Browse Source

Update 优化代码逻辑

YueYunyun 2 years ago
parent
commit
ba23114a28

+ 7 - 0
SERVER/Meter_Service/controller/device.go

@@ -70,6 +70,13 @@ func Mock(c *gin.Context) {
 				LvRef: 220,
 				PvRef: 380,
 			},
+			{
+				Addr:  2,
+				NO:    "2024031185256281582",
+				MType: "TEST",
+				LvRef: 220,
+				PvRef: 380,
+			},
 		},
 	}
 	data = append(data, device)

+ 2 - 2
SERVER/Meter_Service/data/device.go

@@ -7,7 +7,7 @@ import (
 	"MeterService/dataStruct"
 	"MeterService/database/appApi"
 	"encoding/json"
-	"errors"
+	"time"
 )
 
 func initDevice() error {
@@ -15,7 +15,6 @@ func initDevice() error {
 	apiMap, ok := appApiMap.Get(dataStruct.GetDevices)
 	if !ok {
 		logger.Error("获取 设备加载API 错误")
-		return errors.New("获取 设备加载API 错误")
 	}
 	for k, v := range apiMap {
 		go loadDevice(k, v)
@@ -28,6 +27,7 @@ func loadDevice(appId int, api *appApi.AppApi) {
 		logger.Error("应用[%d] 获取 设备加载API 错误", appId)
 		return
 	}
+	time.Sleep(time.Second * 2)
 	http := httpHelper.NewHTTPClientHelper()
 	url := api.Url
 	if !utils.HasPrefix(&url, "http") {

+ 1 - 0
SERVER/Meter_Service/main.go

@@ -40,6 +40,7 @@ func main() {
 		logger.Debug("初始化电表数据成功!")
 		// 启动web服务
 		go webService.NewWebServer()
+		time.Sleep(time.Second * 15)
 		// 启动downStream服务
 		go downStreamService.NewDownStreamService()
 	}