package com.airport.core;

import com.airport.Main;
import org.apache.log4j.Logger;
import com.caac.imf.api.IMFClient;

import redis.clients.jedis.Jedis;

import java.util.Properties;

public class AgentSender extends Thread{

    private static final Logger logger = Logger.getLogger(AgentSender.class);
    private static final String stype = "/MSG/META/STYP";

    public volatile boolean bool = false;
    Jedis jedis = new Jedis("10.50.3.73", 6379);
    //	Jedis jedis = new Jedis("192.168.0.253", 6379);
    public String str ;

    private IMFClient client;

    public AgentSender(IMFClient client){
        this.client = client;
    }

    public AgentSender(){
    }

    public void run(){
        logger.info(jedis);

        while(!bool){
            if(Main.isSuc){
                if(Main.LOGIN_OK){
                    String SendMsg = jedis.rpoplpush("task-queue", "tmp-queue"); //取队列消息
                    logger.info("队列消息为:》》》"+SendMsg);

                    //9是发送成功
                    if(SendMsg !=null){

                        try{
                            String returnMsg = client.sendMSG(SendMsg);
                            logger.debug("<<发送返回的信息:"+returnMsg+">>");

                            if(returnMsg.indexOf("<CODE>9</CODE>")>=0){
                                jedis.rpop("tmp-queue");
                                logger.debug("<<移除队列>>");
                            }else{
                                //如果发送不成功继续发送
                                jedis.rpoplpush("tmp-queue", "task-queue");
                                logger.info("！！<<执行未成功发送的消息返回到发送消息队列>>！！");
                            }
                        }catch (Exception e){
                            e.printStackTrace();
                            logger.info("！！<<请注意！发送异常====>>！！");
                        }

                    }

                }else{
                    logger.info("---------登陆中");
                }

                try {
                    Thread.sleep(500);//发送延迟
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public String getStr() {
        return str;
    }

    public void setStr(String str) {
        this.str = str;
    }
}