调整获取未读的接口

src/main/java/com/uas/platform/b2c/common/psmessage/controller/MessageController.java

@@ -45,8 +45,8 @@ public class MessageController {
      * @return
      */
     @RequestMapping(value = "/count/unread", method = RequestMethod.GET)
-    public Map<String, Object> getUnReadMessageCount() {
-        return messageService.getUnReadMessageCount();
+    public Map<String, Object> getUnReadMessageCount(String type) {
+        return messageService.getUnReadMessageCount(type);
     }
 
     /**

src/main/java/com/uas/platform/b2c/common/psmessage/service/MessageService.java

@@ -54,7 +54,7 @@ public interface MessageService {
      * 获取未读消息数量
      * @return
      */
-    Map<String, Object> getUnReadMessageCount();
+    Map<String, Object> getUnReadMessageCount(String type);
 
     /**
      * 短信

src/main/java/com/uas/platform/b2c/common/psmessage/service/impl/MessageServiceImpl.java

@@ -13,6 +13,7 @@ import com.uas.platform.b2c.common.psmessage.util.JsonObjectUtil;
 import com.uas.platform.b2c.core.config.SysConf;
 import com.uas.platform.b2c.core.support.SystemSession;
 import com.uas.platform.b2c.core.utils.FastjsonUtils;
+import com.uas.platform.b2c.prod.commodity.constant.IntegerConstant;
 import com.uas.platform.b2c.trade.support.CodeType;
 import com.uas.platform.b2c.trade.support.ResultMap;
 import com.uas.platform.b2c.trade.util.BoundedExecutor;
@@ -199,7 +200,7 @@ public class MessageServiceImpl implements MessageService {
      * @return
      */
     @Override
-    public Map<String, Object> getUnReadMessageCount() {
+    public Map<String, Object> getUnReadMessageCount(String type) {
         Map<String , Object> resultMap = new HashedMap();
         resultMap.put("success", "success");
         resultMap.put("count", "0");
@@ -213,8 +214,12 @@ public class MessageServiceImpl implements MessageService {
             }
         }
         map.put("consumerApp", ConsumerApp.MALL);
+        if (!StringUtils.isEmpty(type)) {
+            map.put("type", type);
+        }
+        map.put("isRead", IntegerConstant.YES_INT);
         try {
-            HttpUtil.Response response = HttpUtil.sendGetRequest(sysConf.getMessageServiceUrl() + "messages/count/unread", map);
+            HttpUtil.Response response = HttpUtil.sendGetRequest(sysConf.getMessageServiceUrl() + "messages/count", map);
             int statusCode = response.getStatusCode();
             if (statusCode == HttpStatus.OK.value()) {
                 String responseText = response.getResponseText();