calendar.go 82 KB

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