入门客AI创业平台(我带你入门,你带我飞行)
博文笔记

tp 用户登录日志记录

创建时间:2017-05-18 投稿人: 浏览次数:1506
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | PHP@妖孽 [三十年河东三十年河西,莫欺少年穷.!]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2014 http://www.yaonies.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Author: PHP@妖孽 <msj@yaonies.com>
  8. // +----------------------------------------------------------------------
  9. /**
  10.  +------------------------------------------------------------------------------
  11.  * 基于用户的操作记录验证类
  12.  +------------------------------------------------------------------------------
  13.  * @category   ORG
  14.  * @package  ORG
  15.  * @subpackage  Msj
  16.  * @author    PHP@妖孽 <msj@yaonies.com>
  17.  * @version   1.0
  18.  +------------------------------------------------------------------------------
  19.  */
  20. // 配置文件增加设置
  21. //  "OPERATION_ON"=>true,// 开启用户记录日志
  22. //     "OPERATION_MEMBER"=>"learn_member",
  23. //     "OPERATION_TYPE"=>"web",//分别为web,interface也就是网站,和接口
  24. //     "OPERATION_MEMBER_ID"=>"member_id", //如果后台就取session,如果接口就直接取get,post请求的值
  25. /*
  26. -- --------------------------------------------------------
  27. CREATE TABLE IF NOT EXISTS `msj_operation_log` (
  28.   `operation_log` mediumint(8) unsigned NOT NULL AUTO_INCREMENT COMMENT "操作记录主键",
  29.   `operation_uid` mediumint(4) NOT NULL DEFAULT "0" COMMENT "操作人/如果是接口返回-1暂不记录接口请求人",
  30.   `operation_node` char(50) COLLATE utf8_bin NOT NULL DEFAULT "" COMMENT "操作节点",
  31.   `operation_ip` mediumtext COLLATE utf8_bin NOT NULL COMMENT "记录操作IP,省市,等信息",
  32.   `operation_time` int(10) NOT NULL DEFAULT "0" COMMENT "操作时间",
  33.   PRIMARY KEY (`operation_log`),
  34.   KEY `index_uid_node` (`operation_uid`,`operation_node`,`operation_log`)
  35. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT="@author PHP@妖孽 @since 2014-5-4"
  36. */
  37. class Operation {
  38.     
  39.     private $operation_on;//操作记录开关
  40.     public    $error;//错误信息
  41.     
  42.     /**
  43.      * @todo  验证是否开启记录
  44.      */
  45.     public function __construct(){
  46.         $this->operation_on = C("OPERATION_ON");
  47.         if($this->operation_on === false){
  48.             return false;
  49.         }
  50.     }
  51.     
  52.     /**
  53.      *  @todo获取客户端IP地址
  54.      * @param integer $type 返回类型 0 返回IP地址 1 返回IPV4地址数字
  55.      * @return mixed
  56.      */
  57.     private function getClientIp($type=0){
  58.         $type       =  $type ? 1 : 0;
  59.         static $ip  =   NULL;
  60.         if ($ip !== NULL) return $ip[$type];
  61.         if (isset($_SERVER["HTTP_X_FORWARDED_FOR"])) {
  62.             $arr    =   explode(",", $_SERVER["HTTP_X_FORWARDED_FOR"]);
  63.             $pos    =   array_search("unknown",$arr);
  64.             if(false !== $pos) unset($arr[$pos]);
  65.             $ip     =   trim($arr[0]);
  66.         }elseif (isset($_SERVER["HTTP_CLIENT_IP"])) {
  67.             $ip     =   $_SERVER["HTTP_CLIENT_IP"];
  68.         }elseif (isset($_SERVER["REMOTE_ADDR"])) {
  69.             $ip     =   $_SERVER["REMOTE_ADDR"];
  70.         }
  71.         // IP地址合法验证
  72.         $long = sprintf("%u",ip2long($ip));
  73.         $ip   = $long ? array($ip, $long) : array("0.0.0.0", 0);
  74.         return $ip[$type];
  75.     }
  76.     
  77.     /**
  78.      * @todo 检测表是否存在,如果不存在则创建新表
  79.      */
  80.     static public function checkTableIsExist(){
  81.         $db     =   Db::getInstance(C("RBAC_DB_DSN"));
  82.         $table_prefix = C("DB_PREFIX");
  83.         $sql    =   "CREATE TABLE IF NOT EXISTS `{$table_prefix}msj_operation_log` (
  84.           `operation_log` mediumint(8) unsigned NOT NULL AUTO_INCREMENT COMMENT "操作记录主键",
  85.           `operation_uid` mediumint(4) NOT NULL DEFAULT "0" COMMENT "操作人/如果是接口返回-1暂不记录接口请求人",
  86.           `operation_node` char(50) COLLATE utf8_bin NOT NULL DEFAULT "" COMMENT "操作节点",
  87.           `operation_ip` mediumtext COLLATE utf8_bin NOT NULL COMMENT "记录操作IP,省市,等信息",
  88.           `operation_time` int(10) NOT NULL DEFAULT "0" COMMENT "操作时间",
  89.           PRIMARY KEY (`operation_log`),
  90.           KEY `index_uid_node` (`operation_uid`,`operation_node`,`operation_log`)
  91.         ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT="@author PHP@妖孽 @since 2014-5-4"";
  92.         $db->execute($sql);
  93.     }
  94.     
  95.     /**
  96.      * @todo 写入操作日志
  97.      */
  98.     public function writeLog(){
  99.         (defined("NOW_TIME"))?$time = NOW_TIME: $time=time();
  100.                 
  101.         switch (C("OPERATION_TYPE")){
  102.             case "web":
  103.                 $uid = session(C("OPERATION_MEMBER_ID"));
  104.                 $uid = ($uid)?$uid:0;
  105.                 break;
  106.             case "interface"://预留
  107.                 $uid = -1;//接口的操作日志暂时不记录操作人
  108.                 break;
  109.             default:
  110.                 $uid = -2;
  111.                 break;
  112.         }
  113.         
  114.         $db_name =C("DB_NAME") ;
  115.         $table_prefix = C("DB_PREFIX");
  116.         import("@.ORG.Msj.IpLocation");// 导入IpLocation类
  117.         $Ip = new IpLocation(); // 实例化类
  118.         $ip_info = $Ip->getlocation($this->getClientIp()); // 获取某个IP地址所在的位置
  119.         $ip_info["country"] = iconv("gbk", "utf-8", $ip_info["country"]);
  120.         $db     =   Db::getInstance(C("RBAC_DB_DSN"));
  121.         $sql    =    "INSERT INTO `{$db_name}`.`{$table_prefix}msj_operation_log` (`operation_uid`, `operation_node`, `operation_ip`, `operation_time`) VALUES ("".$uid."","".$_SERVER["REQUEST_URI"]."","".serialize($ip_info)."","".$time."");"; 
  122.         if($db->execute($sql) === false ){
  123.             //插入失败写日志
  124.             Log::write("uid:{$uid},"."node:".$_SERVER["REQUEST_URI"].",operation_ip:".serialize($ip_info).",time:".date("Y-m-d H:i:s",$time));
  125.         }
  126.         
  127.     }
  128.     
  129.     /**
  130.      * @todo 查询操作日志
  131.      * @param array $map 目前只支持用户id的查询.
  132.      */
  133.     public function logList($map=array()){
  134.         $db     =   Db::getInstance(C("RBAC_DB_DSN"));
  135.         $member_table_name = C("OPERATION_MEMBER");
  136.         $operation_table_name =C("DB_PREFIX")."msj_operation_log";
  137.         $member_id = implode(",",$map);
  138.         $sql = "(SELECT 
  139.                   msj_operation_log.operation_log AS operation_log,
  140.                   msj_operation_log.operation_uid AS operation_uid,
  141.                   msj_operation_log.operation_node AS operation_node,
  142.                   msj_operation_log.operation_ip AS operation_ip,
  143.                   msj_operation_log.operation_time AS operation_time,
  144.                   Member.member_name AS member_name 
  145.                 FROM
  146.                   {$operation_table_name} msj_operation_log 
  147.                   JOIN {$member_table_name} Member 
  148.                     ON msj_operation_log.operation_uid = Member.member_id 
  149.                 WHERE (`member_id` IN("{$member_id}")))";
  150.         $log_list = $db->query($sql);
  151.         $Ip = new IpLocation(); // 实例化类
  152.         $ip_info = $Ip->getlocation($this->getClientIp()); // 获取某个IP地址所在的位置
  153.         if(!empty($log_list)){
  154.             foreach($log_list as $key=>$val){
  155.                 $log_list[$key]["operation_time"] = date("Y-m-d H:i:s",$val["operation_time"]);
  156.                 $info = unserialize($val["operation_ip"]);
  157.                 $log_list[$key]["operation_ip"] = "地区:".$info["area"].",城市:".$info["country"].",IP:".$info["ip"];
  158.             }
  159.             return $log_list;
  160.         }else{
  161.             return false;
  162.         }
  163.     }
  164.     
  165.     public function __destruct(){
  166.         $this->operation_on=false;
  167.         $this->error ="";
  168.     }
  169.     
  170. }
  171. //查list;
  172. import("@.ORG.Msj.Operation");
  173. $operation_obj = new Operation();
  174. $log_list  = $operation_obj->logList(array("member_id"=>2086));
  175. //记录日志
  176. $operation_obj->writeLog();
声明:该文观点仅代表作者本人,入门客AI创业平台信息发布平台仅提供信息存储空间服务,如有疑问请联系rumenke@qq.com。