Commit 164cd064 by 李小惠

添加配置信息接口,除湿机配置接口,本地获取基础信息、人员信息装备接口,修改使用统计报表接口,修改bug

parent 007f54de
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
import java.util.Date;
@Data
public class DeviceConfigDto {
private Long id;
/**
* 设备名称
*/
private String deviceName;
/**
* 设备编号
*/
private String deviceCode;
/**
* 设备状态(0异常1正常)
*/
private Integer state;
/**
* 位置
*/
private String position;
/**
* 仓库id
*/
private String locationId;
/**
* 日常日志信息
*/
private String errorLog;
/**
* 设备配置信息
*/
private String deviceConfig;
/**
* 组织机构id
*/
private Long orgId;
/**
* 创建时间
*/
private Date createTime;
/**
* 更新时间
*/
private Date updateTime;
/**
* 创建人
*/
private String createUser;
/**
* 更新人
*/
private String updateUser;
private String locationName;
private String orgName;
private Integer deviceType;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import lombok.Data;
import java.math.BigDecimal;
import java.util.Date;
@Data
public class EquipmentDto {
private String id;
/**
* 装备包ID
*/
private String packageId;
private Integer equipmentType;
/**
* 装备类型ID
*/
private String typeId;
/**
* 装备号型ID
*/
private String sizeId;
/**
* 供应商id
*/
private String supplierId;
/**
* epc
*/
private String epc;
/**
* 组织机构id
*/
private String orgId;
/**
* 物资状态
*/
private String state;
/**
* 业务状态
*/
private String bussinessState;
/**
* 生产日期
*/
private Date productionDate;
/**
* 质保期
*/
private int warrantyPeriod;
/**
* 维保期
*/
private int maintenancePeriod;
/**
* 维修次数
*/
private int fixCount;
/**
* 位置类型
*/
private String locationType;
/**
* 位置
*/
private String locationId ;
/**
* 是否遗失
*/
private int lostFlag ;
/**
* 价格
*/
private BigDecimal price ;
/**
* 备注
*/
private String note ;
private Date createTime;
private Date updateTime;
private String typeName;
private String sizeName;
private String supplierName;
private String locationName;
//状态,normal正常,destory销毁,fix维修
private String equState;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import com.junmp.jyzb.api.bean.dto.PoliceFingerDto;
import lombok.Data;
import java.util.Date;
import java.util.List;
@Data
public class PoliceDto {
private String id;
private String name;
//组织机构id
private Long orgId;
private String policeCode;
private String doorCode;
private String faceInfo;
private String password;
private String photo;
private String tel;
private String phone;
private String idCard;
//状态
private Integer state;
private Long userId;
/**
* 0警员,1辅警
*/
private Integer identity;
/**
* 海康人脸机
*/
private Integer hkFaceDevice;
private Date updateTime;
private Date createTime;
//指纹信息列表
private List<PoliceFingerDto> fingersList;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import lombok.Data;
import java.util.Date;
@Data
public class SupplierInfoDto {
/**
* 供应商ID
*/
private String id;
/**
* 供应商名称
*/
private String name;
/**
* 供应商短码
*/
private String code;
/**
* 简称
*/
private String shortName;
/**
* 联系人
*/
private String contacts;
/**
* 联系电话
*/
private String phone;
private Date createTime;
private Date updateTime;
/**
* 创建人员
*/
private String createUser;
/**
* 1为启用,0为禁用
*/
private Integer state;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import lombok.Data;
import java.util.Date;
import java.util.List;
@Data
public class TypeDto {
private String id;
private String name;
private String unit;
private String unitType;
private String parentId;
private String parentIds;
private String code;
private Integer state;
private String note;
private String guid;
private Integer type;
private Date createTime;
private Date updateTime;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.util.Date;
@Data
public class UserDto {
private Long userId;
private String realName;
private String nickName;
private String account;
private String password;
private Integer userType;
private Date birthday;
private String sex;
private String email;
private String phone;
private String tel;
private String superAdminFlag;
private Integer statusFlag;
private Date createTime;
private Date updateTime;
private String roleCode;
private String roleName;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import lombok.Data;
import java.util.Date;
@Data
public class WarehouseDevInfoDto {
private String id;
/**
*
*/
private String warehouseId;
/**
* Ip地址
*/
private String devIp;
/**
* 端口
*/
private String devPort;
/**
* 名称
*/
private String devName;
/**
* 设备mac
*/
private String devCode;
/**
* 湿度
*/
private String warehouseSd;
/**
* 温度
*/
private String warehouseWd;
/**
* 设定的开关
*/
private String setState;
/**
* 状态:0关闭1开启
*/
private Integer devState;
/**
* 设定的温度
*/
private Integer setSd;
/**
*
*/
private Date createTime;
/**
*
*/
private Date updateTime;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import lombok.Data;
@Data
public class WarehouseInfoDto {
private String id;
private String name;
private String location;
private String phone;
private Long orgId;
/**
* 是否锁库,0未锁,1已锁定
*/
private Integer isLocked;
private String state;
}
package com.junmp.jyzb.api.bean.dto.FetchingDataDto;
import lombok.Data;
import java.math.BigDecimal;
import java.util.Date;
@Data
public class sizeDto {
/**
* 装备号型ID
*/
private String id;
/**
* 装备类型ID
*/
private String typeId;
/**
* 号型码
*/
private String code;
/**
* 号型名称
*/
private String name;
/**
* 更新时间
*/
private Date updateTime;
private Date createTime;
/**
* 备注
*/
private String note;
/**
* 价格
*/
private BigDecimal price;
/**
* 当前状态:0关闭/1启用
*/
private Integer state;
private Integer epcType;
}
...@@ -4,12 +4,19 @@ package com.junmp.jyzb.api.bean.dto; ...@@ -4,12 +4,19 @@ package com.junmp.jyzb.api.bean.dto;
import lombok.Data; import lombok.Data;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date;
@Data @Data
public class PoliceFingerDto implements Serializable { public class PoliceFingerDto implements Serializable {
private Integer id;
private String policeId;
private String name; private String name;
private String fingerInfo; private String fingerInfo;
private Date createTime;
private Date updateTime;
} }
...@@ -69,4 +69,6 @@ public class TjOrgCountDto implements Serializable { ...@@ -69,4 +69,6 @@ public class TjOrgCountDto implements Serializable {
*/ */
private Integer number; private Integer number;
private String typeParentId;
} }
\ No newline at end of file
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
import java.util.Date;
@Data
public class WarehouseDevDto {
private String id;
/**
* 仓库id
*/
private String warehouseId;
/**
* 组织机构id
*/
private String orgId;
/**
* Ip地址
*/
private String devIp;
/**
* 端口
*/
private String devPort;
/**
* 名称
*/
private String devName;
/**
* 设备mac
*/
private String devCode;
/**
* 湿度
*/
private String warehouseSd;
/**
* 温度
*/
private String warehouseWd;
/**
* 设定的开关
*/
private String setState;
/**
* 状态:0关闭1开启
*/
private Integer devState;
/**
* 设定的温度
*/
private Integer setSd;
private Date createTime;
private Date updateTime;
private String orgName;
private String warehouseName;
}
package com.junmp.jyzb.api.bean.query;
import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data;
import java.util.Date;
@Data
public class QueryDeviceConfigReq extends BaseRequest {
private Long id;
/**
* 设备名称
*/
private String deviceName;
/**
* 设备编号
*/
private String deviceCode;
/**
* 设备状态(0异常1正常)
*/
private Integer state;
/**
* 位置
*/
private String position;
/**
* 仓库id
*/
private String locationId;
/**
* 日常日志信息
*/
private String errorLog;
/**
* 设备配置信息
*/
private String deviceConfig;
/**
* 组织机构id
*/
private Long orgId;
/**
* 创建时间
*/
private Date createTime;
/**
* 更新时间
*/
private Date updateTime;
/**
* 创建人
*/
private String createUser;
/**
* 更新人
*/
private String updateUser;
private Integer deviceType;
}
package com.junmp.jyzb.api.bean.query;
import lombok.Data;
import java.util.Date;
@Data
public class QueryWarehouseDevReq {
private String id;
/**
* 仓库id
*/
private String warehouseId;
/**
* 组织机构id
*/
private String orgId;
/**
* Ip地址
*/
private String devIp;
/**
* 端口
*/
private String devPort;
/**
* 名称
*/
private String devName;
/**
* 设备mac
*/
private String devCode;
/**
* 湿度
*/
private String warehouseSd;
/**
* 温度
*/
private String warehouseWd;
/**
* 设定的开关
*/
private String setState;
/**
* 状态:0关闭1开启
*/
private Integer devState;
/**
* 设定的温度
*/
private Integer setSd;
private Date createTime;
private Date updateTime;
}
...@@ -16,4 +16,6 @@ public class TjOrgCountReq extends BaseRequest { ...@@ -16,4 +16,6 @@ public class TjOrgCountReq extends BaseRequest {
private List<String> sizeNameList; private List<String> sizeNameList;
@NotNull(message = "年份不能为空",groups = detail.class) @NotNull(message = "年份不能为空",groups = detail.class)
private Integer year; private Integer year;
private List<Integer> monthList;
} }
\ No newline at end of file
package com.junmp.jyzb.api.bean.req;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class UpdateDeivceConfigReq implements Serializable {
private Long id;
/**
* 设备名称
*/
private String deviceName;
/**
* 设备编号
*/
private String deviceCode;
/**
* 设备状态(0异常1正常)
*/
private Integer state;
/**
* 位置
*/
private String position;
/**
* 仓库id
*/
private String locationId;
/**
* 日常日志信息
*/
private String errorLog;
/**
* 设备配置信息
*/
private String deviceConfig;
/**
* 组织机构id
*/
private Long orgId;
/**
* 创建时间
*/
private Date createTime;
/**
* 更新时间
*/
private Date updateTime;
/**
* 创建人
*/
private String createUser;
/**
* 更新人
*/
private String updateUser;
private Integer deviceType;
}
package com.junmp.jyzb.api.bean.req;
import com.junmp.v2.common.bean.request.ValidationApi;
import lombok.Data;
import javax.validation.constraints.NotNull;
import java.util.Date;
@Data
public class UpdateWarehouseDevReq {
private String id;
/**
* 仓库id
*/
private String warehouseId;
/**
* 组织机构id
*/
@NotNull(message = "组织机构id不能为空",groups = {ValidationApi.list.class})
private String orgId;
/**
* Ip地址
*/
private String devIp;
/**
* 端口
*/
private String devPort;
/**
* 名称
*/
private String devName;
/**
* 设备mac
*/
private String devCode;
/**
* 湿度
*/
private String warehouseSd;
/**
* 温度
*/
private String warehouseWd;
/**
* 设定的开关
*/
private String setState;
/**
* 状态:0关闭1开启
*/
private Integer devState;
/**
* 设定的温度
*/
private Integer setSd;
private Date createTime;
private Date updateTime;
}
package com.junmp.jyzb.controller;
import com.junmp.jyzb.api.bean.query.QueryDeviceConfigReq;
import com.junmp.jyzb.api.bean.req.UpdateDeivceConfigReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseDevReq;
import com.junmp.jyzb.entity.DeviceConfig;
import com.junmp.jyzb.entity.WarehouseDev;
import com.junmp.jyzb.service.DeviceConfigService;
import com.junmp.jyzb.service.WarehouseDevService;
import com.junmp.v2.common.bean.request.ValidationApi;
import com.junmp.v2.common.bean.response.ApiRes;
import com.junmp.v2.db.api.page.PageResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
@RestController
@Slf4j
@RequestMapping("/DeviceConfig")
@Api(tags = "[配置]配置信息模块")
public class DeviceConfigController {
@Resource
private DeviceConfigService deviceConfigService;
@Resource
private WarehouseDevService warehouseDevService;
//新增配置
@PostMapping("/addDeviceConfig")
@ApiOperation("新增配置")
public ApiRes<Long> addDeviceConfig(@RequestBody UpdateDeivceConfigReq req){
return ApiRes.success(deviceConfigService.addDeviceConfig(req));
}
//修改配置
@PostMapping("/updateDeviceConfig")
@ApiOperation("修改配置")
public ApiRes<Boolean> updateDeviceConfig(@RequestBody UpdateDeivceConfigReq req){
return ApiRes.success(deviceConfigService.updateDeviceConfig(req));
}
//查询配置Page
@PostMapping("/showDeviceConfigPage")
@ApiOperation("查询配置Page")
public ApiRes<PageResult<DeviceConfig>> showDeviceConfigPage(@RequestBody QueryDeviceConfigReq req){
return ApiRes.success(deviceConfigService.showDeviceConfigPage(req));
}
//查询配置List
@PostMapping("/showDeviceConfigList")
@ApiOperation("查询配置List")
public ApiRes<List<DeviceConfig>> showDeviceConfigList(@RequestBody QueryDeviceConfigReq req){
return ApiRes.success(deviceConfigService.showDeviceConfigList(req));
}
//新增除湿机配置
@PostMapping("/addWarehouseDev")
@ApiOperation("新增除湿机配置")
public ApiRes<String> addWarehouseDev(@RequestBody UpdateWarehouseDevReq req){
return ApiRes.success(warehouseDevService.addWarehouseDev(req));
}
//修改除湿机配置
@PostMapping("/updateWarehouseDev")
@ApiOperation("修改除湿机配置")
public ApiRes<Boolean> updateWarehouseDev(@RequestBody UpdateWarehouseDevReq req){
return ApiRes.success(warehouseDevService.updateWarehouseDev(req));
}
//查看除湿机配置
@PostMapping("/showWarehouseDevList")
@ApiOperation("查看除湿机配置")
public ApiRes<List<WarehouseDev>> showWarehouseDevList(@RequestBody @Validated(ValidationApi.list.class) UpdateWarehouseDevReq req){
return ApiRes.success(warehouseDevService.showWarehouseDevList(req));
}
}
package com.junmp.jyzb.controller; package com.junmp.jyzb.controller;
import com.junmp.jyzb.api.bean.dto.*; import com.junmp.jyzb.api.bean.dto.*;
import com.junmp.jyzb.api.bean.dto.FetchingDataDto.EquipmentDto;
import com.junmp.jyzb.api.bean.query.*; import com.junmp.jyzb.api.bean.query.*;
import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq; import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq;
import com.junmp.jyzb.api.bean.req.EquipmentBindReq; import com.junmp.jyzb.api.bean.req.EquipmentBindReq;
...@@ -264,8 +265,15 @@ public class InventoryController { ...@@ -264,8 +265,15 @@ public class InventoryController {
} }
@PostMapping("/selectSumByItems") @PostMapping("/selectSumByItems")
@ApiOperation("通过条件查询库存汇总")
public ApiRes<List<InventorySummary>> selectSumByItems(@RequestBody SelectTotalNumReq req){ public ApiRes<List<InventorySummary>> selectSumByItems(@RequestBody SelectTotalNumReq req){
return ApiRes.success(inventorySummaryService.selectSumByItems(req)); return ApiRes.success(inventorySummaryService.selectSumByItems(req));
} }
@PostMapping("/alignInventoryInfo")
@ApiOperation("同步更新装备信息")
public ApiRes<List<EquipmentDto>> alignInventoryInfo(@RequestBody InventoryReq req){
return ApiRes.success(inventoryService.alignInventoryInfo(req));
}
} }
package com.junmp.jyzb.controller; package com.junmp.jyzb.controller;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.junmp.jyzb.api.bean.dto.FetchingDataDto.PoliceDto;
import com.junmp.jyzb.api.bean.dto.PolicemanDto; import com.junmp.jyzb.api.bean.dto.PolicemanDto;
import com.junmp.jyzb.api.bean.dto.ReassignmentDto; import com.junmp.jyzb.api.bean.dto.ReassignmentDto;
import com.junmp.jyzb.api.bean.query.CabinetReq; import com.junmp.jyzb.api.bean.query.CabinetReq;
...@@ -252,4 +253,10 @@ public class PoliceController { ...@@ -252,4 +253,10 @@ public class PoliceController {
return ApiRes.success(policemanService.getPoliceWithoutOrg()); return ApiRes.success(policemanService.getPoliceWithoutOrg());
} }
@PostMapping("/alignPoliceInfo")
@ApiOperation("同步更新警员信息")
public ApiRes<List<PoliceDto>> alignPoliceInfo(@RequestBody PolicemanReq req){
return ApiRes.success(policemanService.alignPoliceInfo(req));
}
} }
...@@ -123,6 +123,13 @@ public class TjController { ...@@ -123,6 +123,13 @@ public class TjController {
return ApiRes.success(tjService.updateTjOrgCount(req)); return ApiRes.success(tjService.updateTjOrgCount(req));
} }
//首页使用柱状图
@PostMapping("/TjOrgCountByType")
@ApiOperation("九大类使用统计柱状图")
public ApiRes<List<TjOrgCountDto>> TjOrgCountByType(@RequestBody TjOrgCountReq req){
return ApiRes.success(tjService.TjOrgCountByType(req));
}
/** /**
* --------------------------------------人员统计报表------------------------------------------- * --------------------------------------人员统计报表-------------------------------------------
*/ */
......
package com.junmp.jyzb.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
*
* @TableName base_device_config
*/
@TableName(value ="base_device_config")
@Data
public class DeviceConfig implements Serializable {
/**
* id
*/
@TableId(type = IdType.AUTO)
private Long id;
/**
* 设备名称
*/
@TableField(value = "device_name")
private String deviceName;
/**
* 设备编号
*/
@TableField(value = "device_code")
private String deviceCode;
/**
* 设备状态(0异常1正常)
*/
@TableField(value = "state")
private Integer state;
/**
* 位置
*/
@TableField(value = "position")
private String position;
/**
* 仓库id
*/
@TableField(value = "location_id")
private String locationId;
/**
* 日常日志信息
*/
@TableField(value = "error_log")
private String errorLog;
/**
* 设备配置信息
*/
@TableField(value = "device_config")
private String deviceConfig;
/**
* 组织机构id
*/
@TableField(value = "org_id")
private Long orgId;
/**
* 类型:0通道1仓库主机
*/
@TableField(value = "device_type")
private Integer deviceType;
/**
* 创建时间
*/
@TableField(value = "create_time")
private Date createTime;
/**
* 更新时间
*/
@TableField(value = "update_time")
private Date updateTime;
/**
* 创建人
*/
@TableField(value = "create_user")
private String createUser;
/**
* 更新人
*/
@TableField(value = "update_user")
private String updateUser;
@TableField(exist = false)
private String locationName;
@TableField(exist = false)
private String orgName;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}
\ No newline at end of file
...@@ -30,6 +30,9 @@ public class PoliceFinger implements Serializable { ...@@ -30,6 +30,9 @@ public class PoliceFinger implements Serializable {
@TableField(value = "finger_info") @TableField(value = "finger_info")
private String fingerInfo; private String fingerInfo;
@TableField(value = "finger_num")
private String fingerNum;
@TableField(fill = FieldFill.INSERT, value = "create_time") @TableField(fill = FieldFill.INSERT, value = "create_time")
private Date createTime; private Date createTime;
......
package com.junmp.jyzb.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 温湿度
* @TableName sys_temp_humidity
*/
@TableName(value ="base_warehouse_dev")
@Data
public class WarehouseDev implements Serializable {
/**
*
*/
@TableId(value = "id",type = IdType.ASSIGN_UUID)
private String id;
/**
* 仓库id
*/
@TableField(value = "warehouse_id")
private String warehouseId;
/**
* 组织机构id
*/
@TableField(value = "org_id")
private String orgId;
/**
* Ip地址
*/
@TableField(value = "dev_ip")
private String devIp;
/**
* 端口
*/
@TableField(value = "dev_port")
private String devPort;
/**
* 名称
*/
@TableField(value = "dev_name")
private String devName;
/**
* 设备mac
*/
@TableField(value = "dev_code")
private String devCode;
/**
* 湿度
*/
@TableField(value = "warehouse_sd")
private String warehouseSd;
/**
* 温度
*/
@TableField(value = "warehouse_wd")
private String warehouseWd;
/**
* 设定的开关
*/
@TableField(value = "set_state")
private String setState;
/**
* 状态:0关闭1开启
*/
@TableField(value = "dev_state")
private Integer devState;
/**
* 设定的温度
*/
@TableField(value = "set_sd")
private Integer setSd;
/**
*
*/
@TableField(value = "create_time")
private Date createTime;
/**
*
*/
@TableField(value = "update_time")
private Date updateTime;
@TableField(exist = false)
private String orgName;
@TableField(exist = false)
private String warehouseName;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}
\ No newline at end of file
package com.junmp.jyzb.mapper;
import com.junmp.jyzb.api.bean.query.QueryDeviceConfigReq;
import com.junmp.jyzb.entity.DeviceConfig;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* @author lxh专属坐骑
* @description 针对表【base_device_config】的数据库操作Mapper
* @createDate 2023-12-19 07:18:22
* @Entity com.junmp.jyzb.entity.DeviceConfig
*/
public interface DeviceConfigMapper extends BaseMapper<DeviceConfig> {
int showDeviceConfigCount(@Param("req") QueryDeviceConfigReq req);
List<DeviceConfig> showDeviceConfig(@Param("orgId") Long orgId,
@Param("deviceType") Integer deviceType,
@Param("deviceName") String deviceName,
@Param("deviceCode") String deviceCode,
@Param("pageNo") Long pageNo,
@Param("pageSize") Long pageSize);
}
...@@ -2,6 +2,7 @@ package com.junmp.jyzb.mapper; ...@@ -2,6 +2,7 @@ package com.junmp.jyzb.mapper;
import com.junmp.jyzb.api.bean.dto.TjDto.FinalTjOrgCountDto; import com.junmp.jyzb.api.bean.dto.TjDto.FinalTjOrgCountDto;
import com.junmp.jyzb.api.bean.dto.TjDto.TjOrgCountDto; import com.junmp.jyzb.api.bean.dto.TjDto.TjOrgCountDto;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgCountReq;
import com.junmp.jyzb.entity.EquipmentCountSummary; import com.junmp.jyzb.entity.EquipmentCountSummary;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
...@@ -40,6 +41,8 @@ public interface EquipmentCountSummaryMapper extends BaseMapper<EquipmentCountSu ...@@ -40,6 +41,8 @@ public interface EquipmentCountSummaryMapper extends BaseMapper<EquipmentCountSu
@Param("pageNo")Long pageNo, @Param("pageSize") Long pageSize); @Param("pageNo")Long pageNo, @Param("pageSize") Long pageSize);
void deleteAll(@Param("orgId") Long orgId); void deleteAll(@Param("orgId") Long orgId);
List<TjOrgCountDto> TjOrgCountByType(@Param("req") TjOrgCountReq req);
} }
......
...@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage; ...@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.junmp.jyzb.api.bean.dto.EqsBriefDto; import com.junmp.jyzb.api.bean.dto.EqsBriefDto;
import com.junmp.jyzb.api.bean.dto.EqsSumDto; import com.junmp.jyzb.api.bean.dto.EqsSumDto;
import com.junmp.jyzb.api.bean.dto.FetchingDataDto.EquipmentDto;
import com.junmp.jyzb.api.bean.dto.InventoryDto; import com.junmp.jyzb.api.bean.dto.InventoryDto;
import com.junmp.jyzb.api.bean.query.InventoryReq; import com.junmp.jyzb.api.bean.query.InventoryReq;
import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq; import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq;
...@@ -32,32 +33,36 @@ public interface InventoryMapper extends BaseMapper<Inventory> { ...@@ -32,32 +33,36 @@ public interface InventoryMapper extends BaseMapper<Inventory> {
//根据货架id查询汇总信息(list) //根据货架id查询汇总信息(list)
List<InventorySummary> getSumByShelf(String shelfId); List<InventorySummary> getSumByShelf(@Param("shelfId") String shelfId);
//根据货架id查询汇总信息(page) //根据货架id查询汇总信息(page)
IPage<InventorySummary> ShelfInventoryPage(Page<InventorySummary> page, String shelfId); IPage<InventorySummary> ShelfInventoryPage(@Param("page") Page<InventorySummary> page,
@Param("shelfId") String shelfId);
//根据区域id查询汇总信息(list) //根据区域id查询汇总信息(list)
List<InventorySummary> getSumByArea(String id); List<InventorySummary> getSumByArea(@Param("id") String id);
//根据区域id查询汇总信息(page) //根据区域id查询汇总信息(page)
IPage<InventorySummary> AreaInventoryPage(Page<InventorySummary> page, String id); IPage<InventorySummary> AreaInventoryPage(@Param("page") Page<InventorySummary> page,
@Param("id") String id);
//通过单警柜箱门id获取箱门下的装备汇总信息(list) //通过单警柜箱门id获取箱门下的装备汇总信息(list)
List<InventorySummary> getSumByCabinetBox(String id); List<InventorySummary> getSumByCabinetBox(@Param("id") String id);
//通过查询条件查询出装备数量报表 //通过查询条件查询出装备数量报表
List<EqsSumDto> GetListEquipment(InventoryReq req); List<EqsSumDto> GetListEquipment(@Param("req") InventoryReq req);
//查询组织机构下面的装备信息 //查询组织机构下面的装备信息
List<InventoryVo> selectListByOrg(Long orgId); List<InventoryVo> selectListByOrg(@Param("orgId") Long orgId);
//通过单警柜箱门id获取箱门下的装备汇总信息(page) //通过单警柜箱门id获取箱门下的装备汇总信息(page)
IPage<InventorySummary> EqsByCabinetBoxIdPage(Page<InventorySummary> page,@Param("id") String id); IPage<InventorySummary> EqsByCabinetBoxIdPage(@Param("page") Page<InventorySummary> page,
@Param("id") String id);
boolean insertInventorySummary(@Param("req") BatchEditingInvsReq req,@Param("brokenNumberDays")Integer brokenNumberDays); boolean insertInventorySummary(@Param("req") BatchEditingInvsReq req,
@Param("brokenNumberDays")Integer brokenNumberDays);
//判断epc是否存在 //判断epc是否存在
List<String> checkEPCList(@Param("list") List<String> epcList); List<String> checkEPCList(@Param("list") List<String> epcList);
...@@ -74,5 +79,7 @@ public interface InventoryMapper extends BaseMapper<Inventory> { ...@@ -74,5 +79,7 @@ public interface InventoryMapper extends BaseMapper<Inventory> {
List<Inventory> searchExpireEqs(@Param("list") List<Object[]> searchItem); List<Inventory> searchExpireEqs(@Param("list") List<Object[]> searchItem);
IPage<InventoryDto> GetDetailByTerms(Page<Object> defaultPage, @Param("req") InventoryReq req); IPage<InventoryDto> GetDetailByTerms(@Param("page") Page<Object> defaultPage, @Param("req") InventoryReq req);
List<EquipmentDto> alignInventoryInfo(@Param("req") InventoryReq req);
} }
\ No newline at end of file
package com.junmp.jyzb.mapper;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseDevReq;
import com.junmp.jyzb.entity.WarehouseDev;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* @author lxh专属坐骑
* @description 针对表【sys_temp_humidity(温湿度)】的数据库操作Mapper
* @createDate 2023-12-19 08:33:43
* @Entity com.junmp.jyzb.entity.WarehouseDev
*/
public interface WarehouseDevMapper extends BaseMapper<WarehouseDev> {
List<WarehouseDev> showWarehouseDevList(@Param("req") UpdateWarehouseDevReq req);
}
package com.junmp.jyzb.service;
import com.junmp.jyzb.api.bean.query.QueryDeviceConfigReq;
import com.junmp.jyzb.api.bean.req.UpdateDeivceConfigReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseDevReq;
import com.junmp.jyzb.entity.DeviceConfig;
import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.entity.WarehouseDev;
import com.junmp.v2.db.api.page.PageResult;
import java.util.List;
/**
* @author lxh专属坐骑
* @description 针对表【base_device_config】的数据库操作Service
* @createDate 2023-12-19 07:18:22
*/
public interface DeviceConfigService extends IService<DeviceConfig> {
Long addDeviceConfig(UpdateDeivceConfigReq req);
boolean updateDeviceConfig(UpdateDeivceConfigReq req);
PageResult<DeviceConfig> showDeviceConfigPage(QueryDeviceConfigReq req);
List<DeviceConfig> showDeviceConfigList(QueryDeviceConfigReq req);
}
...@@ -2,6 +2,7 @@ package com.junmp.jyzb.service; ...@@ -2,6 +2,7 @@ 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.*; import com.junmp.jyzb.api.bean.dto.*;
import com.junmp.jyzb.api.bean.dto.FetchingDataDto.EquipmentDto;
import com.junmp.jyzb.api.bean.query.*; import com.junmp.jyzb.api.bean.query.*;
import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq; import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq;
...@@ -84,4 +85,6 @@ public interface InventoryService extends IService<Inventory> { ...@@ -84,4 +85,6 @@ public interface InventoryService extends IService<Inventory> {
//根据条件查询满足条件的数据(用于快速移库修改装备仓库id) //根据条件查询满足条件的数据(用于快速移库修改装备仓库id)
List<Inventory> selectEqsByItem(List<Object[]> searchCriteria); List<Inventory> selectEqsByItem(List<Object[]> searchCriteria);
List<EquipmentDto> alignInventoryInfo(InventoryReq 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.FetchingDataDto.EquipmentDto;
import com.junmp.jyzb.api.bean.dto.InventorySumDto; import com.junmp.jyzb.api.bean.dto.InventorySumDto;
import com.junmp.jyzb.api.bean.dto.NormalInOutDto; import com.junmp.jyzb.api.bean.dto.NormalInOutDto;
import com.junmp.jyzb.api.bean.query.InventoryReq;
import com.junmp.jyzb.api.bean.query.InventorySumReq; import com.junmp.jyzb.api.bean.query.InventorySumReq;
import com.junmp.jyzb.api.bean.query.SelectTotalNumReq; import com.junmp.jyzb.api.bean.query.SelectTotalNumReq;
import com.junmp.jyzb.api.bean.req.CabinetInOutRecordsReq; import com.junmp.jyzb.api.bean.req.CabinetInOutRecordsReq;
...@@ -41,7 +43,7 @@ public interface InventorySummaryService extends IService<InventorySummary> { ...@@ -41,7 +43,7 @@ public interface InventorySummaryService extends IService<InventorySummary> {
//计算装备总数(装备数量数据统计) //计算装备总数(装备数量数据统计)
List<InventorySummary> EquipmentStatistics(InventorySumReq req); List<InventorySummary> EquipmentStatistics(InventorySumReq req);
//出入库时无单据查询库存汇总并统计更新或者记账时根据单据查询库存汇总并统计更新 //通过条件查询库存汇总
List<InventorySummary> selectSumByItems(SelectTotalNumReq req); List<InventorySummary> selectSumByItems(SelectTotalNumReq req);
...@@ -53,4 +55,6 @@ public interface InventorySummaryService extends IService<InventorySummary> { ...@@ -53,4 +55,6 @@ public interface InventorySummaryService extends IService<InventorySummary> {
* 更新使用次数和维修次数 * 更新使用次数和维修次数
*/ */
void updateCount(); void updateCount();
} }
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.FetchingDataDto.PoliceDto;
import com.junmp.jyzb.api.bean.dto.PolicemanDto; import com.junmp.jyzb.api.bean.dto.PolicemanDto;
import com.junmp.jyzb.api.bean.dto.ReassignmentDto; import com.junmp.jyzb.api.bean.dto.ReassignmentDto;
import com.junmp.jyzb.api.bean.dto.UploadPolicePhotoDto; import com.junmp.jyzb.api.bean.dto.UploadPolicePhotoDto;
...@@ -109,4 +110,6 @@ public interface PolicemanService extends IService<Policeman> { ...@@ -109,4 +110,6 @@ public interface PolicemanService extends IService<Policeman> {
boolean reSetPassword(SysUserReq req); boolean reSetPassword(SysUserReq req);
boolean updatePassword(SysUserReq req); boolean updatePassword(SysUserReq req);
List<PoliceDto> alignPoliceInfo(PolicemanReq req);
} }
...@@ -42,4 +42,6 @@ public interface TjService { ...@@ -42,4 +42,6 @@ public interface TjService {
List<TjOrgCountDto> TjOrgCountDetailList(TjOrgCountReq req); List<TjOrgCountDto> TjOrgCountDetailList(TjOrgCountReq req);
boolean updateTjOrgCount(TjOrgCountReq req); boolean updateTjOrgCount(TjOrgCountReq req);
List<TjOrgCountDto> TjOrgCountByType(TjOrgCountReq req);
} }
package com.junmp.jyzb.service;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseDevReq;
import com.junmp.jyzb.entity.WarehouseDev;
import com.baomidou.mybatisplus.extension.service.IService;
import java.util.List;
/**
* @author lxh专属坐骑
* @description 针对表【sys_temp_humidity(温湿度)】的数据库操作Service
* @createDate 2023-12-19 08:33:43
*/
public interface WarehouseDevService extends IService<WarehouseDev> {
String addWarehouseDev(UpdateWarehouseDevReq req);
boolean updateWarehouseDev(UpdateWarehouseDevReq req);
List<WarehouseDev> showWarehouseDevList(UpdateWarehouseDevReq req);
}
package com.junmp.jyzb.service.impl;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.query.QueryDeviceConfigReq;
import com.junmp.jyzb.api.bean.req.UpdateDeivceConfigReq;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseDevReq;
import com.junmp.jyzb.entity.DeviceConfig;
import com.junmp.jyzb.entity.WarehouseDev;
import com.junmp.jyzb.mapper.WarehouseDevMapper;
import com.junmp.jyzb.service.DeviceConfigService;
import com.junmp.jyzb.mapper.DeviceConfigMapper;
import com.junmp.jyzb.service.WarehouseDevService;
import com.junmp.jyzb.utils.DateTimeUtil;
import com.junmp.v2.common.util.BeanPlusUtil;
import com.junmp.v2.db.api.factory.PageFactory;
import com.junmp.v2.db.api.factory.PageResultFactory;
import com.junmp.v2.db.api.page.PageResult;
import net.minidev.json.writer.BeansMapper;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
/**
* @author lxh专属坐骑
* @description 针对表【base_device_config】的数据库操作Service实现
* @createDate 2023-12-19 07:18:22
*/
@Service
public class DeviceConfigServiceImpl extends ServiceImpl<DeviceConfigMapper, DeviceConfig>
implements DeviceConfigService{
@Resource
private DeviceConfigMapper deviceConfigMapper;
@Override
public Long addDeviceConfig(UpdateDeivceConfigReq req) {
DeviceConfig deviceConfig = new DeviceConfig();
BeanPlusUtil.copyProperties(req,deviceConfig);
deviceConfig.setCreateTime(DateTimeUtil.getCurrentDateTime());
save(deviceConfig);
return deviceConfig.getId() ;
}
@Override
public boolean updateDeviceConfig(UpdateDeivceConfigReq req) {
DeviceConfig deviceConfig = new DeviceConfig();
BeanPlusUtil.copyProperties(req,deviceConfig);
deviceConfig.setUpdateTime(DateTimeUtil.getCurrentDateTime());
return updateById(deviceConfig);
}
@Override
public PageResult<DeviceConfig> showDeviceConfigPage(QueryDeviceConfigReq req) {
int size=deviceConfigMapper.showDeviceConfigCount(req);
if (ObjectUtil.isNull(req.getPageNo()) && ObjectUtil.isNull(req.getPageSize())) {
req.setPageNo(1L);
req.setPageSize(10L);
}
List<DeviceConfig> list=deviceConfigMapper.showDeviceConfig(req.getOrgId(),req.getDeviceType(),req.getDeviceName(),
req.getDeviceCode(),(req.getPageNo()-1)*req.getPageSize(),req.getPageSize());
Page<DeviceConfig> page = PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize());
page.setTotal(size);
page.setRecords(list);
return PageResultFactory.createPageResult(page);
}
@Override
public List<DeviceConfig> showDeviceConfigList(QueryDeviceConfigReq req) {
List<DeviceConfig> list=deviceConfigMapper.showDeviceConfig(req.getOrgId(),req.getDeviceType(),req.getDeviceName(),
req.getDeviceCode(),null,null);
return list;
}
}
...@@ -8,6 +8,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -8,6 +8,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.dto.*; import com.junmp.jyzb.api.bean.dto.*;
import com.junmp.jyzb.api.bean.dto.FetchingDataDto.EquipmentDto;
import com.junmp.jyzb.api.bean.query.*; import com.junmp.jyzb.api.bean.query.*;
import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq; import com.junmp.jyzb.api.bean.req.BatchEditingInvsReq;
import com.junmp.jyzb.api.bean.req.EquipmentBindReq; import com.junmp.jyzb.api.bean.req.EquipmentBindReq;
...@@ -596,5 +597,11 @@ public class InventoryServiceImpl extends ServiceImpl<InventoryMapper, Inventory ...@@ -596,5 +597,11 @@ public class InventoryServiceImpl extends ServiceImpl<InventoryMapper, Inventory
return inventoryMapper.selectEqsByItem(searchCriteria); return inventoryMapper.selectEqsByItem(searchCriteria);
} }
@Override
public List<EquipmentDto> alignInventoryInfo(InventoryReq req) {
return inventoryMapper.alignInventoryInfo(req);
}
} }
\ No newline at end of file
...@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; ...@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; 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.dto.FetchingDataDto.EquipmentDto;
import com.junmp.jyzb.api.bean.dto.InventorySumDto; import com.junmp.jyzb.api.bean.dto.InventorySumDto;
import com.junmp.jyzb.api.bean.dto.NormalInOutDto; import com.junmp.jyzb.api.bean.dto.NormalInOutDto;
import com.junmp.jyzb.api.bean.dto.WarehouseDto; import com.junmp.jyzb.api.bean.dto.WarehouseDto;
...@@ -77,6 +78,8 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa ...@@ -77,6 +78,8 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa
@Resource @Resource
private EquipmentCountSummaryMapper equipmentCountSummaryMapper; private EquipmentCountSummaryMapper equipmentCountSummaryMapper;
@Override @Override
public void MonthStartSum() { public void MonthStartSum() {
PriceSumSummaryMapper.MonthStart(); PriceSumSummaryMapper.MonthStart();
...@@ -272,7 +275,7 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa ...@@ -272,7 +275,7 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa
} }
//出入库时无单据查询库存汇总并统计更新或者记账时根据单据查询库存汇总并统计更新 //根据条件查询库存汇总
@Override @Override
public List<InventorySummary> selectSumByItems(SelectTotalNumReq req) { public List<InventorySummary> selectSumByItems(SelectTotalNumReq req) {
List<InventorySumReq> list = req.getList(); List<InventorySumReq> list = req.getList();
...@@ -355,6 +358,7 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa ...@@ -355,6 +358,7 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa
} }
private LambdaQueryWrapper<InventorySummary> createWrapper(InventorySumReq req) { private LambdaQueryWrapper<InventorySummary> createWrapper(InventorySumReq req) {
LambdaQueryWrapper<InventorySummary> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<InventorySummary> wrapper = new LambdaQueryWrapper<>();
if (ObjectUtil.isEmpty(req)) { if (ObjectUtil.isEmpty(req)) {
......
...@@ -12,6 +12,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; ...@@ -12,6 +12,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.junmpProcess.dto.StartProcessInstanceDTO; import com.junmp.junmpProcess.dto.StartProcessInstanceDTO;
import com.junmp.junmpProcess.service.IFlowInstanceService; import com.junmp.junmpProcess.service.IFlowInstanceService;
import com.junmp.jyzb.api.bean.dto.*; import com.junmp.jyzb.api.bean.dto.*;
import com.junmp.jyzb.api.bean.dto.FetchingDataDto.PoliceDto;
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.query.PolicemanReq; import com.junmp.jyzb.api.bean.query.PolicemanReq;
...@@ -113,9 +114,6 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -113,9 +114,6 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
private CabinetBoxPoliceService cabinetBoxPoliceService; private CabinetBoxPoliceService cabinetBoxPoliceService;
@Resource @Resource
private PolicemanService policemanService;
@Resource
private SysDictService sysDictService; private SysDictService sysDictService;
@Resource @Resource
...@@ -961,7 +959,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -961,7 +959,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
LambdaQueryWrapper<PoliceEquipment> eq = new LambdaQueryWrapper<PoliceEquipment>(); LambdaQueryWrapper<PoliceEquipment> eq = new LambdaQueryWrapper<PoliceEquipment>();
if (ObjectUtil.isNotNull(req.getPoliceId() )&& ! req.getPoliceId().trim().isEmpty()){ if (ObjectUtil.isNotNull(req.getPoliceId() )&& ! req.getPoliceId().trim().isEmpty()){
Policeman policeman = policemanService.PoliceExist(req.getPoliceId()); Policeman policeman = PoliceExist(req.getPoliceId());
eq.eq(PoliceEquipment::getPoliceId, policeman.getId()); eq.eq(PoliceEquipment::getPoliceId, policeman.getId());
return policeEquipmentService.list(eq); return policeEquipmentService.list(eq);
}else { }else {
...@@ -973,7 +971,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -973,7 +971,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
req.setColumn(req.getColumn().replaceAll("[A-Z]","_$0").toLowerCase()); req.setColumn(req.getColumn().replaceAll("[A-Z]","_$0").toLowerCase());
req.setOrder(req.getOrder().toLowerCase()); req.setOrder(req.getOrder().toLowerCase());
} }
Policeman one = policemanService.getOne(new LambdaQueryWrapper<Policeman>().eq(Policeman::getUserId, req.getUserId())); Policeman one = getOne(new LambdaQueryWrapper<Policeman>().eq(Policeman::getUserId, req.getUserId()));
if (ObjectUtil.isNotNull(one)){ if (ObjectUtil.isNotNull(one)){
eq.eq(PoliceEquipment::getPoliceId, one.getId()) eq.eq(PoliceEquipment::getPoliceId, one.getId())
.like(ObjectUtil.isNotNull(req.getTypeName()),PoliceEquipment::getTypeName,req.getTypeName()) .like(ObjectUtil.isNotNull(req.getTypeName()),PoliceEquipment::getTypeName,req.getTypeName())
...@@ -1281,7 +1279,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -1281,7 +1279,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
// 如果存在,则查询file表将该数据进行删除,再调用上传文件接口,将返回的文件信息以及地址更新存储到警员表最终返回警员id和照片地址 // 如果存在,则查询file表将该数据进行删除,再调用上传文件接口,将返回的文件信息以及地址更新存储到警员表最终返回警员id和照片地址
// 如果不存在照片,那么直接调用上传文件接口,将照片存储到警员表并且返回警员id和照片地址 // 如果不存在照片,那么直接调用上传文件接口,将照片存储到警员表并且返回警员id和照片地址
SysFileInfoReq sysFileInfoReq = new SysFileInfoReq(); SysFileInfoReq sysFileInfoReq = new SysFileInfoReq();
Policeman policeman = policemanService.getById(req.getPoliceId()); Policeman policeman = getById(req.getPoliceId());
PubOrg pubOrg = pubOrgService.PubOrgExist(policeman.getOrgId()); PubOrg pubOrg = pubOrgService.PubOrgExist(policeman.getOrgId());
if (ObjectUtil.isNotNull(policeman.getFileId())){ if (ObjectUtil.isNotNull(policeman.getFileId())){
//删除照片 //删除照片
...@@ -1316,11 +1314,11 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -1316,11 +1314,11 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
String password = iStoredEncryptApi.encrypt(defaultPassword); String password = iStoredEncryptApi.encrypt(defaultPassword);
sysUserService.update(new LambdaUpdateWrapper<SysUser>().eq(SysUser::getUserId,req.getUserId()) sysUserService.update(new LambdaUpdateWrapper<SysUser>().eq(SysUser::getUserId,req.getUserId())
.set(SysUser::getPassword,password)); .set(SysUser::getPassword,password));
Policeman one = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman one = getOne(new LambdaQueryWrapper<Policeman>()
.eq(Policeman::getUserId, req.getUserId())); .eq(Policeman::getUserId, req.getUserId()));
if (ObjectUtil.isNotNull(one)){ if (ObjectUtil.isNotNull(one)){
one.setPassword(password); one.setPassword(password);
policemanService.updateById(one); updateById(one);
} }
return true; return true;
} }
...@@ -1329,7 +1327,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -1329,7 +1327,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean updatePassword(SysUserReq req) { public boolean updatePassword(SysUserReq req) {
Policeman one = policemanService.getOne(new LambdaQueryWrapper<Policeman>() Policeman one = getOne(new LambdaQueryWrapper<Policeman>()
.eq(Policeman::getUserId, req.getUserId())); .eq(Policeman::getUserId, req.getUserId()));
if (ObjectUtil.isNotNull(one)){ if (ObjectUtil.isNotNull(one)){
IStoredEncryptApi storedEncryptApi = (IStoredEncryptApi)SpringUtil.getBean(IStoredEncryptApi.class); IStoredEncryptApi storedEncryptApi = (IStoredEncryptApi)SpringUtil.getBean(IStoredEncryptApi.class);
...@@ -1337,10 +1335,34 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -1337,10 +1335,34 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
String newPassword = storedEncryptApi.encrypt(req.getPassword()); String newPassword = storedEncryptApi.encrypt(req.getPassword());
//同时修改警员密码 //同时修改警员密码
one.setPassword(newPassword); one.setPassword(newPassword);
policemanService.updateById(one); updateById(one);
} }
sysUserService.editPassword(req); sysUserService.editPassword(req);
return true; return true;
} }
//同步警员信息
@Override
public List<PoliceDto> alignPoliceInfo(PolicemanReq req) {
LambdaQueryWrapper<Policeman> eq = new LambdaQueryWrapper<Policeman>()
.eq(Policeman::getOrgId, req.getOrgId())
.ge(Policeman::getUpdateTime, req.getUpdateTime());
List<Policeman> list = list(eq);
List<PoliceDto> returnList = list.stream().map(policeman -> {
PoliceDto policeDto = new PoliceDto();
BeanPlusUtil.copyProperties(policeman, policeDto);
LambdaQueryWrapper<PoliceFinger> wq = new LambdaQueryWrapper<PoliceFinger>()
.eq(PoliceFinger::getPoliceId, policeman.getId());
List<PoliceFinger> list1 = policeFingerService.list(wq);
List<PoliceFingerDto> collect = list1.stream().map(policeFinger -> {
PoliceFingerDto policeFingerDto = new PoliceFingerDto();
BeanPlusUtil.copyProperties(policeFinger, policeFingerDto);
return policeFingerDto;
}).collect(Collectors.toList());
policeDto.setFingersList(collect);
return policeDto;
}).collect(Collectors.toList());
return returnList;
}
} }
...@@ -400,10 +400,16 @@ public class TjServiceImpl implements TjService { ...@@ -400,10 +400,16 @@ public class TjServiceImpl implements TjService {
} }
@Override @Override
@Transactional(rollbackFor = Exception.class)
public boolean updateTjOrgCount(TjOrgCountReq req) { public boolean updateTjOrgCount(TjOrgCountReq req) {
String sql=" org_id_int = "+"'"+req.getOrgId()+"'"; String sql=" org_id_int = "+"'"+req.getOrgId()+"'";
equipmentCountSummaryMapper.deleteAll(req.getOrgId()); equipmentCountSummaryMapper.deleteAll(req.getOrgId());
equipmentCountSummaryMapper.addInfo(sql); equipmentCountSummaryMapper.addInfo(sql);
return true; return true;
} }
@Override
public List<TjOrgCountDto> TjOrgCountByType(TjOrgCountReq req) {
return equipmentCountSummaryMapper.TjOrgCountByType(req);
}
} }
package com.junmp.jyzb.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.api.bean.req.UpdateWarehouseDevReq;
import com.junmp.jyzb.entity.WarehouseDev;
import com.junmp.jyzb.service.WarehouseDevService;
import com.junmp.jyzb.mapper.WarehouseDevMapper;
import com.junmp.jyzb.utils.DateTimeUtil;
import com.junmp.v2.common.util.BeanPlusUtil;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
/**
* @author lxh专属坐骑
* @description 针对表【sys_temp_humidity(温湿度)】的数据库操作Service实现
* @createDate 2023-12-19 08:33:43
*/
@Service
public class WarehouseDevServiceImpl extends ServiceImpl<WarehouseDevMapper, WarehouseDev>
implements WarehouseDevService {
@Resource
private WarehouseDevService warehouseDevService;
@Resource
private WarehouseDevMapper warehouseDevMapper;
@Override
public String addWarehouseDev(UpdateWarehouseDevReq req) {
WarehouseDev warehouseDev = new WarehouseDev();
BeanPlusUtil.copyProperties(req,warehouseDev);
warehouseDev.setCreateTime(DateTimeUtil.getCurrentDateTime());
warehouseDevService.save(warehouseDev);
return warehouseDev.getId();
}
@Override
public boolean updateWarehouseDev(UpdateWarehouseDevReq req) {
WarehouseDev warehouseDev = new WarehouseDev();
BeanPlusUtil.copyProperties(req,warehouseDev);
warehouseDev.setUpdateTime(DateTimeUtil.getCurrentDateTime());
return warehouseDevService.updateById(warehouseDev);
}
@Override
public List<WarehouseDev> showWarehouseDevList(UpdateWarehouseDevReq req) {
return warehouseDevMapper.showWarehouseDevList(req);
}
}
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.junmp.jyzb.mapper.DeviceConfigMapper">
<resultMap id="BaseResultMap" type="com.junmp.jyzb.entity.DeviceConfig">
<id property="id" column="id" jdbcType="BIGINT"/>
<result property="deviceName" column="device_name" jdbcType="VARCHAR"/>
<result property="deviceCode" column="device_code" jdbcType="VARCHAR"/>
<result property="state" column="state" jdbcType="INTEGER"/>
<result property="position" column="position" jdbcType="VARCHAR"/>
<result property="locationId" column="location_id" jdbcType="VARCHAR"/>
<result property="errorLog" column="errorLog" jdbcType="VARCHAR"/>
<result property="deviceConfig" column="device_config" jdbcType="VARCHAR"/>
<result property="orgId" column="org_id" jdbcType="BIGINT"/>
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
<result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
<result property="createUser" column="create_user" jdbcType="VARCHAR"/>
<result property="updateUser" column="update_user" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
id,device_name,device_code,
state,position,location_id,
errorLog,device_config,org_id,
create_time,update_time,create_user,
update_user
</sql>
<select id="showDeviceConfig" resultType="com.junmp.jyzb.entity.DeviceConfig"
parameterType="com.junmp.jyzb.api.bean.query.QueryDeviceConfigReq">
select dc.*,po.org_name as org_name,bw.name as location_name from base_device_config dc
join pub_org po on po.org_id=dc.org_id
left join base_warehouse bw on bw.id=dc.location_id
where dc.org_id =#{orgId} and dc.device_type=#{deviceType}
<if test="deviceName != null and deviceName != ''">
and dc.device_name =#{deviceName}
</if>
<if test="deviceCode != null and deviceCode != ''">
and dc.device_code =#{deviceCode}
</if>
<if test="pageNo != null and pageNo != '' and pageSize != null and pageSize != '' ">
limit #{pageNo},#{pageSize}
</if>
</select>
<select id="showDeviceConfigCount" resultType="java.lang.Integer"
parameterType="com.junmp.jyzb.api.bean.query.QueryDeviceConfigReq">
select count(*) from (
select dc.*,po.org_name as org_name,bw.name as location_name from base_device_config dc
join pub_org po on po.org_id=dc.org_id
left join base_warehouse bw on bw.id=dc.location_id
where dc.org_id =#{req.orgId}
<if test="req.deviceName != null and req.deviceName != ''">
and dc.device_name =#{req.deviceName}
</if>
<if test="req.deviceCode != null and req.deviceCode != ''">
and dc.device_code =#{req.deviceCode}
</if>
) as a
</select>
</mapper>
...@@ -244,4 +244,29 @@ ...@@ -244,4 +244,29 @@
limit #{pageNo},#{pageSize} limit #{pageNo},#{pageSize}
</if> </if>
</select> </select>
<select id="TjOrgCountByType" resultType="com.junmp.jyzb.api.bean.dto.TjDto.TjOrgCountDto"
parameterType="com.junmp.jyzb.api.bean.query.TjReq.TjOrgCountReq">
select et.id as type_parent_id,a.org_id,max(a.org_name) as org_name,coalesce(sum(a.use_count),0) as use_count
FROM base_equipment_type et
LEFT JOIN
(select
org_id_int AS org_id,
max(org_name) as org_name,
max(parent_id) as parent_id,
max(org_name_short) AS d_name,
`year`,
SUM(use_count) AS use_count,
type_parent_id
FROM vie_equipment_count_summary
where `year`= #{req.year} and org_id_int=#{req.orgId}
<if test="req.monthList!=null and req.monthList.size() > 0">
and month in
<foreach collection="req.monthList" item="item" open="(" separator="," close=")">
#{item}
</foreach>
</if>
GROUP BY org_id,type_parent_id) as a on a.type_parent_id=et.id
where TRIM(et.parent_ids )='' and et.id !="00000000-0000-0000-0000-000000000000"
GROUP BY et.id,a.org_id
</select>
</mapper> </mapper>
...@@ -548,6 +548,23 @@ ...@@ -548,6 +548,23 @@
<select id="GetDetailByTerms" resultType="com.junmp.jyzb.api.bean.dto.InventoryDto"> <select id="GetDetailByTerms" resultType="com.junmp.jyzb.api.bean.dto.InventoryDto">
</select> </select>
<select id="alignInventoryInfo" resultType="com.junmp.jyzb.api.bean.dto.FetchingDataDto.EquipmentDto"
parameterType="com.junmp.jyzb.api.bean.query.InventoryReq">
SELECT i.id,i.package_id,i.type_id,i.size_id,i.supplier_id,i.epc,
i.org_id_int as org_id,i.state as equ_state,i.bussiness_state,i.location_state as state,
i.production_date,i.warranty_period,i.maintenance_period,i.fix_count,i.location_id,i.location_type,i.lost_flag,
i.price,i.create_time,i.update_time,i.note,es.name as size_name,et.name as type_name,bs.name as supplier_name, bw.name as location_name
FROM `base_inventory` i
join base_equipment_size es on i.size_id=es.id
join base_equipment_type et on i.type_id=et.id
join base_warehouse bw on bw.id=i.location_id
join base_supplier bs on bs.id=i.supplier_id
where i.org_id_int=#{req.orgId}
<if test="req.locationId!= null and req.locationId != ''">
and i.location_id=#{req.locationId}
</if>
and i.update_time &gt; #{req.updateTime}
</select>
</mapper> </mapper>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.junmp.jyzb.mapper.WarehouseDevMapper">
<resultMap id="BaseResultMap" type="com.junmp.jyzb.entity.WarehouseDev">
<id property="id" column="id" jdbcType="VARCHAR"/>
<result property="warehouseId" column="warehouse_id" jdbcType="VARCHAR"/>
<result property="devIp" column="dev_ip" jdbcType="VARCHAR"/>
<result property="devPort" column="dev_port" jdbcType="VARCHAR"/>
<result property="devName" column="dev_name" jdbcType="VARCHAR"/>
<result property="devCode" column="dev_code" jdbcType="VARCHAR"/>
<result property="warehouseSd" column="warehouse_sd" jdbcType="VARCHAR"/>
<result property="warehouseWd" column="warehouse_wd" jdbcType="VARCHAR"/>
<result property="setState" column="set_state" jdbcType="VARCHAR"/>
<result property="devState" column="dev_state" jdbcType="INTEGER"/>
<result property="setSd" column="set_sd" jdbcType="INTEGER"/>
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
<result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
</resultMap>
<sql id="Base_Column_List">
id,warehouse_id,dev_ip,
dev_port,dev_name,dev_code,
warehouse_sd,warehouse_wd,set_state,
dev_state,set_sd,create_time,
update_time
</sql>
<select id="showWarehouseDevList" resultType="com.junmp.jyzb.entity.WarehouseDev"
parameterType="com.junmp.jyzb.api.bean.req.UpdateWarehouseDevReq">
select wd.*,po.org_name as org_name, bw.name as warehouse_name FROM base_warehouse_dev wd
join pub_org po on po.org_id=wd.org_id
left join base_warehouse bw on bw.id=wd.warehouse_id
where wd.org_id=#{req.orgId}
<if test="req.devName !=null and req.devName !=''">
and wd.dev_name =#{req.devName}
</if>
<if test="req.devCode !=null and req.devCode !=''">
and wd.dev_code =#{req.devCode}
</if>
</select>
</mapper>
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论