同步手机号与外呼手机号

models/activity.go

@@ -404,7 +404,7 @@ func GetSignupExport(activityId int) (item []*SignupExportRep, err error) {
 			LEFT JOIN wx_user AS u ON u.user_id = s.user_id
 			LEFT JOIN cygx_activity AS a ON a.activity_id = s.activity_id
 			LEFT JOIN company_product AS p ON p.company_id = u.company_id 
-			WHERE a.activity_id = ?  AND s.fail_type = 0  AND p.product_id = 2`
+			WHERE a.activity_id = ?  AND s.fail_type = 0  `
 	_, err = o.Raw(sql, activityId).QueryRows(&item)
 	return
 }

models/activity_signup.go

@@ -304,3 +304,19 @@ func AddActivitySignupByRestrict(item *CygxActivitySignup) (lastId int64, err er
 	lastId, err = o.Insert(itemLog)
 	return
 }
+
+//列表
+func GetActivitySignupListAll() (items []*CygxActivitySignup, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM cygx_activity_signup `
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}
+
+//修改是否推送消息状态
+func UPdateSignup(item *CygxActivitySignup) (err error) {
+	sql := ` UPDATE cygx_activity_signup SET  outbound_mobile= ? , country_code=86  WHERE id = ?`
+	o := orm.NewOrm()
+	_, err = o.Raw(sql, item.Mobile, item.Id).Exec()
+	return
+}

services/activity.go

@@ -254,3 +254,26 @@ func SendEmailFileToExpert(cont context.Context) (err error) {
 	fmt.Println("发送附件完成")
 	return
 }
+
+func EditOutboundMobile(cont context.Context) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println("发送失败，Err:", err.Error())
+		}
+	}()
+
+	list, err := models.GetActivitySignupListAll()
+	if err != nil {
+		fmt.Println("GetActivitySendMsgListAll Err:", err.Error())
+		return
+	}
+	for _, v := range list {
+		err = models.UPdateSignup(v)
+		fmt.Println("修改:", strconv.Itoa(v.Id))
+		if err != nil {
+			fmt.Println("发送失败，Err:", err.Error()+strconv.Itoa(v.Id))
+		}
+	}
+	fmt.Println("修改完成")
+	return
+}

services/task.go

@@ -50,6 +50,9 @@ func Task() {
 	//预约外呼名单，会前1小时自动发送邮件给专家组
 	sendEmailFileToExpert := task.NewTask("sendEmailFileToExpert", "0 */5 8-22 * * *", SendEmailFileToExpert) //预约外呼名单，会前1小时自动发送邮件给专家组
 	task.AddTask("sendEmailFileToExpert", sendEmailFileToExpert)
+
+	//editOutboundMobile := task.NewTask("editOutboundMobile", "0 */1 8-22 * * *", EditOutboundMobile) //预约外呼名单，会前1小时自动发送邮件给专家组
+	//task.AddTask("sendEmailFileToExpert", editOutboundMobile)
 	//UpdateActivitySattus()
 	task.StartTask()
 	fmt.Println("end")