yujian
2019-01-22 88b54772dbcf5ecab1e2316e4e4626ac901b8908
fanli/src/main/java/com/yeshi/fanli/controller/client/PushController.java
@@ -6,9 +6,6 @@
import javax.annotation.Resource;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -17,14 +14,13 @@
import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.common.JumpDetailV2;
import com.yeshi.fanli.entity.goods.CommonGoods;
import com.yeshi.fanli.entity.push.DeviceActive;
import com.yeshi.fanli.entity.push.DeviceTokenIOS;
import com.yeshi.fanli.entity.push.PushGoods;
import com.yeshi.fanli.entity.push.PushGoodsGroup;
import com.yeshi.fanli.entity.push.PushGoodsRecord;
import com.yeshi.fanli.entity.system.System;
import com.yeshi.fanli.exception.push.PushGoodsGroupException;
import com.yeshi.fanli.goods.CommonGoods;
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SystemService;
@@ -39,6 +35,9 @@
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.factory.JumpDetailParamsFactory;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
@Controller
@RequestMapping(value = "api/v1/push")
@@ -58,25 +57,25 @@
   @Resource
   private DeviceActiveService deviceActiveService;
   @Resource
   private PushService pushService;
   @Resource
   private PushGoodsService PushGoodsService;
   @Resource
   private PushGoodsGroupService pushGoodsGroupService;
   @Resource
   private PushGoodsRecordService pushGoodsRecordService;
   @Resource
   private JumpDetailV2Service jumpDetailV2Service;
   @Resource
   private ConfigService configService;
   @Resource(name = "taskExecutor")
   private TaskExecutor executor;
@@ -111,16 +110,10 @@
         da.setDeviceToken(deviceToken);
         da.setPlatform(DeviceActive.PLATFORM_IOS);
         da.setVersionCode(Integer.parseInt(acceptData.getVersion()));
         da.setDevice(acceptData.getDevice());
         deviceActiveService.addDeviceActive(da);
         DeviceTokenIOS deviceTokenIOS = iosPushService.getDeviceTokenByDeviceToken(deviceToken);
         if (deviceTokenIOS == null)
            iosPushService.addDeviceToken(null, Integer.parseInt(acceptData.getVersion()), deviceToken,
                  acceptData.getDevice());
         else {
            deviceTokenIOS.setDevice(acceptData.getDevice());
            iosPushService.updateDeviceToken(deviceTokenIOS);
         }
         iosPushService.addDeviceToken(null, Integer.parseInt(acceptData.getVersion()), deviceToken,
               acceptData.getDevice());
         out.print(JsonUtil.loadTrue(0, null, "成功"));
      }
   }
@@ -141,19 +134,11 @@
         da.setDeviceToken(deviceToken);
         da.setPlatform(DeviceActive.PLATFORM_IOS);
         da.setVersionCode(Integer.parseInt(acceptData.getVersion()));
         da.setDevice(acceptData.getDevice());
         deviceActiveService.addDeviceActive(da);
         // 添加token
         DeviceTokenIOS deviceTokenIOS = iosPushService.getDeviceTokenByDeviceToken(deviceToken);
         if (deviceTokenIOS != null) {
            deviceTokenIOS.setUid(uid);
            deviceTokenIOS.setDevice(acceptData.getDevice());
            deviceTokenIOS.setVersion(Integer.parseInt(acceptData.getVersion()));
            iosPushService.updateDeviceToken(deviceTokenIOS);
         } else {
            iosPushService.addDeviceToken(uid, Integer.parseInt(acceptData.getVersion()), deviceToken,
                  acceptData.getDevice());
         }
         out.print(JsonUtil.loadTrueResult(""));
         iosPushService.addDeviceToken(uid, Integer.parseInt(acceptData.getVersion()), deviceToken,
               acceptData.getDevice());
      }
   }
@@ -165,12 +150,8 @@
    */
   @RequestMapping(value = "/unBind", method = RequestMethod.POST)
   public void unBind(AcceptData acceptData, String deviceToken, PrintWriter out) {
      if (!StringUtil.isNullOrEmpty(deviceToken)) {
         DeviceTokenIOS deviceTokenIOS = iosPushService.getDeviceTokenByDeviceToken(deviceToken);
         if (deviceTokenIOS != null) {
            deviceTokenIOS.setUid(null);
            iosPushService.updateDeviceToken(deviceTokenIOS);
         }
      if (!StringUtil.isNullOrEmpty(acceptData.getDevice())) {
         iosPushService.unBindUidAndDevice(acceptData.getDevice());
         out.print(JsonUtil.loadTrue(0, null, "解绑成功"));
      }
   }
@@ -202,8 +183,7 @@
      deviceTokenHWService.unBindDeviceToken(acceptData.getDevice());
      out.print(JsonUtil.loadTrueResult("成功"));
   }
   /**
    * 解绑推送
    * 
@@ -272,16 +252,15 @@
               String fontColor1 = "#666666";
               String fontColor2 = "#E5005C";
               JSONArray array = new JSONArray();
               JSONObject contentJson1 = new JSONObject();
               contentJson1.put("color", fontColor1);
               contentJson1.put("content", "本次推荐共");
               JSONObject contentJson2 = new JSONObject();
               contentJson2.put("color", fontColor2);
               contentJson2.put("content", totalgoods);
               JSONObject contentJson3 = new JSONObject();
               contentJson3.put("color", fontColor1);
               contentJson3.put("content", "个商品");
@@ -339,8 +318,8 @@
                  Long deviceId = deviceActive.getId();
                  for (PushGoods pushGoods : listPush) {
                     List<PushGoodsRecord> listRecord = pushGoodsRecordService.listByPushIdAndDeviceId(
                           pushGoods.getId(), deviceId);
                     List<PushGoodsRecord> listRecord = pushGoodsRecordService
                           .listByPushIdAndDeviceId(pushGoods.getId(), deviceId);
                     if (listRecord != null && listRecord.size() > 0) {
                        continue; // 已被记录
                     }
@@ -361,5 +340,5 @@
         });
      }
   }
}