修正航班删除问题。
This commit is contained in:
@@ -338,7 +338,7 @@ public class SCHD
|
|||||||
@XmlElement(name = "MVIN", required = true)
|
@XmlElement(name = "MVIN", required = true)
|
||||||
@JsonProperty("MVIN")
|
@JsonProperty("MVIN")
|
||||||
@XmlSchemaType(name = "string")
|
@XmlSchemaType(name = "string")
|
||||||
protected MOVEMENTINDICATOR mvin;//movement indicator 运行标识
|
protected MOVEMENTINDICATOR mvin;//movement indicator 运行标识,A – Arrival/到达 D – Departure/离港
|
||||||
|
|
||||||
@XmlElement(name = "SODT", required = true)
|
@XmlElement(name = "SODT", required = true)
|
||||||
@JsonProperty("SODT")
|
@JsonProperty("SODT")
|
||||||
|
|||||||
@@ -0,0 +1,44 @@
|
|||||||
|
package com.gzzn.omms.msgexchangeapi.msghandler.flop;
|
||||||
|
|
||||||
|
import org.springframework.beans.BeanUtils;
|
||||||
|
import org.springframework.util.CollectionUtils;
|
||||||
|
|
||||||
|
import com.gzzn.omms.msgexchangeapi.entity.msg.CHOCKSDATA;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.entity.msg.DELAYDATA;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTCHOCKSDATA;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDELAYDATA;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 航班轮挡时间事件
|
||||||
|
* @author zhouxiunai
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
public class CHOTHandler extends FlopBaseHandler {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr)
|
||||||
|
{
|
||||||
|
//update
|
||||||
|
if(CollectionUtils.isEmpty(flop.getCHOT()) )
|
||||||
|
{
|
||||||
|
//清空轮档时间事件
|
||||||
|
fltr.getCHOT().clear();
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
//新增
|
||||||
|
for (OPTCHOCKSDATA optchocksdata : flop.getCHOT() ) {
|
||||||
|
|
||||||
|
CHOCKSDATA chocksdata = new CHOCKSDATA();
|
||||||
|
BeanUtils.copyProperties(optchocksdata, chocksdata);
|
||||||
|
|
||||||
|
|
||||||
|
fltr.getCHOT().add(chocksdata);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return fltr;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -24,7 +24,7 @@ public class FDELHandler extends FlopBaseHandler {
|
|||||||
FLOP flop = msg.getFLOP();
|
FLOP flop = msg.getFLOP();
|
||||||
|
|
||||||
|
|
||||||
SCHD.FLTR fltr = flightInfoService.getByFlid(flop.getFLID().toString());
|
SCHD.FLTR fltr = flightInfoService.getByFlid(flop.getFLID().toString());
|
||||||
|
|
||||||
if(null != fltr)
|
if(null != fltr)
|
||||||
{
|
{
|
||||||
@@ -39,6 +39,7 @@ public class FDELHandler extends FlopBaseHandler {
|
|||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
//没有该动态航班信息
|
//没有该动态航班信息
|
||||||
|
this.updateCminmsgToProcessed(cminmsg);
|
||||||
logger.warn("没有flid为:{}的消息",flop.getFLID());
|
logger.warn("没有flid为:{}的消息",flop.getFLID());
|
||||||
return HandlerResult.failure();
|
return HandlerResult.failure();
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-1
@@ -82,7 +82,7 @@ public class FlightInfoServiceImpl implements IFlightInfoService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean deleteFltr(FLTR fltr) {
|
public boolean deleteFltr(FLTR fltr) {
|
||||||
redisService.hdel(redisKey, fltr.getFLID());
|
redisService.hdel(redisKey, fltr.getFLID().toString());
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user