| | |
| | | package org.jeecg.modules.mes.job; |
| | | |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.jeecg.modules.lsw.service.ILswMaterialService; |
| | | import org.jeecg.modules.mdc.util.DateUtils; |
| | | import org.jeecg.modules.mdc.util.ThrowableUtil; |
| | | import org.jeecg.modules.mes.entity.MesProductionOrder; |
| | |
| | | import org.jeecg.modules.sap.dto.OrderBomDTO; |
| | | import org.jeecg.modules.sap.dto.OrderProcessDTO; |
| | | import org.jeecg.modules.sap.dto.ProductionOrderDTO; |
| | | import org.jeecg.modules.sap.request.ProductionOrderSyncRequest; |
| | | import org.jeecg.modules.sap.service.OrderBomSync; |
| | | import org.jeecg.modules.sap.service.OrderProcessSync; |
| | | import org.jeecg.modules.sap.service.ProductionOrderSync; |
| | |
| | | private ISysQuartzLogService sysQuartzLogService; |
| | | @Autowired |
| | | private IQuartzJobService quartzJobService; |
| | | @Autowired |
| | | private ILswMaterialService lswMaterialService; |
| | | |
| | | @Override |
| | | public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { |
| | |
| | | lastSyncDateHigh = null; |
| | | } |
| | | } |
| | | ProductionOrderSyncRequest request = new ProductionOrderSyncRequest(); |
| | | request.setFactoryCode(FACTORY_CODE); |
| | | request.setOrderTypeCode(ORDER_TYPE_CODE); |
| | | request.setProductionManager(PRODUCTION_MANAGER); |
| | | request.setOrderStatus(ORDER_STATUS); |
| | | request.setUpdateTimeLow(lastSyncDateLow); |
| | | request.setUpdateTimeHigh(lastSyncDateHigh); |
| | | try { |
| | | //调用SAP接口获取生产订单 |
| | | Map<String, Object> productionOrderMap = productionOrderSync.syncProductionOrder(FACTORY_CODE, ORDER_TYPE_CODE, PRODUCTION_MANAGER, ORDER_STATUS, null, null, lastSyncDateLow, lastSyncDateHigh); |
| | | Map<String, Object> productionOrderMap = productionOrderSync.syncProductionOrder(request); |
| | | if (productionOrderMap == null || !SUCCESS_CODE.equals(productionOrderMap.get("ztype"))) { |
| | | log.error("未同步到订单信息!日期:{}", LocalDateTime.now()); |
| | | return; |
| | |
| | | log.error("保存订单BOM失败,日期:{}", LocalDateTime.now()); |
| | | return; |
| | | } |
| | | //物料数据处理 |
| | | b = lswMaterialService.saveOrUpdateMaterial(orderMap, orderBomDTOList); |
| | | if (!b) { |
| | | log.error("保存物料失败,日期:{}", LocalDateTime.now()); |
| | | return; |
| | | } |
| | | //订单工序同步 |
| | | Map<String, Object> orderProcessMap = orderProcessSync.syncOrderProcess(FACTORY_CODE, orderCodes); |
| | | if (orderBomMap == null || !SUCCESS_CODE.equals(orderProcessMap.get("ztype"))) { |