activity_special.go 57 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749
  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 permissionStr != "" {
  941. if activityInfo.ChartPermissionName == utils.CE_LUE_NAME {
  942. permissionStr += "," + utils.CE_LUE_NAME
  943. }
  944. }
  945. //如果没有对应的升级权限,则返回
  946. if !strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  947. return
  948. }
  949. //userType, e := GetSpecialUserType(user)
  950. var pars []interface{}
  951. var condition string
  952. var userTypes string
  953. condition += ` AND art.publish_status = 1 AND art.is_offline = 0 `
  954. userTypes = "%" + userTypeStr + "%"
  955. condition += ` AND art.customer_type_ids LIKE ? `
  956. pars = append(pars, userTypes)
  957. condition += ` AND art.activity_id = ? `
  958. pars = append(pars, activityInfo.ActivityId)
  959. total, e := models.GetActivitySpecialCount(condition, pars)
  960. if e != nil {
  961. err = errors.New("GetSpecialUserType, Err: " + e.Error())
  962. return
  963. }
  964. if total == 1 {
  965. havePower = true
  966. return
  967. }
  968. fmt.Println(userType)
  969. fmt.Println(permissionStr)
  970. fmt.Println(activityInfo.ChartPermissionName)
  971. fmt.Println(activityInfo.CustomerTypeIds)
  972. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, "8") {
  973. havePower = true
  974. return
  975. }
  976. return
  977. }
  978. // 预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳
  979. func SendWxMsgActivitySpecial10(activityInfo *models.CygxActivitySpecialDetail) (err error) {
  980. activityId := activityInfo.ActivityId
  981. var msg string
  982. defer func() {
  983. if err != nil {
  984. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  985. go utils.SendAlarmMsg(fmt.Sprint("预报名活动,感兴趣人数满10人时,推送给活动负责人和王芳消息发送失败", activityInfo.ResearchTheme, ", activityId"), 2)
  986. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  987. }
  988. }()
  989. var first string
  990. var keyword1 string
  991. var keyword2 string
  992. var keyword3 string
  993. var keyword4 string
  994. var remark string
  995. adminUser, e := models.GetSellerByAdminId(activityInfo.AdminId)
  996. if e != nil {
  997. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  998. return
  999. }
  1000. cnf, _ := models.GetConfigByCode("tpl_msg")
  1001. mobile := adminUser.Mobile + "," + cnf.ConfigValue
  1002. specialSignupList, e := models.GetActivityListSpecialByActivityId(activityId)
  1003. if e != nil {
  1004. err = errors.New("GetActivityListSpecialAll, Err: " + e.Error())
  1005. return
  1006. }
  1007. for _, v := range specialSignupList {
  1008. keyword1 += "【" + v.RealName + "--" + v.CompanyName + "】"
  1009. }
  1010. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  1011. if e != nil {
  1012. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1013. return
  1014. }
  1015. first = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
  1016. keyword3 = "-"
  1017. keyword2 = "-"
  1018. keyword4 = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
  1019. openIdArr := make([]string, 0)
  1020. for _, v := range openIdList {
  1021. openIdArr = append(openIdArr, v.OpenId)
  1022. }
  1023. redirectUrl := utils.WX_MSG_PATH_ACTIVITY_SPECIAL_DETAIL + strconv.Itoa(activityId)
  1024. sendInfo := new(SendWxTemplate)
  1025. sendInfo.First = first
  1026. sendInfo.Keyword1 = keyword1
  1027. sendInfo.Keyword2 = keyword2
  1028. sendInfo.Keyword3 = keyword3
  1029. sendInfo.Keyword4 = keyword4
  1030. sendInfo.Remark = remark
  1031. sendInfo.TemplateId = utils.WxMsgTemplateIdAskMsgXzs
  1032. sendInfo.RedirectUrl = redirectUrl
  1033. sendInfo.RedirectTarget = 3
  1034. sendInfo.Resource = strconv.Itoa(activityId)
  1035. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  1036. sendInfo.OpenIdArr = openIdArr
  1037. err = PublicSendTemplateMsg(sendInfo)
  1038. if err != nil {
  1039. return
  1040. }
  1041. return
  1042. }
  1043. // SendWxMsgActivitySpecialTwoDays 活动开始前两天08:00,提醒报名客户 \提醒报名客户的对口销售
  1044. func SendWxMsgActivitySpecialTwoDays(cont context.Context) (err error) {
  1045. //func SendWxMsgActivitySpecialTwoDays() (err error) {
  1046. var msg string
  1047. defer func() {
  1048. if err != nil {
  1049. fmt.Println(err)
  1050. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  1051. go utils.SendAlarmMsg(fmt.Sprint(" 活动开始前两天08:00,提醒报名客户、提醒报名客户的对口销售消息发送失败"), 2)
  1052. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  1053. }
  1054. }()
  1055. twoDayTime := time.Now().AddDate(0, 0, 2)
  1056. startTime := twoDayTime.Format(utils.FormatDate) + " 00:00:00"
  1057. endTime := twoDayTime.Format(utils.FormatDate) + " 23:59:59"
  1058. var condition string
  1059. var pars []interface{}
  1060. condition = ` AND days >0 AND activity_time BETWEEN ? AND ? `
  1061. pars = append(pars, startTime, endTime)
  1062. listActivitySpecial, e := models.GetActivitySpecialListAll(condition, pars, 0, 1000)
  1063. if e != nil {
  1064. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1065. return
  1066. }
  1067. if len(listActivitySpecial) == 0 {
  1068. return
  1069. }
  1070. var activityIds []int
  1071. for _, v := range listActivitySpecial {
  1072. activityIds = append(activityIds, v.ActivityId)
  1073. condition = ` AND is_cancel = 0 AND activity_id = ` + strconv.Itoa(v.ActivityId)
  1074. pars = make([]interface{}, 0)
  1075. listSpecialTrip, e := models.GetCygxActivitySpecialTripList(condition, pars)
  1076. if e != nil {
  1077. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  1078. return
  1079. }
  1080. if len(listSpecialTrip) == 0 {
  1081. return
  1082. }
  1083. var mobile string
  1084. var companyIds []int
  1085. for _, vT := range listSpecialTrip {
  1086. mobile += "'" + vT.Mobile + "',"
  1087. companyIds = append(companyIds, vT.CompanyId)
  1088. }
  1089. mobile = strings.TrimRight(mobile, ",")
  1090. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  1091. if e != nil {
  1092. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1093. return
  1094. }
  1095. first := ""
  1096. keyword1 := "专项调研【" + v.ResearchTheme + "】"
  1097. keyword2 := "将在两天后进行,如不能参加,请及时取消报名"
  1098. keyword3 := ""
  1099. keyword4 := ""
  1100. remark := "点击查看活动详情"
  1101. SendWxMsgWithFrequencySpecial(first, keyword1, keyword2, keyword3, keyword4, remark, openIdList, v.ActivityId)
  1102. //活动开始前两天08:00,提醒报名客户的对口销售
  1103. companyIdsLen := len(companyIds)
  1104. if companyIdsLen == 0 {
  1105. continue
  1106. } else {
  1107. pars = make([]interface{}, 0)
  1108. condition = ` AND p.company_id IN (` + utils.GetOrmInReplace(companyIdsLen) + `) GROUP BY p.company_id `
  1109. pars = append(pars, companyIds)
  1110. //获取销售的手机号
  1111. listSeller, e := models.GetAdminOpendidByCompany(condition, pars)
  1112. if e != nil && e.Error() != utils.ErrNoRow() {
  1113. err = errors.New("GetAdminOpendidByCompany, Err: " + e.Error())
  1114. return
  1115. }
  1116. if len(listSeller) == 0 {
  1117. continue
  1118. }
  1119. var mobileArr []string
  1120. for _, v := range listSeller {
  1121. if v.Mobile != "" {
  1122. mobileArr = append(mobileArr, v.Mobile)
  1123. }
  1124. }
  1125. mobileLen := len(mobileArr)
  1126. if mobileLen == 0 {
  1127. return
  1128. }
  1129. //获取手机号对应的Openid
  1130. listSellerOpenid, e := models.GetWxOpenIdByMobileSliceList(mobileArr)
  1131. if e != nil && e.Error() != utils.ErrNoRow() {
  1132. err = errors.New("GetWxOpenIdByMobileSliceList, Err: " + e.Error())
  1133. return
  1134. }
  1135. mapMobileOpenid := make(map[string]string)
  1136. for _, v := range listSellerOpenid {
  1137. mapMobileOpenid[v.Mobile] = v.OpenId
  1138. }
  1139. mapSller := make(map[string]string)
  1140. mapSllerOpenid := make(map[string]string)
  1141. for _, vS := range listSeller {
  1142. for _, vT := range listSpecialTrip {
  1143. if vT.CompanyId == vS.CompanyId {
  1144. mapSller[vS.Mobile] += "【" + vT.RealName + "--" + vT.CompanyName + "】"
  1145. mapSllerOpenid[vS.Mobile] = mapMobileOpenid[vS.Mobile]
  1146. }
  1147. }
  1148. }
  1149. for k, _ := range mapSller {
  1150. keyword2 = "将在两天后进行,请及时提醒您的报名客户"
  1151. openIdList = make([]*models.OpenIdList, 0)
  1152. openIdList = append(openIdList, &models.OpenIdList{OpenId: mapSllerOpenid[k]})
  1153. SendWxMsgWithFrequencySpecial(first, keyword1, keyword2, keyword3, keyword4, remark, openIdList, v.ActivityId)
  1154. }
  1155. }
  1156. }
  1157. return
  1158. }
  1159. // SendWxMsgActivitySpecialCancel 线下活动前4天08:00报名人数不足7人,线上活动前3天08:00报名人数不足10人,活动自动取消发布,并推送模板消息至报名客户及对口销售
  1160. func SendWxMsgActivitySpecialCancel(cont context.Context) (err error) {
  1161. var msg string
  1162. defer func() {
  1163. if err != nil {
  1164. fmt.Println(err)
  1165. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  1166. go utils.SendAlarmMsg(fmt.Sprint(" 活动开始前两天08:00,提醒报名客户、提醒报名客户的对口销售消息发送失败"), 2)
  1167. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  1168. }
  1169. }()
  1170. dayTime3 := time.Now().AddDate(0, 0, 3)
  1171. startTime := dayTime3.Format(utils.FormatDate) + " 00:00:00"
  1172. endTime := dayTime3.Format(utils.FormatDate) + " 23:59:59"
  1173. dayTime4 := time.Now().AddDate(0, 0, 4)
  1174. startTime4 := dayTime4.Format(utils.FormatDate) + " 00:00:00"
  1175. endTime4 := dayTime4.Format(utils.FormatDate) + " 23:59:59"
  1176. var condition string
  1177. var pars []interface{}
  1178. condition = ` AND days >0 AND activity_time BETWEEN ? AND ? AND special_type= 1 `
  1179. pars = append(pars, startTime, endTime)
  1180. condition += ` OR ( days >0 AND activity_time BETWEEN ? AND ? AND special_type= 2 ) `
  1181. pars = append(pars, startTime4, endTime4)
  1182. listActivitySpecial, e := models.GetActivitySpecialListAll(condition, pars, 0, 1000)
  1183. if e != nil {
  1184. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1185. return
  1186. }
  1187. if len(listActivitySpecial) == 0 {
  1188. return
  1189. }
  1190. var activityIds []int
  1191. for _, v := range listActivitySpecial {
  1192. activityIds = append(activityIds, v.ActivityId)
  1193. condition = ` AND is_cancel = 0 AND activity_id = ` + strconv.Itoa(v.ActivityId)
  1194. pars = make([]interface{}, 0)
  1195. listSpecialTrip, e := models.GetCygxActivitySpecialTripList(condition, pars)
  1196. if e != nil {
  1197. err = errors.New("GetCygxActivitySpecialTripList, Err: " + e.Error())
  1198. return
  1199. }
  1200. if v.SpecialType == 1 {
  1201. if len(listSpecialTrip) >= 10 {
  1202. continue
  1203. }
  1204. }
  1205. if v.SpecialType == 2 {
  1206. if len(listSpecialTrip) >= 7 {
  1207. continue
  1208. }
  1209. }
  1210. e = models.UpdateActivitySpecialPublishStatus(0, v.ActivityId)
  1211. if e != nil {
  1212. err = errors.New("UpdateActivitySpecialPublishStatus,自动取消专项调研日程失败 Err: " + e.Error() + strconv.Itoa(v.ActivityId))
  1213. return
  1214. }
  1215. if len(listSpecialTrip) < 0 {
  1216. return
  1217. }
  1218. var mobile string
  1219. var companyIds []int
  1220. for _, vT := range listSpecialTrip {
  1221. mobile += "'" + vT.Mobile + "',"
  1222. companyIds = append(companyIds, vT.CompanyId)
  1223. }
  1224. mobile = strings.TrimRight(mobile, ",")
  1225. openIdList, e := models.GetWxOpenIdByMobileList(mobile)
  1226. if e != nil {
  1227. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  1228. return
  1229. }
  1230. first := "【" + v.ResearchTheme + "】专项调研因专家安排变动,本次调研活动延期举办,具体时间另行通知"
  1231. keyword1 := v.ResearchTheme
  1232. keyword2 := "已取消"
  1233. keyword3 := ""
  1234. keyword4 := ""
  1235. remark := ""
  1236. openIdArr := make([]string, 0)
  1237. for _, vOpenid := range openIdList {
  1238. openIdArr = append(openIdArr, vOpenid.OpenId)
  1239. }
  1240. companyIdsLen := len(companyIds)
  1241. if len(companyIds) > 0 {
  1242. pars = make([]interface{}, 0)
  1243. condition = ` AND p.company_id IN (` + utils.GetOrmInReplace(companyIdsLen) + `) GROUP BY p.company_id `
  1244. pars = append(pars, companyIds)
  1245. listSeller, e := models.GetAdminOpendidByCompany(condition, pars)
  1246. if e != nil && e.Error() != utils.ErrNoRow() {
  1247. err = errors.New("GetAdminOpendidByCompany, Err: " + e.Error())
  1248. return
  1249. }
  1250. if len(listSeller) == 0 {
  1251. continue
  1252. }
  1253. var mobileArr []string
  1254. for _, v := range listSeller {
  1255. if v.Mobile != "" {
  1256. mobileArr = append(mobileArr, v.Mobile)
  1257. }
  1258. }
  1259. mobileLen := len(mobileArr)
  1260. if mobileLen == 0 {
  1261. return
  1262. }
  1263. //获取手机号对应的Openid
  1264. listSellerOpenid, e := models.GetWxOpenIdByMobileSliceList(mobileArr)
  1265. if e != nil && e.Error() != utils.ErrNoRow() {
  1266. err = errors.New("GetWxOpenIdByMobileSliceList, Err: " + e.Error())
  1267. return
  1268. }
  1269. if len(listSellerOpenid) > 0 {
  1270. for _, vOpenid := range listSellerOpenid {
  1271. openIdArr = append(openIdArr, vOpenid.OpenId)
  1272. }
  1273. }
  1274. }
  1275. redirectUrl := ""
  1276. sendInfo := new(SendWxTemplate)
  1277. sendInfo.First = first
  1278. sendInfo.Keyword1 = keyword1
  1279. sendInfo.Keyword2 = keyword2
  1280. sendInfo.Keyword3 = keyword3
  1281. sendInfo.Keyword4 = keyword4
  1282. sendInfo.Remark = remark
  1283. sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
  1284. sendInfo.RedirectUrl = redirectUrl
  1285. sendInfo.RedirectTarget = 3
  1286. sendInfo.Resource = strconv.Itoa(v.ActivityId)
  1287. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  1288. sendInfo.OpenIdArr = openIdArr
  1289. fmt.Println(sendInfo)
  1290. err = PublicSendTemplateMsg(sendInfo)
  1291. }
  1292. return
  1293. }
  1294. func GetChartPermissionSpecialSurplusByCompany(companyId int) (userType int, tripRemaining int, mapChartName map[string]int, err error) {
  1295. companyDetail, e := models.GetCompanyDetailByIdGroup(companyId)
  1296. if e != nil {
  1297. err = errors.New("GetCompanyDetailByIdGroup, Err: " + e.Error())
  1298. }
  1299. if companyDetail == nil {
  1300. return
  1301. }
  1302. if companyDetail.Status != "永续" && companyDetail.Status != "正式" {
  1303. return
  1304. }
  1305. var specialSurplus string
  1306. if companyDetail.Status == "永续" {
  1307. specialSurplus = "不限次数"
  1308. }
  1309. //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}
  1310. //chartNumMap := map[int]int{utils.YI_YAO_ID:0, utils.XIAO_FEI_ID:0, utils.KE_JI_ID:0, utils.ZHI_ZAO_ID:0}
  1311. chartNameMap := map[string]int{utils.YI_YAO_NAME: 0, utils.XIAO_FEI_NAME: 0, utils.KE_JI_NAME: 0, utils.ZHI_ZAO_NAME: 0}
  1312. if companyDetail.Status == "正式" {
  1313. //var packageType int
  1314. userType, _, _ = GetUserType(companyId)
  1315. var condition string
  1316. var pars []interface{}
  1317. condition += ` AND company_id = ? `
  1318. pars = append(pars, companyId)
  1319. //查询当年的数据
  1320. condition += ` AND b.create_time >= ? `
  1321. pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
  1322. listTripBill, e := models.GetCygxActivitySpecialTripBillList(condition, pars)
  1323. if e != nil {
  1324. err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
  1325. return
  1326. }
  1327. PermissionNameMap, e := GetPermissionNameMap()
  1328. if e != nil {
  1329. err = errors.New("GetPermissionNameMap, Err: " + e.Error())
  1330. return
  1331. }
  1332. for k, v := range listTripBill {
  1333. listTripBill[k].ChartPermissionName = PermissionNameMap[v.ChartPermissionId]
  1334. }
  1335. // 获取继承点数
  1336. //inheritList, e := models.GetCygxActivitySpecialInheritPointsByCompanyId(companyId)
  1337. //if e != nil && e.Error() != utils.ErrNoRow() {
  1338. // err = errors.New("GetCygxActivitySpecialInheritPointsByCompanyId, Err: " + e.Error())
  1339. //}
  1340. if userType == 2 {
  1341. var tripBillNum int
  1342. for _, v := range listTripBill {
  1343. //if v.ActivityId == 0 {
  1344. // continue
  1345. //}
  1346. tripBillNum += v.BillDetailed
  1347. }
  1348. //if len(inheritList) > 0 {
  1349. // for _, v := range inheritList {
  1350. // if v.ChartPermissionId == 0 {
  1351. // tripBillNum += v.Points
  1352. // }
  1353. // }
  1354. //}
  1355. tripRemaining = tripBillNum
  1356. if tripRemaining < 0 {
  1357. tripRemaining = 0
  1358. }
  1359. } else {
  1360. list, e := models.GetCompanyReportPermissionByCompanyIdAndProductId(companyId, 2)
  1361. if e != nil && e.Error() != utils.ErrNoRow() {
  1362. err = errors.New("GetCompanyReportPermissionUpgrade, Err: " + e.Error())
  1363. }
  1364. if len(list) == 0 {
  1365. return
  1366. }
  1367. var chartPermissionIdSlice []string
  1368. mapChartName = make(map[string]int)
  1369. mapUpgradeId := make(map[int]int)
  1370. mapPermissionNameTrip := make(map[string]int)
  1371. mapInheritChartName := make(map[string]int)
  1372. //mapPermissionName := make(map[int]string)
  1373. for _, v := range list {
  1374. chartPermissionIdSlice = append(chartPermissionIdSlice, strconv.Itoa(v.ChartPermissionId))
  1375. //是升级套餐才有点数
  1376. if v.IsUpgrade == 1 {
  1377. mapUpgradeId[v.ChartPermissionId] = 1
  1378. }
  1379. }
  1380. chartList := make([]*models.ChartPermission, 0)
  1381. if len(chartPermissionIdSlice) > 0 {
  1382. chartList, e = models.GetChartPermissionByIds(chartPermissionIdSlice)
  1383. if e != nil {
  1384. err = errors.New("获取品种信息失败, Err:" + e.Error())
  1385. return
  1386. }
  1387. }
  1388. if len(chartList) == 0 {
  1389. return
  1390. }
  1391. for _, v := range listTripBill {
  1392. if v.ActivityId == 0 {
  1393. continue
  1394. }
  1395. mapPermissionNameTrip[v.ChartPermissionName] += v.BillDetailed
  1396. }
  1397. for _, v := range chartList {
  1398. //如果是升级则加点
  1399. if _, ok := mapUpgradeId[v.ChartPermissionId]; ok {
  1400. mapChartName[v.PermissionName] = 5 + mapPermissionNameTrip[v.PermissionName]
  1401. } else {
  1402. mapChartName[v.PermissionName] = mapPermissionNameTrip[v.PermissionName]
  1403. }
  1404. }
  1405. // 通过继承获得的加点
  1406. //for _, v := range inheritList {
  1407. // mapInheritChartName[v.ChartPermissionName] = v.Points
  1408. //}
  1409. for k, _ := range chartNameMap {
  1410. if _, ok := mapChartName[k]; ok {
  1411. if inherit, ok2 := mapInheritChartName[k]; ok2 {
  1412. mapChartName[k] += inherit
  1413. }
  1414. }
  1415. }
  1416. for k, v := range mapChartName {
  1417. if v > 0 {
  1418. specialSurplus += k + strconv.Itoa(v) + "次+"
  1419. }
  1420. }
  1421. specialSurplus = strings.TrimRight(specialSurplus, "+")
  1422. }
  1423. }
  1424. return
  1425. }
  1426. // 清零初始化用-去掉了正式用户的判断
  1427. func GetChartPermissionSpecialSurplusByCompanyForInit(companyId int) (userType int, tripRemaining int, mapChartName map[string]int, err error) {
  1428. companyDetail, e := models.GetCompanyDetailByIdGroup(companyId)
  1429. if e != nil {
  1430. err = errors.New("GetCompanyDetailByIdGroup, Err: " + e.Error())
  1431. }
  1432. if companyDetail == nil {
  1433. return
  1434. }
  1435. //if companyDetail.Status != "永续" && companyDetail.Status != "正式" {
  1436. // return
  1437. //}
  1438. //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}
  1439. chartNumMap := map[int]int{utils.YI_YAO_ID: 0, utils.XIAO_FEI_ID: 0, utils.KE_JI_ID: 0, utils.ZHI_ZAO_ID: 0}
  1440. //var packageType int
  1441. userType, _, _ = GetUserType(companyId)
  1442. var condition string
  1443. var pars []interface{}
  1444. condition += ` AND company_id = ? `
  1445. pars = append(pars, companyId)
  1446. //查询当年的数据
  1447. condition += ` AND b.create_time >= ? `
  1448. pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
  1449. listTripBill, e := models.GetCygxActivitySpecialTripBillList(condition, pars)
  1450. if e != nil {
  1451. err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
  1452. return
  1453. }
  1454. // 获取继承点数
  1455. inheritList, e := models.GetCygxActivitySpecialInheritPointsByCompanyId(companyId)
  1456. if e != nil && e.Error() != utils.ErrNoRow() {
  1457. err = errors.New("GetCygxActivitySpecialInheritPointsByCompanyId, Err: " + e.Error())
  1458. }
  1459. if userType == 2 {
  1460. var tripBillNum int
  1461. for _, v := range listTripBill {
  1462. //if v.ActivityId == 0 {
  1463. // continue
  1464. //}
  1465. tripBillNum += v.BillDetailed
  1466. }
  1467. if len(inheritList) > 0 {
  1468. for _, v := range inheritList {
  1469. if v.ChartPermissionId == 0 {
  1470. tripBillNum += v.Points
  1471. }
  1472. }
  1473. }
  1474. tripRemaining = tripBillNum
  1475. if tripRemaining < 0 {
  1476. tripRemaining = 0
  1477. }
  1478. } else {
  1479. list, e := models.GetCompanyReportPermissionByCompanyIdAndProductIdForInit(companyId, 2)
  1480. if e != nil && e.Error() != utils.ErrNoRow() {
  1481. err = errors.New("GetCompanyReportPermissionByCompanyIdAndProductIdForInit, Err: " + e.Error())
  1482. }
  1483. if len(list) == 0 {
  1484. return
  1485. }
  1486. var chartPermissionIdSlice []string
  1487. mapChartName = make(map[string]int)
  1488. mapUpgradeId := make(map[int]int)
  1489. mapPermissionNameTrip := make(map[string]int)
  1490. mapInheritChartName := make(map[string]int)
  1491. //mapPermissionName := make(map[int]string)
  1492. for _, v := range list {
  1493. chartPermissionIdSlice = append(chartPermissionIdSlice, strconv.Itoa(v.ChartPermissionId))
  1494. //是升级套餐才有点数
  1495. if v.IsUpgrade == 1 {
  1496. mapUpgradeId[v.ChartPermissionId] = 1
  1497. }
  1498. }
  1499. chartList := make([]*models.ChartPermission, 0)
  1500. if len(chartPermissionIdSlice) > 0 {
  1501. chartList, e = models.GetChartPermissionByIds(chartPermissionIdSlice)
  1502. if e != nil {
  1503. err = errors.New("获取品种信息失败, Err:" + e.Error())
  1504. return
  1505. }
  1506. }
  1507. if len(chartList) == 0 {
  1508. return
  1509. }
  1510. for _, v := range listTripBill {
  1511. if v.ActivityId == 0 {
  1512. continue
  1513. }
  1514. mapPermissionNameTrip[v.ChartPermissionName] += v.BillDetailed
  1515. }
  1516. for _, v := range chartList {
  1517. if _, ok := chartNumMap[v.ChartPermissionId]; ok {
  1518. //如果是升级则加点
  1519. if _, ok := mapUpgradeId[v.ChartPermissionId]; ok {
  1520. mapChartName[v.PermissionName] = 5 + mapPermissionNameTrip[v.PermissionName]
  1521. } else {
  1522. mapChartName[v.PermissionName] = mapPermissionNameTrip[v.PermissionName]
  1523. }
  1524. }
  1525. }
  1526. // 通过继承获得的加点
  1527. for _, v := range inheritList {
  1528. mapInheritChartName[v.ChartPermissionName] = v.Points
  1529. }
  1530. for _, v := range mapChartName {
  1531. if v > 0 {
  1532. tripRemaining += v
  1533. }
  1534. }
  1535. }
  1536. return
  1537. }
  1538. // total初始化用-去掉了正式用户的判断
  1539. func GetChartPermissionSpecialSurplusByCompanyForInitTotal(companyId int) (userType int, tripRemaining int, mapChartName map[string]int, err error) {
  1540. companyDetail, e := models.GetCompanyDetailByIdGroup(companyId)
  1541. if e != nil {
  1542. err = errors.New("GetCompanyDetailByIdGroup, Err: " + e.Error())
  1543. }
  1544. if companyDetail == nil {
  1545. return
  1546. }
  1547. //if companyDetail.Status != "永续" && companyDetail.Status != "正式" {
  1548. // return
  1549. //}
  1550. //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}
  1551. chartNumMap := map[int]int{utils.YI_YAO_ID: 0, utils.XIAO_FEI_ID: 0, utils.KE_JI_ID: 0, utils.ZHI_ZAO_ID: 0}
  1552. //var packageType int
  1553. userType, _, _ = GetUserType(companyId)
  1554. var condition string
  1555. var pars []interface{}
  1556. condition += ` AND company_id = ? `
  1557. pars = append(pars, companyId)
  1558. //查询当年的数据
  1559. condition += ` AND b.create_time >= ? `
  1560. pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
  1561. listTripBill, e := models.GetCygxActivitySpecialTripBillList(condition, pars)
  1562. if e != nil {
  1563. err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
  1564. return
  1565. }
  1566. // 获取继承点数
  1567. inheritList, e := models.GetCygxActivitySpecialInheritPointsByCompanyId(companyId)
  1568. if e != nil && e.Error() != utils.ErrNoRow() {
  1569. err = errors.New("GetCygxActivitySpecialInheritPointsByCompanyId, Err: " + e.Error())
  1570. }
  1571. if userType == 2 {
  1572. var tripBillNum int
  1573. for _, v := range listTripBill {
  1574. //if v.ActivityId == 0 {
  1575. // continue
  1576. //}
  1577. tripBillNum += v.BillDetailed
  1578. }
  1579. if len(inheritList) > 0 {
  1580. for _, v := range inheritList {
  1581. if v.ChartPermissionId == 0 {
  1582. tripBillNum += v.Points
  1583. }
  1584. }
  1585. }
  1586. tripRemaining = tripBillNum
  1587. if tripRemaining < 0 {
  1588. tripRemaining = 0
  1589. }
  1590. } else {
  1591. list, e := models.GetCompanyReportPermissionByCompanyIdAndProductIdForInit2(companyId, 2)
  1592. if e != nil && e.Error() != utils.ErrNoRow() {
  1593. err = errors.New("GetCompanyReportPermissionByCompanyIdAndProductIdForInit, Err: " + e.Error())
  1594. }
  1595. if len(list) == 0 {
  1596. return
  1597. }
  1598. var chartPermissionIdSlice []string
  1599. mapChartName = make(map[string]int)
  1600. mapUpgradeId := make(map[int]int)
  1601. mapPermissionNameTrip := make(map[string]int)
  1602. mapInheritChartName := make(map[string]int)
  1603. //mapPermissionName := make(map[int]string)
  1604. for _, v := range list {
  1605. chartPermissionIdSlice = append(chartPermissionIdSlice, strconv.Itoa(v.ChartPermissionId))
  1606. //是升级套餐才有点数
  1607. if v.IsUpgrade == 1 {
  1608. mapUpgradeId[v.ChartPermissionId] = 1
  1609. }
  1610. }
  1611. chartList := make([]*models.ChartPermission, 0)
  1612. if len(chartPermissionIdSlice) > 0 {
  1613. chartList, e = models.GetChartPermissionByIds(chartPermissionIdSlice)
  1614. if e != nil {
  1615. err = errors.New("获取品种信息失败, Err:" + e.Error())
  1616. return
  1617. }
  1618. }
  1619. if len(chartList) == 0 {
  1620. return
  1621. }
  1622. for _, v := range listTripBill {
  1623. if v.ActivityId == 0 {
  1624. continue
  1625. }
  1626. mapPermissionNameTrip[v.ChartPermissionName] += v.BillDetailed
  1627. }
  1628. for _, v := range chartList {
  1629. if _, ok := chartNumMap[v.ChartPermissionId]; ok {
  1630. //如果是升级则加点
  1631. if _, ok := mapUpgradeId[v.ChartPermissionId]; ok {
  1632. mapChartName[v.PermissionName] = 5 + mapPermissionNameTrip[v.PermissionName]
  1633. } else {
  1634. mapChartName[v.PermissionName] = mapPermissionNameTrip[v.PermissionName]
  1635. }
  1636. }
  1637. }
  1638. // 通过继承获得的加点
  1639. for _, v := range inheritList {
  1640. mapInheritChartName[v.ChartPermissionName] = v.Points
  1641. }
  1642. for _, v := range mapChartName {
  1643. if v > 0 {
  1644. tripRemaining += v
  1645. }
  1646. }
  1647. }
  1648. return
  1649. }