Commit 118c3cd4 by 李小惠

修改报表,添加人脸机照片上传

parent e73f49b5
...@@ -3,11 +3,10 @@ package com.junmp.jyzb.api.bean.dto.TjDto; ...@@ -3,11 +3,10 @@ package com.junmp.jyzb.api.bean.dto.TjDto;
import lombok.Data; import lombok.Data;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date;
@Data @Data
public class FinalTjCountDto implements Serializable { public class FinalTjOrgCountDto implements Serializable {
/** /**
* 使用次数 * 使用次数
......
package com.junmp.jyzb.api.bean.dto.TjDto;
import lombok.Data;
@Data
public class FinalTjOrgPoliceDto {
private String policeId;
private String policeName;
private String policeCode;
private Integer number;
private Integer inStockNum;
private Integer outStockNum;
}
package com.junmp.jyzb.api.bean.dto.TjDto; package com.junmp.jyzb.api.bean.dto.TjDto;
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 lombok.Data; import lombok.Data;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date;
@Data @Data
public class TjCountDto implements Serializable { public class TjOrgCountDto implements Serializable {
/** /**
...@@ -32,7 +27,7 @@ public class TjCountDto implements Serializable { ...@@ -32,7 +27,7 @@ public class TjCountDto implements Serializable {
/** /**
* 父id * 父id
*/ */
private Integer parentId; private Long parentId;
/** /**
* 组织机构简称 * 组织机构简称
......
package com.junmp.jyzb.api.bean.dto.TjDto;
import lombok.Data;
@Data
public class TjOrgPoliceDto {
private String policeId;
private String policeName;
private String sizeId;
private String sizeName;
private String typeId;
private String typeName;
private String locationId;
private String locationName;
}
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
/**
* 本地主机人脸机上传图片返回接口实体类
*/
@Data
public class UploadPolicePhotoDto {
private String policeId;
private String photo;
}
...@@ -3,15 +3,17 @@ package com.junmp.jyzb.api.bean.query.TjReq; ...@@ -3,15 +3,17 @@ package com.junmp.jyzb.api.bean.query.TjReq;
import com.junmp.v2.common.bean.request.BaseRequest; import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data; import lombok.Data;
import java.io.Serializable; import javax.validation.constraints.NotNull;
import java.util.List; import java.util.List;
@Data @Data
public class TjCountReq extends BaseRequest { public class TjOrgCountReq extends BaseRequest {
//组织机构 //组织机构
@NotNull(message = "组织机构不能为空",groups = detail.class)
private Long orgId; private Long orgId;
private List<String> typeIdsList; private List<String> typeIdsList;
private List<String> sizeNameList; private List<String> sizeNameList;
@NotNull(message = "年份不能为空",groups = detail.class)
private Integer year; private Integer year;
} }
\ No newline at end of file
package com.junmp.jyzb.api.bean.query.TjReq;
import com.junmp.v2.common.bean.request.BaseRequest;
import lombok.Data;
import java.util.List;
@Data
public class TjOrgPoliceReq extends BaseRequest {
private Long orgId;
private String policeName;
List<String> typeIdsList;
private List<String> sizeNameList;
}
...@@ -42,6 +42,8 @@ public class UpdatePolicemanReq extends BaseRequest { ...@@ -42,6 +42,8 @@ public class UpdatePolicemanReq extends BaseRequest {
private String password; private String password;
private Long fileId;
private String photo; private String photo;
private String phone; private String phone;
......
package com.junmp.jyzb.api.bean.req;
import lombok.Data;
import org.springframework.web.multipart.MultipartFile;
import java.io.File;
/**
* 本地主机人脸机上传图片返回接口实体类
*/
@Data
public class UploadPolicePhotoReq {
private String policeId;
private MultipartFile picture;
}
package com.junmp.jyzb.api.exception.enums;
import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum;
import lombok.Getter;
@Getter
public enum ProcessExceptionEnum implements IExceptionEnum {
/**
* 流程不存在
*/
PROCESS_ISNOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE,"设计流程不存在,请先设计流程");
/**
* 错误编码
*/
private final Integer code;
/**
* 提示用户信息
*/
private final String message;
ProcessExceptionEnum(Integer code, String message) {
this.code = code;
this.message = message;
}
}
package com.junmp.jyzb.api.exception.enums;
import com.junmp.v2.common.constant.CommonConstant;
import com.junmp.v2.common.exception.IExceptionEnum;
import lombok.Getter;
@Getter
public enum PublicExceptionEnum implements IExceptionEnum {
FILE_DEL_FAILTURE(CommonConstant.DEFAULT_USER_ERROR_CODE,"文件删除失败");
/**
* 错误编码
*/
private final Integer code;
/**
* 提示用户信息
*/
private final String message;
PublicExceptionEnum(Integer code, String message) {
this.code = code;
this.message = message;
}
}
...@@ -125,6 +125,10 @@ ...@@ -125,6 +125,10 @@
<artifactId>dict-biz</artifactId> <artifactId>dict-biz</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.junmp.v2</groupId>
<artifactId>file-biz</artifactId>
</dependency>
<dependency>
<groupId>com.junmp.jyzb</groupId> <groupId>com.junmp.jyzb</groupId>
<artifactId>jyzb-process</artifactId> <artifactId>jyzb-process</artifactId>
</dependency> </dependency>
......
...@@ -3,20 +3,36 @@ package com.junmp.jyzb.controller; ...@@ -3,20 +3,36 @@ package com.junmp.jyzb.controller;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.toolkit.AES; import com.baomidou.mybatisplus.core.toolkit.AES;
import com.junmp.jyzb.api.bean.dto.UploadPolicePhotoDto;
import com.junmp.jyzb.api.bean.query.DbAccessReq; import com.junmp.jyzb.api.bean.query.DbAccessReq;
import com.junmp.jyzb.api.bean.query.PolicemanReq; import com.junmp.jyzb.api.bean.query.PolicemanReq;
import com.junmp.jyzb.api.bean.req.UploadPolicePhotoReq;
import com.junmp.jyzb.api.bean.vo.AuthAccessVo; import com.junmp.jyzb.api.bean.vo.AuthAccessVo;
import com.junmp.jyzb.api.exception.enums.PublicExceptionEnum;
import com.junmp.jyzb.entity.Policeman;
import com.junmp.jyzb.entity.PubOrg;
import com.junmp.jyzb.service.PolicemanService;
import com.junmp.jyzb.service.PubOrgService;
import com.junmp.jyzb.utils.FileUtil; import com.junmp.jyzb.utils.FileUtil;
import com.junmp.v2.common.bean.response.ApiRes; import com.junmp.v2.common.bean.response.ApiRes;
import com.junmp.v2.common.exception.base.ServiceException;
import com.junmp.v2.common.exception.enums.DefaultBizExceptionEnum; import com.junmp.v2.common.exception.enums.DefaultBizExceptionEnum;
import com.junmp.v2.file.api.bean.req.SysFileInfoReq;
import com.junmp.v2.file.api.bean.res.SysFileInfoResp;
import com.junmp.v2.file.biz.entity.SysFileInfo;
import com.junmp.v2.file.biz.service.SysFileInfoService;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.compress.utils.IOUtils; import org.apache.commons.compress.utils.IOUtils;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream; import java.io.ByteArrayOutputStream;
import java.io.File; import java.io.File;
import java.io.FileInputStream; import java.io.FileInputStream;
import java.io.IOException;
import java.net.URL; import java.net.URL;
/** /**
...@@ -36,6 +52,15 @@ import java.net.URL; ...@@ -36,6 +52,15 @@ import java.net.URL;
@RequestMapping("/api") @RequestMapping("/api")
public class PublicController { public class PublicController {
@Resource
private PolicemanService policemanService;
@Resource
private SysFileInfoService sysFileInfoService;
@Resource
private PubOrgService pubOrgService;
private final static String DB_URL_TEMPLATE = "jdbc:mysql://{}:{}/{}?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&nullCatalogMeansCurrent=true"; private final static String DB_URL_TEMPLATE = "jdbc:mysql://{}:{}/{}?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT&nullCatalogMeansCurrent=true";
@GetMapping(path = "/pub/authInfo", name = "生成数据库认证信息") @GetMapping(path = "/pub/authInfo", name = "生成数据库认证信息")
...@@ -57,12 +82,40 @@ public class PublicController { ...@@ -57,12 +82,40 @@ public class PublicController {
} }
// @PostMapping("/downloadPhoto")
// @ApiOperation("/下载图片并返回图片内容信息")
// public ApiRes<byte[]> downloadPhoto (@RequestBody PolicemanReq req)throws Exception{ @PostMapping("/uploadPolicePhoto")
// byte[] bytes = FileUtil.fileToByte(req.getPhoto()); public UploadPolicePhotoDto uploadPolicePhoto(@RequestBody UploadPolicePhotoReq req) {
// //查询警员表,判断该警员是否已经存在警员照片
// return ApiRes.success(bytes); // 如果存在,则查询file表将该数据进行删除,再调用上传文件接口,将返回的文件信息以及地址更新存储到警员表最终返回警员id和照片地址
// } // 如果不存在照片,那么直接调用上传文件接口,将照片存储到警员表并且返回警员id和照片地址
SysFileInfoReq sysFileInfoReq = new SysFileInfoReq();
Policeman policeman = policemanService.getById(req.getPoliceId());
PubOrg pubOrg = pubOrgService.PubOrgExist(policeman.getOrgId());
if (ObjectUtil.isNotNull(policeman.getFileId())){
SysFileInfo byId = sysFileInfoService.getById(policeman.getFileId());
//删除照片
sysFileInfoReq.setFileId(policeman.getFileId());
try {
this.sysFileInfoService.deleteReally(sysFileInfoReq);
} catch (Exception var3) {
throw new ServiceException(PublicExceptionEnum.FILE_DEL_FAILTURE);
}
}
//上传照片
sysFileInfoReq.setFileBucket("jyzb");
sysFileInfoReq.setFileLocation(3);
sysFileInfoReq.setFileObjectName("policePhoto/"+pubOrg.getOrgCode()+"/");
SysFileInfoResp sysFileInfoResp = sysFileInfoService.uploadFile(req.getPicture(), sysFileInfoReq);
UploadPolicePhotoDto uploadPolicePhotoDto = new UploadPolicePhotoDto();
// uploadPolicePhotoDto.setPoliceId();
// uploadPolicePhotoDto.setPhoto();
return uploadPolicePhotoDto;
}
} }
...@@ -2,16 +2,18 @@ package com.junmp.jyzb.controller; ...@@ -2,16 +2,18 @@ package com.junmp.jyzb.controller;
import com.junmp.jyzb.api.bean.dto.InventorySumDto; import com.junmp.jyzb.api.bean.dto.InventorySumDto;
import com.junmp.jyzb.api.bean.dto.TjDto.*; import com.junmp.jyzb.api.bean.dto.TjDto.*;
import com.junmp.jyzb.api.bean.query.InventoryReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgCountReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjCountReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgEqsReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgEqsReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgPoliceReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgPriceReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgPriceReq;
import com.junmp.jyzb.service.TjService; import com.junmp.jyzb.service.TjService;
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 com.junmp.v2.db.api.page.PageResult; import com.junmp.v2.db.api.page.PageResult;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
...@@ -89,33 +91,57 @@ public class TjController { ...@@ -89,33 +91,57 @@ public class TjController {
/** /**
* --------------------------------------使用统计报表------------------------------------------- * --------------------------------------使用统计报表-------------------------------------------
*/ */
//财务统计报表
@PostMapping("/TjOrgCount") @PostMapping("/TjOrgCount")
@ApiOperation("/财务统计报表") @ApiOperation("/使用统计报表")
public ApiRes<PageResult<TjCountDto>> TjOrgCount(@RequestBody TjCountReq req){ public ApiRes<PageResult<TjOrgCountDto>> TjOrgCount(@RequestBody @Validated(ValidationApi.detail.class) TjOrgCountReq req){
return ApiRes.success(tjService.TjOrgCount(req)); return ApiRes.success(tjService.TjOrgCount(req));
} }
@PostMapping("/TjOrgCountSum") @PostMapping("/TjOrgCountSum")
@ApiOperation("/财务统计报表汇总") @ApiOperation("/使用统计报表汇总")
public ApiRes<FinalTjCountDto> TjOrgCountSum(@RequestBody TjCountReq req){ public ApiRes<FinalTjOrgCountDto> TjOrgCountSum(@RequestBody @Validated(ValidationApi.detail.class) TjOrgCountReq req){
return ApiRes.success(tjService.TjOrgCountSum(req)); return ApiRes.success(tjService.TjOrgCountSum(req));
} }
//财务统计报表(点击+后里面的数据) //财务统计报表(点击+后里面的数据)
@PostMapping("/TjOrgCountDetailPage") @PostMapping("/TjOrgCountDetailPage")
@ApiOperation("/查询组织机构下的财务统计明细") @ApiOperation("/查询组织机构下的使用统计明细")
public ApiRes<PageResult<TjCountDto>> TjOrgPriceDetailPage(@RequestBody TjCountReq req){ public ApiRes<PageResult<TjOrgCountDto>> TjOrgPriceDetailPage(@RequestBody TjOrgCountReq req){
return ApiRes.success(tjService.TjOrgCountDetailPage(req)); return ApiRes.success(tjService.TjOrgCountDetailPage(req));
} }
@PostMapping("/TjOrgCountDetailList") @PostMapping("/TjOrgCountDetailList")
@ApiOperation("/查询组织机构下的财务统计明细") @ApiOperation("/查询组织机构下的使用统计明细")
public ApiRes<List<TjCountDto>> TjOrgCountDetailList(@RequestBody TjCountReq req){ public ApiRes<List<TjOrgCountDto>> TjOrgCountDetailList(@RequestBody TjOrgCountReq req){
return ApiRes.success(tjService.TjOrgCountDetailList(req)); return ApiRes.success(tjService.TjOrgCountDetailList(req));
} }
/** /**
* --------------------------------------人员统计报表------------------------------------------- * --------------------------------------人员统计报表-------------------------------------------
*/ */
// @PostMapping("/TjOrgPolice")
// @ApiOperation("/人员统计报表")
// public ApiRes<PageResult<TjOrgPoliceDto>> TjOrgPolice(@RequestBody TjOrgPoliceReq req){
// return ApiRes.success(tjService.TjOrgPolice(req));
// }
// @PostMapping("/TjOrgPoliceSum")
// @ApiOperation("/人员统计报表汇总")
// public ApiRes<FinalTjOrgPoliceDto> TjOrgPoliceSum(@RequestBody TjOrgPoliceReq req){
// return ApiRes.success(tjService.TjOrgPoliceSum(req));
// }
//
// //财务统计报表(点击+后里面的数据)
// @PostMapping("/TjOrgPoliceDetailPage")
// @ApiOperation("/查询组织机构下的人员统计明细")
// public ApiRes<PageResult<TjOrgPoliceDto>> TjOrgPoliceDetailPage(@RequestBody TjOrgPoliceReq req){
// return ApiRes.success(tjService.TjOrgPoliceDetailPage(req));
// }
// @PostMapping("/TjOrgPoliceDetailList")
// @ApiOperation("/查询组织机构下的人员统计明细")
// public ApiRes<List<TjOrgPoliceDto>> TjOrgPoliceDetailList(@RequestBody TjOrgPoliceReq req){
// return ApiRes.success(tjService.TjOrgPoliceDetailList(req));
// }
/** /**
* --------------------------------------温湿度记录------------------------------------------- * --------------------------------------温湿度记录-------------------------------------------
......
...@@ -46,6 +46,9 @@ public class Policeman implements Serializable { ...@@ -46,6 +46,9 @@ public class Policeman implements Serializable {
@TableField(value = "password",updateStrategy = FieldStrategy.IGNORED) @TableField(value = "password",updateStrategy = FieldStrategy.IGNORED)
private String password; private String password;
@TableField(value = "file_id")
private Long fileId;
@TableField(value = "photo") @TableField(value = "photo")
private String photo; private String photo;
......
package com.junmp.jyzb.mapper; package com.junmp.jyzb.mapper;
import com.junmp.jyzb.api.bean.dto.TjDto.FinalTjCountDto; import com.junmp.jyzb.api.bean.dto.TjDto.FinalTjOrgCountDto;
import com.junmp.jyzb.api.bean.dto.TjDto.TjCountDto; import com.junmp.jyzb.api.bean.dto.TjDto.TjOrgCountDto;
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;
...@@ -18,26 +18,26 @@ public interface EquipmentCountSummaryMapper extends BaseMapper<EquipmentCountSu ...@@ -18,26 +18,26 @@ public interface EquipmentCountSummaryMapper extends BaseMapper<EquipmentCountSu
void addInfo(); void addInfo();
List<TjCountDto> TjOrgCount(@Param("orgId") Long orgId, List<TjOrgCountDto> TjOrgCount(@Param("orgId") Long orgId,
@Param("typeIdsList") List<String> typeIdsList, @Param("typeIdsList") List<String> typeIdsList,
@Param("sizeNameList") List<String> sizeNameList, @Param("sizeNameList") List<String> sizeNameList,
@Param("year")Integer year); @Param("year")Integer year);
FinalTjCountDto TjOrgCountSum(@Param("orgId") Long orgId, FinalTjOrgCountDto TjOrgCountSum(@Param("orgId") Long orgId,
@Param("typeIdsList") List<String> typeIdsList, @Param("sizeNameList") List<String> sizeNameList,
@Param("sizeNameList") List<String> sizeNameList, @Param("typeIdsList") List<String> typeIdsList,
@Param("year")Integer year); @Param("year")Integer year);
int TjOrgCountDetailSum(@Param("orgId")Long orgId, int TjOrgCountDetailSum(@Param("orgId")Long orgId,
@Param("year") Integer year, @Param("year") Integer year,
@Param("typeIdsList") List<String> typeIdsList, @Param("typeIdsList") List<String> typeIdsList,
@Param("sizeNameList") List<String> sizeNameList); @Param("sizeNameList") List<String> sizeNameList);
List<TjCountDto> TjOrgCountDetail(@Param("orgId")Long orgId, List<TjOrgCountDto> TjOrgCountDetail(@Param("orgId")Long orgId,
@Param("year") Integer year, @Param("year") Integer year,
@Param("typeIdsList") List<String> typeIdsList, @Param("typeIdsList") List<String> typeIdsList,
@Param("sizeNameList") List<String> sizeNameList, @Param("sizeNameList") List<String> sizeNameList,
@Param("pageNo")Long pageNo, @Param("pageSize") Long pageSize); @Param("pageNo")Long pageNo, @Param("pageSize") Long pageSize);
} }
......
...@@ -3,7 +3,7 @@ package com.junmp.jyzb.service; ...@@ -3,7 +3,7 @@ package com.junmp.jyzb.service;
import com.junmp.jyzb.api.bean.dto.InventorySumDto; import com.junmp.jyzb.api.bean.dto.InventorySumDto;
import com.junmp.jyzb.api.bean.dto.TjDto.*; import com.junmp.jyzb.api.bean.dto.TjDto.*;
import com.junmp.jyzb.api.bean.query.InventoryReq; import com.junmp.jyzb.api.bean.query.InventoryReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjCountReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgCountReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgEqsReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgEqsReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgPriceReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgPriceReq;
import com.junmp.v2.db.api.page.PageResult; import com.junmp.v2.db.api.page.PageResult;
...@@ -33,11 +33,11 @@ public interface TjService { ...@@ -33,11 +33,11 @@ public interface TjService {
FinalTjOrgPriceDto TjOrgPriceSum(TjOrgPriceReq req); FinalTjOrgPriceDto TjOrgPriceSum(TjOrgPriceReq req);
PageResult<TjCountDto> TjOrgCount(TjCountReq req); PageResult<TjOrgCountDto> TjOrgCount(TjOrgCountReq req);
FinalTjCountDto TjOrgCountSum(TjCountReq req); FinalTjOrgCountDto TjOrgCountSum(TjOrgCountReq req);
PageResult<TjCountDto> TjOrgCountDetailPage(TjCountReq req); PageResult<TjOrgCountDto> TjOrgCountDetailPage(TjOrgCountReq req);
List<TjCountDto> TjOrgCountDetailList(TjCountReq req); List<TjOrgCountDto> TjOrgCountDetailList(TjOrgCountReq req);
} }
...@@ -18,7 +18,9 @@ import com.junmp.jyzb.service.ReassignmentService; ...@@ -18,7 +18,9 @@ import com.junmp.jyzb.service.ReassignmentService;
import com.junmp.jyzb.utils.BusinessUtil; import com.junmp.jyzb.utils.BusinessUtil;
import com.junmp.v2.common.util.BeanPlusUtil; import com.junmp.v2.common.util.BeanPlusUtil;
import com.junmp.v2.sys.user.service.SysUserService; import com.junmp.v2.sys.user.service.SysUserService;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.TaskService; import org.flowable.engine.TaskService;
import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.Task; import org.flowable.task.api.Task;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
...@@ -52,16 +54,23 @@ public class OrderCommonServiceImpl implements OrderCommonService { ...@@ -52,16 +54,23 @@ public class OrderCommonServiceImpl implements OrderCommonService {
@Resource @Resource
private InventorySummaryMapper inventorySummaryMapper; private InventorySummaryMapper inventorySummaryMapper;
@Resource
private RuntimeService runtimeService;
@Override @Override
public boolean changeOrderExamineState(HandleDataDTO handleDataDTO) { public boolean changeOrderExamineState(HandleDataDTO handleDataDTO) {
String taskId = handleDataDTO.getTaskId(); String taskId = handleDataDTO.getTaskId();
Task task = taskService.createTaskQuery().taskId(taskId).singleResult(); Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().includeProcessVariables().processInstanceId(task.getProcessInstanceId()).singleResult();
//更新单子的状态(改为已驳回,如果单子是报废,那么该单子的审核中的报废数量应该进行减少) //更新单子的状态(改为已驳回,如果单子是报废,那么该单子的审核中的报废数量应该进行减少)
Map<String, Object> processVariables = task.getProcessVariables(); // Map<String, Object> processVariables = task.getProcessVariables();
//单据类型(出入库单、调岗单、业务单、盘库单) //单据类型(出入库单、调岗单、业务单、盘库单)
String orderType = MapUtil.getStr(processVariables, ORDER_TYPE); // String orderType = MapUtil.getStr(processVariables, ORDER_TYPE);
String orderType= MapUtil.getStr(processInstance.getProcessVariables(),ORDER_TYPE);
//单据业务类型(采购啥的......) //单据业务类型(采购啥的......)
String bussinessType = MapUtil.getStr(processVariables, BUSSINESS_TYPE); String bussinessType= MapUtil.getStr(processInstance.getProcessVariables(),BUSSINESS_TYPE);
// String bussinessType = MapUtil.getStr(processVariables, BUSSINESS_TYPE);
String processInstanceId = task.getProcessInstanceId(); String processInstanceId = task.getProcessInstanceId();
boolean result=true; boolean result=true;
switch (orderType){ switch (orderType){
......
...@@ -1016,6 +1016,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -1016,6 +1016,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
.eq(Reassignment::getPoliceId, req.getPoliceId()) .eq(Reassignment::getPoliceId, req.getPoliceId())
.eq(Reassignment::getReassignmentType,req.getReassignmentType()) .eq(Reassignment::getReassignmentType,req.getReassignmentType())
.eq(Reassignment::getOrgId, req.getOrgId()) .eq(Reassignment::getOrgId, req.getOrgId())
.eq(Reassignment::getExamineState,"working")
.isNotNull(Reassignment::getProcessId) .isNotNull(Reassignment::getProcessId)
.orderByDesc(Reassignment::getCreateTime)); .orderByDesc(Reassignment::getCreateTime));
if (list.size()>0){ if (list.size()>0){
...@@ -1065,7 +1066,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -1065,7 +1066,7 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
StartProcessInstanceDTO startProcessInstanceDTO=new StartProcessInstanceDTO(); StartProcessInstanceDTO startProcessInstanceDTO=new StartProcessInstanceDTO();
startProcessInstanceDTO.setProcessDefinitionId(req.getProcessDefinitionId()); startProcessInstanceDTO.setProcessDefinitionId(req.getProcessDefinitionId());
startProcessInstanceDTO.setOrderId(reassignment.getId()); startProcessInstanceDTO.setOrderId(reassignment.getId());
startProcessInstanceDTO.setOrderType("reassigment"); startProcessInstanceDTO.setOrderType("reassignment");
startProcessInstanceDTO.setUserId(req.getUserId()); startProcessInstanceDTO.setUserId(req.getUserId());
startProcessInstanceDTO.setBussinessType(req.getBussinessType()); startProcessInstanceDTO.setBussinessType(req.getBussinessType());
startProcessInstanceDTO.setReassignmentType(req.getReassignmentType()); startProcessInstanceDTO.setReassignmentType(req.getReassignmentType());
......
...@@ -4,13 +4,11 @@ import cn.hutool.core.util.ObjectUtil; ...@@ -4,13 +4,11 @@ import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.junmp.jyzb.api.bean.dto.EqsSumDto; import com.junmp.jyzb.api.bean.dto.EqsSumDto;
import com.junmp.jyzb.api.bean.dto.InventorySumDto; import com.junmp.jyzb.api.bean.dto.InventorySumDto;
import com.junmp.jyzb.api.bean.dto.OrgDto;
import com.junmp.jyzb.api.bean.dto.TjDto.*; import com.junmp.jyzb.api.bean.dto.TjDto.*;
import com.junmp.jyzb.api.bean.query.InventoryReq; import com.junmp.jyzb.api.bean.query.InventoryReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjCountReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgCountReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgEqsReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgEqsReq;
import com.junmp.jyzb.api.bean.query.TjReq.TjOrgPriceReq; import com.junmp.jyzb.api.bean.query.TjReq.TjOrgPriceReq;
import com.junmp.jyzb.entity.PubOrg;
import com.junmp.jyzb.mapper.*; import com.junmp.jyzb.mapper.*;
import com.junmp.jyzb.service.EquipmentSizeService; import com.junmp.jyzb.service.EquipmentSizeService;
import com.junmp.jyzb.service.PubOrgService; import com.junmp.jyzb.service.PubOrgService;
...@@ -21,9 +19,6 @@ import com.junmp.v2.db.api.page.PageResult; ...@@ -21,9 +19,6 @@ import com.junmp.v2.db.api.page.PageResult;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.util.*; import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;
...@@ -351,45 +346,45 @@ public class TjServiceImpl implements TjService { ...@@ -351,45 +346,45 @@ public class TjServiceImpl implements TjService {
} }
@Override @Override
public PageResult<TjCountDto> TjOrgCount(TjCountReq req) { public PageResult<TjOrgCountDto> TjOrgCount(TjOrgCountReq req) {
List<TjCountDto> tjCountDtoList=equipmentCountSummaryMapper.TjOrgCount(req.getOrgId(), List<TjOrgCountDto> tjOrgCountDtoList =equipmentCountSummaryMapper.TjOrgCount(req.getOrgId(),
req.getTypeIdsList(),req.getSizeNameList(),req.getYear()); req.getTypeIdsList(),req.getSizeNameList(),req.getYear());
//对组织机构进行排序 //对组织机构进行排序
Comparator<TjCountDto> orgComparator = createOrgComparator(); Comparator<TjOrgCountDto> orgComparator = createOrgComparator();
Collections.sort(tjCountDtoList, orgComparator); Collections.sort(tjOrgCountDtoList, orgComparator);
Page<TjCountDto> page = PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize()); Page<TjOrgCountDto> page = PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize());
if (ObjectUtil.isNull(req.getPageNo()) && ObjectUtil.isNull(req.getPageSize())) { if (ObjectUtil.isNull(req.getPageNo()) && ObjectUtil.isNull(req.getPageSize())) {
req.setPageNo(1L); req.setPageNo(1L);
req.setPageSize(10L); req.setPageSize(10L);
} }
long startIndex = (req.getPageNo() - 1) * req.getPageSize(); long startIndex = (req.getPageNo() - 1) * req.getPageSize();
long endIndex = Math.min(startIndex + req.getPageSize(), tjCountDtoList.size()); long endIndex = Math.min(startIndex + req.getPageSize(), tjOrgCountDtoList.size());
List<TjCountDto> subList = tjCountDtoList.subList((int) startIndex, (int)endIndex); List<TjOrgCountDto> subList = tjOrgCountDtoList.subList((int) startIndex, (int)endIndex);
page.setTotal(tjCountDtoList.size()); page.setTotal(tjOrgCountDtoList.size());
page.setRecords(subList); page.setRecords(subList);
return PageResultFactory.createPageResult(page); return PageResultFactory.createPageResult(page);
} }
@Override @Override
public FinalTjCountDto TjOrgCountSum(TjCountReq req) { public FinalTjOrgCountDto TjOrgCountSum(TjOrgCountReq req) {
FinalTjCountDto finalTjCountDto=equipmentCountSummaryMapper.TjOrgCountSum(req.getOrgId(),req.getSizeNameList(), FinalTjOrgCountDto finalTjOrgCountDto =equipmentCountSummaryMapper.TjOrgCountSum(req.getOrgId(),req.getSizeNameList(),
req.getTypeIdsList(), req.getYear()); req.getTypeIdsList(), req.getYear());
if (ObjectUtil.isNotNull(finalTjCountDto)) { if (ObjectUtil.isNotNull(finalTjOrgCountDto)) {
return finalTjCountDto; return finalTjOrgCountDto;
}else { }else {
return new FinalTjCountDto(); return new FinalTjOrgCountDto();
} }
} }
@Override @Override
public PageResult<TjCountDto> TjOrgCountDetailPage(TjCountReq req) { public PageResult<TjOrgCountDto> TjOrgCountDetailPage(TjOrgCountReq req) {
int size = equipmentCountSummaryMapper.TjOrgCountDetailSum(req.getOrgId(),req.getYear(),req.getTypeIdsList(),req.getSizeNameList()); int size = equipmentCountSummaryMapper.TjOrgCountDetailSum(req.getOrgId(),req.getYear(),req.getTypeIdsList(),req.getSizeNameList());
if (ObjectUtil.isNull(req.getPageNo()) && ObjectUtil.isNull(req.getPageSize())) { if (ObjectUtil.isNull(req.getPageNo()) && ObjectUtil.isNull(req.getPageSize())) {
req.setPageNo(1L); req.setPageNo(1L);
req.setPageSize(10L); req.setPageSize(10L);
} }
Page<TjCountDto> page = PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize()); Page<TjOrgCountDto> page = PageFactory.getDefaultPage(req.getPageNo(), req.getPageSize());
List<TjCountDto> returnList=equipmentCountSummaryMapper.TjOrgCountDetail(req.getOrgId(),req.getYear(), List<TjOrgCountDto> returnList=equipmentCountSummaryMapper.TjOrgCountDetail(req.getOrgId(),req.getYear(),
req.getTypeIdsList(),req.getSizeNameList(),(req.getPageNo()-1)* req.getPageSize(),req.getPageSize()); req.getTypeIdsList(),req.getSizeNameList(),(req.getPageNo()-1)* req.getPageSize(),req.getPageSize());
page.setTotal(size); page.setTotal(size);
page.setRecords(returnList); page.setRecords(returnList);
...@@ -397,8 +392,8 @@ public class TjServiceImpl implements TjService { ...@@ -397,8 +392,8 @@ public class TjServiceImpl implements TjService {
} }
@Override @Override
public List<TjCountDto> TjOrgCountDetailList(TjCountReq req) { public List<TjOrgCountDto> TjOrgCountDetailList(TjOrgCountReq req) {
List<TjCountDto> returnList=equipmentCountSummaryMapper.TjOrgCountDetail(req.getOrgId(),req.getYear(), List<TjOrgCountDto> returnList=equipmentCountSummaryMapper.TjOrgCountDetail(req.getOrgId(),req.getYear(),
req.getTypeIdsList(),req.getSizeNameList(),null,null); req.getTypeIdsList(),req.getSizeNameList(),null,null);
return returnList; return returnList;
} }
......
...@@ -38,7 +38,7 @@ ...@@ -38,7 +38,7 @@
<select id="addInfo" statementType="CALLABLE" > <select id="addInfo" statementType="CALLABLE" >
{call AddEquipmentCountSummary()} {call AddEquipmentCountSummary()}
</select> </select>
<select id="TjOrgCount" resultType="com.junmp.jyzb.api.bean.dto.TjDto.TjCountDto"> <select id="TjOrgCount" resultType="com.junmp.jyzb.api.bean.dto.TjDto.TjOrgCountDto">
SELECT SELECT
t.org_id, t.org_id,
t.org_code, t.org_code,
...@@ -69,7 +69,7 @@ ...@@ -69,7 +69,7 @@
#{item} #{item}
</foreach> </foreach>
</if> </if>
<if test="sizeNameList!=null and !sizeNameList.size() > 0"> <if test="sizeNameList!=null and sizeNameList.size() > 0">
AND AND
<foreach collection="sizeNameList " item="item" open="(" separator="or" close=")"> <foreach collection="sizeNameList " item="item" open="(" separator="or" close=")">
size_name like CONCAT('%', #{item}, '%') size_name like CONCAT('%', #{item}, '%')
...@@ -81,49 +81,49 @@ ...@@ -81,49 +81,49 @@
GROUP BY GROUP BY
t.org_id,t.org_code, t.org_name,t.parent_id,t.d_name t.org_id,t.org_code, t.org_name,t.parent_id,t.d_name
</select> </select>
<select id="TjOrgCountSum" resultType="com.junmp.jyzb.api.bean.dto.TjDto.FinalTjCountDto"> <select id="TjOrgCountSum" resultType="com.junmp.jyzb.api.bean.dto.TjDto.FinalTjOrgCountDto">
select sum(use_count),sum(fix_count),sum(number) FROM ( select sum(use_count) as use_count,sum(fix_count) as fix_count,sum(number) as number FROM (
SELECT SELECT
t.org_id, t.org_id,
t.org_code, t.org_code,
t.org_name, t.org_name,
t.parent_id, t.parent_id,
t.d_name, t.d_name,
MAX(t.`year`) AS `year`, MAX(t.`year`) AS `year`,
SUM(t.use_count) AS use_count, SUM(t.use_count) AS use_count,
SUM(t.fix_count) AS fix_count, SUM(t.fix_count) AS fix_count,
sum(CASE WHEN t.month = MONTH(CURRENT_DATE()) THEN t.number ELSE 0 END) AS number sum(CASE WHEN t.month = MONTH(CURRENT_DATE()) THEN t.number ELSE 0 END) AS number
FROM ( FROM (
SELECT SELECT
org_id_int AS org_id, org_id_int AS org_id,
org_code, org_code,
org_name, org_name,
parent_id, parent_id,
org_name_short AS d_name, org_name_short AS d_name,
`year`, `year`,
`month`, `month`,
SUM(use_count) AS use_count, SUM(use_count) AS use_count,
SUM(fix_count) AS fix_count, SUM(fix_count) AS fix_count,
sum(number) as number sum(number) as number
FROM vie_equipment_count_summary FROM vie_equipment_count_summary
where `year`= #{year} and (org_id_int=#{orgId} or parent_id=#{orgId}) where `year`= #{year} and (org_id_int=#{orgId} or parent_id=#{orgId})
<if test="typeIdsList!=null and typeIdsList.size() > 0"> <if test="typeIdsList!=null and typeIdsList.size() > 0">
and type_id in and type_id in
<foreach collection="typeIdsList" item="item" open="(" separator="," close=")"> <foreach collection="typeIdsList" item="item" open="(" separator="," close=")">
#{item} #{item}
</foreach> </foreach>
</if> </if>
<if test="sizeNameList!=null and !sizeNameList.size() > 0"> <if test="sizeNameList!=null and sizeNameList.size() > 0">
AND AND
<foreach collection="sizeNameList " item="item" open="(" separator="or" close=")"> <foreach collection="sizeNameList " item="item" open="(" separator="or" close=")">
size_name like CONCAT('%', #{item}, '%') size_name like CONCAT('%', #{item}, '%')
</foreach> </foreach>
</if> </if>
GROUP BY org_id,org_code,org_name,parent_id, d_name,`year`,month GROUP BY org_id,org_code,org_name,parent_id, d_name,`year`,month
) AS t ) AS t
GROUP BY GROUP BY
t.org_id,t.org_code, t.org_name,t.parent_id,t.d_name t.org_id,t.org_code, t.org_name,t.parent_id,t.d_name
) as a ) as a
</select> </select>
<select id="TjOrgCountDetailSum" resultType="java.lang.Integer"> <select id="TjOrgCountDetailSum" resultType="java.lang.Integer">
...@@ -159,8 +159,7 @@ ...@@ -159,8 +159,7 @@
type_name, type_name,
sum(number) as number sum(number) as number
FROM vie_equipment_count_summary FROM vie_equipment_count_summary
WHERE year = #{year} WHERE year = #{year} and org_id_int = #{orgId}
org_id_int = #{orgId}
<if test="typeIdsList!=null and typeIdsList.size() > 0"> <if test="typeIdsList!=null and typeIdsList.size() > 0">
AND type_id IN AND type_id IN
<foreach collection="typeIdsList " item="item" open="(" separator="," close=")"> <foreach collection="typeIdsList " item="item" open="(" separator="," close=")">
...@@ -181,7 +180,7 @@ ...@@ -181,7 +180,7 @@
ORDER BY t.type_id,size_id ORDER BY t.type_id,size_id
) as a ) as a
</select> </select>
<select id="TjOrgCountDetail" resultType="com.junmp.jyzb.api.bean.dto.TjDto.TjCountDto"> <select id="TjOrgCountDetail" resultType="com.junmp.jyzb.api.bean.dto.TjDto.TjOrgCountDto">
SELECT SELECT
t.org_id, t.org_id,
t.org_code, t.org_code,
...@@ -213,8 +212,7 @@ ...@@ -213,8 +212,7 @@
type_name, type_name,
sum(number) as number sum(number) as number
FROM vie_equipment_count_summary FROM vie_equipment_count_summary
WHERE year = #{year} WHERE year = #{year} and org_id_int = #{orgId}
org_id_int = #{orgId}
<if test="typeIdsList!=null and typeIdsList.size() > 0"> <if test="typeIdsList!=null and typeIdsList.size() > 0">
AND type_id IN AND type_id IN
<foreach collection="typeIdsList " item="item" open="(" separator="," close=")"> <foreach collection="typeIdsList " item="item" open="(" separator="," close=")">
......
...@@ -34,11 +34,13 @@ import com.junmp.junmpProcess.vo.*; ...@@ -34,11 +34,13 @@ import com.junmp.junmpProcess.vo.*;
import com.junmp.jyzb.api.bean.query.ProcessReq.FormReq; import com.junmp.jyzb.api.bean.query.ProcessReq.FormReq;
import com.junmp.jyzb.api.bean.query.ProcessReq.SuspendOrActivateDefinitionReq; import com.junmp.jyzb.api.bean.query.ProcessReq.SuspendOrActivateDefinitionReq;
import com.junmp.jyzb.api.exception.enums.ProcessExceptionEnum;
import com.junmp.v2.auth.api.LoginUserApi; import com.junmp.v2.auth.api.LoginUserApi;
import com.junmp.v2.auth.api.bean.login.LoginUser; import com.junmp.v2.auth.api.bean.login.LoginUser;
import com.junmp.v2.auth.api.context.LoginContext; import com.junmp.v2.auth.api.context.LoginContext;
import com.junmp.v2.common.bean.request.BaseRequest; import com.junmp.v2.common.bean.request.BaseRequest;
import com.junmp.v2.common.bean.response.ApiRes; import com.junmp.v2.common.bean.response.ApiRes;
import com.junmp.v2.common.exception.base.ServiceException;
import com.junmp.v2.common.util.BeanPlusUtil; import com.junmp.v2.common.util.BeanPlusUtil;
import com.junmp.v2.db.api.factory.PageFactory; import com.junmp.v2.db.api.factory.PageFactory;
import com.junmp.v2.db.api.factory.PageResultFactory; import com.junmp.v2.db.api.factory.PageResultFactory;
...@@ -274,7 +276,7 @@ public class WorkProcessServiceImpl extends ServiceImpl<ProcessTemplatesMapper, ...@@ -274,7 +276,7 @@ public class WorkProcessServiceImpl extends ServiceImpl<ProcessTemplatesMapper,
processTemplates.setTemplateId(templateId); processTemplates.setTemplateId(templateId);
processTemplates.setFormName(req.getFormName()); processTemplates.setFormName(req.getFormName());
processTemplates.setRemark(req.getRemark()); processTemplates.setRemark(req.getRemark());
processTemplates.setIsStop(true); processTemplates.setIsStop(false);
Date date= new Date(); Date date= new Date();
processTemplates.setUpdated(date); processTemplates.setUpdated(date);
...@@ -285,6 +287,9 @@ public class WorkProcessServiceImpl extends ServiceImpl<ProcessTemplatesMapper, ...@@ -285,6 +287,9 @@ public class WorkProcessServiceImpl extends ServiceImpl<ProcessTemplatesMapper,
@Override @Override
public Boolean suspendOrActivateProcessDefinitionById(SuspendOrActivateDefinitionReq req) { public Boolean suspendOrActivateProcessDefinitionById(SuspendOrActivateDefinitionReq req) {
if (StringUtils.isBlank(req.getProcessDefinitionId()) || ObjectUtil.isNull(req.getProcessDefinitionId())){
throw new ServiceException(ProcessExceptionEnum.PROCESS_ISNOT_EXIST);
}
ProcessTemplates processTemplates = processTemplateService.getById(req.getFormId()); ProcessTemplates processTemplates = processTemplateService.getById(req.getFormId());
if (req.getIsStop() == true){ if (req.getIsStop() == true){
repositoryService.suspendProcessDefinitionById(req.getProcessDefinitionId(), true, null); repositoryService.suspendProcessDefinitionById(req.getProcessDefinitionId(), true, null);
......
...@@ -59,7 +59,7 @@ public class SysFormServiceImpl extends ServiceImpl<ProcessTemplatesMapper, Proc ...@@ -59,7 +59,7 @@ public class SysFormServiceImpl extends ServiceImpl<ProcessTemplatesMapper, Proc
processTemplates.setTemplateId(templateId); processTemplates.setTemplateId(templateId);
processTemplates.setFormName(req.getFormName()); processTemplates.setFormName(req.getFormName());
processTemplates.setRemark(req.getRemark()); processTemplates.setRemark(req.getRemark());
processTemplates.setIsStop(false); processTemplates.setIsStop(true);
Date date= new Date(); Date date= new Date();
processTemplates.setUpdated(date); processTemplates.setUpdated(date);
processTemplateService.save(processTemplates); processTemplateService.save(processTemplates);
......
...@@ -320,6 +320,12 @@ ...@@ -320,6 +320,12 @@
<artifactId>dict-biz</artifactId> <artifactId>dict-biz</artifactId>
<version>${junmp.v2.version}</version> <version>${junmp.v2.version}</version>
</dependency> </dependency>
<dependency>
<groupId>com.junmp.v2</groupId>
<artifactId>file-biz</artifactId>
<version>${junmp.v2.version}</version>
</dependency>
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论