package com.dy.testClient.httpCl;

import java.util.Base64;

import com.dy.common.threadPool.ThreadPool;

public class MyThreadJob implements ThreadPool.Job {

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

	@Override
	public void execute() throws Exception {
		testMeterV1_0() ;
		//testHAC_NBhV2_5() ;
	}
	
	private void testMeterV1_0(){
		try{
			RtuData4MeterV1_0 rd = new RtuData4MeterV1_0() ;
			byte[] bs = rd.create(imei) ;
			bs = Base64.getEncoder().encode(bs) ;
			
			UpDataPayloadVo payloadVo = new UpDataPayloadVo() ;
			payloadVo.APPdata = new String(bs, "UTF-8") ;
			
			UpDataVo vo = new UpDataVo(imei, "8086" + imei ) ;
			vo.payload = payloadVo ;
			String json = vo.toJson() ;
			byte[] bytes = json.getBytes() ;
			HttpPost.post(bytes);
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			HttpClUnit.clientOver() ;
		}
	}
	
	@SuppressWarnings("unused")
	private void testHAC_NBhV2_5(){
		try{
			RtuData4HAC_NBhV2_5 rd = new RtuData4HAC_NBhV2_5() ;
			byte[] bs = rd.create(imei) ;
			bs = Base64.getEncoder().encode(bs) ;
			
			UpDataPayloadVo payloadVo = new UpDataPayloadVo() ;
			payloadVo.APPdata = new String(bs, "UTF-8") ;
			
			UpDataVo vo = new UpDataVo(imei, "8086" + imei ) ;
			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;
	}


}