Commit 8fe59493 by 赵剑炜

Merge branch 'develop' into develop-zhaojw

parents 8cae604f 938b67a2
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
import java.io.Serializable;
@Data
public class ShelfDto implements Serializable {
private String shelfId;
private String shelfName;
private String code;
private String type;
private Integer shelfRows;
private Integer shelfColumns;
private Integer shelfRanges;
private String url;
private String sizeInfo;
}
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
import java.io.Serializable;
@Data
public class WarehouseAreaDto implements Serializable {
private String id;
private String areaName;
private String photo;
}
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
import java.io.Serializable;
@Data
public class WarehouseDto implements Serializable {
private String id;
private String name;
private String location;
private String phone;
private Long orgId;
private Boolean isLocked;
private Integer sum;
private Integer outSum;
private Integer inSum;
private String state;
private String orgName;
}
package com.junmp.jyzb.api.bean.query; package com.junmp.jyzb.api.bean.query;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField;
import com.junmp.v2.common.bean.request.BaseRequest; import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import java.util.Date; import javax.validation.constraints.NotBlank;
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class ShelfReq extends BaseRequest { public class ShelfReq extends BaseRequest {
private String shelfId; private String shelfId;
private Long areaId; private Long areaId;
...@@ -21,6 +20,7 @@ public class ShelfReq extends BaseRequest { ...@@ -21,6 +20,7 @@ public class ShelfReq extends BaseRequest {
private String type; private String type;
@NotBlank(message = "仓库id不能为空",groups = {detail.class})
private String warehouseId; private String warehouseId;
private Integer shelfRows; private Integer shelfRows;
......
package com.junmp.jyzb.api.bean.query; package com.junmp.jyzb.api.bean.query;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField;
import com.junmp.v2.common.bean.request.BaseRequest; import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotBlank;
import java.util.Date; import java.util.Date;
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class WarehouseAreaReq extends BaseRequest { public class WarehouseAreaReq extends BaseRequest {
@NotNull(message = "地区主键不能为空", groups = {edit.class, delete.class, detail.class}) @NotBlank(message = "地区主键不能为空", groups = {edit.class, delete.class, detail.class})
private String id; private String id;
private String areaName; private String areaName;
......
...@@ -10,6 +10,7 @@ import lombok.Data; ...@@ -10,6 +10,7 @@ import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigDecimal; import java.math.BigDecimal;
...@@ -18,7 +19,7 @@ import java.util.Date; ...@@ -18,7 +19,7 @@ import java.util.Date;
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class WarehouseReq extends BaseRequest { public class WarehouseReq extends BaseRequest {
@NotNull(message = "仓库主键不能为空", groups = {edit.class, delete.class, detail.class}) @NotBlank(message = "仓库主键不能为空", groups = {edit.class, delete.class, detail.class})
private String id; private String id;
private Long departmentId; private Long departmentId;
...@@ -50,6 +51,7 @@ public class WarehouseReq extends BaseRequest { ...@@ -50,6 +51,7 @@ public class WarehouseReq extends BaseRequest {
private BigDecimal priceTotal; private BigDecimal priceTotal;
@NotNull(message = "仓库状态不能为空", groups = {edit.class})
private Integer state; private Integer state;
private Long orderId; private Long orderId;
......
...@@ -89,7 +89,6 @@ public class UpdateCabinetReq extends BaseRequest { ...@@ -89,7 +89,6 @@ public class UpdateCabinetReq extends BaseRequest {
private List<UpdateCabinetBoxReq> cabinetBoxList; private List<UpdateCabinetBoxReq> cabinetBoxList;
//单警柜id列表 //单警柜id列表
@NotBlank(message = "单警柜不能为空", groups = {delete.class})
private List<String> cabinetList; private List<String> cabinetList;
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
......
...@@ -11,25 +11,23 @@ import java.util.Date; ...@@ -11,25 +11,23 @@ import java.util.Date;
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
public class UpdatePolicemanReq extends BaseRequest { public class UpdatePolicemanReq extends BaseRequest {
@NotNull(message = "警员主键不能为空", groups = {edit.class, delete.class, detail.class}) @NotNull(message = "警员主键不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String id; private String id;
@NotNull(message = "警员名字不能为空", groups = {edit.class, delete.class, detail.class}) @NotNull(message = "警员名字不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String name; private String name;
private String cabinetBoxId; private String cabinetBoxId;
@NotNull(message = "组织机构不能为空", groups = {edit.class, delete.class, detail.class}) @NotNull(message = "组织机构id不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String orgId; private Long orgId;
private Long orgIdInt;
private Long departmentId; private Long departmentId;
@NotNull(message = "警员编号不能为空", groups = {edit.class, delete.class, detail.class}) @NotNull(message = "警员编号不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String policeCode; private String policeCode;
@NotNull(message = "性别不能为空", groups = {edit.class, delete.class, detail.class}) @NotNull(message = "性别不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String sex; private String sex;
private String faceInfo; private String faceInfo;
...@@ -40,7 +38,7 @@ public class UpdatePolicemanReq extends BaseRequest { ...@@ -40,7 +38,7 @@ public class UpdatePolicemanReq extends BaseRequest {
private String password; private String password;
@NotNull(message = "电话不能为空", groups = {edit.class, delete.class, detail.class}) @NotNull(message = "电话不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String photo; private String photo;
private String phone; private String phone;
...@@ -49,7 +47,7 @@ public class UpdatePolicemanReq extends BaseRequest { ...@@ -49,7 +47,7 @@ public class UpdatePolicemanReq extends BaseRequest {
private Date updateTime; private Date updateTime;
@NotNull(message = "身份证号不能为空", groups = {edit.class, delete.class, detail.class}) @NotNull(message = "身份证号不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String idCard; private String idCard;
private String updateUser; private String updateUser;
......
package com.junmp.jyzb.api.bean.req;
import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
@Data
public class UpdateShelfReq extends BaseRequest {
@NotBlank(message = "货架id不能为空",groups = {edit.class, delete.class})
private String shelfId;
private Long areaId;
@NotBlank(message = "货架名称不能为空",groups = {add.class,edit.class})
private String shelfName;
@NotBlank(message = "货架编号不能为空",groups = {add.class,edit.class})
private String code;
@NotBlank(message = "货架类型不能为空",groups = {add.class,edit.class})
private String type;
@NotBlank(message = "仓库id不能为空",groups = {add.class})
private String warehouseId;
@NotNull(message = "货架层数不能为空",groups = {add.class,edit.class})
private Integer shelfRows;
@NotNull(message = "货架列数不能为空",groups = {add.class,edit.class})
private Integer shelfColumns;
@NotNull(message = "货架排数不能为空",groups = {add.class,edit.class})
private Integer shelfRanges;
/**
* 只能货架地址,普通则为空
*/
private String url;
@NotBlank(message = "型号信息不能为空",groups = {add.class,edit.class})
private String sizeInfo;
}
package com.junmp.jyzb.api.bean.req;
import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import java.util.Date;
@Data
public class UpdateWarehouseAreaReq extends BaseRequest {
@NotBlank(message = "地区主键不能为空", groups = {edit.class, delete.class, detail.class})
private String areaId;
@NotBlank(message = "区域名称不能为空", groups = {add.class,edit.class, detail.class})
private String areaName;
private Long orgIdInt;
@NotBlank(message = "仓库id不能为空", groups = {add.class,edit.class, detail.class})
private String warehouseId;
@NotBlank(message = "照片不能为空", groups = {add.class,edit.class, detail.class})
private String photo;
private Date createTime;
private Date updateTime;
private String createUser;
private String updateUser;
}
package com.junmp.jyzb.api.bean.req;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
@Data
public class UpdateWarehouseReq extends BaseRequest {
@NotBlank(message = "仓库主键不能为空", groups = {edit.class, delete.class, detail.class})
private String id;
private Long departmentId;
@NotBlank(message = "仓库名称不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String name;
@NotBlank(message = "仓库地点不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String location;
@NotBlank(message = "联系方式不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private String phone;
private String video;
@TableField(value = "create_time",fill = FieldFill.INSERT)
private Date createTime;
@TableField(value = "update_time",fill = FieldFill.UPDATE)
private Date updateTime;
private String updateUser;
@JsonProperty(value = "orgId")
@NotNull(message = "组织机构id不能为空", groups = {add.class,edit.class, delete.class, detail.class})
private Long orgId;
private Boolean isLocked;
private Integer sum;
private Integer outSum;
private Integer inSum;
private BigDecimal priceTotal;
private Integer state;
private Long orderId;
//仓库id列表做批量操作
private List<String> warehouseList;
}
package com.junmp.jyzb.exception.enums; package com.junmp.jyzb.api.exception.enums;
import com.junmp.v2.common.constant.CommonConstant; import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum; import com.junmp.v2.common.exception.IExceptionEnum;
......
package com.junmp.jyzb.exception.enums; package com.junmp.jyzb.api.exception.enums;
import com.junmp.v2.common.constant.CommonConstant; import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum; import com.junmp.v2.common.exception.IExceptionEnum;
......
package com.junmp.jyzb.exception.enums; package com.junmp.jyzb.api.exception.enums;
import com.junmp.v2.common.constant.CommonConstant; import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum; import com.junmp.v2.common.exception.IExceptionEnum;
......
package com.junmp.jyzb.exception.enums; package com.junmp.jyzb.api.exception.enums;
import com.junmp.v2.common.constant.CommonConstant; import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum; import com.junmp.v2.common.exception.IExceptionEnum;
......
package com.junmp.jyzb.exception.enums; package com.junmp.jyzb.api.exception.enums;
import com.junmp.v2.common.constant.CommonConstant; import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum; import com.junmp.v2.common.exception.IExceptionEnum;
......
...@@ -11,54 +11,11 @@ public enum WarehouseAreaExceptionEnum implements IExceptionEnum { ...@@ -11,54 +11,11 @@ public enum WarehouseAreaExceptionEnum implements IExceptionEnum {
* 仓库地区信息不存在 * 仓库地区信息不存在
*/ */
WAREHOUSEAREA_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 12, "地区信息不存在"), WAREHOUSEAREA_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 12, "地区信息不存在"),
/**
* 批次信息不存在
*/
BATCH_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 14, "批次不存在"),
/**
* 批次信息不存在
*/
BATCH_PROCESSED(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 15, "批次已生产"),
/** /**
* 批次生产已完成 * 区域已存在
*/ */
BATCH_PROCESSED_DONE(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 16, "批次生产已完成"), AREA_IS_EXISTS(CommonConstant.DEFAULT_USER_ERROR_CODE,"区域已经存在")
;
/**
* 批次生产已完成
*/
MODIFY_NUM_ERROR(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 17, "批次生产已完成,数量不能小于原数量"),
/**
* 标签信息不存在
*/
TAG_INFO_NOT_EXISTS(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 19, "标签信息不存在"),
/**
* 标签信息初始化完成
*/
TAG_INFO_INIT_DONE(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 20, "检查标签信息是否绑定完成"),
/**
* 标签已绑定
*/
TAG_INFO_HAD_BINDING(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 21, "标签已绑定"),
/**
* 确认绑定是否已完成
*/
TAG_UID_BINDING_ERROR(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 22, "确认绑定是否已完成"),
/**
* 标签重复
*/
TAG_INFO_REPEAT_ERROR(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 23, "标签重复"),
; ;
......
...@@ -12,57 +12,6 @@ public enum WarehouseExceptionEnum implements IExceptionEnum { ...@@ -12,57 +12,6 @@ public enum WarehouseExceptionEnum implements IExceptionEnum {
*/ */
WAREHOUSE_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 12, "仓库信息不存在"), WAREHOUSE_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 12, "仓库信息不存在"),
/**
* 产品信息不存在
*/
PRODUCT_SKU_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 13, "号型不存在"),
/**
* 批次信息不存在
*/
BATCH_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 14, "批次不存在"),
/**
* 批次信息不存在
*/
BATCH_PROCESSED(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 15, "批次已生产"),
/**
* 批次生产已完成
*/
BATCH_PROCESSED_DONE(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 16, "批次生产已完成"),
/**
* 批次生产已完成
*/
MODIFY_NUM_ERROR(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 17, "批次生产已完成,数量不能小于原数量"),
/**
* 标签信息不存在
*/
TAG_INFO_NOT_EXISTS(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 19, "标签信息不存在"),
/**
* 标签信息初始化完成
*/
TAG_INFO_INIT_DONE(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 20, "检查标签信息是否绑定完成"),
/**
* 标签已绑定
*/
TAG_INFO_HAD_BINDING(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 21, "标签已绑定"),
/**
* 确认绑定是否已完成
*/
TAG_UID_BINDING_ERROR(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 22, "确认绑定是否已完成"),
/**
* 标签重复
*/
TAG_INFO_REPEAT_ERROR(CommonConstant.DEFAULT_USER_ERROR_CODE + JYZBConstant.JYZB_EXCEPTION_STEP_CODE + 23, "标签重复"),
; ;
......
...@@ -54,7 +54,7 @@ public class CabinetController { ...@@ -54,7 +54,7 @@ public class CabinetController {
@PostMapping("/DeleteCabinetInfo") @PostMapping("/DeleteCabinetInfo")
@ApiOperation("删除单警柜信息") @ApiOperation("删除单警柜信息")
public ApiRes<Boolean> deleteCabinetInfo(@RequestBody @Validated(ValidationApi.delete.class) UpdateCabinetReq req) { public ApiRes<Boolean> deleteCabinetInfo(@RequestBody UpdateCabinetReq req) {
return ApiRes.success(cabinetService.deleteCabinetInfo(req)); return ApiRes.success(cabinetService.deleteCabinetInfo(req));
} }
......
...@@ -30,7 +30,7 @@ public class PoliceController { ...@@ -30,7 +30,7 @@ public class PoliceController {
@PostMapping("/AddPoliceman") @PostMapping("/AddPoliceman")
@ApiOperation("添加警员信息") @ApiOperation("添加警员信息")
public ApiRes<String> AddPoliceman(@RequestBody UpdatePolicemanReq req) { public ApiRes<String> AddPoliceman(@RequestBody @Validated(ValidationApi.add.class) UpdatePolicemanReq req) {
String policeId = policemanService.AddPoliceman(req); String policeId = policemanService.AddPoliceman(req);
return ApiRes.success(policeId); return ApiRes.success(policeId);
} }
...@@ -68,7 +68,6 @@ public class PoliceController { ...@@ -68,7 +68,6 @@ public class PoliceController {
//根据组织机构id查询,只查询本级,不包含下级 //根据组织机构id查询,只查询本级,不包含下级
@PostMapping("/ShowPoliceList") @PostMapping("/ShowPoliceList")
@ApiOperation("查询某个组织机构下的所有警员信息") @ApiOperation("查询某个组织机构下的所有警员信息")
...@@ -116,7 +115,7 @@ public class PoliceController { ...@@ -116,7 +115,7 @@ public class PoliceController {
@PostMapping("/AddFaceInfo") @PostMapping("/AddFaceInfo")
@ApiOperation("添加警员面部信息") @ApiOperation("添加警员面部信息")
public ApiRes<Boolean> AddFaceInfo(@RequestBody PolicemanReq req) { public ApiRes<Boolean> AddFaceInfo(@RequestBody UpdatePolicemanReq req) {
boolean b = policemanService.AddFaceInfo(req); boolean b = policemanService.AddFaceInfo(req);
if (!b){ if (!b){
return ApiRes.failure("添加失败"); return ApiRes.failure("添加失败");
......
package com.junmp.jyzb.controller; package com.junmp.jyzb.controller;
import com.junmp.jyzb.api.bean.dto.ShelfDto;
import com.junmp.jyzb.api.bean.dto.WarehouseAreaDto;
import com.junmp.jyzb.api.bean.dto.WarehouseDto;
import com.junmp.jyzb.api.bean.query.ShelfReq; import com.junmp.jyzb.api.bean.query.ShelfReq;
import com.junmp.jyzb.api.bean.query.WarehouseAreaReq; import com.junmp.jyzb.api.bean.query.WarehouseAreaReq;
import com.junmp.jyzb.api.bean.query.WarehouseReq; import com.junmp.jyzb.api.bean.query.WarehouseReq;
import com.junmp.jyzb.api.bean.req.UpdateShelfReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseAreaReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseReq;
import com.junmp.jyzb.entity.*; import com.junmp.jyzb.entity.*;
import com.junmp.jyzb.service.*; import com.junmp.jyzb.service.*;
import com.junmp.v2.common.bean.request.ValidationApi;
import com.junmp.v2.common.bean.response.ApiRes; import com.junmp.v2.common.bean.response.ApiRes;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
...@@ -35,15 +42,15 @@ public class WarehouseController { ...@@ -35,15 +42,15 @@ public class WarehouseController {
@PostMapping("/AddWarehouse") @PostMapping("/AddWarehouse")
@ApiOperation("添加仓库") @ApiOperation("添加仓库")
public ApiRes<Boolean> addWarehouse(@RequestBody @Validated(WarehouseReq.add.class) WarehouseReq req) { public ApiRes<String> AddWarehouse(@RequestBody @Validated(ValidationApi.add.class) UpdateWarehouseReq req) {
return ApiRes.success(warehouseService.addWarehouse(req)); return ApiRes.success(warehouseService.AddWarehouse(req));
} }
@PostMapping("/DeleteWarehouse") @PostMapping("/DeleteWarehouse")
@ApiOperation("删除仓库信息") @ApiOperation("删除仓库信息")
public ApiRes<Boolean> deleteWarehouse(@RequestBody @Validated(WarehouseReq.delete.class)WarehouseReq req) { public ApiRes<Boolean> DeleteWarehouse(@RequestBody UpdateWarehouseReq req) {
return ApiRes.success(warehouseService.deleteWarehouse(req)); return ApiRes.success(warehouseService.DeleteWarehouse(req));
} }
@PostMapping("/ChangeWarehouseState") @PostMapping("/ChangeWarehouseState")
...@@ -54,68 +61,68 @@ public class WarehouseController { ...@@ -54,68 +61,68 @@ public class WarehouseController {
@PostMapping("/ShowWarehouse") @PostMapping("/ShowWarehouse")
@ApiOperation("查询仓库列表") @ApiOperation("查询仓库列表")
public ApiRes<List<Warehouse>> getAllWarehouse(@RequestBody WarehouseReq req){ public ApiRes<List<WarehouseDto>> getAllWarehouse(@RequestBody WarehouseReq req){
return ApiRes.success(warehouseService.getAllWarehouse(req)); return ApiRes.success(warehouseService.getAllWarehouse(req));
} }
@PostMapping("/GetWarehouseDetail") @PostMapping("/GetWarehouseDetail")
@ApiOperation("查询单个仓库信息") @ApiOperation("查询单个仓库信息")
public ApiRes<Warehouse> getOneWarehouse(@RequestBody @Validated(WarehouseReq.detail.class)WarehouseReq req) { public ApiRes<WarehouseDto> getOneWarehouse(@RequestBody @Validated(WarehouseReq.detail.class)WarehouseReq req) {
return ApiRes.success(warehouseService.getOneWarehouse(req)); return ApiRes.success(warehouseService.getOneWarehouse(req));
} }
@PostMapping("/UpdateWarehouse") @PostMapping("/UpdateWarehouse")
@ApiOperation("修改仓库信息") @ApiOperation("修改仓库信息")
public ApiRes<Boolean> updateWarehouse(@RequestBody @Validated(WarehouseReq.edit.class) WarehouseReq req) { public ApiRes<Boolean> updateWarehouse(@RequestBody @Validated(WarehouseReq.edit.class) UpdateWarehouseReq req) {
return ApiRes.success(warehouseService.updateWarehouse(req)); return ApiRes.success(warehouseService.updateWarehouse(req));
} }
@PostMapping("/AddArea") @PostMapping("/AddArea")
@ApiOperation("添加区域") @ApiOperation("添加区域")
public ApiRes<Boolean> addArea(@RequestBody @Validated(WarehouseAreaReq.add.class) WarehouseAreaReq req) { public ApiRes<Boolean> addArea(@RequestBody @Validated(ValidationApi.add.class) UpdateWarehouseAreaReq req) {
return ApiRes.success(warehouseAreaService.addArea(req)); return ApiRes.success(warehouseAreaService.addArea(req));
} }
@PostMapping("/UpdateArea") @PostMapping("/UpdateArea")
@ApiOperation("修改区域") @ApiOperation("修改区域")
public ApiRes<Boolean> updateArea(@RequestBody @Validated(WarehouseAreaReq.edit.class) WarehouseAreaReq req) { public ApiRes<Boolean> updateArea(@RequestBody @Validated(ValidationApi.edit.class) UpdateWarehouseAreaReq req) {
return ApiRes.success(warehouseAreaService.updateArea(req)); return ApiRes.success(warehouseAreaService.updateArea(req));
} }
@PostMapping("/DeleteArea") @PostMapping("/DeleteArea")
@ApiOperation("删除区域") @ApiOperation("删除区域")
public ApiRes<Boolean> deleteArea(@RequestBody @Validated(WarehouseAreaReq.delete.class) WarehouseAreaReq req) { public ApiRes<Boolean> deleteArea(@RequestBody @Validated(ValidationApi.delete.class) UpdateWarehouseAreaReq req) {
return ApiRes.success(warehouseAreaService.deleteArea(req)); return ApiRes.success(warehouseAreaService.deleteArea(req));
} }
@PostMapping("/GetAreaList") @PostMapping("/GetAreaList")
@ApiOperation("查询区域信息") @ApiOperation("查询区域信息")
public ApiRes<List<WarehouseArea>> getAreaList(@RequestBody WarehouseAreaReq req){ public ApiRes<List<WarehouseAreaDto>> getAreaList(@RequestBody WarehouseAreaReq req){
return ApiRes.success(warehouseAreaService.getAreaList(req)); return ApiRes.success(warehouseAreaService.getAreaList(req));
} }
@PostMapping("/AddShelf") @PostMapping("/AddShelf")
@ApiOperation("添加货架") @ApiOperation("添加货架")
public ApiRes<Boolean> addShelf(@RequestBody @Validated(ShelfReq.add.class) ShelfReq req) { public ApiRes<Boolean> AddShelf(@RequestBody @Validated(ValidationApi.add.class) UpdateShelfReq req) {
return ApiRes.success(shelfService.addShelf(req)); return ApiRes.success(shelfService.AddShelf(req));
} }
@PostMapping("/UpdateShelf") @PostMapping("/UpdateShelf")
@ApiOperation("修改货架") @ApiOperation("修改货架")
public ApiRes<Boolean> updateShelf(@RequestBody @Validated(ShelfReq.edit.class) ShelfReq req) { public ApiRes<Boolean> UpdateShelf(@RequestBody @Validated(ValidationApi.edit.class) UpdateShelfReq req) {
return ApiRes.success(shelfService.updateShelf(req)); return ApiRes.success(shelfService.UpdateShelf(req));
} }
@PostMapping("/DeleteShelf") @PostMapping("/DeleteShelf")
@ApiOperation("删除货架") @ApiOperation("删除货架")
public ApiRes<Boolean> deleteShelf(@RequestBody @Validated(ShelfReq.delete.class) ShelfReq req) { public ApiRes<Boolean> DeleteShelf(@RequestBody @Validated(ShelfReq.delete.class) UpdateShelfReq req) {
return ApiRes.success(shelfService.deleteShelf(req)); return ApiRes.success(shelfService.DeleteShelf(req));
} }
@PostMapping("/GetShelfList") @PostMapping("/GetShelfList")
@ApiOperation("查询区域信息") @ApiOperation("查询货架信息")
public ApiRes<List<Shelf>> getShelfList(@RequestBody ShelfReq req){ public ApiRes<List<ShelfDto>> GetShelfList(@RequestBody @Validated(ValidationApi.detail.class) ShelfReq req){
return ApiRes.success(shelfService.getShelfList(req)); return ApiRes.success(shelfService.GetShelfList(req));
} }
} }
...@@ -6,10 +6,6 @@ import com.junmp.jyzb.api.bean.dto.PolicemanDto; ...@@ -6,10 +6,6 @@ import com.junmp.jyzb.api.bean.dto.PolicemanDto;
import com.junmp.jyzb.api.bean.query.PolicemanReq; import com.junmp.jyzb.api.bean.query.PolicemanReq;
import com.junmp.jyzb.api.bean.req.UpdatePolicemanReq; import com.junmp.jyzb.api.bean.req.UpdatePolicemanReq;
import com.junmp.jyzb.entity.Policeman; import com.junmp.jyzb.entity.Policeman;
import com.junmp.jyzb.utils.ResponseResult;
import java.util.List;
import java.util.Map;
public interface PolicemanService extends IService<Policeman> { public interface PolicemanService extends IService<Policeman> {
...@@ -29,7 +25,8 @@ public interface PolicemanService extends IService<Policeman> { ...@@ -29,7 +25,8 @@ public interface PolicemanService extends IService<Policeman> {
boolean UpdatePolice(UpdatePolicemanReq req); boolean UpdatePolice(UpdatePolicemanReq req);
boolean AddFaceInfo(PolicemanReq req);
boolean AddFaceInfo(UpdatePolicemanReq req);
//修改警员状态 //修改警员状态
...@@ -48,7 +45,6 @@ public interface PolicemanService extends IService<Policeman> { ...@@ -48,7 +45,6 @@ public interface PolicemanService extends IService<Policeman> {
Policeman SearchFaceInfo(PolicemanReq req); Policeman SearchFaceInfo(PolicemanReq req);
boolean PoliceBindUser(PolicemanReq req); boolean PoliceBindUser(PolicemanReq req);
boolean PoliceBindBox(PolicemanReq req); boolean PoliceBindBox(PolicemanReq req);
......
package com.junmp.jyzb.service; package com.junmp.jyzb.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.api.bean.dto.ShelfDto;
import com.junmp.jyzb.api.bean.query.ShelfReq; import com.junmp.jyzb.api.bean.query.ShelfReq;
import com.junmp.jyzb.api.bean.req.UpdateShelfReq;
import com.junmp.jyzb.entity.Shelf; import com.junmp.jyzb.entity.Shelf;
import java.util.List; import java.util.List;
public interface ShelfService extends IService<Shelf> { public interface ShelfService extends IService<Shelf> {
boolean addShelf(ShelfReq msg); boolean AddShelf(UpdateShelfReq req);
boolean updateShelf(ShelfReq msg); boolean UpdateShelf(UpdateShelfReq req);
boolean deleteShelf(ShelfReq msg); boolean DeleteShelf(UpdateShelfReq req);
List<Shelf> getShelfList(ShelfReq msg); List<ShelfDto> GetShelfList(ShelfReq req);
} }
package com.junmp.jyzb.service; package com.junmp.jyzb.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.api.bean.dto.WarehouseAreaDto;
import com.junmp.jyzb.api.bean.query.WarehouseAreaReq; import com.junmp.jyzb.api.bean.query.WarehouseAreaReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseAreaReq;
import com.junmp.jyzb.entity.WarehouseArea; import com.junmp.jyzb.entity.WarehouseArea;
import java.util.List; import java.util.List;
public interface WarehouseAreaService extends IService<WarehouseArea> { public interface WarehouseAreaService extends IService<WarehouseArea> {
boolean addArea(WarehouseAreaReq msg); boolean addArea(UpdateWarehouseAreaReq msg);
boolean updateArea(WarehouseAreaReq msg); boolean updateArea(UpdateWarehouseAreaReq msg);
boolean deleteArea(WarehouseAreaReq msg); boolean deleteArea(UpdateWarehouseAreaReq msg);
List<WarehouseArea> getAreaList(WarehouseAreaReq msg); List<WarehouseAreaDto> getAreaList(WarehouseAreaReq msg);
} }
package com.junmp.jyzb.service; package com.junmp.jyzb.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.api.bean.dto.WarehouseDto;
import com.junmp.jyzb.api.bean.query.WarehouseReq; import com.junmp.jyzb.api.bean.query.WarehouseReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseReq;
import com.junmp.jyzb.entity.Warehouse; import com.junmp.jyzb.entity.Warehouse;
import com.junmp.jyzb.utils.ResponseResult; import com.junmp.jyzb.utils.ResponseResult;
...@@ -16,29 +18,29 @@ public interface WarehouseService extends IService<Warehouse> { ...@@ -16,29 +18,29 @@ public interface WarehouseService extends IService<Warehouse> {
* *
* @param req * @param req
*/ */
boolean addWarehouse(WarehouseReq req); String AddWarehouse(UpdateWarehouseReq req);
/** /**
* 查询单个仓库信息 * 查询单个仓库信息
* *
* @param req * @param req
*/ */
Warehouse getOneWarehouse(WarehouseReq req); WarehouseDto getOneWarehouse(WarehouseReq req);
// ResponseResult deleteWarehouse(Map<String, Object> msg); // ResponseResult deleteWarehouse(Map<String, Object> msg);
boolean deleteWarehouse(WarehouseReq req); boolean DeleteWarehouse(UpdateWarehouseReq req);
/** /**
* 编辑 * 编辑
* *
* @param req * @param req
*/ */
boolean updateWarehouse(WarehouseReq req); boolean updateWarehouse(UpdateWarehouseReq req);
boolean changeWarehouseState(WarehouseReq req); boolean changeWarehouseState(WarehouseReq req);
List<Warehouse> getAllWarehouse(WarehouseReq orgId); List<WarehouseDto> getAllWarehouse(WarehouseReq orgId);
ResponseResult setWarehouseInventory(Map<String, Object> msg); ResponseResult setWarehouseInventory(Map<String, Object> msg);
......
...@@ -7,9 +7,8 @@ import com.junmp.jyzb.api.bean.query.CabinetReq; ...@@ -7,9 +7,8 @@ import com.junmp.jyzb.api.bean.query.CabinetReq;
import com.junmp.jyzb.api.bean.req.UpdateCabinetBoxReq; import com.junmp.jyzb.api.bean.req.UpdateCabinetBoxReq;
import com.junmp.jyzb.entity.Cabinet; import com.junmp.jyzb.entity.Cabinet;
import com.junmp.jyzb.entity.CabinetBox; import com.junmp.jyzb.entity.CabinetBox;
import com.junmp.jyzb.entity.Policeman; import com.junmp.jyzb.api.exception.enums.CabinetBoxExceptionEnum;
import com.junmp.jyzb.exception.enums.CabinetBoxExceptionEnum; import com.junmp.jyzb.api.exception.enums.CabinetExceptionEnum;
import com.junmp.jyzb.exception.enums.CabinetExceptionEnum;
import com.junmp.jyzb.mapper.CabinetBoxMapper; import com.junmp.jyzb.mapper.CabinetBoxMapper;
import com.junmp.jyzb.mapper.PoliceFingerMapper; import com.junmp.jyzb.mapper.PoliceFingerMapper;
import com.junmp.jyzb.mapper.PolicemanMapper; import com.junmp.jyzb.mapper.PolicemanMapper;
...@@ -21,10 +20,8 @@ import org.springframework.stereotype.Service; ...@@ -21,10 +20,8 @@ import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.UUID;
@Service @Service
public class CabinetBoxServiceImpl extends ServiceImpl<CabinetBoxMapper, CabinetBox> implements CabinetBoxService { public class CabinetBoxServiceImpl extends ServiceImpl<CabinetBoxMapper, CabinetBox> implements CabinetBoxService {
......
...@@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; ...@@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.dto.CabinetDto; import com.junmp.jyzb.api.bean.dto.CabinetDto;
import com.junmp.jyzb.api.bean.dto.CabinetBoxDto; import com.junmp.jyzb.api.bean.dto.CabinetBoxDto;
import com.junmp.jyzb.api.bean.dto.CabinetDto;
import com.junmp.jyzb.api.bean.query.CabinetBoxReq; import com.junmp.jyzb.api.bean.query.CabinetBoxReq;
import com.junmp.jyzb.api.bean.query.CabinetReq; import com.junmp.jyzb.api.bean.query.CabinetReq;
import com.junmp.jyzb.api.bean.req.UpdateCabinetBoxReq; import com.junmp.jyzb.api.bean.req.UpdateCabinetBoxReq;
...@@ -14,9 +13,9 @@ import com.junmp.jyzb.entity.Cabinet; ...@@ -14,9 +13,9 @@ import com.junmp.jyzb.entity.Cabinet;
import com.junmp.jyzb.entity.CabinetBox; import com.junmp.jyzb.entity.CabinetBox;
import com.junmp.jyzb.entity.Policeman; import com.junmp.jyzb.entity.Policeman;
import com.junmp.jyzb.entity.PubOrg; import com.junmp.jyzb.entity.PubOrg;
import com.junmp.jyzb.exception.enums.CabinetExceptionEnum; import com.junmp.jyzb.api.exception.enums.CabinetExceptionEnum;
import com.junmp.jyzb.exception.enums.PolicemanExceptionEnum; import com.junmp.jyzb.api.exception.enums.PolicemanExceptionEnum;
import com.junmp.jyzb.exception.enums.PubOrgExceptionEnum; import com.junmp.jyzb.api.exception.enums.PubOrgExceptionEnum;
import com.junmp.jyzb.mapper.*; import com.junmp.jyzb.mapper.*;
import com.junmp.jyzb.service.CabinetBoxService; import com.junmp.jyzb.service.CabinetBoxService;
import com.junmp.jyzb.service.CabinetService; import com.junmp.jyzb.service.CabinetService;
...@@ -149,6 +148,9 @@ public class CabinetServiceImpl extends ServiceImpl<CabinetMapper, Cabinet> impl ...@@ -149,6 +148,9 @@ public class CabinetServiceImpl extends ServiceImpl<CabinetMapper, Cabinet> impl
public boolean deleteCabinetInfo(UpdateCabinetReq req) { public boolean deleteCabinetInfo(UpdateCabinetReq req) {
//获取传递的id列表 //获取传递的id列表
List<String> cabinetIdList = req.getCabinetList(); List<String> cabinetIdList = req.getCabinetList();
if (cabinetIdList.size()==0){
throw new ServiceException(CabinetExceptionEnum.PARAMETER_ERROR);
}
List<Cabinet> cabinetList=new ArrayList<>(); List<Cabinet> cabinetList=new ArrayList<>();
//遍历单警柜id列表 //遍历单警柜id列表
for (String id:cabinetIdList) { for (String id:cabinetIdList) {
......
...@@ -6,7 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -6,7 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.query.PolicemanFingerReq; import com.junmp.jyzb.api.bean.query.PolicemanFingerReq;
import com.junmp.jyzb.entity.PoliceFinger; import com.junmp.jyzb.entity.PoliceFinger;
import com.junmp.jyzb.exception.enums.PolicemanFingerExceptionEnum; import com.junmp.jyzb.api.exception.enums.PolicemanFingerExceptionEnum;
import com.junmp.jyzb.service.PoliceFingerService; import com.junmp.jyzb.service.PoliceFingerService;
import com.junmp.jyzb.utils.DateTimeUtil; import com.junmp.jyzb.utils.DateTimeUtil;
import com.junmp.v2.common.exception.base.ServiceException; import com.junmp.v2.common.exception.base.ServiceException;
......
...@@ -9,10 +9,10 @@ import com.junmp.jyzb.api.bean.dto.PolicemanDto; ...@@ -9,10 +9,10 @@ import com.junmp.jyzb.api.bean.dto.PolicemanDto;
import com.junmp.jyzb.api.bean.query.PolicemanReq; import com.junmp.jyzb.api.bean.query.PolicemanReq;
import com.junmp.jyzb.api.bean.req.UpdatePolicemanReq; import com.junmp.jyzb.api.bean.req.UpdatePolicemanReq;
import com.junmp.jyzb.entity.*; import com.junmp.jyzb.entity.*;
import com.junmp.jyzb.exception.enums.CabinetBoxExceptionEnum; import com.junmp.jyzb.api.exception.enums.CabinetBoxExceptionEnum;
import com.junmp.jyzb.exception.enums.CabinetExceptionEnum; import com.junmp.jyzb.api.exception.enums.CabinetExceptionEnum;
import com.junmp.jyzb.exception.enums.PolicemanExceptionEnum; import com.junmp.jyzb.api.exception.enums.PolicemanExceptionEnum;
import com.junmp.jyzb.exception.enums.PubOrgExceptionEnum; import com.junmp.jyzb.api.exception.enums.PubOrgExceptionEnum;
import com.junmp.jyzb.mapper.*; import com.junmp.jyzb.mapper.*;
import com.junmp.jyzb.service.*; import com.junmp.jyzb.service.*;
import com.junmp.jyzb.utils.*; import com.junmp.jyzb.utils.*;
...@@ -40,6 +40,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -40,6 +40,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
private PolicemanMapper policemanMapper; private PolicemanMapper policemanMapper;
@Resource @Resource
private PoliceFingerMapper policeFingerMapper;
@Resource
private CabinetBoxMapper cabinetBoxMapper;
@Resource
private CabinetMapper cabinetMapper;
@Resource
private PubOrgMapper pubOrgMapper;
@Resource
private PubOrgService pubOrgService; private PubOrgService pubOrgService;
@Resource @Resource
...@@ -57,10 +69,13 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -57,10 +69,13 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
@Resource @Resource
private SysuserService sysUserService; private SysuserService sysUserService;
private static final String REDIS_POLICE = "Policeman_";
private static final String REDIS_ORG = "Organization_";
/** /**
* 添加警员信息 * 添加警员信息
*
* @param req * @param req
* @return * @return
*/ */
...@@ -68,28 +83,61 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -68,28 +83,61 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
public String AddPoliceman(UpdatePolicemanReq req) { public String AddPoliceman(UpdatePolicemanReq req) {
//查询传入的组织机构id是否存在 //查询传入的组织机构id是否存在
PubOrg puborg = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>() PubOrg puborg = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>()
.eq(ObjectUtil.isNotEmpty(req.getOrgId()),PubOrg::getOrgId,req.getOrgId())); .eq(ObjectUtil.isNotEmpty(req.getOrgId()), PubOrg::getOrgId, req.getOrgId()));
if (ObjectUtil.isEmpty(puborg)) { if (ObjectUtil.isEmpty(puborg)) {
//抛出组织机构不存在异常 //抛出组织机构不存在异常
throw new ServiceException(PubOrgExceptionEnum.PUBORG_NOT_EXIST); throw new ServiceException(PubOrgExceptionEnum.PUBORG_NOT_EXIST);
} }
//查询是否有重复的policeCode //查询是否有重复的policeCode
List<Policeman> list = policemanService.list(new LambdaQueryWrapper<Policeman>() List<Policeman> list = policemanService.list(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotEmpty(req.getPoliceCode()), Policeman::getPoliceCode, req.getPoliceCode())); .eq(ObjectUtil.isNotEmpty(req.getPoliceCode()), Policeman::getPoliceCode, req.getPoliceCode()));
if (list.size()>0){ if (list.size() > 0) {
throw new ServiceException(PolicemanExceptionEnum.POLICECODE_IS_EXISTS); throw new ServiceException(PolicemanExceptionEnum.POLICECODE_IS_EXISTS);
} }
Policeman policeman = new Policeman(); Policeman policeman = new Policeman();
BeanPlusUtil.copyProperties(req,policeman); BeanPlusUtil.copyProperties(req, policeman);
//添加警员绑定用户信息 //添加警员绑定用户信息
policemanService.save(policeman); policemanService.save(policeman);
return policeman.getId(); return policeman.getId();
} }
// 更新缓存的方法,新增警员信息时调用
private void updatePoliceIdCache(String orgId, String newPoliceId) {
// 构建 Redis 缓存键
String redisKeyFalse = "getAllPoliceId_false_" + orgId;
String redisKeyTrue = "getAllPoliceId_true_" + orgId;
// 从 Redis 中获取旧的缓存数据
List<String> cachedDataFalse = redisUtils.findCachedData(redisKeyFalse);
List<String> cachedDataTrue = redisUtils.findCachedData(redisKeyTrue);
//如果缓存中没有数据,则直接查询数据库并更新Redis缓存
//如果缓存中有数据,就更新数据
if (cachedDataFalse == null && cachedDataTrue == null) {
//getAllPoliceId(Map.of("IncludeLowerLevel", false, "orgId", orgId));
return;
} else if (cachedDataFalse != null) {
cachedDataFalse.add(newPoliceId);
redisUtils.set(redisKeyFalse, cachedDataFalse);
} else if (cachedDataTrue != null) {
cachedDataTrue.add(newPoliceId);
redisUtils.set(redisKeyTrue, cachedDataTrue);
}
}
//删除缓存的方法
private void deletePoliceIdCache(String orgId) {
//构建 Redis 缓存键
String redisKey = "getAllPoliceId_false_" + orgId;
redisUtils.delete(redisKey);
//构建 Redis 缓存键
redisKey = "getAllPoliceId_true_" + orgId;
redisUtils.delete(redisKey);
}
/** /**
*
* @param req * @param req
* @return * @return
*/ */
...@@ -97,18 +145,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -97,18 +145,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
public PolicemanDto GetOnePolice(PolicemanReq req) { public PolicemanDto GetOnePolice(PolicemanReq req) {
Policeman one = getOne(new LambdaQueryWrapper<Policeman>() Policeman one = getOne(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId())); .eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId()));
if (ObjectUtil.isNull(one)){ if (ObjectUtil.isNull(one)) {
throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST); throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST);
} }
PolicemanDto policemanDto = new PolicemanDto(); PolicemanDto policemanDto = new PolicemanDto();
BeanPlusUtil.copyProperties(one,policemanDto); BeanPlusUtil.copyProperties(one, policemanDto);
//将警员的指纹信息查询出来 //将警员的指纹信息查询出来
List<PoliceFinger> list1 = policeFingerService.list(new LambdaQueryWrapper<PoliceFinger>() List<PoliceFinger> list1 = policeFingerService.list(new LambdaQueryWrapper<PoliceFinger>()
.eq(ObjectUtil.isNotNull(req.getId()), PoliceFinger::getPoliceId, req.getId())); .eq(ObjectUtil.isNotNull(req.getId()), PoliceFinger::getPoliceId, req.getId()));
List<PoliceFingerDto> fingerDtoList=new ArrayList<>(); List<PoliceFingerDto> fingerDtoList = new ArrayList<>();
for (PoliceFinger policeFinger:list1) { for (PoliceFinger policeFinger : list1) {
PoliceFingerDto policeFingerDto = new PoliceFingerDto(); PoliceFingerDto policeFingerDto = new PoliceFingerDto();
BeanPlusUtil.copyProperties(policeFinger,policeFingerDto); BeanPlusUtil.copyProperties(policeFinger, policeFingerDto);
fingerDtoList.add(policeFingerDto); fingerDtoList.add(policeFingerDto);
} }
policemanDto.setFingersList(fingerDtoList); policemanDto.setFingersList(fingerDtoList);
...@@ -118,6 +166,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -118,6 +166,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
/** /**
* 删除警员信息 * 删除警员信息
*
* @param req * @param req
* @return * @return
*/ */
...@@ -128,34 +177,35 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -128,34 +177,35 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
Policeman policeman = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman policeman = policemanService.getOne(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId())); .eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId()));
//查询不到警员信息则抛异常 //查询不到警员信息则抛异常
if (ObjectUtil.isNull(policeman)){ if (ObjectUtil.isNull(policeman)) {
throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST); throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST);
} }
//如果查询出来的警员信息中没有绑定箱门而参数传递了箱门id,则抛出异常警员绑定箱门错误 //如果查询出来的警员信息中没有绑定箱门而参数传递了箱门id,则抛出异常警员绑定箱门错误
//如果传递的箱门id参数与查询出来的箱门id不一致,则抛出异常警员绑定的箱门与实际绑定不符合 //如果传递的箱门id参数与查询出来的箱门id不一致,则抛出异常警员绑定的箱门与实际绑定不符合
if ((ObjectUtil.isNull(policeman.getCabinetBoxId()) && ObjectUtil.isNotNull(req.getCabinetBoxId()))){ if ((ObjectUtil.isNull(policeman.getCabinetBoxId()) && ObjectUtil.isNotNull(req.getCabinetBoxId()))) {
throw new ServiceException(CabinetBoxExceptionEnum.CABINETBOX_ISNOT_EXISTS); throw new ServiceException(CabinetBoxExceptionEnum.CABINETBOX_ISNOT_EXISTS);
} }
//通过警员信息中的userId对账号进行删除 //通过警员信息中的userId对账号进行删除
sysUserService.remove(new LambdaQueryWrapper<User>() sysUserService.remove(new LambdaQueryWrapper<User>()
.eq(User::getUserId,policeman.getUserId())); .eq(User::getUserId, policeman.getUserId()));
return policemanService.removeById(policeman); return policemanService.removeById(policeman);
} }
/** /**
* 修改警员信息 * 修改警员信息
*
* @param req * @param req
* @return * @return
*/ */
@Override @Override
public boolean UpdatePolice(UpdatePolicemanReq req) { public boolean UpdatePolice(UpdatePolicemanReq req) {
Policeman policeman = new Policeman(); Policeman policeman = new Policeman();
BeanPlusUtil.copyProperties(req,policeman); BeanPlusUtil.copyProperties(req, policeman);
//查询传入的组织机构id是否存在 //查询传入的组织机构id是否存在
PubOrg puborg = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>() PubOrg puborg = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>()
.eq(ObjectUtil.isNotEmpty(req.getOrgId()),PubOrg::getOrgId,req.getOrgId())); .eq(ObjectUtil.isNotEmpty(req.getOrgId()), PubOrg::getOrgId, req.getOrgId()));
if (ObjectUtil.isEmpty(puborg)) { if (ObjectUtil.isEmpty(puborg)) {
//抛出组织机构不存在异常 //抛出组织机构不存在异常
throw new ServiceException(PubOrgExceptionEnum.PUBORG_NOT_EXIST); throw new ServiceException(PubOrgExceptionEnum.PUBORG_NOT_EXIST);
...@@ -163,10 +213,10 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -163,10 +213,10 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
//判断传入的修改的警员编号与本身编号一致,如果一致则无所谓,如果不一致则需要判断修改的警员编号是否已经存在 //判断传入的修改的警员编号与本身编号一致,如果一致则无所谓,如果不一致则需要判断修改的警员编号是否已经存在
Policeman one = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman one = policemanService.getOne(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId())); .eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId()));
if (!req.getPoliceCode().equals(one.getPoliceCode())){ if (!req.getPoliceCode().equals(one.getPoliceCode())) {
Policeman one1 = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman one1 = policemanService.getOne(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotNull(req.getPoliceCode()), Policeman::getPoliceCode, req.getPoliceCode())); .eq(ObjectUtil.isNotNull(req.getPoliceCode()), Policeman::getPoliceCode, req.getPoliceCode()));
if (ObjectUtil.isNotNull(one1)){ if (ObjectUtil.isNotNull(one1)) {
throw new ServiceException(PolicemanExceptionEnum.POLICECODE_IS_EXISTS); throw new ServiceException(PolicemanExceptionEnum.POLICECODE_IS_EXISTS);
} }
} }
...@@ -174,7 +224,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -174,7 +224,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
//查询单警柜箱号是否存在,箱门不存在抛异常 //查询单警柜箱号是否存在,箱门不存在抛异常
CabinetBox cabinetBox = cabinetBoxService.getOne(new LambdaQueryWrapper<CabinetBox>() CabinetBox cabinetBox = cabinetBoxService.getOne(new LambdaQueryWrapper<CabinetBox>()
.eq(CabinetBox::getId, req.getCabinetBoxId())); .eq(CabinetBox::getId, req.getCabinetBoxId()));
if (ObjectUtil.isNull(cabinetBox)){ if (ObjectUtil.isNull(cabinetBox)) {
throw new ServiceException(CabinetBoxExceptionEnum.CABINETBOX_ISNOT_EXISTS); throw new ServiceException(CabinetBoxExceptionEnum.CABINETBOX_ISNOT_EXISTS);
} }
policeman.setUpdateTime(DateTimeUtil.getCurrentDateTime()); policeman.setUpdateTime(DateTimeUtil.getCurrentDateTime());
...@@ -182,12 +232,9 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -182,12 +232,9 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
} }
/** /**
* 修改警员状态 * 修改警员状态
*
* @param req * @param req
* @return * @return
*/ */
...@@ -196,7 +243,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -196,7 +243,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
//通过警员id查询出警员信息 //通过警员id查询出警员信息
Policeman one = getOne(new LambdaQueryWrapper<Policeman>() Policeman one = getOne(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId())); .eq(ObjectUtil.isNotNull(req.getId()), Policeman::getId, req.getId()));
if (ObjectUtil.isNull(one)){ if (ObjectUtil.isNull(one)) {
throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST); throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST);
} }
one.setState(req.getState()); one.setState(req.getState());
...@@ -204,15 +251,44 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -204,15 +251,44 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
} }
public List<Map<String, Object>> getAllPolicemanMsg(Map<String, Object> msg, List<String> allPoliceId) {
List<Map<String, Object>> allPoliceman = new ArrayList<>();
// 构建 Redis 缓存键
String redisKey = REDIS_ORG + msg.get("IncludeLowerLevel").toString() + '_' + msg.get("orgId").toString();
// 从 Redis 中获取数据
List<Map<String, Object>> cachedData = redisUtils.findCachedData(redisKey);
if (cachedData != null) {
//将Long类型的数据转化为Date
for (Map<String, Object> one : cachedData) {
Long dataMsg = (Long) one.get("updateTime");
one.put("updateTime", redisUtils.getDate(dataMsg));
allPoliceman.add(one);
}
return cachedData;
}
for (String policeId : allPoliceId) {
Map<String, Object> policeMsg = policemanMapper.getOnePolice(policeId);
allPoliceman.add(policeMsg);
}
//按照updateTime降序排序
DateTimeUtil.timeSort(allPoliceman);
//将查询结果存入 Redis 中
redisUtils.set(redisKey, allPoliceman);
return allPoliceman;
}
/** /**
* 通过组织机构id查询警员列表 * 通过组织机构id查询警员列表
*
* @param orgId * @param orgId
*/ */
@Override @Override
public PoliceDto GetAllPolicemanList(Long orgId) { public PoliceDto GetAllPolicemanList(Long orgId) {
//查询传入的组织机构id是否存在 //查询传入的组织机构id是否存在
PubOrg puborg = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>() PubOrg puborg = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>()
.eq(ObjectUtil.isNotEmpty(orgId),PubOrg::getOrgId,orgId)); .eq(ObjectUtil.isNotEmpty(orgId), PubOrg::getOrgId, orgId));
if (ObjectUtil.isNull(puborg)) { if (ObjectUtil.isNull(puborg)) {
//抛出组织机构不存在异常 //抛出组织机构不存在异常
throw new ServiceException(PubOrgExceptionEnum.PUBORG_NOT_EXIST); throw new ServiceException(PubOrgExceptionEnum.PUBORG_NOT_EXIST);
...@@ -220,18 +296,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -220,18 +296,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
//查询出组织机构下的所有警员信息 //查询出组织机构下的所有警员信息
List<Policeman> list = list(new LambdaQueryWrapper<Policeman>() List<Policeman> list = list(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotEmpty(orgId), Policeman::getOrgId, orgId) .eq(ObjectUtil.isNotEmpty(orgId), Policeman::getOrgId, orgId)
.eq(Policeman::getState,1)); .eq(Policeman::getState, 1));
List<PolicemanDto> policeList=new ArrayList<>(); List<PolicemanDto> policeList = new ArrayList<>();
//查询出警员信息下的指纹列表信息 //查询出警员信息下的指纹列表信息
for (Policeman p:list) { for (Policeman p : list) {
PolicemanDto policemanDto = new PolicemanDto(); PolicemanDto policemanDto = new PolicemanDto();
BeanPlusUtil.copyProperties(p,policemanDto); BeanPlusUtil.copyProperties(p, policemanDto);
List<PoliceFinger> list1 = policeFingerService.list(new LambdaQueryWrapper<PoliceFinger>() List<PoliceFinger> list1 = policeFingerService.list(new LambdaQueryWrapper<PoliceFinger>()
.eq(ObjectUtil.isNotNull(p.getId()), PoliceFinger::getPoliceId, p.getId())); .eq(ObjectUtil.isNotNull(p.getId()), PoliceFinger::getPoliceId, p.getId()));
List<PoliceFingerDto> policeFingerDtoList=new ArrayList<>(); List<PoliceFingerDto> policeFingerDtoList = new ArrayList<>();
for (PoliceFinger policeFinger:list1) { for (PoliceFinger policeFinger : list1) {
PoliceFingerDto policeFingerDto = new PoliceFingerDto(); PoliceFingerDto policeFingerDto = new PoliceFingerDto();
BeanPlusUtil.copyProperties(policeFinger,policeFingerDto); BeanPlusUtil.copyProperties(policeFinger, policeFingerDto);
policeFingerDtoList.add(policeFingerDto); policeFingerDtoList.add(policeFingerDto);
} }
policemanDto.setFingersList(policeFingerDtoList); policemanDto.setFingersList(policeFingerDtoList);
...@@ -247,6 +323,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -247,6 +323,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
} }
//根据单警柜id查询警员信息 //根据单警柜id查询警员信息
@Override @Override
public PoliceDto GetPoliceData(String id) { public PoliceDto GetPoliceData(String id) {
...@@ -254,22 +331,22 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -254,22 +331,22 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
//判断单警柜id是否正确 //判断单警柜id是否正确
Cabinet cabinet = cabinetService.getOne(new LambdaQueryWrapper<Cabinet>() Cabinet cabinet = cabinetService.getOne(new LambdaQueryWrapper<Cabinet>()
.eq(Cabinet::getId, id)); .eq(Cabinet::getId, id));
if (ObjectUtil.isNull(cabinet)){ if (ObjectUtil.isNull(cabinet)) {
throw new ServiceException(CabinetExceptionEnum.CABINET_ISNOT_EXISTS); throw new ServiceException(CabinetExceptionEnum.CABINET_ISNOT_EXISTS);
} }
//通过箱门id查询出警员 //通过箱门id查询出警员
List<Policeman> policemenList = policemanMapper.SearchPoliceList(id); List<Policeman> policemenList = policemanMapper.SearchPoliceList(id);
List<PolicemanDto> list = new ArrayList<>(); List<PolicemanDto> list = new ArrayList<>();
for (Policeman policeman:policemenList) { for (Policeman policeman : policemenList) {
PolicemanDto policemanDto = new PolicemanDto(); PolicemanDto policemanDto = new PolicemanDto();
BeanPlusUtil.copyProperties(policeman,policemanDto); BeanPlusUtil.copyProperties(policeman, policemanDto);
//指纹信息查找 //指纹信息查找
List<PoliceFinger> fingerList = policeFingerService.list(new LambdaQueryWrapper<PoliceFinger>() List<PoliceFinger> fingerList = policeFingerService.list(new LambdaQueryWrapper<PoliceFinger>()
.eq(PoliceFinger::getPoliceId, policeman.getId())); .eq(PoliceFinger::getPoliceId, policeman.getId()));
List<PoliceFingerDto> fingerDtoList=new ArrayList<>(); List<PoliceFingerDto> fingerDtoList = new ArrayList<>();
for (PoliceFinger policeFinger:fingerList) { for (PoliceFinger policeFinger : fingerList) {
PoliceFingerDto policeFingerDto = new PoliceFingerDto(); PoliceFingerDto policeFingerDto = new PoliceFingerDto();
BeanPlusUtil.copyProperties(policeFinger,policeFingerDto); BeanPlusUtil.copyProperties(policeFinger, policeFingerDto);
fingerDtoList.add(policeFingerDto); fingerDtoList.add(policeFingerDto);
} }
policemanDto.setFingersList(fingerDtoList); policemanDto.setFingersList(fingerDtoList);
...@@ -287,14 +364,14 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -287,14 +364,14 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
//添加人脸信息 //添加人脸信息
@Override @Override
public boolean AddFaceInfo(PolicemanReq req) { public boolean AddFaceInfo(UpdatePolicemanReq req) {
//面部信息为null或者为空 //面部信息为null或者为空
if (ObjectUtil.isNull(req.getFaceInfo()) || ObjectUtil.isEmpty(req.getFaceInfo())){ if (ObjectUtil.isNull(req.getFaceInfo()) || ObjectUtil.isEmpty(req.getFaceInfo())) {
return false; return false;
} }
Policeman police = getOne(new LambdaQueryWrapper<Policeman>() Policeman police = getOne(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotEmpty(req.getId()),Policeman::getId,req.getId())); .eq(ObjectUtil.isNotEmpty(req.getId()), Policeman::getId, req.getId()));
if (ObjectUtil.isNull(police)){ if (ObjectUtil.isNull(police)) {
throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST); throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST);
} }
police.setFaceInfo(req.getFaceInfo()); police.setFaceInfo(req.getFaceInfo());
...@@ -303,17 +380,17 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -303,17 +380,17 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
} }
/** /**
* @author lxh * @param
* @description 更新人脸信息\删除人脸信息 * @return
* 删除时:传一个null的人脸信息即可 * @author lxh
* @since 2023/7/18 15:02 * @description 更新人脸信息\删除人脸信息
* @param * 删除时:传一个null的人脸信息即可
* @return * @since 2023/7/18 15:02
**/ **/
@Override @Override
public boolean UpdateFaceInfo(UpdatePolicemanReq req) { public boolean UpdateFaceInfo(UpdatePolicemanReq req) {
//警员id不能为空 //警员id不能为空
if (ObjectUtil.isEmpty(req.getId()) || ObjectUtil.isNull(req.getId())){ if (ObjectUtil.isEmpty(req.getId()) || ObjectUtil.isNull(req.getId())) {
return false; return false;
} }
Policeman police = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman police = policemanService.getOne(new LambdaQueryWrapper<Policeman>()
...@@ -325,30 +402,30 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -325,30 +402,30 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
} }
/** /**
* @author lxh * @param
* @description 查询人脸信息 * @return
* @since 2023/7/18 15:02 * @author lxh
* @param * @description 查询人脸信息
* @return * @since 2023/7/18 15:02
**/ **/
@Override @Override
public Policeman SearchFaceInfo(PolicemanReq req) { public Policeman SearchFaceInfo(PolicemanReq req) {
//警员id不能为空 //警员id不能为空
if (ObjectUtil.isEmpty(req.getId()) || ObjectUtil.isNull(req.getId())){ if (ObjectUtil.isEmpty(req.getId()) || ObjectUtil.isNull(req.getId())) {
return null; return null;
} }
Policeman policeman = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman policeman = policemanService.getOne(new LambdaQueryWrapper<Policeman>()
.eq(ObjectUtil.isNotEmpty(req.getId()), Policeman::getId, req.getId())); .eq(ObjectUtil.isNotEmpty(req.getId()), Policeman::getId, req.getId()));
if (ObjectUtil.isNull(policeman)){ if (ObjectUtil.isNull(policeman)) {
throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST); throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST);
} }
return policeman; return policeman;
} }
/** /**
* 警员绑定账号 * 警员绑定账号
*
* @param req * @param req
* @return * @return
*/ */
...@@ -356,16 +433,16 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -356,16 +433,16 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
@Override @Override
public boolean PoliceBindUser(PolicemanReq req) { public boolean PoliceBindUser(PolicemanReq req) {
User user = new User(); User user = new User();
BeanPlusUtil.copyProperties(req,user); BeanPlusUtil.copyProperties(req, user);
//密码加密,依赖注入错误 //密码加密,依赖注入错误
BcryptPasswordStoredEncrypt passwordStoredEncrypt = new BcryptPasswordStoredEncrypt(); BcryptPasswordStoredEncrypt passwordStoredEncrypt = new BcryptPasswordStoredEncrypt();
String encrypt = passwordStoredEncrypt.encrypt(req.getPassword()); String encrypt = passwordStoredEncrypt.encrypt(req.getPassword());
user.setPassword(encrypt); user.setPassword(encrypt);
//存储到数据库 //存储到数据库
//判断传入的sex是什么,需要做处理 //判断传入的sex是什么,需要做处理
if (req.getSex().equals("男")){ if (req.getSex().equals("男")) {
user.setSex("M"); user.setSex("M");
}else{ } else {
user.setSex("F"); user.setSex("F");
} }
user.setRealName(req.getName()); user.setRealName(req.getName());
...@@ -375,7 +452,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -375,7 +452,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
//通过警员id将查询到的警员信息进行修改设置 //通过警员id将查询到的警员信息进行修改设置
Policeman policeman = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman policeman = policemanService.getOne(new LambdaQueryWrapper<Policeman>()
.eq(Policeman::getId, req.getId())); .eq(Policeman::getId, req.getId()));
if (ObjectUtil.isNull(policeman)){ if (ObjectUtil.isNull(policeman)) {
throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST); throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST);
} }
policeman.setUserId(user.getUserId()); policeman.setUserId(user.getUserId());
...@@ -388,20 +465,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -388,20 +465,18 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
@Override @Override
public boolean PoliceBindBox(PolicemanReq req) { public boolean PoliceBindBox(PolicemanReq req) {
Policeman policeman = new Policeman(); Policeman policeman = new Policeman();
BeanPlusUtil.copyProperties(req,policeman); BeanPlusUtil.copyProperties(req, policeman);
Policeman one = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman one = policemanService.getOne(new LambdaQueryWrapper<Policeman>()
.eq(Policeman::getId, req.getId())); .eq(Policeman::getId, req.getId()));
if (ObjectUtil.isNull(one)){ if (ObjectUtil.isNull(one)) {
throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST); throw new ServiceException(PolicemanExceptionEnum.POLICEMAN_NOT_EXIST);
} }
//判断箱子是否存在 //判断箱子是否存在
CabinetBox cabinetBox = cabinetBoxService.getOne(new LambdaQueryWrapper<CabinetBox>() CabinetBox cabinetBox = cabinetBoxService.getOne(new LambdaQueryWrapper<CabinetBox>()
.eq(CabinetBox::getId, req.getCabinetBoxId())); .eq(CabinetBox::getId, req.getCabinetBoxId()));
if (ObjectUtil.isNull(cabinetBox)){ if (ObjectUtil.isNull(cabinetBox)) {
throw new ServiceException(CabinetBoxExceptionEnum.CABINETBOX_ISNOT_EXISTS); throw new ServiceException(CabinetBoxExceptionEnum.CABINETBOX_ISNOT_EXISTS);
} }
return policemanService.updateById(policeman); return policemanService.updateById(policeman);
} }
} }
...@@ -3,9 +3,14 @@ package com.junmp.jyzb.service.impl; ...@@ -3,9 +3,14 @@ package com.junmp.jyzb.service.impl;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.dto.ShelfDto;
import com.junmp.jyzb.api.bean.query.ShelfReq; import com.junmp.jyzb.api.bean.query.ShelfReq;
import com.junmp.jyzb.api.bean.req.UpdateShelfReq;
import com.junmp.jyzb.api.exception.enums.ShelfExceptionEnum; import com.junmp.jyzb.api.exception.enums.ShelfExceptionEnum;
import com.junmp.jyzb.api.exception.enums.WarehouseExceptionEnum;
import com.junmp.jyzb.entity.Shelf; import com.junmp.jyzb.entity.Shelf;
import com.junmp.jyzb.entity.Warehouse;
import com.junmp.jyzb.service.WarehouseService;
import com.junmp.v2.common.exception.base.ServiceException; import com.junmp.v2.common.exception.base.ServiceException;
import com.junmp.v2.common.util.BeanPlusUtil; import com.junmp.v2.common.util.BeanPlusUtil;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -13,48 +18,66 @@ import javax.annotation.Resource; ...@@ -13,48 +18,66 @@ import javax.annotation.Resource;
import com.junmp.jyzb.mapper.ShelfMapper; import com.junmp.jyzb.mapper.ShelfMapper;
import com.junmp.jyzb.service.ShelfService; import com.junmp.jyzb.service.ShelfService;
import java.util.ArrayList;
import java.util.List; import java.util.List;
@Service @Service
public class ShelfServiceImpl extends ServiceImpl<ShelfMapper, Shelf> implements ShelfService { public class ShelfServiceImpl extends ServiceImpl<ShelfMapper, Shelf> implements ShelfService {
@Resource @Resource
private ShelfMapper shelfMapper; private WarehouseService warehouseService;
@Override @Override
public boolean addShelf(ShelfReq req) { public boolean AddShelf(UpdateShelfReq req) {
Shelf shelf = new Shelf(); Shelf shelf = new Shelf();
BeanPlusUtil.copyProperties(req,shelf); BeanPlusUtil.copyProperties(req,shelf);
return this.save(shelf); return this.save(shelf);
} }
@Override @Override
public boolean updateShelf(ShelfReq req) { public boolean UpdateShelf(UpdateShelfReq req) {
Shelf shelf = this.queryShelf(req); //判断货架id是否正确
Shelf shelf = this.QueryShelf(req);
BeanPlusUtil.copyProperties(req, shelf); BeanPlusUtil.copyProperties(req, shelf);
return this.updateById(shelf); return this.updateById(shelf);
} }
@Override @Override
public boolean deleteShelf(ShelfReq req) { public boolean DeleteShelf(UpdateShelfReq req) {
Shelf shelf = queryShelf(req); QueryShelf(req);
this.removeById(req.getShelfId()); return removeById(req.getShelfId());
return true;
} }
@Override @Override
public List<Shelf> getShelfList(ShelfReq req) { public List<ShelfDto> GetShelfList(ShelfReq req) {
//判断仓库id是否存在
Warehouse one = warehouseService.getOne(new LambdaQueryWrapper<Warehouse>()
.eq(Warehouse::getId, req.getWarehouseId()));
if (ObjectUtil.isNull(one)){
throw new ServiceException(WarehouseExceptionEnum.WAREHOUSE_NOT_EXIST);
}
LambdaQueryWrapper<Shelf> wrapper = createWrapper(req); LambdaQueryWrapper<Shelf> wrapper = createWrapper(req);
return this.list(wrapper); List<Shelf> list = list(wrapper);
List<ShelfDto> shelfDtoList=new ArrayList<>();
for (Shelf shelf:list) {
ShelfDto shelfDto = new ShelfDto();
BeanPlusUtil.copyProperties(shelf,shelfDto);
shelfDtoList.add(shelfDto);
}
return shelfDtoList;
} }
private Shelf queryShelf(ShelfReq req) { /**
Shelf app = this.getById(req.getShelfId()); * 判断货架id是否存在
* @param req
if (ObjectUtil.isNull(app)) { * @return
*/
private Shelf QueryShelf(UpdateShelfReq req) {
Shelf shelf = this.getById(req.getShelfId());
if (ObjectUtil.isNull(shelf)) {
throw new ServiceException(ShelfExceptionEnum.SHELF_NOT_EXIST); throw new ServiceException(ShelfExceptionEnum.SHELF_NOT_EXIST);
} }
return app; return shelf;
} }
private LambdaQueryWrapper<Shelf> createWrapper(ShelfReq req) { private LambdaQueryWrapper<Shelf> createWrapper(ShelfReq req) {
......
...@@ -3,9 +3,14 @@ package com.junmp.jyzb.service.impl; ...@@ -3,9 +3,14 @@ package com.junmp.jyzb.service.impl;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.dto.WarehouseAreaDto;
import com.junmp.jyzb.api.bean.query.WarehouseAreaReq; import com.junmp.jyzb.api.bean.query.WarehouseAreaReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseAreaReq;
import com.junmp.jyzb.api.exception.enums.WarehouseAreaExceptionEnum; import com.junmp.jyzb.api.exception.enums.WarehouseAreaExceptionEnum;
import com.junmp.jyzb.api.exception.enums.WarehouseExceptionEnum;
import com.junmp.jyzb.entity.Warehouse;
import com.junmp.jyzb.entity.WarehouseArea; import com.junmp.jyzb.entity.WarehouseArea;
import com.junmp.jyzb.service.WarehouseService;
import com.junmp.v2.common.exception.base.ServiceException; import com.junmp.v2.common.exception.base.ServiceException;
import com.junmp.v2.common.util.BeanPlusUtil; import com.junmp.v2.common.util.BeanPlusUtil;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -13,6 +18,7 @@ import javax.annotation.Resource; ...@@ -13,6 +18,7 @@ import javax.annotation.Resource;
import com.junmp.jyzb.mapper.WarehouseAreaMapper; import com.junmp.jyzb.mapper.WarehouseAreaMapper;
import com.junmp.jyzb.service.WarehouseAreaService; import com.junmp.jyzb.service.WarehouseAreaService;
import java.util.ArrayList;
import java.util.List; import java.util.List;
@Service @Service
...@@ -21,53 +27,79 @@ public class WarehouseAreaServiceImpl extends ServiceImpl<WarehouseAreaMapper, W ...@@ -21,53 +27,79 @@ public class WarehouseAreaServiceImpl extends ServiceImpl<WarehouseAreaMapper, W
@Resource @Resource
private WarehouseAreaMapper warehouseAreaMapper; private WarehouseAreaMapper warehouseAreaMapper;
@Resource
private WarehouseService warehouseService;
@Override @Override
public boolean addArea(WarehouseAreaReq req) { public boolean addArea(UpdateWarehouseAreaReq req) {
WarehouseArea area = new WarehouseArea(); WarehouseArea area = new WarehouseArea();
BeanPlusUtil.copyProperties(req, area); BeanPlusUtil.copyProperties(req, area);
//判断仓库是否存在
WarehouseExist(req.getWarehouseId());
//判断区域名称是否存在如果存在则抛出异常
List<WarehouseArea> list = list(new LambdaQueryWrapper<WarehouseArea>()
.eq(WarehouseArea::getWarehouseId, req.getWarehouseId())
.eq(WarehouseArea::getAreaName, req.getAreaName()));
if (list.size()>0){
throw new ServiceException(WarehouseAreaExceptionEnum.AREA_IS_EXISTS);
}
return this.save(area); return this.save(area);
} }
@Override @Override
public boolean updateArea(WarehouseAreaReq req) { public boolean updateArea(UpdateWarehouseAreaReq req) {
WarehouseArea area = this.queryWarehouseArea(req); WarehouseArea warehouseArea = new WarehouseArea();
BeanPlusUtil.copyProperties(req, area); BeanPlusUtil.copyProperties(req,warehouseArea);
return this.updateById(area); //判断仓库是否存在
WarehouseExist(req.getWarehouseId());
//判断传入的区域id是否存在
WarehouseAreaExist(req.getAreaId());
return this.updateById(warehouseArea);
} }
@Override @Override
public boolean deleteArea(WarehouseAreaReq req) { public boolean deleteArea(UpdateWarehouseAreaReq req) {
WarehouseArea warehouseArea = queryWarehouseArea(req); //判断传入的区域id是否存在
this.removeById(req.getId()); WarehouseAreaExist(req.getAreaId());
return true; WarehouseArea warehouseArea = new WarehouseArea();
BeanPlusUtil.copyProperties(req,warehouseArea);
return this.removeById(warehouseArea.getId());
} }
@Override @Override
public List<WarehouseArea> getAreaList(WarehouseAreaReq req) { public List<WarehouseAreaDto> getAreaList(WarehouseAreaReq req) {
LambdaQueryWrapper<WarehouseArea> wrapper = createWrapper(req); //判断仓库是否存在
return this.list(wrapper); WarehouseExist(req.getWarehouseId());
List<WarehouseArea> list = list(new LambdaQueryWrapper<WarehouseArea>()
.eq(WarehouseArea::getWarehouseId, req.getWarehouseId()));
List<WarehouseAreaDto> warehouseAreaDtoList=new ArrayList<>();
for (WarehouseArea warehouseArea:list) {
WarehouseAreaDto warehouseAreaDto = new WarehouseAreaDto();
BeanPlusUtil.copyProperties(warehouseArea,warehouseAreaDto);
warehouseAreaDtoList.add(warehouseAreaDto);
}
return warehouseAreaDtoList;
} }
private WarehouseArea queryWarehouseArea(WarehouseAreaReq req) {
WarehouseArea app = this.getById(req.getId());
if (ObjectUtil.isNull(app)) { //判断仓库是否存在
throw new ServiceException(WarehouseAreaExceptionEnum.WAREHOUSEAREA_NOT_EXIST); private Warehouse WarehouseExist(String id){
Warehouse one = warehouseService.getOne(new LambdaQueryWrapper<Warehouse>()
.eq(Warehouse::getId, id));
if (ObjectUtil.isNull(one)){
throw new ServiceException(WarehouseExceptionEnum.WAREHOUSE_NOT_EXIST);
} }
return app; return one;
} }
private LambdaQueryWrapper<WarehouseArea> createWrapper(WarehouseAreaReq req) { //判断区域id是否正确存在
LambdaQueryWrapper<WarehouseArea> wrapper = new LambdaQueryWrapper<>(); private WarehouseArea WarehouseAreaExist(String id){
if (ObjectUtil.isEmpty(req)) { WarehouseArea warehouseArea = this.getById(id);
return wrapper; if (ObjectUtil.isNull(warehouseArea)){
throw new ServiceException(WarehouseAreaExceptionEnum.WAREHOUSEAREA_NOT_EXIST);
} }
//根据地区id查询 return warehouseArea;
wrapper.eq(ObjectUtil.isNotEmpty(req.getId()), WarehouseArea::getId, req.getId());
//根据地区名称模糊查询
wrapper.like(ObjectUtil.isNotEmpty(req.getAreaName()), WarehouseArea::getAreaName, req.getAreaName());
wrapper.orderByDesc(WarehouseArea::getCreateTime);
return wrapper;
} }
} }
...@@ -3,11 +3,14 @@ package com.junmp.jyzb.service.impl; ...@@ -3,11 +3,14 @@ package com.junmp.jyzb.service.impl;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.query.WarehouseAreaReq; import com.junmp.jyzb.api.bean.dto.WarehouseDto;
import com.junmp.jyzb.api.bean.query.ProductReq; import com.junmp.jyzb.api.bean.query.ProductReq;
import com.junmp.jyzb.api.bean.query.WarehouseReq; import com.junmp.jyzb.api.bean.query.WarehouseReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseReq;
import com.junmp.jyzb.api.exception.enums.WarehouseExceptionEnum; import com.junmp.jyzb.api.exception.enums.WarehouseExceptionEnum;
import com.junmp.jyzb.entity.*; import com.junmp.jyzb.entity.*;
import com.junmp.jyzb.api.exception.enums.CabinetExceptionEnum;
import com.junmp.jyzb.api.exception.enums.PubOrgExceptionEnum;
import com.junmp.jyzb.mapper.*; import com.junmp.jyzb.mapper.*;
import com.junmp.jyzb.service.PubOrgService; import com.junmp.jyzb.service.PubOrgService;
import com.junmp.jyzb.service.WarehouseService; import com.junmp.jyzb.service.WarehouseService;
...@@ -16,12 +19,12 @@ import com.junmp.v2.common.exception.base.ServiceException; ...@@ -16,12 +19,12 @@ import com.junmp.v2.common.exception.base.ServiceException;
import com.junmp.v2.common.util.BeanPlusUtil; import com.junmp.v2.common.util.BeanPlusUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.*; import java.util.*;
import static com.junmp.jyzb.utils.CheckBlank.checkNotBlank;
@Service @Service
@Slf4j @Slf4j
public class WarehouseServiceImpl extends ServiceImpl<WarehouseMapper,Warehouse> implements WarehouseService { public class WarehouseServiceImpl extends ServiceImpl<WarehouseMapper,Warehouse> implements WarehouseService {
...@@ -36,56 +39,86 @@ public class WarehouseServiceImpl extends ServiceImpl<WarehouseMapper,Warehouse> ...@@ -36,56 +39,86 @@ public class WarehouseServiceImpl extends ServiceImpl<WarehouseMapper,Warehouse>
@Override @Override
public boolean addWarehouse(WarehouseReq req) { public String AddWarehouse(UpdateWarehouseReq req) {
Warehouse warehouse = new Warehouse(); Warehouse warehouse = new Warehouse();
BeanPlusUtil.copyProperties(req, warehouse); BeanPlusUtil.copyProperties(req, warehouse);
return this.save(warehouse); save(warehouse);
return warehouse.getId();
} }
@Override @Override
public Warehouse getOneWarehouse(WarehouseReq req) { public WarehouseDto getOneWarehouse(WarehouseReq req) {
Warehouse warehouseMsg=this.getById(req.getId()); Warehouse warehouseMsg=this.getById(req.getId());
if (warehouseMsg == null) { if (ObjectUtil.isNull(warehouseMsg)){
return null; throw new ServiceException(WarehouseExceptionEnum.WAREHOUSE_NOT_EXIST);
} }
// 填充其他关联信息的字段和对象引用 WarehouseDto warehouseDto = new WarehouseDto();
return warehouseMsg; BeanPlusUtil.copyProperties(warehouseMsg,warehouseDto);
//获取组织机构名称
PubOrg one = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>()
.eq(PubOrg::getOrgId, warehouseMsg.getOrgId()));
warehouseDto.setOrgName(one.getOrgName());
return warehouseDto;
} }
@Override @Override
public boolean deleteWarehouse(WarehouseReq req) { @Transactional(rollbackFor = Exception.class)
this.removeById(req.getId()); public boolean DeleteWarehouse(UpdateWarehouseReq req) {
List<String> warehouseList = req.getWarehouseList();
if (warehouseList.size()<1){
//抛出参数传递异常
throw new ServiceException(CabinetExceptionEnum.PARAMETER_ERROR);
}
removeBatchByIds(warehouseList);
return true; return true;
} }
@Override @Override
public boolean updateWarehouse(WarehouseReq req) { public boolean updateWarehouse(UpdateWarehouseReq req) {
Warehouse warehouse = this.queryWarehouse(req); Warehouse warehouse = new Warehouse();
BeanPlusUtil.copyProperties(req, warehouse); BeanPlusUtil.copyProperties(req,warehouse);
return this.updateById(warehouse); return this.updateById(warehouse);
} }
@Override @Override
public List<Warehouse> getAllWarehouse(WarehouseReq msg) { public List<WarehouseDto> getAllWarehouse(WarehouseReq msg) {
List<Warehouse> allWarehouse=new ArrayList<>(); List<Warehouse> allWarehouse=new ArrayList<>();
List<WarehouseDto> warehouseDtoList=new ArrayList<>();
//判断组织机构是否存在
PubOrg one = pubOrgService.getOne(new LambdaQueryWrapper<PubOrg>()
.eq(PubOrg::getOrgId, msg.getOrgId()));
if (ObjectUtil.isNull(one)){
throw new ServiceException(PubOrgExceptionEnum.PUBORG_NOT_EXIST);
}
//根据组织机构id查询组织机构名称
String orgName = one.getOrgName();
//如果组织机构是浙江省公安厅 //如果组织机构是浙江省公安厅
if (msg.getOrgId().equals(1369509498032808905l) && msg.getIncludeLowerLevel().equals("true")){ if (msg.getOrgId().equals(1369509498032808905L) && msg.getIncludeLowerLevel().equals("true")){
allWarehouse = this.list(); allWarehouse = this.list();
return allWarehouse; for (Warehouse warehouse:allWarehouse) {
WarehouseDto warehouseDto = new WarehouseDto();
BeanPlusUtil.copyProperties(warehouse,warehouseDto);
warehouseDto.setOrgName(orgName);
warehouseDtoList.add(warehouseDto);
}
return warehouseDtoList;
} }
//获取组织机构Id //获取组织机构Id
List<String> allOrgId =getAllOrgId(msg); List<String> allOrgId =getAllOrgId(msg);
//根据获取的组织机构查询警员信息
allWarehouse = getAllWarehouseByOrg(allOrgId); allWarehouse = getAllWarehouseByOrg(allOrgId);
return allWarehouse; for (Warehouse warehouse:allWarehouse) {
WarehouseDto warehouseDto = new WarehouseDto();
BeanPlusUtil.copyProperties(warehouse,warehouseDto);
warehouseDto.setOrgName(orgName);
warehouseDtoList.add(warehouseDto);
}
return warehouseDtoList;
} }
......
...@@ -264,6 +264,7 @@ ...@@ -264,6 +264,7 @@
<dependency> <dependency>
<groupId>org.springframework.security</groupId> <groupId>org.springframework.security</groupId>
<artifactId>spring-security-web</artifactId> <artifactId>spring-security-web</artifactId>
<version>5.0.5.RELEASE</version>
</dependency> </dependency>
</dependencies> </dependencies>
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论