From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/job/MQJob.java | 126 +++++++++++++++++++++---------------------
1 files changed, 63 insertions(+), 63 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/MQJob.java b/fanli/src/main/java/com/yeshi/fanli/job/MQJob.java
index a55a5a9..129218a 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/MQJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/MQJob.java
@@ -1,63 +1,63 @@
-package com.yeshi.fanli.job;
-
-import java.util.Date;
-import java.util.List;
-
-import javax.annotation.Resource;
-
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import com.aliyun.openservices.ons.api.Message;
-import com.aliyun.openservices.ons.api.SendResult;
-import com.yeshi.fanli.entity.mq.MQUnSendInfo;
-import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;
-import com.yeshi.fanli.service.manger.msg.RocketMQManager;
-import com.yeshi.fanli.util.Constant;
-import com.yeshi.fanli.util.StringUtil;
-
-/**
- * 娑堟伅浠诲姟
- *
- * @author Administrator
- *
- */
-@Component
-public class MQJob {
-
- @Resource
- private MQUnSendInfoService mqUnSendInfoService;
-
- @Resource
- private RocketMQManager rocketMQManager;
-
-
- public MQJob() {
- }
-
- /**
- * 閲嶆柊鍙戦�佹秷鎭�(2鍒嗛挓閲嶅彂涓�娆�)
- */
- @Scheduled(cron = "0 0/2 * * * ? ")
- public void retrySendMsg() {
- if (!Constant.IS_TASK)
- return;
- Long maxSendTime = System.currentTimeMillis() - 1000 * 60 * 10L;// 鑾峰彇10鍒嗛挓浠ュ墠鍙戦�佺殑娑堟伅
- List<MQUnSendInfo> list = mqUnSendInfoService.listByMaxSendTime(new Date(maxSendTime), 1, 50);
- if (list != null)
- for (MQUnSendInfo sendInfo : list) {
- Message msg = new Message(sendInfo.getTopic(), sendInfo.getTag(), sendInfo.getBody().getBytes());
- if (!StringUtil.isNullOrEmpty(sendInfo.getKey()))
- msg.setKey(sendInfo.getKey());
- if (sendInfo.getDeliverTime() != null)
- msg.setStartDeliverTime(sendInfo.getDeliverTime().getTime());
- SendResult sendResult =rocketMQManager.sendNormalMsg(msg, null,null);
- if (sendResult != null) {
- mqUnSendInfoService.deleteByPrimaryKey(sendInfo.getId());
- LogHelper.mqInfo("娑堟伅閲嶅彂鎴愬姛",sendResult.getMessageId(), sendInfo.getTopic(), sendInfo.getTag(), sendInfo.getBody());
- }
- }
- }
-
-}
+package com.yeshi.fanli.job;
+
+import java.util.Date;
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import com.aliyun.openservices.ons.api.Message;
+import com.aliyun.openservices.ons.api.SendResult;
+import com.yeshi.fanli.entity.mq.MQUnSendInfo;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;
+import com.yeshi.fanli.service.manger.msg.RocketMQManager;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.StringUtil;
+
+/**
+ * 娑堟伅浠诲姟
+ *
+ * @author Administrator
+ *
+ */
+@Component
+public class MQJob {
+
+ @Resource
+ private MQUnSendInfoService mqUnSendInfoService;
+
+ @Resource
+ private RocketMQManager rocketMQManager;
+
+
+ public MQJob() {
+ }
+
+ /**
+ * 閲嶆柊鍙戦�佹秷鎭�(2鍒嗛挓閲嶅彂涓�娆�)
+ */
+ @Scheduled(cron = "0 0/2 * * * ? ")
+ public void retrySendMsg() {
+ if (!Constant.IS_TASK)
+ return;
+ Long maxSendTime = System.currentTimeMillis() - 1000 * 60 * 10L;// 鑾峰彇10鍒嗛挓浠ュ墠鍙戦�佺殑娑堟伅
+ List<MQUnSendInfo> list = mqUnSendInfoService.listByMaxSendTime(new Date(maxSendTime), 1, 50);
+ if (list != null)
+ for (MQUnSendInfo sendInfo : list) {
+ Message msg = new Message(sendInfo.getTopic(), sendInfo.getTag(), sendInfo.getBody().getBytes());
+ if (!StringUtil.isNullOrEmpty(sendInfo.getKey()))
+ msg.setKey(sendInfo.getKey());
+ if (sendInfo.getDeliverTime() != null)
+ msg.setStartDeliverTime(sendInfo.getDeliverTime().getTime());
+ SendResult sendResult =rocketMQManager.sendNormalMsg(msg, null,null);
+ if (sendResult != null) {
+ mqUnSendInfoService.deleteByPrimaryKey(sendInfo.getId());
+ LogHelper.mqInfo("娑堟伅閲嶅彂鎴愬姛",sendResult.getMessageId(), sendInfo.getTopic(), sendInfo.getTag(), sendInfo.getBody());
+ }
+ }
+ }
+
+}
--
Gitblit v1.8.0