123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956 |
- package services
- import (
- "context"
- "fmt"
- "hongze/hongze_task/models/data_manage"
- "hongze/hongze_task/services/alarm_msg"
- "hongze/hongze_task/utils"
- "regexp"
- "strconv"
- "strings"
- "time"
- )
- func CygxResearchSummary(cont context.Context) (err error) {
- defer func() {
- if err != nil {
- go alarm_msg.SendAlarmMsg("CygxResearchSummary-定时本周生成研究汇总失败, ErrMsg:\n"+err.Error(), 3)
- fmt.Println(err)
- }
- }()
- //content := "本周研究汇总"
- friday := utils.GetNowWeekFriday().Add(15 * time.Hour)
- lastfriday := utils.GetLastWeekFriday().Add(15 * time.Hour)
- lastMonth := int(lastfriday.Month())
- month := int(friday.Month())
- lastDay := lastfriday.Day()
- day := friday.Day()
- //friday, _ = time.Parse(utils.FormatDateTime, "2022-09-02 15:00:00")
- //lastfriday, _ = time.Parse(utils.FormatDateTime, "2022-08-26 15:00:00")
- itemCrs := new(data_manage.CygxResearchSummary)
- itemCrs.AdminId = 11
- itemCrs.AdminName = "admin"
- itemCrs.Title = fmt.Sprintf("本周研究汇总(%d月%d日至%d月%d日)", lastMonth, lastDay, month, day)
- itemCrs.Department = "弘则产品组"
- itemCrs.Abstract = ""
- itemCrs.PublishStatus = 0
- //itemCrs.Periods = strconv.Itoa(total + 1)
- itemCrs.CreateTime = time.Now()
- itemCrs.LastUpdatedTime = time.Now()
- itemCrs.PublishDate = time.Now()
- articleId, e := data_manage.AddCygxResearchSummaryOrm(itemCrs)
- if e != nil {
- err = e
- return
- }
- mappingList, err := data_manage.CygxReportMappingist()
- if err != nil {
- return
- }
- CategoryChartPermissionIdMap := make(map[int]int)
- for _, item := range mappingList {
- CategoryChartPermissionIdMap[item.CategoryId] = item.ChartPermissionId
- }
- yanxMappingList, err := data_manage.CygxArticleTypeMappingList()
- if err != nil {
- return
- }
- articleTypeChartPermissionIdMap := make(map[int]int)
- for _, item := range yanxMappingList {
- articleTypeChartPermissionIdMap[item.ArticleTypeId] = item.YanxPermissionId
- }
- //深度报告
- {
- var condition string
- var pars []interface{}
- condition += ` AND publish_date < ? AND publish_date >= ? `
- pars = append(pars, friday, lastfriday)
- sdbgList := make([]*data_manage.CygxArticle, 0)
- //医药
- {
- newCondition := condition + ` AND category_id_two IN(65,102)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- sdbgList = append(sdbgList, article)
- }
- }
- //消费
- {
- newCondition := condition + ` AND category_id_two IN(62,67,1008)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- sdbgList = append(sdbgList, article)
- }
- }
- //科技
- {
- newCondition := condition + ` AND category_id_two IN(57,69,1009)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- sdbgList = append(sdbgList, article)
- }
- }
- //智造
- {
- newCondition := condition + ` AND category_id_two IN(66,85)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- sdbgList = append(sdbgList, article)
- }
- }
- var logItems []*data_manage.CygxResearchSummaryLog
- for _, article := range sdbgList {
- head := "<div class=\"title-content\">\n 【" + article.Title + "】 "
- sliceSubjects := strings.Split(article.Stock, "/")
- var company string
- if sliceSubjects[0] != "" {
- for _, vSubject := range sliceSubjects {
- sliceKuohao := strings.Split(vSubject, "(") //过滤括号
- sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
- subject := sliceXiahuaxian[0]
- company += "#" + subject
- }
- company = " <span style=\"color: #ff1720\">" + company + "</span>"
- }
- annotation := strings.ReplaceAll(article.Annotation, "<strong>", "")
- annotation = strings.ReplaceAll(annotation, "</strong>", "")
- annotation = strings.ReplaceAll(annotation, "</ol>", "</div>")
- annotation = strings.ReplaceAll(annotation, "<ol>", "<div>")
- annotation = strings.ReplaceAll(annotation, "</li>", "</p>")
- annotation = strings.ReplaceAll(annotation, "<li>", "<p>")
- re, _ := regexp.Compile("<strong.*?>")
- annotation = re.ReplaceAllString(annotation, "")
- reLi, _ := regexp.Compile("<li.*?>")
- annotation = reLi.ReplaceAllString(annotation, "")
- logItem := data_manage.CygxResearchSummaryLog{
- ArticleId: int(articleId),
- Type: "SDBG",
- ChartPermissionId: CategoryChartPermissionIdMap[article.CategoryIdTwo],
- CreateTime: time.Now(),
- Body: head + company + annotation,
- ReportLink: "https://vmp.hzinsights.com/v2/articles/" + strconv.Itoa(article.ArticleId),
- LinkArticleId: article.LinkArticleId,
- }
- logItems = append(logItems, &logItem)
- }
- if len(logItems) > 0 {
- _, e := data_manage.AddCygxResearchSummaryLogOrm(logItems)
- if e != nil {
- err = e
- return
- }
- }
- }
- //产业调研纪要
- {
- var condition string
- var pars []interface{}
- condition += ` AND publish_date < ? AND publish_date >= ? `
- pars = append(pars, friday, lastfriday)
- cydyjyList := make([]*data_manage.CygxArticle, 0)
- //医药
- {
- newCondition := condition + ` AND category_id_two IN(28,93,301,71)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- //消费
- {
- newCondition := condition + ` AND category_id_two IN(32,58)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- //科技
- {
- newCondition := condition + ` AND category_id_two IN(79)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- //智造
- {
- newCondition := condition + ` AND category_id_two IN(84)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- var logItems []*data_manage.CygxResearchSummaryLog
- for _, article := range cydyjyList {
- head := "<div class=\"title-content\">\n 【" + article.Title + "】 "
- sliceSubjects := strings.Split(article.Stock, "/")
- var company string
- if sliceSubjects[0] != "" {
- for _, vSubject := range sliceSubjects {
- sliceKuohao := strings.Split(vSubject, "(") //过滤括号
- sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
- subject := sliceXiahuaxian[0]
- company += "#" + subject
- }
- company = " <span style=\"color: #ff1720\">" + company + "</span>"
- }
- annotation := strings.ReplaceAll(article.Annotation, "<strong>", "")
- annotation = strings.ReplaceAll(annotation, "</strong>", "")
- annotation = strings.ReplaceAll(annotation, "</ol>", "</div>")
- annotation = strings.ReplaceAll(annotation, "<ol>", "<div>")
- annotation = strings.ReplaceAll(annotation, "</li>", "</p>")
- annotation = strings.ReplaceAll(annotation, "<li>", "<p>")
- re, _ := regexp.Compile("<strong.*?>")
- annotation = re.ReplaceAllString(annotation, "")
- reLi, _ := regexp.Compile("<li.*?>")
- annotation = reLi.ReplaceAllString(annotation, "")
- logItem := data_manage.CygxResearchSummaryLog{
- ArticleId: int(articleId),
- Type: "CYDYJY",
- ChartPermissionId: CategoryChartPermissionIdMap[article.CategoryIdTwo],
- CreateTime: time.Now(),
- Body: head + company + annotation,
- ReportLink: "https://vmp.hzinsights.com/v2/articles/" + strconv.Itoa(article.ArticleId),
- LinkArticleId: article.LinkArticleId,
- }
- logItems = append(logItems, &logItem)
- }
- if len(logItems) > 0 {
- _, e := data_manage.AddCygxResearchSummaryLogOrm(logItems)
- if e != nil {
- err = e
- return
- }
- }
- }
- //上市公司调研纪要
- {
- var condition string
- var pars []interface{}
- condition += ` AND publish_date < ? AND publish_date >= ? `
- pars = append(pars, friday, lastfriday)
- ssgsdyjyList := make([]*data_manage.CygxArticle, 0)
- //医药
- {
- newCondition := condition + ` AND category_id_two IN(74,96)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- //消费
- {
- newCondition := condition + ` AND category_id_two IN(88)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- //科技
- {
- newCondition := condition + ` AND category_id_two IN(45)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- //智造
- {
- newCondition := condition + ` AND category_id_two IN(86)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- var logItems []*data_manage.CygxResearchSummaryLog
- for _, article := range ssgsdyjyList {
- head := "<div class=\"title-content\">\n 【" + article.Title + "】 "
- sliceSubjects := strings.Split(article.Stock, "/")
- var company string
- if sliceSubjects[0] != "" {
- for _, vSubject := range sliceSubjects {
- sliceKuohao := strings.Split(vSubject, "(") //过滤括号
- sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
- subject := sliceXiahuaxian[0]
- company += "#" + subject
- }
- company = " <span style=\"color: #ff1720\">" + company + "</span>"
- }
- annotation := strings.ReplaceAll(article.Annotation, "<strong>", "")
- annotation = strings.ReplaceAll(annotation, "</strong>", "")
- annotation = strings.ReplaceAll(annotation, "</ol>", "</div>")
- annotation = strings.ReplaceAll(annotation, "<ol>", "<div>")
- annotation = strings.ReplaceAll(annotation, "</li>", "</p>")
- annotation = strings.ReplaceAll(annotation, "<li>", "<p>")
- re, _ := regexp.Compile("<strong.*?>")
- annotation = re.ReplaceAllString(annotation, "")
- reLi, _ := regexp.Compile("<li.*?>")
- annotation = reLi.ReplaceAllString(annotation, "")
- logItem := data_manage.CygxResearchSummaryLog{
- ArticleId: int(articleId),
- Type: "SSGS",
- ChartPermissionId: CategoryChartPermissionIdMap[article.CategoryIdTwo],
- CreateTime: time.Now(),
- Body: head + company + annotation,
- ReportLink: "https://vmp.hzinsights.com/v2/articles/" + strconv.Itoa(article.ArticleId),
- LinkArticleId: article.LinkArticleId,
- }
- logItems = append(logItems, &logItem)
- }
- if len(logItems) > 0 {
- _, e := data_manage.AddCygxResearchSummaryLogOrm(logItems)
- if e != nil {
- err = e
- return
- }
- }
- }
- //买方研选
- //{
- // ids, e := data_manage.GetYanXuanArticleIdList()
- // if e != nil {
- // err = e
- // fmt.Println("GetReportArticleList err:", e)
- // return
- // }
- //
- // var condition string
- // var pars []interface{}
- // condition += ` AND publish_date < ? AND publish_date >= ? `
- // pars = append(pars, friday, lastfriday)
- // mfyxList := make([]*data_manage.CygxArticle, 0)
- //
- // //9.23新增研选所有类型的报告都要
- // newCondition := condition + ` AND article_type_id IN (`+ *ids +`) `
- // list, e := data_manage.GetReportArticleList(newCondition, pars)
- // if e != nil {
- // err = e
- // fmt.Println("GetReportArticleList err:", e)
- // return
- // }
- // for _, article := range list {
- // mfyxList = append(mfyxList, article)
- // }
- //
- // ////纪要
- // //{
- // // newCondition := condition + ` AND article_type_id = 1 `
- // // list, e := data_manage.GetReportArticleList(newCondition, pars)
- // // if e != nil {
- // // err = e
- // // fmt.Println("GetReportArticleList err:", e)
- // // return
- // // }
- // // for _, article := range list {
- // // mfyxList = append(mfyxList, article)
- // // }
- // //}
- // ////观点
- // //{
- // // newCondition := condition + ` AND article_type_id = 2 `
- // // list, e := data_manage.GetReportArticleList(newCondition, pars)
- // // if e != nil {
- // // err = e
- // // fmt.Println("GetReportArticleList err:", e)
- // // return
- // // }
- // // for _, article := range list {
- // // mfyxList = append(mfyxList, article)
- // // }
- // //}
- // ////沙龙
- // //{
- // // newCondition := condition + ` AND article_type_id = 13 `
- // // list, e := data_manage.GetReportArticleList(newCondition, pars)
- // // if e != nil {
- // // err = e
- // // fmt.Println("GetReportArticleList err:", e)
- // // return
- // // }
- // // for _, article := range list {
- // // mfyxList = append(mfyxList, article)
- // // }
- // //}
- // var articleIdStr string
- // for _, v := range mfyxList {
- // articleIdStr += strconv.Itoa(v.ArticleId) + ","
- // }
- // mapArticleSubject := make(map[int]string)
- // articleIdStr = strings.TrimRight(articleIdStr, ",")
- // listSubject, e := data_manage.GetArticleSubjectList(articleIdStr)
- // if e != nil {
- // err = e
- // fmt.Println("GetArticleSubjectList err:", e)
- // return
- // }
- // for _, v := range listSubject {
- // mapArticleSubject[v.ArticleId] = v.SubjectName
- // }
- // var logItems []*data_manage.CygxResearchSummaryLog
- // for _, article := range mfyxList {
- // head := "<div class=\"title-content\">\n 【" + article.Title + "】 "
- // body := strings.ReplaceAll(article.Body, "<strong>", "")
- // body = strings.ReplaceAll(body, "</strong>", "")
- // body = strings.ReplaceAll(body, "</ol>", "</div>")
- // body = strings.ReplaceAll(body, "<ol>", "<div>")
- // body = strings.ReplaceAll(body, "</li>", "</p>")
- // body = strings.ReplaceAll(body, "<li>", "<p>")
- // re, _ := regexp.Compile("<strong.*?>")
- // body = re.ReplaceAllString(body, "")
- // reLi, _ := regexp.Compile("<li.*?>")
- // body = reLi.ReplaceAllString(body, "")
- // //研选的公司需要单独处理
- // //sliceSubjects := strings.Split(article.Stock, "/")
- // var company string
- // //if sliceSubjects[0] != "" {
- // // for _, vSubject := range sliceSubjects {
- // // sliceKuohao := strings.Split(vSubject, "(") //过滤括号
- // // sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
- // // subject := sliceXiahuaxian[0]
- // // company += "#" + subject
- // // }
- // // company = " <span style=\"color: #ff1720\">" + company + "</span>"
- // //}
- // if mapArticleSubject[article.ArticleId] != "" {
- // company = " <span style=\"color: #ff1720\">" + "#" + mapArticleSubject[article.ArticleId] + "</span>"
- // }
- // var plus int
- // coreIndex := strings.Index(body, "核心观点:")
- // plus = 15
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心观点:")
- // plus = 13
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心观点")
- // plus = 12
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心结论:")
- // plus = 15
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心结论:")
- // plus = 13
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心结论")
- // plus = 12
- // }
- // endIndex := strings.Index(body, "<hr")
- // fmt.Println("ID:", article.ArticleId)
- // fmt.Println("coreIndex:", coreIndex, endIndex)
- // if coreIndex != -1 && endIndex != -1 {
- // body = body[coreIndex+plus : endIndex]
- // logItem := data_manage.CygxResearchSummaryLog{
- // ArticleId: int(articleId),
- // Type: "YANX",
- // ChartPermissionId: articleTypeChartPermissionIdMap[article.ArticleTypeId],
- // CreateTime: time.Now(),
- // Body: head + company + body,
- // ReportLink: "https://details.hzinsights.com/cygx/report?id=" + article.ArticleIdMd5,
- // LinkArticleId: article.LinkArticleId,
- // }
- // logItems = append(logItems, &logItem)
- // }
- // }
- // if len(logItems) > 0 {
- // _, e := data_manage.AddCygxResearchSummaryLogOrm(logItems)
- // if e != nil {
- // err = e
- // return
- // }
- // }
- //
- //}
- return
- }
- func CygxLastWeekSummary(cont context.Context) (err error) {
- defer func() {
- if err != nil {
- go alarm_msg.SendAlarmMsg("CygxLastWeekSummary-定时生成上周纪要汇总失败, ErrMsg:\n"+err.Error(), 3)
- fmt.Println(err)
- }
- }()
- tuesday := utils.GetNowWeekTuesday().Add(8 * time.Hour)
- lastTuesday := utils.GetLastWeekTuesday().Add(8 * time.Hour)
- lastMonth := int(lastTuesday.Month())
- month := int(tuesday.Month())
- lastDay := lastTuesday.Day()
- day := tuesday.Day()
- itemCrs := new(data_manage.CygxMinutesSummary)
- itemCrs.AdminId = 11
- itemCrs.AdminName = "admin"
- itemCrs.Title = fmt.Sprintf("上周纪要汇总(%d月%d日至%d月%d日)", lastMonth, lastDay, month, day)
- itemCrs.Department = "弘则产品组"
- itemCrs.Abstract = ""
- itemCrs.PublishStatus = 0
- //itemCrs.Periods = strconv.Itoa(total + 1)
- itemCrs.CreateTime = time.Now()
- itemCrs.LastUpdatedTime = time.Now()
- itemCrs.PublishDate = time.Now()
- articleId, e := data_manage.AddCygxMinutesSummaryOrm(itemCrs)
- if e != nil {
- err = e
- return
- }
- mappingList, err := data_manage.CygxReportMappingist()
- if err != nil {
- return
- }
- CategoryChartPermissionIdMap := make(map[int]int)
- for _, item := range mappingList {
- CategoryChartPermissionIdMap[item.CategoryId] = item.ChartPermissionId
- }
- yanxMappingList, err := data_manage.CygxArticleTypeMappingList()
- if err != nil {
- return
- }
- articleTypeChartPermissionIdMap := make(map[int]int)
- for _, item := range yanxMappingList {
- articleTypeChartPermissionIdMap[item.ArticleTypeId] = item.YanxPermissionId
- }
- //产业调研纪要
- {
- var condition string
- var pars []interface{}
- condition += ` AND publish_date < ? AND publish_date >= ? `
- pars = append(pars, tuesday, lastTuesday)
- cydyjyList := make([]*data_manage.CygxArticle, 0)
- //医药
- {
- newCondition := condition + ` AND category_id_two IN(28,93,301,71)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- //消费
- {
- newCondition := condition + ` AND category_id_two IN(32,58)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- //科技
- {
- newCondition := condition + ` AND category_id_two IN(79)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- //智造
- {
- newCondition := condition + ` AND category_id_two IN(84)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- cydyjyList = append(cydyjyList, article)
- }
- }
- var logItems []*data_manage.CygxMinutesSummaryLog
- for _, article := range cydyjyList {
- head := "<div class=\"title-content\">\n 【" + article.Title + "】 "
- sliceSubjects := strings.Split(article.Stock, "/")
- var company string
- if sliceSubjects[0] != "" {
- for _, vSubject := range sliceSubjects {
- sliceKuohao := strings.Split(vSubject, "(") //过滤括号
- sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
- subject := sliceXiahuaxian[0]
- company += "#" + subject
- }
- company = " <span style=\"color: #ff1720\">" + company + "</span>"
- }
- annotation := strings.ReplaceAll(article.Annotation, "<strong>", "")
- annotation = strings.ReplaceAll(annotation, "</strong>", "")
- annotation = strings.ReplaceAll(annotation, "</ol>", "</div>")
- annotation = strings.ReplaceAll(annotation, "<ol>", "<div>")
- annotation = strings.ReplaceAll(annotation, "</li>", "</p>")
- annotation = strings.ReplaceAll(annotation, "<li>", "<p>")
- re, _ := regexp.Compile("<strong.*?>")
- annotation = re.ReplaceAllString(annotation, "")
- reLi, _ := regexp.Compile("<li.*?>")
- annotation = reLi.ReplaceAllString(annotation, "")
- logItem := data_manage.CygxMinutesSummaryLog{
- ArticleId: int(articleId),
- Type: "CYDYJY",
- ChartPermissionId: CategoryChartPermissionIdMap[article.CategoryIdTwo],
- CreateTime: time.Now(),
- Body: head + company + annotation,
- ReportLink: "https://vmp.hzinsights.com/v2/articles/" + strconv.Itoa(article.ArticleId),
- LinkArticleId: article.LinkArticleId,
- }
- logItems = append(logItems, &logItem)
- }
- if len(logItems) > 0 {
- _, e := data_manage.AddCygxMinutesSummaryLogOrm(logItems)
- if e != nil {
- err = e
- return
- }
- }
- }
- //上市公司调研纪要
- {
- var condition string
- var pars []interface{}
- condition += ` AND publish_date < ? AND publish_date >= ? `
- pars = append(pars, tuesday, lastTuesday)
- ssgsdyjyList := make([]*data_manage.CygxArticle, 0)
- //医药
- {
- newCondition := condition + ` AND category_id_two IN(74,96)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- //消费
- {
- newCondition := condition + ` AND category_id_two IN(88)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- //科技
- {
- newCondition := condition + ` AND category_id_two IN(45)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- //智造
- {
- newCondition := condition + ` AND category_id_two IN(86)`
- list, e := data_manage.GetReportArticleList(newCondition, pars)
- if e != nil {
- err = e
- fmt.Println("GetReportArticleList err:", e)
- return
- }
- for _, article := range list {
- ssgsdyjyList = append(ssgsdyjyList, article)
- }
- }
- var logItems []*data_manage.CygxMinutesSummaryLog
- for _, article := range ssgsdyjyList {
- head := "<div class=\"title-content\">\n 【" + article.Title + "】 "
- sliceSubjects := strings.Split(article.Stock, "/")
- var company string
- if sliceSubjects[0] != "" {
- for _, vSubject := range sliceSubjects {
- sliceKuohao := strings.Split(vSubject, "(") //过滤括号
- sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
- subject := sliceXiahuaxian[0]
- company += "#" + subject
- }
- company = " <span style=\"color: #ff1720\">" + company + "</span>"
- }
- annotation := strings.ReplaceAll(article.Annotation, "<strong>", "")
- annotation = strings.ReplaceAll(annotation, "</strong>", "")
- annotation = strings.ReplaceAll(annotation, "</ol>", "</div>")
- annotation = strings.ReplaceAll(annotation, "<ol>", "<div>")
- annotation = strings.ReplaceAll(annotation, "</li>", "</p>")
- annotation = strings.ReplaceAll(annotation, "<li>", "<p>")
- re, _ := regexp.Compile("<strong.*?>")
- annotation = re.ReplaceAllString(annotation, "")
- reLi, _ := regexp.Compile("<li.*?>")
- annotation = reLi.ReplaceAllString(annotation, "")
- logItem := data_manage.CygxMinutesSummaryLog{
- ArticleId: int(articleId),
- Type: "SSGS",
- ChartPermissionId: CategoryChartPermissionIdMap[article.CategoryIdTwo],
- CreateTime: time.Now(),
- Body: head + company + annotation,
- ReportLink: "https://vmp.hzinsights.com/v2/articles/" + strconv.Itoa(article.ArticleId),
- LinkArticleId: article.LinkArticleId,
- }
- logItems = append(logItems, &logItem)
- }
- if len(logItems) > 0 {
- _, e := data_manage.AddCygxMinutesSummaryLogOrm(logItems)
- if e != nil {
- err = e
- return
- }
- }
- }
- //买方研选
- //{
- // var condition string
- // var pars []interface{}
- // condition += ` AND publish_date < ? AND publish_date >= ? `
- // pars = append(pars, tuesday, lastTuesday)
- // mfyxList := make([]*data_manage.CygxArticle, 0)
- //
- // //纪要
- // {
- // newCondition := condition + ` AND article_type_id = 1 `
- // list, e := data_manage.GetReportArticleList(newCondition, pars)
- // if e != nil {
- // err = e
- // fmt.Println("GetReportArticleList err:", e)
- // return
- // }
- // for _, article := range list {
- // mfyxList = append(mfyxList, article)
- // }
- // }
- // ////观点
- // //{
- // // newCondition := condition + ` AND article_type_id = 2 `
- // // list ,e := data_manage.GetReportArticleList(newCondition, pars)
- // // if e != nil {
- // // err = e
- // // fmt.Println("GetReportArticleList err:", e)
- // // return
- // // }
- // // for _, article := range list {
- // // mfyxList = append(mfyxList, article)
- // // }
- // //}
- // ////沙龙
- // //{
- // // newCondition := condition + ` AND article_type_id = 13 `
- // // list ,e := data_manage.GetReportArticleList(newCondition, pars)
- // // if e != nil {
- // // err = e
- // // fmt.Println("GetReportArticleList err:", e)
- // // return
- // // }
- // // for _, article := range list {
- // // mfyxList = append(mfyxList, article)
- // // }
- // //}
- // fmt.Println("mfyxList:", len(mfyxList))
- // var articleIdStr string
- // for _, v := range mfyxList {
- // articleIdStr += strconv.Itoa(v.ArticleId) + ","
- // }
- // mapArticleSubject := make(map[int]string)
- // articleIdStr = strings.TrimRight(articleIdStr, ",")
- // listSubject, e := data_manage.GetArticleSubjectList(articleIdStr)
- // if e != nil {
- // err = e
- // fmt.Println("GetArticleSubjectList err:", e)
- // return
- // }
- // for _, v := range listSubject {
- // mapArticleSubject[v.ArticleId] = v.SubjectName
- // }
- // var logItems []*data_manage.CygxMinutesSummaryLog
- // for _, article := range mfyxList {
- // head := "<div class=\"title-content\">\n 【" + article.Title + "】 "
- // body := strings.ReplaceAll(article.Body, "<strong>", "")
- // body = strings.ReplaceAll(body, "</strong>", "")
- // body = strings.ReplaceAll(body, "</ol>", "</div>")
- // body = strings.ReplaceAll(body, "<ol>", "<div>")
- // body = strings.ReplaceAll(body, "</li>", "</p>")
- // body = strings.ReplaceAll(body, "<li>", "<p>")
- // re, _ := regexp.Compile("<strong.*?>")
- // body = re.ReplaceAllString(body, "")
- // reLi, _ := regexp.Compile("<li.*?>")
- // body = reLi.ReplaceAllString(body, "")
- // //研选的公司需要单独处理
- // //sliceSubjects := strings.Split(article.Stock, "/")
- // var company string
- // //if sliceSubjects[0] != "" {
- // // for _, vSubject := range sliceSubjects {
- // // sliceKuohao := strings.Split(vSubject, "(") //过滤括号
- // // sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
- // // subject := sliceXiahuaxian[0]
- // // company += "#" + subject
- // // }
- // // company = " <span style=\"color: #ff1720\">" + company + "</span>"
- // //}
- // if mapArticleSubject[article.ArticleId] != "" {
- // company = " <span style=\"color: #ff1720\">" + "#" + mapArticleSubject[article.ArticleId] + "</span>"
- // }
- // var plus int
- // coreIndex := strings.Index(body, "核心观点:")
- // plus = 15
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心观点:")
- // plus = 13
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心观点")
- // plus = 12
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心结论:")
- // plus = 15
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心结论:")
- // plus = 13
- // }
- // if coreIndex == -1 {
- // coreIndex = strings.Index(body, "核心结论")
- // plus = 12
- // }
- // endIndex := strings.Index(body, "<hr")
- // if coreIndex != -1 && endIndex != -1 {
- // body = body[coreIndex+plus : endIndex]
- // logItem := data_manage.CygxMinutesSummaryLog{
- // ArticleId: int(articleId),
- // Type: "YANX",
- // ChartPermissionId: articleTypeChartPermissionIdMap[article.ArticleTypeId],
- // CreateTime: time.Now(),
- // Body: head + company + body,
- // ReportLink: "https://details.hzinsights.com/cygx/report?id=" + article.ArticleIdMd5,
- // LinkArticleId: article.LinkArticleId,
- // }
- // logItems = append(logItems, &logItem)
- // }
- // }
- // if len(logItems) > 0 {
- // _, e := data_manage.AddCygxMinutesSummaryLogOrm(logItems)
- // if e != nil {
- // err = e
- // return
- // }
- // }
- //
- //}
- return
- }
|