From 4fabfe4dbd2eb28d07a4350597d314958cc1c281 Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期四, 09 十月 2025 11:16:43 +0800
Subject: [PATCH] 优化
---
server/platform/src/main/java/com/doumee/task/ScheduleTool.java | 66 ++++++++++++++++++++++++++++++---
1 files changed, 60 insertions(+), 6 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 92ffb41..e755ee9 100644
--- a/server/platform/src/main/java/com/doumee/task/ScheduleTool.java
+++ b/server/platform/src/main/java/com/doumee/task/ScheduleTool.java
@@ -4,11 +4,14 @@
import com.alibaba.fastjson.JSONObject;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.constants.Constants;
+import com.doumee.core.dingding.DingDingNotice;
import com.doumee.core.exception.BusinessException;
+import com.doumee.core.mqtt.config.MqttClientInit;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.HttpsUtil;
import com.doumee.core.wx.WxPayProperties;
import com.doumee.dao.business.model.Goodsorder;
+import com.doumee.dao.business.model.Sites;
import com.doumee.dao.system.model.SystemDictData;
import com.doumee.service.business.*;
import com.doumee.service.system.SystemDictDataService;
@@ -60,12 +63,16 @@
/**
* @throws Exception
*/
+ @Scheduled(cron = "0 0 10 * * ? ")
public void getWxBill() throws Exception {
//鍓嶄竴澶╃殑鏁告摎
Date ydate = DateUtil.addDaysToDate(new Date(), -1);
wxBillService.getWxBill(ydate);
-
}
+
+
+
+
/**
* 娓│
* @throws Exception
@@ -82,13 +89,25 @@
* 30 绉掑埛鏂颁竴娆�
* @throws Exception
*/
- @Scheduled(cron = "0/30 * * * * ? ")
+ @Scheduled(cron = "0/15 * * * * ? ")
public void autoRefreshLockStatus() throws Exception {
log.info("=====================寮�濮嬪畾鏃跺埛鏂伴獞琛屼腑鐨勬暟鍏呭�兼湭寮�閿佸け璐�=======================");
- memberRidesService.autoRefreshLockStatus();
+ memberRidesService.autoRefreshLockStatus();
log.info("=====================缁撴潫瀹氭椂鍒锋柊楠戣涓殑鏁板厖鍊兼湭寮�閿佸け璐�=======================");
}
+
+ /**
+ * 瀹氭椂鍏抽棴 瓒呮椂鏈敮浠樼殑璁㈠崟
+ * 30 绉掑埛鏂颁竴娆�
+ * @throws Exception
+ */
+ @Scheduled(cron = "0/15 * * * * ? ")
+ public void autCancel() throws Exception {
+ log.info("=====================寮�濮嬪畾鏃跺埛鏂板叧闂秴鏃舵湭鏀粯鐨勮鍗�=======================");
+ goodsorderService.autCancel();
+ log.info("=====================缁撴潫瀹氭椂鍒锋柊鍏抽棴瓒呮椂鏈敮浠樼殑璁㈠崟=======================");
+ }
/**
* 绔欑偣杞﹁締婊℃灦鐜囬璀�
@@ -100,7 +119,16 @@
sitesService.siteReservesNotice();;
log.info("=====================缁撴潫 绔欑偣杞﹁締婊℃灦鐜囬璀�=======================");
}
-
+ /**
+ * 妫�鏌ラ�氫俊寮傚父鐨勭珯鐐瑰彂閫氱煡
+ * @throws Exception
+ */
+ @Scheduled(fixedDelay = 1000L * 60L * 5)
+ public void noticeNoLinkList() throws Exception {
+ log.info("=====================寮�濮� 妫�鏌ラ�氫俊寮傚父鐨勭珯鐐瑰彂閫氱煡=======================");
+ sitesService.noticeNoLinkList(new Sites());;
+ log.info("=====================缁撴潫 妫�鏌ラ�氫俊寮傚父鐨勭珯鐐瑰彂閫氱煡=======================");
+ }
@Autowired
private WxPayProperties wxPayProperties;
@@ -108,7 +136,7 @@
/**
* 鏇存柊寰俊 ACCESS_TOKEN
*/
- @Scheduled(fixedDelay = 1000L * 60L * 90L)
+// @Scheduled(fixedDelay = 1000L * 60L * 90L)
public void updAccessToken(){
DefaultWebSecurityManager manager = new DefaultWebSecurityManager();
ThreadContext.bind(manager);
@@ -121,7 +149,7 @@
}
//鐢熸垚寰俊token
String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+appId+"&secret="+appSecret;
- String response = HttpsUtil.doGet(url,null);
+ String response = HttpsUtil.get(url,false);
JSONObject json = JSONObject.parseObject(response);
SystemDictData systemDictData = systemDictDataBiz.queryByCode(Constants.MINI_PROGRAMME,Constants.ACCESS_TOKEN);
if(!Objects.isNull(systemDictData)){
@@ -133,6 +161,24 @@
/**
* 鏇存柊寰俊 ACCESS_TOKEN
*/
+ @Scheduled(fixedDelay = 1000L * 60L * 90L)
+ public void updAccessDingdingToken() throws Exception {
+ DefaultWebSecurityManager manager = new DefaultWebSecurityManager();
+ ThreadContext.bind(manager);
+ String token = DingDingNotice.getToken(systemDictDataBiz.queryByCode(Constants.DINGDING,Constants.DINGDING_APPKEY).getCode()
+ ,systemDictDataBiz.queryByCode(Constants.DINGDING,Constants.DINGDING_SECRET).getCode());
+ if(StringUtils.isNotBlank(token)){
+ SystemDictData systemDictData = systemDictDataBiz.queryByCode(Constants.DINGDING,Constants.DINGDING_TOKEN);
+ if(!Objects.isNull(systemDictData)){
+ systemDictData.setCode(token);
+ systemDictData.setUpdateTime(new Date());
+ systemDictDataService.updateById(systemDictData);
+ }
+ }
+ }
+ /**
+ * 鏇存柊寰俊 ACCESS_TOKEN
+ */
@Scheduled(fixedDelay = 1000L * 60L )
public void autoCancelRefunOrder(){
log.info("=====================寮�濮� 鑷嫊鍙栨秷鏈帹閫侀��娆剧姸鎬佺殑閫�娆惧崟鐘舵��=======================");
@@ -141,4 +187,12 @@
}
+ @Scheduled(fixedDelay = 1000L * 60L )
+ public void autCancelGoodsOrder(){
+ log.info("=====================寮�濮� 鑷嫊鍙栨秷鏈敮浠樿鍗曠姸鎬�=======================");
+ goodsorderService.autoCancelRefunOrder();;
+ log.info("=====================缁撴潫 鑷嫊鍙栨秷鏈敮浠樿鍗曠姸鎬�=======================");
+ }
+
+
}
--
Gitblit v1.9.3