Kaynağa Gözat

fix:补充了研报收藏的接口

zqbao 10 ay önce
ebeveyn
işleme
6b8eb227c0

+ 44 - 2
controllers/my_report.go

@@ -93,7 +93,7 @@ func (this *MyReportController) Collect() {
 		br.Msg = "用户没有权限收藏"
 		return
 	}
-	count, err := models.GetMyReportByUserIdAndReportId(user.UserId, req.ReportId)
+	count, err := models.GetMyReportCountByUserIdAndReportId(user.UserId, req.ReportId)
 	if err != nil {
 		br.Msg = "收藏失败"
 		br.ErrMsg = "查询收藏数量失败,Err:" + err.Error()
@@ -167,7 +167,7 @@ func (this *MyReportController) CollectCancel() {
 		br.Msg = "用户没有权限收藏"
 		return
 	}
-	count, err := models.GetMyReportByUserIdAndReportId(user.UserId, req.ReportId)
+	count, err := models.GetMyReportCountByUserIdAndReportId(user.UserId, req.ReportId)
 	if err != nil {
 		br.Msg = "取消收藏失败"
 		br.ErrMsg = "获取收藏信息失败,Err:" + err.Error()
@@ -188,3 +188,45 @@ func (this *MyReportController) CollectCancel() {
 	br.Success = true
 	br.Ret = 200
 }
+
+// @Title 是否收藏研报
+// @Description 是否收藏研报
+// @Param	request	body request.MyReportCollectReq true "type json string"
+// @Success 200 {object} models.BaseResponse
+// @router /isCollect [post]
+func (this *MyReportController) IsCollect() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+
+	var req request.MyReportCollectReq
+	if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
+		br.Msg = "参数解析失败"
+		br.ErrMsg = "参数解析失败,Err:" + err.Error()
+		return
+	}
+	user := this.User
+	if user.Status != 2 {
+		br.Msg = "用户没有权限收藏"
+		return
+	}
+	count, err := models.GetMyReportCountByUserIdAndReportId(user.UserId, req.ReportId)
+	if err != nil {
+		br.Msg = "收藏失败"
+		br.ErrMsg = "查询收藏数量失败,Err:" + err.Error()
+		return
+	}
+	resp := new(response.MyReportIsCollectResp)
+	if count > 0 {
+		resp.IsCollect = true
+	} else {
+		resp.IsCollect = false
+	}
+
+	br.Data = resp
+	br.Msg = "收藏成功"
+	br.Success = true
+	br.Ret = 200
+}

+ 1 - 1
controllers/report.go

@@ -41,7 +41,7 @@ func (this *ReportController) Detail() {
 		return
 	}
 
-	count, err := models.GetMyReportByUserIdAndReportId(user.UserId, reportId)
+	count, err := models.GetMyReportCountByUserIdAndReportId(user.UserId, reportId)
 	if err != nil {
 		br.Msg = "查询收藏数量失败"
 		br.ErrMsg = "查询收藏数量失败,Err:" + err.Error()

+ 1 - 1
models/my_report.go

@@ -24,7 +24,7 @@ func (m *MyReport) Insert() (err error) {
 	return
 }
 
-func GetMyReportByUserIdAndReportId(userId, reportId int) (count int, err error) {
+func GetMyReportCountByUserIdAndReportId(userId, reportId int) (count int, err error) {
 	o := orm.NewOrm()
 	sql := "SELECT COUNT(*) AS count FROM my_report WHERE user_id = ? AND report_id = ?"
 	err = o.Raw(sql, userId, reportId).QueryRow(&count)

+ 9 - 0
routers/commentsRouter.go

@@ -142,6 +142,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["eta/eta_mini_api/controllers:MyReportController"] = append(beego.GlobalControllerRouter["eta/eta_mini_api/controllers:MyReportController"],
+        beego.ControllerComments{
+            Method: "IsCollect",
+            Router: `/isCollect`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["eta/eta_mini_api/controllers:MyReportController"] = append(beego.GlobalControllerRouter["eta/eta_mini_api/controllers:MyReportController"],
         beego.ControllerComments{
             Method: "List",