添加大车、大理片笼以及多设备串行/并行执行写入基础逻辑

huang

2025-11-20 366ba040d2447bacd3455299425e3166f1f992bb

 mes-processes/mes-plcSend/src/main/java/com/mes/interaction/flow/LoadVehicleInteraction.java

@@ -1,9 +1,12 @@
package com.mes.interaction.flow;

import com.mes.device.entity.DeviceConfig;
import com.mes.device.service.DeviceInteractionService;
import com.mes.device.vo.DevicePlcVO;
import com.mes.interaction.DeviceInteraction;
import com.mes.interaction.base.InteractionContext;
import com.mes.interaction.base.InteractionResult;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

@@ -16,7 +19,10 @@
 * 上大车交互实现
 */
@Component
@RequiredArgsConstructor
public class LoadVehicleInteraction implements DeviceInteraction {

    private final DeviceInteractionService deviceInteractionService;

    @Override
    public String getDeviceType() {
@@ -25,19 +31,65 @@

    @Override
    public InteractionResult execute(InteractionContext context) {
        List<String> glassIds = context.getParameters().getGlassIds();
        if (CollectionUtils.isEmpty(glassIds)) {
            return InteractionResult.waitResult("未提供玻璃ID，等待输入", null);
        try {
            // 前置条件验证
            if (context.getCurrentDevice() == null) {
                return InteractionResult.fail("设备配置不存在");
            }

            List<String> glassIds = context.getParameters().getGlassIds();
            if (CollectionUtils.isEmpty(glassIds)) {
                return InteractionResult.waitResult("未提供玻璃ID，等待输入", null);
            }

            // 验证玻璃ID格式
            for (String glassId : glassIds) {
                if (glassId == null || glassId.trim().isEmpty()) {
                    return InteractionResult.fail("玻璃ID不能为空");
                }
            }

            // 构建PLC写入参数
            Map<String, Object> params = new HashMap<>();
            params.put("glassIds", glassIds);
            params.put("positionCode", context.getParameters().getPositionCode());
            params.put("positionValue", context.getParameters().getPositionValue());
            params.put("triggerRequest", true);

            // 执行实际的PLC写入操作
            DevicePlcVO.OperationResult plcResult = deviceInteractionService.executeOperation(
                    context.getCurrentDevice().getId(), 
                    "feedGlass", 
                    params
            );

            // 检查PLC写入结果
            if (plcResult == null || !Boolean.TRUE.equals(plcResult.getSuccess())) {
                String errorMsg = plcResult != null ? plcResult.getMessage() : "PLC写入操作返回空结果";
                return InteractionResult.fail("PLC写入失败: " + errorMsg);
            }

            // 执行上大车操作（数据流转）
            List<String> copied = new ArrayList<>(glassIds);
            context.setLoadedGlassIds(copied);
            context.getSharedData().put("glassesFromVehicle", copied);
            context.getSharedData().put("loadVehicleTime", System.currentTimeMillis());

            // 后置条件检查
            if (context.getLoadedGlassIds().isEmpty()) {
                return InteractionResult.fail("上大车操作失败：玻璃ID列表为空");
            }

            Map<String, Object> data = new HashMap<>();
            data.put("loaded", copied);
            data.put("glassCount", copied.size());
            data.put("deviceId", context.getCurrentDevice().getId());
            data.put("deviceCode", context.getCurrentDevice().getDeviceCode());
            data.put("plcResult", plcResult.getMessage());
            return InteractionResult.success(data);
        } catch (Exception e) {
            return InteractionResult.fail("上大车交互执行异常: " + e.getMessage());
        }

        List<String> copied = new ArrayList<>(glassIds);
        context.setLoadedGlassIds(copied);
        context.getSharedData().put("glassesFromVehicle", copied);

        Map<String, Object> data = new HashMap<>();
        data.put("loaded", copied);
        data.put("glassCount", copied.size());
        return InteractionResult.success(data);
    }
}