| | |
| | | |
| | | 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.IPurchaseApplyUserInnerServiceSMO; |
| | | import com.java110.intf.common.IWorkflowInnerServiceSMO; |
| | | import com.java110.intf.job.IDataBusInnerServiceSMO; |
| | | import com.java110.intf.store.IComplaintInnerServiceSMO; |
| | | import com.java110.intf.store.IPurchaseApplyInnerServiceSMO; |
| | | import com.java110.intf.user.IUserInnerServiceSMO; |
| | | import com.java110.po.contract.ContractPo; |
| | | import com.java110.po.machine.MachineRecordPo; |
| | | import com.java110.po.purchase.PurchaseApplyPo; |
| | | import com.java110.utils.constant.BusinessTypeConstant; |
| | |
| | | machineRecordPo.setPurchaseUserId(actRuTaskUserId); |
| | | machineRecordPo.setResOrderType(resOrderType); |
| | | //传送databus |
| | | dataBusInnerServiceSMOImpl.customExchange(CustomBusinessDatabusDto.getInstance( |
| | | dataBusInnerServiceSMOImpl.databusData(DatabusDataDto.getInstance( |
| | | BusinessTypeConstant.BUSINESS_TYPE_DATABUS_PURCHASE_APPLY, BeanConvertUtil.beanCovertJson(machineRecordPo))); |
| | | } |
| | | } |
| | |
| | | variables.put("currentUserId", purchaseApplyDto.getCurrentUserId()); |
| | | variables.put("flag", "1200".equals(purchaseApplyDto.getAuditCode()) ? "false" : "true"); |
| | | variables.put("startUserId", purchaseApplyDto.getStartUserId()); |
| | | variables.put("nextUserId", purchaseApplyDto.getNextStaffId()); |
| | | taskService.complete(purchaseApplyDto.getTaskId(), variables); |
| | | ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); |
| | | if (pi == null) { |
| | |
| | | machineRecordPo.setResOrderType(resOrderType); |
| | | machineRecordPo.setAuditMessage(auditMessage); |
| | | //传送databus |
| | | dataBusInnerServiceSMOImpl.customExchange(CustomBusinessDatabusDto.getInstance( |
| | | dataBusInnerServiceSMOImpl.databusData(DatabusDataDto.getInstance( |
| | | BusinessTypeConstant.BUSINESS_TYPE_DATABUS_PURCHASE_APPLY, BeanConvertUtil.beanCovertJson(machineRecordPo))); |
| | | } |
| | | } |