1.修改更新氚云数据方法

src/main/java/com/galaxis/manatee/service/LogUpdateService.java

@@ -48,24 +48,7 @@ public class LogUpdateService {
      */
     public void updateAllChuanyunSelfWorkHour() {
         long startTime = Instant.now().getEpochSecond();
-        var pageSize = 200;
-        var page = 0;
-        while (true) {
-            try {
-                var pageable = PageRequest.of(page, pageSize);
-                var updateList = chuanyunSelfWorkHourDao.findAll(pageable);
-                if (page <= updateList.getTotalPages()) {
-                    page += 1;
-                    this.updateChuanyunSelfWorkHourList(updateList.toList());
-                } else {
-                    break;
-                }
-            } catch (Exception e) {
-                log.error(e.getMessage(), e);
-                log.error("更新每日工时异常");
-            }
-
-        }
+        chuanyunUserCompanyDao.findAll().forEach(chuanyunUserCompanyDO -> this.updateChuanyunSelfWorkHourListByUserId(chuanyunUserCompanyDO.getUserId()));
         log.info("更新所有每日工时花费" + (Instant.now().getEpochSecond() - startTime) + "秒");
     }
 
@@ -74,23 +57,7 @@ public class LogUpdateService {
      */
     public void updateAllChuanyunWeekMemberHour() {
         long startTime = Instant.now().getEpochSecond();
-        var pageSize = 20;
-        var page = 0;
-        while (true) {
-            try {
-                var pageable = PageRequest.of(page, pageSize);
-                var updateList = chuanyunWeekMemberHourDao.findAll(pageable);
-                if (page <= updateList.getTotalPages()) {
-                    page += 1;
-                    this.updateChuanyunWeekMemberHourList(updateList.toList());
-                } else {
-                    break;
-                }
-            } catch (Exception e) {
-                log.error(e.getMessage(), e);
-                log.error("更新周工时异常");
-            }
-        }
+        chuanyunUserCompanyDao.findAll().forEach(chuanyunUserCompanyDO -> this.updateChuanyunWeekMemberHourListByUserId(chuanyunUserCompanyDO.getUserId()));
         log.info("更新所有每周工时花费" + (Instant.now().getEpochSecond() - startTime) + "秒");
     }
 
@@ -99,18 +66,7 @@ public class LogUpdateService {
      */
     public void updateAllChuanyunSelfCost() {
         long startTime = Instant.now().getEpochSecond();
-        var pageSize = 20;
-        var page = 0;
-        while (true) {
-            var pageable = PageRequest.of(page, pageSize);
-            var updateList = chuanyunSelfCostDao.findAll(pageable);
-            if (page <= updateList.getTotalPages()) {
-                page += 1;
-                this.updateChuanyunSelfCostList(updateList.toList());
-            } else {
-                break;
-            }
-        }
+        chuanyunUserCompanyDao.findAll().forEach(chuanyunUserCompanyDO -> this.updateChuanyunSelfCostListByUserId(chuanyunUserCompanyDO.getUserId()));
         log.info("更新所有每月工时花费" + (Instant.now().getEpochSecond() - startTime) + "秒");
     }