activity_special.go 36 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052
  1. package services
  2. import (
  3. "errors"
  4. "fmt"
  5. "hongze/hongze_clpt/models"
  6. "hongze/hongze_clpt/utils"
  7. "strconv"
  8. "strings"
  9. "time"
  10. )
  11. //func init() {
  12. // UpdateCygxActivitySpecialSignupNum()
  13. //}
  14. func ActivityLabelSpecialSql(chartPermissionIds, whichDay, activeState string) (condition string) {
  15. //行业名称
  16. if len(chartPermissionIds) > 0 {
  17. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  18. }
  19. if whichDay != "" {
  20. var startDate string
  21. var endDate string
  22. if whichDay == "1" {
  23. startDate = time.Now().Format(utils.FormatDate)
  24. endDate = startDate
  25. } else if whichDay == "2" {
  26. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  27. endDate = startDate
  28. } else if whichDay == "1,2" || whichDay == "2,1" {
  29. startDate = time.Now().Format(utils.FormatDate)
  30. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  31. } else if whichDay == "3" {
  32. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  33. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  34. } else if whichDay == "4" {
  35. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  36. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  37. } else if whichDay == "5" {
  38. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  39. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  40. } else if whichDay == "6" {
  41. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  42. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  43. } else if whichDay == "3,4" || whichDay == "4,3" {
  44. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  45. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  46. } else if whichDay == "5,6" || whichDay == "6,5" {
  47. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  48. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  49. } else {
  50. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  51. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  52. }
  53. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  54. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  55. }
  56. if activeState == "2" {
  57. condition += ` AND art.days > 0 AND art.activity_time <= ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  58. condition += ` AND art.activity_time_end >= ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  59. }
  60. if activeState == "3" {
  61. condition += ` AND art.days > 0 AND art.activity_time_end <= ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  62. }
  63. //if activeState != "3" {
  64. // condition += ` AND art.activity_time_end > ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  65. //}
  66. //if activeState == "" && whichDay == "" {
  67. // condition += ` AND art.activity_time_end > ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  68. //}
  69. if whichDay != "" {
  70. condition += ` AND art.days > 0 `
  71. }
  72. condition += ` AND art.label != '' AND art.is_offline = 0 `
  73. if activeState == "1" {
  74. condition = condition + ` AND art.days > 0 AND art.activity_time_end > ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  75. }
  76. return
  77. }
  78. // ActivityLabelSpecialUserSql 专项产业调研用户权限查询数据预处理
  79. func ActivityLabelSpecialUserSql(user *models.WxUserItem) (conditionShengji, conditionZhengshi, conditionHangYe string, err error) {
  80. _, userType, e := HandleActivityLabelSpecialTripPermission(user)
  81. if e != nil {
  82. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  83. return
  84. }
  85. // 8: 行业升级套餐客户:该活动对应行业为升级权限的客户
  86. permissionShengji, errs := models.GetCompanyPermissionByUserZhengShiTrip(user.CompanyId)
  87. if errs != nil {
  88. err = errs
  89. return
  90. }
  91. if permissionShengji != "" {
  92. slicePerShengji := strings.Split(permissionShengji, ",")
  93. permissionShengji = ""
  94. for _, v := range slicePerShengji {
  95. permissionShengji += "'" + v + "',"
  96. }
  97. permissionShengji = strings.TrimRight(permissionShengji, ",")
  98. conditionShengji = ` art.customer_type_ids LIKE '%8%' AND art.chart_permission_name IN (` + permissionShengji + `)`
  99. }
  100. //9:其他行业正式客户:前述所有正式客户以外的正式客户 查询处理
  101. permissionZhengShiStr, errs := models.GetCompanyPermissionByUserZhengShi(user.CompanyId)
  102. if errs != nil {
  103. err = errs
  104. return
  105. }
  106. if permissionZhengShiStr != "" {
  107. slicePerZhengshi := strings.Split(permissionZhengShiStr, ",")
  108. permissionZhengShiStr = ""
  109. for _, v := range slicePerZhengshi {
  110. if userType == 1 {
  111. //研选权限处理(永续客户无法查看研选)
  112. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  113. permissionZhengShiStr += "'" + v + "',"
  114. }
  115. } else {
  116. permissionZhengShiStr += "'" + v + "',"
  117. }
  118. }
  119. permissionZhengShiStr = strings.Replace(permissionZhengShiStr, "(主观)", "", -1)
  120. permissionZhengShiStr = strings.Replace(permissionZhengShiStr, "(客观)", "", -1)
  121. permissionZhengShiStr = strings.TrimRight(permissionZhengShiStr, ",")
  122. permissionZhengShiStr += `, '宏观'`
  123. if userType != 1 && userType != 2 && userType != 10 {
  124. conditionHangYe = ` art.customer_type_ids LIKE '%3%' AND art.chart_permission_name IN (` + permissionZhengShiStr + `)`
  125. }
  126. if userType == 3 {
  127. conditionZhengshi = ` art.customer_type_ids LIKE '%9%' AND art.chart_permission_name NOT IN (` + permissionZhengShiStr + `)`
  128. }
  129. }
  130. return
  131. }
  132. // 处理专项调研的展示
  133. func GetActivityLabelSpecialList(user *models.WxUserItem, conditionActivitySpecial string) (item *models.ActivityTypeHome, err error) {
  134. itemList := new(models.ActivityTypeHome)
  135. if user.CompanyId <= 1 {
  136. itemList.List = make([]*models.CygxActivityLabelList, 0)
  137. item = itemList
  138. return
  139. }
  140. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(user.CompanyId)
  141. if e != nil && e.Error() != utils.ErrNoRow() {
  142. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  143. return
  144. }
  145. if companyDetail == nil {
  146. return
  147. }
  148. //如果是永续的就按照普通的权限逻辑来查,如果不是就按照升级的逻辑来查
  149. var condition string
  150. var conditionUser string
  151. //var userType int
  152. if companyDetail.Status == "永续" {
  153. conditionUser, e = HandleActivityLabelSpecialPermission(user)
  154. if e != nil {
  155. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  156. return
  157. }
  158. } else {
  159. conditionUser, _, e = HandleActivityLabelSpecialTripPermission(user)
  160. if e != nil {
  161. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  162. return
  163. }
  164. }
  165. var pars []interface{}
  166. condition += ` AND art.publish_status = 1 AND art.label != '' AND art.is_offline = 0 ` + conditionActivitySpecial
  167. conditionTrip := condition
  168. conditionTripSql := condition
  169. conditionNoTrip := condition
  170. conditionNoTripSql := condition
  171. //condition += conditionUser
  172. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  173. if e != nil {
  174. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  175. return
  176. }
  177. conditionTrip += ` AND art.days > 0 AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + ` '`
  178. var conditionZhengshiTrip string
  179. var conditionShengjiTrip string
  180. var conditionHangYeTrip string
  181. //处理专项调研确认行程的其它正式客户权限查询
  182. if conditionZhengshi != "" {
  183. conditionZhengshiTrip = ` OR ( ` + conditionZhengshi + conditionTrip + ` )`
  184. }
  185. //处理升级权限查询
  186. if conditionShengji != "" {
  187. conditionShengjiTrip = ` OR ( ` + conditionShengji + conditionTrip + ` )`
  188. }
  189. //处理行业套餐客户权限查询
  190. if conditionHangYe != "" {
  191. conditionHangYeTrip = ` OR ( ` + conditionHangYe + conditionTrip + ` )`
  192. }
  193. if conditionZhengshi != "" {
  194. conditionTrip += conditionZhengshiTrip
  195. }
  196. if conditionShengjiTrip != "" {
  197. conditionTrip += conditionShengjiTrip
  198. }
  199. if conditionHangYeTrip != "" {
  200. conditionTrip += conditionHangYeTrip
  201. }
  202. conditionTripSql += conditionUser + conditionTrip + ` ORDER BY art.activity_time ASC `
  203. specialList, err := models.GetActivityLabelSpecialListAll(conditionTripSql, pars, 0, 80)
  204. if err != nil {
  205. return
  206. }
  207. //if len(specialList) < 80 {
  208. conditionNoTrip += ` AND art.days = 0 `
  209. var conditionShengjiNoTrip string
  210. var conditionZhengshiNoTrip string
  211. var conditionHangYeNoTrip string
  212. if conditionShengji != "" {
  213. conditionShengjiNoTrip = ` OR ( ` + conditionShengji + conditionNoTrip + ` )`
  214. }
  215. if conditionZhengshi != "" {
  216. conditionZhengshiNoTrip = ` OR ( ` + conditionZhengshi + conditionNoTrip + ` )`
  217. }
  218. if conditionHangYe != "" {
  219. conditionHangYeNoTrip = ` OR ( ` + conditionHangYe + conditionNoTrip + ` )`
  220. }
  221. if conditionShengji != "" {
  222. conditionNoTrip += conditionShengjiNoTrip
  223. }
  224. if conditionZhengshi != "" {
  225. conditionNoTrip += conditionZhengshiNoTrip
  226. }
  227. if conditionHangYe != "" {
  228. conditionNoTrip += conditionHangYeNoTrip
  229. }
  230. conditionNoTripSql += conditionUser + conditionNoTrip + ` ORDER BY art.last_updated_time DESC`
  231. specialListNotrip, e := models.GetActivityLabelSpecialListAll(conditionNoTripSql, pars, 0, 200)
  232. if e != nil {
  233. err = e
  234. return
  235. }
  236. for _, v := range specialListNotrip {
  237. specialList = append(specialList, v)
  238. }
  239. //}
  240. for k2, v2 := range specialList {
  241. v2.Resource = 2
  242. if v2.Days == 0 {
  243. specialList[k2].TripStatus = 1
  244. } else {
  245. specialList[k2].TripStatus = 2
  246. }
  247. specialList[k2].KeyWord = LabelStr(v2.KeyWord, v2.IsShowSubjectName, v2.TemporaryLabel)
  248. specialList[k2].ImgUrlBg = "https://hzstatic.hzinsights.com/static/temp/20220426202204/20220426/XDLLsjC9XAAy8LIzQr7GsjrBbtX6.png"
  249. specialList[k2].ImgUrlBg = utils.ACTIVITY_ZXDY_ImgUrl3
  250. }
  251. itemList.ActivityTypeName = "专项产业调研"
  252. itemList.Resource = 2
  253. itemList.List = specialList
  254. itemList.ActivityTypeId = 7
  255. itemList.OnlineIco = utils.ACTIVITY_ZXDY_ImgUrl1
  256. itemList.ImgUrlBgPc = utils.ACTIVITY_ZXDY_ImgUrl2
  257. item = itemList
  258. return
  259. }
  260. // HandleActivityLabelSpecialPermission 处理专项产业调研的查询权限sql 永续
  261. func HandleActivityLabelSpecialPermission(user *models.WxUserItem) (condition string, err error) {
  262. permissionStr, e := GetCompanyPermission(user.CompanyId)
  263. if e != nil {
  264. err = errors.New("GetCompanyPermission, Err: " + e.Error())
  265. return
  266. }
  267. userType, e := GetSpecialUserType(user)
  268. if e != nil {
  269. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  270. return
  271. }
  272. slicePer := strings.Split(permissionStr, ",")
  273. var permissionSqlStr string
  274. for _, v := range slicePer {
  275. if userType == 1 {
  276. if !strings.Contains(v, "研选") {
  277. permissionSqlStr += "'" + v + "',"
  278. }
  279. } else {
  280. permissionSqlStr += "'" + v + "',"
  281. }
  282. }
  283. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  284. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.is_offline = 0 `
  285. //if permissionSqlStr != "" {
  286. // condition += ` AND art.chart_permission_name IN (` + permissionSqlStr + `) `
  287. //}
  288. condition += ` AND art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  289. return
  290. }
  291. // HandleActivityLabelSpecialPermisseion 处理专项产业调研的查询权限sql
  292. // HandleActivityLabelSpecialPermisseion 处理专项产业调研的查询权限sql
  293. func HandleActivityLabelSpecialTripPermission(user *models.WxUserItem) (condition string, userType int, err error) {
  294. permissionStr, e := GetCompanyPermission(user.CompanyId)
  295. if e != nil {
  296. err = errors.New("GetCompanyPermission, Err: " + e.Error())
  297. return
  298. }
  299. userType, _, e = GetUserType(user.CompanyId)
  300. //userType, e := GetSpecialUserType(user)
  301. if e != nil {
  302. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  303. return
  304. }
  305. mapUserType, e := GetActivityCcustomerTypeList()
  306. if e != nil {
  307. err = e
  308. return
  309. }
  310. var userTypeStr string
  311. userTypeStr = mapUserType[userType]
  312. //fmt.Println(userType)
  313. slicePer := strings.Split(permissionStr, ",")
  314. var permissionSqlStr string
  315. for _, v := range slicePer {
  316. if userType == 1 {
  317. if !strings.Contains(v, "研选") {
  318. permissionSqlStr += "'" + v + "',"
  319. }
  320. } else {
  321. permissionSqlStr += "'" + v + "',"
  322. }
  323. }
  324. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  325. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.is_offline = 0 `
  326. if permissionSqlStr != "" && userType == 3 {
  327. condition += ` AND art.chart_permission_name IN (` + permissionSqlStr + `) `
  328. }
  329. condition += ` AND art.customer_type_ids LIKE '%` + userTypeStr + `%' `
  330. //if userType != 2 {
  331. return
  332. }
  333. // 获取预报名列表
  334. func GetActivitySpecialPrepareList(user *models.WxUserItem, startSize, pageSize int, keywords, conditionActivity string) (list []*models.CygxActivitySpecialDetail, totalPrepare int, err error) {
  335. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(user.CompanyId)
  336. if e != nil && e.Error() != utils.ErrNoRow() {
  337. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  338. return
  339. }
  340. if companyDetail == nil {
  341. return
  342. }
  343. //如果是永续的就按照普通的权限逻辑来查,如果不是就按照升级的逻辑来查
  344. var condition string
  345. var conditionUser string
  346. if companyDetail.Status == "永续" {
  347. conditionUser, e = HandleActivityLabelSpecialPermission(user)
  348. if e != nil {
  349. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  350. return
  351. }
  352. } else {
  353. conditionUser, _, e = HandleActivityLabelSpecialTripPermission(user)
  354. if e != nil {
  355. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  356. return
  357. }
  358. }
  359. var pars []interface{}
  360. condition += ` AND art.days = 0 AND art.publish_status = 1 AND art.is_offline = 0 ` + conditionActivity
  361. if keywords != "" {
  362. keywords = "%" + keywords + "%"
  363. condition += ` AND art.research_theme LIKE ` + keywords
  364. }
  365. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  366. if e != nil {
  367. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  368. return
  369. }
  370. conditionNoTrip := condition
  371. var conditionShengjiNoTrip string
  372. var conditionZhengshiNoTrip string
  373. var conditionHangYeNoTrip string
  374. if conditionShengji != "" {
  375. conditionShengjiNoTrip = ` OR ( ` + conditionShengji + conditionNoTrip + ` )`
  376. }
  377. if conditionZhengshi != "" {
  378. conditionZhengshiNoTrip = ` OR ( ` + conditionZhengshi + conditionNoTrip + ` )`
  379. }
  380. //处理行业套餐权限查询
  381. if conditionHangYe != "" {
  382. conditionHangYeNoTrip = ` OR ( ` + conditionHangYe + conditionNoTrip + ` )`
  383. }
  384. if conditionShengji != "" {
  385. conditionNoTrip += conditionShengjiNoTrip
  386. }
  387. if conditionZhengshi != "" {
  388. conditionNoTrip += conditionZhengshiNoTrip
  389. }
  390. if conditionHangYe != "" {
  391. conditionNoTrip += conditionHangYeNoTrip
  392. }
  393. conditionNoTripSql := conditionUser + conditionNoTrip
  394. totalPrepare, e = models.GetActivitySpecialCount(conditionNoTripSql, pars)
  395. if e != nil {
  396. err = errors.New("GetActivitySpecialCount, Err: " + e.Error())
  397. return
  398. }
  399. conditionNoTripSql += ` ORDER BY art.last_updated_time DESC `
  400. list, e = models.GetCygxActivitySpecialDetailList(conditionNoTripSql, pars, user.UserId, startSize, pageSize)
  401. if e != nil {
  402. err = errors.New("GetCygxActivitySpecialDetailList, Err: " + e.Error())
  403. return
  404. }
  405. return
  406. }
  407. /*
  408. 确定行程的查询 GetActivityLabelSpecialConfirmList
  409. state 进行状态 1:未开始,2:进行中,3:已结束,4:未开始、进行中 不传默认查询全部items []*CygxActivitySpecialDetail
  410. */
  411. func GetActivityLabelSpecialConfirmList(user *models.WxUserItem, startSize, pageSize, state int, keywords, conditionActivity string) (list []*models.CygxActivitySpecialDetail, totalConfirm int, err error) {
  412. //var condition string
  413. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(user.CompanyId)
  414. if e != nil && e.Error() != utils.ErrNoRow() {
  415. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  416. return
  417. }
  418. if companyDetail == nil {
  419. return
  420. }
  421. //如果是永续的就按照普通的权限逻辑来查,如果不是就按照升级的逻辑来查
  422. var condition string
  423. var conditionUser string
  424. //var userType int
  425. if companyDetail.Status == "永续" {
  426. conditionUser, e = HandleActivityLabelSpecialPermission(user)
  427. if e != nil {
  428. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  429. return
  430. }
  431. } else {
  432. conditionUser, _, e = HandleActivityLabelSpecialTripPermission(user)
  433. if e != nil {
  434. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  435. return
  436. }
  437. }
  438. var pars []interface{}
  439. condition += ` AND art.days >0 AND art.publish_status =1 AND art.is_offline = 0 ` + conditionActivity
  440. if state == 1 {
  441. condition += ` AND art.activity_time > '` + time.Now().Format(utils.FormatDateTime) + `'`
  442. }
  443. if state == 2 {
  444. condition += ` AND art.activity_time < '` + time.Now().Format(utils.FormatDateTime) + `'`
  445. condition += ` AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + `'`
  446. }
  447. if state == 3 {
  448. condition += ` AND art.activity_time_end < '` + time.Now().Format(utils.FormatDateTime) + `'`
  449. }
  450. if state == 4 {
  451. condition += ` AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + `'`
  452. }
  453. if keywords != "" {
  454. keywords = "%" + keywords + "%"
  455. condition += ` AND art.research_theme LIKE ` + keywords
  456. }
  457. //condition += ` AND art.publish_status = 1 AND art.label != '' AND art.is_offline = 0 ` + conditionActivitySpecial
  458. conditionTrip := condition
  459. conditionTripSql := condition
  460. //condition += conditionUser
  461. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  462. if e != nil {
  463. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  464. return
  465. }
  466. conditionTrip += ` AND art.days > 0 AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + ` '`
  467. var conditionZhengshiTrip string
  468. var conditionShengjiTrip string
  469. var conditionHangYeTrip string
  470. //处理专项调研确认行程的其它正式客户权限查询
  471. if conditionZhengshi != "" {
  472. conditionZhengshiTrip = ` OR ( ` + conditionZhengshi + conditionTrip + ` )`
  473. }
  474. //处理专项调研确认行程的升级权限查询
  475. if conditionShengji != "" {
  476. conditionShengjiTrip = ` OR ( ` + conditionShengji + conditionTrip + ` )`
  477. }
  478. //处理行业套餐客户权限查询
  479. if conditionHangYe != "" {
  480. conditionHangYeTrip = ` OR ( ` + conditionHangYe + conditionTrip + ` )`
  481. }
  482. if conditionZhengshi != "" {
  483. conditionTrip += conditionZhengshiTrip
  484. }
  485. if conditionShengjiTrip != "" {
  486. conditionTrip += conditionShengjiTrip
  487. }
  488. if conditionHangYeTrip != "" {
  489. conditionTrip += conditionHangYeTrip
  490. }
  491. conditionTripSql += conditionUser + conditionTrip + ` ORDER BY art.activity_time ASC `
  492. //condition += conditionUser + conditionOr
  493. totalConfirm, e = models.GetActivitySpecialCount(conditionTripSql, pars)
  494. if e != nil {
  495. err = errors.New("GetActivitySpecialCount, Err: " + e.Error())
  496. return
  497. }
  498. condition += ` ORDER BY art.activity_time ASC `
  499. list, e = models.GetCygxActivitySpecialDetailList(conditionTripSql, pars, user.UserId, startSize, pageSize)
  500. if e != nil {
  501. err = errors.New("GetCygxActivitySpecialDetailList, Err: " + e.Error())
  502. return
  503. }
  504. var activityIds []int
  505. for k, v := range list {
  506. resultTimeStart := utils.StrTimeToTime(v.ActivityTime) //时间字符串格式转时间格式
  507. resultTimeEnd := utils.StrTimeToTime(v.ActivityTimeEnd) //时间字符串格式转时间格式
  508. if resultTimeStart.After(time.Now()) {
  509. list[k].ActiveState = strconv.Itoa(1)
  510. } else if time.Now().After(resultTimeEnd) {
  511. list[k].ActiveState = strconv.Itoa(3)
  512. } else {
  513. list[k].ActiveState = strconv.Itoa(2)
  514. }
  515. if list[k].Days == 0 {
  516. list[k].TripStatus = 1
  517. } else {
  518. list[k].TripStatus = 2
  519. }
  520. activityIds = append(activityIds, v.ActivityId)
  521. }
  522. //处理用户已经报名了的行程
  523. UserMap, e := GetSpecialTripUserMap(activityIds, user.UserId)
  524. if e != nil {
  525. err = errors.New("GetSpecialTripUserMap, Err: " + e.Error())
  526. return
  527. }
  528. for k, v := range list {
  529. if _, ok := UserMap[v.ActivityId]; ok {
  530. list[k].IsTrip = 1
  531. }
  532. }
  533. return
  534. }
  535. // 获取用户已经报名的活动
  536. func GetSpecialTripUserMap(activityIds []int, userId int) (mapUserId map[int]int, err error) {
  537. var condition string
  538. var pars []interface{}
  539. activityIdsLen := len(activityIds)
  540. if activityIdsLen > 0 {
  541. condition += ` AND activity_id IN (` + utils.GetOrmInReplace(activityIdsLen) + `)`
  542. pars = append(pars, activityIds)
  543. }
  544. condition += ` AND user_id = ? AND is_cancel = 0 `
  545. pars = append(pars, userId)
  546. list, e := models.GetCygxActivitySpecialTripList(condition, pars)
  547. if e != nil {
  548. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  549. return
  550. }
  551. mapUid := make(map[int]int)
  552. for _, v := range list {
  553. mapUid[v.ActivityId] = v.UserId
  554. }
  555. mapUserId = mapUid
  556. return
  557. }
  558. // 获取用户已经报名的活动数量
  559. func GetSpecialTripUserSchedule(userId int) (total int, err error) {
  560. var condition string
  561. var pars []interface{}
  562. condition += ` AND t.user_id = ? AND t.is_cancel = 0 `
  563. pars = append(pars, userId)
  564. condition += ` AND a.activity_time_end >= ? `
  565. pars = append(pars, time.Now())
  566. condition += ` AND is_valid = 1 `
  567. total, err = models.GetActivitySpecialTripCountByActivitySpecial(condition, pars)
  568. return
  569. }
  570. // GetActivitySpecialList 获取专项调研列表
  571. func GetActivitySpecialList(user *models.WxUserItem, currentIndex, pageSize int, keywords, conditionActivity, activeState string) (list []*models.CygxActivitySpecialDetail, total int, err error) {
  572. state := 4
  573. if activeState == "3" {
  574. state = 3
  575. }
  576. listConfirm, totalConfirm, e := GetActivityLabelSpecialConfirmList(user, (currentIndex-1)*pageSize, pageSize, state, keywords, conditionActivity)
  577. if e != nil {
  578. err = errors.New("GetActivityLabelSpecialConfirmList, Err: " + e.Error())
  579. return
  580. }
  581. if currentIndex == 1 && len(listConfirm) > 0 {
  582. listConfirm[0].Explain = utils.ACtIVITY_SPECIAL_TRIP_EXPLAIN
  583. }
  584. list = listConfirm
  585. total = totalConfirm
  586. var startSizePrepare, pageSizePrepare int
  587. //全是确定行程的查询数据
  588. if totalConfirm >= currentIndex*pageSize {
  589. startSizePrepare = 0
  590. pageSizePrepare = 0
  591. } else if totalConfirm > (currentIndex-1)*pageSize && totalConfirm < currentIndex*pageSize {
  592. //一半确认行程一半预报名
  593. startSizePrepare = 0
  594. pageSizePrepare = pageSize - len(listConfirm)
  595. } else {
  596. //全是预报名
  597. startSizePrepare = (currentIndex-1)*pageSize - totalConfirm
  598. pageSizePrepare = pageSize - len(listConfirm)
  599. }
  600. listPrepare, totalPrepare, e := GetActivitySpecialPrepareList(user, startSizePrepare, pageSizePrepare, keywords, conditionActivity)
  601. if e != nil {
  602. err = errors.New("GetActivitySpecialPrepareList, Err: " + e.Error())
  603. return
  604. }
  605. if len(listPrepare) > 0 {
  606. for _, v := range listPrepare {
  607. list = append(list, v)
  608. }
  609. if startSizePrepare == 0 {
  610. listPrepare[0].Explain = utils.ACtIVITY_SPECIAL_EXPLAIN
  611. }
  612. }
  613. total = totalConfirm + totalPrepare
  614. //处理封面图片
  615. detail, e := models.GetConfigByCode("city_img_url")
  616. if e != nil {
  617. err = errors.New("GetConfigByCode, Err: " + e.Error())
  618. return
  619. }
  620. detailChart, e := models.GetConfigByCode("chart_img_url")
  621. if e != nil {
  622. err = errors.New("GetConfigByCode, Err: " + e.Error())
  623. return
  624. }
  625. addressList := strings.Split(detail.ConfigValue, "{|}")
  626. mapAddress := make(map[string]string)
  627. chartList := strings.Split(detailChart.ConfigValue, "{|}")
  628. mapChart := make(map[string]string)
  629. var cityName string
  630. var chartName string
  631. var imgUrl string
  632. var imgUrlChart string
  633. for _, v := range addressList {
  634. vslice := strings.Split(v, "_")
  635. cityName = vslice[0]
  636. imgUrl = vslice[len(vslice)-1]
  637. mapAddress[cityName] = imgUrl
  638. }
  639. for _, v := range chartList {
  640. vslice := strings.Split(v, "_")
  641. chartName = vslice[0]
  642. imgUrlChart = vslice[len(vslice)-1]
  643. mapChart[chartName] = imgUrlChart
  644. }
  645. for k, v := range list {
  646. //list[k].ImgUrlText = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202112/20211221/bIdfv8t86xrFRpDOeGGHXOmKEuKl.png"
  647. if mapChart[v.ChartPermissionName] != "" {
  648. list[k].ImgUrl = mapChart[v.ChartPermissionName]
  649. }
  650. list[k].ActivityTypeName = "专项调研"
  651. if list[k].Days == 0 {
  652. list[k].TripStatus = 1
  653. } else {
  654. list[k].TripStatus = 2
  655. list[k].TripImgLink = list[k].TripImgLinkFix
  656. }
  657. }
  658. return
  659. }
  660. // HandleActivitySpecialShow 处理活动的状态
  661. func HandleActivitySpecialShow(activityDetail *models.CygxActivitySpecialDetail, user *models.WxUserItem) (item *models.CygxActivitySpecialDetail, err error) {
  662. var activityIds []int
  663. resultTimeStart := utils.StrTimeToTime(activityDetail.ActivityTime) //时间字符串格式转时间格式
  664. resultTimeEnd := utils.StrTimeToTime(activityDetail.ActivityTimeEnd) //时间字符串格式转时间格式
  665. if resultTimeStart.After(time.Now()) {
  666. activityDetail.ActiveState = strconv.Itoa(1)
  667. } else if time.Now().After(resultTimeEnd) {
  668. activityDetail.ActiveState = strconv.Itoa(3)
  669. } else {
  670. activityDetail.ActiveState = strconv.Itoa(2)
  671. }
  672. activityIds = append(activityIds, activityDetail.ActivityId)
  673. //处理用户已经报名了的行程
  674. UserMap, e := GetSpecialTripUserMap(activityIds, user.UserId)
  675. if e != nil {
  676. err = errors.New("GetSpecialTripUserMap, Err: " + e.Error())
  677. return
  678. }
  679. if activityDetail.Days == 0 {
  680. activityDetail.TripStatus = 1
  681. activityDetail.Explain = utils.ACtIVITY_SPECIAL_EXPLAIN
  682. } else {
  683. activityDetail.TripStatus = 2
  684. activityDetail.TripImgLink = activityDetail.TripImgLinkFix
  685. activityDetail.Explain = utils.ACtIVITY_SPECIAL_TRIP_EXPLAIN
  686. }
  687. if _, ok := UserMap[activityDetail.ActivityId]; ok {
  688. activityDetail.IsTrip = 1
  689. }
  690. if activityDetail.Days == 0 {
  691. activityDetail.ActiveState = ""
  692. }
  693. item = activityDetail
  694. return
  695. }
  696. // 活动与专项调研搜索 GetActivitySpecialSearcheList
  697. // 活动与专项调研搜索 GetActivitySpecialSearcheList
  698. func GetActivitySpecialSearcheList(user *models.WxUserItem, condition string, startSize, pageSize, playBack int, keywords string) (items []*models.ActivityDetail, total int, err error) {
  699. var conditionSpecil string
  700. var pars, parsSpecil []interface{}
  701. keyword := keywords
  702. if keywords != "" {
  703. keywords = "%" + keywords + "%"
  704. conditionSpecil += ` AND art.days > 0 AND (art.research_theme LIKE ? OR art.label LIKE ? OR art.industrial_name LIKE ? OR art.industrial_subject_name LIKE ? ) `
  705. parsSpecil = append(parsSpecil, keywords, keywords, keywords, keywords)
  706. }
  707. if playBack == 1 {
  708. conditionSpecil += ` AND art.activity_id = 0 `
  709. }
  710. list, totalSearche, e := models.GetActivitySpecialSearcheList(condition, pars, conditionSpecil, parsSpecil, startSize, pageSize)
  711. if e != nil {
  712. err = errors.New("GetActivitySpecialSearcheList, Err: " + e.Error())
  713. return
  714. }
  715. keyWordArr, e := GetIndustryMapNameSliceV3(keywords)
  716. if e != nil {
  717. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  718. return
  719. }
  720. var totalIk int
  721. if len(keyWordArr) > 1 {
  722. // 查询IK分词后那一部分的数据
  723. conditionActivityIk, e := GetActivityonditionList(user, "", "", "", "", "", 0, 1, keyword, playBack, 2)
  724. if e != nil && e.Error() != utils.ErrNoRow() {
  725. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  726. return
  727. }
  728. conditionActivityIk += " AND art.is_limit_people = 1 AND art.publish_status = 1 "
  729. totalIk, e = models.GetActivityCount(conditionActivityIk, 0, pars, 0)
  730. if e != nil {
  731. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  732. return
  733. }
  734. keyWordArr, e := GetIndustryMapNameSliceV3(keywords)
  735. if e != nil {
  736. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  737. return
  738. }
  739. keyWordArr = RemoveDuplicatesAndEmpty(keyWordArr)
  740. startSizeIk := startSize - totalSearche
  741. if startSizeIk < 0 {
  742. startSizeIk = 0
  743. }
  744. var pageSizeIk int
  745. pageSizeIk = pageSize - len(list)
  746. if pageSizeIk > 0 {
  747. //搜索关键词联想
  748. conditionActivityIk += ` ORDER BY art.activity_time DESC , art.active_state ASC `
  749. listIk, e := models.GetActivityListNew(conditionActivityIk, pars, user.UserId, startSizeIk, pageSizeIk, 0, 0, "")
  750. if e != nil {
  751. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  752. return
  753. }
  754. for _, item := range listIk {
  755. list = append(list, item)
  756. }
  757. }
  758. }
  759. total = totalSearche + totalIk
  760. items, e = HandleActivityListButton(list, user)
  761. if e != nil {
  762. err = errors.New("HandleActivityListButton, Err: " + e.Error())
  763. return
  764. }
  765. return
  766. }
  767. // 获取 专项调研客户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //8、行业升级套餐客户 //9、其余正式客户;5、试用客户
  768. func GetActivitySpecialUserType(companyId int) (userType int, permissionStrnew string, err error) {
  769. var permissionStr string
  770. if companyId <= 1 {
  771. userType = 0
  772. } else {
  773. total, e := models.GetCountCompanyDetailByIdGroupTrip(companyId)
  774. if e != nil {
  775. err = errors.New("GetCountCompanyDetailByIdGroupTrip, Err: " + e.Error())
  776. return
  777. }
  778. if total == 0 {
  779. userType = 0
  780. } else {
  781. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(companyId)
  782. if e != nil {
  783. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  784. return
  785. }
  786. permissionStr, e = models.GetCompanyPermissionByUserTrip(companyId)
  787. if e != nil {
  788. err = errors.New("GetCompanyPermissionByUserTrip, Err: " + e.Error())
  789. return
  790. }
  791. //permissionZhengShiStr, e = models.GetCompanyPermissionByUserZhengShiTrip(companyId)
  792. //if e != nil {
  793. // err = errors.New("GetCompanyPermissionByUserZhengShiTrip, Err: " + e.Error())
  794. // return
  795. //}
  796. //大套餐客户定义:医药、消费、科技、智造。4个行业中为升级,策略是正式,属于大套餐客户
  797. if companyDetail.Status == "永续" {
  798. userType = 1
  799. } else if companyDetail.Status == "试用" {
  800. userType = 5
  801. } else if companyDetail.Status == "正式" {
  802. if permissionStr == "专家" {
  803. userType = 4
  804. } else if strings.Count(permissionStr, "医药") == 2 && strings.Count(permissionStr, "消费") == 2 && strings.Count(permissionStr, "科技") == 2 && strings.Count(permissionStr, "智造") == 2 && strings.Count(permissionStr, "策略") == 1 {
  805. userType = 2
  806. } else {
  807. userType = 3
  808. }
  809. if userType == 3 {
  810. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  811. userType = 4
  812. }
  813. }
  814. } else if companyDetail.Status == "冻结" {
  815. userType = 6
  816. } else if companyDetail.Status == "流失" {
  817. userType = 7
  818. }
  819. }
  820. }
  821. permissionStrnew = permissionStr
  822. return
  823. }
  824. // GetSpecialUserType 获取专项产业调研的用户身份类型
  825. // 获取 专项调研客户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //8、行业升级套餐客户 //9、其余正式客户;5、试用客户
  826. func GetSpecialUserType(user *models.WxUserItem) (userType int, err error) {
  827. companyId := user.CompanyId
  828. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(companyId)
  829. if e != nil && e.Error() != utils.ErrNoRow() {
  830. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  831. return
  832. }
  833. if companyDetail == nil {
  834. return
  835. }
  836. if companyId <= 1 {
  837. userType = 0
  838. } else {
  839. if companyDetail.Status == "永续" {
  840. userType = 1
  841. } else {
  842. if companyDetail.Status == "正式" {
  843. list, e := models.GetCompanyReportPermissionUpgrade(companyId, 2)
  844. if e != nil && e.Error() != utils.ErrNoRow() {
  845. err = errors.New("GetCompanyReportPermissionUpgrade, Err: " + e.Error())
  846. }
  847. if len(list) == 0 {
  848. userType = 9
  849. }
  850. if len(list) == 4 {
  851. totalName, e := models.GetCompanyPermissionNameCheck(companyId, 2, "策略")
  852. if e != nil {
  853. err = errors.New("获取品种信息失败, Err:" + e.Error())
  854. return
  855. }
  856. if totalName > 0 {
  857. userType = 2
  858. } else {
  859. userType = 8
  860. }
  861. } else {
  862. userType = 8
  863. }
  864. } else if companyDetail.Status == "试用" {
  865. userType = 5
  866. }
  867. }
  868. }
  869. return
  870. }
  871. // GetSpecialDetailUserPower 处理用户查看专项调研详情的权限
  872. func GetSpecialDetailUserPower(user *models.WxUserItem, activityInfo *models.CygxActivitySpecialDetail) (havePower bool, err error) {
  873. if user.CompanyId == utils.HZ_COMPANY_ID {
  874. havePower = true
  875. return
  876. }
  877. userType, _, e := GetUserType(user.CompanyId)
  878. if e != nil {
  879. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  880. return
  881. }
  882. if userType == 0 {
  883. return
  884. }
  885. mapUserType, e := GetActivityCcustomerTypeList()
  886. if e != nil {
  887. err = e
  888. return
  889. }
  890. var userTypeStr string
  891. userTypeStr = mapUserType[userType]
  892. // 永续客户、大套餐客户可以查看行业升级套餐客户 权限
  893. if userTypeStr == "1" || userTypeStr == "2" {
  894. if strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) || strings.Contains(activityInfo.CustomerTypeIds, "8") {
  895. havePower = true
  896. return
  897. }
  898. }
  899. permissionStr, e := GetCompanyPermissionUpgrade(user.CompanyId)
  900. if e != nil {
  901. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  902. return
  903. }
  904. //如果没有对应的升级权限,则返回
  905. if !strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  906. return
  907. }
  908. //userType, e := GetSpecialUserType(user)
  909. var pars []interface{}
  910. var condition string
  911. var userTypes string
  912. condition += ` AND art.publish_status = 1 AND art.is_offline = 0 `
  913. userTypes = "%" + userTypeStr + "%"
  914. condition += ` AND art.customer_type_ids LIKE ? `
  915. pars = append(pars, userTypes)
  916. condition += ` AND art.activity_id = ? `
  917. pars = append(pars, activityInfo.ActivityId)
  918. total, e := models.GetActivitySpecialCount(condition, pars)
  919. if e != nil {
  920. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  921. return
  922. }
  923. if total == 1 {
  924. havePower = true
  925. return
  926. }
  927. fmt.Println(userType)
  928. fmt.Println(permissionStr)
  929. fmt.Println(activityInfo.ChartPermissionName)
  930. fmt.Println(activityInfo.CustomerTypeIds)
  931. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, "8") {
  932. havePower = true
  933. return
  934. }
  935. return
  936. }
  937. // 预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳
  938. func SendWxMsgActivitySpecial10(activityInfo *models.CygxActivitySpecialDetail) (err error) {
  939. activityId := activityInfo.ActivityId
  940. var msg string
  941. defer func() {
  942. if err != nil {
  943. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  944. go utils.SendAlarmMsg(fmt.Sprint("预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳消息发送失败", activityInfo.ResearchTheme, ", activityId"), 2)
  945. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  946. }
  947. }()
  948. var first string
  949. var keyword1 string
  950. var keyword2 string
  951. var keyword3 string
  952. var keyword4 string
  953. var remark string
  954. adminUser, e := models.GetSellerByAdminId(activityInfo.AdminId)
  955. if e != nil {
  956. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  957. return
  958. }
  959. cnf, _ := models.GetConfigByCode("tpl_msg")
  960. mobile := adminUser.Mobile + "," + cnf.ConfigValue
  961. specialSignupList, e := models.GetActivityListSpecialByActivityId(activityId)
  962. if e != nil {
  963. err = errors.New("GetActivityListSpecialAll, Err: " + e.Error())
  964. return
  965. }
  966. for _, v := range specialSignupList {
  967. keyword1 += "【" + v.RealName + "--" + v.CompanyName + "】"
  968. }
  969. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  970. if e != nil {
  971. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  972. return
  973. }
  974. first = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
  975. keyword3 = "-"
  976. keyword2 = "-"
  977. keyword4 = activityInfo.ResearchTheme
  978. openIdArr := make([]string, 0)
  979. for _, v := range openIdList {
  980. openIdArr = append(openIdArr, v.OpenId)
  981. }
  982. redirectUrl := utils.WX_MSG_PATH_ACTIVITY_SPECIAL_DETAIL + strconv.Itoa(activityId)
  983. sendInfo := new(SendWxTemplate)
  984. sendInfo.First = first
  985. sendInfo.Keyword1 = keyword1
  986. sendInfo.Keyword2 = keyword2
  987. sendInfo.Keyword3 = keyword3
  988. sendInfo.Keyword4 = keyword4
  989. sendInfo.Remark = remark
  990. sendInfo.TemplateId = utils.WxMsgTemplateIdAskMsgXzs
  991. sendInfo.RedirectUrl = redirectUrl
  992. sendInfo.RedirectTarget = 3
  993. sendInfo.Resource = strconv.Itoa(activityId)
  994. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  995. sendInfo.OpenIdArr = openIdArr
  996. err = PublicSendTemplateMsg(sendInfo)
  997. if err != nil {
  998. return
  999. }
  1000. return
  1001. }