admin
2019-03-20 435bed78efa8ab34bbf456ef55eb586ccfc113f1
fanli/src/main/java/com/yeshi/fanli/controller/client/UserMsgController.java
@@ -219,9 +219,30 @@
         return;
      }
      UserMsgUnReadNum num = userMsgReadStateService.getReadStateByUid(uid);
      JSONObject data = JSONObject.fromObject(JsonUtil.getApiCommonGson().toJson(num));
      data.put("totalCount", num.getTypeAccount() + num.getTypeInvite() + num.getTypeMoney() + num.getTypeOrder()
            + num.getTypeScore() + num.getTypeSystem()+num.getTypeOther());
      GsonBuilder androidBuilder = new GsonBuilder().registerTypeAdapter(Integer.class,
            new JsonSerializer<Integer>() {
               @Override
               public JsonElement serialize(Integer value, Type theType, JsonSerializationContext context) {
                  if (value == null) {
                     return new JsonPrimitive("0");
                  } else {
                     if (value >= 100)
                        return new JsonPrimitive("99+");
                     else
                        return new JsonPrimitive(value);
                  }
               }
            });
      int totalCount = num.getTypeAccount() + num.getTypeInvite() + num.getTypeMoney() + num.getTypeOrder()
            + num.getTypeScore() + num.getTypeSystem() + num.getTypeOther();
      JSONObject data = null;
      if ("android".equalsIgnoreCase(acceptData.getPlatform())) {
         data = JSONObject.fromObject(androidBuilder.excludeFieldsWithoutExposeAnnotation().create().toJson(num));
      } else {
         data = JSONObject.fromObject(JsonUtil.getApiCommonGson().toJson(num));
      }
      data.put("totalCount", totalCount);
      try {
         UserSettingsVO vo = userCustomSettingsService.getMySettings(uid);
@@ -274,7 +295,7 @@
      return builder;
   }
   private void addRecommendGoods(Long uid, String imei, String idfa) {
   private void addRecommendGoods(Long uid, String device, String imei, String idfa) {
      TaoBaoSearchResult result = TaoKeApiUtil.guessDeviceLike(1, 50, imei, idfa);
      if (result != null && result.getTaoBaoGoodsBriefs() != null) {
         for (int i = 0; i < result.getTaoBaoGoodsBriefs().size(); i++) {
@@ -305,7 +326,7 @@
               }
            }
            try {
               recommendUserGoodsService.addRecommend(uid, "", goodsList);
               recommendUserGoodsService.addRecommend(uid, device, "", goodsList);
            } catch (RecommendUserGoodsException e) {
               e.printStackTrace();
            }
@@ -313,7 +334,7 @@
      }
   }
   private void addRecommendGoods(Long uid) {
   private void addRecommendGoods(Long uid, String device) {
      List<QualityFactory> qfList = qualityFactoryService.listByMinSalesCountOrderByCreateTimeDesc(10000, 1, 20);
      if (qfList != null && qfList != null) {
         for (int i = 0; i < qfList.size(); i++) {
@@ -344,7 +365,7 @@
               }
            }
            try {
               recommendUserGoodsService.addRecommend(uid, "", goodsList);
               recommendUserGoodsService.addRecommend(uid, device, "", goodsList);
            } catch (RecommendUserGoodsException e) {
               e.printStackTrace();
            }
@@ -362,15 +383,18 @@
    */
   @RequestMapping(value = "getHomeMsgList", method = RequestMethod.POST)
   public void getHomeMsgList(AcceptData acceptData, Long uid, int page, HttpSession session, PrintWriter out) {
      if (uid == null) {
         out.print(JsonUtil.loadFalseResult(1, "用户未登录"));
      String device = acceptData.getDevice();
      if (device == null || device.trim().length() == 0) {
         out.print(JsonUtil.loadFalseResult("设备号不能为空"));
         return;
      }
      if (page == 1) {
         boolean canAdd = false;
         int hour = Calendar.getInstance().get(Calendar.HOUR);
         RecommendUserGoods goods = recommendUserGoodsService.getLatestRecommendUserGoods(uid);
         RecommendUserGoods goods = recommendUserGoodsService.getLatestRecommendUserGoodsByDevice(device);
         if (goods == null) {
            canAdd = true;
         } else {
@@ -380,30 +404,32 @@
            }
         }
         String key = "recommend-goods-user-" + uid;
         //String key = "recommend-goods-user-" + uid;
         String key = "recommend-goods-user-" + device;
         if (Constant.IS_OUTNET) {
            if (canAdd && StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {
               if (Constant.IS_OUTNET)
                  redisManager.cacheCommonString(key, "1", 20);
               if (hour < 12)
                  addRecommendGoods(uid);
                  addRecommendGoods(uid, device);
               else
                  addRecommendGoods(uid, acceptData.getImei(), acceptData.getIdfa());
                  addRecommendGoods(uid, device, acceptData.getImei(), acceptData.getIdfa());
               session.removeAttribute("recommendgoods");
            }
         } else {
            if (canAdd) {
               if (hour < 12)
                  addRecommendGoods(uid);
                  addRecommendGoods(uid, device);
               else
                  addRecommendGoods(uid, acceptData.getImei(), acceptData.getIdfa());
                  addRecommendGoods(uid, device, acceptData.getImei(), acceptData.getIdfa());
            }
         }
      }
      List<UserHomeMsgVO> volist = new ArrayList<>();
      List<RecommendUserGoods> list = recommendUserGoodsService.listRecommend(uid, page, Constant.PAGE_SIZE);
      long count = recommendUserGoodsService.countRecommend(uid);//
      List<RecommendUserGoods> list = recommendUserGoodsService.listRecommendGoodsByDevice(device, page, Constant.PAGE_SIZE);
      long count = recommendUserGoodsService.countRecommendGoodsByDevice(device);
      Date now = new Date();
      for (RecommendUserGoods goods : list) {
@@ -446,7 +472,7 @@
         volist.add(vo);
      }
      Long time = userInfoService.selectByPKey(uid).getCreatetime();
      Long time = System.currentTimeMillis();//userInfoService.selectByPKey(uid).getCreatetime();
      if (time > TimeUtil.convertToTimeTemp("2019-01-28", "yyyy-MM-dd"))
         count++;// 计算欢迎语的数量
@@ -465,7 +491,7 @@
      JSONObject root = new JSONObject();
      root.put("msgList", new Gson().toJson(volist));
      if (page == 1) {
      if (page == 1 && uid != null) {
         UserMsgUnReadNum num = userMsgReadStateService.getReadStateByUid(uid);
         UserSystemMsg usm = userSystemMsgService.getLatestUserSystemMsg(uid);
         if (usm != null)
@@ -550,7 +576,7 @@
      UserMsgUnReadNum num = userMsgReadStateService.getReadStateByUid(uid);
      int totalNum = num.getTypeAccount() + num.getTypeInvite() + num.getTypeMoney() + num.getTypeOrder()
            + num.getTypeScore() + num.getTypeSystem();
            + num.getTypeScore() + num.getTypeSystem() + num.getTypeOther();
      if (totalNum == 0) {
         out.print(JsonUtil.loadFalseResult(1, "没有未读消息"));
         return;