优化目录订阅时父节点的更新

648540858

2022-03-11 4a22611320f7016d98a37dda57ef1ca4ea9489ec

优化目录订阅时父节点的更新

 src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java

@@ -30,7 +30,7 @@
//    @Scheduled(fixedRate= 100 * 60 * 60 )
    @Scheduled(cron="0 0/5 * * * ?")   //每5分钟执行一次
    public void execute(){
        logger.info("[定时任务] 清理过期的订阅信息");
        logger.info("[定时任务] 清理过期的SIP订阅信息");
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(new Date());
        calendar.set(Calendar.MINUTE, calendar.get(Calendar.MINUTE) - 5);

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java

@@ -233,7 +233,6 @@
     */
    private void processNotifyCatalogList(RequestEvent evt) {
        try {
            System.out.println(343434);
            FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
            String deviceId = SipUtils.getUserIdFromFromHeader(fromHeader);


 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/MessageRequestProcessor.java

@@ -67,9 +67,6 @@
        // 查询设备是否存在
        CSeqHeader cseqHeader = (CSeqHeader) evt.getRequest().getHeader(CSeqHeader.NAME);
        String method = cseqHeader.getMethod();
        if (method.equals("MESSAGE")) {
            System.out.println();
        }
        Device device = redisCatchStorage.getDevice(deviceId);
        // 查询上级平台是否存在
        ParentPlatform parentPlatform = storage.queryParentPlatByServerGBId(deviceId);

 src/main/java/com/genersoft/iot/vmp/storager/dao/DeviceChannelMapper.java

@@ -247,4 +247,13 @@
            "<foreach collection='channels'  item='item'  open='(' separator=',' close=')' > #{item.channelId}</foreach>" +
            " </script>"})
    int cleanChannelsNotInList(String deviceId, List<DeviceChannel> channels);

    @Update(" update device_channel" +
            " set subCount = (select *" +
            "                from (select count(0)" +
            "                      from device_channel" +
            "                      where deviceId = #{deviceId} and parentId = #{channelId}) as temp)" +
            " where deviceId = #{deviceId} " +
            " and channelId = #{channelId}")
    int updateChannelSubCount(String deviceId, String channelId);
}

 src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java

@@ -42,7 +42,7 @@
@Component
public class VideoManagerStoragerImpl implements IVideoManagerStorager {

    private Logger logger = LoggerFactory.getLogger(VideoManagerStoragerImpl.class);
    private final Logger logger = LoggerFactory.getLogger(VideoManagerStoragerImpl.class);

    @Autowired
    EventPublisher eventPublisher;
@@ -171,6 +171,7 @@
        }else {
            deviceChannelMapper.update(channel);
        }
        deviceChannelMapper.updateChannelSubCount(deviceId,channel.getParentId());
    }

    @Override