Thirdparty
/
wvp-GB28181-pro
mirror of https://github.com/648540858/wvp-GB28181-pro
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[集群] 修复BUG

dev/数据库统合
648540858 2025-01-03 16:25:33 +08:00
parent 42322c75cc
commit bfc77a1d11
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcPlatformController.java
View File

@ -6,7 +6,6 @@ import com.genersoft.iot.vmp.conf.redis.RedisRpcConfig;
import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcMessage; import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcMessage;
import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcRequest; import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcRequest;
import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcResponse; import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcResponse;
import com.genersoft.iot.vmp.gb28181.bean.CommonGBChannel;
import com.genersoft.iot.vmp.gb28181.bean.Platform; import com.genersoft.iot.vmp.gb28181.bean.Platform;
import com.genersoft.iot.vmp.gb28181.event.EventPublisher; import com.genersoft.iot.vmp.gb28181.event.EventPublisher;
import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent; import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent;
@ -21,9 +20,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.Arrays;
import java.util.List;
@Component @Component
@Slf4j @Slf4j
@RedisRpcController("platform") @RedisRpcController("platform")
@ -72,7 +68,11 @@ public class RedisRpcPlatformController extends RpcController {
@RedisRpcMapping("catalogEventPublish") @RedisRpcMapping("catalogEventPublish")
public RedisRpcResponse catalogEventPublish(RedisRpcRequest request) { public RedisRpcResponse catalogEventPublish(RedisRpcRequest request) {
CatalogEvent event = JSONObject.parseObject(request.getParam().toString(), CatalogEvent.class); CatalogEvent event = JSONObject.parseObject(request.getParam().toString(), CatalogEvent.class);
eventPublisher.catalogEventPublish(event); CatalogEvent catalogEvent = new CatalogEvent(this);
catalogEvent.setPlatform(event.getPlatform());
catalogEvent.setChannels(event.getChannels());
catalogEvent.setType(event.getType());
eventPublisher.catalogEventPublish(catalogEvent);
RedisRpcResponse response = request.getResponse(); RedisRpcResponse response = request.getResponse();
response.setStatusCode(ErrorCode.SUCCESS.getCode()); response.setStatusCode(ErrorCode.SUCCESS.getCode());
return response; return response;