朱兆平 / imfClient · 提交

转到一个项目

作者 朱兆平
提交 13bfae2733fc3b91c902a8ab1084d23be29c6cae 1 个父辈 030f9311

天信达测试发送

内嵌 并排对比
正在显示 4 个修改的文件 包含 52 行增加 和 17 行删除
... ... @@ -6,7 +6,7 @@
package com.airport;
import com.airport.core.IMFReader;
import com.airport.core.SendMessageTask;
import com.airport.core.IMFSender;
import com.airport.util.ConfigUtils;
import com.airport.util.SystemBean;
import com.caac.imf.api.IMFClient;
... ... @@ -41,8 +41,10 @@ public class Main {
if (LOGIN_OK && client != null) {
logger.info("start run Timer,client hasocde=" + client.hashCode());
Timer timer = new Timer();
SendMessageTask sender = new SendMessageTask(client, "data/fid_index.txt");
timer.schedule(sender, 30000L, 1200000L);
// SendMessageTask sender = new SendMessageTask(client, "data/fid_index.txt");
IMFSender imfSender = new IMFSender(client,"data/fid_index.txt");
// timer.schedule(sender, 30000L, 1200000L);
timer.schedule(imfSender,30000L,1200000L);
}
}
... ...
... ... @@ -12,20 +12,23 @@ 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.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;
import java.util.TimerTask;
import org.apache.log4j.Logger;
public class SendMessageTask extends TimerTask {
private static final Logger logger = Logger.getLogger(SendMessageTask.class);
public class IMFSender extends TimerTask {
private static final Logger logger = Logger.getLogger(IMFSender.class);
private Dao dao = (DaoImpl)SystemBean.getBean("dao");
private IMFClient client;
private String indexFileName;
public SendMessageTask(IMFClient client, String fileName) {
public IMFSender(IMFClient client, String fileName) {
this.indexFileName = fileName;
this.client = client;
}
... ... @@ -65,7 +68,8 @@ public class SendMessageTask extends TimerTask {
logger.info("准备发送数据 FID:" + m.getFid() + " XML.length=:" + m.getContent().length());
String sendMsg = Utils.searchReplace(m.getContent(), header.getSndr(), "SNDR");
sendMsg = Utils.searchReplace(sendMsg, header.getType(), "TYPE");
sendMsg = Utils.searchReplace(sendMsg, header.getStype(), "STYP");
String stype = tranlateXML(m.getContent());
sendMsg = Utils.searchReplace(sendMsg, stype, "STYP");
sendMsg = Utils.searchReplaceSingle(sendMsg, header.getRcvr(), "RCVR");
if (!"".equals(sendMsg)) {
logger.info("开始发送数据 XML:" + sendMsg);
... ... @@ -79,7 +83,7 @@ public class SendMessageTask extends TimerTask {
}
}
this.dao.update(m.getFid(), times);
// this.dao.update(m.getFid(), times);
} else {
logger.info("FID=" + m.getFid() + "XML is null ");
}
... ... @@ -96,4 +100,20 @@ public class SendMessageTask extends TimerTask {
}
}
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;
}
}
... ...
... ... @@ -45,7 +45,7 @@ public class DaoImpl implements Dao {
this.jdbcTemplate.update(new PreparedStatementCreator() {
public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
DaoImpl.logger.info("oper=" + oper + " sndr=" + sndr);
String sql = "insert into T_ETL_MESSAGE(OPER,SNDR,SNTM,content) values(?,?,sysdate,empty_clob())";
String sql = "insert into MESSAGE_BAK(OPER,SNDR,SNTM,content) values(?,?,sysdate,empty_clob())";
PreparedStatement ps = connection.prepareStatement(sql, new String[]{"FID"});
ps.setString(1, oper);
ps.setString(2, sndr);
... ... @@ -67,7 +67,7 @@ public class DaoImpl implements Dao {
conn = this.jdbcTemplate.getDataSource().getConnection();
conn.setAutoCommit(false);
stmt = conn.createStatement();
String SQL = "select CONTENT from T_ETL_MESSAGE where FID=" + fid + " and SNDR='FIMS' for update";
String SQL = "select CONTENT from MESSAGE_BAK where FID=" + fid + " and SNDR='CFPS' for update";
rs = stmt.executeQuery(SQL);
while(rs.next()) {
... ... @@ -108,15 +108,15 @@ public class DaoImpl implements Dao {
}
public void delete(int fid) {
this.jdbcTemplate.update("delete from T_ETL_MESSAGE where fid=" + fid);
this.jdbcTemplate.update("delete from MESSAGE_BAK where fid=" + fid);
}
public int getMaxFID() {
return this.jdbcTemplate.queryForInt("select max(FID) from T_ETL_MESSAGE where SNDR='FIMS'");
return this.jdbcTemplate.queryForInt("select max(FID) from MESSAGE_BAK where SNDR='CFPS'");
}
public List<MessageBak> getRecordByFID(int fid) {
String SQL_FMT = "select FID,CONTENT from T_ETL_MESSAGE where (FID>%s and FID<%s+%s) and SNDR='FIMS' order by FID";
String SQL_FMT = "select FID,CONTENT from MESSAGE_BAK where (FID>%s and FID<%s+%s) and (SNDR='CFPS') order by FID";
String sql = String.format(SQL_FMT, fid, fid, ConfigUtils.RECORD_COUNT);
logger.info(sql);
final LobHandler lobHandler = new DefaultLobHandler();
... ... @@ -148,11 +148,11 @@ public class DaoImpl implements Dao {
}
public int getRecordCount() {
return this.jdbcTemplate.queryForInt("select count(*) from T_ETL_MESSAGE where SNDR='FIMS' ");
return this.jdbcTemplate.queryForInt("select count(*) from MESSAGE_BAK where SNDR='CFPS' ");
}
public void update(int fid, int times) {
String sql = String.format("update T_ETL_MESSAGE set OUTFLAG=%s ,OUTTM=sysdate where FID=%s", times, fid);
String sql = String.format("update MESSAGE_BAK set OUTFLAG=%s ,OUTTM=sysdate where FID=%s", times, fid);
logger.info("sql=" + sql);
this.jdbcTemplate.update(sql);
}
... ...
... ... @@ -27,13 +27,26 @@ public class ConfigUtils {
public static String XML_HEADER_STYPE = "";
public static String XML_HEADER_RCVR = "";
public static Map<Integer, XMLHeader> XML_HEADER_MAP = new HashMap();
public static String RCVR = "";
public static String APPID = "";
public static String SNDR = "";
public static Map<String, String> XTYPE_MAP = new HashMap();
public ConfigUtils() {
}
private void initMap() {
XTYPE_MAP.put("FSU_DEP", "UDEP");
XTYPE_MAP.put("FSU_RCF", "URCF");
XTYPE_MAP.put("FSU_FOH", "UFOH");
XTYPE_MAP.put("FZE_DEP", "EDEP");
XTYPE_MAP.put("FZE_RCF", "ERCF");
XTYPE_MAP.put("FZE_FOH", "EFOH");
XTYPE_MAP.put("CARGO_SERV", "CARG");
}
public void Initialize() throws LteException {
logger.debug("Loading all the config parameters...");
this.loadParameter();
this.initMap();
}
private final void loadParameter() throws LteException {
... ...