package com.sy.task;

import com.sy.bwAnalysis.MessageAnalysis;
import com.sy.bwAssist.Message;
import com.sy.service.router.MessageRouter;
import com.sy.service.router.RouterContext;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/**
 * 本地报文处理器
 */
@Component
@Slf4j
public class LocalFileTaskHandle implements Runnable{

    private static  LocalFileTaskHandle localFileTaskHandle;

    private String message;

    @Qualifier("X21")
    @Autowired
    private MessageRouter messageRouterX21;

    @Qualifier("X22")
    @Autowired
    private MessageRouter messageRouterX22;

    @PostConstruct
    public void init() {
        localFileTaskHandle = this;
    }

    @Override
    public void run() {
        try{
            log.info("\n[LocalFileTaskHandle-XML-MESSAGE]-开始处理采集报文:\n{}\n",message);
            String xmlMessage = message.replace("Msg","MSG");
            MessageAnalysis analysis = new MessageAnalysis();
            Message message = analysis.readTicketsXml(xmlMessage);


            mesageHandle(message);
        }catch (Exception e){
            log.error("\n[LocalFileTaskHandle-ERR]-抓取到异常信息:",e);
        }

    }

    public void mesageHandle(Message message){
        if ("CARM".equals(message.getMeta().getSmType())) {
            //策略判断
            if(message.getComInfo() !=null){
                RouterContext routerContext = new RouterContext(localFileTaskHandle.messageRouterX22);
                routerContext.executeStrategy(message);
            }else{
                RouterContext routerContext = new RouterContext(localFileTaskHandle.messageRouterX21);
                routerContext.executeStrategy(message);
            }
        }
    }

    public void setMessage(String message) {
        this.message = message;
    }
}