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; } 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; } 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(); } 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"/> 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; } 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("不是月初,不予修改状态"); } } } skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/ProjectXxlJob.java
New file @@ -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; } }