Kaynağa Gözat

定时任务调整

lvjs 1 ay önce
ebeveyn
işleme
04d6084ec9

+ 46 - 45
src/main/java/com/malk/eastar/schedule/ScheduleTask9.java

@@ -112,6 +112,7 @@ public class ScheduleTask9 {
                             customerAiTableId = ltcCustomerRecord.get("aiTableId").toString();
                             syncLog.put("aiTableID",customerAiTableId);
                             syncLog.put("newOrOld","老客户");
+                            log.info("数据同步日志:"+JSONObject.toJSONString(syncLog));
                             yidaService.addSyncLog(syncLog);
                             count++;
                         }
@@ -386,55 +387,55 @@ public class ScheduleTask9 {
             }
         }
 
-        if(privateCustomerNumMap.isEmpty()){
-            log.info("业务员私海客户数量获取不正确");
-            return;
-        }
+//        if(privateCustomerNumMap.isEmpty()){
+//            log.info("业务员私海客户数量获取不正确");
+//            return;
+//        }
 
         /*
             更新各业务员私海客户数量
          */
-        for (String userIdKey : userIdList){
-            if(privateCustomerNumMap.containsKey(userIdKey)){
-                numOfPrivateCustomer = privateCustomerNumMap.get(userIdKey);
-            }else{
-                //私海客户归0
-                numOfPrivateCustomer = 0;
-            }
-            try {
-                formInstId = userIdFormInstIdMap.get(userIdKey);
-                log.info("更新各业务员私海客户数量:" + formInstId + " " + numOfPrivateCustomer);
-                yidaService.updateLtcBusinessUserPrivateCustomerNum(formInstId, numOfPrivateCustomer);
-            } catch (Exception e) {
-                log.error("更新各业务员私海客户数量异常",e);
-            }
-            if(privateNewCustomerNumMap.containsKey(userIdKey)){
-                numOfPrivateNewCustomer = privateNewCustomerNumMap.get(userIdKey);
-            }else{
-                //新客户归0
-                numOfPrivateNewCustomer = 0;
-            }
-            try {
-                formInstId = userIdFormInstIdMap.get(userIdKey);
-                log.info("更新各业务员新客户数量:" + formInstId + " " + numOfPrivateNewCustomer);
-                yidaService.updateLtcBusinessUserPrivateNewCustomerNum(formInstId, numOfPrivateNewCustomer);
-            } catch (Exception e) {
-                log.error("更新各业务员新客户数量异常",e);
-            }
-            if(privateOldCustomerNumMap.containsKey(userIdKey)){
-                numOfPrivateOldCustomer = privateOldCustomerNumMap.get(userIdKey);
-            }else{
-                //老客户归0
-                numOfPrivateOldCustomer = 0;
-            }
-            try {
-                formInstId = userIdFormInstIdMap.get(userIdKey);
-                log.info("更新各业务员老客户数量:" + formInstId + " " + numOfPrivateOldCustomer);
-                yidaService.updateLtcBusinessUserPrivateOldCustomerNum(formInstId, numOfPrivateOldCustomer);
-            } catch (Exception e) {
-                log.error("更新各业务员老客户数量异常",e);
-            }
-        }
+//        for (String userIdKey : userIdList){
+//            if(privateCustomerNumMap.containsKey(userIdKey)){
+//                numOfPrivateCustomer = privateCustomerNumMap.get(userIdKey);
+//            }else{
+//                //私海客户归0
+//                numOfPrivateCustomer = 0;
+//            }
+//            try {
+//                formInstId = userIdFormInstIdMap.get(userIdKey);
+//                log.info("更新各业务员私海客户数量:" + formInstId + " " + numOfPrivateCustomer);
+//                yidaService.updateLtcBusinessUserPrivateCustomerNum(formInstId, numOfPrivateCustomer);
+//            } catch (Exception e) {
+//                log.error("更新各业务员私海客户数量异常",e);
+//            }
+//            if(privateNewCustomerNumMap.containsKey(userIdKey)){
+//                numOfPrivateNewCustomer = privateNewCustomerNumMap.get(userIdKey);
+//            }else{
+//                //新客户归0
+//                numOfPrivateNewCustomer = 0;
+//            }
+//            try {
+//                formInstId = userIdFormInstIdMap.get(userIdKey);
+//                log.info("更新各业务员新客户数量:" + formInstId + " " + numOfPrivateNewCustomer);
+//                yidaService.updateLtcBusinessUserPrivateNewCustomerNum(formInstId, numOfPrivateNewCustomer);
+//            } catch (Exception e) {
+//                log.error("更新各业务员新客户数量异常",e);
+//            }
+//            if(privateOldCustomerNumMap.containsKey(userIdKey)){
+//                numOfPrivateOldCustomer = privateOldCustomerNumMap.get(userIdKey);
+//            }else{
+//                //老客户归0
+//                numOfPrivateOldCustomer = 0;
+//            }
+//            try {
+//                formInstId = userIdFormInstIdMap.get(userIdKey);
+//                log.info("更新各业务员老客户数量:" + formInstId + " " + numOfPrivateOldCustomer);
+//                yidaService.updateLtcBusinessUserPrivateOldCustomerNum(formInstId, numOfPrivateOldCustomer);
+//            } catch (Exception e) {
+//                log.error("更新各业务员老客户数量异常",e);
+//            }
+//        }