Browse Source

flowable集成完成,采购申请流程的测试

master
djz8236 2 years ago
parent
commit
839bcb62c3
  1. 13
      yxt_supervise/supervise-system/supervise-system-biz/src/main/java/com/yxt/supervise/system/purchasingrequisition/PurchasingRequisitionService.java

13
yxt_supervise/supervise-system/supervise-system-biz/src/main/java/com/yxt/supervise/system/purchasingrequisition/PurchasingRequisitionService.java

@ -3,6 +3,7 @@ package com.yxt.supervise.system.purchasingrequisition;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.google.common.util.concurrent.ThreadFactoryBuilder; import com.google.common.util.concurrent.ThreadFactoryBuilder;
@ -26,6 +27,7 @@ import com.yxt.supervise.system.region.RegionListVo;
import com.yxt.supervise.system.sysstaffinfo.SysStaffinfoService; import com.yxt.supervise.system.sysstaffinfo.SysStaffinfoService;
import com.yxt.supervise.system.sysuser.SysUserService; import com.yxt.supervise.system.sysuser.SysUserService;
import com.yxt.supervise.system.sysuser.SysUserVo; import com.yxt.supervise.system.sysuser.SysUserVo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.apache.tomcat.util.threads.ThreadPoolExecutor; import org.apache.tomcat.util.threads.ThreadPoolExecutor;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -40,6 +42,7 @@ import java.util.stream.Collectors;
* @Date 2023/1/30 14:24 * @Date 2023/1/30 14:24
* @Description * @Description
*/ */
@Slf4j
@Service @Service
public class PurchasingRequisitionService extends MybatisBaseService<PurchasingRequisitionMapper, PurchasingRequisition> { public class PurchasingRequisitionService extends MybatisBaseService<PurchasingRequisitionMapper, PurchasingRequisition> {
@ -89,7 +92,7 @@ public class PurchasingRequisitionService extends MybatisBaseService<PurchasingR
BeanUtil.copyProperties(dto, productInformation, "sid"); BeanUtil.copyProperties(dto, productInformation, "sid");
baseMapper.updateById(productInformation); baseMapper.updateById(productInformation);
} }
if (StringUtils.isBlank(sid)&&StringUtils.isBlank(taskid)) { if (StringUtils.isBlank(taskid)) {
startProcess(dto); startProcess(dto);
} else { } else {
PurchasingRequisition pr = fetchBySid(sid); PurchasingRequisition pr = fetchBySid(sid);
@ -141,6 +144,7 @@ public class PurchasingRequisitionService extends MybatisBaseService<PurchasingR
bv.setModelId(ProcDefEnum.PR.getProDefId()); bv.setModelId(ProcDefEnum.PR.getProDefId());
// String nextNodeUserSids_ = "0331e5b5-9d60-11ed-87ce-525401028fe8";//sysOrganization.getManagerSid(); // String nextNodeUserSids_ = "0331e5b5-9d60-11ed-87ce-525401028fe8";//sysOrganization.getManagerSid();
// bv.setNextNodeUserSids(nextNodeUserSids_); // bv.setNextNodeUserSids(nextNodeUserSids_);
int r = submitBusinessVehicleData(dto); int r = submitBusinessVehicleData(dto);
if (r == 1) { if (r == 1) {
ResultBean<UpdateFlowFieldVo> voResultBean = flowableFeign.startProcess(bv); ResultBean<UpdateFlowFieldVo> voResultBean = flowableFeign.startProcess(bv);
@ -175,11 +179,16 @@ public class PurchasingRequisitionService extends MybatisBaseService<PurchasingR
* @return * @return
*/ */
private synchronized int submitBusinessVehicleData(PurchasingRequisitionDto dto ) { private synchronized int submitBusinessVehicleData(PurchasingRequisitionDto dto ) {
log.info("PurchasingRequisitionDto:{}", JSONObject.toJSONString(dto));
int r = 0; int r = 0;
if (StringUtils.isBlank(dto.getSid())&&StringUtils.isBlank(dto.getTaskId())) { if (StringUtils.isBlank(dto.getSid())&&StringUtils.isBlank(dto.getTaskId())) {
log.info("PurchasingRequisitionDto1:{}", JSONObject.toJSONString(dto));
r = 1;
}else if (StringUtils.isNotBlank(dto.getSid())&&StringUtils.isBlank(dto.getTaskId())){
log.info("PurchasingRequisitionDto2:{}", JSONObject.toJSONString(dto));
r = 1; r = 1;
} else { } else {
//二次提交//只有数据一致的时候才能进行下一步 log.info("PurchasingRequisitionDto3:{}", JSONObject.toJSONString(dto));
r = 2; r = 2;
} }
return r; return r;

Loading…
Cancel
Save