report_article.go 81 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858
  1. package cygx
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "github.com/tealeg/xlsx"
  7. "hongze/hz_crm_api/controllers"
  8. "hongze/hz_crm_api/models"
  9. "hongze/hz_crm_api/models/company"
  10. "hongze/hz_crm_api/models/cygx"
  11. "hongze/hz_crm_api/models/system"
  12. "hongze/hz_crm_api/services"
  13. cygxService "hongze/hz_crm_api/services/cygx"
  14. "hongze/hz_crm_api/utils"
  15. "html"
  16. "os"
  17. "path/filepath"
  18. "strconv"
  19. "strings"
  20. "time"
  21. )
  22. // 报告管理
  23. type ReportArticleController struct {
  24. controllers.BaseAuthController
  25. }
  26. // @Title 主题列表
  27. // @Description 获取主题列表接口
  28. // @Param ChartPermissionId query int true "分类ID"
  29. // @Success 200 {object} cygx.CygxReportMappingListRep
  30. // @router /reportMappingist/list [get]
  31. func (this *ReportArticleController) CygxReportMappingist() {
  32. br := new(models.BaseResponse).Init()
  33. defer func() {
  34. this.Data["json"] = br
  35. this.ServeJSON()
  36. }()
  37. sysUser := this.SysUser
  38. if sysUser == nil {
  39. br.Msg = "请登录"
  40. br.ErrMsg = "请登录,SysUser Is Empty"
  41. return
  42. }
  43. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  44. if chartPermissionId < 1 {
  45. br.Msg = "请输入分类ID"
  46. return
  47. }
  48. list, err := cygx.CygxReportMappingist(chartPermissionId)
  49. if err != nil {
  50. br.Msg = "获取失败"
  51. br.ErrMsg = "获取失败,Err:" + err.Error()
  52. return
  53. }
  54. resp := new(cygx.CygxReportMappingListRep)
  55. resp.List = list
  56. br.Ret = 200
  57. br.Success = true
  58. br.Msg = "获取成功"
  59. br.Data = resp
  60. }
  61. // @Title 报告匹配类型列表
  62. // @Description 获取报告匹配类型列表接口
  63. // @Success 200 {object} cygx.CygxReportMappingMatchTypeRep
  64. // @Param ChartPermissionId query int true "分类ID"
  65. // @router /reportMappingMatchTypeRep/list [get]
  66. func (this *ReportArticleController) CygxReportMappingMatchTypeList() {
  67. br := new(models.BaseResponse).Init()
  68. defer func() {
  69. this.Data["json"] = br
  70. this.ServeJSON()
  71. }()
  72. sysUser := this.SysUser
  73. if sysUser == nil {
  74. br.Msg = "请登录"
  75. br.ErrMsg = "请登录,SysUser Is Empty"
  76. return
  77. }
  78. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  79. var condition string
  80. var pars []interface{}
  81. if chartPermissionId > 0 {
  82. condition += ` AND chart_permission_id = ? `
  83. pars = append(pars, chartPermissionId)
  84. }
  85. list, err := cygx.GetCygxReportMappingCygxList(condition, pars, 0, 0)
  86. if err != nil {
  87. br.Msg = "获取失败"
  88. br.ErrMsg = "获取失败,Err:" + err.Error()
  89. return
  90. }
  91. resp := new(cygx.CygxCygxReportMappingCygxResp)
  92. resp.List = list
  93. br.Ret = 200
  94. br.Success = true
  95. br.Msg = "获取成功"
  96. br.Data = resp
  97. }
  98. // @Title 报告列表
  99. // @Description 报告列表接口
  100. // @Param PageSize query int true "每页数据条数"
  101. // @Param CurrentIndex query int true "当前页页码,从1开始"
  102. // @Param IsFilter query int true "是否过滤 ,1是,0否,不传默认为0"
  103. // @Param IsClass query int true "是否归类 ,1是,0否 ,不传默认为0"
  104. // @Param ChartPermissionId query int true "行业ID --> 一级分类列表中 ChartPermissionId"
  105. // @Param SubCategoryName query string true "主题"
  106. // @Param MatchTypeName query string true "报告匹配类型"
  107. // @Param IndustrialManagementId int string true "产业ID"
  108. // @Param StartDate query string true "开始时间用0 补齐,列如2021-03-06 08:09:01"
  109. // @Param EndDate query string true "结束时间用0 补齐,列如2021-03-06 08:09:01"
  110. // @Param KeyWord query string true "搜索关键词"
  111. // @Param KeyWordStock query string true "搜索关键词.个股标签,关联标的部分"
  112. // @Success 200 {object} cygx.GetReportArticleListRep
  113. // @router /reportArticle/list [get]
  114. func (this *ReportArticleController) ReportArticleList() {
  115. br := new(models.BaseResponse).Init()
  116. defer func() {
  117. this.Data["json"] = br
  118. this.ServeJSON()
  119. }()
  120. sysUser := this.SysUser
  121. if sysUser == nil {
  122. br.Msg = "请登录"
  123. br.ErrMsg = "请登录,SysUser Is Empty"
  124. return
  125. }
  126. pageSize, _ := this.GetInt("PageSize")
  127. currentIndex, _ := this.GetInt("CurrentIndex")
  128. isFilter, _ := this.GetInt("IsFilter")
  129. isClass, _ := this.GetInt("IsClass")
  130. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  131. subCategoryName := this.GetString("SubCategoryName")
  132. matchTypeName := this.GetString("MatchTypeName")
  133. industrialManagementId, _ := this.GetInt("IndustrialManagementId")
  134. startDate := this.GetString("StartDate")
  135. endDate := this.GetString("EndDate")
  136. keyWord := this.GetString("KeyWord")
  137. keyWordStock := this.GetString("KeyWordStock")
  138. reportLabel := this.GetString("ReportLabel") // 查研观向7.4-报告标签
  139. var startSize int
  140. if pageSize <= 0 {
  141. pageSize = utils.PageSize20
  142. }
  143. if currentIndex <= 0 {
  144. currentIndex = 1
  145. }
  146. startSize = utils.StartIndex(currentIndex, pageSize)
  147. var condition string
  148. var pars []interface{}
  149. listPermission, errper := cygx.GetPermissionMappingCategoryID()
  150. if errper != nil {
  151. br.Msg = "获取失败"
  152. br.ErrMsg = "获取失败,Err:" + errper.Error()
  153. return
  154. }
  155. condition += ` AND art.is_report = 1 AND re.id !=28 `
  156. if isClass == 0 {
  157. condition += ` AND art.is_class = 0 `
  158. } else {
  159. condition += ` AND art.is_class = 1 `
  160. if industrialManagementId > 0 {
  161. condition += ` AND man.industrial_management_id = ` + strconv.Itoa(industrialManagementId)
  162. }
  163. }
  164. if keyWord != "" {
  165. condition += ` AND (art.title LIKE '%` + keyWord + `%' ) `
  166. }
  167. //个股标签跟标的的搜索
  168. if keyWordStock != "" {
  169. condition += ` AND (art.stock LIKE '%` + keyWordStock + `%' OR art.article_id IN (SELECT article_id FROM cygx_industrial_article_group_subject WHERE industrial_subject_id IN (SELECT industrial_subject_id FROM cygx_industrial_subject WHERE subject_name LIKE '%` + keyWordStock + `%')) ) `
  170. }
  171. if isFilter == 0 {
  172. condition += ` AND art.is_filter = 0 `
  173. } else {
  174. condition += ` AND art.is_filter = 1 `
  175. }
  176. //行业
  177. if chartPermissionId > 0 {
  178. condition += ` AND re.chart_permission_id = ` + strconv.Itoa(chartPermissionId)
  179. }
  180. //主题
  181. if subCategoryName != "" {
  182. condition += ` AND art.sub_category_name = ` + "'" + subCategoryName + "' "
  183. }
  184. //发布时间
  185. if startDate != "" {
  186. condition += ` AND art.publish_date >= ` + "'" + startDate + " 00:00:00'"
  187. }
  188. if endDate != "" {
  189. condition += ` AND art.publish_date <= ` + "'" + endDate + " 23:59:59'"
  190. }
  191. //报告匹配类型
  192. if matchTypeName != "" && chartPermissionId > 0 {
  193. //condition += ` AND re.match_type_name = ` + "'" + matchTypeName + "' "
  194. //mappingCygxDetai, err := cygx.GetCygxReportMappingCygxDetailByNameAndChartPermissionId(matchTypeName, chartPermissionId)
  195. //if err != nil && err.Error() != utils.ErrNoRow() {
  196. // br.Msg = "获取失败"
  197. // br.ErrMsg = "获取失败,Err:" + err.Error()
  198. // return
  199. //}
  200. //if mappingCygxDetai == nil {
  201. // resp := new(cygx.GetReportArticleListRep)
  202. // resp.List = make([]*cygx.CygxReportArticle, 0)
  203. // page := paging.GetPaging(currentIndex, pageSize, 0)
  204. // resp.Paging = page
  205. // br.Ret = 200
  206. // br.Success = true
  207. // br.Msg = "获取成功"
  208. // br.Data = resp
  209. // return
  210. //}
  211. //这里量不大,走一下子查询
  212. //condition += ` AND art.category_id IN ( SELECT category_id_celue FROM cygx_report_mapping_group WHERE id_cygx = ` + strconv.Itoa(mappingCygxDetai.Id) + ` ) `
  213. condition += ` AND art.category_id IN ( SELECT category_id FROM cygx_report_mapping WHERE match_type_name = ` + "'" + matchTypeName + "'" + ` ) `
  214. }
  215. // 报告标签
  216. if reportLabel != "" {
  217. keywords := "%" + reportLabel + "%"
  218. // 查询包含关键词的产业/标的所关联的报告IDs
  219. artIds, e := cygx.GetArticleIdsFromIndustryAndSubjectGroupByKeyword(keywords)
  220. if e != nil {
  221. br.Msg = "获取失败"
  222. br.ErrMsg = "产业/标的关键词获取文章IDs失败, Err:" + e.Error()
  223. return
  224. }
  225. if len(artIds) > 0 {
  226. condition += ` AND art.article_id IN (` + utils.GetOrmInReplace(len(artIds)) + `)`
  227. pars = append(pars, artIds)
  228. }
  229. }
  230. total, err := cygx.GetReportArticleCount(condition, pars)
  231. if err != nil {
  232. br.Msg = "获取失败"
  233. br.ErrMsg = "获取失败,Err:" + err.Error()
  234. return
  235. }
  236. condition += ` GROUP BY art.article_id ORDER BY art.publish_date DESC `
  237. //fmt.Println(condition)
  238. list, err := cygx.GetReportArticleList(condition, pars, startSize, pageSize, isClass)
  239. if err != nil {
  240. br.Msg = "获取失败"
  241. br.ErrMsg = "获取失败,Err:" + err.Error()
  242. return
  243. }
  244. reportMap := make(map[int]string)
  245. listMap, err := cygx.GetReportMapping()
  246. if err != nil {
  247. br.Msg = "获取失败"
  248. br.ErrMsg = "获取映射分类失败,Err:" + err.Error()
  249. return
  250. }
  251. for _, v := range listMap {
  252. reportMap[v.CategoryId] = v.MatchTypeName
  253. }
  254. var articleIds string
  255. for k, v := range list {
  256. var isShowButton bool
  257. if sysUser.RoleTypeCode == "rai_admin" || sysUser.RoleTypeCode == "rai_researcher" || sysUser.RoleTypeCode == "admin" {
  258. isShowButton = true
  259. } else {
  260. isShowButton = false
  261. }
  262. list[k].MatchTypeName = reportMap[v.CategoryId]
  263. list[k].ShowButton = true
  264. for _, vper := range listPermission {
  265. if v.CategoryId == vper.CategoryId {
  266. isShowButton = false
  267. }
  268. list[k].ShowButton = isShowButton
  269. }
  270. articleIds += strconv.Itoa(v.ArticleId) + ","
  271. }
  272. mapCommment := make(map[int]int)
  273. if articleIds != "" {
  274. articleIds = strings.TrimRight(articleIds, ",")
  275. condition = ` AND art.article_id IN (` + articleIds + `)`
  276. listPv, err := cygx.GetReportArticleListPvUv(condition)
  277. if err != nil {
  278. br.Msg = "获取失败"
  279. br.ErrMsg = "获取PV,Uv 失败,Err:" + err.Error()
  280. return
  281. }
  282. var condition string
  283. var pars []interface{}
  284. condition = ` AND k.article_id IN (` + articleIds + `)`
  285. listComment, err := cygx.GetArticleCommentListSearch(condition, pars)
  286. if err != nil {
  287. br.Msg = "获取失败"
  288. br.ErrMsg = "获取失败,Err:" + err.Error()
  289. return
  290. }
  291. for _, v := range listComment {
  292. mapCommment[v.ArticleId]++
  293. }
  294. if len(listPv) > 0 {
  295. for _, pv := range listPv {
  296. for k, v := range list {
  297. if v.ArticleId == pv.ArticleId {
  298. list[k].Pv = pv.Pv
  299. list[k].Uv = pv.Uv
  300. list[k].ClPv = pv.ClPv
  301. list[k].ClUv = pv.ClUv
  302. list[k].CollectionNum = pv.CollectionNum
  303. }
  304. }
  305. }
  306. }
  307. }
  308. //ListIndustrial []*IndustrialActivityGroupManagementRep
  309. //ListSubject []*SubjectActivityGroupManagementRep
  310. mapIndustrial := make(map[int]string)
  311. mapSubject := make(map[string]string)
  312. mapIndustrialList := make(map[int][]*cygx.IndustrialActivityGroupManagementRep)
  313. mapSubjectList := make(map[int][]*cygx.SubjectActivityGroupManagementRep)
  314. if articleIds != "" {
  315. industrialList, err := cygx.GetIndustrialArticleGroupListByarticleIds(articleIds)
  316. if err != nil {
  317. br.Msg = "获取失败"
  318. br.ErrMsg = "获取失败,GetIndustrialArticleGroupListByarticleIds Err:" + err.Error()
  319. return
  320. }
  321. subjectList, err := cygx.GetSubjectArticleGroupListByarticleIds(articleIds)
  322. if err != nil {
  323. br.Msg = "获取失败"
  324. br.ErrMsg = "获取失败,GetSubjectArticleGroupListByarticleIds Err:" + err.Error()
  325. return
  326. }
  327. //合并活动对应的多个标的
  328. for _, v := range subjectList {
  329. mapSubject[fmt.Sprint(v.ArticleId, "_", v.IndustrialManagementId)] += v.SubjectName + "/"
  330. itemSubject := new(cygx.SubjectActivityGroupManagementRep)
  331. itemSubject.SubjectName = v.SubjectName
  332. itemSubject.IndustrialSubjectId = v.IndustrialSubjectId
  333. mapSubjectList[v.ArticleId] = append(mapSubjectList[v.ArticleId], itemSubject)
  334. }
  335. //活动对应的产业
  336. for _, v := range industrialList {
  337. var labelSubject string
  338. labelSubject = mapSubject[fmt.Sprint(v.ArticleId, "_", v.IndustrialManagementId)]
  339. if labelSubject != "" {
  340. mapIndustrial[v.ArticleId] += v.IndustryName + "--" + strings.TrimRight(labelSubject, "/") + ","
  341. } else {
  342. mapIndustrial[v.ArticleId] += v.IndustryName + ","
  343. }
  344. itemindustrial := new(cygx.IndustrialActivityGroupManagementRep)
  345. itemindustrial.IndustryName = v.IndustryName
  346. itemindustrial.IndustrialManagementId = v.IndustrialManagementId
  347. mapIndustrialList[v.ArticleId] = append(mapIndustrialList[v.ArticleId], itemindustrial)
  348. }
  349. }
  350. for k, v := range list {
  351. if mapIndustrial[v.ArticleId] != "" {
  352. list[k].Label = strings.TrimRight(mapIndustrial[v.ArticleId], ",")
  353. }
  354. if v.SubCategoryName == "专项调研" {
  355. v.PublishDate = cygxService.ArticlePublishDate(v.PublishDate)
  356. }
  357. list[k].CommentNum = mapCommment[v.ArticleId]
  358. list[k].ListIndustrial = mapIndustrialList[v.ArticleId]
  359. list[k].ListSubject = mapSubjectList[v.ArticleId]
  360. }
  361. page := paging.GetPaging(currentIndex, pageSize, total)
  362. resp := new(cygx.GetReportArticleListRep)
  363. resp.List = list
  364. resp.Paging = page
  365. br.Ret = 200
  366. br.Success = true
  367. br.Msg = "获取成功"
  368. br.Data = resp
  369. }
  370. // @Title 过滤报告
  371. // @Description 过滤报告接口
  372. // @Param ReportId query int true "报告ID"
  373. // @Success Ret=200
  374. // @router /reportArticle/filter [post]
  375. func (this *IndustrialSubjectController) ReportArticleFilter() {
  376. br := new(models.BaseResponse).Init()
  377. defer func() {
  378. this.Data["json"] = br
  379. this.ServeJSON()
  380. }()
  381. sysUser := this.SysUser
  382. if sysUser == nil {
  383. br.Msg = "请登录"
  384. br.ErrMsg = "请登录,SysUser Is Empty"
  385. br.Ret = 408
  386. return
  387. }
  388. //if sysUser.RoleTypeCode != "rai_admin" && sysUser.RoleTypeCode != "rai_researcher" && sysUser.RoleTypeCode != "admin" {
  389. // br.Msg = "你没有操作权限请联系管理员"
  390. // return
  391. //}
  392. var req cygx.CygxReportArticleID
  393. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  394. if err != nil {
  395. br.Msg = "参数解析异常!"
  396. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  397. return
  398. }
  399. reportId := req.ReportId
  400. reportInfo, err := cygx.GetReportArticleId(reportId)
  401. if reportInfo == nil {
  402. br.Msg = "报告ID不存在!"
  403. return
  404. }
  405. if err != nil {
  406. br.Msg = "过滤失败!"
  407. br.ErrMsg = "过滤失败,Err:" + err.Error()
  408. return
  409. }
  410. if reportInfo.IsFilter == 1 {
  411. br.Msg = "您已过滤请勿重复操作!"
  412. return
  413. }
  414. if reportInfo.ReportType != 2 {
  415. br.Msg = "操作失败!"
  416. br.ErrMsg = "报告类型不属于产业报告!"
  417. return
  418. }
  419. err = cygx.FilterReportArticle(reportId)
  420. if err != nil {
  421. br.Msg = "过滤失败"
  422. br.ErrMsg = "过滤失败,Err:" + err.Error()
  423. return
  424. }
  425. br.Ret = 200
  426. br.Success = true
  427. br.Msg = "过滤成功"
  428. br.IsAddLog = true
  429. }
  430. // @Title 报告归类
  431. // @Description 报告归类接口
  432. // @Param request body cygx.ReportArticleClassificationResp true "type json string"
  433. // @Success Ret=200
  434. // @router /reportArticle/classification [post]
  435. func (this *IndustrialSubjectController) ReportArticleClassification() {
  436. br := new(models.BaseResponse).Init()
  437. defer func() {
  438. this.Data["json"] = br
  439. this.ServeJSON()
  440. }()
  441. sysUser := this.SysUser
  442. if sysUser == nil {
  443. br.Msg = "请登录"
  444. br.ErrMsg = "请登录,SysUser Is Empty"
  445. br.Ret = 408
  446. return
  447. }
  448. //if sysUser.RoleTypeCode != "rai_admin" && sysUser.RoleTypeCode != "rai_researcher" && sysUser.RoleTypeCode != "admin" {
  449. // br.Msg = "你没有操作权限请联系管理员"
  450. // return
  451. //}
  452. var req cygx.ReportArticleClassificationResp
  453. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  454. if err != nil {
  455. br.Msg = "参数解析异常!"
  456. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  457. return
  458. }
  459. var pars []interface{}
  460. var condition string
  461. reportId := req.ReportId
  462. industrialManagementIdStr := req.IndustrialManagementId
  463. reportInfo, _ := cygx.GetReportArticleId(reportId)
  464. if reportInfo == nil {
  465. br.Msg = "报告ID不存在!"
  466. return
  467. }
  468. if reportInfo.ReportType != 2 {
  469. br.Msg = "操作失败!"
  470. br.ErrMsg = "报告类型不属于产业报告!"
  471. return
  472. }
  473. industrialStrList := strings.Split(industrialManagementIdStr, ",")
  474. for _, v := range industrialStrList {
  475. condition = `AND industrial_management_id = ` + v
  476. totalIndustrialManagement, _ := cygx.GetIndustrialManagementCount(condition, pars)
  477. if totalIndustrialManagement < 1 {
  478. br.Msg = "操作失败"
  479. br.ErrMsg = "操作失败,产业不存在IndustrialManagementId:" + v
  480. return
  481. }
  482. }
  483. if req.IndustrialSubjectIdStr != "0" && req.IndustrialSubjectIdStr != "" {
  484. strList := strings.Split(req.IndustrialSubjectIdStr, ",")
  485. for _, v := range strList {
  486. condition = `AND industrial_subject_id = ` + v + ` AND industrial_management_id IN ( ` + industrialManagementIdStr + `)`
  487. totalIndustrialSubject, _ := cygx.GetIndustrialSubjectCount(condition, pars)
  488. if totalIndustrialSubject < 1 {
  489. br.Msg = "操作失败"
  490. br.ErrMsg = "操作失败,标的不存在IndustrialSubjectId:" + v
  491. return
  492. }
  493. }
  494. }
  495. err = cygx.ReportArticleClassificationEditNew(req.ReportId, industrialManagementIdStr, reportInfo.ArticleId, req.IndustrialSubjectIdStr)
  496. if err != nil {
  497. br.Msg = "分类失败"
  498. br.ErrMsg = "分类失败,Err:" + err.Error()
  499. return
  500. }
  501. go cygxService.DoArticleOnenIdWxTemplateMsg(reportInfo.ArticleId, 2)
  502. br.Ret = 200
  503. br.Success = true
  504. br.Msg = "分类成功"
  505. br.IsAddLog = true
  506. }
  507. // @Title 是否展示操作按钮
  508. // @Description 获取是否展示操作按钮接口
  509. // @Success Ret=200 {object} cygx.ShowButton
  510. // @router /reportArticle/showButton [get]
  511. func (this *IndustrialSubjectController) ShowButton() {
  512. br := new(models.BaseResponse).Init()
  513. defer func() {
  514. this.Data["json"] = br
  515. this.ServeJSON()
  516. }()
  517. sysUser := this.SysUser
  518. if sysUser == nil {
  519. br.Msg = "请登录"
  520. br.ErrMsg = "请登录,SysUser Is Empty"
  521. return
  522. }
  523. resp := new(cygx.ShowButton)
  524. if sysUser.RoleTypeCode == "rai_admin" || sysUser.RoleTypeCode == "rai_researcher" || sysUser.RoleTypeCode == "admin" {
  525. resp.IsShowButton = true
  526. }
  527. br.Ret = 200
  528. br.Success = true
  529. br.Msg = "获取成功"
  530. br.Data = resp
  531. }
  532. // @Title 下载阅读明细
  533. // @Description 获取下载阅读明细接口
  534. // @Param ReportId query int true "报告ID"
  535. // @Success Ret=200
  536. // @router /reportArticle/export [get]
  537. func (this *IndustrialSubjectController) Export() {
  538. br := new(models.BaseResponse).Init()
  539. defer func() {
  540. this.Data["json"] = br
  541. this.ServeJSON()
  542. }()
  543. sysUser := this.SysUser
  544. if sysUser == nil {
  545. br.Msg = "请登录"
  546. br.ErrMsg = "请登录,SysUser Is Empty"
  547. return
  548. }
  549. reportId, _ := this.GetInt("ReportId")
  550. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  551. resp := new(cygx.CanDownload)
  552. adminInfo, errAdmin := system.GetSysUserById(sysUser.AdminId)
  553. if errAdmin != nil {
  554. br.Msg = "获取失败"
  555. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  556. return
  557. }
  558. if adminInfo.Role == "admin" || adminInfo.Role == "researcher" {
  559. resp.IsCanDownload = true
  560. }
  561. var list []*cygx.ReportExportRep
  562. var err error
  563. if resp.IsCanDownload == false {
  564. //权益申请销售只能看到自己名下的客户的申请
  565. companyIds, err := cygxService.GetAdminLookUserCompanyIds(sysUser)
  566. if err != nil {
  567. br.Msg = "获取失败"
  568. br.ErrMsg = "获取失败,GetAdminLookUserCompanyIds Err:" + err.Error()
  569. return
  570. }
  571. var companyIdstr []string
  572. for _, v := range companyIds {
  573. companyIdstr = append(companyIdstr, strconv.Itoa(v))
  574. }
  575. sqlStr := ` AND h.company_id IN (` + strings.Join(companyIdstr, ",") + `) `
  576. listSeller, errSeller := cygx.GetReportExportRep(reportId, sqlStr)
  577. list = listSeller
  578. err = errSeller
  579. } else {
  580. sqlStr := ""
  581. listAdmin, errAdmin := cygx.GetReportExportRep(reportId, sqlStr)
  582. list = listAdmin
  583. err = errAdmin
  584. }
  585. if err != nil {
  586. br.Msg = "获取失败"
  587. br.ErrMsg = "获取失败,Err:" + err.Error()
  588. return
  589. }
  590. var listNew []*cygx.ReportExportRep
  591. for k, v := range list {
  592. if k > 0 && list[k].Id == list[k-1].Id {
  593. list[k-1].SellerName = list[k-1].SellerName + "/" + v.SellerName
  594. }
  595. }
  596. for k, v := range list {
  597. if k > 0 && list[k].Id != list[k-1].Id {
  598. listNew = append(listNew, v)
  599. }
  600. }
  601. //创建excel
  602. dir, err := os.Executable()
  603. exPath := filepath.Dir(dir)
  604. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  605. xlsxFile := xlsx.NewFile()
  606. if err != nil {
  607. br.Msg = "生成文件失败"
  608. br.ErrMsg = "生成文件失败"
  609. return
  610. }
  611. style := xlsx.NewStyle()
  612. alignment := xlsx.Alignment{
  613. Horizontal: "center",
  614. Vertical: "center",
  615. WrapText: true,
  616. }
  617. style.Alignment = alignment
  618. style.ApplyAlignment = true
  619. sheet, err := xlsxFile.AddSheet("关键词搜索统计")
  620. if err != nil {
  621. br.Msg = "新增Sheet失败"
  622. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  623. return
  624. }
  625. //标头
  626. rowTitle := sheet.AddRow()
  627. cellA := rowTitle.AddCell()
  628. cellA.Value = "姓名"
  629. cellB := rowTitle.AddCell()
  630. cellB.Value = "公司名"
  631. cellC := rowTitle.AddCell()
  632. cellC.Value = "销售名称"
  633. cellD := rowTitle.AddCell()
  634. cellD.Value = "阅读时间"
  635. cellE := rowTitle.AddCell()
  636. cellE.Value = "停留时间(s)"
  637. for _, item := range listNew {
  638. row := sheet.AddRow()
  639. cellA := row.AddCell()
  640. cellA.Value = item.RealName
  641. cellB := row.AddCell()
  642. cellB.Value = item.CompanyName
  643. cellC := row.AddCell()
  644. cellC.Value = item.SellerName
  645. cellD := row.AddCell()
  646. cellD.Value = item.CreateTime
  647. cellE := row.AddCell()
  648. cellE.Value = item.StopTime
  649. }
  650. err = xlsxFile.Save(downLoadnFilePath)
  651. if err != nil {
  652. br.Msg = "保存文件失败"
  653. br.ErrMsg = "保存文件失败"
  654. return
  655. }
  656. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  657. downloadFileName := "阅读明细统计列表" + randStr + ".xlsx"
  658. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  659. defer func() {
  660. os.Remove(downLoadnFilePath)
  661. }()
  662. br.Ret = 200
  663. br.Success = true
  664. br.Msg = "导出成功"
  665. }
  666. // @Title 通过报告ID获取对应的匹配类型
  667. // @Description 通过报告ID获取对应的匹配类型接口
  668. // @Param ReportId query int true "报告ID"
  669. // @Success 200 {object} cygx.ReportMatchTypeNameList
  670. // @router /reportArticle/getMatchTypeName [get]
  671. func (this *IndustrialSubjectController) GetMatchTypeNameByReportId() {
  672. br := new(models.BaseResponse).Init()
  673. defer func() {
  674. this.Data["json"] = br
  675. this.ServeJSON()
  676. }()
  677. sysUser := this.SysUser
  678. if sysUser == nil {
  679. br.Msg = "请登录"
  680. br.ErrMsg = "请登录,SysUser Is Empty"
  681. return
  682. }
  683. reportId, _ := this.GetInt("ReportId")
  684. detail, err := cygx.GetArticleDetailById(reportId)
  685. if err != nil {
  686. br.Msg = "获取信息失败"
  687. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  688. return
  689. }
  690. list, err := cygx.GetMatchTypeName(detail.CategoryId)
  691. if err != nil {
  692. br.Msg = "获取信息失败"
  693. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  694. return
  695. }
  696. resp := new(cygx.ReportMatchTypeNameList)
  697. resp.List = list
  698. br.Ret = 200
  699. br.Success = true
  700. br.Msg = "获取成功"
  701. br.Data = resp
  702. }
  703. // @Title 修改报告的匹配类型
  704. // @Description 修改报告的匹配类型接口
  705. // @Param request body cygx.UpdateReportMatchTypeNameRep true "type json string"
  706. // @Success Ret=200
  707. // @router /reportArticle/updateMatchTypeName [post]
  708. func (this *IndustrialSubjectController) UpdateMatchTypeName() {
  709. br := new(models.BaseResponse).Init()
  710. defer func() {
  711. this.Data["json"] = br
  712. this.ServeJSON()
  713. }()
  714. sysUser := this.SysUser
  715. if sysUser == nil {
  716. br.Msg = "请登录"
  717. br.ErrMsg = "请登录,SysUser Is Empty"
  718. return
  719. }
  720. var req cygx.UpdateReportMatchTypeNameRep
  721. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  722. reportId := req.ReportId
  723. if err != nil {
  724. br.Msg = "参数解析异常!"
  725. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  726. return
  727. }
  728. detail, err := cygx.GetMatchTypeNameById(req.MatchID)
  729. if err != nil {
  730. br.Msg = "获取信息失败"
  731. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  732. return
  733. }
  734. detailArt, err := cygx.GetArticleDetailById(reportId)
  735. if err != nil {
  736. br.Msg = "获取信息失败"
  737. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  738. return
  739. }
  740. err = cygx.UpdateReportMatchTypeName(detail.MatchTypeName, detail.ReportType, detail.CategoryId, req.ReportId, detailArt.IsSummary, detailArt.IsClass)
  741. if err != nil {
  742. br.Msg = "修改失败"
  743. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  744. return
  745. }
  746. go cygxService.DoArticleOnenIdWxTemplateMsg(detailArt.ArticleId, 2)
  747. go cygxService.AddCygxReportMappingCategoryGroupByArticleId(detailArt.ArticleId) // 手动修改报告归类
  748. go cygxService.UpdateArticleResourceData(detailArt.ArticleId) //写入首页最新 cygx_resource_data 表
  749. br.Ret = 200
  750. br.Success = true
  751. br.Msg = "修改成功"
  752. br.IsAddLog = true
  753. }
  754. // @Title 报告内容的保存与发布
  755. // @Description 报告内容的保存与发布接口
  756. // @Param request body cygx.ReportAddRep true "type json string"
  757. // @Success 200 操作成功
  758. // @router /reportArticle/PreserveAndPublish [post]
  759. func (this *ReportArticleController) PreserveAndPublish() {
  760. br := new(models.BaseResponse).Init()
  761. defer func() {
  762. this.Data["json"] = br
  763. this.ServeJSON()
  764. }()
  765. AdminUser := this.SysUser
  766. if AdminUser == nil {
  767. br.Msg = "请登录"
  768. br.ErrMsg = "请登录,用户信息为空"
  769. br.Ret = 408
  770. return
  771. }
  772. var req cygx.ReportAddRep
  773. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  774. if err != nil {
  775. br.Msg = "参数解析异常!"
  776. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  777. return
  778. }
  779. if req.Title == "" {
  780. br.Msg = "标题不可为空"
  781. br.ErrMsg = "标题不可为空"
  782. return
  783. }
  784. if req.Abstract == "" {
  785. br.Msg = "摘要不可为空"
  786. br.ErrMsg = "摘要不可为空"
  787. return
  788. }
  789. var articleId int
  790. industrialManagementIds := req.IndustrialManagementIds
  791. industrialSubjectIds := req.IndustrialSubjectIds
  792. chartPermissionId := req.ChartPermissionId
  793. publishDate := req.PublishDate
  794. if industrialManagementIds == "" {
  795. br.Msg = "请选择产业"
  796. return
  797. }
  798. if publishDate == "" {
  799. br.Msg = "请选择发布时间"
  800. return
  801. }
  802. industryIds := make([]int, 0)
  803. industrialManagementIdList := strings.Split(industrialManagementIds, ",")
  804. for _, v := range industrialManagementIdList {
  805. i, err := strconv.Atoi(v)
  806. if err != nil {
  807. br.Msg = "参数解析异常!"
  808. br.ErrMsg = "产业ID不规范,Err:" + err.Error() + industrialManagementIds
  809. return
  810. }
  811. industryIds = append(industryIds, i)
  812. }
  813. if industrialSubjectIds != "" {
  814. industrialSubjectIdList := strings.Split(industrialSubjectIds, ",")
  815. for _, v := range industrialSubjectIdList {
  816. _, err := strconv.Atoi(v)
  817. if err != nil {
  818. br.Msg = "参数解析异常!"
  819. br.ErrMsg = "标的ID不规范,Err:" + err.Error() + industrialSubjectIds
  820. return
  821. }
  822. }
  823. }
  824. var pars []interface{}
  825. var condition string
  826. condition += ` AND chart_permission_id = ? AND sub_category_name = '专项调研' `
  827. pars = append(pars, chartPermissionId)
  828. charInfo, err := cygx.GetReportMappingDetail(condition, pars)
  829. if err != nil {
  830. br.Msg = "请选择所属行业"
  831. br.ErrMsg = "获取所属行业信息失败,Err:" + err.Error()
  832. return
  833. }
  834. var articleIdNew int
  835. if articleId == 0 {
  836. maxArticleIdArticleInfo, errMax := cygx.GetMaxArticleIdInfo()
  837. if errMax != nil {
  838. br.Msg = "发布失败"
  839. br.ErrMsg = "发布失败,Err:" + errMax.Error()
  840. return
  841. }
  842. if maxArticleIdArticleInfo.ArticleId < utils.SummaryArticleId {
  843. articleIdNew = utils.SummaryArticleId
  844. } else {
  845. articleIdNew = maxArticleIdArticleInfo.ArticleId + 1
  846. }
  847. }
  848. expertNumStr, expertContentStr, interviewDateStr, fileLink := cygx.BodyAnalysis(req.Body)
  849. item := new(cygx.CygxArticle)
  850. item.AdminId = AdminUser.AdminId
  851. item.AdminName = AdminUser.AdminName
  852. item.Title = req.Title
  853. item.Body = cygxService.GetRichtext(req.Body)
  854. item.BodyText, _ = cygx.GetReportContentTextSub(item.Body)
  855. item.Abstract = req.Abstract
  856. item.CategoryName = charInfo.MatchTypeName
  857. item.SubCategoryName = charInfo.SubCategoryName
  858. item.ArticleId = articleId
  859. item.CreateDate = time.Now()
  860. item.LastUpdatedTime = time.Now()
  861. item.IsReport = 1
  862. item.IsSummary = 1
  863. item.Source = 1
  864. item.IsClass = 1
  865. item.IsReport = 1
  866. item.ReportType = 2
  867. item.ArticleIdMd5 = utils.MD5(strconv.Itoa(articleIdNew))
  868. item.UpdateFrequency = "unknow"
  869. item.SellerAndMobile = req.SellerAndMobile
  870. item.ExpertBackground = expertContentStr
  871. item.ExpertNumber = expertNumStr
  872. item.InterviewDate = interviewDateStr
  873. item.FileLink = fileLink
  874. item.CategoryId = charInfo.CategoryId
  875. item.CategoryIdTwo = charInfo.CategoryId
  876. item.ChartPermissionIds = strconv.Itoa(chartPermissionId)
  877. item.PublishDate = utils.StrTimeToTime(publishDate + " 00:00:00") //时间字符串格式转时间格式
  878. //处理作者内容的格式信息
  879. if req.DoType == 1 {
  880. item.PublishStatus = 1
  881. }
  882. itemDepartment := new(cygx.CygxArticleDepartment)
  883. if req.ArticleId == 0 {
  884. item.ArticleId = articleIdNew
  885. //需求修改纪要的新增与修改与报告一致
  886. _, err := cygx.AddAReportrticle(item, 0, "", "", itemDepartment, industrialManagementIds, industrialSubjectIds)
  887. if err != nil {
  888. br.Msg = "发布失败"
  889. br.ErrMsg = "发布失败,Err:" + err.Error()
  890. return
  891. }
  892. } else {
  893. articleInfo, err := cygx.GetArticleIdInfoByArticleId(req.ArticleId)
  894. if err != nil {
  895. br.Msg = "文章不存在"
  896. return
  897. }
  898. if item.PublishStatus == 0 {
  899. item.PublishStatus = articleInfo.PublishStatus
  900. }
  901. item.ArticleId = req.ArticleId
  902. err = cygx.EditReportrticle(item, 0, "", "", articleInfo.PublishStatus, itemDepartment, industrialManagementIds, industrialSubjectIds)
  903. if err != nil {
  904. br.Msg = "发布失败"
  905. br.ErrMsg = "发布失败,Err:" + err.Error()
  906. return
  907. }
  908. }
  909. //if req.DoType == 1 {
  910. // go cygxService.DoArticleOnenIdWxTemplateMsg(articleId, 1)
  911. //}
  912. //{|1|}表示报告类型,{|2|}表示纪要类型
  913. //cygx.UpdateSubjecIds(subjectIds+"—"+strconv.Itoa(industrialDetail.IndustrialManagementId)+"{|2|}", industrialDetail.IndustrialManagementId, articleId)
  914. if item.PublishStatus == 1 {
  915. services.EsAddOrEditData(item)
  916. //go cygxService.UpdateResourceData(item.ArticleId, "article", "add", time.Now().Format(utils.FormatDateTime))
  917. go cygxService.UpdateArticleResourceData(item.ArticleId) //写入首页最新 cygx_resource_data 表
  918. }
  919. // 查研观向7.4-更新产业布局时间
  920. if len(industryIds) > 0 {
  921. go cygxService.UpdateIndustryLayoutTime(industryIds, false)
  922. }
  923. if len(industryIds) > 0 && req.DoType == 1 {
  924. //查研观向8.2.1专项调研报告模板消息推送
  925. cygxService.SendWxMsgWithCygxActivitySpecialArticle(item.ArticleId)
  926. }
  927. go cygxService.AddCygxReportMappingCategoryGroupByArticleId(item.ArticleId) // 手动修改报告归类
  928. br.Ret = 200
  929. br.Success = true
  930. br.Msg = "操作成功"
  931. br.IsAddLog = true
  932. }
  933. // @Title 报告详情
  934. // @Description 获取报告详情接口
  935. // @Param ReportId query int true "报告ID"
  936. // @Success Ret=200 {object} cygx.CygxArticleReport
  937. // @router /reportArticle/detail [get]
  938. func (this *ReportArticleController) Detail() {
  939. br := new(models.BaseResponse).Init()
  940. defer func() {
  941. this.Data["json"] = br
  942. this.ServeJSON()
  943. }()
  944. AdminUser := this.SysUser
  945. if AdminUser == nil {
  946. br.Msg = "请登录"
  947. br.ErrMsg = "请登录,用户信息为空"
  948. br.Ret = 408
  949. return
  950. }
  951. //reportId, _ := this.GetInt("ReportId")
  952. //if reportId < 1 {
  953. // br.Msg = "请输入报告ID"
  954. // return
  955. //}
  956. //articleInfo, err := cygx.GetArticleIdInfoByreportIdEdit(reportId)
  957. //if err != nil {
  958. // br.Msg = "报告不存在"
  959. // br.ErrMsg = "报告ID错误,Err:" + err.Error()
  960. // return
  961. //}
  962. articleId, _ := this.GetInt("ArticleId")
  963. if articleId < 1 {
  964. br.Msg = "请输入文章ID"
  965. return
  966. }
  967. articleInfo, err := cygx.GetArticleIdInfoByreportIdEdit(articleId)
  968. if err != nil {
  969. br.Msg = "文章内容不存在"
  970. br.ErrMsg = "纪要ID错误,Err:" + err.Error()
  971. return
  972. }
  973. industrialList, err := cygx.GetIndustrialArticleGroupManagementList(articleInfo.ArticleId)
  974. if err != nil && err.Error() != utils.ErrNoRow() {
  975. br.Msg = "获取信息失败"
  976. br.ErrMsg = "获取活动关联的产业列表信息失败,Err:" + err.Error() + "activityId:" + strconv.Itoa(articleInfo.ArticleId)
  977. return
  978. }
  979. subjectList, err := cygx.GetSubjectArticleGroupManagementList(articleInfo.ArticleId)
  980. if err != nil && err.Error() != utils.ErrNoRow() {
  981. br.Msg = "获取信息失败"
  982. br.ErrMsg = "获取活动关联的标的列表信息失败,Err:" + err.Error() + "activityId:" + strconv.Itoa(articleInfo.ArticleId)
  983. return
  984. }
  985. articleInfo.PublishDate = cygxService.ArticlePublishDate(articleInfo.PublishDate)
  986. articleInfo.ListIndustrial = industrialList
  987. articleInfo.ListSubject = subjectList
  988. if articleInfo.ChartPermissionIds != "" {
  989. chartPermissionIdArr := strings.Split(articleInfo.ChartPermissionIds, ",")
  990. if len(chartPermissionIdArr) > 0 {
  991. articleInfo.ChartPermissionId, _ = strconv.Atoi(chartPermissionIdArr[0])
  992. }
  993. }
  994. if articleId < utils.SummaryArticleId {
  995. articleInfo.Abstract, _ = cygx.GetReportContentTextSub(articleInfo.Abstract)
  996. articleInfo.Body = html.UnescapeString(articleInfo.Body)
  997. }
  998. br.Ret = 200
  999. br.Success = true
  1000. br.Msg = "获取成功"
  1001. br.Data = articleInfo
  1002. }
  1003. // @Title 获取作者列表
  1004. // @Description 获取作者列表接口
  1005. // @Param KeyWord query string true "搜索关键词"
  1006. // @Success Ret=200 {object} cygx.CygxArticleDepartmentList
  1007. // @router /reportArticle/departmentList [get]
  1008. func (this *ReportArticleController) DepartmentList() {
  1009. br := new(models.BaseResponse).Init()
  1010. defer func() {
  1011. this.Data["json"] = br
  1012. this.ServeJSON()
  1013. }()
  1014. sysUser := this.SysUser
  1015. if sysUser == nil {
  1016. br.Msg = "请登录"
  1017. br.ErrMsg = "请登录,SysUser Is Empty"
  1018. br.Ret = 408
  1019. return
  1020. }
  1021. var condition string
  1022. keyWord := this.GetString("KeyWord")
  1023. if keyWord != "" {
  1024. condition = `WHERE nick_name LIKE'%` + keyWord + `%' ORDER BY create_time DESC `
  1025. } else {
  1026. condition += ` ORDER BY create_time DESC`
  1027. }
  1028. list, err := cygx.GetCygxArticleDepartmentList(condition)
  1029. if err != nil {
  1030. br.Msg = "获取失败"
  1031. br.ErrMsg = "获取失败,Err:" + err.Error()
  1032. return
  1033. }
  1034. resp := new(cygx.CygxArticleDepartmentList)
  1035. resp.List = list
  1036. br.Ret = 200
  1037. br.Success = true
  1038. br.Msg = "获取成功"
  1039. br.Data = resp
  1040. }
  1041. // @Title 下载客户阅读记录
  1042. // @Description 下载客户阅读记录接口
  1043. // @Param CompanyId query int true "公司ID"
  1044. // @Success Ret=200
  1045. // @router /reportArticle/companyHistory [get]
  1046. func (this *IndustrialSubjectController) CompanyHistory() {
  1047. br := new(models.BaseResponse).Init()
  1048. defer func() {
  1049. this.Data["json"] = br
  1050. this.ServeJSON()
  1051. }()
  1052. sysUser := this.SysUser
  1053. if sysUser == nil {
  1054. br.Msg = "请登录"
  1055. br.ErrMsg = "请登录,SysUser Is Empty"
  1056. return
  1057. }
  1058. companyId, _ := this.GetInt("CompanyId")
  1059. if companyId < 1 {
  1060. br.Msg = "请输入公司ID"
  1061. return
  1062. }
  1063. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  1064. var isCanDownload bool
  1065. adminInfo, err := system.GetSysUserById(sysUser.AdminId)
  1066. if err != nil {
  1067. br.Msg = "获取失败"
  1068. br.ErrMsg = "获取失败,Err:" + err.Error()
  1069. return
  1070. }
  1071. if adminInfo.Role == "admin" || strings.Index(adminInfo.RoleTypeCode, "rai") > -1 {
  1072. isCanDownload = true
  1073. }
  1074. if !isCanDownload {
  1075. br.Msg = "暂无下载权限"
  1076. return
  1077. }
  1078. //获取企业客户信息
  1079. companyInfo, err := company.GetCompanyById(companyId)
  1080. if err != nil {
  1081. br.Msg = "获取失败"
  1082. br.ErrMsg = "获取企业客户信息失败,Err:" + err.Error()
  1083. return
  1084. }
  1085. mapChartPermissionName := make(map[int]string)
  1086. listMap, err := cygx.GetPermissionMappingCategoryAll()
  1087. if err != nil {
  1088. br.Msg = "获取失败"
  1089. br.ErrMsg = "获取失败,Err:" + err.Error()
  1090. return
  1091. }
  1092. for _, v := range listMap {
  1093. mapChartPermissionName[v.CategoryId] = v.ChartPermissionName
  1094. }
  1095. mobiles, err := models.GetCompanyUserMobilesByCompanyId(companyId)
  1096. if err != nil && err.Error() != utils.ErrNoRow() {
  1097. br.Msg = "获取信息失败"
  1098. br.ErrMsg = "获取客户手机号信息失败,Err:" + err.Error()
  1099. return
  1100. }
  1101. if mobiles != "" {
  1102. mobiles = strings.Replace(mobiles, ",", "','", -1)
  1103. mobiles = "'" + mobiles + "'"
  1104. } else {
  1105. mobiles = "'1'"
  1106. }
  1107. emails, err := models.GetCompanyUserEmailsByCompanyId(companyId)
  1108. if err != nil && err.Error() != utils.ErrNoRow() {
  1109. br.Msg = "获取信息失败"
  1110. br.ErrMsg = "获取客户邮箱信息失败,Err:" + err.Error()
  1111. return
  1112. }
  1113. if emails != "" {
  1114. emails = strings.Replace(emails, ",", "','", -1)
  1115. emails = "'" + emails + "'"
  1116. } else {
  1117. emails = "'1'"
  1118. }
  1119. list, err := cygx.GetCompanyHistoryRecordNewPv(mobiles, emails)
  1120. if err != nil {
  1121. br.Msg = "获取失败"
  1122. br.ErrMsg = "获取失败,Err:" + err.Error()
  1123. return
  1124. }
  1125. for k, v := range list {
  1126. list[k].PermissionName = mapChartPermissionName[v.CategoryId]
  1127. }
  1128. //创建excel
  1129. dir, err := os.Executable()
  1130. exPath := filepath.Dir(dir)
  1131. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1132. xlsxFile := xlsx.NewFile()
  1133. if err != nil {
  1134. br.Msg = "生成文件失败"
  1135. br.ErrMsg = "生成文件失败"
  1136. return
  1137. }
  1138. style := xlsx.NewStyle()
  1139. alignment := xlsx.Alignment{
  1140. Horizontal: "center",
  1141. Vertical: "center",
  1142. WrapText: true,
  1143. }
  1144. style.Alignment = alignment
  1145. style.ApplyAlignment = true
  1146. sheet, err := xlsxFile.AddSheet("客户阅读记录")
  1147. if err != nil {
  1148. br.Msg = "新增Sheet失败"
  1149. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1150. return
  1151. }
  1152. //标头
  1153. rowTitle := sheet.AddRow()
  1154. cellA := rowTitle.AddCell()
  1155. cellA.Value = "姓名"
  1156. cellB := rowTitle.AddCell()
  1157. cellB.Value = "手机号/邮箱"
  1158. cellC := rowTitle.AddCell()
  1159. cellC.Value = "报告标题"
  1160. cellD := rowTitle.AddCell()
  1161. cellD.Value = "所属行业"
  1162. cellE := rowTitle.AddCell()
  1163. cellE.Value = "所属产业"
  1164. cellF := rowTitle.AddCell()
  1165. cellF.Value = "关联标的"
  1166. cellG := rowTitle.AddCell()
  1167. cellG.Value = "发布时间"
  1168. cellH := rowTitle.AddCell()
  1169. cellH.Value = "阅读时间"
  1170. cellI := rowTitle.AddCell()
  1171. cellI.Value = "阅读时长"
  1172. for _, item := range list {
  1173. row := sheet.AddRow()
  1174. cellA := row.AddCell()
  1175. cellA.Value = item.RealName
  1176. cellB := row.AddCell()
  1177. cellB.Value = item.Mobile
  1178. if item.Mobile == "" {
  1179. cellB.Value = item.Email
  1180. }
  1181. cellC := row.AddCell()
  1182. cellC.Value = item.Title
  1183. cellD := row.AddCell()
  1184. if item.CategoryId == 0 {
  1185. cellD.Value = "研选"
  1186. } else {
  1187. cellD.Value = item.PermissionName
  1188. }
  1189. cellE := row.AddCell()
  1190. cellE.Value = item.IndustryName
  1191. cellF := row.AddCell()
  1192. cellF.Value = item.SubjectNameStr
  1193. cellG := row.AddCell()
  1194. cellG.Value = item.PublishDate
  1195. cellH := row.AddCell()
  1196. cellH.Value = item.CreateTime
  1197. cellI := row.AddCell()
  1198. cellI.Value = item.StopTime
  1199. }
  1200. err = xlsxFile.Save(downLoadnFilePath)
  1201. if err != nil {
  1202. br.Msg = "保存文件失败"
  1203. br.ErrMsg = "保存文件失败"
  1204. return
  1205. }
  1206. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1207. downloadFileName := companyInfo.CompanyName + "阅读记录" + randStr + ".xlsx"
  1208. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1209. defer func() {
  1210. os.Remove(downLoadnFilePath)
  1211. }()
  1212. br.Ret = 200
  1213. br.Success = true
  1214. br.Msg = "导出成功"
  1215. }
  1216. // @Title 客户其他行为数据
  1217. // @Description 下载客户其他行为数据接口
  1218. // @Param CompanyId query int true "公司ID"
  1219. // @Success Ret=200
  1220. // @router /reportArticle/companyOtherHistory [get]
  1221. func (this *IndustrialSubjectController) CompanyOtherHistory() {
  1222. br := new(models.BaseResponse).Init()
  1223. defer func() {
  1224. this.Data["json"] = br
  1225. this.ServeJSON()
  1226. }()
  1227. sysUser := this.SysUser
  1228. if sysUser == nil {
  1229. br.Msg = "请登录"
  1230. br.ErrMsg = "请登录,SysUser Is Empty"
  1231. return
  1232. }
  1233. companyId, _ := this.GetInt("CompanyId")
  1234. if companyId <= 0 {
  1235. br.Msg = "请选择客户"
  1236. br.ErrMsg = "客户参数错误"
  1237. return
  1238. }
  1239. //获取企业客户信息
  1240. companyInfo, err := company.GetCompanyById(companyId)
  1241. if err != nil {
  1242. br.Msg = "获取失败"
  1243. br.ErrMsg = "获取企业客户信息失败,Err:" + err.Error()
  1244. return
  1245. }
  1246. var condition string
  1247. var pars []interface{}
  1248. //非管理员,那么只能看到该产品下的联系人
  1249. if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
  1250. productId := services.GetProductId(sysUser.RoleTypeCode)
  1251. condition += ` AND b.product_id = ? `
  1252. pars = append(pars, productId)
  1253. //流失客户(除非是超级管理员或者是部门管理员,要不然不允许看对应的联系人)
  1254. var companyProduct *company.CompanyProduct
  1255. if productId == 2 && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_ADMIN {
  1256. // 当前是权益权限,且非 权益管理员
  1257. tmpCompanyProduct, _ := company.GetCompanyProductByCompanyIdAndProductId(companyId, 2)
  1258. companyProduct = tmpCompanyProduct
  1259. if companyProduct != nil && companyProduct.Status == utils.COMPANY_STATUS_LOSE {
  1260. condition += ` AND seller_id=? `
  1261. pars = append(pars, sysUser.AdminId)
  1262. }
  1263. }
  1264. }
  1265. list, err := company.GetCompanyUserListV2(condition, pars, companyId, 0, 1000)
  1266. if err != nil {
  1267. br.Msg = "获取失败"
  1268. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1269. return
  1270. }
  1271. var userIdstr string
  1272. for _, v := range list {
  1273. userIdstr += strconv.Itoa(int(v.UserId)) + ","
  1274. }
  1275. userIdstr = strings.TrimRight(userIdstr, ",")
  1276. resp := new(cygx.CompanyOtherHistoryListResp)
  1277. condition = ` AND user_id IN (` + userIdstr + `)`
  1278. listArticle, err := cygx.GetArticleCollectList(condition)
  1279. if err != nil {
  1280. br.Msg = "获取失败"
  1281. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1282. return
  1283. }
  1284. listIndustry, err := cygx.GetCygxIndustryList(companyId)
  1285. if err != nil {
  1286. br.Msg = "获取失败"
  1287. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1288. return
  1289. }
  1290. listDepartment, err := cygx.GetArticleDepartmentList(companyId)
  1291. if err != nil {
  1292. br.Msg = "获取失败"
  1293. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1294. return
  1295. }
  1296. //listkeyWord, err := cygx.GetCygxUserSearchKeyWordList(userIdstr)
  1297. //if err != nil {
  1298. // br.Msg = "获取失败"
  1299. // br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1300. // return
  1301. //}
  1302. //listkeyWord, err := cygx.GetCygxUserSearchKeyWordList(userIdstr)
  1303. //if err != nil {
  1304. // br.Msg = "获取失败"
  1305. // br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1306. // return
  1307. //}
  1308. for _, v := range list {
  1309. userItem := new(cygx.CompanyOtherHistoryList)
  1310. var artItems []*cygx.CygxArticleCollect
  1311. var industryItems []*cygx.CygxArticleIndustry
  1312. var departmentItems []*cygx.ArticleDepartment
  1313. //var keyWordItems []*cygx.KeyWord
  1314. for _, vArt := range listArticle {
  1315. if vArt.UserId == int(v.UserId) {
  1316. artItems = append(artItems, vArt)
  1317. }
  1318. }
  1319. for _, vIn := range listIndustry {
  1320. if vIn.UserId == int(v.UserId) {
  1321. industryItems = append(industryItems, vIn)
  1322. }
  1323. }
  1324. for _, vDe := range listDepartment {
  1325. if vDe.UserId == int(v.UserId) {
  1326. departmentItems = append(departmentItems, vDe)
  1327. }
  1328. }
  1329. //for _, vKw := range listkeyWord {
  1330. // if vKw.UserId == int(v.UserId) {
  1331. // keyWordItems = append(keyWordItems, vKw)
  1332. // }
  1333. //}
  1334. if len(artItems) > 0 || len(industryItems) > 0 || len(departmentItems) > 0 {
  1335. userItem.RealName = v.RealName
  1336. userItem.Email = v.Email
  1337. userItem.Mobile = v.Mobile
  1338. userItem.ListArticle = artItems
  1339. userItem.ListIndustrial = industryItems
  1340. userItem.ListDepartment = departmentItems
  1341. //userItem.ListKeyWord = keyWordItems
  1342. resp.List = append(resp.List, userItem)
  1343. }
  1344. }
  1345. //创建excel
  1346. dir, err := os.Executable()
  1347. exPath := filepath.Dir(dir)
  1348. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1349. xlsxFile := xlsx.NewFile()
  1350. if err != nil {
  1351. br.Msg = "生成文件失败"
  1352. br.ErrMsg = "生成文件失败"
  1353. return
  1354. }
  1355. style := xlsx.NewStyle()
  1356. alignment := xlsx.Alignment{
  1357. Horizontal: "center",
  1358. Vertical: "center",
  1359. WrapText: true,
  1360. }
  1361. style.Alignment = alignment
  1362. style.ApplyAlignment = true
  1363. sheet, err := xlsxFile.AddSheet("客户其他行为数据(收藏,关注)")
  1364. if err != nil {
  1365. br.Msg = "新增Sheet失败"
  1366. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1367. return
  1368. }
  1369. //标题样式
  1370. titleStyle := xlsx.NewStyle()
  1371. titleFont := xlsx.NewFont(16, "宋体")
  1372. titleFont.Bold = true
  1373. titleStyle.Font = *titleFont
  1374. titleStyle.Alignment = alignment
  1375. sheet.SetColWidth(0, 0, 20)
  1376. sheet.SetColWidth(1, 1, 20)
  1377. sheet.SetColWidth(2, 2, 20)
  1378. sheet.SetColWidth(3, 3, 20)
  1379. sheet.SetColWidth(4, 4, 20)
  1380. titleSonStyle := xlsx.NewStyle()
  1381. titleSonFont := xlsx.NewFont(16, "宋体")
  1382. titleSonFont.Bold = true
  1383. titleSonStyle.Font = *titleSonFont
  1384. for _, item := range resp.List {
  1385. rowTitle := sheet.AddRow()
  1386. //标题列
  1387. titleCell := rowTitle.AddCell()
  1388. titleCell.HMerge = 6 //向右合并列数,不包括自身列
  1389. titleCell.SetValue("客户姓名:" + item.RealName + " 手机号/邮箱:" + item.Mobile)
  1390. titleCell.SetStyle(titleStyle)
  1391. //文章
  1392. if len(item.ListArticle) > 0 {
  1393. rowArticle := sheet.AddRow()
  1394. cellA := rowArticle.AddCell()
  1395. cellA.Value = "收藏报告"
  1396. cellB := rowArticle.AddCell()
  1397. cellB.Value = "收藏时间"
  1398. cellC := rowArticle.AddCell()
  1399. cellC.Value = "发布时间"
  1400. cellD := rowArticle.AddCell()
  1401. cellD.Value = "报告类型"
  1402. cellE := rowArticle.AddCell()
  1403. cellE.Value = "所属产业"
  1404. cellF := rowArticle.AddCell()
  1405. cellF.Value = "关联标的"
  1406. cellA.SetStyle(titleSonStyle)
  1407. cellB.SetStyle(titleSonStyle)
  1408. cellC.SetStyle(titleSonStyle)
  1409. cellD.SetStyle(titleSonStyle)
  1410. cellE.SetStyle(titleSonStyle)
  1411. cellF.SetStyle(titleSonStyle)
  1412. for _, vArt := range item.ListArticle {
  1413. rowArticleVal := sheet.AddRow()
  1414. cellA := rowArticleVal.AddCell()
  1415. cellA.Value = vArt.Title
  1416. cellB := rowArticleVal.AddCell()
  1417. cellB.Value = vArt.CreateTime
  1418. cellC := rowArticleVal.AddCell()
  1419. cellC.Value = vArt.PublishDate
  1420. cellD := rowArticleVal.AddCell()
  1421. cellD.Value = vArt.MatchTypeName
  1422. cellE := rowArticleVal.AddCell()
  1423. cellE.Value = vArt.IndustryName
  1424. cellF := rowArticleVal.AddCell()
  1425. cellF.Value = vArt.SubjectName
  1426. }
  1427. }
  1428. //产业
  1429. if len(item.ListIndustrial) > 0 {
  1430. rowIndustrial := sheet.AddRow()
  1431. cellA := rowIndustrial.AddCell()
  1432. cellA.Value = "关注产业"
  1433. cellB := rowIndustrial.AddCell()
  1434. cellB.Value = "关注时间"
  1435. cellA.SetStyle(titleSonStyle)
  1436. cellB.SetStyle(titleSonStyle)
  1437. for _, vArt := range item.ListIndustrial {
  1438. rowIndustrialVal := sheet.AddRow()
  1439. cellA := rowIndustrialVal.AddCell()
  1440. cellA.Value = vArt.IndustryName
  1441. cellB := rowIndustrialVal.AddCell()
  1442. cellB.Value = vArt.CreateTime
  1443. }
  1444. }
  1445. //作者
  1446. if len(item.ListDepartment) > 0 {
  1447. rowDepartment := sheet.AddRow()
  1448. cellA := rowDepartment.AddCell()
  1449. cellA.Value = "关注作者"
  1450. cellB := rowDepartment.AddCell()
  1451. cellB.Value = "关注时间"
  1452. cellC := rowDepartment.AddCell()
  1453. cellC.Value = "作者相关产业"
  1454. cellA.SetStyle(titleSonStyle)
  1455. cellB.SetStyle(titleSonStyle)
  1456. cellC.SetStyle(titleSonStyle)
  1457. for _, vArt := range item.ListDepartment {
  1458. rowDepartmentVal := sheet.AddRow()
  1459. cellA := rowDepartmentVal.AddCell()
  1460. cellA.Value = vArt.NickName
  1461. cellB := rowDepartmentVal.AddCell()
  1462. cellB.Value = vArt.CreateTime
  1463. cellC := rowDepartmentVal.AddCell()
  1464. cellC.Value = vArt.IndustryName
  1465. }
  1466. }
  1467. }
  1468. err = xlsxFile.Save(downLoadnFilePath)
  1469. if err != nil {
  1470. br.Msg = "保存文件失败"
  1471. br.ErrMsg = "保存文件失败"
  1472. return
  1473. }
  1474. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1475. downloadFileName := companyInfo.CompanyName + "其他行为数据(收藏,关注)" + randStr + ".xlsx"
  1476. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1477. defer func() {
  1478. os.Remove(downLoadnFilePath)
  1479. }()
  1480. br.Ret = 200
  1481. br.Data = resp
  1482. br.Success = true
  1483. br.Msg = "导出成功"
  1484. }
  1485. // @Title 客户阅读量月度统计
  1486. // @Description 客户阅读量月度统计
  1487. // @Param CompanyId query int true "公司ID"
  1488. // @Success Ret=200
  1489. // @router /reportArticle/companyCount [get]
  1490. func (this *IndustrialSubjectController) CompanyCount() {
  1491. br := new(models.BaseResponse).Init()
  1492. defer func() {
  1493. this.Data["json"] = br
  1494. this.ServeJSON()
  1495. }()
  1496. sysUser := this.SysUser
  1497. if sysUser == nil {
  1498. br.Msg = "请登录"
  1499. br.ErrMsg = "请登录,SysUser Is Empty"
  1500. return
  1501. }
  1502. companyId, _ := this.GetInt("CompanyId")
  1503. if companyId < 1 {
  1504. br.Msg = "请输入公司ID"
  1505. return
  1506. }
  1507. //超级管理员和权益管理员、权益研究员可以下载所有客户,销售组长能下载本组客户,销售只能下载本人名下客户
  1508. var isCanDownload bool
  1509. adminInfo, err := system.GetSysUserById(sysUser.AdminId)
  1510. if err != nil {
  1511. br.Msg = "获取失败"
  1512. br.ErrMsg = "获取失败,Err:" + err.Error()
  1513. return
  1514. }
  1515. if adminInfo.Role == "admin" || strings.Index(adminInfo.RoleTypeCode, "rai") > -1 {
  1516. isCanDownload = true
  1517. }
  1518. if !isCanDownload {
  1519. br.Msg = "暂无下载权限"
  1520. return
  1521. }
  1522. //获取企业客户信息
  1523. companyInfo, err := company.GetCompanyById(companyId)
  1524. if err != nil {
  1525. br.Msg = "获取失败"
  1526. br.ErrMsg = "获取企业客户信息失败,Err:" + err.Error()
  1527. return
  1528. }
  1529. mobiles, err := models.GetCompanyUserMobilesByCompanyId(companyId)
  1530. if err != nil && err.Error() != utils.ErrNoRow() {
  1531. br.Msg = "获取信息失败"
  1532. br.ErrMsg = "获取客户手机号信息失败,Err:" + err.Error()
  1533. return
  1534. }
  1535. if mobiles != "" {
  1536. mobiles = strings.Replace(mobiles, ",", "','", -1)
  1537. mobiles = "'" + mobiles + "'"
  1538. } else {
  1539. mobiles = "'1'"
  1540. }
  1541. emails, err := models.GetCompanyUserEmailsByCompanyId(companyId)
  1542. if err != nil && err.Error() != utils.ErrNoRow() {
  1543. br.Msg = "获取信息失败"
  1544. br.ErrMsg = "获取客户邮箱信息失败,Err:" + err.Error()
  1545. return
  1546. }
  1547. if emails != "" {
  1548. emails = strings.Replace(emails, ",", "','", -1)
  1549. emails = "'" + emails + "'"
  1550. } else {
  1551. emails = "'1'"
  1552. }
  1553. listDate, err := cygx.GetCompanyHistoryRecordPvGroupDate(mobiles, emails)
  1554. if err != nil {
  1555. br.Msg = "获取失败"
  1556. br.ErrMsg = "获取失败,Err:" + err.Error()
  1557. return
  1558. }
  1559. dateMap := make(map[string]int)
  1560. permissionNameMap := make(map[string]int)
  1561. list, err := cygx.GetCompanyHistoryRecordPv(mobiles, emails)
  1562. if err != nil {
  1563. br.Msg = "获取失败"
  1564. br.ErrMsg = "获取失败,Err:" + err.Error()
  1565. return
  1566. }
  1567. for _, v := range list {
  1568. if dateMap[v.CreateTime] == 0 {
  1569. dateMap[v.CreateTime] = 1
  1570. } else {
  1571. dateMap[v.CreateTime] += 1
  1572. }
  1573. if v.CategoryId == 0 {
  1574. v.PermissionName = "研选"
  1575. }
  1576. if permissionNameMap[v.CreateTime+v.PermissionName] == 0 {
  1577. permissionNameMap[v.CreateTime+v.PermissionName] = 1
  1578. } else {
  1579. permissionNameMap[v.CreateTime+v.PermissionName] += 1
  1580. }
  1581. }
  1582. //创建excel
  1583. dir, err := os.Executable()
  1584. exPath := filepath.Dir(dir)
  1585. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1586. xlsxFile := xlsx.NewFile()
  1587. if err != nil {
  1588. br.Msg = "生成文件失败"
  1589. br.ErrMsg = "生成文件失败"
  1590. return
  1591. }
  1592. style := xlsx.NewStyle()
  1593. alignment := xlsx.Alignment{
  1594. Horizontal: "center",
  1595. Vertical: "center",
  1596. WrapText: true,
  1597. }
  1598. style.Alignment = alignment
  1599. style.ApplyAlignment = true
  1600. sheet, err := xlsxFile.AddSheet("客户阅读量月度统计")
  1601. if err != nil {
  1602. br.Msg = "新增Sheet失败"
  1603. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1604. return
  1605. }
  1606. //标头
  1607. rowTitle := sheet.AddRow()
  1608. cellA := rowTitle.AddCell()
  1609. cellA.Value = "月份"
  1610. cellB := rowTitle.AddCell()
  1611. cellB.Value = "总阅读数"
  1612. cellC := rowTitle.AddCell()
  1613. cellC.Value = "医药"
  1614. cellD := rowTitle.AddCell()
  1615. cellD.Value = "消费"
  1616. cellE := rowTitle.AddCell()
  1617. cellE.Value = "科技"
  1618. cellF := rowTitle.AddCell()
  1619. cellF.Value = "智造"
  1620. cellG := rowTitle.AddCell()
  1621. cellG.Value = "策略"
  1622. cellH := rowTitle.AddCell()
  1623. cellH.Value = "研选"
  1624. for _, item := range listDate {
  1625. row := sheet.AddRow()
  1626. cellA := row.AddCell()
  1627. cellA.Value = item.CreateTimes
  1628. cellB := row.AddCell()
  1629. cellB.Value = strconv.Itoa(dateMap[item.CreateTimes])
  1630. cellC := row.AddCell()
  1631. cellC.Value = strconv.Itoa(permissionNameMap[item.CreateTimes+"医药"])
  1632. cellD := row.AddCell()
  1633. cellD.Value = strconv.Itoa(permissionNameMap[item.CreateTimes+"消费"])
  1634. cellE := row.AddCell()
  1635. cellE.Value = strconv.Itoa(permissionNameMap[item.CreateTimes+"科技"])
  1636. cellF := row.AddCell()
  1637. cellF.Value = strconv.Itoa(permissionNameMap[item.CreateTimes+"智造"])
  1638. cellG := row.AddCell()
  1639. cellG.Value = strconv.Itoa(permissionNameMap[item.CreateTimes+"策略"])
  1640. cellH := row.AddCell()
  1641. cellH.Value = strconv.Itoa(permissionNameMap[item.CreateTimes+"研选"])
  1642. }
  1643. err = xlsxFile.Save(downLoadnFilePath)
  1644. if err != nil {
  1645. br.Msg = "保存文件失败"
  1646. br.ErrMsg = "保存文件失败"
  1647. return
  1648. }
  1649. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1650. downloadFileName := companyInfo.CompanyName + "客户阅读量月度统计" + randStr + ".xlsx"
  1651. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1652. defer func() {
  1653. os.Remove(downLoadnFilePath)
  1654. }()
  1655. br.Ret = 200
  1656. br.Success = true
  1657. br.Msg = "导出成功"
  1658. }
  1659. // @Title 客户导出文件种类
  1660. // @Description 客户导出文件种类接口
  1661. // @Success Ret=200 {object} cygx.NameAndUrlList
  1662. // @router /company/exportList [get]
  1663. func (this *ReportArticleController) ExportList() {
  1664. br := new(models.BaseResponse).Init()
  1665. defer func() {
  1666. this.Data["json"] = br
  1667. this.ServeJSON()
  1668. }()
  1669. sysUser := this.SysUser
  1670. if sysUser == nil {
  1671. br.Msg = "请登录"
  1672. br.ErrMsg = "请登录,SysUser Is Empty"
  1673. br.Ret = 408
  1674. return
  1675. }
  1676. detail, err := cygx.GetCygxConfigDetailByCode("export_list")
  1677. if err != nil {
  1678. br.Msg = "获取失败"
  1679. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1680. return
  1681. }
  1682. resp := new(cygx.NameAndUrlList)
  1683. exportList := strings.Split(detail.ConfigValue, "{|}")
  1684. for _, v := range exportList {
  1685. item := new(cygx.NameAndUrl)
  1686. vslice := strings.Split(v, "_")
  1687. item.Name = vslice[0]
  1688. item.Url = vslice[len(vslice)-1]
  1689. resp.List = append(resp.List, item)
  1690. }
  1691. br.Ret = 200
  1692. br.Success = true
  1693. br.Msg = "获取成功"
  1694. br.Data = resp
  1695. }
  1696. // @Title 留言列表详情
  1697. // @Description 获取留言列表详情接口
  1698. // @Param ArticleId query int true "文章ID"
  1699. // @Success 200 {object} cygx.ArticleCommentListResp
  1700. // @router /reportArticle/commentList [get]
  1701. func (this *ReportArticleController) CommentList() {
  1702. br := new(models.BaseResponse).Init()
  1703. defer func() {
  1704. this.Data["json"] = br
  1705. this.ServeJSON()
  1706. }()
  1707. sysUser := this.SysUser
  1708. if sysUser == nil {
  1709. br.Msg = "请登录"
  1710. br.ErrMsg = "请登录,SysUser Is Empty"
  1711. return
  1712. }
  1713. articleId, _ := this.GetInt("ArticleId")
  1714. articleInfo, _ := cygx.GetArticleIdInfoByArticleId(articleId)
  1715. if articleInfo == nil {
  1716. br.Msg = "操作失败"
  1717. br.ErrMsg = "报告ID错误"
  1718. return
  1719. }
  1720. list, err := cygx.GetArticleCommentList(articleInfo.ArticleId)
  1721. resp := new(cygx.ArticleCommentListResp)
  1722. if err != nil {
  1723. br.Msg = "获取留言失败"
  1724. br.ErrMsg = "获取留言失败,Err:" + err.Error()
  1725. return
  1726. }
  1727. resp.List = list
  1728. br.Ret = 200
  1729. br.Success = true
  1730. br.Msg = "获取成功"
  1731. br.Data = resp
  1732. }
  1733. // @Title 提问详情excel表格下载
  1734. // @Description 提问详情excel表格下载接口
  1735. // @Param SummaryManageId query int true "纪要ID"
  1736. // @Success 200 导出成功
  1737. // @router /reportArticle/commnetListExport [get]
  1738. func (this *ReportArticleController) CommentListExport() {
  1739. br := new(models.BaseResponse).Init()
  1740. defer func() {
  1741. this.Data["json"] = br
  1742. this.ServeJSON()
  1743. }()
  1744. sysUser := this.SysUser
  1745. if sysUser == nil {
  1746. br.Msg = "请登录"
  1747. br.ErrMsg = "请登录,SysUser Is Empty"
  1748. return
  1749. }
  1750. articleId, _ := this.GetInt("ArticleId")
  1751. articleInfo, _ := cygx.GetArticleIdInfoByArticleId(articleId)
  1752. if articleInfo == nil {
  1753. br.Msg = "操作失败"
  1754. br.ErrMsg = "报告ID错误"
  1755. return
  1756. }
  1757. list, err := cygx.GetArticleCommentList(articleInfo.ArticleId)
  1758. if err != nil {
  1759. br.Msg = "获取失败"
  1760. br.ErrMsg = "获取失败,Err:" + err.Error()
  1761. return
  1762. }
  1763. //创建excel
  1764. dir, err := os.Executable()
  1765. exPath := filepath.Dir(dir)
  1766. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1767. xlsxFile := xlsx.NewFile()
  1768. if err != nil {
  1769. br.Msg = "生成文件失败"
  1770. br.ErrMsg = "生成文件失败"
  1771. return
  1772. }
  1773. style := xlsx.NewStyle()
  1774. alignment := xlsx.Alignment{
  1775. Horizontal: "center",
  1776. Vertical: "center",
  1777. WrapText: true,
  1778. }
  1779. style.Alignment = alignment
  1780. style.ApplyAlignment = true
  1781. sheet, err := xlsxFile.AddSheet("名单")
  1782. if err != nil {
  1783. br.Msg = "新增Sheet失败"
  1784. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  1785. return
  1786. }
  1787. //标头
  1788. rowTitle := sheet.AddRow()
  1789. cellA := rowTitle.AddCell()
  1790. cellA.Value = "姓名"
  1791. cellB := rowTitle.AddCell()
  1792. cellB.Value = "公司名称"
  1793. cellC := rowTitle.AddCell()
  1794. cellC.Value = "留言"
  1795. cellD := rowTitle.AddCell()
  1796. cellD.Value = "提交时间"
  1797. for _, item := range list {
  1798. row := sheet.AddRow()
  1799. cellA := row.AddCell()
  1800. cellA.Value = item.RealName
  1801. cellB := row.AddCell()
  1802. cellB.Value = item.CompanyName
  1803. cellC := row.AddCell()
  1804. cellC.Value = item.Content
  1805. cellD := row.AddCell()
  1806. cellD.Value = item.CreateTime
  1807. }
  1808. err = xlsxFile.Save(downLoadnFilePath)
  1809. if err != nil {
  1810. br.Msg = "保存文件失败"
  1811. br.ErrMsg = "保存文件失败"
  1812. return
  1813. }
  1814. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  1815. downloadFileName := "留言列表" + randStr + ".xlsx"
  1816. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  1817. defer func() {
  1818. os.Remove(downLoadnFilePath)
  1819. }()
  1820. br.Success = true
  1821. br.Ret = 200
  1822. br.Msg = "导出成功"
  1823. }
  1824. // @Title 新建报告类型
  1825. // @Description 新建报告类型接口
  1826. // @Param request body cygx.CygxReportMappingCygxAdd true "type json string"
  1827. // @Success Ret=200 {object} cygx.CygxReportMappingCygx
  1828. // @router /reportMapping/add [post]
  1829. func (this *IndustrialSubjectController) ReportMappingAdd() {
  1830. br := new(models.BaseResponse).Init()
  1831. defer func() {
  1832. this.Data["json"] = br
  1833. this.ServeJSON()
  1834. }()
  1835. sysUser := this.SysUser
  1836. if sysUser == nil {
  1837. br.Msg = "请登录"
  1838. br.ErrMsg = "请登录,SysUser Is Empty"
  1839. br.Ret = 408
  1840. return
  1841. }
  1842. var req cygx.CygxReportMappingCygxAdd
  1843. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1844. if err != nil {
  1845. br.Msg = "参数解析异常!"
  1846. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1847. return
  1848. }
  1849. var condition string
  1850. var pars []interface{}
  1851. reportType := req.ReportType
  1852. chartPermissionId := req.ChartPermissionId
  1853. chartPermissionName := req.ChartPermissionName
  1854. matchTypeName := req.MatchTypeName
  1855. condition = ` AND match_type_name = ? AND chart_permission_id = ? `
  1856. pars = append(pars, matchTypeName, chartPermissionId)
  1857. total, err := cygx.GetCygxReportMappingCygxCount(condition, pars)
  1858. if err != nil {
  1859. br.Msg = "新建报告类型失败"
  1860. br.ErrMsg = "新建报告类型失败,Err:" + err.Error()
  1861. return
  1862. }
  1863. if total > 0 {
  1864. br.Msg = "名称已存在"
  1865. br.ErrMsg = "名称已存在,Err:" + matchTypeName
  1866. return
  1867. }
  1868. maxDeatil, err := cygx.GetCygxReportMappingCelueMaxDetail()
  1869. if err != nil {
  1870. br.Msg = "新建报告类型失败"
  1871. br.ErrMsg = "GetCygxReportMappingCelueMaxDetail,Err:" + err.Error()
  1872. return
  1873. }
  1874. itemCygx := new(cygx.CygxReportMappingCygx)
  1875. itemCygx.ChartPermissionId = chartPermissionId
  1876. itemCygx.ChartPermissionName = chartPermissionName
  1877. itemCygx.MatchTypeName = matchTypeName
  1878. itemCygx.ReportType = reportType
  1879. itemCygx.IsReport = 1
  1880. itemCygx.CreateTime = time.Now()
  1881. itemCygx.ModifyTime = time.Now()
  1882. itemCelue := new(cygx.CygxReportMappingCelue)
  1883. itemCelue.ChartPermissionId = chartPermissionId
  1884. itemCelue.ChartPermissionName = chartPermissionName
  1885. itemCelue.SubCategoryName = matchTypeName
  1886. itemCelue.ReportType = reportType
  1887. itemCelue.IsReport = 1
  1888. itemCelue.CategoryId = maxDeatil.CategoryId + 1
  1889. itemCelue.CreateTime = time.Now()
  1890. itemCelue.ModifyTime = time.Now()
  1891. itemCygxId, err := cygx.AddCygxReportMappingCygx(itemCygx, itemCelue)
  1892. if err != nil {
  1893. br.Msg = "新建报告类型失败"
  1894. br.ErrMsg = "AddCygxReportMappingCygx,Err:" + err.Error()
  1895. return
  1896. }
  1897. resp := new(cygx.CygxReportMappingCygx)
  1898. resp.Id = int(itemCygxId)
  1899. resp.MatchTypeName = matchTypeName
  1900. br.Ret = 200
  1901. br.Success = true
  1902. br.Data = resp
  1903. br.Msg = "分类成功"
  1904. br.IsAddLog = true
  1905. }
  1906. //func init() {
  1907. // initOrderArticle()
  1908. //}
  1909. func initart() {
  1910. //行业
  1911. var condition string
  1912. var pars []interface{}
  1913. condition += ` AND re.chart_permission_id = 62 `
  1914. //报告匹配类型
  1915. //9.5 13:52
  1916. condition += ` GROUP BY art.article_id ORDER BY art.publish_date DESC `
  1917. listart, err := cygx.GetReportArticleList(condition, pars, 0, 200, 1)
  1918. if err != nil {
  1919. fmt.Println(err)
  1920. return
  1921. }
  1922. //创建excel
  1923. dir, err := os.Executable()
  1924. exPath := filepath.Dir(dir)
  1925. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1926. xlsxFile := xlsx.NewFile()
  1927. if err != nil {
  1928. fmt.Println(err)
  1929. return
  1930. }
  1931. style := xlsx.NewStyle()
  1932. alignment := xlsx.Alignment{
  1933. Horizontal: "center",
  1934. Vertical: "center",
  1935. WrapText: true,
  1936. }
  1937. style.Alignment = alignment
  1938. style.ApplyAlignment = true
  1939. redStyle := xlsx.NewStyle()
  1940. redStyle.Alignment = alignment
  1941. redStyle.ApplyAlignment = true
  1942. redStyle.Font.Color = "ff0000"
  1943. //定义底色需要标黄的 单元格颜色
  1944. redFill := xlsx.Fill{"solid", "ffff00", "ffff00"}
  1945. redStyle.Fill = redFill
  1946. //redStyle.Border = *border
  1947. var sheetName string
  1948. sheetName = "PV"
  1949. sheet, err := xlsxFile.AddSheet(sheetName)
  1950. if err != nil {
  1951. fmt.Println(err)
  1952. return
  1953. }
  1954. //标头
  1955. rowTitle := sheet.AddRow()
  1956. cellAt := rowTitle.AddCell()
  1957. cellAt.Value = "标题"
  1958. cellPd := rowTitle.AddCell()
  1959. cellPd.Value = "发布时间"
  1960. cellA := rowTitle.AddCell()
  1961. cellA.Value = "姓名"
  1962. cellB := rowTitle.AddCell()
  1963. cellB.Value = "手机号"
  1964. cellC := rowTitle.AddCell()
  1965. cellC.Value = "公司名称"
  1966. cellD := rowTitle.AddCell()
  1967. cellD.Value = "所属销售"
  1968. cellDCreatedTime := rowTitle.AddCell()
  1969. cellDCreatedTime.Value = "阅读时间(最后一次)"
  1970. cellE := rowTitle.AddCell()
  1971. cellE.Value = "停留时长(多次合计))"
  1972. cellF := rowTitle.AddCell()
  1973. cellF.Value = "阅读来源"
  1974. cellStatus := rowTitle.AddCell()
  1975. cellStatus.Value = "客户状态"
  1976. cellTc := rowTitle.AddCell()
  1977. cellTc.Value = "签约套餐"
  1978. for _, v := range listart {
  1979. articleId := v.ArticleId
  1980. condition = ` AND h.company_id != ` + strconv.Itoa(utils.HZ_COMPANY_ID) // 过滤弘则
  1981. list, err := cygx.GetArticleHistoryList(articleId, condition)
  1982. if err != nil {
  1983. fmt.Println(err)
  1984. return
  1985. }
  1986. //上一次的阅读记录
  1987. list_H, err := cygx.GetArticleHistoryList_H(articleId, condition)
  1988. if err != nil {
  1989. fmt.Println(err)
  1990. return
  1991. }
  1992. mapArticle_H := make(map[string]bool)
  1993. for _, vPv := range list_H {
  1994. if !utils.ValidateMobileFormatat(vPv.Mobile) {
  1995. continue
  1996. }
  1997. mapArticle_H[fmt.Sprint("m_", vPv.Mobile, "a_", vPv.ArticleId)] = true
  1998. }
  1999. listClPv, err := cygx.GetCygxCelueArticleHistoryRecordPvAll(strconv.Itoa(articleId))
  2000. if err != nil && err.Error() != utils.ErrNoRow() {
  2001. fmt.Println(err)
  2002. return
  2003. }
  2004. listClPv_H, err := cygx.GetCygxCelueArticleHistoryRecordPvAll_H(strconv.Itoa(articleId))
  2005. if err != nil && err.Error() != utils.ErrNoRow() {
  2006. fmt.Println(err)
  2007. return
  2008. }
  2009. for _, vPv := range listClPv_H {
  2010. if !utils.ValidateMobileFormatat(vPv.Mobile) {
  2011. continue
  2012. }
  2013. mapArticle_H[fmt.Sprint("m_", vPv.Mobile, "a_", vPv.ArticleId)] = true
  2014. }
  2015. var listDate []*cygx.ArticleHistoryRep
  2016. var mobiles []string
  2017. var mapMobileCy = make(map[string]bool)
  2018. var mapMobileCl = make(map[string]bool)
  2019. mapstopTime := make(map[string]int)
  2020. if len(list) > 0 {
  2021. for _, vPv := range list {
  2022. if !utils.ValidateMobileFormatat(vPv.Mobile) {
  2023. continue
  2024. }
  2025. if mapArticle_H[fmt.Sprint("m_", vPv.Mobile, "a_", vPv.ArticleId)] {
  2026. continue
  2027. }
  2028. mobiles = append(mobiles, vPv.Mobile)
  2029. stopTime, _ := strconv.Atoi(vPv.StopTime)
  2030. mapstopTime[vPv.Mobile] += stopTime
  2031. }
  2032. }
  2033. if len(listClPv) > 0 {
  2034. for _, vPv := range listClPv {
  2035. if !utils.ValidateMobileFormatat(vPv.Mobile) {
  2036. continue
  2037. }
  2038. vPv.Ly = "1"
  2039. //if vPv.Mobile != "" {
  2040. mobiles = append(mobiles, vPv.Mobile)
  2041. //}
  2042. if mapArticle_H[fmt.Sprint("m_", vPv.Mobile, "a_", vPv.ArticleId)] {
  2043. continue
  2044. }
  2045. }
  2046. }
  2047. listUser, err := models.GetWxUserRaiSllerListByUserMobile(mobiles)
  2048. if err != nil {
  2049. fmt.Println(err)
  2050. return
  2051. }
  2052. listUserFicc, err := models.GetWxUserRaiSllerListByUserMobileFiic(mobiles)
  2053. if err != nil {
  2054. fmt.Println(err)
  2055. return
  2056. }
  2057. mapuserMapbil := make(map[string]*models.WxUserSller)
  2058. var companyIds []int
  2059. for _, vuser := range listUser {
  2060. //mapuserMapbil[vuser.Mobile] = vuser
  2061. companyIds = append(companyIds, vuser.CompanyId)
  2062. }
  2063. //合并合同所对应的权限
  2064. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapByIds(companyIds)
  2065. if err != nil {
  2066. fmt.Println(err)
  2067. return
  2068. }
  2069. //fmt.Println(companyIds)
  2070. //for k, vuser := range mappermissionName {
  2071. // fmt.Println(k, vuser)
  2072. //}
  2073. //fmt.Println(mappermissionName)
  2074. for _, vuser := range listUser {
  2075. vuser.ChartPermissionName = mappermissionName[vuser.CompanyId]
  2076. mapuserMapbil[vuser.Mobile] = vuser
  2077. }
  2078. for _, vuser := range listUserFicc {
  2079. vuser.Status = ""
  2080. vuser.SellerName = ""
  2081. if mapuserMapbil[vuser.Mobile] == nil {
  2082. mapuserMapbil[vuser.Mobile] = vuser
  2083. }
  2084. }
  2085. if len(list) > 0 {
  2086. for _, vPv := range list {
  2087. if !utils.ValidateMobileFormatat(vPv.Mobile) || mapMobileCy[vPv.Mobile] {
  2088. continue
  2089. }
  2090. if mapArticle_H[fmt.Sprint("m_", vPv.Mobile, "a_", vPv.ArticleId)] {
  2091. continue
  2092. }
  2093. mapMobileCy[vPv.Mobile] = true
  2094. listDate = append(listDate, vPv)
  2095. }
  2096. }
  2097. if len(listClPv) > 0 {
  2098. for _, vPv := range listClPv {
  2099. if !utils.ValidateMobileFormatat(vPv.Mobile) || mapMobileCl[vPv.Mobile] {
  2100. continue
  2101. }
  2102. if mapArticle_H[fmt.Sprint("m_", vPv.Mobile, "a_", vPv.ArticleId)] {
  2103. continue
  2104. }
  2105. mapMobileCl[vPv.Mobile] = true
  2106. listDate = append(listDate, vPv)
  2107. }
  2108. }
  2109. //rowtitle := sheet.AddRow()
  2110. //cellADatatitle := rowtitle.AddCell()
  2111. //cellADatatitle.Value = v.Title
  2112. for _, item := range listDate {
  2113. row := sheet.AddRow()
  2114. cellADatatitle := row.AddCell()
  2115. cellADatatitle.Value = v.Title
  2116. cellADataPd := row.AddCell()
  2117. cellADataPd.Value = v.PublishDate
  2118. cellAData := row.AddCell()
  2119. cellAData.Value = item.RealName
  2120. //if item.Ly == "1" {
  2121. // cellAData.SetStyle(redStyle)
  2122. //}
  2123. cellBData := row.AddCell()
  2124. cellBData.Value = item.Mobile
  2125. cellCData := row.AddCell()
  2126. //cellCData.Value = item.CompanyName
  2127. cellDData := row.AddCell()
  2128. //cellDData.Value = item.SellerName
  2129. cellEData := row.AddCell()
  2130. cellEData.Value = item.CreateTime
  2131. cellFData := row.AddCell()
  2132. if item.Ly == "" {
  2133. cellFData.Value = strconv.Itoa(mapstopTime[item.Mobile])
  2134. }
  2135. //fmt.Println(item.Source)
  2136. cellLyData := row.AddCell()
  2137. switch item.Source {
  2138. case "MOBILE":
  2139. cellLyData.Value = "小程序"
  2140. case "WEB":
  2141. cellLyData.Value = "网页版"
  2142. case "CELUE":
  2143. cellLyData.Value = "vmp"
  2144. }
  2145. cellStatusData := row.AddCell()
  2146. cellermissionNameData := row.AddCell()
  2147. if mapuserMapbil[item.Mobile] != nil {
  2148. cellCData.Value = mapuserMapbil[item.Mobile].CompanyName
  2149. cellDData.Value = mapuserMapbil[item.Mobile].SellerName
  2150. cellStatusData.Value = mapuserMapbil[item.Mobile].Status
  2151. cellermissionNameData.Value = mapuserMapbil[item.Mobile].ChartPermissionName
  2152. }
  2153. }
  2154. err = xlsxFile.Save(downLoadnFilePath)
  2155. if err != nil {
  2156. fmt.Println(err)
  2157. return
  2158. }
  2159. }
  2160. }
  2161. func initAct() {
  2162. var condition string
  2163. mapMobile := make(map[string]bool)
  2164. //condition = " AND s.activity_id = 5747 AND duration != '' AND s.create_time < '2024-08-28 18:00:00' "
  2165. //condition = " AND s.activity_id = 5734 AND is_meeting = 1 AND s.create_time < '2024-08-28 18:00:00' "
  2166. //list_H, err := cygx.GetActivityMeetByUser(condition, 0, 1000)
  2167. //if err != nil && err.Error() != utils.ErrNoRow() {
  2168. // fmt.Println(err)
  2169. // return
  2170. //}
  2171. //
  2172. //
  2173. //for _, v := range list_H {
  2174. // mapMobile[v.Mobile] = true
  2175. //}
  2176. //condition = " AND s.activity_id = 5833 AND duration != '' "
  2177. condition = " AND s.activity_id = 5832 AND duration != '' " // 2024-09-06 09:20
  2178. //condition = " AND s.activity_id = 5805 AND is_meeting = 1 "
  2179. list, err := cygx.GetActivityMeetByUser(condition, 0, 1000)
  2180. if err != nil && err.Error() != utils.ErrNoRow() {
  2181. fmt.Println(err)
  2182. return
  2183. }
  2184. var companyIds []int
  2185. for _, vuser := range list {
  2186. //mapuserMapbil[vuser.Mobile] = vuser
  2187. companyIds = append(companyIds, vuser.CompanyId)
  2188. }
  2189. mapuserMapbil := make(map[int]*models.WxUserSller)
  2190. listCompany, err := models.GetWxUserRaiSllerListByUserComapnyId(companyIds)
  2191. if err != nil {
  2192. fmt.Println(err)
  2193. return
  2194. }
  2195. //合并合同所对应的权限
  2196. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapByIds(companyIds)
  2197. if err != nil {
  2198. fmt.Println(err)
  2199. return
  2200. }
  2201. for _, v := range listCompany {
  2202. v.ChartPermissionName = mappermissionName[v.CompanyId]
  2203. mapuserMapbil[v.CompanyId] = v
  2204. }
  2205. listCompanyFicc, err := models.GetWxUserRaiSllerListByUserComapnyIdFicc(companyIds)
  2206. if err != nil {
  2207. fmt.Println(err)
  2208. return
  2209. }
  2210. for _, v := range listCompanyFicc {
  2211. if mapuserMapbil[v.CompanyId] != nil {
  2212. continue
  2213. }
  2214. v.Status = ""
  2215. v.SellerName = ""
  2216. mapuserMapbil[v.CompanyId] = v
  2217. }
  2218. //创建excel
  2219. dir, err := os.Executable()
  2220. exPath := filepath.Dir(dir)
  2221. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  2222. xlsxFile := xlsx.NewFile()
  2223. if err != nil {
  2224. fmt.Println(err)
  2225. return
  2226. }
  2227. style := xlsx.NewStyle()
  2228. alignment := xlsx.Alignment{
  2229. Horizontal: "center",
  2230. Vertical: "center",
  2231. WrapText: true,
  2232. }
  2233. style.Alignment = alignment
  2234. style.ApplyAlignment = true
  2235. redStyle := xlsx.NewStyle()
  2236. redStyle.Alignment = alignment
  2237. redStyle.ApplyAlignment = true
  2238. redStyle.Font.Color = "ff0000"
  2239. //定义底色需要标黄的 单元格颜色
  2240. redFill := xlsx.Fill{"solid", "ffff00", "ffff00"}
  2241. redStyle.Fill = redFill
  2242. //redStyle.Border = *border
  2243. var sheetName string
  2244. sheetName = "到会信息"
  2245. sheet, err := xlsxFile.AddSheet(sheetName)
  2246. if err != nil {
  2247. fmt.Println(err)
  2248. return
  2249. }
  2250. //标头
  2251. rowTitle := sheet.AddRow()
  2252. cellA := rowTitle.AddCell()
  2253. cellA.Value = "姓名"
  2254. cellB := rowTitle.AddCell()
  2255. cellB.Value = "手机号"
  2256. cellC := rowTitle.AddCell()
  2257. cellC.Value = "公司名称"
  2258. cellD := rowTitle.AddCell()
  2259. cellD.Value = "所属销售"
  2260. cellStatus := rowTitle.AddCell()
  2261. cellStatus.Value = "客户状态"
  2262. cellTc := rowTitle.AddCell()
  2263. cellTc.Value = "签约套餐"
  2264. for _, item := range list {
  2265. if mapMobile[item.Mobile] {
  2266. continue
  2267. }
  2268. row := sheet.AddRow()
  2269. cellAData := row.AddCell()
  2270. cellAData.Value = item.RealName
  2271. //if item.Ly == "1" {
  2272. // cellAData.SetStyle(redStyle)
  2273. //}
  2274. cellBData := row.AddCell()
  2275. cellBData.Value = item.Mobile
  2276. cellCData := row.AddCell()
  2277. //cellCData.Value = item.CompanyName
  2278. cellDData := row.AddCell()
  2279. //cellDData.Value = item.SellerName
  2280. cellStatusData := row.AddCell()
  2281. cellermissionNameData := row.AddCell()
  2282. if mapuserMapbil[item.CompanyId] != nil {
  2283. cellCData.Value = mapuserMapbil[item.CompanyId].CompanyName
  2284. cellDData.Value = mapuserMapbil[item.CompanyId].SellerName
  2285. cellStatusData.Value = mapuserMapbil[item.CompanyId].Status
  2286. cellermissionNameData.Value = mapuserMapbil[item.CompanyId].ChartPermissionName
  2287. }
  2288. }
  2289. err = xlsxFile.Save(downLoadnFilePath)
  2290. if err != nil {
  2291. fmt.Println(err)
  2292. return
  2293. }
  2294. }
  2295. func initarta() {
  2296. //行业
  2297. var condition string
  2298. var pars []interface{}
  2299. condition += ` AND share_seller_id In (702,703,704,707) `
  2300. listProduct, err := company.GetCompanyProductList(condition, pars)
  2301. if err != nil {
  2302. fmt.Println(err)
  2303. return
  2304. }
  2305. var companyIds []int
  2306. mapSeller := make(map[int]string)
  2307. for _, v := range listProduct {
  2308. companyIds = append(companyIds, v.CompanyId)
  2309. mapSeller[v.CompanyId] = v.ShareSeller
  2310. }
  2311. //报告匹配类型
  2312. pars = make([]interface{}, 0)
  2313. condition = ` AND re.chart_permission_id IN (23,53) `
  2314. listart, err := cygx.GetReportArticleList(condition, pars, 0, 4000, 1)
  2315. if err != nil {
  2316. fmt.Println(err)
  2317. return
  2318. }
  2319. mapArticleTitle := make(map[int]string)
  2320. mapchart_permission_name := make(map[int]string)
  2321. var articleIds []int
  2322. for _, v := range listart {
  2323. mapArticleTitle[v.ArticleId] = v.Title
  2324. mapchart_permission_name[v.ArticleId] = v.ChartPermissionName
  2325. articleIds = append(articleIds, v.ArticleId)
  2326. }
  2327. //创建excel
  2328. dir, err := os.Executable()
  2329. exPath := filepath.Dir(dir)
  2330. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  2331. xlsxFile := xlsx.NewFile()
  2332. if err != nil {
  2333. fmt.Println(err)
  2334. return
  2335. }
  2336. style := xlsx.NewStyle()
  2337. alignment := xlsx.Alignment{
  2338. Horizontal: "center",
  2339. Vertical: "center",
  2340. WrapText: true,
  2341. }
  2342. style.Alignment = alignment
  2343. style.ApplyAlignment = true
  2344. redStyle := xlsx.NewStyle()
  2345. redStyle.Alignment = alignment
  2346. redStyle.ApplyAlignment = true
  2347. redStyle.Font.Color = "ff0000"
  2348. //定义底色需要标黄的 单元格颜色
  2349. redFill := xlsx.Fill{"solid", "ffff00", "ffff00"}
  2350. redStyle.Fill = redFill
  2351. //redStyle.Border = *border
  2352. var sheetName string
  2353. sheetName = "PV"
  2354. sheet, err := xlsxFile.AddSheet(sheetName)
  2355. if err != nil {
  2356. fmt.Println(err)
  2357. return
  2358. }
  2359. //标头
  2360. rowTitle := sheet.AddRow()
  2361. cellA := rowTitle.AddCell()
  2362. cellA.Value = "姓名"
  2363. cellB := rowTitle.AddCell()
  2364. cellB.Value = "手机号"
  2365. cellC := rowTitle.AddCell()
  2366. cellC.Value = "公司名称"
  2367. cellD := rowTitle.AddCell()
  2368. cellD.Value = "服务销售"
  2369. cellDCreatedTime := rowTitle.AddCell()
  2370. cellDCreatedTime.Value = "最近阅读时间"
  2371. cellE := rowTitle.AddCell()
  2372. cellE.Value = "行业"
  2373. cellF := rowTitle.AddCell()
  2374. cellF.Value = "报告标题"
  2375. //articleId := v.ArticleId
  2376. //condition = ` AND h.company_id != ` + strconv.Itoa(utils.HZ_COMPANY_ID) // 过滤弘则
  2377. list, err := cygx.GetArticleHistoryListInit(articleIds, companyIds)
  2378. if err != nil {
  2379. fmt.Println(err)
  2380. return
  2381. }
  2382. mapMobile := make(map[string]bool)
  2383. for _, item := range list {
  2384. if mapMobile[item.Mobile] {
  2385. continue
  2386. }
  2387. row := sheet.AddRow()
  2388. cellAData := row.AddCell()
  2389. cellAData.Value = item.RealName
  2390. cellBData := row.AddCell()
  2391. cellBData.Value = item.Mobile
  2392. cellCData := row.AddCell()
  2393. cellCData.Value = item.CompanyName
  2394. cellDData := row.AddCell()
  2395. cellDData.Value = mapSeller[item.CompanyId]
  2396. cellEData := row.AddCell()
  2397. cellEData.Value = item.CreateTime
  2398. cellEcData := row.AddCell()
  2399. cellEcData.Value = mapchart_permission_name[item.ArticleId]
  2400. cellFData := row.AddCell()
  2401. cellFData.Value = mapArticleTitle[item.ArticleId]
  2402. mapMobile[item.Mobile] = true
  2403. }
  2404. err = xlsxFile.Save(downLoadnFilePath)
  2405. if err != nil {
  2406. fmt.Println(err)
  2407. return
  2408. }
  2409. }
  2410. func initActList() {
  2411. var condition string
  2412. var pars []interface{}
  2413. condition = " AND chart_permission_id = 31 AND activity_time >= '2024-03-01' AND activity_time <= '2024-09-21' AND activity_type_id = 3 AND publish_status = 1 AND yidong_activity_id = '' ORDER BY activity_time ASC "
  2414. list, errList := cygx.GetActivityListAll(condition, pars, 0, 999)
  2415. if errList != nil {
  2416. fmt.Println(errList)
  2417. return
  2418. }
  2419. //创建excel
  2420. dir, err := os.Executable()
  2421. exPath := filepath.Dir(dir)
  2422. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  2423. xlsxFile := xlsx.NewFile()
  2424. if err != nil {
  2425. fmt.Println(err)
  2426. return
  2427. }
  2428. style := xlsx.NewStyle()
  2429. alignment := xlsx.Alignment{
  2430. Horizontal: "center",
  2431. Vertical: "center",
  2432. WrapText: true,
  2433. }
  2434. style.Alignment = alignment
  2435. style.ApplyAlignment = true
  2436. redStyle := xlsx.NewStyle()
  2437. redStyle.Alignment = alignment
  2438. redStyle.ApplyAlignment = true
  2439. redStyle.Font.Color = "ff0000"
  2440. //定义底色需要标黄的 单元格颜色
  2441. redFill := xlsx.Fill{"solid", "ffff00", "ffff00"}
  2442. redStyle.Fill = redFill
  2443. //redStyle.Border = *border
  2444. var sheetName string
  2445. sheetName = "到会信息"
  2446. sheet, err := xlsxFile.AddSheet(sheetName)
  2447. if err != nil {
  2448. fmt.Println(err)
  2449. return
  2450. }
  2451. //标头
  2452. rowTitle := sheet.AddRow()
  2453. cellA := rowTitle.AddCell()
  2454. cellA.Value = "活动名称"
  2455. cellB := rowTitle.AddCell()
  2456. cellB.Value = "活动时间"
  2457. cellC := rowTitle.AddCell()
  2458. cellC.Value = "活动标签"
  2459. for _, item := range list {
  2460. row := sheet.AddRow()
  2461. cellAData := row.AddCell()
  2462. cellAData.Value = item.ActivityName
  2463. cellBData := row.AddCell()
  2464. cellBData.Value = item.ActivityTime
  2465. cellCData := row.AddCell()
  2466. cellCData.Value = item.Label
  2467. }
  2468. err = xlsxFile.Save(downLoadnFilePath)
  2469. if err != nil {
  2470. fmt.Println(err)
  2471. return
  2472. }
  2473. }
  2474. func initOrder() {
  2475. var condition string
  2476. var pars []interface{}
  2477. //condition = " WHERE 1 = 1 AND source In ('article','yanxuanspecial') AND order_status = 2 GROUP BY order_id ASC "
  2478. condition = " AND source In ('activity') AND order_status = 2 GROUP BY order_id DESC "
  2479. list, errList := cygx.GetCygxOrderList(condition, pars, 0, 9999)
  2480. if errList != nil {
  2481. fmt.Println(errList)
  2482. return
  2483. }
  2484. //创建excel
  2485. dir, err := os.Executable()
  2486. exPath := filepath.Dir(dir)
  2487. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  2488. xlsxFile := xlsx.NewFile()
  2489. if err != nil {
  2490. fmt.Println(err)
  2491. return
  2492. }
  2493. style := xlsx.NewStyle()
  2494. alignment := xlsx.Alignment{
  2495. Horizontal: "center",
  2496. Vertical: "center",
  2497. WrapText: true,
  2498. }
  2499. style.Alignment = alignment
  2500. style.ApplyAlignment = true
  2501. redStyle := xlsx.NewStyle()
  2502. redStyle.Alignment = alignment
  2503. redStyle.ApplyAlignment = true
  2504. redStyle.Font.Color = "ff0000"
  2505. //定义底色需要标黄的 单元格颜色
  2506. redFill := xlsx.Fill{"solid", "ffff00", "ffff00"}
  2507. redStyle.Fill = redFill
  2508. //redStyle.Border = *border
  2509. var sheetName string
  2510. sheetName = "活动"
  2511. sheet, err := xlsxFile.AddSheet(sheetName)
  2512. if err != nil {
  2513. fmt.Println(err)
  2514. return
  2515. }
  2516. //标头
  2517. rowTitle := sheet.AddRow()
  2518. cellA := rowTitle.AddCell()
  2519. cellA.Value = "姓名"
  2520. cellB := rowTitle.AddCell()
  2521. cellB.Value = "手机号"
  2522. cellC := rowTitle.AddCell()
  2523. cellC.Value = "公司名称"
  2524. cellMoney := rowTitle.AddCell()
  2525. cellMoney.Value = "金额"
  2526. cellname := rowTitle.AddCell()
  2527. cellname.Value = "活动名称"
  2528. cellTime := rowTitle.AddCell()
  2529. cellTime.Value = "支付时间"
  2530. for _, item := range list {
  2531. row := sheet.AddRow()
  2532. cellAData := row.AddCell()
  2533. cellAData.Value = item.RealName
  2534. cellBData := row.AddCell()
  2535. cellBData.Value = item.Mobile
  2536. cellCData := row.AddCell()
  2537. cellCData.Value = item.CompanyName
  2538. cellCMoneyData := row.AddCell()
  2539. cellCMoneyData.Value = fmt.Sprint(item.PayMoney)
  2540. cellCnameData := row.AddCell()
  2541. cellCnameData.Value = item.SourceTitle
  2542. cellTimeata := row.AddCell()
  2543. cellTimeata.Value = item.PayTime.Format(utils.FormatDateTime)
  2544. }
  2545. err = xlsxFile.Save(downLoadnFilePath)
  2546. if err != nil {
  2547. fmt.Println(err)
  2548. return
  2549. }
  2550. }
  2551. func initOrderArticle() {
  2552. var condition string
  2553. var pars []interface{}
  2554. condition = " AND source In ('article','yanxuanspecial') AND order_status = 2 GROUP BY order_id DESC "
  2555. list, errList := cygx.GetCygxOrderList(condition, pars, 0, 9999)
  2556. if errList != nil {
  2557. fmt.Println(errList)
  2558. return
  2559. }
  2560. var articleIds []int
  2561. var yanxuanArticleids []int
  2562. for _, v := range list {
  2563. if v.Source == "article" {
  2564. articleIds = append(articleIds, v.SourceId)
  2565. }
  2566. if v.Source == "yanxuanspecial" {
  2567. yanxuanArticleids = append(yanxuanArticleids, v.SourceId)
  2568. }
  2569. }
  2570. pars = make([]interface{}, 0)
  2571. condition = " AND art.article_id IN (" + utils.GetOrmInReplace(len(articleIds)) + ") GROUP BY art.article_id "
  2572. pars = append(pars, articleIds)
  2573. mapArtcileNickName := make(map[int]string)
  2574. listartcile, errList := cygx.GetSummaryManageListInit(condition, pars, 0, 999)
  2575. if errList != nil {
  2576. fmt.Println(errList)
  2577. return
  2578. }
  2579. for _, v := range listartcile {
  2580. mapArtcileNickName[v.ArticleId] = v.NickName
  2581. }
  2582. //fmt.Println(mapArtcileNickName)
  2583. //return
  2584. pars = make([]interface{}, 0)
  2585. condition = " AND a.id IN (" + utils.GetOrmInReplace(len(yanxuanArticleids)) + ") "
  2586. pars = append(pars, yanxuanArticleids)
  2587. mapArtcileNickNameYx := make(map[int]string)
  2588. listartcileYx, errList := cygx.GetYanxuanSpecialList(condition, pars, 0, 999)
  2589. if errList != nil {
  2590. fmt.Println(errList)
  2591. return
  2592. }
  2593. for _, v := range listartcileYx {
  2594. mapArtcileNickNameYx[v.Id] = v.NickName
  2595. }
  2596. //创建excel
  2597. dir, err := os.Executable()
  2598. exPath := filepath.Dir(dir)
  2599. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  2600. xlsxFile := xlsx.NewFile()
  2601. if err != nil {
  2602. fmt.Println(err)
  2603. return
  2604. }
  2605. style := xlsx.NewStyle()
  2606. alignment := xlsx.Alignment{
  2607. Horizontal: "center",
  2608. Vertical: "center",
  2609. WrapText: true,
  2610. }
  2611. style.Alignment = alignment
  2612. style.ApplyAlignment = true
  2613. redStyle := xlsx.NewStyle()
  2614. redStyle.Alignment = alignment
  2615. redStyle.ApplyAlignment = true
  2616. redStyle.Font.Color = "ff0000"
  2617. //定义底色需要标黄的 单元格颜色
  2618. redFill := xlsx.Fill{"solid", "ffff00", "ffff00"}
  2619. redStyle.Fill = redFill
  2620. //redStyle.Border = *border
  2621. var sheetName string
  2622. sheetName = "活动"
  2623. sheet, err := xlsxFile.AddSheet(sheetName)
  2624. if err != nil {
  2625. fmt.Println(err)
  2626. return
  2627. }
  2628. //标头
  2629. rowTitle := sheet.AddRow()
  2630. cellA := rowTitle.AddCell()
  2631. cellA.Value = "姓名"
  2632. cellB := rowTitle.AddCell()
  2633. cellB.Value = "手机号"
  2634. cellC := rowTitle.AddCell()
  2635. cellC.Value = "公司名称"
  2636. cellMoney := rowTitle.AddCell()
  2637. cellMoney.Value = "金额"
  2638. cellname := rowTitle.AddCell()
  2639. cellname.Value = "报告标题"
  2640. cellNickename := rowTitle.AddCell()
  2641. cellNickename.Value = "作者"
  2642. cellTime := rowTitle.AddCell()
  2643. cellTime.Value = "支付时间"
  2644. for _, item := range list {
  2645. row := sheet.AddRow()
  2646. cellAData := row.AddCell()
  2647. cellAData.Value = item.RealName
  2648. cellBData := row.AddCell()
  2649. cellBData.Value = item.Mobile
  2650. cellCData := row.AddCell()
  2651. cellCData.Value = item.CompanyName
  2652. cellCMoneyData := row.AddCell()
  2653. cellCMoneyData.Value = fmt.Sprint(item.PayMoney)
  2654. cellCnameData := row.AddCell()
  2655. cellCnameData.Value = item.SourceTitle
  2656. cellNickenameData := row.AddCell()
  2657. if item.Source == "article" {
  2658. fmt.Println(mapArtcileNickName[item.SourceId])
  2659. cellNickenameData.Value = mapArtcileNickName[item.SourceId]
  2660. }
  2661. if item.Source == "yanxuanspecial" {
  2662. cellNickenameData.Value = mapArtcileNickNameYx[item.SourceId]
  2663. }
  2664. cellTimeata := row.AddCell()
  2665. cellTimeata.Value = item.PayTime.Format(utils.FormatDateTime)
  2666. }
  2667. err = xlsxFile.Save(downLoadnFilePath)
  2668. if err != nil {
  2669. fmt.Println(err)
  2670. return
  2671. }
  2672. }