package com.tianbo.imfClient.schedul;

import com.caac.imf.api.IMFClient;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestOperations;

@Component
public class IMF_Reader extends Thread{
    protected static final Logger logger = Logger.getLogger(IMF_Reader.class);
    public static  boolean isrunning;
    protected IMF_Reader imf_reader;


    @Autowired
    private RestOperations restTemplate;


    @Override
    public void run() {
        try{
            isrunning =true;
            while(true) {
                IMFClient client = IMF_Task.client;
                if (null==restTemplate){
                    RestTemplateBuilder builder = new RestTemplateBuilder();
                    restTemplate = builder.build();
                }
                if (IMF_Task.LOGIN_OK) {
                        String message = client.getMSG();
                        if (message != null) {
                            //调用spring cloud 其他服务接口处理
                            restTemplate.put("http://fimsagentserver/msgAgent",message);
//                            IMFSaveHandle imfSaveHandle = new IMFSaveHandle();
//                            imfSaveHandle.handle(message);
                        }

                } else {
                    //logger.info("***");
                }

                try {
                    Thread.sleep(500L);
                } catch (InterruptedException var3) {
                    var3.printStackTrace();

                }
            }

        }catch (Exception e){
            e.printStackTrace();
        }
        isrunning=false;
        logger.info("****************读取线程不在了****************");
    }
}