Compare commits

...

4 Commits

Author SHA1 Message Date
WangXuewen
a50595f4bf
Pre Merge pull request !34 from WangXuewen/master 2025-07-07 09:56:20 +00:00
lin
4765d0efa6 调整国标级联通道发送逻辑 2025-07-07 17:56:06 +08:00
lin
70356c08d2 调整国标级联通道发送逻辑 2025-07-07 16:17:14 +08:00
wangxw
b05f770a57 解决sql错误,启动是PGSQL查询报错integer=boolean 2024-12-12 17:37:36 +08:00

View File

@ -243,7 +243,7 @@ public class SIPCommanderForPlatform implements ISIPCommanderForPlatform {
if (sendAfterResponse) {
// 默认按照收到200回复后发送下一条 如果超时收不到回复就以30毫秒的间隔直接发送
sipSender.transmitRequest(parentPlatform.getDeviceIp(), request, eventResult -> {
if (eventResult.type.equals(SipSubscribe.EventResultType.timeout)) {
if (eventResult.statusCode == -1024) {
// 消息发送超时, 以30毫秒的间隔直接发送
int indexNext = index + parentPlatform.getCatalogGroup();
try {
@ -266,8 +266,7 @@ public class SIPCommanderForPlatform implements ISIPCommanderForPlatform {
});
}else {
sipSender.transmitRequest(parentPlatform.getDeviceIp(), request, eventResult -> {
log.error("[目录推送失败] 国标级联 platform : {}, code: {}, msg: {}, 停止发送", parentPlatform.getServerGBId(), eventResult.statusCode, eventResult.msg);
dynamicTask.stop(timeoutTaskKey);
log.error("[目录推送失败] 国标级联 platform : {}, code: {}, msg: {}", parentPlatform.getServerGBId(), eventResult.statusCode, eventResult.msg);
}, null);
dynamicTask.startDelay(timeoutTaskKey, ()->{
int indexNext = index + parentPlatform.getCatalogGroup();