|
|
@ -45,6 +45,7 @@ import com.yxt.anrui.base.api.flow.FlowTaskVo; |
|
|
|
import com.yxt.anrui.base.biz.basemanufacturer.BaseManufacturerService; |
|
|
|
import com.yxt.anrui.base.biz.baseoutsourcingapplicationvehicle.BaseOutsourcingApplicationVehicleService; |
|
|
|
import com.yxt.anrui.base.biz.basevehicle.BaseVehicleService; |
|
|
|
import com.yxt.anrui.base.biz.basevehiclebrand.BaseVehicleBrandService; |
|
|
|
import com.yxt.anrui.base.biz.commonappendix.CommonAppendixService; |
|
|
|
import com.yxt.anrui.base.common.enums.BillTypeEnum; |
|
|
|
import com.yxt.anrui.base.common.enums.ManPurOrderType; |
|
|
@ -143,6 +144,8 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
private AppSubsetVersionFeign appSubsetVersionFeign; |
|
|
|
@Autowired |
|
|
|
private BaseManufacturerService baseManufacturerService; |
|
|
|
@Autowired |
|
|
|
private BaseVehicleBrandService baseVehicleBrandService; |
|
|
|
|
|
|
|
private QueryWrapper<BaseOutsourcingApplication> createQueryWrapper(BaseOutsourcingApplicationQuery query) { |
|
|
|
// todo: 这里根据具体业务调整查询条件
|
|
|
@ -200,10 +203,10 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
String sid = dto.getSid(); |
|
|
|
BigDecimal guidedPrice = dto.getGuidedPrice(); |
|
|
|
BigDecimal purchasePrice = dto.getPurchasePrice(); |
|
|
|
if (guidedPrice == null){ |
|
|
|
if (guidedPrice == null) { |
|
|
|
return rb.setMsg("销售指导价不能为空"); |
|
|
|
} |
|
|
|
if (purchasePrice == null){ |
|
|
|
if (purchasePrice == null) { |
|
|
|
return rb.setMsg("采购价格不能为空"); |
|
|
|
} |
|
|
|
if (StringUtils.isBlank(sid)) {//新增
|
|
|
@ -236,6 +239,19 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
entity.setUseOrgSid(orgSidPath); |
|
|
|
entity.setCreateBySid(dto.getUserSid()); |
|
|
|
entity.setNodeState("待提交"); |
|
|
|
String carBrandSid = dto.getCarBrandSid(); |
|
|
|
String brandCode = baseVehicleBrandService.fetchBySid(carBrandSid).getBrandCode(); |
|
|
|
entity.setCarBrandCode(brandCode); |
|
|
|
String purchaseSystemSid = dto.getPurchaseSystemSid(); |
|
|
|
String purchaseSystemCode = sysOrganizationFeign.fetchBySid(purchaseSystemSid).getData().getOrgCode(); |
|
|
|
entity.setPurchaseSystemCode(purchaseSystemCode); |
|
|
|
entity.setManPurOrderTypeKey("002"); |
|
|
|
String purchasingUnitSid = dto.getPurchasingUnitSid(); |
|
|
|
String manufacturerCode = baseManufacturerService.fetchBySid(purchasingUnitSid).getManufacturerCode(); |
|
|
|
entity.setSupplierCode(manufacturerCode); |
|
|
|
String useOrgSid = dto.getUseOrgSid(); |
|
|
|
String orgCode = sysOrganizationFeign.fetchBySid(useOrgSid).getData().getOrgCode(); |
|
|
|
entity.setOrgCode(orgCode); |
|
|
|
save(entity); |
|
|
|
for (BaseOutsourcingApplicationVehicleDto baseOutsourcingApplicationVehicleDto : baseOutsourcingApplicationVehicleDtos) { |
|
|
|
BaseOutsourcingApplicationVehicle baseOutsourcingApplicationVehicle = new BaseOutsourcingApplicationVehicle(); |
|
|
@ -412,12 +428,12 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
BaseOutsourcingApplication baseOutsourcingApplication = fetchBySid(businessSid); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(uff,messageFlowVo); |
|
|
|
BeanUtil.copyProperties(uff, messageFlowVo); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(businessSid); |
|
|
|
messageFlowableQuery.setModuleName("外采申请"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName()+"提交的"+messageFlowableQuery.getModuleName()+",请审批"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
messageFlowableQuery.setMsgTitle("外采申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
//极光推送
|
|
|
@ -459,13 +475,13 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
BaseOutsourcingApplication baseOutsourcingApplication = fetchBySid(businessSid); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(uff,messageFlowVo); |
|
|
|
BeanUtil.copyProperties(uff, messageFlowVo); |
|
|
|
uff.setProcInsId(baseOutsourcingApplication.getProcInstSid()); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(businessSid); |
|
|
|
messageFlowableQuery.setModuleName("外采申请"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName()+"提交的"+messageFlowableQuery.getModuleName()+",请审批"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
messageFlowableQuery.setMsgTitle("外采申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
// String msgSid = getMessage(uff, appMap, baseOutsourcingApplication);
|
|
|
@ -483,14 +499,14 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
BaseOutsourcingApplication baseOutsourcingApplication = fetchBySid(businessSid); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(uff,messageFlowVo); |
|
|
|
BeanUtil.copyProperties(uff, messageFlowVo); |
|
|
|
uff.setProcInsId(baseOutsourcingApplication.getProcInstSid()); |
|
|
|
uff.setProcDefId(baseOutsourcingApplication.getProcDefId()); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(businessSid); |
|
|
|
messageFlowableQuery.setModuleName("外采申请"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName()+"提交的"+messageFlowableQuery.getModuleName()+",请审批"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
messageFlowableQuery.setMsgTitle("外采申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
// String msgSid = getMessage(uff, appMap, baseOutsourcingApplication);
|
|
|
@ -528,12 +544,12 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
String businessTaskid = booad.getTaskId(); |
|
|
|
if (businessTaskid.equals(bv.getTaskId())) { //只有数据一致的时候才能进行下一步
|
|
|
|
//=================添加app相关参数
|
|
|
|
Map<String,Object> appMap = new HashMap<>(); |
|
|
|
appMap.put("sid",bv.getBusinessSid()); |
|
|
|
bv.getFormVariables().put("app",appMap); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
appMap.put("sid", bv.getBusinessSid()); |
|
|
|
bv.getFormVariables().put("app", appMap); |
|
|
|
//================添加app相关参数
|
|
|
|
BaseOutsourcingApplicationDto dto= baseMapper.getBySid(bv.getBusinessSid()); |
|
|
|
ResultBean<UpdateFlowFieldVo> rb = complete_handleProsess(bv,dto); |
|
|
|
BaseOutsourcingApplicationDto dto = baseMapper.getBySid(bv.getBusinessSid()); |
|
|
|
ResultBean<UpdateFlowFieldVo> rb = complete_handleProsess(bv, dto); |
|
|
|
String taskDefKey = rb.getData().getTaskDefKey(); |
|
|
|
Map<String, Object> stringObjectMap = BeanUtil.beanToMap(rb.getData()); |
|
|
|
updateFlowFiled(stringObjectMap); |
|
|
@ -562,19 +578,19 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
return rb.setMsg("验车单业务模块的数据推送失败!"); |
|
|
|
} |
|
|
|
} |
|
|
|
}else{ |
|
|
|
} else { |
|
|
|
//======================添加消息推送开始
|
|
|
|
UpdateFlowFieldVo uff = rb.getData(); |
|
|
|
BaseOutsourcingApplication baseOutsourcingApplication = fetchBySid(bv.getBusinessSid()); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(uff,messageFlowVo); |
|
|
|
BeanUtil.copyProperties(uff, messageFlowVo); |
|
|
|
uff.setProcInsId(baseOutsourcingApplication.getProcInstSid()); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(bv.getBusinessSid()); |
|
|
|
messageFlowableQuery.setModuleName("外采申请"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName()+"提交的"+messageFlowableQuery.getModuleName()+",请审批"); |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
messageFlowableQuery.setMsgTitle("外采申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
//======================添加消息推送结束
|
|
|
@ -586,11 +602,11 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean<UpdateFlowFieldVo> complete_handleProsess(BusinessVariables bv, BaseOutsourcingApplicationDto dto) { |
|
|
|
ResultBean<UpdateFlowFieldVo> rb = flowableFeign.handleProsess(bv); |
|
|
|
Map<String, Object> stringObjectMap = BeanUtil.beanToMap(rb.getData()); |
|
|
|
updateFlowFiled(stringObjectMap); |
|
|
|
//消息推送===========开始
|
|
|
|
public ResultBean<UpdateFlowFieldVo> complete_handleProsess(BusinessVariables bv, BaseOutsourcingApplicationDto dto) { |
|
|
|
ResultBean<UpdateFlowFieldVo> rb = flowableFeign.handleProsess(bv); |
|
|
|
Map<String, Object> stringObjectMap = BeanUtil.beanToMap(rb.getData()); |
|
|
|
updateFlowFiled(stringObjectMap); |
|
|
|
//消息推送===========开始
|
|
|
|
/* UpdateFlowFieldVo uff = rb.getData(); |
|
|
|
if (!"Event_end".equals(uff.getTaskDefKey())) { |
|
|
|
BaseOutsourcingApplication baseOutsourcingApplication = fetchBySid(bv.getBusinessSid()); |
|
|
@ -607,8 +623,8 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
messageFlowableQuery.setMsgTitle("供应链"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
}*/ |
|
|
|
//消息推送结束=====
|
|
|
|
return rb; |
|
|
|
//消息推送结束=====
|
|
|
|
return rb; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
@ -747,9 +763,9 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
if (businessTaskid.equals(flowTaskVo.getTaskId())) { //只有数据一致的时候才能进行下一步
|
|
|
|
BeanUtil.copyProperties(flowTaskVo, fl); |
|
|
|
//==========添加app相关参数
|
|
|
|
Map<String,Object> appMap = new HashMap<>(); |
|
|
|
appMap.put("sid",flowTaskVo.getBusinessSid()); |
|
|
|
flowTaskVo.getValues().put("app",appMap); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
appMap.put("sid", flowTaskVo.getBusinessSid()); |
|
|
|
flowTaskVo.getValues().put("app", appMap); |
|
|
|
//=========添加app相关参数
|
|
|
|
BaseOutsourcingApplicationDto boad = baseMapper.getBySid(flowTaskVo.getBusinessSid()); |
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.taskReject(fl); |
|
|
@ -764,20 +780,20 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
BaseOutsourcingApplication baseOutsourcingApplication = fetchBySid(flowTaskVo.getBusinessSid()); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(data,messageFlowVo); |
|
|
|
BeanUtil.copyProperties(data, messageFlowVo); |
|
|
|
String procId = baseOutsourcingApplication.getProcInstSid(); |
|
|
|
data.setProcInsId(procId); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(flowTaskVo.getBusinessSid()); |
|
|
|
messageFlowableQuery.setModuleName("外采申请"); |
|
|
|
ResultBean<List<LatestTaskVo>> listResultBean = flowTaskFeign.getLatestTasks(procId); |
|
|
|
ResultBean<List<LatestTaskVo>> listResultBean = flowTaskFeign.getLatestTasks(procId); |
|
|
|
String nextNodeUserSids = listResultBean.getData().get(0).getASSIGNEE_(); |
|
|
|
List<String> receiveSidList = Arrays.asList(nextNodeUserSids.split(",")); |
|
|
|
if(receiveSidList.size() == 1 && receiveSidList.get(0).equals(baseOutsourcingApplication.getCreateBySid())){ |
|
|
|
messageFlowableQuery.setMsgContent("您提交的"+messageFlowableQuery.getModuleName()+"已被驳回,请重新提交"); |
|
|
|
}else{ |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName()+"提交的"+messageFlowableQuery.getModuleName()+",请审批"); |
|
|
|
if (receiveSidList.size() == 1 && receiveSidList.get(0).equals(baseOutsourcingApplication.getCreateBySid())) { |
|
|
|
messageFlowableQuery.setMsgContent("您提交的" + messageFlowableQuery.getModuleName() + "已被驳回,请重新提交"); |
|
|
|
} else { |
|
|
|
messageFlowableQuery.setMsgContent(baseOutsourcingApplication.getCreateByName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
} |
|
|
|
|
|
|
|
messageFlowableQuery.setMsgTitle("外采申请"); |
|
|
@ -875,7 +891,7 @@ public class BaseOutsourcingApplicationService extends MybatisBaseService<BaseOu |
|
|
|
List<CommonAppendixVo> commonAppendixVos = commonAppendixService.selByLinkSid(sid); |
|
|
|
List<String> stringList = new ArrayList<>(); |
|
|
|
if (commonAppendixVos != null && commonAppendixVos.size() > 0) { |
|
|
|
stringList.add(fileUploadComponent.getUrlPrefix()+commonAppendixVos.get(0).getFilePath()); |
|
|
|
stringList.add(fileUploadComponent.getUrlPrefix() + commonAppendixVos.get(0).getFilePath()); |
|
|
|
} |
|
|
|
ResultBean<AppSubVersionVo> resultBean = appSubsetVersionFeign.selectLast(); |
|
|
|
AppSubVersionVo appSubVersionVo = resultBean.getData(); |
|
|
|