|
|
@@ -260,10 +260,6 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
|
|
|
rdb.Do("SELECT","2")
|
|
|
if reply, err := redis.String(rdb.Do("GET", tmp["buyer"])); err != nil {
|
|
|
//redis不存在存到临时表,定时任务处理
|
|
|
- if tmp["buyer"]=="无" {
|
|
|
- log.Println("redis不存在:",tmp["buyer"])
|
|
|
- }
|
|
|
-
|
|
|
FClient.DbName = Config["mgodb_extract_kf"]
|
|
|
if tmpid := FClient.Save("buyer_new", tmp); tmpid == nil {
|
|
|
log.Println("FClient.Save err", tmpid)
|
|
|
@@ -304,10 +300,6 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
|
|
|
|
|
|
esId := oldTmp["_id"].(primitive.ObjectID).Hex()
|
|
|
|
|
|
- if tmp["buyer"]=="无" {
|
|
|
- log.Println("无无无无无无无")
|
|
|
- }
|
|
|
-
|
|
|
//更新行业类型 buyerclass合并
|
|
|
if tmp["buyerperson"] == nil || tmp["buyerperson"] == "" || Reg_xing.MatchString(util.ObjToString(tmp["buyerperson"])) {
|
|
|
|
