修改psdt增加原值机位信息记录。 修改dnld发送消息到msg

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/PSDTHandler.java

@@ -22,6 +22,19 @@ public class PSDTHandler extends FlopBaseHandler {
 	@Override
 	protected SCHD.FLTR  updateFltr(FLOP flop,SCHD.FLTR  fltr)
 	{
+		//先保存当前航班机位数据
+		String lpsdt="";
+		for(STANDDATA node : fltr.getPSDT()) 
+		{
+			lpsdt += node.getPSST();
+			lpsdt += ",";
+		}
+		if(lpsdt.endsWith(","))
+		{
+			lpsdt = lpsdt.substring(0, lpsdt.length() - 1);
+		}
+		fltr.setLpsdt(lpsdt);
+		
 		fltr.getPSDT().clear(); //清空旧数据
 		for(OPTSTANDDATA optStandata : flop.getPSDT() ) 
 		{

src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java

@@ -57,8 +57,14 @@ public class SchdBaseHandler  implements IBaseHandler{
 		int recs = dnldMsg.getSCHD().getRECS();
 		logger.info("发送日计划到kafka,条数:{}",recs);
 		
-		ResponseDto<Integer> resDto  =  ResponseDto.success(recs);
-		kafkaservice.msgSend("dschd", JsonUtil.getString(resDto));
+		
+		//去除body部分
+		MSG  dnldMsgCopy = new MSG();
+		dnldMsgCopy.setMETA(dnldMsg.getMETA());
+		dnldMsgCopy.setSCHD(null);
+		
+		String msg = exchangeService.msgToJson(dnldMsgCopy);
+		kafkaservice.msgSend("msg", msg);
 
         logger.info("发送日计划到kafka完毕");
 	}