activity_special.go 33 KB

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