docGet.go 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package stdlib
  2. import (
  3. "context"
  4. "app.yhyue.com/moapp/jy_docs/rpc/stdlib/stdlib"
  5. "app.yhyue.com/moapp/jy_docs/services/model"
  6. jyDocsRpcUtil "app.yhyue.com/moapp/jy_docs/services/util"
  7. "app.yhyue.com/moapp/jyfs/rpc/filesystem"
  8. )
  9. func DocGetCheck(docId, userId, appId string) stdlib.DocGetCheckResp {
  10. // docPrice := 0
  11. var buyCount int64
  12. isbuy := false
  13. jyDocsRpcUtil.GetJyDocsDB().Table("download_collection_record").Where("docId = ? and userId = ? and appId = ? and category = 1", docId, userId, appId).Count(&buyCount)
  14. if buyCount > 0 {
  15. isbuy = true
  16. }
  17. //已购买
  18. doc := &model.Doc{}
  19. jyDocsRpcUtil.GetJyDocsDB().Where("id = ? and appId = ?", docId, appId).Find(doc)
  20. if doc.DocName != "" {
  21. // docPrice = docData["price"].(int)
  22. docStatistics := model.DocStatistics{}
  23. jyDocsRpcUtil.GetJyDocsDB().First(&docStatistics, &model.DocStatistics{AppId: appId, DocId: docId})
  24. docCheck := stdlib.DocGetCheckResp{
  25. Code: 1,
  26. Msg: "ok",
  27. IsBuy: isbuy,
  28. DocDeail: &stdlib.DocInfo{
  29. DocId: doc.Id,
  30. DocName: doc.DocName,
  31. Price: int64(doc.Price),
  32. DocFileSize: int64(doc.DocFileSize),
  33. DocPageSize: int64(doc.DocPageSize),
  34. Tags: doc.DocTags,
  35. DownTimes: int64(docStatistics.DownTimes),
  36. ViewTimes: int64(docStatistics.ViewTimes),
  37. UploadDate: doc.UploadDate.Format("2006-01-02 15:04:05"),
  38. DocSummary: doc.DocSummary,
  39. DocFileType: int64(doc.DocFileType),
  40. PreviewImgId: doc.PreviewImgId,
  41. OssPdfId: doc.OssPdfId,
  42. },
  43. }
  44. return docCheck
  45. }
  46. return stdlib.DocGetCheckResp{Code: 0, Msg: "查询失败"}
  47. }
  48. func DocGetContent(docId, userId, bucketName, appId string) stdlib.DocGetContentResp {
  49. doc := &model.Doc{}
  50. docContent := stdlib.DocGetContentResp{Code: 0, Msg: "查询失败"}
  51. jyDocsRpcUtil.GetJyDocsDB().Where("id = ? and appId = ?", docId, appId).Find(doc)
  52. if doc.DocName != "" {
  53. file := filesystem.LoadFileReq{
  54. Domain: bucketName,
  55. FileId: doc.OssDocId,
  56. }
  57. res, err := jyDocsRpcUtil.FileSystem.GetFile(context.Background(), &file)
  58. if err == nil {
  59. docContent.Code = 1
  60. docContent.Msg = "ok"
  61. docContent.DocContent = res.RawFileContent
  62. }
  63. }
  64. return docContent
  65. }