Commit b08b7605 by 李小惠

1

parents e86019e5 7be07d0c
package com.junmp.jyzb.api.bean.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
@Data
public class BussinessInventoryDto implements Serializable {
private String totalNum;
private List<EquipmentListDto> equipmentList;
}
\ No newline at end of file
package com.junmp.jyzb.api.bean.dto;
import lombok.Data;
import java.io.Serializable;
@Data
public class EquipmentListDto {
private String typeId;
private String typeName;
private String sizeId;
private String sizeName;
private String planNum;
}
package com.junmp.jyzb.api.bean.query;
import com.junmp.v2.common.bean.request.ValidationApi;
import lombok.Data;
import javax.validation.constraints.NotNull;
@Data
public class BussinessInventoryReq {
@NotNull(message = "预览时,盘点仓库不能为空", groups = { ValidationApi.detail.class})
private String warehouseId;
private String orderId;
private String inventoryType;
private String inventoryState;
private String examineState;
private String type;
private String typeList;
private String orgId;
private String orderState;
private String pageNo;
private String pageSize;
private String startTime;
private String endTime;
private String column;
private String order;
}
\ No newline at end of file
package com.junmp.jyzb.api.bean.query;
import com.junmp.v2.common.bean.request.BaseRequest;
import com.junmp.v2.validator.api.validators.unique.TableUniqueValue;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
/**
* <pre>
*
* 描述:
* 版本:1.0.0
* 日期:2022/8/1 10:56
* 作者:ningzp@junmp.com.cn
* <br>修改记录
* <br>修改日期 修改人 修改内容
*
* </pre>
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class CompanyReq extends BaseRequest {
@NotNull(message = "企业编号不能为空", groups = {edit.class, delete.class, detail.class})
private Long bizId;
@NotBlank(message = "企业编码不能为空", groups = {edit.class})
@TableUniqueValue(
message = "编码重复",
groups = {edit.class},
tableName = "biz_company",
columnName = "biz_code",
idFieldName = "biz_id")
private String bizCode;
/**
* 单位类型
*/
private String bizType;
/**
* 名称
*/
private String name;
/**
* 简称
*/
private String shortName;
/**
* 备注
*/
private String remark;
}
......@@ -44,6 +44,10 @@ public class InventorySumReq extends BaseRequest {
*/
public List<String> typeIds;
/**
* 号型IDs
*/
public List<String> sizeIds;
/**
* 类型名称
*/
private String typeName;
......
package com.junmp.jyzb.api.bean.req;
import com.junmp.v2.common.bean.request.BaseRequest;
import com.junmp.v2.common.bean.request.ValidationApi;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.util.Date;
@Data
public class UpdateInventoryReq {
/**
* id
*/
@NotBlank(message = "id不能为空", groups = {ValidationApi.edit.class})
private String id;
private String applyTime;
/**
* 工作流
*/
private String processDefinitionId;
/**
*
*/
@NotBlank(message = "组织机构id不能为空", groups = {ValidationApi.edit.class})
private Long orgId;
/**
*
*/
@NotBlank(message = "仓库id不能为空", groups = {ValidationApi.edit.class})
private String warehouseId;
/**
* 单据单号
*/
private String operator;
private String inventoryType;
private String rules;
private String ExamineState;
}
......@@ -6,9 +6,10 @@ import lombok.Getter;
@Getter
public enum InventoryExceptionEnum implements IExceptionEnum {
INVENTORY_NOT_EXIST(CommonConstant.DEFAULT_USER_ERROR_CODE,"装备信息不存在"),
INVENTORY_BEYOND_STOCK(CommonConstant.DEFAULT_USER_ERROR_CODE,"填写的报废的装备数量大于实际能进行报废的数量"),
BROKENNUM_BEYOND_STOCK(CommonConstant.DEFAULT_USER_ERROR_CODE,"审核中的数量已存在最大可报废数量,现提交失败"),
INVENTORY_NOT_EXIST(CommonConstant.DEFAULT_BIZ_ERROR_CODE,"装备信息不存在"),
INVENTORY_BEYOND_STOCK(CommonConstant.DEFAULT_BIZ_ERROR_CODE,"填写的报废的装备数量大于实际能进行报废的数量"),
BROKENNUM_BEYOND_STOCK(CommonConstant.DEFAULT_BIZ_ERROR_CODE,"审核中的数量已存在最大可报废数量,现提交失败"),
ORDER_NOT_EXIST(CommonConstant.DEFAULT_BIZ_ERROR_CODE,"盘点单据不存在"),
;
/**
* 错误编码
......
......@@ -26,7 +26,7 @@ import java.util.Map;
@RestController
@Slf4j
@RequestMapping("/BussinessManage")
@Api(tags = "业务管理模块")
@Api(tags = "[业务]业务管理模块")
public class BussinessController {
@Resource
public BusFormService busFormService;
......
package com.junmp.jyzb.controller;
import cn.hutool.core.util.ObjectUtil;
import com.junmp.jyzb.api.bean.dto.BussinessInventoryDto;
import com.junmp.jyzb.api.bean.query.BussinessInventoryReq;
import com.junmp.jyzb.api.bean.req.UpdateInventoryReq;
import com.junmp.jyzb.api.bean.req.UpdateStocktakeReq;
import com.junmp.jyzb.entity.BussinessInventory;
import com.junmp.jyzb.entity.InventorySummary;
import com.junmp.jyzb.service.BussinessInventoryService;
import com.junmp.jyzb.service.CabinetBoxService;
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("/BussinessInventory")
@Api(tags = "[盘点]盘点管理模块")
public class BussinessInventoryController {
@Resource
private BussinessInventoryService BussinessInventoryService;
//盘库申请
@PostMapping("/AddStocktake")
@ApiOperation("盘库申请")
public ApiRes<String> AddStocktake (@RequestBody @Validated(ValidationApi.add.class) UpdateInventoryReq req){
//判断是否有工作流id,如果有则将状态进行修改
if (ObjectUtil.isEmpty(req.getProcessDefinitionId()))
{
req.setExamineState("none");
}
else
{
req.setExamineState("working");
}
return ApiRes.success(BussinessInventoryService.AddInvOrder(req));
}
//盘库申请
@PostMapping("/Check")
@ApiOperation("预览盘点单")
public ApiRes<BussinessInventoryDto> Check (@RequestBody @Validated(ValidationApi.detail.class) BussinessInventoryReq req){
//判断是否有工作流id,如果有则将状态进行修改
return ApiRes.success(BussinessInventoryService.Check(req));
}
//盘库申请
@PostMapping("/Start")
@ApiOperation("开始盘点")
public ApiRes<Boolean> Start (@RequestBody BussinessInventoryReq req){
//判断是否有工作流id,如果有则将状态进行修改
return ApiRes.success(BussinessInventoryService.Start(req));
}
//盘库申请
@PostMapping("/GetPage")
@ApiOperation("查询列表")
public ApiRes<PageResult<BussinessInventory>> GetPage (@RequestBody BussinessInventoryReq req){
//判断是否有工作流id,如果有则将状态进行修改
return ApiRes.success(BussinessInventoryService.GetPage(req));
}
}
......@@ -19,7 +19,7 @@ import javax.annotation.Resource;
@RestController
@Slf4j
@RequestMapping("/CabinetBox")
@Api(tags = "箱门信息模块")
@Api(tags = "[基础信息]箱门信息模块")
public class CabinetBoxController {
@Resource
private CabinetBoxService cabinetBoxService;
......
......@@ -26,7 +26,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Cabinet")
@Api(tags = "单警柜基础信息模块")
@Api(tags = "[基础信息]单警柜基础信息模块")
public class CabinetController {
@Resource
public CabinetService cabinetService;
......
package com.junmp.jyzb.controller;
import cn.hutool.core.util.StrUtil;
import com.junmp.jyzb.api.bean.query.CompanyReq;
import com.junmp.jyzb.doc.CompanyDoc;
import com.junmp.jyzb.entity.Company;
import com.junmp.jyzb.service.CompanyService;
import com.junmp.v2.common.bean.request.ValidationApi;
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.db.api.page.PageResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
/**
* <pre>
*
* 描述:
* 版本:1.0.0
* 日期:2022/8/1 10:24
* 作者:ningzp@junmp.com.cn
* <br>修改记录
* <br>修改日期 修改人 修改内容
*
* </pre>
*/
@RestController
@Slf4j
@RequestMapping("/api")
public class CompanyController implements CompanyDoc {
@Resource
private CompanyService companyService;
@PostMapping(path = "/company", name = "新增企业")
@Override
public ApiRes<Boolean> addBiz(@RequestBody @Validated(CompanyReq.add.class) CompanyReq req) {
try {
companyService.addBiz(req);
return ApiRes.success();
} catch (ServiceException ex) {
log.error("企业新增异常>>" + ex.getMessage());
return ApiRes.failure(DefaultBizExceptionEnum.SYS_RUNTIME_ERROR);
}
}
@PutMapping(path = "/company", name = "编辑企业")
@Override
public ApiRes<Boolean> editBiz(@RequestBody @Validated(ValidationApi.edit.class) CompanyReq req) {
boolean flag = companyService.editBiz(req);
if (flag) {
return ApiRes.success();
} else {
return ApiRes.failure(StrUtil.format("单位编码:{},更新失败", req.getBizCode()));
}
}
@GetMapping(path = "/company", name = "企业列表")
@Override
public ApiRes<List<Company>> list(CompanyReq req) {
List<Company> list = companyService.findList(req);
return ApiRes.success(list);
}
@DeleteMapping(path = "/company", name = "删除企业")
@Override
public ApiRes<Boolean> delBiz(@RequestBody @Validated(ValidationApi.delete.class) CompanyReq req) {
boolean flag = companyService.del(req);
if (flag) {
return ApiRes.success();
} else {
return ApiRes.failure(StrUtil.format("单位编码:{},删除失败", req.getBizCode()));
}
}
@GetMapping(path = "/company/page", name = "分页企业信息")
@Override
public ApiRes<PageResult<Company>> page(CompanyReq req) {
return ApiRes.success(companyService.findPage(req));
}
}
......@@ -26,7 +26,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Size")
@Api(tags = "号型基础信息模块")
@Api(tags = "[基础信息]号型基础信息模块")
public class EquipmentSizeController {
@Resource
public EquipmentSizeService equipmentSizeService;
......
......@@ -22,7 +22,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Equipment")
@Api(tags = "物资基础信息模块")
@Api(tags = "[基础信息]物资基础信息模块")
public class EquipmentTypeController {
@Resource
public EquipmentTypeService equipmentTypeService;
......
......@@ -25,7 +25,7 @@ import java.util.*;
@RestController
@Slf4j
@RequestMapping("/Inventory")
@Api(tags = "库存模块")
@Api(tags = "[基础信息]库存模块")
public class InventoryController {
@Resource
public InventoryService inventoryService;
......
......@@ -21,7 +21,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Manufacturer")
@Api(tags = "生产厂商模块")
@Api(tags = "[基础信息]生产厂商模块")
public class ManufacturerController {
@Resource
private ManufacturerService manufacturerService;
......
......@@ -17,7 +17,7 @@ import javax.annotation.Resource;
@RestController
@Slf4j
@RequestMapping("/OrderCommon")
@Api(tags = "业务通用模块")
@Api(tags = "[业务]业务通用模块")
public class OrderCommonController {
//单子拒绝之后,需要修改当前单子的审批状态,修改为已驳回
@Resource
......
......@@ -27,7 +27,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Order")
@Api(tags = "业务模块")
@Api(tags = "[业务]业务模块")
public class OrderController {
@Resource
public OrderMainService orderMainService;
......
......@@ -32,7 +32,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/OutAndInRecords")
@Api(tags = "出入库模块")
@Api(tags = "[业务]出入库模块")
public class OutAndInboundController {
@Resource
......
......@@ -35,7 +35,7 @@ import java.util.Map;
@RestController
@Slf4j
@RequestMapping("/Police")
@Api(tags = "警员基础信息模块")
@Api(tags = "[基础信息]警员基础信息模块")
public class PoliceController {
@Resource
......
......@@ -20,7 +20,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/PolicemanFinger")
@Api(tags = "警员指纹信息模块")
@Api(tags = "[基础信息]警员指纹信息模块")
public class PolicemanFingerController implements PolicemanFingerDoc {
@Resource
......
......@@ -22,7 +22,7 @@ import java.util.Map;
@RestController
@Slf4j
@RequestMapping("/PubOrg")
@Api(tags = "组织机构模块")
@Api(tags = "[基础信息]组织机构模块")
public class PubOrgController {
@Resource
public PubOrgService pubOrgService;
......
......@@ -22,7 +22,7 @@ import java.util.List;
@RestController
@Slf4j
@Api(tags = "维修单位模块")
@Api(tags = "[业务]维修单位模块")
@RequestMapping("/RepairUnit")
public class RepairUnitController {
@Resource
......
......@@ -22,7 +22,7 @@ import javax.annotation.Resource;
@RestController
@Slf4j
@Api(tags ="盘库管理")
@Api(tags ="[盘点]盘库管理")
@RequestMapping("/Stocktake")
public class StocktakeController {
......
......@@ -23,7 +23,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Supplier")
@Api(tags = "供应商基础信息模块")
@Api(tags = "[基础信息]供应商基础信息模块")
public class SupplierController {
@Resource
public SupplierService supplierService;
......
......@@ -24,7 +24,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Tj")
@Api(tags = "统计报表模块")
@Api(tags = "[报表]统计报表模块")
public class TjController {
@Resource
......
......@@ -26,7 +26,7 @@ import java.util.List;
@RestController
@Slf4j
@RequestMapping("/Warehouse")
@Api(tags = "仓库基础信息模块")
@Api(tags = "[基础信息]仓库基础信息模块")
public class WarehouseController {
@Resource
public WarehouseService warehouseService;
......
package com.junmp.jyzb.doc;
import com.junmp.jyzb.api.bean.query.CompanyReq;
import com.junmp.jyzb.entity.Company;
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 java.util.List;
/**
* <pre>
*
* 描述:
* 版本:1.0.0
* 日期:2022/8/1 10:47
* 作者:ningzp@junmp.com.cn
* <br>修改记录
* <br>修改日期 修改人 修改内容
*
* </pre>
*/
@Api(value = "企业管理", tags = "企业管理接口")
public interface CompanyDoc {
/**
* 新增企业
*/
@ApiOperation(value = "新增企业", tags = "企业管理接口")
ApiRes<Boolean> addBiz(CompanyReq req);
/**
* 更新企业
*/
@ApiOperation(value = "更新企业", tags = "企业管理接口")
ApiRes<Boolean> editBiz(CompanyReq req);
/**
* 获取所有企业
*/
@ApiOperation(value = "获取所有企业", tags = "企业管理接口")
ApiRes<List<Company>> list(CompanyReq req);
/**
* 删除企业
*/
@ApiOperation(value = "删除企业",tags = "企业管理接口")
ApiRes<Boolean> delBiz(CompanyReq req);
/**
* 企业信息分页
*/
@ApiOperation(value = "分页企业信息", tags = "企业管理接口")
ApiRes<PageResult<Company>> page(CompanyReq req);
}
package com.junmp.jyzb.entity;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import java.io.Serializable;
import java.util.Date;
@TableName(value ="bussiness_inventory_detail")
@Data
@AllArgsConstructor
@NoArgsConstructor
@JsonIgnoreProperties(ignoreUnknown = true)
public class BussinessDetail implements Serializable {
/**
* id
*/
@TableId(value = "id")
@Id
private Long id;
/**
* 工作流id
*/
@TableField(value = "inventory_id")
private Long inventoryId;
/**
* 工作流id
*/
@TableField(value = "type_id")
private String typeId;
/**
* 单据业务类型
*/
@TableField(value = "type_name")
private String typeName;
/**
* 单据编号
*/
@TableField(value = "size_id")
private String sizeId;
/**
* 年度
*/
@TableField(value = "size_name")
private String sizeName;
/**
* 月
*/
@TableField(value = "stock_number")
private Integer stockNumber;
/**
* 申请时间
*/
@TableField(value = "fix_number")
private Integer fixNumber;
/**
* 仓库名称
*/
@TableField(value = "num")
private Integer num;
/**
* 仓库名称
*/
@TableField(value = "state")
private String state;
/**
* 创建时间
*/
@TableField(value = "create_time",fill = FieldFill.INSERT)
private Date createTime;
/**
* 更新时间
*/
@TableField(value = "update_time",fill = FieldFill.UPDATE)
private Date updateTime;
private static final long serialVersionUID = 1L;
}
\ No newline at end of file
package com.junmp.jyzb.entity;
import com.baomidou.mybatisplus.annotation.*;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
/**
*
* @TableName base_bus_form
*/
@TableName(value ="bussiness_inventory")
@Data
@AllArgsConstructor
@NoArgsConstructor
@JsonIgnoreProperties(ignoreUnknown = true)
public class BussinessInventory implements Serializable {
/**
* id
*/
@TableId(value = "id")
@Id
private String id;
/**
* 工作流id
*/
@TableField(value = "process_id")
private Long processId;
/**
* 工作流id
*/
@TableField(value = "current_assign")
private String currentAssign;
/**
* 单据编号
*/
@TableField(value = "order_num")
private String orderNum;
/**
* 年度
*/
@TableField(value = "year")
private Integer year;
/**
* 月
*/
@TableField(value = "month")
private Integer month;
/**
* 申请时间
*/
@TableField(value = "apply_time")
private Date applyTime;
/**
* 仓库名称
*/
@TableField(value = "warehouse_id")
private String warehouseId;
/**
* 仓库名称
*/
@TableField(value = "warehouse_name")
private String warehouseName;
/**
* 组织机构ID
*/
@TableField(value = "org_id")
private Long orgId;
/**
* 组织机构名称
*/
@TableField(value = "org_name")
private String orgName;
/**
* 经办人
*/
@TableField(value = "operator")
private String operator;
/**
* 盘点状态
*/
@TableField(value = "inventory_state")
private String inventoryState;
/**
*
*/
@TableField(value = "inventory_type")
private Integer inventoryType;
/**
* 类别
*/
@TableField(value = "rules")
private String rules;
/**
* 经办人id
*/
@TableField(value = "result")
private String result;
/**
* 原有epc备份
*/
@TableField(value = "epc_back")
private String epcBack;
/**
* 需要更新的epc汇总
*/
@TableField(value = "epc_update")
private String epc_update;
/**
* 归还人
*/
@TableField(value = "examine_state")
private String examineState;
/**
* 创建时间
*/
@TableField(value = "create_time",fill = FieldFill.INSERT)
private Date createTime;
/**
* 更新时间
*/
@TableField(value = "update_time",fill = FieldFill.UPDATE)
private Date updateTime;
@TableField(value = "detail_list", exist = false)
private List<BussinessDetail> detailList;
private static final long serialVersionUID = 1L;
}
\ No newline at end of file
package com.junmp.jyzb.entity;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import java.io.Serializable;
import java.util.Date;
@TableName(value ="bussiness_inventory_detail")
@Data
@AllArgsConstructor
@NoArgsConstructor
@JsonIgnoreProperties(ignoreUnknown = true)
public class InventoryDetail implements Serializable {
/**
* id
*/
@TableId(value = "id")
@Id
private Long id;
/**
* 盘点表主键
*/
@TableField(value = "inventory_id")
private Long inventoryId;
/**
* 装备类型id
*/
@TableField(value = "type_id")
private String typeId;
/**
* 装备类型名称
*/
@TableField(value = "type_name")
private String typeName;
/**
* 装备号型id
*/
@TableField(value = "size_id")
private String sizeId;
/**
* 装备号型名称
*/
@TableField(value = "size_name")
private String sizeName;
/**
* 在库数(包含报废区)
*/
@TableField(value = "stock_number")
private Integer stockNumber;
/**
* 修正后的在库数量
*/
@TableField(value = "fix_number")
private Integer fixNumber;
/**
* 差距数量
*/
@TableField(value = "num")
private Integer num;
/**
* 状态.0正常,1盈余,2亏损
*/
@TableField(value = "state")
private Integer state;
/**
* 创建时间
*/
@TableField(value = "create_time",fill = FieldFill.INSERT)
private Date createTime;
/**
* 更新时间
*/
@TableField(value = "update_time",fill = FieldFill.UPDATE)
private Date updateTime;
private static final long serialVersionUID = 1L;
}
package com.junmp.jyzb.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.junmp.jyzb.entity.BussinessDetail;
import com.junmp.jyzb.entity.BussinessInventory;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface BussinessInventoryDetailMapper extends BaseMapper<BussinessDetail> {
}
package com.junmp.jyzb.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.junmp.jyzb.entity.BusForm;
import com.junmp.jyzb.entity.BussinessInventory;
import com.junmp.jyzb.entity.CabinetBox;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
import java.util.Map;
@Mapper
public interface BussinessInventoryMapper extends BaseMapper<BussinessInventory> {
}
package com.junmp.jyzb.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.api.bean.dto.BussinessInventoryDto;
import com.junmp.jyzb.api.bean.query.BussinessInventoryReq;
import com.junmp.jyzb.api.bean.req.UpdateInventoryReq;
import com.junmp.jyzb.entity.BussinessDetail;
import com.junmp.jyzb.entity.BussinessInventory;
import com.sun.org.apache.xpath.internal.operations.Bool;
public interface BussinessInventoryDetailService extends IService<BussinessDetail> {
}
\ No newline at end of file
package com.junmp.jyzb.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.api.bean.dto.BusFormDto;
import com.junmp.jyzb.api.bean.dto.BussinessInventoryDto;
import com.junmp.jyzb.api.bean.query.BussinessInventoryReq;
import com.junmp.jyzb.api.bean.query.QueryBusFormReq;
import com.junmp.jyzb.api.bean.req.UpdateBusFormReq;
import com.junmp.jyzb.api.bean.req.UpdateInventoryReq;
import com.junmp.jyzb.api.bean.req.UpdateStocktakeReq;
import com.junmp.jyzb.entity.BusForm;
import com.junmp.jyzb.entity.BussinessInventory;
import com.junmp.v2.db.api.page.PageResult;
import com.sun.org.apache.xpath.internal.operations.Bool;
import java.util.List;
public interface BussinessInventoryService extends IService<BussinessInventory> {
String AddInvOrder(UpdateInventoryReq req);
BussinessInventoryDto Check(BussinessInventoryReq req);
Boolean Start(BussinessInventoryReq req);
PageResult<BussinessInventory> GetPage(BussinessInventoryReq req);
}
package com.junmp.jyzb.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.junmp.jyzb.api.bean.query.CompanyReq;
import com.junmp.jyzb.entity.Company;
import com.junmp.v2.db.api.page.PageResult;
import java.util.List;
/**
* <pre>
*
* 描述:
* 版本:1.0.0
* 日期:2022/8/1 09:35
* 作者:ningzp@junmp.com.cn
* <br>修改记录
* <br>修改日期 修改人 修改内容
*
* </pre>
*/
public interface CompanyService extends IService<Company> {
/**
* 新增
*
* @param req
*/
boolean addBiz(CompanyReq req);
/**
* 编辑
*
* @param req
*/
boolean editBiz(CompanyReq req);
/**
* 删除
*
* @param req
*/
boolean del(CompanyReq req);
/**
* 列表信息
*
* @param req
*/
List<Company> findList(CompanyReq req);
/**
* 分页信息
*
* @param req
*/
PageResult<Company> findPage(CompanyReq req);
}
......@@ -23,7 +23,7 @@ public interface InventorySummaryService extends IService<InventorySummary> {
//根据条件查询库存汇总信息
PageResult<InventorySummary> getEquipmentInfo(InventorySumReq req);
List<InventorySummary> getEquipmentInfoList(InventorySumReq req);
//根据条件查询装备汇总信息,用于出库单的选择装备
List<InventorySumDto> GetInventorySumInfo(InventorySumReq req);
......
package com.junmp.jyzb.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.jyzb.entity.BussinessDetail;
import com.junmp.jyzb.entity.BussinessInventory;
import com.junmp.jyzb.mapper.BussinessInventoryDetailMapper;
import com.junmp.jyzb.mapper.BussinessInventoryMapper;
import com.junmp.jyzb.service.BussinessInventoryDetailService;
import com.junmp.jyzb.service.BussinessInventoryService;
import org.springframework.stereotype.Service;
@Service
public class BussinessInventoryDetailServiceImpl extends ServiceImpl<BussinessInventoryDetailMapper, BussinessDetail>
implements BussinessInventoryDetailService {
}
package com.junmp.jyzb.service.impl;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.druid.sql.dialect.oracle.ast.stmt.OracleCreateTableStatement;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.junmp.junmpProcess.dto.StartProcessInstanceDTO;
import com.junmp.junmpProcess.service.IFlowInstanceService;
import com.junmp.jyzb.api.bean.dto.BussinessInventoryDto;
import com.junmp.jyzb.api.bean.dto.CabinetDto;
import com.junmp.jyzb.api.bean.dto.EquipmentListDto;
import com.junmp.jyzb.api.bean.dto.OrderMainDto;
import com.junmp.jyzb.api.bean.query.BussinessInventoryReq;
import com.junmp.jyzb.api.bean.query.InventorySumReq;
import com.junmp.jyzb.api.bean.req.UpdateInventoryReq;
import com.junmp.jyzb.api.bean.req.UpdateStocktakeReq;
import com.junmp.jyzb.api.exception.enums.EquipmentExceptionEnum;
import com.junmp.jyzb.api.exception.enums.InventoryExceptionEnum;
import com.junmp.jyzb.entity.*;
import com.junmp.jyzb.mapper.BussinessInventoryDetailMapper;
import com.junmp.jyzb.mapper.BussinessInventoryMapper;
import com.junmp.jyzb.mapper.CabinetBoxPoliceMapper;
import com.junmp.jyzb.service.*;
import com.junmp.jyzb.utils.DateTimeUtil;
import com.junmp.jyzb.utils.RabbitMQSendMsg;
import com.junmp.v2.common.exception.base.ServiceException;
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 com.junmp.v2.dict.entity.SysDict;
import com.junmp.v2.dict.entity.SysDictItem;
import com.junmp.v2.dict.service.SysDictItemService;
import com.junmp.v2.dict.service.SysDictService;
import com.junmp.v2.sys.api.OrganizationServiceApi;
import com.sun.org.apache.xpath.internal.operations.Bool;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.beans.Transient;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
@Service
public class BussinessInventoryServiceImpl extends ServiceImpl<BussinessInventoryMapper, BussinessInventory>
implements BussinessInventoryService {
@Resource
private IFlowInstanceService FlowInstanceService;
@Resource
private SysDictItemService sysDictItemService;
@Resource
private SysDictService sysDictService;
@Resource
private BussinessInventoryDetailService bussinessInventoryDetailService;
@Resource
private WarehouseService warehouseService;
@Resource
private PubOrgService orgService;
@Resource
private InventorySummaryService inventorySummaryService;
@Resource
private OrderNumService orderNumService;
@Autowired
private RabbitMQSendMsg MQ;
@Transactional(rollbackFor = Exception.class)
public String AddInvOrder(UpdateInventoryReq req) {
if (StringUtils.isNotBlank(req.getId()))
{
BussinessInventory BI=this.getById(req.getId());
Warehouse warehouse= warehouseService.getById(req.getWarehouseId());
PubOrg pubOrg=orgService.getById(req.getOrgId());
BeanPlusUtil.copyProperties(req,BI);
BI.setWarehouseName(warehouse.getName());
if (StringUtils.isNotBlank(pubOrg.getDName()) )
{
BI.setOrgName(pubOrg.getOrgName());
}
else
{
BI.setOrgName(pubOrg.getDName());
}
BI.setUpdateTime(DateTimeUtil.getCurrentDateTime());
//执行工作流
if (req.getExamineState().equals("working"))
{
StartProcessInstanceDTO startProcessInstanceDTO=new StartProcessInstanceDTO();
startProcessInstanceDTO.setProcessDefinitionId(req.getProcessDefinitionId());
startProcessInstanceDTO.setOrderId(BI.getId());
startProcessInstanceDTO.setOrderType("stocktakeOrder");
String ProcessInstanceId= FlowInstanceService.startProcessInstanceById(startProcessInstanceDTO);
BI.setProcessId(Long.valueOf(ProcessInstanceId));
String assigns= FlowInstanceService.GetNextAssign(ProcessInstanceId);//这里需要手动更新审核人信息
BI.setCurrentAssign(assigns);
updateById(BI);
}
this.save(BI);
return BI.getId();
}
else
{ BussinessInventory BI = new BussinessInventory();
Warehouse warehouse= warehouseService.getById(req.getWarehouseId());
PubOrg pubOrg=orgService.getById(req.getOrgId());
BeanPlusUtil.copyProperties(req,BI);
BI.setWarehouseName(warehouse.getName());
//设置单号
if (ObjectUtil.isNull(pubOrg.getDName()) )
{
BI.setOrgName(pubOrg.getOrgName());
}
else
{
BI.setOrgName(pubOrg.getDName());
}
BI.setYear(LocalDate.now().getYear());
BI.setMonth(Integer.valueOf(LocalDate.now().getMonthValue()));
OrderNum orderNum = setOrderCode("bussinessInventory",req.getOrgId());
String codeValue=String.format("%04d",orderNum.getNum());
BI.setOrderNum(orderNum.getBussinessType()+orderNum.getYear()+
String.format("%02d", LocalDateTime.now().getMonth().getValue())+
String.format("%02d",LocalDateTime.now().getDayOfMonth())+codeValue);
BI.setCreateTime(DateTimeUtil.getCurrentDateTime());
BI.setUpdateTime(DateTimeUtil.getCurrentDateTime());
BI.setInventoryState("waitting");
//执行工作流
if (req.getExamineState().equals("working"))
{
StartProcessInstanceDTO startProcessInstanceDTO=new StartProcessInstanceDTO();
startProcessInstanceDTO.setProcessDefinitionId(req.getProcessDefinitionId());
startProcessInstanceDTO.setOrderId(BI.getId());
startProcessInstanceDTO.setOrderType("stocktakeOrder");
// startProcessInstanceDTO.setUserId(req.getUserId());
String ProcessInstanceId= FlowInstanceService.startProcessInstanceById(startProcessInstanceDTO);
BI.setProcessId(Long.valueOf(ProcessInstanceId));
String assigns= FlowInstanceService.GetNextAssign(ProcessInstanceId);//这里需要手动更新审核人信息
BI.setCurrentAssign(assigns);
updateById(BI);
}
this.save(BI);
return BI.getId();}
}
@Override
public BussinessInventoryDto Check(BussinessInventoryReq req) {
String Id=req.getOrderId();
if (StringUtils.isNotBlank(Id))//如果传了订单号,则全部通过订单号查询
{
BussinessInventory inventory= this.getById(Id);
String type=inventory.getInventoryType().toString();
String warehouseId=inventory.getWarehouseId();
InventorySumReq sumreq=new InventorySumReq();
sumreq.setLocationType("0");
sumreq.setLocationId(warehouseId);
BussinessInventoryDto BIDto=new BussinessInventoryDto();
if (type.equals("1"))//按装备类型盘点
{
List<String> typeIds = Arrays.asList(req.getTypeList().split(","));
sumreq.setTypeIds(typeIds);
} else if (type.equals("2"))//按装备号型盘点
{
List<String> sizeIds = Arrays.asList(req.getTypeList().split(","));
sumreq.setSizeIds(sizeIds);
}
List<EquipmentListDto> eqList=new ArrayList<>();
Integer totalNumber=0;
List<InventorySummary> SumResult = inventorySummaryService.getEquipmentInfoList(sumreq);
for (InventorySummary summary : SumResult) {
EquipmentListDto eq=new EquipmentListDto();
BeanPlusUtil.copyProperties(summary,eq);
eq.setPlanNum(String.valueOf(summary.getStockNumber()));
totalNumber+=summary.getStockNumber();
eqList.add(eq);
}
BIDto.setTotalNum(String.valueOf(totalNumber));
BIDto.setEquipmentList(eqList);
return BIDto;
}
String type=req.getType();
String warehouseId=req.getWarehouseId();
InventorySumReq sumreq=new InventorySumReq();
sumreq.setLocationType("0");
sumreq.setLocationId(warehouseId);
BussinessInventoryDto BIDto=new BussinessInventoryDto();
if (ObjectUtil.isEmpty(type) || ObjectUtil.isNull(type)) {
}
else {
if (type.equals("1"))//按装备类型盘点
{
List<String> typeIds = Arrays.asList(req.getTypeList().split(","));
sumreq.setTypeIds(typeIds);
} else if (type.equals("2"))//按装备号型盘点
{
List<String> sizeIds = Arrays.asList(req.getTypeList().split(","));
sumreq.setSizeIds(sizeIds);
}
}
List<EquipmentListDto> eqList=new ArrayList<>();
Integer totalNumber=0;
List<InventorySummary> SumResult = inventorySummaryService.getEquipmentInfoList(sumreq);
for (InventorySummary summary : SumResult) {
EquipmentListDto eq=new EquipmentListDto();
BeanPlusUtil.copyProperties(summary,eq);
eq.setPlanNum(String.valueOf(summary.getStockNumber()));
totalNumber+=summary.getStockNumber();
eqList.add(eq);
}
BIDto.setTotalNum(String.valueOf(totalNumber));
BIDto.setEquipmentList(eqList);
return BIDto;
}
//开始盘点
@Transactional(rollbackFor = Exception.class)
@Override
public Boolean Start(BussinessInventoryReq req) {
String orderId=req.getOrderId();
BussinessInventory bi= this.getById(orderId);
if (bi!=null)
{
List<BussinessDetail> details = bussinessInventoryDetailService.list(
new LambdaQueryWrapper<BussinessDetail>().eq(BussinessDetail::getInventoryId, bi.getId())
);
bi.setDetailList(details);
Warehouse warehouseSet= warehouseService.getById(bi.getWarehouseId());//先锁库,再下发盘点
warehouseSet.setIsLocked(true);
bi.setInventoryState("running");
MQ.SendMsg("BussinessInv",warehouseSet.getOrgId().toString(),bi);
}
else
{
throw new ServiceException(InventoryExceptionEnum.ORDER_NOT_EXIST);
}
return true;
}
@Override
public PageResult<BussinessInventory> GetPage(BussinessInventoryReq req) {
//排序字段处理,将驼峰改成和数据库同步的字段名(如果传其他不是数据库字段参数或者排序规则不是deac或者asc可能会出现错误)
if (ObjectUtil.isNotNull(req.getColumn()) && !req.getColumn().trim().isEmpty() &&
(req.getOrder().equalsIgnoreCase("asc")|| req.getOrder().equalsIgnoreCase("desc")) &&
ObjectUtil.isNotNull(req.getOrder()) &&!req.getOrder().trim().isEmpty()) {
//修改字段,和数据库字段进行统一
req.setColumn(req.getColumn().replaceAll("[A-Z]", "_$0").toLowerCase());
req.setOrder(req.getOrder().toLowerCase());
}
LambdaQueryWrapper<BussinessInventory> wrapper = createWrapper(req);
// 使用 PageHelper 开始分页
// Page<BussinessInventory> page = PageFactory.getDefaultPage(Long.parseLong(req.getPageNo()),Long.parseLong(req.getPageSize()));
Page<BussinessInventory> page = this.page(PageFactory.getDefaultPage(), wrapper);
return PageResultFactory.createPageResult(page);
}
/**
* 设置单据单号
* 通用方法,根据组织机构id以及业务单据类型来进行设置
* @param
*/
public OrderNum setOrderCode(String bussinessType,Long orgId){
//设置采购单号,需要先判断该组织机构的采购单号是否存在,如果存在则将数量进行增加,如果不存在则新增一条对应的数据
OrderNum orderNum = new OrderNum();
orderNum.setYear(LocalDateTime.now().getYear());
orderNum.setBussinessType(bussinessType);
orderNum.setOrgId(orgId);
//将业务类型转为中文简写
Long sysDictId = sysDictService.getOne(new LambdaQueryWrapper<SysDict>()
.eq(SysDict::getDictCode, "busstype_chinese")).getDictId();
String itemValue = sysDictItemService.getOne(new LambdaQueryWrapper<SysDictItem>()
.eq(SysDictItem::getItemText, bussinessType)
.eq(SysDictItem::getDictId,sysDictId)).getItemValue();
orderNum.setBussinessType(itemValue);
OrderNum one = orderNumService.getOne(new LambdaQueryWrapper<OrderNum>()
.eq(OrderNum::getOrgId, orderNum.getOrgId())
.eq(OrderNum::getBussinessType, orderNum.getBussinessType())
.eq(OrderNum::getYear, orderNum.getYear()));
//设置num的数量
if (ObjectUtil.isNull(one)){
orderNum.setNum(1);
orderNumService.save(orderNum);
return orderNum;
}else {
one.setNum(one.getNum()+1);
orderNumService.updateById(one);
return one;
}
}
private LambdaQueryWrapper<BussinessInventory> createWrapper(BussinessInventoryReq req) {
LambdaQueryWrapper<BussinessInventory> wrapper = new LambdaQueryWrapper<>();
if (ObjectUtil.isEmpty(req)) {
return wrapper;
}
wrapper.eq(BussinessInventory::getOrgId, req.getOrgId());
wrapper.eq(StringUtils.isNotBlank(req.getWarehouseId()), BussinessInventory::getWarehouseId, req.getWarehouseId());
wrapper.eq(StringUtils.isNotBlank(req.getInventoryState()), BussinessInventory::getInventoryState, req.getInventoryState());
wrapper.eq(StringUtils.isNotBlank(req.getExamineState()), BussinessInventory::getExamineState, req.getExamineState());
wrapper.eq(StringUtils.isNotBlank(req.getInventoryType()), BussinessInventory::getInventoryType, req.getInventoryType());
return wrapper;
}
}
\ No newline at end of file
package com.junmp.jyzb.service.impl;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
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.CompanyReq;
import com.junmp.jyzb.api.exception.enums.CompanyExceptionEnum;
import com.junmp.jyzb.api.util.GenCodeUtil;
import com.junmp.jyzb.entity.Company;
import com.junmp.jyzb.mapper.CompanyMapper;
import com.junmp.jyzb.service.CompanyService;
import com.junmp.v2.common.exception.base.ServiceException;
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 lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* <pre>
*
* 描述:
* 版本:1.0.0
* 日期:2022/8/1 09:35
* 作者:ningzp@junmp.com.cn
* <br>修改记录
* <br>修改日期 修改人 修改内容
*
* </pre>
*/
@Slf4j
@Service
public class CompanyServiceImpl extends ServiceImpl<CompanyMapper, Company> implements CompanyService {
@Override
public boolean addBiz(CompanyReq req) {
Company company = new Company();
BeanPlusUtil.copyProperties(req, company);
Integer maxSn = baseMapper.getMaxSn();
//1-获取当前序号
Integer sn = maxSn + 1;
company.setSn(sn);
//2-获取当前编码
String bizCode = GenCodeUtil.genBizCode(sn);
company.setBizCode(bizCode);
return this.save(company);
}
@Override
public boolean editBiz(CompanyReq req) {
Company company = queryCompany(req);
BeanPlusUtil.copyProperties(req, company);
return this.updateById(company);
}
@Override
public boolean del(CompanyReq req) {
Company entity = queryCompany(req);
if (ObjectUtil.isNull(entity)) {
log.warn(StrUtil.format("企业信息不存在,企业编号为:{}", req.getBizId()));
return false;
} else {
return this.removeById(entity.getBizId());
}
}
@Override
public List<Company> findList(CompanyReq req) {
LambdaQueryWrapper<Company> wrapper = createWrapper(req);
return this.list(wrapper);
}
@Override
public PageResult<Company> findPage(CompanyReq req) {
LambdaQueryWrapper<Company> wrapper = createWrapper(req);
Page<Company> page = this.page(PageFactory.getDefaultPage(req.getPageNo(),req.getPageSize()), wrapper);
return PageResultFactory.createPageResult(page);
}
private Company queryCompany(CompanyReq req) {
Company app = this.getById(req.getBizId());
if (ObjectUtil.isNull(app)) {
throw new ServiceException(CompanyExceptionEnum.COMPANY_NOT_EXIST);
}
return app;
}
private LambdaQueryWrapper<Company> createWrapper(CompanyReq req) {
LambdaQueryWrapper<Company> wrapper = new LambdaQueryWrapper<>();
if (ObjectUtil.isEmpty(req)) {
return wrapper;
}
//根据业务编码查询
wrapper.like(ObjectUtil.isNotEmpty(req.getBizCode()), Company::getBizCode, req.getBizCode());
//根据企业名称模糊查询
wrapper.like(ObjectUtil.isNotEmpty(req.getName()), Company::getName, req.getName());
wrapper.orderByDesc(Company::getCreateTime);
return wrapper;
}
}
......@@ -116,6 +116,22 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa
return PageResultFactory.createPageResult(page);
}
@Override
public List<InventorySummary> getEquipmentInfoList(InventorySumReq req) {
//当没有参数传递的时候默认查询全部,但是如果传递了条件,根据条件查询并且如果是根据id进行查询,则需要判断该id是否存在
//(如果传其他不是数据库字段参数或者排序规则不是deac或者asc可能会出现错误)
if (ObjectUtil.isNotNull(req.getColumn()) && !req.getColumn().trim().isEmpty() &&
(req.getOrder().equalsIgnoreCase("asc")|| req.getOrder().equalsIgnoreCase("desc")) &&
ObjectUtil.isNotNull(req.getOrder()) && !req.getOrder().trim().isEmpty()) {
//修改字段,和数据库字段进行统一
req.setColumn(req.getColumn().replaceAll("[A-Z]", "_$0").toLowerCase());
req.setOrder(req.getOrder().toLowerCase());
}
LambdaQueryWrapper<InventorySummary> wp = createWrapper(req);//取出仓库中总数并计算
return list(wp);
}
/**
* 用于出库单中的装备选择
* @return
......@@ -421,6 +437,10 @@ public class InventorySummaryServiceImpl extends ServiceImpl<InventorySummaryMa
wrapper.and(qw -> req.typeIds.forEach(typeId -> qw.or().eq(InventorySummary::getTypeId, typeId)));
}
//根据类别
if (ObjectUtil.isNotEmpty(req.sizeIds) && req.sizeIds.size()>0) {
wrapper.and(qw -> req.sizeIds.forEach(sizeId -> qw.or().eq(InventorySummary::getSizeId, sizeId)));
}
//根据类别
if (ObjectUtil.isNotEmpty(req.getSizeNames()) && req.getSizeNames().size()>0) {
wrapper.and(qw -> req.getSizeNames().forEach(sizeName -> qw.or().eq(InventorySummary::getSizeName, sizeName)));
}
......
......@@ -93,6 +93,42 @@ public class StocktakeServiceImpl extends ServiceImpl<StocktakeMapper, Stocktake
return stocktake.getId();
}
@Override
@Transactional(rollbackFor = Exception.class)
public String AddInvOrder(UpdateStocktakeReq req) {
Stocktake stocktake = new Stocktake();
BeanPlusUtil.copyProperties(req,stocktake);
//设置单号
if (ObjectUtil.isNull(stocktake.getOrderCode())){
OrderNum orderNum = setOrderCode(req.getBussinessType(),req.getOrgId());
String codeValue=String.format("%04d",orderNum.getNum());
stocktake.setOrderCode(orderNum.getBussinessType()+orderNum.getYear()+
String.format("%02d",LocalDateTime.now().getMonth().getValue())+
String.format("%02d",LocalDateTime.now().getDayOfMonth())+codeValue);
}
stocktake.setCreateTime(DateTimeUtil.getCurrentDateTime());
stocktake.setApplyTime(DateTimeUtil.getCurrentDateTime());
//执行工作流
if (req.getExamineState().equals("working"))
{
StartProcessInstanceDTO startProcessInstanceDTO=new StartProcessInstanceDTO();
startProcessInstanceDTO.setProcessDefinitionId(req.getProcessDefinitionId());
startProcessInstanceDTO.setOrderId(stocktake.getId());
startProcessInstanceDTO.setOrderType("stocktakeOrder");
startProcessInstanceDTO.setUserId(req.getUserId());
String ProcessInstanceId= FlowInstanceService.startProcessInstanceById(startProcessInstanceDTO);
stocktake.setProcessId(ProcessInstanceId);
String assigns= FlowInstanceService.GetNextAssign(ProcessInstanceId);//这里需要手动更新审核人信息
stocktake.setCurrentAssign(assigns);
updateById(stocktake);
}
this.save(stocktake);
return stocktake.getId();
}
//盘库单据查询
@Override
public PageResult<Stocktake> ShowStocktakeOrderPage(StocktakeReq req) {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论