report_service.go 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420
  1. package report
  2. import (
  3. "encoding/json"
  4. <<<<<<< Updated upstream
  5. "eta_mini_ht_api/common/component/es"
  6. logger "eta_mini_ht_api/common/component/log"
  7. "eta_mini_ht_api/common/utils/page"
  8. =======
  9. <<<<<<< Updated upstream
  10. "eta/eta_mini_ht_api/common/component/es"
  11. logger "eta/eta_mini_ht_api/common/component/log"
  12. "eta/eta_mini_ht_api/common/utils/page"
  13. "eta/eta_mini_ht_api/models"
  14. "eta/eta_mini_ht_api/models/eta"
  15. etaDao "eta/eta_mini_ht_api/models/eta"
  16. reportDao "eta/eta_mini_ht_api/models/report"
  17. =======
  18. "eta_mini_ht_api/common/component/es"
  19. logger "eta_mini_ht_api/common/component/log"
  20. "eta_mini_ht_api/common/utils/page"
  21. stringUtils "eta_mini_ht_api/common/utils/string"
  22. userService "eta_mini_ht_api/domian/user"
  23. >>>>>>> Stashed changes
  24. "eta_mini_ht_api/models"
  25. "eta_mini_ht_api/models/eta"
  26. etaDao "eta_mini_ht_api/models/eta"
  27. reportDao "eta_mini_ht_api/models/report"
  28. <<<<<<< Updated upstream
  29. =======
  30. "github.com/google/uuid"
  31. >>>>>>> Stashed changes
  32. >>>>>>> Stashed changes
  33. "strconv"
  34. "strings"
  35. "time"
  36. )
  37. const (
  38. SourceETA = "ETA"
  39. SourceHT = "HT"
  40. DESC models.Order = "desc"
  41. ASC models.Order = "asc"
  42. ESIndex = "report_index"
  43. ESColumn = "title"
  44. ESRangeColumn = "reportId"
  45. )
  46. var (
  47. sortField = []string{"_score:desc"}
  48. )
  49. func elastic() *es.ESClient {
  50. return es.GetInstance()
  51. }
  52. // ESReport Report ES研报mapping
  53. type ESReport struct {
  54. ReportID int `json:"reportId"`
  55. OrgId int `json:"orgId"`
  56. Title string `json:"title"`
  57. Author string `json:"author"`
  58. Source reportDao.ReportSource `json:"source"`
  59. Abstract string `json:"abstract"`
  60. CoverSrc string `json:"coverSrc"`
  61. Status reportDao.ReportStatus `json:"status"`
  62. PublishedTime string `json:"publishedTime"`
  63. }
  64. type ReportDTO struct {
  65. ReportID int `json:"reportId"`
  66. OrgId int `json:"orgId"`
  67. Title string `json:"title"`
  68. Author string `json:"author"`
  69. Source string `json:"source"`
  70. Abstract string `json:"abstract"`
  71. PublishedTime string `json:"publishedTime"`
  72. Permissions map[int]string `json:"-"`
  73. PermissionNames interface{} `json:"permissionNames,omitempty"`
  74. Highlight []string `json:"highlight,omitempty"`
  75. Detail json.RawMessage `json:"detail,omitempty"`
  76. CoverSrc string `json:"coverSrc"`
  77. }
  78. type Detail struct {
  79. }
  80. type PermissionDTO struct {
  81. ID int
  82. Name string
  83. ParentID int
  84. }
  85. type RecordCountDTO struct {
  86. UserId int
  87. Mobile string
  88. ReportId int
  89. IpAddress string
  90. Location string
  91. Referer string
  92. Additional string
  93. }
  94. func GetGetReportById(reportId int) (ReportDTO ReportDTO, err error) {
  95. report, err := reportDao.GetReportById(reportId)
  96. if err == nil {
  97. ReportDTO = convertReportDTO(report)
  98. }
  99. return
  100. }
  101. func GetTotalPageCount() (total int64) {
  102. return reportDao.GetTotalPageCount()
  103. }
  104. func GetTotalPageCountByAnalyst(analyst string) (total int64, latestId int64) {
  105. return reportDao.GetTotalPageCountByAnalyst(analyst)
  106. }
  107. func SearchMaxReportId(key string) (total int64, reportId int64) {
  108. sort := []string{"reportId:desc"}
  109. request := matchAll(sort, key)
  110. //同步es
  111. re, err := elastic().Count(request)
  112. if err != nil {
  113. logger.Error("es搜索异常:%v", err)
  114. }
  115. count := re.Count
  116. total = int64(count)
  117. if total > 0 {
  118. request = match(key, 0, count, sort)
  119. re, err = elastic().Search(request)
  120. if err != nil {
  121. logger.Error("es搜索异常:%v", err)
  122. }
  123. hits := elastic().GetSource(re.Hits)
  124. data := hits[0].Source
  125. report := ReportDTO{}
  126. err = json.Unmarshal(data, &report)
  127. if err != nil {
  128. logger.Error("获取当前最大研报id失败:%v", err)
  129. return
  130. }
  131. reportId = int64(report.ReportID)
  132. }
  133. return
  134. }
  135. func SearchReportList(key string, from int, size int, max int64) (reports []ReportDTO, err error) {
  136. //同步es
  137. sorts := append(sortField, "publishedTime:desc")
  138. request := matchRange(key, from, size, max, sorts)
  139. re, err := elastic().Search(request)
  140. if err != nil {
  141. logger.Error("es搜索异常:%v", err)
  142. }
  143. hits := elastic().GetSource(re.Hits)
  144. if len(hits) == 0 {
  145. reports = []ReportDTO{}
  146. return
  147. }
  148. for _, hit := range hits {
  149. var content map[string][]string
  150. err = json.Unmarshal(hit.Highlight, &content)
  151. report := ReportDTO{}
  152. err = json.Unmarshal(hit.Source, &report)
  153. if err != nil {
  154. logger.Error("解析研报数据失败:%v", err)
  155. continue
  156. }
  157. report.Highlight = content[ESColumn]
  158. report.Title = report.Highlight[0]
  159. report.PublishedTime = report.PublishedTime[:10]
  160. reports = append(reports, report)
  161. }
  162. return
  163. }
  164. func GetReportPageByAnalyst(pageInfo page.PageInfo, analyst string) (list []ReportDTO, err error) {
  165. offset := page.StartIndex(pageInfo.Current, pageInfo.PageSize)
  166. reports, err := reportDao.GetReportPageByAnalyst(pageInfo.LatestId, pageInfo.PageSize, offset, analyst)
  167. if err != nil {
  168. logger.Error("分页查询报告列表失败:%v", err)
  169. return
  170. }
  171. list = make([]ReportDTO, 0)
  172. if reports != nil {
  173. for _, report := range reports {
  174. dto := convertReportDTO(report)
  175. list = append(list, dto)
  176. }
  177. }
  178. return
  179. }
  180. func GetReportPageByOrgIds(pageInfo page.PageInfo, orgIds []int) (list []ReportDTO, err error) {
  181. offset := page.StartIndex(pageInfo.Current, pageInfo.PageSize)
  182. reports, err := reportDao.GetReportPageByOrgIds(pageInfo.LatestId, pageInfo.PageSize, offset, orgIds)
  183. if err != nil {
  184. logger.Error("分页查询报告列表失败:%v", err)
  185. return
  186. }
  187. list = make([]ReportDTO, 0)
  188. if reports != nil {
  189. for _, report := range reports {
  190. dto := convertReportDTO(report)
  191. list = append(list, dto)
  192. }
  193. }
  194. return
  195. }
  196. func GetNewReportByPublishTime(time time.Time) (reports []ReportDTO) {
  197. list := reportDao.GetNewReportByPublishTime(time)
  198. if list != nil {
  199. for _, report := range list {
  200. dto := convertReportDTO(report)
  201. reports = append(reports, dto)
  202. }
  203. }
  204. return
  205. }
  206. func GetReportPage(pageInfo page.PageInfo) (list []ReportDTO, err error) {
  207. offset := page.StartIndex(pageInfo.Current, pageInfo.PageSize)
  208. reports, err := reportDao.GetReportPage(pageInfo.LatestId, pageInfo.PageSize, offset)
  209. if err != nil {
  210. logger.Error("分页查询报告列表失败:%v", err)
  211. return
  212. }
  213. list = make([]ReportDTO, 0)
  214. if reports != nil {
  215. for _, report := range reports {
  216. dto := convertReportDTO(report)
  217. list = append(list, dto)
  218. }
  219. }
  220. return
  221. }
  222. func getETAReportFirstPermissions(id int) (permissionDTOs []PermissionDTO) {
  223. classifyId, err := etaDao.GetReportClassifyById(id)
  224. if err != nil || classifyId == 0 {
  225. logger.Error("获取研报分类信息失败:%v", err)
  226. return
  227. }
  228. permissions, err := etaDao.GetFirstPermissionsByClassifyID(classifyId)
  229. if err != nil {
  230. logger.Error("获取研报一级品种信息失败:%v", err)
  231. return
  232. }
  233. for _, permission := range permissions {
  234. permissionDTOs = append(permissionDTOs, convertPermissionDTO(permission))
  235. }
  236. return
  237. }
  238. func (es ESReport) GetId() string {
  239. return strconv.Itoa(es.ReportID)
  240. }
  241. func GetETALatestReportId() (id int, err error) {
  242. return reportDao.GetETALatestReportId()
  243. }
  244. func SyncETAReportList(list []eta.ETAReport) (err error) {
  245. logger.Info("同步研报数量%d", len(list))
  246. var reports []reportDao.Report
  247. var esReports []es.ESBase
  248. for _, etaRp := range list {
  249. destRp := convertEtaReport(etaRp)
  250. reports = append(reports, destRp)
  251. }
  252. err = reportDao.BatchInsertReport(&reports)
  253. if err != nil {
  254. logger.Error("同步ETA研报失败:%v", err)
  255. return
  256. }
  257. for _, etaRp := range reports {
  258. esRp := convertEsReport(etaRp)
  259. esReports = append(esReports, esRp)
  260. }
  261. //同步es
  262. err = elastic().BulkInsert(ESIndex, esReports)
  263. if err != nil {
  264. logger.Error("同步ETA研报到es失败:%v", err)
  265. return
  266. }
  267. //生产meta信息
  268. logger.Info("生成推送META信息")
  269. for _, report := range reports {
  270. userIds := userService.GetPostUser(report.Author, report.PublishedTime)
  271. if len(userIds) > 0 {
  272. usersStr := stringUtils.IntToStringSlice(userIds)
  273. Meta := reportMeta{
  274. AuthorName: report.Author,
  275. PublishedTime: report.PublishedTime,
  276. ReportId: report.ID,
  277. Title: report.Title,
  278. }
  279. metaStr, _ := json.Marshal(Meta)
  280. toStr := strings.Join(usersStr, ",")
  281. UUID := uuid.New()
  282. uuidStr := UUID.String()
  283. metaContent := userService.MetaInfoDTO{
  284. From: "ETA",
  285. Uid: "report:" + uuidStr,
  286. Meta: string(metaStr),
  287. MetaType: "USER_NOTICE",
  288. SourceType: "REPORT",
  289. To: toStr,
  290. }
  291. err = userService.CreateMetaInfo(metaContent)
  292. if err != nil {
  293. logger.Error("创建Meta信息失败:%v", err)
  294. return err
  295. }
  296. }
  297. }
  298. return
  299. }
  300. type reportMeta struct {
  301. ReportId int `json:"reportId"`
  302. AuthorName string `json:"authorName"`
  303. Title string `json:"title"`
  304. PublishedTime string `json:"publishedTime"`
  305. }
  306. func GetListOrderByConditionWeekly(week bool, column string, limit int, order models.Order) (dtoList []ReportDTO, err error) {
  307. reports, err := reportDao.GetListOrderByCondition(week, column, limit, order)
  308. if err != nil {
  309. logger.Error("获取研报失败:%v", err)
  310. return
  311. }
  312. for _, report := range reports {
  313. dto := convertReportDTO(report)
  314. dtoList = append(dtoList, dto)
  315. }
  316. return
  317. }
  318. func GetListByCondition[T any](column string, ids []T) (dtoList []ReportDTO, err error) {
  319. var values []interface{}
  320. for _, id := range ids {
  321. values = append(values, id)
  322. }
  323. reports, err := reportDao.GetListByCondition(column, ids)
  324. if err != nil {
  325. logger.Error("获取研报失败:%v", err)
  326. return
  327. }
  328. for _, report := range reports {
  329. dto := convertReportDTO(report)
  330. dtoList = append(dtoList, dto)
  331. }
  332. return
  333. }
  334. func GetTotalPageCountByPermissionIds(permissionIds []int) (total int64, latestId int64, ids []int) {
  335. //TODO 一期品种筛选reportIds
  336. htIds := []int{}
  337. etaIds, err := GetETAReportIdsByPermissionIds(permissionIds)
  338. if err != nil {
  339. logger.Error("品种筛选eta报告id失败:%v", err)
  340. etaIds = []int{}
  341. }
  342. total = int64(len(etaIds) + len(htIds))
  343. ids = append(etaIds, htIds...)
  344. latestId = reportDao.GetMaxIdByPermissionIds(ids)
  345. return
  346. }
  347. func convertEtaReport(etaRp eta.ETAReport) reportDao.Report {
  348. return reportDao.Report{
  349. OrgID: etaRp.ID,
  350. Title: etaRp.Title,
  351. Abstract: etaRp.Abstract,
  352. Author: etaRp.Author,
  353. PublishedTime: etaRp.PublishTime,
  354. Source: reportDao.SourceETA,
  355. Status: reportDao.StatusInit,
  356. }
  357. }
  358. func convertEsReport(report reportDao.Report) ESReport {
  359. return ESReport{
  360. ReportID: report.ID,
  361. Title: report.Title,
  362. OrgId: report.OrgID,
  363. Author: report.Author,
  364. Source: report.Source,
  365. Abstract: report.Abstract,
  366. Status: report.Status,
  367. CoverSrc: report.CoverSrc,
  368. PublishedTime: report.PublishedTime,
  369. }
  370. }
  371. func convertReportDTO(report reportDao.Report) (reportDTO ReportDTO) {
  372. reportDTO = ReportDTO{
  373. ReportID: report.ID,
  374. Title: report.Title,
  375. OrgId: report.OrgID,
  376. Author: report.Author,
  377. Source: string(report.Source),
  378. Abstract: report.Abstract,
  379. PublishedTime: report.PublishedTime,
  380. }
  381. publishDate, err := time.Parse(time.DateTime, reportDTO.PublishedTime)
  382. if err == nil {
  383. reportDTO.PublishedTime = publishDate.Format(time.DateOnly)
  384. }
  385. return
  386. }
  387. func matchAll(sorts []string, key string) (request *es.ESQueryRequest) {
  388. req := new(es.ESQueryRequest)
  389. return req.CreateESQueryRequest(ESIndex, ESColumn, key, 0, 1, sorts, es.MatchAll)
  390. }
  391. func match(key string, from int, to int, sorts []string) (request *es.ESQueryRequest) {
  392. req := new(es.ESQueryRequest)
  393. return req.CreateESQueryRequest(ESIndex, ESColumn, key, from, to, sorts, es.Match)
  394. }
  395. func matchRange(key string, from int, to int, max int64, sorts []string) (request *es.ESQueryRequest) {
  396. req := new(es.ESQueryRequest)
  397. return req.CreateESQueryRequest(ESIndex, ESColumn, key, from, to, sorts, es.Range).Range(0, max, ESRangeColumn)
  398. }