腾讯会议号：" + MeetingCode + "
" } activityInfo.TencentConferenceNumber = MeetingCode err = cygx.UpdateCygxActivityTencentConferenceNumber(activityInfo) return } // 发布路演到活动广场（新） func YiDongUpdateActivityPublish(activityId int) { var err error defer func() { if err != nil { fmt.Println(err) go alarm_msg.SendAlarmMsg("发布路演到活动广场（新）；err："+err.Error(), 3) } }() activityInfo, err := cygx.GetAddActivityInfoById(activityId) if err != nil { fmt.Println(err) return } if activityInfo == nil { return } //C类分析师电话会 不对外发布 if activityInfo.ActivityTypeId == 7 { activityInfo.PublishStatus = 0 } token, _ := GetYidongToken() if token == "" { return } url := utils.YiDongZhengTongYunUrl + "interact/activityThirdApi/updateActivityPublish" + "?access_token=" + token if activityInfo.IsYidongConduct == 0 || activityInfo.YidongActivityIdByCygx == "" { return } params := YiDongUpdateActivityPublishResp{ Id: activityInfo.YidongActivityIdByCygx, PublishFlag: strconv.Itoa(activityInfo.PublishStatus), } postData, err := json.Marshal(params) if err != nil { fmt.Println("PostData json.Marshal Err:" + err.Error()) utils.FileLogCygx.Info("PostData json.Marshal Err:" + err.Error()) return } method := "POST" client := &http.Client{} req, err := http.NewRequest(method, url, strings.NewReader(string(postData))) if err != nil { fmt.Println(err) return } req.Header.Add("Content-Type", "application/json") res, err := client.Do(req) if err != nil { fmt.Println(err) return } defer res.Body.Close() body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) return } itemApiLog := new(cygx.CygxThreeApiLog) itemApiLog.CreateTime = time.Now() itemApiLog.Source = 1 itemApiLog.Url = url itemApiLog.Body = string(postData) itemApiLog.Result = string(body) go cygx.AddCygxThreeApiLog(itemApiLog) var yidongResp *YiDongGetRoadshowDetailResp err = json.Unmarshal(body, &yidongResp) if err != nil { return } if !yidongResp.Success { err = errors.New("发布路演到活动广场（新） 接口失败，" + yidongResp.ErrorCode + yidongResp.ErrorMsg) return } if activityInfo.PublishStatus == 0 { YiDongUpdateActivityStatus(activityId) } return } // 易董创建/更新路演活动结构体 type SignAppointmentsForThirdParam struct { ActivityId string `description:"易董活动ID" json:"activityId"` MobileCountryCode string `description:"国际区号注意要带前面+号 " json:"mobileCountryCode"` PersonTelephone string `description:"手机号" json:"personTelephone"` ThirdPartySource string `description:"第三方来源；弘则固定：01" json:"thirdPartySource"` InvestorType string `description:"投资者类型 0个人1机构" json:"investorType"` PersonName string `description:"姓名" json:"personName"` CompanyName string `description:"公司名" json:"companyName"` JoinRole string `description:"1:嘉宾, 2:普通参会人员, 3:会议助理。不传默认取值2" json:"joinRole"` OutCallStatus string `description:"1:需要，0：不需要。不传取默认值0" json:"outCallStatus"` } type YiDongSignAppointmentsForThirdResp struct { ErrorCode string `json:"errorCode"` // 错误码，001：活动不存在；002：该活动不支持此渠道报名；003：该手机号或邮箱已经被其他账号提交报名；004：不在报名时间；005：报名人数已满 ErrorMsg string `json:"errorMsg"` // 错误信息 Success bool `json:"success"` // 成功标识，true：成功；false：失败。可作为判断报名是否成功的标识 Timestamp float64 `json:"timestamp"` // 时间戳 } // 根据填入的主讲人姓名 以嘉宾的身份自动报名 func YiDongSignAppointmentsForThirdSpeaker(activityId int) { var err error defer func() { if err != nil { fmt.Println(err) go alarm_msg.SendAlarmMsg("易董获取路演详细信息（2.0）；err："+err.Error(), 3) } }() activityInfo, err := cygx.GetAddActivityInfoById(activityId) if err != nil { fmt.Println(err) return } if activityInfo == nil { return } speaker := activityInfo.Speaker if speaker == "" { return } // 获取admin列表-匹配联系人是否为admin用户 sysUserList, err := cygx.GetAskEmail() var personNameites []*cygx.AskEmailRep if err != nil { return } //var personName string //var personTelephone string for _, v := range sysUserList { if strings.Contains(speaker, v.Name) && v.Mobile != "" { personNameites = append(personNameites, &cygx.AskEmailRep{ Name: v.Name, Mobile: v.Mobile, }) } } if activityInfo.IsYidongConduct == 0 || len(personNameites) == 0 { return } url := utils.YiDongHuaWeiYunUrl + "app/hz/signAppointmentsForThird" for _, v := range personNameites { params := SignAppointmentsForThirdParam{ ActivityId: activityInfo.YidongActivityIdByCygx, MobileCountryCode: "+86", PersonTelephone: v.Mobile, ThirdPartySource: "01", InvestorType: "0", PersonName: v.Name, JoinRole: "1", CompanyName: "弘则研究", OutCallStatus: "0", } postData, err := json.Marshal(params) if err != nil { fmt.Println("PostData json.Marshal Err:" + err.Error()) utils.FileLogCygx.Info("PostData json.Marshal Err:" + err.Error()) return } method := "POST" client := &http.Client{} req, err := http.NewRequest(method, url, strings.NewReader(string(postData))) if err != nil { fmt.Println(err) return } req.Header.Add("Content-Type", "application/json") res, err := client.Do(req) if err != nil { fmt.Println(err) return } defer res.Body.Close() body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) return } itemApiLog := new(cygx.CygxThreeApiLog) itemApiLog.CreateTime = time.Now() itemApiLog.Source = 1 itemApiLog.Url = url itemApiLog.Body = string(postData) itemApiLog.Result = string(body) go cygx.AddCygxThreeApiLog(itemApiLog) var yidongResp *YiDongSignAppointmentsForThirdResp err = json.Unmarshal(body, &yidongResp) if err != nil { return } if !yidongResp.Success { err = errors.New(" 根据填入的主讲人姓名 以嘉宾的身份自动报名 接口失败，" + yidongResp.ErrorCode + yidongResp.ErrorMsg) return } } return } //func init() { // YiDongUpdateActivityStatus(2180) //} // 删除路演活动（新） func YiDongUpdateActivityStatus(activityId int) { var err error defer func() { if err != nil { fmt.Println(err) go alarm_msg.SendAlarmMsg(" 删除路演活动（新）；err："+err.Error(), 3) } }() activityInfo, err := cygx.GetAddActivityInfoById(activityId) if err != nil { fmt.Println(err) return } if activityInfo == nil { return } //C类分析师电话会 不对外发布 if activityInfo.ActivityTypeId == 7 { activityInfo.PublishStatus = 0 } //如果关联的易董活动ID为空，那么不做处理 if activityInfo.YidongActivityIdByCygx == "" { return } //如果状态是已发布，而且是易董办会那么就不做处理 if activityInfo.IsYidongConduct == 1 && activityInfo.PublishStatus == 1 { return } token, _ := GetYidongToken() if token == "" { return } url := utils.YiDongZhengTongYunUrl + "interact/activityThirdApi/updateActivityStatus" + "?access_token=" + token //if activityInfo.IsYidongConduct == 0 || activityInfo.YidongActivityIdByCygx == "" { // return //} params := YiDongUpdateActivityPublishResp{ Id: activityInfo.YidongActivityIdByCygx, } postData, err := json.Marshal(params) if err != nil { fmt.Println("PostData json.Marshal Err:" + err.Error()) utils.FileLogCygx.Info("PostData json.Marshal Err:" + err.Error()) return } method := "POST" client := &http.Client{} req, err := http.NewRequest(method, url, strings.NewReader(string(postData))) if err != nil { fmt.Println(err) return } req.Header.Add("Content-Type", "application/json") res, err := client.Do(req) if err != nil { fmt.Println(err) return } defer res.Body.Close() body, err := ioutil.ReadAll(res.Body) if err != nil { fmt.Println(err) return } itemApiLog := new(cygx.CygxThreeApiLog) itemApiLog.CreateTime = time.Now() itemApiLog.Source = 1 itemApiLog.Url = url itemApiLog.Body = string(postData) itemApiLog.Result = string(body) go cygx.AddCygxThreeApiLog(itemApiLog) var yidongResp *YiDongGetRoadshowDetailResp err = json.Unmarshal(body, &yidongResp) if err != nil { return } if !yidongResp.Success { err = errors.New("删除路演活动 接口失败，" + yidongResp.ErrorCode + yidongResp.ErrorMsg) return } activityInfo.Body = strings.Replace(activityInfo.Body, "腾讯会议号："+activityInfo.TencentConferenceNumber, "", -1) activityInfo.Body = strings.Replace(activityInfo.Body, "", "", -1) activityInfo.YidongActivityIdByCygx = "" activityInfo.TencentConferenceNumber = "" err = cygx.UpdateCygxActivityTencentConferenceNumber(activityInfo) return } // GetLoginAuthCodeReq 获取登录编码请求体 type GetYiDongActivityByApiReq struct { MeetingStatus string `json:"meetingStatus" description:"会议状态必需（0未开始1进行中2已结束）多个逗号分隔"` ConveneStartStr string `json:"conveneStartStr" description:"活动日期范围开始"` ConveneEndStr string `json:"conveneEndStr" description:"活动日期范围结束"` LastUpdateTime string `json:"lastUpdateTime" description:"上次同步时间（用于筛选更新时间大于同步时间的活动数据）"` } // 根据条件获取易董建会列表信息 func GetYiDongActivityListByApi(param *GetYiDongActivityByApiReq) (yiDongResult []YidongActivityResult) { var err error defer func() { if err != nil { fmt.Println(err) go alarm_msg.SendAlarmMsg(fmt.Sprint("根据条件获取易董建会列表信息 GetYiDongActivityListByApi"+err.Error(), param), 2) } }() var token string token, _ = GetYidongToken() url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getRoadshowList?access_token=" + token method := "POST" data, e := json.Marshal(param) if e != nil { err = errors.New("data json marshal err: " + e.Error()) return } payload := strings.NewReader(string(data)) client := &http.Client{} req, e := http.NewRequest(method, url, payload) if e != nil { err = errors.New(" http.NewRequest err: " + e.Error()) return } req.Header.Add("Content-Type", "application/json") res, e := client.Do(req) if e != nil { err = errors.New(" client.Do err: " + e.Error()) return } defer res.Body.Close() var ApifoxModal *YidongApifoxModal body, e := ioutil.ReadAll(res.Body) if e != nil { err = errors.New(" ioutil.ReadAll: " + e.Error()) return } //添加请求日志记录 itemApiLog := new(cygx.CygxThreeApiLog) itemApiLog.CreateTime = time.Now() itemApiLog.Source = 1 itemApiLog.Url = url itemApiLog.Body = utils.ReplaceSpaceAndWrap(fmt.Sprint(payload)) itemApiLog.Result = string(body) go cygx.AddCygxThreeApiLog(itemApiLog) err = json.Unmarshal(body, &ApifoxModal) if err != nil { fmt.Println("Getres.PublicGetDate Err:", err.Error()) return } if len(ApifoxModal.Result) > 0 { yiDongResult = ApifoxModal.Result } else { yiDongResult = make([]YidongActivityResult, 0) } return } type GetYiDongActivityMeetByActivityIdReq struct { ActivityId string `json:"activityId" description:"活动ID"` } type YidongApifoxModaluser struct { ErrorCode interface{} `json:"errorCode"` ErrorMsg interface{} `json:"errorMsg"` Result []YidongResultuser `json:"result"` Success bool `json:"success"` Timestamp int64 `json:"timestamp"` } // 根据条件获取易董活动ID获取到会信息 func GetYiDongActivityMeetDataByaAtivityId(ativityId string) (yiDongResult []YidongResultuser) { var err error defer func() { if err != nil { fmt.Println(err) go alarm_msg.SendAlarmMsg(fmt.Sprint("根据条件获取易董建会列表信息 GetYiDongActivityListByApi"+err.Error(), ativityId), 2) } }() var token string token, _ = GetYidongToken() url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getAttendPersonList?access_token=" + token method := "POST" param := new(GetYiDongActivityMeetByActivityIdReq) param.ActivityId = ativityId data, e := json.Marshal(param) if e != nil { err = errors.New("data json marshal err: " + e.Error()) return } payload := strings.NewReader(string(data)) client := &http.Client{} req, e := http.NewRequest(method, url, payload) if e != nil { err = errors.New(" http.NewRequest err: " + e.Error()) return } req.Header.Add("Content-Type", "application/json") res, e := client.Do(req) if e != nil { err = errors.New(" client.Do err: " + e.Error()) return } defer res.Body.Close() var ApifoxModal *YidongApifoxModaluser body, e := ioutil.ReadAll(res.Body) if e != nil { err = errors.New(" ioutil.ReadAll err: " + e.Error()) return } e = json.Unmarshal(body, &ApifoxModal) if e != nil { err = errors.New(" json.Unmarshal err: " + e.Error()) return } //添加请求日志记录 itemApiLog := new(cygx.CygxThreeApiLog) itemApiLog.CreateTime = time.Now() itemApiLog.Source = 1 itemApiLog.Url = url itemApiLog.Body = utils.ReplaceSpaceAndWrap(fmt.Sprint(payload)) itemApiLog.Result = string(body) go cygx.AddCygxThreeApiLog(itemApiLog) err = json.Unmarshal(body, &ApifoxModal) if err != nil { fmt.Println("Getres.PublicGetDate Err:", err.Error()) return } if len(ApifoxModal.Result) > 0 { yiDongResult = ApifoxModal.Result } else { yiDongResult = make([]YidongResultuser, 0) } return } // 根据条件获取易董活动ID获取到会信息 func GetYiDongActivityMeeting(yidongActivityId string, cygxActivityId int) (yiDongResult []YidongResultuser) { var err error defer func() { if err != nil { fmt.Println(err) go alarm_msg.SendAlarmMsg(fmt.Sprint("根据条件获取易董建会列表信息 GetYiDongActivityMeeting"+err.Error(), cygxActivityId), 2) } }() //跟易董返回的用户状态修改活动以提交到会状态 e := cygx.UpdateCygxActivitySubmitMeetingByYidong(yidongActivityId) if e != nil { err = errors.New("UpdateCygxActivitySubmitMeetingByYidong err: " + e.Error()) return } meetDataList := GetYiDongActivityMeetDataByaAtivityId(yidongActivityId) var mobiles []string var mobileStr string var mobileStrMeet string mapActivityAttendanceDetail := make(map[string]*cygx.CygxActivityAttendanceDetail) if len(meetDataList) > 0 { var itemsUpdate []*cygx.CygxActivitySignupDetail needAddAttendanc := make([]*cygx.CygxActivityAttendanceDetail, 0) for _, vresult := range meetDataList { if vresult.PersonTelephone == "" { continue } if vresult.Duration != "" || vresult.DurationReview != "" { mobiles = append(mobiles, vresult.PersonTelephone) var itemDetail = new(cygx.CygxActivitySignupDetail) if vresult.Duration != "" { itemDetail.FirstMeetingTime = vresult.StartTime itemDetail.LastMeetingTime = vresult.EndTime itemDetail.Duration = vresult.Duration itemDetail.MeetingStatusStr = "直播" } else if vresult.DurationReview != "" { itemDetail.FirstMeetingTime = vresult.StartTimeReview itemDetail.LastMeetingTime = vresult.EndTimeReview itemDetail.Duration = vresult.DurationReview itemDetail.MeetingStatusStr = "回放" } itemDetail.Position = vresult.JobName itemDetail.RealName = vresult.PersonName itemDetail.Mobile = vresult.PersonTelephone itemDetail.OutboundMobile = vresult.PersonTelephone itemDetail.IsMeeting = 1 itemDetail.ActivityId = cygxActivityId mapActivityAttendanceDetail[vresult.PersonTelephone] = new(cygx.CygxActivityAttendanceDetail) mapActivityAttendanceDetail[vresult.PersonTelephone].FirstMeetingTime = vresult.StartTime mapActivityAttendanceDetail[vresult.PersonTelephone].LastMeetingTime = vresult.EndTime mapActivityAttendanceDetail[vresult.PersonTelephone].Duration = utils.GetAttendanceDetailSecondsByYiDong(vresult.Duration) itemsUpdate = append(itemsUpdate, itemDetail) } item := new(cygx.CygxActivityAttendanceDetail) item.ActivityId = cygxActivityId item.Mobile = vresult.PersonTelephone if vresult.Duration != "" { if vresult.Duration != "" { item.FirstMeetingTime = vresult.StartTime item.LastMeetingTime = vresult.EndTime item.Duration = vresult.Duration item.MeetingStatusStr = "直播" } else if vresult.DurationReview != "" { item.FirstMeetingTime = vresult.StartTimeReview item.LastMeetingTime = vresult.EndTimeReview item.Duration = vresult.DurationReview item.MeetingStatusStr = "回放" } item.Position = vresult.JobName item.RealName = vresult.PersonName item.FirstMeetingTime = vresult.StartTime item.LastMeetingTime = vresult.EndTime item.Duration = vresult.Duration item.IsMeetingStr = 1 mobileStrMeet += "'" + vresult.PersonTelephone + "'" + "," item.CreateTime = time.Now() needAddAttendanc = append(needAddAttendanc, item) } mobileStr += "'" + vresult.PersonTelephone + "'" + "," } lenmobiles := len(mobiles) if lenmobiles > 0 { var parsYd []interface{} var conditionYd string conditionYd = ` AND mobile IN (` + utils.GetOrmInReplace(lenmobiles) + `) AND activity_id=? ` parsYd = append(parsYd, mobiles, cygxActivityId) e = cygx.UpdateCygxActivitySignupisMeetList(conditionYd, parsYd) if e != nil { err = errors.New("UpdateCygxActivitySignupisMeetList err: " + e.Error()) return } e = cygx.UpdateActivitySignupDetailMultiByYiDong(itemsUpdate) if e != nil { err = errors.New("UpdateActivitySignupDetailMultiByYiDong err: " + e.Error()) return } } mobileStr = strings.TrimRight(mobileStr, ",") if mobileStr == "" { mobileStr = "1" } mobileStrMeet = strings.TrimRight(mobileStrMeet, ",") if mobileStrMeet == "" { mobileStrMeet = "1" } listUser, e := cygx.GetWxUserOutboundMobile(mobileStr) if e != nil { err = errors.New("GetWxUserOutboundMobile err: " + e.Error()) return } for kAdd, vAdd := range needAddAttendanc { for _, v2 := range listUser { if v2.OutboundMobile == vAdd.Mobile || v2.Mobile == vAdd.Mobile { if needAddAttendanc[kAdd].CompanyId <= 1 { needAddAttendanc[kAdd].CompanyId = v2.CompanyId needAddAttendanc[kAdd].SellerName = v2.SellerName needAddAttendanc[kAdd].CompanyName = v2.CompanyName //needAddAttendanc[k].IsMeetingStr = 1 } } } } //参会记录 e = cygx.AddAttendancDetail(needAddAttendanc, cygxActivityId, mobileStrMeet) if e != nil { err = errors.New("AddAttendancDetail err: " + e.Error()) return } ////处理是否限制报名 e = AddCygxActivityRestrictSignupByAdmin(cygxActivityId) if e != nil { err = errors.New("AddCygxActivityRestrictSignupByAdmin err: " + e.Error()) return } AddctivitySignupDetailListByHand(needAddAttendanc, cygxActivityId) } return }