admin
2018-12-10 01d627f3c67e2bc5c28b2dd5e23983ddcf7a08f3
fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java
@@ -6,8 +6,6 @@
import javax.annotation.Resource;
import net.sf.json.JSONObject;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -21,14 +19,14 @@
import com.yeshi.fanli.entity.xinge.MessageInfo;
import com.yeshi.fanli.entity.xinge.PushRecord;
import com.yeshi.fanli.exception.PushException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.log.PushLogHelper;
import com.yeshi.fanli.service.inter.push.IOSPushService;
import com.yeshi.fanli.util.CMQManager;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.ThreadUtil;
import com.yeshi.fanli.util.push.IOSPushUtil;
import net.sf.json.JSONObject;
@Service
public class IOSPushServiceImpl implements IOSPushService {
@@ -241,7 +239,7 @@
   @Override
   public void addDeviceToken(Long uid, int version, String deviceToken, String device) {
      // 如果device为空就返回
      if (StringUtil.isNullOrEmpty(device))
      if (StringUtil.isNullOrEmpty(device) || StringUtil.isNullOrEmpty(deviceToken))
         return;
      // 判断device是否存在
@@ -252,9 +250,18 @@
         deviceTokenIos.setUpdateTime(new Date());
         deviceTokenIos.setDevice(device);
         deviceTokenIos.setDeviceToken(deviceToken);
         deviceTokenIos.setDeviceTokenMd5(StringUtil.Md5(deviceToken));
         deviceTokenIos.setUid(uid);
         deviceTokenIos.setVersion(version);
         deviceTokenIOSMapper.insertSelective(deviceTokenIos);
      } else {// 更新devicetoken
         DeviceTokenIOS updateDeviceTokenIOS = new DeviceTokenIOS();
         updateDeviceTokenIOS.setId(deviceTokenIos.getId());
         updateDeviceTokenIOS.setDeviceToken(deviceToken);
         updateDeviceTokenIOS.setDeviceTokenMd5(StringUtil.Md5(deviceToken));
         updateDeviceTokenIOS.setUid(uid);
         updateDeviceTokenIOS.setUpdateTime(new Date());
         deviceTokenIOSMapper.updateByPrimaryKeySelective(updateDeviceTokenIOS);
      }
   }
@@ -288,8 +295,8 @@
   }
   @Override
   public DeviceTokenIOS getDeviceTokenByDevice(String device) {
      return deviceTokenIOSMapper.selectByDevice(device);
   public DeviceTokenIOS getDeviceTokenByDeviceToken(String deviceToken) {
      return deviceTokenIOSMapper.selectByDeviceToken(deviceToken);
   }
   /**
@@ -468,4 +475,16 @@
      pushQueueRecordMapper.updateByPrimaryKeySelective(pushQueueRecord);
   }
   @Override
   public void unBindUidAndDevice(String device) {
      if (StringUtil.isNullOrEmpty(device))
         return;
      DeviceTokenIOS deviceTokenIOS = deviceTokenIOSMapper.selectByDevice(device);
      if (device != null) {
         deviceTokenIOS.setUpdateTime(new Date());
         deviceTokenIOS.setUid(null);
         deviceTokenIOSMapper.updateByPrimaryKey(deviceTokenIOS);
      }
   }
}