From d8359ddb48dab5cc797a9d552e11fde571f4920c Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期二, 27 八月 2019 12:32:46 +0800
Subject: [PATCH] Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

---
 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserMsgController.java |   57 ++++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 54 insertions(+), 3 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserMsgController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserMsgController.java
index dbb57f0..da9a5ab 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserMsgController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserMsgController.java
@@ -39,9 +39,11 @@
 import com.yeshi.fanli.entity.bus.msg.MsgInviteDetail;
 import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail;
 import com.yeshi.fanli.entity.bus.msg.MsgOrderDetail;
+import com.yeshi.fanli.entity.bus.msg.MsgOrderDetail.MsgTypeOrderTypeEnum;
 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;
@@ -71,12 +73,15 @@
 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;
 import com.yeshi.fanli.util.StringUtil;
 import com.yeshi.fanli.util.TimeUtil;
 import com.yeshi.fanli.util.VersionUtil;
+import com.yeshi.fanli.util.account.UserUtil;
+import com.yeshi.fanli.util.annotation.RequestSerializableByKey;
 import com.yeshi.fanli.util.factory.CommonGoodsFactory;
 import com.yeshi.fanli.util.factory.msg.UserMsgVOFactory;
 import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
@@ -152,6 +157,9 @@
 	@Resource
 	private MsgDeviceReadStateService msgDeviceReadStateService;
 
+	@Resource
+	private UserInfoExtraService userInfoExtraService;
+
 	// 娑堟伅鐨勭被鍨�
 	final static String MSG_TYPE_ORDER = "order";
 	final static String MSG_TYPE_MONEY = "money";
@@ -193,6 +201,9 @@
 				for (MsgOrderDetail detail : detailList) {
 					JSONObject params = new JSONObject();
 					params.put("orderNo", detail.getOrderId());
+					if (detail.getType() == MsgTypeOrderTypeEnum.share
+							|| detail.getType() == MsgTypeOrderTypeEnum.invite)
+						params.put("orderHideNo", UserUtil.filterOrderId(detail.getOrderId()));
 					list.add(UserMsgVOFactory.create(detail, jumpDetailV2Service.getByTypeCache("order_search"),
 							params));
 				}
@@ -256,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,
@@ -304,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;
 		}
@@ -326,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);
@@ -630,6 +654,7 @@
 	 * @param type
 	 * @param out
 	 */
+	@RequestSerializableByKey(key = "#acceptData.device")
 	@RequestMapping(value = "getHomeMsgListNew", method = RequestMethod.POST)
 	public void getHomeMsgListNew(AcceptData acceptData, Long uid, PrintWriter out) {
 		if (uid != null && uid == 0)
@@ -699,11 +724,11 @@
 						acceptData.getPlatform().equalsIgnoreCase("android") ? 1 : 2);
 				boolean read = false;
 				if (state != null && state.getReadTime() != null
-						&& list.get(0).getCreateTime().getTime() < state.getReadTime().getTime())
+						&& list.get(0).getPushTime().getTime() < state.getReadTime().getTime())
 					read = true;
 
 				commonMsgList.add(new UserCommonMsgVO("http://img.flqapp.com/resource/msg/icon_recommend.png", "鎺ㄨ崘璁板綍",
-						list.get(0).getCreateTime(), UserCommonMsgVO.TYPE_RECOMMEND, list.get(0).getContent(), read,
+						list.get(0).getPushTime(), UserCommonMsgVO.TYPE_RECOMMEND, list.get(0).getContent(), read,
 						jumpDetailV2Service.getByTypeCache("recommend_list"), null, 0));
 			}
 		}
@@ -739,6 +764,9 @@
 				for (MsgOrderDetail detail : detailList) {
 					JSONObject params = new JSONObject();
 					params.put("orderNo", detail.getOrderId());
+					if (detail.getType() == MsgTypeOrderTypeEnum.share
+							|| detail.getType() == MsgTypeOrderTypeEnum.invite)
+						params.put("orderHideNo", UserUtil.filterOrderId(detail.getOrderId()));
 					UserMsgVO userMsgVO = UserMsgVOFactory.create(detail,
 							jumpDetailV2Service.getByTypeCache("order_search"), params);
 					userMsgVO.setType(MSG_TYPE_ORDER);
@@ -834,6 +862,29 @@
 			}
 		}
 
+		/**
+		 * 鎻愰啋澶у浘
+		 */
+		MsgCommonDTO notify = msgConfigService.getNotifyMsg();
+
+		if (notify != null && notify.getShow() == true) {
+			boolean read = false;
+			MsgDeviceReadState state = msgDeviceReadStateService.getByDeviceAndPlatformAndType(
+					UserCommonMsgVO.TYPE_NOTIFY, acceptData.getDevice(),
+					acceptData.getPlatform().equalsIgnoreCase("android") ? 1 : 2);
+			if (state != null && state.getReadTime() != null
+					&& zhuShouMsg.getUpdateTime().getTime() < state.getReadTime().getTime())
+				read = true;
+			if (notify.getJumpDetail() == null)
+				read = true;
+			// 鏌ヨ鏄惁宸茶
+			UserCommonMsgVO vo = new UserCommonMsgVO(notify.getIcon(), notify.getTitle(), notify.getUpdateTime(),
+					UserCommonMsgVO.TYPE_NOTIFY, notify.getContent(), read, notify.getJumpDetail(), notify.getParams(),
+					0);
+			vo.setPicture(notify.getPicture());
+			root.put("notifyMsg", builder.create().toJson(vo));
+		}
+
 		root.put("list", builder.create().toJson(listCenter));
 		root.put("commonList", builder.create().toJson(commonMsgList));
 		root.put("count", listCenter.size());

--
Gitblit v1.8.0