提交

src/jfw/modules/common/src/qfw/util/jy/entnichepush.go

@@ -395,7 +395,7 @@ func (e *entnichePush) GetExportInfoByIds(Mgo_bidding mg.MongodbSim, bidding, bi
 	//var newsDatalen = make(chan bool, 1000000)
 	newCount :=0  // 新导出数量
 	infoIdList := []string{} // 临时infoid数组
-	log.Println(pushCas,"啦啦啦")
+	//log.Println(pushCas,"啦啦啦")
 	if len(pushCas) == 0 {
 		return array, 0
 	}
@@ -419,7 +419,7 @@ func (e *entnichePush) GetExportInfoByIds(Mgo_bidding mg.MongodbSim, bidding, bi
 				"isInsert": "false",  // 是否插入数据
 				"isEnt":    "true", // 是否根据企业id判重
 			})
-			if err5 != nil || int(rs["code"].(int64))!=0{
+			if err5 != nil || IntAll(rs["code"])!=0{
 				log.Println("企业订阅数据导出接口判重失败", err5)
 			} else {
 				log.Println("企业订阅数据导出", rs)
@@ -427,9 +427,9 @@ func (e *entnichePush) GetExportInfoByIds(Mgo_bidding mg.MongodbSim, bidding, bi
 				infoIdList = []string{}
 				// 本次数据累计
 				returnData := rs["data"].(map[string]interface{})
-				log.Println(newCount,"加之前121")
+				//log.Println(newCount,"加之前121")
 				newCount+=int(returnData["newCount"].(float64))
-				log.Println(newCount,"加之后121")
+				//log.Println(newCount,"加之后121")
 			}
 
 		}
@@ -446,7 +446,7 @@ func (e *entnichePush) GetExportInfoByIds(Mgo_bidding mg.MongodbSim, bidding, bi
 			"isEnt":"true",
 
 		})
-		if err5 !=nil|| int(rs["code"].(int64))!=0{
+		if err5 !=nil|| IntAll(rs["code"])!=0{
 			log.Println("判重失败===",err5)
 		}else {
 			// 置空

src/jfw/public/entdataexport.go

@@ -61,7 +61,7 @@ func GetEntDataExportCount(_id string, entId, entUserId, limitNum, current int,
 				"isInsert": insertFlag,
 				"isEnt":    "true",
 			})
-			if err5 != nil|| rs["code"]!=0 {
+			if err5 != nil|| util.IntAll(rs["code"])!=0 {
 				log.Println("企业订阅数据导出接口判重失败", err5)
 			} else {
 				log.Println("企业订阅数据导出")