|
|
|
@ -20,8 +20,11 @@ import com.yxt.anrui.buscenter.api.busarrearscarryvehicleapply.flowable.*; |
|
|
|
import com.yxt.anrui.buscenter.api.busarrearscarryvehicledetails.BusArrearsCarryVehicleDetails; |
|
|
|
import com.yxt.anrui.buscenter.api.busarrearscarryvehicledetails.BusArrearsCarryVehicleDetailsDto; |
|
|
|
import com.yxt.anrui.buscenter.api.busarrearscarryvehicledetails.BusArrearsCarryVehicleDetailsVo; |
|
|
|
import com.yxt.anrui.buscenter.api.busdelivered.AddRetrievalApplyDto; |
|
|
|
import com.yxt.anrui.buscenter.api.busdelivered.BusDeliveredFeign; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesorder.contract.AppRovalContractPageVo; |
|
|
|
import com.yxt.anrui.buscenter.biz.busarrearscarryvehicledetails.BusArrearsCarryVehicleDetailsService; |
|
|
|
import com.yxt.anrui.buscenter.biz.busdelivered.BusDeliveredService; |
|
|
|
import com.yxt.anrui.buscenter.biz.bussalesorder.BusSalesOrderService; |
|
|
|
import com.yxt.anrui.buscenter.biz.flow.FlowableService; |
|
|
|
import com.yxt.anrui.crm.api.crmcustomertemp.CrmCustomerTempFeign; |
|
|
|
@ -122,6 +125,9 @@ public class BusArrearsCarryVehicleApplyService extends MybatisBaseService<BusAr |
|
|
|
@Autowired |
|
|
|
private FlowTaskFeign flowTaskFeign; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private BusDeliveredService busDeliveredService; |
|
|
|
|
|
|
|
/** |
|
|
|
* 欠款提车分页列表查询条件 |
|
|
|
* |
|
|
|
@ -763,9 +769,29 @@ public class BusArrearsCarryVehicleApplyService extends MybatisBaseService<BusAr |
|
|
|
appMaps.put("contractSid", busArrearsCarryVehicleApply.getSid()); |
|
|
|
List<String> recipientSidList = new ArrayList<>(); |
|
|
|
|
|
|
|
// 风控中心总经理角色用户
|
|
|
|
//推送出库申请
|
|
|
|
List<BusArrearsCarryVehicleDetailsVo> vehicleDetailsVos = busArrearsCarryVehicleDetailsService.selByArrearsSid(busArrearsCarryVehicleApply.getSid()); |
|
|
|
if (vehicleDetailsVos.size() > 0) { |
|
|
|
for (BusArrearsCarryVehicleDetailsVo vehicleDetailsVo : vehicleDetailsVos) { |
|
|
|
AddRetrievalApplyDto addRetrievalApplyDto = new AddRetrievalApplyDto(); |
|
|
|
addRetrievalApplyDto.setVinNo(vehicleDetailsVo.getVinNo()); |
|
|
|
addRetrievalApplyDto.setPrice(String.valueOf(vehicleDetailsVo.getDealMoney())); |
|
|
|
addRetrievalApplyDto.setContractNo(busArrearsCarryVehicleApply.getContractNo()); |
|
|
|
addRetrievalApplyDto.setName(busArrearsCarryVehicleApply.getCustomerName()); |
|
|
|
busDeliveredService.addRetrievalApply(addRetrievalApplyDto); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
// 风控中心风控经理
|
|
|
|
UserRoleQuery userRoleQuery1 = new UserRoleQuery(); |
|
|
|
userRoleQuery1.setRoleSid("967e63b0-3b7a-49ed-b42a-d4f904ab84f4"); |
|
|
|
List<SysUserVo> list4 = sysUserFeign.getOtherOrgRoleUser(userRoleQuery1).getData(); |
|
|
|
for (SysUserVo userVo : list4) { |
|
|
|
recipientSidList.add(userVo.getSid()); |
|
|
|
} |
|
|
|
// 风控中心风控内勤
|
|
|
|
UserRoleQuery userRoleQuery = new UserRoleQuery(); |
|
|
|
userRoleQuery.setRoleSid("537bea8f-75e8-430c-9a5f-3140bda41f39"); |
|
|
|
userRoleQuery.setRoleSid("967e63b0-3b7a-49ed-b42a-d4f904ab84f4"); |
|
|
|
List<SysUserVo> list1 = sysUserFeign.getOtherOrgRoleUser(userRoleQuery).getData(); |
|
|
|
for (SysUserVo userVo : list1) { |
|
|
|
recipientSidList.add(userVo.getSid()); |
|
|
|
@ -812,6 +838,7 @@ public class BusArrearsCarryVehicleApplyService extends MybatisBaseService<BusAr |
|
|
|
|
|
|
|
public ResultBean InitiatorToAnswerInfo(BusinessVariables bv) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
SysUserVo userVos = sysUserFeign.fetchBySid(bv.getUserSid()).getData(); |
|
|
|
BusArrearsCarryVehicleApply busArrearsCarryVehicleApply = fetchBySid(bv.getBusinessSid()); |
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
@ -842,7 +869,92 @@ public class BusArrearsCarryVehicleApplyService extends MybatisBaseService<BusAr |
|
|
|
if (!resultBean1.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean1.getMsg()); |
|
|
|
} |
|
|
|
UpdateFlowFieldVo ufVos = resultBean1.getData(); |
|
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean1.getData())); |
|
|
|
|
|
|
|
if (!"Event_end".equals(ufVos.getTaskDefKey())) { |
|
|
|
//极光推送
|
|
|
|
busArrearsCarryVehicleApply = fetchBySid(bv.getBusinessSid()); |
|
|
|
ufVos.setProcInsId(busArrearsCarryVehicleApply.getProcInstId()); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(ufVos, messageFlowVo); |
|
|
|
ufVos.setProcInsId(busArrearsCarryVehicleApply.getProcInstId()); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(bv.getBusinessSid()); |
|
|
|
messageFlowableQuery.setModuleName("欠款提车申请"); |
|
|
|
messageFlowableQuery.setMsgContent(busArrearsCarryVehicleApply.getApplyName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
messageFlowableQuery.setMsgTitle("欠款提车申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
} else { |
|
|
|
AppScmMessageFlowableQuery query = new AppScmMessageFlowableQuery(); |
|
|
|
Map<String, Object> appMaps = new HashMap<>(); |
|
|
|
appMaps.put("contractSid", busArrearsCarryVehicleApply.getSid()); |
|
|
|
List<String> recipientSidList = new ArrayList<>(); |
|
|
|
|
|
|
|
//推送出库申请
|
|
|
|
List<BusArrearsCarryVehicleDetailsVo> vehicleDetailsVos = busArrearsCarryVehicleDetailsService.selByArrearsSid(busArrearsCarryVehicleApply.getSid()); |
|
|
|
if (vehicleDetailsVos.size() > 0) { |
|
|
|
for (BusArrearsCarryVehicleDetailsVo vehicleDetailsVo : vehicleDetailsVos) { |
|
|
|
AddRetrievalApplyDto addRetrievalApplyDto = new AddRetrievalApplyDto(); |
|
|
|
addRetrievalApplyDto.setVinNo(vehicleDetailsVo.getVinNo()); |
|
|
|
addRetrievalApplyDto.setPrice(String.valueOf(vehicleDetailsVo.getDealMoney())); |
|
|
|
addRetrievalApplyDto.setContractNo(busArrearsCarryVehicleApply.getContractNo()); |
|
|
|
addRetrievalApplyDto.setName(busArrearsCarryVehicleApply.getCustomerName()); |
|
|
|
busDeliveredService.addRetrievalApply(addRetrievalApplyDto); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
// 风控中心风控经理
|
|
|
|
UserRoleQuery userRoleQuery1 = new UserRoleQuery(); |
|
|
|
userRoleQuery1.setRoleSid("242d52de-7df9-4fab-91ff-d6f07dc98341"); |
|
|
|
List<SysUserVo> list4 = sysUserFeign.getOtherOrgRoleUser(userRoleQuery1).getData(); |
|
|
|
for (SysUserVo userVo : list4) { |
|
|
|
recipientSidList.add(userVo.getSid()); |
|
|
|
} |
|
|
|
// 风控中心风控内勤
|
|
|
|
UserRoleQuery userRoleQuery2 = new UserRoleQuery(); |
|
|
|
userRoleQuery2.setRoleSid("967e63b0-3b7a-49ed-b42a-d4f904ab84f4"); |
|
|
|
List<SysUserVo> list1 = sysUserFeign.getOtherOrgRoleUser(userRoleQuery2).getData(); |
|
|
|
for (SysUserVo userVo : list1) { |
|
|
|
recipientSidList.add(userVo.getSid()); |
|
|
|
} |
|
|
|
// 分公司会计角色用户
|
|
|
|
UserQuery userQuery = new UserQuery(); |
|
|
|
userQuery.setRoleSid("94e3e298-e934-42d2-af02-50e93eee583a"); |
|
|
|
userQuery.setOrgSidPath(bv.getOrgSidPath()); |
|
|
|
List<SysUserVo> list = sysUserFeign.getUserByRole(userQuery).getData(); |
|
|
|
for (SysUserVo userVo : list) { |
|
|
|
recipientSidList.add(userVo.getSid()); |
|
|
|
} |
|
|
|
//财务中心总经理角色用户
|
|
|
|
UserRoleQuery userRoleQuery3 = new UserRoleQuery(); |
|
|
|
userRoleQuery3.setRoleSid("b2bcdfd6-ac51-408c-9c7a-7e9818d23155"); |
|
|
|
List<SysUserVo> list3 = sysUserFeign.getOtherOrgRoleUser(userRoleQuery3).getData(); |
|
|
|
for (SysUserVo userVo : list3) { |
|
|
|
recipientSidList.add(userVo.getSid()); |
|
|
|
} |
|
|
|
//事业部运营经理角色用户
|
|
|
|
UserRoleQuery userRoleQuery4 = new UserRoleQuery(); |
|
|
|
userRoleQuery4.setRoleSid("f60b30b0-c7ad-4533-8367-b3ff95cbe725"); |
|
|
|
List<SysUserVo> list2 = sysUserFeign.getOtherOrgRoleUser(userRoleQuery4).getData(); |
|
|
|
for (SysUserVo userVo : list2) { |
|
|
|
recipientSidList.add(userVo.getSid()); |
|
|
|
} |
|
|
|
query.setRecipientSidList(recipientSidList); |
|
|
|
query.setAppMap(appMaps); |
|
|
|
query.setMsgTitle("业务"); |
|
|
|
query.setMsgContent(userVos.getName() + "提交的欠款提车申请,请查阅"); |
|
|
|
query.setMsgSource("业务"); |
|
|
|
query.setMsgTargetUri(MsgTargetUriEnum.TQKPSQTS.getUri()); |
|
|
|
query.setApp_type("2"); |
|
|
|
query.setModuleSid("e25e13b5-f2ed-421f-bdb3-6f2eca2a3028"); |
|
|
|
query.setName("业务"); |
|
|
|
// 消息推送
|
|
|
|
messageFeign.sendAutoserviceMessage(query); |
|
|
|
} |
|
|
|
|
|
|
|
return rb.success().setData(resultBean1.getData()); |
|
|
|
} else { |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致"); |
|
|
|
|
God
2 years ago