|
@@ -1,13 +1,15 @@
|
|
|
package jy
|
|
|
|
|
|
import (
|
|
|
- "time"
|
|
|
-
|
|
|
"app.yhyue.com/moapp/jybase/common"
|
|
|
qutil "app.yhyue.com/moapp/jybase/common"
|
|
|
+ elastic "app.yhyue.com/moapp/jybase/es"
|
|
|
"app.yhyue.com/moapp/jybase/go-xweb/httpsession"
|
|
|
"app.yhyue.com/moapp/jybase/go-xweb/log"
|
|
|
"app.yhyue.com/moapp/jybase/mongodb"
|
|
|
+ "fmt"
|
|
|
+ "github.com/gogf/gf/v2/util/gconv"
|
|
|
+ "time"
|
|
|
)
|
|
|
|
|
|
func GetSubScribeInfo(session *httpsession.Session, mg mongodb.MongodbSim, types, appid string) *map[string]interface{} {
|
|
@@ -185,3 +187,12 @@ func SaveUserLog(mg mongodb.MongodbSim, userid, phone, way, system, source, open
|
|
|
}
|
|
|
mg.Save("register_log", data)
|
|
|
}
|
|
|
+
|
|
|
+func GetEsDetail(sid string) string {
|
|
|
+ r := elastic.Get("bidding", "bidding", fmt.Sprintf(`{"query":{"bool":{"must":[{"term":{"id":"%s"}}]}},"_source":["_id","detail"],"size":1}`, sid))
|
|
|
+ detail := ""
|
|
|
+ if len(*r) > 0 {
|
|
|
+ detail = gconv.String((*r)[0]["detail"])
|
|
|
+ }
|
|
|
+ return detail
|
|
|
+}
|