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 |   85 +++++++++++++++++++++++++++++++++++++++---
 1 files changed, 78 insertions(+), 7 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 bb3bc0f..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
@@ -1,14 +1,17 @@
 package com.ks.daylucky.service.impl.remote;
 
+import com.ks.daylucky.exception.UserInfoExtraException;
 import com.ks.daylucky.mapper.UserInfoExtraMapper;
 import com.ks.daylucky.pojo.DO.UserInfoExtra;
 import com.ks.daylucky.pojo.DTO.UserMsgSettings;
 import com.ks.daylucky.service.UserInfoExtraService;
-import org.apache.dubbo.config.annotation.Service;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
+import java.util.Date;
 
-@Service(version = "1.0.0")
+@Service
 public class UserInfoExtraServiceImpl implements UserInfoExtraService {
 
     @Resource
@@ -16,22 +19,90 @@
 
 
     @Override
+    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);
+    }
+
+    @Override
     public UserInfoExtra getUserInfoExtra(Long uid) {
-        return null;
+        return userInfoExtraMapper.selectByPrimaryKey(uid);
     }
 
     @Override
-    public void setMsgRead(Long uid) {
-
+    public void setMsgRead(Long uid) throws UserInfoExtraException {
+        UserInfoExtra extra = new UserInfoExtra();
+        extra.setUid(uid);
+        extra.setMsgUnreadCount(0);
+        extra.setUpdateTime(new Date());
+        userInfoExtraMapper.updateByPrimaryKeySelective(extra);
     }
 
     @Override
-    public void setUserMsgSetting(UserMsgSettings setting) {
+    public void setUserMsgSetting(Long uid, UserMsgSettings setting) {
+        UserMsgSettings old = getUserMsgSettings(uid);
+        //璁剧疆宸茬粡璁剧疆鐨�
+        if (setting.getAssistSuccessMsg() != null) {
+            old.setAssistSuccessMsg(setting.getAssistSuccessMsg());
+        }
 
+        if (setting.getDrawnMsg() != null) {
+            old.setDrawnMsg(setting.getDrawnMsg());
+        }
+
+        if (setting.getJoinActivityMsg() != null) {
+            old.setJoinActivityMsg(setting.getJoinActivityMsg());
+        }
+
+        if (setting.getNotDrawnMsg() != null) {
+            old.setNotDrawnMsg(setting.getNotDrawnMsg());
+        }
+
+        if (setting.getNotOpenActivityMsg() != null) {
+            old.setNotOpenActivityMsg(setting.getNotOpenActivityMsg());
+        }
+
+        if (setting.getOpenActivityMsg() != null) {
+            old.setOpenActivityMsg(setting.getOpenActivityMsg());
+        }
+
+
+        UserInfoExtra extra = new UserInfoExtra();
+        extra.setUid(uid);
+        extra.setMsgSetting(old.toString());
+        extra.setUpdateTime(new Date());
+        userInfoExtraMapper.updateByPrimaryKeySelective(extra);
     }
 
     @Override
     public UserMsgSettings getUserMsgSettings(Long uid) {
-        return null;
+        UserInfoExtra userInfoExtra = userInfoExtraMapper.selectByPrimaryKeyForUpdate(uid);
+        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