修复qyxy_std 处理company_partner 错误

qyxy_inc_data_new/main.go

@@ -65,7 +65,7 @@ func init() {
 		Port: util.IntAll(changePort),
 		IP:   net.ParseIP(util.ObjToString(SysConfig["target_ip"])),
 	}
-	util.Debug("qyxyEsAddr:=>", changeAddr)
+	util.Debug("changeAddr:=>", changeAddr)
 }
 
 func main() {

qyxy_listen/main.go

@@ -64,7 +64,7 @@ func main() {
 	cronServer := cron.New(cron.WithLocation(local), cron.WithSeconds())
 
 	//spec := "0 */1 * * * *" //秒，分，时，日，月，星期
-	//spec := "0 10 09 * * 1" //每周一的9点十分执行
+	//spec := "0 30 08 * * 1" //每周一的8点30执行
 	spec := util.ObjToString(Sysconfig["spec"])
 	cronServer.AddFunc(spec, dealWatch)
 

qyxy_std_new/main.go

@@ -434,7 +434,7 @@ func dealCompanyPartner(data map[string]interface{}) {
 	var names []string
 	var arr []map[string]interface{}
 	if (*oldTmp)["partners"] != nil {
-		arr = util.ObjArrToMapArr((*oldTmp)["employees"].([]interface{}))
+		arr = util.ObjArrToMapArr((*oldTmp)["partners"].([]interface{}))
 	} else {
 		arr = make([]map[string]interface{}, 0)
 	}

read.txt

@@ -0,0 +1,33 @@
+es 添加新字段
+
+issue_quota         float64     发行额度
+bidopen_shape       string      开标形式
+quote_mode          string      报价方式
+is_acquire_tender   bool        是否需要获取标书
+is_payment_deposit  bool        是否缴纳保证金
+is_joint_bidding    bool        是否联合体投标
+
+
+## bidding 和 es 都需要添加这6个字段值
+
+开始ID        6384db000000000000000000
+
+
+结束ID        63bf9753779467cff13c03e0
+
+
+1.读取85 抽取表 result_20220219 和 result_20220218 二个数据表内容，有上述字段就读取然后更新到 mongodb 的bidding表.
+    更新到MongoDB ，可以直接使用tmp["_id"]
+
+2.同样操作更新到Es
+    更新到es，id 需要转换一下
+
+
+
+
+
+
+
+
+
+