From 715f40da0c953ec0080ccf056f9d759c3a249ea0 Mon Sep 17 00:00:00 2001 From: jiazx0107@163.com <jiazx0107@163.com> Date: 星期五, 10 十一月 2023 01:37:12 +0800 Subject: [PATCH] 重新调整代码结构和实现方式2,注意设备中的上行协议调整 --- src/main/java/com/fzzy/gateway/hx2023/service/ApiInitService.java | 19 ++++++++++++++++--- 1 files changed, 16 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/fzzy/gateway/hx2023/service/ApiInitService.java b/src/main/java/com/fzzy/gateway/hx2023/service/ApiInitService.java index 05ebc0e..75a354b 100644 --- a/src/main/java/com/fzzy/gateway/hx2023/service/ApiInitService.java +++ b/src/main/java/com/fzzy/gateway/hx2023/service/ApiInitService.java @@ -1,28 +1,37 @@ package com.fzzy.gateway.hx2023.service; +import com.bstek.dorado.annotation.Expose; import com.fzzy.gateway.api.GatewayRemoteManager; import com.fzzy.gateway.api.GatewayRemoteService; import com.fzzy.gateway.entity.GatewayConf; import com.fzzy.gateway.service.GatewayConfService; -import lombok.extern.slf4j.Slf4j; + + +import com.fzzy.gateway.service.GatewayDeviceService; import org.springframework.stereotype.Component; import javax.annotation.Resource; + import java.util.List; /** * 褰撳墠鎺ュ彛锛屽垵濮嬪寲鐩稿叧 */ -@Slf4j @Component public class ApiInitService { @Resource private GatewayConfService confService; @Resource + private GatewayDeviceService deviceService; + @Resource private GatewayRemoteManager gatewayRemoteManager; + /** + * apiInitService#init + */ + @Expose public void init() { List<GatewayConf> list = confService.listAll(); @@ -34,9 +43,13 @@ GatewayRemoteService gatewayRemoteService; for (GatewayConf gatewayConf : list) { gatewayRemoteService = gatewayRemoteManager.getRemoteService(gatewayConf.getPushProtocol()); - gatewayRemoteService.authorize(gatewayConf); + gatewayRemoteService.init(gatewayConf); } } + + public void updateDeviceCache() { + deviceService.flushCache(); + } } -- Gitblit v1.9.3