package com.mes.connect.addressparser;

import com.mes.connect.industrialinterface.AddressParser;
import com.mes.connect.protocol.ProtocolAddress;
import com.mes.connect.protocol.ProtocolType;


/**
 * Modbus地址解析器
 *
 * @author yzx
 * @version 1.0
 */
public class ModbusAddressParser implements AddressParser {

    /**
     * modbusTcp协议
     */
    private final String protocolMB="MB";
    /**
     * 字符串截取
     */
    private final String protocolMB_="MB.";
    /**
     * 地址类型
     */
    private final String addressTypeDB="DB";

    /**
     * 地址值类型
     */
    private final String valueTypeDBW="DBW";

    /**
     * 地址值类型
     */
    private final String valueTypeDBD="DBD";
    /**
     * 线圈
     */
    private final String functionCode0x="0x";
    /**
     * 离散输入
     */
    private final String functionCode1x="1x";
    /**
     * 离散输入
     */
    private final String functionCode3x="3x";
    /**
     * 离散输入
     */
    private final String functionCode4x="4x";
    /**
     * 离散输入
     */
    private final int functionCode3=3;
    /**
     * 读写功能码
     */
    private final int functionCode4=4;


    /**
     * @param address
     * @return
     */
    @Override
    public ProtocolAddress parse(String address) {
        // 格式示例: "MB.4x0001" 或 "MB.0x100.2"
        if (!address.startsWith(protocolMB)) {
            throw new IllegalArgumentException("Invalid Modbus address format: " + address);
        }

        String[] parts = address.substring(3).split("\\.");

        if (parts.length < 1) {
            throw new IllegalArgumentException("Invalid Modbus address format: " + address);
        }

        // 解析区域
        String areaStr = parts[0];
        int functionCode;

        if (areaStr.startsWith(functionCode0x)) {
            // 1读线圈 5写单个线圈
            functionCode = 1;
        } else if (areaStr.startsWith(functionCode1x)) {
            // 读离散输入
            functionCode = 2;
        } else if (areaStr.startsWith(functionCode3x)) {
            // 读输入寄存器
            functionCode = 4;
        } else if (areaStr.startsWith(functionCode4x)) {
            // 读保持寄存器
            functionCode = 3;
        } else {
            throw new IllegalArgumentException("Invalid Modbus area: " + areaStr);
        }

        // 解析地址
        int addressValue = Integer.parseInt(areaStr.substring(2));
        if (functionCode == functionCode3 || functionCode == functionCode4) {
            addressValue--; // Modbus保持寄存器和输入寄存器地址从0开始
        }

        // 解析位地址（如果有）
        int bit = 0;
        if (parts.length > 1) {
            bit = Integer.parseInt(parts[1]);
        }

        return new ProtocolAddress(ProtocolType.MODBUS_TCP, functionCode, 0, addressValue, bit);
    }
}