From 8e75bb4e451d6d3f33e2146335bad0f85d27d99f Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期四, 02 十一月 2023 17:06:46 +0800 Subject: [PATCH] 硬件协议对接 --- server/platform/src/main/java/com/doumee/task/ScheduleTool.java | 71 +++++++++++++++++++++++++++++++++-- 1 files changed, 67 insertions(+), 4 deletions(-) diff --git a/server/platform/src/main/java/com/doumee/task/ScheduleTool.java b/server/platform/src/main/java/com/doumee/task/ScheduleTool.java index ad8077e..ef5de1a 100644 --- a/server/platform/src/main/java/com/doumee/task/ScheduleTool.java +++ b/server/platform/src/main/java/com/doumee/task/ScheduleTool.java @@ -2,11 +2,23 @@ import com.doumee.biz.system.SystemDictDataBiz; +import com.doumee.core.constants.Constants; +import com.doumee.core.exception.BusinessException; +import com.doumee.core.utils.DateUtil; +import com.doumee.dao.business.model.Goodsorder; +import com.doumee.service.business.GoodsorderService; +import com.doumee.service.business.MemberRidesService; +import com.doumee.service.business.SitesService; import com.doumee.service.business.WxBillService; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; +import org.springframework.util.CollectionUtils; + +import java.util.Date; +import java.util.List; /** * 瀹氭椂浠诲姟 @@ -16,29 +28,80 @@ */ @Component @EnableScheduling +@Slf4j public class ScheduleTool { @Autowired private SystemDictDataBiz systemDictDataBiz; + @Autowired private WxBillService wxBillService; + @Autowired + private GoodsorderService goodsorderService; + + @Autowired + private MemberRidesService memberRidesService; + + @Autowired + private SitesService sitesService; + /** * @throws Exception */ - @Scheduled(cron = "0 0 11 * * ? ") +// @Scheduled(cron = "0 0 11 * * ? ") public void syncStudent() throws Exception { - wxBillService.getWxBill(); + //鍓嶄竴澶╃殑鏁告摎 + Date ydate = DateUtil.addDaysToDate(new Date(), -1); + wxBillService.getWxBill(ydate); } /** + * 娓│ * @throws Exception */ - @Scheduled(fixedDelay = 1000*60) + @Scheduled(cron = "0 0 21 * * ? ") public void getYesterdayBill() throws Exception { - wxBillService.getWxBill(); + log.info("=====================寮�濮嬫瘡澶╄嚜鍔ㄧ粨绠�======================="); + goodsorderService.autoCloseOrder(); + log.info("=====================缁撴潫姣忓ぉ鑷姩缁撶畻======================="); } + + /** + * 瀹氭椂鍒锋柊楠戣涓殑鏁板厖鍊兼湭寮�閿佸け璐� + * 30 绉掑埛鏂颁竴娆� + * @throws Exception + */ +// @Scheduled(cron = "0/30 * * * * ? ") + public void autoRefreshLockStatus() throws Exception { +<<<<<<< HEAD + log.info("=====================寮�濮嬪埛鏂伴獞琛屼腑鐨勬暟鍏呭�兼湭寮�閿佸け璐�======================="); + memberRidesService.autoRefreshLockStatus(); + log.info("=====================寮�濮嬪埛鏂伴獞琛屼腑鐨勬暟鍏呭�兼湭寮�閿佸け璐�======================="); +======= + log.info("=====================寮�濮嬪畾鏃跺埛鏂伴獞琛屼腑鐨勬暟鍏呭�兼湭寮�閿佸け璐�======================="); + memberRidesService.autoRefreshLockStatus(); + log.info("=====================缁撴潫瀹氭椂鍒锋柊楠戣涓殑鏁板厖鍊兼湭寮�閿佸け璐�======================="); +>>>>>>> 50c564c2568e7fb52d8dcbcbebb937a6a8284eeb + } + + + /** + * 绔欑偣杞﹁締婊℃灦鐜囬璀� + * @throws Exception + */ +<<<<<<< HEAD + @Scheduled(fixedDelay = 1000L * 60L * 10L) +======= +// @Scheduled(fixedDelay = 1000L * 60L * 3L) +>>>>>>> 50c564c2568e7fb52d8dcbcbebb937a6a8284eeb + public void siteReserves() throws Exception { + log.info("=====================寮�濮� 绔欑偣杞﹁締婊℃灦鐜囬璀�======================="); + sitesService.siteReservesNotice();; + log.info("=====================缁撴潫 绔欑偣杞﹁締婊℃灦鐜囬璀�======================="); + } + } -- Gitblit v1.9.3