| | |
| | | |
| | | import com.java110.core.base.smo.BaseServiceSMO; |
| | | import com.java110.dto.PageDto; |
| | | import com.java110.dto.auditMessage.AuditMessageDto; |
| | | import com.java110.dto.businessDatabus.CustomBusinessDatabusDto; |
| | | import com.java110.dto.purchaseApply.PurchaseApplyDto; |
| | | import com.java110.dto.audit.AuditMessageDto; |
| | | import com.java110.dto.data.DatabusDataDto; |
| | | import com.java110.dto.purchase.PurchaseApplyDto; |
| | | import com.java110.dto.user.UserDto; |
| | | import com.java110.dto.workflow.WorkflowDto; |
| | | import com.java110.entity.audit.AuditUser; |
| | | import com.java110.dto.oaWorkflow.WorkflowDto; |
| | | import com.java110.dto.audit.AuditUser; |
| | | import com.java110.intf.common.IGoodCollectionUserInnerServiceSMO; |
| | | import com.java110.intf.common.IWorkflowInnerServiceSMO; |
| | | import com.java110.intf.job.IDataBusInnerServiceSMO; |
| | |
| | | variables.put("nextAuditStaffId", purchaseApplyDto.getStaffId()); |
| | | variables.put("userId", purchaseApplyDto.getCurrentUserId()); |
| | | variables.put("startUserId", purchaseApplyDto.getCurrentUserId()); |
| | | variables.put("nextUserId", purchaseApplyDto.getNextStaffId()); |
| | | //开启流程 |
| | | ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(getWorkflowDto(purchaseApplyDto.getStoreId(),purchaseApplyDto.getCommunityId()), purchaseApplyDto.getApplyOrderId(), variables); |
| | | //将得到的实例流程id值赋给之前设置的变量 |
| | |
| | | machineRecordPo.setPurchaseUserId(actRuTaskUserId); |
| | | machineRecordPo.setResOrderType(resOrderType); |
| | | //传送databus |
| | | dataBusInnerServiceSMOImpl.customExchange(CustomBusinessDatabusDto.getInstance( |
| | | dataBusInnerServiceSMOImpl.databusData(DatabusDataDto.getInstance( |
| | | BusinessTypeConstant.BUSINESS_TYPE_DATABUS_PURCHASE_APPLY, BeanConvertUtil.beanCovertJson(machineRecordPo))); |
| | | } |
| | | } |