修改用户数据分析

esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/user/service/impl/MetaUserGridOpiningServiceImpl.java

@@ -34,6 +34,8 @@ import com.elink.esua.epdc.dto.user.result.GridOpeningResultDTO;
 import com.elink.esua.epdc.modules.user.dao.MetaUserGridOpiningDao;
 import com.elink.esua.epdc.modules.user.entity.MetaUserGridOpiningEntity;
 import com.elink.esua.epdc.modules.user.service.MetaUserGridOpiningService;
+import com.elink.esua.epdc.modules.user.service.MetaUserPartyRankService;
+import com.elink.esua.epdc.modules.user.service.MetaUserRegisterRankService;
 import com.elink.esua.epdc.modules.user.service.UserAnalysisService;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -55,6 +57,12 @@ public class MetaUserGridOpiningServiceImpl extends BaseServiceImpl<MetaUserGrid
     @Autowired
     private UserAnalysisService userAnalysisService;
 
+    @Autowired
+    private MetaUserPartyRankService metaUserPartyRankService;
+
+    @Autowired
+    private MetaUserRegisterRankService metaUserRegisterRankService;
+
     @Override
     @DataSource(name = DataSourceNames.TWELVE)
     public PageData<MetaUserGridOpiningDTO> page(Map<String, Object> params) {
@@ -137,6 +145,8 @@ public class MetaUserGridOpiningServiceImpl extends BaseServiceImpl<MetaUserGrid
         List<GridOpeningResultDTO> list = userAnalysisService.getToLeadGridOpenings(new HashMap<>());
         List<MetaUserGridOpiningEntity> metaUserGridOpiningEntities = ConvertUtils.sourceToTarget(list, MetaUserGridOpiningEntity.class);
         boolean b = insertBatch(metaUserGridOpiningEntities);
+        metaUserPartyRankService.toLeadPartyRankData();
+        metaUserRegisterRankService.toLeadUserRegisterRandData();
         return b?new Result<>():new Result().error("录入失败");
     }
 }

esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobUserServiceImpl.java

@@ -20,10 +20,10 @@ public class ScheduleJobUserServiceImpl implements ScheduleJobUserService {
     public void createUserAnalysisData() {
         // 网格开通
         userFeignClint.createUserAnalysisData();
-        // 用户注册
+//        // 用户注册
-        userFeignClint.toLeadUserRegisterRandData();
+//        userFeignClint.toLeadUserRegisterRandData();
-
+//
-        // 党员排行绑
+//        // 党员排行绑
-        userFeignClint.toLeadPartyRankData();
+//        userFeignClint.toLeadPartyRankData();
     }
 }