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/service/impl/push/IOSPushServiceImpl.java | 38 ++++++++++++++++----------------------
1 files changed, 16 insertions(+), 22 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java
index 2c5919c..492d218 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java
@@ -1,24 +1,11 @@
package com.yeshi.fanli.service.impl.push;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.List;
-
-import javax.annotation.Resource;
-
-import com.yeshi.fanli.entity.SystemEnum;
-import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;
-import com.yeshi.fanli.service.inter.config.SystemConfigService;
-import org.springframework.scheduling.annotation.Async;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
import com.yeshi.fanli.dao.mybatis.push.DeviceTokenIOSMapper;
import com.yeshi.fanli.dao.mybatis.push.PushQueueRecordMapper;
import com.yeshi.fanli.dto.push.PushTypeEnum;
+import com.yeshi.fanli.entity.SystemEnum;
import com.yeshi.fanli.entity.bus.user.AccountMessage;
+import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;
import com.yeshi.fanli.entity.push.DeviceTokenIOS;
import com.yeshi.fanli.entity.push.PushQueueRecord;
import com.yeshi.fanli.entity.system.SystemZnx;
@@ -26,14 +13,20 @@
import com.yeshi.fanli.entity.xinge.PushRecord;
import com.yeshi.fanli.exception.push.PushException;
import com.yeshi.fanli.log.PushLogHelper;
+import com.yeshi.fanli.service.inter.config.SystemConfigService;
import com.yeshi.fanli.service.inter.push.IOSPushService;
import com.yeshi.fanli.service.inter.user.UserCustomSettingsService;
-import com.yeshi.fanli.util.CMQManager;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import com.yeshi.fanli.util.push.IOSPushUtil;
-
import net.sf.json.JSONObject;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.*;
@Service
public class IOSPushServiceImpl implements IOSPushService {
@@ -50,10 +43,13 @@
@Resource
private SystemConfigService systemConfigService;
+ @Resource
+ private RabbitmqManager rabbitmqManager;
+
@Async("pushExecutor")
@Override
- public void pushGoods(Long uid, Long auctionId, String title, String content, String versionCodes, SystemEnum system)
+ public void pushGoods(Long uid, String auctionId, String title, String content, String versionCodes, SystemEnum system)
throws PushException {
String url = "https://item.taobao.com/item.htm?id=" + auctionId;
@@ -330,8 +326,6 @@
/**
* 淇濆瓨鎺ㄩ�佸唴瀹瑰彧闃熷垪涓�
- *
- * @param json
*/
@Transactional(rollbackFor = Exception.class)
public void addPushIOSQueue(MessageInfo info, String url, int type, String versionCodes,SystemEnum system) throws PushException {
@@ -379,7 +373,7 @@
pushQueueRecordMapper.insert(pushQueueRecord);
// 鍔犲叆闃熷垪
- CMQManager.getInstance().addIOSPushMsg(pushQueueRecord);
+ rabbitmqManager.addIOSPushMsg(pushQueueRecord);
break;
@@ -396,7 +390,7 @@
// 瀛樺叆鏁版嵁搴�
pushQueueRecordMapper.insert(pushQueueRecord);
// 鍔犲叆闃熷垪
- CMQManager.getInstance().addIOSPushMsg(pushQueueRecord);
+ rabbitmqManager.addIOSPushMsg(pushQueueRecord);
}
i += totalCount;
--
Gitblit v1.8.0