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 |   92 ++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 81 insertions(+), 11 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 61b4259..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,20 +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.List;
+import java.util.*;
 
-@Service(version = "1.0.0")
+@Service
 public class UserInfoServiceImpl implements UserInfoService {
 
     @Resource
@@ -23,39 +27,105 @@
     @Resource
     private UserInfoExtraMapper userInfoExtraMapper;
 
+    @Resource
+    private UserInfoExtraService userInfoExtraService;
+
     @Override
     public UserInfo getUserInfo(Long appId, String identifyCode) {
+        UserInfoQuery query = new UserInfoQuery();
+        query.appId = appId;
+        query.identifyCode = identifyCode;
+        query.count = 1;
+        List<UserInfo> list = userInfoMapper.list(query);
+        if (list != null && list.size() > 0) {
+            return list.get(0);
+        }
         return null;
     }
 
     @Validated
     @Override
-    public Long addUserInfo(@Valid UserInfo userInfo) throws ParameterException, UserInfoException {
-        return null;
+    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, "鐢ㄦ埛宸插瓨鍦�");
+        }
+
+        if (userInfo.getCreateTime() != null) {
+            userInfo.setCreateTime(new Date());
+        }
+        userInfoMapper.insertSelective(userInfo);
+
+        //鍒濆鍖栭檮鍔犱俊鎭�
+        userInfoExtraService.init(userInfo.getId(), userInfo.getType() == UserInfo.TYPE_NORMAL ? true : false);
+        return userInfo.getId();
+    }
+
+
+    @Override
+    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, int page, int pageSize) {
-        return null;
+    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);
     }
 
     @Override
     public long countUser(UserInfoQuery query) {
-        return 0;
+        return userInfoMapper.count(query);
     }
 
     @Override
     public UserInfo getUserDetail(Long appId, String identifyCode) {
-        return null;
+        UserInfo userInfo = getUserInfo(appId, identifyCode);
+        if (userInfo == null) {
+            return null;
+        }
+
+        UserInfoExtra extra = userInfoExtraMapper.selectByPrimaryKey(userInfo.getId());
+        userInfo.setUserInfoExtra(extra);
+        return userInfo;
     }
 
     @Override
     public UserInfo getUserDetail(Long id) {
-        return null;
+        UserInfo userInfo = userInfoMapper.selectByPrimaryKey(id);
+        if (userInfo == null) {
+            return null;
+        }
+        UserInfoExtra extra = userInfoExtraMapper.selectByPrimaryKey(userInfo.getId());
+        userInfo.setUserInfoExtra(extra);
+        return userInfo;
     }
 
     @Override
     public void updateUserInfo(UserInfo userInfo) {
+        if (userInfo == null || userInfo.getId() == null) {
+            return;
+        }
+        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