|
@ -49,6 +49,8 @@ import com.yxt.anrui.scm.api.scmvehrebatecheckapply.flow.SubmitScmVehRebateCheck |
|
|
import com.yxt.anrui.scm.api.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetail; |
|
|
import com.yxt.anrui.scm.api.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetail; |
|
|
import com.yxt.anrui.scm.api.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetailDetailsVo; |
|
|
import com.yxt.anrui.scm.api.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetailDetailsVo; |
|
|
import com.yxt.anrui.scm.api.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetailDto; |
|
|
import com.yxt.anrui.scm.api.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetailDto; |
|
|
|
|
|
import com.yxt.anrui.scm.api.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetailVo; |
|
|
|
|
|
import com.yxt.anrui.scm.biz.scmvehrebate.ScmVehRebateService; |
|
|
import com.yxt.anrui.scm.biz.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetailService; |
|
|
import com.yxt.anrui.scm.biz.scmvehrebatecheckapplydetail.ScmVehrebateCheckapplydetailService; |
|
|
import com.yxt.common.core.result.ResultBean; |
|
|
import com.yxt.common.core.result.ResultBean; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
import org.apache.commons.lang3.StringUtils; |
|
@ -87,6 +89,8 @@ public class ScmVehrebateCheckapplyService extends MybatisBaseService<ScmVehreba |
|
|
@Autowired |
|
|
@Autowired |
|
|
ScmVehrebateCheckapplydetailService scmVehrebateCheckapplydetailService; |
|
|
ScmVehrebateCheckapplydetailService scmVehrebateCheckapplydetailService; |
|
|
@Autowired |
|
|
@Autowired |
|
|
|
|
|
private ScmVehRebateService scmVehRebateService; |
|
|
|
|
|
@Autowired |
|
|
private SysStaffOrgFeign sysStaffOrgFeign; |
|
|
private SysStaffOrgFeign sysStaffOrgFeign; |
|
|
@Autowired |
|
|
@Autowired |
|
|
private FlowableFeign flowableFeign; |
|
|
private FlowableFeign flowableFeign; |
|
@ -364,10 +368,15 @@ public class ScmVehrebateCheckapplyService extends MybatisBaseService<ScmVehreba |
|
|
bv.setFormVariables(variables); |
|
|
bv.setFormVariables(variables); |
|
|
//流程定义id
|
|
|
//流程定义id
|
|
|
bv.setModelId(ProcDefEnum.SCMVEHREBATECHECKAPPLY.getProDefId()); |
|
|
bv.setModelId(ProcDefEnum.SCMVEHREBATECHECKAPPLY.getProDefId()); |
|
|
|
|
|
//查询单车明细
|
|
|
|
|
|
List<ScmVehrebateCheckapplydetailVo> scmVehrebateCheckapplydetailVos = scmVehrebateCheckapplydetailService.selByMainSid(dto.getSid()); |
|
|
if (r == 1) { |
|
|
if (r == 1) { |
|
|
ResultBean<UpdateFlowFieldVo> voResultBean = flowFeign.startProcess(bv); |
|
|
ResultBean<UpdateFlowFieldVo> voResultBean = flowFeign.startProcess(bv); |
|
|
UpdateFlowFieldVo ufVo = voResultBean.getData(); |
|
|
UpdateFlowFieldVo ufVo = voResultBean.getData(); |
|
|
updateFlowFiled(BeanUtil.beanToMap(ufVo)); |
|
|
updateFlowFiled(BeanUtil.beanToMap(ufVo)); |
|
|
|
|
|
for (ScmVehrebateCheckapplydetailVo scmVehrebateCheckapplydetailVo : scmVehrebateCheckapplydetailVos) { |
|
|
|
|
|
scmVehRebateService.updateAdjustmentState(2,scmVehrebateCheckapplydetailVo.getVehRebateSid()); |
|
|
|
|
|
} |
|
|
return voResultBean; |
|
|
return voResultBean; |
|
|
} |
|
|
} |
|
|
if (r == 2) { |
|
|
if (r == 2) { |
|
@ -379,6 +388,9 @@ public class ScmVehrebateCheckapplyService extends MybatisBaseService<ScmVehreba |
|
|
bv.setTaskDefKey(scmVehrebateCheckapply.getNodeSid()); |
|
|
bv.setTaskDefKey(scmVehrebateCheckapply.getNodeSid()); |
|
|
bv.setComment(StringUtils.isNotBlank(dto.getComment()) ? dto.getComment() : "重新提交"); |
|
|
bv.setComment(StringUtils.isNotBlank(dto.getComment()) ? dto.getComment() : "重新提交"); |
|
|
bv.setInstanceId(dto.getInstanceId()); |
|
|
bv.setInstanceId(dto.getInstanceId()); |
|
|
|
|
|
for (ScmVehrebateCheckapplydetailVo scmVehrebateCheckapplydetailVo : scmVehrebateCheckapplydetailVos) { |
|
|
|
|
|
scmVehRebateService.updateAdjustmentState(2,scmVehrebateCheckapplydetailVo.getVehRebateSid()); |
|
|
|
|
|
} |
|
|
return complete(bv); |
|
|
return complete(bv); |
|
|
} |
|
|
} |
|
|
return rb; |
|
|
return rb; |
|
@ -426,6 +438,10 @@ public class ScmVehrebateCheckapplyService extends MybatisBaseService<ScmVehreba |
|
|
} |
|
|
} |
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
if ("Event_end".equals(resultBean.getData().getTaskDefKey())) { |
|
|
if ("Event_end".equals(resultBean.getData().getTaskDefKey())) { |
|
|
|
|
|
List<ScmVehrebateCheckapplydetailVo> scmVehrebateCheckapplydetailVos = scmVehrebateCheckapplydetailService.selByMainSid(bv.getBusinessSid()); |
|
|
|
|
|
for (ScmVehrebateCheckapplydetailVo scmVehrebateCheckapplydetailVo : scmVehrebateCheckapplydetailVos) { |
|
|
|
|
|
scmVehRebateService.updateAdjustmentState(3,scmVehrebateCheckapplydetailVo.getVehRebateSid()); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
return rb.success().setData(resultBean.getData()); |
|
|
return rb.success().setData(resultBean.getData()); |
|
|
} else { |
|
|
} else { |
|
@ -491,17 +507,38 @@ public class ScmVehrebateCheckapplyService extends MybatisBaseService<ScmVehreba |
|
|
} |
|
|
} |
|
|
ScmVehrebateCheckapply scmVehrebateCheckapply = fetchBySid(query.getBusinessSid()); |
|
|
ScmVehrebateCheckapply scmVehrebateCheckapply = fetchBySid(query.getBusinessSid()); |
|
|
String businessTaskId = scmVehrebateCheckapply.getTaskId(); |
|
|
String businessTaskId = scmVehrebateCheckapply.getTaskId(); |
|
|
|
|
|
List<ScmVehrebateCheckapplydetailVo> scmVehrebateCheckapplydetailVos = scmVehrebateCheckapplydetailService.selByMainSid(query.getBusinessSid()); |
|
|
if (StringUtils.isNotBlank(businessTaskId)) { |
|
|
if (StringUtils.isNotBlank(businessTaskId)) { |
|
|
if (businessTaskId.equals(query.getTaskId())) { |
|
|
if (query.getUserSid().equals(scmVehrebateCheckapply.getCreateBySid())) { |
|
|
com.yxt.anrui.flowable.api.flowtask.FlowTaskVo flowTaskVo = new com.yxt.anrui.flowable.api.flowtask.FlowTaskVo(); |
|
|
com.yxt.anrui.flowable.api.flowtask.FlowTaskVo flowTaskVo = new com.yxt.anrui.flowable.api.flowtask.FlowTaskVo(); |
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.breakProcess(flowTaskVo); |
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.breakProcess(flowTaskVo); |
|
|
if (!resultBean.getSuccess()) { |
|
|
if (!resultBean.getSuccess()) { |
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
} |
|
|
} |
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
Map<String, Object> map = BeanUtil.beanToMap(resultBean.getData()); |
|
|
|
|
|
updateFlowFiled(map); |
|
|
|
|
|
for (ScmVehrebateCheckapplydetailVo scmVehrebateCheckapplydetailVo : scmVehrebateCheckapplydetailVos) { |
|
|
|
|
|
scmVehRebateService.updateAdjustmentState(1,scmVehrebateCheckapplydetailVo.getVehRebateSid()); |
|
|
|
|
|
} |
|
|
return rb.success().setData(resultBean.getData()); |
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
|
|
} else { |
|
|
|
|
|
if (businessTaskId.equals(query.getTaskId())) { |
|
|
|
|
|
com.yxt.anrui.flowable.api.flowtask.FlowTaskVo flowTaskVo = new com.yxt.anrui.flowable.api.flowtask.FlowTaskVo(); |
|
|
|
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.breakProcess(flowTaskVo); |
|
|
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
|
|
} |
|
|
|
|
|
Map<String, Object> map = BeanUtil.beanToMap(resultBean.getData()); |
|
|
|
|
|
updateFlowFiled(map); |
|
|
|
|
|
for (ScmVehrebateCheckapplydetailVo scmVehrebateCheckapplydetailVo : scmVehrebateCheckapplydetailVos) { |
|
|
|
|
|
scmVehRebateService.updateAdjustmentState(1,scmVehrebateCheckapplydetailVo.getVehRebateSid()); |
|
|
|
|
|
} |
|
|
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
return rb.setMsg("操作失败!提交的数据不一致!"); |
|
|
return rb.setMsg("操作失败!提交的数据不一致!"); |
|
|
} |
|
|
} |
|
|