From a60f6c73996b4a8d94995753093e2d1b8faac302 Mon Sep 17 00:00:00 2001
From: yxm <zhp1521624>
Date: Mon, 08 Jul 2024 14:05:27 +0800
Subject: [PATCH] 项目管理每月初重置填报状态v0.1

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.xml               |    5 ++
 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClientFallback.java |    5 ++
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/ITbProjectService.java           |    3 +
 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClient.java         |    6 +++
 skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/ProjectXxlJob.java     |   27 +++++++++++++
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/TbProjectServiceImpl.java   |   20 ++++++++++
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.java              |    2 +
 7 files changed, 67 insertions(+), 1 deletions(-)

diff --git a/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClient.java b/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClient.java
index 7cf707f..49d2696 100644
--- a/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClient.java
+++ b/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClient.java
@@ -4,6 +4,7 @@
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 
+import java.text.ParseException;
 import java.util.List;
 
 @FeignClient(
@@ -20,6 +21,8 @@
 	//保存昨日报汛内容
 	String SAVE_YESTERDAY_FLOOD_REPORT_CONTENT = API_PREFIX + "/saveYesterdayFloodReportContent";
 
+	String GET_PROJECT_CHECK_STATUS = API_PREFIX + "/updateProjectCheckStatus";
+
 	@GetMapping(GENERATE_DAY_REPORT_FLOOD)
 	String generateDayReportFlood(@RequestParam("isShow") String isShow) throws Exception;
 
@@ -30,4 +33,7 @@
 	@GetMapping(GET_RESERVOIR_RAINFALL_FORECAST)
 	void getReservoirRainfallForecast(@RequestParam("dayIndexList") List<String> dayIndexList) throws Exception;
 
+	@GetMapping(GET_PROJECT_CHECK_STATUS)
+	void setGetProjectCheckStatus() throws ParseException;
+
 }
diff --git a/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClientFallback.java b/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClientFallback.java
index bc63913..f20f00d 100644
--- a/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClientFallback.java
+++ b/skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/sjztmd/feign/ISjztMdClientFallback.java
@@ -27,6 +27,11 @@
 	}
 
 	@Override
+	public void setGetProjectCheckStatus() {
+
+	}
+
+	@Override
 	public String saveYesterdayFloodReportContent(String isShow) throws Exception {
 		return null;
 	}
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.java
index 78247c1..fba56f0 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.java
@@ -29,4 +29,6 @@
 	List<StatisticsPriceVO> getStatisticsPieBar(@Param("params") StatisticsParams statisticsParams);
 
 	List<StatisticsPriceVO> getStatisticsPieBars(@Param("params") StatisticsParams statisticsParams);
+
+    void updateallcheck();
 }
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.xml b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.xml
index c41c339..fe9af31 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.xml
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/TbProjectMapper.xml
@@ -38,6 +38,9 @@
                  LEFT JOIN YWXT."att_ad_base" city ON city."ad_code" = county."p_ad_code"
                  LEFT JOIN YWXT."att_ad_base" province ON province."ad_code" = city."p_ad_code"
     </sql>
+    <update id="updateallcheck">
+        update SJZT_MD."tb_project" set set "is_fill" ='', "check_state" ='';
+    </update>
 
     <select id="getList" resultType="cn.gistack.sm.sjztmd.vo.TbProjectVO">
 
@@ -77,7 +80,7 @@
         <result property="cityName" column="city_name"/>
         <result property="countyCode" column="county_code"/>
         <result property="countyName" column="county_name"/>
-
+        <result property="other"      column="other"/>
         <result property="centerFund" column="center_fund"/>
         <result property="localFund" column="local_fund"/>
         <result property="isEstablishPlan" column="is_establish_plan"/>
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/ITbProjectService.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/ITbProjectService.java
index 243fd3c..4f12a38 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/ITbProjectService.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/ITbProjectService.java
@@ -12,6 +12,7 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.text.ParseException;
 import java.util.List;
 
 public interface ITbProjectService extends IService<TbProject> {
@@ -30,4 +31,6 @@
 	StatisticsPrice statisticsPie(StatisticsParams statisticsParams);
 
 	List<StatisticsPriceVO> statisticsBar(StatisticsParams statisticsParams);
+
+    void updateallcheck() throws ParseException;
 }
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/TbProjectServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/TbProjectServiceImpl.java
index 4cec098..c67f769 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/TbProjectServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/TbProjectServiceImpl.java
@@ -29,7 +29,10 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import java.math.BigDecimal;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.Arrays;
+import java.util.Date;
 import java.util.List;
 
 @Service
@@ -196,4 +199,21 @@
 		List<StatisticsPriceVO>	 statisticsPieBar =baseMapper.getStatisticsPieBars(statisticsParams);
 		return statisticsPieBar;
 	}
+
+	@Override
+	public void updateallcheck() throws ParseException {
+		Date now = new Date();
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+		String today = sdf.format(now);
+
+		// 转换为年月格式,用于检查是否为月初
+		String yearMonth = sdf.format(sdf.parse(today).getTime()).substring(0, 7);
+		// 检查当前日期是否为月初
+		if (today.startsWith(yearMonth + "-01")) {
+			baseMapper.updateallcheck();
+		} else {
+			System.out.println("不是月初,不予修改状态");
+		}
+
+	}
 }
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/ProjectXxlJob.java b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/ProjectXxlJob.java
new file mode 100644
index 0000000..a212d3d
--- /dev/null
+++ b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/ProjectXxlJob.java
@@ -0,0 +1,27 @@
+package cn.gistack.job.executor.jobhandler;
+
+import cn.gistack.sm.sjztmd.feign.ISjztMdClient;
+import cn.gistack.sm.sjztods.vo.SkxsQkTjVO;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xxl.job.core.log.XxlJobLogger;
+import org.springblade.core.tool.utils.DateUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+
+@Component
+public class ProjectXxlJob {
+	@Autowired
+	private ISjztMdClient sjztMdClient;
+
+	@XxlJob("projectcheckHaJobHandler")
+	public ReturnT<String> skxsDailyJobHandler() throws ParseException {
+		XxlJobLogger.log("执行时间:"+ new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(DateUtil.now()));
+		sjztMdClient.setGetProjectCheckStatus();
+		XxlJobLogger.log("完成时间:"+ new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(DateUtil.now()));
+		return ReturnT.SUCCESS;
+	}
+}

--
Gitblit v1.9.3