|
@@ -409,6 +409,50 @@ public class BizArchiveInputServiceImpl extends ServiceImpl<BizArchiveInputMappe
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
|
+ // 更新循环任务
|
|
|
+ @Override
|
|
|
+ public boolean updateTasks(BizWorkOrder workOrder) {
|
|
|
+ if (workOrder.getTaskTypeId() == 1L) {
|
|
|
+ return updateReportTask(workOrder);
|
|
|
+ } else if (workOrder.getTaskTypeId() == 2L) {
|
|
|
+ return updateSocialSecurity(workOrder);
|
|
|
+ } else if (workOrder.getTaskTypeId() == 3L) {
|
|
|
+ return updateHousingFund(workOrder);
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ private boolean updateHousingFund(BizWorkOrder workOrder) {
|
|
|
+ List<Map<String, Object>> maps = Arrays.stream(housingFundTaskTableNames).map(v -> {
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ map.put("tableName", v);
|
|
|
+ map.put("workOrderId", workOrder.getId());
|
|
|
+ return map;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ workOrderService.updateTasks(maps);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ private boolean updateSocialSecurity(BizWorkOrder workOrder) {
|
|
|
+ List<Map<String, Object>> maps = Arrays.stream(socialSecurityTaskTableNames).map(v -> {
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ map.put("tableName", v);
|
|
|
+ map.put("workOrderId", workOrder.getId());
|
|
|
+ return map;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ workOrderService.updateTasks(maps);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ private boolean updateReportTask(BizWorkOrder workOrder) {
|
|
|
+ List<Map<String, Object>> maps = Arrays.stream(reportTaskTableNames).map(v -> {
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ map.put("tableName", v);
|
|
|
+ map.put("workOrderId", workOrder.getId());
|
|
|
+ return map;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ workOrderService.updateTasks(maps);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
|
|
|
private boolean stopHousingFund(BizWorkOrder workOrder) {
|
|
|
List<Map<String, Object>> maps = Arrays.stream(housingFundTaskTableNames).map(v -> {
|