src/AppBundle/Component/Track/UserOnlineTrack.php line 100

Open in your IDE?
  1. <?php
  3. namespace AppBundle\Component\Track;
  5. use AppBundle\Component\DeviceDetector\DeviceDetectorAdapter;
  6. use Codeages\Biz\Framework\Context\Biz;
  7. use Symfony\Component\DependencyInjection\ContainerInterface;
  9. class UserOnlineTrack
  10. {
  11.     /**
  12.      * @var \Symfony\Component\DependencyInjection\ContainerInterface
  13.      */
  14.     private $container;
  16.     /**
  17.      * @var \Codeages\Biz\Framework\Context\Biz
  18.      */
  19.     private $biz;
  21.     /**
  22.      * @var \AppBundle\Component\DeviceDetector\DeviceDetectorAdapter
  23.      */
  24.     private $deviceDetector;
  26.     public function __construct(ContainerInterface $container, Biz $biz)
  27.     {
  28.         $this->container = $container;
  29.         $this->biz = $biz;
  30.         $this->deviceDetector = new DeviceDetectorAdapter($this->getUserAgent());
  31.     }
  33.     /**
  34.      * @todo api 和 web 的sessionId 应该统一
  35.      *
  36.      * @param $sessionId
  37.      */
  38.     public function track($sessionId)
  39.     {
  40.         // 过滤掉爬虫
  41.         if ($this->deviceDetector->isBot()) {
  42.             return;
  43.         }
  45.         $user = $this->biz['user'];
  46.         if (empty($user)) {
  47.             return;
  48.         }
  49.         if (!$user->isLogin()) {
  50.             return;
  51.         }
  53.         $online = [
  54.             'sess_id' => $sessionId,
  55.             'user_id' => $user['id'],
  56.             'ip' => $this->getClientIp(),
  57.             'user_agent' => $this->getUserAgent(),
  58.             'source' => $this->isFromApp() ? 'App' : 'Web',
  59.         ];
  61.         $this->getUserActiveService()->saveOnline($online);
  62.         $this->logUserLogin();
  63.     }
  65.     protected function logUserLogin()
  66.     {
  67.         $user = $this->biz['user'];
  68.         if (empty($user)) {
  69.             return;
  70.         }
  71.         $conditions = [
  72.             'userId' => $user['id'],
  73.             'startDateTime_GE' => strtotime(date('Y-m-d')),
  74.             'startDateTime_LE' => strtotime(date('Y-m-d').' 23:59:59'),
  75.             'actions' => ['login_success', 'user_login'],
  76.         ];
  77.         $hasLoginLog = $this->getLogService()->countUserLoginNum($conditions);
  78.         if (!$hasLoginLog) {
  79.             $this->getUserService()->markLoginInfo();
  80.         }
  81.     }
  83.     private function isFromApp()
  84.     {
  85.         $pathInfo = $this->getRequest()->getPathInfo();
  87.         return 0 === strpos($pathInfo, '/api');
  88.     }
  90.     private function getRequest()
  91.     {
  92.         return $this->container->get('request_stack')->getMainRequest();
  93.     }
  95.     private function getClientIp()
  96.     {
  97.         return $this->getRequest()->getClientIp();
  98.     }
  100.     private function getUserAgent()
  101.     {
  102.         return $this->getRequest()->headers->get('User-Agent');
  103.     }
  105.     /**
  106.      * @return \Biz\User\Service\UserActiveService
  107.      */
  108.     private function getUserActiveService()
  109.     {
  110.         return $this->biz->service('User:UserActiveService');
  111.     }
  113.     private function getUserService()
  114.     {
  115.         return $this->biz->service('User:UserService');
  116.     }
  118.     private function getLogService()
  119.     {
  120.         return $this->biz->service('System:LogService');
  121.     }
  122. }