Commit ee6d8621 by liulianglang

区域协作

parent b3a4c979
package org.springblade.founder.xzqq.controller;
import org.springblade.founder.utils.R;
import org.springblade.founder.xzqq.entity.TbYwXzqqMjxx;
import org.springblade.founder.xzqq.entity.TbYwXzqqXx;
import org.springblade.founder.xzqq.service.TbYwXzqqMjxxService;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
/**
* (TbYwXzqqMjxx)表控制层
*
* @author liulianglang
* @since 2023-11-07 15:06:00
*/
@RestController
@RequestMapping("tbYwXzqqMjxx")
public class TbYwXzqqMjxxController {
/**
* 服务对象
*/
@Resource
private TbYwXzqqMjxxService tbYwXzqqMjxxService;
/**
* 通过主键查询单条数据
*
* @param id 主键
* @return 单条数据
*/
@PostMapping("selectOne")
public TbYwXzqqMjxx selectOne(String id) {
return this.tbYwXzqqMjxxService.queryById(id);
}
@PostMapping("/insertMjxx")
public R insertMjxx(TbYwXzqqMjxx tbYwXzqqXx) {
tbYwXzqqMjxxService.insert(tbYwXzqqXx);
return R.ok().data("xxzjbh","");
}
}
package org.springblade.founder.xzqq.controller;
import org.springblade.founder.utils.R;
import org.springblade.founder.xzqq.entity.TbYwXzqqXx;
import org.springblade.founder.xzqq.service.TbYwXzqqXxService;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
/**
* 协作请求主表(TbYwXzqqXx)表控制层
*
* @author liulianglang
* @since 2023-11-07 14:59:00
*/
@RestController
@RequestMapping("tbYwXzqqXx")
public class TbYwXzqqXxController {
/**
* 服务对象
*/
@Resource
private TbYwXzqqXxService tbYwXzqqXxService;
/**
* 通过主键查询单条数据
*
* @param id 主键
* @return 单条数据
*/
@PostMapping("selectOne")
public TbYwXzqqXx selectOne(String id) {
return this.tbYwXzqqXxService.queryById(id);
}
@PostMapping("/insertXzqqXx")
public R insertXzqqXx(TbYwXzqqXx tbYwXzqqXx) {
tbYwXzqqXxService.insert(tbYwXzqqXx);
return R.ok().data("xxzjbh","");
}
}
package org.springblade.founder.xzqq.controller;
import org.springblade.founder.utils.R;
import org.springblade.founder.xzqq.entity.TbYwXzqqXx;
import org.springblade.founder.xzqq.entity.TbYwXzqqXyrxx;
import org.springblade.founder.xzqq.service.TbYwXzqqXyrxxService;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
/**
* (TbYwXzqqXyrxx)表控制层
*
* @author liulianglang
* @since 2023-11-07 15:05:02
*/
@RestController
@RequestMapping("tbYwXzqqXyrxx")
public class TbYwXzqqXyrxxController {
/**
* 服务对象
*/
@Resource
private TbYwXzqqXyrxxService tbYwXzqqXyrxxService;
/**
* 通过主键查询单条数据
*
* @param id 主键
* @return 单条数据
*/
@PostMapping("selectOne")
public TbYwXzqqXyrxx selectOne(String id) {
return this.tbYwXzqqXyrxxService.queryById(id);
}
@PostMapping("/insertXyrxx")
public R insertXyrxx(TbYwXzqqXyrxx tbYwXzqqXx) {
tbYwXzqqXyrxxService.insert(tbYwXzqqXx);
return R.ok().data("xxzjbh","");
}
}
package org.springblade.founder.xzqq.controller;
import org.springblade.founder.utils.R;
import org.springblade.founder.xzqq.entity.TbYwXzqqXx;
import org.springblade.founder.xzqq.entity.TbYwXzqqZhryxx;
import org.springblade.founder.xzqq.service.TbYwXzqqZhryxxService;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
/**
* (TbYwXzqqZhryxx)表控制层
*
* @author liulianglang
* @since 2023-11-07 15:06:42
*/
@RestController
@RequestMapping("tbYwXzqqZhryxx")
public class TbYwXzqqZhryxxController {
/**
* 服务对象
*/
@Resource
private TbYwXzqqZhryxxService tbYwXzqqZhryxxService;
/**
* 通过主键查询单条数据
*
* @param id 主键
* @return 单条数据
*/
@PostMapping("selectOne")
public TbYwXzqqZhryxx selectOne(String id) {
return this.tbYwXzqqZhryxxService.queryById(id);
}
@PostMapping("/insertZhryxx")
public R insertZhryxx(TbYwXzqqZhryxx tbYwXzqqXx) {
tbYwXzqqZhryxxService.insert(tbYwXzqqXx);
return R.ok().data("xxzjbh","");
}
}
package org.springblade.founder.xzqq.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.util.Date;
/**
* 调证请求附件信息*
*
* @author zzj*
*/
@Data
public class TbYwDzqqFj {
/**
* 信息主键编号*
*/
private String xxzjbh;
/**
* 关联的调证xxzjbh,非dzbh*
*/
private String dzXxzjbh;
/**
* 电子文件标题*
*/
private String dzwjbt;
/**
* 电子文件格式*
*/
private String dzwjgs;
/**
* 电子文件位置*
*/
private String dzwjwz;
/**
* 电子文件内容*
*/
private byte[] dzwjnr;
private String fjlx;
/**
* 创建时间*
*/
private Date createTime;
/**
* 创建人 身份证号*
*/
private String createBy;
/**
* 更新时间*
*/
private Date updateTime;
/**
* 更新人 身份证号*
*/
private String updateBy;
/**
* 信息删除判断标志*
*/
private String xxscPdbz;
}
package org.springblade.founder.xzqq.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class TbYwXzqqMjxx implements Serializable {
private static final long serialVersionUID = 601465493791735514L;
/**
* 信息主键编号
*/
private String xxzjbh;
/**
* 关联信息主键编号
*/
private String glxxzjbh;
/**
* 身份证号
*/
private String identitycard;
/**
* 警号
*/
private String policemanid;
private String zmjgzp;
/**
* 反面警官照片
*/
private String fmjgzp;
/**
* 登记时间
*/
private Object djsj;
/**
* 更新时间
*/
private Object gxsj;
/**
* 登记单位代码
*/
private String lrdwdm;
}
package org.springblade.founder.xzqq.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class TbYwXzqqXx implements Serializable {
private static final long serialVersionUID = 323302592009039237L;
/**
* 信息主键编号
*/
private String xxzjbh;
/**
* 协作编号
*/
private String xzbh;
/**
* 办案单位名称
*/
private String badwmc;
/**
* 办案单位代码
*/
private String badwdm;
/**
* 关联的案件编号
*/
private String asjbh;
/**
* 案件名称
*/
private String ajmc;
/**
* 案件类别代码
*/
private String ajlbdm;
/**
* 简要案情
*/
private String jayq;
/**
* 申请时间
*/
private Date sqsj;
/**
* 审批人身份证号
*/
private String sprSfzh;
/**
* 审批意见
*/
private String spyj;
/**
* 审批时间
*/
private Date spsj;
/**
* 协作状态
*/
private String xzzt;
/**
* 信息删除判断标志
*/
private String xxscPdbz;
/**
* 信息登记单位_公安机关机构代码/采用GA 380《全国公安机关机构代码编码规则》统一编制的代码/CODE_GXS
*/
private String xxdjdwGajgjgdm;
/**
* 信息登记单位_公安机关名称
*/
private String xxdjdwGajgmc;
/**
* 信息登记人员_姓名
*/
private String xxdjryXm;
/**
* 信息登记人员_公民身份号码/符合GB 11643《公民身份号码》
*/
private String xxdjryGmsfhm;
/**
* 信息登记人员_联系电话
*/
private String xxdjryLxdh;
/**
* 登记时间
*/
private Date djsj;
/**
* 信息操作单位_公安机关机构代码/采用GA 380《全国公安机关机构代码编码规则》统一编制的代码/CODE_GXS
*/
private String xxczdwGajgjgdm;
/**
* 信息操作单位_公安机关名称
*/
private String xxczdwGajgmc;
/**
* 信息操作人员_姓名
*/
private String xxczryXm;
/**
* 信息操作人员_公民身份号码/符合GB 11643《公民身份号码》
*/
private String xxczryGmsfhm;
/**
* 更新时间
*/
private Date gxsj;
}
package org.springblade.founder.xzqq.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class TbYwXzqqXyrxx implements Serializable {
private static final long serialVersionUID = 432361304166919401L;
/**
* 信息主键编号
*/
private String xxzjbh;
/**
* 关联信息主键编号
*/
private String glxxzjbh;
/**
* 人员类型
*/
private String rylx;
/**
* 网安协助
*/
private String waxz;
/**
* 任务编号
*/
private String rwbh;
/**
* 信息删除判断标志
*/
private String xxscPdbz;
/**
* 嫌疑人姓名
*/
private String xyrxm;
/**
* 嫌疑人sfzh
*/
private String xyrsfzh;
/**
* 嫌疑人性别
*/
private String xyrxb;
/**
* 嫌疑人户籍地
*/
private String xyrhjd;
/**
* 嫌疑人涉嫌罪名
*/
private String xyrsxzm;
/**
* 嫌疑人所在位置
*/
private String xyrszwz;
/**
* 嫌疑人近期活动轨迹
*/
private String xyrjqhdgj;
/**
* 嫌疑人协作地
*/
private String xyrxzd;
/**
* 信息登记单位_公安机关机构代码/采用GA 380《全国公安机关机构代码编码规则》统一编制的代码/CODE_GXS
*/
private String xxdjdwGajgjgdm;
/**
* 信息登记单位_公安机关名称
*/
private String xxdjdwGajgmc;
/**
* 信息登记人员_姓名
*/
private String xxdjryXm;
/**
* 信息登记人员_公民身份号码/符合GB 11643《公民身份号码》
*/
private String xxdjryGmsfhm;
/**
* 信息登记人员_联系电话
*/
private String xxdjryLxdh;
/**
* 登记时间
*/
private Date djsj;
/**
* 信息操作单位_公安机关机构代码/采用GA 380《全国公安机关机构代码编码规则》统一编制的代码/CODE_GXS
*/
private String xxczdwGajgjgdm;
/**
* 信息操作单位_公安机关名称
*/
private String xxczdwGajgmc;
/**
* 信息操作人员_姓名
*/
private String xxczryXm;
/**
* 信息操作人员_公民身份号码/符合GB 11643《公民身份号码》
*/
private String xxczryGmsfhm;
/**
* 更新时间
*/
private Date gxsj;
}
package org.springblade.founder.xzqq.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class TbYwXzqqZhryxx implements Serializable {
private static final long serialVersionUID = 653890608077800682L;
/**
* 信息主键编号
*/
private String xxzjbh;
/**
* 关联信息主键编号
*/
private String glxxzjbh;
/**
* 信息删除判断标志
*/
private String xxscPdbz;
/**
* 嫌疑人姓名
*/
private String xyrxm;
/**
* 嫌疑人sfzh
*/
private String xyrsfzh;
/**
* 嫌疑人户籍地
*/
private String xyrhjd;
/**
* 嫌疑人涉嫌罪名
*/
private String xyrsxzm;
/**
* 关联案事件编号
*/
private String glasjbh;
/**
* 嫌疑人抓获地址
*/
private String xyrzhdz;
/**
* 刑事强制措施
*/
private String xsqzcs;
/**
* 角色地位
*/
private String jsdw;
/**
* 信息登记单位_公安机关机构代码/采用GA 380《全国公安机关机构代码编码规则》统一编制的代码/CODE_GXS
*/
private String xxdjdwGajgjgdm;
/**
* 信息登记单位_公安机关名称
*/
private String xxdjdwGajgmc;
/**
* 信息登记人员_姓名
*/
private String xxdjryXm;
/**
* 信息登记人员_公民身份号码/符合GB 11643《公民身份号码》
*/
private String xxdjryGmsfhm;
/**
* 信息登记人员_联系电话
*/
private String xxdjryLxdh;
/**
* 登记时间
*/
private Date djsj;
/**
* 信息操作单位_公安机关机构代码/采用GA 380《全国公安机关机构代码编码规则》统一编制的代码/CODE_GXS
*/
private String xxczdwGajgjgdm;
/**
* 信息操作单位_公安机关名称
*/
private String xxczdwGajgmc;
/**
* 信息操作人员_姓名
*/
private String xxczryXm;
/**
* 信息操作人员_公民身份号码/符合GB 11643《公民身份号码》
*/
private String xxczryGmsfhm;
/**
* 更新时间
*/
private Date gxsj;
}
package org.springblade.founder.xzqq.mapper;
import org.springblade.founder.xzqq.entity.TbYwXzqqMjxx;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import com.baomidou.dynamic.datasource.annotation.DS;
/**
* (TbYwXzqqMjxx)表数据库访问层
*
* @author liulianglang
* @since 2023-11-07 15:06:00
*/
@Component
@Mapper
public interface TbYwXzqqMjxxMapper {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqMjxx queryById(String xxzjbh);
/**
* 查询指定行数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqMjxx> queryAllByLimit(@Param("offset") int offset, @Param("limit") int limit);
/**
* 通过实体作为筛选条件查询
*
* @param tbYwXzqqMjxx 实例对象
* @return 对象列表
*/
List<TbYwXzqqMjxx> queryAll(TbYwXzqqMjxx tbYwXzqqMjxx);
int queryAllCount(TbYwXzqqMjxx tbYwXzqqMjxx);
/**
* 新增数据
*
* @param tbYwXzqqMjxx 实例对象
* @return 影响行数
*/
int insert(TbYwXzqqMjxx tbYwXzqqMjxx);
/**
* 批量新增数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqMjxx> 实例对象列表
* @return 影响行数
*/
int insertBatch(@Param("entities") List<TbYwXzqqMjxx> entities);
/**
* 批量新增或按主键更新数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqMjxx> 实例对象列表
* @return 影响行数
*/
int insertOrUpdateBatch(@Param("entities") List<TbYwXzqqMjxx> entities);
/**
* 修改数据
*
* @param tbYwXzqqMjxx 实例对象
* @return 影响行数
*/
int update(TbYwXzqqMjxx tbYwXzqqMjxx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 影响行数
*/
int deleteById(String xxzjbh);
}
<?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="org.springblade.founder.xzqq.mapper.TbYwXzqqMjxxMapper">
<!--查询单个-->
<select id="queryById" resultType="org.springblade.founder.xzqq.entity.TbYwXzqqMjxx">
select
glxxzjbh, identitycard, policemanid, zmjgzp, fmjgzp, djsj, gxsj, lrdwdm
from xzxt.tb_yw_xzqq_mjxx
where xxzjbh = #{xxzjbh}
</select>
<!--查询指定行数据-->
<select id="queryAllByLimit" resultType="org.springblade.founder.xzqq.entity.TbYwXzqqMjxx">
select
glxxzjbh, identitycard, policemanid, zmjgzp, fmjgzp, djsj, gxsj, lrdwdm
from xzxt.tb_yw_xzqq_mjxx
limit #{offset}, #{limit}
</select>
<!--通过实体作为筛选条件查询-->
<select id="queryAll" resultType="org.springblade.founder.xzqq.entity.TbYwXzqqMjxx">
select
glxxzjbh, identitycard, policemanid, zmjgzp, fmjgzp, djsj, gxsj, lrdwdm
from xzxt.tb_yw_xzqq_mjxx
<where>
<if test="xxzjbh != null and xxzjbh != ''">
and xxzjbh = #{xxzjbh}
</if>
<if test="glxxzjbh != null and glxxzjbh != ''">
and glxxzjbh = #{glxxzjbh}
</if>
<if test="identitycard != null and identitycard != ''">
and identitycard = #{identitycard}
</if>
<if test="policemanid != null and policemanid != ''">
and policemanid = #{policemanid}
</if>
<if test="zmjgzp != null and zmjgzp != ''">
and zmjgzp = #{zmjgzp}
</if>
<if test="fmjgzp != null and fmjgzp != ''">
and fmjgzp = #{fmjgzp}
</if>
<if test="djsj != null">
and djsj = #{djsj}
</if>
<if test="gxsj != null">
and gxsj = #{gxsj}
</if>
<if test="lrdwdm != null and lrdwdm != ''">
and lrdwdm = #{lrdwdm}
</if>
</where>
</select>
<!--新增所有列-->
<insert id="insert" >
insert into tb_yw_xzqq_mjxx(xxzjbh,glxxzjbh, identitycard, policemanid, zmjgzp, fmjgzp, djsj, gxsj, lrdwdm)
values (#{xxzjbh},#{glxxzjbh}, #{identitycard}, #{policemanid}, #{zmjgzp}, #{fmjgzp}, #{djsj}, #{gxsj}, #{lrdwdm})
</insert>
<insert id="insertBatch" keyProperty="xxzjbh" useGeneratedKeys="true">
insert into xzxt.tb_yw_xzqq_mjxx(glxxzjbh, identitycard, policemanid, zmjgzp, fmjgzp, djsj, gxsj, lrdwdm)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.glxxzjbh}, #{entity.identitycard}, #{entity.policemanid}, #{entity.zmjgzp}, #{entity.fmjgzp}, #{entity.djsj}, #{entity.gxsj}, #{entity.lrdwdm})
</foreach>
</insert>
<insert id="insertOrUpdateBatch" keyProperty="xxzjbh" useGeneratedKeys="true">
insert into xzxt.tb_yw_xzqq_mjxx(glxxzjbh, identitycard, policemanid, zmjgzp, fmjgzp, djsj, gxsj, lrdwdm)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.glxxzjbh}, #{entity.identitycard}, #{entity.policemanid}, #{entity.zmjgzp}, #{entity.fmjgzp}, #{entity.djsj}, #{entity.gxsj}, #{entity.lrdwdm})
</foreach>
on duplicate key update
glxxzjbh = values(glxxzjbh) , identitycard = values(identitycard) , policemanid = values(policemanid) , zmjgzp = values(zmjgzp) , fmjgzp = values(fmjgzp) , djsj = values(djsj) , gxsj = values(gxsj) , lrdwdm = values(lrdwdm) </insert>
<!--通过主键修改数据-->
<update id="update">
update xzxt.tb_yw_xzqq_mjxx
<set>
<if test="glxxzjbh != null and glxxzjbh != ''">
glxxzjbh = #{glxxzjbh},
</if>
<if test="identitycard != null and identitycard != ''">
identitycard = #{identitycard},
</if>
<if test="policemanid != null and policemanid != ''">
policemanid = #{policemanid},
</if>
<if test="zmjgzp != null and zmjgzp != ''">
zmjgzp = #{zmjgzp},
</if>
<if test="fmjgzp != null and fmjgzp != ''">
fmjgzp = #{fmjgzp},
</if>
<if test="djsj != null">
djsj = #{djsj},
</if>
<if test="gxsj != null">
gxsj = #{gxsj},
</if>
<if test="lrdwdm != null and lrdwdm != ''">
lrdwdm = #{lrdwdm},
</if>
</set>
where xxzjbh = #{xxzjbh}
</update>
<!--通过主键删除-->
<delete id="deleteById">
delete from xzxt.tb_yw_xzqq_mjxx where xxzjbh = #{xxzjbh}
</delete>
</mapper>
package org.springblade.founder.xzqq.mapper;
import org.springblade.founder.xzqq.entity.TbYwDzqqFj;
import org.springblade.founder.xzqq.entity.TbYwXzqqXx;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import com.baomidou.dynamic.datasource.annotation.DS;
/**
* 协作请求主表(TbYwXzqqXx)表数据库访问层
*
* @author liulianglang
* @since 2023-11-07 14:58:46
*/
@Component
@Mapper
public interface TbYwXzqqXxMapper {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqXx queryById(String xxzjbh);
/**
* 查询指定行数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqXx> queryAllByLimit(@Param("offset") int offset, @Param("limit") int limit);
/**
* 通过实体作为筛选条件查询
*
* @param tbYwXzqqXx 实例对象
* @return 对象列表
*/
List<TbYwXzqqXx> queryAll(TbYwXzqqXx tbYwXzqqXx);
int queryAllCount(TbYwXzqqXx tbYwXzqqXx);
/**
* 新增数据
*
* @param tbYwXzqqXx 实例对象
* @return 影响行数
*/
int insert(TbYwXzqqXx tbYwXzqqXx);
TbYwDzqqFj queryFjById(String xxzjbh);
int insertFj(TbYwDzqqFj tbYwDzqqFj);
/**
* 批量新增数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqXx> 实例对象列表
* @return 影响行数
*/
int insertBatch(@Param("entities") List<TbYwXzqqXx> entities);
/**
* 批量新增或按主键更新数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqXx> 实例对象列表
* @return 影响行数
*/
int insertOrUpdateBatch(@Param("entities") List<TbYwXzqqXx> entities);
/**
* 修改数据
*
* @param tbYwXzqqXx 实例对象
* @return 影响行数
*/
int update(TbYwXzqqXx tbYwXzqqXx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 影响行数
*/
int deleteById(String xxzjbh);
}
package org.springblade.founder.xzqq.mapper;
import org.springblade.founder.xzqq.entity.TbYwXzqqXyrxx;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import com.baomidou.dynamic.datasource.annotation.DS;
/**
* (TbYwXzqqXyrxx)表数据库访问层
*
* @author liulianglang
* @since 2023-11-07 15:05:02
*/
@Component
@Mapper
public interface TbYwXzqqXyrxxMapper {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqXyrxx queryById(String xxzjbh);
/**
* 查询指定行数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqXyrxx> queryAllByLimit(@Param("offset") int offset, @Param("limit") int limit);
/**
* 通过实体作为筛选条件查询
*
* @param tbYwXzqqXyrxx 实例对象
* @return 对象列表
*/
List<TbYwXzqqXyrxx> queryAll(TbYwXzqqXyrxx tbYwXzqqXyrxx);
int queryAllCount(TbYwXzqqXyrxx tbYwXzqqXyrxx);
/**
* 新增数据
*
* @param tbYwXzqqXyrxx 实例对象
* @return 影响行数
*/
int insert(TbYwXzqqXyrxx tbYwXzqqXyrxx);
/**
* 批量新增数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqXyrxx> 实例对象列表
* @return 影响行数
*/
int insertBatch(@Param("entities") List<TbYwXzqqXyrxx> entities);
/**
* 批量新增或按主键更新数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqXyrxx> 实例对象列表
* @return 影响行数
*/
int insertOrUpdateBatch(@Param("entities") List<TbYwXzqqXyrxx> entities);
/**
* 修改数据
*
* @param tbYwXzqqXyrxx 实例对象
* @return 影响行数
*/
int update(TbYwXzqqXyrxx tbYwXzqqXyrxx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 影响行数
*/
int deleteById(String xxzjbh);
}
package org.springblade.founder.xzqq.mapper;
import org.springblade.founder.xzqq.entity.TbYwXzqqZhryxx;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import com.baomidou.dynamic.datasource.annotation.DS;
/**
* (TbYwXzqqZhryxx)表数据库访问层
*
* @author liulianglang
* @since 2023-11-07 15:06:42
*/
@Component
@Mapper
public interface TbYwXzqqZhryxxMapper {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqZhryxx queryById(String xxzjbh);
/**
* 查询指定行数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqZhryxx> queryAllByLimit(@Param("offset") int offset, @Param("limit") int limit);
/**
* 通过实体作为筛选条件查询
*
* @param tbYwXzqqZhryxx 实例对象
* @return 对象列表
*/
List<TbYwXzqqZhryxx> queryAll(TbYwXzqqZhryxx tbYwXzqqZhryxx);
int queryAllCount(TbYwXzqqZhryxx tbYwXzqqZhryxx);
/**
* 新增数据
*
* @param tbYwXzqqZhryxx 实例对象
* @return 影响行数
*/
int insert(TbYwXzqqZhryxx tbYwXzqqZhryxx);
/**
* 批量新增数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqZhryxx> 实例对象列表
* @return 影响行数
*/
int insertBatch(@Param("entities") List<TbYwXzqqZhryxx> entities);
/**
* 批量新增或按主键更新数据(MyBatis原生foreach方法)
*
* @param entities List<TbYwXzqqZhryxx> 实例对象列表
* @return 影响行数
*/
int insertOrUpdateBatch(@Param("entities") List<TbYwXzqqZhryxx> entities);
/**
* 修改数据
*
* @param tbYwXzqqZhryxx 实例对象
* @return 影响行数
*/
int update(TbYwXzqqZhryxx tbYwXzqqZhryxx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 影响行数
*/
int deleteById(String xxzjbh);
}
package org.springblade.founder.xzqq.service;
import org.springblade.founder.xzqq.entity.TbYwXzqqMjxx;
import java.util.List;
/**
* (TbYwXzqqMjxx)表服务接口
*
* @author liulianglang
* @since 2023-11-07 15:06:00
*/
public interface TbYwXzqqMjxxService {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqMjxx queryById(String xxzjbh);
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqMjxx> queryAllByLimit(int offset, int limit);
/**
* 新增数据
*
* @param tbYwXzqqMjxx 实例对象
* @return 实例对象
*/
TbYwXzqqMjxx insert(TbYwXzqqMjxx tbYwXzqqMjxx);
/**
* 修改数据
*
* @param tbYwXzqqMjxx 实例对象
* @return 实例对象
*/
TbYwXzqqMjxx update(TbYwXzqqMjxx tbYwXzqqMjxx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
boolean deleteById(String xxzjbh);
}
package org.springblade.founder.xzqq.service;
import org.springblade.founder.xzqq.entity.TbYwXzqqXx;
import java.util.List;
/**
* 协作请求主表(TbYwXzqqXx)表服务接口
*
* @author liulianglang
* @since 2023-11-07 14:58:52
*/
public interface TbYwXzqqXxService {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqXx queryById(String xxzjbh);
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqXx> queryAllByLimit(int offset, int limit);
/**
* 新增数据
*
* @param tbYwXzqqXx 实例对象
* @return 实例对象
*/
TbYwXzqqXx insert(TbYwXzqqXx tbYwXzqqXx);
/**
* 修改数据
*
* @param tbYwXzqqXx 实例对象
* @return 实例对象
*/
TbYwXzqqXx update(TbYwXzqqXx tbYwXzqqXx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
boolean deleteById(String xxzjbh);
}
package org.springblade.founder.xzqq.service;
import org.springblade.founder.xzqq.entity.TbYwXzqqXyrxx;
import java.util.List;
/**
* (TbYwXzqqXyrxx)表服务接口
*
* @author liulianglang
* @since 2023-11-07 15:05:02
*/
public interface TbYwXzqqXyrxxService {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqXyrxx queryById(String xxzjbh);
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqXyrxx> queryAllByLimit(int offset, int limit);
/**
* 新增数据
*
* @param tbYwXzqqXyrxx 实例对象
* @return 实例对象
*/
TbYwXzqqXyrxx insert(TbYwXzqqXyrxx tbYwXzqqXyrxx);
/**
* 修改数据
*
* @param tbYwXzqqXyrxx 实例对象
* @return 实例对象
*/
TbYwXzqqXyrxx update(TbYwXzqqXyrxx tbYwXzqqXyrxx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
boolean deleteById(String xxzjbh);
}
package org.springblade.founder.xzqq.service;
import org.springblade.founder.xzqq.entity.TbYwXzqqZhryxx;
import java.util.List;
/**
* (TbYwXzqqZhryxx)表服务接口
*
* @author liulianglang
* @since 2023-11-07 15:06:42
*/
public interface TbYwXzqqZhryxxService {
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
TbYwXzqqZhryxx queryById(String xxzjbh);
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
List<TbYwXzqqZhryxx> queryAllByLimit(int offset, int limit);
/**
* 新增数据
*
* @param tbYwXzqqZhryxx 实例对象
* @return 实例对象
*/
TbYwXzqqZhryxx insert(TbYwXzqqZhryxx tbYwXzqqZhryxx);
/**
* 修改数据
*
* @param tbYwXzqqZhryxx 实例对象
* @return 实例对象
*/
TbYwXzqqZhryxx update(TbYwXzqqZhryxx tbYwXzqqZhryxx);
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
boolean deleteById(String xxzjbh);
}
package org.springblade.founder.xzqq.service.impl;
import org.springblade.core.secure.utils.SecureUtil;
import org.springblade.founder.utils.SysXxzjbhService;
import org.springblade.founder.xzqq.entity.TbYwXzqqMjxx;
import org.springblade.founder.xzqq.mapper.TbYwXzqqMjxxMapper;
import org.springblade.founder.xzqq.service.TbYwXzqqMjxxService;
import org.springblade.modules.system.entity.XzxtUser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
import java.util.UUID;
/**
* (TbYwXzqqMjxx)表服务实现类
*
* @author liulianglang
* @since 2023-11-07 15:06:00
*/
@Service("tbYwXzqqMjxxService")
public class TbYwXzqqMjxxServiceImpl implements TbYwXzqqMjxxService {
@Resource
private TbYwXzqqMjxxMapper tbYwXzqqMjxxMapper;
@Autowired
private SysXxzjbhService xxzjbhService;
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
@Override
public TbYwXzqqMjxx queryById(String xxzjbh) {
return this.tbYwXzqqMjxxMapper.queryById(xxzjbh);
}
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
@Override
public List<TbYwXzqqMjxx> queryAllByLimit(int offset, int limit) {
return this.tbYwXzqqMjxxMapper.queryAllByLimit(offset, limit);
}
/**
* 新增数据
*
* @param tbYwXzqqMjxx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqMjxx insert(TbYwXzqqMjxx tbYwXzqqMjxx) {
XzxtUser xzxtUser = SecureUtil.getUserXzxt();
String blxxzjbh = getOrderIdByUUId();
tbYwXzqqMjxx.setXxzjbh(blxxzjbh);
this.tbYwXzqqMjxxMapper.insert(tbYwXzqqMjxx);
return tbYwXzqqMjxx;
}
/**
* 修改数据
*
* @param tbYwXzqqMjxx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqMjxx update(TbYwXzqqMjxx tbYwXzqqMjxx) {
this.tbYwXzqqMjxxMapper.update(tbYwXzqqMjxx);
return this.queryById(tbYwXzqqMjxx.getXxzjbh());
}
public static String getOrderIdByUUId(){
int machineId = 1;//最大支持1-9个集群机器部署
int hashCodev = UUID.randomUUID().toString().hashCode();
// System.out.println(UUID.randomUUID().toString());
if(hashCodev < 0){
//有可能是负数
hashCodev = -hashCodev;
}
//"%015d"的意思:0代表不足位数的补0,这样可以确保相同的位数,15是位数也就是要得到到的字符串长度是15,d代表数字。
return machineId + String.format("%029d", hashCodev);
}
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
@Override
public boolean deleteById(String xxzjbh) {
return this.tbYwXzqqMjxxMapper.deleteById(xxzjbh) > 0;
}
}
package org.springblade.founder.xzqq.service.impl;
import org.springblade.core.secure.utils.SecureUtil;
import org.springblade.founder.utils.SysXxzjbhService;
import org.springblade.founder.xzqq.entity.TbYwDzqqFj;
import org.springblade.founder.xzqq.entity.TbYwXzqqXx;
import org.springblade.founder.xzqq.mapper.TbYwXzqqXxMapper;
import org.springblade.founder.xzqq.service.TbYwXzqqXxService;
import org.springblade.modules.system.entity.XzxtUser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.io.IOException;
import java.util.Date;
import java.util.List;
import java.util.UUID;
/**
* 协作请求主表(TbYwXzqqXx)表服务实现类
*
* @author liulianglang
* @since 2023-11-07 14:58:58
*/
@Service("tbYwXzqqXxService")
public class TbYwXzqqXxServiceImpl implements TbYwXzqqXxService {
@Resource
private TbYwXzqqXxMapper tbYwXzqqXxMapper;
@Autowired
private SysXxzjbhService xxzjbhService;
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
@Override
public TbYwXzqqXx queryById(String xxzjbh) {
return this.tbYwXzqqXxMapper.queryById(xxzjbh);
}
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
@Override
public List<TbYwXzqqXx> queryAllByLimit(int offset, int limit) {
return this.tbYwXzqqXxMapper.queryAllByLimit(offset, limit);
}
/**
* 新增数据
*
* @param tbYwXzqqXx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqXx insert(TbYwXzqqXx tbYwXzqqXx) {
XzxtUser xzxtUser = SecureUtil.getUserXzxt();
String blxxzjbh = xxzjbhService.getXxzjbh(xzxtUser.getUnitcode(),null);//xxzjbh
this.tbYwXzqqXxMapper.insert(tbYwXzqqXx);
return tbYwXzqqXx;
}
//保存附件至tb_yw_xzqq_fj表
private void saveAttachment(String dzXxzjbh, List<MultipartFile> fjList, String fjlx) throws IOException {
XzxtUser userXzxt = SecureUtil.getUserXzxt();
for (MultipartFile multipartFile : fjList) {
TbYwDzqqFj fj = new TbYwDzqqFj();
fj.setXxzjbh(getOrderIdByUUId());
fj.setDzXxzjbh(dzXxzjbh);
String dzwjbt = multipartFile.getOriginalFilename();
fj.setDzwjbt(dzwjbt);
String dzwjgs = dzwjbt.substring(dzwjbt.lastIndexOf("."));
fj.setDzwjgs(dzwjgs.toLowerCase());
fj.setDzwjnr(multipartFile.getBytes());
fj.setFjlx(fjlx);
fj.setCreateTime(new Date());
fj.setCreateBy(userXzxt.getIdentitycard());
fj.setUpdateTime(new Date());
fj.setUpdateBy(userXzxt.getIdentitycard());
fj.setXxscPdbz("0");
tbYwXzqqXxMapper.insertFj(fj);
}
}
public static String getOrderIdByUUId(){
int machineId = 1;//最大支持1-9个集群机器部署
int hashCodev = UUID.randomUUID().toString().hashCode();
// System.out.println(UUID.randomUUID().toString());
if(hashCodev < 0){
//有可能是负数
hashCodev = -hashCodev;
}
//"%015d"的意思:0代表不足位数的补0,这样可以确保相同的位数,15是位数也就是要得到到的字符串长度是15,d代表数字。
return machineId + String.format("%029d", hashCodev);
}
/**
* 修改数据
*
* @param tbYwXzqqXx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqXx update(TbYwXzqqXx tbYwXzqqXx) {
this.tbYwXzqqXxMapper.update(tbYwXzqqXx);
return this.queryById(tbYwXzqqXx.getXxzjbh());
}
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
@Override
public boolean deleteById(String xxzjbh) {
return this.tbYwXzqqXxMapper.deleteById(xxzjbh) > 0;
}
}
package org.springblade.founder.xzqq.service.impl;
import org.springblade.founder.xzqq.entity.TbYwXzqqXyrxx;
import org.springblade.founder.xzqq.mapper.TbYwXzqqXyrxxMapper;
import org.springblade.founder.xzqq.service.TbYwXzqqXyrxxService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
import java.util.UUID;
/**
* (TbYwXzqqXyrxx)表服务实现类
*
* @author liulianglang
* @since 2023-11-07 15:05:02
*/
@Service("tbYwXzqqXyrxxService")
public class TbYwXzqqXyrxxServiceImpl implements TbYwXzqqXyrxxService {
@Resource
private TbYwXzqqXyrxxMapper tbYwXzqqXyrxxMapper;
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
@Override
public TbYwXzqqXyrxx queryById(String xxzjbh) {
return this.tbYwXzqqXyrxxMapper.queryById(xxzjbh);
}
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
@Override
public List<TbYwXzqqXyrxx> queryAllByLimit(int offset, int limit) {
return this.tbYwXzqqXyrxxMapper.queryAllByLimit(offset, limit);
}
/**
* 新增数据
*
* @param tbYwXzqqXyrxx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqXyrxx insert(TbYwXzqqXyrxx tbYwXzqqXyrxx) {
tbYwXzqqXyrxx.setXxzjbh(getOrderIdByUUId());
this.tbYwXzqqXyrxxMapper.insert(tbYwXzqqXyrxx);
return tbYwXzqqXyrxx;
}
public static String getOrderIdByUUId(){
int machineId = 1;//最大支持1-9个集群机器部署
int hashCodev = UUID.randomUUID().toString().hashCode();
// System.out.println(UUID.randomUUID().toString());
if(hashCodev < 0){
//有可能是负数
hashCodev = -hashCodev;
}
//"%015d"的意思:0代表不足位数的补0,这样可以确保相同的位数,15是位数也就是要得到到的字符串长度是15,d代表数字。
return machineId + String.format("%029d", hashCodev);
}
/**
* 修改数据
*
* @param tbYwXzqqXyrxx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqXyrxx update(TbYwXzqqXyrxx tbYwXzqqXyrxx) {
this.tbYwXzqqXyrxxMapper.update(tbYwXzqqXyrxx);
return this.queryById(tbYwXzqqXyrxx.getXxzjbh());
}
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
@Override
public boolean deleteById(String xxzjbh) {
return this.tbYwXzqqXyrxxMapper.deleteById(xxzjbh) > 0;
}
}
package org.springblade.founder.xzqq.service.impl;
import org.springblade.founder.xzqq.entity.TbYwXzqqZhryxx;
import org.springblade.founder.xzqq.mapper.TbYwXzqqZhryxxMapper;
import org.springblade.founder.xzqq.service.TbYwXzqqZhryxxService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
import java.util.UUID;
/**
* (TbYwXzqqZhryxx)表服务实现类
*
* @author liulianglang
* @since 2023-11-07 15:06:42
*/
@Service("tbYwXzqqZhryxxService")
public class TbYwXzqqZhryxxServiceImpl implements TbYwXzqqZhryxxService {
@Resource
private TbYwXzqqZhryxxMapper tbYwXzqqZhryxxMapper;
/**
* 通过ID查询单条数据
*
* @param xxzjbh 主键
* @return 实例对象
*/
@Override
public TbYwXzqqZhryxx queryById(String xxzjbh) {
return this.tbYwXzqqZhryxxMapper.queryById(xxzjbh);
}
/**
* 查询多条数据
*
* @param offset 查询起始位置
* @param limit 查询条数
* @return 对象列表
*/
@Override
public List<TbYwXzqqZhryxx> queryAllByLimit(int offset, int limit) {
return this.tbYwXzqqZhryxxMapper.queryAllByLimit(offset, limit);
}
/**
* 新增数据
*
* @param tbYwXzqqZhryxx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqZhryxx insert(TbYwXzqqZhryxx tbYwXzqqZhryxx) {
tbYwXzqqZhryxx.setXxzjbh(getOrderIdByUUId());
this.tbYwXzqqZhryxxMapper.insert(tbYwXzqqZhryxx);
return tbYwXzqqZhryxx;
}
public static String getOrderIdByUUId(){
int machineId = 1;//最大支持1-9个集群机器部署
int hashCodev = UUID.randomUUID().toString().hashCode();
// System.out.println(UUID.randomUUID().toString());
if(hashCodev < 0){
//有可能是负数
hashCodev = -hashCodev;
}
//"%015d"的意思:0代表不足位数的补0,这样可以确保相同的位数,15是位数也就是要得到到的字符串长度是15,d代表数字。
return machineId + String.format("%029d", hashCodev);
}
/**
* 修改数据
*
* @param tbYwXzqqZhryxx 实例对象
* @return 实例对象
*/
@Override
public TbYwXzqqZhryxx update(TbYwXzqqZhryxx tbYwXzqqZhryxx) {
this.tbYwXzqqZhryxxMapper.update(tbYwXzqqZhryxx);
return this.queryById(tbYwXzqqZhryxx.getXxzjbh());
}
/**
* 通过主键删除数据
*
* @param xxzjbh 主键
* @return 是否成功
*/
@Override
public boolean deleteById(String xxzjbh) {
return this.tbYwXzqqZhryxxMapper.deleteById(xxzjbh) > 0;
}
}
......@@ -4,8 +4,10 @@ import com.alibaba.fastjson.JSONObject;
import org.apache.commons.codec.binary.Base64;
import org.springblade.founder.utils.NumberUtil;
import org.springblade.modules.system.entity.User;
import org.springframework.stereotype.Component;
import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
import java.math.RoundingMode;
import java.text.DecimalFormat;
......@@ -14,8 +16,14 @@ import java.text.DecimalFormat;
* @author szLi
* @date 2021/9/7 17:13
*/
public class SecurityUtil {
@Component
public class SecurityUtil {
/***
* key和iv值可以随机生成,确保与前端的key,iv对应
*/
private static String KEY = "xzeq2021@zhyy#54";
private static String IV = "xzeq2021@zhyy#54";
public static String encrypt(String input, String key){
byte[] crypted = null;
try{
......@@ -41,6 +49,36 @@ public class SecurityUtil {
}
return new String(output);
}
public static String desEncryptDate(String data, String key, String iv) {
return desEncrypt(data, key, iv);
}
/**
* 解密方法
*/
private static String desEncrypt(String data, String key, String iv) {
try {
byte[] encrypted1 = new Base64().decode(data);
Cipher cipher = Cipher.getInstance("AES/CBC/NoPadding");
SecretKeySpec keySpec = new SecretKeySpec(key.getBytes(), "AES");
IvParameterSpec ivSpec = new IvParameterSpec(iv.getBytes());
cipher.init(Cipher.DECRYPT_MODE, keySpec, ivSpec);
byte[] original = cipher.doFinal(encrypted1);
return new String(original).trim();
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/***
* 解密
* @param data 要解密的数据
*/
public static String desEncrypt(String data) {
return desEncrypt(data, KEY, IV);
}
public static void main(String[] args) {
JSONObject jsonObj=new JSONObject();
......
......@@ -4,7 +4,9 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springblade.founder.utils.EasyUIPage;
import org.springblade.founder.utils.R;
import org.springblade.modules.auth.utils.TokenUtil;
import org.springblade.modules.system.entity.SysNewUser;
import org.springblade.modules.system.entity.XzxtUser;
import org.springblade.modules.system.service.ISysUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
......@@ -26,20 +28,48 @@ import java.util.Map;
public class UserNewController {
@Autowired
private ISysUserService sysUserService;
@PostMapping("/insertUserNew")
@PostMapping("/zcinsertUserNew")
@ResponseBody
@ApiOperation(value = "录入用户信息", notes = "录入用户信息")
public R insertUserNew(SysNewUser sysNewUser){
public Map<String,Object> zcinsertUserNew(SysNewUser sysNewUser){
Map<String,Object> rtMap = new HashMap<>();
int code = 200;
String msg = "新增成功";
try {
//解密
//解密
String submit = sysUserService.submit(sysNewUser);
return R.ok().data("xxzjbh",submit);
String ip = TokenUtil.getIp();
XzxtUser user = sysUserToXzxtUser(sysNewUser);
// String jsonObject = JSONObject.toJSONString(sysNewUser);
// authService.addNewLogOper(user,"用户注册","E0201",ip,jsonObject);
rtMap.put("data",submit);
rtMap.put("success", true);
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
code=201;
msg=e.getMessage();
rtMap.put("state","exception");
rtMap.put("success", false);
}
rtMap.put("code",code);
rtMap.put("message",msg);
return rtMap;
}
private XzxtUser sysUserToXzxtUser(SysNewUser sysNewUser){
XzxtUser xzxtUser = new XzxtUser();
xzxtUser.setIdentitycard(sysNewUser.getIdentitycard());
xzxtUser.setUnitcode(sysNewUser.getUnitcode());
xzxtUser.setRealname(sysNewUser.getTrueName());
xzxtUser.setUnitname(sysNewUser.getUnitname());
xzxtUser.setPhone(sysNewUser.getTelephone());
return xzxtUser;
}
......@@ -175,5 +205,61 @@ public class UserNewController {
}
}
@PostMapping("/getUserShList")
@ResponseBody
@ApiOperation(value = "查询审核用户的list集合", notes = "查询审核用户的list集合")
public R getUserShList(SysNewUser sysNewUser){
try {
EasyUIPage easyUIPage = new EasyUIPage();
easyUIPage.setPage(sysNewUser.getPage());
easyUIPage.setPagePara(sysNewUser.getLimit());
int begin = easyUIPage.getBegin();
int end = easyUIPage.getEnd();
sysNewUser.setBegin(begin);
sysNewUser.setEnd(end);
Map<String,Object> map = new HashMap<>();
List<SysNewUser> list = sysUserService.getUserShList(sysNewUser);
if(list == null){
return R.error("无权限查看");
}else{
int count = sysUserService.getUserShCount(sysNewUser);
map.put("rows",list);
map.put("total",count);
return R.ok().data(map);
}
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
//对用户注册进行审核
@PostMapping("/shUser")
@ResponseBody
@ApiOperation(value = "审核用户注册申请", notes = "审核用户注册申请")
public R shUser(SysNewUser sysNewUser){
try {
sysUserService.shUser(sysNewUser);
return R.ok();
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
//审核注册用户申请详情
@PostMapping("/shUserDetail")
@ResponseBody
@ApiOperation(value = "审核用户注册申请详情", notes = "审核用户注册申请")
public R shUserDetail(SysNewUser sysNewUser){
try {
SysNewUser detail = sysUserService.getShUserDetail(sysNewUser.getId());
return R.ok().data("data", detail);
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
}
......@@ -26,6 +26,7 @@ public class SysNewUser extends BaseModel {
private String sfzsjgsql;
private String qhmc;
private static final long serialVersionUID = 1L;
private String shzt; //审核状态(0-管理员添加;1-待审核;2-审核通过;3-审核不通过)
@ApiModelProperty(value = "主键")
private String id;
......@@ -130,10 +131,19 @@ public class SysNewUser extends BaseModel {
this.lrdwmc=user.getUnitname();
}
private String gxdwdm; //更新单位代码
private String gxdwmc; //更新单位名称
// 更新人员
public void setUpUser(XzxtUser user){
this.gxr=user.getRealname();
}
//更新人员和单位
public void setUpUserAll(XzxtUser user){
this.gxr=user.getRealname();
this.gxdwdm=user.getUnitcode();
this.gxdwmc=user.getUnitname();
}
}
......@@ -20,6 +20,8 @@ public interface SysUserMapper {
int submit(SysNewUser user);
int judgePolicemanid(@Param(value = "policemanid") String policemanid, @Param(value = "identitycard") String identitycard, @Param(value = "id") String id);
String getUnitnameByUnitcode(@Param(value = "unitcode") String unitcode);
// 获取用户 列表
List<SysNewUser> getUserNewList(SysNewUser sysNewUser)throws Exception;
// 获取用户 个数
......@@ -27,10 +29,14 @@ public interface SysUserMapper {
// 更新用户 信息
int updateUserNew(SysNewUser sysNewUser)throws Exception;
//查询数据数量
int getUserZpCount(SysNewUser sysNewUser)throws Exception;
//新增用户照片
int insertUserPhoto(SysNewUser user);
// 根据id查询用户 信息
SysNewUser getUserByBh(String id) throws Exception ;
//更新用户照片
int updateUserPhoto(SysNewUser sysNewUser)throws Exception;
//删除用户信息
void deleteUserNew(SysNewUser sysNewUser)throws Exception;
......@@ -51,4 +57,16 @@ public interface SysUserMapper {
SysNewUser getPersonInfo(@Param(value = "id") String id);
SysNewUser getUserInfoByParam(@Param("param") Map<String, String> requestParam);
//获取审核列表
List<SysNewUser> getUserShList(SysNewUser sysNewUser)throws Exception;
//获取审核列表总数
Integer getUserShListCount(SysNewUser sysNewUser)throws Exception;
//获取审核详情
SysNewUser getShUserDetail(@Param(value = "id") String id);
//审核数据
int updateUserSh(SysNewUser sysNewUser);
String getHqdwGrade(String dwdm);
}
......@@ -16,7 +16,7 @@ public interface ISysUserService {
* @param user
* @return
*/
String submit(SysNewUser user);
String submit(SysNewUser user) throws Exception;
// 获取用户 列表
List<SysNewUser> getUserNewList(SysNewUser sysNewUser)throws Exception;
......@@ -39,4 +39,12 @@ public interface ISysUserService {
SysNewUser getPersonInfo() throws Exception;
SysNewUser getUserInfoByParam(Map<String, String> requestParam);
// 获取用户审核列表
List<SysNewUser> getUserShList(SysNewUser sysNewUser)throws Exception;
// 获取用户 个数
int getUserShCount(SysNewUser sysNewUser)throws Exception;
//审核用户注册申请
int shUser(SysNewUser sysNewUser) throws Exception;
//审核用户注册详情
SysNewUser getShUserDetail(String id) throws Exception;
}
package org.springblade.modules.system.service.impl;
import org.apache.commons.lang.StringUtils;
import org.springblade.common.tool.HqXjDwCommon;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.secure.utils.SecureUtil;
import org.springblade.core.tool.utils.DigestUtil;
import org.springblade.founder.utils.SysXxzjbhService;
import org.springblade.modules.auth.utils.SecurityUtil;
import org.springblade.modules.system.entity.SysNewUser;
import org.springblade.modules.system.entity.SysUserRolesNew;
import org.springblade.modules.system.entity.XzxtUser;
......@@ -27,24 +30,59 @@ public class ISysUserServiceImpl implements ISysUserService {
@Autowired
private SysXxzjbhService xxzjbhService;
private boolean judgePolicemanidCount(String policemanid, String identitycard, String id) throws Exception{
//判断该警号是否唯一
if(StringUtils.isEmpty(policemanid)){
throw new Exception("警号不能为空");
}
if(StringUtils.isEmpty(identitycard)){
throw new Exception("身份证号不能为空");
}
int count = sysUserMapper.judgePolicemanid(policemanid, identitycard, id);
if(count > 0){
throw new Exception("当前警号已有数据, 请更换警号");
}
return true;
}
@Override
public String submit(SysNewUser user) {
public String submit(SysNewUser user) throws Exception {
XzxtUser xzxtUser = SecureUtil.getUserXzxt();
String jyxxzjbh = xxzjbhService.getXxzjbh(xzxtUser.getUnitcode(),null);//xxzjbh
if(judgePolicemanidCount(user.getPolicemanid(), user.getIdentitycard(), null)){
XzxtUser xzxtUser = new XzxtUser();
xzxtUser.setRealname(user.getTrueName());
xzxtUser.setUnitcode(user.getUnitcode());
String unitName = sysUserMapper.getUnitnameByUnitcode(user.getUnitcode());
xzxtUser.setUnitname(unitName);
user.setUnitname(unitName);
String jyxxzjbh = xxzjbhService.getXxzjbh(xzxtUser.getUnitcode(),null);//xxzjbh
user.setId(jyxxzjbh);
user.setPassword(DigestUtil.encrypt(user.getPassword()));
user.setId(jyxxzjbh);
user.setPassword(DigestUtil.encrypt(user.getPassword()));
// String xxzjbh = xxzjbhService.getXxzjbh(xzxtUser.getUnitcode(),null);//xxzjbh
// user.setId(xxzjbh);
user.setDjUser(xzxtUser);
sysUserMapper.submit(user);
return jyxxzjbh;
user.setDjUser(xzxtUser);
sysUserMapper.submit(user);
//判断数据库里是否有当前身份证号码的数据,如果有就修改,如果没有就新增
if(sysUserMapper.getUserZpCount(user) == 0){
sysUserMapper.insertUserPhoto(user);
}else{
sysUserMapper.updateUserPhoto(user);
}
return jyxxzjbh;
}
return null;
}
// 用户的列表展示
// 用户的列表展示
@Override
public List<SysNewUser> getUserNewList(SysNewUser sysNewUser) throws Exception {
// XzxtUser xzxtUser = SecureUtil.getUserXzxt();
......@@ -206,5 +244,70 @@ public class ISysUserServiceImpl implements ISysUserService {
return sysUserMapper.getUserInfoByParam(requestParam);
}
@Override
public List<SysNewUser> getUserShList(SysNewUser sysNewUser) throws Exception {
XzxtUser xzxtUser = SecureUtil.getUserXzxt();
String dwUnitCode = xzxtUser.getUnitcode(); //当前单位代码
String userGrade = xzxtUser.getGrade(); //用户等级
System.out.println("从系统中获取的用户等级" + userGrade);
//加一个判断,如果有这个权限,表明可以看所有的用户
//------2023-03-17 去掉F010101和F010102菜单,用户信息管理菜单默认权限为本单位及以下 begin------
// int a = sysUserMapper.getCodeNum(xzxtUser.getId(), "F010101");
int a = 0;
//------2023-03-17 去掉F010101和F010102菜单,用户信息管理菜单默认权限为本单位及以下 end------
// if(a > 0){
dwUnitCode = "460000000000";
userGrade = "S";
// }else{
// return new ArrayList<>();
// }
String grade = sysUserMapper.getHqdwGrade(dwUnitCode); //单位所在级别
Map<String, String> mapDwLevCode = HqXjDwCommon.getMapDwLevCode(dwUnitCode, grade);
sysNewUser.setCodeLevCol(mapDwLevCode.get("codeLevCol"));
sysNewUser.setUserUnitCode(dwUnitCode);
List<SysNewUser> userNewList = sysUserMapper.getUserShList(sysNewUser);
return userNewList;
}
@Override
public int getUserShCount(SysNewUser sysNewUser) throws Exception {
return sysUserMapper.getUserShListCount(sysNewUser);
}
@Override
public int shUser(SysNewUser sysNewUser) throws Exception {
int a = 0;
String shzt = sysNewUser.getShzt();
if (StringUtils.isNotEmpty(shzt)){
XzxtUser xzxtUser = SecureUtil.getUserXzxt();
sysNewUser.setUpUserAll(xzxtUser);
if ("2".equals(shzt)){ //同意
String policemanid = sysNewUser.getPolicemanid();
int count = sysUserMapper.judgePolicemanid(policemanid, null,null);
if(count > 0){
throw new Exception("当前警号已有数据, 审批失败");
}
SysNewUser user = sysUserMapper.getShUserDetail(sysNewUser.getId());
user.setOpenFlag("1");
String xxzjbh = submit(user);
if (StringUtils.isNotEmpty(xxzjbh)){
sysNewUser.setOpenFlag("1");
a = sysUserMapper.updateUserSh(sysNewUser);
}else {
throw new Exception("新增失败, 不可审批");
}
}else if("3".equals(shzt)){
a = sysUserMapper.updateUserSh(sysNewUser);
}
}
return a;
}
@Override
public SysNewUser getShUserDetail(String id) throws Exception {
return sysUserMapper.getShUserDetail(id);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment