no message

fullproject/src_v1/config.json

@@ -29,7 +29,7 @@
             "memo": "创建项目索引new"
         },
         {
-            "addr": "192.168.3.207",
+            "addr": "127.0.0.1",
             "port": 1483,
             "memo": "修改项目创建new"
         }
@@ -53,7 +53,7 @@
         "中班椅", "书架", "书柜", "休息台", "不争辩", "不准确", "不压缩", "不处于", "不挑剔", "不留密码", "中标候选", "中级", "义务", "不存", "东山", "东莞", "中山", "佛山", "南方基地", "不处", "中材", "中美合资", "五效", "万元整", "不漏项", "东进西移",
         "业务", "中级职称", "水土", "成都", "税率为", "合肥", "天津", "保养等", "东湖", "万张图片", "仪表", "中标人", "中标内容", "书桌", "不卡顿", "不跳帧", "不完整", "不组织", "之中", "东建业", "东北特钢", "业主", "不锈钢", "中转",
         "凭借栏杆", "不含", "不含斜", "中杯", "光分纤箱", "光交箱","宜宾", "合柜", "性质", "不及格等", "中央空调", "中检", "乌鲁木齐", "五个环", "乙方", "保密", "保证", "人民币", "无效", "以活动", "从化", "休息室", "位置", "储入", "中间件", "公众",
