完善不发送共享航班信息及消息

This commit is contained in:
zhouxiunai
2019-01-25 10:14:38 +08:00
parent 3b95239fdc
commit c715a135de
3 changed files with 14 additions and 11 deletions
@@ -61,11 +61,15 @@ public class FlopBaseHandler implements IBaseHandler {
// //
flightInfoService.saveFltr(fltrResult); flightInfoService.saveFltr(fltrResult);
//send and update //send and update,,不发送共享航班信息及消息
this.addToBuffer(fltrResult); if(fltr.getMAID() == null)
this.sendMsg(cminmsg); {
this.updateCminmsgToProcessed(cminmsg); this.addToBuffer(fltrResult);
this.sendMsg(cminmsg);
}
this.updateCminmsgToProcessed(cminmsg);
return HandlerResult.success(fltrResult); return HandlerResult.success(fltrResult);
} }
else { else {
@@ -33,9 +33,13 @@ public class ADFTHandler extends SchdBaseHandler{
FLTR fltr = msg.getSCHD().getFLTR().get(0); FLTR fltr = msg.getSCHD().getFLTR().get(0);
flightInfoService.saveFltr(fltr); flightInfoService.saveFltr(fltr);
//不发送共享航班信息及消息
if(fltr.getMAID() == null)
{
this.addToBuffer(fltr);
this.sendMsg(cminmsg);
}
this.addToBuffer(fltr);
this.sendMsg(cminmsg);
this.updateCminmsgToProcessed(cminmsg); this.updateCminmsgToProcessed(cminmsg);
@@ -21,11 +21,6 @@ public class FltrSendBufferService implements IFltrSendBufferService {
@Override @Override
public void addFltr(SCHD.FLTR fltr) { public void addFltr(SCHD.FLTR fltr) {
//共享航班不进入发送缓存,不发送到前端
if (fltr.getMAID() != null) {
return ;
}
synchronized (fltrBuffer) { synchronized (fltrBuffer) {
fltrBuffer.add(fltr); fltrBuffer.add(fltr);
} }