From b9f8ef2c4737b6e6be4b12fc8f7bafb033bfcfe5 Mon Sep 17 00:00:00 2001 From: admin <2780501319@qq.com> Date: 星期日, 22 九月 2019 16:47:33 +0800 Subject: [PATCH] 金币BUG修改 --- fanli/src/main/java/com/yeshi/fanli/service/impl/push/DeviceActiveServiceImpl.java | 20 +++++++++++++++++--- 1 files changed, 17 insertions(+), 3 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 d99ce29..d645020 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 @@ -10,6 +10,7 @@ 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 { @@ -44,11 +45,15 @@ } 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())); @@ -72,16 +77,25 @@ DeviceActive deviceActive = null; if ("android".equalsIgnoreCase(platform)) { - deviceActive = deviceActiveMapper.selectByDeviceAndPlatform(device, DeviceActive.PLATFORM_ANDROID); + deviceActive = deviceActiveMapper.selectFirstByDeviceAndPlatform(device, DeviceActive.PLATFORM_ANDROID); } else if ("ios".equalsIgnoreCase(platform)) { - deviceActive = deviceActiveMapper.selectByDeviceToeknMd5AndPlatform(StringUtil.Md5(deviceToken), - DeviceActive.PLATFORM_IOS); + 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