admin
2020-04-21 0b57cfd62e842b309d03467b96a331c673ecad7c
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserActiveLogServiceImpl.java
@@ -8,13 +8,24 @@
import com.yeshi.fanli.dao.mybatis.user.UserActiveLogMapper;
import com.yeshi.fanli.entity.bus.user.UserActiveLog;
import com.yeshi.fanli.entity.bus.user.UserInfoRegister;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.user.UserActiveLogService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserInfoRegisterService;
@Service
public class UserActiveLogServiceImpl implements UserActiveLogService {
   @Resource
   private UserActiveLogMapper userActiveLogMapper;
   @Resource
   private UserInfoExtraService userInfoExtraService;
   @Resource
   private UserInfoRegisterService userInfoRegisterService;
   @Override
   public void addUserActiveLog(UserActiveLog userActiveLog) {
@@ -22,12 +33,42 @@
         return;
      if (userActiveLog.getUid() == null || userActiveLog.getUid() == 0)
         return;
      UserActiveLog latestLog = getUserLatestActiveInfo(userActiveLog.getUid());
      if (latestLog == null) {
         try { // 保存注册信息
            UserInfoRegister register = new UserInfoRegister();
            register.setId(userActiveLog.getUid());
            register.setIp(userActiveLog.getIp());
            register.setChannel(userActiveLog.getChannel());
            register.setDevice(userActiveLog.getDevice());
            userInfoRegisterService.addRegisterInfo(register);
         } catch (Exception e) {
            LogHelper.errorDetailInfo(e);
         }
      }
      // 间隔5分钟以上再记录
      if (latestLog == null || System.currentTimeMillis() - latestLog.getCreateTime().getTime() > 1000 * 60 * 5L) {
         userActiveLog.setCreateTime(new Date());
         userActiveLog.setUpdateTime(new Date());
         userActiveLogMapper.insertSelective(userActiveLog);
         // 更新最新活跃时间
         userInfoExtraService.updateActiveTime(userActiveLog.getUid() , new Date());
      } else if (latestLog != null) {
         // 如果设备 ,版本,渠道有变化则需要更改
         String oldIdentify = latestLog.getDevice() + "#" + latestLog.getVersionCode() + "#"
               + latestLog.getChannel();
         String newIdentify = userActiveLog.getDevice() + "#" + userActiveLog.getVersionCode() + "#"
               + userActiveLog.getChannel();
         if (!oldIdentify.equalsIgnoreCase(newIdentify)) {// 设备信息变化要记录信息
            userActiveLog.setCreateTime(new Date());
            userActiveLog.setUpdateTime(new Date());
            userActiveLogMapper.insertSelective(userActiveLog);
            // 更新最新活跃时间
            userInfoExtraService.updateActiveTime(userActiveLog.getUid() , new Date());
         }
      }
   }
@@ -36,8 +77,19 @@
      return userActiveLogMapper.selectLatestByUid(uid);
   }
   @Override
   public UserActiveLog getFirstActiveInfo(Long uid) {
      return userActiveLogMapper.selectFirstActiveInfo(uid);
   }
   
   @Override
   public long count90DaysLaterActiveNum(String preDay){
      Long count = userActiveLogMapper.countActiveNumByDate(preDay);
      if (count == null) {
         count = 0L;
      }
      return count;
   }
   
}