fix:供应信息es有效时间字段添加

rpc/common/internal/logic/sensitivemethodlogic.go

@@ -144,6 +144,12 @@ func (l *SensitiveMethodLogic) SensitiveMethod(in *commoninfo.SensitiveRequest)
 				supInfo["detail"] = (*data)["detail"]
 				supInfo["province"] = (*data)["province"]
 				supInfo["city"] = (*data)["city"]
+				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)
+					validityTime = validity.Unix()
+				}
+				supInfo["validityTime"] = validityTime
 				if !model.SaveSupplyInfo(entName, supInfo) {
 					log.Println("调用信息发布成功，更新信息失败", entName, supInfo)
 					resp.ErrCode = -3

rpc/manager/internal/logic/infoexaminelogic.go

@@ -110,6 +110,12 @@ func (l *InfoExamineLogic) InfoExamine(in *manager.InfoExamineReq) (*manager.Inf
 				supInfo["detail"] = (*data)["detail"]
 				supInfo["province"] = (*data)["province"]
 				supInfo["city"] = (*data)["city"]
+				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)
+					validityTime = validity.Unix()
+				}
+				supInfo["validityTime"] = validityTime
 				if !model.SaveSupplyInfo(entName, supInfo) {
 					resp.ErrCode = -1
 					resp.ErrMsg = "人工审核通过，信息发布调用失败"

rpc/manager/internal/logic/infoonekeyactionlogic.go

@@ -81,6 +81,12 @@ func (l *InfoOneKeyActionLogic) InfoOneKeyAction(in *manager.OneKeyActionReq) (*
 					supInfo["detail"] = res["detail"]
 					supInfo["province"] = res["province"]
 					supInfo["city"] = res["city"]
+					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)
+						validityTime = validity.Unix()
+					}
+					supInfo["validityTime"] = validityTime
 					if ok := es.SaveSupplyInfo(in.EntName, supInfo); ok {
 						if !model.Mysql.Update(tname, query, map[string]interface{}{
 							"published": 1,

rpc/model/es/es.go

@@ -123,7 +123,7 @@ func SaveSupplyInfo(ent_name string, supplyInfo map[string]interface{}) bool {
 		"ent_name":      ent_name, //机构名称
 		"province":      supplyInfo["province"],
 		"city":          supplyInfo["city"],
-		"validity_time": now,
+		"validity_time": supplyInfo["validity_time"],
 		"create_time":   now,
 		"publish_time":  now,
 	})