1.5.3部分需求 提交

yujian

2019-04-08 1da17d215d48e3e3aa9e8d7a3ef526904764f408

 fanli/src/main/java/com/yeshi/fanli/controller/client/UserMsgController.java

@@ -5,9 +5,13 @@
import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Collections;

import java.util.Comparator;

import java.util.Date;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;



import javax.annotation.Resource;

@@ -27,6 +31,7 @@
import com.google.gson.JsonSerializationContext;

import com.google.gson.JsonSerializer;

import com.yeshi.fanli.entity.accept.AcceptData;

import com.yeshi.fanli.entity.bus.homemodule.Special;

import com.yeshi.fanli.entity.bus.lable.QualityFactory;

import com.yeshi.fanli.entity.bus.msg.MsgAccountDetail;

import com.yeshi.fanli.entity.bus.msg.MsgInviteDetail;

@@ -37,14 +42,17 @@
import com.yeshi.fanli.entity.bus.msg.UserSystemMsg;

import com.yeshi.fanli.entity.goods.CommonGoods;

import com.yeshi.fanli.entity.goods.RecommendUserGoods;

import com.yeshi.fanli.entity.system.BusinessSystem;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;

import com.yeshi.fanli.exception.goods.CommonGoodsException;

import com.yeshi.fanli.exception.goods.RecommendUserGoodsException;

import com.yeshi.fanli.exception.msg.UserSystemMsgException;

import com.yeshi.fanli.exception.user.UserCustomSettingsException;

import com.yeshi.fanli.service.inter.config.BusinessSystemService;

import com.yeshi.fanli.service.inter.goods.CommonGoodsService;

import com.yeshi.fanli.service.inter.goods.RecommendUserGoodsService;

import com.yeshi.fanli.service.inter.homemodule.SpecialService;

import com.yeshi.fanli.service.inter.lable.QualityFactoryService;

import com.yeshi.fanli.service.inter.msg.MsgAccountDetailService;

import com.yeshi.fanli.service.inter.msg.MsgInviteDetailService;

@@ -63,6 +71,7 @@
import com.yeshi.fanli.util.factory.msg.UserMsgVOFactory;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

import com.yeshi.fanli.vo.msg.UserHomeMsgVO;

import com.yeshi.fanli.vo.msg.UserMsgCenter;

import com.yeshi.fanli.vo.msg.UserMsgVO;

import com.yeshi.fanli.vo.msg.UserSystemMsgVO;

import com.yeshi.fanli.vo.user.UserSettingsVO;

@@ -73,6 +82,8 @@
@RequestMapping("api/v1/user/msg")

public class UserMsgController {



   @Resource

   private BusinessSystemService businessSystemService;

   @Resource

   private MsgOrderDetailService msgOrderDetailService;



@@ -111,6 +122,10 @@


   @Resource

   private RedisManager redisManager;

	
   @Resource

   private SpecialService specialService;

	


   // 消息的类型

   final static String MSG_TYPE_ORDER = "order";

@@ -295,7 +310,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++) {

@@ -326,7 +341,7 @@
               }

            }

            try {

               recommendUserGoodsService.addRecommend(uid, "", goodsList);

               recommendUserGoodsService.addRecommend(uid, device, "", goodsList);

            } catch (RecommendUserGoodsException e) {

               e.printStackTrace();

            }

@@ -334,7 +349,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++) {

@@ -365,7 +380,7 @@
               }

            }

            try {

               recommendUserGoodsService.addRecommend(uid, "", goodsList);

               recommendUserGoodsService.addRecommend(uid, device, "", goodsList);

            } catch (RecommendUserGoodsException e) {

               e.printStackTrace();

            }

@@ -383,15 +398,21 @@
    */

   @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) {

         if (uid != null)

            recommendUserGoodsService.syncDeviceAndUid(uid, acceptData.getDevice());



         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 {

@@ -401,30 +422,33 @@
            }

         }



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

@@ -467,26 +491,25 @@
         volist.add(vo);

      }



      Long time = userInfoService.selectByPKey(uid).getCreatetime();

      if (time > TimeUtil.convertToTimeTemp("2019-01-28", "yyyy-MM-dd"))

         count++;// 计算欢迎语的数量

      Long time = (uid == null ? System.currentTimeMillis() : userInfoService.selectByPKey(uid).getCreatetime());



      if (volist.size() > 0 && volist.size() < Constant.PAGE_SIZE) {

         // 添加欢迎语

         // 创建时间在28号后的才有新人欢迎

         if (time > TimeUtil.convertToTimeTemp("2019-01-28", "yyyy-MM-dd")) {

         if ((time > TimeUtil.convertToTimeTemp("2019-01-28", "yyyy-MM-dd") || uid == null)) {

            UserHomeMsgVO vo = new UserHomeMsgVO();

            vo.setContent("恭喜你，成为返利券的用户\n独家优惠券帮你省钱；\n参与奖金活动帮你赚钱；\n让返利券成为你的省钱助手吧！");

            vo.setTitle("新人欢迎");

            vo.setCreateTime(getTimeDesc(now, new Date(time)));

            vo.setType(UserHomeMsgVO.TYPE_WELCOME);

            volist.add(vo);

            count++;

         }

      }



      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)

