activity_special.go 34 KB

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