From 452714cdffb21300ed64d5818efaa9cc38c3ee83 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 17 十二月 2020 18:35:43 +0800 Subject: [PATCH] rpc服务引用优化 --- service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoExtraServiceImpl.java | 63 ++++++++++++++++++++++++++++--- 1 files changed, 56 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..0a2802e 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,16 @@ 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 javax.annotation.Resource; +import java.util.Date; -@Service(version = "1.0.0") +@Service public class UserInfoExtraServiceImpl implements UserInfoExtraService { @Resource @@ -16,22 +18,69 @@ @Override + public void init(Long uid) { + UserInfoExtra extra = new UserInfoExtra(); + extra.setUid(uid); + extra.setCreateTime(new Date()); + extra.setMsgSetting(new UserMsgSettings().toString()); + extra.setMsgUnreadCount(0); + 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); } } -- Gitblit v1.8.0