对外开放接口 用户操作完成

CODE/foreign-service/src/main/java/com/community/huiju/controller/TaUserController.java

@@ -2,8 +2,14 @@ package com.community.huiju.controller;
 
 
 import com.community.huiju.common.base.BaseController;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import com.community.huiju.common.base.ResponseBean;
+import com.community.huiju.service.ITaUserService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
 
 /**
  * <p>
@@ -15,6 +21,65 @@ import org.springframework.web.bind.annotation.RestController;
  */
 @RestController
 @RequestMapping("/")
+@Api(value = "用户操作 API")
 public class TaUserController extends BaseController {
 
+    @Autowired
+    private ITaUserService iTaUserService;
+
+
+    @RequestMapping(value = "/user", method = RequestMethod.POST)
+    @ApiOperation(value = "添加用户", notes = "添加用户")
+    @ApiImplicitParams({
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "userName", value = "用户名"),
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "idCard", value = "身份证"),
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "gender", value = "性别 1：男   2：女"),
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "phone", value = "手机号"),
+    })
+    public ResponseBean addUser(@RequestParam(value = "userName") String userName,
+                                @RequestParam(value = "idCard") String idCard,
+                                @RequestParam(value = "gender") String gender,
+                                @RequestParam(value = "phone") String phone){
+        ResponseBean responseBean = iTaUserService.addTaUser(userName, idCard, gender, phone);
+        return responseBean;
+    }
+
+    @RequestMapping(value = "/user/{userId}", method = RequestMethod.PUT)
+    @ApiOperation(value = "修改用户", notes = "修改用户")
+    @ApiImplicitParams({
+            @ApiImplicitParam(dataTypeClass = Integer.class, paramType = "path", name = "userId", value = "用户id"),
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "userName", value = "用户名"),
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "idCard", value = "身份证"),
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "gender", value = "性别 1：男   2：女"),
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "form", name = "phone", value = "手机号"),
+    })
+    public ResponseBean updateUser(@PathVariable(value = "userId") Integer userId,
+                                @RequestParam(value = "userName", required = false) String userName,
+                                @RequestParam(value = "idCard", required = false) String idCard,
+                                @RequestParam(value = "gender", required = false) String gender,
+                                @RequestParam(value = "phone", required = false) String phone){
+        ResponseBean responseBean = iTaUserService.updateTaUser(userId,userName, idCard, gender, phone);
+        return responseBean;
+    }
+
+    @RequestMapping(value = "/user/{userId}", method = RequestMethod.GET)
+    @ApiOperation(value = "根据用户ID查询", notes = "根据用户ID查询")
+    @ApiImplicitParams({
+            @ApiImplicitParam(dataTypeClass = Integer.class, paramType = "path", name = "userId", value = "用户id")
+    })
+    public ResponseBean updateUser(@PathVariable(value = "userId") Integer userId){
+        ResponseBean responseBean = iTaUserService.getTaUser(userId);
+        return responseBean;
+    }
+
+    @RequestMapping(value = "/user", method = RequestMethod.GET)
+    @ApiOperation(value = "根据用户ID查询", notes = "根据用户ID查询")
+    @ApiImplicitParams({
+            @ApiImplicitParam(dataTypeClass = String.class, paramType = "query", name = "phone", value = "手机号")
+    })
+    public ResponseBean updateUser(@RequestParam(value = "phone") String phone){
+        ResponseBean responseBean = iTaUserService.getTaUserByPhone(phone);
+        return responseBean;
+    }
+
 }

CODE/foreign-service/src/main/java/com/community/huiju/enums/ResponseErrorsMessages.java

