package com.dy.testClient.tcpClient;

import com.dy.common.threadPool.ThreadPool;
import com.dy.testClient.httpCl.*;

import java.util.Base64;

public class MyThreadJob  implements ThreadPool.Job {

    public String rtuAddr;

    public MyThreadJob(){
    }
    public MyThreadJob(String rtuAddr){
        this.rtuAddr = rtuAddr ;
    }

    @Override
    public void execute() throws Exception {
        testP206V1_0_0() ;
    }

    private void testP206V1_0_0(){
        try{
            RtuData4MeterV1_0 rd = new RtuData4MeterV1_0() ;
            byte[] bs = rd.create(rtuAddr) ;
            bs = Base64.getEncoder().encode(bs) ;

            UpDataPayloadVo payloadVo = new UpDataPayloadVo() ;
            payloadVo.APPdata = new String(bs, "UTF-8") ;

            UpDataVo vo = new UpDataVo(rtuAddr, "8086" + rtuAddr) ;
            vo.payload = payloadVo ;
            String json = vo.toJson() ;
            byte[] bytes = json.getBytes() ;
            HttpPost.post(bytes);
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            HttpClUnit.clientOver() ;
        }
    }


    @Override
    public void destroy() {
    }

    @Override
    public boolean isDestroy() {
        return false;
    }


}