package roadshow import ( "encoding/json" "errors" "fmt" "github.com/rdlucklib/rdluck_tools/http" "hongze/hz_crm_api/models/roadshow" "hongze/hz_crm_api/models/system" "hongze/hz_crm_api/services/alarm_msg" "hongze/hz_crm_api/utils" "io/ioutil" netHttp "net/http" "net/url" "strconv" "strings" "time" ) type SyncCalendarFromShanghaiRecord struct { UserPhone string `description:"手机号"` StartDate string `description:"开始时间"` EndDate string `description:"结束时间"` } // 上海路演数据同步到自系统 从Redis获取 func InsertSyncCalendarFromShanghai() { var err error defer func() { if err != nil { go alarm_msg.SendAlarmMsg("上海路演数据同步到自系统 失败;InsertSyncCalendarFromShanghai ERR:"+err.Error(), 3) } }() for { utils.Rc.Brpop(utils.CACHE_KEY_SHANG_HAI_RS_CALENDAR_API, func(b []byte) { record := new(SyncCalendarFromShanghaiRecord) if err := json.Unmarshal(b, &record); err != nil { fmt.Println("json unmarshal wrong!") } //fmt.Println(record.UserPhone) _ = SyncCalendarFromShanghai(record.UserPhone, record.StartDate, record.EndDate) }) } } // 上海路演数据同步到自系统请求放到Redis func InsertSyncCalendarFromShanghaiLPush(userPhone, startDate, endDate string) bool { log := &SyncCalendarFromShanghaiRecord{UserPhone: userPhone, StartDate: startDate, EndDate: endDate} if utils.Re == nil { err := utils.Rc.LPush(utils.CACHE_KEY_SHANG_HAI_RS_CALENDAR_API, log) if err != nil { fmt.Println(err) go alarm_msg.SendAlarmMsg("上海路演数据同步到自系统 失败;InsertSyncCalendarFromShanghaiLPush ERR:"+err.Error(), 3) } return true } return false } // getAccessToken token内部请求接口 func getAccessToken() (tokenData roadshow.TokenData, err error) { defer func() { if err != nil { go alarm_msg.SendAlarmMsg("更新上海的token失败;ERR:"+err.Error(), 3) //go utils.SendEmail(utils.APPNAME+"更新上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers) } }() 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) body, err := http.Get(getUrl) if err != nil { err = errors.New("NewRequest Err:" + err.Error()) return } var tokenResp roadshow.GetTokenResp err = json.Unmarshal(body, &tokenResp) if err != nil { err = errors.New("Unmarshal Err:" + err.Error()) return } if tokenResp.Code != 1 { err = errors.New("getAccessToken err:" + tokenResp.Msg) return } tokenData = tokenResp.TokenData return } // refreshAccessToken 强制刷新获取accessToken func refreshAccessToken() (token string, err error) { defer func() { if err != nil { go alarm_msg.SendAlarmMsg("刷新上海的token失败;ERR:"+err.Error(), 3) //go utils.SendEmail(utils.APPNAME+"刷新上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers) } }() tokenInfo, tmpErr := getAccessToken() if tmpErr != nil { err = tmpErr return } token = tokenInfo.AccessToken //token存入redis err = utils.Rc.Put("SH_ACCESS_TOKEN", token, time.Duration(tokenInfo.ExpireIn-600)*time.Second) if err != nil { go alarm_msg.SendAlarmMsg("获取上海的token失败;上海token存入redis失败,ERR:"+err.Error(), 3) //go utils.SendEmail(utils.APPNAME+"获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), "上海token存入redis失败:", utils.EmailSendToUsers) } return } // getCalendarFrom 获取上海方的路演活动列表 func getCalendarFrom(userPhone, startDate, endDate string) (list []roadshow.UserCalendar, err error) { exUrl := utils.CRM_OPEN_API_URL + "/v1/calendar/userCalendarList" form := url.Values{ "user_phone": {userPhone}, "start_time": {startDate}, "end_time": {endDate}, } body, err := getCurl(exUrl, form, 0) if err != nil { err = errors.New("NewRequest Err:" + err.Error()) return } var userCalendarList roadshow.UserCalendarList err = json.Unmarshal(body, &userCalendarList) if err != nil { err = errors.New("Unmarshal Err:" + err.Error()) return } list = userCalendarList.Data //fmt.Println(response) //userCalendarList := response.([]interface{}) // //for _, userCalendar := range userCalendarList { // fmt.Println(userCalendar) // fmt.Printf("type :%T;\n", userCalendar) // //list = append(list, userCalendar.(roadshow.UserCalendar)) //} //fmt.Println(userCalendarList) //list = userCalendarList return } // creatSHCalendar 新增上海日历活动 func creatSHCalendar(userPhone, toUserPhone, content, startTime, endTime string, calendarType int8, selfCalendarId int) (err error, errMsg string) { logMsg := `` defer func() { if err != nil { if logMsg != `` { errMsg = logMsg } } }() finalUrl := utils.CRM_OPEN_API_URL + "/v1/Calendar/create" form := url.Values{ "user_phone": {userPhone}, "to_user_phone": {toUserPhone}, "content": {content}, "start_time": {startTime}, "end_time": {endTime}, } //发送创建请求 body, err, logMsg := postCurl(finalUrl, form, 0) if err != nil { err = errors.New("NewRequest Err:" + err.Error()) return } var creatSHCalendarResp roadshow.CreatSHCalendarResp err = json.Unmarshal(body, &creatSHCalendarResp) if err != nil { err = errors.New("Unmarshal Err:" + err.Error()) return } calendar := creatSHCalendarResp.Data //上海系统id sThirdId := calendar.CalendarID thirdId, err := strconv.Atoi(sThirdId) if err != nil { err = errors.New("string to int Err:" + err.Error()) return } // 添加自系统与上海系统的路演关系 relationItem := roadshow.RsCalendarRelation{ UserPhone: userPhone, CalendarType: calendarType, SelfCalendarId: selfCalendarId, ThirdCalendarId: thirdId, Title: content, ResearcherMobile: toUserPhone, ModifyTime: time.Now(), CreateTime: time.Now(), } _, err = roadshow.AddRsCalendarRelation(&relationItem) if err != nil { err = errors.New("AddRsCalendarRelation Err:" + err.Error()) fmt.Println(err) return } return } // updateSHCalendar 内部函数,只用于发送修改上海日历的http请求 func updateSHCalendar(thirdCalendarId, researcherMobile, content, startTime, endTime string) (calendarResp roadshow.CreatSHCalendarResp, err error) { finalUrl := utils.CRM_OPEN_API_URL + "/v1/Calendar/update" form := url.Values{ "calendar_id": {thirdCalendarId}, "to_user_phone": {researcherMobile}, "content": {content}, "start_time": {startTime}, "end_time": {endTime}, } //发送创建请求 _, err, _ = postCurl(finalUrl, form, 0) if err != nil { err = errors.New("NewRequest Err:" + err.Error()) return } return } // deleteSHCalendar 删除上海方的路演 func deleteSHCalendar(userPhone string, calendarId int) (err error) { finalUrl := utils.CRM_OPEN_API_URL + "/v1/Calendar/delete" form := url.Values{ "user_phone": {userPhone}, "calendar_id": {fmt.Sprintf("%v", calendarId)}, } //发送创建请求 _, err, _ = postCurl(finalUrl, form, 0) if err != nil { err = errors.New("NewRequest Err:" + err.Error()) return } return } // ShResponse 上海数据返回结构体 type ShResponse struct { Code int `json:"code" description:"1:正常返回;4001:token失效"` Msg string `json:"msg" description:"文字描述"` Time int `json:"time" description:"时间戳"` Data interface{} `json:"data" description:"业务数据"` } // getCurl get请求上海接口 func getCurl(urlStr string, params url.Values, num int) (body []byte, err error) { if err != nil { go alarm_msg.SendAlarmMsg("get请求上海接口失败,ERR:"+err.Error(), 3) //go utils.SendEmail(utils.APPNAME+"get请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05"), "get请求上海接口失败:"+err.Error(), utils.EmailSendToUsers) } token, err := GetAccessToken(false) if err != nil { return } params.Add("access_token", token) getUrl := urlStr + "?" + params.Encode() body, err = http.Get(getUrl) if err != nil { utils.FileLog.Info(fmt.Sprint("get Err:", err.Error(), ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body))) err = errors.New("NewRequest Err:" + err.Error()) return } var response ShResponse err = json.Unmarshal(body, &response) if err != nil { utils.FileLog.Info(fmt.Sprint("get Err:", err.Error(), ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body))) err = errors.New("Unmarshal Err:" + err.Error()) return } //如果是token失效,同时只是第一次请求(没有尝试强制刷新token,那么重新请求) if response.Code == 4001 && num <= 0 { utils.FileLog.Info(fmt.Sprint("get data err", ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body))) //token失效 _, tmpErr := refreshAccessToken() if tmpErr != nil { err = tmpErr } num++ params.Del("access_token") return getCurl(urlStr, params, num) } else if response.Code != 1 { utils.FileLog.Info(fmt.Sprint("get data err", ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body))) err = errors.New(response.Msg) return } return } // postCurl post请求上海接口 func postCurl(urlStr string, form url.Values, num int) (body []byte, err error, errMsg string) { logMsg := `` defer func() { if err != nil { if logMsg != `` { errMsg = logMsg go alarm_msg.SendAlarmMsg("post请求上海接口失败,ERR:"+err.Error()+";errMsg:"+errMsg, 3) //go utils.SendEmail(utils.APPNAME+"post请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05"), "post请求上海接口失败:"+errMsg, utils.EmailSendToUsers) } } }() token, err := GetAccessToken(false) if err != nil { return } finalUrl := urlStr + "?access_token=" + token //发送创建请求 resp, err := netHttp.PostForm(finalUrl, form) if err != nil { err = errors.New("NewRequest Err:" + err.Error()) return } defer resp.Body.Close() //解析resp并且存入关联表 body, err = ioutil.ReadAll(resp.Body) if err != nil { logMsg = fmt.Sprint("post err; request:", form.Encode(), "; errMsg:", err.Error()) utils.FileLog.Info(logMsg) return } logMsg = fmt.Sprint("post request:", form.Encode(), "; response:", string(body)) utils.FileLog.Info(logMsg) var response ShResponse err = json.Unmarshal(body, &response) if err != nil { utils.FileLog.Info("post Err:", err.Error(), ";url:", finalUrl, ";params:", form.Encode(), ";response:", string(body)) err = errors.New("Unmarshal Err:" + err.Error()) return } utils.FileLog.Info(fmt.Sprint("post request url:", finalUrl, ";params:", form.Encode(), ";response:", string(body))) //如果是token失效,同时只是第一次请求(没有尝试强制刷新token,那么重新请求) if response.Code == 4001 && num <= 0 { //token失效 _, tmpErr := refreshAccessToken() if tmpErr != nil { err = tmpErr } num++ return postCurl(urlStr, form, num) } else if response.Code != 1 { utils.FileLog.Info(fmt.Sprint("post data err", ";url:", finalUrl, ";params:", form.Encode(), ";response:", string(body))) err = errors.New(response.Msg) return } return } // GetAccessToken 获取accessToken func GetAccessToken(isRefresh bool) (token string, err error) { defer func() { if err != nil { go alarm_msg.SendAlarmMsg("获取上海的token失败,ERR:"+err.Error(), 3) //go utils.SendEmail(utils.APPNAME+"获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers) } }() token, redisErr := utils.Rc.RedisString("SH_ACCESS_TOKEN") //如果从redis中accessToken 获取失败或者token为空了,再或者需要强制刷新了,那么重新获取accessToken if redisErr != nil || token == `` || isRefresh { return refreshAccessToken() } return } // CalendarToSH 创建活动时同步上海的前置函数 func CalendarToSH(rsCalendar roadshow.RsCalendar, researcher roadshow.RsCalendarResearcher) { var err error errMsg := `` defer func() { if err != nil { errMsg = err.Error() + ";" + errMsg go alarm_msg.SendAlarmMsg("新建上海研究员日历失败,ERR:"+err.Error()+";errMsg:"+errMsg, 3) //go utils.SendEmail(utils.APPNAME+"新建上海研究员日历失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers) } }() //redis获取创建者及研究员信息 userInfo, err := getAdminInfoById(rsCalendar.SysUserId) if err != nil { utils.FileLog.Info("getAdminInfoById err: " + err.Error()) return } researcherInfo, err := getAdminInfoById(researcher.ResearcherId) if err != nil { utils.FileLog.Info("getAdminInfoById err: " + err.Error()) return } sTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.StartDate+" "+researcher.StartTime, time.Now().Location()) startTime := sTime.Format("2006-01-02 15:04") eTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.EndDate+" "+researcher.EndTime, time.Now().Location()) endTime := eTime.Format("2006-01-02 15:04") // 创建上海路演日程 err, errMsg = creatSHCalendar(userInfo.Mobile, researcherInfo.Mobile, rsCalendar.Title, startTime, endTime, 1, researcher.RsCalendarResearcherId) if err != nil { utils.FileLog.Info("CreatSHCalendar err: " + err.Error()) fmt.Println(err) return } // 更新路演与研究员关系表的同步字段 whereParams := make(map[string]interface{}) updateParams := make(map[string]interface{}) whereParams["rs_calendar_researcher_id"] = researcher.RsCalendarResearcherId updateParams["is_synced"] = 1 updateParams["modify_time"] = time.Now() err = roadshow.UpdateCalendarResearcher(whereParams, updateParams) if err != nil { utils.FileLog.Info("UpdateCalendarResearcher err: " + err.Error()) fmt.Println("UpdateCalendarResearcher err: " + err.Error()) return } // 更新路演的同步字段 calWhereParams := make(map[string]interface{}) calWhereParams["rs_calendar_id"] = rsCalendar.RsCalendarId err = roadshow.UpdateRsCalendar(calWhereParams, updateParams) if err != nil { utils.FileLog.Info("UpdateRsCalendar err: " + err.Error()) fmt.Println("UpdateRsCalendar err: " + err.Error()) return } } // MatterToSH 创建事项时同步上海的前置函数 func MatterToSH(matter roadshow.RsMatters) (err error) { errMsg := `` defer func() { if err != nil { errMsg = err.Error() + ";" + errMsg go alarm_msg.SendAlarmMsg("新建上海研究员事项失败,ERR:"+err.Error()+";errMsg:"+errMsg, 3) //go utils.SendEmail(utils.APPNAME+"新建上海研究员事项失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers) } }() //获取研究员信息 researcherInfo, err := getAdminInfoById(matter.SysUserId) if err != nil { //utils.FileLog.Info("getAdminInfoById err: " + err.Error()) return } sTime, _ := time.ParseInLocation(utils.FormatDateTime, matter.StartDate+" "+matter.StartTime, time.Now().Location()) startTime := sTime.Format("2006-01-02 15:04") eTime, _ := time.ParseInLocation(utils.FormatDateTime, matter.EndDate+" "+matter.EndTime, time.Now().Location()) endTime := eTime.Format("2006-01-02 15:04") err, errMsg = creatSHCalendar(researcherInfo.Mobile, researcherInfo.Mobile, matter.MatterContent, startTime, endTime, 2, matter.RsMattersId) if err != nil { return } // 修改事项的同步字段 updateParams := make(map[string]interface{}) whereParams := make(map[string]interface{}) updateParams["is_synced"] = 1 whereParams["rs_matters_id"] = matter.RsMattersId err = roadshow.UpdateRsMatters(whereParams, updateParams) if err != nil { err = fmt.Errorf("UpdateRsMatters err: " + err.Error()) } return } // UpdateSHCalendar 更新上海日历活动 func UpdateSHCalendar(rsCalendarId, rsCalendarResearcherId int, activityType, roadshowType, activityCategory, roadshowPlatform, province, city string, calendarResearcherList []*roadshow.CalendarResearcher) (err error) { errMsg := `` defer func() { if errMsg != `` { if err != nil { errMsg = err.Error() + ";" + errMsg } go alarm_msg.SendAlarmMsg("更新上海日历活动失败,errMsg:"+errMsg, 3) //go utils.SendEmail(utils.APPNAME+"更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05"), errMsg, utils.EmailSendToUsers) } }() //查询关联表获取信息 var condition string var pars []interface{} condition = ` AND self_calendar_id = ? and calendar_type = 1 ` pars = append(pars, rsCalendarResearcherId) relationItem, err := roadshow.GetRelationByPars(condition, pars) if err != nil { err = errors.New("GetRelationByPars err:" + err.Error()) fmt.Println(err) return } //需要同时修改创建人及研究员的日历(目前听说只有1个,先按一个处理吧) for _, researcher := range calendarResearcherList { sTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.StartDate+" "+researcher.StartTime, time.Now().Location()) startTime := sTime.Format("2006-01-02 15:04") eTime, _ := time.ParseInLocation(utils.FormatDateTime, researcher.EndDate+" "+researcher.EndTime, time.Now().Location()) endTime := eTime.Format("2006-01-02 15:04") title := getTitle(activityType, roadshowType, activityCategory, roadshowPlatform, province, city) //发送更新请求 _, err = updateSHCalendar(fmt.Sprintf("%v", relationItem.ThirdCalendarId), relationItem.ResearcherMobile, title, startTime, endTime) if err != nil { errMsg += fmt.Sprint("更新研究员日历信息:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";") } //// 更新路演活动的信息 //calWhereParams := make(map[string]interface{}) //calWhereParams["rs_calendar_id"] = rsCalendarId //err = roadshow.UpdateRsCalendarRelation(calWhereParams, updateParams) //if err != nil { // errMsg += fmt.Sprint("UpdateRsCalendar:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";") // return //} } // 更新路演活动中 研究员的信息 whereParams := make(map[string]interface{}) updateParams := make(map[string]interface{}) whereParams["rs_calendar_researcher_id"] = rsCalendarResearcherId updateParams["is_synced"] = 1 updateParams["modify_time"] = time.Now() err = roadshow.UpdateCalendarResearcher(whereParams, updateParams) if err != nil { errMsg += fmt.Sprint("UpdateCalendarResearcher:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";") return } // 更新路演活动的信息 calWhereParams := make(map[string]interface{}) calWhereParams["rs_calendar_id"] = rsCalendarId err = roadshow.UpdateRsCalendar(calWhereParams, updateParams) if err != nil { errMsg += fmt.Sprint("UpdateRsCalendar:", relationItem.ThirdCalendarId, ";err:"+err.Error(), ";") return } return } // UpdateSHCalendarByMatter 更新上海日历活动 func UpdateSHCalendarByMatter(req roadshow.UpdateMattersReq) (err error) { defer func() { if err != nil { go alarm_msg.SendAlarmMsg("更新上海日历活动失败,Err:"+err.Error(), 3) //go utils.SendEmail(utils.APPNAME+"更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05"), err.Error(), utils.EmailSendToUsers) } }() if err != nil { return } //需要同时修改创建人及研究员的日历 //查询关联表获取信息 var condition string var pars []interface{} condition = ` AND self_calendar_id = ? and calendar_type = 2 ` pars = append(pars, req.RsMattersId) relationItem, err := roadshow.GetRelationByPars(condition, pars) if err != nil { err = errors.New("GetRelationByPars err:" + err.Error()) fmt.Println(err) } sTime, _ := time.ParseInLocation(utils.FormatDateTime, req.StartDate+" "+req.StartTime, time.Now().Location()) startTime := sTime.Format("2006-01-02 15:04") eTime, _ := time.ParseInLocation(utils.FormatDateTime, req.EndDate+" "+req.EndTime, time.Now().Location()) endTime := eTime.Format("2006-01-02 15:04") //发送更新请求 _, err = updateSHCalendar(fmt.Sprintf("%v", relationItem.ThirdCalendarId), relationItem.ResearcherMobile, req.MatterContent, startTime, endTime) if err == nil { updateParams := make(map[string]interface{}) whereParams := make(map[string]interface{}) updateParams["is_synced"] = 1 whereParams["rs_matters_id"] = req.RsMattersId err = roadshow.UpdateRsMatters(whereParams, updateParams) if err != nil { utils.FileLog.Info("UpdateRsMatters err: " + err.Error()) fmt.Println("UpdateRsMatters err: " + err.Error()) return } } return } // DeleteSHCalendar 删除上海日历活动 func DeleteSHCalendar(rsCalendarResearcherId int) (err error) { defer func() { if err != nil { go alarm_msg.SendAlarmMsg(fmt.Sprint("删除上海日历活动失败,关系id:", rsCalendarResearcherId, ";err:", err.Error()), 3) //go utils.SendEmail(utils.APPNAME+"删除上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05"), fmt.Sprint("关系id:", rsCalendarResearcherId, ";err:", err.Error()), utils.EmailSendToUsers) } }() var condition string var pars []interface{} condition = ` AND self_calendar_id = ? and calendar_type = 1 ` pars = append(pars, rsCalendarResearcherId) relationItem, err := roadshow.GetRelationByPars(condition, pars) if err != nil { logInfo := fmt.Sprint("删除上海日历活动失败;rsCalendarResearcherId:,", rsCalendarResearcherId, " ;GetRelationByPars err"+err.Error()) err = errors.New(logInfo) utils.FileLog.Info(logInfo) if err.Error() == utils.ErrNoRow() { err = nil return } return } //删除上海方的路演 err = deleteSHCalendar(relationItem.UserPhone, relationItem.ThirdCalendarId) if err != nil { return } //删除活动表及事项表 err = roadshow.DeleteRsCalendarRelation(relationItem.RelationId) if err != nil { err = errors.New("DeleteRsCalendarRelation err:" + err.Error()) return } return } // DeleteSHMatter 删除上海日历事项 func DeleteSHMatter(matterId int) (err error) { defer func() { if err != nil { go alarm_msg.SendAlarmMsg("删除上海研究员日历失败;ERR:"+err.Error(), 3) //go utils.SendEmail(utils.APPNAME+"删除上海日历事项失败:", "删除上海研究员日历失败 "+err.Error(), utils.EmailSendToUsers) } }() var condition string var pars []interface{} condition = ` AND self_calendar_id = ? and calendar_type = 2 ` pars = append(pars, matterId) relationItem, err := roadshow.GetRelationByPars(condition, pars) if err != nil { err = errors.New(fmt.Sprint("删除上海日历事项失败;matterId:,", matterId, " ;GetRelationByPars err"+err.Error())) utils.FileLog.Info(err.Error()) if err.Error() == utils.ErrNoRow() { err = nil return } return } //删除上海方的路演 err = deleteSHCalendar(relationItem.UserPhone, relationItem.ThirdCalendarId) //删除活动表及事项表 err = roadshow.DeleteRsCalendarRelation(relationItem.RelationId) if err != nil { err = errors.New("DeleteRsCalendarRelation err:" + err.Error()) return } return } // SyncCalendarFromShanghai 上海路演数据同步到自系统 func SyncCalendarFromShanghai(userPhone, startDate, endDate string) (err error) { errMsgList := make([]string, 0) defer func() { if len(errMsgList) > 0 { //fmt.Println("err:", errMsg) if err != nil { errMsgList = append(errMsgList, fmt.Sprint("ERR:"+err.Error(), ";")) } go alarm_msg.SendAlarmMsg("上海路演数据同步到自系统失败;errMsg:"+strings.Join(errMsgList, "\n"), 3) //go utils.SendEmail(utils.APPNAME+"上海路演数据同步到自系统失败:"+time.Now().Format("2006-01-02 15:04:05"), errMsg, utils.EmailSendToUsers) } }() //fmt.Println(userPhone, startDate, endDate) endDateTime, err := time.ParseInLocation(utils.FormatDate, endDate, time.Local) if err != nil { errMsgList = append(errMsgList, `结束日期转time类型失败,err:`+err.Error()) return } //往后延迟一天,避免截止到当天 endDate = endDateTime.AddDate(0, 0, 1).Format(utils.FormatDate) currDay := time.Now().Format(utils.FormatDate) nowDateTime, _ := time.ParseInLocation(utils.FormatDate, currDay, time.Local) //如果传入的结束日期早于当前日期,那么就不去查询了 if endDateTime.Before(nowDateTime) { return } //获取当前研究员信息 userPhoneInfo, err := getAdminInfo(userPhone) if err != nil { errMsgList = append(errMsgList, fmt.Sprint("获取手机号信息失败:手机号:", userPhone, ";err:"+err.Error(), ";")) return } //根据研究员和开始/结束日期获取上海的活动路演 rsCalendarResearcherList, err := roadshow.GetRsCalendarResearcherInfoIByResearcherIdAndDate(userPhoneInfo.AdminId, currDay, endDate) if err != nil { errMsgList = append(errMsgList, fmt.Sprint("获取研究员日程信息失败:手机号:", userPhone, ";err:"+err.Error(), ";")) return } //待删除的活动路演 deleteRsCalendarResearcherMap := make(map[int][]*roadshow.RsCalendarResearcherRelationInfo) for _, v := range rsCalendarResearcherList { tmpList, ok := deleteRsCalendarResearcherMap[v.ThirdCalendarId] if !ok { tmpList = make([]*roadshow.RsCalendarResearcherRelationInfo, 0) } tmpList = append(tmpList, v) deleteRsCalendarResearcherMap[v.ThirdCalendarId] = tmpList } //以当前日期作为起始日期去同步 list, err := getCalendarFrom(userPhone, currDay, endDate) if err != nil { errMsgList = append(errMsgList, fmt.Sprint("获取第三方路演日历数据失败,", "userPhone:", userPhone, ";currDay:", currDay, ";endDate:", endDate, ";err:"+err.Error())) return } thirdIdList := make([]int, 0) if len(list) > 0 { for _, v := range list { thirdIdList = append(thirdIdList, v.ID) //移除还存在的活动,保留不存在的活动 delete(deleteRsCalendarResearcherMap, v.ID) } rsCalendarRelationList, tmpErr := roadshow.GetRsCalendarRelationListByThirdIds(thirdIdList) if tmpErr != nil { err = tmpErr errMsgList = append(errMsgList, "获取关联列表失败,err:"+tmpErr.Error()) return } rsCalendarRelationMap := make(map[int]*roadshow.RsCalendarRelation) for _, rsCalendarRelation := range rsCalendarRelationList { rsCalendarRelationMap[rsCalendarRelation.ThirdCalendarId] = rsCalendarRelation } for _, v := range list { //展示优先级:1、customer_name 2、project_name 3、title 需求池953 if v.CustomerName != "" { v.Title = v.CustomerName } else if v.ProjectName != "" { v.Title = v.ProjectName } if rsCalendarRelation, ok := rsCalendarRelationMap[v.ID]; ok { //存在的话,那么就去查找对应的信息 if rsCalendarRelation.CalendarType == 1 { //路演 rsCalendarResearcherInfo, tmpErr := roadshow.GetRsCalendarResearcherById(rsCalendarRelation.SelfCalendarId) if tmpErr != nil { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "获取路演研究员信息失败;err:"+tmpErr.Error(), ";")) continue } rsCalendarInfo, tmpErr := roadshow.GetRsCalendarById(rsCalendarResearcherInfo.RsCalendarId) if tmpErr != nil { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "获取路演信息失败;err:"+tmpErr.Error(), ";")) continue } if rsCalendarInfo.Source == 0 { //自系统创建的路演活动,不需要依靠上海方来修改 continue } //是否去同步变更数据库 isUpdateSync := false //是否变更 isUpdate := false if v.StartTime != rsCalendarRelation.StartTime { isUpdate = true } if v.EndTime != rsCalendarRelation.EndTime { isUpdate = true } if v.Title != rsCalendarRelation.Title { isUpdate = true } if rsCalendarResearcherInfo.Status == 4 { // 被删除了,现在是需要更新 isUpdate = true } researcherList := make([]system.AdminItem, 0) researcherMap := make(map[int]system.AdminItem) addResearcherList := make([]system.AdminItem, 0) // 需要新增的研究员 delResearcherIdList := make([]int, 0) //需要删除的路演活动与研究员的关系id updateResearcherList := make([]*roadshow.RsCalendarResearcher, 0) //待更新的路演活动中研究员信息 if v.ResearcherMobile != rsCalendarRelation.ResearcherMobile { //研究员变更了,需要去改表 isUpdateSync = true researcherMobileList := strings.Split(v.ResearcherMobile, ",") if len(researcherMobileList) > 0 { for _, mobile := range researcherMobileList { researcherInfo, tmpErr := getAdminInfo(mobile) if tmpErr != nil { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "获取研究员失败,研究员手机号:", mobile, ";err:"+tmpErr.Error(), ";")) continue } if researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_DEPARTMENT || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_DEPARTMENT || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN { researcherList = append(researcherList, researcherInfo) researcherMap[researcherInfo.AdminId] = researcherInfo } } } //没有研究员 if len(researcherList) <= 0 { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, ";对方研究员信息失败;")) continue } rsCalendarResearcherList, tmpErr := roadshow.GetRsCalendarResearcherListByRsCalendarId(rsCalendarInfo.RsCalendarId) if tmpErr != nil { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "获取路演活动中的研究员列表失败,路演活动ID:", rsCalendarInfo.RsCalendarId, ";err:"+tmpErr.Error(), ";")) continue } //现有活动中的研究员 rsCalendarResearcherMap := make(map[int]*roadshow.RsCalendarResearcher) for _, rsCalendarResearcher := range rsCalendarResearcherList { if _, ok := researcherMap[rsCalendarResearcher.ResearcherId]; ok { if isUpdate { updateResearcherList = append(updateResearcherList, rsCalendarResearcher) } } else { delResearcherIdList = append(delResearcherIdList, rsCalendarResearcher.RsCalendarResearcherId) } rsCalendarResearcherMap[rsCalendarResearcher.ResearcherId] = rsCalendarResearcher } //校验是否需要新增研究员 for adminId, researcherInfo := range researcherMap { //如果 if _, ok := rsCalendarResearcherMap[adminId]; !ok { addResearcherList = append(addResearcherList, researcherInfo) } } } else if isUpdate { //如果有字段更新,那么需要将所有的研究员信息更新 isUpdateSync = true rsCalendarResearcherList, tmpErr := roadshow.GetRsCalendarResearcherListByRsCalendarId(rsCalendarInfo.RsCalendarId) if tmpErr != nil { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "获取路演活动中的研究员列表失败,路演活动ID:", rsCalendarInfo.RsCalendarId, ";err:"+tmpErr.Error(), ";")) continue } for _, rsCalendarResearcher := range rsCalendarResearcherList { updateResearcherList = append(updateResearcherList, rsCalendarResearcher) } } if isUpdateSync { tmpErr = roadshow.UpdateSyncRsCalendarRelation(v, rsCalendarInfo, rsCalendarRelation, updateResearcherList, delResearcherIdList, addResearcherList) if tmpErr != nil { err = tmpErr errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "修改关联关系失败;err:"+tmpErr.Error(), ";")) return } } } else { //事项 //事项都是由自系统创建的,不需要依靠上海方来修改 } } else { //数据不存在 createUser, tmpErr := getAdminInfo(v.UserPhone) if tmpErr != nil { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "获取创建人失败,创建人手机号:", v.UserPhone, ";err:"+tmpErr.Error(), ";")) continue } //研究员列表 researcherList := make([]system.AdminItem, 0) researcherMobileList := strings.Split(v.ResearcherMobile, ",") if len(researcherMobileList) > 0 { for _, mobile := range researcherMobileList { researcherInfo, tmpErr := getAdminInfo(mobile) if tmpErr != nil { errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "获取研究员失败,研究员手机号:", mobile, ";err:"+tmpErr.Error(), ";")) continue } if researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_RESEARCHR || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RESEARCHR || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_RESEARCHR || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_DEPARTMENT || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_DEPARTMENT || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN || researcherInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN { researcherList = append(researcherList, researcherInfo) } } } //没有研究员 if len(researcherList) <= 0 { continue } //数据入库 tmpErr = roadshow.SyncRsCalendarRelation(v, createUser, researcherList) if tmpErr != nil { err = tmpErr errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", v.ID, "绑定关联关系失败;err:"+tmpErr.Error(), ";")) continue } //fmt.Println("createUser:", createUser) } } } //上海那边已经删除了路演,这边也要同步删除 for _, deleteRsCalendarResearcherList := range deleteRsCalendarResearcherMap { for _, deleteRsCalendarResearcher := range deleteRsCalendarResearcherList { // 更新路演与研究员关系表的状态字段 whereParams := make(map[string]interface{}) updateParams := make(map[string]interface{}) whereParams["rs_calendar_researcher_id"] = deleteRsCalendarResearcher.RsCalendarResearcherId updateParams["status"] = 4 updateParams["modify_time"] = time.Now() tmpErr := roadshow.UpdateCalendarResearcher(whereParams, updateParams) if tmpErr != nil { err = tmpErr errMsgList = append(errMsgList, fmt.Sprint("第三方日历ID:", deleteRsCalendarResearcher.ThirdCalendarId, "删除关联关系失败;err:"+tmpErr.Error(), ";")) continue } // 更新路演的同步字段 //calWhereParams := make(map[string]interface{}) //calUpdateParams := make(map[string]interface{}) //calWhereParams["rs_calendar_id"] = deleteRsCalendarResearcher.RsCalendarId //updateParams["is_synced"] = 1 //err = roadshow.UpdateRsCalendar(calWhereParams, calUpdateParams) } } return } // CreateOaUser 新增系统用户 func CreateOaUser(mobile, username string, groupId int) (err error) { defer func() { if err != nil { errMsg := fmt.Sprint("手机号:", mobile, ";username:", username, ";分组id:", groupId, ";err:", err.Error()) go alarm_msg.SendAlarmMsg("系统用户同步到上海失败;ERR:"+err.Error()+";errMsg:"+errMsg, 3) //go utils.SendEmail(utils.APPNAME+"系统用户同步到上海失败:"+time.Now().Format("2006-01-02 15:04:05"), errMsg, utils.EmailSendToUsers) } }() finalUrl := utils.CRM_OPEN_API_URL + "/v1/OaUser/create" //发送创建请求 form := url.Values{} form.Add("mobile", mobile) form.Add("username", username) form.Add("group_id", fmt.Sprint(groupId)) //发送创建请求 _, err, _ = postCurl(finalUrl, form, 0) if err != nil { err = errors.New("NewRequest Err:" + err.Error()) return } return } // getAdminInfo 通过手机号获取用户信息 func getAdminInfo(mobile string) (adminInfo system.AdminItem, err error) { adminMap := make(map[string]system.AdminItem) redisAdminData, redisErr := utils.Rc.RedisString(utils.CACHE_KEY_ADMIN) if redisErr != nil { list, err := system.GetSysuserList("", []interface{}{}, 0, 1000) // GetSysuserList for _, tmpAdminInfo := range list { adminMap[tmpAdminInfo.Mobile] = *tmpAdminInfo } //入缓存 redisJsonData, err := json.Marshal(adminMap) if err == nil { _ = utils.Rc.Put(utils.CACHE_KEY_ADMIN, string(redisJsonData), time.Minute*30) } } else { err := json.Unmarshal([]byte(redisAdminData), &adminMap) if err != nil { fmt.Println("用户数据,json转换失败:", err) } } adminInfo, ok := adminMap[mobile] if !ok { err = fmt.Errorf("找不到该手机号用户,mobile:" + mobile) } return } // getAdminInfoById 通过用户id获取用户信息 func getAdminInfoById(sysId int) (adminInfo system.AdminItem, err error) { adminMap := make(map[int]system.AdminItem) redisAdminData, redisErr := utils.Rc.RedisString(utils.CACHE_KEY_ADMIN_ID) if redisErr != nil { list, err := system.GetSysuserList("", []interface{}{}, 0, 1000) // GetSysuserList for _, tmpAdminInfo := range list { adminMap[tmpAdminInfo.AdminId] = *tmpAdminInfo } //入缓存 redisJsonData, err := json.Marshal(adminMap) if err == nil { _ = utils.Rc.Put(utils.CACHE_KEY_ADMIN_ID, string(redisJsonData), time.Minute*30) } } else { err := json.Unmarshal([]byte(redisAdminData), &adminMap) if err != nil { fmt.Println("用户数据,json转换失败:", err) } } adminInfo, ok := adminMap[sysId] if !ok { err = fmt.Errorf("找不到该用户id,sysId:" + fmt.Sprint(sysId)) } return } func getTitle(activityType, roadshowType, activityCategory, roadshowPlatform, province, city string) string { var title string switch activityType { case "内部会议": title = "内部会议" case "公开会议", "路演": if roadshowType == "线上" { title = roadshowType + activityType + roadshowPlatform } else { title = roadshowType + activityType + province + city } case "报告电话会": title = activityCategory + "电话会" } return title } // GetCalendarFrom 获取上海方的路演活动列表 func GetCalendarFrom(userPhone, startDate, endDate string) (list []roadshow.UserCalendar, err error) { list, err = getCalendarFrom(userPhone, startDate, endDate) return }