diagbotcloud/user-service/src/main/java/com/diagbot/web/UserController.java

package com.diagbot.web;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.diagbot.annotation.SysLogger;
import com.diagbot.dto.RespDTO;
import com.diagbot.entity.User;
import com.diagbot.facade.UserFacade;
import com.diagbot.vo.UserSaveVO;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import springfox.documentation.annotations.ApiIgnore;

import java.util.Map;

/**
 * @Description: 用户对外接口层
 * @author: gaodm
 * @time: 2018/8/2 13:56
 */
@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserFacade userFacade;

    @ApiOperation(value = "注册", notes = "username|password|organization|email|linkman|imgId|code为必填项")
    @PostMapping("/registry")
    @SysLogger("registry")
    @Transactional
    public RespDTO createUser(@RequestBody UserSaveVO userSaveVO){
        User user = userFacade.createUser(userSaveVO);
        return RespDTO.onSuc(user);
    }


    @ApiOperation(value = "登录", notes = "username|password为必选项")
    @PostMapping("/login")
    @SysLogger("login")
    public RespDTO login(@RequestParam String username, @RequestParam String password){
        return  userFacade.login(username, password);
    }


    @ApiOperation(value = "重置密码", notes = "username|password为必选项")
    @PostMapping("/resetPassword")
    @SysLogger("resetPassword")
    public RespDTO resetPassword(String username, String password){
        return  userFacade.resetPassword(username, password);
    }


    @ApiOperation(value = "根据用户名获取用户", notes = "根据用户名获取用户")
    @PostMapping("/getByUsername")
    @SysLogger("getByUsername")
    @ApiIgnore
//    @PreAuthorize("hasAnyAuthority('ROLE_USER')")
    public RespDTO getUserInfo(@RequestParam String username){
        //参数判读省略
        User user=  userFacade.getUserInfo(username);
        return RespDTO.onSuc(user);
    }

    @ApiOperation(value = "根据用户id获取用户信息", notes = "根据用户id获取用户信息")
    @PostMapping("/getById")
    @SysLogger("getUserInfoByID")
    @ApiIgnore
    public RespDTO getUserInfoByID(Long id, Page page){
        //参数判读省略
        Page<Map> mapPage = new Page<>(page.getCurrent(),page.getSize());
        User userVo = new User();
        userVo.setId(id);
        Page<User> user=  userFacade.selectUserListPage(mapPage, userVo);
        return RespDTO.onSuc(user);
    }

//    @ApiOperation(value = "注册事务", notes = "username和password为必选项")
//    @PostMapping("/registryTran")
//    @SysLogger("registryTran")
//    @Transactional
//    public RespDTO createUserTran(@RequestBody User user){
//        //参数判读省略,判读该用户在数据库是否已经存在省略
//        userFacade.createUser(user);
//        throw new CommonException(CommonErrorCode.FAIL);
////        return RespDTO.onSuc(user);
//    }

//    @Autowired
//    private AmqpTemplate rabbitTemplate;
//    @GetMapping("/test")
//    public void test(){
//        rabbitTemplate.convertAndSend(RabbitConfig.queueName, "Hello from RabbitMQ!");
//    }

    /**
     * 增加用户
     * @param user 用户信息
     * @return 增加是否成功
     */
    @ApiOperation(value = "增加用户", notes = "username和password为必选项")
    @PostMapping("/addUser")
    @SysLogger("addUser")
    @Transactional
    @ApiIgnore
    public RespDTO addUser(@RequestBody User user){
        //参数判读省略,判读该用户在数据库是否已经存在省略
        userFacade.saveUser(user);
        //        throw new CommonException(ErrorCode.FAIL);
        return RespDTO.onSuc(user);
    }

    /**
     * 修改用户
     * @param user 用户信息
     * @return 修改是否成功
     */
    @ApiOperation(value = "修改用户", notes = "username和password为必选项")
    @PostMapping("/updateUser")
    @SysLogger("updateUser")
    @Transactional
    @ApiIgnore
    public RespDTO updateUser(@RequestBody User user){
        //参数判读省略,判读该用户在数据库是否已经存在省略
        userFacade.updateUser(user);
        return RespDTO.onSuc(user);
    }

    /**
     * 查询用户信息
     * @param id 用户ID
     * @return 用户信息
     */
    @ApiOperation(value = "查询用户", notes = "查询用户")
    @GetMapping("/getUser")
    @SysLogger("getUser")
    @Transactional
    @ApiIgnore
    public RespDTO getUser(Long id){
        return RespDTO.onSuc(userFacade.getById(id));
    }

    /**
     * 删除用户
     * @param id 用户ID
     * @return 删除是否成功
     */
    @ApiOperation(value = "删除用户", notes = "删除用户")
    @PostMapping("/delUser")
    @SysLogger("delUser")
    @Transactional
    @ApiIgnore
    public RespDTO delUser(Long id){
        return RespDTO.onSuc(userFacade.removeById(id));
    }
}