易董

controllers/yidong.go

@@ -85,8 +85,7 @@ func (this *BaseYidongController) Ativitylist() {
 		this.Data["json"] = br
 		this.ServeJSON()
 	}()
-	cacheKey := utils.YD_TOKEN
-	Ydtoklen, _ := utils.Rc.RedisString(cacheKey)
+	Ydtoklen, _ := services.GetYiDongToken()
 	url := "https://services-dev.valueonline.cn/interact/activityManageApi/getRoadshowList?access_token=" + Ydtoklen
 	method := "POST"
 	//payload := strings.NewReader(`{"meetingStatus":"0,1","conveneStartStr":"2022-05-06","conveneEndStr":"2022-05-14",

services/task.go

@@ -84,6 +84,9 @@ func Task() {
 		updateCygxActivitySpecialSignupNum := task.NewTask("updateCygxActivitySpecialSignupNum", "0 25 0 * * *", UpdateCygxActivitySpecialSignupNum) //修改专项调研，用户与公司的参与数量
 		task.AddTask("updateCygxActivitySpecialSignupNum", updateCygxActivitySpecialSignupNum)
 
+		getYiDongActivity := task.NewTask("getYiDongActivity", "0 */2 * * * *", GetYiDongActivity) //同步易董的活动信息
+		task.AddTask("getYiDongActivity", getYiDongActivity)
+
 	}
 	if utils.RunMode != "release" {
 		getArticleListByApi := task.NewTask("getArticleListByApi", "0 */60 * * * *", GetArticleListByApi) //通过三方接口获取策略平台上的文章

services/yidong.go

@@ -1,6 +1,7 @@
 package services
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"hongze/hongze_cygx/models"
@@ -148,7 +149,6 @@ func GetYiDongToken() (token string, err error) {
 			err = errReq
 			return
 		}
-		fmt.Println(string(body))
 		errReq = json.Unmarshal(body, &ydtoklen)
 		if errReq != nil {
 			err = errReq
@@ -161,7 +161,7 @@ func GetYiDongToken() (token string, err error) {
 }
 
 //获取易董活动列表
-func GetYiDongActivity() (err error) {
+func GetYiDongActivity(cont context.Context) (err error) {
 	defer func() {
 		if err != nil {
 			fmt.Println(err)
@@ -170,11 +170,10 @@ func GetYiDongActivity() (err error) {
 	}()
 	var token string
 	token, _ = GetYiDongToken()
-	fmt.Println(token)
 	url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getRoadshowList?access_token=" + token
 	method := "POST"
 	payload := strings.NewReader(`{
-    "meetingStatus": "0,1,2"
+    "meetingStatus": "0"
 }`)
 	client := &http.Client{}
 	req, err := http.NewRequest(method, url, payload)
@@ -257,9 +256,9 @@ func GetYiDongActivity() (err error) {
 			} else {
 				//如果内容主体有做变更，就修改内容
 				if mapOldYiDongBody[v.ID] != fmt.Sprint(item.ActivityName, item.Label, item.ChartPermissionId, item.ActivityTime, item.YidongActivityEndTime, item.DistinguishedGuest) {
-					fmt.Println("修改")
-					fmt.Println(mapOldYiDongBody[v.ID])
-					fmt.Println(fmt.Sprint(item.ActivityName, item.Label, item.ChartPermissionId, item.ActivityTime, item.DistinguishedGuest))
+					//fmt.Println("修改")
+					//fmt.Println(mapOldYiDongBody[v.ID])
+					//fmt.Println(fmt.Sprint(item.ActivityName, item.Label, item.ChartPermissionId, item.ActivityTime, item.DistinguishedGuest))
 					updateParams := make(map[string]interface{})
 					updateParams["ActivityName"] = item.ActivityName
 					updateParams["Label"] = item.Label
@@ -280,7 +279,6 @@ func GetYiDongActivity() (err error) {
 				}
 			}
 		}
-
 	}
 	return
 }
@@ -295,7 +293,6 @@ func GetYiDongActivityDetail(activityId string) (detail *models.ApifoxModaldetai
 	}()
 	var token string
 	token, _ = GetYiDongToken()
-	fmt.Println(token)
 	url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getRoadshowDetail?access_token=" + token
 	method := "POST"
 	payload := strings.NewReader(`{"activityId":"` + activityId + `"}`)
@@ -322,7 +319,6 @@ func GetYiDongActivityDetail(activityId string) (detail *models.ApifoxModaldetai
 		return
 	}
 	utils.FileLog.Info(string(body))
-	fmt.Println(string(body))
 	err = json.Unmarshal(body, &ApifoxModal)
 	if err != nil {
 		fmt.Println("Getres.PublicGetDate Err:", err.Error())
@@ -384,7 +380,7 @@ func GetYiDongCreateUserInfo(user *models.WxUserItem) (userTgc string, err error
 
 //处理易董这边过来的时间格式
 func GetActivityTextTime(timeYidong string) (timeText string) {
-	strTime := "2022-08-18 12:34:00"
+	strTime := timeYidong
 	startTime := utils.StrTimeToTime(strTime)
 	week := utils.StrDateTimeToWeek(strTime)
 	timeStrYmd := startTime.Format(utils.FormatDate)
@@ -401,7 +397,7 @@ func GetActivityTextTime(timeYidong string) (timeText string) {
 }
 
 func init() {
-	GetYiDongActivity()
+	//GetYiDongActivity()
 	//var timeText string
 	//strTime := "2022-08-18 12:34:00"
 	//startTime := utils.StrTimeToTime(strTime)