package service import ( "fmt" "sfbase/core" "sfbase/utils" "sfis/db" ) var SE = utils.SimpleEncrypt{Key: "topJYBX2019"} func ProjectDetailData(id string) (data []map[string]interface{}, httpStatus int, err error) { httpStatus = 200 _query := `{"query":{"bool":{"must":[{"term":{"id":"%s"}}],"must_not":[],"should":[]}},"_source":[%s]}` fields := `"_id","s_winner","projectname","projectcode","buyer","buyertel","buyerperson","jgtime","zbtime","bidamount","budget","buyerclass","area","city","sourceinfourl"` query := fmt.Sprintf(_query, id, fields) INDEX := core.GetStringConf("es.project.index") TYPE := core.GetStringConf("es.project.itype") infos := db.Es.Get(INDEX, TYPE, query) if infos != nil && len(*infos) > 0 { data = *infos for _, val := range data { val["project_id"] = SE.EncodeString(utils.ObjToString(val["_id"])) delete(val, "_id") } } return data, httpStatus, nil }