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/DeviceActiveServiceImpl.java | 212 ++++++++++++++++++++++++++--------------------------
1 files changed, 107 insertions(+), 105 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/DeviceActiveServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/DeviceActiveServiceImpl.java
index 17868de..7b1d4c2 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/DeviceActiveServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/DeviceActiveServiceImpl.java
@@ -1,105 +1,107 @@
-package com.yeshi.fanli.service.impl.push;
-
-import java.util.Date;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Service;
-
-import com.yeshi.fanli.dao.mybatis.push.DeviceActiveMapper;
-import com.yeshi.fanli.entity.push.DeviceActive;
-import com.yeshi.fanli.service.inter.push.DeviceActiveService;
-import com.yeshi.fanli.util.StringUtil;
-import com.yeshi.fanli.util.cmq.DouYinDeviceActiveCMQManager;
-
-@Service
-public class DeviceActiveServiceImpl implements DeviceActiveService {
- @Resource
- private DeviceActiveMapper deviceActiveMapper;
-
- @Override
- public void addDeviceActive(DeviceActive deviceActive) {
- // 娣诲姞璁板綍
- if (deviceActive == null)
- return;
- if (deviceActive.getPlatform() == null)
- return;
-
- if (deviceActive.getVersionCode() == null)
- return;
-
- if (StringUtil.isNullOrEmpty(deviceActive.getDevice()))
- return;
-
- // Android鐨勫敮涓�鏍囪瘑涓篸evice
- if (StringUtil.isNullOrEmpty(deviceActive.getDevice()))
- return;
- DeviceActive da = deviceActiveMapper.selectByDeviceAndPlatform(deviceActive.getDevice(),
- deviceActive.getPlatform());
- if (da == null) {
- deviceActive.setId(null);
- deviceActive.setUpdateTime(new Date());
- deviceActive.setCreateTime(new Date());
- if (!StringUtil.isNullOrEmpty(deviceActive.getDeviceToken())) {
- deviceActive.setDeviceTokenMd5(StringUtil.Md5(deviceActive.getDeviceToken()));
- }
-
- deviceActiveMapper.insertSelective(deviceActive);
- DouYinDeviceActiveCMQManager.getInstance().addDeviceActive(deviceActive.getDevice(),
- deviceActive.getPlatform());
- } else {
- DeviceActive updateDeviceActive = new DeviceActive();
- updateDeviceActive.setId(da.getId());
- updateDeviceActive.setUpdateTime(new Date());
- updateDeviceActive.setVersionCode(deviceActive.getVersionCode());
- if (StringUtil.isNullOrEmpty(da.getImei()))
- updateDeviceActive.setImei(deviceActive.getImei());
- if (!StringUtil.isNullOrEmpty(deviceActive.getDeviceToken())) {
- updateDeviceActive.setDeviceToken(deviceActive.getDeviceToken());
- updateDeviceActive.setDeviceTokenMd5(StringUtil.Md5(deviceActive.getDeviceToken()));
- }
-
- if (StringUtil.isNullOrEmpty(da.getMac()))
- updateDeviceActive.setImei(deviceActive.getMac());
-
- deviceActiveMapper.updateByPrimaryKeySelective(updateDeviceActive);
- }
-
- }
-
- /**
- *
- * @param device
- * 璁惧鍙�
- * @param platform
- * 骞冲彴绫诲瀷
- * @return
- */
- @Override
- public DeviceActive getDeviceByDeviceAndPlatform(String device, String deviceToken, String platform) {
-
- DeviceActive deviceActive = null;
- if ("android".equalsIgnoreCase(platform)) {
-
- deviceActive = deviceActiveMapper.selectFirstByDeviceAndPlatform(device, DeviceActive.PLATFORM_ANDROID);
-
- } else if ("ios".equalsIgnoreCase(platform)) {
-
- deviceActive = deviceActiveMapper.selectFirstByDeviceAndPlatform(device, DeviceActive.PLATFORM_IOS);
-
- }
-
- return deviceActive;
- }
-
- @Override
- public DeviceActive getFirstActiveInfo(String device) {
- return deviceActiveMapper.selectFirst(device);
- }
-
- @Override
- public DeviceActive getFirstActiveInfoByImei(String imei) {
- return deviceActiveMapper.selectFirstByImei(imei);
- }
-
-}
+package com.yeshi.fanli.service.impl.push;
+
+import com.yeshi.fanli.dao.mybatis.push.DeviceActiveMapper;
+import com.yeshi.fanli.entity.push.DeviceActive;
+import com.yeshi.fanli.service.inter.push.DeviceActiveService;
+import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.mq.cmq.DouYinDeviceActiveCMQManager;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Date;
+
+@Service
+public class DeviceActiveServiceImpl implements DeviceActiveService {
+ @Resource
+ private DeviceActiveMapper deviceActiveMapper;
+
+ @Resource
+ private DouYinDeviceActiveCMQManager douYinDeviceActiveCMQManager;
+
+ @Override
+ public void addDeviceActive(DeviceActive deviceActive) {
+ // 娣诲姞璁板綍
+ if (deviceActive == null)
+ return;
+ if (deviceActive.getPlatform() == null)
+ return;
+
+ if (deviceActive.getVersionCode() == null)
+ return;
+
+ if (StringUtil.isNullOrEmpty(deviceActive.getDevice()))
+ return;
+
+ // Android鐨勫敮涓�鏍囪瘑涓篸evice
+ if (StringUtil.isNullOrEmpty(deviceActive.getDevice()))
+ return;
+ DeviceActive da = deviceActiveMapper.selectByDeviceAndPlatform(deviceActive.getDevice(),
+ deviceActive.getPlatform());
+ if (da == null) {
+ deviceActive.setId(null);
+ if (deviceActive.getUpdateTime() == null)
+ deviceActive.setUpdateTime(new Date());
+ if (deviceActive.getCreateTime() == null)
+ deviceActive.setCreateTime(new Date());
+ if (!StringUtil.isNullOrEmpty(deviceActive.getDeviceToken())) {
+ deviceActive.setDeviceTokenMd5(StringUtil.Md5(deviceActive.getDeviceToken()));
+ }
+
+ deviceActiveMapper.insertSelective(deviceActive);
+ douYinDeviceActiveCMQManager.addDeviceActive(deviceActive.getDevice(),
+ deviceActive.getPlatform());
+ } else {
+ DeviceActive updateDeviceActive = new DeviceActive();
+ updateDeviceActive.setId(da.getId());
+ updateDeviceActive.setUpdateTime(new Date());
+ updateDeviceActive.setVersionCode(deviceActive.getVersionCode());
+ if (StringUtil.isNullOrEmpty(da.getImei()))
+ updateDeviceActive.setImei(deviceActive.getImei());
+ if (!StringUtil.isNullOrEmpty(deviceActive.getDeviceToken())) {
+ updateDeviceActive.setDeviceToken(deviceActive.getDeviceToken());
+ updateDeviceActive.setDeviceTokenMd5(StringUtil.Md5(deviceActive.getDeviceToken()));
+ }
+
+ if (StringUtil.isNullOrEmpty(da.getMac()))
+ updateDeviceActive.setMac(deviceActive.getMac());
+ deviceActiveMapper.updateByPrimaryKeySelective(updateDeviceActive);
+ }
+
+ }
+
+ /**
+ *
+ * @param device
+ * 璁惧鍙�
+ * @param platform
+ * 骞冲彴绫诲瀷
+ * @return
+ */
+ @Override
+ public DeviceActive getDeviceByDeviceAndPlatform(String device, String deviceToken, String platform) {
+
+ DeviceActive deviceActive = null;
+ if ("android".equalsIgnoreCase(platform)) {
+
+ deviceActive = deviceActiveMapper.selectFirstByDeviceAndPlatform(device, DeviceActive.PLATFORM_ANDROID);
+
+ } else if ("ios".equalsIgnoreCase(platform)) {
+
+ deviceActive = deviceActiveMapper.selectFirstByDeviceAndPlatform(device, DeviceActive.PLATFORM_IOS);
+
+ }
+
+ return deviceActive;
+ }
+
+ @Override
+ public DeviceActive getFirstActiveInfo(String device) {
+ return deviceActiveMapper.selectFirst(device);
+ }
+
+ @Override
+ public DeviceActive getFirstActiveInfoByImei(String imei) {
+ return deviceActiveMapper.selectFirstByImei(imei);
+ }
+
+}
--
Gitblit v1.8.0