From 27f44676f4eba50ea38e7e20693db44a937c992f Mon Sep 17 00:00:00 2001 From: hongchao <3228015117@qq.com> Date: Sat, 5 Jul 2025 13:48:29 +0800 Subject: [PATCH] =?UTF-8?q?iws=E4=B8=ADi8=E5=B7=A5=E7=A8=8B=E9=A1=B9?= =?UTF-8?q?=E7=9B=AE=E6=AF=8F=E6=97=A5=E5=AE=9A=E6=97=B6=E5=99=A8=E7=BC=96?= =?UTF-8?q?=E5=86=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mapper/ConsProjectLeaseMoneyMapper.java | 5 +++ .../push/service/RentalCostsService.java | 2 ++ .../service/impl/RentalCostsServiceImpl.java | 15 +++++++++ .../bonus/material/remind/InformMonthly.java | 32 +++++++++++++++++++ .../push/ConsProjectLeaseMoneyMapper.xml | 22 ++++++++++--- 5 files changed, 72 insertions(+), 4 deletions(-) diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ConsProjectLeaseMoneyMapper.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ConsProjectLeaseMoneyMapper.java index 6744a6c4..efffe1cc 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ConsProjectLeaseMoneyMapper.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ConsProjectLeaseMoneyMapper.java @@ -1,5 +1,6 @@ package com.bonus.material.push.mapper; +import com.bonus.material.basic.domain.BmProject; import com.bonus.material.push.domain.ConsProjectLeaseMoneyBean; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -32,4 +33,8 @@ public interface ConsProjectLeaseMoneyMapper { List getRepairMoney(ConsProjectLeaseMoneyBean o); int insertProjectMonthCosts(@Param("list") List total); + + List getIwsProjectList(); + + void updateIwsProject(@Param("list") List list); } diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/RentalCostsService.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/RentalCostsService.java index 0a892688..f4dbb790 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/RentalCostsService.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/RentalCostsService.java @@ -16,4 +16,6 @@ public interface RentalCostsService { void calcMonthInfo(); + + void iwsProjectCycle(); } diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/RentalCostsServiceImpl.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/RentalCostsServiceImpl.java index 6cc741cb..25c09a8c 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/RentalCostsServiceImpl.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/RentalCostsServiceImpl.java @@ -4,6 +4,7 @@ import com.alibaba.nacos.common.utils.CollectionUtils; import com.bonus.common.biz.config.DateTimeHelper; import com.bonus.common.core.utils.StringUtils; import com.bonus.common.core.web.domain.AjaxResult; +import com.bonus.material.basic.domain.BmProject; import com.bonus.material.push.domain.AccProjectLeaseMoneyBean; import com.bonus.material.push.domain.ConsProjectLeaseMoneyBean; import com.bonus.material.push.domain.IwsCostPushBean; @@ -77,6 +78,20 @@ public class RentalCostsServiceImpl implements RentalCostsService { calcMonthInfoDetails(list, startTime, endTime, taskId); } + @Override + @Transactional(rollbackFor = Exception.class) + public void iwsProjectCycle() { + //查找iws的工程数据 + List list = consDao.getIwsProjectList(); + //修正bns_cloud_material数据 + if (list != null && list.size() > 0) { + consDao.updateIwsProject(list); + } + + } + + + private void calcMonthInfoDetails(List list, String startTime, String endTime, String taskId) { int res; diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/remind/InformMonthly.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/remind/InformMonthly.java index 05557718..0324bd94 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/remind/InformMonthly.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/remind/InformMonthly.java @@ -1,6 +1,7 @@ package com.bonus.material.remind; import com.bonus.common.biz.config.DateTimeHelper; +import com.bonus.material.basic.domain.BmProject; import com.bonus.material.push.service.RentalCostsService; import org.springframework.beans.factory.annotation.Autowired; @@ -51,4 +52,35 @@ public class InformMonthly { System.err.println("定时任务获取时间报错:" + e.getMessage()); } } + + /** + * 定时任务注解，用于配置任务的执行周期。 + * 该任务被安排在每天晚上十二点执行。 + * cron表达式解释： + * - "0 0 0 * * ?" 表示在每天的0点0分0秒执行。 + * - 分钟（0）：表示分钟，这里指定为0分钟。 + * - 小时（0）：表示小时，这里指定为0点。 + * - 日期（*）：表示日期，这里使用通配符*表示所有日期。 + * - 月份（*）：表示月份，这里使用通配符*表示所有月份。 + * - 星期（?）：表示星期，由于日期字段已使用*，因此使用?表示不指定星期。 + * - 年份（空）：不指定年份，表示每年都执行。 + */ + @Scheduled(cron = "0 0 0 * * ?") + public void iwsProjectCycle() { + System.out.println("使用SpringMVC框架配置定时任务"); + try { + System.out.println("执行每天晚上十二点的定时任务...执行时间:" + DateTimeHelper.currentDateTime()); + } catch (Exception e) { + System.err.println("定时任务获取时间报错:" + e.getMessage()); + } + + service.iwsProjectCycle(); + + try { + System.out.println("当天的定时任务已结束：" + DateTimeHelper.currentDateTime()); + } catch (Exception e) { + System.err.println("定时任务获取时间报错:" + e.getMessage()); + } + } + } diff --git a/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ConsProjectLeaseMoneyMapper.xml b/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ConsProjectLeaseMoneyMapper.xml index 988f7dbd..3a1b9c66 100644 --- a/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ConsProjectLeaseMoneyMapper.xml +++ b/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ConsProjectLeaseMoneyMapper.xml @@ -3,10 +3,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> - - - - + select + dfs.id as externalId, + dfs.project_status as proStatus, + dfs.real_end_date as actualEndDate + from data_center.dx_fb_son dfs + + + + + UPDATE bm_project + SET + pro_status = #{item.proStatus}, + actual_end_date = #{item.actualEndDate} + WHERE external_id = #{item.externalId} + +