activity_special.go 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738
  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 ActivityLabelSpecialSql(chartPermissionIds, whichDay, activeState string) (condition string) {
  13. //行业名称
  14. if len(chartPermissionIds) > 0 {
  15. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  16. }
  17. if whichDay != "" {
  18. var startDate string
  19. var endDate string
  20. if whichDay == "1" {
  21. startDate = time.Now().Format(utils.FormatDate)
  22. endDate = startDate
  23. } else if whichDay == "2" {
  24. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  25. endDate = startDate
  26. } else if whichDay == "1,2" || whichDay == "2,1" {
  27. startDate = time.Now().Format(utils.FormatDate)
  28. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  29. } else if whichDay == "3" {
  30. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  31. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  32. } else if whichDay == "4" {
  33. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  34. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  35. } else if whichDay == "5" {
  36. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  37. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  38. } else if whichDay == "6" {
  39. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  40. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  41. } else if whichDay == "3,4" || whichDay == "4,3" {
  42. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  43. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  44. } else if whichDay == "5,6" || whichDay == "6,5" {
  45. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  46. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  47. } else {
  48. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  49. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  50. }
  51. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  52. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  53. }
  54. if activeState == "2" {
  55. condition += ` AND art.days > 0 AND art.activity_time <= ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  56. condition += ` AND art.activity_time_end >= ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  57. }
  58. if activeState == "3" {
  59. condition += ` AND art.days > 0 AND art.activity_time_end <= ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  60. }
  61. //if activeState != "3" {
  62. // condition += ` AND art.activity_time_end > ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  63. //}
  64. //if activeState == "" && whichDay == "" {
  65. // condition += ` AND art.activity_time_end > ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  66. //}
  67. if whichDay != "" {
  68. condition += ` AND art.days > 0 `
  69. }
  70. condition += ` AND art.label != '' AND art.is_offline = 0 `
  71. if activeState == "1" {
  72. condition = condition + ` AND art.days > 0 AND art.activity_time_end > ` + "'" + time.Now().Format(utils.FormatDateTime) + " '"
  73. }
  74. return
  75. }
  76. // ActivityLabelSpecialUserSql 专项产业调研用户权限查询数据预处理
  77. func ActivityLabelSpecialUserSql(user *models.WxUserItem) (conditionShengji, conditionZhengshi, conditionHangYe string, err error) {
  78. _, userType, e := HandleActivityLabelSpecialTripPermission(user)
  79. if e != nil {
  80. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  81. return
  82. }
  83. // 8: 行业升级套餐客户:该活动对应行业为升级权限的客户
  84. permissionShengji, errs := models.GetCompanyPermissionByUserZhengShiTrip(user.CompanyId)
  85. if errs != nil {
  86. err = errs
  87. return
  88. }
  89. if permissionShengji != "" {
  90. slicePerShengji := strings.Split(permissionShengji, ",")
  91. permissionShengji = ""
  92. for _, v := range slicePerShengji {
  93. permissionShengji += "'" + v + "',"
  94. }
  95. permissionShengji = strings.TrimRight(permissionShengji, ",")
  96. conditionShengji = ` art.customer_type_ids LIKE '%8%' AND art.chart_permission_name IN (` + permissionShengji + `)`
  97. }
  98. //9:其他行业正式客户:前述所有正式客户以外的正式客户 查询处理
  99. permissionZhengShiStr, errs := models.GetCompanyPermissionByUserZhengShi(user.CompanyId)
  100. if errs != nil {
  101. err = errs
  102. return
  103. }
  104. if permissionZhengShiStr != "" {
  105. slicePerZhengshi := strings.Split(permissionZhengShiStr, ",")
  106. permissionZhengShiStr = ""
  107. for _, v := range slicePerZhengshi {
  108. if userType == 1 {
  109. //研选权限处理(永续客户无法查看研选)
  110. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  111. permissionZhengShiStr += "'" + v + "',"
  112. }
  113. } else {
  114. permissionZhengShiStr += "'" + v + "',"
  115. }
  116. }
  117. permissionZhengShiStr = strings.Replace(permissionZhengShiStr, "(主观)", "", -1)
  118. permissionZhengShiStr = strings.Replace(permissionZhengShiStr, "(客观)", "", -1)
  119. permissionZhengShiStr = strings.TrimRight(permissionZhengShiStr, ",")
  120. permissionZhengShiStr += `, '宏观'`
  121. if userType != 1 && userType != 2 && userType != 10 {
  122. conditionHangYe = ` art.customer_type_ids LIKE '%3%' AND art.chart_permission_name IN (` + permissionZhengShiStr + `)`
  123. }
  124. if userType == 3 {
  125. conditionZhengshi = ` art.customer_type_ids LIKE '%9%' AND art.chart_permission_name NOT IN (` + permissionZhengShiStr + `)`
  126. }
  127. }
  128. return
  129. }
  130. // 修改专项调研,用户与公司的参与数量
  131. func UpdateCygxActivitySpecialSignupNum(cont context.Context) (err error) {
  132. defer func() {
  133. if err != nil {
  134. fmt.Println(err)
  135. go utils.SendAlarmMsg("修改活动状态至进行中失败"+err.Error(), 2)
  136. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至进行中失败 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  137. }
  138. }()
  139. //根据手机号分组获取列表以及数量
  140. var condition string
  141. var pars []interface{}
  142. condition += ` AND s.create_time < ? `
  143. pars = append(pars, time.Now().Format(utils.FormatDate))
  144. listSpecial, err := models.GetActivityListSpecialGroupByMobile(condition, pars)
  145. if err != nil {
  146. return err
  147. }
  148. var mapMobile []string
  149. for _, v := range listSpecial {
  150. mapMobile = append(mapMobile, v.Mobile)
  151. }
  152. //根据手机号获取这些用户的信息
  153. userList, err := models.GetWxUserByMobiles(mapMobile)
  154. if err != nil {
  155. return err
  156. }
  157. //更改这些手机对应的关注关注数量
  158. err = models.UpdateActivitySpecialSignupNumMulti(listSpecial)
  159. if err != nil {
  160. return err
  161. }
  162. //更改这些手机对应的公司ID
  163. err = models.UpdateActivitySpecialSignupCompanyIdMulti(userList)
  164. if err != nil {
  165. return err
  166. }
  167. //根据CompanyId分组获取列表以及数量
  168. listSpecialByCompanyId, err := models.GetActivityListSpecialGroupByCompanyId(condition, pars)
  169. if err != nil {
  170. return err
  171. }
  172. //更改这些公司对应的关注关注数量
  173. err = models.UpdateActivitySpecialSignupCompanyNumMulti(listSpecialByCompanyId)
  174. if err != nil {
  175. return err
  176. }
  177. fmt.Println("UpdateCygxActivitySpecialSignupNum end")
  178. return
  179. }
  180. // 处理专项调研的展示
  181. func GetActivityLabelSpecialList(user *models.WxUserItem, conditionActivitySpecial, activeState string) (item *models.ActivityTypeHome, err error) {
  182. itemList := new(models.ActivityTypeHome)
  183. if user.CompanyId <= 1 {
  184. itemList.List = make([]*models.CygxActivityLabelList, 0)
  185. item = itemList
  186. return
  187. }
  188. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(user.CompanyId)
  189. if e != nil && e.Error() != utils.ErrNoRow() {
  190. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  191. return
  192. }
  193. if companyDetail == nil {
  194. return
  195. }
  196. //如果是永续的就按照普通的权限逻辑来查,如果不是就按照升级的逻辑来查
  197. var condition string
  198. var conditionUser string
  199. //var userType int
  200. if companyDetail.Status == "永续" {
  201. conditionUser, e = HandleActivityLabelSpecialPermission(user)
  202. if e != nil {
  203. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  204. return
  205. }
  206. } else {
  207. conditionUser, _, e = HandleActivityLabelSpecialTripPermission(user)
  208. if e != nil {
  209. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  210. return
  211. }
  212. }
  213. var pars []interface{}
  214. condition += ` AND art.publish_status = 1 AND art.label != '' AND art.is_offline = 0 ` + conditionActivitySpecial
  215. conditionTrip := condition
  216. conditionTripSql := condition
  217. conditionNoTrip := condition
  218. conditionNoTripSql := condition
  219. //condition += conditionUser
  220. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  221. if e != nil {
  222. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  223. return
  224. }
  225. conditionTrip += ` AND art.days > 0 AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + ` '`
  226. var conditionZhengshiTrip string
  227. var conditionShengjiTrip string
  228. var conditionHangYeTrip string
  229. //处理专项调研确认行程的其它正式客户权限查询
  230. if conditionZhengshi != "" {
  231. conditionZhengshiTrip = ` OR ( ` + conditionZhengshi + conditionTrip + ` )`
  232. }
  233. //处理升级权限查询
  234. if conditionShengji != "" {
  235. conditionShengjiTrip = ` OR ( ` + conditionShengji + conditionTrip + ` )`
  236. }
  237. //处理行业套餐客户权限查询
  238. if conditionHangYe != "" {
  239. conditionHangYeTrip = ` OR ( ` + conditionHangYe + conditionTrip + ` )`
  240. }
  241. if conditionZhengshi != "" {
  242. conditionTrip += conditionZhengshiTrip
  243. }
  244. if conditionShengjiTrip != "" {
  245. conditionTrip += conditionShengjiTrip
  246. }
  247. if conditionHangYeTrip != "" {
  248. conditionTrip += conditionHangYeTrip
  249. }
  250. conditionTripSql += conditionUser + conditionTrip + ` ORDER BY art.activity_time ASC `
  251. specialList, err := models.GetActivityLabelSpecialListAll(conditionTripSql, pars, 0, 80)
  252. if err != nil {
  253. return
  254. }
  255. //if len(specialList) < 80 {
  256. if activeState == "" {
  257. conditionNoTrip += ` AND art.days = 0 `
  258. }
  259. var conditionShengjiNoTrip string
  260. var conditionZhengshiNoTrip string
  261. var conditionHangYeNoTrip string
  262. if conditionShengji != "" {
  263. conditionShengjiNoTrip = ` OR ( ` + conditionShengji + conditionNoTrip + ` )`
  264. }
  265. if conditionZhengshi != "" {
  266. conditionZhengshiNoTrip = ` OR ( ` + conditionZhengshi + conditionNoTrip + ` )`
  267. }
  268. if conditionHangYe != "" {
  269. conditionHangYeNoTrip = ` OR ( ` + conditionHangYe + conditionNoTrip + ` )`
  270. }
  271. if conditionShengji != "" {
  272. conditionNoTrip += conditionShengjiNoTrip
  273. }
  274. if conditionZhengshi != "" {
  275. conditionNoTrip += conditionZhengshiNoTrip
  276. }
  277. if conditionHangYe != "" {
  278. conditionNoTrip += conditionHangYeNoTrip
  279. }
  280. conditionNoTripSql += conditionUser + conditionNoTrip + ` ORDER BY art.last_updated_time DESC`
  281. specialListNotrip, e := models.GetActivityLabelSpecialListAll(conditionNoTripSql, pars, 0, 200)
  282. if e != nil {
  283. err = e
  284. return
  285. }
  286. for _, v := range specialListNotrip {
  287. specialList = append(specialList, v)
  288. }
  289. //}
  290. for k2, v2 := range specialList {
  291. v2.Resource = 2
  292. if v2.Days == 0 {
  293. specialList[k2].TripStatus = 1
  294. } else {
  295. specialList[k2].TripStatus = 2
  296. }
  297. specialList[k2].KeyWord = LabelStrV5(v2.KeyWord, v2.IsShowSubjectName, v2.TemporaryLabel)
  298. specialList[k2].ImgUrlBg = "https://hzstatic.hzinsights.com/static/temp/20220426202204/20220426/XDLLsjC9XAAy8LIzQr7GsjrBbtX6.png"
  299. specialList[k2].ImgUrlBg = utils.ACTIVITY_ZXDY_ImgUrl3
  300. }
  301. itemList.ActivityTypeName = "专项产业调研"
  302. itemList.Resource = 2
  303. itemList.List = specialList
  304. itemList.ActivityTypeId = 7
  305. itemList.ImgUrl = utils.ACTIVITY_ZXDY_ImgUrl1
  306. itemList.ImgUrlBg = utils.ACTIVITY_ZXDY_ImgUrl2
  307. item = itemList
  308. return
  309. }
  310. // HandleActivityLabelSpecialPermission 处理专项产业调研的查询权限sql 永续
  311. func HandleActivityLabelSpecialPermission(user *models.WxUserItem) (condition string, err error) {
  312. permissionStr, e := GetCompanyPermission(user.CompanyId)
  313. if e != nil {
  314. err = errors.New("GetCompanyPermission, Err: " + e.Error())
  315. return
  316. }
  317. userType, e := GetSpecialUserType(user)
  318. if e != nil {
  319. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  320. return
  321. }
  322. slicePer := strings.Split(permissionStr, ",")
  323. var permissionSqlStr string
  324. for _, v := range slicePer {
  325. if userType == 1 {
  326. if !strings.Contains(v, "研选") {
  327. permissionSqlStr += "'" + v + "',"
  328. }
  329. } else {
  330. permissionSqlStr += "'" + v + "',"
  331. }
  332. }
  333. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  334. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.is_offline = 0 `
  335. //if permissionSqlStr != "" {
  336. // condition += ` AND art.chart_permission_name IN (` + permissionSqlStr + `) `
  337. //}
  338. condition += ` AND art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  339. return
  340. }
  341. // HandleActivityLabelSpecialPermisseion 处理专项产业调研的查询权限sql
  342. func HandleActivityLabelSpecialTripPermission(user *models.WxUserItem) (condition string, userType int, err error) {
  343. permissionStr, e := GetCompanyPermission(user.CompanyId)
  344. if e != nil {
  345. err = errors.New("GetCompanyPermission, Err: " + e.Error())
  346. return
  347. }
  348. userType, _, e = GetUserType(user.CompanyId)
  349. //userType, e := GetSpecialUserType(user)
  350. if e != nil {
  351. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  352. return
  353. }
  354. mapUserType, e := GetActivityCcustomerTypeList()
  355. if e != nil {
  356. err = e
  357. return
  358. }
  359. var userTypeStr string
  360. userTypeStr = mapUserType[userType]
  361. //fmt.Println(userType)
  362. slicePer := strings.Split(permissionStr, ",")
  363. var permissionSqlStr string
  364. for _, v := range slicePer {
  365. if userType == 1 {
  366. if !strings.Contains(v, "研选") {
  367. permissionSqlStr += "'" + v + "',"
  368. }
  369. } else {
  370. permissionSqlStr += "'" + v + "',"
  371. }
  372. }
  373. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  374. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.is_offline = 0 `
  375. if permissionSqlStr != "" && userType == 3 {
  376. condition += ` AND art.chart_permission_name IN (` + permissionSqlStr + `) `
  377. }
  378. condition += ` AND art.customer_type_ids LIKE '%` + userTypeStr + `%' `
  379. //if userType != 2 {
  380. return
  381. }
  382. // 获取预报名列表
  383. func GetActivitySpecialPrepareList(user *models.WxUserItem, startSize, pageSize int, keywords string) (list []*models.CygxActivitySpecialDetail, totalPrepare int, err error) {
  384. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(user.CompanyId)
  385. if e != nil {
  386. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  387. return
  388. }
  389. //如果是永续的就按照普通的权限逻辑来查,如果不是就按照升级的逻辑来查
  390. var condition string
  391. var conditionUser string
  392. if companyDetail.Status == "永续" {
  393. conditionUser, e = HandleActivityLabelSpecialPermission(user)
  394. if e != nil {
  395. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  396. return
  397. }
  398. } else {
  399. conditionUser, _, e = HandleActivityLabelSpecialTripPermission(user)
  400. if e != nil {
  401. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  402. return
  403. }
  404. }
  405. var pars []interface{}
  406. condition += ` AND art.days = 0 AND art.publish_status = 1 AND art.is_offline = 0 `
  407. if keywords != "" {
  408. keywords = "%" + keywords + "%"
  409. condition += ` AND art.research_theme LIKE ? `
  410. pars = append(pars, keywords)
  411. }
  412. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  413. if e != nil {
  414. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  415. return
  416. }
  417. conditionNoTrip := condition
  418. var conditionShengjiNoTrip string
  419. var conditionZhengshiNoTrip string
  420. var conditionHangYeNoTrip string
  421. if conditionShengji != "" {
  422. conditionShengjiNoTrip = ` OR ( ` + conditionShengji + conditionNoTrip + ` )`
  423. }
  424. if conditionZhengshi != "" {
  425. conditionZhengshiNoTrip = ` OR ( ` + conditionZhengshi + conditionNoTrip + ` )`
  426. }
  427. //处理行业套餐权限查询
  428. if conditionHangYe != "" {
  429. conditionHangYeNoTrip = ` OR ( ` + conditionHangYe + conditionNoTrip + ` )`
  430. }
  431. if conditionShengji != "" {
  432. conditionNoTrip += conditionShengjiNoTrip
  433. }
  434. if conditionZhengshi != "" {
  435. conditionNoTrip += conditionZhengshiNoTrip
  436. }
  437. if conditionHangYe != "" {
  438. conditionNoTrip += conditionHangYeNoTrip
  439. }
  440. conditionNoTripSql := conditionUser + conditionNoTrip
  441. //condition += conditionUser + conditionOr
  442. totalPrepare, e = models.GetActivitySpecialCount(conditionNoTripSql, pars)
  443. if e != nil {
  444. err = errors.New("GetActivitySpecialCount, Err: " + e.Error())
  445. return
  446. }
  447. conditionNoTripSql += ` ORDER BY art.last_updated_time DESC `
  448. list, e = models.GetCygxActivitySpecialDetailList(conditionNoTripSql, pars, user.UserId, startSize, pageSize)
  449. if e != nil {
  450. err = errors.New("GetCygxActivitySpecialDetailList, Err: " + e.Error())
  451. return
  452. }
  453. return
  454. }
  455. /*
  456. 确定行程的查询 GetActivityLabelSpecialConfirmList
  457. state 进行状态 1:未开始,2:进行中,3:已结束,4:未开始、进行中 不传默认查询全部items []*CygxActivitySpecialDetail
  458. */
  459. func GetActivityLabelSpecialConfirmList(user *models.WxUserItem, startSize, pageSize, state int, keywords string) (list []*models.CygxActivitySpecialDetail, totalConfirm int, err error) {
  460. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(user.CompanyId)
  461. if e != nil && e.Error() != utils.ErrNoRow() {
  462. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  463. return
  464. }
  465. if companyDetail == nil {
  466. return
  467. }
  468. //如果是永续的就按照普通的权限逻辑来查,如果不是就按照升级的逻辑来查
  469. var condition string
  470. var conditionUser string
  471. //var userType int
  472. if companyDetail.Status == "永续" {
  473. conditionUser, e = HandleActivityLabelSpecialPermission(user)
  474. if e != nil {
  475. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  476. return
  477. }
  478. } else {
  479. conditionUser, _, e = HandleActivityLabelSpecialTripPermission(user)
  480. if e != nil {
  481. err = errors.New("HandleActivityLabelSpecialPermission, Err: " + e.Error())
  482. return
  483. }
  484. }
  485. var pars []interface{}
  486. condition += ` AND art.days >0 AND art.publish_status =1 AND art.is_offline = 0 `
  487. if state == 1 {
  488. condition += ` AND art.activity_time > '` + time.Now().Format(utils.FormatDateTime) + `'`
  489. }
  490. if state == 2 {
  491. condition += ` AND art.activity_time < '` + time.Now().Format(utils.FormatDateTime) + `'`
  492. condition += ` AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + `'`
  493. }
  494. if state == 3 {
  495. condition += ` AND art.activity_time_end < '` + time.Now().Format(utils.FormatDateTime) + `'`
  496. }
  497. if state == 4 {
  498. condition += ` AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + `'`
  499. }
  500. if keywords != "" {
  501. keywords = "%" + keywords + "%"
  502. condition += ` AND art.research_theme LIKE ` + keywords
  503. //pars = append(pars, keywords)
  504. }
  505. conditionTrip := condition
  506. conditionTripSql := condition
  507. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  508. if e != nil {
  509. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  510. return
  511. }
  512. conditionTrip += ` AND art.days > 0 AND art.activity_time_end > '` + time.Now().Format(utils.FormatDateTime) + ` '`
  513. var conditionZhengshiTrip string
  514. var conditionShengjiTrip string
  515. var conditionHangYeTrip string
  516. //处理专项调研确认行程的其它正式客户权限查询
  517. if conditionZhengshi != "" {
  518. conditionZhengshiTrip = ` OR ( ` + conditionZhengshi + conditionTrip + ` )`
  519. }
  520. //处理专项调研确认行程的升级权限查询
  521. if conditionShengji != "" {
  522. conditionShengjiTrip = ` OR ( ` + conditionShengji + conditionTrip + ` )`
  523. }
  524. //处理行业套餐客户权限查询
  525. if conditionHangYe != "" {
  526. conditionHangYeTrip = ` OR ( ` + conditionHangYe + conditionTrip + ` )`
  527. }
  528. if conditionZhengshi != "" {
  529. conditionTrip += conditionZhengshiTrip
  530. }
  531. if conditionShengjiTrip != "" {
  532. conditionTrip += conditionShengjiTrip
  533. }
  534. if conditionHangYeTrip != "" {
  535. conditionTrip += conditionHangYeTrip
  536. }
  537. conditionTripSql += conditionUser + conditionTrip + ` ORDER BY art.activity_time ASC `
  538. totalConfirm, e = models.GetActivitySpecialCount(conditionTripSql, pars)
  539. if e != nil {
  540. err = errors.New("GetActivitySpecialCount, Err: " + e.Error())
  541. return
  542. }
  543. condition += ` ORDER BY art.activity_time ASC `
  544. list, e = models.GetCygxActivitySpecialDetailList(conditionTripSql, pars, user.UserId, startSize, pageSize)
  545. if e != nil {
  546. err = errors.New("GetCygxActivitySpecialDetailList, Err: " + e.Error())
  547. return
  548. }
  549. var activityIds []int
  550. for k, v := range list {
  551. resultTimeStart := utils.StrTimeToTime(v.ActivityTime) //时间字符串格式转时间格式
  552. resultTimeEnd := utils.StrTimeToTime(v.ActivityTimeEnd) //时间字符串格式转时间格式
  553. if resultTimeStart.After(time.Now()) {
  554. list[k].ActiveState = 1
  555. } else if time.Now().After(resultTimeEnd) {
  556. list[k].ActiveState = 3
  557. } else {
  558. list[k].ActiveState = 2
  559. }
  560. if list[k].Days == 0 {
  561. list[k].TripStatus = 1
  562. } else {
  563. list[k].TripStatus = 2
  564. }
  565. activityIds = append(activityIds, v.ActivityId)
  566. }
  567. //处理用户已经报名了的行程
  568. UserMap, e := GetSpecialTripUserMap(activityIds, user.UserId)
  569. if e != nil {
  570. err = errors.New("GetSpecialTripUserMap, Err: " + e.Error())
  571. return
  572. }
  573. for k, v := range list {
  574. if _, ok := UserMap[v.ActivityId]; ok {
  575. list[k].IsTrip = 1
  576. }
  577. }
  578. return
  579. }
  580. // 获取用户已经报名的活动
  581. func GetSpecialTripUserMap(activityIds []int, userId int) (mapUserId map[int]int, err error) {
  582. var condition string
  583. var pars []interface{}
  584. activityIdsLen := len(activityIds)
  585. if activityIdsLen > 0 {
  586. condition += ` AND activity_id IN (` + utils.GetOrmInReplace(activityIdsLen) + `)`
  587. pars = append(pars, activityIds)
  588. }
  589. condition += ` AND user_id = ? AND is_cancel = 0 `
  590. pars = append(pars, userId)
  591. list, e := models.GetCygxActivitySpecialTripList(condition, pars)
  592. if e != nil {
  593. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  594. return
  595. }
  596. mapUid := make(map[int]int)
  597. for _, v := range list {
  598. mapUid[v.ActivityId] = v.UserId
  599. }
  600. mapUserId = mapUid
  601. return
  602. }
  603. // 获取用户已经报名的活动数量
  604. func GetSpecialTripUserSchedule(userId int) (total int, err error) {
  605. var condition string
  606. var pars []interface{}
  607. condition += ` AND t.user_id = ? AND t.is_cancel = 0 `
  608. pars = append(pars, userId)
  609. condition += ` AND a.activity_time_end >= ? `
  610. pars = append(pars, time.Now())
  611. condition += ` AND is_valid = 1 `
  612. total, err = models.GetActivitySpecialTripCountByActivitySpecial(condition, pars)
  613. return
  614. }
  615. // GetActivitySpecialList 获取专项调研列表
  616. func GetActivitySpecialList(user *models.WxUserItem, currentIndex, pageSize int, keywords string) (list []*models.CygxActivitySpecialDetail, total int, err error) {
  617. listConfirm, totalConfirm, e := GetActivityLabelSpecialConfirmList(user, (currentIndex-1)*pageSize, pageSize, 4, keywords)
  618. if e != nil && e.Error() != utils.ErrNoRow() {
  619. err = errors.New("GetActivityLabelSpecialConfirmList11, Err: " + e.Error())
  620. return
  621. }
  622. //if totalConfirm == 0 {
  623. // return
  624. //}
  625. if currentIndex == 1 && len(listConfirm) > 0 {
  626. listConfirm[0].Explain = utils.ACtIVITY_SPECIAL_TRIP_EXPLAIN
  627. }
  628. list = listConfirm
  629. total = totalConfirm
  630. var startSizePrepare, pageSizePrepare int
  631. //全是确定行程的查询数据
  632. if totalConfirm >= currentIndex*pageSize {
  633. startSizePrepare = 0
  634. pageSizePrepare = 0
  635. } else if totalConfirm > (currentIndex-1)*pageSize && totalConfirm < currentIndex*pageSize {
  636. //一半确认行程一半预报名
  637. startSizePrepare = 0
  638. pageSizePrepare = pageSize - len(listConfirm)
  639. } else {
  640. //全是预报名
  641. startSizePrepare = (currentIndex-1)*pageSize - totalConfirm
  642. pageSizePrepare = pageSize - len(listConfirm)
  643. }
  644. listPrepare, totalPrepare, e := GetActivitySpecialPrepareList(user, startSizePrepare, pageSizePrepare, keywords)
  645. if e != nil && e.Error() != utils.ErrNoRow() {
  646. err = errors.New("GetActivityLabelSpecialConfirmList, Err: " + e.Error())
  647. return
  648. }
  649. if len(listPrepare) > 0 {
  650. for _, v := range listPrepare {
  651. list = append(list, v)
  652. }
  653. if startSizePrepare == 0 {
  654. listPrepare[0].Explain = utils.ACtIVITY_SPECIAL_EXPLAIN
  655. }
  656. }
  657. total = totalConfirm + totalPrepare
  658. //处理封面图片
  659. detail, e := models.GetConfigByCode("city_img_url")
  660. if e != nil {
  661. err = errors.New("GetConfigByCode, Err: " + e.Error())
  662. return
  663. }
  664. detailChart, e := models.GetConfigByCode("chart_img_url")
  665. if e != nil {
  666. err = errors.New("GetConfigByCode, Err: " + e.Error())
  667. return
  668. }
  669. addressList := strings.Split(detail.ConfigValue, "{|}")
  670. mapAddress := make(map[string]string)
  671. chartList := strings.Split(detailChart.ConfigValue, "{|}")
  672. mapChart := make(map[string]string)
  673. var cityName string
  674. var chartName string
  675. var imgUrl string
  676. var imgUrlChart string
  677. for _, v := range addressList {
  678. vslice := strings.Split(v, "_")
  679. cityName = vslice[0]
  680. imgUrl = vslice[len(vslice)-1]
  681. mapAddress[cityName] = imgUrl
  682. }
  683. for _, v := range chartList {
  684. vslice := strings.Split(v, "_")
  685. chartName = vslice[0]
  686. imgUrlChart = vslice[len(vslice)-1]
  687. mapChart[chartName] = imgUrlChart
  688. }
  689. for k, v := range list {
  690. //list[k].ImgUrlText = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202112/20211221/bIdfv8t86xrFRpDOeGGHXOmKEuKl.png"
  691. if mapChart[v.ChartPermissionName] != "" {
  692. list[k].ImgUrl = mapChart[v.ChartPermissionName]
  693. }
  694. list[k].ActivityTypeName = "专项调研"
  695. if list[k].Days == 0 {
  696. list[k].TripStatus = 1
  697. } else {
  698. list[k].TripStatus = 2
  699. list[k].TripImgLink = list[k].TripImgLinkFix
  700. }
  701. }
  702. return
  703. }
  704. // HandleActivitySpecialShow 处理活动的状态
  705. func HandleActivitySpecialShow(activityDetail *models.CygxActivitySpecialDetail, user *models.WxUserItem) (item *models.CygxActivitySpecialDetail, err error) {
  706. var activityIds []int
  707. resultTimeStart := utils.StrTimeToTime(activityDetail.ActivityTime) //时间字符串格式转时间格式
  708. resultTimeEnd := utils.StrTimeToTime(activityDetail.ActivityTimeEnd) //时间字符串格式转时间格式
  709. if resultTimeStart.After(time.Now()) {
  710. activityDetail.ActiveState = 1
  711. } else if time.Now().After(resultTimeEnd) {
  712. activityDetail.ActiveState = 3
  713. } else {
  714. activityDetail.ActiveState = 2
  715. }
  716. activityIds = append(activityIds, activityDetail.ActivityId)
  717. //处理用户已经报名了的行程
  718. UserMap, e := GetSpecialTripUserMap(activityIds, user.UserId)
  719. if e != nil {
  720. err = errors.New("GetSpecialTripUserMap, Err: " + e.Error())
  721. return
  722. }
  723. if activityDetail.Days == 0 {
  724. activityDetail.TripStatus = 1
  725. activityDetail.Explain = utils.ACtIVITY_SPECIAL_EXPLAIN
  726. } else {
  727. activityDetail.TripStatus = 2
  728. activityDetail.TripImgLink = activityDetail.TripImgLinkFix
  729. activityDetail.Explain = utils.ACtIVITY_SPECIAL_TRIP_EXPLAIN
  730. }
  731. if _, ok := UserMap[activityDetail.ActivityId]; ok {
  732. activityDetail.IsTrip = 1
  733. }
  734. item = activityDetail
  735. return
  736. }
  737. // 活动与专项调研搜索 GetActivitySpecialSearcheList
  738. func GetActivitySpecialSearcheList(user *models.WxUserItem, condition string, startSize, pageSize int, keywords string) (items []*models.ActivityDetail, total int, err error) {
  739. var conditionSpecil string
  740. var pars, parsSpecil []interface{}
  741. keyword := keywords
  742. if user.UserId == 0 {
  743. conditionSpecil += ` AND art.activity_id = 0 ` // 未登录的用户不查看专项调研活动 v12.2.1
  744. }
  745. if keywords != "" {
  746. keywords = "%" + keywords + "%"
  747. 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 ? ) `
  748. parsSpecil = append(parsSpecil, keywords, keywords, keywords, keywords)
  749. }
  750. list, totalSearche, e := models.GetActivitySpecialSearcheList(condition, pars, conditionSpecil, parsSpecil, startSize, pageSize)
  751. if e != nil {
  752. err = errors.New("GetActivitySpecialSearcheList, Err: " + e.Error())
  753. return
  754. }
  755. keyWordArr, e := GetIndustryMapNameSliceV3(keywords)
  756. if e != nil {
  757. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  758. return
  759. }
  760. var totalIk int
  761. if len(keyWordArr) > 1 {
  762. // 查询IK分词后那一部分的数据
  763. conditionActivityIk, e := GetActivityonditionList(user, "", "", "", "", "", 0, 1, keyword, 0, 2)
  764. if e != nil && e.Error() != utils.ErrNoRow() {
  765. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  766. return
  767. }
  768. conditionActivityIk += " AND art.is_limit_people = 1 AND art.publish_status = 1 "
  769. totalIk, e = models.GetActivityCount(conditionActivityIk, 0, pars, 0)
  770. if e != nil {
  771. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  772. return
  773. }
  774. keyWordArr = RemoveDuplicatesAndEmpty(keyWordArr)
  775. startSizeIk := startSize - totalSearche
  776. if startSizeIk < 0 {
  777. startSizeIk = 0
  778. }
  779. var pageSizeIk int
  780. pageSizeIk = pageSize - len(list)
  781. if pageSizeIk > 0 {
  782. //搜索关键词联想
  783. conditionActivityIk += ` ORDER BY art.activity_time DESC , art.active_state ASC `
  784. listIk, e := models.GetActivityListNew(conditionActivityIk, pars, user.UserId, startSizeIk, pageSizeIk, 0, 0, "")
  785. if e != nil {
  786. err = errors.New("GetActivityonditionList, Err: " + e.Error())
  787. return
  788. }
  789. for _, item := range listIk {
  790. list = append(list, item)
  791. }
  792. }
  793. }
  794. total = totalSearche + totalIk
  795. items, e = HandleActivityListButton(list, user)
  796. if e != nil {
  797. err = errors.New("HandleActivityListButton, Err: " + e.Error())
  798. return
  799. }
  800. return
  801. }
  802. // 获取 专项调研客户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //8、行业升级套餐客户 //9、其余正式客户;5、试用客户
  803. func GetActivitySpecialUserType(companyId int) (userType int, permissionStrnew string, err error) {
  804. var permissionStr string
  805. if companyId <= 1 {
  806. userType = 0
  807. } else {
  808. total, e := models.GetCountCompanyDetailByIdGroupTrip(companyId)
  809. if e != nil {
  810. err = errors.New("GetCountCompanyDetailByIdGroupTrip, Err: " + e.Error())
  811. return
  812. }
  813. if total == 0 {
  814. userType = 0
  815. } else {
  816. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(companyId)
  817. if e != nil {
  818. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  819. return
  820. }
  821. permissionStr, e = models.GetCompanyPermissionByUserTrip(companyId)
  822. if e != nil {
  823. err = errors.New("GetCompanyPermissionByUserTrip, Err: " + e.Error())
  824. return
  825. }
  826. //permissionZhengShiStr, e = models.GetCompanyPermissionByUserZhengShiTrip(companyId)
  827. //if e != nil {
  828. // err = errors.New("GetCompanyPermissionByUserZhengShiTrip, Err: " + e.Error())
  829. // return
  830. //}
  831. //大套餐客户定义:医药、消费、科技、智造。4个行业中为升级,策略是正式,属于大套餐客户
  832. if companyDetail.Status == "永续" {
  833. userType = 1
  834. } else if companyDetail.Status == "试用" {
  835. userType = 5
  836. } else if companyDetail.Status == "正式" {
  837. if permissionStr == "专家" {
  838. userType = 4
  839. } else if strings.Count(permissionStr, "医药") == 2 && strings.Count(permissionStr, "消费") == 2 && strings.Count(permissionStr, "科技") == 2 && strings.Count(permissionStr, "智造") == 2 && strings.Count(permissionStr, "策略") == 1 {
  840. userType = 2
  841. } else {
  842. userType = 3
  843. }
  844. if userType == 3 {
  845. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  846. userType = 4
  847. }
  848. }
  849. } else if companyDetail.Status == "冻结" {
  850. userType = 6
  851. } else if companyDetail.Status == "流失" {
  852. userType = 7
  853. }
  854. }
  855. }
  856. permissionStrnew = permissionStr
  857. return
  858. }
  859. // GetSpecialUserType 获取专项产业调研的用户身份类型
  860. // 获取 专项调研客户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //8、行业升级套餐客户 //9、其余正式客户;5、试用客户
  861. func GetSpecialUserType(user *models.WxUserItem) (userType int, err error) {
  862. companyId := user.CompanyId
  863. companyDetail, e := models.GetCompanyDetailByIdGroupTrip(companyId)
  864. if e != nil && e.Error() != utils.ErrNoRow() {
  865. err = errors.New("GetCompanyDetailByIdGroupTrip, Err: " + e.Error())
  866. return
  867. }
  868. if companyDetail == nil {
  869. return
  870. }
  871. if companyId <= 1 {
  872. userType = 0
  873. } else {
  874. if companyDetail.Status == "永续" {
  875. userType = 1
  876. } else {
  877. if companyDetail.Status == "正式" {
  878. list, e := models.GetCompanyReportPermissionUpgrade(companyId, 2)
  879. if e != nil && e.Error() != utils.ErrNoRow() {
  880. err = errors.New("GetCompanyReportPermissionUpgrade, Err: " + e.Error())
  881. }
  882. if len(list) == 0 {
  883. userType = 9
  884. }
  885. if len(list) == 4 {
  886. totalName, e := models.GetCompanyPermissionNameCheck(companyId, 2, "策略")
  887. if e != nil {
  888. err = errors.New("获取品种信息失败, Err:" + e.Error())
  889. return
  890. }
  891. if totalName > 0 {
  892. userType = 2
  893. } else {
  894. userType = 8
  895. }
  896. } else {
  897. userType = 8
  898. }
  899. } else if companyDetail.Status == "试用" {
  900. userType = 5
  901. }
  902. }
  903. }
  904. return
  905. }
  906. // GetSpecialDetailUserPower 处理用户查看专项调研详情的权限
  907. func GetSpecialDetailUserPower(user *models.WxUserItem, activityInfo *models.CygxActivitySpecialDetail) (havePower bool, err error) {
  908. if user.CompanyId == utils.HZ_COMPANY_ID {
  909. havePower = true
  910. return
  911. }
  912. userType, _, e := GetUserType(user.CompanyId)
  913. if e != nil {
  914. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  915. return
  916. }
  917. if userType == 0 {
  918. return
  919. }
  920. mapUserType, e := GetActivityCcustomerTypeList()
  921. if e != nil {
  922. err = e
  923. return
  924. }
  925. var userTypeStr string
  926. userTypeStr = mapUserType[userType]
  927. // 永续客户、大套餐客户可以查看行业升级套餐客户 权限
  928. if userTypeStr == "1" || userTypeStr == "2" {
  929. if strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) || strings.Contains(activityInfo.CustomerTypeIds, "8") {
  930. havePower = true
  931. return
  932. }
  933. }
  934. permissionStr, e := GetCompanyPermissionUpgrade(user.CompanyId)
  935. if e != nil {
  936. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  937. return
  938. }
  939. //如果没有对应的升级权限,则返回
  940. if !strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  941. return
  942. }
  943. //userType, e := GetSpecialUserType(user)
  944. var pars []interface{}
  945. var condition string
  946. var userTypes string
  947. condition += ` AND art.publish_status = 1 AND art.is_offline = 0 `
  948. userTypes = "%" + userTypeStr + "%"
  949. condition += ` AND art.customer_type_ids LIKE ? `
  950. pars = append(pars, userTypes)
  951. condition += ` AND art.activity_id = ? `
  952. pars = append(pars, activityInfo.ActivityId)
  953. total, e := models.GetActivitySpecialCount(condition, pars)
  954. if e != nil {
  955. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  956. return
  957. }
  958. if total == 1 {
  959. havePower = true
  960. return
  961. }
  962. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, "8") {
  963. havePower = true
  964. return
  965. }
  966. return
  967. }
  968. // 预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳
  969. func SendWxMsgActivitySpecial10(activityInfo *models.CygxActivitySpecialDetail) (err error) {
  970. activityId := activityInfo.ActivityId
  971. var msg string
  972. defer func() {
  973. if err != nil {
  974. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  975. go utils.SendAlarmMsg(fmt.Sprint("预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳消息发送失败", activityInfo.ResearchTheme, ", activityId"), 2)
  976. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  977. }
  978. }()
  979. var first string
  980. var keyword1 string
  981. var keyword2 string
  982. var keyword3 string
  983. var keyword4 string
  984. var remark string
  985. adminUser, e := models.GetSellerByAdminId(activityInfo.AdminId)
  986. if e != nil {
  987. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  988. return
  989. }
  990. cnf, _ := models.GetConfigByCode("tpl_msg")
  991. mobile := adminUser.Mobile + "," + cnf.ConfigValue
  992. specialSignupList, e := models.GetActivityListSpecialByActivityId(activityId)
  993. if e != nil {
  994. err = errors.New("GetActivityListSpecialAll, Err: " + e.Error())
  995. return
  996. }
  997. for _, v := range specialSignupList {
  998. keyword1 += "【" + v.RealName + "--" + v.CompanyName + "】"
  999. }
  1000. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  1001. if e != nil {
  1002. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1003. return
  1004. }
  1005. first = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
  1006. keyword3 = "-"
  1007. keyword2 = "-"
  1008. keyword4 = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
  1009. openIdArr := make([]string, 0)
  1010. for _, v := range openIdList {
  1011. openIdArr = append(openIdArr, v.OpenId)
  1012. }
  1013. redirectUrl := utils.WX_MSG_PATH_ACTIVITY_SPECIAL_DETAIL + strconv.Itoa(activityId)
  1014. sendInfo := new(SendWxTemplate)
  1015. sendInfo.First = first
  1016. sendInfo.Keyword1 = keyword1
  1017. sendInfo.Keyword2 = keyword2
  1018. sendInfo.Keyword3 = keyword3
  1019. sendInfo.Keyword4 = keyword4
  1020. sendInfo.Remark = remark
  1021. sendInfo.TemplateId = utils.WxMsgTemplateIdAskMsgXzs
  1022. sendInfo.RedirectUrl = redirectUrl
  1023. sendInfo.RedirectTarget = 3
  1024. sendInfo.Resource = strconv.Itoa(activityId)
  1025. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  1026. sendInfo.OpenIdArr = openIdArr
  1027. err = PublicSendTemplateMsg(sendInfo)
  1028. if err != nil {
  1029. return
  1030. }
  1031. return
  1032. }
  1033. // SendWxMsgActivitySpecialTwoDays 活动开始前两天08:00,提醒报名客户 \提醒报名客户的对口销售
  1034. func SendWxMsgActivitySpecialTwoDays(cont context.Context) (err error) {
  1035. //func SendWxMsgActivitySpecialTwoDays() (err error) {
  1036. var msg string
  1037. defer func() {
  1038. if err != nil {
  1039. fmt.Println(err)
  1040. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  1041. go utils.SendAlarmMsg(fmt.Sprint(" 活动开始前两天08:00,提醒报名客户、提醒报名客户的对口销售消息发送失败"), 2)
  1042. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  1043. }
  1044. }()
  1045. twoDayTime := time.Now().AddDate(0, 0, 2)
  1046. startTime := twoDayTime.Format(utils.FormatDate) + " 00:00:00"
  1047. endTime := twoDayTime.Format(utils.FormatDate) + " 23:59:59"
  1048. var condition string
  1049. var pars []interface{}
  1050. condition = ` AND days >0 AND activity_time BETWEEN ? AND ? `
  1051. pars = append(pars, startTime, endTime)
  1052. listActivitySpecial, e := models.GetActivitySpecialListAll(condition, pars, 0, 1000)
  1053. if e != nil {
  1054. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1055. return
  1056. }
  1057. if len(listActivitySpecial) == 0 {
  1058. return
  1059. }
  1060. var activityIds []int
  1061. for _, v := range listActivitySpecial {
  1062. activityIds = append(activityIds, v.ActivityId)
  1063. condition = ` AND is_cancel = 0 AND activity_id = ` + strconv.Itoa(v.ActivityId)
  1064. pars = make([]interface{}, 0)
  1065. listSpecialTrip, e := models.GetCygxActivitySpecialTripList(condition, pars)
  1066. if e != nil {
  1067. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  1068. return
  1069. }
  1070. if len(listSpecialTrip) == 0 {
  1071. return
  1072. }
  1073. var mobile string
  1074. var companyIds []int
  1075. for _, vT := range listSpecialTrip {
  1076. mobile += "'" + vT.Mobile + "',"
  1077. companyIds = append(companyIds, vT.CompanyId)
  1078. }
  1079. mobile = strings.TrimRight(mobile, ",")
  1080. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  1081. if e != nil {
  1082. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1083. return
  1084. }
  1085. first := ""
  1086. keyword1 := "专项调研【" + v.ResearchTheme + "】"
  1087. keyword2 := "将在两天后进行,如不能参加,请及时取消报名"
  1088. keyword3 := ""
  1089. keyword4 := ""
  1090. remark := "点击查看活动详情"
  1091. SendWxMsgWithFrequencySpecial(first, keyword1, keyword2, keyword3, keyword4, remark, openIdList, v.ActivityId)
  1092. //活动开始前两天08:00,提醒报名客户的对口销售
  1093. companyIdsLen := len(companyIds)
  1094. if companyIdsLen == 0 {
  1095. continue
  1096. } else {
  1097. pars = make([]interface{}, 0)
  1098. condition = ` AND p.company_id IN (` + utils.GetOrmInReplace(companyIdsLen) + `) GROUP BY p.company_id `
  1099. pars = append(pars, companyIds)
  1100. //获取销售的手机号
  1101. listSeller, e := models.GetAdminOpendidByCompany(condition, pars)
  1102. if e != nil && e.Error() != utils.ErrNoRow() {
  1103. err = errors.New("GetAdminOpendidByCompany, Err: " + e.Error())
  1104. return
  1105. }
  1106. if len(listSeller) == 0 {
  1107. continue
  1108. }
  1109. var mobileArr []string
  1110. for _, v := range listSeller {
  1111. if v.Mobile != "" {
  1112. mobileArr = append(mobileArr, v.Mobile)
  1113. }
  1114. }
  1115. mobileLen := len(mobileArr)
  1116. if mobileLen == 0 {
  1117. return
  1118. }
  1119. //获取手机号对应的Openid
  1120. listSellerOpenid, e := models.GetWxOpenIdByMobileSliceList(mobileArr)
  1121. if e != nil && e.Error() != utils.ErrNoRow() {
  1122. err = errors.New("GetWxOpenIdByMobileSliceList, Err: " + e.Error())
  1123. return
  1124. }
  1125. mapMobileOpenid := make(map[string]string)
  1126. for _, v := range listSellerOpenid {
  1127. mapMobileOpenid[v.Mobile] = v.OpenId
  1128. }
  1129. mapSller := make(map[string]string)
  1130. mapSllerOpenid := make(map[string]string)
  1131. for _, vS := range listSeller {
  1132. for _, vT := range listSpecialTrip {
  1133. if vT.CompanyId == vS.CompanyId {
  1134. mapSller[vS.Mobile] += "【" + vT.RealName + "--" + vT.CompanyName + "】"
  1135. mapSllerOpenid[vS.Mobile] = mapMobileOpenid[vS.Mobile]
  1136. }
  1137. }
  1138. }
  1139. for k, _ := range mapSller {
  1140. keyword2 = "将在两天后进行,请及时提醒您的报名客户"
  1141. openIdList = make([]*models.OpenIdList, 0)
  1142. openIdList = append(openIdList, &models.OpenIdList{OpenId: mapSllerOpenid[k]})
  1143. SendWxMsgWithFrequencySpecial(first, keyword1, keyword2, keyword3, keyword4, remark, openIdList, v.ActivityId)
  1144. }
  1145. }
  1146. }
  1147. return
  1148. }
  1149. // SendWxMsgActivitySpecialCancel 线下活动前4天08:00报名人数不足7人,线上活动前3天08:00报名人数不足10人,活动自动取消发布,并推送模板消息至报名客户及对口销售
  1150. func SendWxMsgActivitySpecialCancel(cont context.Context) (err error) {
  1151. var msg string
  1152. defer func() {
  1153. if err != nil {
  1154. fmt.Println(err)
  1155. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  1156. go utils.SendAlarmMsg(fmt.Sprint(" 活动开始前两天08:00,提醒报名客户、提醒报名客户的对口销售消息发送失败"), 2)
  1157. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  1158. }
  1159. }()
  1160. dayTime3 := time.Now().AddDate(0, 0, 3)
  1161. startTime := dayTime3.Format(utils.FormatDate) + " 00:00:00"
  1162. endTime := dayTime3.Format(utils.FormatDate) + " 23:59:59"
  1163. dayTime4 := time.Now().AddDate(0, 0, 4)
  1164. startTime4 := dayTime4.Format(utils.FormatDate) + " 00:00:00"
  1165. endTime4 := dayTime4.Format(utils.FormatDate) + " 23:59:59"
  1166. var condition string
  1167. var pars []interface{}
  1168. condition = ` AND days >0 AND activity_time BETWEEN ? AND ? AND special_type= 1 `
  1169. pars = append(pars, startTime, endTime)
  1170. condition += ` OR ( days >0 AND activity_time BETWEEN ? AND ? AND special_type= 2 ) `
  1171. pars = append(pars, startTime4, endTime4)
  1172. listActivitySpecial, e := models.GetActivitySpecialListAll(condition, pars, 0, 1000)
  1173. if e != nil {
  1174. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1175. return
  1176. }
  1177. if len(listActivitySpecial) == 0 {
  1178. return
  1179. }
  1180. var activityIds []int
  1181. for _, v := range listActivitySpecial {
  1182. activityIds = append(activityIds, v.ActivityId)
  1183. condition = ` AND is_cancel = 0 AND activity_id = ` + strconv.Itoa(v.ActivityId)
  1184. pars = make([]interface{}, 0)
  1185. listSpecialTrip, e := models.GetCygxActivitySpecialTripList(condition, pars)
  1186. if e != nil {
  1187. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  1188. return
  1189. }
  1190. if v.SpecialType == 1 {
  1191. if len(listSpecialTrip) >= 10 {
  1192. continue
  1193. }
  1194. }
  1195. if v.SpecialType == 2 {
  1196. if len(listSpecialTrip) >= 7 {
  1197. continue
  1198. }
  1199. }
  1200. e = models.UpdateActivitySpecialPublishStatus(0, v.ActivityId)
  1201. if e != nil {
  1202. err = errors.New("UpdateActivitySpecialPublishStatus,自动取消专项调研日程失败 Err: " + e.Error() + strconv.Itoa(v.ActivityId))
  1203. return
  1204. }
  1205. if len(listSpecialTrip) < 0 {
  1206. return
  1207. }
  1208. var mobile string
  1209. var companyIds []int
  1210. for _, vT := range listSpecialTrip {
  1211. mobile += "'" + vT.Mobile + "',"
  1212. companyIds = append(companyIds, vT.CompanyId)
  1213. }
  1214. mobile = strings.TrimRight(mobile, ",")
  1215. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  1216. if e != nil {
  1217. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1218. return
  1219. }
  1220. first := "【" + v.ResearchTheme + "】专项调研因专家安排变动,本次调研活动延期举办,具体时间另行通知"
  1221. keyword1 := v.ResearchTheme
  1222. keyword2 := "已取消"
  1223. keyword3 := ""
  1224. keyword4 := ""
  1225. remark := ""
  1226. openIdArr := make([]string, 0)
  1227. for _, vOpenid := range openIdList {
  1228. openIdArr = append(openIdArr, vOpenid.OpenId)
  1229. }
  1230. companyIdsLen := len(companyIds)
  1231. if len(companyIds) > 0 {
  1232. pars = make([]interface{}, 0)
  1233. condition = ` AND p.company_id IN (` + utils.GetOrmInReplace(companyIdsLen) + `) GROUP BY p.company_id `
  1234. pars = append(pars, companyIds)
  1235. listSeller, e := models.GetAdminOpendidByCompany(condition, pars)
  1236. if e != nil && e.Error() != utils.ErrNoRow() {
  1237. err = errors.New("GetAdminOpendidByCompany, Err: " + e.Error())
  1238. return
  1239. }
  1240. if len(listSeller) == 0 {
  1241. continue
  1242. }
  1243. var mobileArr []string
  1244. for _, v := range listSeller {
  1245. if v.Mobile != "" {
  1246. mobileArr = append(mobileArr, v.Mobile)
  1247. }
  1248. }
  1249. mobileLen := len(mobileArr)
  1250. if mobileLen == 0 {
  1251. return
  1252. }
  1253. //获取手机号对应的Openid
  1254. listSellerOpenid, e := models.GetWxOpenIdByMobileSliceList(mobileArr)
  1255. if e != nil && e.Error() != utils.ErrNoRow() {
  1256. err = errors.New("GetWxOpenIdByMobileSliceList, Err: " + e.Error())
  1257. return
  1258. }
  1259. if len(listSellerOpenid) > 0 {
  1260. for _, vOpenid := range listSellerOpenid {
  1261. openIdArr = append(openIdArr, vOpenid.OpenId)
  1262. }
  1263. }
  1264. }
  1265. redirectUrl := ""
  1266. sendInfo := new(SendWxTemplate)
  1267. sendInfo.First = first
  1268. sendInfo.Keyword1 = keyword1
  1269. sendInfo.Keyword2 = keyword2
  1270. sendInfo.Keyword3 = keyword3
  1271. sendInfo.Keyword4 = keyword4
  1272. sendInfo.Remark = remark
  1273. sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
  1274. sendInfo.RedirectUrl = redirectUrl
  1275. sendInfo.RedirectTarget = 3
  1276. sendInfo.Resource = strconv.Itoa(v.ActivityId)
  1277. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  1278. sendInfo.OpenIdArr = openIdArr
  1279. fmt.Println(sendInfo)
  1280. err = PublicSendTemplateMsg(sendInfo)
  1281. }
  1282. return
  1283. }
  1284. func GetChartPermissionSpecialSurplusByCompany(companyId int) (userType int, tripRemaining int, mapChartName map[string]int, err error) {
  1285. companyDetail, e := models.GetCompanyDetailByIdGroup(companyId)
  1286. if e != nil {
  1287. err = errors.New("GetCompanyDetailByIdGroup, Err: " + e.Error())
  1288. }
  1289. if companyDetail == nil {
  1290. return
  1291. }
  1292. if companyDetail.Status != "永续" && companyDetail.Status != "正式" {
  1293. return
  1294. }
  1295. var specialSurplus string
  1296. if companyDetail.Status == "永续" {
  1297. specialSurplus = "不限次数"
  1298. }
  1299. //chartMap := map[int]string{utils.YI_YAO_ID:utils.YI_YAO_NAME, utils.XIAO_FEI_ID:utils.XIAO_FEI_NAME, utils.KE_JI_ID:utils.KE_JI_NAME, utils.ZHI_ZAO_ID:utils.ZHI_ZAO_NAME}
  1300. //chartNumMap := map[int]int{utils.YI_YAO_ID:0, utils.XIAO_FEI_ID:0, utils.KE_JI_ID:0, utils.ZHI_ZAO_ID:0}
  1301. chartNameMap := map[string]int{utils.YI_YAO_NAME: 0, utils.XIAO_FEI_NAME: 0, utils.KE_JI_NAME: 0, utils.ZHI_ZAO_NAME: 0}
  1302. if companyDetail.Status == "正式" {
  1303. //var packageType int
  1304. userType, _, _ = GetUserType(companyId)
  1305. var condition string
  1306. var pars []interface{}
  1307. condition += ` AND company_id = ? `
  1308. pars = append(pars, companyId)
  1309. //查询当年的数据
  1310. condition += ` AND b.create_time >= ? `
  1311. pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
  1312. listTripBill, e := models.GetCygxActivitySpecialTripBillList(condition, pars)
  1313. if e != nil {
  1314. err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
  1315. return
  1316. }
  1317. PermissionNameMap, e := GetPermissionNameMap()
  1318. if e != nil {
  1319. err = errors.New("GetPermissionNameMap, Err: " + e.Error())
  1320. return
  1321. }
  1322. for k, v := range listTripBill {
  1323. listTripBill[k].ChartPermissionName = PermissionNameMap[v.ChartPermissionId]
  1324. }
  1325. // 获取继承点数
  1326. //inheritList, e := models.GetCygxActivitySpecialInheritPointsByCompanyId(companyId)
  1327. //if e != nil && e.Error() != utils.ErrNoRow() {
  1328. // err = errors.New("GetCygxActivitySpecialInheritPointsByCompanyId, Err: " + e.Error())
  1329. //}
  1330. if userType == 2 {
  1331. var tripBillNum int
  1332. for _, v := range listTripBill {
  1333. //if v.ActivityId == 0 {
  1334. // continue
  1335. //}
  1336. tripBillNum += v.BillDetailed
  1337. }
  1338. //if len(inheritList) > 0 {
  1339. // for _, v := range inheritList {
  1340. // if v.ChartPermissionId == 0 {
  1341. // tripBillNum += v.Points
  1342. // }
  1343. // }
  1344. //}
  1345. tripRemaining = tripBillNum
  1346. if tripRemaining < 0 {
  1347. tripRemaining = 0
  1348. }
  1349. } else {
  1350. list, e := models.GetCompanyReportPermissionByCompanyIdAndProductId(companyId, 2)
  1351. if e != nil && e.Error() != utils.ErrNoRow() {
  1352. err = errors.New("GetCompanyReportPermissionUpgrade, Err: " + e.Error())
  1353. }
  1354. if len(list) == 0 {
  1355. return
  1356. }
  1357. var chartPermissionIdSlice []string
  1358. mapChartName = make(map[string]int)
  1359. mapUpgradeId := make(map[int]int)
  1360. mapPermissionNameTrip := make(map[string]int)
  1361. mapInheritChartName := make(map[string]int)
  1362. //mapPermissionName := make(map[int]string)
  1363. for _, v := range list {
  1364. chartPermissionIdSlice = append(chartPermissionIdSlice, strconv.Itoa(v.ChartPermissionId))
  1365. //是升级套餐才有点数
  1366. if v.IsUpgrade == 1 {
  1367. mapUpgradeId[v.ChartPermissionId] = 1
  1368. }
  1369. }
  1370. chartList := make([]*models.ChartPermission, 0)
  1371. if len(chartPermissionIdSlice) > 0 {
  1372. chartList, e = models.GetChartPermissionByIds(chartPermissionIdSlice)
  1373. if e != nil {
  1374. err = errors.New("获取品种信息失败, Err:" + e.Error())
  1375. return
  1376. }
  1377. }
  1378. if len(chartList) == 0 {
  1379. return
  1380. }
  1381. for _, v := range listTripBill {
  1382. if v.ActivityId == 0 {
  1383. continue
  1384. }
  1385. mapPermissionNameTrip[v.ChartPermissionName] += v.BillDetailed
  1386. }
  1387. for _, v := range chartList {
  1388. //如果是升级则加点
  1389. if _, ok := mapUpgradeId[v.ChartPermissionId]; ok {
  1390. mapChartName[v.PermissionName] = 5 + mapPermissionNameTrip[v.PermissionName]
  1391. } else {
  1392. mapChartName[v.PermissionName] = mapPermissionNameTrip[v.PermissionName]
  1393. }
  1394. }
  1395. // 通过继承获得的加点
  1396. //for _, v := range inheritList {
  1397. // mapInheritChartName[v.ChartPermissionName] = v.Points
  1398. //}
  1399. for k, _ := range chartNameMap {
  1400. if _, ok := mapChartName[k]; ok {
  1401. if inherit, ok2 := mapInheritChartName[k]; ok2 {
  1402. mapChartName[k] += inherit
  1403. }
  1404. }
  1405. }
  1406. for k, v := range mapChartName {
  1407. if v > 0 {
  1408. specialSurplus += k + strconv.Itoa(v) + "次+"
  1409. }
  1410. }
  1411. specialSurplus = strings.TrimRight(specialSurplus, "+")
  1412. }
  1413. }
  1414. return
  1415. }
  1416. // 清零初始化用-去掉了正式用户的判断
  1417. func GetChartPermissionSpecialSurplusByCompanyForInit(companyId int) (userType int, tripRemaining int, mapChartName map[string]int, err error) {
  1418. companyDetail, e := models.GetCompanyDetailByIdGroup(companyId)
  1419. if e != nil {
  1420. err = errors.New("GetCompanyDetailByIdGroup, Err: " + e.Error())
  1421. }
  1422. if companyDetail == nil {
  1423. return
  1424. }
  1425. //if companyDetail.Status != "永续" && companyDetail.Status != "正式" {
  1426. // return
  1427. //}
  1428. //chartMap := map[int]string{utils.YI_YAO_ID:utils.YI_YAO_NAME, utils.XIAO_FEI_ID:utils.XIAO_FEI_NAME, utils.KE_JI_ID:utils.KE_JI_NAME, utils.ZHI_ZAO_ID:utils.ZHI_ZAO_NAME}
  1429. chartNumMap := map[int]int{utils.YI_YAO_ID: 0, utils.XIAO_FEI_ID: 0, utils.KE_JI_ID: 0, utils.ZHI_ZAO_ID: 0}
  1430. //var packageType int
  1431. userType, _, _ = GetUserType(companyId)
  1432. var condition string
  1433. var pars []interface{}
  1434. condition += ` AND company_id = ? `
  1435. pars = append(pars, companyId)
  1436. //查询当年的数据
  1437. condition += ` AND b.create_time >= ? `
  1438. pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
  1439. listTripBill, e := models.GetCygxActivitySpecialTripBillList(condition, pars)
  1440. if e != nil {
  1441. err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
  1442. return
  1443. }
  1444. // 获取继承点数
  1445. inheritList, e := models.GetCygxActivitySpecialInheritPointsByCompanyId(companyId)
  1446. if e != nil && e.Error() != utils.ErrNoRow() {
  1447. err = errors.New("GetCygxActivitySpecialInheritPointsByCompanyId, Err: " + e.Error())
  1448. }
  1449. if userType == 2 {
  1450. var tripBillNum int
  1451. for _, v := range listTripBill {
  1452. //if v.ActivityId == 0 {
  1453. // continue
  1454. //}
  1455. tripBillNum += v.BillDetailed
  1456. }
  1457. if len(inheritList) > 0 {
  1458. for _, v := range inheritList {
  1459. if v.ChartPermissionId == 0 {
  1460. tripBillNum += v.Points
  1461. }
  1462. }
  1463. }
  1464. tripRemaining = tripBillNum
  1465. if tripRemaining < 0 {
  1466. tripRemaining = 0
  1467. }
  1468. } else {
  1469. list, e := models.GetCompanyReportPermissionByCompanyIdAndProductIdForInit(companyId, 2)
  1470. if e != nil && e.Error() != utils.ErrNoRow() {
  1471. err = errors.New("GetCompanyReportPermissionByCompanyIdAndProductIdForInit, Err: " + e.Error())
  1472. }
  1473. if len(list) == 0 {
  1474. return
  1475. }
  1476. var chartPermissionIdSlice []string
  1477. mapChartName = make(map[string]int)
  1478. mapUpgradeId := make(map[int]int)
  1479. mapPermissionNameTrip := make(map[string]int)
  1480. mapInheritChartName := make(map[string]int)
  1481. //mapPermissionName := make(map[int]string)
  1482. for _, v := range list {
  1483. chartPermissionIdSlice = append(chartPermissionIdSlice, strconv.Itoa(v.ChartPermissionId))
  1484. //是升级套餐才有点数
  1485. if v.IsUpgrade == 1 {
  1486. mapUpgradeId[v.ChartPermissionId] = 1
  1487. }
  1488. }
  1489. chartList := make([]*models.ChartPermission, 0)
  1490. if len(chartPermissionIdSlice) > 0 {
  1491. chartList, e = models.GetChartPermissionByIds(chartPermissionIdSlice)
  1492. if e != nil {
  1493. err = errors.New("获取品种信息失败, Err:" + e.Error())
  1494. return
  1495. }
  1496. }
  1497. if len(chartList) == 0 {
  1498. return
  1499. }
  1500. for _, v := range listTripBill {
  1501. if v.ActivityId == 0 {
  1502. continue
  1503. }
  1504. mapPermissionNameTrip[v.ChartPermissionName] += v.BillDetailed
  1505. }
  1506. for _, v := range chartList {
  1507. if _, ok := chartNumMap[v.ChartPermissionId]; ok {
  1508. //如果是升级则加点
  1509. if _, ok := mapUpgradeId[v.ChartPermissionId]; ok {
  1510. mapChartName[v.PermissionName] = 5 + mapPermissionNameTrip[v.PermissionName]
  1511. } else {
  1512. mapChartName[v.PermissionName] = mapPermissionNameTrip[v.PermissionName]
  1513. }
  1514. }
  1515. }
  1516. // 通过继承获得的加点
  1517. for _, v := range inheritList {
  1518. mapInheritChartName[v.ChartPermissionName] = v.Points
  1519. }
  1520. for _, v := range mapChartName {
  1521. if v > 0 {
  1522. tripRemaining += v
  1523. }
  1524. }
  1525. }
  1526. return
  1527. }
  1528. // total初始化用-去掉了正式用户的判断
  1529. func GetChartPermissionSpecialSurplusByCompanyForInitTotal(companyId int) (userType int, tripRemaining int, mapChartName map[string]int, err error) {
  1530. companyDetail, e := models.GetCompanyDetailByIdGroup(companyId)
  1531. if e != nil {
  1532. err = errors.New("GetCompanyDetailByIdGroup, Err: " + e.Error())
  1533. }
  1534. if companyDetail == nil {
  1535. return
  1536. }
  1537. //if companyDetail.Status != "永续" && companyDetail.Status != "正式" {
  1538. // return
  1539. //}
  1540. //chartMap := map[int]string{utils.YI_YAO_ID:utils.YI_YAO_NAME, utils.XIAO_FEI_ID:utils.XIAO_FEI_NAME, utils.KE_JI_ID:utils.KE_JI_NAME, utils.ZHI_ZAO_ID:utils.ZHI_ZAO_NAME}
  1541. chartNumMap := map[int]int{utils.YI_YAO_ID: 0, utils.XIAO_FEI_ID: 0, utils.KE_JI_ID: 0, utils.ZHI_ZAO_ID: 0}
  1542. //var packageType int
  1543. userType, _, _ = GetUserType(companyId)
  1544. var condition string
  1545. var pars []interface{}
  1546. condition += ` AND company_id = ? `
  1547. pars = append(pars, companyId)
  1548. //查询当年的数据
  1549. condition += ` AND b.create_time >= ? `
  1550. pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
  1551. listTripBill, e := models.GetCygxActivitySpecialTripBillList(condition, pars)
  1552. if e != nil {
  1553. err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
  1554. return
  1555. }
  1556. // 获取继承点数
  1557. inheritList, e := models.GetCygxActivitySpecialInheritPointsByCompanyId(companyId)
  1558. if e != nil && e.Error() != utils.ErrNoRow() {
  1559. err = errors.New("GetCygxActivitySpecialInheritPointsByCompanyId, Err: " + e.Error())
  1560. }
  1561. if userType == 2 {
  1562. var tripBillNum int
  1563. for _, v := range listTripBill {
  1564. //if v.ActivityId == 0 {
  1565. // continue
  1566. //}
  1567. tripBillNum += v.BillDetailed
  1568. }
  1569. if len(inheritList) > 0 {
  1570. for _, v := range inheritList {
  1571. if v.ChartPermissionId == 0 {
  1572. tripBillNum += v.Points
  1573. }
  1574. }
  1575. }
  1576. tripRemaining = tripBillNum
  1577. if tripRemaining < 0 {
  1578. tripRemaining = 0
  1579. }
  1580. } else {
  1581. list, e := models.GetCompanyReportPermissionByCompanyIdAndProductIdForInit2(companyId, 2)
  1582. if e != nil && e.Error() != utils.ErrNoRow() {
  1583. err = errors.New("GetCompanyReportPermissionByCompanyIdAndProductIdForInit, Err: " + e.Error())
  1584. }
  1585. if len(list) == 0 {
  1586. return
  1587. }
  1588. var chartPermissionIdSlice []string
  1589. mapChartName = make(map[string]int)
  1590. mapUpgradeId := make(map[int]int)
  1591. mapPermissionNameTrip := make(map[string]int)
  1592. mapInheritChartName := make(map[string]int)
  1593. //mapPermissionName := make(map[int]string)
  1594. for _, v := range list {
  1595. chartPermissionIdSlice = append(chartPermissionIdSlice, strconv.Itoa(v.ChartPermissionId))
  1596. //是升级套餐才有点数
  1597. if v.IsUpgrade == 1 {
  1598. mapUpgradeId[v.ChartPermissionId] = 1
  1599. }
  1600. }
  1601. chartList := make([]*models.ChartPermission, 0)
  1602. if len(chartPermissionIdSlice) > 0 {
  1603. chartList, e = models.GetChartPermissionByIds(chartPermissionIdSlice)
  1604. if e != nil {
  1605. err = errors.New("获取品种信息失败, Err:" + e.Error())
  1606. return
  1607. }
  1608. }
  1609. if len(chartList) == 0 {
  1610. return
  1611. }
  1612. for _, v := range listTripBill {
  1613. if v.ActivityId == 0 {
  1614. continue
  1615. }
  1616. mapPermissionNameTrip[v.ChartPermissionName] += v.BillDetailed
  1617. }
  1618. for _, v := range chartList {
  1619. if _, ok := chartNumMap[v.ChartPermissionId]; ok {
  1620. //如果是升级则加点
  1621. if _, ok := mapUpgradeId[v.ChartPermissionId]; ok {
  1622. mapChartName[v.PermissionName] = 5 + mapPermissionNameTrip[v.PermissionName]
  1623. } else {
  1624. mapChartName[v.PermissionName] = mapPermissionNameTrip[v.PermissionName]
  1625. }
  1626. }
  1627. }
  1628. // 通过继承获得的加点
  1629. for _, v := range inheritList {
  1630. mapInheritChartName[v.ChartPermissionName] = v.Points
  1631. }
  1632. for _, v := range mapChartName {
  1633. if v > 0 {
  1634. tripRemaining += v
  1635. }
  1636. }
  1637. }
  1638. return
  1639. }