SwordFish_Interface_Service/service/projectDetail.go

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, err := db.Es.Get(INDEX, TYPE, query)
	if err != nil {
		return nil, 200, err
	}
	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
}