From 0e9b6603d4ae9d11c1fbc90257ce816c5807b8ff Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 28 十月 2022 16:55:02 +0800
Subject: [PATCH] 批量添加结算消息
---
app/src/main/java/com/yeshi/makemoney/app/service/impl/msg/UserMsgServiceImpl.java | 25 ++++++++++++++++++++++---
1 files changed, 22 insertions(+), 3 deletions(-)
diff --git a/app/src/main/java/com/yeshi/makemoney/app/service/impl/msg/UserMsgServiceImpl.java b/app/src/main/java/com/yeshi/makemoney/app/service/impl/msg/UserMsgServiceImpl.java
index d3cfb79..9075b73 100644
--- a/app/src/main/java/com/yeshi/makemoney/app/service/impl/msg/UserMsgServiceImpl.java
+++ b/app/src/main/java/com/yeshi/makemoney/app/service/impl/msg/UserMsgServiceImpl.java
@@ -3,6 +3,8 @@
import java.lang.Exception;
import javax.annotation.Resource;
+import com.yeshi.makemoney.app.entity.user.UserExtraInfo;
+import com.yeshi.makemoney.app.service.inter.user.UserExtraInfoService;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;
@@ -27,6 +29,9 @@
@Resource
private UserMsgDao userMsgDao;
+
+ @Resource
+ private UserExtraInfoService userExtraInfoService;
@Override
public List<UserMsg> list(UserMsgQuery userMsgQuery, int page, int pageSize) {
@@ -60,16 +65,25 @@
@Override
public void add(UserMsg userMsg) throws Exception {
+
+ if (userMsg.getCreateTime() == null) {
+ userMsg.setCreateTime(new Date());
+ }
+
+ if (userMsg.getId() == null) {
+ userMsg.setId(userMsg.toId());
+ }
+
//鏌ヨ涓婚敭ID鏄惁瀛樺湪
if (userMsgDao.get(userMsg.getId()) != null) {
throw new Exception("宸插瓨鍦�");
}
- if (userMsg.getCreateTime() == null) {
- userMsg.setCreateTime(new Date());
- }
//淇濆瓨
userMsgDao.save(userMsg);
+
+ //娣诲姞娑堟伅鏁伴噺
+ userExtraInfoService.addUnReadMsgCount(userMsg.getUid(), 1);
}
@Override
@@ -88,5 +102,10 @@
}
}
+ @Override
+ public void readAllMsg(Long uid) {
+ userExtraInfoService.setMsgRead(uid);
+ }
+
}
\ No newline at end of file
--
Gitblit v1.8.0