核对-发布时间

src/check_publishtime.go

@@ -0,0 +1,27 @@
+package main
+
+import (
+	qu "qfw/util"
+)
+
+func getCheckDataPublishtime(tmp map[string]interface{},update_check *map[string]interface{}) {
+	publishtime := qu.IntAll(tmp["publishtime"])
+	bidopentime := qu.IntAll(tmp["bidopentime"])
+	bidendtime := qu.IntAll(tmp["bidendtime"])
+
+	if (bidopentime > 0 || bidendtime > 0) && publishtime > 0 {
+		//验证-是否超过周期16天
+		bid_time := 0
+		if bidopentime>0 {
+			bid_time = bidopentime
+		}
+		if bidendtime<bidopentime {
+			bid_time = bidendtime
+		}
+		if publishtime-bid_time>16*86400 { //需要修复-异常时间数据
+			(*update_check)["dataging"]  =  1
+			(*update_check)["publishtime"] = bid_time
+		}
+	}
+
+}

src/config.json

@@ -3,7 +3,7 @@
   "mongodb": {
     "addrName": "127.0.0.1:27017",
     "dbName": "zhengkun",
-    "collName": "zktest_erracd_data",
+    "collName": "extract_test",
     "pool": 10
   },
   "qy_mongodb": {

src/main.go

@@ -150,7 +150,7 @@ func init() {
 	go UpdateTask.updateData()
 }
 
-func mainT()  {
+func main()  {
 	updport := Sysconfig["udpport"].(string)
 	udpclient = mu.UdpClient{Local: updport, BufSize: 1024}
 	udpclient.Listen(processUdpMsg)
@@ -159,9 +159,10 @@ func mainT()  {
 }
 
 //临时校验
-func main()  {
-	sid := "618dc3b045a326c6c3f2f230"
-	eid := "618e137545a326c6c3f44195"
+func mainT()  {
+	sid := "120fc2800000000000000000"
+	eid := "620fd0900000000000000000"
+
 	startCheckData(sid,eid)
 	time.Sleep(99999 * time.Hour)
 }
@@ -203,6 +204,11 @@ func startCheckData(sid, eid string) {
 			getCheckDataCity(tmp,&update_check)
 			//审查-中标金额
 			getCheckDataBidamount(tmp,&update_check)
+			//验证是否修复发布时间 - 对比开标日期，投标截止日期
+			getCheckDataPublishtime(tmp,&update_check)
+
+
+
 
 			if len(update_check)>0 {
 				isRepair++
@@ -213,6 +219,8 @@ func startCheckData(sid, eid string) {
 					},
 				}
 			}
+
+
 		}(tmp,update_id)
 		tmp = make(map[string]interface{})
 	}