From 764d883b5ea3bdc06abbec548b6df0511e567978 Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Tue, 03 Sep 2024 09:46:05 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/binlog' into binlog
---
src/main/java/org/springblade/modules/task/service/impl/SelfExaminationTaskHandler.java | 84 ++++++++++++++++++++++++++++++++++++++++++
1 files changed, 84 insertions(+), 0 deletions(-)
diff --git a/src/main/java/org/springblade/modules/task/service/impl/SelfExaminationTaskHandler.java b/src/main/java/org/springblade/modules/task/service/impl/SelfExaminationTaskHandler.java
new file mode 100644
index 0000000..457278f
--- /dev/null
+++ b/src/main/java/org/springblade/modules/task/service/impl/SelfExaminationTaskHandler.java
@@ -0,0 +1,84 @@
+package org.springblade.modules.task.service.impl;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springblade.common.utils.SpringUtils;
+import org.springblade.core.mp.support.Condition;
+import org.springblade.core.mp.support.Query;
+import org.springblade.modules.threeColorTask.entity.CustomTaskEntity;
+import org.springblade.modules.place.service.IPlaceService;
+import org.springblade.modules.place.vo.PlaceVO;
+import org.springblade.modules.task.entity.TaskEntity;
+import org.springblade.modules.task.entity.TaskPlaceSelfCheckEntity;
+import org.springblade.modules.task.service.ITaskPlaceSelfCheckService;
+import org.springblade.modules.task.service.ITaskService;
+import org.springblade.modules.task.service.TaskHandle;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+/**
+ * 自查任务ServiceImpl
+ */
+@Component("SelfExaminationTaskHandler")
+public class SelfExaminationTaskHandler implements TaskHandle {
+
+ private static final Logger logger = LoggerFactory.getLogger(SelfExaminationTaskHandler.class);
+ @Autowired
+ private IPlaceService placeService;
+
+ @Autowired
+ private ITaskPlaceSelfCheckService taskPlaceSelfCheckService;
+
+ @Override
+ public void taskHandle(CustomTaskEntity customTask) {
+ try {
+ Query query = new Query();
+ IPage<PlaceVO> page = Condition.getPage(query);
+ PlaceVO placeVO = new PlaceVO();
+ placeVO.setPlaceLabel(customTask.getPlaceLabel());
+ placeVO.setPlaceSmallLabel(customTask.getPlaceSmallLabel());
+ placeVO.setNineType(customTask.getNineType());
+ placeVO.setColor(customTask.getLabelColor());
+ placeVO.setTaskRange(customTask.getTaskRange());
+ IPage<PlaceVO> placePage = placeService.getPlacePage(page, placeVO);
+ ITaskService iTaskService = SpringUtils.getBean(ITaskService.class);
+ // 计算总页数
+ long pages = placePage.getPages();
+ System.out.println("总页数：" + pages);
+ for (int i = 1; i <= pages; i++) {
+ page = Condition.getPage(query);
+ page.setCurrent(i);
+ placePage = placeService.getPlacePage(page, placeVO);
+ placePage.getRecords().forEach(place -> {
+ TaskEntity taskEntity = new TaskEntity();
+ taskEntity.setType(1);
+ taskEntity.setName(customTask.getName());
+ taskEntity.setCreateTime(new Date());
+ taskEntity.setHouseCode(place.getHouseCode());
+ taskEntity.setReportType(7);
+ taskEntity.setStatus(4);
+ taskEntity.setFrequency(2);
+ // taskEntitiesList.add(taskEntity);
+ iTaskService.save(taskEntity);
+
+ TaskPlaceSelfCheckEntity taskPlaceSelfCheck = new TaskPlaceSelfCheckEntity();
+ taskPlaceSelfCheck.setTaskId(taskEntity.getId());
+ taskPlaceSelfCheck.setHouseCode(place.getHouseCode());
+ taskPlaceSelfCheck.setPlaceName(place.getPlaceName());
+ taskPlaceSelfCheck.setStatus(4);
+ taskPlaceSelfCheck.setType("1");
+ taskPlaceSelfCheckService.save(taskPlaceSelfCheck);
+ // taskPlaceSelfCheckList.add(taskPlaceSelfCheck);
+ });
+ }
+ } catch (Exception e) {
+ System.out.println("自查任务异常" + e);
+ }
+ // iTaskService.saveBatch(taskEntitiesList);
+ // boolean save = taskPlaceSelfCheckService.saveBatch(taskPlaceSelfCheckList);
+
+ }
+}
--
Gitblit v1.9.3