" + "【" + item.ActivityName + "】" + "
时间：" + item.ActivityTimeText + "
嘉宾：" + item.DistinguishedGuest + "" //fmt.Println(item.Body) //return err if mapOldYiDong[v.ID] == "" { itemsAdd = append(itemsAdd, item) newId, err := models.AddCygxActivity(item) if err != nil { fmt.Println(err) utils.FileLog.Info(string(err.Error())) return err } //把公司名称当做标的 对活动进行产业标的的关联 YidongActivityGroup(companyInfo, int(newId)) } else { //如果内容主体有做变更，就修改内容 if mapOldYiDongBody[v.ID] != fmt.Sprint(item.ActivityName+"12", item.Label, item.ChartPermissionId, item.ActivityTime, item.YidongActivityEndTime, item.DistinguishedGuest) { updateParams := make(map[string]interface{}) updateParams["ActivityName"] = item.ActivityName updateParams["Body"] = item.Body updateParams["Label"] = item.Label //updateParams["TemporaryLabel"] = item.TemporaryLabel updateParams["DistinguishedGuest"] = item.DistinguishedGuest updateParams["ChartPermissionId"] = item.ChartPermissionId updateParams["ChartPermissionName"] = item.ChartPermissionName updateParams["ChartPermissionNames"] = item.ChartPermissionNames updateParams["ActivityTime"] = item.ActivityTime updateParams["YidongActivityEndTime"] = item.YidongActivityEndTime updateParams["ActivityTimeText"] = item.ActivityTimeText updateParams["YidongActivityUrl"] = item.YidongActivityUrl updateParams["ActivityJoinType"] = item.ActivityJoinType updateParams["YidongSignUpStart"] = item.YidongSignUpStart updateParams["YidongSignUpEnd"] = item.YidongSignUpEnd updateParams["LastUpdatedTime"] = time.Now() whereParam := map[string]interface{}{"yidong_activity_id": item.YidongActivityId} err = models.UpdateByExpr(models.CygxActivity{}, whereParam, updateParams) if err != nil { return err } } } } } return } //获取易董活动详情 func GetYiDongActivityDetail(activityId string) (detail *models.ApifoxModaldetail, err error) { defer func() { if err != nil { go utils.SendAlarmMsg("获取易董活动详情失败："+err.Error(), 2) } }() var token string token, _ = GetYiDongToken() url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getRoadshowDetail?access_token=" + token method := "POST" payload := strings.NewReader(`{"activityId":"` + activityId + `"}`) client := &http.Client{} req, err := http.NewRequest(method, url, payload) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return } req.Header.Add("Content-Type", "application/json") res, err := client.Do(req) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return } defer res.Body.Close() var ApifoxModal *models.ApifoxModaldetail body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return } //添加请求日志记录 itemApiLog := new(models.CygxThreeApiLog) itemApiLog.CreateTime = time.Now() itemApiLog.Source = 1 itemApiLog.Url = url itemApiLog.Body = utils.ReplaceSpaceAndWrap(fmt.Sprint(payload)) itemApiLog.Result = string(body) go models.AddCygxThreeApiLog(itemApiLog) err = json.Unmarshal(body, &ApifoxModal) if err != nil { fmt.Println("Getres.PublicGetDate Err:", err.Error()) utils.FileLog.Info(err.Error()) return } detail = ApifoxModal return } //生成用户相关信息接口 获取用户tgc func GetYiDongCreateUserInfo(user *models.WxUserItem) (userTgc string, err error) { defer func() { if err != nil { fmt.Println(err) go utils.SendAlarmMsg("生成用户相关信息接口 获取用户tgc失败："+err.Error(), 2) utils.FileLog.Info(err.Error()) } }() url := utils.YiDongHuaWeiYunUrl + "app/hz/createUserInfo" method := "POST" payload := strings.NewReader(`{ "phone": "` + user.Mobile + `", "personName": "` + user.RealName + `", "companyName": "` + user.CompanyName + `", "jobName": "` + user.Position + `", "mobileCountryCode": "+` + user.CountryCode + `", "sourceFrom": "01" }`) client := &http.Client{} req, err := http.NewRequest(method, url, payload) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return } req.Header.Add("Content-Type", "application/json") res, err := client.Do(req) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return } defer res.Body.Close() var ApifoxModal *models.ApifoxModalUserTgc body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return } err = json.Unmarshal(body, &ApifoxModal) if err != nil { fmt.Println("Getres.PublicGetDate Err:", err.Error()) utils.FileLog.Info(err.Error()) return } userTgc = ApifoxModal.Result.Tgc return } //GetYiDongOriginalLink 将易懂的短连接转为长链接 func GetYiDongOriginalLink(item *models.ActivityDetail) (yidongLongLink string, err error) { defer func() { if err != nil { fmt.Println(err) go utils.SendAlarmMsg("将易懂的短连接转为长链接 失败："+err.Error(), 2) utils.FileLog.Info(err.Error()) } }() sliceYidongActivityUrl := strings.Split(item.YidongActivityUrl, "/") var shortLink string if len(sliceYidongActivityUrl) > 1 { shortLink = sliceYidongActivityUrl[len(sliceYidongActivityUrl)-1] } var token string token, err = GetYiDongToken() if err != nil { fmt.Println(err) return } url := utils.YiDonggetOriginalLink + shortLink + "&access_token=" + token fmt.Println(url) method := "GET" client := &http.Client{} req, err := http.NewRequest(method, url, nil) if err != nil { fmt.Println(err) return } res, err := client.Do(req) if err != nil { fmt.Println(err) return } defer res.Body.Close() var ApifoxModal *models.ApifoxgetOriginalLink body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return } err = json.Unmarshal(body, &ApifoxModal) if err != nil { fmt.Println("Getres.PublicGetDate Err:", err.Error()) utils.FileLog.Info(err.Error()) return } lingLink := ApifoxModal.Result slicelingLink := strings.Split(lingLink, "redirect_uri=") //var shortLink string if len(slicelingLink) > 1 { lingLink = slicelingLink[len(slicelingLink)-1] } yidongLongLink = lingLink return } //处理易董这边过来的时间格式 func GetActivityTextTime(timeYidong string) (timeText string) { strTime := timeYidong startTime := utils.StrTimeToTime(strTime) week := utils.StrDateTimeToWeek(strTime) timeStrYmd := startTime.Format(utils.FormatDate) timeStrHmm := startTime.Format(utils.FormatTime) timeYmd := utils.StrTimeToTime(timeStrYmd + " 12:00:00") //拼接当天中午12点的时间 var amOrPm string if startTime.After(timeYmd) { amOrPm = " PM" } else { amOrPm = " AM" } timeText = timeStrYmd + "（" + week + "）" + timeStrHmm + amOrPm return } func init232() { //YidongActivityGroup("美团", 1623) //GetYiDongActivityMeeting() //GetYiDongActivity() //var timeText string //strTime := "2022-08-18 12:34:00" //startTime := utils.StrTimeToTime(strTime) //week := utils.StrDateTimeToWeek(strTime) //timeStrYmd := startTime.Format(utils.FormatDate) //timeStrHmm := startTime.Format(utils.FormatTime) //timeYmd := utils.StrTimeToTime(timeStrYmd + " 12:00:00") //拼接当天中午12点的时间 //var amOrPm string //if startTime.After(timeYmd) { // amOrPm = " PM" //} else { // amOrPm = " AM" //} //timeText = timeStrYmd + "（" + week + "）" + timeStrHmm //fmt.Println(week) //fmt.Println(amOrPm) //fmt.Println(strTime) //fmt.Println(timeText) } //GetYiDongActivityMeeting获取易董到会详情 func GetYiDongActivityMeeting(cont context.Context) (err error) { var condition string startDate := time.Now().AddDate(0, 0, -2).Format(utils.FormatDateTime) endDate := time.Now().Add(-time.Minute * 120).Format(utils.FormatDateTime) condition += ` AND activity_time > ` + "'" + startDate + "'" condition += ` AND activity_time < ` + "'" + endDate + "'" //fmt.Println(startDate) //fmt.Println(endDate) artivityListYidong, err := models.GetActivityListByYidong(condition) if err != nil { fmt.Println("GetActivityListByYidong Err:", err.Error()) return err } //return err if len(artivityListYidong) == 0 { return err } var token string token, _ = GetYiDongToken() for _, v := range artivityListYidong { defer func() { if err != nil { go utils.SendAlarmMsg("获取易董到会详情失败："+err.Error(), 2) } }() url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getAttendPersonList?access_token=" + token method := "POST" payload := strings.NewReader(`{"activityId":"` + v.YidongActivityId + `"}`) client := &http.Client{} req, err := http.NewRequest(method, url, payload) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return err } req.Header.Add("Content-Type", "application/json") res, err := client.Do(req) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return err } defer res.Body.Close() var ApifoxModal *models.ApifoxModaluser body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) utils.FileLog.Info(err.Error()) return err } //utils.FileLog.Info(string(body)) //fmt.Println(string(body)) err = json.Unmarshal(body, &ApifoxModal) if err != nil { fmt.Println("Getres.PublicGetDate Err:", err.Error()) utils.FileLog.Info(err.Error()) return err } //跟易董返回的用户状态修改活动以提交到会状态 err = models.UpdateCygxActivitySubmitMeetingByYidong(v.YidongActivityId) if err != nil { fmt.Println("UpdateCygxActivitySubmitMeetingByYidong Err:", err.Error()) return err } if len(ApifoxModal.Result) > 0 { itemlog := new(models.CygxYidongActivityMeetingApiLog) itemlog.YidongActivityId = v.YidongActivityId itemlog.Data = string(body) itemlog.CreateTime = time.Now() err = models.AddCygxYidongActivityMeetingApiLog(itemlog) if err != nil { fmt.Println("AddCygxYidongActivityMeetingApiLog Err:", err.Error()) return err } for _, vresult := range ApifoxModal.Result { if vresult.EndTime != "" { err = models.UpdateCygxActivitySignupisMeet(v.ActivityId, vresult.PersonTelephone) if err != nil { fmt.Println("UpdateCygxActivitySignupisMeet Err:", err.Error()) return err } } } } } return } //YidongActivityGroup 添加活动与产业标的的关联 func YidongActivityGroup(subjectName string, activityId int) (err error) { subjectList, err := models.GetCygxIndustrialSubjectList(subjectName) if err != nil { fmt.Println(err) return err } if len(subjectList) == 0 { return err } fmt.Println("去掉临时标签的活动", activityId) err = models.UpdateActivityshowSubject(activityId) if err != nil { go utils.SendAlarmMsg("UpdateActivityshowSubject ：根据易董推过来的匹配信息，判断临时标签是否展示失败"+err.Error(), 2) } var industrialActivityItems []*models.CygxIndustrialActivityGroupManagement var subjectActivityItems []*models.CygxIndustrialActivityGroupSubject mapSubjectName := make(map[string]string) for _, v := range subjectList { industrialActivityItem := new(models.CygxIndustrialActivityGroupManagement) subjectActivityItem := new(models.CygxIndustrialActivityGroupSubject) industrialActivityItem.ActivityId = activityId industrialActivityItem.IndustrialManagementId = v.IndustrialManagementId industrialActivityItem.Source = 1 industrialActivityItem.CreateTime = time.Now() industrialActivityItems = append(industrialActivityItems, industrialActivityItem) subjectActivityItem.ActivityId = activityId subjectActivityItem.IndustrialSubjectId = v.IndustrialSubjectId subjectActivityItem.Source = 1 subjectActivityItem.CreateTime = time.Now() if mapSubjectName[v.SubjectName] == "" { subjectActivityItems = append(subjectActivityItems, subjectActivityItem) mapSubjectName[v.SubjectName] = v.SubjectName } } err = models.AddCygxActiuvityGroupMulti(industrialActivityItems, subjectActivityItems) if err != nil { go utils.SendAlarmMsg("AddCygxActiuvityGroupMulti ：批量添加易董活动关联的活动标签失败"+err.Error(), 2) } return }