activity_special.go 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029
  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. keyWordArr, e := GetIndustryMapNameSliceV3(keywords)
  517. if e != nil {
  518. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  519. return
  520. }
  521. var totalIk int
  522. if len(keyWordArr) > 1 {
  523. // 查询IK分词后那一部分的数据
  524. conditionActivityIk, e := GetActivityonditionList(user, "", "", "", "", "", 0, 1, keyword, 0, 2)
  525. if e != nil && e.Error() != utils.ErrNoRow() {
  526. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  527. return
  528. }
  529. conditionActivityIk += " AND art.is_limit_people = 1 AND art.publish_status = 1 "
  530. totalIk, e = models.GetActivityCount(conditionActivityIk, 0, pars, 0)
  531. if e != nil {
  532. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  533. return
  534. }
  535. keyWordArr = RemoveDuplicatesAndEmpty(keyWordArr)
  536. startSizeIk := startSize - totalSearche
  537. if startSizeIk < 0 {
  538. startSizeIk = 0
  539. }
  540. var pageSizeIk int
  541. pageSizeIk = pageSize - len(list)
  542. if pageSizeIk > 0 {
  543. //搜索关键词联想
  544. conditionActivityIk += ` ORDER BY art.activity_time DESC , art.active_state ASC `
  545. listIk, e := models.GetActivityListNew(conditionActivityIk, pars, user.UserId, startSizeIk, pageSizeIk, 0, 0, "")
  546. if e != nil {
  547. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  548. return
  549. }
  550. for _, item := range listIk {
  551. list = append(list, item)
  552. }
  553. }
  554. }
  555. total = totalSearche + totalIk
  556. items, e = HandleActivityListButton(list, user)
  557. if e != nil {
  558. err = errors.New("HandleActivityListButton, Err: " + e.Error())
  559. return
  560. }
  561. return
  562. }
  563. // 获取 专项调研客户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //8、行业升级套餐客户 //9、其余正式客户;5、试用客户
  564. func GetActivitySpecialUserType(companyId int) (userType int, permissionStrnew string, err error) {
  565. var permissionStr string
  566. if companyId <= 1 {
  567. userType = 0
  568. } else {
  569. total, e := models.GetCountCompanyDetailByIdGroupTrip(companyId)
  570. if e != nil {
  571. err = errors.New("GetCountCompanyDetailByIdGroupTrip, Err: " + e.Error())
  572. return
  573. }
  574. if total == 0 {
  575. userType = 0
  576. } else {
  577. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(companyId)
  578. if e != nil {
  579. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  580. return
  581. }
  582. permissionStr, e = models.GetCompanyPermissionByUserTrip(companyId)
  583. if e != nil {
  584. err = errors.New("GetCompanyPermissionByUserTrip, Err: " + e.Error())
  585. return
  586. }
  587. //permissionZhengShiStr, e = models.GetCompanyPermissionByUserZhengShiTrip(companyId)
  588. //if e != nil {
  589. // err = errors.New("GetCompanyPermissionByUserZhengShiTrip, Err: " + e.Error())
  590. // return
  591. //}
  592. //大套餐客户定义:医药、消费、科技、智造。4个行业中为升级,策略是正式,属于大套餐客户
  593. if companyDetail.Status == "永续" {
  594. userType = 1
  595. } else if companyDetail.Status == "试用" {
  596. userType = 5
  597. } else if companyDetail.Status == "正式" {
  598. if permissionStr == "专家" {
  599. userType = 4
  600. } else if strings.Count(permissionStr, "医药") == 2 && strings.Count(permissionStr, "消费") == 2 && strings.Count(permissionStr, "科技") == 2 && strings.Count(permissionStr, "智造") == 2 && strings.Count(permissionStr, "策略") == 1 {
  601. userType = 2
  602. } else {
  603. userType = 3
  604. }
  605. if userType == 3 {
  606. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  607. userType = 4
  608. }
  609. }
  610. } else if companyDetail.Status == "冻结" {
  611. userType = 6
  612. } else if companyDetail.Status == "流失" {
  613. userType = 7
  614. }
  615. }
  616. }
  617. permissionStrnew = permissionStr
  618. return
  619. }
  620. // GetSpecialUserType 获取专项产业调研的用户身份类型
  621. // 获取 专项调研客户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //8、行业升级套餐客户 //9、其余正式客户;5、试用客户
  622. func GetSpecialUserType(user *models.WxUserItem) (userType int, err error) {
  623. companyId := user.CompanyId
  624. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(companyId)
  625. if e != nil {
  626. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  627. return
  628. }
  629. if companyId <= 1 {
  630. userType = 0
  631. } else {
  632. if companyDetail.Status == "永续" {
  633. userType = 1
  634. } else {
  635. if companyDetail.Status == "正式" {
  636. list, e := models.GetCompanyReportPermissionUpgrade(companyId, 2)
  637. if e != nil && e.Error() != utils.ErrNoRow() {
  638. err = errors.New("GetCompanyReportPermissionUpgrade, Err: " + e.Error())
  639. }
  640. if len(list) == 0 {
  641. userType = 9
  642. }
  643. if len(list) == 4 {
  644. totalName, e := models.GetCompanyPermissionNameCheck(companyId, 2, "策略")
  645. if e != nil {
  646. err = errors.New("获取品种信息失败, Err:" + e.Error())
  647. return
  648. }
  649. if totalName > 0 {
  650. userType = 2
  651. } else {
  652. userType = 8
  653. }
  654. } else {
  655. userType = 8
  656. }
  657. } else if companyDetail.Status == "试用" {
  658. userType = 5
  659. }
  660. }
  661. }
  662. return
  663. }
  664. // GetSpecialDetailUserPower 处理用户查看专项调研详情的权限
  665. func GetSpecialDetailUserPower(user *models.WxUserItem, activityInfo *models.CygxActivitySpecialDetail) (havePower bool, err error) {
  666. permissionStr, e := GetCompanyPermissionUpgrade(user.CompanyId)
  667. if e != nil {
  668. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  669. return
  670. }
  671. fmt.Println(permissionStr)
  672. //如果没有对应的升级权限,则返回
  673. if !strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  674. return
  675. }
  676. userType, e := GetSpecialUserType(user)
  677. if e != nil {
  678. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  679. return
  680. }
  681. if userType == 0 {
  682. return
  683. }
  684. var pars []interface{}
  685. var condition string
  686. var userTypes string
  687. condition += ` AND art.publish_status = 1 AND art.is_offline = 0 `
  688. userTypes = "%" + strconv.Itoa(userType) + "%"
  689. condition += ` AND art.customer_type_ids LIKE ? `
  690. pars = append(pars, userTypes)
  691. condition += ` AND art.activity_id = ? `
  692. pars = append(pars, activityInfo.ActivityId)
  693. total, e := models.GetActivitySpecialCount(condition, pars)
  694. if e != nil {
  695. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  696. return
  697. }
  698. if total == 1 {
  699. havePower = true
  700. }
  701. return
  702. }
  703. // 预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳
  704. func SendWxMsgActivitySpecial10(activityInfo *models.CygxActivitySpecialDetail) (err error) {
  705. activityId := activityInfo.ActivityId
  706. var msg string
  707. defer func() {
  708. if err != nil {
  709. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  710. go utils.SendAlarmMsg(fmt.Sprint("预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳消息发送失败", activityInfo.ResearchTheme, ", activityId"), 2)
  711. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  712. }
  713. }()
  714. var first string
  715. var keyword1 string
  716. var keyword2 string
  717. var keyword3 string
  718. var keyword4 string
  719. var remark string
  720. adminUser, e := models.GetSellerByAdminId(activityInfo.AdminId)
  721. if e != nil {
  722. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  723. return
  724. }
  725. cnf, _ := models.GetConfigByCode("tpl_msg")
  726. mobile := adminUser.Mobile + "," + cnf.ConfigValue
  727. specialSignupList, e := models.GetActivityListSpecialByActivityId(activityId)
  728. if e != nil {
  729. err = errors.New("GetActivityListSpecialAll, Err: " + e.Error())
  730. return
  731. }
  732. for _, v := range specialSignupList {
  733. keyword1 += "【" + v.RealName + "--" + v.CompanyName + "】"
  734. }
  735. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  736. if e != nil {
  737. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  738. return
  739. }
  740. first = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
  741. keyword3 = "-"
  742. keyword2 = "-"
  743. keyword4 = activityInfo.ResearchTheme
  744. openIdArr := make([]string, 0)
  745. for _, v := range openIdList {
  746. openIdArr = append(openIdArr, v.OpenId)
  747. }
  748. redirectUrl := utils.WX_MSG_PATH_ACTIVITY_SPECIAL_DETAIL + strconv.Itoa(activityId)
  749. sendInfo := new(SendWxTemplate)
  750. sendInfo.First = first
  751. sendInfo.Keyword1 = keyword1
  752. sendInfo.Keyword2 = keyword2
  753. sendInfo.Keyword3 = keyword3
  754. sendInfo.Keyword4 = keyword4
  755. sendInfo.Remark = remark
  756. sendInfo.TemplateId = utils.WxMsgTemplateIdAskMsgXzs
  757. sendInfo.RedirectUrl = redirectUrl
  758. sendInfo.RedirectTarget = 3
  759. sendInfo.Resource = strconv.Itoa(activityId)
  760. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  761. sendInfo.OpenIdArr = openIdArr
  762. err = PublicSendTemplateMsg(sendInfo)
  763. if err != nil {
  764. return
  765. }
  766. return
  767. }
  768. // SendWxMsgActivitySpecialTwoDays 活动开始前两天08:00,提醒报名客户 \提醒报名客户的对口销售
  769. func SendWxMsgActivitySpecialTwoDays(cont context.Context) (err error) {
  770. var msg string
  771. defer func() {
  772. if err != nil {
  773. fmt.Println(err)
  774. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  775. go utils.SendAlarmMsg(fmt.Sprint(" 活动开始前两天08:00,提醒报名客户、提醒报名客户的对口销售消息发送失败"), 2)
  776. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  777. }
  778. }()
  779. twoDayTime := time.Now().AddDate(0, 0, 2)
  780. startTime := twoDayTime.Format(utils.FormatDate) + " 00:00:00"
  781. endTime := twoDayTime.Format(utils.FormatDate) + " 23:59:59"
  782. var condition string
  783. var pars []interface{}
  784. condition = ` AND days >0 AND activity_time BETWEEN ? AND ? `
  785. pars = append(pars, startTime, endTime)
  786. listActivitySpecial, e := models.GetActivitySpecialListAll(condition, pars, 0, 1000)
  787. if e != nil {
  788. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  789. return
  790. }
  791. if len(listActivitySpecial) == 0 {
  792. return
  793. }
  794. var activityIds []int
  795. for _, v := range listActivitySpecial {
  796. activityIds = append(activityIds, v.ActivityId)
  797. condition = ` AND is_cancel = 0 AND activity_id = ` + strconv.Itoa(v.ActivityId)
  798. pars = make([]interface{}, 0)
  799. listSpecialTrip, e := models.GetCygxActivitySpecialTripList(condition, pars)
  800. if e != nil {
  801. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  802. return
  803. }
  804. if len(listSpecialTrip) == 0 {
  805. return
  806. }
  807. var mobile string
  808. var companyIds []int
  809. for _, vT := range listSpecialTrip {
  810. mobile += "'" + vT.Mobile + "',"
  811. companyIds = append(companyIds, vT.CompanyId)
  812. }
  813. mobile = strings.TrimRight(mobile, ",")
  814. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  815. if e != nil {
  816. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  817. return
  818. }
  819. first := "【" + v.ResearchTheme + "】专项调研将在两天后进行,如不能参加,请及时取消报名"
  820. keyword1 := v.ResearchTheme
  821. keyword2 := "已报名"
  822. keyword3 := v.ActivityTimeTextByDay
  823. keyword4 := "线上"
  824. if v.SpecialType == 2 {
  825. keyword4 = v.City
  826. }
  827. remark := "点击查看活动详情"
  828. SendWxMsgWithFrequency(first, keyword1, keyword2, keyword3, keyword4, remark, openIdList, v.ActivityId)
  829. //活动开始前两天08:00,提醒报名客户的对口销售
  830. companyIdsLen := len(companyIds)
  831. if companyIdsLen == 0 {
  832. continue
  833. } else {
  834. pars = make([]interface{}, 0)
  835. condition = ` AND p.company_id IN (` + utils.GetOrmInReplace(companyIdsLen) + `) GROUP BY p.company_id `
  836. pars = append(pars, companyIds)
  837. listSeller, e := models.GetAdminOpendidByCompany(condition, pars)
  838. if e != nil && e.Error() != utils.ErrNoRow() {
  839. err = errors.New("GetAdminOpendidByCompany, Err: " + e.Error())
  840. return
  841. }
  842. if len(listSeller) == 0 {
  843. continue
  844. }
  845. type SllerData struct {
  846. Openid string `description:"Openid"`
  847. Keyword string `description:"Keyword "`
  848. }
  849. mapSller := make(map[string]string)
  850. mapSllerOpenid := make(map[string]string)
  851. for _, vS := range listSeller {
  852. for _, vT := range listSpecialTrip {
  853. if vT.CompanyId == vS.CompanyId {
  854. mapSller[vS.Mobile] += "【" + vT.RealName + "--" + vT.CompanyName + "】"
  855. mapSllerOpenid[vS.Mobile] = vS.OpenId
  856. }
  857. }
  858. }
  859. for k, vM := range mapSller {
  860. first = "【" + v.ResearchTheme + "】专项调研将在两天后进行,请及时提醒您的报名客户"
  861. keyword2 = vM
  862. openIdList = make([]*models.OpenIdList, 0)
  863. openIdList = append(openIdList, &models.OpenIdList{OpenId: mapSllerOpenid[k]})
  864. SendWxMsgWithFrequency(first, keyword1, keyword2, keyword3, keyword4, remark, openIdList, v.ActivityId)
  865. }
  866. }
  867. }
  868. return
  869. }
  870. // SendWxMsgActivitySpecialCancel 线下活动前4天08:00报名人数不足7人,线上活动前3天08:00报名人数不足10人,活动自动取消发布,并推送模板消息至报名客户及对口销售
  871. func SendWxMsgActivitySpecialCancel(cont context.Context) (err error) {
  872. var msg string
  873. defer func() {
  874. if err != nil {
  875. fmt.Println(err)
  876. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  877. go utils.SendAlarmMsg(fmt.Sprint(" 活动开始前两天08:00,提醒报名客户、提醒报名客户的对口销售消息发送失败"), 2)
  878. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  879. }
  880. }()
  881. dayTime3 := time.Now().AddDate(0, 0, 3)
  882. startTime := dayTime3.Format(utils.FormatDate) + " 00:00:00"
  883. endTime := dayTime3.Format(utils.FormatDate) + " 23:59:59"
  884. dayTime4 := time.Now().AddDate(0, 0, 4)
  885. startTime4 := dayTime4.Format(utils.FormatDate) + " 00:00:00"
  886. endTime4 := dayTime4.Format(utils.FormatDate) + " 23:59:59"
  887. var condition string
  888. var pars []interface{}
  889. condition = ` AND days >0 AND activity_time BETWEEN ? AND ? AND special_type= 1 `
  890. pars = append(pars, startTime, endTime)
  891. condition += ` OR ( days >0 AND activity_time BETWEEN ? AND ? AND special_type= 2 ) `
  892. pars = append(pars, startTime4, endTime4)
  893. listActivitySpecial, e := models.GetActivitySpecialListAll(condition, pars, 0, 1000)
  894. if e != nil {
  895. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  896. return
  897. }
  898. if len(listActivitySpecial) == 0 {
  899. return
  900. }
  901. var activityIds []int
  902. for _, v := range listActivitySpecial {
  903. activityIds = append(activityIds, v.ActivityId)
  904. condition = ` AND is_cancel = 0 AND activity_id = ` + strconv.Itoa(v.ActivityId)
  905. pars = make([]interface{}, 0)
  906. listSpecialTrip, e := models.GetCygxActivitySpecialTripList(condition, pars)
  907. if e != nil {
  908. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  909. return
  910. }
  911. if v.SpecialType == 1 {
  912. if len(listSpecialTrip) >= 10 {
  913. continue
  914. }
  915. }
  916. if v.SpecialType == 2 {
  917. if len(listSpecialTrip) >= 7 {
  918. continue
  919. }
  920. }
  921. e = models.UpdateActivitySpecialPublishStatus(0, v.ActivityId)
  922. if e != nil {
  923. err = errors.New("UpdateActivitySpecialPublishStatus,自动取消专项调研日程失败 Err: " + e.Error() + strconv.Itoa(v.ActivityId))
  924. return
  925. }
  926. if len(listSpecialTrip) < 0 {
  927. return
  928. }
  929. var mobile string
  930. var companyIds []int
  931. for _, vT := range listSpecialTrip {
  932. mobile += "'" + vT.Mobile + "',"
  933. companyIds = append(companyIds, vT.CompanyId)
  934. }
  935. mobile = strings.TrimRight(mobile, ",")
  936. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  937. if e != nil {
  938. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  939. return
  940. }
  941. first := "【" + v.ResearchTheme + "】专项调研因专家安排变动,本次调研活动延期举办,具体时间另行通知"
  942. keyword1 := v.ResearchTheme
  943. keyword2 := "已取消"
  944. keyword3 := ""
  945. keyword4 := ""
  946. remark := ""
  947. openIdArr := make([]string, 0)
  948. for _, vOpenid := range openIdList {
  949. openIdArr = append(openIdArr, vOpenid.OpenId)
  950. }
  951. companyIdsLen := len(companyIds)
  952. if len(companyIds) > 0 {
  953. pars = make([]interface{}, 0)
  954. condition = ` AND p.company_id IN (` + utils.GetOrmInReplace(companyIdsLen) + `) GROUP BY p.company_id `
  955. pars = append(pars, companyIds)
  956. listSeller, e := models.GetAdminOpendidByCompany(condition, pars)
  957. if e != nil && e.Error() != utils.ErrNoRow() {
  958. err = errors.New("GetAdminOpendidByCompany, Err: " + e.Error())
  959. return
  960. }
  961. if len(listSeller) > 0 {
  962. for _, vOpenid := range listSeller {
  963. openIdArr = append(openIdArr, vOpenid.OpenId)
  964. }
  965. }
  966. }
  967. redirectUrl := ""
  968. sendInfo := new(SendWxTemplate)
  969. sendInfo.First = first
  970. sendInfo.Keyword1 = keyword1
  971. sendInfo.Keyword2 = keyword2
  972. sendInfo.Keyword3 = keyword3
  973. sendInfo.Keyword4 = keyword4
  974. sendInfo.Remark = remark
  975. sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
  976. sendInfo.RedirectUrl = redirectUrl
  977. sendInfo.RedirectTarget = 3
  978. sendInfo.Resource = strconv.Itoa(v.ActivityId)
  979. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  980. sendInfo.OpenIdArr = openIdArr
  981. fmt.Println(sendInfo)
  982. err = PublicSendTemplateMsg(sendInfo)
  983. }
  984. return
  985. }