工位扫描 日志

modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/equiplog/MesWorkCellScanMonitorLogExtService.java

@@ -1,19 +1,48 @@
 package cn.estsh.i3plus.ext.mes.pcn.apiservice.serviceimpl.equiplog;
 
+import cn.estsh.i3plus.ext.mes.pcn.api.busi.IMesProductionProcessContextStepService;
+import cn.estsh.i3plus.ext.mes.pcn.pojo.context.MesScanMonitorContext;
 import cn.estsh.i3plus.mes.pcn.serviceimpl.fsm.swslog.ISwsWriteDbLogService;
+import cn.estsh.i3plus.platform.common.convert.ConvertBean;
+import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
+import cn.estsh.i3plus.pojo.mes.bean.MesWorkCellScanMonitorLog;
 import cn.estsh.i3plus.pojo.mes.model.StationResultBean;
+import cn.estsh.i3plus.pojo.mes.repository.MesWorkCellScanMonitorLogRepository;
+import cn.estsh.i3plus.pojo.mes.util.MesExtEnumUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 @Slf4j
 @Service
 public class MesWorkCellScanMonitorLogExtService implements ISwsWriteDbLogService {
 
-    @Override
-    public void doWriteDbLog(StationResultBean resultBean) {
+    @Autowired
+    private IMesProductionProcessContextStepService productionProcessContextStepService;
 
+    @Autowired
+    private MesWorkCellScanMonitorLogRepository workCellScanMonitorLogRepository;
 
+    @Override
+    public void doWriteDbLog(StationResultBean resultBean) {
 
+        //获取上下文工位扫描监控信息
+        MesScanMonitorContext scanMonitorContext = productionProcessContextStepService.getScanMonitorContext(resultBean.getOrganizeCode(), resultBean.getWorkCenterCode(), resultBean.getWorkCellCode());
+        if (null == scanMonitorContext) {
+            log.info("工厂{}生产线{}工位{}: MesWorkCellScanMonitorLogExtService --- 上下文当前不存在工位扫描监控信息 --- {}", resultBean.getOrganizeCode(), resultBean.getWorkCenterCode(), resultBean.getWorkCellCode(), resultBean.toWriteDbString());
+            return;
+        }
+
+        MesWorkCellScanMonitorLog workCellScanMonitorLog = new MesWorkCellScanMonitorLog();
+        BeanUtils.copyProperties(scanMonitorContext, workCellScanMonitorLog);
+        workCellScanMonitorLog.setScanInfo(resultBean.getScanInfo());
+        workCellScanMonitorLog.setMessage(resultBean.getMessage());
+        workCellScanMonitorLog.setMessageType(MesExtEnumUtil.WORK_CELL_SCAN_MONITOR_MESSAGE_TYPE.codeOfValue(resultBean.getDataType()));
+        workCellScanMonitorLog.setLogType(resultBean.getLogType());
+        workCellScanMonitorLog.setServiceFlag(CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue());
+        ConvertBean.serviceModelInitialize(workCellScanMonitorLog, resultBean.getUserInfo());
+        workCellScanMonitorLogRepository.insert(workCellScanMonitorLog);
 
     }