|
|
|
@ -6,15 +6,19 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
|
|
import com.chanjet.openapi.sdk.java.exception.ChanjetApiException;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.chanjet.ChanjetSpi;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.chanjet.vo.CreateDepartmentVO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.chanjet.vo.CreateProcedureVO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.chanjet.vo.QueryPartnerVO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.chanjet.vo.SimpleChanjetResponse;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.controller.admin.procedure.vo.ProcedureSaveReqVO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.controller.admin.workshop.vo.WorkshopSaveReqVO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.dal.dataobject.customer.CustomerDO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.dal.dataobject.procedure.ProcedureDO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.dal.dataobject.supplier.SupplierDO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.dal.dataobject.workshop.WorkshopDO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.dal.mysql.customer.CustomerMapper;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.dal.mysql.supplier.SupplierMapper;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.enums.ValidStatusEnum;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.service.procedure.ProcedureService;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.service.workshop.WorkshopService;
|
|
|
|
|
import com.chanko.yunxi.mes.module.system.controller.admin.dept.vo.dept.DeptSaveReqVO;
|
|
|
|
|
import com.chanko.yunxi.mes.module.system.dal.dataobject.dept.DeptDO;
|
|
|
|
@ -49,6 +53,8 @@ public class ChanjetManager {
|
|
|
|
|
private CustomerMapper customerMapper;
|
|
|
|
|
@Resource
|
|
|
|
|
private SupplierMapper supplierMapper;
|
|
|
|
|
@Resource
|
|
|
|
|
private ProcedureService procedureService;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 创建部门
|
|
|
|
@ -226,4 +232,35 @@ public class ChanjetManager {
|
|
|
|
|
}
|
|
|
|
|
}while (maxTs != null);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 创建工序
|
|
|
|
|
* @param createReqVO
|
|
|
|
|
* @return
|
|
|
|
|
* @throws ChanjetApiException
|
|
|
|
|
*/
|
|
|
|
|
public Long createProcedure(ProcedureSaveReqVO createReqVO) throws ChanjetApiException {
|
|
|
|
|
Long procedureId = procedureService.createProcedure(createReqVO);
|
|
|
|
|
|
|
|
|
|
ProcedureDO procedure = procedureService.getProcedure(procedureId);
|
|
|
|
|
String wCode = null;
|
|
|
|
|
Long wid = procedure.getWid();
|
|
|
|
|
if(wid != null){
|
|
|
|
|
WorkshopDO workshop = workshopService.getWorkshop(wid);
|
|
|
|
|
wCode = workshop.getCode();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
String finalWCode = wCode;
|
|
|
|
|
CreateProcedureVO.ProcedureVO dto = new CreateProcedureVO.ProcedureVO(procedure.getCode(), procedure.getName()
|
|
|
|
|
, ValidStatusEnum.VALID.getCode() == procedure.getStatus()
|
|
|
|
|
, !StringUtils.isEmpty(wCode) ? new HashMap<String, String>(){{
|
|
|
|
|
put("Code", finalWCode);
|
|
|
|
|
}} : null);
|
|
|
|
|
SimpleChanjetResponse response = (SimpleChanjetResponse) chanjetSpi.execute(CREATE_PROCEDURE, new CreateProcedureVO(dto));
|
|
|
|
|
if(!response.isSuccess()){
|
|
|
|
|
throw new RuntimeException(response.getMessage());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return procedureId;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|