calendar.go 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035
  1. package rs
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "fmt"
  6. "github.com/rdlucklib/rdluck_tools/http"
  7. "hongze/hongze_mobile_admin/models/roadshow"
  8. "hongze/hongze_mobile_admin/models/tables/admin"
  9. "hongze/hongze_mobile_admin/services/alarm_msg"
  10. "hongze/hongze_mobile_admin/utils"
  11. "io/ioutil"
  12. netHttp "net/http"
  13. "net/url"
  14. "strconv"
  15. "strings"
  16. "time"
  17. )
  18. // getAccessToken token内部请求接口
  19. func getAccessToken() (tokenData roadshow.TokenData, err error) {
  20. defer func() {
  21. if err != nil {
  22. //go utils.SendEmail(utils.APPNAME+"更新上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  23. go alarm_msg.SendAlarmMsg("更新上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  24. }
  25. }()
  26. getUrl := fmt.Sprintf(utils.CRM_OPEN_API_URL+"/v1/auth/getAccessToken?app_key=%s&app_secret=%s", utils.CRM_OPEN_API_APP_KEY, utils.CRM_OPEN_API_APP_SECRET)
  27. body, err := http.Get(getUrl)
  28. if err != nil {
  29. err = errors.New("NewRequest Err:" + err.Error())
  30. return
  31. }
  32. var tokenResp roadshow.GetTokenResp
  33. err = json.Unmarshal(body, &tokenResp)
  34. if err != nil {
  35. err = errors.New("Unmarshal Err:" + err.Error())
  36. return
  37. }
  38. if tokenResp.Code != 1 {
  39. err = errors.New("getAccessToken err:" + tokenResp.Msg)
  40. return
  41. }
  42. tokenData = tokenResp.TokenData
  43. return
  44. }
  45. // refreshAccessToken 强制刷新获取accessToken
  46. func refreshAccessToken() (token string, err error) {
  47. defer func() {
  48. if err != nil {
  49. //go utils.SendEmail(utils.APPNAME+"获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  50. go alarm_msg.SendAlarmMsg("获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  51. }
  52. }()
  53. tokenInfo, tmpErr := getAccessToken()
  54. if tmpErr != nil {
  55. err = tmpErr
  56. return
  57. }
  58. token = tokenInfo.AccessToken
  59. //token存入redis
  60. err = utils.Rc.Put("SH_ACCESS_TOKEN", token, time.Duration(tokenInfo.ExpireIn-600)*time.Second)
  61. if err != nil {
  62. //go utils.SendEmail(utils.APPNAME+"获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), "上海token存入redis失败:", utils.EmailSendToUsers)
  63. go alarm_msg.SendAlarmMsg("获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:上海token存入redis失败", 3)
  64. }
  65. return
  66. }
  67. // getCalendarFrom 获取上海方的路演活动列表
  68. func getCalendarFrom(userPhone, startDate, endDate string) (list []roadshow.UserCalendar, err error) {
  69. exUrl := utils.CRM_OPEN_API_URL + "/v1/calendar/userCalendarList"
  70. form := url.Values{
  71. "user_phone": {userPhone},
  72. "start_time": {startDate},
  73. "end_time": {endDate},
  74. }
  75. body, err := getCurl(exUrl, form, 0)
  76. if err != nil {
  77. err = errors.New("NewRequest Err:" + err.Error())
  78. return
  79. }
  80. var userCalendarList roadshow.UserCalendarList
  81. err = json.Unmarshal(body, &userCalendarList)
  82. if err != nil {
  83. err = errors.New("Unmarshal Err:" + err.Error())
  84. return
  85. }
  86. list = userCalendarList.Data
  87. //fmt.Println(response)
  88. //userCalendarList := response.([]interface{})
  89. //
  90. //for _, userCalendar := range userCalendarList {
  91. // fmt.Println(userCalendar)
  92. // fmt.Printf("type :%T;\n", userCalendar)
  93. // //list = append(list, userCalendar.(roadshow.UserCalendar))
  94. //}
  95. //fmt.Println(userCalendarList)
  96. //list = userCalendarList
  97. return
  98. }
  99. // creatSHCalendar 新增上海日历活动
  100. func creatSHCalendar(userPhone, toUserPhone, content, startTime, endTime string, calendarType int8, selfCalendarId int) (err error, errMsg string) {
  101. logMsg := ``
  102. defer func() {
  103. if err != nil {
  104. if logMsg != `` {
  105. errMsg = logMsg
  106. }
  107. }
  108. }()
  109. finalUrl := utils.CRM_OPEN_API_URL + "/v1/Calendar/create"
  110. form := url.Values{
  111. "user_phone": {userPhone},
  112. "to_user_phone": {toUserPhone},
  113. "content": {content},
  114. "start_time": {startTime},
  115. "end_time": {endTime},
  116. }
  117. //发送创建请求
  118. body, err, logMsg := postCurl(finalUrl, form, 0)
  119. if err != nil {
  120. err = errors.New("NewRequest Err:" + err.Error())
  121. return
  122. }
  123. var creatSHCalendarResp roadshow.CreatSHCalendarResp
  124. err = json.Unmarshal(body, &creatSHCalendarResp)
  125. if err != nil {
  126. err = errors.New("Unmarshal Err:" + err.Error())
  127. return
  128. }
  129. calendar := creatSHCalendarResp.Data
  130. //上海系统id
  131. sThirdId := calendar.CalendarID
  132. thirdId, err := strconv.Atoi(sThirdId)
  133. if err != nil {
  134. err = errors.New("string to int Err:" + err.Error())
  135. return
  136. }
  137. // 添加自系统与上海系统的路演关系
  138. relationItem := roadshow.RsCalendarRelation{
  139. UserPhone: userPhone,
  140. CalendarType: calendarType,
  141. SelfCalendarId: selfCalendarId,
  142. ThirdCalendarId: thirdId,
  143. Title: content,
  144. ResearcherMobile: toUserPhone,
  145. ModifyTime: time.Now(),
  146. CreateTime: time.Now(),
  147. }
  148. _, err = roadshow.AddRsCalendarRelation(&relationItem)
  149. if err != nil {
  150. err = errors.New("AddRsCalendarRelation Err:" + err.Error())
  151. fmt.Println(err)
  152. return
  153. }
  154. return
  155. }
  156. // updateSHCalendar 内部函数,只用于发送修改上海日历的http请求
  157. func updateSHCalendar(thirdCalendarId, researcherMobile, content, startTime, endTime string) (calendarResp roadshow.CreatSHCalendarResp, err error) {
  158. finalUrl := utils.CRM_OPEN_API_URL + "/v1/Calendar/update"
  159. form := url.Values{
  160. "calendar_id": {thirdCalendarId},
  161. "to_user_phone": {researcherMobile},
  162. "content": {content},
  163. "start_time": {startTime},
  164. "end_time": {endTime},
  165. }
  166. //发送创建请求
  167. _, err, _ = postCurl(finalUrl, form, 0)
  168. if err != nil {
  169. err = errors.New("NewRequest Err:" + err.Error())
  170. return
  171. }
  172. return
  173. }
  174. // deleteSHCalendar 删除上海方的路演
  175. func deleteSHCalendar(userPhone string, calendarId int) (err error) {
  176. finalUrl := utils.CRM_OPEN_API_URL + "/v1/Calendar/delete"
  177. form := url.Values{
  178. "user_phone": {userPhone},
  179. "calendar_id": {fmt.Sprintf("%v", calendarId)},
  180. }
  181. //发送创建请求
  182. _, err, _ = postCurl(finalUrl, form, 0)
  183. if err != nil {
  184. err = errors.New("NewRequest Err:" + err.Error())
  185. return
  186. }
  187. return
  188. }
  189. // ShResponse 上海数据返回结构体
  190. type ShResponse struct {
  191. Code int `json:"code" description:"1:正常返回;4001:token失效"`
  192. Msg string `json:"msg" description:"文字描述"`
  193. Time int `json:"time" description:"时间戳"`
  194. Data interface{} `json:"data" description:"业务数据"`
  195. }
  196. // getCurl get请求上海接口
  197. func getCurl(urlStr string, params url.Values, num int) (body []byte, err error) {
  198. defer func() {
  199. if err != nil {
  200. //go utils.SendEmail(utils.APPNAME+"get请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05"), "get请求上海接口失败:"+err.Error(), utils.EmailSendToUsers)
  201. go alarm_msg.SendAlarmMsg("get请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:get请求上海接口失败", 3)
  202. }
  203. }()
  204. token, err := GetAccessToken(false)
  205. if err != nil {
  206. return
  207. }
  208. params.Add("access_token", token)
  209. getUrl := urlStr + "?" + params.Encode()
  210. body, err = http.Get(getUrl)
  211. if err != nil {
  212. utils.FileLog.Info(fmt.Sprint("get Err:", err.Error(), ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body)))
  213. err = errors.New("NewRequest Err:" + err.Error())
  214. return
  215. }
  216. var response ShResponse
  217. err = json.Unmarshal(body, &response)
  218. if err != nil {
  219. utils.FileLog.Info(fmt.Sprint("get Err:", err.Error(), ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body)))
  220. err = errors.New("Unmarshal Err:" + err.Error())
  221. return
  222. }
  223. //如果是token失效,同时只是第一次请求(没有尝试强制刷新token,那么重新请求)
  224. if response.Code == 4001 && num <= 0 {
  225. utils.FileLog.Info(fmt.Sprint("get data err", ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body)))
  226. //token失效
  227. _, tmpErr := refreshAccessToken()
  228. if tmpErr != nil {
  229. err = tmpErr
  230. }
  231. num++
  232. params.Del("access_token")
  233. return getCurl(urlStr, params, num)
  234. } else if response.Code != 1 {
  235. utils.FileLog.Info(fmt.Sprint("get data err", ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body)))
  236. err = errors.New(response.Msg)
  237. return
  238. }
  239. return
  240. }
  241. // postCurl post请求上海接口
  242. func postCurl(urlStr string, form url.Values, num int) (body []byte, err error, errMsg string) {
  243. logMsg := ``
  244. defer func() {
  245. if err != nil {
  246. if logMsg != `` {
  247. errMsg = logMsg
  248. //go utils.SendEmail(utils.APPNAME+"post请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05"), "post请求上海接口失败:"+errMsg, utils.EmailSendToUsers)
  249. go alarm_msg.SendAlarmMsg("post请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
  250. }
  251. }
  252. }()
  253. token, err := GetAccessToken(false)
  254. if err != nil {
  255. return
  256. }
  257. finalUrl := urlStr + "?access_token=" + token
  258. //发送创建请求
  259. resp, err := netHttp.PostForm(finalUrl, form)
  260. if err != nil {
  261. err = errors.New("NewRequest Err:" + err.Error())
  262. return
  263. }
  264. defer resp.Body.Close()
  265. //解析resp并且存入关联表
  266. body, err = ioutil.ReadAll(resp.Body)
  267. if err != nil {
  268. logMsg = fmt.Sprint("post err; request:", form.Encode(), "; errMsg:", err.Error())
  269. utils.FileLog.Info(logMsg)
  270. return
  271. }
  272. logMsg = fmt.Sprint("post request:", form.Encode(), "; response:", string(body))
  273. utils.FileLog.Info(logMsg)
  274. var response ShResponse
  275. err = json.Unmarshal(body, &response)
  276. if err != nil {
  277. utils.FileLog.Info("post Err:", err.Error(), ";url:", finalUrl, ";params:", form.Encode(), ";response:", string(body))
  278. err = errors.New("Unmarshal Err:" + err.Error())
  279. return
  280. }
  281. utils.FileLog.Info(fmt.Sprint("post request url:", finalUrl, ";params:", form.Encode(), ";response:", string(body)))
  282. //如果是token失效,同时只是第一次请求(没有尝试强制刷新token,那么重新请求)
  283. if response.Code == 4001 && num <= 0 {
  284. //token失效
  285. _, tmpErr := refreshAccessToken()
  286. if tmpErr != nil {
  287. err = tmpErr
  288. }
  289. num++
  290. return postCurl(urlStr, form, num)
  291. } else if response.Code != 1 {
  292. utils.FileLog.Info(fmt.Sprint("post data err", ";url:", finalUrl, ";params:", form.Encode(), ";response:", string(body)))
  293. err = errors.New(response.Msg)
  294. return
  295. }
  296. return
  297. }
  298. // GetAccessToken 获取accessToken
  299. func GetAccessToken(isRefresh bool) (token string, err error) {
  300. defer func() {
  301. if err != nil {
  302. //go utils.SendEmail(utils.APPNAME+"获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  303. go alarm_msg.SendAlarmMsg("获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  304. }
  305. }()
  306. token, redisErr := utils.Rc.RedisString("SH_ACCESS_TOKEN")
  307. //如果从redis中accessToken 获取失败或者token为空了,再或者需要强制刷新了,那么重新获取accessToken
  308. if redisErr != nil || token == `` || isRefresh {
  309. return refreshAccessToken()
  310. }
  311. return
  312. }
  313. // CalendarToSH 创建活动时同步上海的前置函数
  314. func CalendarToSH(rsCalendar roadshow.RsCalendar, researcher roadshow.RsCalendarResearcher) {
  315. var err error
  316. errMsg := ``
  317. defer func() {
  318. if err != nil {
  319. errMsg = err.Error() + ";" + errMsg
  320. //go utils.SendEmail(utils.APPNAME+"新建上海研究员日历失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  321. go alarm_msg.SendAlarmMsg("新建上海研究员日历失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  322. }
  323. }()
  324. //redis获取创建者及研究员信息
  325. userInfo, err := getAdminInfoById(rsCalendar.SysUserId)
  326. if err != nil {
  327. utils.FileLog.Info("getAdminInfoById err: " + err.Error())
  328. return
  329. }
  330. researcherInfo, err := getAdminInfoById(researcher.ResearcherId)
  331. if err != nil {
  332. utils.FileLog.Info("getAdminInfoById err: " + err.Error())
  333. return
  334. }
  335. sTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.StartDate+" "+researcher.StartTime, time.Now().Location())
  336. startTime := sTime.Format("2006-01-02 15:04")
  337. eTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.EndDate+" "+researcher.EndTime, time.Now().Location())
  338. endTime := eTime.Format("2006-01-02 15:04")
  339. // 创建上海路演日程
  340. err, errMsg = creatSHCalendar(userInfo.Mobile, researcherInfo.Mobile, rsCalendar.Title, startTime, endTime, 1, researcher.RsCalendarResearcherId)
  341. if err != nil {
  342. utils.FileLog.Info("CreatSHCalendar err: " + err.Error())
  343. fmt.Println(err)
  344. return
  345. }
  346. // 更新路演与研究员关系表的同步字段
  347. whereParams := make(map[string]interface{})
  348. updateParams := make(map[string]interface{})
  349. whereParams["rs_calendar_researcher_id"] = researcher.RsCalendarResearcherId
  350. updateParams["is_synced"] = 1
  351. updateParams["modify_time"] = time.Now()
  352. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  353. if err != nil {
  354. utils.FileLog.Info("UpdateCalendarResearcher err: " + err.Error())
  355. fmt.Println("UpdateCalendarResearcher err: " + err.Error())
  356. return
  357. }
  358. // 更新路演的同步字段
  359. calWhereParams := make(map[string]interface{})
  360. calWhereParams["rs_calendar_id"] = rsCalendar.RsCalendarId
  361. err = roadshow.UpdateRsCalendar(calWhereParams, updateParams)
  362. if err != nil {
  363. utils.FileLog.Info("UpdateRsCalendar err: " + err.Error())
  364. fmt.Println("UpdateRsCalendar err: " + err.Error())
  365. return
  366. }
  367. }
  368. // MatterToSH 创建事项时同步上海的前置函数
  369. func MatterToSH(matter roadshow.RsMatters) (err error) {
  370. errMsg := ``
  371. defer func() {
  372. if err != nil {
  373. errMsg = err.Error() + ";" + errMsg
  374. //go utils.SendEmail(utils.APPNAME+"新建上海研究员事项失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  375. go alarm_msg.SendAlarmMsg("新建上海研究员事项失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  376. }
  377. }()
  378. //获取研究员信息
  379. researcherInfo, err := getAdminInfoById(matter.SysUserId)
  380. if err != nil {
  381. //utils.FileLog.Info("getAdminInfoById err: " + err.Error())
  382. return
  383. }
  384. sTime, _ := time.ParseInLocation(utils.FormatDateTime, matter.StartDate+" "+matter.StartTime, time.Now().Location())
  385. startTime := sTime.Format("2006-01-02 15:04")
  386. eTime, _ := time.ParseInLocation(utils.FormatDateTime, matter.EndDate+" "+matter.EndTime, time.Now().Location())
  387. endTime := eTime.Format("2006-01-02 15:04")
  388. err, errMsg = creatSHCalendar(researcherInfo.Mobile, researcherInfo.Mobile, matter.MatterContent, startTime, endTime, 2, matter.RsMattersId)
  389. if err != nil {
  390. return
  391. }
  392. // 修改事项的同步字段
  393. updateParams := make(map[string]interface{})
  394. whereParams := make(map[string]interface{})
  395. updateParams["is_synced"] = 1
  396. whereParams["rs_matters_id"] = matter.RsMattersId
  397. err = roadshow.UpdateRsMatters(whereParams, updateParams)
  398. if err != nil {
  399. err = fmt.Errorf("UpdateRsMatters err: " + err.Error())
  400. }
  401. return
  402. }
  403. // UpdateSHCalendar 更新上海日历活动
  404. func UpdateSHCalendar(rsCalendarId, rsCalendarResearcherId int, activityType, roadshowType, activityCategory, roadshowPlatform, province, city string, calendarResearcherList []*roadshow.CalendarResearcher) (err error) {
  405. errMsg := ``
  406. defer func() {
  407. if errMsg != `` {
  408. //go utils.SendEmail(utils.APPNAME+"更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05"), errMsg, utils.EmailSendToUsers)
  409. go alarm_msg.SendAlarmMsg("更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
  410. }
  411. }()
  412. //查询关联表获取信息
  413. var condition string
  414. var pars []interface{}
  415. condition = ` AND self_calendar_id = ? and calendar_type = 1 `
  416. pars = append(pars, rsCalendarResearcherId)
  417. relationItem, err := roadshow.GetRelationByPars(condition, pars)
  418. if err != nil {
  419. err = errors.New("GetRelationByPars err:" + err.Error())
  420. //go utils.SendEmail(utils.APPNAME+"上海关联表查询失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  421. go alarm_msg.SendAlarmMsg("上海关联表查询失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  422. fmt.Println(err)
  423. return
  424. }
  425. //需要同时修改创建人及研究员的日历(目前听说只有1个,先按一个处理吧)
  426. for _, researcher := range calendarResearcherList {
  427. sTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.StartDate+" "+researcher.StartTime, time.Now().Location())
  428. startTime := sTime.Format("2006-01-02 15:04")
  429. eTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.EndDate+" "+researcher.EndTime, time.Now().Location())
  430. endTime := eTime.Format("2006-01-02 15:04")
  431. title := getTitle(activityType, roadshowType, activityCategory, roadshowPlatform, province, city)
  432. //发送更新请求
  433. _, err = updateSHCalendar(fmt.Sprintf("%v", relationItem.ThirdCalendarId), relationItem.ResearcherMobile, title, startTime, endTime)
  434. if err != nil {
  435. errMsg += fmt.Sprint("更新研究员日历信息:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";")
  436. }
  437. //// 更新路演活动的信息
  438. //calWhereParams := make(map[string]interface{})
  439. //calWhereParams["rs_calendar_id"] = rsCalendarId
  440. //err = roadshow.UpdateRsCalendarRelation(calWhereParams, updateParams)
  441. //if err != nil {
  442. // errMsg += fmt.Sprint("UpdateRsCalendar:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";")
  443. // return
  444. //}
  445. }
  446. // 更新路演活动中 研究员的信息
  447. whereParams := make(map[string]interface{})
  448. updateParams := make(map[string]interface{})
  449. whereParams["rs_calendar_researcher_id"] = rsCalendarResearcherId
  450. updateParams["is_synced"] = 1
  451. updateParams["modify_time"] = time.Now()
  452. err = roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  453. if err != nil {
  454. errMsg += fmt.Sprint("UpdateCalendarResearcher:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";")
  455. return
  456. }
  457. // 更新路演活动的信息
  458. calWhereParams := make(map[string]interface{})
  459. calWhereParams["rs_calendar_id"] = rsCalendarId
  460. err = roadshow.UpdateRsCalendar(calWhereParams, updateParams)
  461. if err != nil {
  462. errMsg += fmt.Sprint("UpdateRsCalendar:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";")
  463. return
  464. }
  465. return
  466. }
  467. // UpdateSHCalendarByMatter 更新上海日历活动
  468. func UpdateSHCalendarByMatter(req roadshow.UpdateMattersReq) (err error) {
  469. defer func() {
  470. if err != nil {
  471. //go utils.SendEmail(utils.APPNAME+"更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  472. go alarm_msg.SendAlarmMsg("更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  473. }
  474. }()
  475. if err != nil {
  476. return
  477. }
  478. //需要同时修改创建人及研究员的日历
  479. //查询关联表获取信息
  480. var condition string
  481. var pars []interface{}
  482. condition = ` AND self_calendar_id = ? and calendar_type = 2 `
  483. pars = append(pars, req.RsMattersId)
  484. relationItem, err := roadshow.GetRelationByPars(condition, pars)
  485. if err != nil {
  486. err = errors.New("GetRelationByPars err:" + err.Error())
  487. //go utils.SendEmail(utils.APPNAME+"上海关联表查询失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers)
  488. go alarm_msg.SendAlarmMsg("上海关联表查询失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  489. fmt.Println(err)
  490. return
  491. }
  492. sTime, _ := time.ParseInLocation(utils.FormatDateTime, req.StartDate+" "+req.StartTime, time.Now().Location())
  493. startTime := sTime.Format("2006-01-02 15:04")
  494. eTime, _ := time.ParseInLocation(utils.FormatDateTime, req.EndDate+" "+req.EndTime, time.Now().Location())
  495. endTime := eTime.Format("2006-01-02 15:04")
  496. //发送更新请求
  497. _, err = updateSHCalendar(fmt.Sprintf("%v", relationItem.ThirdCalendarId), relationItem.ResearcherMobile, relationItem.Content, startTime, endTime)
  498. if err == nil {
  499. updateParams := make(map[string]interface{})
  500. whereParams := make(map[string]interface{})
  501. updateParams["is_synced"] = 1
  502. whereParams["rs_matters_id"] = req.RsMattersId
  503. err = roadshow.UpdateRsMatters(whereParams, updateParams)
  504. if err != nil {
  505. utils.FileLog.Info("UpdateRsMatters err: " + err.Error())
  506. fmt.Println("UpdateRsMatters err: " + err.Error())
  507. return
  508. }
  509. }
  510. return
  511. }
  512. // DeleteSHCalendar 删除上海日历活动
  513. func DeleteSHCalendar(rsCalendarResearcherId int) (err error) {
  514. defer func() {
  515. if err != nil {
  516. //go utils.SendEmail(utils.APPNAME+"删除上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05"), fmt.Sprint("关系id:", rsCalendarResearcherId, ";err:", err.Error()), utils.EmailSendToUsers)
  517. go alarm_msg.SendAlarmMsg("删除上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+fmt.Sprint("关系id:", rsCalendarResearcherId, ";err:", err.Error()), 3)
  518. }
  519. }()
  520. var condition string
  521. var pars []interface{}
  522. condition = ` AND self_calendar_id = ? and calendar_type = 1 `
  523. pars = append(pars, rsCalendarResearcherId)
  524. relationItem, err := roadshow.GetRelationByPars(condition, pars)
  525. if err != nil {
  526. logInfo := fmt.Sprint("删除上海日历活动失败;rsCalendarResearcherId:,", rsCalendarResearcherId, " ;GetRelationByPars err"+err.Error())
  527. err = errors.New(logInfo)
  528. utils.FileLog.Info(logInfo)
  529. if err.Error() == utils.ErrNoRow() {
  530. err = nil
  531. return
  532. }
  533. return
  534. }
  535. //删除上海方的路演
  536. err = deleteSHCalendar(relationItem.UserPhone, relationItem.ThirdCalendarId)
  537. if err != nil {
  538. return
  539. }
  540. //删除活动表及事项表
  541. err = roadshow.DeleteRsCalendarRelation(relationItem.RelationId)
  542. if err != nil {
  543. err = errors.New("DeleteRsCalendarRelation err:" + err.Error())
  544. return
  545. }
  546. return
  547. }
  548. // DeleteSHMatter 删除上海日历事项
  549. func DeleteSHMatter(matterId int) (err error) {
  550. defer func() {
  551. if err != nil {
  552. //go utils.SendEmail(utils.APPNAME+"删除上海日历事项失败:", "删除上海研究员日历失败 "+err.Error(), utils.EmailSendToUsers)
  553. go alarm_msg.SendAlarmMsg("删除上海研究员日历失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
  554. }
  555. }()
  556. var condition string
  557. var pars []interface{}
  558. condition = ` AND self_calendar_id = ? and calendar_type = 2 `
  559. pars = append(pars, matterId)
  560. relationItem, err := roadshow.GetRelationByPars(condition, pars)
  561. if err != nil {
  562. err = errors.New(fmt.Sprint("删除上海日历事项失败;matterId:,", matterId, " ;GetRelationByPars err"+err.Error()))
  563. utils.FileLog.Info(err.Error())
  564. if err.Error() == utils.ErrNoRow() {
  565. err = nil
  566. return
  567. }
  568. return
  569. }
  570. //删除上海方的路演
  571. err = deleteSHCalendar(relationItem.UserPhone, relationItem.ThirdCalendarId)
  572. //删除活动表及事项表
  573. err = roadshow.DeleteRsCalendarRelation(relationItem.RelationId)
  574. if err != nil {
  575. err = errors.New("DeleteRsCalendarRelation err:" + err.Error())
  576. return
  577. }
  578. return
  579. }
  580. // SyncCalendarFromShanghai 上海路演数据同步到自系统
  581. func SyncCalendarFromShanghai(userPhone, startDate, endDate string) (err error) {
  582. errMsg := ``
  583. defer func() {
  584. if errMsg != `` {
  585. //fmt.Println("err:", errMsg)
  586. //go utils.SendEmail(utils.APPNAME+"上海路演数据同步到自系统失败:"+time.Now().Format("2006-01-02 15:04:05"), errMsg, utils.EmailSendToUsers)
  587. go alarm_msg.SendAlarmMsg("上海路演数据同步到自系统失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
  588. }
  589. }()
  590. //fmt.Println(userPhone, startDate, endDate)
  591. endDateTime, err := time.ParseInLocation(utils.FormatDate, endDate, time.Local)
  592. if err != nil {
  593. errMsg = `结束日期转time类型失败,err:` + err.Error()
  594. return
  595. }
  596. //往后延迟一天,避免截止到当天
  597. endDate = endDateTime.AddDate(0, 0, 1).Format(utils.FormatDate)
  598. currDay := time.Now().Format(utils.FormatDate)
  599. nowDateTime, _ := time.ParseInLocation(utils.FormatDate, currDay, time.Local)
  600. //如果传入的结束日期早于当前日期,那么就不去查询了
  601. if endDateTime.Before(nowDateTime) {
  602. return
  603. }
  604. //获取当前研究员信息
  605. userPhoneInfo, err := getAdminInfo(userPhone)
  606. if err != nil {
  607. errMsg += fmt.Sprint("获取手机号信息失败:手机号:", userPhone, ";err:"+err.Error(), ";")
  608. return
  609. }
  610. //根据研究员和开始/结束日期获取上海的活动路演
  611. rsCalendarResearcherList, err := roadshow.GetRsCalendarResearcherInfoIByResearcherIdAndDate(userPhoneInfo.AdminId, currDay, endDate)
  612. if err != nil {
  613. errMsg += fmt.Sprint("获取研究员日程信息失败:手机号:", userPhone, ";err:"+err.Error(), ";")
  614. return
  615. }
  616. //待删除的活动路演
  617. deleteRsCalendarResearcherMap := make(map[int][]*roadshow.RsCalendarResearcherRelationInfo)
  618. for _, v := range rsCalendarResearcherList {
  619. tmpList, ok := deleteRsCalendarResearcherMap[v.ThirdCalendarId]
  620. if !ok {
  621. tmpList = make([]*roadshow.RsCalendarResearcherRelationInfo, 0)
  622. }
  623. tmpList = append(tmpList, v)
  624. deleteRsCalendarResearcherMap[v.ThirdCalendarId] = tmpList
  625. }
  626. //以当前日期作为起始日期去同步
  627. list, err := getCalendarFrom(userPhone, currDay, endDate)
  628. if err != nil {
  629. errMsg = fmt.Sprint("获取第三方路演日历数据失败,", "userPhone:", userPhone, ";currDay:", currDay, ";endDate:", endDate, ";err:"+err.Error())
  630. return
  631. }
  632. thirdIdList := make([]int, 0)
  633. if len(list) > 0 {
  634. for _, v := range list {
  635. thirdIdList = append(thirdIdList, v.ID)
  636. //移除还存在的活动,保留不存在的活动
  637. delete(deleteRsCalendarResearcherMap, v.ID)
  638. }
  639. rsCalendarRelationList, tmpErr := roadshow.GetRsCalendarRelationListByThirdIds(thirdIdList)
  640. if tmpErr != nil {
  641. err = tmpErr
  642. errMsg = "获取关联列表失败,err:" + tmpErr.Error()
  643. return
  644. }
  645. rsCalendarRelationMap := make(map[int]*roadshow.RsCalendarRelation)
  646. for _, rsCalendarRelation := range rsCalendarRelationList {
  647. rsCalendarRelationMap[rsCalendarRelation.ThirdCalendarId] = rsCalendarRelation
  648. }
  649. for _, v := range list {
  650. if rsCalendarRelation, ok := rsCalendarRelationMap[v.ID]; ok {
  651. //存在的话,那么就去查找对应的信息
  652. if rsCalendarRelation.CalendarType == 1 {
  653. //路演
  654. rsCalendarResearcherInfo, tmpErr := roadshow.GetRsCalendarResearcherById(rsCalendarRelation.SelfCalendarId)
  655. if tmpErr != nil {
  656. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取路演研究员信息失败;err:"+tmpErr.Error(), ";")
  657. continue
  658. }
  659. rsCalendarInfo, tmpErr := roadshow.GetRsCalendarById(rsCalendarResearcherInfo.RsCalendarId)
  660. if tmpErr != nil {
  661. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取路演信息失败;err:"+tmpErr.Error(), ";")
  662. continue
  663. }
  664. if rsCalendarInfo.Source == 0 { //自系统创建的路演活动,不需要依靠上海方来修改
  665. continue
  666. }
  667. //是否去同步变更数据库
  668. isUpdateSync := false
  669. //是否变更
  670. isUpdate := false
  671. if v.StartTime != rsCalendarRelation.StartTime {
  672. isUpdate = true
  673. }
  674. if v.EndTime != rsCalendarRelation.EndTime {
  675. isUpdate = true
  676. }
  677. if v.Title != rsCalendarRelation.Title {
  678. isUpdate = true
  679. }
  680. if rsCalendarResearcherInfo.Status == 4 { // 被删除了,现在是需要更新
  681. isUpdate = true
  682. }
  683. researcherList := make([]admin.AdminItem, 0)
  684. researcherMap := make(map[int]admin.AdminItem)
  685. addResearcherList := make([]admin.AdminItem, 0) // 需要新增的研究员
  686. delResearcherIdList := make([]int, 0) //需要删除的路演活动与研究员的关系id
  687. updateResearcherList := make([]*roadshow.RsCalendarResearcher, 0) //待更新的路演活动中研究员信息
  688. if v.ResearcherMobile != rsCalendarRelation.ResearcherMobile {
  689. //研究员变更了,需要去改表
  690. isUpdateSync = true
  691. researcherMobileList := strings.Split(v.ResearcherMobile, ",")
  692. if len(researcherMobileList) > 0 {
  693. for _, mobile := range researcherMobileList {
  694. researcherInfo, tmpErr := getAdminInfo(mobile)
  695. if tmpErr != nil {
  696. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取研究员失败,研究员手机号:", mobile, ";err:"+tmpErr.Error(), ";")
  697. continue
  698. }
  699. if researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR ||
  700. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR ||
  701. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR ||
  702. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_DEPARTMENT ||
  703. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_DEPARTMENT {
  704. researcherList = append(researcherList, researcherInfo)
  705. researcherMap[researcherInfo.AdminId] = researcherInfo
  706. }
  707. }
  708. }
  709. //没有研究员
  710. if len(researcherList) <= 0 {
  711. errMsg += fmt.Sprint("第三方日历ID:", v.ID, ";对方研究员信息失败;")
  712. continue
  713. }
  714. rsCalendarResearcherList, tmpErr := roadshow.GetRsCalendarResearcherListByRsCalendarId(rsCalendarInfo.RsCalendarId)
  715. if tmpErr != nil {
  716. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取路演活动中的研究员列表失败,路演活动ID:", rsCalendarInfo.RsCalendarId, ";err:"+tmpErr.Error(), ";")
  717. continue
  718. }
  719. //现有活动中的研究员
  720. rsCalendarResearcherMap := make(map[int]*roadshow.RsCalendarResearcher)
  721. for _, rsCalendarResearcher := range rsCalendarResearcherList {
  722. if _, ok := researcherMap[rsCalendarResearcher.ResearcherId]; ok {
  723. if isUpdate {
  724. updateResearcherList = append(updateResearcherList, rsCalendarResearcher)
  725. }
  726. } else {
  727. delResearcherIdList = append(delResearcherIdList, rsCalendarResearcher.RsCalendarResearcherId)
  728. }
  729. rsCalendarResearcherMap[rsCalendarResearcher.ResearcherId] = rsCalendarResearcher
  730. }
  731. //校验是否需要新增研究员
  732. for adminId, researcherInfo := range researcherMap {
  733. //如果
  734. if _, ok := rsCalendarResearcherMap[adminId]; !ok {
  735. addResearcherList = append(addResearcherList, researcherInfo)
  736. }
  737. }
  738. } else if isUpdate { //如果有字段更新,那么需要将所有的研究员信息更新
  739. isUpdateSync = true
  740. rsCalendarResearcherList, tmpErr := roadshow.GetRsCalendarResearcherListByRsCalendarId(rsCalendarInfo.RsCalendarId)
  741. if tmpErr != nil {
  742. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取路演活动中的研究员列表失败,路演活动ID:", rsCalendarInfo.RsCalendarId, ";err:"+tmpErr.Error(), ";")
  743. continue
  744. }
  745. for _, rsCalendarResearcher := range rsCalendarResearcherList {
  746. updateResearcherList = append(updateResearcherList, rsCalendarResearcher)
  747. }
  748. }
  749. if isUpdateSync {
  750. tmpErr = roadshow.UpdateSyncRsCalendarRelation(v, rsCalendarInfo, rsCalendarRelation, updateResearcherList, delResearcherIdList, addResearcherList)
  751. if tmpErr != nil {
  752. err = tmpErr
  753. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "修改关联关系失败;err:"+tmpErr.Error(), ";")
  754. return
  755. }
  756. }
  757. } else {
  758. //事项
  759. //事项都是由自系统创建的,不需要依靠上海方来修改
  760. }
  761. } else {
  762. //数据不存在
  763. createUser, tmpErr := getAdminInfo(v.UserPhone)
  764. if tmpErr != nil {
  765. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取创建人失败,创建人手机号:", v.UserPhone, ";err:"+tmpErr.Error(), ";")
  766. continue
  767. }
  768. //研究员列表
  769. researcherList := make([]admin.AdminItem, 0)
  770. researcherMobileList := strings.Split(v.ResearcherMobile, ",")
  771. if len(researcherMobileList) > 0 {
  772. for _, mobile := range researcherMobileList {
  773. researcherInfo, tmpErr := getAdminInfo(mobile)
  774. if tmpErr != nil {
  775. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取研究员失败,研究员手机号:", mobile, ";err:"+tmpErr.Error(), ";")
  776. continue
  777. }
  778. if researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR ||
  779. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR ||
  780. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR ||
  781. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_DEPARTMENT ||
  782. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_DEPARTMENT ||
  783. researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN {
  784. researcherList = append(researcherList, researcherInfo)
  785. }
  786. }
  787. }
  788. //没有研究员
  789. if len(researcherList) <= 0 {
  790. continue
  791. }
  792. //数据入库
  793. tmpErr = roadshow.SyncRsCalendarRelation(v, createUser, researcherList)
  794. if tmpErr != nil {
  795. err = tmpErr
  796. errMsg += fmt.Sprint("第三方日历ID:", v.ID, "绑定关联关系失败;err:"+tmpErr.Error(), ";")
  797. continue
  798. }
  799. //fmt.Println("createUser:", createUser)
  800. }
  801. }
  802. }
  803. //上海那边已经删除了路演,这边也要同步删除
  804. for _, deleteRsCalendarResearcherList := range deleteRsCalendarResearcherMap {
  805. for _, deleteRsCalendarResearcher := range deleteRsCalendarResearcherList {
  806. // 更新路演与研究员关系表的状态字段
  807. whereParams := make(map[string]interface{})
  808. updateParams := make(map[string]interface{})
  809. whereParams["rs_calendar_researcher_id"] = deleteRsCalendarResearcher.RsCalendarResearcherId
  810. updateParams["status"] = 4
  811. updateParams["modify_time"] = time.Now()
  812. tmpErr := roadshow.UpdateCalendarResearcher(whereParams, updateParams)
  813. if tmpErr != nil {
  814. err = tmpErr
  815. errMsg += fmt.Sprint("第三方日历ID:", deleteRsCalendarResearcher.ThirdCalendarId, "删除关联关系失败;err:"+tmpErr.Error(), ";")
  816. continue
  817. }
  818. // 更新路演的同步字段
  819. //calWhereParams := make(map[string]interface{})
  820. //calUpdateParams := make(map[string]interface{})
  821. //calWhereParams["rs_calendar_id"] = deleteRsCalendarResearcher.RsCalendarId
  822. //updateParams["is_synced"] = 1
  823. //err = roadshow.UpdateRsCalendar(calWhereParams, calUpdateParams)
  824. }
  825. }
  826. return
  827. }
  828. // CreateOaUser 新增系统用户
  829. func CreateOaUser(mobile, username string, groupId int) (err error) {
  830. defer func() {
  831. if err != nil {
  832. errMsg := fmt.Sprint("手机号:", mobile, ";username:", username, ";分组id:", groupId, ";err:", err.Error())
  833. //go utils.SendEmail(utils.APPNAME+"系统用户同步到上海失败:"+time.Now().Format("2006-01-02 15:04:05"), errMsg, utils.EmailSendToUsers)
  834. go alarm_msg.SendAlarmMsg("系统用户同步到上海失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
  835. }
  836. }()
  837. finalUrl := utils.CRM_OPEN_API_URL + "/v1/OaUser/create"
  838. //发送创建请求
  839. form := url.Values{}
  840. form.Add("mobile", mobile)
  841. form.Add("username", username)
  842. form.Add("group_id", fmt.Sprint(groupId))
  843. //发送创建请求
  844. _, err, _ = postCurl(finalUrl, form, 0)
  845. if err != nil {
  846. err = errors.New("NewRequest Err:" + err.Error())
  847. return
  848. }
  849. return
  850. }
  851. // getAdminInfo 通过手机号获取用户信息
  852. func getAdminInfo(mobile string) (adminInfo admin.AdminItem, err error) {
  853. adminMap := make(map[string]admin.AdminItem)
  854. redisAdminData, redisErr := utils.Rc.RedisString(utils.CACHE_KEY_ADMIN)
  855. if redisErr != nil {
  856. list, err := admin.GetSysuserList("", []interface{}{}, 0, 1000)
  857. // GetSysuserList
  858. for _, tmpAdminInfo := range list {
  859. adminMap[tmpAdminInfo.Mobile] = *tmpAdminInfo
  860. }
  861. //入缓存
  862. redisJsonData, err := json.Marshal(adminMap)
  863. if err == nil {
  864. _ = utils.Rc.Put(utils.CACHE_KEY_ADMIN, string(redisJsonData), time.Minute*30)
  865. }
  866. } else {
  867. err := json.Unmarshal([]byte(redisAdminData), &adminMap)
  868. if err != nil {
  869. fmt.Println("用户数据,json转换失败:", err)
  870. }
  871. }
  872. adminInfo, ok := adminMap[mobile]
  873. if !ok {
  874. err = fmt.Errorf("找不到该手机号用户,mobile:" + mobile)
  875. }
  876. return
  877. }
  878. // getAdminInfoById 通过用户id获取用户信息
  879. func getAdminInfoById(sysId int) (adminInfo admin.AdminItem, err error) {
  880. adminMap := make(map[int]admin.AdminItem)
  881. redisAdminData, redisErr := utils.Rc.RedisString(utils.CACHE_KEY_ADMIN_ID)
  882. if redisErr != nil {
  883. list, err := admin.GetSysuserList("", []interface{}{}, 0, 1000)
  884. // GetSysuserList
  885. for _, tmpAdminInfo := range list {
  886. adminMap[tmpAdminInfo.AdminId] = *tmpAdminInfo
  887. }
  888. //入缓存
  889. redisJsonData, err := json.Marshal(adminMap)
  890. if err == nil {
  891. _ = utils.Rc.Put(utils.CACHE_KEY_ADMIN_ID, string(redisJsonData), time.Minute*30)
  892. }
  893. } else {
  894. err := json.Unmarshal([]byte(redisAdminData), &adminMap)
  895. if err != nil {
  896. fmt.Println("用户数据,json转换失败:", err)
  897. }
  898. }
  899. adminInfo, ok := adminMap[sysId]
  900. if !ok {
  901. err = fmt.Errorf("找不到该用户id,sysId:" + fmt.Sprint(sysId))
  902. }
  903. return
  904. }
  905. func getTitle(activityType, roadshowType, activityCategory, roadshowPlatform, province, city string) string {
  906. var title string
  907. switch activityType {
  908. case "内部会议":
  909. title = "内部会议"
  910. case "公开会议", "路演":
  911. if roadshowType == "线上" {
  912. title = roadshowType + activityType + roadshowPlatform
  913. } else {
  914. title = roadshowType + activityType + province + city
  915. }
  916. case "报告电话会":
  917. title = activityCategory + "电话会"
  918. }
  919. return title
  920. }
  921. // GetAllActivityType 获取全部的活动分类
  922. func GetAllActivityType() (list []*roadshow.ActivityTypeList, err error) {
  923. list, err = roadshow.GetActivityTypeListByActivityTypePId(0)
  924. if err != nil {
  925. return
  926. }
  927. for _, v := range list {
  928. tmpList, tmpErr := roadshow.GetActivityTypeListByActivityTypePId(v.ActivityTypeId)
  929. if tmpErr != nil {
  930. err = tmpErr
  931. return
  932. }
  933. v.ChildList = tmpList
  934. }
  935. return
  936. }
  937. // GetCalendarFrom 获取上海方的路演活动列表
  938. func GetCalendarFrom(userPhone, startDate, endDate string) (list []roadshow.UserCalendar, err error) {
  939. list, err = getCalendarFrom(userPhone, startDate, endDate)
  940. return
  941. }