修改留言

zxkf-api/src/main/java/api/controller/online/MessageController.java

@@ -1,6 +1,8 @@
 package api.controller.online;
 
+import api.entity.database.system.Customer;
 import api.entity.input.online.MessageInput;
+import api.service.system.ICustomerService;
 import api.service.websocket.WebSocket;
 import api.util.helper.AsyncHelper;
 import api.util.helper.DateHelper;
@@ -27,6 +29,7 @@ import org.springframework.web.multipart.MultipartFile;
 import javax.annotation.Resource;
 import java.io.IOException;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Api(value = "聊天消息",tags = "聊天消息")
 @RestController
@@ -34,6 +37,8 @@ import java.util.*;
 public class MessageController extends BaseController {
     @Autowired
     private IMessageService messageService;
+    @Autowired
+    private ICustomerService customerService;
     @Resource
     private WebSocket webSocket;
 
@@ -92,8 +97,22 @@ public class MessageController extends BaseController {
     public AjaxResult getLeaveList() {
         LambdaQueryWrapper<Message> qw = new QueryWrapper().select("kh_user user,count(*) as count").lambda();
         qw.eq( Message::getSend, 1).isNull( Message::getKfUser).groupBy(Message::getKhUser);
+        List<Map<String,Object>> list=messageService.getMaps(qw);
+        List<String> users=list.stream().map(p->p.get("user").toString()).collect(Collectors.toList());
+        LambdaQueryWrapper<Customer> qw1=new LambdaQueryWrapper<>();
+        qw1.in(Customer::getCustomerNo,users).select(Customer::getCustomerNo,Customer::getCustomerName);
+        List<Map<String,Object>> userlist=customerService.getMaps(qw1);
+        for (Map<String,Object> map:list) {
+            String user = map.get("user").toString();
+            List<Map<String, Object>> mapUsers = userlist.stream().filter(p -> p.get("customer_no").equals(user)).collect(Collectors.toList());
+            if (mapUsers != null && mapUsers.size() > 0) {
+                map.put("name", mapUsers.get(0).get("customer_name"));
+            } else {
+                map.put("name", "");
+            }
+        }
 
-        return Success("成功", messageService.getMaps(qw));
+        return Success("成功", list);
     }
 
     @ApiOperation("接入留言客户")