no message

services/roadshow/calendar.go

@@ -267,7 +267,7 @@ func getCalendarFrom(userPhone, startDate, endDate string) (list []roadshow.User
 //}
 
 // SyncCalendarFromShanghai 上海路演数据同步到自系统
-func SyncCalendarFromShanghai() (err error) {
+func SyncCalendarFromShanghai(cont context.Context) (err error) {
 	errMsgList := make([]string, 0)
 	defer func() {
 		if len(errMsgList) > 0 {
@@ -336,6 +336,7 @@ func SyncCalendarFromShanghai() (err error) {
 		if v == "" {
 			continue
 		}
+		time.Sleep(200 * time.Millisecond) // 加一个延迟0.2秒
 		userPhone = v
 		//以当前日期作为起始日期去同步
 		listSh, tmpErr := getCalendarFrom(userPhone, startDate, endDate)
@@ -352,7 +353,7 @@ func SyncCalendarFromShanghai() (err error) {
 	//根据研究员和开始/结束日期获取上海的活动路演
 	rsCalendarResearcherList, tmpErr := roadshow.GetRsCalendarResearcherInfoIByResearcherIdAndDate(startDate, endDate)
 	if tmpErr != nil {
-		errMsgList = append(errMsgList, fmt.Sprint("获取研究员日程信息失败：手机号：", userPhone, ";err:"+tmpErr.Error(), ";"))
+		errMsgList = append(errMsgList, fmt.Sprint("根据研究员和开始/结束日期获取上海的活动路演 失败：时间段：", startDate, endDate, ";err:"+tmpErr.Error(), ";"))
 		return
 	}
 	//return
@@ -629,7 +630,7 @@ func SyncCalendarFromShanghai() (err error) {
 				continue
 			}
 			CalendarToSH(mapRsCalendar[v.RsCalendarId], v.ResearcherId)
-			time.Sleep(3000 * time.Millisecond) // 延迟3秒
+			time.Sleep(1000 * time.Millisecond) // 延迟1秒
 		}
 	}
 	return

services/task.go

@@ -39,7 +39,7 @@ func InitTask() {
 			go alarm_msg.SendAlarmMsg(utils.APPNAME+"崩了"+time.Now().Format("2006-01-02 15:04:05")+"\n"+stack, 3)
 		}
 	}()
-	//comein.SyncWhiteList(nil)
+	comein.SyncWhiteList(nil)
 	// 实际开始定时任务
 	Task()
 }
@@ -291,6 +291,10 @@ func releaseTask() {
 	//问答社区定时发送模版消息给研究员
 	notifyNeedAnswerQuestionToResearch := task.NewTask("notifyNeedAnswerQuestionToResearch", "0 0 10 * * *", NotifyNeedAnswerQuestionToResearch)
 	task.AddTask("问答社区定时发送模版消息给研究员", notifyNeedAnswerQuestionToResearch)
+
+	//上海路演数据同步到自系统
+	syncCalendarFromShanghai := task.NewTask("syncCalendarFromShanghai", "0 0 * * * *", roadshow.SyncCalendarFromShanghai)
+	task.AddTask("上海路演数据同步到自系统", syncCalendarFromShanghai)
 }
 
 //func TaskTest() {