更新依赖包

bidding_listen/config.toml

@@ -1,17 +1,17 @@
 [mongob]  ## bidding 链接
-    host = "127.0.0.1:27017"
+    host = "127.0.0.1:27083"
 #    host = "192.168.3.207:29099"
-    db = "wcc"
+    db = "qfw"
     coll = "bidding"
-    username = ""
-    password = ""
+    username = "SJZY_RWbid_ES"
+    password = "SJZY@B4i4D5e6S"
 
 
 [mongop] ## 项目信息
-    host = "127.0.0.1:27017"
+    host = "127.0.0.1:27080"
     #    host = "192.168.3.207:29099"
-    db = "wcc"
-    coll = "bidding"
+    db = "qfw"
+    coll = "projectset_20230904"
     username = ""
     password = ""
 
@@ -32,18 +32,18 @@
 
 
 [mysql]
-#    address = "172.17.4.242:4000"
-#    dbname=   "global_common_data"
-#    username = "wangchengcheng"
-#    password= "Wcc#20221209P"
-#    table = "ods_datamonitoring_bidding"
+    address = "127.0.0.1:4001"
+    dbname=   "global_common_data"
+    username = "wangchengcheng"
+    password= "Wcc#20221209P"
+    table = "ods_datamonitoring_bidding"
 
     ## 测试环境
-    address = "192.168.3.14:4000"
-    dbname=   "global_common_data"
-    username = "root"
-    password= "=PDT49#80Z!RVv52_z"
-    table = "ods_datamonitoring_bidding"    ## 存储结果数据表
+#    address = "192.168.3.14:4000"
+#    dbname=   "global_common_data"
+#    username = "root"
+#    password= "=PDT49#80Z!RVv52_z"
+#    table = "ods_datamonitoring_bidding"    ## 存储结果数据表
 
 [email]
     api = "http://172.17.145.179:19281/_send/_mail"

bidding_listen/go.mod

@@ -47,4 +47,5 @@ require (
 	gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22 // indirect
 	gopkg.in/natefinch/lumberjack.v2 v2.0.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
+	jygit.jydev.jianyu360.cn/data_processing/common_utils v0.0.0-20230919095552-4cb37e2b9caf // indirect
 )

bidding_listen/go.sum

@@ -576,6 +576,8 @@ honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWh
 honnef.co/go/tools v0.0.1-2019.2.3/go.mod h1:a3bituU0lyd329TUQxRnasdCoJDkEUEAqEt0JzvZhAg=
 honnef.co/go/tools v0.0.1-2020.1.3/go.mod h1:X/FiERA/W4tHapMX5mGpAtMSVEeEUOyHaw9vFzvIQ3k=
 honnef.co/go/tools v0.0.1-2020.1.4/go.mod h1:X/FiERA/W4tHapMX5mGpAtMSVEeEUOyHaw9vFzvIQ3k=
+jygit.jydev.jianyu360.cn/data_processing/common_utils v0.0.0-20230919095552-4cb37e2b9caf h1:7RYFbRUmw5Yug9x85AgcFfGuRsdePk635j5BA+VBE2U=
+jygit.jydev.jianyu360.cn/data_processing/common_utils v0.0.0-20230919095552-4cb37e2b9caf/go.mod h1:1Rp0ioZBhikjXHYYXmnzL6RNfvTDM/2XvRB+vuPLurI=
 rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
 rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
 rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=

bidding_listen/init.go

@@ -1,13 +1,12 @@
 package main
 
 import (
-	//"app.yhyue.com/data_processing/common_utils/elastic"
-	"app.yhyue.com/data_processing/common_utils/log"
-	"app.yhyue.com/data_processing/common_utils/mongodb"
-	"app.yhyue.com/data_processing/common_utils/mysqldb"
 	"fmt"
 	"github.com/spf13/viper"
 	"go.uber.org/zap"
+	"jygit.jydev.jianyu360.cn/data_processing/common_utils/log"
+	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
+	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mysqldb"
 	"os"
 	"time"
 )

bidding_listen/main.go

@@ -2,13 +2,13 @@ package main
 
 import (
 	utils "app.yhyue.com/data_processing/common_utils"
-	"app.yhyue.com/data_processing/common_utils/log"
-	"app.yhyue.com/data_processing/common_utils/mongodb"
-	"app.yhyue.com/data_processing/common_utils/mysqldb"
 	"context"
 	"fmt"
 	"github.com/robfig/cron/v3"
 	"go.uber.org/zap"
+	"jygit.jydev.jianyu360.cn/data_processing/common_utils/log"
+	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
+	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mysqldb"
 	"sync"
 	"time"
 )
@@ -360,9 +360,6 @@ func dealProject() {
 	total := 0
 	for rows.Next() {
 		total++
-		if total%100 == 0 {
-			log.Info("dealProject", zap.Int("current", total))
-		}
 		scanArgs := make([]interface{}, len(columns))
 		values := make([]interface{}, len(columns))
 		ret := make(map[string]interface{})
@@ -389,6 +386,10 @@ func dealProject() {
 		buyerPool <- true
 		wg.Add(1)
 
+		if total%100 == 0 {
+			log.Info("dealProject", zap.Int("current", total), zap.Any("bidding_id", ret["bidding_id"]))
+		}
+
 		go func(tmp map[string]interface{}) {
 			defer func() {
 				<-buyerPool
@@ -404,6 +405,7 @@ func dealProject() {
 	rows.Close()
 	wg.Wait()
 
+	log.Info("dealProject", zap.String("deal", "over"))
 }
 
 func updateProject(tmp map[string]interface{}) {

bidding_listen/utils.go

@@ -1,9 +1,9 @@
 package main
 
 import (
-	"app.yhyue.com/data_processing/common_utils/log"
 	"fmt"
 	"go.uber.org/zap"
+	"jygit.jydev.jianyu360.cn/data_processing/common_utils/log"
 	"net/http"
 	"sort"
 	"time"