package com.mes.s7.provider;

import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
import com.github.xingshuangs.iot.protocol.s7.service.S7PLC;
import com.mes.device.entity.DeviceConfig;
import com.mes.s7.enhanced.EnhancedS7Serializer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.Objects;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

/**
 * 提供 S7 序列化器的公共工厂，避免各处重复创建/缓存
 * @author huang
 */
@Slf4j
@Component
public class S7SerializerProvider {

    private final ConcurrentMap<String, EnhancedS7Serializer> serializerCache = new ConcurrentHashMap<>();

    /**
     * 获取或创建与设备绑定的 S7 序列化器
     */
    public EnhancedS7Serializer getSerializer(DeviceConfig deviceConfig) {
        if (deviceConfig == null) {
            log.error("设备配置为空，无法获取S7序列化器");
            return null;
        }

        String cacheKey = buildCacheKey(deviceConfig);
        return serializerCache.computeIfAbsent(cacheKey, key -> createSerializer(deviceConfig));
    }

    /**
     * 清除指定设备对应的缓存
     */
    public void clear(DeviceConfig deviceConfig) {
        if (deviceConfig == null) {
            return;
        }
        serializerCache.remove(buildCacheKey(deviceConfig));
    }

    private String buildCacheKey(DeviceConfig deviceConfig) {
        if (deviceConfig.getId() != null) {
            return "device:" + deviceConfig.getId();
        }
        if (deviceConfig.getDeviceCode() != null) {
            return "device:" + deviceConfig.getDeviceCode();
        }
        return "device:" + Objects.hash(deviceConfig);
    }

    private EnhancedS7Serializer createSerializer(DeviceConfig deviceConfig) {
        try {
            EPlcType plcType = parsePlcType(deviceConfig.getPlcType());
            String plcIp = deviceConfig.getPlcIp();
            if (plcIp == null || plcIp.isEmpty()) {
                log.warn("设备未配置PLC IP，使用默认值 192.168.10.21, deviceId={}", deviceConfig.getId());
                plcIp = "192.168.10.21";
            }
            S7PLC s7Plc = new S7PLC(plcType, plcIp);
            EnhancedS7Serializer serializer = EnhancedS7Serializer.newInstance(s7Plc);
            if (serializer == null) {
                log.error("创建EnhancedS7Serializer失败: deviceId={}, plcIp={}, plcType={}",
                        deviceConfig.getId(), plcIp, plcType);
            }
            return serializer;
        } catch (Exception e) {
            log.error("创建S7序列化器异常: deviceId={}", deviceConfig.getId(), e);
            return null;
        }
    }

    private EPlcType parsePlcType(String plcTypeValue) {
        if (plcTypeValue == null || plcTypeValue.isEmpty()) {
            return EPlcType.S1200;
        }
        try {
            return EPlcType.valueOf(plcTypeValue);
        } catch (IllegalArgumentException e) {
            log.warn("未知的PLC类型: {}，使用默认类型S1200", plcTypeValue);
            return EPlcType.S1200;
        }
    }
}