activity_special.go 34 KB

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