From c1c36c56ca77b8f69db91804353ca1d446e062ca Mon Sep 17 00:00:00 2001
From: pjhmizn49 <zhangjiadi2008@126.com>
Date: Sat, 14 Dec 2024 21:01:55 +0800
Subject: [PATCH] ADD file via upload

---
 .../flower/service/ImSingleService.java       | 41 +++++++++++++++++++
 1 file changed, 41 insertions(+)
 create mode 100644 flower_back/src/main/java/com/example/flower/service/ImSingleService.java

diff --git a/flower_back/src/main/java/com/example/flower/service/ImSingleService.java b/flower_back/src/main/java/com/example/flower/service/ImSingleService.java
new file mode 100644
index 0000000..67951fd
--- /dev/null
+++ b/flower_back/src/main/java/com/example/flower/service/ImSingleService.java
@@ -0,0 +1,41 @@
+package com.example.flower.service;
+
+import cn.hutool.core.lang.Dict;
+import com.example.flower.mapper.ImSingleDao;
+import com.example.flower.entity.ImSingle;
+import org.springframework.stereotype.Service;
+
+import jakarta.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Service
+public class ImSingleService {
+
+    @Resource
+    private ImSingleDao imSingleDao;
+
+    public ImSingle add(ImSingle imSingle) {
+        imSingle.setReaded(0);
+        imSingleDao.insert(imSingle);
+        return imSingle;
+    }
+    public List<ImSingle> findByUsername(String fromUser, String toUser) {
+        List<ImSingle> list = imSingleDao.findByUsername(fromUser, toUser);
+        list.forEach(x -> {
+            if (x.getTouser().equals(fromUser) && x.getFromuser().equals(toUser)) {
+                x.setReaded(1);
+                imSingleDao.updateById(x);
+            }
+        });
+        return list;
+    }
+    public Dict findUnReadNums(String toUsername) {
+        List<ImSingle> list = imSingleDao.findByToUsername(toUsername);
+        Map<String, List<ImSingle>> collect = list.stream().collect(Collectors.groupingBy(ImSingle::getFromuser));
+        Dict dict = Dict.create();
+        collect.forEach((k,v) -> dict.set(k, v.size()));
+        return dict;
+    }
+}
\ No newline at end of file