提交文库浏览、下载次数

jydocs-back/rpc/stdDocRpc.go

@@ -125,3 +125,27 @@ func GetDocDetail(userId, docId string) (*stdlib.DocInfo, bool, bool, error) {
 	}
 	return resp.DocDeail, resp.IsBuy, resp.IsCollect, nil
 }
+
+/*
+文库浏览次数、下载次数统计
+param
+	userId  用户id
+	docId	文库id
+	sign	1增加下载次数 2增加浏览次数 3评分
+*/
+const Down int32 = 1
+const View int32 = 2
+
+func DocStatistics(userId, docId string, sign int32) {
+	resp, err := jyStdDocStdlib.DocStatistics(context.Background(), &stdlib.DocStatisticsReq{
+		AppId:             config.JyDocsAppConfig.AppId,
+		DocId:             docId,
+		DocStatisticsType: sign,
+	})
+	if err != nil {
+		log.Printf("%s DocStatistics call error %v\n", userId, err)
+	}
+	if !resp.State {
+		log.Printf("%s DocStatistics fail Message %v\n", userId, resp)
+	}
+}

jydocs-back/servers/stdDoc.go

@@ -81,7 +81,7 @@ func (stdDoc *StdDoc) Detail() {
 		detail.OssPdfId = ""
 		detail.OssDocId = ""
 		detail.PreviewImgId = fmt.Sprintf("https://%s.%s/%s", config.JyDocsAppConfig.OssBucket.Priv, config.JyDocsAppConfig.OssAdmin, detail.PreviewImgId)
-
+		go rpc.DocStatistics(userId, docId, rpc.View) //统计下载次数
 		return map[string]interface{}{
 			"status":  common.If(isBuy, 1, 0),
 			"collect": common.If(IsCollect, 1, 0),
@@ -111,6 +111,7 @@ func (stdDoc *StdDoc) GetDoc(sign string) {
 		fileId := detail.OssPdfId
 		if sign == "Down" {
 			fileId = detail.OssDocId
+			go rpc.DocStatistics(userId, docId, rpc.Down) //统计下载次数
 		}
 		url, err := rpc.GetFileContext(userId, fileId)
 		if err != nil {

jydocs-back/servers/userDoc.go

@@ -140,6 +140,7 @@ func (userDoc *UserDoc) DocBuy() {
 					"s_source":     "jydoc",
 				})
 			}
+			rpc.DocStatistics(userId, docId, rpc.Down)
 		}()
 		return map[string]interface{}{
 			"code":    docId,