calendar.go 81 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641
  1. package roadshow
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hz_crm_api/controllers"
  7. "hongze/hz_crm_api/models"
  8. "hongze/hz_crm_api/models/cygx"
  9. "hongze/hz_crm_api/models/roadshow"
  10. "hongze/hz_crm_api/models/system"
  11. "hongze/hz_crm_api/services"
  12. roadshowService "hongze/hz_crm_api/services/roadshow"
  13. "hongze/hz_crm_api/utils"
  14. "strconv"
  15. "strings"
  16. "time"
  17. )
  18. // 日历
  19. type CalendarController struct {
  20. controllers.BaseAuthController
  21. }
  22. // @Title 新增路演活动接口
  23. // @Description 新增路演活动接口
  24. // @Param request body roadshow.AddActivityReq true "type json string"
  25. // @Success Ret=200 保存成功
  26. // @router /add [post]
  27. func (this *CalendarController) Add() {
  28. br := new(models.BaseResponse).Init()
  29. defer func() {
  30. this.Data["json"] = br
  31. this.ServeJSON()
  32. }()
  33. sysUser := this.SysUser
  34. if sysUser == nil {
  35. br.Msg = "请登录"
  36. br.ErrMsg = "请登录,SysUser Is Empty"
  37. br.Ret = 408
  38. return
  39. }
  40. deleteCache := true
  41. cacheKey := "CACHE_RS_ACTIVITY_ADD_" + strconv.Itoa(sysUser.AdminId)
  42. defer func() {
  43. if deleteCache {
  44. utils.Rc.Delete(cacheKey)
  45. }
  46. }()
  47. if !utils.Rc.SetNX(cacheKey, 1, 5*time.Second) {
  48. deleteCache = false
  49. br.Msg = "系统处理中,请稍后重试!"
  50. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
  51. return
  52. }
  53. var req roadshow.AddActivityReq
  54. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  55. if err != nil {
  56. br.Msg = "参数解析异常!"
  57. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  58. return
  59. }
  60. if len(req.ResearcherList) <= 0 {
  61. br.Msg = "请选择研究员!"
  62. return
  63. }
  64. researcherMap := make(map[int]string)
  65. var checkIsAdd []string
  66. //var tipMsg string
  67. for _, v := range req.ResearcherList {
  68. if v.ResearcherId <= 0 {
  69. br.Msg = "请选择研究员!"
  70. return
  71. }
  72. if v.ResearcherName == "" {
  73. br.Msg = "请选择研究员!"
  74. return
  75. }
  76. if v.StartDate == "" {
  77. br.Msg = "请选择开始日期!"
  78. return
  79. }
  80. if v.EndDate == "" {
  81. br.Msg = "请选择结束日期!"
  82. return
  83. }
  84. if v.StartTime == "" {
  85. br.Msg = "请选择开始时间!"
  86. return
  87. }
  88. if v.EndTime == "" {
  89. br.Msg = "请选择结束时间!"
  90. return
  91. }
  92. if v.StartWeek == "" {
  93. br.Msg = "请选择周!"
  94. return
  95. }
  96. if v.EndWeek == "" {
  97. br.Msg = "请选择周!"
  98. return
  99. }
  100. startDateTime := v.StartDate + " " + v.StartTime
  101. endDateTime := v.EndDate + " " + v.EndTime
  102. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  103. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  104. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  105. br.Msg = "活动开始时间不能小于当前时间!"
  106. return
  107. }
  108. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  109. br.Msg = "活动结束时间不能小于当前时间!"
  110. return
  111. }
  112. if startP.After(endP) || startP.Equal(endP) {
  113. br.Msg = "活动开始时间应小于结束时间!"
  114. return
  115. }
  116. if realName, ok := researcherMap[v.ResearcherId]; ok {
  117. br.Msg = "研究员:" + realName + " 被重复选择"
  118. return
  119. }
  120. researcherMap[v.ResearcherId] = v.ResearcherName
  121. //同步上海数据
  122. researcherInfo, err := system.GetSysAdminById(v.ResearcherId)
  123. if err != nil {
  124. br.Msg = "研究员异常"
  125. return
  126. }
  127. _ = roadshowService.SyncCalendarFromShanghai(researcherInfo.Mobile, v.StartDate, v.EndDate)
  128. //校验事项时间冲突
  129. {
  130. matterCount, err := roadshowService.CheckMatters(startDateTime, endDateTime, v.ResearcherId, 0)
  131. if err != nil {
  132. br.Msg = "时间冲突检测失败!"
  133. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!Err:" + err.Error()
  134. return
  135. }
  136. if matterCount > 0 {
  137. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  138. }
  139. }
  140. //校验活动时间冲突
  141. {
  142. calendarCount, err := roadshowService.CheckCalendar(startDateTime, endDateTime, "1,2", v.ResearcherId, 0)
  143. if err != nil {
  144. br.Msg = "时间冲突检测失败!"
  145. br.ErrMsg = "时间冲突检测失败-CheckCalendar!Err:" + err.Error()
  146. return
  147. }
  148. if calendarCount > 0 {
  149. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  150. }
  151. }
  152. }
  153. if len(checkIsAdd) > 0 {
  154. br.Msg = strings.Join(checkIsAdd, ",") + " 时间已被占用!"
  155. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!"
  156. br.IsSendEmail = false
  157. return
  158. }
  159. rsCalendar := new(roadshow.RsCalendar)
  160. rsCalendar.SysUserId = sysUser.AdminId
  161. rsCalendar.SysUserRealName = sysUser.RealName
  162. rsCalendar.ActivityType = req.ActivityType
  163. rsCalendar.RoadshowType = req.RoadshowType
  164. rsCalendar.RoadshowPlatform = req.RoadshowPlatform
  165. rsCalendar.CompanyId = req.CompanyId
  166. rsCalendar.CompanyName = req.CompanyName
  167. rsCalendar.Province = req.Province
  168. rsCalendar.ProvinceCode = req.ProvinceCode
  169. rsCalendar.City = req.City
  170. rsCalendar.CityCode = req.CityCode
  171. rsCalendar.District = req.District
  172. rsCalendar.Theme = req.Theme
  173. rsCalendar.CooperationName = req.CooperationName
  174. rsCalendar.CreateTime = time.Now()
  175. rsCalendar.ModifyTime = time.Now()
  176. rsCalendar.ActivityCategory = req.ActivityCategory
  177. rsCalendar.Source = 0
  178. rsCalendar.EnglishCompany = req.EnglishCompany
  179. rsCalendar.Title = getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City)
  180. rsCalendarId, err := roadshow.AddRsCalendar(rsCalendar)
  181. if err != nil {
  182. br.Msg = "保存失败!"
  183. br.ErrMsg = "保存日历活动信息失败!Err:" + err.Error()
  184. return
  185. }
  186. //if researcherId != 99 {
  187. for k, v := range req.ResearcherList {
  188. researcher := new(roadshow.RsCalendarResearcher)
  189. researcher.RsCalendarId = int(rsCalendarId)
  190. researcher.ResearcherId = v.ResearcherId
  191. researcher.ResearcherName = v.ResearcherName
  192. researcher.StartDate = v.StartDate
  193. researcher.EndDate = v.EndDate
  194. researcher.StartTime = v.StartTime
  195. researcher.EndTime = v.EndTime
  196. researcher.StartWeek = v.StartWeek
  197. researcher.EndWeek = v.EndWeek
  198. researcher.CreateTime = time.Now()
  199. researcher.ModifyTime = time.Now()
  200. researcher.ResearcherSort = k + 1
  201. if req.ActivityType == "路演" || req.ActivityType == "公开会议" {
  202. researcher.Status = 1
  203. } else {
  204. researcher.Status = 2
  205. }
  206. rsCalendarResearcherId, err := roadshow.AddRsCalendarResearcher(researcher)
  207. if err != nil {
  208. br.Msg = "保存失败!"
  209. br.ErrMsg = "保存日历活动-研究员信息失败!Err:" + err.Error()
  210. return
  211. }
  212. rsCalendar.RsCalendarId = int(rsCalendarId)
  213. researcher.RsCalendarResearcherId = int(rsCalendarResearcherId)
  214. go roadshowService.CalendarToSH(*rsCalendar, *researcher)
  215. //模板消息通知
  216. {
  217. go func(researcherId, tmpRsCalendarId, tmpRsCalendarResearcherId int) { // 研究员id,路演id,路演与研究员记录的id
  218. var wxAppPath string
  219. sysAdmin, _ := system.GetSysAdminById(researcherId)
  220. if sysAdmin != nil && sysAdmin.OpenId != "" {
  221. openIdObj := &system.OpenIdList{
  222. OpenId: sysAdmin.OpenId,
  223. AdminId: sysAdmin.AdminId,
  224. }
  225. openIdList := make([]*system.OpenIdList, 0)
  226. openIdList = append(openIdList, openIdObj)
  227. if req.ActivityType == "路演" || req.ActivityType == "公开会议" {
  228. wxAppPath = "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(tmpRsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherId)
  229. first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  230. keyword1 := sysUser.RealName
  231. keyword2 := "--"
  232. startDateSub := v.StartDate[5:]
  233. startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  234. //keyword3 := time.Now().Format(utils.FormatDateTime)
  235. keyword3 := startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5]
  236. var keyword4 string
  237. if req.ActivityType == "路演" {
  238. keyword4 = req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  239. } else {
  240. keyword4 = req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  241. }
  242. remark := "请尽快完成审批"
  243. //wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(int(rsCalendarId)) + "&RsCalendarResearcherId=" + strconv.Itoa(int(rsCalendarResearcherId))
  244. if len(openIdList) > 0 {
  245. services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, openIdList)
  246. }
  247. } else {
  248. wxAppPath = ""
  249. first := sysUser.RealName + "为你添加了一场【" + req.ActivityType + "】"
  250. startDate := researcher.StartDate[5:]
  251. startDate = strings.Replace(startDate, "-", ".", -1)
  252. keyword1 := startDate + "(" + researcher.StartWeek + ")" + " " + researcher.StartTime[:5] + "-" + researcher.EndTime[:5]
  253. keyword2 := sysUser.RealName + "为你添加了【" + req.ActivityType + "】"
  254. if len(openIdList) > 0 {
  255. services.SendWxMsgWithRoadshowDeleteNotice(first, keyword1, keyword2, "", wxAppPath, openIdList)
  256. }
  257. }
  258. }
  259. }(v.ResearcherId, int(rsCalendarId), int(rsCalendarResearcherId))
  260. }
  261. }
  262. //if req.ActivityType == "公开会议" {
  263. // go roadshowService.SetPublicMeetingUnionCode()
  264. //}
  265. br.Ret = 200
  266. br.Success = true
  267. br.Msg = "保存成功"
  268. br.IsAddLog = true
  269. }
  270. // @Title 编辑路演活动接口
  271. // @Description编辑路演活动接口
  272. // @Param request body roadshow.EditActivityReq true "type json string"
  273. // @Success Ret=200 保存成功
  274. // @router /edit [post]
  275. func (this *CalendarController) Edit() {
  276. br := new(models.BaseResponse).Init()
  277. defer func() {
  278. this.Data["json"] = br
  279. this.ServeJSON()
  280. }()
  281. sysUser := this.SysUser
  282. if sysUser == nil {
  283. br.Msg = "请登录"
  284. br.ErrMsg = "请登录,SysUser Is Empty"
  285. br.Ret = 408
  286. return
  287. }
  288. deleteCache := true
  289. cacheKey := "CACHE_RS_ACTIVITY_EDIT_" + strconv.Itoa(sysUser.AdminId)
  290. defer func() {
  291. if deleteCache {
  292. utils.Rc.Delete(cacheKey)
  293. }
  294. }()
  295. if !utils.Rc.SetNX(cacheKey, 1, 5*time.Second) {
  296. deleteCache = false
  297. br.Msg = "系统处理中,请稍后重试!"
  298. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
  299. return
  300. }
  301. var req roadshow.EditActivityReq
  302. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  303. if err != nil {
  304. br.Msg = "参数解析异常!"
  305. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  306. return
  307. }
  308. if req.RsCalendarId <= 0 {
  309. br.Msg = "参数错误!"
  310. br.ErrMsg = "RsCalendarId<=0"
  311. return
  312. }
  313. if req.RsCalendarResearcherId <= 0 {
  314. br.Msg = "参数错误!"
  315. br.ErrMsg = "RsCalendarResearcherId<=0"
  316. return
  317. }
  318. if req.ActivityType == "" {
  319. br.Msg = "请选择活动类型!"
  320. return
  321. }
  322. if len(req.ResearcherList) <= 0 {
  323. br.Msg = "请选择研究员!"
  324. return
  325. }
  326. researcherMap := make(map[int]string)
  327. var checkIsAdd []string
  328. for _, v := range req.ResearcherList {
  329. if v.ResearcherId <= 0 {
  330. br.Msg = "请选择研究员!"
  331. return
  332. }
  333. if v.ResearcherName == "" {
  334. br.Msg = "请选择研究员!"
  335. return
  336. }
  337. if v.StartDate == "" {
  338. br.Msg = "请选择开始日期!"
  339. return
  340. }
  341. if v.EndDate == "" {
  342. br.Msg = "请选择结束日期!"
  343. return
  344. }
  345. if v.StartTime == "" {
  346. br.Msg = "请选择开始时间!"
  347. return
  348. }
  349. if v.EndTime == "" {
  350. br.Msg = "请选择结束时间!"
  351. return
  352. }
  353. if v.StartWeek == "" {
  354. br.Msg = "请选择周!"
  355. return
  356. }
  357. if v.EndWeek == "" {
  358. br.Msg = "请选择周!"
  359. return
  360. }
  361. if realName, ok := researcherMap[v.ResearcherId]; ok {
  362. br.Msg = "研究员:" + realName + " 被重复选择"
  363. return
  364. }
  365. researcherMap[v.ResearcherId] = v.ResearcherName
  366. startDateTime := v.StartDate + " " + v.StartTime
  367. endDateTime := v.EndDate + " " + v.EndTime
  368. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  369. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  370. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  371. br.Msg = "活动开始时间不能小于当前时间!"
  372. return
  373. }
  374. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  375. br.Msg = "活动结束时间不能小于当前时间!"
  376. return
  377. }
  378. if startP.After(endP) || startP.Equal(endP) {
  379. br.Msg = "活动开始时间应小于结束时间!"
  380. return
  381. }
  382. /*
  383. 时间冲突时,提示:xxx时间已被占用
  384. 当有任意一个研究员时间有冲突时,所有申请订单都不发送。
  385. */
  386. rsCalendarResearcherItem, err := roadshow.GetRsCalendarResearcherByRsCalendarIdAndResearcherId(req.RsCalendarId, v.ResearcherId)
  387. var isAdd bool
  388. if err != nil {
  389. if err.Error() == utils.ErrNoRow() {
  390. isAdd = true
  391. } else {
  392. br.Msg = "获取数据失败!"
  393. br.ErrMsg = "获取数据失败!GetRsCalendarResearcherByRsCalendarIdAndResearcherId:" + err.Error()
  394. return
  395. }
  396. }
  397. var rsCalendarResearcherId int
  398. if rsCalendarResearcherItem == nil {
  399. isAdd = true
  400. } else {
  401. rsCalendarResearcherId = rsCalendarResearcherItem.RsCalendarResearcherId
  402. }
  403. //同步上海数据
  404. researcherInfo, err := system.GetSysAdminById(v.ResearcherId)
  405. if err != nil {
  406. br.Msg = "研究员异常"
  407. return
  408. }
  409. _ = roadshowService.SyncCalendarFromShanghai(researcherInfo.Mobile, v.StartDate, v.EndDate)
  410. //校验事项时间冲突
  411. {
  412. if isAdd || (rsCalendarResearcherItem != nil && (rsCalendarResearcherItem.StartDate != v.StartDate ||
  413. rsCalendarResearcherItem.StartTime != v.StartTime ||
  414. rsCalendarResearcherItem.EndDate != v.EndDate ||
  415. rsCalendarResearcherItem.EndTime != v.EndTime)) {
  416. matterCount, err := roadshowService.CheckMatters(startDateTime, endDateTime, v.ResearcherId, 0)
  417. if err != nil {
  418. br.Msg = "时间冲突检测失败!"
  419. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!Err:" + err.Error()
  420. return
  421. }
  422. if matterCount > 0 {
  423. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  424. }
  425. }
  426. }
  427. //校验活动时间冲突
  428. //{
  429. // if isAdd || (rsCalendarResearcherItem != nil && (rsCalendarResearcherItem.StartDate != v.StartDate ||
  430. // rsCalendarResearcherItem.StartTime != v.StartTime ||
  431. // rsCalendarResearcherItem.EndDate != v.EndDate ||
  432. // rsCalendarResearcherItem.EndTime != v.EndTime)) {
  433. //
  434. // calendarCount, err := roadshowService.CheckCalendar(startDateTime, endDateTime, "1,2", v.ResearcherId, rsCalendarResearcherId)
  435. // if err != nil {
  436. // br.Msg = "时间冲突检测失败!"
  437. // br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!Err:" + err.Error()
  438. // return
  439. // }
  440. // if calendarCount > 0 {
  441. // checkIsAdd = append(checkIsAdd, v.ResearcherName)
  442. // }
  443. // }
  444. //}
  445. calendarCount, err := roadshowService.CheckCalendar(startDateTime, endDateTime, "1,2", v.ResearcherId, rsCalendarResearcherId)
  446. if err != nil {
  447. br.Msg = "时间冲突检测失败!"
  448. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!Err:" + err.Error()
  449. return
  450. }
  451. if calendarCount > 0 {
  452. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  453. }
  454. }
  455. if len(checkIsAdd) > 0 {
  456. br.Msg = strings.Join(checkIsAdd, ",") + "时间已被占用!"
  457. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!"
  458. br.IsSendEmail = false
  459. return
  460. }
  461. rsCalendarItem, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  462. if err != nil {
  463. br.Msg = "获取数据失败!"
  464. br.ErrMsg = "获取数据失败!GetRsCalendarById:" + err.Error()
  465. return
  466. }
  467. if rsCalendarItem == nil {
  468. br.Msg = "保存失败!"
  469. br.ErrMsg = "获取数据失败!GetRsCalendarById:" + err.Error()
  470. return
  471. }
  472. calendarWhereParams := make(map[string]interface{})
  473. calendarUpdateParams := make(map[string]interface{})
  474. calendarWhereParams["rs_calendar_id"] = req.RsCalendarId
  475. if req.ActivityType != "" {
  476. calendarUpdateParams["activity_type"] = req.ActivityType
  477. }
  478. if req.RoadshowType != "" {
  479. calendarUpdateParams["roadshow_type"] = req.RoadshowType
  480. }
  481. if req.RoadshowPlatform != "" {
  482. calendarUpdateParams["roadshow_platform"] = req.RoadshowPlatform
  483. }
  484. if req.CompanyId > 0 {
  485. calendarUpdateParams["company_id"] = req.CompanyId
  486. }
  487. if req.CompanyName != "" {
  488. calendarUpdateParams["company_name"] = req.CompanyName
  489. }
  490. if req.ActivityCategory != "" {
  491. calendarUpdateParams["activity_category"] = req.ActivityCategory
  492. }
  493. if req.Theme != "" {
  494. calendarUpdateParams["theme"] = req.Theme
  495. }
  496. if req.CooperationName != "" {
  497. calendarUpdateParams["cooperation_name"] = req.CooperationName
  498. }
  499. if req.Province != "" {
  500. calendarUpdateParams["province"] = req.Province
  501. }
  502. if req.City != "" {
  503. calendarUpdateParams["city"] = req.City
  504. }
  505. if req.District != "" {
  506. calendarUpdateParams["district"] = req.District
  507. }
  508. calendarUpdateParams["english_company"] = req.EnglishCompany
  509. calendarUpdateParams["modify_time"] = time.Now()
  510. calendarUpdateParams["title"] = getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City)
  511. err = roadshow.UpdateRsCalendar(calendarWhereParams, calendarUpdateParams)
  512. if err != nil {
  513. br.Msg = "保存失败!"
  514. br.ErrMsg = "保存失败!UpdateRsCalendar:" + err.Error()
  515. return
  516. }
  517. //newResearcherMap := make(map[int]string)
  518. existList, err := roadshow.GetRsCalendarResearcherByCalendarId(req.RsCalendarId)
  519. if err != nil {
  520. br.Msg = "保存失败!"
  521. br.ErrMsg = "保存失败!GetRsCalendarResearcherByCalendarId:" + err.Error()
  522. return
  523. }
  524. existResearcherMap := make(map[int]string)
  525. for _, ev := range existList {
  526. existResearcherMap[ev.ResearcherId] = ev.ResearcherName
  527. }
  528. if rsCalendarItem.ActivityType == "路演" || rsCalendarItem.ActivityType == "公开会议" {
  529. // 更新研究员信息
  530. //go roadshowService.UpdateSHCalendar(req.RsCalendarId, req.RsCalendarResearcherId, req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City, req.ResearcherList)
  531. for k, v := range req.ResearcherList {
  532. rsCalendarResearcherItem, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  533. if err != nil {
  534. br.Msg = "获取数据失败!"
  535. br.ErrMsg = "获取数据失败!GetRsCalendarResearcherById:" + err.Error()
  536. return
  537. }
  538. calendarResearcherWhereParams := make(map[string]interface{})
  539. calendarResearcherUpdateParams := make(map[string]interface{})
  540. calendarResearcherWhereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  541. calendarResearcherUpdateParams["researcher_id"] = v.ResearcherId
  542. calendarResearcherUpdateParams["researcher_name"] = v.ResearcherName
  543. rsCalendarResearcherItem.ResearcherId = v.ResearcherId
  544. rsCalendarResearcherItem.ResearcherName = v.ResearcherName
  545. if rsCalendarResearcherItem.Status == 3 || rsCalendarResearcherItem.Status == 5 {
  546. calendarResearcherUpdateParams["status"] = 1
  547. rsCalendarResearcherItem.Status = 1
  548. }
  549. calendarResearcherUpdateParams["start_date"] = v.StartDate
  550. rsCalendarResearcherItem.StartDate = v.StartDate
  551. calendarResearcherUpdateParams["end_date"] = v.EndDate
  552. rsCalendarResearcherItem.EndDate = v.EndDate
  553. calendarResearcherUpdateParams["start_time"] = v.StartTime
  554. rsCalendarResearcherItem.StartTime = v.StartTime
  555. calendarResearcherUpdateParams["end_time"] = v.EndTime
  556. rsCalendarResearcherItem.EndTime = v.EndTime
  557. calendarResearcherUpdateParams["start_week"] = v.StartWeek
  558. rsCalendarResearcherItem.StartWeek = v.StartWeek
  559. calendarResearcherUpdateParams["end_week"] = v.EndWeek
  560. rsCalendarResearcherItem.EndWeek = v.EndWeek
  561. calendarResearcherUpdateParams["refuse_reason"] = ""
  562. rsCalendarResearcherItem.RefuseReason = ""
  563. calendarResearcherUpdateParams["refuse_time"] = nil
  564. calendarResearcherUpdateParams["delete_reason"] = ""
  565. rsCalendarResearcherItem.DeleteReason = ""
  566. calendarResearcherUpdateParams["approve_time"] = nil
  567. calendarResearcherUpdateParams["researcher_sort"] = k + 1
  568. rsCalendarResearcherItem.ResearcherSort = k + 1
  569. calendarResearcherUpdateParams["modify_time"] = time.Now()
  570. rsCalendarResearcherItem.ModifyTime = time.Now()
  571. calendarResearcherUpdateParams["create_time"] = time.Now()
  572. rsCalendarResearcherItem.CreateTime = time.Now()
  573. err = roadshow.UpdateCalendarResearcher(calendarResearcherWhereParams, calendarResearcherUpdateParams)
  574. if err != nil {
  575. br.Msg = "保存失败!"
  576. br.ErrMsg = "保存失败!UpdateCalendarResearcher:" + err.Error()
  577. return
  578. }
  579. //上海新增(因为在驳回的时候,就把上海该时间段的日程给删除了,所以修改的时候,需要重新调用新增接口)
  580. calendar := roadshow.RsCalendar{
  581. RsCalendarId: req.RsCalendarId,
  582. SysUserId: this.SysUser.AdminId,
  583. Title: getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City),
  584. }
  585. researcher := *rsCalendarResearcherItem
  586. researcher.StartDate = v.StartDate
  587. researcher.EndDate = v.EndDate
  588. researcher.StartTime = v.StartTime
  589. researcher.EndTime = v.EndTime
  590. researcher.StartWeek = v.StartWeek
  591. researcher.EndWeek = v.EndWeek
  592. go roadshowService.CalendarToSH(calendar, researcher)
  593. if req.EditType == 2 {
  594. //模板消息通知
  595. go func(researcherId, tmpRsCalendarId, tmpRsCalendarResearcherId int) {
  596. sysAdmin, _ := system.GetSysAdminById(researcherId)
  597. if sysAdmin != nil && req.ActivityType != "内部会议" && req.ActivityType != "报告电话会" {
  598. first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  599. keyword1 := sysUser.RealName
  600. keyword2 := "--"
  601. //keyword3 := time.Now().Format(utils.FormatDateTime)
  602. startDateSub := v.StartDate[5:]
  603. startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  604. keyword3 := startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5]
  605. var keyword4 string
  606. if req.ActivityType == "路演" {
  607. keyword4 = req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  608. } else {
  609. keyword4 = req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  610. }
  611. remark := "请尽快完成审批"
  612. wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(tmpRsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherId)
  613. openIdObj := &system.OpenIdList{
  614. OpenId: sysAdmin.OpenId,
  615. AdminId: sysAdmin.AdminId,
  616. }
  617. openIdList := make([]*system.OpenIdList, 0)
  618. openIdList = append(openIdList, openIdObj)
  619. if sysAdmin.OpenId != "" {
  620. services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, openIdList)
  621. }
  622. }
  623. }(v.ResearcherId, req.RsCalendarId, rsCalendarResearcherItem.RsCalendarResearcherId)
  624. }
  625. }
  626. } else {
  627. //先获取到所有的研究员日历表id
  628. researchers, err := roadshow.GetRsCalendarResearcherByCalendarId(req.RsCalendarId)
  629. if err != nil {
  630. utils.FileLog.Info("GetRsCalendarResearcherByCalendarId err: ", err)
  631. fmt.Println(err)
  632. return
  633. }
  634. //先删后增
  635. err = roadshow.DeleteRsCalendarResearcher(req.RsCalendarId)
  636. if err != nil {
  637. br.Msg = "保存失败!"
  638. br.ErrMsg = "保存失败!DeleteRsCalendarResearcher:" + err.Error()
  639. return
  640. }
  641. //删除上海
  642. for _, researcher := range researchers {
  643. roadshowService.DeleteSHCalendar(researcher.RsCalendarResearcherId)
  644. }
  645. for k, v := range req.ResearcherList {
  646. researcher := new(roadshow.RsCalendarResearcher)
  647. researcher.RsCalendarId = req.RsCalendarId
  648. researcher.ResearcherId = v.ResearcherId
  649. researcher.ResearcherName = v.ResearcherName
  650. researcher.StartDate = v.StartDate
  651. researcher.EndDate = v.EndDate
  652. researcher.StartTime = v.StartTime
  653. researcher.EndTime = v.EndTime
  654. researcher.StartWeek = v.StartWeek
  655. researcher.EndWeek = v.EndWeek
  656. researcher.CreateTime = time.Now()
  657. researcher.ModifyTime = time.Now()
  658. researcher.ResearcherSort = k + 1
  659. if req.ActivityType == "路演" || req.ActivityType == "公开会议" {
  660. researcher.Status = 1
  661. } else {
  662. researcher.Status = 2
  663. }
  664. rsCalendarResearcherId, err := roadshow.AddRsCalendarResearcher(researcher)
  665. if err != nil {
  666. br.Msg = "保存失败!"
  667. br.ErrMsg = "保存日历活动-研究员信息失败!Err:" + err.Error()
  668. return
  669. }
  670. //上海新增
  671. calendar := roadshow.RsCalendar{
  672. RsCalendarId: req.RsCalendarId,
  673. SysUserId: this.SysUser.AdminId,
  674. Title: getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City),
  675. }
  676. researcher.RsCalendarResearcherId = int(rsCalendarResearcherId)
  677. go roadshowService.CalendarToSH(calendar, *researcher)
  678. go func(researcherId, tmpRsCalendarId, tmpRsCalendarResearcherId int) {
  679. sysAdmin, _ := system.GetSysAdminById(researcherId)
  680. if sysAdmin != nil && req.ActivityType != "内部会议" && req.ActivityType != "报告电话会" {
  681. first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  682. keyword1 := sysUser.RealName
  683. keyword2 := "--"
  684. //keyword3 := time.Now().Format(utils.FormatDateTime)
  685. startDateSub := v.StartDate[5:]
  686. startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  687. keyword3 := startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5]
  688. var keyword4 string
  689. if req.ActivityType == "路演" {
  690. keyword4 = req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  691. } else {
  692. keyword4 = req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  693. }
  694. remark := "请尽快完成审批"
  695. wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(tmpRsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherId)
  696. openIdObj := &system.OpenIdList{
  697. OpenId: sysAdmin.OpenId,
  698. AdminId: sysAdmin.AdminId,
  699. }
  700. openIdList := make([]*system.OpenIdList, 0)
  701. openIdList = append(openIdList, openIdObj)
  702. if sysAdmin.OpenId != "" {
  703. services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, openIdList)
  704. }
  705. }
  706. }(v.ResearcherId, req.RsCalendarId, int(rsCalendarResearcherId))
  707. }
  708. }
  709. //for k, v := range req.ResearcherList {
  710. // rsCalendarResearcherItem, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  711. // var isAdd bool
  712. // if err != nil {
  713. // if err.Error() == utils.ErrNoRow() {
  714. // isAdd = true
  715. // } else {
  716. // br.Msg = "获取数据失败!"
  717. // br.ErrMsg = "获取数据失败!GetRsCalendarResearcherById:" + err.Error()
  718. // return
  719. // }
  720. // }
  721. // if rsCalendarResearcherItem == nil {
  722. // isAdd = true
  723. // }
  724. // if _, ok := existResearcherMap[v.ResearcherId]; !ok {
  725. // isAdd = true
  726. // }
  727. // fmt.Println("isAdd:", isAdd)
  728. // if isAdd {
  729. // exist, err := roadshow.GetRsCalendarResearcherExist(req.RsCalendarResearcherId, req.RsCalendarId, v.ResearcherId)
  730. // if err != nil && err.Error() != utils.ErrNoRow() {
  731. // br.Msg = "保存失败!"
  732. // br.ErrMsg = "保存失败!GetRsCalendarResearcherExist:" + err.Error()
  733. // return
  734. // }
  735. // if exist > 0 {
  736. // br.Msg = "研究员 " + v.ResearcherName + " 已存在相同活动"
  737. // br.ErrMsg = "研究员 " + v.ResearcherName + " 已存在相同活动"
  738. // return
  739. // }
  740. // researcher := new(roadshow.RsCalendarResearcher)
  741. // researcher.RsCalendarId = req.RsCalendarId
  742. // researcher.ResearcherId = v.ResearcherId
  743. // researcher.ResearcherName = v.ResearcherName
  744. // researcher.StartDate = v.StartDate
  745. // researcher.EndDate = v.EndDate
  746. // researcher.StartTime = v.StartTime
  747. // researcher.EndTime = v.EndTime
  748. // researcher.StartWeek = v.StartWeek
  749. // researcher.EndWeek = v.EndWeek
  750. // researcher.CreateTime = time.Now()
  751. // researcher.ModifyTime = time.Now()
  752. // researcher.ResearcherSort = k + 1
  753. // if req.ActivityType == "路演" || req.ActivityType == "公开会议" {
  754. // researcher.Status = 1
  755. // } else {
  756. // researcher.Status = 2
  757. // }
  758. // rsCalendarResearcherId, err := roadshow.AddRsCalendarResearcher(researcher)
  759. // if err != nil {
  760. // br.Msg = "保存失败!"
  761. // br.ErrMsg = "保存日历活动-研究员信息失败!Err:" + err.Error()
  762. // return
  763. // }
  764. //
  765. // //模板消息通知
  766. // {
  767. // sysAdmin, _ := system.GetSysAdminById(v.ResearcherId)
  768. // if sysAdmin != nil && req.ActivityType != "内部会议" && req.ActivityType != "报告电话会" {
  769. // first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  770. // keyword1 := sysUser.RealName
  771. // keyword2 := "--"
  772. // keyword3 := time.Now().Format(utils.FormatDateTime)
  773. // startDateSub := v.StartDate[5:]
  774. // startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  775. // var keyword4 string
  776. // if req.ActivityType == "路演" {
  777. // keyword4 = startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5] + " ," + req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  778. // } else {
  779. // keyword4 = startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5] + " ," + req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  780. // }
  781. // remark := "请尽快完成审批"
  782. // wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(req.RsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(int(rsCalendarResearcherId))
  783. // openIdList, _ := models.GetOpenIdListByMobile(sysAdmin.Mobile)
  784. // if len(openIdList) > 0 {
  785. // go services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, openIdList)
  786. // }
  787. // }
  788. // }
  789. // } else {
  790. // calendarResearcherWhereParams := make(map[string]interface{})
  791. // calendarResearcherUpdateParams := make(map[string]interface{})
  792. //
  793. // calendarResearcherWhereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  794. //
  795. // exist, err := roadshow.GetRsCalendarResearcherExist(req.RsCalendarResearcherId, req.RsCalendarId, v.ResearcherId)
  796. // if err != nil && err.Error() != utils.ErrNoRow() {
  797. // br.Msg = "保存失败!"
  798. // br.ErrMsg = "保存失败!GetRsCalendarResearcherExist:" + err.Error()
  799. // return
  800. // }
  801. // if exist > 0 {
  802. // br.Msg = "研究员 " + v.ResearcherName + " 已存在相同活动"
  803. // br.ErrMsg = "研究员 " + v.ResearcherName + " 已存在相同活动"
  804. // return
  805. // }
  806. //
  807. // calendarResearcherUpdateParams["researcher_id"] = v.ResearcherId
  808. // calendarResearcherUpdateParams["researcher_name"] = v.ResearcherName
  809. //
  810. // if rsCalendarResearcherItem.Status == 3 || rsCalendarResearcherItem.Status == 5 {
  811. // calendarResearcherUpdateParams["status"] = 1
  812. // }
  813. // calendarResearcherUpdateParams["start_date"] = v.StartDate
  814. // calendarResearcherUpdateParams["end_date"] = v.EndDate
  815. // calendarResearcherUpdateParams["start_time"] = v.StartTime
  816. // calendarResearcherUpdateParams["end_time"] = v.EndTime
  817. // calendarResearcherUpdateParams["start_week"] = v.StartWeek
  818. // calendarResearcherUpdateParams["end_week"] = v.EndWeek
  819. // calendarResearcherUpdateParams["refuse_reason"] = ""
  820. // calendarResearcherUpdateParams["refuse_time"] = nil
  821. // calendarResearcherUpdateParams["delete_reason"] = ""
  822. // calendarResearcherUpdateParams["approve_time"] = nil
  823. // calendarResearcherUpdateParams["researcher_sort"] = k + 1
  824. // calendarResearcherUpdateParams["modify_time"] = time.Now()
  825. // calendarResearcherUpdateParams["create_time"] = time.Now()
  826. //
  827. // err = roadshow.UpdateCalendarResearcher(calendarResearcherWhereParams, calendarResearcherUpdateParams)
  828. // if err != nil {
  829. // br.Msg = "保存失败!"
  830. // br.ErrMsg = "保存失败!UpdateCalendarResearcher:" + err.Error()
  831. // return
  832. // }
  833. // if req.EditType == 2 {
  834. // //模板消息通知
  835. // {
  836. // sysAdmin, _ := system.GetSysAdminById(v.ResearcherId)
  837. // if sysAdmin != nil && req.ActivityType != "内部会议" && req.ActivityType != "报告电话会" {
  838. // first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  839. // keyword1 := sysUser.RealName
  840. // keyword2 := "--"
  841. // keyword3 := time.Now().Format(utils.FormatDateTime)
  842. // startDateSub := v.StartDate[5:]
  843. // startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  844. // var keyword4 string
  845. // if req.ActivityType == "路演" {
  846. // keyword4 = startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5] + " ," + req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  847. // } else {
  848. // keyword4 = startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5] + " ," + req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  849. // }
  850. // remark := "请尽快完成审批"
  851. // wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(req.RsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(rsCalendarResearcherItem.RsCalendarResearcherId)
  852. // openIdList, _ := models.GetOpenIdListByMobile(sysAdmin.Mobile)
  853. // if len(openIdList) > 0 {
  854. // go services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, openIdList)
  855. // }
  856. // }
  857. // }
  858. // }
  859. //
  860. // }
  861. // newResearcherMap[v.ResearcherId] = v.ResearcherName
  862. //}
  863. //处理删除情况
  864. //{
  865. // if req.EditType == 1 {
  866. // researchList, err := roadshow.GetRsCalendarResearcherListByRsCalendarId(req.RsCalendarId)
  867. // if err != nil {
  868. // br.Msg = "保存失败!"
  869. // br.ErrMsg = "保存失败!UpdateCalendarResearcher:" + err.Error()
  870. // return
  871. // }
  872. // for _, ev := range researchList {
  873. // if _, ok := newResearcherMap[ev.ResearcherId]; !ok {
  874. // roadshow.DeleteCalendar(req.RsCalendarId, ev.RsCalendarResearcherId)
  875. // }
  876. // }
  877. // }
  878. //}
  879. //if req.ActivityType == "公开会议" {
  880. // go roadshowService.SetPublicMeetingUnionCode()
  881. //}
  882. br.Ret = 200
  883. br.Success = true
  884. br.Msg = "保存成功"
  885. br.IsAddLog = true
  886. }
  887. // ResearcherList
  888. // @Title 研究员列表
  889. // @Description 研究员列表接口
  890. // @Success 200 {object} roadshow.ResearcherGroup
  891. // @router /researcher/list [get]
  892. func (this *CalendarController) ResearcherList() {
  893. br := new(models.BaseResponse).Init()
  894. defer func() {
  895. this.Data["json"] = br
  896. this.ServeJSON()
  897. }()
  898. group, err := roadshow.GetResearcherGroup()
  899. if err != nil {
  900. br.Msg = "获取信息失败!"
  901. br.ErrMsg = "获取分组信息失败!Err:" + err.Error()
  902. return
  903. }
  904. researcherList, err := roadshow.GetResearcher()
  905. groupMap := make(map[int][]*roadshow.ResearcherGroup)
  906. for _, v := range researcherList {
  907. item := &roadshow.ResearcherGroup{
  908. GroupId: v.GroupId,
  909. GroupName: v.GroupName,
  910. AdminId: v.AdminId,
  911. RealName: v.RealName,
  912. RoleTypeCode: v.RoleTypeCode,
  913. }
  914. if findItems, ok := groupMap[v.GroupId]; ok {
  915. findItems = append(findItems, item)
  916. groupMap[v.GroupId] = findItems
  917. } else {
  918. findItems = append(findItems, item)
  919. groupMap[v.GroupId] = findItems
  920. }
  921. //}
  922. }
  923. for _, v := range group {
  924. v.ResearcherList = groupMap[v.GroupId]
  925. }
  926. ficcGroup := new(roadshow.ResearcherGroup)
  927. ficcGroup.GroupId = 999
  928. ficcGroup.GroupName = "ficc"
  929. ficcGroup.ResearcherList = group
  930. sysUserList, err := system.GetAdminList()
  931. if err != nil {
  932. br.Msg = "获取失败"
  933. br.ErrMsg = "获取admin列表失败, Err:" + err.Error()
  934. return
  935. }
  936. adminMap := make(map[int]*system.Admin, 0)
  937. for _, v := range sysUserList {
  938. adminMap[v.AdminId] = v
  939. }
  940. askUserList, err := cygx.GetAskEmailList()
  941. if err != nil {
  942. br.Msg = "获取失败"
  943. br.ErrMsg = "获取失败,GetAskEmailList Err: " + err.Error()
  944. return
  945. }
  946. mapPermissionUser := make(map[string][]*roadshow.ResearcherGroup)
  947. listPermission, err := cygx.GetChartPermissionAll()
  948. if err != nil {
  949. br.Msg = "获取信息失败"
  950. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  951. return
  952. }
  953. mapPermissionId := make(map[string]int)
  954. for _, v := range listPermission {
  955. mapPermissionId[v.PermissionName] = v.ChartPermissionId
  956. }
  957. for _, v := range askUserList {
  958. if admin, ok := adminMap[v.AdminId]; ok {
  959. item := &roadshow.ResearcherGroup{
  960. AdminId: v.AdminId,
  961. RealName: v.Name,
  962. GroupId: admin.GroupId,
  963. GroupName: admin.GroupName,
  964. RoleTypeCode: admin.RoleTypeCode,
  965. }
  966. mapPermissionUser[v.ChartPermissionName] = append(mapPermissionUser[v.ChartPermissionName], item)
  967. }
  968. }
  969. raiList := make([]*roadshow.ResearcherGroup, 0)
  970. for k, v := range mapPermissionUser {
  971. respItem := new(roadshow.ResearcherGroup)
  972. respItem.GroupName = k + "组"
  973. respItem.GroupId = mapPermissionId[k]
  974. respItem.ResearcherList = v
  975. raiList = append(raiList, respItem)
  976. }
  977. raiGroup := new(roadshow.ResearcherGroup)
  978. raiGroup.GroupId = 888
  979. raiGroup.GroupName = "权益"
  980. raiGroup.ResearcherList = raiList
  981. var resp []*roadshow.ResearcherGroup
  982. resp = append(resp, ficcGroup, raiGroup)
  983. br.Ret = 200
  984. br.Success = true
  985. br.Msg = "获取成功"
  986. br.Data = resp
  987. }
  988. // CalendarList
  989. // @Title 我的日历列表
  990. // @Description 我的日历列表接口
  991. // @Param PageSize query int true "每页数据条数"
  992. // @Param CurrentIndex query int true "当前页页码,从1开始"
  993. // @Param CalendarType query int true "1:待处理申请,2:已处理申请,3:内部会议,4:报告电话会"
  994. // @Success 200 {object} roadshow.CalendarListResp
  995. // @router /calendar/list [get]
  996. func (this *CalendarController) CalendarList() {
  997. br := new(models.BaseResponse).Init()
  998. defer func() {
  999. this.Data["json"] = br
  1000. this.ServeJSON()
  1001. }()
  1002. sysUser := this.SysUser
  1003. if sysUser == nil {
  1004. br.Msg = "请登录"
  1005. br.ErrMsg = "请登录,SysUser Is Empty"
  1006. br.Ret = 408
  1007. return
  1008. }
  1009. calendarType, _ := this.GetInt("CalendarType")
  1010. pageSize, _ := this.GetInt("PageSize")
  1011. currentIndex, _ := this.GetInt("CurrentIndex")
  1012. var total int
  1013. page := paging.GetPaging(currentIndex, pageSize, total)
  1014. var startSize int
  1015. if pageSize <= 0 {
  1016. pageSize = utils.PageSize10
  1017. }
  1018. if currentIndex <= 0 {
  1019. currentIndex = 1
  1020. }
  1021. startSize = paging.StartIndex(currentIndex, pageSize)
  1022. var condition string
  1023. var pars []interface{}
  1024. roleTypeCode := sysUser.RoleTypeCode
  1025. //销售
  1026. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER ||
  1027. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER ||
  1028. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_GROUP ||
  1029. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP ||
  1030. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_TEAM {
  1031. condition += ` AND a.sys_user_id=?`
  1032. pars = append(pars, sysUser.AdminId)
  1033. //condition += ` AND a.activity_type IN('路演','公开会议') `
  1034. }
  1035. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR ||
  1036. roleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR ||
  1037. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR ||
  1038. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_DEPARTMENT ||
  1039. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_DEPARTMENT ||
  1040. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN ||
  1041. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN {
  1042. if calendarType != 3 {
  1043. condition += ` AND b.researcher_id=?`
  1044. pars = append(pars, sysUser.AdminId)
  1045. }
  1046. }
  1047. if roleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  1048. condition += ` AND a.sys_user_id=?`
  1049. pars = append(pars, sysUser.AdminId)
  1050. }
  1051. if calendarType == 1 {
  1052. condition += ` AND b.status=1`
  1053. }
  1054. if calendarType == 2 {
  1055. condition += ` AND b.status>=2`
  1056. condition += ` AND a.activity_type IN('路演','公开会议') `
  1057. }
  1058. if calendarType == 3 {
  1059. condition += ` AND a.activity_type='内部会议' `
  1060. condition += ` AND a.sys_user_id=?`
  1061. pars = append(pars, sysUser.AdminId)
  1062. }
  1063. if calendarType == 4 {
  1064. condition += ` AND a.activity_type='报告电话会' `
  1065. }
  1066. if calendarType < 0 || calendarType > 4 {
  1067. br.Msg = "参数错误"
  1068. br.ErrMsg = "参数错误,calendarType:" + strconv.Itoa(calendarType)
  1069. return
  1070. }
  1071. resp := new(roadshow.CalendarListResp)
  1072. total, err := roadshow.GetCalendarListCount(condition, pars, calendarType)
  1073. if err != nil && err.Error() != utils.ErrNoRow() {
  1074. br.Msg = "获取信息失败"
  1075. br.ErrMsg = "获取数据总数失败,GetCalendarListCount,Err:" + err.Error()
  1076. return
  1077. }
  1078. page = paging.GetPaging(currentIndex, pageSize, total)
  1079. dataList, err := roadshow.GetCalendarList(condition, pars, startSize, pageSize, calendarType)
  1080. if err != nil {
  1081. br.Msg = "获取指标信息失败"
  1082. br.ErrMsg = "获取数据失败,GetCalendarList,Err:" + err.Error()
  1083. return
  1084. }
  1085. // 英文客户的国家以及点击量
  1086. englishIds := make([]int, 0)
  1087. for i := range dataList {
  1088. if dataList[i].EnglishCompany == 1 {
  1089. englishIds = append(englishIds, dataList[i].CompanyId)
  1090. }
  1091. }
  1092. englishMap := make(map[int]*models.EnglishCompany)
  1093. if len(englishIds) > 0 {
  1094. englishCond := ` AND company_id IN (` + utils.GetOrmInReplace(len(englishIds)) + `)`
  1095. englishPars := make([]interface{}, 0)
  1096. englishPars = append(englishPars, englishIds)
  1097. englishList, e := models.GetEnglishCompanyList(englishCond, englishPars, "")
  1098. if e != nil {
  1099. br.Msg = "获取英文客户失败"
  1100. br.ErrMsg = "获取英文客户失败, Err:" + e.Error()
  1101. return
  1102. }
  1103. for i := range englishList {
  1104. englishMap[englishList[i].CompanyId] = englishList[i]
  1105. }
  1106. }
  1107. for i := range dataList {
  1108. if dataList[i].EnglishCompany == 1 {
  1109. en := englishMap[dataList[i].CompanyId]
  1110. if en != nil {
  1111. dataList[i].EnglishCountry = en.Country
  1112. dataList[i].EnglishViewTotal = en.ViewTotal
  1113. }
  1114. }
  1115. }
  1116. resp.Paging = page
  1117. resp.List = dataList
  1118. br.Ret = 200
  1119. br.Success = true
  1120. br.Msg = "获取成功"
  1121. br.Data = resp
  1122. }
  1123. // Accept
  1124. // @Description 接受路演活动接口
  1125. // @Param request body roadshow.AcceptReq true "type json string"
  1126. // @Success Ret=200 保存成功
  1127. // @router /accept [post]
  1128. func (this *CalendarController) Accept() {
  1129. br := new(models.BaseResponse).Init()
  1130. defer func() {
  1131. this.Data["json"] = br
  1132. this.ServeJSON()
  1133. }()
  1134. sysUser := this.SysUser
  1135. if sysUser == nil {
  1136. br.Msg = "请登录"
  1137. br.ErrMsg = "请登录,SysUser Is Empty"
  1138. br.Ret = 408
  1139. return
  1140. }
  1141. var req roadshow.AcceptReq
  1142. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1143. if err != nil {
  1144. br.Msg = "参数解析异常!"
  1145. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1146. return
  1147. }
  1148. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  1149. br.Msg = "参数错误!"
  1150. br.ErrMsg = "参数错误!RsCalendarId:" + strconv.Itoa(req.RsCalendarId) + ";RsCalendarResearcherId:" + strconv.Itoa(req.RsCalendarResearcherId)
  1151. return
  1152. }
  1153. rsCalendar, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  1154. if err != nil {
  1155. br.Msg = "获取数据失败!"
  1156. br.ErrMsg = "获取数据失败!GetRsCalendarById:" + err.Error()
  1157. return
  1158. }
  1159. rsCalendarResearcher, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  1160. if err != nil {
  1161. br.Msg = "获取数据失败!"
  1162. br.ErrMsg = "获取数据失败!GetRsCalendarResearcherById:" + err.Error()
  1163. return
  1164. }
  1165. if rsCalendarResearcher.Status == 2 {
  1166. br.Msg = "已接受,不可重复操作!"
  1167. return
  1168. } else if rsCalendarResearcher.Status == 3 {
  1169. br.Msg = "已拒绝,不可进行接受操作!"
  1170. return
  1171. } else if rsCalendarResearcher.Status == 4 {
  1172. br.Msg = "已删除,不可进行接受操作!"
  1173. return
  1174. } else if rsCalendarResearcher.Status == 5 {
  1175. br.Msg = "已撤回,不可进行接受操作!"
  1176. return
  1177. }
  1178. whereParams := make(map[string]interface{})
  1179. updateParams := make(map[string]interface{})
  1180. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  1181. whereParams["rs_calendar_id"] = req.RsCalendarId
  1182. updateParams["status"] = 2
  1183. updateParams["modify_time"] = time.Now()
  1184. updateParams["approve_time"] = time.Now()
  1185. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  1186. if err != nil {
  1187. br.Msg = "保存失败!"
  1188. br.ErrMsg = "保存失败!UpdateCalendarResearcher:" + err.Error()
  1189. return
  1190. }
  1191. //模板消息通知
  1192. {
  1193. if rsCalendar != nil {
  1194. go func(tmpRsCalendar roadshow.RsCalendar) {
  1195. sysAdmin, _ := system.GetSysAdminById(tmpRsCalendar.SysUserId)
  1196. first := "【" + sysUser.RealName + "】接受了你的【" + tmpRsCalendar.ActivityType + "】申请"
  1197. var keyword1, keyword2, keyword3, keyword4, keyword5 string
  1198. keyword1 = tmpRsCalendar.CompanyName + "(" + tmpRsCalendar.RoadshowType + tmpRsCalendar.ActivityType + ")"
  1199. keyword2 = tmpRsCalendar.ActivityType
  1200. keyword4 = `【` + sysUser.RealName + `】已接受`
  1201. remark := ""
  1202. wxAppPath := ""
  1203. openIdObj := &system.OpenIdList{
  1204. OpenId: sysAdmin.OpenId,
  1205. AdminId: sysAdmin.AdminId,
  1206. }
  1207. openIdList := make([]*system.OpenIdList, 0)
  1208. openIdList = append(openIdList, openIdObj)
  1209. if sysAdmin.OpenId != "" {
  1210. services.SendWxMsgWithRoadshowDetailResult(first, keyword1, keyword2, keyword3, keyword4, keyword5, remark, wxAppPath, openIdList)
  1211. }
  1212. }(*rsCalendar)
  1213. }
  1214. }
  1215. br.Ret = 200
  1216. br.Success = true
  1217. br.Msg = "保存成功"
  1218. br.IsAddLog = true
  1219. }
  1220. // @Title 拒绝路演活动接口
  1221. // @Description 拒绝路演活动接口
  1222. // @Param request body roadshow.RefuseReq true "type json string"
  1223. // @Success Ret=200 保存成功
  1224. // @router /refuse [post]
  1225. func (this *CalendarController) Refuse() {
  1226. br := new(models.BaseResponse).Init()
  1227. defer func() {
  1228. this.Data["json"] = br
  1229. this.ServeJSON()
  1230. }()
  1231. sysUser := this.SysUser
  1232. if sysUser == nil {
  1233. br.Msg = "请登录"
  1234. br.ErrMsg = "请登录,SysUser Is Empty"
  1235. br.Ret = 408
  1236. return
  1237. }
  1238. var req roadshow.RefuseReq
  1239. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1240. if err != nil {
  1241. br.Msg = "参数解析异常!"
  1242. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1243. return
  1244. }
  1245. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  1246. br.Msg = "参数错误!"
  1247. br.ErrMsg = "参数错误!RsCalendarId:" + strconv.Itoa(req.RsCalendarId) + ";RsCalendarResearcherId:" + strconv.Itoa(req.RsCalendarResearcherId)
  1248. return
  1249. }
  1250. rsCalendar, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  1251. if err != nil {
  1252. br.Msg = "获取数据失败!"
  1253. br.ErrMsg = "获取数据失败!GetRsCalendarById:" + err.Error()
  1254. return
  1255. }
  1256. rsCalendarResearcher, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  1257. if err != nil {
  1258. br.Msg = "获取数据失败!"
  1259. br.ErrMsg = "获取数据失败!GetRsCalendarResearcherById:" + err.Error()
  1260. return
  1261. }
  1262. if rsCalendarResearcher.Status == 2 {
  1263. br.Msg = "已接受,不可进行拒绝操作!"
  1264. return
  1265. } else if rsCalendarResearcher.Status == 3 {
  1266. br.Msg = "已拒绝,不可进行重复操作!"
  1267. return
  1268. } else if rsCalendarResearcher.Status == 4 {
  1269. br.Msg = "已删除,不可进行拒绝操作!"
  1270. return
  1271. } else if rsCalendarResearcher.Status == 5 {
  1272. br.Msg = "已撤回,不可进行拒绝操作!"
  1273. return
  1274. }
  1275. whereParams := make(map[string]interface{})
  1276. updateParams := make(map[string]interface{})
  1277. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  1278. whereParams["rs_calendar_id"] = req.RsCalendarId
  1279. updateParams["status"] = 3
  1280. updateParams["refuse_reason"] = req.RefuseReason
  1281. updateParams["refuse_time"] = time.Now()
  1282. updateParams["modify_time"] = time.Now()
  1283. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  1284. if err != nil {
  1285. br.Msg = "保存失败!"
  1286. br.ErrMsg = "保存失败!UpdateCalendarResearcher:" + err.Error()
  1287. return
  1288. }
  1289. //拒绝后,需要删除该日程
  1290. go roadshowService.DeleteSHCalendar(req.RsCalendarResearcherId)
  1291. //模板消息通知
  1292. {
  1293. if rsCalendar != nil {
  1294. go func(tmpRsCalendar roadshow.RsCalendar) {
  1295. sysAdmin, _ := system.GetSysAdminById(tmpRsCalendar.SysUserId)
  1296. first := "【" + sysUser.RealName + "】拒绝了你的【" + tmpRsCalendar.ActivityType + "】申请"
  1297. var keyword1, keyword2, keyword3, keyword4, keyword5 string
  1298. keyword1 = tmpRsCalendar.CompanyName + "(" + tmpRsCalendar.RoadshowType + tmpRsCalendar.ActivityType + ")"
  1299. keyword2 = tmpRsCalendar.ActivityType
  1300. keyword4 = `【` + sysUser.RealName + `】已拒绝`
  1301. keyword5 = req.RefuseReason
  1302. remark := req.RefuseReason
  1303. wxAppPath := ""
  1304. openIdObj := &system.OpenIdList{
  1305. OpenId: sysAdmin.OpenId,
  1306. AdminId: sysAdmin.AdminId,
  1307. }
  1308. openIdList := make([]*system.OpenIdList, 0)
  1309. openIdList = append(openIdList, openIdObj)
  1310. if sysAdmin.OpenId != "" {
  1311. services.SendWxMsgWithRoadshowDetailResult(first, keyword1, keyword2, keyword3, keyword4, keyword5, remark, wxAppPath, openIdList)
  1312. }
  1313. }(*rsCalendar)
  1314. }
  1315. }
  1316. br.Ret = 200
  1317. br.Success = true
  1318. br.Msg = "保存成功"
  1319. br.IsAddLog = true
  1320. }
  1321. // @Title 撤回路演活动接口
  1322. // @Description 撤回路演活动接口
  1323. // @Param request body roadshow.AcceptReq true "type json string"
  1324. // @Success Ret=200 保存成功
  1325. // @router /back [post]
  1326. func (this *CalendarController) Back() {
  1327. br := new(models.BaseResponse).Init()
  1328. defer func() {
  1329. this.Data["json"] = br
  1330. this.ServeJSON()
  1331. }()
  1332. sysUser := this.SysUser
  1333. if sysUser == nil {
  1334. br.Msg = "请登录"
  1335. br.ErrMsg = "请登录,SysUser Is Empty"
  1336. br.Ret = 408
  1337. return
  1338. }
  1339. var req roadshow.AcceptReq
  1340. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1341. if err != nil {
  1342. br.Msg = "参数解析异常!"
  1343. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1344. return
  1345. }
  1346. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  1347. br.Msg = "参数错误!"
  1348. br.ErrMsg = "参数错误!RsCalendarId:" + strconv.Itoa(req.RsCalendarId) + ";RsCalendarResearcherId:" + strconv.Itoa(req.RsCalendarResearcherId)
  1349. return
  1350. }
  1351. _, err = roadshow.GetRsCalendarById(req.RsCalendarId)
  1352. if err != nil {
  1353. br.Msg = "获取数据失败!"
  1354. br.ErrMsg = "获取数据失败!GetRsCalendarById:" + err.Error()
  1355. return
  1356. }
  1357. rsCalendarResearcher, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  1358. if err != nil {
  1359. br.Msg = "获取数据失败!"
  1360. br.ErrMsg = "获取数据失败!GetRsCalendarResearcherById:" + err.Error()
  1361. return
  1362. }
  1363. if rsCalendarResearcher.Status == 2 {
  1364. br.Msg = "已接受,不可进行撤回操作!"
  1365. return
  1366. } else if rsCalendarResearcher.Status == 3 {
  1367. br.Msg = "已拒绝,不可进行撤回操作!"
  1368. return
  1369. } else if rsCalendarResearcher.Status == 4 {
  1370. br.Msg = "已删除,不可进行撤回操作!"
  1371. return
  1372. } else if rsCalendarResearcher.Status == 5 {
  1373. br.Msg = "已撤回,不可进行重复操作!"
  1374. return
  1375. }
  1376. whereParams := make(map[string]interface{})
  1377. updateParams := make(map[string]interface{})
  1378. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  1379. whereParams["rs_calendar_id"] = req.RsCalendarId
  1380. updateParams["status"] = 5
  1381. updateParams["modify_time"] = time.Now()
  1382. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  1383. //撤回后,需要删除该日程
  1384. go roadshowService.DeleteSHCalendar(req.RsCalendarResearcherId)
  1385. if err != nil {
  1386. br.Msg = "保存失败!"
  1387. br.ErrMsg = "保存失败!UpdateCalendarResearcher:" + err.Error()
  1388. return
  1389. }
  1390. br.Ret = 200
  1391. br.Success = true
  1392. br.Msg = "保存成功"
  1393. br.IsAddLog = true
  1394. }
  1395. // @Title 删除路演活动接口
  1396. // @Description 删除路演活动接口
  1397. // @Param request body roadshow.DeleteReq true "type json string"
  1398. // @Success Ret=200 保存成功
  1399. // @router /delete [post]
  1400. func (this *CalendarController) Delete() {
  1401. br := new(models.BaseResponse).Init()
  1402. defer func() {
  1403. this.Data["json"] = br
  1404. this.ServeJSON()
  1405. }()
  1406. sysUser := this.SysUser
  1407. if sysUser == nil {
  1408. br.Msg = "请登录"
  1409. br.ErrMsg = "请登录,SysUser Is Empty"
  1410. br.Ret = 408
  1411. return
  1412. }
  1413. var req roadshow.DeleteReq
  1414. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1415. if err != nil {
  1416. br.Msg = "参数解析异常!"
  1417. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1418. return
  1419. }
  1420. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  1421. br.Msg = "参数错误!"
  1422. br.ErrMsg = "参数错误!RsCalendarId:" + strconv.Itoa(req.RsCalendarId) + ";RsCalendarResearcherId:" + strconv.Itoa(req.RsCalendarResearcherId)
  1423. return
  1424. }
  1425. rsCalendarItem, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  1426. if err != nil {
  1427. br.Msg = "获取数据失败!"
  1428. br.ErrMsg = "获取数据失败!GetRsCalendarById:" + err.Error()
  1429. return
  1430. }
  1431. rsCalendarResearcherItemList, err := roadshow.GetRsCalendarResearcherListById(req.RsCalendarId)
  1432. if err != nil {
  1433. br.Msg = "获取数据失败!"
  1434. br.ErrMsg = "获取数据失败!GetRsCalendarResearcherById:" + err.Error()
  1435. return
  1436. }
  1437. if rsCalendarItem.ActivityType == "报告电话会" || rsCalendarItem.ActivityType == "内部会议" {
  1438. err = roadshow.DeleteCalendar(req.RsCalendarId, req.RsCalendarResearcherId)
  1439. if err != nil {
  1440. br.Msg = "删除失败!"
  1441. br.ErrMsg = "删除失败!DeleteCalendar:" + err.Error()
  1442. return
  1443. }
  1444. //检测报表记录中是否已经存在,如果存在,则删除
  1445. {
  1446. err = roadshow.DeleteRsReportRecord(req.RsCalendarId, req.RsCalendarResearcherId)
  1447. if err != nil {
  1448. br.Msg = "删除失败!"
  1449. br.ErrMsg = "删除失败!DeleteRsReportRecord:" + err.Error()
  1450. return
  1451. }
  1452. }
  1453. } else {
  1454. //只获取一条路演数据
  1455. rsCalendarResearcherItemList, err = roadshow.GetRsCalendarResearcherListByCalendarResearcherId(req.RsCalendarResearcherId)
  1456. if err != nil {
  1457. br.Msg = "获取数据失败!"
  1458. br.ErrMsg = "获取数据失败!GetRsCalendarResearcherById:" + err.Error()
  1459. return
  1460. }
  1461. whereParams := make(map[string]interface{})
  1462. updateParams := make(map[string]interface{})
  1463. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  1464. whereParams["rs_calendar_id"] = req.RsCalendarId
  1465. updateParams["status"] = 4
  1466. updateParams["delete_reason"] = req.DeleteReason
  1467. updateParams["modify_time"] = time.Now()
  1468. updateParams["delete_time"] = time.Now()
  1469. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  1470. if err != nil {
  1471. br.Msg = "删除失败!"
  1472. br.ErrMsg = "删除失败!UpdateCalendarResearcher:" + err.Error()
  1473. return
  1474. }
  1475. }
  1476. //`status` int(11) DEFAULT '0' COMMENT '1:待接受,2:已接受,3:已拒绝,4:已删除,5:已撤回,6:已结束',
  1477. //待接受、已接受的情况,需要同步删除上海那边的日程
  1478. for _, rsCalendarResearcherItem := range rsCalendarResearcherItemList {
  1479. //删除上海的活动
  1480. if rsCalendarResearcherItem.Status == 1 || rsCalendarResearcherItem.Status == 2 {
  1481. go roadshowService.DeleteSHCalendar(rsCalendarResearcherItem.RsCalendarResearcherId)
  1482. }
  1483. //模板消息通知
  1484. {
  1485. if rsCalendarItem != nil && rsCalendarResearcherItem != nil {
  1486. go func(tmpRsCalendarItem roadshow.RsCalendar, tmpRsCalendarResearcherItem roadshow.RsCalendarResearcher) {
  1487. sysAdmin, _ := system.GetSysAdminById(tmpRsCalendarResearcherItem.ResearcherId)
  1488. var first string
  1489. var wxAppPath string
  1490. if tmpRsCalendarItem.ActivityType == "路演" || tmpRsCalendarItem.ActivityType == "公开会议" {
  1491. wxAppPath = "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(tmpRsCalendarItem.RsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherItem.RsCalendarResearcherId)
  1492. }
  1493. first = "【" + sysUser.RealName + "】删除了你的【" + tmpRsCalendarItem.ActivityType + "】安排"
  1494. keyword2 := "【" + sysUser.RealName + "】已删除(" + req.DeleteReason + ")"
  1495. var keyword1 string
  1496. if tmpRsCalendarItem.ActivityType == "路演" {
  1497. keyword1 = tmpRsCalendarItem.CompanyName + "," + tmpRsCalendarItem.RoadshowType + tmpRsCalendarItem.ActivityType
  1498. } else if tmpRsCalendarItem.ActivityType == "公开会议" {
  1499. keyword1 = tmpRsCalendarItem.Theme + "," + tmpRsCalendarItem.RoadshowType + tmpRsCalendarItem.ActivityType
  1500. } else {
  1501. startDate := tmpRsCalendarResearcherItem.StartDate[5:]
  1502. startDate = strings.Replace(startDate, "-", ".", -1)
  1503. keyword1 = "会议时间:" + startDate + "(" + tmpRsCalendarResearcherItem.StartWeek + ")" + " " + tmpRsCalendarResearcherItem.StartTime[:5] + "-" + tmpRsCalendarResearcherItem.EndTime[:5]
  1504. keyword2 = "【" + sysUser.RealName + "】已删除" + "【" + tmpRsCalendarItem.ActivityType + ")"
  1505. }
  1506. //keyword2 := "已删除"
  1507. remark := req.DeleteReason
  1508. if sysAdmin.OpenId != "" {
  1509. openIdObj := &system.OpenIdList{
  1510. OpenId: sysAdmin.OpenId,
  1511. AdminId: sysAdmin.AdminId,
  1512. }
  1513. openIdList := make([]*system.OpenIdList, 0)
  1514. openIdList = append(openIdList, openIdObj)
  1515. if len(openIdList) > 0 {
  1516. services.SendWxMsgWithRoadshowDeleteNotice(first, keyword1, keyword2, remark, wxAppPath, openIdList)
  1517. }
  1518. }
  1519. }(*rsCalendarItem, *rsCalendarResearcherItem)
  1520. }
  1521. }
  1522. }
  1523. br.Ret = 200
  1524. br.Success = true
  1525. br.Msg = "删除成功"
  1526. br.IsAddLog = true
  1527. }
  1528. // @Title 新增事项接口
  1529. // @Description 新增事项接口
  1530. // @Param request body roadshow.AddMattersReq true "type json string"
  1531. // @Success Ret=200 保存成功
  1532. // @router /matters/add [post]
  1533. func (this *CalendarController) MattersAdd() {
  1534. br := new(models.BaseResponse).Init()
  1535. defer func() {
  1536. this.Data["json"] = br
  1537. this.ServeJSON()
  1538. }()
  1539. sysUser := this.SysUser
  1540. if sysUser == nil {
  1541. br.Msg = "请登录"
  1542. br.ErrMsg = "请登录,SysUser Is Empty"
  1543. br.Ret = 408
  1544. return
  1545. }
  1546. deleteCache := true
  1547. cacheKey := "CACHE_RS_MATTERS_ADD_" + strconv.Itoa(sysUser.AdminId)
  1548. defer func() {
  1549. if deleteCache {
  1550. utils.Rc.Delete(cacheKey)
  1551. }
  1552. }()
  1553. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  1554. deleteCache = false
  1555. br.Msg = "系统处理中,请稍后重试!"
  1556. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
  1557. return
  1558. }
  1559. var req roadshow.AddMattersReq
  1560. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1561. if err != nil {
  1562. br.Msg = "参数解析异常!"
  1563. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1564. return
  1565. }
  1566. if req.StartDate == "" {
  1567. br.Msg = "请选择开始日期!"
  1568. return
  1569. }
  1570. if req.EndDate == "" {
  1571. br.Msg = "请选择结束日期!"
  1572. return
  1573. }
  1574. if req.StartTime == "" {
  1575. br.Msg = "请选择开始时间!"
  1576. return
  1577. }
  1578. if req.EndTime == "" {
  1579. br.Msg = "请选择结束时间!"
  1580. return
  1581. }
  1582. if req.StartWeek == "" {
  1583. br.Msg = "请选择周!"
  1584. return
  1585. }
  1586. if req.EndWeek == "" {
  1587. br.Msg = "请选择周!"
  1588. return
  1589. }
  1590. if req.MatterContent == "" {
  1591. br.Msg = "请选择研究员!"
  1592. return
  1593. }
  1594. // 是否为销售
  1595. sales := isSellerRole(sysUser.RoleTypeCode)
  1596. startDateTime := req.StartDate + " " + req.StartTime
  1597. endDateTime := req.EndDate + " " + req.EndTime
  1598. //校验事项时间冲突
  1599. {
  1600. matterCount, err := roadshowService.CheckMatters(startDateTime, endDateTime, sysUser.AdminId, 0)
  1601. if err != nil {
  1602. br.Msg = "时间冲突检测失败!"
  1603. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!Err:" + err.Error()
  1604. return
  1605. }
  1606. if matterCount > 0 {
  1607. br.Msg = "当前时间已被占用!"
  1608. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!"
  1609. br.IsSendEmail = false
  1610. return
  1611. }
  1612. }
  1613. if !sales {
  1614. //校验活动时间冲突--待接受
  1615. {
  1616. calendarCount, err := roadshowService.CheckCalendar(startDateTime, endDateTime, "1", sysUser.AdminId, 0)
  1617. if err != nil {
  1618. br.Msg = "时间冲突检测失败!"
  1619. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!Err:" + err.Error()
  1620. return
  1621. }
  1622. if calendarCount > 0 {
  1623. br.Msg = "当前时间与待处理的申请有冲突,请与相关销售沟通!"
  1624. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!"
  1625. br.IsSendEmail = false
  1626. return
  1627. }
  1628. }
  1629. //校验活动时间冲突--已接受
  1630. {
  1631. calendarCount, err := roadshowService.CheckCalendar(startDateTime, endDateTime, "2", sysUser.AdminId, 0)
  1632. if err != nil {
  1633. br.Msg = "时间冲突检测失败!"
  1634. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!Err:" + err.Error()
  1635. return
  1636. }
  1637. if calendarCount > 0 {
  1638. br.Msg = "当前时间已被占用!"
  1639. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!"
  1640. br.IsSendEmail = false
  1641. return
  1642. }
  1643. }
  1644. }
  1645. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  1646. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  1647. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  1648. br.Msg = "事项开始时间不能小于当前时间!"
  1649. return
  1650. }
  1651. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  1652. br.Msg = "事项结束时间不能小于当前时间!"
  1653. return
  1654. }
  1655. if startP.After(endP) || startP.Equal(endP) {
  1656. br.Msg = "事项开始时间应小于结束时间!"
  1657. return
  1658. }
  1659. item := new(roadshow.RsMatters)
  1660. item.SysUserId = sysUser.AdminId
  1661. item.SysUserRealName = sysUser.RealName
  1662. item.StartDate = req.StartDate
  1663. item.EndDate = req.EndDate
  1664. item.StartTime = req.StartTime
  1665. item.EndTime = req.EndTime
  1666. item.StartWeek = req.StartWeek
  1667. item.EndWeek = req.EndWeek
  1668. item.MatterContent = req.MatterContent
  1669. item.Status = 1
  1670. item.CreateTime = time.Now()
  1671. item.ModifyTime = time.Now()
  1672. if sales {
  1673. item.IsSeller = 1
  1674. }
  1675. id, err := roadshow.AddRsMatters(item)
  1676. if err != nil {
  1677. br.Msg = "保存失败!"
  1678. br.ErrMsg = "保存失败,AddRsMatters Err:" + err.Error()
  1679. return
  1680. }
  1681. item.RsMattersId = int(id)
  1682. // 销售的事项不同步上海
  1683. if !sales {
  1684. go roadshowService.MatterToSH(*item)
  1685. }
  1686. br.Ret = 200
  1687. br.Success = true
  1688. br.Msg = "保存成功"
  1689. br.IsAddLog = true
  1690. }
  1691. // @Title 修改事项接口
  1692. // @Description 修改事项接口
  1693. // @Param request body roadshow.UpdateMattersReq true "type json string"
  1694. // @Success Ret=200 保存成功
  1695. // @router /matters/update [post]
  1696. func (this *CalendarController) MattersUpdate() {
  1697. br := new(models.BaseResponse).Init()
  1698. defer func() {
  1699. this.Data["json"] = br
  1700. this.ServeJSON()
  1701. }()
  1702. sysUser := this.SysUser
  1703. if sysUser == nil {
  1704. br.Msg = "请登录"
  1705. br.ErrMsg = "请登录,SysUser Is Empty"
  1706. br.Ret = 408
  1707. return
  1708. }
  1709. deleteCache := true
  1710. cacheKey := "CACHE_RS_MATTERS_UPDATE_" + strconv.Itoa(sysUser.AdminId)
  1711. defer func() {
  1712. if deleteCache {
  1713. utils.Rc.Delete(cacheKey)
  1714. }
  1715. }()
  1716. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  1717. deleteCache = false
  1718. br.Msg = "系统处理中,请稍后重试!"
  1719. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
  1720. return
  1721. }
  1722. var req roadshow.UpdateMattersReq
  1723. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1724. if err != nil {
  1725. br.Msg = "参数解析异常!"
  1726. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1727. return
  1728. }
  1729. updateParams := make(map[string]interface{})
  1730. if req.RsMattersId <= 0 {
  1731. br.Msg = "参数错误!"
  1732. return
  1733. }
  1734. if req.StartDate == "" {
  1735. br.Msg = "请选择开始日期!"
  1736. return
  1737. } else {
  1738. updateParams["start_date"] = req.StartDate
  1739. }
  1740. if req.EndDate == "" {
  1741. br.Msg = "请选择结束日期!"
  1742. return
  1743. } else {
  1744. updateParams["end_date"] = req.EndDate
  1745. }
  1746. if req.StartTime == "" {
  1747. br.Msg = "请选择开始时间!"
  1748. return
  1749. } else {
  1750. updateParams["start_time"] = req.StartTime
  1751. }
  1752. if req.EndTime == "" {
  1753. br.Msg = "请选择结束时间!"
  1754. return
  1755. } else {
  1756. updateParams["end_time"] = req.EndTime
  1757. }
  1758. if req.StartWeek == "" {
  1759. br.Msg = "请选择周!"
  1760. return
  1761. } else {
  1762. updateParams["start_week"] = req.StartWeek
  1763. }
  1764. if req.EndWeek == "" {
  1765. br.Msg = "请选择周!"
  1766. return
  1767. } else {
  1768. updateParams["end_week"] = req.EndWeek
  1769. }
  1770. if req.MatterContent == "" {
  1771. br.Msg = "请选择研究员!"
  1772. return
  1773. } else {
  1774. updateParams["matter_content"] = req.MatterContent
  1775. }
  1776. req.EditReason = strings.TrimSpace(req.EditReason)
  1777. if req.EditReason == "" {
  1778. br.Msg = "请填写修改原因"
  1779. return
  1780. }
  1781. updateParams["edit_reason"] = req.EditReason
  1782. startDateTime := req.StartDate + " " + req.StartTime
  1783. endDateTime := req.EndDate + " " + req.EndTime
  1784. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  1785. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  1786. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  1787. br.Msg = "事项开始时间不能小于当前时间!"
  1788. return
  1789. }
  1790. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  1791. br.Msg = "事项结束时间不能小于当前时间!"
  1792. return
  1793. }
  1794. if startP.After(endP) || startP.Equal(endP) {
  1795. br.Msg = "事项开始时间应小于结束时间!"
  1796. return
  1797. }
  1798. // 结束后14天不可再编辑
  1799. endP = endP.AddDate(0, 0, 14)
  1800. if endP.Before(time.Now().Local()) {
  1801. br.Msg = "事项结束14天后不可再编辑"
  1802. return
  1803. }
  1804. matterItem, err := roadshow.GetMattersById(req.RsMattersId)
  1805. if err != nil {
  1806. br.Msg = "保存失败!"
  1807. br.Msg = "保存失败,GetMattersById,Err:" + err.Error()
  1808. return
  1809. }
  1810. // 是否为销售
  1811. sales := isSellerRole(sysUser.RoleTypeCode)
  1812. //校验事项时间冲突
  1813. {
  1814. if matterItem != nil && (matterItem.StartDate != req.StartDate ||
  1815. matterItem.StartTime != req.StartTime ||
  1816. matterItem.EndDate != req.EndDate ||
  1817. matterItem.EndTime != req.EndTime) {
  1818. matterCount, err := roadshowService.CheckMatters(startDateTime, endDateTime, sysUser.AdminId, matterItem.RsMattersId)
  1819. if err != nil {
  1820. br.Msg = "时间冲突检测失败!"
  1821. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!Err:" + err.Error()
  1822. return
  1823. }
  1824. if matterCount > 0 {
  1825. br.Msg = "时间冲突,已存在时间段内的事项!"
  1826. br.ErrMsg = "时间冲突检测失败-CheckMattersCount!"
  1827. br.IsSendEmail = false
  1828. return
  1829. }
  1830. }
  1831. }
  1832. if !sales {
  1833. //校验活动时间冲突--待接受
  1834. {
  1835. calendarCount, err := roadshowService.CheckCalendar(startDateTime, endDateTime, "1", sysUser.AdminId, 0)
  1836. if err != nil {
  1837. br.Msg = "时间冲突检测失败!"
  1838. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!Err:" + err.Error()
  1839. return
  1840. }
  1841. if calendarCount > 0 {
  1842. br.Msg = "当前时间与待处理的申请有冲突,请与相关销售沟通!"
  1843. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!"
  1844. br.IsSendEmail = false
  1845. return
  1846. }
  1847. }
  1848. //校验活动时间冲突--待接受
  1849. {
  1850. calendarCount, err := roadshowService.CheckCalendar(startDateTime, endDateTime, "2", sysUser.AdminId, 0)
  1851. if err != nil {
  1852. br.Msg = "时间冲突检测失败!"
  1853. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!Err:" + err.Error()
  1854. return
  1855. }
  1856. if calendarCount > 0 {
  1857. br.Msg = "时间冲突,已存在时间段内的活动!"
  1858. br.ErrMsg = "时间冲突检测失败-CheckCalendarResearcherCount!"
  1859. br.IsSendEmail = false
  1860. return
  1861. }
  1862. }
  1863. }
  1864. whereParams := make(map[string]interface{})
  1865. whereParams["rs_matters_id"] = req.RsMattersId
  1866. updateParams["modify_time"] = time.Now()
  1867. err = roadshow.UpdateRsMatters(whereParams, updateParams)
  1868. if err != nil {
  1869. br.Msg = "保存失败!"
  1870. br.ErrMsg = "保存失败!UpdateRsMatters:" + err.Error()
  1871. return
  1872. }
  1873. // 销售不做上海那边的处理
  1874. if !sales {
  1875. go roadshowService.UpdateSHCalendarByMatter(req)
  1876. }
  1877. br.Ret = 200
  1878. br.Success = true
  1879. br.Msg = "保存成功"
  1880. br.IsAddLog = true
  1881. }
  1882. // @Title 删除事项接口
  1883. // @Description 删除事项接口
  1884. // @Param request body roadshow.DeleteMattersReq true "type json string"
  1885. // @Success Ret=200 保存成功
  1886. // @router /matters/delete [post]
  1887. func (this *CalendarController) MattersDelete() {
  1888. br := new(models.BaseResponse).Init()
  1889. defer func() {
  1890. this.Data["json"] = br
  1891. this.ServeJSON()
  1892. }()
  1893. sysUser := this.SysUser
  1894. if sysUser == nil {
  1895. br.Msg = "请登录"
  1896. br.ErrMsg = "请登录,SysUser Is Empty"
  1897. br.Ret = 408
  1898. return
  1899. }
  1900. var req roadshow.DeleteMattersReq
  1901. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1902. if err != nil {
  1903. br.Msg = "参数解析异常!"
  1904. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1905. return
  1906. }
  1907. if req.RsMattersId <= 0 {
  1908. br.Msg = "参数错误!"
  1909. return
  1910. }
  1911. matters, e := roadshow.GetMattersById(req.RsMattersId)
  1912. if e != nil {
  1913. if e.Error() == utils.ErrNoRow() {
  1914. br.Msg = "事项已被删除, 请刷新页面"
  1915. return
  1916. }
  1917. br.Msg = "操作失败"
  1918. br.ErrMsg = "获取事项失败, Err: " + e.Error()
  1919. return
  1920. }
  1921. // 事项结束14天后不可再删除
  1922. t := fmt.Sprintf("%s %s", matters.EndDate, matters.EndTime)
  1923. ed, _ := time.ParseInLocation(utils.FormatDateTime, t, time.Local)
  1924. ed = ed.AddDate(0, 0, 14)
  1925. if ed.Before(time.Now().Local()) {
  1926. br.Msg = "事项结束14天后不可再删除"
  1927. return
  1928. }
  1929. err = roadshow.DeleteRsMatters(req.RsMattersId)
  1930. if err != nil {
  1931. br.Msg = "保存失败!"
  1932. br.ErrMsg = "保存失败!DeleteRsMatters:" + err.Error()
  1933. return
  1934. }
  1935. // 是否为销售
  1936. sales := isSellerRole(sysUser.RoleTypeCode)
  1937. // 删除上海的路演活动, 销售不同步
  1938. if !sales {
  1939. go roadshowService.DeleteSHMatter(req.RsMattersId)
  1940. }
  1941. br.Ret = 200
  1942. br.Success = true
  1943. br.Msg = "删除成功"
  1944. br.IsAddLog = true
  1945. }
  1946. // @Title 路演-研究员日历详情
  1947. // @Description 路演-研究员日历详情接口
  1948. // @Param StartDate query string true "开始日期"
  1949. // @Param EndDate query string true "结束日期日期"
  1950. // @Param ResearcherId query int true "研究员id"
  1951. // @Success 200 {object} roadshow.CalendarDetailResp
  1952. // @router /researcher/calendar/detail [get]
  1953. func (this *CalendarController) ResearcherCalendarDetail() {
  1954. br := new(models.BaseResponse).Init()
  1955. defer func() {
  1956. this.Data["json"] = br
  1957. this.ServeJSON()
  1958. }()
  1959. sysUser := this.SysUser
  1960. if sysUser == nil {
  1961. br.Msg = "请登录"
  1962. br.ErrMsg = "请登录,SysUser Is Empty"
  1963. br.Ret = 408
  1964. return
  1965. }
  1966. startDate := this.GetString("StartDate")
  1967. endDate := this.GetString("EndDate")
  1968. researcherId, _ := this.GetInt("ResearcherId")
  1969. if startDate == "" || endDate == "" {
  1970. br.Msg = "参数错误"
  1971. return
  1972. }
  1973. var condition string
  1974. var pars []interface{}
  1975. if researcherId <= 0 {
  1976. calendarList := make([]*roadshow.CalendarListView, 0)
  1977. matterList := make([]*roadshow.RsMatters, 0)
  1978. resp := new(roadshow.CalendarDetailResp)
  1979. resp.CalendarList = calendarList
  1980. resp.RsMattersList = matterList
  1981. br.Ret = 200
  1982. br.Success = true
  1983. br.Msg = "获取成功"
  1984. br.Data = resp
  1985. return
  1986. } else {
  1987. condition += ` AND b.researcher_id =? `
  1988. pars = append(pars, researcherId)
  1989. }
  1990. //同步上海数据
  1991. researcherInfo, err := system.GetSysAdminById(researcherId)
  1992. if err != nil {
  1993. br.Msg = "研究员异常"
  1994. return
  1995. }
  1996. go roadshowService.SyncCalendarFromShanghai(researcherInfo.Mobile, startDate, endDate)
  1997. condition += ` AND b.start_date>=?`
  1998. pars = append(pars, startDate)
  1999. condition += ` AND b.end_date<=?`
  2000. pars = append(pars, endDate)
  2001. condition += ` AND b.status IN(2) `
  2002. //pars = append(pars, 2)
  2003. calendarList, err := roadshow.GetCalendarDetailList(condition, pars)
  2004. if err != nil {
  2005. br.Msg = "获取数据失败"
  2006. br.ErrMsg = "获取数据失败,GetCalendarDetailList Err:" + err.Error()
  2007. return
  2008. }
  2009. matterList, err := roadshow.GetRsMattersList(startDate, endDate, researcherId)
  2010. if err != nil {
  2011. br.Msg = "获取数据失败"
  2012. br.ErrMsg = "获取数据失败,GetRsMattersList Err:" + err.Error()
  2013. return
  2014. }
  2015. if calendarList == nil {
  2016. calendarList = make([]*roadshow.CalendarListView, 0)
  2017. }
  2018. if matterList == nil {
  2019. matterList = make([]*roadshow.RsMatters, 0)
  2020. }
  2021. resp := new(roadshow.CalendarDetailResp)
  2022. resp.CalendarList = calendarList
  2023. resp.RsMattersList = matterList
  2024. br.Ret = 200
  2025. br.Success = true
  2026. br.Msg = "获取成功"
  2027. br.Data = resp
  2028. }
  2029. // @Title 路演-我的日历详情
  2030. // @Description 路演-我的日历详情接口
  2031. // @Param StartDate query string true "开始日期"
  2032. // @Param EndDate query string true "结束日期日期"
  2033. // @Success 200 {object} roadshow.CalendarDetailResp
  2034. // @router /my/calendar/detail [get]
  2035. func (this *CalendarController) MyCalendarDetail() {
  2036. br := new(models.BaseResponse).Init()
  2037. defer func() {
  2038. this.Data["json"] = br
  2039. this.ServeJSON()
  2040. }()
  2041. sysUser := this.SysUser
  2042. if sysUser == nil {
  2043. br.Msg = "请登录"
  2044. br.ErrMsg = "请登录,SysUser Is Empty"
  2045. br.Ret = 408
  2046. return
  2047. }
  2048. startDate := this.GetString("StartDate")
  2049. endDate := this.GetString("EndDate")
  2050. if startDate == "" || endDate == "" {
  2051. br.Msg = "参数错误"
  2052. return
  2053. }
  2054. var condition string
  2055. var pars []interface{}
  2056. roleTypeCode := sysUser.RoleTypeCode
  2057. fmt.Println("roleTypeCode:", roleTypeCode)
  2058. //销售
  2059. sales := isSellerRole(sysUser.RoleTypeCode)
  2060. if sales {
  2061. condition += ` AND a.sys_user_id=?`
  2062. pars = append(pars, sysUser.AdminId)
  2063. condition += ` AND a.activity_type IN('路演','公开会议') `
  2064. }
  2065. //研究员
  2066. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR ||
  2067. roleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR ||
  2068. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR ||
  2069. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN ||
  2070. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER {
  2071. condition += ` AND b.researcher_id=?`
  2072. pars = append(pars, sysUser.AdminId)
  2073. //同步上海数据(研究员才需要同步上海的数据)
  2074. researcherInfo, err := system.GetSysAdminById(sysUser.AdminId)
  2075. if err != nil {
  2076. br.Msg = "研究员异常"
  2077. return
  2078. }
  2079. go roadshowService.SyncCalendarFromShanghai(researcherInfo.Mobile, startDate, endDate)
  2080. }
  2081. //中级/普通/admin 管理员
  2082. if roleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  2083. condition += ` AND a.sys_user_id=?`
  2084. pars = append(pars, sysUser.AdminId)
  2085. }
  2086. condition += ` AND b.start_date>=?`
  2087. pars = append(pars, startDate)
  2088. condition += ` AND b.end_date<=?`
  2089. pars = append(pars, endDate)
  2090. condition += ` AND b.status IN(2) `
  2091. //pars = append(pars, 2)
  2092. fmt.Println("condition:" + condition)
  2093. calendarList, err := roadshow.GetCalendarDetailList(condition, pars)
  2094. if err != nil {
  2095. br.Msg = "获取数据失败"
  2096. br.ErrMsg = "获取数据失败,GetCalendarDetailList Err:" + err.Error()
  2097. return
  2098. }
  2099. matterList, err := roadshow.GetRsMattersList(startDate, endDate, sysUser.AdminId)
  2100. if err != nil {
  2101. br.Msg = "获取数据失败"
  2102. br.ErrMsg = "获取数据失败,GetRsMattersList Err:" + err.Error()
  2103. return
  2104. }
  2105. resp := new(roadshow.CalendarDetailResp)
  2106. resp.CalendarList = calendarList
  2107. resp.RsMattersList = matterList
  2108. br.Ret = 200
  2109. br.Success = true
  2110. br.Msg = "获取成功"
  2111. br.Data = resp
  2112. }
  2113. // @Title 事项列表
  2114. // @Description 事项列表接口
  2115. // @Param PageSize query int true "每页数据条数"
  2116. // @Param CurrentIndex query int true "当前页页码,从1开始"
  2117. // @Success 200 {object} roadshow.MattersListResp
  2118. // @router /matters/list [get]
  2119. func (this *CalendarController) MattersList() {
  2120. br := new(models.BaseResponse).Init()
  2121. defer func() {
  2122. this.Data["json"] = br
  2123. this.ServeJSON()
  2124. }()
  2125. sysUser := this.SysUser
  2126. if sysUser == nil {
  2127. br.Msg = "请登录"
  2128. br.ErrMsg = "请登录,SysUser Is Empty"
  2129. br.Ret = 408
  2130. return
  2131. }
  2132. pageSize, _ := this.GetInt("PageSize")
  2133. currentIndex, _ := this.GetInt("CurrentIndex")
  2134. var total int
  2135. page := paging.GetPaging(currentIndex, pageSize, total)
  2136. var startSize int
  2137. if pageSize <= 0 {
  2138. pageSize = utils.PageSize10
  2139. }
  2140. if currentIndex <= 0 {
  2141. currentIndex = 1
  2142. }
  2143. startSize = paging.StartIndex(currentIndex, pageSize)
  2144. var condition string
  2145. var pars []interface{}
  2146. condition += ` AND a.sys_user_id=?`
  2147. pars = append(pars, sysUser.AdminId)
  2148. resp := new(roadshow.MattersListResp)
  2149. total, err := roadshow.GetMattersListCount(condition, pars)
  2150. if err != nil && err.Error() != utils.ErrNoRow() {
  2151. br.Msg = "获取事项信息失败"
  2152. br.ErrMsg = "获取事项信息失败,GetMattersListCount,Err:" + err.Error()
  2153. return
  2154. }
  2155. page = paging.GetPaging(currentIndex, pageSize, total)
  2156. dataList, err := roadshow.GetMattersList(condition, pars, startSize, pageSize)
  2157. if err != nil {
  2158. br.Msg = "获取事项信息失败"
  2159. br.ErrMsg = "获取事项信息失败,GetMattersList,Err:" + err.Error()
  2160. return
  2161. }
  2162. // 按钮权限,超过14天无按钮
  2163. now := time.Now().Local()
  2164. for _, v := range dataList {
  2165. // 结束日期14天后无编辑删除按钮权限
  2166. t := fmt.Sprintf("%s %s", v.EndDate, v.EndTime)
  2167. ed, e := time.ParseInLocation(utils.FormatDateTime, t, time.Local)
  2168. if e != nil {
  2169. br.Msg = "事项结束日期有误"
  2170. br.ErrMsg = "事项结束日期有误, Err: " + e.Error()
  2171. return
  2172. }
  2173. ed = ed.AddDate(0, 0, 14)
  2174. if ed.Before(now) {
  2175. v.ButtonAuth.EditDisabled = true
  2176. v.ButtonAuth.RemoveDisabled = true
  2177. }
  2178. }
  2179. resp.Paging = page
  2180. resp.List = dataList
  2181. br.Ret = 200
  2182. br.Success = true
  2183. br.Msg = "获取成功"
  2184. br.Data = resp
  2185. }
  2186. func getTitle(activityType, roadshowType, activityCategory, roadshowPlatform, province, city string) string {
  2187. var title string
  2188. switch activityType {
  2189. case "内部会议":
  2190. title = "内部会议"
  2191. case "公开会议", "路演":
  2192. if roadshowType == "线上" {
  2193. title = roadshowType + activityType + roadshowPlatform
  2194. } else {
  2195. title = roadshowType + activityType + province + city
  2196. }
  2197. case "报告电话会":
  2198. title = activityCategory + "电话会"
  2199. }
  2200. return title
  2201. }
  2202. // @Title 路演-公开会议总览
  2203. // @Description 路演-公开会议总览接口
  2204. // @Param StartDate query string true "开始日期"
  2205. // @Param EndDate query string true "结束日期日期"
  2206. // @Success 200 {object} roadshow.PublicMeetingDetailResp
  2207. // @router /public_meeting/detail [get]
  2208. func (this *CalendarController) PublicMeetingDetail() {
  2209. br := new(models.BaseResponse).Init()
  2210. defer func() {
  2211. this.Data["json"] = br
  2212. this.ServeJSON()
  2213. }()
  2214. sysUser := this.SysUser
  2215. if sysUser == nil {
  2216. br.Msg = "请登录"
  2217. br.ErrMsg = "请登录,SysUser Is Empty"
  2218. br.Ret = 408
  2219. return
  2220. }
  2221. startDate := this.GetString("StartDate")
  2222. endDate := this.GetString("EndDate")
  2223. if startDate == "" || endDate == "" {
  2224. br.Msg = "参数错误"
  2225. return
  2226. }
  2227. var condition string
  2228. var pars []interface{}
  2229. roleTypeCode := sysUser.RoleTypeCode
  2230. fmt.Println("roleTypeCode:", roleTypeCode)
  2231. condition += ` AND a.activity_type = '公开会议' `
  2232. condition += ` AND b.start_date>=?`
  2233. pars = append(pars, startDate)
  2234. condition += ` AND b.end_date<=?`
  2235. pars = append(pars, endDate)
  2236. condition += ` AND b.status IN(2) `
  2237. //pars = append(pars, 2)
  2238. fmt.Println("condition:" + condition)
  2239. //calendarList, err := roadshow.GetCalendarDetailList(condition, pars)
  2240. calendarList, err := roadshow.GetPublicCalendarDetailList(condition, pars)
  2241. if err != nil {
  2242. br.Msg = "获取数据失败"
  2243. br.ErrMsg = "获取数据失败,GetCalendarDetailList Err:" + err.Error()
  2244. return
  2245. }
  2246. groupMap := make(map[string][]*roadshow.CalendarListView)
  2247. var groupArr []string
  2248. for _, v := range calendarList {
  2249. if findGroup, ok := groupMap[v.UnionCode]; !ok {
  2250. newGroup := make([]*roadshow.CalendarListView, 0)
  2251. newGroup = append(newGroup, v)
  2252. groupMap[v.UnionCode] = newGroup
  2253. groupArr = append(groupArr, v.UnionCode)
  2254. } else {
  2255. findGroup = append(findGroup, v)
  2256. groupMap[v.UnionCode] = findGroup
  2257. }
  2258. }
  2259. resp := new(roadshow.PublicMeetingDetailResp)
  2260. for _, v := range groupArr {
  2261. newGroup := new(roadshow.PublicMeetingGroup)
  2262. newGroup.UnionCode = v
  2263. calendarList := groupMap[v]
  2264. var minTimeStr, maxTimeStr string
  2265. var minTime, maxTime time.Time
  2266. for _, cv := range calendarList {
  2267. startTimeStr := cv.StartDate + " " + cv.StartTime
  2268. endTimeStr := cv.EndDate + " " + cv.EndTime
  2269. startTime, _ := time.ParseInLocation(utils.FormatDateTime, startTimeStr, time.Local)
  2270. endTime, _ := time.ParseInLocation(utils.FormatDateTime, endTimeStr, time.Local)
  2271. if minTime.IsZero() {
  2272. minTime = startTime
  2273. } else {
  2274. if startTime.Before(minTime) {
  2275. minTime = startTime
  2276. }
  2277. }
  2278. if maxTime.IsZero() {
  2279. maxTime = endTime
  2280. } else {
  2281. if endTime.After(maxTime) {
  2282. maxTime = endTime
  2283. }
  2284. }
  2285. }
  2286. minTimeStr = minTime.Format(utils.FormatDateTime)
  2287. maxTimeStr = maxTime.Format(utils.FormatDateTime)
  2288. newGroup.MinTime = minTimeStr
  2289. newGroup.MaxTime = maxTimeStr
  2290. newGroup.CalendarList = calendarList
  2291. resp.Group = append(resp.Group, newGroup)
  2292. }
  2293. br.Ret = 200
  2294. br.Success = true
  2295. br.Msg = "获取成功"
  2296. br.Data = resp
  2297. }
  2298. //func init() {
  2299. // fmt.Println("start")
  2300. // mobile := `13818594925`
  2301. // roadshowService.SyncCalendarFromShanghai(mobile, "", "2023-03-09")
  2302. // //err := roadshowService.SetPublicMeetingUnionCode()
  2303. // //if err != nil {
  2304. // // fmt.Println("SetPublicMeetingUnionCode Err:" + err.Error())
  2305. // //}
  2306. // fmt.Println("end")
  2307. //}
  2308. // SellerCalendarDetail
  2309. // @Title 路演-销售日历详情
  2310. // @Description 路演-销售日历详情
  2311. // @Param StartDate query string true "开始日期"
  2312. // @Param EndDate query string true "结束日期日期"
  2313. // @Param SellerId query int true "销售ID"
  2314. // @Success 200 {object} roadshow.CalendarDetailResp
  2315. // @router /seller/calendar/detail [get]
  2316. func (this *CalendarController) SellerCalendarDetail() {
  2317. br := new(models.BaseResponse).Init()
  2318. defer func() {
  2319. if br.ErrMsg == "" {
  2320. br.IsSendEmail = false
  2321. }
  2322. this.Data["json"] = br
  2323. this.ServeJSON()
  2324. }()
  2325. sysUser := this.SysUser
  2326. if sysUser == nil {
  2327. br.Msg = "请登录"
  2328. br.ErrMsg = "请登录,SysUser Is Empty"
  2329. br.Ret = 408
  2330. return
  2331. }
  2332. startDate := this.GetString("StartDate")
  2333. endDate := this.GetString("EndDate")
  2334. sellerId, _ := this.GetInt("SellerId")
  2335. if startDate == "" || endDate == "" {
  2336. br.Msg = "参数错误"
  2337. return
  2338. }
  2339. if sellerId <= 0 {
  2340. calendarList := make([]*roadshow.CalendarListView, 0)
  2341. matterList := make([]*roadshow.RsMatters, 0)
  2342. resp := new(roadshow.CalendarDetailResp)
  2343. resp.CalendarList = calendarList
  2344. resp.RsMattersList = matterList
  2345. br.Ret = 200
  2346. br.Success = true
  2347. br.Msg = "获取成功"
  2348. br.Data = resp
  2349. return
  2350. }
  2351. // 路演
  2352. condition := ` AND a.sys_user_id = ? AND b.start_date >= ? AND b.end_date <= ? AND b.status = 2`
  2353. pars := make([]interface{}, 0)
  2354. pars = append(pars, sellerId, startDate, endDate)
  2355. calendarList, err := roadshow.GetCalendarDetailList(condition, pars)
  2356. if err != nil {
  2357. br.Msg = "获取数据失败"
  2358. br.ErrMsg = "获取数据失败,GetCalendarDetailList Err:" + err.Error()
  2359. return
  2360. }
  2361. if calendarList == nil {
  2362. calendarList = make([]*roadshow.CalendarListView, 0)
  2363. }
  2364. // 事项
  2365. matterList, err := roadshow.GetRsMattersList(startDate, endDate, sellerId)
  2366. if err != nil {
  2367. br.Msg = "获取数据失败"
  2368. br.ErrMsg = "获取数据失败,GetRsMattersList Err:" + err.Error()
  2369. return
  2370. }
  2371. if matterList == nil {
  2372. matterList = make([]*roadshow.RsMatters, 0)
  2373. }
  2374. resp := new(roadshow.CalendarDetailResp)
  2375. resp.CalendarList = calendarList
  2376. resp.RsMattersList = matterList
  2377. br.Ret = 200
  2378. br.Success = true
  2379. br.Msg = "获取成功"
  2380. br.Data = resp
  2381. }
  2382. // isSellerRole 是否为销售角色
  2383. func isSellerRole(roleType string) (ok bool) {
  2384. sellerArr := []string{
  2385. utils.ROLE_TYPE_CODE_FICC_SELLER, utils.ROLE_TYPE_CODE_FICC_GROUP, utils.ROLE_TYPE_CODE_FICC_TEAM,
  2386. utils.ROLE_TYPE_CODE_RAI_SELLER, utils.ROLE_TYPE_CODE_RAI_GROUP,
  2387. }
  2388. if utils.InArrayByStr(sellerArr, roleType) {
  2389. ok = true
  2390. }
  2391. return
  2392. }