package com.yami.trading.admin.controller.chat;
|
|
import com.yami.trading.bean.c2c.C2cOrder;
|
import com.yami.trading.bean.chat.domain.OtcMessageUser;
|
import com.yami.trading.bean.chat.domain.OtcOnlineChatMessage;
|
import com.yami.trading.common.constants.Constants;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.util.DateUtils;
|
import com.yami.trading.common.util.StringUtils;
|
import com.yami.trading.security.common.util.SecurityUtils;
|
import com.yami.trading.service.AwsS3OSSFileService;
|
import com.yami.trading.service.c2c.C2cOrderService;
|
import com.yami.trading.service.chat.otc.OtcOnlineChatMessageService;
|
import com.yami.trading.service.chat.otc.OtcOnlineChatMessageServiceImpl;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.core.token.TokenService;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLDecoder;
|
import java.util.*;
|
|
@RestController
|
@CrossOrigin
|
public class OtcOnlineChatController {
|
|
private Logger logger = LoggerFactory.getLogger(OtcOnlineChatController.class);
|
private final String action = "normal/adminOtcOnlineChatAction!";
|
|
@Autowired
|
private OtcOnlineChatMessageService otcOnlineChatMessageService;
|
@Autowired
|
AwsS3OSSFileService awsS3OSSFileService;
|
@Autowired
|
private C2cOrderService c2cOrderService;
|
|
@RequestMapping(action + "list.action")
|
public Result<List<Map<String, Object>>> list(HttpServletRequest request) {
|
|
String messageId = request.getParameter("message_id");
|
String orderNo = request.getParameter("order_no");
|
String partyId = request.getParameter("partyid");
|
|
if (SecurityUtils.getCurrentSysUserId()==null){
|
// 首页的时候才更新未读数
|
if (StringUtils.isNullOrEmpty(messageId) && !StringUtils.isNullOrEmpty(partyId)) {
|
OtcMessageUser cacheOtcMessageUser = otcOnlineChatMessageService.cacheMessageUser(orderNo);
|
if (cacheOtcMessageUser != null && cacheOtcMessageUser.getCustomerUnreadmsg() > 0) {
|
otcOnlineChatMessageService.updateUnreadAdmin(partyId, "read", orderNo);
|
}
|
}
|
}
|
else {
|
if (SecurityUtils.getCurrentSysUserId()!=null){
|
OtcMessageUser cacheOtcMessageUser = otcOnlineChatMessageService.cacheMessageUser(orderNo);
|
if (cacheOtcMessageUser != null && cacheOtcMessageUser.getCustomerUnreadmsg() > 0) {
|
otcOnlineChatMessageService.delete(orderNo);
|
}
|
}
|
}
|
List<Map<String, Object>> data = new ArrayList<Map<String, Object>>();
|
List<OtcOnlineChatMessage> list = otcOnlineChatMessageService.cacheGetList(messageId, 30, orderNo);
|
C2cOrder c2cOrder = c2cOrderService.get(orderNo);
|
// 承兑商ID
|
String c2cUserId = c2cOrder.getC2cUserPartyId();
|
for (OtcOnlineChatMessage message : list) {
|
logger.info("message =>" + message);
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("id", message.getUuid());
|
if (!StringUtils.isNullOrEmpty(c2cUserId) && c2cUserId.equals(message.getPartyId())) {
|
map.put("send_receive", "receive");
|
} else {
|
// 当前登陆用户，记录访问发给谁的。如果当前是这个人登陆，消息全是他的
|
if(SecurityUtils.getSysUser().getUsername().equals(message.getUsername())){
|
map.put("send_receive", "receive");
|
map.put("is_read", message.getIsRead());
|
}else{
|
map.put("send_receive", "send");
|
if(null != message.getUuid()) otcOnlineChatMessageService.updateMessageRead(message.getUuid(),message.getOrderNo());
|
map.put("is_read", 1);
|
}
|
}
|
String type = message.getContentType();
|
map.put("type", type);
|
String content = message.getContent();
|
if ("img".equals(type)) {
|
// content = awsS3OSSFileService.getUrl(message.getContent());
|
if(!content.startsWith("https")){
|
map.put("url", Constants.IMAGES_HTTP+content);
|
map.put("content", Constants.IMAGES_HTTP+content);
|
|
}else{
|
map.put("content", content);
|
map.put("url", content);
|
}
|
}
|
else {
|
map.put("content", content);
|
}
|
|
map.put("createtime", DateUtils.format(message.getCreateTime(), "MM-dd HH:mm"));
|
map.put("delete_status", message.getDeleteStatus());
|
data.add(map);
|
}
|
return Result.succeed(data);
|
}
|
|
//
|
|
|
@RequestMapping(value = action + "send.action")
|
public Result<String> send(HttpServletRequest request) throws UnsupportedEncodingException {
|
// 后台配置的承兑商用户ID
|
String partyId = request.getParameter("partyid");
|
String type = request.getParameter("type");
|
String content = request.getParameter("content");
|
String orderNo = request.getParameter("order_no");
|
if (StringUtils.isNullOrEmpty(partyId)) {
|
throw new YamiShopBindException("暂无用户");
|
}
|
if (StringUtils.isNullOrEmpty(content.trim()) || StringUtils.isNullOrEmpty(type)) {
|
throw new YamiShopBindException("请输入内容");
|
}
|
if (StringUtils.isEmptyString(orderNo)) {
|
throw new YamiShopBindException("订单号不能未空");
|
}
|
// 文字内容乱码处理
|
content = URLDecoder.decode(content.replaceAll("%(?![0-9a-fA-F]{2})", "%25"), "utf-8");
|
otcOnlineChatMessageService.saveSend(partyId, type, content, SecurityUtils.getSysUser().getUsername(), orderNo);
|
return Result.succeed("ok");
|
}
|
|
@RequestMapping(value = action + "create.action", produces = "text/html;charset=UTF-8")
|
public Result<String> create(HttpServletRequest request) {
|
String orderNo = request.getParameter("order_no");
|
otcOnlineChatMessageService.saveCreateByOrderNo(orderNo);
|
return Result.succeed("ok");
|
}
|
|
@RequestMapping(value = action + "del.action")
|
public Result<String> del(HttpServletRequest request) {
|
|
String partyId = request.getParameter("partyid");
|
// ip，表示游客
|
if (partyId.indexOf(".") != -1) {
|
otcOnlineChatMessageService.deleteByIp(partyId);
|
} else {
|
otcOnlineChatMessageService.delete(partyId);
|
}
|
return Result.succeed("ok");
|
}
|
|
@RequestMapping(value = action + "unread.action", produces = "text/html;charset=UTF-8")
|
public Result<Integer> unread() {
|
|
int unreadMsg = otcOnlineChatMessageService.unreadMsgAdmin(null);
|
return Result.succeed(unreadMsg);
|
}
|
|
@RequestMapping(value = action + "unreads.action", produces = "text/html;charset=UTF-8")
|
public Result<List<Map<String, Object>>> unreads(HttpServletRequest request) {
|
|
String orderNos = request.getParameter("order_nos");
|
if (StringUtils.isNullOrEmpty(orderNos)) {
|
return Result.succeed(new ArrayList<>());
|
} else {
|
List<String> nos = new ArrayList<String>(Arrays.asList(orderNos.split(",")));
|
List<Map<String, Object>> datas = new ArrayList<Map<String, Object>>();
|
Map<String, Integer> unreadMsgs = otcOnlineChatMessageService.unreadMsgs(nos);
|
for (Map.Entry<String, Integer> entry : unreadMsgs.entrySet()) {
|
Map<String, Object> data = new HashMap<String, Object>();
|
data.put("order_no", entry.getKey());
|
data.put("unread_msg", entry.getValue());
|
datas.add(data);
|
}
|
return Result.succeed(datas);
|
}
|
}
|
|
@RequestMapping(value = action + "resetRemarks.action")
|
public Result<String> resetRemarks(HttpServletRequest request) throws Exception {
|
|
String remarks = request.getParameter("remarks");
|
String orderNo = request.getParameter("order_no");
|
return Result.succeed(otcOnlineChatMessageService.resetRemarks(orderNo, remarks));
|
}
|
|
@RequestMapping(value = action + "saveGetUserInfo.action", produces = "text/html;charset=UTF-8")
|
public Result<Map<String, Object>> saveGetUserInfo(HttpServletRequest request) {
|
|
String partyId = request.getParameter("partyid");
|
String orderNo = request.getParameter("order_no");
|
return Result.succeed(otcOnlineChatMessageService.saveGetUserInfo(orderNo, partyId));
|
}
|
|
@RequestMapping(value = action + "deleteOnlineChatMessage.action")
|
public Result<String> deleteOnlineChatMessage(HttpServletRequest request) {
|
String messageId = request.getParameter("message_id");
|
otcOnlineChatMessageService.updateMessageDelete(messageId, SecurityUtils.getSysUser().getUsername());
|
return Result.succeed("ok");
|
}
|
|
}
|