@@ -499,7 +522,151 @@
      root.put("count", count);

      out.print(JsonUtil.loadTrueResult(root));

   }

	
	
   /**

    * 获取消息列表

    * 
    * @param acceptData

    * @param uid

    * @param page

    * @param type

    * @param out

    */

   @RequestMapping(value = "getHomeMsgListNew", method = RequestMethod.POST)

   public void getHomeMsgListNew(AcceptData acceptData, Long uid, PrintWriter out) {



      if (uid == null) {

         out.print(JsonUtil.loadFalseResult(1, "用户未登录"));

         return;

      }

		
      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),

            acceptData.getPackages());

      if (system == null) {

         out.print(JsonUtil.loadFalseResult(1, "系统不存在"));

         return;

      }

		
      int page = 1;

      List<UserMsgVO> list = new ArrayList<>();

      List<MsgOrderDetail> detailList = msgOrderDetailService.listMsgOrderDetail(uid, page);

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

         for (MsgOrderDetail detail : detailList) {

            list.add(UserMsgVOFactory.create(detail));

         }

      }



      List<MsgMoneyDetail> detailList1 = msgMoneyDetailService.listMsgMoneyDetail(uid, page);

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

         for (MsgMoneyDetail detail : detailList1) {

            list.add(UserMsgVOFactory.create(detail));

         }

      }



      List<MsgAccountDetail> detailList2 = msgAccountDetailService.listMsgAccountDetail(uid, page);

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

         for (MsgAccountDetail detail : detailList2) {

            list.add(UserMsgVOFactory.create(detail));

         }

      }



      List<MsgInviteDetail> detailList3 = msgInviteDetailService.listMsgInviteDetail(uid, page);

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

         for (MsgInviteDetail detail : detailList3) {

            UserMsgVO vo = UserMsgVOFactory.create(detail);

            if (vo != null) {

               list.add(vo);

            }

         }

      }



      List<MsgOtherDetail> detailList4 = msgOtherDetailService.listMsgOtherDetail(uid, page);

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

         for (MsgOtherDetail detail : detailList4) {

            UserMsgVO vo = UserMsgVOFactory.create(detail);

            if (vo != null) {

               list.add(vo);

            }

         }

      }

		
      List<UserMsgCenter> listCenter = new ArrayList<>();

		
      List<Special> listSpecial = specialService.listBySystemAndCard("", system.getId());

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

         for (Special special: listSpecial) {

            UserMsgCenter msgCenter = new UserMsgCenter();

            msgCenter.setSpecial(special);

            listCenter.add(msgCenter);

         }

      }

		
      if (list.size() > 0 ) {

         // 时间排序

         listSort(list);

			
         if (list.size() <= 20 ) {

				
         } else {

            list = list.subList(0, 19);

         }

			
         for (UserMsgVO userMsgVO: list) {

            UserMsgCenter userMsgCenter = new UserMsgCenter();

            userMsgCenter.setUserMsg(userMsgVO);

            listCenter.add(userMsgCenter);

         }

      }

		
		
      // 添加欢迎语

      Long time = (uid == null ? System.currentTimeMillis() : userInfoService.selectByPKey(uid).getCreatetime());

      // 创建时间在28号后的才有新人欢迎

      if ((time > TimeUtil.convertToTimeTemp("2019-01-28", "yyyy-MM-dd") || uid == null)) {

         Map<String, Object> map = new HashMap<String, Object>();

         map.put("title", "新人欢迎");

         map.put("content", "恭喜你，成为返利券的用户\n独家优惠券帮你省钱；\n参与奖金活动帮你赚钱；\n让返利券成为你的省钱助手吧！");

         map.put("createTime",new Date(time));

         UserMsgCenter msgCenternre = new UserMsgCenter();

         msgCenternre.setWelcomeMsg(map);

         listCenter.add(msgCenternre);

      }

		
      GsonBuilder builder = new GsonBuilder();

      builder = getTimeDescJsonBuilder(builder);

		
      JSONObject root = new JSONObject();

		
      UserMsgUnReadNum num = userMsgReadStateService.getReadStateByUid(uid);

      UserSystemMsg usm = userSystemMsgService.getLatestUserSystemMsg(uid);

      if (usm != null) {

         root.put("systemMsg", new UserSystemMsgVO(usm.getId(), usm.getType().name(), usm.getSolved(), "系统消息", usm.getTitle(),

            usm.getTimeTag() == 1 ? "http://img.flqapp.com/resource/msg/icon_emergent.png" : "", "http://img.flqapp.com/resource/msg/icon_msg_system.png",getTimeDesc(new Date(), usm.getCreateTime()), num.getTypeSystem()));

      }

		
      root.put("list", builder.create().toJson(listCenter));

      root.put("count", listCenter.size());

      out.print(JsonUtil.loadTrueResult(root));

   }





   public static void listSort(List<UserMsgVO> list) {

      Collections.sort(list, new Comparator<UserMsgVO>() {

         @Override

         public int compare(UserMsgVO o1, UserMsgVO o2) {

            if (o1.getTime().getTime() > o2.getTime().getTime()) {

               return -1;

            } else if (o1 == o2) {

               return 0;

            } else {

               return 1;

            }

         }

      });

   }

	
	
   /**

    * 获取系统消息列表

    *