admin
2019-09-11 cf9f918e7af7481432cfc93eaac38bcb3d4cbfd8
fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserMsgController.java
@@ -43,6 +43,7 @@
import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail;
import com.yeshi.fanli.entity.bus.msg.UserMsgUnReadNum;
import com.yeshi.fanli.entity.bus.msg.UserSystemMsg;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.entity.common.JumpDetailV2;
import com.yeshi.fanli.entity.goods.CommonGoods;
import com.yeshi.fanli.entity.goods.RecommendUserGoods;
@@ -72,6 +73,7 @@
import com.yeshi.fanli.service.inter.push.DeviceActiveService;
import com.yeshi.fanli.service.inter.push.PushGoodsService;
import com.yeshi.fanli.service.inter.user.UserCustomSettingsService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.RedisManager;
@@ -154,6 +156,9 @@
   @Resource
   private MsgDeviceReadStateService msgDeviceReadStateService;
   @Resource
   private UserInfoExtraService userInfoExtraService;
   // 消息的类型
   final static String MSG_TYPE_ORDER = "order";
@@ -262,6 +267,7 @@
    * @param uid
    * @param out
    */
   @RequestSerializableByKey(key = "#acceptData.device")
   @RequestMapping(value = "getUnReadMsgCount", method = RequestMethod.POST)
   public void getUnReadMsgCount(AcceptData acceptData, Long uid, PrintWriter out) {
      GsonBuilder androidBuilder = new GsonBuilder().registerTypeAdapter(Integer.class,
@@ -310,7 +316,7 @@
                  "android".equalsIgnoreCase(acceptData.getPlatform()) ? 1 : 2, MsgDeviceReadState.TYPE_KEFU);
            data.put("totalCount", totalCount);
         }
         data.put("mineCount", 0);
         out.print(JsonUtil.loadTrueResult(data));
         return;
      }
@@ -332,6 +338,18 @@
         data = JSONObject.fromObject(JsonUtil.getApiCommonGson().toJson(num));
      }
      data.put("totalCount", totalCount);
      // "我的"选项角标
      int welfareCenterNews = 0;
      if (uid != null) {
         UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
         if (userInfoExtra != null) {
            if (userInfoExtra.getCouponNews() != null) {
               welfareCenterNews = userInfoExtra.getCouponNews();
            }
         }
      }
      data.put("mineCount", welfareCenterNews);
      try {
         UserSettingsVO vo = userCustomSettingsService.getMySettings(uid);
@@ -474,6 +492,9 @@
   public void getHomeMsgList(AcceptData acceptData, Long uid, int page, HttpSession session, PrintWriter out) {
      if (uid != null && uid == 0)
         uid = null;
      if (uid != null)
         userSystemMsgService.syncSystemZNX(uid);
      String device = acceptData.getDevice();
      if (device == null || device.trim().length() == 0) {
         out.print(JsonUtil.loadFalseResult("设备号不能为空"));
@@ -636,11 +657,14 @@
    * @param type
    * @param out
    */
   @RequestSerializableByKey(key="#acceptData.device")
   @RequestSerializableByKey(key = "#acceptData.device")
   @RequestMapping(value = "getHomeMsgListNew", method = RequestMethod.POST)
   public void getHomeMsgListNew(AcceptData acceptData, Long uid, PrintWriter out) {
      if (uid != null && uid == 0)
         uid = null;
      if (uid != null) {
         userSystemMsgService.syncSystemZNX(uid);
      }
      List<UserMsgCenter> listCenter = new ArrayList<>();
@@ -720,7 +744,9 @@
      // list = pushGoodsService.listHistoryByPushTime(0, 1, uid, createTime);
      // 1、活动区域
      List<Special> listSpecial = specialService.listByPlaceKey("msg_activities");
      int platformCode = Constant.getPlatformCode(acceptData.getPlatform());
      List<Special> listSpecial = specialService.listByPlaceKey("msg_activities", platformCode, Integer.parseInt(acceptData.getVersion()));
      if (listSpecial != null && listSpecial.size() > 0) {
         for (Special special : listSpecial) {