activity_special.go 35 KB

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