Merge branch 'master' of http://8.136.199.33:3000/hongze/hongze_cygx into cygx_10.4

models/activity.go

@@ -624,6 +624,14 @@ func UPdateSendedMsgStatus(signupIds string) (err error) {
 	return
 }
 
+// 修改是否推送消息状态
+func UPdateSendedYiDongSignUp(activityId int) (err error) {
+	sql := ` UPDATE cygx_activity SET  is_yidong_sign_up= 1  WHERE activity_id = ? `
+	o := orm.NewOrm()
+	_, err = o.Raw(sql, activityId).Exec()
+	return
+}
+
 // 修改是否推送消息状态
 func UPdateSendedMsgMeetingStatus(signupIds string) (err error) {
 	sql := ` UPDATE cygx_activity_meeting_reminder SET  is_send_wx_msg= 1  WHERE id IN(` + signupIds + `)`

services/activity.go

@@ -2088,3 +2088,15 @@ func GetActivityCityResp() (mapItem map[string]string, err error) {
 	mapItem = mapActivityCity
 	return
 }
+
+// UpdateIsSendYidongSignUp更改活动是否向易董推送报名名单的状态
+func UpdateIsSendYidongSignUp(activityId int) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			go utils.SendAlarmMsg("更改活动是否向易董推送报名名单的状态，失败,活动ID："+strconv.Itoa(activityId)+err.Error(), 2)
+		}
+	}()
+	err = models.UPdateSendedYiDongSignUp(activityId)
+	return
+}

services/yidong.go

@@ -797,6 +797,7 @@ func YidongActivityGroup(subjectName string, activityId int) (err error) {
 
 // 会前一小时将，报名信息同步到易董
 func YiDongSignAppointmentsForThird(cont context.Context) (err error) {
+	//func YiDongSignAppointmentsForThird() (err error) {
 	defer func() {
 		if err != nil {
 			fmt.Println(err)
@@ -807,7 +808,7 @@ func YiDongSignAppointmentsForThird(cont context.Context) (err error) {
 	var condition string
 	startDate := time.Now().Add(+time.Minute * 45).Format(utils.FormatDateTime)
 	endDate := time.Now().Add(+time.Minute * 60).Format(utils.FormatDateTime)
-	condition = " AND yidong_activity_id_by_cygx != ''  AND activity_time  BETWEEN ?  AND  ? "
+	condition = " AND  is_yidong_sign_up = 0 AND yidong_activity_id_by_cygx != ''  AND activity_time  BETWEEN ?  AND  ? "
 	pars = append(pars, startDate, endDate)
 	activityList, err := models.GetActivityListByCondition(condition, pars)
 	if err != nil {
@@ -816,6 +817,7 @@ func YiDongSignAppointmentsForThird(cont context.Context) (err error) {
 	url := utils.YiDongHuaWeiYunUrl + "app/hz/signAppointmentsForThird"
 	var outCallStatus string
 	for _, v := range activityList {
+		go UpdateIsSendYidongSignUp(v.ActivityId)
 		var parsSignUp []interface{}
 		var conditionSignUp string
 		conditionSignUp += ` AND activity_id = ?`