feat:增加企业ID存es

rpc/common/internal/logic/sensitivemethodlogic.go

@@ -144,6 +144,7 @@ func (l *SensitiveMethodLogic) SensitiveMethod(in *commoninfo.SensitiveRequest)
 				supInfo["detail"] = (*data)["detail"]
 				supInfo["province"] = (*data)["province"]
 				supInfo["city"] = (*data)["city"]
+				supInfo["ent_id"] = (*data)["ent_id"]
 				validityTime := time.Now().Unix()
 				if (*data)["validity_time"] != nil && (*data)["validity_time"] != "" {
 					validity, _ := time.ParseInLocation("2006-01-02 15:04:05", mc.InterfaceToStr((*data)["validity_time"]), time.Local)

rpc/manager/internal/logic/infoexaminelogic.go

@@ -110,6 +110,7 @@ func (l *InfoExamineLogic) InfoExamine(in *manager.InfoExamineReq) (*manager.Inf
 				supInfo["detail"] = (*data)["detail"]
 				supInfo["province"] = (*data)["province"]
 				supInfo["city"] = (*data)["city"]
+				supInfo["ent_id"] = (*data)["ent_id"]
 				validityTime := time.Now().Unix()
 				if (*data)["validity_time"] != nil && (*data)["validity_time"] != "" {
 					validity, _ := time.ParseInLocation("2006-01-02 15:04:05", common.InterfaceToStr((*data)["validity_time"]), time.Local)

rpc/manager/internal/logic/infoonekeyactionlogic.go

@@ -81,6 +81,7 @@ func (l *InfoOneKeyActionLogic) InfoOneKeyAction(in *manager.OneKeyActionReq) (*
 					supInfo["detail"] = res["detail"]
 					supInfo["province"] = res["province"]
 					supInfo["city"] = res["city"]
+					supInfo["ent_id"] = res["ent_id"]
 					validityTime := time.Now().Unix()
 					if res["validity_time"] != nil && res["validity_time"] != "" {
 						validity, _ := time.ParseInLocation("2006-01-02 15:04:05", mc.InterfaceToStr(res["validity_time"]), time.Local)

rpc/model/es/es.go

@@ -2,6 +2,7 @@ package model
 
 import (
 	"fmt"
+	"log"
 	"strconv"
 	"strings"
 	"time"
@@ -113,6 +114,7 @@ func GetSearchQuery(in *consumerinfo.SupplyInfoSearchReq) (qstr string) {
 
 //保存供应信息
 func SaveSupplyInfo(ent_name string, supplyInfo map[string]interface{}) bool {
+	log.Println("es保存接收字段:", ent_name, supplyInfo)
 	now := time.Now().Unix()
 	return elastic.Save(INDEX, TYPE, &map[string]interface{}{
 		"_id":           supplyInfo["id"],
@@ -120,7 +122,8 @@ func SaveSupplyInfo(ent_name string, supplyInfo map[string]interface{}) bool {
 		"msg_type":      "1",
 		"title":         supplyInfo["title"],
 		"detail":        supplyInfo["detail"],
-		"ent_name":      ent_name, //机构名称
+		"ent_name":      ent_name,             //机构名称
+		"ent_id":        supplyInfo["ent_id"], //机构id
 		"province":      supplyInfo["province"],
 		"city":          supplyInfo["city"],
 		"validity_time": supplyInfo["validity_time"],