no message

models/activity_signup.go

@@ -581,3 +581,14 @@ func UpdateCygxActivitySignupisMeet(activityId int, mobile string) (err error) {
 	_, err = o.Raw(sql, activityId, mobile).Exec()
 	return
 }
+
+//UpdateCygxActivitySignupisMeetList 批量修改易董的活动，用户已到会
+func UpdateCygxActivitySignupisMeetList(condition string, pars []interface{}) (err error) {
+	if condition == "" {
+		return
+	}
+	o := orm.NewOrm()
+	sql := `UPDATE cygx_activity_signup SET is_meeting=1 WHERE  1= 1 ` + condition
+	_, err = o.Raw(sql, pars).Exec()
+	return
+}

models/activity_signup_detail.go

@@ -142,62 +142,10 @@ func UpdateActivitySignupDetailMulti(items []*CygxActivitySignupDetail) (err err
 	return
 }
 
-type CygxActivitySignupDetailCopy struct {
-	Id                    int       `orm:"column(id);pk"`
-	ActivityId            int       `description:"活动ID"`
-	UserId                int       `description:"用户ID"`
-	CreateTime            time.Time `description:"创建时间"`
-	Mobile                string    `description:"手机号"`
-	Email                 string    `description:"邮箱"`
-	CompanyId             int       `description:"公司id"`
-	CompanyName           string    `description:"公司名称"`
-	FailType              int       `description:"失败原因，0，未失败，1总人数已满，2单机构超限制，3，爽约次数超限"`
-	SignupType            int       `description:"报名方式，1预约外呼，2自主拨入，3我要报名"`
-	DoFailType            int       `description:"失败原因，0，未失败，1总人数已满，2单机构超限制，3，爽约次数超限"`
-	OutboundMobile        string    `description:"外呼手机号"`
-	CountryCode           string    `description:"手机国家区号"`
-	RealName              string    `description:"用户实际名称"`
-	SellerName            string    `description:"所属销售"`
-	FirstMeetingTime      string    `description:"首次入会时间"`
-	LastMeetingTime       string    `description:"最后退出时间"`
-	Duration              string    `description:"参会时长"`
-	MeetingTypeStr        string    `description:"参会方式"`
-	MeetingAuthentication string    `description:"参会权鉴"`
-	MeetingStatusStr      string    `description:"参会状态"`
-	Position              string    `description:"职位"`
-	IsMeeting             int       `description:"是否到会，1到会，0未到会"`
-	UseridEntity          int       `description:"参会者身份. 1:主讲人, 2:主持人, 3:嘉宾, 4:普通参会者, 5:联席主讲人, 6:会议助理"`
-	ActivityTime          string    `description:"活动时间"`
-	CrmCompanyMapStatusId int       `description:"转换后的对应状态信息：1=正式客户, 2=曾使用客户, 3=其他"`
-}
-
-//添加
-func AddCygxActivitySignupDetailCopy(items []*CygxActivitySignupDetailCopy) (err error) {
-	o, err := orm.NewOrm().Begin()
-	if err != nil {
-		return
-	}
-	defer func() {
-		if err == nil {
-			o.Commit()
-		} else {
-			o.Rollback()
-		}
-	}()
-	if len(items) > 0 {
-		//批量添加
-		_, err = o.InsertMulti(len(items), items)
-		if err != nil {
-			return err
-		}
-	}
-	return
-}
-
-// UpdateActivitySignupDetailMulti 批量修改用户报名信息且报名的人
-func UpdateActivitySignupDetailMultiCopy(items []*CygxActivitySignupDetailCopy) (err error) {
+// UpdateActivitySignupDetailMultiByYiDong 易董批量修改用户报名信息且报名的人
+func UpdateActivitySignupDetailMultiByYiDong(items []*CygxActivitySignupDetail) (err error) {
 	o := orm.NewOrm()
-	p, err := o.Raw(` UPDATE cygx_activity_signup_detail_copy SET 
+	p, err := o.Raw(` UPDATE cygx_activity_signup_detail SET 
 							first_meeting_time = ?,
 							last_meeting_time = ?,
 							duration = ?,
@@ -236,13 +184,3 @@ func UpdateActivitySignupDetailMultiCopy(items []*CygxActivitySignupDetailCopy)
 	}
 	return
 }
-
-// 获取参会记录表列表
-func GetSignupDetailListCopy(condition string, pars []interface{}) (list []*CygxActivitySignupDetail, err error) {
-	sql := `SELECT * FROM cygx_activity_signup_detail_copy  WHERE  1= 1 `
-	if condition != "" {
-		sql += condition
-	}
-	_, err = orm.NewOrm().Raw(sql, pars).QueryRows(&list)
-	return
-}

models/db.go

@@ -121,7 +121,6 @@ func init() {
 		new(CygxIndustrialArticleGroupManagement),
 		new(ArticleTopHistoryRecord),
 		new(CygxActivitySignupDetail),
-		new(CygxActivitySignupDetailCopy),
 		new(CygxMicroRoadshowVideoHistory),
 		new(MicroRoadshowVideo),
 		new(CygxActivityVideoHistory),

services/yidong.go

@@ -615,6 +615,7 @@ func GetYiDongActivityMeeting(cont context.Context) (err error) {
 			fmt.Println("UpdateCygxActivitySubmitMeetingByYidong Err:", err.Error())
 			return err
 		}
+		var mobiles []string
 		if len(ApifoxModal.Result) > 0 {
 			itemlog := new(models.CygxYidongActivityMeetingApiLog)
 			itemlog.YidongActivityId = v.YidongActivityId
@@ -627,6 +628,7 @@ func GetYiDongActivityMeeting(cont context.Context) (err error) {
 			}
 			for _, vresult := range ApifoxModal.Result {
 				if vresult.EndTime != "" {
+					mobiles = append(mobiles, vresult.PersonTelephone)
 					err = models.UpdateCygxActivitySignupisMeet(v.ActivityId, vresult.PersonTelephone)
 					if err != nil {
 						fmt.Println("UpdateCygxActivitySignupisMeet Err:", err.Error())
@@ -634,6 +636,14 @@ func GetYiDongActivityMeeting(cont context.Context) (err error) {
 					}
 				}
 			}
+
+			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, v.ActivityId)
+			}
 		}
 	}
 	return