站内信接口

weiliwhereareyou@163.com
1 parent 24c4f801
Showing 7 changed files with 75 additions and 11 deletions
mobsite-getway-domain/src/main/java/com/diligrp/mobsite/getway/domain/protocol/msg/GetStationMsgListReq.java
mobsite-getway-domain/src/main/java/com/diligrp/mobsite/getway/domain/protocol/msg/MarkStationMsgReq.java
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/StationMsgRPC.java
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/StationMsgRPCImpl.java
mobsite-getway-service/src/main/java/com/diligrp/mobsite/getway/service/buyer/user/impl/StationMsgServiceImpl.java
mobsite-getway-web/pom.xml
pom.xml
@@ -16,6 +16,7 @@ public class GetStationMsgListReq extends BaseReq {
 	/**
 	 * 消息类型
 	 */
+
 	private String groupType;
 	/**
 	 * 页码
 package com.diligrp.mobsite.getway.domain.protocol.msg;
 import com.diligrp.mobsite.getway.domain.protocol.BaseReq;
+import io.swagger.annotations.ApiModelProperty;
 /**
  * <B>Description</B> 按类型标识站内信已读(请求)<br />
@@ -17,7 +18,7 @@ public class MarkStationMsgReq extends BaseReq {
 	/**
 	 * 消息类型
 	 */
-	private String groupType ;
+	private String groupType;
 	public String getGroupType() {
 		return groupType;
@@ -32,7 +32,7 @@ public interface StationMsgRPC extends BaseService {
 	 * @param userid
 	 * @return
 	 */
-	Boolean isMsgRead(Long userid);
+	Boolean isMsgRead(Long userid,String userRole);
 	/**
 	 * 查询未读站内消息
@@ -8,9 +8,9 @@ import com.diligrp.mobsite.getway.domain.except.ServiceException;
 import com.diligrp.mobsite.getway.domain.protocol.msg.*;
 import com.diligrp.mobsite.getway.domain.protocol.msg.model.HomeMsgInfo;
 import com.diligrp.mobsite.getway.domain.protocol.msg.model.StationMsg;
+import com.diligrp.mobsite.getway.rpc.StationMsgRPC;
 import com.diligrp.mobsite.getway.rpc.base.BaseOutput;
 import com.diligrp.mobsite.getway.rpc.base.impl.BaseServiceImpl;
-import com.diligrp.mobsite.getway.rpc.StationMsgRPC;
 import com.diligrp.website.util.security.Validator;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -47,6 +47,7 @@ public class StationMsgRPCImpl extends BaseServiceImpl implements StationMsgRPC 
 		Map<String,String> params = new HashMap<String, String>();
         params.put("groupCode", req.getGroupType().toString());
         params.put("userId", req.getUserId().toString());
+		params.put("userRole", req.getUserRole().toString());
         BaseOutput<String> output = null;
         try {
         	output = super.httpPost("/messages/readAllByGroup.do", params, null);
@@ -88,6 +89,7 @@ public class StationMsgRPCImpl extends BaseServiceImpl implements StationMsgRPC 
         params.put("currPage", req.getPageNum().toString());
         params.put("pageSize", PAGESIZE);
 		params.put("groupCode",req.getGroupType());
+		params.put("userRole", req.getUserRole().toString());
         BaseOutput<String> output = null;
         try {
         	output = super.httpPost("/messages.do", params, null);
@@ -179,9 +181,10 @@ public class StationMsgRPCImpl extends BaseServiceImpl implements StationMsgRPC 
 	}
 	@Override
-	public Boolean isMsgRead(Long userid) {
+	public Boolean isMsgRead(Long userid,String userRole) {
 		Map<String,String> params = new HashMap<String, String>();
         params.put("userId", userid.toString());
+		params.put("userRole", userRole);
         BaseOutput<String> output = null;
         try {
         	output = super.httpPost("/messages/unRead.do", params, null);
@@ -216,6 +219,7 @@ public class StationMsgRPCImpl extends BaseServiceImpl implements StationMsgRPC 
 		GetHomeInfoResp resp = new GetHomeInfoResp();
 		Map<String,String> params = new HashMap<String, String>();
 		params.put("userId", req.getUserId().toString());
+		params.put("userRole", req.getUserRole().toString());
 		BaseOutput<String> output = null;
 		try {
 			output = super.httpPost("/groupedMessage.do", params, null);
 package com.diligrp.mobsite.getway.service.buyer.user.impl;
+import com.diligrp.mobsite.getway.domain.common.ResultCode;
 import com.diligrp.mobsite.getway.domain.protocol.msg.*;
+import com.diligrp.mobsite.getway.domain.protocol.msg.model.HomeMsgInfo;
+import com.diligrp.mobsite.getway.domain.protocol.msg.model.StationMsg;
+import com.diligrp.mobsite.getway.rpc.StationMsgRPC;
 import com.diligrp.mobsite.getway.service.buyer.user.StationMsgService;
+import com.diligrp.website.util.security.Validator;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import java.util.ArrayList;
+import java.util.List;
+
 /**
  * <B>Description</B> 站内信 <br />
  * <B>Copyright</B> Copyright (c) 2014 www.diligrp.com All rights reserved. <br />
@@ -17,25 +26,74 @@ public class StationMsgServiceImpl implements StationMsgService {
 	//是否有未读消息
 	private static final Integer ISREAD_TRUE = 1 ; 
 	private static final Integer ISREAD_FALSE = 2 ;
-
+	@Autowired
+	StationMsgRPC stationMsgRPC;
 	@Override
 	public GetStationMsgListResp getStationMsgList(GetStationMsgListReq req) {
-		return null;
+		GetStationMsgListResp msglistResp = new GetStationMsgListResp();
+
+		msglistResp = stationMsgRPC.getMsgList(req);
+
+
+		return msglistResp;
 	}
 	@Override
 	public MarkStationMsgResp markStationMsg(MarkStationMsgReq req) {
-		return null;
+
+		MarkStationMsgResp markResp = new MarkStationMsgResp();
+		markResp = stationMsgRPC.markMsgByGroup(req);
+
+		return markResp;
 	}
 	@Override
 	public GetHomeInfoResp getHomeInfo(GetHomeInfoReq req) {
-		return null;
+
+		GetHomeInfoResp homeInfoResp = new GetHomeInfoResp();
+
+		//获取相关系统消息信息
+		GetStationMsgListResp msglistResp = new GetStationMsgListResp();
+		GetStationMsgListReq listReq = new GetStationMsgListReq();
+		listReq.setPageNum(1);
+		listReq.setUserId(req.getUserId());
+		msglistResp = stationMsgRPC.getMsgList(listReq);
+		Boolean isread = stationMsgRPC.isMsgRead(req.getUserId(),req.getUserRole().toString());
+
+		if (!Validator.isNull(msglistResp)
+				&& !Validator.isEmpty(msglistResp.getMessages())) {
+			List<HomeMsgInfo> homeMsgInfos = new ArrayList<HomeMsgInfo>();
+			HomeMsgInfo homeMsgInfo = new HomeMsgInfo();
+			StationMsg stationMsg = msglistResp.getMessages().get(0);
+			homeMsgInfo.setContent(stationMsg.getContent());
+			homeMsgInfo.setContentTitle(stationMsg.getSecondCategoryName());
+			homeMsgInfo.setGroupName(stationMsg.getGroupName());
+			homeMsgInfo.setGroupType(stationMsg.getGroupCode());
+			if (isread) {
+				homeMsgInfo.setIsRead(ISREAD_TRUE);
+			}else {
+				homeMsgInfo.setIsRead(ISREAD_FALSE);
+			}
+			homeMsgInfo.setTime(stationMsg.getTime());
+			homeMsgInfos.add(homeMsgInfo);
+			homeInfoResp.setTcpMessages(homeMsgInfos);
+			homeInfoResp.setCode(ResultCode.SUCCESS);
+			homeInfoResp.setMsg("获取成功");
+		}else {
+			homeInfoResp.setCode(msglistResp.getCode());
+			homeInfoResp.setMsg(msglistResp.getMsg());
+		}
+
+		return homeInfoResp;
 	}
 	@Override
 	public GetHomeInfoResp getHomeInfoArray(GetHomeInfoReq req) {
-		return null;
+
+		GetHomeInfoResp getHomeInfoResp = new GetHomeInfoResp();
+
+		getHomeInfoResp = stationMsgRPC.getHomeInfo(req);
+		return getHomeInfoResp;
 	}
 }
@@ -38,7 +38,7 @@
 				<version>2.2</version>
 				<configuration>
 					<port>8080</port>
-					<url>http://10.28.11.181:8080/manager</url>
+					<url>http://10.28.11.181:80/manager</url>
                     <username>gateway</username>
 					<password>123456</password>
 					<path>/</path>
@@ -10,7 +10,7 @@
 	<url>http://maven.apache.org</url>
 	<properties>
 		<spring.version>4.2.8.RELEASE</spring.version>
-		<java.version>1.8</java.version>
+		<java.version>1.7</java.version>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 	</properties>