| | |
| | | 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.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) { |
| | |
| | | } |
| | | |
| | | deviceActiveMapper.insertSelective(deviceActive); |
| | | DouYinDeviceActiveCMQManager.getInstance().addDeviceActive(deviceActive.getDevice(), |
| | | douYinDeviceActiveCMQManager.addDeviceActive(deviceActive.getDevice(), |
| | | deviceActive.getPlatform()); |
| | | } else { |
| | | DeviceActive updateDeviceActive = new DeviceActive(); |
| | |
| | | |
| | | if (StringUtil.isNullOrEmpty(da.getMac())) |
| | | updateDeviceActive.setMac(deviceActive.getMac()); |
| | | |
| | | deviceActiveMapper.updateByPrimaryKeySelective(updateDeviceActive); |
| | | } |
| | | |