package com.fzzy.protocol.weightyh;

import com.fzzy.api.utils.BytesUtil;
import com.fzzy.api.utils.SpringUtil;
import com.fzzy.gateway.GatewayUtils;
import com.fzzy.gateway.api.GatewayRemoteManager;
import com.fzzy.gateway.entity.GatewayDevice;
import com.ld.io.api.IoMsgConsumer;
import com.ld.io.api.IoSession;
import lombok.extern.slf4j.Slf4j;

/**
 * 地磅信息推送
 *
 * @author: andy.jia
 * @description:
 * @version:
 * @data:2020年3月19日
 */
@Slf4j
public class MessageConsumer implements IoMsgConsumer {

    private long timeTag = 0;

    private GatewayRemoteManager reportService;

    @Override
    public void consume(IoSession session, byte[] bytes) {
        analysisInfo(session.getAddress(), session.getPort(), bytes);
    }

    /**
     * 02 2B 30 30 31 31 38 30 30 31 33 03 02开始 03 结束
     */
    public void analysisInfo(String ip, Integer port, byte[] bytes) {
        String strMsg = BytesUtil.bytesToString(bytes);
        //log.debug("开始解析地磅返回信息=" + strMsg);
        if (strMsg.length() < 22) {
            return;
        }

        // 每间隔2.5执行一次
        if (System.currentTimeMillis() - timeTag <= 2500) {
            return;
        }
        timeTag = System.currentTimeMillis();

        String temp = strMsg.substring(2, 4);
        //String symbol = HexASCIIToConvert(temp);
        temp = strMsg.substring(4, 16);
        String w = HexASCIIToConvert(temp);
        temp = strMsg.substring(16, 18);
        int d = getProduct(Integer.parseInt(HexASCIIToConvert(temp)));

        //最终重量结果
        double weigh = Double.valueOf(w) / d;


        log.debug("----------地磅称重数值解析------{}", weigh);

        //当前地磅协议不支持传递SN，使用局域网IP作为SN
        String sn = ip;


        //根据信息获取设备
        GatewayDevice device = GatewayUtils.getCacheByDeviceSn(sn);

        if (null == device) {
            log.error("----------没有获取到设备信息--------{}", sn);
            return;
        }

        //直接调用实现类，更多实现类单独调用
        if (null == reportService) {
            reportService = SpringUtil.getBean(GatewayRemoteManager.class);
        }

        reportService.getDeviceReportService(device.getPushProtocol()).report2GatewayBySn(weigh, device);
    }

    /**
     * 根据小数点位数计算原数字需要除以多少
     *
     * @param i
     */
    private int getProduct(int i) {
        if (i == 0)
            return 1;
        int num = 1;
        for (int a = 0; a < i; a++) {
            num = num * 10;
        }
        return num;
    }

    private String HexASCIIToConvert(String value) {
        // String value = "30 30 31 31 38 30 30";
        StringBuffer sbu = new StringBuffer();
        char t = 0;
        int size = value.length() / 2;
        for (int i = 0; i < size; i++) {
            String tmp = value.substring(i * 2, (i + 1) * 2);
            t = (char) Integer.parseInt(""
                    + BytesUtil.bytesToInt(BytesUtil.hexStrToBytes(tmp)));
            sbu.append(t);
        }

        return sbu.toString();
    }


}