完善功能,添加日志,添加nsq tcp上报

gigibox

2023-06-19 942f3416b333304bde50f0dca5581595f397eafa

 report/report.go

@@ -2,7 +2,7 @@

import (
   "context"
   "fmt"
   "kingdee-dbapi/logger"
   "time"

   "kingdee-dbapi/config"
@@ -23,11 +23,11 @@
}

func Loop(c context.Context) {
   fmt.Println("start report")
   logger.Debug("启动数据上报任务")
   for {
      select {
      case <-c.Done():
         fmt.Println("loop break")
         logger.Debug("停止上报")
         return
      default:
         // 上报订单