管道基础大数据平台系统开发-【后端】-Server
Surpriseplus
2022-09-28 db09d7f7172399662996e34e4f9327bd7f027eb9
用户管理 令牌管理
已添加7个文件
851 ■■■■■ 文件已修改
src/main/java/com/lf/server/controller/data/UsersController.java 194 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/data/TokenEntity.java 115 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/entity/data/UsersEntity.java 214 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/mapper/data/TokenMapper.java 94 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/mapper/data/UsersMapper.java 90 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/UsersService.java 65 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/data/UsersMapper.xml 79 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/data/UsersController.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,194 @@
package com.lf.server.controller.data;
import com.lf.server.controller.BaseController;
import com.lf.server.entity.all.ResponseMsg;
import com.lf.server.entity.data.UsersEntity;
import com.lf.server.service.data.UsersService;
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.*;
import java.util.List;
/**
 * ç”¨æˆ·è¡¨
 * @author sws
 * @date 2022-09-27
 */
@Api(tags = "用户管理")
@RestController
@RequestMapping("/user")
public class UsersController extends BaseController {
    @Autowired
    UsersService userService;
    @ApiOperation(value = "查询记录数")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "uname", value = "用户名", dataType = "String", paramType = "query", required = false, example = "sys_user")
    })
    @GetMapping({"/selectCount"})
    public ResponseMsg<Integer> selectCount(String uname) {
        try {
            int count = userService.selectCount(uname);
            return success(count);
        } catch (Exception ex) {
            return fail(ex.getMessage(), -1);
        }
    }
    @ApiOperation(value = "分页查询")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "uname", value = "用戶名", dataType = "String", paramType = "query", example = "sys_user"),
            @ApiImplicitParam(name = "pageSize", value = "每页条数", dataType = "Integer", paramType = "query", example = "10"),
            @ApiImplicitParam(name = "pageIndex", value = "分页数(从1开始)", dataType = "Integer", paramType = "query", example = "1")
    })
    @GetMapping(value = "/selectByPage")
    public ResponseMsg<List<UsersEntity>> selectByPage(String uname, Integer pageSize, Integer pageIndex) {
        try {
            if (pageSize < 1 || pageIndex < 1) {
                return fail("每页页数或分页数小于1", null);
            }
            List<UsersEntity> rs = userService.selectByPage(uname, pageSize, pageSize * (pageIndex - 1));
            return success(rs);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @ApiOperation(value = "分页查询并返回记录数")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "uname", value = "用户名", dataType = "String", paramType = "query", example = "sys_dict"),
            @ApiImplicitParam(name = "pageSize", value = "每页条数", dataType = "Integer", paramType = "query", example = "10"),
            @ApiImplicitParam(name = "pageIndex", value = "分页数(从1开始)", dataType = "Integer", paramType = "query", example = "1")
    })
    @GetMapping(value = "/selectByPageAndCount")
    public ResponseMsg<List<UsersEntity>> selectByPageAndCount(String uname, Integer pageSize, Integer pageIndex) {
        try {
            if (pageSize < 1 || pageIndex < 1) {
                return fail("每页页数或分页数小于1", null);
            }
            int count = userService.selectCount(uname);
            if (count == 0) {
                return success(0, null);
            }
            List<UsersEntity> rs = userService.selectByPage(uname, pageSize, pageSize * (pageIndex - 1));
            return success(count, rs);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @ApiOperation(value = "插入字典")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "userEntity", value = "字典实体类", dataType = "com.lf.server.entity.data.UserEntity", paramType = "body", example = "")
    })
    @PostMapping(value = "/insertUser", produces = "application/json; charset=UTF-8")
    public ResponseMsg<Integer> insertUser(UsersEntity usersEntity) {
        try {
            int count = userService.insertUser(usersEntity);
            return success(count);
        } catch (Exception ex) {
            return fail(ex.getMessage(), -1);
        }
    }
    @ApiOperation(value = "插入多条字典")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "userEntity", value = "字典实体类集合", dataType = "List<UserEntity>", paramType = "body", example = "")
    })
    @PostMapping(value = "/insertUsers", produces = "application/json; charset=UTF-8")
    public ResponseMsg<Integer> insertUsers(@RequestBody List<UsersEntity> usersEntity) {
        try {
            int count = userService.insertUsers(usersEntity);
            return success(count);
        } catch (Exception ex) {
            return fail(ex.getMessage(), -1);
        }
    }
    @ApiOperation(value = "删除一条字典")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "字典ID", dataType = "Integer", paramType = "query", example = "1")
    })
    @GetMapping(value = "/deleteUser")
    public ResponseMsg<Integer> deleteUser(int id) {
        try {
            int count = userService.deleteUser(id);
            return success(count);
        } catch (Exception ex) {
            return fail(ex.getMessage(), -1);
        }
    }
    @ApiOperation(value = "删除多条字典")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "ids", value = "字典ID集合", dataType = "List<Integer>", paramType = "query", example = "1,2")
    })
    @GetMapping(value = "/deleteUsers")
    public ResponseMsg<Integer> deleteUsers(@RequestParam List<Integer> ids) {
        try {
            if (ids == null || ids.isEmpty()) {
                return fail("id数组不能为空", -1);
            }
            int count = userService.deleteUsers(ids);
            return success(count);
        } catch (Exception ex) {
            return fail(ex.getMessage(), -1);
        }
    }
    @ApiOperation(value = "更新一条字典")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "userEntity", value = "字典ID集合", dataType = "UserEntity", paramType = "body", example = "")
    })
    @ResponseBody
    @PostMapping(value = "/updateUsers", produces = "application/json; charset=UTF-8")
    public ResponseMsg<Integer> updateUsers(UsersEntity usersEntity) {
        try {
            int count = userService.updateUsers(usersEntity);
            return success(count);
        } catch (Exception ex) {
            return fail(ex.getMessage(), -1);
        }
    }
    @ApiOperation(value = "根据ID查询字典")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id", value = "字典ID", dataType = "Integer", paramType = "query", example = "1")
    })
    @GetMapping(value = "/selectUser")
    public ResponseMsg<UsersEntity> selectUser(int id) {
        try {
            UsersEntity usersEntity = userService.selectUser(id);
            return success(usersEntity);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
    @ApiOperation(value = "查询所有字典")
    @GetMapping(value = "/selectUserAll")
    public ResponseMsg<List<UsersEntity>> selectUserAll() {
        try {
            List<UsersEntity> list = userService.selectUserAll();
            return success(list);
        } catch (Exception ex) {
            return fail(ex.getMessage(), null);
        }
    }
}
src/main/java/com/lf/server/entity/data/TokenEntity.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,115 @@
package com.lf.server.entity.data;
import java.io.Serializable;
import java.sql.Time;
import java.sql.Timestamp;
/**
 * ä»¤ç‰Œè¡¨
 * @author sws
 * @date 2022-09-28
 */
public class TokenEntity implements Serializable {
    private static final long serialVersionUID = 1419309705830103150L;
    private int id;
    private String token;
    private int duration;
    private Timestamp expire;
    private int type;
    private String ip;
    private int createUser;
    private Timestamp createTime;
    private int updateUser;
    private Timestamp updateTime;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getToken() {
        return token;
    }
    public void setToken(String token) {
        this.token = token;
    }
    public int getDuration() {
        return duration;
    }
    public void setDuration(int duration) {
        this.duration = duration;
    }
    public Timestamp getExpire() {
        return expire;
    }
    public void setExpire(Timestamp expire) {
        this.expire = expire;
    }
    public int getType() {
        return type;
    }
    public void setType(int type) {
        this.type = type;
    }
    public String getIp() {
        return ip;
    }
    public void setIp(String ip) {
        this.ip = ip;
    }
    public int getCreateUser() {
        return createUser;
    }
    public void setCreateUser(int createUser) {
        this.createUser = createUser;
    }
    public Timestamp getCreateTime() {
        return createTime;
    }
    public void setCreateTime(Timestamp createTime) {
        this.createTime = createTime;
    }
    public int getUpdateUser() {
        return updateUser;
    }
    public void setUpdateUser(int updateUser) {
        this.updateUser = updateUser;
    }
    public Timestamp getUpdateTime() {
        return updateTime;
    }
    public void setUpdateTime(Timestamp updateTime) {
        this.updateTime = updateTime;
    }
}
src/main/java/com/lf/server/entity/data/UsersEntity.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,214 @@
package com.lf.server.entity.data;
import java.io.Serializable;
import java.sql.Timestamp;
/**
 * ç”¨æˆ·è¡¨
 * @author sws
 * @date 2022-09-27
 */
public class UsersEntity implements Serializable {
    private static final long serialVersionUID = 5676976561729666299L;
    private int id;
    private int depid;
    private String uid;
    private String uname;
    private String pwd;
    private String salt;
    private int sex;
    private String natives;
    private String contact;
    private String job;
    private String email;
    private String addr;
    private String edu;
    private String idcard;
    private int status;
    private int createUser;
    private Timestamp createTime;
    private int updateUser;
    private Timestamp updateTime;
    private String bak;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public int getDepid() {
        return depid;
    }
    public void setDepid(int depid) {
        this.depid = depid;
    }
    public String getUid() {
        return uid;
    }
    public void setUid(String uid) {
        this.uid = uid;
    }
    public String getUname() {
        return uname;
    }
    public void setUname(String uname) {
        this.uname = uname;
    }
    public String getPwd() {
        return pwd;
    }
    public void setPwd(String pwd) {
        this.pwd = pwd;
    }
    public String getSalt() {
        return salt;
    }
    public void setSalt(String salt) {
        this.salt = salt;
    }
    public int getSex() {
        return sex;
    }
    public void setSex(int sex) {
        this.sex = sex;
    }
    public String getNatives() {
        return natives;
    }
    public void setNatives(String natives) {
        this.natives = natives;
    }
    public String getContact() {
        return contact;
    }
    public void setContact(String contact) {
        this.contact = contact;
    }
    public String getJob() {
        return job;
    }
    public void setJob(String job) {
        this.job = job;
    }
    public String getEmail() {
        return email;
    }
    public void setEmail(String email) {
        this.email = email;
    }
    public String getAddr() {
        return addr;
    }
    public void setAddr(String addr) {
        this.addr = addr;
    }
    public String getEdu() {
        return edu;
    }
    public void setEdu(String edu) {
        this.edu = edu;
    }
    public String getIdcard() {
        return idcard;
    }
    public void setIdcard(String idcard) {
        this.idcard = idcard;
    }
    public int getStatus() {
        return status;
    }
    public void setStatus(int status) {
        this.status = status;
    }
    public int getCreateUser() {
        return createUser;
    }
    public void setCreateUser(int createUser) {
        this.createUser = createUser;
    }
    public Timestamp getCreateTime() {
        return createTime;
    }
    public void setCreateTime(Timestamp createTime) {
        this.createTime = createTime;
    }
    public int getUpdateUser() {
        return updateUser;
    }
    public void setUpdateUser(int updateUser) {
        this.updateUser = updateUser;
    }
    public Timestamp getUpdateTime() {
        return updateTime;
    }
    public void setUpdateTime(Timestamp updateTime) {
        this.updateTime = updateTime;
    }
    public String getBak() {
        return bak;
    }
    public void setBak(String bak) {
        this.bak = bak;
    }
}
src/main/java/com/lf/server/mapper/data/TokenMapper.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,94 @@
package com.lf.server.mapper.data;
import com.lf.server.entity.data.DictEntity;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.List;
/**
 * ä»¤ç‰Œè¡¨
 * @author sws
 * @date 2022-09-28
 */
@Mapper
@ResponseBody
public interface TokenMapper {
    /**
     * æ ¹æ®è¡¨åæŸ¥è¯¢è®°å½•æ•°
     *
     * @param tab è¡¨å
     * @return è®°å½•æ•°
     */
    public Integer selectCount(String tab);
    /**
     * æ ¹æ®è¡¨ååˆ†é¡µæŸ¥è¯¢
     *
     * @param tab    è¡¨å
     * @param limit  è®°å½•表
     * @param offset åç§»é‡
     * @return åˆ—表
     */
    public List<DictEntity> selectByPage(String tab, Integer limit, Integer offset);
    /**
     * æ·»åŠ æ•°æ®
     *
     * @param dictEntity
     * @return
     */
    public Integer insertDict(DictEntity dictEntity);
    /**
     * æ‰¹é‡æ·»åŠ 
     *
     * @param dictEntity
     * @return
     */
    public Integer insertDicts(List<DictEntity> dictEntity);
    /**
     * åˆªé™¤æ•°æ®
     *
     * @param id
     * @return
     */
    public Integer deleteDict(int id);
    /**
     * æ‰¹é‡åˆ é™¤
     *
     * @param ids
     * @return
     */
    public Integer deleteDicts(List<Integer> ids);
    /**
     * ä¿®æ”¹æ•°æ®
     *
     * @param dictEntity
     * @return
     */
    public Integer updateDict(DictEntity dictEntity);
    /**
     * æŸ¥è¯¢å•条数据
     *
     * @param id
     * @return
     */
    public DictEntity selectDict(int id);
    /**
     * æŸ¥è¯¢å…¨éƒ¨æ•°æ®
     *
     * @return
     */
    public List<DictEntity> selectDictAll();
}
src/main/java/com/lf/server/mapper/data/UsersMapper.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,90 @@
package com.lf.server.mapper.data;
import com.lf.server.entity.data.UsersEntity;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
 * å­—典管理
 * @author sws
 * @date 2022-09-27
 */
@Mapper
@Repository
public interface UsersMapper {
    /**
     * æ ¹æ®è¡¨åæŸ¥è¯¢è®°å½•æ•°
     *
     * @param uname ç”¨æˆ·å
     * @return è®°å½•æ•°
     */
    public Integer selectCount(String uname);
    /**
     * æ ¹æ®è¡¨ååˆ†é¡µæŸ¥è¯¢
     *
     * @param uname  ç”¨æˆ¶å
     * @param limit  è®°å½•表
     * @param offset åç§»é‡
     * @return åˆ—表
     */
    public List<UsersEntity> selectByPage(String uname, Integer limit, Integer offset);
    /**
     * æ·»åŠ æ•°æ®
     * @param usersEntity
     * @return
     */
    public Integer insertUser(UsersEntity usersEntity);
    /**
     * æ‰¹é‡æ·»åŠ 
     *
     * @param usersEntity
     * @return
     */
    public Integer insertUsers(List<UsersEntity> usersEntity);
    /**
     * åˆªé™¤æ•°æ®
     *
     * @param id
     * @return
     */
    public Integer deleteUser(int id);
    /**
     * æ‰¹é‡åˆ é™¤
     *
     * @param ids
     * @return
     */
    public Integer deleteUsers(List<Integer> ids);
    /**
     * ä¿®æ”¹æ•°æ®
     *
     * @param usersEntity
     * @return
     */
    public Integer updateUsers(UsersEntity usersEntity);
    /**
     * æŸ¥è¯¢å•条数据
     *
     * @param id
     * @return
     */
    public UsersEntity selectUser(int id);
    /**
     * æŸ¥è¯¢å…¨éƒ¨æ•°æ®
     *
     * @return
     */
    public List<UsersEntity> selectUserAll();
}
src/main/java/com/lf/server/service/data/UsersService.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,65 @@
package com.lf.server.service.data;
import com.lf.server.entity.data.UsersEntity;
import com.lf.server.mapper.data.UsersMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
 * ç”¨æˆ·è¡¨
 * @author sws
 * @date 2022-09-27
 */
@Service
public class UsersService implements UsersMapper {
    @Autowired
    UsersMapper usersMapper;
    @Override
    public Integer selectCount(String uname) {
        return usersMapper.selectCount(uname);
    }
    @Override
    public UsersEntity selectUser(int id) {
        return usersMapper.selectUser(id);
    }
    @Override
    public List<UsersEntity> selectUserAll() {
        return usersMapper.selectUserAll();
    }
    @Override
    public List<UsersEntity> selectByPage(String uname, Integer limit, Integer offset) {
        return usersMapper.selectByPage(uname,limit,offset);
    }
    @Override
    public Integer insertUser(UsersEntity usersEntity) {
        return usersMapper.insertUser(usersEntity);
    }
    @Override
    public Integer insertUsers(List<UsersEntity> usersEntity) {
        return usersMapper.insertUsers(usersEntity);
    }
    @Override
    public Integer deleteUser(int id) {
        return usersMapper.deleteUser(id);
    }
    @Override
    public Integer deleteUsers(List<Integer> ids) {
        return usersMapper.deleteUsers(ids);
    }
    @Override
    public Integer updateUsers(UsersEntity usersEntity) {
        return usersMapper.updateUsers(usersEntity);
    }
}
src/main/resources/mapper/data/UsersMapper.xml
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,79 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lf.server.mapper.data.UsersMapper">
    <resultMap id="resultMap" type="com.lf.server.entity.data.UsersEntity">
        <id property="id" column="id"></id>
        <result property="natives" column="native"></result>
        <result property="createUser" column="create_user"></result>
        <result property="createTime" column="create_time"></result>
        <result property="updateUser" column="update_user"></result>
        <result property="updateTime" column="update_time"></result>
    </resultMap>
    <!-- ç»Ÿè®¡è¡Œæ•° -->
    <select id="selectCount" resultType="java.lang.Integer" parameterType="java.lang.String">
        select count(*) from lf.sys_user
        <where>
            <if test="uname != null">
                uname = #{uname}
            </if>
        </where>
    </select>
    <!-- åˆ†é¡µæŸ¥è¯¢ -->
    <select id="selectByPage" resultMap="resultMap" resultType="com.lf.server.entity.data.UsersEntity">
        select * from lf.sys_user
        <where>
            <if test="uname != null">
                uname = #{uname}
            </if>
        </where>
        order by id
        limit #{limit} offset #{offset}
    </select>
    <select id="selectUserAll" resultMap="resultMap" resultType="com.lf.server.entity.data.UsersEntity">
        select * from lf.sys_user
    </select>
    <select id="selectUser" resultMap="resultMap" resultType="com.lf.server.entity.data.UsersEntity">
        select * from lf.sys_user where id = #{id}
    </select>
    <insert id="insertUser"  parameterType="com.lf.server.entity.data.UsersEntity">
       insert into lf.sys_user
       (depid,uid,uname,pwd,salt,sex,native,contact,job,email,addr,edu,idcard,status,create_user,create_time,bak)
       values
       (#{depid},#{uid},#{uname},#{pwd},#{salt},#{sex},#{natives},#{contact},#{job},#{email},#{addr},#{edu},#{idcard},
       #{status},#{createUser},now(),#{bak})
    </insert>
    <insert id="insertUsers"   >
       insert into lf.sys_user
        (depid,uid,uname,pwd,salt,sex,native,contact,job,email,addr,edu,idcard,status,create_user,create_time,bak)
       values
        <foreach collection="list"   item="item" index="index" separator=","  >
            (#{item.depid},#{item.uid},#{item.uname},#{item.pwd},#{item.salt},#{item.sex},#{item.natives},#{item.contact},#{item.job},
            #{item.email},#{item.addr},#{item.edu},#{item.idcard},#{item.status},#{item.createUser}, now(),#{item.bak})
        </foreach>
    </insert>
    <delete id="deleteUser"  >
        delete from lf.sys_user where id = #{id}
    </delete>
    <delete id="deleteUsers"  >
        delete from lf.sys_user where id in
        <foreach item="ids" collection="list" index="index" open="("
                 separator="," close=")">
            #{ids}
        </foreach>
    </delete>
    <update id="updateUsers">
    update lf.sys_user set depid=#{depid},uid=#{uid},uname=#{uname},pwd=#{pwd},salt=#{salt},sex=#{sex},native=#{natives},contact=#{contact},job=#{job},email=#{email},
    addr=#{addr},edu=#{edu},idcard=#{idcard},status=#{status},update_user=#{updateUser},update_time=now(),bak=#{bak} where id=#{id}
    </update>
</mapper>