wip:tj

userSign/config.yaml

@@ -1,9 +1,9 @@
 database:
   default:
-    link: "clickhouse:jydev:Jsh2scksi7&hs@tcp(127.0.0.1:2900)/pub_tags?dial_timeout=2000ms&max_execution_time=60"
+    link: "clickhouse:jydev:Jsh2scksi7&hs@tcp(127.0.0.1:3900)/pub_tags?dial_timeout=2000ms&max_execution_time=60"
     debug: true
   order:
-    link: "clickhouse:jytop:pwdTopJy123@tcp(192.168.3.207:19000)/pub_tags?dial_timeout=2000ms&max_execution_time=60"
+    link: "mysql:readuser:jyTi_R202403@tcp(192.168.3.71:4003)/jianyu"
     debug: true
 
 
@@ -15,10 +15,3 @@ mongodb:
     dbName: "qfw"
     userName: "JS2Z_Rbid_ProG"
     password: "JS2z@S1e3aR5Ch"
-  log:
-    address: "172.17.4.187:27090,172.17.189.141:27092"
-    size: 5
-    dbName: "qfw"
-    replSet: ""
-    userName: "jianyu"
-    password: "jylog2020_123"

userSign/main.go

@@ -3,7 +3,8 @@ package main
 import (
 	"context"
 	"fmt"
-	"github.com/gogf/gf/v2/frame/g"
+	_ "github.com/gogf/gf/contrib/drivers/clickhouse/v2"
+	_ "github.com/gogf/gf/contrib/drivers/mysql/v2"
 	"time"
 	"workTasks/userSign/userAnalysis"
 )
@@ -14,18 +15,18 @@ func main() {
 
 func runOnce(ctx context.Context) {
 	manager := userAnalysis.NewManager()
-	if err := manager.LoadMapping(); err != nil {
-		g.Log().Errorf(ctx, "加载对应关系异常 %v", err)
-	}
 	var allRes []*userAnalysis.AnalysisRes
-	//订单分析
-	if res, err := manager.TiDBOrderRange(ctx); err == nil && len(res) > 0 {
-		allRes = append(allRes, res...)
-	}
-	//会员状态分析
-	if res, err := manager.GetMgoUserRes(ctx); err == nil && len(res) > 0 {
-		allRes = append(allRes, res...)
-	}
+	//if err := manager.LoadMapping(); err != nil {
+	//	g.Log().Errorf(ctx, "加载对应关系异常 %v", err)
+	//}
+	////订单分析
+	//if res, err := manager.TiDBOrderRange(ctx); err == nil && len(res) > 0 {
+	//	allRes = append(allRes, res...)
+	//}
+	////会员状态分析
+	//if res, err := manager.GetMgoUserRes(ctx); err == nil && len(res) > 0 {
+	//	allRes = append(allRes, res...)
+	//}
 
 	var (
 		sourceArr    = []string{"pc", "wx", "app"}
@@ -46,6 +47,6 @@ func runOnce(ctx context.Context) {
 	}
 
 	for _, re := range allRes {
-		re.Save(ctx)
+		re.UpdateTag(ctx)
 	}
 }

userSign/userAnalysis/analysisManager.go

@@ -24,7 +24,7 @@ type (
 	}
 )
 
-func (ar *AnalysisRes) Save(ctx context.Context) {
+func (ar *AnalysisRes) UpdateTag(ctx context.Context) {
 	list := make([]string, 0, len(ar.Data))
 	for id, ok := range ar.Data {
 		if !ok {
@@ -32,7 +32,8 @@ func (ar *AnalysisRes) Save(ctx context.Context) {
 		}
 		list = append(list, fmt.Sprintf("toUInt64(%d)", id))
 	}
-	if _, err := g.DB().Exec(ctx, fmt.Sprintf(`ALTER TABLE dwd_d_tag UPDATE bitobj = bitmapBuild([%v]) WHERE code = %v;`, strings.Join(list, ","), ar.Code)); err != nil {
+	execSql := fmt.Sprintf(`ALTER TABLE dwd_d_tag UPDATE bitobj = bitmapBuild([%v]) WHERE code = '%v';`, strings.Join(list, ","), ar.Code)
+	if _, err := g.DB().Exec(ctx, execSql); err != nil {
 		g.Log().Errorf(ctx, "更新标签%s异常 %v", ar.Code, err)
 	}
 }