package project.web.admin;
|
|
import java.net.URLDecoder;
|
import java.net.URLEncoder;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.Comparator;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.DateUtils;
|
import kernel.util.JsonUtils;
|
import kernel.util.StringUtils;
|
import kernel.web.PageActionSupport;
|
import kernel.web.ResultObject;
|
import project.Constants;
|
import project.onlinechat.MessageUser;
|
import project.onlinechat.OnlineChatMessage;
|
import project.onlinechat.OnlineChatMessageService;
|
import project.onlinechat.OnlineChatVisitorMessageService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.user.token.Token;
|
import project.user.token.TokenService;
|
import systemuser.CustomerService;
|
import systemuser.model.Customer;
|
|
@RestController
|
public class NewAdminOnlineChatController extends PageActionSupport {
|
|
private Logger logger = LoggerFactory.getLogger(NewAdminOnlineChatController.class);
|
|
@Autowired
|
OnlineChatMessageService onlineChatMessageService;
|
|
@Autowired
|
OnlineChatVisitorMessageService onlineChatVisitorMessageService;
|
|
@Autowired
|
PartyService partyService;
|
|
@Autowired
|
CustomerService customerService;
|
|
@Autowired
|
TokenService tokenService;
|
|
private final String action = "public/newAdminOnlineChatAction!";
|
|
/**
|
* 在线聊天-人员列表
|
*/
|
@RequestMapping(value = action + "userlist.action", produces="text/html;charset=UTF-8")
|
public String userlist(HttpServletRequest request) {
|
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
int pageNo = 1;
|
int pageSize = 50;
|
try {
|
pageNo = this.checkAndSetPageNo(request.getParameter("page_no"));
|
String token = request.getParameter("token");
|
|
List<MessageUser> list = onlineChatMessageService
|
.cacheGetMessageUserPage(pageNo, pageSize, this.tokenService.cacheGet(token));
|
List<Map<String, Object>> data = new ArrayList<Map<String, Object>>();
|
for (int i = 0; i < list.size(); i++) {
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("id", list.get(i).getId());
|
Party party = this.partyService.cachePartyBy(list.get(i).getPartyId(), true);
|
if (party != null) {
|
map.put("username", party.getUsername());
|
map.put("uid", party.getUsercode());
|
map.put("partyid", party.getId().toString());
|
} else {
|
map.put("username", list.get(i).getIp());
|
map.put("partyid", list.get(i).getIp());
|
}
|
|
map.put("remarks", list.get(i).getRemarks());
|
map.put("unreadmsg", list.get(i).getCustomer_unreadmsg());
|
List<OnlineChatMessage> chats = onlineChatMessageService.cacheGetList(null, 1,
|
StringUtils.isNullOrEmpty(list.get(i).getPartyId()) ? list.get(i).getIp() : list.get(i).getPartyId());
|
String content = "";
|
Date chatDate = null;
|
if (chats.size() > 0) {
|
chatDate = chats.get(0).getCreateTime();
|
if ("img".equals(chats.get(0).getType())) {
|
content = "[picture]";
|
} else {
|
content = chats.get(0).getContent();
|
}
|
}
|
map.put("content", content);
|
map.put("updatetime",
|
DateUtils.format(chatDate != null ? chatDate : list.get(i).getUpdateTime(), "MM-dd HH:mm"));
|
|
map.put("order_updatetime", chatDate != null&&chatDate.after(list.get(i).getUpdateTime()) ? chatDate : list.get(i).getUpdateTime());// 用作排序
|
data.add(map);
|
}
|
Collections.sort(data, new Comparator<Map<String, Object>>() {
|
@Override
|
public int compare(Map<String, Object> paramT1, Map<String, Object> paramT2) {
|
Date date1 = (Date) paramT1.get("order_updatetime");
|
Date date2 = (Date) paramT2.get("order_updatetime");
|
return -date1.compareTo(date2);
|
}
|
});
|
int start = 0;
|
int end = start + pageSize;
|
|
if (data.size() <= end) {
|
end = data.size();
|
}
|
|
List<Map<String, Object>> resultData = new ArrayList<Map<String, Object>>();
|
resultData.addAll(data);
|
List<Map<String, Object>> subList = resultData.subList(start, end);
|
resultObject.setData(subList);
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
/**
|
* 聊天记录列表
|
*/
|
@RequestMapping(value = action + "list.action", produces="text/html;charset=UTF-8")
|
public String list(HttpServletRequest request) {
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
try {
|
String message_id = request.getParameter("message_id");
|
String partyid = request.getParameter("partyid");
|
|
List<OnlineChatMessage> list = onlineChatMessageService.cacheGetList(message_id, 30, partyid);
|
// 首页的时候才更新未读数
|
if (StringUtils.isNullOrEmpty(message_id) && !StringUtils.isNullOrEmpty(partyid)) {
|
MessageUser cacheMessageUser = onlineChatMessageService.cacheMessageUser(partyid);
|
// ip，表示游客
|
if (partyid.indexOf(".") != -1 || partyid.indexOf(":") != -1) {
|
if (cacheMessageUser != null && cacheMessageUser.getCustomer_unreadmsg() > 0) {
|
onlineChatVisitorMessageService.updateUnread(partyid, "customer", "read");
|
}
|
} else {
|
if (cacheMessageUser != null && cacheMessageUser.getCustomer_unreadmsg() > 0) {
|
onlineChatMessageService.updateUnread(partyid, "customer", "read");
|
}
|
}
|
}
|
List<Map<String, Object>> data = new ArrayList<Map<String, Object>>();
|
for (int i = 0; i < list.size(); i++) {
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("id", list.get(i).getId().toString());
|
map.put("send_receive", list.get(i).getSend_receive());
|
String type = list.get(i).getType();
|
map.put("type", type);
|
String content = list.get(i).getContent();
|
if ("img".equals(type)) {
|
content = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + content;
|
}
|
map.put("content", content);
|
map.put("createtime", DateUtils.format(list.get(i).getCreateTime(), "MM-dd HH:mm"));
|
map.put("delete_status", list.get(i).getDelete_status());
|
data.add(map);
|
}
|
resultObject.setData(data);
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
/**
|
* 发送消息
|
*
|
*/
|
@RequestMapping(value = action + "send.action", produces="text/html;charset=UTF-8")
|
public String send(HttpServletRequest request) {
|
ResultObject resultObject = new ResultObject();
|
String token = request.getParameter("token");
|
if (StringUtils.isNullOrEmpty(token)) {
|
resultObject.setCode("403");
|
resultObject.setMsg("请重新登录");
|
return JsonUtils.getJsonString(resultObject);
|
}
|
String partyId = tokenService.cacheGet(token);
|
if (StringUtils.isNullOrEmpty(partyId)) {
|
resultObject.setCode("403");
|
resultObject.setMsg("请重新登录");
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
try {
|
String partyid = request.getParameter("partyid");
|
String type = request.getParameter("type");
|
String content = request.getParameter("content");
|
String send_time_stmp = request.getParameter("send_time_stmp");
|
|
if (StringUtils.isNullOrEmpty(partyid)) {
|
throw new BusinessException("暂无用户");
|
}
|
|
if (StringUtils.isNullOrEmpty(content.trim()) || StringUtils.isNullOrEmpty(type)) {
|
throw new BusinessException("请输入内容");
|
}
|
|
Customer customer = customerService.cacheByUsername(this.tokenService.cacheGet(token));
|
if (customer != null && customer.getOnline_state() != 1) {
|
throw new BusinessException("您已下线无法发送消息");
|
}
|
logger.error("执行前:"+content);
|
// 文字内容乱码处理
|
content = URLDecoder.decode(content.replaceAll("%(?![0-9a-fA-F]{2})", "%25").replaceAll("\\+", "%2B"),"utf-8");
|
String loginUsername = this.tokenService.cacheGet(token);
|
MessageUser messageUser = onlineChatMessageService.cacheMessageUser(partyid);
|
if (!loginUsername.equals(messageUser.getTarget_username())) {
|
throw new BusinessException("该用户已移交");
|
}
|
OnlineChatMessage onlineChatMessage = null;
|
// ip，表示游客
|
if (partyid.indexOf(".") != -1 || partyid.indexOf(":") != -1) {
|
onlineChatMessage = onlineChatVisitorMessageService.saveSend(partyid, type, "receive", content,
|
loginUsername);
|
} else {
|
onlineChatMessage = onlineChatMessageService.saveSend(partyid, type, "receive", content, loginUsername);
|
}
|
Map<String, Object> data = new HashMap<String, Object>();
|
data.put("send_time_stmp", send_time_stmp);
|
data.put("chat_id", onlineChatMessage != null ? onlineChatMessage.getId() : null);
|
data.put("updatetime",
|
onlineChatMessage != null ? DateUtils.format(onlineChatMessage.getCreateTime(), "MM-dd HH:mm")
|
: null);
|
resultObject.setData(data);
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
/**
|
* 创建新用户消息列表
|
*/
|
@RequestMapping(value = action + "create.action", produces="text/html;charset=UTF-8")
|
public String create(HttpServletRequest request) {
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
try {
|
String uid = request.getParameter("uid");
|
String token = request.getParameter("token");
|
|
Customer customer = customerService.cacheByUsername(this.tokenService.cacheGet(token));
|
if (customer != null && customer.getOnline_state() != 1) {
|
throw new BusinessException("您已下线无法接收用户");
|
}
|
String loginUsername = this.tokenService.cacheGet(token);
|
if (uid.indexOf(".") != -1 || uid.indexOf(":") != -1) {// ip，表示游客
|
MessageUser messageUser = onlineChatMessageService.cacheMessageUser(uid);
|
if (messageUser == null) {// 该ip没有发起聊天
|
throw new BusinessException("用户不存在");
|
}
|
MessageUser user = onlineChatVisitorMessageService.saveCreate(uid, loginUsername);
|
resultObject.setData(user.getIp());
|
} else {
|
MessageUser user = onlineChatMessageService.saveCreate(uid, loginUsername);
|
resultObject.setData(user.getPartyId());
|
}
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
/**
|
* 删除聊天
|
*/
|
@RequestMapping(value = action + "del.action")
|
public String del(HttpServletRequest request) {
|
|
HttpServletResponse response = this.getResponse();
|
response.setContentType("application/json;charset=UTF-8");
|
response.setHeader("Access-Control-Allow-Origin", "*");
|
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
try {
|
String partyid = request.getParameter("partyid");
|
if (partyid.indexOf(".") != -1 || partyid.indexOf(":") != -1) {// ip，表示游客
|
onlineChatMessageService.deleteByIp(partyid);
|
} else {
|
onlineChatMessageService.delete(partyid);
|
}
|
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
/**
|
* 查询未读消息
|
*/
|
@RequestMapping(value = action + "unread.action", produces="text/html;charset=UTF-8")
|
public String unread(HttpServletRequest request) {
|
String token = request.getParameter("token");
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
try {
|
// 只有admin才有客服
|
int unreadMsg = onlineChatMessageService.unreadMsg(null, "customer", this.tokenService.cacheGet(token));
|
resultObject.setData(unreadMsg);
|
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
/**
|
* 设置用户备注
|
*/
|
@RequestMapping(value = action + "resetRemarks.action", produces="text/html;charset=UTF-8")
|
public String resetRemarks(HttpServletRequest request) {
|
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
try {
|
String partyid = request.getParameter("partyid");
|
String remarks = request.getParameter("remarks");
|
|
if (partyid.indexOf(".") != -1 || partyid.indexOf(":") != -1) {// ip，表示游客
|
resultObject.setData(onlineChatVisitorMessageService.updateResetRemarks(partyid, remarks));
|
} else {
|
resultObject.setData(onlineChatMessageService.updateResetRemarks(partyid, remarks));
|
}
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
@RequestMapping(value = action + "getUserInfo.action", produces="text/html;charset=UTF-8")
|
public String getUserInfo(HttpServletRequest request) {
|
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
try {
|
String partyid = request.getParameter("partyid");
|
// ip，表示游客
|
if (partyid.indexOf(".") != -1 || partyid.indexOf(":") != -1) {
|
resultObject.setData(onlineChatVisitorMessageService.getUserInfo(partyid));
|
} else {
|
resultObject.setData(onlineChatMessageService.getUserInfo(partyid));
|
}
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
|
@RequestMapping(value = action + "getChatToken.action")
|
public String getChatToken(){
|
|
ResultObject resultObject = new ResultObject();
|
try {
|
Token t = this.tokenService.find(this.getUsername_login());
|
if (null == t) {
|
throw new BusinessException("chatToken is null");
|
}
|
resultObject.setData(t.getToken());
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("loginuser:{" + this.getUsername_login() + "},error:", e);
|
}
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
@RequestMapping(value = action + "deleteOnlineChatMessage.action")
|
public String deleteOnlineChatMessage(HttpServletRequest request) {
|
|
String token = request.getParameter("token");
|
|
ResultObject resultObject = new ResultObject();
|
resultObject = this.readSecurityContextFromSession(resultObject);
|
if (!"0".equals(resultObject.getCode())) {
|
return JsonUtils.getJsonString(resultObject);
|
}
|
try {
|
|
String message_id = request.getParameter("message_id");
|
|
onlineChatMessageService.updateMessageDelete(message_id, this.tokenService.cacheGet(token));
|
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("Program error!");
|
logger.error("error:", e);
|
}
|
|
return JsonUtils.getJsonString(resultObject);
|
}
|
|
public ResultObject readSecurityContextFromSession(ResultObject resultObject) {
|
HttpServletRequest request = this.getRequest();
|
String token = request.getParameter("token");
|
if (StringUtils.isNullOrEmpty(token)) {
|
resultObject.setCode("403");
|
resultObject.setMsg("请重新登录");
|
return resultObject;
|
}
|
String partyId = tokenService.cacheGet(token);
|
if (StringUtils.isNullOrEmpty(partyId)) {
|
resultObject.setCode("403");
|
resultObject.setMsg("请重新登录");
|
return resultObject;
|
}
|
return resultObject;
|
}
|
}
|
