admin
2019-09-19 b469ab33391a3c2c0a031e17eea5de7a069f0c67
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,6 +45,8 @@
         }
         deviceActiveMapper.insertSelective(deviceActive);
         DouYinDeviceActiveCMQManager.getInstance().addDeviceActive(deviceActive.getDevice(),
               deviceActive.getPlatform());
      } else {
         DeviceActive updateDeviceActive = new DeviceActive();
         updateDeviceActive.setId(da.getId());
@@ -72,15 +75,20 @@
      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.selectByDeviceAndPlatform(device, DeviceActive.PLATFORM_IOS);
         deviceActive = deviceActiveMapper.selectFirstByDeviceAndPlatform(device, DeviceActive.PLATFORM_IOS);
      }
      return deviceActive;
   }
   @Override
   public DeviceActive getFirstActiveInfo(String device) {
      return deviceActiveMapper.selectFirst(device);
   }
}