正式数据库修改

admin

2019-03-13 69bee82b81626b82b7f39f0e459e4f56b1699b51

 fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java

@@ -1,12 +1,11 @@
package com.yeshi.fanli.service.impl.push;



import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import net.sf.json.JSONObject;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

@@ -21,14 +20,15 @@
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.service.inter.user.UserCustomSettingsService;

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 {

@@ -38,6 +38,9 @@


   @Resource

   private PushQueueRecordMapper pushQueueRecordMapper;



   @Resource

   private UserCustomSettingsService userCustomSettingsService;



   @Override

   public void pushGoods(Long uid, Long auctionId, String title, String content) throws PushException {

@@ -81,6 +84,10 @@
          * } } });

          */

      } else {

         if (!validateNotDisturbSingle(uid)) {

            return; // 通知免打扰(20:00-24:00 / 00:00 -08:00)

         }



         // IOS 单推

         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid);

         List<String> deviceTokenList = new ArrayList<>();

@@ -135,6 +142,10 @@
          * } catch (Exception e) { PushLogHelper.iosError(e); } } });

          */

      } else {

         if (!validateNotDisturbSingle(uid)) {

            return; // 通知免打扰(20:00-24:00 / 00:00 -08:00)

         }



         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid);

         List<String> deviceTokenList = new ArrayList<>();

         if (deviceTokenIosList != null)

@@ -147,11 +158,6 @@
            PushLogHelper.iosError(e);

         }

      }

   }



   @Override

   public void pushWEEXUrl(Long uid, String weexUrl, String title, String content) throws PushException {



   }



   @Override

@@ -200,6 +206,13 @@
          * } });

          */

      } else if (msg != null) {



         if (uId != null) {

            if (!validateNotDisturbSingle(uId)) {

               return; // 通知免打扰(20:00-24:00 / 00:00 -08:00)

            }

         }



         // 插入推送记录

         PushRecord pushRecord = new PushRecord();

         info.setTitle(msg.getTitle());

@@ -256,6 +269,14 @@
         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);

      }



   }

@@ -352,7 +373,7 @@
               // 结束游标

               pushQueueRecord.setEndCursor(endCursor);



               // TODO 存入数据库

               // 存入数据库

               pushQueueRecordMapper.insert(pushQueueRecord);

               // 加入队列

               CMQManager.getInstance().addIOSPushMsg(pushQueueRecord);

@@ -362,7 +383,6 @@
         }



      } catch (Exception e) {

         // TODO Auto-generated catch block

         e.printStackTrace();

      }



@@ -444,20 +464,36 @@
      JSONObject json = JSONObject.fromObject(jsonContent);



      List<String> tokenList = new ArrayList<>();



      boolean ispush = false;

      List<Long> listNotPushId = null;



      Calendar now = Calendar.getInstance();

      int hour = now.get(Calendar.HOUR_OF_DAY);

      if (hour >= 8 && hour < 20) {

         ispush = true; // 可推送

      } else {

         listNotPushId = validateNotDisturb();

      }



      for (DeviceTokenIOS ios : list) {



         if (!StringUtil.isNullOrEmpty(ios.getDeviceToken())) {

            if (!ispush && listNotPushId != null && listNotPushId.size() > 0) {

               Long uid = ios.getUid();

               if (uid != null && listNotPushId.contains(uid)) {

                  continue; // 通知免打扰(20:00-24:00 / 00:00 -08:00)

               }

            }

            tokenList.add(ios.getDeviceToken());

            // System.out.println(ios.getDeviceToken());

         }

      }



      if (tokenList.size() > 0) {

         // System.out.println(tokenList.size());

         // 执行推送

         try {

            IOSPushUtil.executePushIOS(tokenList, json);

         } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

         }

      }

@@ -465,8 +501,119 @@
      pushQueueRecord.setEndtime(new Date());

      pushQueueRecord.setRecordCursor(recordCursor);



      // TODO 更新数据库

      // 更新数据库

      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);

      }

   }



   @Override

   public void pushWEEX(Long uid, String title, String content, String weexUrl) throws PushException {

      MessageInfo info = new MessageInfo();

      info.setTitle(title);

      info.setContent(content);

      info.setDescription(content);

      // IOS 全推

      if (uid == null || uid == 0) {

         addPushIOSQueue(info, weexUrl, PushController.WEEX);

      } else {

         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid);

         List<String> deviceTokenList = new ArrayList<>();

         if (deviceTokenIosList != null)

            for (DeviceTokenIOS ios : deviceTokenIosList) {

               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, weexUrl, PushController.WEEX);

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

      }

   }



   @Override

   public void pushBaiChuanUrl(Long uid, String title, String content, String url) throws PushException {

      MessageInfo info = new MessageInfo();

      info.setTitle(title);

      info.setContent(content);

      info.setDescription(content);

      // IOS 全推

      if (uid == null || uid == 0) {

         addPushIOSQueue(info, url, PushController.BAICHUAN);

      } else {

         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid);

         List<String> deviceTokenList = new ArrayList<>();

         if (deviceTokenIosList != null)

            for (DeviceTokenIOS ios : deviceTokenIosList) {

               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, url, PushController.BAICHUAN);

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

      }

   }



   /**

    * 通知免打扰(20:00-8:00)

    */

   public List<Long> validateNotDisturb() {

      return userCustomSettingsService.getCancelNoticeUsers();

   }



   /**

    * 通知免打扰(20:00-8:00)

    */

   public boolean validateNotDisturbSingle(Long uid) {

      Calendar now = Calendar.getInstance();

      int hour = now.get(Calendar.HOUR_OF_DAY);

      boolean ispush;

      if (hour >= 8 && hour < 20) {

         ispush = true; // 可推送

      } else {

         // 自定义设置 通知免打扰(20:00-24:00 / 00:00 -08:00)

         ispush = userCustomSettingsService.validateCancelNoticeByUid(uid);

      }



      return ispush;

   }



   @Override

   public void pushWelfareCenter(Long uid, String title, String content) throws PushException {

      MessageInfo info = new MessageInfo();

      info.setTitle(title);

      info.setContent(content);

      info.setDescription(content);

      // IOS 全推

      if (uid == null || uid == 0) {

         addPushIOSQueue(info, "", PushController.WELFARE_CENTER);

      } else {

         if (!validateNotDisturbSingle(uid)) {

            return;

         }

         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid);

         List<String> deviceTokenList = new ArrayList<>();

         if (deviceTokenIosList != null)

            for (DeviceTokenIOS ios : deviceTokenIosList) {

               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, "", PushController.WELFARE_CENTER);

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

      }

   }



}