activity.go 98 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838
  1. package services
  2. import (
  3. "context"
  4. "errors"
  5. "fmt"
  6. "github.com/tealeg/xlsx"
  7. "hongze/hongze_cygx/models"
  8. "hongze/hongze_cygx/utils"
  9. "os"
  10. "path/filepath"
  11. "strconv"
  12. "strings"
  13. "time"
  14. "unicode/utf8"
  15. )
  16. // 修改活动状态
  17. func UpdateActivitySattus(cont context.Context) (err error) {
  18. //defer func() {
  19. // if err != nil {
  20. // fmt.Println("同步失败,Err:", err.Error())
  21. // }
  22. //}()
  23. go models.UpdateActivitySattusToHaveInHand()
  24. go models.UpdateActivitySattusToComplete()
  25. return
  26. }
  27. // 推送会议开始消息提醒60分钟前
  28. func SendActivityBeginMsg(cont context.Context) (err error) {
  29. //func SendActivityBeginMsg() (err error) {
  30. defer func() {
  31. if err != nil {
  32. go utils.SendAlarmMsg("60分钟会议消息提醒失败"+err.Error(), 2)
  33. fmt.Println("发送失败,Err:", err.Error())
  34. }
  35. }()
  36. endDate := time.Now().Add(+time.Minute * 60).Format(utils.FormatDateTime)
  37. listActivity, err := models.GetActivitySendMsgListAll(endDate)
  38. fmt.Println(len(listActivity))
  39. if err != nil {
  40. fmt.Println("GetActivitySendMsgListAll Err:", err.Error())
  41. return
  42. }
  43. if len(listActivity) == 0 {
  44. return
  45. }
  46. //var remark = "点击查看活动详情"
  47. var signupIds string
  48. for _, v := range listActivity {
  49. signupIds += strconv.Itoa(v.Id) + ","
  50. //var reserveResults string
  51. //var first string
  52. openIdItem := new(models.OpenIdList)
  53. openIdItem.OpenId = v.OpenId
  54. openIdItem.UserId = v.UserId
  55. openIdList := make([]*models.OpenIdList, 0)
  56. openIdList = append(openIdList, openIdItem)
  57. //if v.FailType == 0 {
  58. // reserveResults = "成功"
  59. //} else if v.FailType == 1 {
  60. // reserveResults = "失败(总人数已满)"
  61. //} else if v.FailType == 2 {
  62. // reserveResults = "失败(单机构超限制)"
  63. //} else if v.FailType == 3 {
  64. // reserveResults = "失败(爽约次数超限)"
  65. //}
  66. //reserveResults = "--"
  67. //first = "将在1小时后开始"
  68. //SendWxMsgWithFrequency(first, v.ActivityName, reserveResults, v.ActivityTimeText, v.Address, remark, openIdList, v.ActivityId)
  69. SendWxMsgWithFrequencyBycategory(v.ActivityName, v.ActivityTime, openIdList, v.ActivityId)
  70. }
  71. if len(signupIds) == 0 {
  72. return
  73. }
  74. signupIds = strings.TrimRight(signupIds, ",")
  75. err = models.UPdateSendedMsgStatus(signupIds)
  76. if err != nil {
  77. var msg string
  78. go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format(utils.FormatDateTime), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  79. utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
  80. }
  81. return
  82. }
  83. //func init() {
  84. // SendActivityBeginMsgMeeting()
  85. //}
  86. // 推送会议开始消息提醒15分钟前
  87. func SendActivityBeginMsgMeeting(cont context.Context) (err error) {
  88. //func SendActivityBeginMsgMeeting() (err error) {
  89. defer func() {
  90. if err != nil {
  91. //go utils.SendAlarmMsg("15分钟会议消息提醒失败", 2)
  92. go utils.SendAlarmMsg(fmt.Sprint("15分钟会议消息提醒失败 SendActivityBeginMsgMeeting Err:", err.Error()), 2)
  93. //fmt.Println("发送失败,Err:", err.Error())
  94. }
  95. }()
  96. var condition string
  97. var pars []interface{}
  98. endDate := time.Now().Add(+time.Minute * 15).Format(utils.FormatDateTime)
  99. condition = ` AND activity_time <= ? AND activity_time >= NOW() AND publish_status = 1 `
  100. pars = append(pars, endDate)
  101. listActivity, e := models.GetCygxActivityList(condition, pars, 0, 100000)
  102. if e != nil && e.Error() != utils.ErrNoRow() {
  103. err = errors.New("GetCygxActivityList, Err: " + e.Error())
  104. return
  105. }
  106. if len(listActivity) == 0 {
  107. return
  108. }
  109. //var signupIds string
  110. //var remark = "点击查看活动详情"
  111. var activityIds []int
  112. //同一时间举办的活动不多所以这里循环查询
  113. for _, v := range listActivity {
  114. activityIds = append(activityIds, v.ActivityId)
  115. var mobiles []string
  116. pars = make([]interface{}, 0)
  117. condition = ` AND activity_id = ? AND is_send_wx_msg = 0 `
  118. pars = append(pars, v.ActivityId)
  119. //获取设置消息提醒的用户列表
  120. listxReminder, e := models.GetCygxReminderListByUser(condition, pars)
  121. if e != nil {
  122. err = errors.New("GetCygxReminderListByUser, Err: " + e.Error())
  123. return
  124. }
  125. for _, vReminder := range listxReminder {
  126. mobiles = append(mobiles, vReminder.Mobile)
  127. }
  128. pars = make([]interface{}, 0)
  129. condition = ` AND do_fail_type = 0 AND activity_id = ? AND signup_type = 1 AND is_send_wx_msg = 0 `
  130. pars = append(pars, v.ActivityId)
  131. //获取设置预约外呼的用户列表
  132. listSignup, e := models.GetActivitySignupList(condition, pars)
  133. if e != nil && e.Error() != utils.ErrNoRow() {
  134. err = errors.New("GetActivitySignupList, Err: " + e.Error())
  135. return
  136. }
  137. for _, vSignup := range listSignup {
  138. mobiles = append(mobiles, vSignup.Mobile)
  139. }
  140. //获取这些手机号对应的Openid
  141. listOpenid, e := models.GetUserRecordListByMobileArr(mobiles)
  142. if e != nil && e.Error() != utils.ErrNoRow() {
  143. err = errors.New("GetUserRecordListByMobileArr, Err: " + e.Error())
  144. return
  145. }
  146. openIdList := make([]*models.OpenIdList, 0)
  147. for _, vOpenid := range listOpenid {
  148. openIdItem := new(models.OpenIdList)
  149. openIdItem.OpenId = vOpenid.OpenId
  150. openIdItem.UserId = vOpenid.UserId
  151. openIdList = append(openIdList, openIdItem)
  152. }
  153. //var reserveResults string
  154. //var keyword2 string
  155. //reserveResults = "--"
  156. //keyword2 = "将在15分钟后开始"
  157. //SendWxMsgWithFrequency(keyword2, v.ActivityName, reserveResults, v.ActivityTimeText, "--", remark, openIdList, v.ActivityId)
  158. SendWxMsgWithFrequencyBycategory(v.ActivityName, v.ActivityTime, openIdList, v.ActivityId)
  159. }
  160. err = models.UpdateSendedMsgMeetingSendWxMsg(activityIds)
  161. return
  162. }
  163. // 预约外呼名单,会前1小时自动发送邮件给专家组
  164. func SendEmailFileToExpert(cont context.Context) (err error) {
  165. var msg string
  166. var touser string
  167. defer func() {
  168. if err != nil {
  169. fmt.Println("err:", err)
  170. go utils.SendAlarmMsg("预约外呼名单,会前1小时自动发送邮件给专家组失败"+err.Error()+msg, 2)
  171. }
  172. }()
  173. endDate := time.Now().Add(+time.Minute * 60).Format(utils.FormatDateTime)
  174. total, e := models.GetCountActivityIdToSendFile(endDate)
  175. if e != nil && e.Error() != utils.ErrNoRow() {
  176. err = errors.New("GetCountActivityIdToSendFile" + e.Error())
  177. return
  178. }
  179. if total == 0 {
  180. fmt.Println("发送附件完成0")
  181. return nil
  182. }
  183. listActivity, e := models.GetActivityIdToSendFile(endDate)
  184. if e != nil && e.Error() != utils.ErrNoRow() {
  185. err = errors.New("GetActivityIdToSendFile" + e.Error())
  186. return
  187. }
  188. if len(listActivity) == 0 {
  189. return
  190. }
  191. var activityIds []int
  192. for _, v := range listActivity {
  193. activityIds = append(activityIds, v.ActivityId)
  194. }
  195. for _, v := range listActivity {
  196. //time.Sleep(30 * time.Second) //延时30秒,避免邮件发送不成功
  197. activityInfo, e := models.GetAddActivityInfoById(v.ActivityId)
  198. if e != nil {
  199. err = errors.New("GetAddActivityInfoById" + e.Error())
  200. return
  201. }
  202. list, e := models.GetSignupExport(v.ActivityId)
  203. if e != nil {
  204. err = errors.New("GetSignupExport" + e.Error())
  205. return
  206. }
  207. var companyIds []int
  208. for _, vSin := range list {
  209. companyIds = append(companyIds, vSin.CompanyId)
  210. }
  211. sellNameMap := GetSellNameMapByCompanyIds(companyIds)
  212. //创建excel
  213. dir, errFile := os.Executable()
  214. exPath := filepath.Dir(dir)
  215. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandDigit(5) + ".xlsx"
  216. xlsxFile := xlsx.NewFile()
  217. if errFile != nil {
  218. msg = "生成文件失败Err:" + errFile.Error()
  219. return
  220. }
  221. style := xlsx.NewStyle()
  222. alignment := xlsx.Alignment{
  223. Horizontal: "center",
  224. Vertical: "center",
  225. WrapText: true,
  226. }
  227. style.Alignment = alignment
  228. style.ApplyAlignment = true
  229. sheet, errFile := xlsxFile.AddSheet("外呼名单")
  230. if errFile != nil {
  231. msg = "新增Sheet失败,Err:" + errFile.Error()
  232. return
  233. }
  234. //设置宽度
  235. _ = sheet.SetColWidth(1, 1, 15)
  236. _ = sheet.SetColWidth(3, 3, 30)
  237. //标头
  238. rowTitle := sheet.AddRow()
  239. cellA := rowTitle.AddCell()
  240. cellA.Value = "姓名"
  241. cellB := rowTitle.AddCell()
  242. cellB.Value = "外呼号码"
  243. cellC := rowTitle.AddCell()
  244. cellC.Value = "国际代码"
  245. cellD := rowTitle.AddCell()
  246. cellD.Value = "公司名称"
  247. cellE := rowTitle.AddCell()
  248. cellE.Value = "所属销售"
  249. for _, item := range list {
  250. row := sheet.AddRow()
  251. cellA := row.AddCell()
  252. cellA.Value = item.RealName
  253. cellB := row.AddCell()
  254. cellB.Value = item.OutboundMobile
  255. cellC := row.AddCell()
  256. if item.CountryCode == "" {
  257. cellC.Value = "86"
  258. } else {
  259. cellC.Value = item.CountryCode
  260. }
  261. cellD := row.AddCell()
  262. cellD.Value = item.CompanyName
  263. cellE := row.AddCell()
  264. cellE.Value = sellNameMap[item.CompanyId]
  265. }
  266. errFile = xlsxFile.Save(downLoadnFilePath)
  267. if errFile != nil {
  268. msg = "保存文件失败Err:" + errFile.Error()
  269. return
  270. }
  271. title := activityInfo.ActivityName + "外呼名单"
  272. content := "外呼名单详情"
  273. fileName := downLoadnFilePath
  274. if activityInfo.ChartPermissionName == "科技" {
  275. touser = utils.EmailTechnology
  276. } else if activityInfo.ChartPermissionName == "医药" {
  277. touser = utils.EmailMedicine
  278. } else if activityInfo.ChartPermissionName == "消费" {
  279. touser = utils.EmailConsumption
  280. } else if activityInfo.ChartPermissionName == "智造" {
  281. touser = utils.EmailZhizao
  282. } else if activityInfo.ChartPermissionName == "策略" {
  283. touser = utils.EmailStrategy
  284. } else if strings.Contains(activityInfo.ChartPermissionName, "研选") {
  285. touser = utils.EmailExpert
  286. }
  287. sub := strings.Index(touser, ";")
  288. if sub >= 0 {
  289. spArr := strings.Split(touser, ";")
  290. for _, v := range spArr {
  291. utils.SendEmailByHongze(title, content, v, fileName, title+".xlsx")
  292. }
  293. }
  294. os.Remove(downLoadnFilePath)
  295. e = models.UPdateActivityIdToSendFile(v.ActivityId)
  296. if e != nil {
  297. go utils.SendAlarmMsg("UPdateActivityIdToSendFile err"+e.Error(), 2)
  298. }
  299. //sendResult := utils.SendEmailByHongze(title, content, touser, fileName, title+".xlsx")
  300. //if sendResult {
  301. // errFile = models.UPdateActivityIdToSendFile(v.ActivityId)
  302. // if errFile != nil {
  303. // msg = "获取失败,Err:" + errFile.Error()
  304. // return
  305. // }
  306. // os.Remove(downLoadnFilePath)
  307. //} else {
  308. // go utils.SendAlarmMsg("发送附件模版消息失败"+activityInfo.ActivityName, 2)
  309. // utils.FileLog.Info("发送附件模版消息失败,Err:%s", activityInfo.ActivityName)
  310. //}
  311. }
  312. return
  313. }
  314. func EditOutboundMobile(cont context.Context) (err error) {
  315. defer func() {
  316. if err != nil {
  317. fmt.Println("发送失败,Err:", err.Error())
  318. }
  319. }()
  320. list, err := models.GetActivitySignupListAll()
  321. if err != nil {
  322. fmt.Println("GetActivitySendMsgListAll Err:", err.Error())
  323. return
  324. }
  325. for _, v := range list {
  326. err = models.UPdateSignup(v)
  327. fmt.Println("修改:", strconv.Itoa(v.Id))
  328. if err != nil {
  329. fmt.Println("发送失败,Err:", err.Error()+strconv.Itoa(v.Id))
  330. }
  331. }
  332. fmt.Println("修改完成")
  333. return
  334. }
  335. // 同步用户绑定手机号以及区号
  336. func EditUserOutboundMobile(cont context.Context) (err error) {
  337. defer func() {
  338. if err != nil {
  339. fmt.Println("发送失败,Err:", err.Error())
  340. }
  341. }()
  342. list, err := models.GetUserListAll()
  343. if err != nil {
  344. fmt.Println("GetActivitySendMsgListAll Err:", err.Error())
  345. return
  346. }
  347. for _, v := range list {
  348. err = models.UPdateUserCountryCode(v)
  349. fmt.Println("修改:", strconv.Itoa(v.UserId))
  350. if err != nil {
  351. fmt.Println("发送失败,Err:", err.Error()+strconv.Itoa(v.UserId))
  352. }
  353. }
  354. fmt.Println("修改完成")
  355. return
  356. }
  357. // 获取 用户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户;6、冻结客户;7、流失客户
  358. func GetUserType(companyId int) (userType int, permissionStrnew string, err error) {
  359. var permissionStr, permissionZhengShiStr string
  360. if companyId <= 1 {
  361. userType = 0
  362. } else {
  363. total, errs := models.GetCountCompanyDetailByIdGroup(companyId)
  364. if errs != nil {
  365. err = errs
  366. return
  367. }
  368. if total == 0 {
  369. userType = 0
  370. } else {
  371. companyDetail, errs := models.GetCompanyDetailByIdGroup(companyId)
  372. if errs != nil {
  373. err = errs
  374. return
  375. }
  376. permissionStr, errs = models.GetCompanyPermission(companyId)
  377. if errs != nil {
  378. err = errs
  379. return
  380. }
  381. permissionStrnew = permissionStr
  382. //大套餐客户,数据库添加标识,
  383. companyUserTypeDetail, errs := models.GetCygxCompanyUserType(companyId)
  384. if errs != nil && errs.Error() != utils.ErrNoRow() {
  385. err = errs
  386. return
  387. }
  388. if companyUserTypeDetail != nil {
  389. if companyUserTypeDetail.CustomerTypeId != 0 {
  390. userType = companyUserTypeDetail.CustomerTypeId
  391. return
  392. }
  393. }
  394. permissionZhengShiStr, errs = models.GetCompanyPermissionByUserZhengShi(companyId)
  395. if errs != nil {
  396. err = errs
  397. return
  398. }
  399. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户、 10: 30W套餐客户
  400. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  401. if companyDetail.Status == "永续" {
  402. userType = 1
  403. } else if companyDetail.Status == "试用" {
  404. userType = 5
  405. } else if companyDetail.Status == "冻结" {
  406. userType = 6
  407. } else if companyDetail.Status == "流失" {
  408. userType = 7
  409. }
  410. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  411. if userType == 0 && companyDetail.Status == "正式" {
  412. var permissionZhegnshiNum int
  413. if strings.Count(permissionZhengShiStr, "医药") == 2 {
  414. permissionZhegnshiNum++
  415. }
  416. if strings.Count(permissionZhengShiStr, "消费") == 2 {
  417. permissionZhegnshiNum++
  418. }
  419. if strings.Count(permissionZhengShiStr, "科技") == 2 {
  420. permissionZhegnshiNum++
  421. }
  422. if strings.Count(permissionZhengShiStr, "智造") == 2 {
  423. permissionZhegnshiNum++
  424. }
  425. if strings.Count(permissionZhengShiStr, "策略") == 1 {
  426. permissionZhegnshiNum++
  427. }
  428. if strings.Count(permissionZhengShiStr, "路演服务") == 1 {
  429. permissionZhegnshiNum++
  430. }
  431. //if permissionZhegnshiNum == 6 {
  432. // userType = 2
  433. //} else
  434. //大套餐客户,数据库添加标识,条件大于等于四的都是 30W套餐客户
  435. if permissionZhegnshiNum >= 4 {
  436. userType = 10
  437. } else {
  438. userType = 3
  439. }
  440. }
  441. }
  442. }
  443. permissionStrnew = permissionStr
  444. return
  445. }
  446. func GetUserTypeZhengShi(companyId int) (userType int, permissionStrnew, permissionStrZhengShinew string, err error) {
  447. var permissionStr, permissionZhengShiStr string
  448. if companyId <= 1 {
  449. userType = 0
  450. } else {
  451. total, errs := models.GetCountCompanyDetailByIdGroup(companyId)
  452. if errs != nil {
  453. err = errs
  454. return
  455. }
  456. if total == 0 {
  457. userType = 0
  458. } else {
  459. companyDetail, errs := models.GetCompanyDetailByIdGroup(companyId)
  460. if errs != nil {
  461. err = errs
  462. return
  463. }
  464. permissionStr, errs = models.GetCompanyPermission(companyId)
  465. if errs != nil {
  466. err = errs
  467. return
  468. }
  469. permissionStrnew = permissionStr
  470. permissionZhengShiStr, errs = models.GetCompanyPermissionByUserZhengShi(companyId)
  471. if errs != nil {
  472. err = errs
  473. return
  474. }
  475. permissionStrZhengShinew = permissionZhengShiStr
  476. //大套餐客户,数据库添加标识,
  477. companyUserTypeDetail, errs := models.GetCygxCompanyUserType(companyId)
  478. if errs != nil && errs.Error() != utils.ErrNoRow() {
  479. err = errs
  480. return
  481. }
  482. if companyUserTypeDetail != nil {
  483. if companyUserTypeDetail.CustomerTypeId != 0 {
  484. userType = companyUserTypeDetail.CustomerTypeId
  485. return
  486. }
  487. }
  488. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户、 10: 30W套餐客户
  489. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  490. if companyDetail.Status == "永续" {
  491. userType = 1
  492. } else if companyDetail.Status == "试用" {
  493. userType = 5
  494. } else if companyDetail.Status == "冻结" {
  495. userType = 6
  496. } else if companyDetail.Status == "流失" {
  497. userType = 7
  498. }
  499. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  500. if userType == 0 && companyDetail.Status == "正式" {
  501. var permissionZhegnshiNum int
  502. if strings.Count(permissionZhengShiStr, "医药") == 2 {
  503. permissionZhegnshiNum++
  504. }
  505. if strings.Count(permissionZhengShiStr, "消费") == 2 {
  506. permissionZhegnshiNum++
  507. }
  508. if strings.Count(permissionZhengShiStr, "科技") == 2 {
  509. permissionZhegnshiNum++
  510. }
  511. if strings.Count(permissionZhengShiStr, "智造") == 2 {
  512. permissionZhegnshiNum++
  513. }
  514. if strings.Count(permissionZhengShiStr, "策略") == 1 {
  515. permissionZhegnshiNum++
  516. }
  517. if strings.Count(permissionZhengShiStr, "路演服务") == 1 {
  518. permissionZhegnshiNum++
  519. }
  520. //if permissionZhegnshiNum == 6 {
  521. // userType = 2
  522. //} else
  523. //大套餐客户,数据库添加标识,条件大于等于四的都是 30W套餐客户
  524. if permissionZhegnshiNum >= 4 {
  525. userType = 10
  526. } else {
  527. userType = 3
  528. }
  529. }
  530. }
  531. }
  532. permissionStrnew = permissionStr
  533. permissionStrZhengShinew = permissionZhengShiStr
  534. return
  535. }
  536. // GetSpecialDetailUserPower 处理用户查看详情的权限
  537. func GetActivityDetailUserPower(user *models.WxUserItem, activityInfo *models.ActivityDetail) (havePower, isResearchSpecial bool, err error) {
  538. var companyDetailStatus string
  539. var userTypeStr string
  540. userId := user.UserId
  541. activityPointsByUserAllMap := GetActivityPointsByUserAllMap() // 获取对用户进行研选扣点的活动
  542. //勾选【研选扣点】且扣点对象为参会人的活动,需要有买方研选的正式权限
  543. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) && activityPointsByUserAllMap[activityInfo.ActivityId] {
  544. isResearchSpecial = true
  545. }
  546. //如果是弘则的用户或者宏观的权限不做校验
  547. //if (GetBelongingRai(user.Mobile) && user.CompanyId == utils.HZ_COMPANY_ID) || activityInfo.ChartPermissionName == utils.HONG_GUAN_NAME {
  548. if GetBelongingRai(user.Mobile) && user.CompanyId == utils.HZ_COMPANY_ID {
  549. havePower = true
  550. return
  551. }
  552. userType, permissionStr, permissionStrZhengShi, e := GetUserTypeZhengShi(user.CompanyId)
  553. if e != nil {
  554. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  555. return
  556. }
  557. //判断用户是否开通了个人研选权限,如果有权限后缀拼接权限名称
  558. mfyxUserPermissionTotal := GetMfyxUserPermissionTotal(userId)
  559. if mfyxUserPermissionTotal == 1 {
  560. permissionStr += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  561. }
  562. //如果正式权限有开通 研选扣点包 ,那么就拼接一个 研选订阅的权限
  563. if strings.Contains(permissionStrZhengShi, utils.YAN_XUAN_KOU_DIAN_BAO_NAME) {
  564. permissionStr += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  565. permissionStrZhengShi += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  566. }
  567. //如果测试权限有开通 研选扣点包 ,那么就拼接一个 研选订阅的权限
  568. if strings.Contains(permissionStr, utils.YAN_XUAN_KOU_DIAN_BAO_NAME) {
  569. permissionStr += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  570. }
  571. //如果一个权限都没有就返回无权限
  572. if permissionStr == "" {
  573. return
  574. }
  575. //永续客户,无法查看研选权限,但是下面的联系人,单独开通研选后,也可以查看研选内容
  576. if userType == 1 && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) && mfyxUserPermissionTotal == 0 {
  577. havePower = false
  578. return
  579. }
  580. permissionStr += "," + utils.HONG_GUAN_NAME // 添加一个宏观权限
  581. if permissionStrZhengShi == "" {
  582. permissionStrZhengShi = utils.HONG_GUAN_NAME // 添加一个宏观权限
  583. } else {
  584. permissionStrZhengShi += "," + utils.HONG_GUAN_NAME // 添加一个宏观权限
  585. }
  586. //如果是易董的活动,主、副权限有一个满足即可
  587. if activityInfo.YidongActivityId != "" {
  588. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) || strings.Contains(permissionStr, activityInfo.ChartPermissionNameDeputy) {
  589. havePower = true
  590. return
  591. }
  592. }
  593. //如果权限不包含那么直接返回
  594. if !strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  595. return
  596. }
  597. //如果是 对用户的研选扣点的必须要有研选的正式权限
  598. if activityInfo.IsResearchPoints {
  599. //获取活动对用户要扣的点
  600. userPointsNum, e := models.GetCygxActivityPointsSetUserNum(activityInfo.ActivityId)
  601. if e != nil {
  602. err = errors.New("GetActivitySignupSuccessByUserCountNoHz, Err: " + e.Error())
  603. return
  604. }
  605. if userPointsNum > 0 {
  606. //if !strings.Contains(permissionStr, utils.CHART_PERMISSION_NAME_YANXUAN) {
  607. // //如果连试用权限都没有,那么久按照普通的研选样式展示
  608. // isResearchSpecial = false
  609. //}
  610. if !strings.Contains(permissionStrZhengShi, activityInfo.ChartPermissionName) {
  611. havePower = false
  612. return
  613. }
  614. }
  615. }
  616. //处理决策人可见权限
  617. if user.IsMaker == 0 && activityInfo.IsMakerShow == 1 {
  618. havePower = false
  619. return
  620. }
  621. // 处理本组可见权限
  622. if activityInfo.VisibleRange == 1 {
  623. //adminIds, e := models.GetSelleridWhichGroup(user.CompanyId, 2)
  624. //if e != nil {
  625. // err = errors.New("GetSelleridWhichGroup, Err: " + e.Error())
  626. // return
  627. //}
  628. adminIds := GetSelleridWhichGroup(user.CompanyId, 2, user.Mobile)
  629. haveVisibleRange := false
  630. adminIdSlice := strings.Split(adminIds, ",")
  631. for _, v := range adminIdSlice {
  632. if v == strconv.Itoa(activityInfo.AdminId) {
  633. haveVisibleRange = true
  634. }
  635. }
  636. if !haveVisibleRange {
  637. havePower = false
  638. return
  639. }
  640. }
  641. if permissionStr == "" {
  642. return
  643. }
  644. //如果是易董的活动且属于研选类型,只要开通任何权限就可以查看详情
  645. if activityInfo.YidongActivityId != "" && permissionStr != "" && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  646. havePower = true
  647. return
  648. }
  649. //医药消费,科技,智造四大行业,验证主客观。如果主客观校验不通过,那么直接返回
  650. if strings.Contains(utils.YI_YAO_NAME+utils.XIAO_FEI_NAME+utils.KE_JI_NAME+utils.ZHI_ZAO_NAME, activityInfo.ChartPermissionName) {
  651. if activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 6 || activityInfo.ActivityTypeId == 7 {
  652. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(主观)") {
  653. havePower = true
  654. } else {
  655. havePower = false
  656. }
  657. } else {
  658. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(客观)") {
  659. havePower = true
  660. } else {
  661. havePower = false
  662. }
  663. }
  664. if !havePower {
  665. return
  666. }
  667. }
  668. if activityInfo.LimitPeopleNum > 0 {
  669. mapUserType, e := GetActivityCcustomerTypeList()
  670. if e != nil {
  671. err = e
  672. return
  673. }
  674. userTypeStr = mapUserType[userType]
  675. // 永续客户、大套餐客户、30W套餐客户可以查看行业升级套餐客户 权限
  676. if userTypeStr == "1" || userTypeStr == "2" || userTypeStr == "AA" {
  677. if strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) && strings.Contains(activityInfo.CustomerTypeIds, "8") {
  678. havePower = true
  679. //return
  680. }
  681. }
  682. } else {
  683. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  684. havePower = true
  685. return
  686. }
  687. }
  688. //判断管理规模是否满足
  689. companyProduct, e := models.GetCompanyProductDetail(user.CompanyId, 2)
  690. if e != nil {
  691. err = e
  692. return
  693. }
  694. if companyProduct != nil && activityInfo.Scale != "" {
  695. if strings.Contains(activityInfo.Scale, companyProduct.Scale) {
  696. havePower = true
  697. }
  698. }
  699. if user.CompanyId <= 1 {
  700. return
  701. } else {
  702. if permissionStr == "" {
  703. return
  704. } else {
  705. companyDetail, e := models.GetCompanyDetailById(user.CompanyId)
  706. if e != nil {
  707. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  708. return
  709. }
  710. if companyDetail == nil {
  711. err = errors.New("客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId))
  712. return
  713. }
  714. companyDetailStatus = companyDetail.Status
  715. }
  716. }
  717. //宏观满足用户可见身份验证权限既满足 2023-9-18
  718. if activityInfo.ChartPermissionId == 1 {
  719. if activityInfo.LimitPeopleNum > 0 {
  720. if strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) {
  721. havePower = true
  722. return
  723. }
  724. } else {
  725. havePower = true
  726. return
  727. }
  728. }
  729. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  730. havePower = true
  731. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  732. havePower = true
  733. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  734. havePower = true
  735. } else if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3 || activityInfo.ActivityTypeId == 4 || activityInfo.ActivityTypeId == 5) && strings.Contains(permissionStr, "专家") {
  736. havePower = true
  737. }
  738. //fmt.Println(permissionStrZhengShi)
  739. //if (strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略") && strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  740. // havePower = true
  741. // return
  742. //}
  743. if strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略" {
  744. if strings.Contains(activityInfo.CustomerTypeIds, "5") {
  745. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  746. havePower = true
  747. return
  748. }
  749. } else {
  750. if strings.Contains(permissionStrZhengShi, activityInfo.ChartPermissionName) {
  751. havePower = true
  752. return
  753. }
  754. }
  755. }
  756. permissionShengji, errs := models.GetCompanyPermissionByUserTrip(user.CompanyId)
  757. if errs != nil {
  758. err = errs
  759. return
  760. }
  761. //fmt.Println("主客观2", havePower)
  762. //if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) {
  763. // havePower = true
  764. //}
  765. //fmt.Println("主客观3", havePower)
  766. //处理升级权限以及用户身份的 双重判断
  767. if activityInfo.CustomerTypeIds != "" {
  768. if !strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) && userTypeStr != "8" {
  769. havePower = false
  770. if strings.Contains(permissionShengji, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, "8") {
  771. havePower = true
  772. }
  773. }
  774. }
  775. if havePower && activityInfo.LimitPeopleNum > 0 {
  776. //对于一些特殊的活动,即使权限满足也不给产看
  777. noPower, e := GetShareNoPowe(activityInfo, permissionStr, userType, user)
  778. if e != nil {
  779. err = errors.New("GetShareNoPowe, Err: " + e.Error())
  780. return
  781. }
  782. if noPower {
  783. havePower = false
  784. }
  785. }
  786. return
  787. }
  788. // 校验被分享的用户是否有查看详情的权限
  789. func GetShareNoPowe(activityInfo *models.ActivityDetail, permissionStr string, userType int, user *models.WxUserItem) (noPower bool, err error) {
  790. //如果是弘则的就不进行可见权限校验
  791. if user.CompanyId == utils.HZ_COMPANY_ID {
  792. return
  793. }
  794. //var noPower bool
  795. //if !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  796. // noPower = true
  797. //}
  798. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  799. //if userType == 2 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  800. // noPower = true
  801. //}
  802. //if userType == 2 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  803. // noPower = true
  804. //}
  805. //if userType == 3 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  806. // noPower = true
  807. //}
  808. //if userType == 3 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  809. // noPower = true
  810. //}
  811. fmt.Println(userType)
  812. if userType == 8 {
  813. permissionShengji, errs := models.GetCompanyPermissionByUserZhengShiTrip(user.CompanyId)
  814. if errs != nil {
  815. err = errs
  816. return
  817. }
  818. if !strings.Contains(permissionShengji, activityInfo.ChartPermissionName) {
  819. noPower = true
  820. return
  821. }
  822. }
  823. if !noPower {
  824. noPower, err = CheckUserPowerByActivityChoose(user, activityInfo)
  825. }
  826. return
  827. }
  828. // 处理活动本组们是否决策人权限
  829. func CheckUserPowerByActivityChoose(user *models.WxUserItem, activityInfo *models.ActivityDetail) (noPower bool, err error) {
  830. //处理 见范围 1,仅本组可见 、2,全部客户可见
  831. if activityInfo.VisibleRange == 1 {
  832. //adminIds, errAdmin := models.GetSelleridWhichGroup(user.CompanyId, 2)
  833. //if errAdmin != nil {
  834. // err = errAdmin
  835. // return
  836. //}
  837. adminIds := GetSelleridWhichGroup(user.CompanyId, 2, user.Mobile)
  838. sliceAdminIds := strings.Split(adminIds, ",")
  839. var haveAdminId bool
  840. for _, v := range sliceAdminIds {
  841. if v == strconv.Itoa(activityInfo.AdminId) {
  842. haveAdminId = true
  843. }
  844. }
  845. if !haveAdminId {
  846. noPower = true
  847. }
  848. }
  849. //处理 是否仅决策人可见 0,否 、1,是
  850. if activityInfo.IsMakerShow == 1 {
  851. if user.IsMaker == 0 {
  852. noPower = true
  853. }
  854. }
  855. return
  856. }
  857. // 校验用户报名的权限
  858. func GetHavePower(activityInfo *models.ActivityDetail, permissionStr, companyDetailStatus string, userType int) (havePower bool, err error) {
  859. // 查研观向7.4-宏观活动不作权限限制
  860. if activityInfo.ChartPermissionId == 1 {
  861. havePower = true
  862. return
  863. }
  864. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  865. havePower = true
  866. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  867. havePower = true
  868. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  869. havePower = true
  870. //} else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  871. // havePower = true
  872. //} else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  873. // havePower = true
  874. } else if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3 || activityInfo.ActivityTypeId == 4 || activityInfo.ActivityTypeId == 5) && strings.Contains(permissionStr, "专家") {
  875. havePower = true
  876. }
  877. if activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 6 || activityInfo.ActivityTypeId == 7 {
  878. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(主观)") {
  879. havePower = true
  880. }
  881. } else {
  882. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(客观)") {
  883. havePower = true
  884. }
  885. }
  886. if (strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略") && strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  887. havePower = true
  888. }
  889. //如果是易董的活动且属于研选类型,只要开通任何权限就可以查看详情
  890. if activityInfo.YidongActivityId != "" && permissionStr != "" && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  891. havePower = true
  892. }
  893. return
  894. }
  895. // 获取活动列表查询权限的SQL
  896. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  897. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  898. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  899. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  900. // @Param IsPower query int false "是否选择有权限行业 ,1是 0 否 默认0"
  901. // @Param Label query string false "搜索主题 多个用 , 隔开"
  902. // @Param PlayBack query int false "是否仅展示回放 1:是、0:否 默认0"
  903. // @Param KeyWord query string false "搜索关键词 多个用 , 隔开"
  904. // @Param ikType query int false "联想词类型 , 1不做联想,2,做除初始词的联想,3所有联想"
  905. func GetActivityonditionList(user *models.WxUserItem, activityTypeId, chartPermissionIds, whichDay, activeState, label string, isPower, source int, keyWord string, playBack, ikType int) (conditionActivity string, err error) {
  906. keyWordNoIk := keyWord
  907. //adminIds, err := models.GetSelleridWhichGroup(user.CompanyId, 2)
  908. //if err != nil {
  909. // return
  910. //}
  911. adminIds := GetSelleridWhichGroup(user.CompanyId, 2, user.Mobile)
  912. userType, permissionStr, permissionStrZhengShi, err := GetUserTypeZhengShi(user.CompanyId)
  913. if err != nil {
  914. return
  915. }
  916. //判断客户规模是否属于可见范围的活动
  917. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  918. if err != nil && err.Error() != utils.ErrNoRow() {
  919. return
  920. }
  921. isMaker := user.IsMaker
  922. slicePer := strings.Split(permissionStr, ",")
  923. var permissionSqlStr string
  924. var permissionNameStr string
  925. for _, v := range slicePer {
  926. if userType == 1 {
  927. //研选权限处理
  928. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  929. permissionNameStr += "'" + v + "',"
  930. }
  931. } else {
  932. permissionNameStr += "'" + v + "',"
  933. }
  934. }
  935. permissionNameStr = strings.Replace(permissionNameStr, "(主观)", "", -1)
  936. permissionNameStr = strings.Replace(permissionNameStr, "(客观)", "", -1)
  937. permissionNameStr = strings.TrimRight(permissionNameStr, ",")
  938. slicePerZhengShi := strings.Split(permissionStrZhengShi, ",")
  939. var permissionNameStrZhengShi string
  940. for _, v := range slicePerZhengShi {
  941. if userType == 1 {
  942. //研选权限处理
  943. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  944. permissionNameStrZhengShi += "'" + v + "',"
  945. }
  946. } else {
  947. permissionNameStrZhengShi += "'" + v + "',"
  948. }
  949. }
  950. permissionNameStrZhengShi = strings.Replace(permissionNameStrZhengShi, "(主观)", "", -1)
  951. permissionNameStrZhengShi = strings.Replace(permissionNameStrZhengShi, "(客观)", "", -1)
  952. permissionNameStrZhengShi = strings.TrimRight(permissionNameStrZhengShi, ",")
  953. mapUserType, e := GetActivityCcustomerTypeList()
  954. if e != nil {
  955. err = e
  956. return
  957. }
  958. var userTypeStr string
  959. userTypeStr = mapUserType[userType]
  960. // 查研观向7.4-始终查询宏观的权限(无论是否有权限)
  961. if permissionNameStr == `` {
  962. permissionNameStr = `'宏观'`
  963. } else {
  964. permissionNameStr += `, '宏观'`
  965. }
  966. var condition string
  967. var conditionAdmin string
  968. var conditionHz string // 弘则权限处理
  969. var sqlExport string // 专家权限处理
  970. //permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionNameStr + `)`
  971. sqlExport = ` AND (art.customer_type_ids LIKE '%` + userTypeStr + `%' `
  972. //if userType == 2 {
  973. // sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  974. //}
  975. //if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  976. // sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  977. //}
  978. sqlExport += `) `
  979. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  980. if activityTypeId != "" {
  981. if activityTypeId == strconv.Itoa(utils.ANALYST_TELL_ACTIVITY_TYPE_ID) {
  982. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id IN (` + activityTypeId + "," + strconv.Itoa(utils.C_CLASS_ACTIVITY_TYPE_ID) + `)`
  983. } else {
  984. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id IN (` + activityTypeId + `)`
  985. }
  986. }
  987. //主题
  988. if label != "" {
  989. condition = ` AND art.label LIKE "%` + label + `%" `
  990. }
  991. if isPower == 1 {
  992. condition += permissionSqlStr
  993. }
  994. //行业名称
  995. if len(chartPermissionIds) > 0 {
  996. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  997. }
  998. //如果是PC的,则不看易董的
  999. if source == 1 {
  1000. condition += ` AND art.yidong_activity_id = '' `
  1001. }
  1002. var conditionOr string
  1003. if whichDay != "" {
  1004. var startDate string
  1005. var endDate string
  1006. if whichDay == "1" {
  1007. startDate = time.Now().Format(utils.FormatDate)
  1008. endDate = startDate
  1009. } else if whichDay == "2" {
  1010. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1011. endDate = startDate
  1012. } else if whichDay == "3" {
  1013. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  1014. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  1015. } else if whichDay == "4" {
  1016. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  1017. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  1018. } else if whichDay == "5" {
  1019. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  1020. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  1021. } else if whichDay == "6" {
  1022. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  1023. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  1024. } else if whichDay == "1,2" {
  1025. startDate = time.Now().Format(utils.FormatDate)
  1026. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1027. } else if whichDay == "3,4" {
  1028. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  1029. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  1030. } else if whichDay == "5,6" {
  1031. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  1032. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  1033. } else {
  1034. startDate = time.Now().Format(utils.FormatDate)
  1035. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1036. }
  1037. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  1038. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  1039. }
  1040. //有搜索条件传过来时,不判进行状态条件
  1041. if keyWord != "" {
  1042. if ikType == 2 || ikType == 3 {
  1043. keyWordArr, e := GetIndustryMapNameSliceV3(keyWord)
  1044. if e != nil {
  1045. err = errors.New("获取分词失败,GetIndustryMapNameSliceV3, Err: " + keyWord + e.Error())
  1046. return
  1047. }
  1048. keyWordArr = RemoveDuplicatesAndEmpty(keyWordArr)
  1049. //var keywords string
  1050. if len(keyWordArr) > 1 {
  1051. if ikType == 2 {
  1052. keyWord = KeyWordArrSqlRegexp(keyWordArr)
  1053. condition += ` AND (art.label NOT LIKE '%` + keyWordNoIk + `%' AND art.activity_name NOT LIKE '%` + keyWordNoIk + `%' ) `
  1054. } else if ikType == 3 {
  1055. keyWord = KeyWordArrSqlRegexpAll(keyWordArr)
  1056. }
  1057. }
  1058. }
  1059. condition += ` AND (art.label REGEXP '` + keyWord + `' OR art.activity_name REGEXP '` + keyWord + `' ) `
  1060. } else {
  1061. if activeState != "" {
  1062. // 默认查看未开始跟进行中
  1063. if activeState == "1" {
  1064. condition += ` AND art.active_state IN (1,2)`
  1065. } else {
  1066. condition += ` AND art.active_state IN (` + activeState + `)`
  1067. }
  1068. } else {
  1069. condition += ` AND art.active_state IN (1,2)`
  1070. }
  1071. }
  1072. if playBack == 1 {
  1073. var pars []interface{}
  1074. ativityVIdArry := make([]string, 0)
  1075. voiceList, e := models.GetActivityVoiceListAll("", pars, 0, 1000)
  1076. if e != nil && e.Error() != utils.ErrNoRow() {
  1077. err = e
  1078. return
  1079. }
  1080. for _, v := range voiceList {
  1081. ativityVIdArry = append(ativityVIdArry, strconv.Itoa(v.ActivityId))
  1082. }
  1083. videoList, e := models.GetActivityVideoListAll("", pars, 0, 1000)
  1084. if e != nil && e.Error() != utils.ErrNoRow() {
  1085. err = e
  1086. return
  1087. }
  1088. for _, v := range videoList {
  1089. ativityVIdArry = append(ativityVIdArry, strconv.Itoa(v.ActivityId))
  1090. }
  1091. //活动音频,设置有效时间为30天,失效后该活动就不再支持音频回放。有效期起始时间为活动的开始时间
  1092. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  1093. //condition += ` AND art.activity_time > '` + endTime + `' `
  1094. if len(ativityVIdArry) > 0 {
  1095. ativityVIdstr := strings.Join(ativityVIdArry, ",")
  1096. condition += ` AND art.activity_id IN (` + ativityVIdstr + `) `
  1097. } else {
  1098. condition += ` AND art.activity_id = 0 `
  1099. }
  1100. }
  1101. //查询全部可见的数据(是否全部客户可见)
  1102. //condition += ` AND art.visible_range != 1 AND art.publish_status = 1 `
  1103. condition += ` AND art.publish_status = 1 `
  1104. if adminIds == "" {
  1105. //condition += ` AND art.visible_range != 1 `
  1106. } else {
  1107. condition += ` AND ( art.visible_range != 1 OR ( art.admin_id IN ( ` + adminIds + ` ) AND art.visible_range = 1 )) `
  1108. }
  1109. conditionHz = condition
  1110. //活动仅决策人可见
  1111. if isMaker == 0 {
  1112. condition += ` AND art.is_maker_show = 0 `
  1113. }
  1114. conditionAdmin = condition + ` AND art.visible_range = 1 `
  1115. //condition += ` AND art.visible_range != 1 `
  1116. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  1117. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  1118. }
  1119. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  1120. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  1121. }
  1122. if userType == 1 {
  1123. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  1124. } else {
  1125. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1126. }
  1127. if userType == 6 || userType == 7 {
  1128. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' ` + condition + `) `
  1129. }
  1130. if companyProduct != nil {
  1131. if companyProduct.Scale != "" {
  1132. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  1133. }
  1134. }
  1135. if adminIds != "" {
  1136. if userType == 3 {
  1137. conditionAdmin += ` AND art.chart_permission_name IN (` + permissionNameStrZhengShi + `) `
  1138. }
  1139. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + userTypeStr + `%' ` + ` AND art.admin_id IN (` + adminIds + `) ` + conditionAdmin + `) `
  1140. if companyProduct != nil {
  1141. if companyProduct.Scale != "" {
  1142. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%'` + ` AND art.admin_id IN (` + adminIds + `) ` + conditionAdmin + `) `
  1143. }
  1144. }
  1145. }
  1146. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  1147. if e != nil {
  1148. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  1149. return
  1150. }
  1151. if conditionShengji != "" {
  1152. conditionOr += ` OR ( art.is_limit_people = 1 AND ` + conditionShengji + condition + ` ) `
  1153. }
  1154. if conditionZhengshi != "" {
  1155. conditionOr += ` OR ( art.is_limit_people = 1 AND ` + conditionZhengshi + condition + ` ) `
  1156. }
  1157. if conditionHangYe != "" {
  1158. conditionOr += ` OR ( art.is_limit_people = 1 AND ` + conditionHangYe + condition + ` ) `
  1159. }
  1160. //弘则研究下的客户不做权限,限制,C类电话会,仅本组销售、部门管理员、admin、权益研究员账号能看到
  1161. if user.CompanyId == utils.HZ_COMPANY_ID {
  1162. mapMobile, e := GetAdminMobileMap()
  1163. if e != nil {
  1164. err = e
  1165. return
  1166. }
  1167. if _, ok := mapMobile[user.Mobile]; ok {
  1168. conditionOr += ` OR ( art.publish_status = 1 ` + conditionHz + `) `
  1169. }
  1170. }
  1171. if userType == 3 {
  1172. condition += ` AND art.chart_permission_name IN (` + permissionNameStrZhengShi + `) `
  1173. }
  1174. conditionActivity = condition + permissionSqlStr + sqlExport + conditionOr
  1175. return
  1176. }
  1177. // 根据用户身份处理活动可见
  1178. func ActivityConditioninitSql(user *models.WxUserItem, condition string, isPower int) (conditionActivity string, err error) {
  1179. //未登录的用户也可以查看所有活动v12.2.1
  1180. if user.UserId == 0 {
  1181. conditionActivity = ` AND art.publish_status = 1 AND art.yidong_activity_id = '' ` + condition
  1182. return
  1183. }
  1184. // cygx_10.9 未绑定联系方式的客户可以看到部分活动
  1185. if user.UserId == 0 || user.CompanyId == 1 {
  1186. conditionActivity = ` AND art.publish_status = 1 AND art.visible_range != 1 AND (art.is_limit_people = 0 OR (art.is_limit_people=1 AND art.is_all_customer_type=1)) ` + condition
  1187. return
  1188. }
  1189. condition += ` AND art.publish_status = 1 `
  1190. conditionActivity = condition
  1191. //弘则可以查看所有活动
  1192. if (GetBelongingRaiIt(user.Mobile) && user.CompanyId == utils.HZ_COMPANY_ID) || user.UserId == 0 {
  1193. return
  1194. }
  1195. //adminIds, err := models.GetSelleridWhichGroup(user.CompanyId, 2)
  1196. //if err != nil {
  1197. // return
  1198. //}
  1199. adminIds := GetSelleridWhichGroup(user.CompanyId, 2, user.Mobile)
  1200. userType, permissionStr, permissionStrZhengShi, err := GetUserTypeZhengShi(user.CompanyId)
  1201. if err != nil {
  1202. return
  1203. }
  1204. //判断客户规模是否属于可见范围的活动
  1205. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  1206. if err != nil && err.Error() != utils.ErrNoRow() {
  1207. return
  1208. }
  1209. isMaker := user.IsMaker
  1210. slicePer := strings.Split(permissionStr, ",")
  1211. var permissionSqlStr string
  1212. var permissionNameStr string
  1213. for _, v := range slicePer {
  1214. if userType == 1 {
  1215. //研选权限处理
  1216. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1217. permissionNameStr += "'" + v + "',"
  1218. }
  1219. } else {
  1220. permissionNameStr += "'" + v + "',"
  1221. }
  1222. }
  1223. permissionNameStr = strings.Replace(permissionNameStr, "(主观)", "", -1)
  1224. permissionNameStr = strings.Replace(permissionNameStr, "(客观)", "", -1)
  1225. permissionNameStr = strings.TrimRight(permissionNameStr, ",")
  1226. slicePerZhengShi := strings.Split(permissionStrZhengShi, ",")
  1227. var permissionNameStrZhengShi string
  1228. for _, v := range slicePerZhengShi {
  1229. if userType == 1 {
  1230. //研选权限处理
  1231. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  1232. permissionNameStrZhengShi += "'" + v + "',"
  1233. }
  1234. } else {
  1235. permissionNameStrZhengShi += "'" + v + "',"
  1236. }
  1237. }
  1238. permissionNameStrZhengShi = strings.Replace(permissionNameStrZhengShi, "(主观)", "", -1)
  1239. permissionNameStrZhengShi = strings.Replace(permissionNameStrZhengShi, "(客观)", "", -1)
  1240. permissionNameStrZhengShi = strings.TrimRight(permissionNameStrZhengShi, ",")
  1241. mapUserType, e := GetActivityCcustomerTypeList()
  1242. if e != nil {
  1243. err = e
  1244. return
  1245. }
  1246. var userTypeStr string
  1247. userTypeStr = mapUserType[userType]
  1248. // 查研观向7.4-始终查询宏观的权限(无论是否有权限)
  1249. if permissionNameStr == `` {
  1250. permissionNameStr = `'宏观'`
  1251. } else {
  1252. permissionNameStr += `, '宏观'`
  1253. }
  1254. var sqlExport string // 专家权限处理
  1255. sqlExport = ` AND (art.customer_type_ids LIKE '%` + userTypeStr + `%' `
  1256. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  1257. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  1258. }
  1259. sqlExport += `) `
  1260. if isPower == 1 {
  1261. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionNameStr + `)`
  1262. condition += permissionSqlStr
  1263. }
  1264. var conditionOr string
  1265. //查询全部可见的数据(是否全部客户可见)
  1266. if adminIds != "" {
  1267. condition += ` AND ( art.visible_range != 1 OR ( art.admin_id IN ( ` + adminIds + ` ) AND art.visible_range = 1 )) `
  1268. }
  1269. //活动仅决策人可见
  1270. if isMaker == 0 {
  1271. condition += ` AND art.is_maker_show = 0 `
  1272. }
  1273. //condition += ` AND art.visible_range != 1 `
  1274. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  1275. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  1276. }
  1277. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  1278. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  1279. }
  1280. if userType == 1 {
  1281. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  1282. } else {
  1283. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1284. }
  1285. if userType == 6 || userType == 7 {
  1286. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' ` + condition + `) `
  1287. }
  1288. if companyProduct != nil {
  1289. if companyProduct.Scale != "" {
  1290. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  1291. }
  1292. }
  1293. conditionShengji, conditionZhengshi, conditionHangYe, e := ActivityLabelSpecialUserSql(user)
  1294. if e != nil {
  1295. err = errors.New("ActivityLabelSpecialUserSql, Err: " + e.Error())
  1296. return
  1297. }
  1298. // 升级客户可查看范围
  1299. if conditionShengji != "" {
  1300. conditionOr += ` OR ( art.is_limit_people = 1 AND ` + conditionShengji + condition + ` ) `
  1301. }
  1302. // 正式客户可查看范围
  1303. if conditionZhengshi != "" {
  1304. conditionOr += ` OR ( art.is_limit_people = 1 AND ` + conditionZhengshi + condition + ` ) `
  1305. }
  1306. // 行业客户可查看范围
  1307. if conditionHangYe != "" {
  1308. conditionOr += ` OR ( art.is_limit_people = 1 AND ` + conditionHangYe + condition + ` ) `
  1309. }
  1310. if userType == 3 {
  1311. condition += ` AND art.chart_permission_name IN (` + permissionNameStrZhengShi + `) `
  1312. }
  1313. condition += ` AND art.is_limit_people = 1 `
  1314. conditionActivity = condition + permissionSqlStr + sqlExport + conditionOr
  1315. return
  1316. }
  1317. // 研选系列专家电话会,会前1小时将问题列表发送给邮箱
  1318. func SendEmailFileForAskMsgResearch(cont context.Context) (err error) {
  1319. var msg string
  1320. //var touser string
  1321. defer func() {
  1322. if err != nil {
  1323. go utils.SendAlarmMsg("发送附件模版消息失败", 2)
  1324. go utils.SendEmail("发送附件模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format(utils.FormatDateTime), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  1325. }
  1326. if msg != "" {
  1327. go utils.SendAlarmMsg(msg, 2)
  1328. utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
  1329. }
  1330. }()
  1331. endDate := time.Now().Add(+time.Minute * 60).Format(utils.FormatDateTime)
  1332. condition := `AND a.activity_type_id = 1 AND a.chart_permission_id = 31 `
  1333. total, err := models.GetCountActivityResearchToSendFile(condition, endDate)
  1334. if total == 0 {
  1335. fmt.Println("发送附件完成0")
  1336. return nil
  1337. }
  1338. if err != nil {
  1339. msg = "发送附件模版消息失败 Err:" + err.Error()
  1340. return
  1341. }
  1342. listActivity, err := models.GetActivityResearchToSendFile(condition, endDate)
  1343. if err != nil {
  1344. msg = "发送附件模版消息失败 Err:" + err.Error()
  1345. return
  1346. }
  1347. for _, v := range listActivity {
  1348. activityInfo, _ := models.GetAddActivityInfoById(v.ActivityId)
  1349. if activityInfo == nil {
  1350. msg = "活动不存在,Err:activityId:" + strconv.Itoa(v.ActivityId)
  1351. return
  1352. }
  1353. list, errFile := models.GetActivityMsgExport(v.ActivityId)
  1354. if errFile != nil {
  1355. msg = "获取失败,Err:" + errFile.Error()
  1356. return
  1357. }
  1358. for _, v2 := range list {
  1359. user, e := models.GetWxUserItemByUserId(v2.UserId)
  1360. if e != nil && e.Error() != utils.ErrNoRow() {
  1361. err = errors.New("GetWxUserItemByUserId, Err: " + e.Error())
  1362. return err
  1363. }
  1364. //获取销售信息
  1365. sellerItem, e := models.GetSellerByCompanyIdCheckFicc(v2.CompanyId, 2)
  1366. if e != nil && e.Error() != utils.ErrNoRow() {
  1367. err = errors.New("GetSellerByCompanyIdCheckFicc, Err: " + e.Error())
  1368. return
  1369. }
  1370. //如果是研选的就推送给汪洋
  1371. cnf, e := models.GetConfigByCode(utils.TPL_MSG_WANG_YANG)
  1372. if e != nil {
  1373. err = errors.New("GetConfigByCode, Err: " + e.Error())
  1374. return
  1375. }
  1376. //给汪洋推送消息
  1377. if sellerItem != nil {
  1378. openIpItem, _ := models.GetUserRecordByMobile(4, cnf.ConfigValue)
  1379. if openIpItem != nil && openIpItem.OpenId != "" {
  1380. SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "提问:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), v2.Content, activityInfo.ActivityName, openIpItem, activityInfo, v2.AskId)
  1381. }
  1382. }
  1383. //给所属销售推送消息
  1384. if sellerItem != nil {
  1385. openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
  1386. if openIpItem != nil && openIpItem.OpenId != "" {
  1387. SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "提问:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), v2.Content, activityInfo.ActivityName, openIpItem, activityInfo, v2.AskId)
  1388. }
  1389. }
  1390. }
  1391. errFile = models.UPdateActivityMsgToSendFile(v.ActivityId)
  1392. if errFile != nil {
  1393. msg = "获取失败,Err:" + errFile.Error()
  1394. return
  1395. }
  1396. }
  1397. return
  1398. }
  1399. // 非研选系列专家电话会,根据主持人姓名,会前15分钟将问题列表发送给至该主持人对应邮箱
  1400. func SendEmailFileForAskMsg(cont context.Context) (err error) {
  1401. var msg string
  1402. //var touser string
  1403. defer func() {
  1404. if err != nil {
  1405. go utils.SendAlarmMsg("发送附件模版消息失败", 2)
  1406. go utils.SendEmail("发送附件模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format(utils.FormatDateTime), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  1407. }
  1408. if msg != "" {
  1409. go utils.SendAlarmMsg(msg, 2)
  1410. utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
  1411. }
  1412. }()
  1413. endDate := time.Now().Add(+time.Minute * 15).Format(utils.FormatDateTime)
  1414. condition := `AND a.activity_type_id = 1 AND a.chart_permission_id != 31 `
  1415. total, err := models.GetCountActivityResearchToSendFile(condition, endDate)
  1416. if total == 0 {
  1417. fmt.Println("发送附件完成0")
  1418. return nil
  1419. }
  1420. if err != nil {
  1421. msg = "发送附件模版消息失败 Err:" + err.Error()
  1422. return
  1423. }
  1424. listActivity, err := models.GetActivityResearchToSendFile(condition, endDate)
  1425. if err != nil {
  1426. msg = "发送附件模版消息失败 Err:" + err.Error()
  1427. return
  1428. }
  1429. listEmail, errEmail := models.GetAskEmail()
  1430. if errEmail != nil {
  1431. msg = "获取失败,Err:" + errEmail.Error()
  1432. return
  1433. }
  1434. for _, v := range listActivity {
  1435. activityInfo, _ := models.GetAddActivityInfoById(v.ActivityId)
  1436. if activityInfo == nil {
  1437. msg = "活动不存在,Err:activityId:" + strconv.Itoa(v.ActivityId)
  1438. return
  1439. }
  1440. list, errFile := models.GetActivityMsgExport(v.ActivityId)
  1441. if errFile != nil {
  1442. msg = "获取失败,Err:" + errFile.Error()
  1443. return
  1444. }
  1445. for _, v2 := range list {
  1446. user, err := models.GetWxUserItemByUserId(v2.UserId)
  1447. if err != nil && err.Error() != utils.ErrNoRow() {
  1448. return err
  1449. }
  1450. var sendMobile string
  1451. for _, vEmail := range listEmail {
  1452. if strings.Index(activityInfo.Host, vEmail.Name) > 0 {
  1453. sendMobile = vEmail.Mobile
  1454. }
  1455. }
  1456. //获取销售信息
  1457. sellerItem, err := models.GetSellerByCompanyIdCheckFicc(v2.CompanyId, 2)
  1458. if err != nil && err.Error() != utils.ErrNoRow() {
  1459. return err
  1460. }
  1461. //给研究员推送模板消息
  1462. if sellerItem != nil {
  1463. openIpItem, _ := models.GetUserRecordByMobile(4, sendMobile)
  1464. if openIpItem != nil && openIpItem.OpenId != "" {
  1465. //SendActivityAskApplyTemplateMsg(user.RealName+"——"+user.CompanyName+"(所属销售:"+sellerItem.RealName+")", v2.CreateTime, v2.Content, activityInfo.ActivityName, activityInfo.ActivityId, openIpItem)
  1466. //SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName, "所属销售:"+sellerItem.RealName, time.Now().Format(utils.FormatDateTime), v2.Content, activityInfo.ActivityName, openIpItem, activityInfo)
  1467. SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "提问:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), v2.Content, activityInfo.ActivityName, openIpItem, activityInfo, v2.AskId)
  1468. }
  1469. }
  1470. //给销售推送模板消息
  1471. if sellerItem != nil {
  1472. openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
  1473. if openIpItem != nil && openIpItem.OpenId != "" {
  1474. //SendActivityAskApplyTemplateMsg(user.RealName+"——"+user.CompanyName+"(所属销售:"+sellerItem.RealName+")", v2.CreateTime, v2.Content, activityInfo.ActivityName, activityInfo.ActivityId, openIpItem)
  1475. //SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName, "所属销售:"+sellerItem.RealName, time.Now().Format(utils.FormatDateTime), v2.Content, activityInfo.ActivityName, openIpItem, activityInfo)
  1476. SendActivityAskApplyTemplateMsgV2(user.RealName+"——"+user.CompanyName+"("+sellerItem.RealName+")", "提问:"+activityInfo.ActivityName, time.Now().Format(utils.FormatDateTime), v2.Content, activityInfo.ActivityName, openIpItem, activityInfo, v2.AskId)
  1477. }
  1478. }
  1479. }
  1480. errFile = models.UPdateActivityMsgToSendFile(v.ActivityId)
  1481. if errFile != nil {
  1482. msg = "获取失败,Err:" + errFile.Error()
  1483. return
  1484. }
  1485. }
  1486. return
  1487. }
  1488. // 活动标签字符串处理
  1489. func LabelStr(label string) (labelNew string) {
  1490. slicebr := strings.Split(label, "-")
  1491. if len(slicebr) < 2 {
  1492. labelNew = label
  1493. } else {
  1494. labelNew = slicebr[1]
  1495. }
  1496. return labelNew
  1497. }
  1498. // 5.3版本活动标签字符串处理
  1499. func LabelStrV5(label string, isShowSubjectName int, temporaryLabel string) (labelNew string) {
  1500. slicebr := strings.Split(label, "-")
  1501. if len(slicebr) > 1 {
  1502. if isShowSubjectName == 1 {
  1503. labelNew = slicebr[1]
  1504. } else {
  1505. labelNew = slicebr[0]
  1506. }
  1507. } else {
  1508. labelNew = label
  1509. }
  1510. if temporaryLabel != "" {
  1511. labelNew = temporaryLabel
  1512. }
  1513. return labelNew
  1514. }
  1515. func ActivityAttendanceDetail(cont context.Context) (err error) {
  1516. defer func() {
  1517. if err != nil {
  1518. fmt.Println("ActivityAttendanceDetail Err:" + err.Error())
  1519. go utils.SendAlarmMsg("同步进门财经数据失败", 2)
  1520. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "ActivityAttendanceDetail ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  1521. }
  1522. }()
  1523. configCode := "jin_meng_activity_id"
  1524. detail, err := models.GetConfigByCode(configCode)
  1525. if err != nil {
  1526. return err
  1527. }
  1528. fmt.Println(detail.ConfigValue)
  1529. mapActivityId := make(map[string]string)
  1530. sliceValue := strings.Split(detail.ConfigValue, ",")
  1531. for _, v := range sliceValue {
  1532. mapActivityId[v] = v
  1533. }
  1534. var activityIds string
  1535. var activityIdsLongTime string //可回放的会议,到会详情持续更新加入到不做14天限制的活动中
  1536. fmt.Println("开始同步")
  1537. dateTime := time.Now().AddDate(0, 0, -7).Format(utils.FormatDate)
  1538. dateNow := time.Now().AddDate(0, 0, 0).Format(utils.FormatDate)
  1539. startDate := dateTime + " 00:00:00"
  1540. endDate := dateNow + " 23:59:59"
  1541. //获取进门财经需要处理的活动
  1542. listActivityRoadshow, err := models.GetRoadshowDataListByDateTime(startDate, endDate)
  1543. if err != nil {
  1544. fmt.Println("GetRoadshowDataListByDateTime Err:", err.Error())
  1545. return err
  1546. }
  1547. for _, vAct := range listActivityRoadshow {
  1548. doTime := utils.TimeRemoveHms2(vAct.RoadshowBeginTime)
  1549. findStartDate := doTime + " 00:00:00"
  1550. findEndDate := doTime + " 23:59:59"
  1551. var roadshowTitle string
  1552. roadshowTitle = vAct.RoadshowTitle
  1553. vAct.RoadshowTitle = strings.Replace(vAct.RoadshowTitle, "【", "", -1)
  1554. vAct.RoadshowTitle = strings.Replace(vAct.RoadshowTitle, "】", "", -1)
  1555. vAct.RoadshowTitle = strings.Replace(vAct.RoadshowTitle, " ", "", -1)
  1556. vAct.RoadshowTitle = strings.Replace(vAct.RoadshowTitle, "-", "", -1)
  1557. vAct.RoadshowTitle = strings.Replace(vAct.RoadshowTitle, ":", "", -1)
  1558. nameSlice := strings.Split(vAct.RoadshowTitle, "|")
  1559. //fmt.Println(timeSlice[0])
  1560. //对于手动匹配到的活动数据也要更新
  1561. var activityName string
  1562. if len(nameSlice) >= 1 {
  1563. //if vAct.JmcjRoadshowTitle != "" {
  1564. // activityName = vAct.JmcjRoadshowTitle
  1565. //} else {
  1566. // activityName = nameSlice[len(nameSlice)-1]
  1567. //}
  1568. activityName = nameSlice[len(nameSlice)-1]
  1569. if activityName != "" {
  1570. //通过名称去找匹配的活动
  1571. activityDetail, _ := models.GetAddActivityInfoByTitle(activityName, findStartDate, findEndDate)
  1572. if activityDetail == nil {
  1573. continue
  1574. } else {
  1575. activityIds += strconv.Itoa(activityDetail.ActivityId) + ","
  1576. }
  1577. list, err := models.GetRoadshowDataList(roadshowTitle, findStartDate, findEndDate)
  1578. if err != nil {
  1579. fmt.Println("GetTacticsList Err:", err.Error())
  1580. return err
  1581. }
  1582. var isPlayback bool // 是否包含回放
  1583. needAddAttendanc := make([]*models.CygxActivityAttendanceDetail, 0)
  1584. var mobileStr string
  1585. var mobileArr []string
  1586. if len(list) > 0 {
  1587. fmt.Println("原来的", vAct.RoadshowTitle)
  1588. fmt.Println("处理的", activityName)
  1589. for _, v := range list {
  1590. if v.UserPhone != "" {
  1591. item := new(models.CygxActivityAttendanceDetail)
  1592. item.ActivityId = activityDetail.ActivityId
  1593. item.RealName = v.UserName
  1594. item.Mobile = v.UserPhone
  1595. item.CompanyName = v.Company
  1596. //item.SellerName = sellerName
  1597. item.FirstMeetingTime = v.FirstWatchTime
  1598. item.LastMeetingTime = v.LastWatchTime
  1599. item.Duration = utils.GetAttendanceDetailSeconds(v.JoinTime)
  1600. if v.JoinType == 1 {
  1601. item.MeetingTypeStr = "网络"
  1602. } else {
  1603. item.MeetingTypeStr = "电话"
  1604. }
  1605. item.MeetingAuthentication = v.AuthInfo
  1606. if v.DataType == 1 {
  1607. item.MeetingStatusStr = "直播"
  1608. } else {
  1609. item.MeetingStatusStr = "回放"
  1610. isPlayback = true
  1611. }
  1612. item.Position = v.Occupation
  1613. item.UseridEntity = v.UseridEntity
  1614. item.ActivityTime = activityDetail.ActivityTime
  1615. item.CrmCompanyMapStatusId = v.CrmCompanyMapStatusId
  1616. item.CreateTime = time.Now()
  1617. mobileStr += "'" + v.UserPhone + "'" + ","
  1618. mobileArr = append(mobileArr, v.UserPhone)
  1619. needAddAttendanc = append(needAddAttendanc, item)
  1620. }
  1621. }
  1622. if isPlayback && mapActivityId[strconv.Itoa(activityDetail.ActivityId)] == "" {
  1623. activityIdsLongTime += strconv.Itoa(activityDetail.ActivityId) + ","
  1624. }
  1625. mobileStr = strings.TrimRight(mobileStr, ",")
  1626. if mobileStr == "" {
  1627. mobileStr = "1"
  1628. }
  1629. listUser, err := models.GetWxUserOutboundMobile(mobileStr)
  1630. if err != nil {
  1631. fmt.Println("GetWxUserOutboundMobile Err:", err.Error())
  1632. return err
  1633. }
  1634. for k, v := range needAddAttendanc {
  1635. for _, v2 := range listUser {
  1636. if v2.OutboundMobile == v.Mobile || v2.Mobile == v.Mobile {
  1637. if needAddAttendanc[k].CompanyId == 0 {
  1638. needAddAttendanc[k].CompanyId = v2.CompanyId
  1639. needAddAttendanc[k].SellerName = v2.SellerName
  1640. needAddAttendanc[k].CompanyName = v2.CompanyName
  1641. needAddAttendanc[k].IsMeetingStr = 1
  1642. }
  1643. }
  1644. }
  1645. }
  1646. //fmt.Println(mobileStr)
  1647. //参会记录
  1648. err = models.AddAttendancDetail(needAddAttendanc, activityDetail.ActivityId, mobileStr)
  1649. if err != nil {
  1650. fmt.Println("AddAttendancDetail Err:", err.Error())
  1651. return err
  1652. }
  1653. ////处理是否限制报名
  1654. err = AddCygxActivityRestrictSignupByAdmin(activityDetail.ActivityId)
  1655. if err != nil {
  1656. fmt.Println("AddCygxActivityRestrictSignupByAdmin Err:", err.Error())
  1657. return err
  1658. }
  1659. go ActivityUserLabelLogAdd(activityDetail.ActivityId, mobileArr)
  1660. AddctivitySignupDetailByJmcj(needAddAttendanc, activityDetail.ActivityId)
  1661. }
  1662. }
  1663. }
  1664. }
  1665. //获取需要处理的活动
  1666. listActivity, err := models.GetActivityListByDateTime(startDate, endDate, activityIds, detail.ConfigValue)
  1667. if err != nil {
  1668. fmt.Println("GetTacticsList Err:", err.Error())
  1669. return err
  1670. }
  1671. //通过本地去找进门财经的数据
  1672. for _, vAct := range listActivity {
  1673. doTime := utils.TimeRemoveHms2(vAct.ActivityTime)
  1674. findStartDate := doTime + " 00:00:00"
  1675. findEndDate := doTime + " 23:59:59"
  1676. nameSlice := strings.Split(vAct.ActivityName, "】")
  1677. //对于手动匹配到的活动数据也要更新
  1678. var activityName string
  1679. if len(nameSlice) > 1 {
  1680. if vAct.JmcjRoadshowTitle != "" {
  1681. activityName = vAct.JmcjRoadshowTitle
  1682. } else {
  1683. activityName = nameSlice[len(nameSlice)-1]
  1684. }
  1685. //activityName = nameSlice[len(nameSlice)-1]
  1686. if activityName != "" {
  1687. list, err := models.GetRoadshowDataList(activityName, findStartDate, findEndDate)
  1688. if err != nil {
  1689. fmt.Println("GetTacticsList Err:", err.Error())
  1690. return err
  1691. }
  1692. var isPlayback bool // 是否包含回放
  1693. needAddAttendanc := make([]*models.CygxActivityAttendanceDetail, 0)
  1694. var mobileStr string
  1695. var mobileArr []string
  1696. if len(list) > 0 {
  1697. fmt.Println("原来的1", vAct.ActivityName)
  1698. fmt.Println("处理的2", activityName)
  1699. for _, v := range list {
  1700. if v.UserPhone != "" {
  1701. item := new(models.CygxActivityAttendanceDetail)
  1702. item.ActivityId = vAct.ActivityId
  1703. item.RealName = v.UserName
  1704. item.Mobile = v.UserPhone
  1705. item.CompanyName = v.Company
  1706. //item.SellerName = sellerName
  1707. item.FirstMeetingTime = v.FirstWatchTime
  1708. item.LastMeetingTime = v.LastWatchTime
  1709. item.Duration = utils.GetAttendanceDetailSeconds(v.JoinTime)
  1710. if v.JoinType == 1 {
  1711. item.MeetingTypeStr = "网络"
  1712. } else {
  1713. item.MeetingTypeStr = "电话"
  1714. }
  1715. item.MeetingAuthentication = v.AuthInfo
  1716. if v.DataType == 1 {
  1717. item.MeetingStatusStr = "直播"
  1718. } else {
  1719. item.MeetingStatusStr = "回放"
  1720. isPlayback = true
  1721. }
  1722. item.Position = v.Occupation
  1723. item.UseridEntity = v.UseridEntity
  1724. item.ActivityTime = vAct.ActivityTime
  1725. item.CrmCompanyMapStatusId = v.CrmCompanyMapStatusId
  1726. item.CreateTime = time.Now()
  1727. mobileStr += "'" + v.UserPhone + "'" + ","
  1728. mobileArr = append(mobileArr, v.UserPhone)
  1729. needAddAttendanc = append(needAddAttendanc, item)
  1730. }
  1731. }
  1732. if isPlayback && mapActivityId[strconv.Itoa(vAct.ActivityId)] == "" {
  1733. activityIdsLongTime += strconv.Itoa(vAct.ActivityId) + ","
  1734. }
  1735. mobileStr = strings.TrimRight(mobileStr, ",")
  1736. if mobileStr == "" {
  1737. mobileStr = "1"
  1738. }
  1739. listUser, err := models.GetWxUserOutboundMobile(mobileStr)
  1740. if err != nil {
  1741. fmt.Println("GetWxUserOutboundMobile Err:", err.Error())
  1742. return err
  1743. }
  1744. for k, v := range needAddAttendanc {
  1745. for _, v2 := range listUser {
  1746. if v2.OutboundMobile == v.Mobile || v2.Mobile == v.Mobile {
  1747. if needAddAttendanc[k].CompanyId == 0 {
  1748. needAddAttendanc[k].CompanyId = v2.CompanyId
  1749. needAddAttendanc[k].SellerName = v2.SellerName
  1750. needAddAttendanc[k].CompanyName = v2.CompanyName
  1751. needAddAttendanc[k].IsMeetingStr = 1
  1752. }
  1753. }
  1754. }
  1755. }
  1756. ////参会记录
  1757. err = models.AddAttendancDetail(needAddAttendanc, vAct.ActivityId, mobileStr)
  1758. if err != nil {
  1759. fmt.Println("AddAttendancDetail Err:", err.Error())
  1760. return err
  1761. }
  1762. ////处理是否限制报名
  1763. err = AddCygxActivityRestrictSignupByAdmin(vAct.ActivityId)
  1764. if err != nil {
  1765. fmt.Println("AddCygxActivityRestrictSignupByAdmin Err:", err.Error())
  1766. return err
  1767. }
  1768. activityIds += strconv.Itoa(vAct.ActivityId) + ","
  1769. go ActivityUserLabelLogAdd(vAct.ActivityId, mobileArr)
  1770. AddctivitySignupDetailByJmcj(needAddAttendanc, vAct.ActivityId)
  1771. }
  1772. }
  1773. }
  1774. }
  1775. if activityIdsLongTime != "" {
  1776. activityIdsLongTime = strings.TrimRight(activityIdsLongTime, ",")
  1777. activityIdsLongTime = detail.ConfigValue + "," + activityIdsLongTime
  1778. go models.UpdateConfigByCode(activityIdsLongTime, configCode)
  1779. }
  1780. activityIds = strings.TrimRight(activityIds, ",")
  1781. if activityIds != "" {
  1782. detailList, err := models.GetActivityAttendanceDetailList(activityIds)
  1783. if err != nil {
  1784. fmt.Println("GetActivityAttendanceDetailList Err:", err.Error())
  1785. return err
  1786. }
  1787. //添加报名日志 (下载使用)
  1788. err = models.AddCygxActivityMeetDetailLogOnlineByList(detailList, activityIds)
  1789. if err != nil {
  1790. fmt.Println("AddCygxActivityMeetDetailLogOnline Err:", err.Error())
  1791. return err
  1792. }
  1793. }
  1794. fmt.Println("结束路演同步")
  1795. return
  1796. }
  1797. // 查研观向处理活动用户限制报名
  1798. func AddCygxActivityRestrictSignupByAdmin(activityId int) (err error) {
  1799. defer func() {
  1800. if err != nil {
  1801. fmt.Println("err:", err)
  1802. go utils.SendAlarmMsg("查研观向处理活动用户限制报名失败,Err:"+err.Error()+"activityId"+strconv.Itoa(activityId), 3)
  1803. }
  1804. }()
  1805. activityInfo, e := models.GetAddActivityInfoById(activityId)
  1806. if e != nil {
  1807. err = errors.New("GetAddActivityInfoById" + e.Error())
  1808. return
  1809. }
  1810. if activityInfo == nil {
  1811. return
  1812. }
  1813. //不限制报名的不做爽约限制处理
  1814. //if activityInfo.IsLimitPeople > 0 {
  1815. //total, err := cygx.GetActivitySignupNomeetingCount(activityId)
  1816. if err != nil {
  1817. return
  1818. }
  1819. mobileList, _ := models.GetUserMeetingMobile(activityId)
  1820. var userIdArr []int
  1821. if len(mobileList) > 0 {
  1822. for _, v := range mobileList {
  1823. userIdArr = append(userIdArr, v.UserId)
  1824. }
  1825. lenuserIdArr := len(userIdArr)
  1826. var condition string
  1827. var pars []interface{}
  1828. condition = ` AND user_id IN (` + utils.GetOrmInReplace(lenuserIdArr) + `)`
  1829. pars = append(pars, userIdArr)
  1830. restrictSignupList, e := models.GetCygxActivityRestrictSignupList(condition, pars, 0, 9999)
  1831. if e != nil {
  1832. err = errors.New("GetCygxActivityRestrictSignupList" + e.Error())
  1833. return
  1834. }
  1835. //获取这些用户是否被加入到限制报名了
  1836. maptotalRestrict := make(map[int]bool)
  1837. for _, v := range restrictSignupList {
  1838. maptotalRestrict[v.UserId] = true
  1839. }
  1840. pars = make([]interface{}, 0)
  1841. condition = ` AND a.is_limit_people = 1 AND v.is_meeting = 0 AND v.do_fail_type = 0 AND v.user_id IN (` + utils.GetOrmInReplace(lenuserIdArr) + `)`
  1842. pars = append(pars, userIdArr)
  1843. listSignup, e := models.GetActivitySignupInnerActivityList(condition, pars)
  1844. if e != nil && e.Error() != utils.ErrNoRow() {
  1845. err = errors.New("GetActivitySignupInnerActivityList" + e.Error())
  1846. return
  1847. }
  1848. mapNomeet := make(map[int]int)
  1849. if len(listSignup) > 0 {
  1850. for _, v := range listSignup {
  1851. mapNomeet[v.UserId]++
  1852. }
  1853. }
  1854. var userIdDelArr []int
  1855. for _, v := range mobileList {
  1856. //如果加入了爽约限制但是爽约次数少于3条就删除爽约记录
  1857. if maptotalRestrict[v.UserId] && mapNomeet[v.UserId] < 3 {
  1858. userIdDelArr = append(userIdDelArr, v.UserId)
  1859. }
  1860. }
  1861. if len(userIdDelArr) > 0 {
  1862. e = models.DeleteCygxActivityRestrictSignupByUserIds(userIdDelArr)
  1863. if e != nil {
  1864. err = errors.New("DeleteCygxActivityRestrictSignupByUserIds" + e.Error())
  1865. return
  1866. }
  1867. }
  1868. }
  1869. //if total == 0 {
  1870. // return
  1871. //}
  1872. //}
  1873. list, e := models.GetActivitySignupNomeetingCountList(activityId)
  1874. if e != nil {
  1875. err = errors.New("GetActivitySignupNomeetingCountList" + e.Error())
  1876. return
  1877. }
  1878. var userIdSiginArr []int
  1879. var items []*models.CygxActivitySignupBreak
  1880. for _, v := range list {
  1881. userIdSiginArr = append(userIdSiginArr, v.UserId)
  1882. //添加爽约记录
  1883. item := new(models.CygxActivitySignupBreak)
  1884. item.UserId = v.UserId
  1885. item.ActivityId = v.ActivityId
  1886. item.CreateTime = time.Now()
  1887. item.Mobile = v.Mobile
  1888. item.Email = v.Email
  1889. item.CompanyId = v.CompanyId
  1890. item.CompanyName = v.CompanyName
  1891. item.RealName = v.RealName
  1892. item.SellerName = v.SellerName
  1893. items = append(items, item)
  1894. }
  1895. if len(list) == 0 {
  1896. return
  1897. }
  1898. var itemsRestrict []*models.CygxActivityRestrictSignup
  1899. maptotalRestrict := make(map[int]bool)
  1900. lenuserIdSiginArr := len(userIdSiginArr)
  1901. var condition string
  1902. var pars []interface{}
  1903. condition = ` AND user_id IN (` + utils.GetOrmInReplace(lenuserIdSiginArr) + `)`
  1904. pars = append(pars, userIdSiginArr)
  1905. restrictSignupList, e := models.GetCygxActivityRestrictSignupList(condition, pars, 0, 9999)
  1906. if e != nil {
  1907. err = errors.New("GetCygxActivityRestrictSignupList" + e.Error())
  1908. return
  1909. }
  1910. //获取这些用户是否被加入到限制报名了
  1911. for _, v := range restrictSignupList {
  1912. maptotalRestrict[v.UserId] = true
  1913. }
  1914. pars = make([]interface{}, 0)
  1915. condition = ` AND a.is_limit_people = 1 AND v.is_meeting = 0 AND v.do_fail_type = 0 AND user_id IN (` + utils.GetOrmInReplace(lenuserIdSiginArr) + `)`
  1916. pars = append(pars, userIdSiginArr)
  1917. listSignup, e := models.GetActivitySignupInnerActivityList(condition, pars)
  1918. if e != nil && e.Error() != utils.ErrNoRow() {
  1919. err = errors.New("GetActivitySignupInnerActivityList" + e.Error())
  1920. return
  1921. }
  1922. mapNomeet := make(map[int]int)
  1923. if len(listSignup) > 0 {
  1924. for _, v := range listSignup {
  1925. mapNomeet[v.UserId]++
  1926. }
  1927. }
  1928. for _, v := range mobileList {
  1929. //如果加入了爽约限制但是爽约次数少于3条就删除爽约记录
  1930. if !maptotalRestrict[v.UserId] && mapNomeet[v.UserId] >= 3 {
  1931. itemRestrict := new(models.CygxActivityRestrictSignup)
  1932. itemRestrict.UserId = v.UserId
  1933. itemRestrict.CreateTime = time.Now()
  1934. itemRestrict.Mobile = v.Mobile
  1935. itemRestrict.Email = v.Email
  1936. itemRestrict.CompanyId = v.CompanyId
  1937. itemRestrict.CompanyName = v.CompanyName
  1938. itemRestrict.IsRestrict = 1
  1939. itemsRestrict = append(itemsRestrict, itemRestrict)
  1940. }
  1941. }
  1942. err = models.DeleteCygxActivitySignupBreakById(activityId)
  1943. if err != nil {
  1944. err = errors.New("DeleteCygxActivitySignupBreakById" + err.Error())
  1945. return
  1946. }
  1947. //添加爽约记录
  1948. if len(items) > 0 {
  1949. _, e = models.AddCygxActivitySignupBreakList(items)
  1950. if e != nil {
  1951. err = errors.New("AddCygxActivitySignupBreakList, Err: " + e.Error())
  1952. return
  1953. }
  1954. }
  1955. //添加报名限制
  1956. if len(itemsRestrict) > 0 {
  1957. _, e = models.AddCygxActivityRestrictSignupList(itemsRestrict)
  1958. if e != nil {
  1959. err = errors.New("AddCygxActivityRestrictSignupList, Err: " + e.Error())
  1960. return
  1961. }
  1962. }
  1963. return
  1964. }
  1965. // 判断预约纪要按钮是否显示
  1966. func IsShowAppointment(activityTypeId int, chartPermissionName string) (isShowAppointment bool) {
  1967. if activityTypeId == 1 || activityTypeId == 2 || activityTypeId == 3 || activityTypeId == 4 {
  1968. isShowAppointment = true
  1969. }
  1970. if activityTypeId == 5 && chartPermissionName == "医药" {
  1971. isShowAppointment = true
  1972. }
  1973. return
  1974. }
  1975. // 判断预约纪要按钮是否显示
  1976. func IsShowAppointmentByactivityInfo(item *models.ActivityDetail, chartPermissionName string) (isShowAppointment bool) {
  1977. activityTypeId := item.ActivityTypeId
  1978. if activityTypeId == 1 || activityTypeId == 3 || activityTypeId == 4 {
  1979. isShowAppointment = true
  1980. }
  1981. if activityTypeId == 5 && chartPermissionName == "医药" {
  1982. isShowAppointment = true
  1983. }
  1984. if activityTypeId == 2 && item.IsLimitPeople == 0 {
  1985. isShowAppointment = true
  1986. }
  1987. return
  1988. }
  1989. // 用户报告操作行为,模板消息推送 (先放在活动模块下,避免代码冲突)
  1990. func ArticleUserRemind(user *models.WxUserItem, articleDetail *models.ArticleDetail, source int) (err error) {
  1991. defer func() {
  1992. if err != nil {
  1993. go utils.SendAlarmMsg(" 用户报告操作行为,模板消息推送失败"+fmt.Sprint("UserId:", user.UserId, "ArticleId:", articleDetail.ArticleId), 2)
  1994. }
  1995. }()
  1996. countUser, err := models.GetUserRemind(user.UserId)
  1997. if err != nil {
  1998. return err
  1999. }
  2000. if countUser == 0 {
  2001. return err
  2002. }
  2003. var sourceMsg string
  2004. if source == 1 {
  2005. sourceMsg = "阅读报告"
  2006. } else {
  2007. sourceMsg = "收藏报告"
  2008. }
  2009. //获取销售手机号
  2010. sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  2011. if err != nil && err.Error() != utils.ErrNoRow() {
  2012. return err
  2013. }
  2014. if sellerItemQy != nil {
  2015. openIdList, err := models.GetUserRecordListByMobile(4, sellerItemQy.Mobile)
  2016. if err != nil {
  2017. fmt.Println(err)
  2018. return err
  2019. }
  2020. var keyword1 string
  2021. var keyword2 string
  2022. keyword1 = articleDetail.Title
  2023. keyword2 = fmt.Sprint("互动:", sourceMsg, ",", user.RealName, "--", user.CompanyName)
  2024. SendWxMsgWithArticleUserRemind(keyword1, keyword2, openIdList, articleDetail.ArticleId)
  2025. }
  2026. return
  2027. }
  2028. // 用户活动操作行为,模板消息推送
  2029. func ActivityUserRemind(user *models.WxUserItem, activityDetail *models.ActivityDetail, source int) (err error) {
  2030. defer func() {
  2031. if err != nil {
  2032. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "ActivityUserRemind ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  2033. }
  2034. }()
  2035. //获取销售手机号
  2036. countUser, e := models.GetUserRemind(user.UserId)
  2037. if e != nil {
  2038. err = errors.New("GetUserRemind, Err: " + e.Error())
  2039. return
  2040. }
  2041. // 如果是买方研选下的专家沙龙,同时推给内容组四人
  2042. if activityDetail.ActivityTypeId == 5 && activityDetail.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  2043. go SendNeiRongZuActivitieSignTemplateMsg(user, activityDetail)
  2044. go SendNeiRongZuActivitieSignCategoryTemplateMsg(user, activityDetail)
  2045. }
  2046. //获取销售手机号
  2047. sellerItemQy, e := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  2048. if e != nil && e.Error() != utils.ErrNoRow() {
  2049. err = errors.New("GetSellerByCompanyIdCheckFicc, Err: " + e.Error())
  2050. return
  2051. }
  2052. if sellerItemQy == nil {
  2053. err = nil
  2054. return
  2055. }
  2056. //某销售下的所有客户活动报名/预约外呼时,模板消息提醒该销售(可设置销售范围,随时增减销售)
  2057. conf, e := models.GetConfigByCode("tpl_msg_seller_mobile")
  2058. if e != nil {
  2059. err = errors.New("GetConfigByCode, Err: " + e.Error())
  2060. return
  2061. }
  2062. //如果用户没有设置消息提醒,而且销售的手机号也没有添加到配置中,那么就不推送模版消息
  2063. if countUser == 0 && !strings.Contains(conf.ConfigValue, sellerItemQy.Mobile) {
  2064. err = nil
  2065. return
  2066. }
  2067. var sourceMsg string
  2068. if source == 1 {
  2069. sourceMsg = "预约外呼"
  2070. } else if source == 2 {
  2071. sourceMsg = "设置会议提醒"
  2072. } else if source == 3 {
  2073. sourceMsg = "预约纪要"
  2074. } else if source == 4 {
  2075. sourceMsg = "活动报名"
  2076. }
  2077. openIdList, e := models.GetUserRecordListByMobile(4, sellerItemQy.Mobile)
  2078. if e != nil {
  2079. err = errors.New("GetUserRecordListByMobile, Err: " + e.Error())
  2080. return err
  2081. }
  2082. var keyword1 string
  2083. var keyword2 string
  2084. keyword1 = activityDetail.ActivityName
  2085. keyword2 = fmt.Sprint("互动:", sourceMsg, ",", user.RealName, "--", user.CompanyName)
  2086. SendWxMsgWithActivityUserRemind(keyword1, keyword2, openIdList, activityDetail.ActivityId)
  2087. return
  2088. }
  2089. // 用户专项调研操作行为,模板消息推送
  2090. func SpecialActivityUserRemind(user *models.WxUserItem, activityDetail *models.CygxActivitySpecialDetail, source int) (err error) {
  2091. defer func() {
  2092. if err != nil {
  2093. go utils.SendAlarmMsg("同步策略平台阅读数据失败", 2)
  2094. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetCeLueArticlePv ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  2095. }
  2096. }()
  2097. countUser, err := models.GetUserRemind(user.UserId)
  2098. if err != nil {
  2099. return err
  2100. }
  2101. if countUser == 0 {
  2102. return err
  2103. }
  2104. var sourceMsg string
  2105. if source == 1 {
  2106. sourceMsg = "预报名调研"
  2107. }
  2108. //获取销售手机号
  2109. sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  2110. if err != nil && err.Error() != utils.ErrNoRow() {
  2111. return err
  2112. }
  2113. if sellerItemQy != nil {
  2114. openIdList, err := models.GetUserRecordListByMobile(4, sellerItemQy.Mobile)
  2115. if err != nil {
  2116. fmt.Println(err)
  2117. return err
  2118. }
  2119. var keyword1 string
  2120. var keyword2 string
  2121. keyword1 = fmt.Sprint(user.RealName, "--", user.CompanyName, ",有新的互动:", sourceMsg)
  2122. keyword2 = activityDetail.ResearchTheme
  2123. SendWxMsgWithSpecialActivityUserRemind(keyword1, keyword2, openIdList, activityDetail.ActivityId)
  2124. }
  2125. return
  2126. }
  2127. //func init() {
  2128. // DoActivityOnenIdWxTemplateMsg()
  2129. //}
  2130. // 周日下午四点半推送全部活动
  2131. func DoActivityOnenIdWxTemplateMsg(cont context.Context) (err error) {
  2132. var msg string
  2133. defer func() {
  2134. if err != nil {
  2135. go utils.SendAlarmMsg("周日下午四点半推送全部活动失败,DoActivityOnenIdWxTemplateMsg ErrMsg:"+err.Error(), 2)
  2136. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "DoActivityOnenIdWxTemplateMsg ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  2137. fmt.Println(err)
  2138. }
  2139. if msg != "" {
  2140. utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
  2141. }
  2142. }()
  2143. var condition string
  2144. var pars []interface{}
  2145. openidPowerListMobile, err := models.GetCygxUserRecordPower(condition, pars)
  2146. if err != nil {
  2147. return err
  2148. }
  2149. var mobileArr []string
  2150. for _, v := range openidPowerListMobile {
  2151. mobileArr = append(mobileArr, v.Mobile)
  2152. }
  2153. openidPowerList, err := models.GetWxOpenIdByMobileSliceList(mobileArr)
  2154. if err != nil {
  2155. return err
  2156. }
  2157. first := "近期所有行业活动预告,欢迎参与"
  2158. keyword1 := "下周活动预告"
  2159. keyword2 := "已发布"
  2160. keyword3 := ""
  2161. keyword4 := "点击查看下周活动列表"
  2162. SendActivityOnenIdWxTemplateMsg(first, keyword1, keyword2, keyword3, keyword4, openidPowerList)
  2163. return
  2164. }
  2165. func ActivityButtonShow(item *models.ActivityDetail) (activityDetail *models.ActivityDetail) {
  2166. if item.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  2167. item.IsResearch = true
  2168. }
  2169. activityDetail = item
  2170. //IsShowAppointment bool `description:"是否展示预约纪要"`
  2171. //IsShowOutboundCall bool `description:"是否展示预约外呼"`
  2172. //IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  2173. //IsShowHelpSsk bool `description:"是否展示帮我带问"`
  2174. //IsShowSignup bool `description:"是否展示我要报名"`
  2175. activityTypeIdMap := GetActivityTypeIdMap()
  2176. activityDetail.ActivityType = activityTypeIdMap[activityDetail.ActivityTypeId] // 线上还是线下
  2177. activityPointsByUserAllMap := GetActivityPointsByUserAllMap() // 获取对用户进行研选扣点的活动
  2178. activityDetail.IsResearchPoints = activityPointsByUserAllMap[activityDetail.ActivityId]
  2179. if activityDetail.SiginupDeadline == utils.FormatDateTimeInit { //报名截止时间处理
  2180. activityDetail.SiginupDeadline = ""
  2181. }
  2182. //如果报名截止时间不规范,或者是非研选扣点活动就把截止时间设置为空
  2183. if activityDetail.CancelDeadline == utils.FormatDateTimeInit || !activityDetail.IsResearchPoints {
  2184. activityDetail.CancelDeadline = ""
  2185. }
  2186. activityTimeText := activityDetail.ActivityTimeText
  2187. activityTimeText = strings.Replace(activityTimeText, "(", "(", -1)
  2188. activityTimeText = strings.Replace(activityTimeText, ")", ")", -1)
  2189. activityDetail.ActivityTimeText = activityTimeText
  2190. if activityDetail.SourceType != 2 {
  2191. activityDetail.SourceType = 1
  2192. }
  2193. activityDetail.IsShowAppointment = false
  2194. //易董的操作按钮都隐藏
  2195. if activityDetail.YidongActivityId != "" {
  2196. activityDetail.SourceType = 1
  2197. activityDetail.IsShowSignup = false
  2198. activityDetail.IsShowDetails = true
  2199. activityDetail.IsExternalLabel = true
  2200. activityDetail.IsResearch = false
  2201. activityDetail.IsResearchSpecial = false
  2202. return
  2203. }
  2204. //专家电话会 1
  2205. if activityDetail.ActivityTypeId == 1 && activityDetail.IsLimitPeople == 0 && (activityDetail.ActiveState == "1" || activityDetail.ActiveState == "2") {
  2206. activityDetail.IsShowHelpSsk = true
  2207. }
  2208. //新的是否展示规则
  2209. if activityDetail.IsCanAppointmentMinutes == 1 {
  2210. activityDetail.IsShowAppointment = true
  2211. } else {
  2212. activityDetail.IsShowAppointment = false
  2213. }
  2214. if activityDetail.ActiveState == "1" {
  2215. //专家电话会 1
  2216. //专家电话会限制人数的展示我要报名,不限制的展示预约外外呼
  2217. if activityDetail.ActivityTypeId == 1 {
  2218. //articleDetail.IsShowOutboundCall = true
  2219. if activityDetail.LimitPeopleNum == 0 {
  2220. activityDetail.IsShowOutboundCall = true
  2221. //articleDetail.IsShowHelpSsk = true
  2222. } else {
  2223. activityDetail.IsShowSignup = true
  2224. }
  2225. activityDetail.IsShowMeetingReminder = true
  2226. activityDetail.IsShowHelpSsk = true
  2227. }
  2228. //分析师电话会 2
  2229. if activityDetail.ActivityTypeId == 2 {
  2230. if activityDetail.LimitPeopleNum == 0 {
  2231. activityDetail.IsShowOutboundCall = true
  2232. //articleDetail.IsShowHelpSsk = true
  2233. } else {
  2234. activityDetail.IsShowSignup = true
  2235. }
  2236. activityDetail.IsShowMeetingReminder = true
  2237. }
  2238. //公司调研电话会 3
  2239. if activityDetail.ActivityTypeId == 3 {
  2240. if activityDetail.IsResearchPoints || activityDetail.LimitPeopleNum > 0 {
  2241. activityDetail.IsShowSignup = true
  2242. } else {
  2243. activityDetail.IsShowMeetingReminder = true
  2244. activityDetail.IsShowOutboundCall = true
  2245. }
  2246. }
  2247. //公司线下调研 4
  2248. if activityDetail.ActivityTypeId == 4 {
  2249. activityDetail.IsShowSignup = true
  2250. }
  2251. //专家线下沙龙 5
  2252. if activityDetail.ActivityTypeId == 5 {
  2253. activityDetail.IsShowSignup = true
  2254. }
  2255. //分析师线下沙龙 6
  2256. if activityDetail.ActivityTypeId == 6 {
  2257. activityDetail.IsShowSignup = true
  2258. }
  2259. //分析师电话会(C类) 7
  2260. if activityDetail.ActivityTypeId == 7 {
  2261. activityDetail.IsShowSignup = true
  2262. activityDetail.IsShowMeetingReminder = true
  2263. activityDetail.ActivityTypeName = "分析师电话会"
  2264. }
  2265. //买方线下交流 8 // 查研观向 11.0
  2266. if activityDetail.ActivityTypeId == 8 {
  2267. activityDetail.IsShowSignup = true
  2268. }
  2269. }
  2270. //如果是易董创建的活动,展示我要报名,不展示预约外呼
  2271. if activityDetail.IsYidongConduct {
  2272. activityDetail.IsShowSignup = true
  2273. activityDetail.IsShowOutboundCall = false
  2274. }
  2275. return
  2276. }
  2277. func ActivityArrButtonShow(items []*models.ActivityDetail) (activityDetails []*models.ActivityDetail) {
  2278. activityPointsByUserAllMap := GetActivityPointsByUserAllMap() // 获取对用户进行研选扣点的活动
  2279. activityTypeIdMap := GetActivityTypeIdMap()
  2280. for _, activityDetail := range items {
  2281. activityDetail.ActivityType = activityTypeIdMap[activityDetail.ActivityTypeId] // 线上还是线下
  2282. if activityDetail.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  2283. activityDetail.IsResearch = true
  2284. }
  2285. //勾选【研选扣点】且扣点对象为参会人的活动,需要有买方研选的正式权限
  2286. if strings.Contains(activityDetail.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) && activityPointsByUserAllMap[activityDetail.ActivityId] {
  2287. activityDetail.IsResearchSpecial = true
  2288. }
  2289. //IsShowAppointment bool `description:"是否展示预约纪要"`
  2290. //IsShowOutboundCall bool `description:"是否展示预约外呼"`
  2291. //IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  2292. //IsShowHelpSsk bool `description:"是否展示帮我带问"`
  2293. //IsShowSignup bool `description:"是否展示我要报名"`
  2294. activityDetail.IsResearchPoints = activityPointsByUserAllMap[activityDetail.ActivityId]
  2295. if activityDetail.SiginupDeadline == utils.FormatDateTimeInit { //报名截止时间处理
  2296. activityDetail.SiginupDeadline = ""
  2297. }
  2298. //如果报名截止时间不规范,或者是非研选扣点活动就把截止时间设置为空
  2299. if activityDetail.CancelDeadline == utils.FormatDateTimeInit || !activityDetail.IsResearchPoints {
  2300. activityDetail.CancelDeadline = ""
  2301. }
  2302. activityTimeText := activityDetail.ActivityTimeText
  2303. activityTimeText = strings.Replace(activityTimeText, "(", "(", -1)
  2304. activityTimeText = strings.Replace(activityTimeText, ")", ")", -1)
  2305. activityDetail.ActivityTimeText = activityTimeText
  2306. if activityDetail.SourceType != 2 {
  2307. activityDetail.SourceType = 1
  2308. }
  2309. activityDetail.IsShowAppointment = false
  2310. //易董的操作按钮都隐藏
  2311. if activityDetail.YidongActivityId != "" {
  2312. activityDetail.SourceType = 1
  2313. activityDetail.IsShowSignup = false
  2314. activityDetail.IsShowDetails = true
  2315. } else {
  2316. //专家电话会 1
  2317. if activityDetail.ActivityTypeId == 1 && activityDetail.IsLimitPeople == 0 && (activityDetail.ActiveState == "1" || activityDetail.ActiveState == "2") {
  2318. activityDetail.IsShowHelpSsk = true
  2319. }
  2320. //新的是否展示规则
  2321. if activityDetail.IsCanAppointmentMinutes == 1 {
  2322. activityDetail.IsShowAppointment = true
  2323. } else {
  2324. activityDetail.IsShowAppointment = false
  2325. }
  2326. if activityDetail.ActiveState == "1" {
  2327. //专家电话会 1
  2328. //专家电话会限制人数的展示我要报名,不限制的展示预约外外呼
  2329. if activityDetail.ActivityTypeId == 1 {
  2330. //articleDetail.IsShowOutboundCall = true
  2331. if activityDetail.LimitPeopleNum == 0 {
  2332. activityDetail.IsShowOutboundCall = true
  2333. //articleDetail.IsShowHelpSsk = true
  2334. } else {
  2335. activityDetail.IsShowSignup = true
  2336. }
  2337. activityDetail.IsShowMeetingReminder = true
  2338. activityDetail.IsShowHelpSsk = true
  2339. }
  2340. //分析师电话会 2
  2341. if activityDetail.ActivityTypeId == 2 {
  2342. if activityDetail.LimitPeopleNum == 0 {
  2343. activityDetail.IsShowOutboundCall = true
  2344. //articleDetail.IsShowHelpSsk = true
  2345. } else {
  2346. activityDetail.IsShowSignup = true
  2347. }
  2348. activityDetail.IsShowMeetingReminder = true
  2349. }
  2350. //公司调研电话会 3
  2351. if activityDetail.ActivityTypeId == 3 {
  2352. if activityDetail.IsResearchPoints || activityDetail.LimitPeopleNum > 0 {
  2353. activityDetail.IsShowSignup = true
  2354. } else {
  2355. activityDetail.IsShowMeetingReminder = true
  2356. activityDetail.IsShowOutboundCall = true
  2357. }
  2358. }
  2359. //公司线下调研 4
  2360. if activityDetail.ActivityTypeId == 4 {
  2361. activityDetail.IsShowSignup = true
  2362. }
  2363. //专家线下沙龙 5
  2364. if activityDetail.ActivityTypeId == 5 {
  2365. activityDetail.IsShowSignup = true
  2366. }
  2367. //分析师线下沙龙 6
  2368. if activityDetail.ActivityTypeId == 6 {
  2369. activityDetail.IsShowSignup = true
  2370. }
  2371. //分析师电话会(C类) 7
  2372. if activityDetail.ActivityTypeId == 7 {
  2373. activityDetail.IsShowSignup = true
  2374. activityDetail.IsShowMeetingReminder = true
  2375. activityDetail.ActivityTypeName = "分析师电话会"
  2376. }
  2377. //买方线下交流 8 // 查研观向 11.0
  2378. if activityDetail.ActivityTypeId == 8 {
  2379. activityDetail.IsShowSignup = true
  2380. }
  2381. }
  2382. //如果是易董创建的活动,展示我要报名,不展示预约外呼
  2383. if activityDetail.IsYidongConduct {
  2384. activityDetail.IsShowSignup = true
  2385. activityDetail.IsShowOutboundCall = false
  2386. }
  2387. }
  2388. //如果是易董同步过来的,只展示外部资源标签
  2389. if activityDetail.YidongActivityId != "" {
  2390. activityDetail.IsExternalLabel = true
  2391. activityDetail.IsResearch = false
  2392. activityDetail.IsResearchSpecial = false
  2393. }
  2394. activityDetails = append(activityDetails, activityDetail)
  2395. }
  2396. return
  2397. }
  2398. // GetActivityNewLabelMap 获取活动【新】标签Map
  2399. func GetActivityNewLabelMap(activityIds []int) (labelMap map[int]bool, industryNewMap map[int]bool, err error) {
  2400. labelMap = make(map[int]bool, 0)
  2401. industryNewMap = make(map[int]bool, 0)
  2402. if len(activityIds) == 0 {
  2403. return
  2404. }
  2405. // 获取活动关联的产业
  2406. var groupCond string
  2407. var groupPars []interface{}
  2408. groupCond += ` AND a.activity_id IN (` + utils.GetOrmInReplace(len(activityIds)) + `) AND b.source = 1 `
  2409. groupPars = append(groupPars, activityIds)
  2410. groups, e := models.GetActivityIndustryRelationList(groupCond, groupPars)
  2411. if e != nil {
  2412. err = errors.New("获取活动产业关联列表失败, Err: " + e.Error())
  2413. return
  2414. }
  2415. activityIndustryMap := make(map[int][]int, 0)
  2416. industryIds := make([]int, 0)
  2417. for i := range groups {
  2418. industryIds = append(industryIds, groups[i].IndustrialManagementId)
  2419. activityIndustryMap[groups[i].ActivityId] = append(activityIndustryMap[groups[i].ActivityId], groups[i].IndustrialManagementId)
  2420. }
  2421. // 获取新产业Map
  2422. industryLabelMap, e := GetIndustryNewLabelMap(industryIds)
  2423. if e != nil {
  2424. err = errors.New("获取产业新标签Map失败, Err: " + e.Error())
  2425. return
  2426. }
  2427. // 判断活动是否为新
  2428. for k := range industryLabelMap {
  2429. for k2, v2 := range activityIndustryMap {
  2430. if labelMap[k2] {
  2431. continue
  2432. }
  2433. // 活动的产业ID中存在一个新产业即为新活动
  2434. if utils.InArrayByInt(v2, k) {
  2435. labelMap[k2] = true
  2436. }
  2437. }
  2438. }
  2439. ////产业关联的弘则报告发布日期在三个月以内的活动、产业显示 NEW标签
  2440. //articNewLabel, e := GetArticNewLabelWhithActivity3Month()
  2441. //if e != nil {
  2442. // err = errors.New("获取产业新标签Map失败, Err: " + e.Error())
  2443. // return
  2444. //}
  2445. //for k := range articNewLabel {
  2446. // labelMap[k] = true
  2447. //}
  2448. return
  2449. }
  2450. // GetActivityVoiceResp 处理活动音频回放
  2451. func GetActivityVoiceResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVoiceReq, err error) {
  2452. activityVoiceList, err := models.GetCygxActivityVoiceReqList(mapActivityId)
  2453. if err != nil && err.Error() != utils.ErrNoRow() {
  2454. return
  2455. }
  2456. mapActivityVoice := make(map[int]*models.CygxActivityVoiceReq)
  2457. if len(activityVoiceList) > 0 {
  2458. for _, v := range activityVoiceList {
  2459. mapActivityVoice[v.ActivityId] = v
  2460. }
  2461. }
  2462. mapItem = mapActivityVoice
  2463. return
  2464. }
  2465. // AddActivitykeyWordSearch 添加活动搜索记录
  2466. func AddActivitykeyWordSearch(keyWordSearch string, user *models.WxUserItem) {
  2467. if keyWordSearch != "" {
  2468. keyWordItem := new(models.CygxUserSearchKeyWord)
  2469. keyWordItem.UserId = user.UserId
  2470. keyWordItem.KeyWord = keyWordSearch
  2471. keyWordItem.PageType = "ActivitSearch"
  2472. keyWordItem.CreateTime = time.Now()
  2473. go models.AddUserSearchKeyWord(keyWordItem)
  2474. }
  2475. }
  2476. // GetActivityVideoResp 处理活动视频频回放
  2477. func GetActivityVideoResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVideoListResp, err error) {
  2478. var condition string
  2479. var ativityVIdstr string
  2480. for _, v := range mapActivityId {
  2481. ativityVIdstr += strconv.Itoa(v) + ","
  2482. }
  2483. if ativityVIdstr == "" {
  2484. return
  2485. }
  2486. ativityVIdstr = strings.TrimRight(ativityVIdstr, ",")
  2487. condition += ` AND art.activity_id IN (` + ativityVIdstr + `) `
  2488. var pars []interface{}
  2489. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  2490. //condition += ` AND art.activity_time > ? `
  2491. //pars = append(pars, endTime)
  2492. videoList, e := models.GetActivityVideoListAll(condition, pars, 0, 1000)
  2493. if e != nil && e.Error() != utils.ErrNoRow() {
  2494. err = e
  2495. return
  2496. }
  2497. mapActivityVideo := make(map[int]*models.CygxActivityVideoListResp)
  2498. if len(videoList) > 0 {
  2499. for _, v := range videoList {
  2500. mapActivityVideo[v.ActivityId] = v
  2501. }
  2502. }
  2503. mapItem = mapActivityVideo
  2504. return
  2505. }
  2506. // 用户音视频回放操作操作行为,模板消息推送
  2507. func ActivityVideoUserRmind(user *models.WxUserItem, activityId, fileType int) (err error) {
  2508. defer func() {
  2509. if err != nil {
  2510. go utils.SendAlarmMsg("用户音视频回放操作操作行为,模板消息推送失败"+err.Error(), 2)
  2511. }
  2512. }()
  2513. countUser, err := models.GetUserRemind(user.UserId)
  2514. if err != nil {
  2515. return err
  2516. }
  2517. if countUser == 0 {
  2518. return err
  2519. }
  2520. var first string
  2521. var keyword1 string
  2522. var keyword2 string
  2523. var keyword3 string
  2524. var keyword4 string
  2525. var remark string
  2526. //获取销售手机号
  2527. sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  2528. if err != nil && err.Error() != utils.ErrNoRow() {
  2529. return err
  2530. }
  2531. if sellerItemQy != nil {
  2532. openIdList, e := models.GetWxOpenIdByMobileList(sellerItemQy.Mobile)
  2533. if e != nil {
  2534. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  2535. return
  2536. }
  2537. //TripStatus int `description:"行程进行状态 1:预报名,2:确定行程"`
  2538. if fileType == 1 {
  2539. activityInfo, e := models.GetCygxActivityVideoByActivityId(activityId)
  2540. if e != nil {
  2541. err = errors.New("GetCygxActivitySpecialDetailById, Err: " + e.Error())
  2542. return
  2543. }
  2544. if activityInfo == nil {
  2545. return
  2546. }
  2547. keyword1 = activityInfo.VideoName
  2548. keyword2 = fmt.Sprint("互动:播放视频,", user.RealName, "--", user.CompanyName)
  2549. first = fmt.Sprint(user.RealName, "--", user.CompanyName, ",有新的互动:播放视频")
  2550. } else {
  2551. activityInfo, e := models.GetCygxActivityVoiceByActivityId(activityId)
  2552. if e != nil {
  2553. err = errors.New("GetCygxActivitySpecialDetailById, Err: " + e.Error())
  2554. return
  2555. }
  2556. if activityInfo == nil {
  2557. return
  2558. }
  2559. keyword1 = activityInfo.VoiceName
  2560. keyword2 = fmt.Sprint("互动:播放音频,", user.RealName, "--", user.CompanyName)
  2561. first = fmt.Sprint(user.RealName, "--", user.CompanyName, ",有新的互动:播放音频")
  2562. }
  2563. //keyword2 = "__"
  2564. //remark = "点击查看活动详情"
  2565. openIdArr := make([]string, 0)
  2566. for _, v := range openIdList {
  2567. openIdArr = append(openIdArr, v.OpenId)
  2568. }
  2569. redirectUrl := utils.WX_MSG_PATH_ACTIVITY_SPECIAL_DETAIL + strconv.Itoa(activityId)
  2570. sendInfo := new(SendWxTemplate)
  2571. sendInfo.First = first
  2572. sendInfo.Keyword1 = keyword1
  2573. sendInfo.Keyword2 = keyword2
  2574. sendInfo.Keyword3 = keyword3
  2575. sendInfo.Keyword4 = keyword4
  2576. sendInfo.Remark = remark
  2577. sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
  2578. sendInfo.RedirectUrl = redirectUrl
  2579. sendInfo.RedirectTarget = 3
  2580. sendInfo.Resource = strconv.Itoa(activityId)
  2581. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  2582. sendInfo.OpenIdArr = openIdArr
  2583. err = PublicSendTemplateMsg(sendInfo)
  2584. if err != nil {
  2585. return
  2586. }
  2587. }
  2588. return
  2589. }
  2590. // 解析活动填写的报告链接
  2591. func GetActivityReportLinkToArticleList(item *models.ActivityDetail) (items []*models.ActivityArticleResp, err error) {
  2592. reportLink := item.ReportLink
  2593. //处理活动的
  2594. var articleIds []int
  2595. var articleList []string
  2596. if strings.Contains(reportLink, ";") {
  2597. articleList = strings.Split(reportLink, ";")
  2598. } else {
  2599. articleList = strings.Split(reportLink, ";")
  2600. }
  2601. for _, v := range articleList {
  2602. linkList := strings.Split(v, "/")
  2603. if linkList[len(linkList)-1] != "" {
  2604. linkArticleId, _ := strconv.Atoi(linkList[len(linkList)-1])
  2605. articleIds = append(articleIds, linkArticleId)
  2606. }
  2607. }
  2608. lenarticleIds := len(articleIds)
  2609. if lenarticleIds == 0 {
  2610. return
  2611. }
  2612. var condition string
  2613. var pars []interface{}
  2614. pars = make([]interface{}, 0)
  2615. condition = ` AND a.article_id IN (` + utils.GetOrmInReplace(lenarticleIds) + `)`
  2616. pars = append(pars, articleIds)
  2617. listArticle, e := models.GetHomeList(condition, pars, 0, len(articleIds))
  2618. if e != nil {
  2619. err = errors.New("GetResourceDataList, Err: " + e.Error())
  2620. return
  2621. }
  2622. if len(listArticle) > 0 {
  2623. for _, v := range listArticle {
  2624. artItem := new(models.ActivityArticleResp)
  2625. artItem.ArticleId = v.ArticleId
  2626. artItem.Title = v.Title
  2627. items = append(items, artItem)
  2628. }
  2629. }
  2630. return
  2631. }
  2632. // GetActivityCityResp 获取活动关联城市,当同一个活动标签对应多个城市的时候,展示最近举办的活动
  2633. func GetActivityCityResp() (mapItem map[string]string, err error) {
  2634. activityList, err := models.GetActivityLabelListCity()
  2635. if err != nil && err.Error() != utils.ErrNoRow() {
  2636. return
  2637. }
  2638. mapActivityCity := make(map[string]string)
  2639. if len(activityList) > 0 {
  2640. for _, v := range activityList {
  2641. if v.ActivityTypeId == utils.C_CLASS_ACTIVITY_TYPE_ID {
  2642. v.ActivityTypeId = utils.ANALYST_TELL_ACTIVITY_TYPE_ID
  2643. }
  2644. //如果城市民称长度大于2,那么就不显示
  2645. if utf8.RuneCountInString(v.City) != 2 || mapActivityCity[fmt.Sprint(v.Label, "{|}", v.ActivityTypeId)] != "" {
  2646. continue
  2647. }
  2648. mapActivityCity[fmt.Sprint(v.Label, "{|}", v.ActivityTypeId)] = v.City
  2649. }
  2650. }
  2651. mapItem = mapActivityCity
  2652. return
  2653. }
  2654. // UpdateIsSendYidongSignUp更改活动是否向易董推送报名名单的状态
  2655. func UpdateIsSendYidongSignUp(activityId int) (err error) {
  2656. defer func() {
  2657. if err != nil {
  2658. fmt.Println(err)
  2659. go utils.SendAlarmMsg("更改活动是否向易董推送报名名单的状态,失败,活动ID:"+strconv.Itoa(activityId)+err.Error(), 2)
  2660. }
  2661. }()
  2662. err = models.UPdateSendedYiDongSignUp(activityId)
  2663. return
  2664. }
  2665. // 获取活动线上还是线下的类型
  2666. func GetActivityTypeIdMap() (mapResp map[int]int) {
  2667. var err error
  2668. defer func() {
  2669. if err != nil {
  2670. fmt.Println(err)
  2671. go utils.SendAlarmMsg("获取活动线上还是线下的类型,失败,GetActivityTypeIdMap:Err "+err.Error(), 2)
  2672. }
  2673. }()
  2674. list, e := models.GetActivityTypeList("")
  2675. if e != nil {
  2676. err = errors.New("GetActivityTypeList, Err: " + e.Error())
  2677. return
  2678. }
  2679. mapResp = make(map[int]int, 0)
  2680. for _, v := range list {
  2681. mapResp[v.ActivityTypeId] = v.ActivityType
  2682. }
  2683. return
  2684. }