article.go 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581
  1. package services
  2. import (
  3. "context"
  4. "encoding/json"
  5. "fmt"
  6. "github.com/PuerkitoBio/goquery"
  7. "github.com/beego/beego/v2/client/orm"
  8. "hongze/hongze_cygx/models"
  9. "hongze/hongze_cygx/utils"
  10. "html"
  11. "net/url"
  12. "strconv"
  13. "strings"
  14. "time"
  15. )
  16. func GetReportContentSub(content string) (contentSub string, err error) {
  17. content = html.UnescapeString(content)
  18. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  19. if err != nil {
  20. fmt.Println("create doc err:", err.Error())
  21. return
  22. }
  23. n := 0
  24. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  25. if n > 3 {
  26. return
  27. }
  28. n++
  29. phtml, err := s.Html()
  30. if err != nil {
  31. fmt.Println("get html err", err.Error())
  32. return
  33. }
  34. if s.Text() != "" || strings.Contains(phtml, "src") {
  35. contentSub = contentSub + "<p>" + phtml + "</p>"
  36. }
  37. })
  38. return
  39. }
  40. func GetReportContentTextSub(content string) (contentSub string, err error) {
  41. content = html.UnescapeString(content)
  42. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  43. docText := doc.Text()
  44. bodyRune := []rune(docText)
  45. bodyRuneLen := len(bodyRune)
  46. if bodyRuneLen > 200 {
  47. bodyRuneLen = 200
  48. }
  49. body := string(bodyRune[:bodyRuneLen])
  50. contentSub = body
  51. contentSub = strings.Replace(body, "Powered by Froala Editor", "", -1)
  52. return
  53. }
  54. func GetReportContentTextSubNew(content string) (contentSub string, err error) {
  55. content = html.UnescapeString(content)
  56. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  57. docText := doc.Text()
  58. bodyRune := []rune(docText)
  59. bodyRuneLen := len(bodyRune)
  60. body := string(bodyRune[:bodyRuneLen])
  61. contentSub = body
  62. contentSub = strings.Replace(body, "Powered by Froala Editor", "", -1)
  63. return
  64. }
  65. //解析文章内容
  66. func GetArticleAll() {
  67. var err error
  68. defer func() {
  69. if err != nil {
  70. fmt.Println("err:", err.Error())
  71. return
  72. }
  73. }()
  74. list, err := models.GetArticleAll()
  75. if err != nil {
  76. return
  77. }
  78. for _, v := range list {
  79. fmt.Println(v.ArticleId, v.Title)
  80. FixArticleContent(v.ArticleId)
  81. }
  82. }
  83. //解析报告
  84. func FixArticleContent(articleId int) {
  85. item, err := models.GetArticleDetailById(articleId)
  86. if err != nil {
  87. fmt.Println("GetArticleDetailById Err:" + err.Error())
  88. return
  89. }
  90. content := item.Body
  91. bodyText, _ := GetReportContentTextSub(content)
  92. content = html.UnescapeString(content)
  93. content = strings.Replace(content, "http", "https", -1)
  94. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  95. if err != nil {
  96. fmt.Println("create doc err:", err.Error())
  97. return
  98. }
  99. var expertNumArr []string
  100. var expertContentArr []string
  101. var interviewDateArr []string
  102. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  103. contentTxt := s.Text()
  104. if strings.Contains(contentTxt, "#访谈时间:") || strings.Contains(contentTxt, "访谈时间:") {
  105. interviewDate := s.Next().Text()
  106. interviewDateArr = append(interviewDateArr, interviewDate)
  107. }
  108. if strings.Contains(contentTxt, "#专家评价") || strings.Contains(contentTxt, "专家评价") {
  109. expertContent := s.Next().Text()
  110. if expertContent == "" {
  111. expertContent = contentTxt
  112. }
  113. if expertContent != "" {
  114. rightIndex := strings.Index(expertContent, ")")
  115. if rightIndex == 0 {
  116. rightIndex = strings.Index(expertContent, ")")
  117. }
  118. if rightIndex > 0 {
  119. expertNum := expertContent[:rightIndex]
  120. expertNum = strings.Replace(expertNum, "(", "", -1)
  121. expertNum = strings.Replace(expertNum, "(", "", -1)
  122. expertNum = strings.Replace(expertNum, "专家评价", "", -1)
  123. if expertNum != "" {
  124. expertNumArr = append(expertNumArr, expertNum)
  125. rightIndex = rightIndex
  126. expertContentStr := expertContent[rightIndex:]
  127. expertContentStr = strings.Replace(expertContentStr, ")", "", -1)
  128. expertContentStr = strings.TrimLeft(expertContentStr, ":")
  129. expertContentStr = strings.TrimRight(expertContentStr, "(推荐")
  130. expertContentArr = append(expertContentArr, expertContentStr)
  131. }
  132. }
  133. }
  134. }
  135. })
  136. if len(expertContentArr) <= 0 {
  137. doc.Find("pre").Each(func(i int, pre *goquery.Selection) {
  138. pre.Find("span").Each(func(n int, span *goquery.Selection) {
  139. contentTxt := span.Text()
  140. if strings.Contains(contentTxt, "#专家评价") || strings.Contains(contentTxt, "专家评价") {
  141. span.Find("span").Each(func(m int, subspan *goquery.Selection) {
  142. subspanText := subspan.Text()
  143. if strings.Contains(subspanText, "专家评价") {
  144. expertContent := subspan.Next().Text()
  145. if expertContent != "" {
  146. rightIndex := strings.Index(expertContent, ")")
  147. if rightIndex == 0 {
  148. rightIndex = strings.Index(expertContent, ")")
  149. }
  150. if rightIndex > 0 {
  151. expertNum := expertContent[:rightIndex]
  152. expertNum = strings.Replace(expertNum, "(", "", -1)
  153. expertNum = strings.Replace(expertNum, "(", "", -1)
  154. expertNum = strings.Replace(expertNum, "专家评价", "", -1)
  155. if expertNum != "" {
  156. expertNumArr = append(expertNumArr, expertNum)
  157. rightIndex = rightIndex
  158. expertContentStr := expertContent[rightIndex:]
  159. expertContentStr = strings.Replace(expertContentStr, ")", "", -1)
  160. expertContentStr = strings.TrimLeft(expertContentStr, ":")
  161. expertContentStr = strings.TrimRight(expertContentStr, "(推荐")
  162. expertContentArr = append(expertContentArr, expertContentStr)
  163. }
  164. }
  165. }
  166. }
  167. })
  168. }
  169. span.Find("span").Each(func(k int, sspan *goquery.Selection) {
  170. sspanText := sspan.Text()
  171. if strings.Contains(sspanText, "访谈时间") {
  172. sspanText = strings.Replace(sspanText, "#访谈时间:", "", -1)
  173. sspanText = strings.Replace(sspanText, "访谈时间:", "", -1)
  174. sspanText = strings.Replace(sspanText, "\n", "", -1)
  175. sspanText = strings.Replace(sspanText, " ", "", -1)
  176. sspanText = strings.Trim(sspanText, " ")
  177. sspanText = sspanText[:10]
  178. interviewDate := sspanText
  179. if interviewDate != "" {
  180. interviewDateArr = append(interviewDateArr, interviewDate)
  181. }
  182. }
  183. })
  184. })
  185. })
  186. }
  187. if len(expertContentArr) <= 0 {
  188. doc.Find("span").Each(func(i int, span *goquery.Selection) {
  189. span.Find("strong").Each(func(n int, strong *goquery.Selection) {
  190. spanText := span.Text()
  191. strongText := strong.Text()
  192. if strings.Contains(strongText, "#专家评价") || strings.Contains(strongText, "专家评价") {
  193. expertContent := strong.Parents().Text()
  194. if expertContent != "" {
  195. rightIndex := strings.Index(expertContent, ")")
  196. if rightIndex == 0 {
  197. rightIndex = strings.Index(expertContent, ")")
  198. }
  199. if rightIndex > 0 {
  200. expertNum := expertContent[:rightIndex]
  201. expertNum = strings.Replace(expertNum, "(", "", -1)
  202. expertNum = strings.Replace(expertNum, "(", "", -1)
  203. expertNum = strings.Replace(expertNum, "专家评价", "", -1)
  204. expertNum = strings.Replace(expertNum, "#", "", -1)
  205. expertNum = strings.Replace(expertNum, ":", "", -1)
  206. expertNum = strings.Replace(expertNum, "\n", "", -1)
  207. if expertNum != "" {
  208. expertNumArr = append(expertNumArr, expertNum)
  209. rightIndex = rightIndex
  210. expertContentStr := expertContent[rightIndex:]
  211. expertContentStr = strings.Replace(expertContentStr, ")", "", -1)
  212. expertContentStr = strings.TrimLeft(expertContentStr, ":")
  213. expertContentStr = strings.TrimRight(expertContentStr, "(推荐")
  214. expertContentArr = append(expertContentArr, expertContentStr)
  215. return
  216. }
  217. }
  218. }
  219. }
  220. if strings.Contains(spanText, "访谈时间") {
  221. spanText = strings.Replace(spanText, "#访谈时间:", "", -1)
  222. spanText = strings.Replace(spanText, "访谈时间:", "", -1)
  223. spanText = strings.Replace(spanText, "\n", "", -1)
  224. spanText = strings.Replace(spanText, " ", "", -1)
  225. spanText = strings.Trim(spanText, " ")
  226. spanText = spanText[:10]
  227. interviewDate := spanText
  228. if interviewDate != "" {
  229. interviewDateArr = append(interviewDateArr, interviewDate)
  230. }
  231. }
  232. })
  233. })
  234. }
  235. var expertNumStr, expertContentStr, interviewDateStr string
  236. if len(expertNumArr) > 0 {
  237. expertNumStr = expertNumArr[0]
  238. }
  239. if len(expertContentArr) > 0 {
  240. expertContentStr = expertContentArr[0]
  241. }
  242. if len(interviewDateArr) > 0 {
  243. interviewDateStr = interviewDateArr[0]
  244. }
  245. expertNumStr = strings.Replace(expertNumStr, "#:", "", -1)
  246. err = models.ModifyArticleExpert(articleId, expertNumStr, expertContentStr, interviewDateStr, bodyText)
  247. if err != nil {
  248. fmt.Println("ModifyArticleExpert Err:" + err.Error())
  249. return
  250. }
  251. }
  252. func FixArticleImgUrl(body string) (contentSub string, err error) {
  253. r := strings.NewReader(string(body))
  254. doc, err := goquery.NewDocumentFromReader(r)
  255. if err != nil {
  256. fmt.Println(err)
  257. }
  258. doc.Find("img").Each(func(i int, s *goquery.Selection) {
  259. src, _ := s.Attr("src")
  260. if i == 0 && src != "" {
  261. contentSub = src
  262. }
  263. })
  264. return
  265. }
  266. //获取标签里的第一个内容
  267. func FixArticleFirstCount(body string) (contentSub string, err error) {
  268. doc, err := goquery.NewDocumentFromReader(strings.NewReader(body))
  269. if err != nil {
  270. fmt.Println("create doc err:", err.Error())
  271. return
  272. }
  273. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  274. contentTxt := s.Text()
  275. fmt.Println(contentTxt)
  276. })
  277. return
  278. }
  279. func SynchronizationArtclehistory() {
  280. fmt.Println("同步开始")
  281. list, err := models.GetArticleHistoryList()
  282. if err != nil {
  283. fmt.Println("获取列表失败", err)
  284. }
  285. fmt.Println(len(list))
  286. for _, v := range list {
  287. //endDate := v.ModifyTime.Add(+time.Minute * 10).Format(utils.FormatDateTime)
  288. //detail, err := models.GetNewArticleHistoryRecordNewpv(v.UserId, v.ArticleId, endDate)
  289. //if err != nil && err.Error() != utils.ErrNoRow() {
  290. // fmt.Println("获取信息失败", err)
  291. //}
  292. v.OutType = 1
  293. //fmt.Println(v.Id)
  294. //if detail == nil {
  295. // _, err = models.AddCygxArticleViewRecordNewpv(v)
  296. // if err != nil {
  297. // fmt.Println("新增失败", err)
  298. // }
  299. //} else {
  300. // err = models.UpdateCygxArticleViewRecordNewpvList(v, v.StopTime)
  301. // if err != nil {
  302. // fmt.Println("修改失败", err)
  303. // }
  304. //}
  305. newId, err := models.AddCygxArticleViewRecordNewpv(v)
  306. fmt.Println("新增", newId)
  307. if err != nil {
  308. fmt.Println("新增失败", err)
  309. }
  310. }
  311. fmt.Println("同步结束")
  312. }
  313. //统计报表
  314. func StatisticalReport() {
  315. var isSummaryNumAll, isClassNum, pvNumAll, uvNumAll int
  316. list, err := models.GetChartPermissionActivity()
  317. if err != nil {
  318. fmt.Println("获取列表失败", err)
  319. }
  320. for _, v := range list {
  321. var listPv []*models.ReportMappingStatistical
  322. if v.PermissionName == "研选" {
  323. listPv, err = models.GetStatisticalReportArtilceExpert()
  324. if err != nil {
  325. fmt.Println("获取Pv列表失败", err)
  326. }
  327. } else {
  328. listPv, err = models.GetStatisticalReportArtilce(v.ChartPermissionId)
  329. if err != nil {
  330. fmt.Println("获取Pv列表失败", err)
  331. }
  332. }
  333. var pvNum, uvNum, isSummaryNum int
  334. for _, v2 := range listPv {
  335. pvNum += v2.Pv
  336. uvNum += v2.Uv
  337. if v2.IsSummary == "1" {
  338. isSummaryNum += 1
  339. }
  340. if v2.IsClass == "1" && v.ChartPermissionId <= 22 {
  341. isClassNum += 1
  342. }
  343. if v2.IsSummary == "1" && v.ChartPermissionId <= 22 {
  344. isSummaryNumAll += 1
  345. }
  346. }
  347. if v.ChartPermissionId <= 22 {
  348. pvNumAll += pvNum
  349. uvNumAll += uvNum
  350. }
  351. fmt.Println(v.PermissionName+"行业", len(listPv), "篇,其中主观类报告", isSummaryNum, "篇,客观类报告", len(listPv)-isSummaryNum, "篇。共产生阅读量pv-,", pvNum, ",uv-", uvNum)
  352. }
  353. fmt.Println("目前同步四大行业的总报告(已归类)数量", isClassNum, "篇,其中主观类报告", isSummaryNumAll, "篇,客观类报告", isClassNum-isSummaryNumAll, "篇。共产生阅读量pv-", pvNumAll, ",uv-", uvNumAll)
  354. var totalOnline int //线上
  355. var totalOffline int //线下
  356. var totalPeople int //共累计预约外呼人数
  357. var totalSignUpOff int //线下报名人数
  358. var totalSignUpOffTime int //线下报名人数
  359. var totalPeopleMeet int //线下参会人数
  360. o := orm.NewOrm()
  361. sql := `SELECT COUNT(1) FROM cygx_activity WHERE activity_type_id IN (1,2,3) AND publish_status = 1 AND is_submit_meeting = 1 AND activity_time <= NOW();`
  362. err = o.Raw(sql).QueryRow(&totalOnline)
  363. if err != nil {
  364. fmt.Println("获取线上", err)
  365. }
  366. sql = `SELECT COUNT(1) FROM cygx_activity WHERE activity_type_id IN (4,5,6) AND publish_status = 1 AND is_submit_meeting = 1 AND activity_time <= NOW();`
  367. err = o.Raw(sql).QueryRow(&totalOffline)
  368. if err != nil {
  369. fmt.Println("获取线下", err)
  370. }
  371. sql = `SELECT COUNT( 1 ) FROM
  372. cygx_activity_signup as s
  373. INNER JOIN cygx_activity as a ON a.activity_id = s.activity_id
  374. WHERE
  375. s.do_fail_type = 0
  376. AND a.is_submit_meeting = 1
  377. AND a.activity_time <= NOW()
  378. AND a.publish_status = 1`
  379. err = o.Raw(sql).QueryRow(&totalPeople)
  380. if err != nil {
  381. fmt.Println("共累计预约外呼人数", err)
  382. }
  383. sql = `SELECT COUNT( 1 ) FROM
  384. cygx_activity_signup as s
  385. INNER JOIN cygx_activity as a ON a.activity_id = s.activity_id
  386. WHERE
  387. s.do_fail_type = 0
  388. AND a.is_submit_meeting = 1
  389. AND a.activity_time <= NOW()
  390. AND a.activity_type_id IN (4,5,6)
  391. AND a.publish_status = 1`
  392. err = o.Raw(sql).QueryRow(&totalSignUpOff)
  393. if err != nil {
  394. fmt.Println("共累计预约外呼人数", err)
  395. }
  396. sql = `SELECT COUNT( 1 ) FROM
  397. cygx_activity_signup as s
  398. INNER JOIN cygx_activity as a ON a.activity_id = s.activity_id
  399. WHERE
  400. s.do_fail_type = 0
  401. AND a.publish_status = 1
  402. AND a.is_submit_meeting = 1
  403. AND a.activity_time <= NOW()
  404. AND a.is_submit_meeting = 1
  405. AND a.activity_type_id IN (4,5,6);`
  406. err = o.Raw(sql).QueryRow(&totalSignUpOffTime)
  407. if err != nil {
  408. fmt.Println("线下报名参会人数", err)
  409. }
  410. sql = `SELECT COUNT( 1 ) FROM
  411. cygx_activity_signup as s
  412. INNER JOIN cygx_activity as a ON a.activity_id = s.activity_id
  413. WHERE
  414. s.do_fail_type = 0
  415. AND a.is_submit_meeting = 1
  416. AND a.activity_time <= NOW()
  417. AND a.publish_status = 1
  418. AND s.is_meeting = 1
  419. AND a.activity_type_id IN (4,5,6);`
  420. err = o.Raw(sql).QueryRow(&totalPeopleMeet)
  421. if err != nil {
  422. fmt.Println("线下参会人数", err)
  423. }
  424. fmt.Println("共上线活动", totalOnline+totalOffline, "个,其中线上", totalOnline, "个,线下", totalOffline, "个")
  425. fmt.Println("共累计预约外呼人数", totalPeople, "人")
  426. fmt.Println("报名线下参会", totalSignUpOff, "人,实际到会人数", totalPeopleMeet, "人,线下到会率约", totalPeopleMeet*100/totalSignUpOff, "%")
  427. num := totalPeopleMeet / totalSignUpOffTime
  428. fmt.Println(num)
  429. fmt.Println(totalOnline)
  430. fmt.Println(totalOffline)
  431. fmt.Println(totalPeople)
  432. fmt.Println(totalSignUpOff)
  433. fmt.Println(totalPeopleMeet)
  434. fmt.Println(totalSignUpOffTime)
  435. fmt.Println(totalPeopleMeet / totalSignUpOffTime)
  436. return
  437. }
  438. // UserViewRedisData 阅读数据
  439. type UserViewRedisData struct {
  440. Mobile string `json:"mobile"`
  441. Email string `json:"email"`
  442. RealName string `json:"real_name"`
  443. CompanyName string `json:"company_name"`
  444. ViewTime string `json:"view_time" description:"阅读时间,格式:2022-02-17 13:06:13"`
  445. ProductId int `json:"product_id" description:"报告所属产品,ficc:1,权益:2"`
  446. CompanyId int `json:"company_id" description:"客户id"`
  447. }
  448. type ReportViewRecord struct {
  449. Id int `orm:"column(id);pk"`
  450. UserId int `description:"用户id"`
  451. ReportId int `description:"报告id"`
  452. Mobile string `description:"手机号"`
  453. Email string `description:"邮箱"`
  454. RealName string `description:"用户实际姓名"`
  455. CompanyName string `description:"公司名称"`
  456. CreateTime time.Time `description:"创建时间"`
  457. }
  458. // PushViewRecordNewRedisData 阅读数据加入到redis
  459. func PushViewRecordNewRedisData(reportViewRecord *ReportViewRecord, companyId int) bool {
  460. data := &UserViewRedisData{
  461. Mobile: reportViewRecord.Mobile,
  462. Email: reportViewRecord.Email,
  463. RealName: reportViewRecord.RealName,
  464. CompanyName: reportViewRecord.CompanyName,
  465. ViewTime: reportViewRecord.CreateTime.Format(utils.FormatDateTime),
  466. ProductId: 2,
  467. CompanyId: companyId,
  468. }
  469. if utils.Re == nil {
  470. err := utils.Rc.LPush(utils.CACHE_KEY_USER_VIEW, data)
  471. if err != nil {
  472. fmt.Println("PushViewRecordNewRedisData LPush Err:" + err.Error())
  473. }
  474. return true
  475. }
  476. return false
  477. }
  478. //func GetCeLueArticlePv() {
  479. // sum := 0
  480. // for i := 0; i <= 450; i++ {
  481. // if i >= 102 {
  482. // //GetCeLueArticlePvs(strconv.Itoa(i * 1000))
  483. // }
  484. // }
  485. // fmt.Println(sum)
  486. //}
  487. //获取策略平台报告阅读数据
  488. func GetCeLueArticlePv(cont context.Context) (err error) {
  489. defer func() {
  490. if err != nil {
  491. go utils.SendAlarmMsg("同步策略平台阅读数据失败", 2)
  492. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetCeLueArticlePv ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  493. }
  494. }()
  495. startTime := time.Now().Add(-time.Minute * 12).Format("2006-01-02 15:04:05")
  496. endTime := time.Now().Format("2006-01-02 15:04:05")
  497. requestUrl := utils.ApiUrl + "backend/statistics_access?take=1000&skip=0&sort=ASC&mode=all&"
  498. encodeData := url.Values{}
  499. encodeData.Add("start_dt", startTime)
  500. encodeData.Add("end_dt", endTime)
  501. encodeStr := encodeData.Encode()
  502. requestUrl += encodeStr
  503. authorization := utils.ApiAuthorization
  504. body, err := PublicGetDate(requestUrl, authorization)
  505. if err != nil {
  506. return
  507. }
  508. var chartResult models.CeLueArticleResultApi
  509. err = json.Unmarshal(body, &chartResult)
  510. if err != nil {
  511. fmt.Println(err)
  512. return err
  513. }
  514. mapMobileArticleId := make(map[string]int)
  515. //获取当天阅读记录
  516. listPv, err := models.GetArticleHistoryRecordAllList()
  517. if err != nil && err.Error() != utils.ErrNoRow() {
  518. fmt.Println("获取当天阅读记录失败", err)
  519. return err
  520. }
  521. if len(listPv) > 0 {
  522. for _, v := range listPv {
  523. mapMobileArticleId[fmt.Sprint(v.Mobile, "_", v.ArticleId)] = v.ArticleId
  524. }
  525. }
  526. for _, v := range chartResult.Data {
  527. //fmt.Println(v.ArticleId)
  528. item := new(models.CygxCelueArticleHistoryRecord)
  529. item.CelueHistoryId = v.CelueHistoryId
  530. item.Mobile = v.Mobile
  531. item.ArticleId = v.ArticleId
  532. if v.CrmUser != nil {
  533. item.RealName = v.CrmUser.RealName
  534. }
  535. if v.CompanyName != nil {
  536. item.CompanyName = v.CompanyName.RealName
  537. }
  538. item.CreateDateApi = time.Now()
  539. t1, _ := time.Parse("2006-01-02T15:04:05Z", v.CreateDate)
  540. item.CreateTime = t1.Add(+time.Hour * 8).Format(utils.FormatDateTime)
  541. count, err := models.GetCeLueArticleCountById(v.CelueHistoryId)
  542. if err != nil && err.Error() != utils.ErrNoRow() {
  543. return err
  544. }
  545. if count == 0 {
  546. _, err := models.AddCeLueArticle(item, mapMobileArticleId)
  547. if err != nil {
  548. fmt.Println(err)
  549. return err
  550. }
  551. }
  552. }
  553. //处理同步过来的阅读记录所属用户
  554. var condition string
  555. condition = ` AND create_time > ` + "'" + startTime + "'"
  556. listArticlePv, err := models.GetArticleHistoryRecordAllByMobileList(condition)
  557. if err != nil {
  558. fmt.Println("GetArticleHistoryRecordAllByMobileList ,Err" + err.Error())
  559. }
  560. for _, v := range listArticlePv {
  561. if v.Mobile != "" {
  562. user, err := models.GetWxUserItemByMobile(v.Mobile)
  563. if err != nil && err.Error() != utils.ErrNoRow() {
  564. fmt.Println("GetWxUserItemByUserId ,Err" + err.Error())
  565. }
  566. if user != nil {
  567. err = models.UpdateCygxArticleHistoryRecordAll(user)
  568. if err != nil {
  569. fmt.Println("UpdateCygxArticleCollect ,Err" + err.Error())
  570. }
  571. }
  572. }
  573. }
  574. return
  575. }
  576. func GetArticleListByApi(cont context.Context) (err error) {
  577. defer func() {
  578. if err != nil {
  579. //fmt.Println("GetArticleListByApi Err:" + err.Error())
  580. go utils.SendAlarmMsg("同步策略平台数据失败", 2)
  581. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetArticleListByApi ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  582. }
  583. }()
  584. listUpdateArticle, err := models.GetArticleCeluePushList()
  585. if err != nil && err.Error() != utils.ErrNoRow() {
  586. return err
  587. }
  588. //如果长度为零就不处理
  589. if len(listUpdateArticle) == 0 {
  590. return err
  591. }
  592. for _, v := range listUpdateArticle {
  593. // 这里直接go出去会出现并发,导致文章md5ID唯一索引限制报错
  594. err = HandleArticleListByApi(v.ArticleId)
  595. if err != nil {
  596. utils.FileLog.Info("WxGetToken Result:%s ", err.Error())
  597. }
  598. }
  599. return
  600. }
  601. //处理同步过来的文章
  602. func HandleArticleListByApi(artcleId int) (err error) {
  603. defer func() {
  604. if err != nil {
  605. go utils.SendAlarmMsg("处理同步策略平台数据失败"+"GetArticleListByApi ErrMsg:"+err.Error(), 2)
  606. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetArticleListByApi ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  607. }
  608. }()
  609. var clueApiUrl string
  610. clueApiUrl = fmt.Sprint(utils.ApiUrl, "articles/", artcleId)
  611. fmt.Println(clueApiUrl)
  612. authorization := utils.ApiAuthorization
  613. body, err := PublicGetDate(clueApiUrl, authorization)
  614. if err != nil {
  615. fmt.Println(err)
  616. return
  617. }
  618. var articleResultDate models.ArticleDetailResultApi
  619. err = json.Unmarshal(body, &articleResultDate)
  620. if err != nil {
  621. fmt.Println("Getres.PublicGetDate Err:", err.Error())
  622. return err
  623. }
  624. articleResult := articleResultDate.Data
  625. exitMap := make(map[int]int)
  626. classMap := make(map[int]int)
  627. reportMap := make(map[int]int)
  628. summaryMap := make(map[int]int)
  629. listMap, err := models.GetArticleApiMap()
  630. if err != nil {
  631. fmt.Println("GetlistMap Err:", err.Error())
  632. return err
  633. }
  634. openIdList, err := models.GetUserRecordListByMobile(4, utils.ArticleTaskClassMobile)
  635. if err != nil {
  636. fmt.Println(err)
  637. return err
  638. }
  639. fmt.Println(openIdList)
  640. //新旧分类 反向隐射,是否归类,是否是报告,是否是纪要库
  641. for _, v := range listMap {
  642. exitMap[v.Id] = v.OldId
  643. if v.IsClass == 1 {
  644. classMap[v.OldId] = 1
  645. }
  646. if v.IsReport == 1 {
  647. reportMap[v.OldId] = 1
  648. }
  649. if v.IsSummary == 1 {
  650. summaryMap[v.OldId] = 1
  651. }
  652. }
  653. var list []*models.Tactics2
  654. var listAuthor []*models.CygxArticleAuthor
  655. //状态等于 2 跟 4 的进行同步
  656. if exitMap[articleResult.SeriesId] > 0 && (articleResult.PublishStatus == 2 || articleResult.PublishStatus == 4) {
  657. articleResult.PublishDate = time.Date(articleResult.PublishDate.Year(), articleResult.PublishDate.Month(), articleResult.PublishDate.Day(), articleResult.PublishDate.Hour(), articleResult.PublishDate.Minute(), articleResult.PublishDate.Second(), articleResult.PublishDate.Nanosecond(), time.Local)
  658. item := new(models.Tactics2)
  659. itemAuthor := new(models.CygxArticleAuthor)
  660. item.ArticleId = articleResult.ArticleId
  661. item.Title = articleResult.Title
  662. item.TitleEn = articleResult.TitleEn
  663. item.File = articleResult.File
  664. if articleResult.Frequency == "日度" {
  665. item.UpdateFrequency = "daily"
  666. } else if articleResult.Frequency == "周度" {
  667. item.UpdateFrequency = "weekly"
  668. } else if articleResult.Frequency == "月度" {
  669. item.UpdateFrequency = "monthly"
  670. } else if articleResult.Frequency == "季度" {
  671. item.UpdateFrequency = "quarterly"
  672. } else if articleResult.Frequency == "年度" {
  673. item.UpdateFrequency = "yearly"
  674. } else {
  675. item.UpdateFrequency = "unknow"
  676. }
  677. item.CreateDate = articleResult.CreateDate
  678. item.PublishDate = articleResult.PublishDate.Add(time.Hour * 8)
  679. item.PublishStatus = 1
  680. item.Body = articleResult.Content.Body
  681. item.Abstract = articleResult.Content.Abstract
  682. item.CategoryName = articleResult.Industry.Name
  683. item.CategoryId = exitMap[articleResult.SeriesId]
  684. item.SubCategoryName = articleResult.Series.Name
  685. if len(articleResult.Stock) > 0 {
  686. var stock string
  687. for _, vS := range articleResult.Stock {
  688. stock += vS + "/"
  689. }
  690. stock = strings.TrimRight(stock, "/")
  691. item.Stock = stock
  692. }
  693. item.FieldName = articleResult.Field.Name
  694. list = append(list, item)
  695. itemAuthor.ArticleId = articleResult.ArticleId
  696. itemAuthor.Name = articleResult.Author.Name
  697. itemAuthor.Mobile = articleResult.Author.PhoneNumber
  698. listAuthor = append(listAuthor, itemAuthor)
  699. } else {
  700. // 如果这篇文章没有发布,那么就不作处理。
  701. err = models.UpdateArticlePublish(0, artcleId)
  702. if err != nil {
  703. fmt.Println("UpdateArticlePublish Err:", err.Error())
  704. return err
  705. }
  706. go models.UpdateCygxArticleCeluePush(artcleId)
  707. return err
  708. }
  709. //同步作者
  710. for _, v := range listAuthor {
  711. var count int
  712. count, err = models.GetActivityAuthorCount(v.ArticleId, v.Mobile)
  713. if err != nil {
  714. fmt.Println("GetActivityAuthorCount Err:", err.Error())
  715. return err
  716. }
  717. if count == 0 {
  718. _, err = models.AddCygxActivityAuthor(v)
  719. if err != nil {
  720. fmt.Println("AddCygxActivityAuthor Err:", err.Error())
  721. return err
  722. }
  723. }
  724. }
  725. fmt.Println("同步文章条数:", len(list))
  726. listCustomArticle, err := models.GetCustomArticleId() //手动归类的文章,不替换文章类型
  727. if err != nil {
  728. fmt.Println("GetTacticsList Err:", err.Error())
  729. return err
  730. }
  731. listGetMatchTypeName, errMatch := models.GetMatchTypeNamenNotNull() //手动归类的文章,不替换文章类型
  732. if errMatch != nil {
  733. fmt.Println("GetTacticsList Err:", errMatch.Error())
  734. return err
  735. }
  736. fmt.Println("list len:", len(list))
  737. noSummaryArticleIds := "3454,3456,3457,3459,2449,2450,2453,2454,2459,2530,2583,2663,2670,2699,2715,2732,2748,2759,2399,2356,2870,3173,2978,2826,3470" //非纪要库类型的文章ID
  738. listNoSummaryArticleIds := strings.Split(noSummaryArticleIds, ",")
  739. for k, v := range list {
  740. //同步匹配类型
  741. matchTypeName := ""
  742. for _, vMatch := range listGetMatchTypeName {
  743. if v.CategoryId == vMatch.CategoryId {
  744. matchTypeName = vMatch.MatchTypeName
  745. }
  746. }
  747. //是否属于纪要库的数据
  748. if _, has := summaryMap[v.CategoryId]; has {
  749. v.IsSummary = 1
  750. }
  751. //排除不属于纪要库类型的文章
  752. for _, vArt := range listNoSummaryArticleIds {
  753. vArtInt, _ := strconv.Atoi(vArt)
  754. if v.ArticleId == vArtInt {
  755. v.IsSummary = 0
  756. }
  757. }
  758. if _, has := reportMap[v.CategoryId]; has {
  759. v.IsReport = 1
  760. if _, ok := classMap[v.CategoryId]; ok {
  761. v.IsClass = 1
  762. v.ReportType = 1 //是否属于行业报告
  763. } else {
  764. v.ReportType = 2 //是否属于产业报告
  765. }
  766. }
  767. v.Department = "弘则权益研究"
  768. //判断是否已经存在
  769. if v.ArticleId < 0 {
  770. fmt.Println("AddCygxArticle Err:")
  771. return err
  772. }
  773. var count int
  774. count, err = models.GetArticleCountById(v.ArticleId)
  775. if err != nil && err.Error() != utils.ErrNoRow() {
  776. fmt.Println("AddCygxArticle Err:", err.Error())
  777. return err
  778. }
  779. v.Body = strings.Replace(v.Body, "http://vmp.hzinsights.com", "https://vmp.hzinsights.com", -1)
  780. expertNumStr, expertContentStr, interviewDateStr, _, bodyReturn := BodyAnalysis2(v.Body)
  781. if strings.Index(v.Body, "报告全文(") > 0 && strings.Index(v.Body, "PDF格式报告下载.pdf") > 0 {
  782. v.Body = strings.Replace(v.Body, "报告全文(", "", -1)
  783. v.Body = strings.Replace(v.Body, "PDF格式报告下载.pdf", "", -1)
  784. v.Body = strings.Replace(v.Body, "):", "", -1)
  785. }
  786. var titleNew string
  787. titleNew = v.Title
  788. // 7资金流向 、11大类资产 、51每日复盘 、80医药周报、9估值研究
  789. if v.CategoryId == 7 || v.CategoryId == 11 || v.CategoryId == 51 || v.CategoryId == 9 {
  790. if v.UpdateFrequency == "daily" {
  791. var daystr string
  792. daystr = strconv.Itoa(v.PublishDate.Day())
  793. if len(daystr) == 1 {
  794. daystr = "0" + daystr
  795. }
  796. titleNew = v.Title + "(" + strconv.Itoa(v.PublishDate.Year())[2:len(strconv.Itoa(v.PublishDate.Year()))-0] + v.PublishDate.Format("01") + daystr + ")"
  797. } else if v.UpdateFrequency == "weekly" {
  798. titleNew = v.Title + utils.WeekByDate(v.PublishDate)
  799. }
  800. }
  801. if v.CategoryId == 80 {
  802. titleNew = v.Title + utils.WeekByDate(v.PublishDate)
  803. }
  804. if count > 0 {
  805. fmt.Println(k, v.ArticleId, "edit")
  806. var isCustom bool
  807. bodyText, _ := GetReportContentTextSub(v.Body)
  808. updateParams := make(map[string]interface{})
  809. //updateParams["Title"] = v.Title
  810. updateParams["Title"] = titleNew
  811. updateParams["TitleEn"] = v.TitleEn
  812. updateParams["UpdateFrequency"] = v.UpdateFrequency
  813. updateParams["CreateDate"] = v.CreateDate
  814. updateParams["PublishDate"] = v.PublishDate
  815. //updateParams["Body"] = html.EscapeString(v.Body)
  816. updateParams["Body"] = html.EscapeString(bodyReturn)
  817. updateParams["BodyText"] = bodyText
  818. updateParams["Abstract"] = html.EscapeString(v.Abstract)
  819. updateParams["CategoryName"] = v.CategoryName
  820. for _, vCustom := range listCustomArticle {
  821. if v.ArticleId == vCustom.ArticleId {
  822. fmt.Println("手动归类的文章:" + strconv.Itoa(v.ArticleId))
  823. isCustom = true
  824. }
  825. }
  826. if isCustom == false {
  827. updateParams["CategoryId"] = v.CategoryId
  828. updateParams["MatchTypeName"] = matchTypeName
  829. updateParams["IsSummary"] = v.IsSummary
  830. updateParams["IsReport"] = v.IsReport
  831. updateParams["ReportType"] = v.ReportType
  832. updateParams["SubCategoryName"] = v.SubCategoryName
  833. }
  834. //updateParams["CategoryId"] = v.CategoryId
  835. updateParams["PublishStatus"] = 1
  836. updateParams["ExpertBackground"] = expertContentStr
  837. updateParams["ExpertNumber"] = expertNumStr
  838. updateParams["InterviewDate"] = interviewDateStr
  839. //updateParams["IsClass"] = v.IsClass
  840. v.Department = "弘则权益研究"
  841. updateParams["Department"] = v.Department
  842. updateParams["FileLink"] = v.File
  843. updateParams["Stock"] = v.Stock
  844. updateParams["FieldName"] = v.FieldName
  845. whereParam := map[string]interface{}{"article_id": v.ArticleId}
  846. err = models.UpdateByExpr(models.CygxArticle{}, whereParam, updateParams)
  847. if err != nil {
  848. fmt.Println("UpdateByExpr Err:" + err.Error())
  849. return err
  850. }
  851. } else {
  852. fmt.Println(k, v.ArticleId, "add")
  853. item := new(models.CygxArticle)
  854. articleIdInt := v.ArticleId
  855. item.ArticleId = articleIdInt
  856. //item.Title = v.Title
  857. item.Title = titleNew
  858. item.TitleEn = v.TitleEn
  859. item.UpdateFrequency = v.UpdateFrequency
  860. item.CreateDate = v.CreateDate
  861. item.PublishDate = v.PublishDate.Format(utils.FormatDateTime)
  862. //item.Body = html.EscapeString(v.Body)
  863. item.Body = html.EscapeString(bodyReturn)
  864. item.Abstract = html.EscapeString(v.Abstract)
  865. item.CategoryName = v.CategoryName
  866. item.SubCategoryName = v.SubCategoryName
  867. item.CategoryId = v.CategoryId
  868. item.CategoryIdTwo = v.CategoryId
  869. item.PublishStatus = 1
  870. item.ExpertBackground = expertContentStr
  871. item.ExpertNumber = expertNumStr
  872. item.InterviewDate = interviewDateStr
  873. item.Department = v.Department
  874. item.ArticleIdMd5 = utils.MD5(strconv.Itoa(articleIdInt))
  875. item.IsClass = v.IsClass
  876. item.IsSummary = v.IsSummary
  877. item.IsReport = v.IsReport
  878. item.ReportType = v.ReportType
  879. item.FileLink = v.File
  880. item.MatchTypeName = matchTypeName
  881. item.Stock = v.Stock
  882. item.FieldName = v.FieldName
  883. newId, err := models.AddCygxArticles(item)
  884. if err != nil {
  885. fmt.Println("AddCygxArticle Err:", err.Error())
  886. return err
  887. }
  888. //fmt.Println(newId)
  889. //报告自动归类,以及推送相关模板消息
  890. if v.ReportType == 2 {
  891. var subjectStr string
  892. var industrialManagementIdStr string
  893. var industrialSubjectIdStr string
  894. var keyword1 string
  895. var keyword2 string
  896. var keyword3 string
  897. var keyword4 string
  898. sliceSubjects := strings.Split(v.Stock, "/")
  899. mapManagementForSubject := make(map[string]string)
  900. if len(sliceSubjects) > 0 {
  901. for _, vSubject := range sliceSubjects {
  902. sliceKuohao := strings.Split(vSubject, "(") //过滤括号
  903. sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
  904. subject := sliceXiahuaxian[0]
  905. subjectStr += "'" + subject + "',"
  906. }
  907. //获取该产业下所对应的行业图片
  908. detailCategory, errCategory := models.GetdetailByCategoryIdOne(v.CategoryId)
  909. if errCategory != nil {
  910. fmt.Println("GetdetailByCategoryIdOne Err:", err.Error())
  911. return err
  912. }
  913. subjectStr = strings.TrimRight(subjectStr, ",")
  914. if subjectStr != "" {
  915. listIndustrial, err := models.GetIndustrialManagementForSubjecName(subjectStr, detailCategory.ChartPermissionId)
  916. if err != nil {
  917. fmt.Println("GetIndustrialManagementForSubjecName Err:", err.Error())
  918. return err
  919. }
  920. subjectStr = strings.Replace(subjectStr, "','", "】【", -1)
  921. subjectStr = strings.Replace(subjectStr, "'", "", -1)
  922. subjectStr = "【" + subjectStr + "】"
  923. if len(listIndustrial) > 0 {
  924. for _, vIndustrial := range listIndustrial {
  925. industrialManagementIdStr += strconv.Itoa(vIndustrial.IndustrialManagementId) + ","
  926. industrialSubjectIdStr += strconv.Itoa(vIndustrial.IndustrialSubjectId) + ","
  927. mapManagementForSubject[vIndustrial.IndustryName] += vIndustrial.SubjectName + "/"
  928. }
  929. industrialManagementIdStr = strings.TrimRight(industrialManagementIdStr, ",")
  930. industrialSubjectIdStr = strings.TrimRight(industrialSubjectIdStr, ",")
  931. if industrialManagementIdStr != "" {
  932. err = models.ReportArticleClassificationEditNew(int(newId), industrialManagementIdStr, v.ArticleId, industrialSubjectIdStr)
  933. if err != nil {
  934. fmt.Println("ReportArticleClassificationEditNew Err:", err.Error())
  935. return err
  936. }
  937. }
  938. var peoductName string
  939. for mk, mv := range mapManagementForSubject {
  940. peoductName += "【" + mk + "--" + strings.TrimRight(mv, "/") + "】"
  941. }
  942. keyword1 = "新报告产业标签:【" + v.FieldName + "】,个股标签:" + subjectStr
  943. keyword2 = "已自动关联至以下产业和标的:" + peoductName
  944. keyword3 = v.Title
  945. keyword4 = v.PublishDate.Format(utils.FormatDateTime)
  946. SendWxMsgWithArticleClassToAdmin(keyword1, keyword2, keyword3, keyword4, openIdList, articleIdInt)
  947. } else {
  948. keyword1 = "新报告产业标签:【" + v.FieldName + "】,个股标签:" + subjectStr
  949. keyword2 = "未归类"
  950. keyword3 = v.Title
  951. keyword4 = v.PublishDate.Format(utils.FormatDateTime)
  952. SendWxMsgWithArticleClassToAdmin(keyword1, keyword2, keyword3, keyword4, openIdList, articleIdInt)
  953. go models.UpdateIsClassFail(artcleId)
  954. }
  955. }
  956. }
  957. }
  958. }
  959. //类型ID 医药(医享会:28 、药调研:301)、消费【渠道新声:32】、科技【科技前言:79】、智造【匠心智造:84】或者是纪要做消息模板推送
  960. fmt.Println(v.CategoryId)
  961. //if v.IsSummary == 1 || (v.CategoryId == 28 || v.CategoryId == 301 || v.CategoryId == 32 || v.CategoryId == 79 || v.CategoryId == 84) {
  962. // sliceSubjects := strings.Split(v.Stock, "/")
  963. // fmt.Println(sliceSubjects)
  964. // if len(sliceSubjects) > 0 {
  965. // var subjectStr string
  966. // for _, vSubject := range sliceSubjects {
  967. // sliceKuohao := strings.Split(vSubject, "(") //过滤括号
  968. // sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
  969. // subject := sliceXiahuaxian[0]
  970. // subjectStr += "'" + subject + "',"
  971. // }
  972. // if subjectStr != "" {
  973. // subjectStr = strings.TrimRight(subjectStr, ",")
  974. // activityIdList, err := models.GetActivityIdListBySubjecName(subjectStr)
  975. // if err != nil {
  976. // fmt.Println("GetActivityIdListBySubjecName Err:", err.Error())
  977. // return err
  978. // }
  979. // if len(activityIdList) > 0 {
  980. // var activityIdStr string
  981. // for _, vAct := range activityIdList {
  982. // activityIdStr += strconv.Itoa(vAct.ActivityId) + ","
  983. // }
  984. // activityIdStr = strings.TrimRight(activityIdStr, ",")
  985. // if activityIdStr != "" {
  986. // appointmentList, err := models.GetAppointmentListByActivityId(activityIdStr, "1,2,5")
  987. // if err != nil {
  988. // fmt.Println("GetAppointmentListByActivityId Err:", err.Error())
  989. // return err
  990. // }
  991. // if len(appointmentList) > 0 {
  992. // for _, vApp := range appointmentList {
  993. //
  994. // appointmentByMobileList, err := models.GetAppointmentListByActivityIdAndMobile(activityIdStr, vApp.Mobile)
  995. // if err != nil {
  996. // fmt.Println("GetAppointmentListByActivityId Err:", err.Error())
  997. // return err
  998. // }
  999. // var appointmentActivityName string
  1000. // if len(appointmentByMobileList) > 0 {
  1001. // for _, vAppM := range appointmentByMobileList {
  1002. // appointmentActivityName += vAppM.ActivityName + ","
  1003. // }
  1004. // }
  1005. // appointmentActivityName = strings.TrimRight(appointmentActivityName, ",")
  1006. // if vApp.ActivityTypeId == 5 && v.CategoryId != 301 {
  1007. // continue
  1008. // }
  1009. //
  1010. // if vApp.Mobile != "" {
  1011. // openIdListByAppointment, err := models.GetUserRecordListByMobile(4, vApp.Mobile)
  1012. // if err != nil {
  1013. // fmt.Println(err)
  1014. // return err
  1015. // }
  1016. // keyword1 := "您预约的调研,有关联的纪要发布/更新了"
  1017. // keyword2 := appointmentActivityName
  1018. // keyword3 := v.Title
  1019. // keyword4 := v.PublishDate.Format(utils.FormatDateTime)
  1020. // SendWxMsgWithArticleClassToAdmin(keyword1, keyword2, keyword3, keyword4, openIdListByAppointment, artcleId)
  1021. // }
  1022. // }
  1023. // }
  1024. // }
  1025. // }
  1026. // }
  1027. // }
  1028. //}
  1029. //
  1030. ////【公司调研】系列纪要发布/更新后
  1031. //if v.CategoryId == 45 || v.CategoryId == 74 || v.CategoryId == 86 || v.CategoryId == 88 {
  1032. // fmt.Println("处理预约纪要")
  1033. // sliceSubjects := strings.Split(v.Stock, "/")
  1034. // if len(sliceSubjects) > 0 {
  1035. // var subjectStr string
  1036. // for _, vSubject := range sliceSubjects {
  1037. // sliceKuohao := strings.Split(vSubject, "(") //过滤括号
  1038. // sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
  1039. // subject := sliceXiahuaxian[0]
  1040. // subjectStr += "'" + subject + "',"
  1041. // }
  1042. // if subjectStr != "" {
  1043. // subjectStr = strings.TrimRight(subjectStr, ",")
  1044. // activityIdList, err := models.GetActivityIdListBySubjecName(subjectStr)
  1045. // if err != nil {
  1046. // fmt.Println("GetActivityIdListBySubjecName Err:", err.Error())
  1047. // return err
  1048. // }
  1049. // if len(activityIdList) > 0 {
  1050. // var activityIdStr string
  1051. // for _, vAct := range activityIdList {
  1052. // activityIdStr += strconv.Itoa(vAct.ActivityId) + ","
  1053. // }
  1054. // activityIdStr = strings.TrimRight(activityIdStr, ",")
  1055. // if activityIdStr != "" {
  1056. // appointmentList, err := models.GetAppointmentListByActivityId(activityIdStr, "3,4")
  1057. // if err != nil {
  1058. // fmt.Println("GetAppointmentListByActivityId Err:", err.Error())
  1059. // return err
  1060. // }
  1061. // if len(appointmentList) > 0 {
  1062. // for _, vApp := range appointmentList {
  1063. // appointmentByMobileList, err := models.GetAppointmentListByActivityIdAndMobile(activityIdStr, vApp.Mobile)
  1064. // if err != nil {
  1065. // fmt.Println("GetAppointmentListByActivityId Err:", err.Error())
  1066. // return err
  1067. // }
  1068. // var appointmentActivityName string
  1069. // if len(appointmentByMobileList) > 0 {
  1070. // for _, vAppM := range appointmentByMobileList {
  1071. // appointmentActivityName += vAppM.ActivityName + ","
  1072. // }
  1073. // }
  1074. // appointmentActivityName = strings.TrimRight(appointmentActivityName, ",")
  1075. // if vApp.Mobile != "" {
  1076. // openIdListByAppointment, err := models.GetUserRecordListByMobile(4, vApp.Mobile)
  1077. // if err != nil {
  1078. // fmt.Println(err)
  1079. // return err
  1080. // }
  1081. // keyword1 := "您预约的调研,有关联的纪要发布/更新了"
  1082. // keyword2 := appointmentActivityName
  1083. // keyword3 := v.Title
  1084. // keyword4 := v.PublishDate.Format(utils.FormatDateTime)
  1085. // SendWxMsgWithArticleClassToAdmin(keyword1, keyword2, keyword3, keyword4, openIdListByAppointment, artcleId)
  1086. //
  1087. // }
  1088. // }
  1089. // }
  1090. // }
  1091. // }
  1092. // }
  1093. // }
  1094. //}
  1095. //【公司调研】系列纪要发布/更新后 end
  1096. //查研观向6.9模板消息推送规则
  1097. go DoArticleOnenIdWxTemplateMsg(v.ArticleId)
  1098. }
  1099. go models.UpdateCygxArticleCeluePush(artcleId)
  1100. return err
  1101. }
  1102. //func init() {
  1103. // DoArticleOnenIdWxTemplateMsg(6940)
  1104. //}
  1105. //过滤策略平台报告,研选报告重复推送,以及权限勾选的推送
  1106. func DoArticleOnenIdWxTemplateMsg(articleId int) (err error) {
  1107. //策略平台同步过来的文章ID,做微信模板消息推送,同一篇报告12小时只推送一次
  1108. cacheKey := fmt.Sprint(utils.CACHE_KEY_ARTICLE_ID_TEMPLATE, ":ArticleId", articleId)
  1109. ttlTime := utils.Rc.GetRedisTTL(cacheKey)
  1110. if ttlTime > 0 {
  1111. return err
  1112. }
  1113. var msg string
  1114. defer func() {
  1115. if err != nil {
  1116. go utils.SendAlarmMsg("处理同步策略平台数据失败"+"GetArticleListByApi ErrMsg:"+err.Error(), 2)
  1117. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetArticleListByApi ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  1118. fmt.Println(err)
  1119. }
  1120. if msg != "" {
  1121. utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
  1122. }
  1123. }()
  1124. //获取文章详情
  1125. articleInfo, err := models.GetArticleDetailById(articleId)
  1126. if err != nil {
  1127. return
  1128. }
  1129. articleInfo.Abstract, _ = GetReportContentTextSub(articleInfo.Abstract)
  1130. var chartPermissionId int
  1131. var chartPermissionName string
  1132. reportMapDetail, err := models.GetdetailByCategoryIdPush(articleInfo.CategoryId)
  1133. if err != nil {
  1134. return err
  1135. }
  1136. if reportMapDetail.ChartPermissionId == utils.CE_LUE_ID {
  1137. chartPermissionId = utils.CE_LUE_ID
  1138. } else {
  1139. if reportMapDetail.PermissionType == 1 {
  1140. chartPermissionName = reportMapDetail.ChartPermissionName + "(主观)"
  1141. } else {
  1142. chartPermissionName = reportMapDetail.ChartPermissionName + "(客观)"
  1143. }
  1144. chartPermissionDetail, err := models.GetChartPermissionByRemark(chartPermissionName)
  1145. if err != nil {
  1146. return err
  1147. }
  1148. chartPermissionId = chartPermissionDetail.ChartPermissionId
  1149. }
  1150. //文章关联的产业
  1151. var industryName string
  1152. var industrialManagementId string
  1153. if chartPermissionId == utils.CE_LUE_ID {
  1154. industryName = reportMapDetail.SubCategoryName
  1155. } else {
  1156. detailIndustryNameList, err := models.GetIndustrialManagemenDetailByAaticleID(articleId)
  1157. if err != nil && err.Error() != utils.ErrNoRow() {
  1158. return err
  1159. }
  1160. //如果不存在关联的产业则不推送
  1161. if len(detailIndustryNameList) == 0 {
  1162. return err
  1163. }
  1164. for _, v := range detailIndustryNameList {
  1165. industryName += v.IndustryName + ","
  1166. industrialManagementId += strconv.Itoa(v.IndustrialManagementId) + ","
  1167. }
  1168. industryName = strings.TrimRight(industryName, ",")
  1169. industrialManagementId = strings.TrimRight(industrialManagementId, ",")
  1170. //处理勾选了全部行业赛道的用户
  1171. var allIn string
  1172. allIn = DoXzsChooseSend(reportMapDetail.ChartPermissionName)
  1173. if allIn != "" {
  1174. allInList, err := models.GetCygxXzsChooseSendByAllIn(allIn)
  1175. if err != nil && err.Error() != utils.ErrNoRow() {
  1176. return err
  1177. }
  1178. if len(allInList) > 0 {
  1179. var allInUserId string
  1180. for _, v := range allInList {
  1181. allInUserId += strconv.Itoa(v.UserId) + ","
  1182. }
  1183. allInUserId = strings.TrimRight(allInUserId, ",")
  1184. userFllowIndustrialList, err := models.GetUserFllowIndustrialListByUserIdAndIndustrial(allInUserId, industrialManagementId)
  1185. if err != nil && err.Error() != utils.ErrNoRow() {
  1186. return err
  1187. }
  1188. mapUserFllowed := make(map[string]int)
  1189. for _, v := range userFllowIndustrialList {
  1190. //用户ID与其关注的产业组成唯一索引,判断是否存在,如果不存在就进行自动关注
  1191. mapUserFllowed[fmt.Sprint("uid:", v.UserId, "_Industrial:", v.IndustrialManagementId)] = v.UserId
  1192. }
  1193. //获取这些allIN用户的的信息进行遍历生成需要插入的数据
  1194. userList, err := models.GetWxUserListByUserIds(allInUserId)
  1195. if err != nil && err.Error() != utils.ErrNoRow() {
  1196. return err
  1197. }
  1198. var industryFllowItems []*models.CygxIndustryFllow
  1199. for _, v := range detailIndustryNameList {
  1200. for _, vUser := range userList {
  1201. //如果用户这个用户没有关注这个产业就进行自动关注
  1202. if mapUserFllowed[fmt.Sprint("uid:", vUser.UserId, "_Industrial:", v.IndustrialManagementId)] == 0 {
  1203. item := new(models.CygxIndustryFllow)
  1204. item.IndustrialManagementId = v.IndustrialManagementId
  1205. item.UserId = vUser.UserId
  1206. item.Email = vUser.Email
  1207. item.Mobile = vUser.Mobile
  1208. item.RealName = vUser.RealName
  1209. item.CompanyId = vUser.CompanyId
  1210. item.CompanyName = vUser.CompanyName
  1211. item.Source = 3
  1212. item.Type = 1
  1213. item.CreateTime = time.Now()
  1214. item.ModifyTime = time.Now()
  1215. industryFllowItems = append(industryFllowItems, item)
  1216. }
  1217. }
  1218. }
  1219. err = models.AddCygxIndustryFllowMulti(industryFllowItems)
  1220. if err != nil {
  1221. go utils.SendAlarmMsg("用户关注全部赛道,出现新赛道批量添加失败 ,AddCygxIndustryFllowMulti ErrMsg:"+err.Error(), 2)
  1222. }
  1223. }
  1224. }
  1225. }
  1226. // 获取所有有权的用户的 openid
  1227. mapOpenidPower := make(map[int]string)
  1228. permissionIdList := make([]string, 0)
  1229. var condition string
  1230. var pars []interface{}
  1231. slicepermissionId := strings.Split(strconv.Itoa(chartPermissionId), ",")
  1232. if len(slicepermissionId) > 0 {
  1233. for _, v := range slicepermissionId {
  1234. permissionIdList = append(permissionIdList, v)
  1235. }
  1236. condition += ` AND p.chart_permission_id IN (` + utils.GetOrmInReplace(len(slicepermissionId)) + ` ) `
  1237. pars = append(pars, permissionIdList)
  1238. }
  1239. openidPowerList, err := models.GetCygxUserRecordPower(condition, pars)
  1240. if err != nil {
  1241. return err
  1242. }
  1243. for _, v := range openidPowerList {
  1244. mapOpenidPower[v.UserId] = v.OpenId
  1245. }
  1246. //获取关注这个文章对应产业的用户的 openid
  1247. mapOpenidFllow := make(map[int]string)
  1248. if chartPermissionId != utils.CE_LUE_ID {
  1249. openidFllowList, err := models.GetCygxUserFllowOpenid(articleId)
  1250. if err != nil {
  1251. return err
  1252. }
  1253. for _, v := range openidFllowList {
  1254. mapOpenidFllow[v.UserId] = v.OpenId
  1255. }
  1256. }
  1257. //获取拒绝接收推送的的用户的 openid
  1258. mapOpenidRefuset := make(map[int]string)
  1259. openidRefusetList, err := models.GetCygxUserRefusetOpenid()
  1260. if err != nil {
  1261. return err
  1262. }
  1263. for _, v := range openidRefusetList {
  1264. mapOpenidRefuset[v.UserId] = v.OpenId
  1265. }
  1266. //获取提交过推送规则的用户的 openid
  1267. mapUserIdChooseSend := make(map[int]int)
  1268. mapUserIdChooseSendTypeNoPermission := make(map[int]int)
  1269. chooseSendtList, err := models.GetCygxXzsChooseSend()
  1270. for _, v := range chooseSendtList {
  1271. mapUserIdChooseSend[v.UserId] = v.UserId
  1272. if v.IsRefuse == 1 {
  1273. continue
  1274. }
  1275. //获取选择主客观赛道的用户
  1276. if reportMapDetail.PermissionType == 1 {
  1277. if v.IsSubjective == 1 {
  1278. mapUserIdChooseSendTypeNoPermission[v.UserId] = v.UserId
  1279. }
  1280. } else {
  1281. if v.IsObjective == 1 {
  1282. mapUserIdChooseSendTypeNoPermission[v.UserId] = v.UserId
  1283. }
  1284. }
  1285. }
  1286. //已经推送了的openid
  1287. mapOpenidPushed := make(map[int]string)
  1288. keyword2 := articleInfo.Title
  1289. keyword3 := time.Now().Format(utils.FormatDateTime)
  1290. keyword4 := articleInfo.Abstract
  1291. mapAlreadySend := make(map[int]int)
  1292. //如果是策略就按照策略的推送方式来写
  1293. if reportMapDetail.ChartPermissionName == utils.CE_LUE_NAME {
  1294. //获取提交过推送规则的用户的 openid
  1295. mapUserFllowCeLue := make(map[int]string)
  1296. userFllowCeLueList, err := models.GetCygxUserFllowCeLueOpenid(articleInfo.CategoryId)
  1297. if err != nil {
  1298. return err
  1299. }
  1300. for _, v := range userFllowCeLueList {
  1301. mapUserFllowCeLue[v.UserId] = v.OpenId
  1302. }
  1303. for k, v := range mapOpenidPower {
  1304. if mapOpenidPushed[k] != "" {
  1305. continue
  1306. }
  1307. openIditem := new(models.OpenIdList)
  1308. openIditem.UserId = k
  1309. openIditem.OpenId = v
  1310. first := "您关注的赛道,有新的报告发布/更新,欢迎查看"
  1311. keyword1 := "所属赛道:" + industryName
  1312. mapActivityUserId := make(map[int]string)
  1313. if articleInfo.IsSummary == 1 {
  1314. sliceSubjectId, _ := models.GetSubjectIds(articleId)
  1315. if sliceSubjectId != "" {
  1316. appointmentList, err := models.GetCygxAppointmentSummaryBySubjectId(sliceSubjectId)
  1317. if err != nil {
  1318. fmt.Println("GetCygxAppointmentSummaryListBySubjectId Err:", err.Error())
  1319. return err
  1320. }
  1321. var userIds []string
  1322. if len(appointmentList) > 0 {
  1323. for _, v := range appointmentList {
  1324. //fmt.Println("mapActivityUserId:", v.UserId)
  1325. userIds = append(userIds, strconv.Itoa(v.UserId))
  1326. mapActivityUserId[v.UserId] += v.ActivityName + ","
  1327. }
  1328. userIdstr := strings.Join(userIds, ",")
  1329. openIdLists, err := models.GetOpenIdByUserIds(userIdstr)
  1330. if err != nil {
  1331. fmt.Println("GetOpenIdByUserIds Err:", err.Error())
  1332. return err
  1333. }
  1334. for _, item := range openIdLists {
  1335. first := "您预约的调研,有关联的纪要发布/更新了"
  1336. keyword1 := industryName
  1337. openIditem := new(models.OpenIdList)
  1338. openIditem.OpenId = item.OpenId
  1339. openIditem.UserId = item.UserId
  1340. if _, ok := mapAlreadySend[openIditem.UserId]; !ok {
  1341. SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1342. delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1343. fmt.Println("AlreadySend:", openIditem.UserId)
  1344. mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1345. }
  1346. }
  1347. }
  1348. }
  1349. //fmt.Println("openIditem.UserId:", openIditem.UserId)
  1350. //if _,ok := mapActivityUserId[openIditem.UserId]; ok{
  1351. // first = "您预约的调研,有关联的纪要发布/更新了"
  1352. // keyword1 = industryName
  1353. // SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1354. // delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1355. // mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1356. //}
  1357. }
  1358. _, ok := mapAlreadySend[openIditem.UserId]
  1359. //如果有权限而且小助手没有提交过信息的 就做正常推送
  1360. if mapUserIdChooseSend[openIditem.UserId] == 0 && !ok {
  1361. fmt.Println("1:", articleId)
  1362. SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1363. }
  1364. //如果小助手勾选了对应的权限信息 就做正常推送
  1365. if mapUserIdChooseSend[openIditem.UserId] != 0 && mapUserFllowCeLue[openIditem.UserId] != "" && !ok {
  1366. fmt.Println("2:", articleId)
  1367. SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1368. }
  1369. }
  1370. } else {
  1371. for k, v := range mapOpenidPower {
  1372. if mapOpenidPushed[k] != "" {
  1373. continue
  1374. }
  1375. chooseSendtList, err := models.GetCygxXzsChooseSend()
  1376. if err != nil {
  1377. return err
  1378. }
  1379. mapUserIdChooseSendType := make(map[int]int)
  1380. for _, v := range chooseSendtList {
  1381. if v.IsRefuse == 1 {
  1382. continue
  1383. }
  1384. //获取选择主客观赛道的用户
  1385. if reportMapDetail.PermissionType == 1 {
  1386. if v.IsSubjective == 1 {
  1387. mapUserIdChooseSendType[v.UserId] = v.UserId
  1388. }
  1389. } else if reportMapDetail.PermissionType == 2 {
  1390. if v.IsObjective == 1 {
  1391. mapUserIdChooseSendType[v.UserId] = v.UserId
  1392. }
  1393. } else {
  1394. if v.IsSubjective == 1 || v.IsObjective == 1 {
  1395. mapUserIdChooseSendType[v.UserId] = v.UserId
  1396. }
  1397. }
  1398. }
  1399. openIditem := new(models.OpenIdList)
  1400. openIditem.UserId = k
  1401. openIditem.OpenId = v
  1402. first := "您关注的赛道,有新的报告发布/更新,欢迎查看"
  1403. keyword1 := "所属赛道:" + industryName
  1404. mapActivityUserId := make(map[int]string)
  1405. if articleInfo.IsSummary == 1 {
  1406. sliceSubjectId, _ := models.GetSubjectIds(articleId)
  1407. if sliceSubjectId != "" {
  1408. appointmentList, err := models.GetCygxAppointmentSummaryBySubjectId(sliceSubjectId)
  1409. if err != nil {
  1410. fmt.Println("GetCygxAppointmentSummaryListBySubjectId Err:", err.Error())
  1411. return err
  1412. }
  1413. var userIds []string
  1414. if len(appointmentList) > 0 {
  1415. for _, v := range appointmentList {
  1416. //fmt.Println("mapActivityUserId:", v.UserId)
  1417. userIds = append(userIds, strconv.Itoa(v.UserId))
  1418. mapActivityUserId[v.UserId] += v.ActivityName + ","
  1419. }
  1420. userIdstr := strings.Join(userIds, ",")
  1421. openIdLists, err := models.GetOpenIdByUserIds(userIdstr)
  1422. if err != nil {
  1423. fmt.Println("GetOpenIdByUserIds Err:", err.Error())
  1424. return err
  1425. }
  1426. for _, item := range openIdLists {
  1427. first := "您预约的调研,有关联的纪要发布/更新了"
  1428. keyword1 := industryName
  1429. openIditem := new(models.OpenIdList)
  1430. openIditem.OpenId = item.OpenId
  1431. openIditem.UserId = item.UserId
  1432. if _, ok := mapAlreadySend[openIditem.UserId]; !ok {
  1433. SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1434. delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1435. fmt.Println("AlreadySend:", openIditem.UserId)
  1436. mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1437. }
  1438. }
  1439. }
  1440. }
  1441. //fmt.Println("openIditem.UserId:", openIditem.UserId)
  1442. //if _,ok := mapActivityUserId[openIditem.UserId]; ok{
  1443. // first = "您预约的调研,有关联的纪要发布/更新了"
  1444. // keyword1 = industryName
  1445. // SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1446. // delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1447. // mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1448. //}
  1449. }
  1450. //如果有权限而且小助手没有提交过信息的 就做正常推送
  1451. _, ok := mapAlreadySend[openIditem.UserId]
  1452. if mapUserIdChooseSend[openIditem.UserId] == 0 && !ok {
  1453. SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1454. delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1455. mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1456. }
  1457. //如果小助手勾选了对应的权限信息 就做正常推送
  1458. if mapUserIdChooseSend[openIditem.UserId] != 0 && mapOpenidFllow[openIditem.UserId] != "" && mapUserIdChooseSendType[openIditem.UserId] > 0 && !ok {
  1459. SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1460. delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1461. mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1462. }
  1463. }
  1464. //获取提交过推送规则的用户的 openid 并推送模版消息
  1465. openIditem := new(models.OpenIdList)
  1466. first := "您关注的赛道,有新的报告发布/更新,欢迎查看"
  1467. keyword1 := "所属赛道:" + industryName
  1468. //mapActivityUserId := make(map[int]string)
  1469. //if articleInfo.IsSummary == 1 {
  1470. // sliceSubjectId, _ := models.GetSubjectIds(articleId)
  1471. // if sliceSubjectId != ""{
  1472. // appointmentList, err := models.GetCygxAppointmentSummaryBySubjectId(sliceSubjectId)
  1473. // if err != nil {
  1474. // fmt.Println("GetCygxAppointmentSummaryListBySubjectId Err:", err.Error())
  1475. // return err
  1476. // }
  1477. // if len(appointmentList) > 0 {
  1478. // for _, v := range appointmentList {
  1479. // fmt.Println("mapActivityUserId:", v.UserId)
  1480. // mapActivityUserId[v.UserId] += v.ActivityName + ","
  1481. // first = "您预约的调研,有关联的纪要发布/更新了"
  1482. // keyword1 = industryName
  1483. // if _, ok := mapAlreadySend[openIditem.UserId]; !ok{
  1484. // SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1485. // delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1486. // mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1487. // }
  1488. // }
  1489. // }
  1490. // }
  1491. // //fmt.Println("openIditem.UserId:", openIditem.UserId)
  1492. // //if _,ok := mapActivityUserId[openIditem.UserId]; ok{
  1493. // // first = "您预约的调研,有关联的纪要发布/更新了"
  1494. // // keyword1 = industryName
  1495. // // SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1496. // // delete(mapUserIdChooseSendTypeNoPermission, openIditem.UserId)
  1497. // // mapAlreadySend[openIditem.UserId] = openIditem.UserId
  1498. // //}
  1499. //}
  1500. var ids []string
  1501. for k, _ := range mapUserIdChooseSendTypeNoPermission {
  1502. ids = append(ids, strconv.Itoa(k))
  1503. }
  1504. if len(ids) > 0 {
  1505. idStr := strings.Join(ids, ",")
  1506. openidIlist, err := models.GetCygxXzsChooseSendOpenIdByUserIds(idStr)
  1507. if err != nil {
  1508. return err
  1509. }
  1510. for _, item := range openidIlist {
  1511. openIditem.OpenId = item.OpenId
  1512. openIditem.UserId = item.UserId
  1513. if _, ok := mapAlreadySend[openIditem.UserId]; !ok {
  1514. SendWxMsgWithArticleUpdate(first, keyword1, keyword2, keyword3, keyword4, openIditem, articleId)
  1515. }
  1516. }
  1517. }
  1518. }
  1519. utils.Rc.Put(cacheKey, articleId, time.Hour*12)
  1520. return
  1521. }