|
|
|
//
|
|
|
|
// Source code recreated from a .class file by IntelliJ IDEA
|
|
|
|
// (powered by Fernflower decompiler)
|
|
|
|
//
|
|
|
|
|
|
|
|
package com.airport.core;
|
|
|
|
|
|
|
|
import com.airport.bean.MessageBak;
|
|
|
|
import com.airport.bean.XMLHeader;
|
|
|
|
import com.airport.dao.Dao;
|
|
|
|
import com.airport.dao.impl.DaoImpl;
|
|
|
|
import com.airport.util.ConfigUtils;
|
|
|
|
import com.airport.util.SystemBean;
|
|
|
|
import com.airport.util.Utils;
|
|
|
|
import com.airport.util.parse.IMFXMLMaker;
|
|
|
|
import com.airport.util.parse.XMPParse;
|
|
|
|
import com.caac.imf.api.IMFClient;
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
import org.apache.log4j.Logger;
|
|
|
|
|
|
|
|
import java.util.Iterator;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
|
|
public class ZYFNoDelaySender extends Thread{
|
|
|
|
private static final Logger logger = Logger.getLogger(ZYFNoDelaySender.class);
|
|
|
|
private Dao dao = (DaoImpl)SystemBean.getBean("dao");
|
|
|
|
private IMFClient client;
|
|
|
|
private String indexFileName; //记录发送数据的节点
|
|
|
|
private String sql;
|
|
|
|
private String sqlMax;
|
|
|
|
|
|
|
|
public ZYFNoDelaySender(IMFClient client, String fileName, String sql, String sqlMax) {
|
|
|
|
this.indexFileName = fileName;
|
|
|
|
this.client = client;
|
|
|
|
this.sql=sql;
|
|
|
|
this.sqlMax=sqlMax;
|
|
|
|
}
|
|
|
|
|
|
|
|
public synchronized void run() {
|
|
|
|
try {
|
|
|
|
|
|
|
|
if (this.client == null) {
|
|
|
|
logger.info("IMFClient has been closed");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
while(true) {
|
|
|
|
//初始化读取
|
|
|
|
logger.info("job start，发送线程开始["+Thread.currentThread().getName()+"]");
|
|
|
|
int lastFID = Utils.readFIDIndex(this.indexFileName);
|
|
|
|
int maxFID = this.dao.getMaxFID(sqlMax);
|
|
|
|
logger.info("lastROW=" + lastFID + " maxCount=" + maxFID);
|
|
|
|
int is_ok = 0;
|
|
|
|
|
|
|
|
if (maxFID > lastFID) {
|
|
|
|
//这里修改从FID_INDEX文件读取的FID ，改为取搜索结果的rownum，此处FID代表ROWNUM
|
|
|
|
String sqlformat = String.format(sql, lastFID, lastFID, ConfigUtils.RECORD_COUNT);
|
|
|
|
logger.info(sqlformat);
|
|
|
|
List<MessageBak> list = this.dao.getRecordByFID(lastFID,sqlformat); //查询大于[FID]350的报文
|
|
|
|
//如果两个发送者，要用到这里
|
|
|
|
Map<Integer, XMLHeader> map = ConfigUtils.XML_HEADER_MAP;
|
|
|
|
Iterator var7 = list.iterator();
|
|
|
|
|
|
|
|
while(var7.hasNext()) {
|
|
|
|
MessageBak m = (MessageBak)var7.next();
|
|
|
|
if (is_ok != 0) {
|
|
|
|
logger.error("记录FID时发生异常，发送消息任务被迫中断");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (m.getContent() != null) {
|
|
|
|
int times = 0;
|
|
|
|
//配置文件里面有几个sender 这里循环几次
|
|
|
|
for(Iterator var10 = map.keySet().iterator(); var10.hasNext(); times++) {
|
|
|
|
Integer key = (Integer)var10.next();
|
|
|
|
XMLHeader header = (XMLHeader)map.get(key);
|
|
|
|
logger.info("key=" + key + " value=" + ((XMLHeader)map.get(key)).toString());
|
|
|
|
logger.info("准备发送数据 FID:" + m.getFid() + " XML.length=:" + m.getContent().length());
|
|
|
|
|
|
|
|
|
|
|
|
//初始化最终发布报文内容的存储器
|
|
|
|
String sendMsg = "";
|
|
|
|
String xmlStr = m.getContent();
|
|
|
|
|
|
|
|
|
|
|
|
//_____________________________________给多式联运的航空报文，读取配置文件，生成新的META，并把最原始的报文封装到新报文的content里面--------------------------------------------------------------------
|
|
|
|
String sndr = header.getSndr();
|
|
|
|
String type = header.getType();
|
|
|
|
String styp = header.getStype();
|
|
|
|
|
|
|
|
IMFXMLMaker newXml = new IMFXMLMaker(sndr,Integer.toString(m.getFid()),type,styp);
|
|
|
|
newXml.setIMFContent(m.getContent());
|
|
|
|
sendMsg = newXml.finalXmlStr();
|
|
|
|
|
|
|
|
if (!"".equals(sendMsg)) {
|
|
|
|
sendXml(sendMsg);
|
|
|
|
is_ok = Utils.writeFIDIndex(this.indexFileName, m.getRownum_()); //发送成功写入节点文件
|
|
|
|
logger.debug("FID:" + m.getFid() + " 缓存成功");
|
|
|
|
++times;
|
|
|
|
} else {
|
|
|
|
logger.error("查找替换节点数据出现异常,可能找不到这个节点，原始XML=" + m.getContent());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// this.dao.update(m.getFid(), times);
|
|
|
|
} else {
|
|
|
|
logger.info("FID=" + m.getFid() + "XML is null ");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}else {
|
|
|
|
try {
|
|
|
|
Thread.sleep(100000L);
|
|
|
|
logger.info("发送线程》》》"+Thread.currentThread().getName()+"休眠");
|
|
|
|
} catch (InterruptedException var3) {
|
|
|
|
var3.printStackTrace();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}catch (Exception var14) {
|
|
|
|
var14.printStackTrace();
|
|
|
|
logger.info(var14.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public synchronized void sendXml(String msg){
|
|
|
|
logger.info("线程:::"+Thread.currentThread().getName()+"开始发送数据 XML:" + msg);
|
|
|
|
String is_send_ok = this.client.sendMSG(msg);
|
|
|
|
logger.info("发送回执=" + is_send_ok);
|
|
|
|
}
|
|
|
|
|
|
|
|
private static String tranlateXML(String xml) throws Exception {
|
|
|
|
String stype = XMPParse.getNodeValueFromXmlString(xml, "/MSG/META/STYP");
|
|
|
|
if (!StringUtils.isBlank(stype)) {
|
|
|
|
if (ConfigUtils.XTYPE_MAP.containsKey(stype)) {
|
|
|
|
stype = (String)ConfigUtils.XTYPE_MAP.get(stype);
|
|
|
|
} else {
|
|
|
|
logger.info("stype=" + stype + " 在对应关系里找不到这个KEY");
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
logger.info(" 在XML找不到STYPE这个节点");
|
|
|
|
stype = "";
|
|
|
|
}
|
|
|
|
|
|
|
|
return stype;
|
|
|
|
}
|
|
|
|
} |
...
|
...
|
|
