From bbec49a4032ec56fb2833b46524a918b50875627 Mon Sep 17 00:00:00 2001 From: xhxu Date: Sat, 31 Dec 2022 17:30:50 +0800 Subject: [PATCH 1/5] //schedule --- .../main/java/com/iformall/schedule/InvestSchedule.java | 8 ++++---- .../com/iformall/schedule/OrderRefundAuditSchedule.java | 2 +- .../com/iformall/schedule/PowerBillAutoBuildSchedule.java | 4 ++-- .../com/iformall/schedule/SharingOrderRedoSchedule.java | 4 ++-- .../com/iformall/schedule/SharingOrderResultSchedule.java | 4 ++-- .../com/iformall/schedule/TtMerchantReciverSchedule.java | 2 +- .../java/com/iformall/schedule/WxCUserTagsSchedule.java | 2 +- .../java/com/iformall/schedule/WxMsgModelSchedule.java | 4 ++-- .../pay/service/share/wx/v3/WxPayShareV3Service.java | 4 ++-- 9 files changed, 17 insertions(+), 17 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/InvestSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/InvestSchedule.java index 61449f833..11fe0d039 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/InvestSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/InvestSchedule.java @@ -60,8 +60,8 @@ public class InvestSchedule { private static final String TAG_REMIND = "招商定时任务-提醒"; - @Async - @Scheduled(cron = "0 0 14 * * ?") // 每天下午两点执行定时任务 +// @Async +// @Scheduled(cron = "0 0 14 * * ?") // 每天下午两点执行定时任务 //@Scheduled(cron = "0 */30 * * * *?") // 测试,每30分钟执行 public void messageSchedule() { log.info("{}: 开始", TAG_MESSAGE); @@ -72,8 +72,8 @@ public class InvestSchedule { log.info("{}: 结束", TAG_MESSAGE); } - @Async - @Scheduled(cron = "0 */5 * * * *?") +// @Async +// @Scheduled(cron = "0 */5 * * * *?") public void remindSchedule() { log.info("{}: 开始", TAG_REMIND); // 提醒新 diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java index 83b1a79fa..a2bc38e01 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java @@ -42,7 +42,7 @@ public class OrderRefundAuditSchedule { MaUtil maUtil; - @Scheduled(cron = "0 */5 * * * ?")// + @Scheduled(cron = "0 0 */1 * * ?")// //@Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次 public void orderQueryRefund() { diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/PowerBillAutoBuildSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/PowerBillAutoBuildSchedule.java index 5eefd5672..9d6de280e 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/PowerBillAutoBuildSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/PowerBillAutoBuildSchedule.java @@ -61,8 +61,8 @@ public class PowerBillAutoBuildSchedule { /** * 每天5点执行 */ - @Async - @Scheduled(cron = "0 0 5 * * ?") +// @Async +// @Scheduled(cron = "0 0 5 * * ?") public void powerBillAutoConfigStart() { logger.info("自动生成电费账单开始...."); int dayOfMonth = LocalDate.now().getDayOfMonth(); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderRedoSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderRedoSchedule.java index 095de9480..8b9478372 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderRedoSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderRedoSchedule.java @@ -48,8 +48,8 @@ public class SharingOrderRedoSchedule { } @Async -// @Scheduled(cron = "0 0 2 * * ?") // 每天凌晨02:00分账重试 - @Scheduled(cron = "0 15 */2 * * ?")// 每2个小时的15分钟 + @Scheduled(cron = "0 15 2 * * ?") // 每天凌晨02:00分账重试 +// @Scheduled(cron = "0 15 */2 * * ?")// 每2个小时的15分钟 // @Scheduled(cron = "0 0/10 * * * ?") // 测试 public void sharingOrderRedoSchedule() { List malls = getMalls(); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderResultSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderResultSchedule.java index 44aa62f43..c6972f08c 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderResultSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/SharingOrderResultSchedule.java @@ -35,8 +35,8 @@ public class SharingOrderResultSchedule { } @Async -// @Scheduled(cron = "0 0 3 * * ?") // 每天凌晨3:00更新分账结果 - @Scheduled(cron = "0 30 */2 * * ?")// 每2个小时的30分钟 + @Scheduled(cron = "0 15 3 * * ?") // 每天凌晨3:00更新分账结果 +// @Scheduled(cron = "0 30 */2 * * ?")// 每2个小时的30分钟 // @Scheduled(cron = "* */15 * * * ?") // 测试10秒中一次 public void sharingOrderResultSchedule() { List malls = getMalls(); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java index 3e36eddfb..d1046251c 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java @@ -42,7 +42,7 @@ public class TtMerchantReciverSchedule { /** * 每半小时 */ - @Scheduled(cron = "0 */30 * * * ?") + @Scheduled(cron = "0 33 */1 * * ?") // @Scheduled(cron = "0 */5 * * * *?") //测试五分钟执行 public void updateMerchantReciverSchedule() { List ttAppInfos = getTTAppInfos(); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java index ba5a76232..0b96e3975 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java @@ -38,7 +38,7 @@ public class WxCUserTagsSchedule { @Async // TODO 先不执行打标签操作了, 数据量太大,导致数据库CPU 100% //@Scheduled(cron = "0 0 0 25 * ?") // 每月25日凌晨01:00对会员列表扫描补录标签 - @Scheduled(cron = "0 0 2 * * ?") // 测试1分钟一次 +// @Scheduled(cron = "0 0 2 * * ?") // 测试1分钟一次 public void wxCUserTagsSchedule() { WxMall wxMall = new WxMall(); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WxMsgModelSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WxMsgModelSchedule.java index 878a8bcce..e3484125a 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/WxMsgModelSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WxMsgModelSchedule.java @@ -46,7 +46,7 @@ public class WxMsgModelSchedule { WxMsgConfigMapper wxMsgConfigMapper; @Async - @Scheduled(cron = "0 0 */1 * * ?") // + @Scheduled(cron = "0 25 */2 * * ?") // public void querySmsTemplate() { WxMsgModel msgModel = new WxMsgModel(); msgModel.setStatus(EnumMsgModelStatus.AUDITING.getCode()); @@ -91,7 +91,7 @@ public class WxMsgModelSchedule { } @Async - @Scheduled(cron = "30 */10 * * * ?") // + @Scheduled(cron = "0 20 */2 * * ?") // public void querySendDetails() { WxMsgCallback msgCallback = new WxMsgCallback(); msgCallback.setStatus(EnumMsgSendStatus.MSG_SENDING.getCode()); diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java index 1cc113fc1..6543678b8 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java @@ -208,8 +208,8 @@ public class WxPayShareV3Service extends PayShareBaseAdapterService{ } String out_order_no = result.getString("out_order_no"); - if (StringUtils.isBlank(out_order_no) || !out_order_no.equals(record.getId().toString())){ - throw new MallinkException(ErrorCode.PROFIT_SHARING_QUERY_RETURN_INVALID.getCode(),"out_order_no:["+out_order_no+"] WxProfitSharingOrder:["+record.getId()+"]"); + if (StringUtils.isBlank(out_order_no) || !out_order_no.equals(record.getOrderId().toString())){ + throw new MallinkException(ErrorCode.PROFIT_SHARING_QUERY_RETURN_INVALID.getCode(),"out_order_no:["+out_order_no+"] WxProfitSharingOrder:["+record.getOrderId()+"]"); } return new PayShareQueryResult(true, 200, "success",result, this.getReceivers(JSON.toJSONString(result.get("receivers")))); } From f005b8781f0cb60887dd5b732b48c8158af59c9d Mon Sep 17 00:00:00 2001 From: xhxu Date: Sun, 1 Jan 2023 14:58:58 +0800 Subject: [PATCH 2/5] //share --- .../java/com/iformall/controller/callback/WxPayController.java | 1 + .../service/pay/service/share/wx/v3/WxPayShareV3Service.java | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/mallinkCallback/src/main/java/com/iformall/controller/callback/WxPayController.java b/mallinkCallback/src/main/java/com/iformall/controller/callback/WxPayController.java index 060905998..8814c4099 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/callback/WxPayController.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/callback/WxPayController.java @@ -154,6 +154,7 @@ public class WxPayController extends BaseController { xml = IOUtils.toString(request.getInputStream(), Charset.forName("UTF-8")); logger.info(xml); paramMap = WxPayment.xmlToMap(xml); + paramMap.put("tenantId", tenantId); String jsonMsg = JSON.toJSONString(paramMap); FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java index 6543678b8..0422b27a7 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java @@ -211,7 +211,8 @@ public class WxPayShareV3Service extends PayShareBaseAdapterService{ if (StringUtils.isBlank(out_order_no) || !out_order_no.equals(record.getOrderId().toString())){ throw new MallinkException(ErrorCode.PROFIT_SHARING_QUERY_RETURN_INVALID.getCode(),"out_order_no:["+out_order_no+"] WxProfitSharingOrder:["+record.getOrderId()+"]"); } - return new PayShareQueryResult(true, 200, "success",result, this.getReceivers(JSON.toJSONString(result.get("receivers")))); + + return new PayShareQueryResult(true, EnumProfitSharingOrderStatus.PROFIT_SHARING_DONE.getCode(), "success",result, this.getReceivers(JSON.toJSONString(result.get("receivers")))); } From 3d7cb9da6bce4fad9745c24f1d6849bc74af4583 Mon Sep 17 00:00:00 2001 From: xhxu Date: Sun, 1 Jan 2023 15:12:33 +0800 Subject: [PATCH 3/5] //refund --- .../controller/callback/TtPayController.java | 42 +++++++++---------- .../schedule/OrderRefundAuditSchedule.java | 3 +- .../schedule/TtMerchantReciverSchedule.java | 1 + 3 files changed, 24 insertions(+), 22 deletions(-) diff --git a/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java b/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java index 5e7a1c499..5086823c3 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java @@ -210,27 +210,27 @@ public class TtPayController extends BaseController { status = (String) pMap.get("status"); refund_amount = (Integer) pMap.get("refund_amount"); } - - Map map = new HashMap<>(); - map.put("tenantId",tenantId); - map.put("appid",appid); - map.put("cp_refundno",cp_refundno); - map.put("status",status); - map.put("refund_amount",refund_amount.toString()); -// wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); - - String jsonMsg = JSON.toJSONString(map); - - FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); - refundSuccessMsg.setTenantId(tenantId); - refundSuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode()); - refundSuccessMsg.setDelayTimeLevel(3); - refundSuccessMsg.setPayWay(EnumPayWay.PAY_WAY_TT.getCode()); - refundSuccessMsg.setPayVersion(EnumPayVersion.DY_PAY_V2.getCode()); - refundSuccessMsg.setJsonMsg(jsonMsg); - - // response = wxRefundOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP); - mqBaseProducer.sendMessage(refundSuccessMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + //todo 定时处理, 不用回调处理的方式 +// Map map = new HashMap<>(); +// map.put("tenantId",tenantId); +// map.put("appid",appid); +// map.put("cp_refundno",cp_refundno); +// map.put("status",status); +// map.put("refund_amount",refund_amount.toString()); +//// wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); +// +// String jsonMsg = JSON.toJSONString(map); +// +// FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); +// refundSuccessMsg.setTenantId(tenantId); +// refundSuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode()); +// refundSuccessMsg.setDelayTimeLevel(3); +// refundSuccessMsg.setPayWay(EnumPayWay.PAY_WAY_TT.getCode()); +// refundSuccessMsg.setPayVersion(EnumPayVersion.DY_PAY_V2.getCode()); +// refundSuccessMsg.setJsonMsg(jsonMsg); +// +// // response = wxRefundOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP); +// mqBaseProducer.sendMessage(refundSuccessMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); resultMap.put("err_no",0); resultMap.put("err_tips","success"); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java index 60244500a..c7a08b83e 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java @@ -13,6 +13,7 @@ import com.iformall.utils.MaUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @@ -42,7 +43,7 @@ public class OrderRefundAuditSchedule { MaUtil maUtil; @Async - @Scheduled(cron = "0 0 */1 * * ?")// + @Scheduled(cron = "0 40 */1 * * ?")// //@Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次 public void orderQueryRefund() { diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java index 4f131831c..e69d31c83 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/TtMerchantReciverSchedule.java @@ -7,6 +7,7 @@ import com.iformall.service.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; From 2b919956bb7be57ef107941c7a641f68d0ad369e Mon Sep 17 00:00:00 2001 From: xhxu Date: Sun, 1 Jan 2023 15:18:58 +0800 Subject: [PATCH 4/5] //QuestionOneself --- .../service/impl/WxQuestionOneselfServiceImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxQuestionOneselfServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxQuestionOneselfServiceImpl.java index 4cce1f0b7..e74c4e115 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxQuestionOneselfServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxQuestionOneselfServiceImpl.java @@ -88,10 +88,10 @@ public class WxQuestionOneselfServiceImpl implements WxQuestionOneselfService { record.setCreateDate(now); wxQuestionOneselfMapper.insert(record); } else { - WxQuestionOneself byId = this.getById(record.getId()); - if(!byId.getStatus().equals(EnumQuestionOneselfStatus.STATUS_THROW_IN.getCode())){ - throw new MallinkException(ErrorCode.QUESTION_UPUP_LINE); - } +// WxQuestionOneself byId = this.getById(record.getId()); +// if(!byId.getStatus().equals(EnumQuestionOneselfStatus.STATUS_THROW_IN.getCode())){ +// throw new MallinkException(ErrorCode.QUESTION_UPUP_LINE); +// } WxQuestionOneselfTopic wxQuestionOneselfTopic = new WxQuestionOneselfTopic(); wxQuestionOneselfTopic.updateTenantInfo(record); From aac7f051c6d34d4f98f96c23fa9e133df04cbce1 Mon Sep 17 00:00:00 2001 From: xhxu Date: Sun, 1 Jan 2023 17:49:11 +0800 Subject: [PATCH 5/5] //refund --- .../controller/callback/TtPayController.java | 41 ++++++++++--------- .../schedule/OrderRefundAuditSchedule.java | 2 +- 2 files changed, 22 insertions(+), 21 deletions(-) diff --git a/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java b/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java index 5e7a1c499..ad4c3ebcf 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/callback/TtPayController.java @@ -211,26 +211,27 @@ public class TtPayController extends BaseController { refund_amount = (Integer) pMap.get("refund_amount"); } - Map map = new HashMap<>(); - map.put("tenantId",tenantId); - map.put("appid",appid); - map.put("cp_refundno",cp_refundno); - map.put("status",status); - map.put("refund_amount",refund_amount.toString()); -// wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); - - String jsonMsg = JSON.toJSONString(map); - - FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); - refundSuccessMsg.setTenantId(tenantId); - refundSuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode()); - refundSuccessMsg.setDelayTimeLevel(3); - refundSuccessMsg.setPayWay(EnumPayWay.PAY_WAY_TT.getCode()); - refundSuccessMsg.setPayVersion(EnumPayVersion.DY_PAY_V2.getCode()); - refundSuccessMsg.setJsonMsg(jsonMsg); - - // response = wxRefundOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP); - mqBaseProducer.sendMessage(refundSuccessMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + //todo 抖音退款不通过回调处理,通过定时处理 +// Map map = new HashMap<>(); +// map.put("tenantId",tenantId); +// map.put("appid",appid); +// map.put("cp_refundno",cp_refundno); +// map.put("status",status); +// map.put("refund_amount",refund_amount.toString()); +//// wxRefundOrderService.notify(map, EnumPayWay.PAY_WAY_TT); +// +// String jsonMsg = JSON.toJSONString(map); +// +// FmInsideNotifyRefundSuccessMsg refundSuccessMsg = new FmInsideNotifyRefundSuccessMsg(); +// refundSuccessMsg.setTenantId(tenantId); +// refundSuccessMsg.setMsgType(EnumMsgRecordType.INSIDE_NOTIFY_REFUND_SUCCESS.getCode()); +// refundSuccessMsg.setDelayTimeLevel(3); +// refundSuccessMsg.setPayWay(EnumPayWay.PAY_WAY_TT.getCode()); +// refundSuccessMsg.setPayVersion(EnumPayVersion.DY_PAY_V2.getCode()); +// refundSuccessMsg.setJsonMsg(jsonMsg); +// +// // response = wxRefundOrderService.notify(paramMap, EnumPayWay.PAY_WAY_WEAPP); +// mqBaseProducer.sendMessage(refundSuccessMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); resultMap.put("err_no",0); resultMap.put("err_tips","success"); diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java index a2bc38e01..f00fe47bb 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderRefundAuditSchedule.java @@ -42,7 +42,7 @@ public class OrderRefundAuditSchedule { MaUtil maUtil; - @Scheduled(cron = "0 0 */1 * * ?")// + @Scheduled(cron = "0 40 */1 * * ?")// //@Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次 public void orderQueryRefund() {