activity_special.go 53 KB

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