修复回款表 订单编号错误问题

account_order/account_return.go

@@ -339,7 +339,7 @@ func allDataDataexportOrderForAccountReturn() {
 					}
 				}
 				//下单渠道
-				account_return.OrderCode = data_exOrder.OrderChannel
+				account_return.OrderChannel = data_exOrder.OrderChannel
 				//销售渠道-distribution_channel
 				account_return.DistributionChannel = data_exOrder.DistributionChannel
 				//退款状态-refund_status

account_order/main.go

@@ -24,8 +24,8 @@ var (
 func main() {
 	//dealAllDataAccountOrder() // 1.处理归集后-存量剑鱼订单表-dwd_f_account_order
 	//dealAllDataAccountOrderChangeRecord() //2.处理归集后-存量业绩表更表-dwd_f_account_order_change
-	//dealAllDataAccountReturn() //3.处理归集后-存量剑鱼回款表-dwd_f_account_return
-	dealAllDataAccountReturnChange() //4.处理归集后-剑鱼回款变更表-dwd_f_account_return_change
+	dealAllDataAccountReturn() //3.处理归集后-存量剑鱼回款表-dwd_f_account_return
+	//dealAllDataAccountReturnChange() //4.处理归集后-剑鱼回款变更表-dwd_f_account_return_change
 }
 
 // dealAllDataAccountOrder 处理归集后-存量剑鱼订单表-dwd_f_account_order

bidding_tags/config.toml

@@ -68,4 +68,4 @@ format = "json"
     ## 情报_安防
     rulee ="A02091107\nA023704\nA023705\nA023709\nB0510\nB0601\nB060101\nB060102\nB060103\nB060104\nB060199\nB0602\nB060201\nB060202\nB060203\nB060204\nB060205\nB060206\nB060207\nB060208\nB060299\nC160201\nC160202\nC160204\nC160701"
     ## 情报_法务;使用中标单位,标题匹配
-    rulef = "律师\n事务所\n法律服务\n法律顾问\n法律咨询\n法律尽职调查\n法律援助"
+    rulef = "律师\n事务所\n法律服务\n法律顾问\n法律咨询\n法律尽职调查\n法律援助\n调解服务\n诉讼服务\n法律指导\n法治宣传\n法治服务\n律师服务\n诉讼服务\n法治宣传\n律师服务\n司法服务\n法治服务\n仲裁服务\n法律援助\n法律需求\n知识产权服务\n法律指导"

bidding_tags/main.go

@@ -3,7 +3,6 @@ package main
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/robfig/cron/v3"
 	"github.com/spf13/viper"
 	"go.uber.org/zap"
 	util "jygit.jydev.jianyu360.cn/data_processing/common_utils"
@@ -147,17 +146,22 @@ func main() {
 
 	//dealInc()
 
-	//dealTopInformationAi7(nil)
-
-	local, _ := time.LoadLocation("Asia/Shanghai")
-	c := cron.New(cron.WithLocation(local), cron.WithSeconds())
-	_, err := c.AddFunc(GF.Env.Spec, dealInc)
-	if err != nil {
-		log.Println("AddFunc err", err)
+	where := map[string]interface{}{
+		"_id": map[string]interface{}{
+			"$lt": mongodb.StringTOBsonId("6715b7e8b25c3e1debabb8eb"),
+		},
 	}
+	dealTopInformationAi7(where)
 
-	c.Start()
-	defer c.Stop()
+	//local, _ := time.LoadLocation("Asia/Shanghai")
+	//c := cron.New(cron.WithLocation(local), cron.WithSeconds())
+	//_, err := c.AddFunc(GF.Env.Spec, dealInc)
+	//if err != nil {
+	//	log.Println("AddFunc err", err)
+	//}
+	//
+	//c.Start()
+	//defer c.Stop()
 	////
 	select {}
 }
@@ -745,7 +749,7 @@ func dealTopInformationAi7(where interface{}) {
 	sess := Mgo.GetMgoConn()
 	defer Mgo.DestoryMongoConn(sess)
 	count := 0
-	ch := make(chan bool, 50)
+	ch := make(chan bool, 100)
 	wg := &sync.WaitGroup{}
 	var lines = make([]interface{}, 0)
 	it := sess.DB(GF.Mongo.DB).C(GF.Mongo.Coll).Find(where).Select(nil).Sort("-_id").Iter()