From df4441322e9801c102299451da41d7c40b4502e9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 24 六月 2021 18:53:13 +0800
Subject: [PATCH] zookeeper地址修改,Maven采用私服

---
 service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoExtraServiceImpl.java |   24 +++++++++++++++++++++++-
 1 files changed, 23 insertions(+), 1 deletions(-)

diff --git a/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoExtraServiceImpl.java b/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoExtraServiceImpl.java
index 0a2802e..8405b62 100644
--- a/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoExtraServiceImpl.java
+++ b/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoExtraServiceImpl.java
@@ -6,6 +6,7 @@
 import com.ks.daylucky.pojo.DTO.UserMsgSettings;
 import com.ks.daylucky.service.UserInfoExtraService;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.util.Date;
@@ -18,12 +19,22 @@
 
 
     @Override
-    public void init(Long uid) {
+    public void init(Long uid, boolean msgSetting) {
         UserInfoExtra extra = new UserInfoExtra();
         extra.setUid(uid);
         extra.setCreateTime(new Date());
         extra.setMsgSetting(new UserMsgSettings().toString());
         extra.setMsgUnreadCount(0);
+        UserMsgSettings userMsgSettings = new UserMsgSettings();
+        userMsgSettings.setDrawnMsg(true);
+        userMsgSettings.setAssistSuccessMsg(true);
+        userMsgSettings.setJoinActivityMsg(true);
+        userMsgSettings.setNotOpenActivityMsg(false);
+        userMsgSettings.setNotDrawnMsg(false);
+        userMsgSettings.setOpenActivityMsg(false);
+        if (msgSetting) {
+            extra.setMsgSetting(userMsgSettings.toString());
+        }
         userInfoExtraMapper.insertSelective(extra);
     }
 
@@ -83,4 +94,15 @@
         String msg = userInfoExtra.getMsgSetting();
         return UserMsgSettings.parse(msg);
     }
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void addMsgUnReadCount(Long uid, int count) {
+        UserInfoExtra userInfoExtra = userInfoExtraMapper.selectByPrimaryKeyForUpdate(uid);
+        UserInfoExtra update = new UserInfoExtra();
+        update.setUid(uid);
+        update.setMsgUnreadCount(userInfoExtra.getMsgUnreadCount() + count);
+        update.setUpdateTime(new Date());
+        userInfoExtraMapper.updateByPrimaryKeySelective(update);
+    }
 }

--
Gitblit v1.8.0