package com.zy.core.netty.handle;

import com.zy.core.netty.domain.ChPackage;
import com.zy.core.netty.properties.TcpProperties;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 国标编码器
 * 此解码器将会生成校验码
 * 处理方式: 异或和
 * Created by vincent on 2019-04-02
 */
@Slf4j
@Component
@ChannelHandler.Sharable
public class ProtocolEncoder extends MessageToByteEncoder<Object> {

    @Autowired
    private TcpProperties tcpProperties;

    @Override
    protected void encode(ChannelHandlerContext ctx, Object obj, ByteBuf out) {
        boolean upgradeLog = true;
        if (obj instanceof ByteBuf){
            out.writeBytes((ByteBuf) obj);
        } else if (obj instanceof byte[]) {
            out.writeBytes((byte[]) obj);
        } else if (obj instanceof ChPackage) {

        }
//        if (tcpProperties.isPrintPacLog() || upgradeLog){
//            log.info("uuid={} 下行 >>> {}", getVin(out), ByteBufUtil.hexDump(out));
//        }

    }

//    private String getVin(ByteBuf byteBuf){
//        byte[] bytes = new byte[PackagePart.UNIQUENO.getLen()];
//        byteBuf.markReaderIndex();
//        byteBuf.readerIndex(PackagePart.UNIQUENO.getStartIndex());
//        byteBuf.readBytes(bytes);
//        byteBuf.resetReaderIndex();
//        return RadixTools.bytesToStr(bytes);
//    }
}