蓬溪问题处理

attendance-performance-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/AttendSummaryService.java

@@ -41,6 +41,7 @@ public class AttendSummaryService implements IApplicationStartedService {
                     try {
                         AttendanceSummaryQuery query = cacheService.brpop(KEY_ATTENDANCE_STAT_CACHE, 60,AttendanceSummaryQuery.class);
                         if(!ObjectUtils.isEmpty(query)){
+                            Thread.sleep(2000);
                             if (StringUtils.isNotEmpty(query.getSummaryTimeStart()) && StringUtils.isNotEmpty(query.getSummaryTimeEnd())) {
                                 List<String> dateList = getDatesBetween(query.getSummaryTimeStart(), query.getSummaryTimeEnd());
                                 for (String day : dateList) {

attendance-performance-manager/src/main/java/com/mortals/xhx/module/attendance/service/impl/AttendanceStatServiceImpl.java

@@ -338,12 +338,10 @@ public class AttendanceStatServiceImpl extends AbstractCRUDServiceImpl<Attendanc
                     if (staffStatTemp != null) {
                         staffStat.setId(staffStatTemp.getId());
                         staffStat.setUpdateTime(new Date());
-                        log.info(JSON.toJSONString(staffStat));
                         updateStaffStat.add(staffStat);
                     } else {
                         staffStat.setCreateTime(DateUtils.StrToDate(query.getSummaryTime()));
                         staffStat.setCreateUserId(1l);
-                        log.info(JSON.toJSONString(staffStat));
                         addStaffStat.add(staffStat);
                     }
                 }
@@ -354,12 +352,10 @@ public class AttendanceStatServiceImpl extends AbstractCRUDServiceImpl<Attendanc
                     this.dao.updateBatch(updateList);
                 }
                 if(addStaffStat.size()>0){
-                    int u = attendanceStaffStatService.save(addStaffStat);
-                    log.info("attendanceStaffStatService新增数据："+u);
+                    attendanceStaffStatService.save(addStaffStat);
                 }
                 if(updateStaffStat.size()>0){
-                    int u = attendanceStaffStatService.update(updateStaffStat);
-                    log.info("attendanceStaffStatService更新数据："+u);
+                    attendanceStaffStatService.update(updateStaffStat);
                 }
             }
             log.info("完成汇总当前日期假期余额.....");
@@ -450,13 +446,13 @@ public class AttendanceStatServiceImpl extends AbstractCRUDServiceImpl<Attendanc
                         staffStat.setId(staffStatTemp.getId());
                         staffStat.setUpdateTime(new Date());
                         //attendanceStaffStatService.update(staffStat);
-                        log.info(JSON.toJSONString(staffStat));
+                        //log.info(JSON.toJSONString(staffStat));
                         updateStaffStat.add(staffStat);
                     } else {
                         staffStat.setCreateTime(DateUtils.StrToDate(query.getSummaryTime()));
                         staffStat.setCreateUserId(1l);
                         //attendanceStaffStatService.save(staffStat);
-                        log.info(JSON.toJSONString(staffStat));
+                        //log.info(JSON.toJSONString(staffStat));
                         addStaffStat.add(staffStat);
                     }
                 }
@@ -464,12 +460,12 @@ public class AttendanceStatServiceImpl extends AbstractCRUDServiceImpl<Attendanc
                     this.dao.updateBatch(updateList);
                 }
                 if(addStaffStat.size()>0){
-                    int u = attendanceStaffStatService.save(addStaffStat);
-                    log.info("attendanceStaffStatService新增数据："+u);
+                    ttendanceStaffStatService.save(addStaffStat);
+                    //log.info("attendanceStaffStatService新增数据："+u);
                 }
                 if(updateStaffStat.size()>0){
-                    int u = attendanceStaffStatService.update(updateStaffStat);
-                    log.info("attendanceStaffStatService更新数据："+u);
+                    ttendanceStaffStatService.update(updateStaffStat);
+                    //log.info("attendanceStaffStatService更新数据："+u);
                 }
             }
             log.info("完成汇总当前日期异常考勤.....");