package com.mes.interaction.workstation.base;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.mes.device.entity.DeviceConfig;
|
import com.mes.device.service.DevicePlcOperationService;
|
import com.mes.device.vo.DevicePlcVO;
|
import com.mes.interaction.BaseDeviceLogicHandler;
|
import com.mes.interaction.workstation.config.WorkstationLogicConfig;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import java.util.Map;
|
|
/**
|
* 卧转立系列设备的通用处理器基类
|
* 负责解析 workstation 配置、提供占位的执行模板，后续具体设备在子类中实现。
|
*
|
* @author mes
|
* @since 2025-11-24
|
*/
|
@Slf4j
|
public abstract class WorkstationBaseHandler extends BaseDeviceLogicHandler {
|
|
protected WorkstationBaseHandler(DevicePlcOperationService devicePlcOperationService) {
|
super(devicePlcOperationService);
|
}
|
|
/**
|
* 解析 workstation 相关配置
|
*/
|
protected WorkstationLogicConfig parseWorkstationConfig(Map<String, Object> logicParams) {
|
WorkstationLogicConfig config = new WorkstationLogicConfig();
|
if (logicParams == null) {
|
return config;
|
}
|
config.setScanIntervalMs(getLogicParam(logicParams, "scanIntervalMs", 10_000));
|
config.setTransferDelayMs(getLogicParam(logicParams, "transferDelayMs", 30_000));
|
config.setVehicleCapacity(getLogicParam(logicParams, "vehicleCapacity", 6000));
|
config.setAutoAck(getLogicParam(logicParams, "autoAck", Boolean.TRUE));
|
return config;
|
}
|
|
/**
|
* 默认实现：提示尚未实现具体逻辑
|
*/
|
@Override
|
protected DevicePlcVO.OperationResult doExecute(com.mes.device.entity.DeviceConfig deviceConfig,
|
String operation,
|
java.util.Map<String, Object> params,
|
java.util.Map<String, Object> logicParams) {
|
log.warn("当前设备逻辑尚未实现: deviceType={}, operation={}", deviceConfig.getDeviceType(), operation);
|
return DevicePlcVO.OperationResult.builder()
|
.success(false)
|
.message("设备逻辑待实现: " + deviceConfig.getDeviceType())
|
.build();
|
}
|
|
@Override
|
public String validateLogicParams(DeviceConfig deviceConfig) {
|
// 默认认为配置合法，具体校验交由子类实现
|
return null;
|
}
|
|
@Override
|
public String getDefaultLogicParams() {
|
Map<String, Object> defaults = new HashMap<>();
|
defaults.put("scanIntervalMs", 10_000);
|
defaults.put("transferDelayMs", 30_000);
|
defaults.put("vehicleCapacity", 6_000);
|
defaults.put("autoAck", true);
|
try {
|
return objectMapper.writeValueAsString(defaults);
|
} catch (JsonProcessingException e) {
|
return "{\"scanIntervalMs\":10000,\"transferDelayMs\":30000,\"vehicleCapacity\":6000,\"autoAck\":true}";
|
}
|
}
|
}
|