@@ -9,6 +9,10 @@ public enum ResponseErrorsMessages {
     SYSTEM_ERRORS (500, "服务断网了！"),
     NOT_PHONE(1000, "请输入正确的手机号！"),
     NOT_USER_NAME(1001, "用户名不能为空！"),
+    NOT_ID_CARD(1002, "身份证不能为空！"),
+    NOT_GENDER(1003, "性别不能为空！"),
+    EXISTING_GENDER(1004, "手机号已存在！"),
+    NOT_USER(1004, "用户不存在！"),
     ;
 
 

CODE/foreign-service/src/main/java/com/community/huiju/service/ITaUserService.java

@@ -43,5 +43,26 @@ public interface ITaUserService extends IService<TaUser> {
      */
     ResponseBean addTaUser(String userName, String idCard, String gender, String phone);
 
+    /**
+     * 修改用户
+     * @param userName
+     * @param idCard
+     * @param gender
+     * @return
+     */
+    ResponseBean updateTaUser(Integer userId, String userName, String idCard, String gender, String phone);
+
+    /**
+     * 查询用户
+     * @param userId
+     * @return
+     */
+    ResponseBean getTaUser(Integer userId);
 
+    /**
+     * 查询用户
+     * @param phone
+     * @return
+     */
+    ResponseBean getTaUserByPhone(String phone);
 }

CODE/foreign-service/src/main/java/com/community/huiju/service/impl/TaUserServiceImpl.java

@@ -1,11 +1,19 @@
 package com.community.huiju.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.community.huiju.common.base.ResponseBean;
+import com.community.huiju.enums.ResponseErrorsMessages;
 import com.community.huiju.model.TaUser;
 import com.community.huiju.dao.TaUserMapper;
 import com.community.huiju.service.ITaUserService;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDateTime;
 
 /**
  * <p>
@@ -18,22 +26,113 @@ import org.springframework.stereotype.Service;
 @Service
 public class TaUserServiceImpl extends ServiceImpl<TaUserMapper, TaUser> implements ITaUserService {
 
+    @Autowired
+    private TaUserMapper taUserMapper;
+
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public ResponseBean addTaUser(String userName, String idCard, String gender, String phone) {
         ResponseBean responseBean = new ResponseBean();
 
         // 校验手机号 -> 是否重复
         checkPhone(phone);
 
+        if (StringUtils.isBlank(userName)) {
+            responseBean.addError(ResponseErrorsMessages.NOT_USER_NAME.getCode(), ResponseErrorsMessages.NOT_USER_NAME.getMsg());
+            return responseBean;
+        }
+        if (StringUtils.isBlank(idCard)) {
+            responseBean.addError(ResponseErrorsMessages.NOT_ID_CARD.getCode(), ResponseErrorsMessages.NOT_ID_CARD.getMsg());
+            return responseBean;
+        }
+        if (StringUtils.isBlank(gender)) {
+            responseBean.addError(ResponseErrorsMessages.NOT_GENDER.getCode(), ResponseErrorsMessages.NOT_GENDER.getMsg());
+            return responseBean;
+        }
+
+        TaUser one = getByPhone(phone);
+        if (null != one) {
+            responseBean.addError(ResponseErrorsMessages.EXISTING_GENDER.getCode(), ResponseErrorsMessages.EXISTING_GENDER.getMsg());
+            return responseBean;
+        }
+
         TaUser taUser = new TaUser();
         taUser.setUserName(userName);
         taUser.setIdCard(idCard);
         taUser.setLoginName(phone);
+        taUser.setCreateDate(LocalDateTime.now());
 
         boolean saveBool = this.save(taUser);
         if (saveBool) {
+            taUser.setCreateUser(taUser.getUserId());
+            this.updateById(taUser);
             responseBean.addSuccess(taUser);
         }
         return responseBean;
     }
+
+    private TaUser getByPhone(String phone) {
+        QueryWrapper<TaUser> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("login_name", phone);
+        TaUser one = this.getOne(queryWrapper);
+       return one;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public ResponseBean updateTaUser(Integer userId, String userName, String idCard, String gender, String phone) {
+        ResponseBean responseBean = new ResponseBean();
+        TaUser user = this.getById(userId);
+        if (null == user) {
+            responseBean.addError(ResponseErrorsMessages.NOT_USER.getCode(), ResponseErrorsMessages.NOT_USER.getMsg());
+            return responseBean;
+        }
+
+        TaUser one = getByPhone(phone);
+        if (null != one) {
+            responseBean.addError(ResponseErrorsMessages.EXISTING_GENDER.getCode(), ResponseErrorsMessages.EXISTING_GENDER.getMsg());
+            return responseBean;
+        }
+
+        UpdateWrapper<TaUser> userUpdateWrapper = new UpdateWrapper<>();
+        userUpdateWrapper.eq("id", userId);
+        userUpdateWrapper.set(StringUtils.isNotBlank(userName), "user_name", userName);
+        userUpdateWrapper.set(StringUtils.isNotBlank(idCard), "id_card", idCard);
+        userUpdateWrapper.set(StringUtils.isNotBlank(gender), "gender", gender);
+        userUpdateWrapper.set(StringUtils.isNotBlank(phone), "login_name", phone);
+        userUpdateWrapper.set("update_user", userId);
+        userUpdateWrapper.set("update_date", LocalDateTime.now());
+
+        this.update(userUpdateWrapper);
+        user = this.getById(userId);
+        responseBean.addSuccess(user);
+        return responseBean;
+    }
+
+    @Override
+    public ResponseBean getTaUser(Integer userId) {
+        ResponseBean responseBean = new ResponseBean();
+        TaUser user = this.getById(userId);
+        if (null == user) {
+            responseBean.addError(ResponseErrorsMessages.NOT_USER.getCode(), ResponseErrorsMessages.NOT_USER.getMsg());
+            return responseBean;
+        }
+
+        responseBean.addSuccess(user);
+        return responseBean;
+    }
+
+    @Override
+    public ResponseBean getTaUserByPhone(String phone) {
+        ResponseBean responseBean = new ResponseBean();
+        checkPhone(phone);
+        TaUser user = getByPhone(phone);
+        if (null == user) {
+            responseBean.addError(ResponseErrorsMessages.NOT_USER.getCode(), ResponseErrorsMessages.NOT_USER.getMsg());
+            return responseBean;
+        }
+
+        responseBean.addSuccess(user);
+        return responseBean;
+    }
 }

CODE/foreign-service/src/main/resources/application.yml

@@ -13,6 +13,9 @@ spring:
 mybatis-plus:
   type-aliases-package: com.community.huiju.model
   mapper-locations: classpath:mapper/*.xml
+  configuration:
+    call-setters-on-nulls: true
+
 # 打印sql
 logging:
   level: