更新 产权数据统计

data_indicators/go.mod

@@ -5,6 +5,7 @@ go 1.18
 require (
 	github.com/robfig/cron/v3 v3.0.1
 	github.com/spf13/viper v1.16.0
+	go.mongodb.org/mongo-driver v1.10.1
 	go.uber.org/zap v1.22.0
 	jygit.jydev.jianyu360.cn/data_processing/common_utils v0.0.0-20230919095552-4cb37e2b9caf
 )
@@ -31,7 +32,6 @@ require (
 	github.com/xdg-go/scram v1.1.1 // indirect
 	github.com/xdg-go/stringprep v1.0.3 // indirect
 	github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect
-	go.mongodb.org/mongo-driver v1.10.1 // indirect
 	go.uber.org/atomic v1.9.0 // indirect
 	go.uber.org/multierr v1.8.0 // indirect
 	golang.org/x/crypto v0.9.0 // indirect

data_indicators/main.go

@@ -235,7 +235,7 @@ func coverageA() {
 		"site":        "千里马",
 	}
 
-	query := sessC.DB("qlm").C("data_merge").Find(whereQlm).Select(map[string]interface{}{"title": 1, "projectname": 1, "channel": 1}).Iter()
+	query := sessC.DB("qlm").C("data_merge").Find(whereQlm).Select(map[string]interface{}{"title": 1, "projectname": 1, "channel": 1, "qlm_toptype": 1}).Iter()
 	count := 0
 
 	qlmData := make([]map[string]interface{}, 0)     //标讯所有数据
@@ -250,6 +250,7 @@ func coverageA() {
 			"projectname": tmp["projectname"],
 		}
 		channel := utils.ObjToString(tmp["channel"])
+		qlmToptype := utils.ObjToString(tmp["qlm_toptype"])
 		//标讯所有数据
 		if IsInStringArray(channel, channels) {
 			qlmData = append(qlmData, data)
@@ -268,7 +269,7 @@ func coverageA() {
 			njData = append(njData, data)
 		}
 		//产权数据
-		if IsInStringArray(channel, channels3) {
+		if IsInStringArray(channel, channels3) || qlmToptype == "产权" {
 			cqData = append(cqData, data)
 		}
 	}