From ab389a5a6b329b15a655340ba7b87bce7fd7871d Mon Sep 17 00:00:00 2001
From: huang <1532065656@qq.com>
Date: 星期三, 24 十二月 2025 17:16:19 +0800
Subject: [PATCH] 添加新增设备自动生成编码
---
mes-processes/mes-plcSend/src/main/java/com/mes/interaction/workstation/scanner/handler/HorizontalScannerLogicHandler.java | 67 ++++++++++++++++-----------------
1 files changed, 32 insertions(+), 35 deletions(-)
diff --git a/mes-processes/mes-plcSend/src/main/java/com/mes/interaction/workstation/scanner/handler/HorizontalScannerLogicHandler.java b/mes-processes/mes-plcSend/src/main/java/com/mes/interaction/workstation/scanner/handler/HorizontalScannerLogicHandler.java
index f676a3d..8996911 100644
--- a/mes-processes/mes-plcSend/src/main/java/com/mes/interaction/workstation/scanner/handler/HorizontalScannerLogicHandler.java
+++ b/mes-processes/mes-plcSend/src/main/java/com/mes/interaction/workstation/scanner/handler/HorizontalScannerLogicHandler.java
@@ -7,15 +7,15 @@
import com.mes.device.vo.DevicePlcVO;
import com.mes.interaction.workstation.base.WorkstationBaseHandler;
import com.mes.interaction.workstation.config.WorkstationLogicConfig;
-import com.mes.s7.enhanced.EnhancedS7Serializer;
-import com.mes.s7.provider.S7SerializerProvider;
-import com.mes.service.PlcDynamicDataService;
+import com.mes.plc.client.PlcClient;
+import com.mes.plc.factory.PlcClientFactory;
import com.mes.task.model.TaskExecutionContext;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import java.time.LocalDateTime;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Date;
@@ -33,18 +33,16 @@
private static final List<String> MES_FIELDS = Arrays.asList("mesSend", "mesGlassId", "mesWidth", "mesHeight", "workLine");
- private final PlcDynamicDataService plcDynamicDataService;
private final GlassInfoService glassInfoService;
- private final S7SerializerProvider s7SerializerProvider;
+ private final PlcClientFactory plcClientFactory;
public HorizontalScannerLogicHandler(DevicePlcOperationService devicePlcOperationService,
- PlcDynamicDataService plcDynamicDataService,
GlassInfoService glassInfoService,
- S7SerializerProvider s7SerializerProvider) {
+ PlcClientFactory plcClientFactory) {
super(devicePlcOperationService);
- this.plcDynamicDataService = plcDynamicDataService;
this.glassInfoService = glassInfoService;
- this.s7SerializerProvider = s7SerializerProvider;
+ this.plcClientFactory = plcClientFactory;
+ this.setPlcClientFactory(plcClientFactory);
}
@Override
@@ -57,22 +55,22 @@
String operation,
Map<String, Object> params,
Map<String, Object> logicParams) {
- EnhancedS7Serializer serializer = s7SerializerProvider.getSerializer(deviceConfig);
- if (serializer == null) {
- return buildResult(deviceConfig, operation, false, "鑾峰彇PLC搴忓垪鍖栧櫒澶辫触", null);
+ PlcClient plcClient = getPlcClient(deviceConfig);
+ if (plcClient == null) {
+ return buildResult(deviceConfig, operation, false, "鑾峰彇PLC瀹㈡埛绔け璐�", null);
}
if ("clearPlc".equalsIgnoreCase(operation) || "reset".equalsIgnoreCase(operation)) {
- return clearPlc(deviceConfig, serializer);
+ return clearPlc(deviceConfig, plcClient);
}
WorkstationLogicConfig config = parseWorkstationConfig(logicParams);
- return executeScan(deviceConfig, config, serializer, params);
+ return executeScan(deviceConfig, config, plcClient, params);
}
private DevicePlcVO.OperationResult executeScan(DeviceConfig deviceConfig,
WorkstationLogicConfig config,
- EnhancedS7Serializer serializer,
+ PlcClient plcClient,
Map<String, Object> params) {
try {
// 浠庡弬鏁颁腑鑾峰彇鐜荤拑ID锛堝畾鏃跺櫒姣忔鍙鐞嗕竴涓級
@@ -85,7 +83,7 @@
}
// 鎵ц鍗曟鎵弿锛堝畾鏃跺櫒浼氬惊鐜皟鐢ㄦ鏂规硶锛�
- return executeSingleScan(deviceConfig, config, serializer, inputGlassId, params);
+ return executeSingleScan(deviceConfig, config, plcClient, inputGlassId, params);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
log.warn("鍗ц浆绔嬫壂鐮佺瓑寰匨ES鏁版嵁琚腑鏂�, deviceId={}", deviceConfig.getId(), e);
@@ -101,19 +99,19 @@
*/
private DevicePlcVO.OperationResult executeSingleScan(DeviceConfig deviceConfig,
WorkstationLogicConfig config,
- EnhancedS7Serializer serializer,
+ PlcClient plcClient,
String inputGlassId,
Map<String, Object> params) throws InterruptedException {
// 1. 鍐欏叆plcRequest=1鍜宲lcGlassId锛堝鏋滄彁渚涗簡鐜荤拑ID锛�
- triggerScanRequest(deviceConfig, serializer, inputGlassId);
+ triggerScanRequest(deviceConfig, plcClient, inputGlassId);
// 2. 绛夊緟MES鍥炲啓mesSend=1浠ュ強鐜荤拑淇℃伅
- Map<String, Object> mesData = waitForMesData(deviceConfig, serializer, config);
+ Map<String, Object> mesData = waitForMesData(deviceConfig, plcClient, config);
if (mesData == null || mesData.isEmpty()) {
log.error("绛夊緟MES鍐欏叆鐜荤拑淇℃伅瓒呮椂: deviceId={}, timeout={}ms",
deviceConfig.getId(), config.getScanIntervalMs());
// 瓒呮椂涔熻娓呯┖plcRequest
- clearPlcRequestFields(deviceConfig, serializer);
+ clearPlcRequestFields(deviceConfig, plcClient);
return buildResult(deviceConfig, "scanOnce", false,
String.format("绛夊緟MES鍐欏叆鐜荤拑淇℃伅瓒呮椂(%dms)", config.getScanIntervalMs()), null);
}
@@ -122,7 +120,7 @@
String glassId = parseString(mesData.get("mesGlassId"));
if (!StringUtils.hasText(glassId)) {
// MES鏈彁渚涚幓鐠僆D涔熻娓呯┖plcRequest
- clearPlcRequestFields(deviceConfig, serializer);
+ clearPlcRequestFields(deviceConfig, plcClient);
return buildResult(deviceConfig, "scanOnce", false, "MES鍐欏尯鏈彁渚涚幓鐠僆D", null);
}
// 璇诲彇MES灏哄鏁版嵁锛歮esWidth=瀹斤紝mesHeight=闀�
@@ -131,7 +129,7 @@
Integer workLine = parseInteger(mesData.get("workLine"));
// 4. 娓呯┖plcRequest鍜宲lcGlassId锛堝彧娓呴櫎PLC瀛楁锛�
- clearPlcRequestFields(deviceConfig, serializer);
+ clearPlcRequestFields(deviceConfig, plcClient);
// 5. 鏇存柊鐜荤拑淇℃伅鐘舵�侊細灏唖tate浠�0鏀逛负1锛堝凡鎵爜浜や簰锛�
boolean updated = glassInfoService.updateGlassStateAfterScan(glassId, rawWidth, rawHeight, workLine);
@@ -144,12 +142,11 @@
saveScannedGlassId(params, glassId);
Integer intervalMs = config != null ? config.getScanIntervalMs() : null;
- String msg = String.format("鐜荤拑[%s] 灏哄[瀹�:%s x 闀�:%s] 宸叉帴鏀讹紝workLine=%s锛屾壂鎻忛棿闅�=%s",
+ String msg = String.format("鐜荤拑[%s] 灏哄[瀹�:%s x 闀�:%s] 宸叉帴鏀讹紝workLine=%s",
glassId,
rawWidth != null ? rawWidth + "mm" : "-",
rawHeight != null ? rawHeight + "mm" : "-",
- workLine != null ? workLine : "-",
- intervalMs != null ? intervalMs + "ms" : "-");
+ workLine != null ? workLine : "-");
Map<String, Object> resultData = new HashMap<>();
resultData.put("glassIds", Collections.singletonList(glassId));
if (workLine != null) {
@@ -180,7 +177,7 @@
if (contextObj instanceof TaskExecutionContext) {
TaskExecutionContext context = (TaskExecutionContext) contextObj;
List<String> scannedGlassIds = (List<String>) context.getSharedData()
- .computeIfAbsent("scannedGlassIds", k -> new java.util.ArrayList<>());
+ .computeIfAbsent("scannedGlassIds", k -> new ArrayList<>());
if (!scannedGlassIds.contains(glassId)) {
scannedGlassIds.add(glassId);
log.debug("宸蹭繚瀛樻壂鎻忓埌鐨勭幓鐠僆D鍒板叡浜暟鎹�: glassId={}", glassId);
@@ -189,13 +186,13 @@
}
private DevicePlcVO.OperationResult clearPlc(DeviceConfig deviceConfig,
- EnhancedS7Serializer serializer) {
+ PlcClient plcClient) {
try {
// 鍙竻绌篜LC鎿嶄綔鍖哄瓧娈碉紙plcRequest銆乸lcGlassId锛夛紝涓嶆竻绌篗ES鍐欏尯瀛楁
Map<String, Object> resetFields = new HashMap<>();
resetFields.put("plcRequest", 0);
resetFields.put("plcGlassId", "");
- plcDynamicDataService.writePlcData(deviceConfig, resetFields, serializer);
+ plcClient.writeData(resetFields);
return buildResult(deviceConfig, "clearPlc", true, "宸叉竻绌篜LC鎿嶄綔鍖哄瓧娈碉紙淇濈暀MES鍐欏尯瀛楁锛�", null);
} catch (Exception e) {
log.error("鍗ц浆绔嬫壂鐮佹竻绌篜LC澶辫触, deviceId={}", deviceConfig.getId(), e);
@@ -206,7 +203,7 @@
/**
* 瑙﹀彂MES璇锋眰锛氬啓鍏lcRequest=1鍜宲lcGlassId锛堝鏋滄彁渚涗簡鐜荤拑ID锛�
*/
- private void triggerScanRequest(DeviceConfig deviceConfig, EnhancedS7Serializer serializer, String glassId) {
+ private void triggerScanRequest(DeviceConfig deviceConfig, PlcClient plcClient, String glassId) {
Map<String, Object> writeFields = new HashMap<>();
writeFields.put("plcRequest", 1);
@@ -214,18 +211,18 @@
writeFields.put("plcGlassId", glassId);
}
- plcDynamicDataService.writePlcData(deviceConfig, writeFields, serializer);
+ plcClient.writeData(writeFields);
}
/**
* 娓呯┖PLC璇锋眰瀛楁锛氬彧娓呴櫎plcRequest鍜宲lcGlassId锛堜笉娓呴櫎MES鍐欏尯瀛楁锛�
*/
- private void clearPlcRequestFields(DeviceConfig deviceConfig, EnhancedS7Serializer serializer) {
+ private void clearPlcRequestFields(DeviceConfig deviceConfig, PlcClient plcClient) {
try {
Map<String, Object> clearFields = new HashMap<>();
clearFields.put("plcRequest", 0);
clearFields.put("plcGlassId", "");
- plcDynamicDataService.writePlcData(deviceConfig, clearFields, serializer);
+ plcClient.writeData(clearFields);
} catch (Exception e) {
log.error("娓呯┖PLC璇锋眰瀛楁澶辫触: deviceId={}", deviceConfig.getId(), e);
// 涓嶆竻绌轰笉褰卞搷涓绘祦绋嬶紝鍙褰曢敊璇�
@@ -233,14 +230,14 @@
}
private Map<String, Object> waitForMesData(DeviceConfig deviceConfig,
- EnhancedS7Serializer serializer,
+ PlcClient plcClient,
WorkstationLogicConfig config) throws InterruptedException {
long timeoutMs = Math.max(config.getScanIntervalMs(), 3_000);
long deadline = System.currentTimeMillis() + timeoutMs;
int pollInterval = Math.max(200, Math.min(config.getScanIntervalMs() / 5, 1_000));
while (System.currentTimeMillis() < deadline) {
- Map<String, Object> mesData = plcDynamicDataService.readPlcData(deviceConfig, MES_FIELDS, serializer);
+ Map<String, Object> mesData = plcClient.readData(MES_FIELDS.toArray(new String[0]));
if (mesData != null && !mesData.isEmpty()) {
Integer mesSend = parseInteger(mesData.get("mesSend"));
@@ -260,7 +257,7 @@
// 瓒呮椂鍓嶆渶鍚庝竴娆″皾璇曡鍙�
log.warn("绛夊緟MES鏁版嵁瓒呮椂: deviceId={}, timeout={}ms", deviceConfig.getId(), timeoutMs);
- Map<String, Object> lastMesData = plcDynamicDataService.readPlcData(deviceConfig, MES_FIELDS, serializer);
+ Map<String, Object> lastMesData = plcClient.readData(MES_FIELDS.toArray(new String[0]));
if (lastMesData != null && !lastMesData.isEmpty()) {
log.warn("瓒呮椂鍓嶆渶鍚庝竴娆¤鍙栧埌鐨勬暟鎹�: deviceId={}, mesData={}",
deviceConfig.getId(), lastMesData);
--
Gitblit v1.8.0