calendar.go 66 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937
  1. package roadshow
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hongze_mobile_admin/controllers"
  7. "hongze/hongze_mobile_admin/models"
  8. "hongze/hongze_mobile_admin/models/roadshow"
  9. "hongze/hongze_mobile_admin/models/tables/admin"
  10. "hongze/hongze_mobile_admin/models/tables/english_company"
  11. "hongze/hongze_mobile_admin/services"
  12. "hongze/hongze_mobile_admin/services/rs"
  13. "hongze/hongze_mobile_admin/utils"
  14. "strconv"
  15. "strings"
  16. "time"
  17. )
  18. // 日历
  19. type CalendarController struct {
  20. controllers.BaseAuth
  21. }
  22. // @Title 新增路演活动接口
  23. // @Description 新增路演活动接口
  24. // @Param request body rs.AddActivityReq true "type json string"
  25. // @Success Ret=200 保存成功
  26. // @router /add [post]
  27. func (this *CalendarController) Add() {
  28. sysUser := this.AdminWx
  29. if sysUser == nil {
  30. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  31. return
  32. }
  33. deleteCache := true
  34. cacheKey := "CACHE_RS_ACTIVITY_WX_ADD_" + strconv.Itoa(sysUser.AdminId)
  35. defer func() {
  36. if deleteCache {
  37. utils.Rc.Delete(cacheKey)
  38. }
  39. }()
  40. if !utils.Rc.SetNX(cacheKey, 1, 5*time.Second) {
  41. deleteCache = false
  42. this.FailWithMessage("系统处理中,请稍后重试!", "系统处理中,请稍后重试!"+sysUser.RealName+";data:"+string(this.Ctx.Input.RequestBody))
  43. return
  44. }
  45. var req roadshow.AddActivityReq
  46. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  47. if err != nil {
  48. this.FailWithMessage("参数解析异常", "参数解析失败,Err:"+err.Error())
  49. return
  50. }
  51. if len(req.ResearcherList) <= 0 {
  52. this.FailWithMessage("请选择研究员!", "请选择研究员!")
  53. return
  54. }
  55. researcherMap := make(map[int]string)
  56. var checkIsAdd []string
  57. //var tipMsg string
  58. for _, v := range req.ResearcherList {
  59. if v.ResearcherId <= 0 {
  60. this.FailWithMessage("请选择研究员!", "请选择研究员!")
  61. return
  62. }
  63. if v.ResearcherName == "" {
  64. this.FailWithMessage("请选择研究员!", "请选择研究员!")
  65. return
  66. }
  67. if v.StartDate == "" {
  68. this.FailWithMessage("请选择开始日期!", "请选择开始日期!")
  69. return
  70. }
  71. if v.EndDate == "" {
  72. this.FailWithMessage("请选择结束日期!", "请选择结束日期!")
  73. return
  74. }
  75. if v.StartTime == "" {
  76. this.FailWithMessage("请选择开始时间!", "请选择开始时间!")
  77. return
  78. }
  79. if v.EndTime == "" {
  80. this.FailWithMessage("请选择结束时间!", "请选择结束时间!")
  81. return
  82. }
  83. if v.StartWeek == "" {
  84. this.FailWithMessage("请选择周!", "请选择周!")
  85. return
  86. }
  87. if v.EndWeek == "" {
  88. this.FailWithMessage("请选择周!", "请选择周!")
  89. return
  90. }
  91. startDateTime := v.StartDate + " " + v.StartTime
  92. endDateTime := v.EndDate + " " + v.EndTime
  93. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  94. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  95. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  96. this.FailWithMessage("活动开始时间不能小于当前时间!", "活动开始时间不能小于当前时间!")
  97. return
  98. }
  99. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  100. this.FailWithMessage("活动结束时间不能小于当前时间!", "活动结束时间不能小于当前时间!")
  101. return
  102. }
  103. if startP.After(endP) || startP.Equal(endP) {
  104. this.FailWithMessage("活动开始时间应小于结束时间!", "活动开始时间应小于结束时间!")
  105. return
  106. }
  107. if realName, ok := researcherMap[v.ResearcherId]; ok {
  108. this.FailWithMessage("研究员:"+realName+" 被重复选择", "研究员:"+realName+" 被重复选择")
  109. return
  110. }
  111. researcherMap[v.ResearcherId] = v.ResearcherName
  112. //同步上海数据
  113. researcherInfo, err := admin.GetAdminWxById(v.ResearcherId)
  114. if err != nil {
  115. this.FailWithMessage("研究员异常", "获取研究员异常,Err:"+err.Error())
  116. return
  117. }
  118. _ = rs.SyncCalendarFromShanghai(researcherInfo.Mobile, v.StartDate, v.EndDate)
  119. //校验事项时间冲突
  120. {
  121. matterCount, err := rs.CheckMatters(startDateTime, endDateTime, v.ResearcherId, 0)
  122. if err != nil {
  123. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckMattersCount!Err:"+err.Error())
  124. return
  125. }
  126. if matterCount > 0 {
  127. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  128. }
  129. }
  130. //校验活动时间冲突
  131. {
  132. calendarCount, err := rs.CheckCalendar(startDateTime, endDateTime, "1,2", v.ResearcherId, 0)
  133. if err != nil {
  134. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckCalendar!Err:"+err.Error())
  135. return
  136. }
  137. if calendarCount > 0 {
  138. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  139. }
  140. }
  141. }
  142. if len(checkIsAdd) > 0 {
  143. this.FailWithMessage(strings.Join(checkIsAdd, ",")+" 时间已被占用!", "时间冲突检测失败-CheckMattersCount!")
  144. return
  145. }
  146. rsCalendar := new(roadshow.RsCalendar)
  147. rsCalendar.SysUserId = sysUser.AdminId
  148. rsCalendar.SysUserRealName = sysUser.RealName
  149. rsCalendar.ActivityType = req.ActivityType
  150. rsCalendar.RoadshowType = req.RoadshowType
  151. rsCalendar.RoadshowPlatform = req.RoadshowPlatform
  152. rsCalendar.CompanyId = req.CompanyId
  153. rsCalendar.CompanyName = req.CompanyName
  154. rsCalendar.Province = req.Province
  155. rsCalendar.ProvinceCode = req.ProvinceCode
  156. rsCalendar.City = req.City
  157. rsCalendar.CityCode = req.CityCode
  158. rsCalendar.Theme = req.Theme
  159. rsCalendar.CooperationName = req.CooperationName
  160. rsCalendar.CreateTime = time.Now()
  161. rsCalendar.ModifyTime = time.Now()
  162. rsCalendar.ActivityCategory = req.ActivityCategory
  163. rsCalendar.Source = 0
  164. rsCalendar.EnglishCompany = req.EnglishCompany
  165. rsCalendar.Title = getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City)
  166. rsCalendarId, err := roadshow.AddRsCalendar(rsCalendar)
  167. if err != nil {
  168. this.FailWithMessage("保存失败", "保存日历活动信息失败!Err:"+err.Error())
  169. return
  170. }
  171. //if researcherId != 99 {
  172. for k, v := range req.ResearcherList {
  173. researcher := new(roadshow.RsCalendarResearcher)
  174. researcher.RsCalendarId = int(rsCalendarId)
  175. researcher.ResearcherId = v.ResearcherId
  176. researcher.ResearcherName = v.ResearcherName
  177. researcher.StartDate = v.StartDate
  178. researcher.EndDate = v.EndDate
  179. researcher.StartTime = v.StartTime
  180. researcher.EndTime = v.EndTime
  181. researcher.StartWeek = v.StartWeek
  182. researcher.EndWeek = v.EndWeek
  183. researcher.CreateTime = time.Now()
  184. researcher.ModifyTime = time.Now()
  185. researcher.ResearcherSort = k + 1
  186. if req.ActivityType == "路演" || req.ActivityType == "公开会议" {
  187. researcher.Status = 1
  188. } else {
  189. researcher.Status = 2
  190. }
  191. rsCalendarResearcherId, err := roadshow.AddRsCalendarResearcher(researcher)
  192. if err != nil {
  193. this.FailWithMessage("保存失败", "保存日历活动-研究员信息失败!Err:"+err.Error())
  194. return
  195. }
  196. rsCalendar.RsCalendarId = int(rsCalendarId)
  197. researcher.RsCalendarResearcherId = int(rsCalendarResearcherId)
  198. go rs.CalendarToSH(*rsCalendar, *researcher)
  199. //模板消息通知
  200. {
  201. go func(researcherId, tmpRsCalendarId, tmpRsCalendarResearcherId int) {
  202. var wxAppPath string
  203. sysAdmin, _ := admin.GetAdminWxById(researcherId)
  204. if sysAdmin != nil {
  205. if req.ActivityType == "路演" || req.ActivityType == "公开会议" {
  206. wxAppPath = "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(tmpRsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherId)
  207. first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  208. keyword1 := sysUser.RealName
  209. keyword2 := "--"
  210. //keyword3 := time.Now().Format(utils.FormatDateTime)
  211. startDateSub := v.StartDate[5:]
  212. startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  213. keyword3 := startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5]
  214. var keyword4 string
  215. if req.ActivityType == "路演" {
  216. keyword4 = req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  217. } else {
  218. keyword4 = req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  219. }
  220. remark := "请尽快完成审批"
  221. //wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(int(rsCalendarId)) + "&RsCalendarResearcherId=" + strconv.Itoa(int(rsCalendarResearcherId))
  222. if sysAdmin.OpenId != "" {
  223. go services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, sysAdmin.Mobile)
  224. }
  225. } else {
  226. wxAppPath = ""
  227. first := sysUser.RealName + "为你添加了一场【" + req.ActivityType + "】"
  228. startDate := researcher.StartDate[5:]
  229. startDate = strings.Replace(startDate, "-", ".", -1)
  230. keyword1 := startDate + "(" + researcher.StartWeek + ")" + " " + researcher.StartTime[:5] + "-" + researcher.EndTime[:5]
  231. keyword2 := sysUser.RealName + "为你添加了【" + req.ActivityType + "】"
  232. if sysAdmin.OpenId != "" {
  233. go services.SendWxMsgWithRoadshowDeleteNotice(first, keyword1, keyword2, "", wxAppPath, sysAdmin.Mobile)
  234. }
  235. }
  236. }
  237. }(v.ResearcherId, int(rsCalendarId), int(rsCalendarResearcherId))
  238. }
  239. }
  240. this.OkDetailed(nil, "保存成功")
  241. }
  242. // CalendarList
  243. // @Title 我的日历列表
  244. // @Description 我的日历列表接口
  245. // @Param PageSize query int true "每页数据条数"
  246. // @Param CurrentIndex query int true "当前页页码,从1开始"
  247. // @Param Status query int true "1:待接受,2:包含,已接受,已拒绝,已删除,已撤回,已结束"
  248. // @Success 200 {object} rs.CalendarListResp
  249. // @router /calendar/list [get]
  250. func (this *CalendarController) CalendarList() {
  251. adminItem := this.AdminWx
  252. status, _ := this.GetInt("Status")
  253. pageSize, _ := this.GetInt("PageSize")
  254. currentIndex, _ := this.GetInt("CurrentIndex")
  255. var total int
  256. page := paging.GetPaging(currentIndex, pageSize, total)
  257. var startSize int
  258. if pageSize <= 0 {
  259. pageSize = utils.PageSize10
  260. }
  261. if currentIndex <= 0 {
  262. currentIndex = 1
  263. }
  264. startSize = paging.StartIndex(currentIndex, pageSize)
  265. var condition string
  266. var pars []interface{}
  267. roleTypeCode := adminItem.RoleTypeCode
  268. //销售
  269. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER ||
  270. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER ||
  271. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_GROUP ||
  272. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  273. condition += ` AND a.sys_user_id=?`
  274. pars = append(pars, adminItem.AdminId)
  275. }
  276. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR ||
  277. roleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR ||
  278. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR ||
  279. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_DEPARTMENT ||
  280. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_DEPARTMENT ||
  281. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN ||
  282. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN {
  283. condition += ` AND b.researcher_id=?`
  284. pars = append(pars, adminItem.AdminId)
  285. }
  286. if roleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  287. condition += ` AND a.sys_user_id=?`
  288. pars = append(pars, adminItem.AdminId)
  289. }
  290. condition += ` AND a.activity_type IN('路演','公开会议') `
  291. if status == 1 {
  292. condition += ` AND b.status=?`
  293. pars = append(pars, 1)
  294. } else {
  295. condition += ` AND b.status IN(2,3,4,5,6)`
  296. }
  297. resp := new(roadshow.CalendarListResp)
  298. total, err := roadshow.GetCalendarListCount(condition, pars)
  299. if err != nil && err.Error() != utils.ErrNoRow() {
  300. this.FailWithMessage("获取信息失败!", "获取数据总数失败,GetCalendarListCount,Err:"+err.Error())
  301. return
  302. }
  303. page = paging.GetPaging(currentIndex, pageSize, total)
  304. dataList, err := roadshow.GetCalendarList(condition, pars, status, startSize, pageSize)
  305. if err != nil {
  306. this.FailWithMessage("获取信息失败!", "获取数据失败,GetCalendarList,Err:"+err.Error())
  307. return
  308. }
  309. // 英文客户的国家以及点击量
  310. englishIds := make([]int, 0)
  311. for i := range dataList {
  312. if dataList[i].EnglishCompany == 1 {
  313. englishIds = append(englishIds, dataList[i].CompanyId)
  314. }
  315. }
  316. englishMap := make(map[int]*english_company.EnglishCompany)
  317. if len(englishIds) > 0 {
  318. englishCond := ` AND company_id IN (` + utils.GetOrmInReplace(len(englishIds)) + `)`
  319. englishPars := make([]interface{}, 0)
  320. englishPars = append(englishPars, englishIds)
  321. englishList, e := english_company.GetEnglishCompanyList(englishCond, englishPars, "")
  322. if e != nil {
  323. this.FailWithMessage("获取英文客户失败!", "获取英文客户失败, Err:"+err.Error())
  324. return
  325. }
  326. for i := range englishList {
  327. englishMap[englishList[i].CompanyId] = englishList[i]
  328. }
  329. }
  330. for i := range dataList {
  331. if dataList[i].EnglishCompany == 1 {
  332. en := englishMap[dataList[i].CompanyId]
  333. if en != nil {
  334. dataList[i].EnglishCountry = en.Country
  335. dataList[i].EnglishViewTotal = en.ViewTotal
  336. }
  337. }
  338. }
  339. resp.Paging = page
  340. resp.List = dataList
  341. this.OkDetailed(resp, "获取成功")
  342. }
  343. // CalendarList
  344. // @Title 内部会议和报告电话会日历列表
  345. // @Description 内部会议和报告电话会日历列表
  346. // @Param PageSize query int true "每页数据条数"
  347. // @Param CurrentIndex query int true "当前页页码,从1开始"
  348. // @Param CalendarType query int true "1:内部会议,2:报告电话会"
  349. // @Success 200 {object} rs.CalendarListResp
  350. // @router /calendar/type/list [get]
  351. func (this *CalendarController) CalendarTypeList() {
  352. adminItem := this.AdminWx
  353. pageSize, _ := this.GetInt("PageSize")
  354. currentIndex, _ := this.GetInt("CurrentIndex")
  355. calendarType, _ := this.GetInt("CalendarType")
  356. var total int
  357. page := paging.GetPaging(currentIndex, pageSize, total)
  358. var startSize int
  359. if pageSize <= 0 {
  360. pageSize = utils.PageSize10
  361. }
  362. if currentIndex <= 0 {
  363. currentIndex = 1
  364. }
  365. startSize = paging.StartIndex(currentIndex, pageSize)
  366. var condition string
  367. var pars []interface{}
  368. if calendarType == 1 {
  369. condition += ` AND a.activity_type='内部会议' `
  370. condition += ` AND a.sys_user_id=?`
  371. pars = append(pars, adminItem.AdminId)
  372. }
  373. if calendarType == 2 {
  374. condition += ` AND a.activity_type='报告电话会' `
  375. }
  376. resp := new(roadshow.CalendarListResp)
  377. total, err := roadshow.GetCalendarTypeListCount(condition, pars)
  378. if err != nil && err.Error() != utils.ErrNoRow() {
  379. this.FailWithMessage("获取信息失败!", "获取数据总数失败,GetCalendarTypeListCount,Err:"+err.Error())
  380. return
  381. }
  382. page = paging.GetPaging(currentIndex, pageSize, total)
  383. dataList, err := roadshow.GetCalendarTypeList(condition, pars, startSize, pageSize)
  384. if err != nil {
  385. this.FailWithMessage("获取信息失败!", "获取数据失败,GetCalendarTypeList,Err:"+err.Error())
  386. return
  387. }
  388. resp.Paging = page
  389. resp.List = dataList
  390. this.OkDetailed(resp, "获取成功")
  391. }
  392. // Accept
  393. // @Description 接受路演活动接口
  394. // @Param request body rs.AcceptReq true "type json string"
  395. // @Success Ret=200 保存成功
  396. // @router /accept [post]
  397. func (this *CalendarController) Accept() {
  398. //adminItem:=this.AdminWx
  399. var req roadshow.AcceptReq
  400. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  401. if err != nil {
  402. this.FailWithMessage("参数解析失败!", "参数解析失败,Err:"+err.Error())
  403. return
  404. }
  405. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  406. this.FailWithMessage("参数错误!", "RsCalendarId 或 RsCalendarResearcherId 小于等于0:")
  407. return
  408. }
  409. rsCalendar, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  410. if err != nil {
  411. this.FailWithMessage("获取数据失败!", "GetRsCalendarById Err:"+err.Error())
  412. return
  413. }
  414. rsCalendarResearcher, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  415. if err != nil {
  416. this.FailWithMessage("获取数据失败!", "GetRsCalendarResearcherById Err:"+err.Error())
  417. return
  418. }
  419. if rsCalendarResearcher.Status == 2 {
  420. this.FailWithMessage("已接受,不可重复操作!", "")
  421. return
  422. } else if rsCalendarResearcher.Status == 3 {
  423. this.FailWithMessage("已拒绝,不可进行接受操作!", "")
  424. return
  425. } else if rsCalendarResearcher.Status == 4 {
  426. this.FailWithMessage("已删除,不可进行接受操作!", "")
  427. return
  428. } else if rsCalendarResearcher.Status == 5 {
  429. this.FailWithMessage("已撤回,不可进行接受操作!", "")
  430. return
  431. }
  432. whereParams := make(map[string]interface{})
  433. updateParams := make(map[string]interface{})
  434. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  435. whereParams["rs_calendar_id"] = req.RsCalendarId
  436. updateParams["status"] = 2
  437. updateParams["modify_time"] = time.Now()
  438. updateParams["approve_time"] = time.Now()
  439. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  440. if err != nil {
  441. this.FailWithMessage("获取数据失败!", "UpdateCalendarResearcher Err:"+err.Error())
  442. return
  443. }
  444. //模板消息通知
  445. {
  446. if rsCalendar != nil {
  447. sysAdmin, _ := admin.GetAdminById(rsCalendar.SysUserId)
  448. first := "【" + this.AdminWx.RealName + "】接受了你的【" + rsCalendar.ActivityType + "】申请"
  449. var keyword1, keyword2, keyword3, keyword4, keyword5 string
  450. keyword1 = rsCalendar.CompanyName + "(" + rsCalendar.RoadshowType + rsCalendar.ActivityType + ")"
  451. keyword2 = rsCalendar.ActivityType
  452. keyword4 = `【` + this.AdminWx.RealName + `】已接受`
  453. remark := ""
  454. if sysAdmin.Mobile != "" {
  455. go services.SendWxMsgWithRoadshowDetailResult(first, keyword1, keyword2, keyword3, keyword4, keyword5, remark, sysAdmin.Mobile, "", "")
  456. }
  457. }
  458. }
  459. this.OkDetailed(nil, "保存成功")
  460. }
  461. // @Title 拒绝路演活动接口
  462. // @Description 拒绝路演活动接口
  463. // @Param request body rs.RefuseReq true "type json string"
  464. // @Success Ret=200 保存成功
  465. // @router /refuse [post]
  466. func (this *CalendarController) Refuse() {
  467. //adminItem:=this.AdminWx
  468. var req roadshow.RefuseReq
  469. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  470. if err != nil {
  471. this.FailWithMessage("参数解析失败!", "参数解析失败,Err:"+err.Error())
  472. return
  473. }
  474. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  475. this.FailWithMessage("参数错误!", "参数错误!RsCalendarId:"+strconv.Itoa(req.RsCalendarId)+";RsCalendarResearcherId:"+strconv.Itoa(req.RsCalendarResearcherId))
  476. return
  477. }
  478. rsCalendar, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  479. if err != nil {
  480. this.FailWithMessage("获取数据失败!", "GetRsCalendarById,Err:"+err.Error())
  481. return
  482. }
  483. rsCalendarResearcher, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  484. if err != nil {
  485. this.FailWithMessage("获取数据失败!", "GetRsCalendarResearcherById,Err:"+err.Error())
  486. return
  487. }
  488. if rsCalendarResearcher.Status == 2 {
  489. this.FailWithMessage("已接受,不可进行拒绝操作!", "")
  490. return
  491. } else if rsCalendarResearcher.Status == 3 {
  492. this.FailWithMessage("已拒绝,不可进行重复操作!", "")
  493. return
  494. } else if rsCalendarResearcher.Status == 4 {
  495. this.FailWithMessage("已删除,不可进行拒绝操作!", "")
  496. return
  497. } else if rsCalendarResearcher.Status == 5 {
  498. this.FailWithMessage("已撤回,不可进行拒绝操作!", "")
  499. return
  500. }
  501. whereParams := make(map[string]interface{})
  502. updateParams := make(map[string]interface{})
  503. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  504. whereParams["rs_calendar_id"] = req.RsCalendarId
  505. updateParams["status"] = 3
  506. updateParams["refuse_reason"] = req.RefuseReason
  507. updateParams["refuse_time"] = time.Now()
  508. updateParams["modify_time"] = time.Now()
  509. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  510. if err != nil {
  511. this.FailWithMessage("保存失败", "保存失败!UpdateCalendarResearcher:"+err.Error())
  512. return
  513. }
  514. // 拒绝后需要删除上海的日程
  515. go rs.DeleteSHCalendar(req.RsCalendarResearcherId)
  516. //模板消息通知
  517. {
  518. if rsCalendar != nil {
  519. sysAdmin, _ := admin.GetAdminById(rsCalendar.SysUserId)
  520. first := "【" + this.AdminWx.RealName + "】拒绝了你的【" + rsCalendar.ActivityType + "】申请"
  521. var keyword1, keyword2, keyword3, keyword4, keyword5 string
  522. keyword1 = rsCalendar.CompanyName + "(" + rsCalendar.RoadshowType + rsCalendar.ActivityType + ")"
  523. keyword2 = rsCalendar.ActivityType
  524. keyword4 = `【` + this.AdminWx.RealName + `】已拒绝`
  525. keyword5 = req.RefuseReason
  526. remark := req.RefuseReason
  527. if sysAdmin.Mobile != "" {
  528. go services.SendWxMsgWithRoadshowDetailResult(first, keyword1, keyword2, keyword3, keyword4, keyword5, remark, sysAdmin.Mobile, "", "")
  529. }
  530. }
  531. }
  532. this.OkDetailed(nil, "保存成功")
  533. }
  534. // @Title 日历详情
  535. // @Description 日历详情接口
  536. // @Param RsCalendarId query int true "路演活动id"
  537. // @Param RsCalendarResearcherId query int true "活动研究员id"
  538. // @Success 200 {object} rs.CalendarDetailResp
  539. // @router /calendar/detail [get]
  540. func (this *CalendarController) CalendarDetail() {
  541. //adminItem:=this.AdminWx
  542. //roleTypeCode := adminItem.RoleTypeCode
  543. rsCalendarId, _ := this.GetInt("RsCalendarId")
  544. rsCalendarResearcherId, _ := this.GetInt("RsCalendarResearcherId")
  545. if rsCalendarId <= 0 || rsCalendarResearcherId <= 0 {
  546. this.FailWithMessage("参数错误", "rsCalendarId 或 rsCalendarResearcherId")
  547. return
  548. }
  549. calendarItem, err := roadshow.GetRsCalendarById(rsCalendarId)
  550. if err != nil {
  551. this.FailWithMessage("获取数据失败", "获取数据失败!GetRsCalendarById:"+err.Error())
  552. return
  553. }
  554. rsCalendarResearcherItem, err := roadshow.GetRsCalendarResearcherById(rsCalendarResearcherId)
  555. if err != nil {
  556. this.FailWithMessage("获取数据失败", "获取数据失败!GetRsCalendarResearcherById:"+err.Error())
  557. return
  558. }
  559. companyDetailView := new(roadshow.CompanyDetailView)
  560. if calendarItem != nil && calendarItem.CompanyId > 0 {
  561. // 中文客户
  562. if calendarItem.EnglishCompany == 0 {
  563. companyId := calendarItem.CompanyId
  564. companyProductItem, err := models.GetCompanyProductByCompanyIdAndProductId(companyId, 1)
  565. if err != nil {
  566. this.FailWithMessage("获取数据失败", "获取数据失败!GetCompanyProductByCompanyIdAndProductId:"+err.Error())
  567. return
  568. }
  569. permissionList, err := models.GetCompanyProductReportPermissionList(companyId, 1)
  570. if err != nil {
  571. this.FailWithMessage("搜索客户权限失败", "搜索客户权限失败!GetCompanyProductReportPermissionList:"+err.Error())
  572. return
  573. }
  574. var permissionArr []string
  575. for _, v := range permissionList {
  576. permissionArr = append(permissionArr, v.PermissionName)
  577. }
  578. readNum := companyProductItem.ViewTotal
  579. companyDetailView.CompanyId = companyProductItem.CompanyId
  580. companyDetailView.CompanyName = companyProductItem.CompanyName
  581. companyDetailView.Status = companyProductItem.Status
  582. companyDetailView.IndustryId = companyProductItem.IndustryId
  583. companyDetailView.IndustryName = companyProductItem.IndustryName
  584. companyDetailView.PermissionName = strings.Join(permissionArr, "/")
  585. companyDetailView.ReportReadTotal = readNum //ficc报告-累计阅读次数
  586. }
  587. // 英文客户
  588. if calendarItem.EnglishCompany == 1 {
  589. enItem, e := english_company.GetEnglishCompanyById(calendarItem.CompanyId)
  590. if e != nil {
  591. this.FailWithMessage("搜索客户失败!", "获取英文客户详情失败, GetEnglishCompanyById Err: "+e.Error())
  592. return
  593. }
  594. companyDetailView.CompanyId = enItem.CompanyId
  595. companyDetailView.CompanyName = enItem.CompanyName
  596. companyDetailView.Status = "正常"
  597. companyDetailView.EnglishCompany = 1
  598. companyDetailView.EnglishCountry = enItem.Country
  599. companyDetailView.EnglishViewTotal = enItem.ViewTotal
  600. }
  601. }
  602. resp := new(roadshow.CalendarDetailResp)
  603. resp.RsCalendarItem = calendarItem
  604. resp.RsCalendarResearcherItem = rsCalendarResearcherItem
  605. resp.CompanyDetail = companyDetailView
  606. this.OkDetailed(resp, "获取成功")
  607. }
  608. // @Title 事项列表
  609. // @Description 事项列表接口
  610. // @Param PageSize query int true "每页数据条数"
  611. // @Param CurrentIndex query int true "当前页页码,从1开始"
  612. // @Success 200 {object} rs.MattersListResp
  613. // @router /matters/list [get]
  614. func (this *CalendarController) MattersList() {
  615. sysUser := this.AdminWx
  616. if sysUser == nil {
  617. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  618. return
  619. }
  620. pageSize, _ := this.GetInt("PageSize")
  621. currentIndex, _ := this.GetInt("CurrentIndex")
  622. var total int
  623. page := paging.GetPaging(currentIndex, pageSize, total)
  624. var startSize int
  625. if pageSize <= 0 {
  626. pageSize = utils.PageSize10
  627. }
  628. if currentIndex <= 0 {
  629. currentIndex = 1
  630. }
  631. startSize = paging.StartIndex(currentIndex, pageSize)
  632. var condition string
  633. var pars []interface{}
  634. condition += ` AND a.sys_user_id=?`
  635. pars = append(pars, sysUser.AdminId)
  636. resp := new(roadshow.MattersListResp)
  637. total, err := roadshow.GetMattersListCount(condition, pars)
  638. if err != nil && err.Error() != utils.ErrNoRow() {
  639. this.FailWithMessage("获取事项信息失败", "获取事项信息失败,GetMattersListCount,Err:"+err.Error())
  640. return
  641. }
  642. page = paging.GetPaging(currentIndex, pageSize, total)
  643. dataList, err := roadshow.GetMattersList(condition, pars, startSize, pageSize)
  644. if err != nil {
  645. this.FailWithMessage("获取事项信息失败", "获取事项信息失败,GetMattersList,Err:"+err.Error())
  646. return
  647. }
  648. resp.Paging = page
  649. resp.List = dataList
  650. this.OkDetailed(resp, "获取成功")
  651. }
  652. // @Title 新增事项接口
  653. // @Description 新增事项接口
  654. // @Param request body rs.AddMattersReq true "type json string"
  655. // @Success Ret=200 保存成功
  656. // @router /matters/add [post]
  657. func (this *CalendarController) MattersAdd() {
  658. sysUser := this.AdminWx
  659. if sysUser == nil {
  660. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  661. return
  662. }
  663. deleteCache := true
  664. cacheKey := "CACHE_RS_MATTERS_ADD_" + strconv.Itoa(sysUser.AdminId)
  665. defer func() {
  666. if deleteCache {
  667. utils.Rc.Delete(cacheKey)
  668. }
  669. }()
  670. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  671. deleteCache = false
  672. this.FailWithMessage("系统处理中,请稍后重试!", "系统处理中,请稍后重试!"+sysUser.RealName+";data:"+string(this.Ctx.Input.RequestBody))
  673. return
  674. }
  675. var req roadshow.AddMattersReq
  676. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  677. if err != nil {
  678. this.FailWithMessage("参数解析异常", "参数解析失败,Err:"+err.Error())
  679. return
  680. }
  681. if req.StartDate == "" {
  682. this.FailWithMessage("请选择开始日期!", "请选择开始日期!")
  683. return
  684. }
  685. if req.EndDate == "" {
  686. this.FailWithMessage("请选择结束日期!", "请选择结束日期!")
  687. return
  688. }
  689. if req.StartTime == "" {
  690. this.FailWithMessage("请选择开始时间!", "请选择开始时间!")
  691. return
  692. }
  693. if req.EndTime == "" {
  694. this.FailWithMessage("请选择结束时间!", "请选择结束时间!")
  695. return
  696. }
  697. if req.StartWeek == "" {
  698. this.FailWithMessage("请选择周!", "请选择周!")
  699. return
  700. }
  701. if req.EndWeek == "" {
  702. this.FailWithMessage("请选择周!", "请选择周!")
  703. return
  704. }
  705. if req.MatterContent == "" {
  706. this.FailWithMessage("请选择研究员!", "请选择研究员!")
  707. return
  708. }
  709. startDateTime := req.StartDate + " " + req.StartTime
  710. endDateTime := req.EndDate + " " + req.EndTime
  711. //校验事项时间冲突
  712. {
  713. matterCount, err := rs.CheckMatters(startDateTime, endDateTime, sysUser.AdminId, 0)
  714. if err != nil {
  715. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckMattersCount!Err:"+err.Error())
  716. return
  717. }
  718. if matterCount > 0 {
  719. this.FailWithMessage("当前时间已被占用!", "时间冲突检测失败-CheckMattersCount!")
  720. return
  721. }
  722. }
  723. //校验活动时间冲突--待接受
  724. {
  725. calendarCount, err := rs.CheckCalendar(startDateTime, endDateTime, "1", sysUser.AdminId, 0)
  726. if err != nil {
  727. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckCalendarResearcherCount!Err:"+err.Error())
  728. return
  729. }
  730. if calendarCount > 0 {
  731. this.FailWithMessage("当前时间与待处理的申请有冲突,请与相关销售沟通!", "时间冲突检测失败-CheckCalendarResearcherCount!")
  732. return
  733. }
  734. }
  735. //校验活动时间冲突--已接受
  736. {
  737. calendarCount, err := rs.CheckCalendar(startDateTime, endDateTime, "2", sysUser.AdminId, 0)
  738. if err != nil {
  739. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckCalendarResearcherCount!Err:"+err.Error())
  740. return
  741. }
  742. if calendarCount > 0 {
  743. this.FailWithMessage("当前时间已被占用!", "时间冲突检测失败-CheckCalendarResearcherCount!")
  744. return
  745. }
  746. }
  747. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  748. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  749. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  750. this.FailWithMessage("事项开始时间不能小于当前时间!", "事项开始时间不能小于当前时间!")
  751. return
  752. }
  753. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  754. this.FailWithMessage("事项结束时间不能小于当前时间!", "事项结束时间不能小于当前时间!")
  755. return
  756. }
  757. if startP.After(endP) || startP.Equal(endP) {
  758. this.FailWithMessage("事项开始时间应小于结束时间!", "事项开始时间应小于结束时间!")
  759. return
  760. }
  761. item := new(roadshow.RsMatters)
  762. item.SysUserId = sysUser.AdminId
  763. item.SysUserRealName = sysUser.RealName
  764. item.StartDate = req.StartDate
  765. item.EndDate = req.EndDate
  766. item.StartTime = req.StartTime
  767. item.EndTime = req.EndTime
  768. item.StartWeek = req.StartWeek
  769. item.EndWeek = req.EndWeek
  770. item.MatterContent = req.MatterContent
  771. item.Status = 1
  772. item.CreateTime = time.Now()
  773. item.ModifyTime = time.Now()
  774. id, err := roadshow.AddRsMatters(item)
  775. if err != nil {
  776. this.FailWithMessage("保存失败!", "保存失败,AddRsMatters Err:"+err.Error())
  777. return
  778. }
  779. item.RsMattersId = int(id)
  780. go rs.MatterToSH(*item)
  781. this.OkDetailed(nil, "保存成功")
  782. }
  783. // @Title 修改事项接口
  784. // @Description 修改事项接口
  785. // @Param request body rs.UpdateMattersReq true "type json string"
  786. // @Success Ret=200 保存成功
  787. // @router /matters/update [post]
  788. func (this *CalendarController) MattersUpdate() {
  789. sysUser := this.AdminWx
  790. if sysUser == nil {
  791. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  792. return
  793. }
  794. deleteCache := true
  795. cacheKey := "CACHE_RS_MATTERS_UPDATE_" + strconv.Itoa(sysUser.AdminId)
  796. defer func() {
  797. if deleteCache {
  798. utils.Rc.Delete(cacheKey)
  799. }
  800. }()
  801. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  802. deleteCache = false
  803. this.FailWithMessage("系统处理中,请稍后重试!", "系统处理中,请稍后重试!")
  804. return
  805. }
  806. var req roadshow.UpdateMattersReq
  807. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  808. if err != nil {
  809. this.FailWithMessage("参数解析失败!", "参数解析失败,Err:"+err.Error())
  810. return
  811. }
  812. updateParams := make(map[string]interface{})
  813. if req.RsMattersId <= 0 {
  814. this.FailWithMessage("参数错误!", "参数错误")
  815. return
  816. }
  817. if req.StartDate == "" {
  818. this.FailWithMessage("请选择开始日期!", "请选择开始日期")
  819. return
  820. } else {
  821. updateParams["start_date"] = req.StartDate
  822. }
  823. if req.EndDate == "" {
  824. this.FailWithMessage("请选择结束日期!", "请选择结束日期")
  825. return
  826. } else {
  827. updateParams["end_date"] = req.EndDate
  828. }
  829. if req.StartTime == "" {
  830. this.FailWithMessage("请选择开始时间!", "请选择开始时间")
  831. return
  832. } else {
  833. updateParams["start_time"] = req.StartTime
  834. }
  835. if req.EndTime == "" {
  836. this.FailWithMessage("请选择结束时间!", "请选择结束时间")
  837. return
  838. } else {
  839. updateParams["end_time"] = req.EndTime
  840. }
  841. if req.StartWeek == "" {
  842. this.FailWithMessage("请选择周!", "请选择周")
  843. return
  844. } else {
  845. updateParams["start_week"] = req.StartWeek
  846. }
  847. if req.EndWeek == "" {
  848. this.FailWithMessage("请选择周!", "请选择周")
  849. return
  850. } else {
  851. updateParams["end_week"] = req.EndWeek
  852. }
  853. if req.MatterContent == "" {
  854. this.FailWithMessage("请选择研究员!", "请选择研究员")
  855. return
  856. } else {
  857. updateParams["matter_content"] = req.MatterContent
  858. }
  859. startDateTime := req.StartDate + " " + req.StartTime
  860. endDateTime := req.EndDate + " " + req.EndTime
  861. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  862. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  863. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  864. this.FailWithMessage("事项开始时间不能小于当前时间!", "事项开始时间不能小于当前时间!")
  865. return
  866. }
  867. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  868. this.FailWithMessage("事项结束时间不能小于当前时间!", "事项结束时间不能小于当前时间!")
  869. return
  870. }
  871. if startP.After(endP) || startP.Equal(endP) {
  872. this.FailWithMessage("事项开始时间应小于结束时间!", "事项开始时间应小于结束时间!")
  873. return
  874. }
  875. matterItem, err := roadshow.GetMattersById(req.RsMattersId)
  876. if err != nil {
  877. this.FailWithMessage("保存失败!", "保存失败,GetMattersById,Err:"+err.Error())
  878. return
  879. }
  880. //校验事项时间冲突
  881. {
  882. if matterItem != nil && (matterItem.StartDate != req.StartDate ||
  883. matterItem.StartTime != req.StartTime ||
  884. matterItem.EndDate != req.EndDate ||
  885. matterItem.EndTime != req.EndTime) {
  886. matterCount, err := rs.CheckMatters(startDateTime, endDateTime, sysUser.AdminId, matterItem.RsMattersId)
  887. if err != nil {
  888. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckMattersCount!Err:"+err.Error())
  889. return
  890. }
  891. if matterCount > 0 {
  892. this.FailWithMessage("时间冲突,已存在时间段内的事项!", "时间冲突检测失败-CheckMattersCount!")
  893. return
  894. }
  895. }
  896. }
  897. //校验活动时间冲突--待接受
  898. {
  899. calendarCount, err := rs.CheckCalendar(startDateTime, endDateTime, "1", sysUser.AdminId, 0)
  900. if err != nil {
  901. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckCalendarResearcherCount!Err:"+err.Error())
  902. return
  903. }
  904. if calendarCount > 0 {
  905. this.FailWithMessage("当前时间与待处理的申请有冲突,请与相关销售沟通!", "时间冲突检测失败-CheckCalendarResearcherCount!")
  906. return
  907. }
  908. }
  909. //校验活动时间冲突--待接受
  910. {
  911. calendarCount, err := rs.CheckCalendar(startDateTime, endDateTime, "2", sysUser.AdminId, 0)
  912. if err != nil {
  913. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckCalendarResearcherCount!Err:"+err.Error())
  914. return
  915. }
  916. if calendarCount > 0 {
  917. this.FailWithMessage("时间冲突,已存在时间段内的活动!", "时间冲突检测失败-CheckCalendarResearcherCount!")
  918. return
  919. }
  920. }
  921. whereParams := make(map[string]interface{})
  922. whereParams["rs_matters_id"] = req.RsMattersId
  923. updateParams["modify_time"] = time.Now()
  924. err = roadshow.UpdateRsMatters(whereParams, updateParams)
  925. if err != nil {
  926. this.FailWithMessage("保存失败!", "保存失败!UpdateRsMatters:"+err.Error())
  927. return
  928. }
  929. go rs.UpdateSHCalendarByMatter(req)
  930. this.OkDetailed(nil, "保存成功")
  931. }
  932. // @Title 删除事项接口
  933. // @Description 删除事项接口
  934. // @Param request body rs.DeleteMattersReq true "type json string"
  935. // @Success Ret=200 保存成功
  936. // @router /matters/delete [post]
  937. func (this *CalendarController) MattersDelete() {
  938. sysUser := this.AdminWx
  939. if sysUser == nil {
  940. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  941. return
  942. }
  943. var req roadshow.DeleteMattersReq
  944. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  945. if err != nil {
  946. this.FailWithMessage("参数解析失败", "参数解析失败,Err:"+err.Error())
  947. return
  948. }
  949. if req.RsMattersId <= 0 {
  950. this.FailWithMessage("参数错误", "参数错误")
  951. return
  952. }
  953. err = roadshow.DeleteRsMatters(req.RsMattersId)
  954. if err != nil {
  955. this.FailWithMessage("保存失败", "保存失败!DeleteRsMatters:"+err.Error())
  956. return
  957. }
  958. go rs.DeleteSHMatter(req.RsMattersId)
  959. this.OkDetailed(nil, "删除成功")
  960. }
  961. func getTitle(activityType, roadshowType, activityCategory, roadshowPlatform, province, city string) string {
  962. var title string
  963. switch activityType {
  964. case "内部会议":
  965. title = "内部会议"
  966. case "公开会议", "路演":
  967. if roadshowType == "线上" {
  968. title = roadshowType + activityType + roadshowPlatform
  969. } else {
  970. title = roadshowType + activityType + province + city
  971. }
  972. case "报告电话会":
  973. title = activityCategory + "电话会"
  974. }
  975. return title
  976. }
  977. // @Title 编辑路演活动接口
  978. // @Description编辑路演活动接口
  979. // @Param request body rs.EditActivityReq true "type json string"
  980. // @Success Ret=200 保存成功
  981. // @router /edit [post]
  982. func (this *CalendarController) Edit() {
  983. sysUser := this.AdminWx
  984. if sysUser == nil {
  985. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  986. return
  987. }
  988. deleteCache := true
  989. cacheKey := "CACHE_RS_ACTIVITY_EDIT_" + strconv.Itoa(sysUser.AdminId)
  990. defer func() {
  991. if deleteCache {
  992. utils.Rc.Delete(cacheKey)
  993. }
  994. }()
  995. if !utils.Rc.SetNX(cacheKey, 1, 3*time.Second) {
  996. deleteCache = false
  997. this.FailWithMessage("系统处理中,请稍后重试!", "系统处理中,请稍后重试!"+sysUser.RealName+";data:"+string(this.Ctx.Input.RequestBody))
  998. return
  999. }
  1000. var req roadshow.EditActivityReq
  1001. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1002. if err != nil {
  1003. this.FailWithMessage("参数解析异常", "参数解析失败,Err:"+err.Error())
  1004. return
  1005. }
  1006. if req.RsCalendarId <= 0 {
  1007. this.FailWithMessage("参数错误", "RsCalendarId<=0")
  1008. return
  1009. }
  1010. if req.RsCalendarResearcherId <= 0 {
  1011. this.FailWithMessage("参数错误", "RsCalendarResearcherId<=0")
  1012. return
  1013. }
  1014. if req.ActivityType == "" {
  1015. this.FailWithMessage("请选择活动类型", "请选择活动类型")
  1016. return
  1017. }
  1018. if len(req.ResearcherList) <= 0 {
  1019. this.FailWithMessage("请选择研究员!", "请选择研究员!")
  1020. return
  1021. }
  1022. researcherMap := make(map[int]string)
  1023. var checkIsAdd []string
  1024. for _, v := range req.ResearcherList {
  1025. if v.ResearcherId <= 0 {
  1026. this.FailWithMessage("请选择研究员!", "请选择研究员!")
  1027. return
  1028. }
  1029. if v.ResearcherName == "" {
  1030. this.FailWithMessage("请选择研究员!", "请选择研究员!")
  1031. return
  1032. }
  1033. if v.StartDate == "" {
  1034. this.FailWithMessage("请选择开始日期!", "请选择开始日期!")
  1035. return
  1036. }
  1037. if v.EndDate == "" {
  1038. this.FailWithMessage("请选择结束日期!", "请选择结束日期!")
  1039. return
  1040. }
  1041. if v.StartTime == "" {
  1042. this.FailWithMessage("请选择开始时间!", "请选择开始时间!")
  1043. return
  1044. }
  1045. if v.EndTime == "" {
  1046. this.FailWithMessage("请选择结束时间!", "请选择结束时间!")
  1047. return
  1048. }
  1049. if v.StartWeek == "" {
  1050. this.FailWithMessage("请选择周!", "请选择周!")
  1051. return
  1052. }
  1053. if v.EndWeek == "" {
  1054. this.FailWithMessage("请选择周!", "请选择周!")
  1055. return
  1056. }
  1057. if realName, ok := researcherMap[v.ResearcherId]; ok {
  1058. this.FailWithMessage("研究员:"+realName+" 被重复选择", "研究员:"+realName+" 被重复选择")
  1059. return
  1060. }
  1061. researcherMap[v.ResearcherId] = v.ResearcherName
  1062. startDateTime := v.StartDate + " " + v.StartTime
  1063. endDateTime := v.EndDate + " " + v.EndTime
  1064. startP, _ := time.ParseInLocation(utils.FormatDateTime, startDateTime, time.Local)
  1065. endP, _ := time.ParseInLocation(utils.FormatDateTime, endDateTime, time.Local)
  1066. if startP.Before(time.Now()) || startP.Equal(time.Now()) {
  1067. this.FailWithMessage("活动开始时间不能小于当前时间!", "活动开始时间不能小于当前时间!")
  1068. return
  1069. }
  1070. if endP.Before(time.Now()) || endP.Equal(time.Now()) {
  1071. this.FailWithMessage("活动结束时间不能小于当前时间!", "活动结束时间不能小于当前时间!")
  1072. return
  1073. }
  1074. if startP.After(endP) || startP.Equal(endP) {
  1075. this.FailWithMessage("活动开始时间应小于结束时间!", "活动开始时间应小于结束时间!")
  1076. return
  1077. }
  1078. /*
  1079. 时间冲突时,提示:xxx时间已被占用
  1080. 当有任意一个研究员时间有冲突时,所有申请订单都不发送。
  1081. */
  1082. rsCalendarResearcherItem, err := roadshow.GetRsCalendarResearcherByRsCalendarIdAndResearcherId(req.RsCalendarId, v.ResearcherId)
  1083. var isAdd bool
  1084. if err != nil {
  1085. if err.Error() == utils.ErrNoRow() {
  1086. isAdd = true
  1087. } else {
  1088. this.FailWithMessage("获取数据失败!", "获取数据失败!GetRsCalendarResearcherByRsCalendarIdAndResearcherId:"+err.Error())
  1089. return
  1090. }
  1091. }
  1092. var rsCalendarResearcherId int
  1093. if rsCalendarResearcherItem == nil {
  1094. isAdd = true
  1095. } else {
  1096. rsCalendarResearcherId = rsCalendarResearcherItem.RsCalendarResearcherId
  1097. }
  1098. //同步上海数据
  1099. researcherInfo, err := admin.GetAdminById(v.ResearcherId)
  1100. if err != nil {
  1101. this.FailWithMessage("研究员异常!", "研究员异常,Err:"+err.Error())
  1102. return
  1103. }
  1104. _ = rs.SyncCalendarFromShanghai(researcherInfo.Mobile, v.StartDate, v.EndDate)
  1105. //校验事项时间冲突
  1106. {
  1107. if isAdd || (rsCalendarResearcherItem != nil && (rsCalendarResearcherItem.StartDate != v.StartDate ||
  1108. rsCalendarResearcherItem.StartTime != v.StartTime ||
  1109. rsCalendarResearcherItem.EndDate != v.EndDate ||
  1110. rsCalendarResearcherItem.EndTime != v.EndTime)) {
  1111. matterCount, err := rs.CheckMatters(startDateTime, endDateTime, v.ResearcherId, 0)
  1112. if err != nil {
  1113. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckMattersCount!Err:"+err.Error())
  1114. return
  1115. }
  1116. if matterCount > 0 {
  1117. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  1118. }
  1119. }
  1120. }
  1121. calendarCount, err := rs.CheckCalendar(startDateTime, endDateTime, "1,2", v.ResearcherId, rsCalendarResearcherId)
  1122. if err != nil {
  1123. this.FailWithMessage("时间冲突检测失败!", "时间冲突检测失败-CheckCalendarResearcherCount!Err:"+err.Error())
  1124. return
  1125. }
  1126. if calendarCount > 0 {
  1127. checkIsAdd = append(checkIsAdd, v.ResearcherName)
  1128. }
  1129. }
  1130. if len(checkIsAdd) > 0 {
  1131. this.FailWithMessage(strings.Join(checkIsAdd, ",")+"时间已被占用!", "时间冲突检测失败-CheckMattersCount!")
  1132. return
  1133. }
  1134. rsCalendarItem, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  1135. if err != nil {
  1136. this.FailWithMessage("获取数据失败!", "获取数据失败!GetRsCalendarById:"+err.Error())
  1137. return
  1138. }
  1139. if rsCalendarItem == nil {
  1140. this.FailWithMessage("保存失败!", "获取数据失败!GetRsCalendarById:"+err.Error())
  1141. return
  1142. }
  1143. calendarWhereParams := make(map[string]interface{})
  1144. calendarUpdateParams := make(map[string]interface{})
  1145. calendarWhereParams["rs_calendar_id"] = req.RsCalendarId
  1146. if req.ActivityType != "" {
  1147. calendarUpdateParams["activity_type"] = req.ActivityType
  1148. }
  1149. if req.RoadshowType != "" {
  1150. calendarUpdateParams["roadshow_type"] = req.RoadshowType
  1151. }
  1152. if req.RoadshowPlatform != "" {
  1153. calendarUpdateParams["roadshow_platform"] = req.RoadshowPlatform
  1154. }
  1155. if req.CompanyId > 0 {
  1156. calendarUpdateParams["company_id"] = req.CompanyId
  1157. }
  1158. if req.CompanyName != "" {
  1159. calendarUpdateParams["company_name"] = req.CompanyName
  1160. }
  1161. if req.ActivityCategory != "" {
  1162. calendarUpdateParams["activity_category"] = req.ActivityCategory
  1163. }
  1164. if req.Theme != "" {
  1165. calendarUpdateParams["theme"] = req.Theme
  1166. }
  1167. if req.CooperationName != "" {
  1168. calendarUpdateParams["cooperation_name"] = req.CooperationName
  1169. }
  1170. if req.Province != "" {
  1171. calendarUpdateParams["province"] = req.Province
  1172. }
  1173. if req.City != "" {
  1174. calendarUpdateParams["city"] = req.City
  1175. }
  1176. calendarUpdateParams["english_company"] = req.EnglishCompany
  1177. calendarUpdateParams["modify_time"] = time.Now()
  1178. calendarUpdateParams["title"] = getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City)
  1179. err = roadshow.UpdateRsCalendar(calendarWhereParams, calendarUpdateParams)
  1180. if err != nil {
  1181. this.FailWithMessage("保存失败!", "保存失败!UpdateRsCalendar:"+err.Error())
  1182. return
  1183. }
  1184. existList, err := roadshow.GetRsCalendarResearcherByCalendarId(req.RsCalendarId)
  1185. if err != nil {
  1186. this.FailWithMessage("保存失败!", "保存失败!GetRsCalendarResearcherByCalendarId:"+err.Error())
  1187. return
  1188. }
  1189. existResearcherMap := make(map[int]string)
  1190. for _, ev := range existList {
  1191. existResearcherMap[ev.ResearcherId] = ev.ResearcherName
  1192. }
  1193. if rsCalendarItem.ActivityType == "路演" || rsCalendarItem.ActivityType == "公开会议" {
  1194. // 更新研究员信息
  1195. //go roadshowService.UpdateSHCalendar(req.RsCalendarId, req.RsCalendarResearcherId, req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City, req.ResearcherList)
  1196. for k, v := range req.ResearcherList {
  1197. rsCalendarResearcherItem, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  1198. if err != nil {
  1199. this.FailWithMessage("获取数据失败!", "获取数据失败!GetRsCalendarResearcherById:"+err.Error())
  1200. return
  1201. }
  1202. calendarResearcherWhereParams := make(map[string]interface{})
  1203. calendarResearcherUpdateParams := make(map[string]interface{})
  1204. calendarResearcherWhereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  1205. calendarResearcherUpdateParams["researcher_id"] = v.ResearcherId
  1206. calendarResearcherUpdateParams["researcher_name"] = v.ResearcherName
  1207. if rsCalendarResearcherItem.Status == 3 || rsCalendarResearcherItem.Status == 5 {
  1208. calendarResearcherUpdateParams["status"] = 1
  1209. }
  1210. calendarResearcherUpdateParams["start_date"] = v.StartDate
  1211. calendarResearcherUpdateParams["end_date"] = v.EndDate
  1212. calendarResearcherUpdateParams["start_time"] = v.StartTime
  1213. calendarResearcherUpdateParams["end_time"] = v.EndTime
  1214. calendarResearcherUpdateParams["start_week"] = v.StartWeek
  1215. calendarResearcherUpdateParams["end_week"] = v.EndWeek
  1216. calendarResearcherUpdateParams["refuse_reason"] = ""
  1217. calendarResearcherUpdateParams["refuse_time"] = nil
  1218. calendarResearcherUpdateParams["delete_reason"] = ""
  1219. calendarResearcherUpdateParams["approve_time"] = nil
  1220. calendarResearcherUpdateParams["researcher_sort"] = k + 1
  1221. calendarResearcherUpdateParams["modify_time"] = time.Now()
  1222. calendarResearcherUpdateParams["create_time"] = time.Now()
  1223. err = roadshow.UpdateCalendarResearcher(calendarResearcherWhereParams, calendarResearcherUpdateParams)
  1224. if err != nil {
  1225. this.FailWithMessage("保存失败!", "保存失败!UpdateCalendarResearcher:"+err.Error())
  1226. return
  1227. }
  1228. //上海新增(因为在驳回的时候,就把上海该时间段的日程给删除了,所以修改的时候,需要重新调用新增接口)
  1229. calendar := roadshow.RsCalendar{
  1230. RsCalendarId: req.RsCalendarId,
  1231. SysUserId: sysUser.AdminId,
  1232. Title: getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City),
  1233. }
  1234. researcher := *rsCalendarResearcherItem
  1235. researcher.StartDate = v.StartDate
  1236. researcher.EndDate = v.EndDate
  1237. researcher.StartTime = v.StartTime
  1238. researcher.EndTime = v.EndTime
  1239. researcher.StartWeek = v.StartWeek
  1240. researcher.EndWeek = v.EndWeek
  1241. go rs.CalendarToSH(calendar, researcher)
  1242. if req.EditType == 2 {
  1243. //模板消息通知
  1244. go func(researcherId, tmpRsCalendarId, tmpRsCalendarResearcherId int) {
  1245. sysAdmin, _ := admin.GetAdminById(researcherId)
  1246. if sysAdmin != nil && req.ActivityType != "内部会议" && req.ActivityType != "报告电话会" {
  1247. first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  1248. keyword1 := sysUser.RealName
  1249. keyword2 := "--"
  1250. //keyword3 := time.Now().Format(utils.FormatDateTime)
  1251. startDateSub := v.StartDate[5:]
  1252. startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  1253. keyword3 := startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5]
  1254. var keyword4 string
  1255. if req.ActivityType == "路演" {
  1256. keyword4 = req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  1257. } else {
  1258. keyword4 = req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  1259. }
  1260. remark := "请尽快完成审批"
  1261. wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(req.RsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherId)
  1262. if sysAdmin.OpenId != "" {
  1263. services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, sysAdmin.Mobile)
  1264. }
  1265. }
  1266. }(v.ResearcherId, req.RsCalendarId, rsCalendarResearcherItem.RsCalendarResearcherId)
  1267. }
  1268. }
  1269. } else {
  1270. //先获取到所有的研究员日历表id
  1271. researchers, err := roadshow.GetRsCalendarResearcherByCalendarId(req.RsCalendarId)
  1272. if err != nil {
  1273. utils.FileLog.Info("GetRsCalendarResearcherByCalendarId err: ", err)
  1274. fmt.Println(err)
  1275. this.FailWithMessage("保存失败!", "获取数据失败,GetRsCalendarResearcherByCalendarId:"+err.Error())
  1276. return
  1277. }
  1278. //先删后增
  1279. err = roadshow.DeleteRsCalendarResearcher(req.RsCalendarId)
  1280. if err != nil {
  1281. this.FailWithMessage("保存失败!", "保存失败!DeleteRsCalendarResearcher:"+err.Error())
  1282. return
  1283. }
  1284. //删除上海
  1285. for _, researcher := range researchers {
  1286. rs.DeleteSHCalendar(researcher.RsCalendarResearcherId)
  1287. }
  1288. for k, v := range req.ResearcherList {
  1289. researcher := new(roadshow.RsCalendarResearcher)
  1290. researcher.RsCalendarId = req.RsCalendarId
  1291. researcher.ResearcherId = v.ResearcherId
  1292. researcher.ResearcherName = v.ResearcherName
  1293. researcher.StartDate = v.StartDate
  1294. researcher.EndDate = v.EndDate
  1295. researcher.StartTime = v.StartTime
  1296. researcher.EndTime = v.EndTime
  1297. researcher.StartWeek = v.StartWeek
  1298. researcher.EndWeek = v.EndWeek
  1299. researcher.CreateTime = time.Now()
  1300. researcher.ModifyTime = time.Now()
  1301. researcher.ResearcherSort = k + 1
  1302. if req.ActivityType == "路演" || req.ActivityType == "公开会议" {
  1303. researcher.Status = 1
  1304. } else {
  1305. researcher.Status = 2
  1306. }
  1307. rsCalendarResearcherId, err := roadshow.AddRsCalendarResearcher(researcher)
  1308. if err != nil {
  1309. this.FailWithMessage("保存失败!", "保存日历活动-研究员信息失败!Err:"+err.Error())
  1310. return
  1311. }
  1312. //上海新增
  1313. calendar := roadshow.RsCalendar{
  1314. RsCalendarId: req.RsCalendarId,
  1315. SysUserId: sysUser.AdminId,
  1316. Title: getTitle(req.ActivityType, req.RoadshowType, req.ActivityCategory, req.RoadshowPlatform, req.Province, req.City),
  1317. }
  1318. researcher.RsCalendarResearcherId = int(rsCalendarResearcherId)
  1319. go rs.CalendarToSH(calendar, *researcher)
  1320. go func(researcherId, tmpRsCalendarId, tmpRsCalendarResearcherId int) {
  1321. sysAdmin, _ := admin.GetAdminById(researcherId)
  1322. if sysAdmin != nil && req.ActivityType != "内部会议" && req.ActivityType != "报告电话会" {
  1323. first := "您收到一个新的【" + req.ActivityType + "】申请,请及时处理"
  1324. keyword1 := sysUser.RealName
  1325. keyword2 := "--"
  1326. keyword3 := time.Now().Format(utils.FormatDateTime)
  1327. startDateSub := v.StartDate[5:]
  1328. startDateSub = strings.Replace(startDateSub, "-", ".", -1)
  1329. //keyword3 := startDateSub + "(" + v.StartWeek + ")" + " " + v.StartTime[:5] + "~" + v.EndTime[:5]
  1330. var keyword4 string
  1331. if req.ActivityType == "路演" {
  1332. keyword4 = req.CompanyName + "(" + req.RoadshowType + req.ActivityType + ")"
  1333. } else {
  1334. keyword4 = req.Theme + "(" + req.RoadshowType + req.ActivityType + ")"
  1335. }
  1336. remark := "请尽快完成审批"
  1337. wxAppPath := "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(tmpRsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherId)
  1338. if sysAdmin.OpenId != "" {
  1339. services.SendWxMsgWithRoadshowPending(first, keyword1, keyword2, keyword3, keyword4, remark, wxAppPath, sysAdmin.Mobile)
  1340. }
  1341. }
  1342. }(v.ResearcherId, req.RsCalendarId, int(rsCalendarResearcherId))
  1343. }
  1344. }
  1345. this.OkDetailed(nil, "保存成功")
  1346. }
  1347. // ResearcherList
  1348. // @Title 研究员列表
  1349. // @Description 研究员列表接口
  1350. // @Success 200 {object} rs.ResearcherGroup
  1351. // @router /researcher/list [get]
  1352. func (this *CalendarController) ResearcherList() {
  1353. sysUser := this.AdminWx
  1354. if sysUser == nil {
  1355. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  1356. return
  1357. }
  1358. group, err := roadshow.GetResearcherGroup()
  1359. if err != nil {
  1360. this.FailWithMessage("获取信息失败!", "获取分组信息失败!Err:"+err.Error())
  1361. return
  1362. }
  1363. researcherList, err := roadshow.GetResearcher()
  1364. groupMap := make(map[int][]*roadshow.Researcher)
  1365. for _, v := range researcherList {
  1366. if v.RoleTypeCode == "ficc_admin" {
  1367. findItems := groupMap[1]
  1368. findItems = append(findItems, v)
  1369. groupMap[1] = findItems
  1370. } else {
  1371. if findItems, ok := groupMap[v.GroupId]; ok {
  1372. findItems = append(findItems, v)
  1373. groupMap[v.GroupId] = findItems
  1374. } else {
  1375. findItems = append(findItems, v)
  1376. groupMap[v.GroupId] = findItems
  1377. }
  1378. }
  1379. }
  1380. for _, v := range group {
  1381. v.ResearcherList = groupMap[v.GroupId]
  1382. }
  1383. this.OkDetailed(group, "获取成功")
  1384. }
  1385. // @Title 撤回路演活动接口
  1386. // @Description 撤回路演活动接口
  1387. // @Param request body rs.AcceptReq true "type json string"
  1388. // @Success Ret=200 保存成功
  1389. // @router /back [post]
  1390. func (this *CalendarController) Back() {
  1391. sysUser := this.AdminWx
  1392. if sysUser == nil {
  1393. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  1394. return
  1395. }
  1396. var req roadshow.AcceptReq
  1397. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1398. if err != nil {
  1399. this.FailWithMessage("参数解析异常", "参数解析失败,Err:"+err.Error())
  1400. return
  1401. }
  1402. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  1403. this.FailWithMessage("参数错误", "参数错误!RsCalendarId:"+strconv.Itoa(req.RsCalendarId)+";RsCalendarResearcherId:"+strconv.Itoa(req.RsCalendarResearcherId))
  1404. return
  1405. }
  1406. _, err = roadshow.GetRsCalendarById(req.RsCalendarId)
  1407. if err != nil {
  1408. this.FailWithMessage("获取数据失败", "获取数据失败!GetRsCalendarById:"+err.Error())
  1409. return
  1410. }
  1411. rsCalendarResearcher, err := roadshow.GetRsCalendarResearcherById(req.RsCalendarResearcherId)
  1412. if err != nil {
  1413. this.FailWithMessage("获取数据失败", "获取数据失败!GetRsCalendarResearcherById:"+err.Error())
  1414. return
  1415. }
  1416. if rsCalendarResearcher.Status == 2 {
  1417. this.FailWithMessage("已接受,不可进行撤回操作!", "已接受,不可进行撤回操作!")
  1418. return
  1419. } else if rsCalendarResearcher.Status == 3 {
  1420. this.FailWithMessage("已拒绝,不可进行撤回操作!", "已拒绝,不可进行撤回操作!")
  1421. return
  1422. } else if rsCalendarResearcher.Status == 4 {
  1423. this.FailWithMessage("已删除,不可进行撤回操作!", "已删除,不可进行撤回操作!")
  1424. return
  1425. } else if rsCalendarResearcher.Status == 5 {
  1426. this.FailWithMessage("已撤回,不可进行重复操作!", "已撤回,不可进行重复操作!")
  1427. return
  1428. }
  1429. whereParams := make(map[string]interface{})
  1430. updateParams := make(map[string]interface{})
  1431. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  1432. whereParams["rs_calendar_id"] = req.RsCalendarId
  1433. updateParams["status"] = 5
  1434. updateParams["modify_time"] = time.Now()
  1435. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  1436. //撤回后,需要删除该日程
  1437. go rs.DeleteSHCalendar(req.RsCalendarResearcherId)
  1438. if err != nil {
  1439. this.FailWithMessage("保存失败", "保存失败!UpdateCalendarResearcher:"+err.Error())
  1440. return
  1441. }
  1442. this.OkDetailed(nil, "撤回成功")
  1443. }
  1444. // @Title 删除路演活动接口
  1445. // @Description 删除路演活动接口
  1446. // @Param request body rs.DeleteReq true "type json string"
  1447. // @Success Ret=200 保存成功
  1448. // @router /delete [post]
  1449. func (this *CalendarController) Delete() {
  1450. sysUser := this.AdminWx
  1451. if sysUser == nil {
  1452. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  1453. return
  1454. }
  1455. var req roadshow.DeleteReq
  1456. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1457. if err != nil {
  1458. this.FailWithMessage("参数解析异常!", "参数解析失败,Err:"+err.Error())
  1459. return
  1460. }
  1461. if req.RsCalendarId <= 0 || req.RsCalendarResearcherId <= 0 {
  1462. this.FailWithMessage("参数错误!", "参数错误!RsCalendarId:"+strconv.Itoa(req.RsCalendarId)+";RsCalendarResearcherId:"+strconv.Itoa(req.RsCalendarResearcherId))
  1463. return
  1464. }
  1465. rsCalendarItem, err := roadshow.GetRsCalendarById(req.RsCalendarId)
  1466. if err != nil {
  1467. this.FailWithMessage("获取数据失败!", "获取数据失败!GetRsCalendarById:"+err.Error())
  1468. return
  1469. }
  1470. rsCalendarResearcherItemList, err := roadshow.GetRsCalendarResearcherListById(req.RsCalendarId)
  1471. if err != nil {
  1472. this.FailWithMessage("获取数据失败!", "获取数据失败!GetRsCalendarResearcherById:"+err.Error())
  1473. return
  1474. }
  1475. if rsCalendarItem.ActivityType == "报告电话会" || rsCalendarItem.ActivityType == "内部会议" {
  1476. err = roadshow.DeleteCalendar(req.RsCalendarId, req.RsCalendarResearcherId)
  1477. if err != nil {
  1478. this.FailWithMessage("删除失败!", "删除失败!DeleteCalendar:"+err.Error())
  1479. return
  1480. }
  1481. } else {
  1482. //只获取一条路演数据
  1483. rsCalendarResearcherItemList, err = roadshow.GetRsCalendarResearcherListByCalendarResearcherId(req.RsCalendarResearcherId)
  1484. if err != nil {
  1485. this.FailWithMessage("获取数据失败!", "获取数据失败!GetRsCalendarResearcherById:"+err.Error())
  1486. return
  1487. }
  1488. if req.DeleteReason == "" {
  1489. this.FailWithMessage("删除失败,请输入删除理由!", "删除失败!请输入删除理由")
  1490. return
  1491. }
  1492. whereParams := make(map[string]interface{})
  1493. updateParams := make(map[string]interface{})
  1494. whereParams["rs_calendar_researcher_id"] = req.RsCalendarResearcherId
  1495. whereParams["rs_calendar_id"] = req.RsCalendarId
  1496. updateParams["status"] = 4
  1497. updateParams["delete_reason"] = req.DeleteReason
  1498. updateParams["modify_time"] = time.Now()
  1499. updateParams["delete_time"] = time.Now()
  1500. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  1501. if err != nil {
  1502. this.FailWithMessage("删除失败!", "删除失败!UpdateCalendarResearcher:"+err.Error())
  1503. return
  1504. }
  1505. }
  1506. //`status` int(11) DEFAULT '0' COMMENT '1:待接受,2:已接受,3:已拒绝,4:已删除,5:已撤回,6:已结束',
  1507. for _, rsCalendarResearcherItem := range rsCalendarResearcherItemList {
  1508. //待接受、已接受的情况,需要同步删除上海那边的日程
  1509. if rsCalendarResearcherItem.Status == 1 || rsCalendarResearcherItem.Status == 2 {
  1510. go rs.DeleteSHCalendar(rsCalendarResearcherItem.RsCalendarResearcherId)
  1511. }
  1512. ////模板消息通知
  1513. //{
  1514. // go func() {
  1515. // if rsCalendarItem != nil && rsCalendarResearcherItem != nil {
  1516. // sysAdmin, _ := admin.GetAdminById(rsCalendarResearcherItem.ResearcherId)
  1517. // if sysAdmin != nil && sysAdmin.Mobile != "" {
  1518. // first := "【" + sysUser.RealName + "】删除了你的【路演】安排"
  1519. // var keyword1 string
  1520. // if rsCalendarItem.ActivityType == "路演" {
  1521. // keyword1 = rsCalendarItem.CompanyName + "," + rsCalendarItem.RoadshowType + rsCalendarItem.ActivityType
  1522. // } else {
  1523. // keyword1 = rsCalendarItem.Theme + "," + rsCalendarItem.RoadshowType + rsCalendarItem.ActivityType
  1524. // }
  1525. // keyword2 := "已删除"
  1526. // remark := req.DeleteReason
  1527. // var wxAppPath string
  1528. // if rsCalendarItem.ActivityType == "路演" || rsCalendarItem.ActivityType == "公开会议" {
  1529. // wxAppPath = "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(rsCalendarItem.RsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(rsCalendarResearcherItem.RsCalendarResearcherId)
  1530. // }
  1531. // go services.SendWxMsgWithRoadshowDeleteNotice(first, keyword1, keyword2, remark, wxAppPath, sysAdmin.Mobile)
  1532. // }
  1533. // }
  1534. // }()
  1535. //}
  1536. //模板消息通知
  1537. {
  1538. if rsCalendarItem != nil && rsCalendarResearcherItem != nil {
  1539. go func(tmpRsCalendarItem roadshow.RsCalendar, tmpRsCalendarResearcherItem roadshow.RsCalendarResearcher) {
  1540. sysAdmin, _ := admin.GetAdminById(tmpRsCalendarResearcherItem.ResearcherId)
  1541. var first string
  1542. var wxAppPath string
  1543. if tmpRsCalendarItem.ActivityType == "路演" || tmpRsCalendarItem.ActivityType == "公开会议" {
  1544. wxAppPath = "pages-approve/activity/detail?RsCalendarId=" + strconv.Itoa(tmpRsCalendarItem.RsCalendarId) + "&RsCalendarResearcherId=" + strconv.Itoa(tmpRsCalendarResearcherItem.RsCalendarResearcherId)
  1545. }
  1546. first = "【" + sysUser.RealName + "】删除了你的【" + tmpRsCalendarItem.ActivityType + "】安排"
  1547. keyword2 := "【" + sysUser.RealName + "】已删除(" + req.DeleteReason + ")"
  1548. var keyword1 string
  1549. if tmpRsCalendarItem.ActivityType == "路演" {
  1550. keyword1 = tmpRsCalendarItem.CompanyName + "," + tmpRsCalendarItem.RoadshowType + tmpRsCalendarItem.ActivityType
  1551. } else if tmpRsCalendarItem.ActivityType == "公开会议" {
  1552. keyword1 = tmpRsCalendarItem.Theme + "," + tmpRsCalendarItem.RoadshowType + tmpRsCalendarItem.ActivityType
  1553. } else {
  1554. startDate := tmpRsCalendarResearcherItem.StartDate[5:]
  1555. startDate = strings.Replace(startDate, "-", ".", -1)
  1556. keyword1 = "会议时间:" + startDate + "(" + tmpRsCalendarResearcherItem.StartWeek + ")" + " " + tmpRsCalendarResearcherItem.StartTime[:5] + "-" + tmpRsCalendarResearcherItem.EndTime[:5]
  1557. keyword2 = "【" + sysUser.RealName + "】已删除" + "【" + tmpRsCalendarItem.ActivityType + ")"
  1558. }
  1559. //keyword2 := "已删除"
  1560. remark := req.DeleteReason
  1561. if sysAdmin.OpenId != "" {
  1562. go services.SendWxMsgWithRoadshowDeleteNotice(first, keyword1, keyword2, remark, wxAppPath, sysAdmin.Mobile)
  1563. }
  1564. }(*rsCalendarItem, *rsCalendarResearcherItem)
  1565. }
  1566. }
  1567. }
  1568. this.OkDetailed(nil, "删除成功")
  1569. }
  1570. // ResearcherList
  1571. // @Title 获取报告电话会类型
  1572. // @Description 获取报告电话会类型接口
  1573. // @Success 200 {object} rs.ResearcherGroup
  1574. // @router /activity/type/list [get]
  1575. func (this *CalendarController) ActivityTypeList() {
  1576. sysUser := this.AdminWx
  1577. if sysUser == nil {
  1578. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  1579. return
  1580. }
  1581. // 获取所有的分类
  1582. list, err := rs.GetAllActivityType()
  1583. if err != nil {
  1584. this.FailWithMessage("获取活动类型列表失败", "获取活动类型列表失败,Err:"+err.Error())
  1585. return
  1586. }
  1587. this.OkDetailed(list, "获取成功")
  1588. }
  1589. // @Title 路演-研究员日历详情
  1590. // @Description 路演-研究员日历详情接口
  1591. // @Param StartDate query string true "开始日期"
  1592. // @Param EndDate query string true "结束日期日期"
  1593. // @Param ResearcherId query int true "研究员id"
  1594. // @Success 200 {object} roadshow.CalendarDetailResp
  1595. // @router /researcher/calendar/detail [get]
  1596. func (this *CalendarController) ResearcherCalendarDetail() {
  1597. sysUser := this.AdminWx
  1598. if sysUser == nil {
  1599. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  1600. return
  1601. }
  1602. startDate := this.GetString("StartDate")
  1603. endDate := this.GetString("EndDate")
  1604. researcherId, _ := this.GetInt("ResearcherId")
  1605. if startDate == "" || endDate == "" {
  1606. this.FailWithMessage("参数错误!", "参数错误 StartDate"+startDate+" EndDate:"+endDate)
  1607. return
  1608. }
  1609. var condition string
  1610. var pars []interface{}
  1611. if researcherId <= 0 {
  1612. calendarList := make([]*roadshow.CalendarListView, 0)
  1613. matterList := make([]*roadshow.RsMatters, 0)
  1614. resp := new(roadshow.CalendarPanelDetailResp)
  1615. resp.CalendarList = calendarList
  1616. resp.RsMattersList = matterList
  1617. this.OkDetailed(resp, "删除成功")
  1618. return
  1619. } else {
  1620. condition += ` AND b.researcher_id =? `
  1621. pars = append(pars, researcherId)
  1622. }
  1623. //同步上海数据
  1624. researcherInfo, err := admin.GetAdminById(researcherId)
  1625. if err != nil {
  1626. this.FailWithMessage("研究员异常!", "研究员异常"+err.Error())
  1627. return
  1628. }
  1629. go rs.SyncCalendarFromShanghai(researcherInfo.Mobile, startDate, endDate)
  1630. condition += ` AND b.start_date>=?`
  1631. pars = append(pars, startDate)
  1632. condition += ` AND b.end_date<=?`
  1633. pars = append(pars, endDate)
  1634. condition += ` AND b.status IN(2) `
  1635. //pars = append(pars, 2)
  1636. calendarList, err := roadshow.GetCalendarDetailList(condition, pars)
  1637. if err != nil {
  1638. this.FailWithMessage("获取数据失败!", "获取数据失败,GetCalendarDetailList Err:"+err.Error())
  1639. return
  1640. }
  1641. matterList, err := roadshow.GetRsMattersList(startDate, endDate, researcherId)
  1642. if err != nil {
  1643. this.FailWithMessage("获取数据失败!", "获取数据失败,GetRsMattersList Err:"+err.Error())
  1644. return
  1645. }
  1646. if calendarList == nil {
  1647. calendarList = make([]*roadshow.CalendarListView, 0)
  1648. }
  1649. if matterList == nil {
  1650. matterList = make([]*roadshow.RsMatters, 0)
  1651. }
  1652. resp := new(roadshow.CalendarPanelDetailResp)
  1653. resp.CalendarList = calendarList
  1654. resp.RsMattersList = matterList
  1655. this.OkDetailed(resp, "删除成功")
  1656. }
  1657. // @Title 路演-我的日历详情
  1658. // @Description 路演-我的日历详情接口
  1659. // @Param StartDate query string true "开始日期"
  1660. // @Param EndDate query string true "结束日期日期"
  1661. // @Success 200 {object} roadshow.CalendarDetailResp
  1662. // @router /my/calendar/detail [get]
  1663. func (this *CalendarController) MyCalendarDetail() {
  1664. sysUser := this.AdminWx
  1665. if sysUser == nil {
  1666. this.FailWithMessage("请登录", "请登录,SysUser Is Empty")
  1667. return
  1668. }
  1669. startDate := this.GetString("StartDate")
  1670. endDate := this.GetString("EndDate")
  1671. if startDate == "" || endDate == "" {
  1672. this.FailWithMessage("参数错误!", "参数错误 StartDate:"+startDate+" EndDate:"+endDate)
  1673. return
  1674. }
  1675. var condition string
  1676. var pars []interface{}
  1677. roleTypeCode := sysUser.RoleTypeCode
  1678. //销售
  1679. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER ||
  1680. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER ||
  1681. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_GROUP ||
  1682. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  1683. condition += ` AND a.sys_user_id=?`
  1684. pars = append(pars, sysUser.AdminId)
  1685. condition += ` AND a.activity_type IN('路演','公开会议') `
  1686. }
  1687. //研究员
  1688. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR ||
  1689. roleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR ||
  1690. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR ||
  1691. roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN ||
  1692. roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER {
  1693. condition += ` AND b.researcher_id=?`
  1694. pars = append(pars, sysUser.AdminId)
  1695. //同步上海数据
  1696. researcherInfo, err := admin.GetAdminById(sysUser.AdminId)
  1697. if err != nil {
  1698. this.FailWithMessage("研究员异常!", "研究员异常"+err.Error())
  1699. return
  1700. }
  1701. go rs.SyncCalendarFromShanghai(researcherInfo.Mobile, startDate, endDate)
  1702. }
  1703. //中级/普通/admin 管理员
  1704. if roleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
  1705. condition += ` AND a.sys_user_id=?`
  1706. pars = append(pars, sysUser.AdminId)
  1707. }
  1708. condition += ` AND b.start_date>=?`
  1709. pars = append(pars, startDate)
  1710. condition += ` AND b.end_date<=?`
  1711. pars = append(pars, endDate)
  1712. condition += ` AND b.status IN(2) `
  1713. //pars = append(pars, 2)
  1714. calendarList, err := roadshow.GetCalendarDetailList(condition, pars)
  1715. if err != nil {
  1716. this.FailWithMessage("获取数据失败!", "获取数据失败,GetCalendarDetailList Err:"+err.Error())
  1717. return
  1718. }
  1719. matterList, err := roadshow.GetRsMattersList(startDate, endDate, sysUser.AdminId)
  1720. if err != nil {
  1721. this.FailWithMessage("获取数据失败!", "获取数据失败,GetRsMattersList Err:"+err.Error())
  1722. return
  1723. }
  1724. resp := new(roadshow.CalendarPanelDetailResp)
  1725. resp.CalendarList = calendarList
  1726. resp.RsMattersList = matterList
  1727. this.OkDetailed(resp, "删除成功")
  1728. }