定时任务

src/main/java/com/huiju/estateagents/entity/TdWxDict.java

 package com.huiju.estateagents.entity;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.huiju.estateagents.statistic.entity.TsPersonFromStatistic;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
     /**
      * 场景值id
      */
+    @TableId(value = "scene_id", type = IdType.AUTO)
     private String sceneId;
 
     /**

src/main/java/com/huiju/estateagents/job/CustomerStatisticTimeJob.java

      *
      * 开启定时任务，每天23:50执行
      */
-    @Scheduled(cron = "59 50 23 * * ?")
+//    @Scheduled(cron = "59 50 23 * * ?")
 //    @Scheduled(cron = "* 0/1 * * * ?")
     private void configureTasks() {
         LocalDateTime nowDate = LocalDateTime.now();

src/main/java/com/huiju/estateagents/job/JudglActivityTimeJob.java

     @Autowired
     private ITaDrainageService iTaDrainageService;
 
+    @Autowired
+    public ITaPersonFromRecordService iTaPersonFromRecordService;
+    
     /**
      * 开启定时任务，每天12：30执行
      */
         //更新H5活动状态为已结束
         iTaDrainageService.updateDrainageToEnd();
 
+        //统计新增来源用户
+        iTaPersonFromRecordService.personFromStatistic();
     }
 
 }

src/main/java/com/huiju/estateagents/service/impl/TaPersonFromRecordServiceImpl.java

 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.entity.TaPersonFromRecord;
 import com.huiju.estateagents.entity.TaPersonVisitRecord;
+import com.huiju.estateagents.entity.TdWxDict;
 import com.huiju.estateagents.mapper.TaPersonFromRecordMapper;
+import com.huiju.estateagents.mapper.TdWxDictMapper;
 import com.huiju.estateagents.service.ITaPersonFromRecordService;
 import com.huiju.estateagents.statistic.entity.TsPersonFromStatistic;
 import com.huiju.estateagents.statistic.mapper.TsPersonFromStatisticMapper;
     @Autowired
     private TsPersonFromStatisticMapper tsPersonFromStatisticMapper;
 
+    @Autowired
+    private TdWxDictMapper tdWxDictMapper;
+
     /**
      * 通過買點表清洗數據
      * @param taPersonVisitRecord
         taPersonFromRecord.setEvent(taPersonVisitRecord.getEvent());
         taPersonFromRecord.setEventType(taPersonVisitRecord.getEventType());
         taPersonFromRecord.setSceneId(taPersonVisitRecord.getSceneId());
+        TdWxDict tdWxDict = tdWxDictMapper.selectById(taPersonVisitRecord.getSceneId());
+        taPersonFromRecord.setSceneType(null == tdWxDict ? "" : tdWxDict.getSceneType());
         taPersonFromRecord.setSharePersonId(taPersonVisitRecord.getSharePersonId());
         taPersonFromRecord.setTargetId(taPersonVisitRecord.getTargetId());
         QueryWrapper<TaPersonFromRecord> queryWrapper = new QueryWrapper<>();