From 1ca4879df9cc3c22181b2a200aa4b793116d3d35 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期六, 19 十月 2024 16:23:55 +0800
Subject: [PATCH] fix id
---
main.go | 45 ++++++++++++++++++++++++++++-----------------
1 files changed, 28 insertions(+), 17 deletions(-)
diff --git a/main.go b/main.go
index 62e1db2..a71a4de 100644
--- a/main.go
+++ b/main.go
@@ -4,8 +4,9 @@
"data_msg_push_server/config"
"data_msg_push_server/service"
- "fmt"
"time"
+
+ "basic.com/valib/logger.git"
)
func init() {
@@ -14,22 +15,25 @@
func main() {
done := make(chan bool)
+ // 鏃ュ織鍒濆鍖�
+ var logFile = config.LogConf.Path + "esSyncClient.log"
+ logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
go runEvery(done)
<-done
- fmt.Println("绋嬪簭宸查��鍑�")
+ logger.Debug("绋嬪簭宸查��鍑�")
}
func runEvery(done chan<- bool) {
- ticker := time.NewTicker(10 * time.Second)
+ ticker := time.NewTicker(time.Duration(config.Options.Interval) * time.Second)
defer ticker.Stop()
for {
select {
case <-ticker.C:
- fmt.Println("寮�濮嬫墽琛屽嚱鏁般�傘�傘��")
+ logger.Debug("寮�濮嬫墽琛屾帹閫佷换鍔�")
doServer()
- fmt.Println("鏈鎵ц瀹屾瘯, 褰撳墠鎵�鏈夋暟鎹凡鍙戦�侊紒锛侊紒")
+ logger.Debug("鏈鎵ц瀹屾瘯, 褰撳墠鎵�鏈夋暟鎹凡鍙戦�侊紒锛侊紒")
time.Sleep(10 * time.Second)
}
}
@@ -37,35 +41,42 @@
func doServer() {
total := 0
+ retryCount := 0
for {
t, err := service.GetTotal()
if err != nil {
- fmt.Println(err)
+ logger.Error(err.Error())
+ return
}
total = t
- fmt.Println("鏈彂閫佺殑鏁版嵁鎬婚噺锛�", total)
- if total == 0 {
+ logger.Debugf("鏈彂閫佺殑鏁版嵁鎬婚噺:%d, 閲嶈瘯娆℃暟:%d", total, retryCount)
+ if total == 0 || retryCount > 10 {
break
} else {
for {
connectStatus := service.ConnectControl()
- fmt.Println("connectStatus: ", connectStatus)
+ logger.Debug("鏈嶅姟绔繛鎺ョ姸鎬乧onnectStatus: ", connectStatus)
if connectStatus == true {
url := config.Options.ServerUrl
result, err1 := service.GetData()
if err1 != nil {
- fmt.Println(err1)
+ logger.Warn("鑾峰彇es鏁版嵁澶辫触,", err1.Error())
+ return
}
- id, errs2 := service.SendData(result, url)
- fmt.Println("data id is: ", id)
- if errs2 == nil {
- //delStatus := service.DeleteData(id)
- markStatus := service.MarkData(id)
- fmt.Println(markStatus)
+
+ id, err := service.SendData(result, url)
+ logger.Debug("鎺ㄩ�佺殑鏁版嵁 id: ", result.PicId)
+ if err == nil {
+ markStatus := service.MarkData(result.PicId)
+ logger.Debug("璁板綍鎺ㄩ�佺姸鎬� markStatus: ", markStatus)
+ } else {
+ logger.Debugf("鎺ㄩ�佺殑鏁版嵁澶辫触 id: %s, err:%s", id, err.Error())
+ time.Sleep(5 * time.Second)
+ retryCount += 1
}
break
} else {
- fmt.Println("5绉掑悗灏濊瘯閲嶆柊杩炴帴銆傘�傘��")
+ logger.Debug("鏈嶅姟绔繛鎺ュけ璐�, 5绉掑悗灏濊瘯閲嶆柊杩炴帴銆傘�傘��")
time.Sleep(5 * time.Second)
}
}
--
Gitblit v1.8.0