旧代码删除

jyBXSubscribe/rpc/etc/db.yaml

@@ -26,7 +26,7 @@ redis:
         - push=127.0.0.1:6379
         - pushcache_1=127.0.0.1:6379
         - pushcache_2_a=127.0.0.1:6379
-        - pushcache_2_b=127.0.0.1:6379
+        - pushcache_2_b=127.0.0.1:5002
 es:
     addr: http://192.168.3.206:9800
     size: 30

jyBXSubscribe/rpc/model/push.go

@@ -168,14 +168,6 @@ func (s *subscribePush) InfoFormat(p *PushCa, info *map[string]interface{}) *bxs
 	if infotype == "" {
 		infotype = common.ObjToString((*info)["toptype"])
 	}
-	if infotype == "" {
-		infotype = common.ObjToString((*info)["type"])
-		if infotype == "tender" {
-			infotype = "招标"
-		} else if infotype == "bid" {
-			infotype = "中标"
-		}
-	}
 	_id := p.InfoId
 	if _id == "" {
 		_id = common.ObjToString((*info)["_id"])
@@ -327,7 +319,7 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
 	}
 	//时间
 	if starttime > 0 && endtime > 0 {
-		querys = append(querys, fmt.Sprintf("a.date>=%d and date<=%d", starttime, endtime))
+		querys = append(querys, fmt.Sprintf("a.date>=%d and a.date<=%d", starttime, endtime))
 	} else if starttime > 0 && endtime == 0 {
 		querys = append(querys, fmt.Sprintf("a.date>=%d", starttime))
 	} else if starttime == 0 && endtime > 0 {
@@ -489,6 +481,7 @@ func (s *subscribePush) GetInfoByIds(Mgo_bidding mongodb.MongodbSim, bidding, bi
 	}
 	m := map[string]bool{}
 	ids := []string{}
+	//ids = append(ids, "62e22992fe343325df46a5eb")
 	for _, v := range pushCas {
 		if m[v.InfoId] {
 			continue