From cdcbed9af813b2a02cdc01eefa24db8bec6b51a9 Mon Sep 17 00:00:00 2001
From: yujian <yujian>
Date: 星期三, 27 三月 2019 12:17:33 +0800
Subject: [PATCH] 主分类 + 子分类 DAO改造

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/UserMsgController.java |   49 ++++++++++++++++++++++++++++---------------------
 1 files changed, 28 insertions(+), 21 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/UserMsgController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/UserMsgController.java
index 92d54ef..e5a316c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/UserMsgController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/UserMsgController.java
@@ -239,11 +239,10 @@
 		JSONObject data = null;
 		if ("android".equalsIgnoreCase(acceptData.getPlatform())) {
 			data = JSONObject.fromObject(androidBuilder.excludeFieldsWithoutExposeAnnotation().create().toJson(num));
-			data.put("totalCount", totalCount > 99 ? "99+" : totalCount);
 		} else {
 			data = JSONObject.fromObject(JsonUtil.getApiCommonGson().toJson(num));
-			data.put("totalCount", totalCount);
 		}
+		data.put("totalCount", totalCount);
 
 		try {
 			UserSettingsVO vo = userCustomSettingsService.getMySettings(uid);
@@ -296,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++) {
@@ -327,7 +326,7 @@
 					}
 				}
 				try {
-					recommendUserGoodsService.addRecommend(uid, "", goodsList);
+					recommendUserGoodsService.addRecommend(uid, device, "", goodsList);
 				} catch (RecommendUserGoodsException e) {
 					e.printStackTrace();
 				}
@@ -335,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++) {
@@ -366,7 +365,7 @@
 					}
 				}
 				try {
-					recommendUserGoodsService.addRecommend(uid, "", goodsList);
+					recommendUserGoodsService.addRecommend(uid, device, "", goodsList);
 				} catch (RecommendUserGoodsException e) {
 					e.printStackTrace();
 				}
@@ -384,15 +383,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 {
@@ -402,30 +407,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) {
@@ -468,26 +476,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)

--
Gitblit v1.8.0