-        "关键", "化学", "家禽", "水产等", "羊肉", "运行", "金属", "定标", "银行", "本科", "理由", "第五章", "计算机", "通信", "项目管理", "评标", "利益", "香港", "在家", "年度", "不得", "不提供", "中职教材", "以及", "业务", "种类", "从业人员"],
+        "关键", "化学", "家禽", "水产等", "羊肉", "运行", "金属", "定标", "银行", "本科", "理由", "第五章", "计算机", "通信", "项目管理", "评标", "利益", "香港", "在家", "年度", "不得", "不提供", "中职教材", "以及", "业务", "种类", "从业人员", "公告于"],
     "winner": {
         "pre_regexp": ["及报价\\d拟中标人第一:", "中标金额（元）", "第\\d中标候单位:", "第\\d中标侯选人:", "及报价\\d", "成交金额（元）", "成交金额", "成交金额包\\d", "成交金额(元)", "成交金额", "中标供应商为", "</tr><tr><tdcolspan=\"8\">",
             "中标供应商如下:", "中标供应商为", "中标供应商联系地址中标金额(万元)\\d", "基本情况名称:", "基本情况中标候选人第\\d+名:", "______", "第一中标侯选人名称: \\d", "第一中标侯选单位:", "第一中标供应商-", "第一中标排序人:", "第一中标排序人",

fullproject/src_v1/task.go

@@ -162,7 +162,6 @@ func (p *ProjectTask) updateAllQueue() {
 					defer func() {
 						<-sp
 					}()
-					util.Debug("1111111111111111")
 					MongoTool.UpSertBulk(p.coll, arru...)
 				}(arru[:indexu])
 				arru = make([][]map[string]interface{}, p.saveSize)
@@ -711,7 +710,7 @@ func (p *ProjectTask) updateJudge(infoMap map[string]interface{}, pid string) {
 	tmpPro := MongoTool.FindById(ProjectColl, pid)
 
 	modifyProMap := make(map[string]interface{}) // 修改项目的字段
-	for k := range tmpPro{
+	for k := range infoMap{
 		if modifyMap, ok := infoMap["modifyinfo"].(map[string]interface{}); ok {
 			if modifyMap[k] != nil {
 				modifyProMap[k] = infoMap[k]

fullproject/src_v1/update.go

@@ -42,6 +42,19 @@ func (p *ProjectTask) modifyUpdate(pid string, index, position int, tmpPro, modi
 		qu.Debug(string(by))
 		_ = udpclient.WriteUdp(by, mu.OP_TYPE_DATA, toaddr[1])
 	}
+	// 修改内存
+	var pro ProjectInfo
+	err := mapstructure.Decode(tmpPro, &pro)
+	if err != nil {
+		qu.Debug(err)
+	}
+	p.AllIdsMapLock.Lock()
+	if v, ok := p.AllIdsMap[pid]; ok {
+		v.P = &pro
+	}
+	p.AllIdsMapLock.Unlock()
+
+	p.printMemPro(pid)
 }
 
 func (p *ProjectTask) mergeAndModify(pInfoId string, index, position int, tmp map[string]interface{}, tmpPro map[string]interface{}, modifyMap map[string]interface{}) {
@@ -1150,11 +1163,28 @@ func UpdateValue(proMap map[string]interface{}, index, position int, modifyMap m
 	for k := range modifyMap {
 		//项目中lsit大小等于1 或者 修改的招标公告处于项目的list中最后一个
 		if len(infoList) == 1 || index == 2 {
-			updataSet[k] = modifyMap[k]
-			proMap[k] = modifyMap[k]
-			tempMap[k] = modifyMap[k]
+			if k == "budget" || k == "bidamount" {
+				if proMap["sortprice"] == proMap[k] {
+					updataSet["sortprice"] = modifyMap[k]
+				}
+				updataSet[k] = modifyMap[k]
+				proMap[k] = modifyMap[k]
+				tempMap[k] = modifyMap[k]
+			}else {
+				updataSet[k] = modifyMap[k]
+				proMap[k] = modifyMap[k]
+				tempMap[k] = modifyMap[k]
+			}
+
 		} else {
 			tempMap[k] = modifyMap[k]
+			if k == "budget" || k == "bidamount" {
+				if proMap["sortprice"] == proMap[k] {
+					proMap["sortprice"] = modifyMap[k]
+				}
+				updataSet[k] = modifyMap[k]
+				proMap[k] = modifyMap[k]
+			}
 			// 有条件更新项目外围字段值(非空)
 			if proMap[k] == nil || qu.ObjToString(k) == "" {
 				updataSet[k] = modifyMap[k]
@@ -1186,4 +1216,13 @@ func delOldPro(pid string) {
 		defer Es.DestoryEsConn(client)
 		Es.DelById(Index, Itype, pid)
 	}
+}
+
+// 打印内存中的项目信息
+func (p *ProjectTask) printMemPro(pid string) {
+	p.AllIdsMapLock.Lock()
+	if v, ok := p.AllIdsMap[pid]; ok {
+		qu.Debug("mem pro ----------", *v.P)
+	}
+	p.AllIdsMapLock.Unlock()
 }

qyxy/src/config.json

@@ -1,11 +1,11 @@
 {
 	"mgodb": "192.168.3.207:27092",
 	"dbsize": 12,
-	"dbname": "mxs",
+	"dbname": "mixdata",
 	"dbcoll": "qyxy",
 	"savecoll": "qyxy_std",
 	"tasktime": 1,
-	"updatetime": 1597202468,
+	"updatetime": 0,
 	"elastic": {
         "addr": "http://192.168.3.128:9800",
         "index": "qyxy",

qyxy/src/main.go

@@ -69,8 +69,8 @@ func init() {
 }
 
 func main() {
-	go TimeTask()
-	//QyxyStandard()
+	//go TimeTask()
+	QyxyStandard()
 	ch := make(chan bool, 1)
 	<-ch
 }

qyxy/src/task.go

@@ -365,31 +365,31 @@ func QyxyStandard() bool {
 
 			}
 			//es数据过滤
-			EsSaveFlag := true
-			company_name := qu.ObjToString(esMap["company_name"])
-			if len([]rune(company_name)) < 8 {
-				EsSaveFlag = false
-			}
-			if EsSaveFlag {
-				company_type := qu.ObjToString(esMap["company_type"])
-				if company_type == "" || company_type == "个体工商户" {
-					EsSaveFlag = false
-				}
-			}
-			if EsSaveFlag {
-				credit_no := strings.TrimSpace(qu.ObjToString(esMap["credit_no"]))
-				company_code := strings.TrimSpace(qu.ObjToString(esMap["company_code"]))
-				if credit_no == "" && company_code == "" {
-					EsSaveFlag = false
-				}
-			}
-			//qu.Debug("esMap---", esMap)
-			// qu.Debug("mgoMap---", mgoMap)
-			// return
+			//EsSaveFlag := true
+			//company_name := qu.ObjToString(esMap["company_name"])
+			//if len([]rune(company_name)) < 8 {
+			//	EsSaveFlag = false
+			//}
+			//if EsSaveFlag {
+			//	company_type := qu.ObjToString(esMap["company_type"])
+			//	if company_type == "" || company_type == "个体工商户" {
+			//		EsSaveFlag = false
+			//	}
+			//}
+			//if EsSaveFlag {
+			//	credit_no := strings.TrimSpace(qu.ObjToString(esMap["credit_no"]))
+			//	company_code := strings.TrimSpace(qu.ObjToString(esMap["company_code"]))
+			//	if credit_no == "" && company_code == "" {
+			//		EsSaveFlag = false
+			//	}
+			//}
+			////qu.Debug("esMap---", esMap)
+			//// qu.Debug("mgoMap---", mgoMap)
+			//// return
 			lock.Lock()
-			if EsSaveFlag {
-				EsSaveCache <- esMap //过滤后数据保存
-			}
+			//if EsSaveFlag {
+			//	EsSaveCache <- esMap //过滤后数据保存
+			//}
 			EsSaveAllCache <- esMap //所有数据保存
 			update = append(update, map[string]interface{}{"$set": mgoMap})
 			if len(update) == 2 {

udpcreateindex/src/main.go

@@ -47,7 +47,7 @@ var (
 func init() {
 	util.ReadConfig(&Sysconfig)
 	//inits()
-	go checkMapJob()
+	//go checkMapJob()
 	detailLength = util.IntAllDef(Sysconfig["detaillength"], 50000)
 	fileLength = util.IntAllDef(Sysconfig["filelength"], 50000)
 	updport, _ = Sysconfig["updport"].(string)
@@ -65,7 +65,7 @@ func init() {
 		MongodbAddr: mconf["addr"].(string),
 		Size:        util.IntAllDef(mconf["pool"], 5),
 		DbName:      mconf["db"].(string),
-		ReplSet:     "bidding",
+		//ReplSet:     "bidding",
 	}
 	mgo.InitPool()
 
@@ -101,7 +101,7 @@ func init() {
 	}
 	mgostandard = &mongodb.MongodbSim{
 		MongodbAddr: standard["addr"].(string),
-		ReplSet:     "bidding",
+		//ReplSet:     "bidding",
 		Size:        util.IntAllDef(standard["pool"], 5),
 		DbName:      standard["db"].(string),
 	}