1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090 |
- package rs
- import (
- "encoding/json"
- "errors"
- "fmt"
- "github.com/rdlucklib/rdluck_tools/http"
- "hongze/hongze_mobile_admin/models/roadshow"
- "hongze/hongze_mobile_admin/models/tables/admin"
- "hongze/hongze_mobile_admin/services/alarm_msg"
- "hongze/hongze_mobile_admin/utils"
- "io/ioutil"
- netHttp "net/http"
- "net/url"
- "strconv"
- "strings"
- "time"
- )
- type SyncCalendarFromShanghaiRecord struct {
- UserPhone string `description:"手机号"`
- StartDate string `description:"开始时间"`
- EndDate string `description:"结束时间"`
- }
- 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
- }
- func getAccessToken() (tokenData roadshow.TokenData, err error) {
- defer func() {
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("更新上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- }
- }()
- 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
- }
- func refreshAccessToken() (token string, err error) {
- defer func() {
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- }
- }()
- tokenInfo, tmpErr := getAccessToken()
- if tmpErr != nil {
- err = tmpErr
- return
- }
- token = tokenInfo.AccessToken
-
- err = utils.Rc.Put("SH_ACCESS_TOKEN", token, time.Duration(tokenInfo.ExpireIn-600)*time.Second)
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:上海token存入redis失败", 3)
- }
- return
- }
- 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
-
-
-
-
-
-
-
-
-
-
- return
- }
- 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
-
- 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
- }
- 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
- }
- 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
- }
- 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:"业务数据"`
- }
- func getCurl(urlStr string, params url.Values, num int) (body []byte, err error) {
- defer func() {
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("get请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:get请求上海接口失败", 3)
- }
- }()
- 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
- }
-
- if response.Code == 4001 && num <= 0 {
- utils.FileLog.Info(fmt.Sprint("get data err", ";url:", getUrl, ";params:", params.Encode(), ";response:", string(body)))
-
- _, 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
- }
- itemApiLog := new(roadshow.RsCalendarApiLog)
- itemApiLog.CreateTime = time.Now()
- itemApiLog.Remark = "小程序get请求上海接口"
- itemApiLog.Url = getUrl
- itemApiLog.Body = utils.ReplaceSpaceAndWrap(fmt.Sprint(params))
- itemApiLog.Result = string(body)
- go roadshow.AddRsCalendarApiLog(itemApiLog)
- return
- }
- 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请求上海接口失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
- }
- }
- }()
- 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()
-
- 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)))
-
- if response.Code == 4001 && num <= 0 {
-
- _, 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
- }
- itemApiLog := new(roadshow.RsCalendarApiLog)
- itemApiLog.CreateTime = time.Now()
- itemApiLog.Remark = "post请求上海接口"
- itemApiLog.Url = urlStr
- itemApiLog.Body = utils.ReplaceSpaceAndWrap(fmt.Sprint(form))
- itemApiLog.Result = string(body)
- go roadshow.AddRsCalendarApiLog(itemApiLog)
- return
- }
- func GetAccessToken(isRefresh bool) (token string, err error) {
- defer func() {
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("获取上海的token失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- }
- }()
- token, redisErr := utils.Rc.RedisString("SH_ACCESS_TOKEN")
-
- if redisErr != nil || token == `` || isRefresh {
- return refreshAccessToken()
- }
- return
- }
- 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("新建上海研究员日历失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- }
- }()
-
- 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.CompanyName+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
- }
- }
- func MatterToSH(matter roadshow.RsMatters) (err error) {
- errMsg := ``
- defer func() {
- if err != nil {
- errMsg = err.Error() + ";" + errMsg
-
- go alarm_msg.SendAlarmMsg("新建上海研究员事项失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- }
- }()
-
- researcherInfo, err := getAdminInfoById(matter.SysUserId)
- if err != nil {
-
- 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
- }
- func UpdateSHCalendar(rsCalendarId, rsCalendarResearcherId int, activityType, roadshowType, activityCategory, roadshowPlatform, province, city string, calendarResearcherList []*roadshow.CalendarResearcher) (err error) {
- errMsg := ``
- defer func() {
- if errMsg != `` {
-
- go alarm_msg.SendAlarmMsg("更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
- }
- }()
-
- 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())
-
- go alarm_msg.SendAlarmMsg("上海关联表查询失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- fmt.Println(err)
- return
- }
-
- 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(), ";")
- }
-
-
-
-
-
-
-
-
- }
-
- 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
- }
- func UpdateSHCalendarByMatter(req roadshow.UpdateMattersReq) (err error) {
- defer func() {
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("更新上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- }
- }()
- 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())
-
- go alarm_msg.SendAlarmMsg("上海关联表查询失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- fmt.Println(err)
- return
- }
- 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, relationItem.CustomerName+relationItem.Content, 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
- }
- func DeleteSHCalendar(rsCalendarResearcherId int) (err error) {
- defer func() {
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("删除上海日历活动失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+fmt.Sprint("关系id:", rsCalendarResearcherId, ";err:", err.Error()), 3)
- }
- }()
- 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
- }
- func DeleteSHMatter(matterId int) (err error) {
- defer func() {
- if err != nil {
-
- go alarm_msg.SendAlarmMsg("删除上海研究员日历失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
- }
- }()
- 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
- }
- func SyncCalendarFromShanghai(userPhone, startDate, endDate string) (err error) {
- errMsg := ``
- defer func() {
- if errMsg != `` {
-
-
- go alarm_msg.SendAlarmMsg("上海路演数据同步到自系统失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
- }
- }()
-
- endDateTime, err := time.ParseInLocation(utils.FormatDate, endDate, time.Local)
- if err != nil {
- errMsg = `结束日期转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 {
- errMsg += fmt.Sprint("获取手机号信息失败:手机号:", userPhone, ";err:"+err.Error(), ";")
- return
- }
-
- rsCalendarResearcherList, err := roadshow.GetRsCalendarResearcherInfoIByResearcherIdAndDate(userPhoneInfo.AdminId, currDay, endDate)
- if err != nil {
- errMsg += 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 {
- errMsg = 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
- errMsg = "获取关联列表失败,err:" + tmpErr.Error()
- return
- }
- rsCalendarRelationMap := make(map[int]*roadshow.RsCalendarRelation)
- for _, rsCalendarRelation := range rsCalendarRelationList {
- rsCalendarRelationMap[rsCalendarRelation.ThirdCalendarId] = rsCalendarRelation
- }
- for _, v := range list {
-
- 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 {
- errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取路演研究员信息失败;err:"+tmpErr.Error(), ";")
- continue
- }
- rsCalendarInfo, tmpErr := roadshow.GetRsCalendarById(rsCalendarResearcherInfo.RsCalendarId)
- if tmpErr != nil {
- errMsg += 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([]admin.AdminItem, 0)
- researcherMap := make(map[int]admin.AdminItem)
- addResearcherList := make([]admin.AdminItem, 0)
- delResearcherIdList := make([]int, 0)
- 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 {
- errMsg += 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 {
- errMsg += fmt.Sprint("第三方日历ID:", v.ID, ";对方研究员信息失败;")
- continue
- }
- rsCalendarResearcherList, tmpErr := roadshow.GetRsCalendarResearcherListByRsCalendarId(rsCalendarInfo.RsCalendarId)
- if tmpErr != nil {
- errMsg += 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 {
- errMsg += 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
- errMsg += fmt.Sprint("第三方日历ID:", v.ID, "修改关联关系失败;err:"+tmpErr.Error(), ";")
- return
- }
- }
- } else {
-
-
- }
- } else {
-
- createUser, tmpErr := getAdminInfo(v.UserPhone)
- if tmpErr != nil {
- errMsg += fmt.Sprint("第三方日历ID:", v.ID, "获取创建人失败,创建人手机号:", v.UserPhone, ";err:"+tmpErr.Error(), ";")
- continue
- }
-
- researcherList := make([]admin.AdminItem, 0)
- researcherMobileList := strings.Split(v.ResearcherMobile, ",")
- if len(researcherMobileList) > 0 {
- for _, mobile := range researcherMobileList {
- researcherInfo, tmpErr := getAdminInfo(mobile)
- if tmpErr != nil {
- errMsg += 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
- errMsg += fmt.Sprint("第三方日历ID:", v.ID, "绑定关联关系失败;err:"+tmpErr.Error(), ";")
- continue
- }
-
- }
- }
- }
- var itemsApiLog []*roadshow.RsCalendarApiLog
-
- 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
- errMsg += fmt.Sprint("第三方日历ID:", deleteRsCalendarResearcher.ThirdCalendarId, "删除关联关系失败;err:"+tmpErr.Error(), ";")
- continue
- }
- itemApiLog := new(roadshow.RsCalendarApiLog)
- itemApiLog.CreateTime = time.Now()
- itemApiLog.Remark = "小程序对比上海接口之后手动删除"
- itemApiLog.Url = fmt.Sprint("userPhone", userPhone, "currDay", currDay, "endDate", endDate)
- itemApiLog.Body = ""
- itemApiLog.Result = ""
- itemApiLog.RsCalendarResearcherId = deleteRsCalendarResearcher.RsCalendarResearcherId
- itemsApiLog = append(itemsApiLog, itemApiLog)
-
-
-
-
-
-
- }
- }
- if len(itemsApiLog) > 0 {
- go roadshow.AddRsCalendarApiLogList(itemsApiLog)
- }
- return
- }
- 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("系统用户同步到上海失败:"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+errMsg, 3)
- }
- }()
- 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
- }
- func getAdminInfo(mobile string) (adminInfo admin.AdminItem, err error) {
- adminMap := make(map[string]admin.AdminItem)
- redisAdminData, redisErr := utils.Rc.RedisString(utils.CACHE_KEY_ADMIN)
- if redisErr != nil {
- list, err := admin.GetSysuserList("", []interface{}{}, 0, 1000)
-
- 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
- }
- func getAdminInfoById(sysId int) (adminInfo admin.AdminItem, err error) {
- adminMap := make(map[int]admin.AdminItem)
- redisAdminData, redisErr := utils.Rc.RedisString(utils.CACHE_KEY_ADMIN_ID)
- if redisErr != nil {
- list, err := admin.GetSysuserList("", []interface{}{}, 0, 1000)
-
- 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
- }
- func GetAllActivityType() (list []*roadshow.ActivityTypeList, err error) {
- list, err = roadshow.GetActivityTypeListByActivityTypePId(0)
- if err != nil {
- return
- }
- for _, v := range list {
- tmpList, tmpErr := roadshow.GetActivityTypeListByActivityTypePId(v.ActivityTypeId)
- if tmpErr != nil {
- err = tmpErr
- return
- }
- v.ChildList = tmpList
- }
- return
- }
- func GetCalendarFrom(userPhone, startDate, endDate string) (list []roadshow.UserCalendar, err error) {
- list, err = getCalendarFrom(userPhone, startDate, endDate)
- return
- }
|