基于ThinkPHP用户行为记录

/**
* @todo获取客户端IP地址
* @param integer $type 返回类型 0 返回IP地址 1 返回IPV4地址数字
* @return mixed
*/
private function getClientIp($type=0){
$type = $type ? 1 : 0;
static $ip = NULL;
if ($ip !== NULL) return $ip[$type];
if (isset($_SERVER[&＃039;HTTP_X_FORWARDED_FOR&＃039;])) {
$arr = explode(&＃039;,&＃039;, $_SERVER[&＃039;HTTP_X_FORWARDED_FOR&＃039;]);
$pos = array_search(&＃039;unknown&＃039;,$arr);
if(false !== $pos) unset($arr[$pos]);
$ip = trim($arr[0]);
}elseif (isset($_SERVER[&＃039;HTTP_CLIENT_IP&＃039;])) {
$ip = $_SERVER[&＃039;HTTP_CLIENT_IP&＃039;];
}elseif (isset($_SERVER[&＃039;REMOTE_ADDR&＃039;])) {
$ip = $_SERVER[&＃039;REMOTE_ADDR&＃039;];
}
// IP地址合法验证
$lOng= sprintf("%u",ip2long($ip));
$ip = $long ? array($ip, $long) : array(&＃039;0.0.0.0&＃039;, 0);
return $ip[$type];
}

/**
* @todo 检测表是否存在,如果不存在则创建新表
*/
static public function checkTableIsExist(){
$db = Db::getInstance(C(&＃039;RBAC_DB_DSN&＃039;));
$table_prefix = C(&＃039;DB_PREFIX&＃039;);
$sql = "CREATE TABLE IF NOT EXISTS `{$table_prefix}msj_operation_log` (
`operation_log` mediumint(8) unsigned NOT NULL AUTO_INCREMENT COMMENT &＃039;操作记录主键&＃039;,
`operation_uid` mediumint(4) NOT NULL DEFAULT &＃039;0&＃039; COMMENT &＃039;操作人/如果是接口返回-1暂不记录接口请求人&＃039;,
`operation_node` char(50) COLLATE utf8_bin NOT NULL DEFAULT &＃039;&＃039; COMMENT &＃039;操作节点&＃039;,
`operation_ip` mediumtext COLLATE utf8_bin NOT NULL COMMENT &＃039;记录操作IP,省市,等信息&＃039;,
`operation_time` int(10) NOT NULL DEFAULT &＃039;0&＃039; COMMENT &＃039;操作时间&＃039;,
PRIMARY KEY (`operation_log`),
KEY `index_uid_node` (`operation_uid`,`operation_node`,`operation_log`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT=&＃039;@author PHP@妖孽\r\n@since 2014-5-4&＃039;";
$db->execute($sql);
}

/**
* @todo 写入操作日志
*/
public function writeLog(){
(defined(&＃039;NOW_TIME&＃039;))?$time = NOW_TIME: $time=time();

switch (C(&＃039;OPERATION_TYPE&＃039;)){
case &＃039;web&＃039;:
$uid = session(C(&＃039;OPERATION_MEMBER_ID&＃039;));
$uid = ($uid)?$uid:0;
break;
case &＃039;interface&＃039;://预留
$uid = -1;//接口的操作日志暂时不记录操作人
break;
default:
$uid = -2;
break;
}

$db_name =C(&＃039;DB_NAME&＃039;) ;
$table_prefix = C(&＃039;DB_PREFIX&＃039;);
import(&＃039;@.ORG.Msj.IpLocation&＃039;);// 导入IpLocation类
$Ip = new IpLocation(); // 实例化类
$ip_info = $Ip->getlocation($this->getClientIp()); // 获取某个IP地址所在的位置
$ip_info[&＃039;country&＃039;] = iconv(&＃039;gbk&＃039;, &＃039;utf-8&＃039;, $ip_info[&＃039;country&＃039;]);
$db = Db::getInstance(C(&＃039;RBAC_DB_DSN&＃039;));
$sql = "INSERT INTO `{$db_name}`.`{$table_prefix}msj_operation_log` (`operation_uid`, `operation_node`, `operation_ip`, `operation_time`) VALUES (&＃039;".$uid."&＃039;,&＃039;".$_SERVER[&＃039;REQUEST_URI&＃039;]."&＃039;,&＃039;".serialize($ip_info)."&＃039;,&＃039;".$time."&＃039;);";
if($db->execute($sql) === false ){
//插入失败写日志
Log::write("uid:{$uid},".&＃039;node:&＃039;.$_SERVER[&＃039;REQUEST_URI&＃039;].&＃039;,operation_ip:&＃039;.serialize($ip_info).&＃039;,time:&＃039;.date(&＃039;Y-m-d H:i:s&＃039;,$time));
}

}

/**
* @todo 查询操作日志
* @param array $map 目前只支持用户id的查询.
*/
public function logList($map=array()){
$db = Db::getInstance(C(&＃039;RBAC_DB_DSN&＃039;));
$member_table_name = C(&＃039;OPERATION_MEMBER&＃039;);
$operation_table_name =C(&＃039;DB_PREFIX&＃039;).&＃039;msj_operation_log&＃039;;
$member_id = implode(&＃039;,&＃039;,$map);
$sql = "(SELECT
msj_operation_log.operation_log AS operation_log,
msj_operation_log.operation_uid AS operation_uid,
msj_operation_log.operation_node AS operation_node,
msj_operation_log.operation_ip AS operation_ip,
msj_operation_log.operation_time AS operation_time,
Member.member_name AS member_name
FROM
{$operation_table_name} msj_operation_log
JOIN {$member_table_name} Member
ON msj_operation_log.operation_uid = Member.member_id
WHERE (`member_id` IN(&＃039;{$member_id}&＃039;)))";
$log_list = $db->query($sql);
$Ip = new IpLocation(); // 实例化类
$ip_info = $Ip->getlocation($this->getClientIp()); // 获取某个IP地址所在的位置
if(!empty($log_list)){
foreach($log_list as $key=>$val){
$log_list[$key][&＃039;operation_time&＃039;] = date(&＃039;Y-m-d H:i:s&＃039;,$val[&＃039;operation_time&＃039;]);
$info = unserialize($val[&＃039;operation_ip&＃039;]);
$log_list[$key][&＃039;operation_ip&＃039;] = "地区:".$info[&＃039;area&＃039;].&＃039;,城市:&＃039;.$info[&＃039;country&＃039;].&＃039;,IP:&＃039;.$info[&＃039;ip&＃039;];
}
return $log_list;
}else{
return false;
}
}

public function __destruct(){
$this->operation_on=false;
$this->error =&＃039;&＃039;;
}

}

//查list;
import(&＃039;@.ORG.Msj.Operation&＃039;);
$operation_obj = new Operation();
$log_list = $operation_obj->logList(array(&＃039;member_id&＃039;=>2086));

//记录日志