admin
2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe
fanli/src/main/java/com/yeshi/fanli/service/impl/push/DeviceTokenOPPOServiceImpl.java
@@ -1,65 +1,77 @@
package com.yeshi.fanli.service.impl.push;
import java.util.Date;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import com.yeshi.fanli.dao.mybatis.push.DeviceTokenOPPOMapper;
import com.yeshi.fanli.entity.push.DeviceTokenOPPO;
import com.yeshi.fanli.service.inter.push.DeviceTokenOPPOService;
import com.yeshi.fanli.util.StringUtil;
@Service
public class DeviceTokenOPPOServiceImpl implements DeviceTokenOPPOService {
   @Resource
   private DeviceTokenOPPOMapper deviceTokenOPPOMapper;
   @Override
   public void addDeviceTokenOPPO(DeviceTokenOPPO oppo) {
      if (oppo == null || oppo.getDeviceActiveId() == null || StringUtil.isNullOrEmpty(oppo.getRegisterId()))
         return;
      DeviceTokenOPPO oldOppo = deviceTokenOPPOMapper.selectByDeviceActiveId(oppo.getDeviceActiveId());
      if (oldOppo == null) {
         if (oppo.getCreateTime() == null)
            oppo.setCreateTime(new Date());
         deviceTokenOPPOMapper.insertSelective(oppo);
      } else {
         DeviceTokenOPPO update = new DeviceTokenOPPO();
         update.setId(oldOppo.getId());
         update.setRegisterId(oppo.getRegisterId());
         update.setUpdateTime(oppo.getUpdateTime());
         update.setUid(oppo.getUid());
         deviceTokenOPPOMapper.updateByPrimaryKeySelective(update);
      }
   }
   @Override
   public void unBindUid(Long uid, Long deviceActiveId) {
      DeviceTokenOPPO oldOppo = deviceTokenOPPOMapper.selectByDeviceActiveId(deviceActiveId);
      if (oldOppo != null) {
         oldOppo.setUid(null);
         oldOppo.setUpdateTime(new Date());
         deviceTokenOPPOMapper.updateByPrimaryKey(oldOppo);
      }
   }
   @Override
   public long countDeviceToken(List<Integer> versionList) {
      return deviceTokenOPPOMapper.countDeviceToken(versionList);
   }
   @Override
   public List<DeviceTokenOPPO> listDeviceToken(int page, int pageSize, List<Integer> versionList) {
      return deviceTokenOPPOMapper.listDeviceToken((page - 1) * pageSize, pageSize, versionList);
   }
   @Override
   public List<DeviceTokenOPPO> listByUid(Long uid, List<Integer> verisonList) {
      return deviceTokenOPPOMapper.listByUid(uid, verisonList);
   }
}
package com.yeshi.fanli.service.impl.push;
import java.util.Date;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import com.yeshi.fanli.dao.mybatis.push.DeviceTokenOPPOMapper;
import com.yeshi.fanli.entity.push.DeviceTokenOPPO;
import com.yeshi.fanli.service.inter.push.DeviceTokenOPPOService;
import com.yeshi.fanli.util.StringUtil;
@Service
public class DeviceTokenOPPOServiceImpl implements DeviceTokenOPPOService {
   @Resource
   private DeviceTokenOPPOMapper deviceTokenOPPOMapper;
   @Override
   public void addDeviceTokenOPPO(DeviceTokenOPPO oppo) {
      if (oppo == null || oppo.getDeviceActiveId() == null || StringUtil.isNullOrEmpty(oppo.getRegisterId()))
         return;
      DeviceTokenOPPO oldOppo = deviceTokenOPPOMapper.selectByDeviceActiveId(oppo.getDeviceActiveId());
      if (oldOppo == null) {
         if (oppo.getCreateTime() == null)
            oppo.setCreateTime(new Date());
         deviceTokenOPPOMapper.insertSelective(oppo);
      } else {
         DeviceTokenOPPO update = new DeviceTokenOPPO();
         update.setId(oldOppo.getId());
         update.setRegisterId(oppo.getRegisterId());
         update.setUpdateTime(oppo.getUpdateTime());
         update.setUid(oppo.getUid());
         deviceTokenOPPOMapper.updateByPrimaryKeySelective(update);
      }
   }
   @Override
   public void unBindUid(Long uid, Long deviceActiveId) {
      DeviceTokenOPPO oldOppo = deviceTokenOPPOMapper.selectByDeviceActiveId(deviceActiveId);
      if (oldOppo != null) {
         oldOppo.setUid(null);
         oldOppo.setUpdateTime(new Date());
         deviceTokenOPPOMapper.updateByPrimaryKey(oldOppo);
      }
   }
   @Override
   public void bindUid(Long uid, Long deviceActiveId) {
      DeviceTokenOPPO oldOppo = deviceTokenOPPOMapper.selectByDeviceActiveId(deviceActiveId);
      if (oldOppo != null) {
         DeviceTokenOPPO update = new DeviceTokenOPPO();
         update.setId(oldOppo.getId());
         update.setUid(uid);
         update.setUpdateTime(new Date());
         deviceTokenOPPOMapper.updateByPrimaryKeySelective(update);
      }
   }
   @Override
   public long countDeviceToken(List<Integer> versionList, Date minUpdateTime) {
      return deviceTokenOPPOMapper.countDeviceToken(versionList,minUpdateTime);
   }
   @Override
   public List<DeviceTokenOPPO> listDeviceToken(int page, int pageSize, List<Integer> versionList, Date minUpdateTime) {
      return deviceTokenOPPOMapper.listDeviceToken((page - 1) * pageSize, pageSize, versionList,minUpdateTime);
   }
   @Override
   public List<DeviceTokenOPPO> listByUid(Long uid, List<Integer> verisonList) {
      return deviceTokenOPPOMapper.listByUid(uid, verisonList);
   }
}