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/UserInfoServiceImpl.java | 45 +++++++++++++++++++++++++++++++++++---------- 1 files changed, 35 insertions(+), 10 deletions(-) diff --git a/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoServiceImpl.java b/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoServiceImpl.java index d17766e..0cf6124 100644 --- a/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoServiceImpl.java +++ b/service-daylucky/src/main/java/com/ks/daylucky/service/impl/remote/UserInfoServiceImpl.java @@ -1,23 +1,24 @@ package com.ks.daylucky.service.impl.remote; -import com.beust.jcommander.ParameterException; import com.ks.daylucky.exception.UserInfoException; import com.ks.daylucky.mapper.UserInfoExtraMapper; import com.ks.daylucky.mapper.UserInfoMapper; import com.ks.daylucky.pojo.DO.UserInfo; import com.ks.daylucky.pojo.DO.UserInfoExtra; +import com.ks.daylucky.pojo.VO.SimpleUser; import com.ks.daylucky.query.UserInfoQuery; import com.ks.daylucky.service.UserInfoExtraService; import com.ks.daylucky.service.UserInfoService; -import org.apache.dubbo.config.annotation.Service; +import com.ks.lib.common.exception.ParamsException; +import com.ks.lucky.pojo.DO.BaseUser; +import org.springframework.stereotype.Service; import org.springframework.validation.annotation.Validated; import javax.annotation.Resource; import javax.validation.Valid; -import java.util.Date; -import java.util.List; +import java.util.*; -@Service(version = "1.0.0") +@Service public class UserInfoServiceImpl implements UserInfoService { @Resource @@ -44,7 +45,7 @@ @Validated @Override - public Long addUserInfo(@Valid UserInfo userInfo) throws ParameterException, UserInfoException { + public Long addUserInfo(@Valid UserInfo userInfo) throws ParamsException, UserInfoException { UserInfo old = getUserInfo(userInfo.getAppId(), userInfo.getIdentifyCode()); if (old != null) { throw new UserInfoException(UserInfoException.CODE_EXIST, "鐢ㄦ埛宸插瓨鍦�"); @@ -56,14 +57,29 @@ userInfoMapper.insertSelective(userInfo); //鍒濆鍖栭檮鍔犱俊鎭� - userInfoExtraService.init(userInfo.getId()); + userInfoExtraService.init(userInfo.getId(), userInfo.getType() == UserInfo.TYPE_NORMAL ? true : false); return userInfo.getId(); } + @Override - public List<UserInfo> getUserList(UserInfoQuery query, int page, int pageSize) { - query.start = (page - 1) * pageSize; - query.count = pageSize; + public Map<Long, UserInfo> listUserInfoAsMap(BaseUser... users) { + List<UserInfo> list = userInfoMapper.listUserInfo(Arrays.asList(users)); + Map<Long, UserInfo> map = new HashMap<>(); + if (list != null) { + for (UserInfo userInfo : list) { + map.put(userInfo.getId(), userInfo); + } + } + return map; + } + + @Override + public List<UserInfo> getUserList(UserInfoQuery query, Integer page, Integer pageSize) { + if (page != null && pageSize != null) { + query.start = (page - 1) * pageSize; + query.count = pageSize; + } return userInfoMapper.list(query); } @@ -103,4 +119,13 @@ userInfo.setUpdateTime(new Date()); userInfoMapper.updateByPrimaryKeySelective(userInfo); } + + @Override + public SimpleUser getSimpleUser(Long id) { + UserInfo user = userInfoMapper.selectByPrimaryKey(id); + if (user == null) { + return null; + } + return new SimpleUser(user.getId(), user.getNickName(), user.getPortrait()); + } } -- Gitblit v1.8.0