错误日志捕获

src/main/java/com/zfxftech/telmarket/service/followAccount/impl/CommunicationRecordStatisticalLogServiceImpl.java

@@ -41,25 +41,29 @@ public class CommunicationRecordStatisticalLogServiceImpl extends ServiceImpl<Co
 
     private void updateAndSave( List<CustomerCommunicationRecordTask> list,String type){
         for (CustomerCommunicationRecordTask customerCommunicationRecordTask : list) {
-            CommunicationRecordStatisticalLog distinct = getBaseMapper().selectDistinct(customerCommunicationRecordTask.getCustomerId().longValue(), customerCommunicationRecordTask.getProductId().longValue(), customerCommunicationRecordTask.getProductType());
-            if (ObjectUtils.isEmpty(distinct)) {
-                CommunicationRecordStatisticalLog communicationRecordStatisticalLog = new CommunicationRecordStatisticalLog();
-                communicationRecordStatisticalLog.setCustomerId(customerCommunicationRecordTask.getCustomerId().longValue());
-                communicationRecordStatisticalLog.setProductType(customerCommunicationRecordTask.getProductType());
-                communicationRecordStatisticalLog.setProductId(customerCommunicationRecordTask.getProductId().longValue());
-                distinct.setDayConut(customerCommunicationRecordTask.getCount());
-                saveOrUpdate(communicationRecordStatisticalLog);
-            }else {
-                if(type.equals("day")){
+            try {
+                CommunicationRecordStatisticalLog distinct = getBaseMapper().selectDistinct(customerCommunicationRecordTask.getCustomerId().longValue(), customerCommunicationRecordTask.getProductId().longValue(), customerCommunicationRecordTask.getProductType());
+                if (ObjectUtils.isEmpty(distinct)) {
+                    CommunicationRecordStatisticalLog communicationRecordStatisticalLog = new CommunicationRecordStatisticalLog();
+                    communicationRecordStatisticalLog.setCustomerId(customerCommunicationRecordTask.getCustomerId().longValue());
+                    communicationRecordStatisticalLog.setProductType(customerCommunicationRecordTask.getProductType());
+                    communicationRecordStatisticalLog.setProductId(customerCommunicationRecordTask.getProductId().longValue());
                     distinct.setDayConut(customerCommunicationRecordTask.getCount());
+                    saveOrUpdate(communicationRecordStatisticalLog);
+                } else {
+                    if (type.equals("day")) {
+                        distinct.setDayConut(customerCommunicationRecordTask.getCount());
+                    }
+                    if (type.equals("week")) {
+                        distinct.setWeekConut(customerCommunicationRecordTask.getCount());
+                    }
+                    if (type.equals("month")) {
+                        distinct.setMonthConut(customerCommunicationRecordTask.getCount());
+                    }
+                    updateById(distinct);
                 }
-                if(type.equals("week")){
-                    distinct.setWeekConut(customerCommunicationRecordTask.getCount());
-                }
-                if(type.equals("month")){
-                    distinct.setMonthConut(customerCommunicationRecordTask.getCount());
-                }
-                updateById(distinct);
+            }catch (Exception e){
+                log.error("更新或添加错误信息:{},类型:{}",e,type);
             }
         }
     }

src/main/java/com/zfxftech/telmarket/task/communication/TimedTaskController.java

@@ -40,7 +40,6 @@ public class TimedTaskController {
     }
     @ApiOperation(value = "周统计沟通记录次数", notes = "周统计沟通记录次数 ", httpMethod = "GET")
     @GetMapping("weekCommunication")
-//    @Scheduled(cron = "0 33 12,17 * * ?")
     @Scheduled(cron = "0 15 12,16 * * ?")
     public CommonResult weekCommunicationCount() {
         communicationRecordStatisticalLogService.saveOrUpdateWeek();