package topic import ( "context" "fmt" "net/url" "strconv" "go-common/app/interface/main/app-interface/conf" "go-common/app/interface/main/app-interface/model/topic" fav "go-common/app/service/main/favorite/api" "go-common/library/ecode" "go-common/library/log" httpx "go-common/library/net/http/blademaster" "go-common/library/net/metadata" "github.com/pkg/errors" ) const _topic = "/x/internal/v2/fav/topic" // Dao is topic dao type Dao struct { client *httpx.Client topic string favRPC fav.FavoriteClient } // New initial topic dao func New(c *conf.Config) (d *Dao) { d = &Dao{ client: httpx.NewClient(c.HTTPClient), topic: c.Host.APICo + _topic, } var err error d.favRPC, err = fav.New(c.FavClient) if err != nil { panic(fmt.Sprintf("fav NewClient error(%v)", err)) } return } // Topic get topic list from UGC api. func (d *Dao) Topic(c context.Context, accessKey, actionKey, device, mobiApp, platform string, build, ps, pn int, mid int64) (t *topic.Topic, err error) { ip := metadata.String(c, metadata.RemoteIP) params := url.Values{} params.Set("access_key", accessKey) params.Set("mid", strconv.FormatInt(mid, 10)) params.Set("actionKey", actionKey) params.Set("build", strconv.Itoa(build)) params.Set("device", device) params.Set("mobi_app", mobiApp) params.Set("platform", platform) params.Set("ps", strconv.Itoa(ps)) params.Set("pn", strconv.Itoa(pn)) params.Set("mid", strconv.FormatInt(mid, 10)) var res struct { Code int `json:"code"` Data *topic.Topic `json:"data"` } if err = d.client.Get(c, d.topic, ip, params, &res); err != nil { return } if res.Code != ecode.OK.Code() { err = errors.Wrap(ecode.Int(res.Code), d.topic+"?"+params.Encode()) return } t = res.Data return } // UserFolder is func (d *Dao) UserFolder(c context.Context, mid int64, typ int32) (userFolder *fav.UserFolderReply, err error) { if userFolder, err = d.favRPC.UserFolder(c, &fav.UserFolderReq{Typ: typ, Mid: mid}); err != nil { log.Error("d.favRPC.UserFolder error(%+v)", err) return } return }