no message

models/activity_attendance_detail.go

@@ -189,7 +189,7 @@ func GetActivityAttendanceDetailList(activityIds string) (items []*CygxActivityA
 //我的日程列表
 func GetActivityAttendanceDetailListAll() (items []*CygxActivityAttendanceDetail, err error) {
 	o := orm.NewOrm()
-	sql := `SELECT * FROM cygx_activity_attendance_detail WHERE  activity_id >= 1000 ORDER BY activity_id  ASC  `
+	sql := `SELECT * FROM cygx_activity_attendance_detail WHERE  activity_id <= 100 ORDER BY activity_id  ASC  `
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }

models/activity_signup_detail.go

@@ -141,3 +141,69 @@ func UpdateActivitySignupDetailMulti(items []*CygxActivitySignupDetail) (err err
 	}
 	return
 }
+
+//添加
+func AddCygxActivitySignupDetailCopy(items []*CygxActivitySignupDetail) (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 []*CygxActivitySignupDetail) (err error) {
+	o := orm.NewOrm()
+	p, err := o.Raw(` UPDATE cygx_activity_signup_detail SET 
+							first_meeting_time = ?,
+							last_meeting_time = ?,
+							duration = ?,
+							meeting_type_str = ?,
+							meeting_authentication = ?,
+							meeting_status_str = ?,
+							position = ?,
+							is_meeting = ?,
+							userid_entity = ?,
+							activity_time = ?,
+							crm_company_map_status_id = ?
+							WHERE mobile = ? AND activity_id = ? `).Prepare()
+	if err != nil {
+		return
+	}
+	defer func() {
+		_ = p.Close() // 别忘记关闭 statement
+	}()
+	for _, v := range items {
+		_, err = p.Exec(
+			v.FirstMeetingTime,
+			v.LastMeetingTime,
+			v.Duration,
+			v.MeetingTypeStr,
+			v.MeetingAuthentication,
+			v.MeetingStatusStr,
+			v.Position,
+			v.IsMeeting,
+			v.UseridEntity,
+			v.ActivityTime,
+			v.CrmCompanyMapStatusId,
+			v.Mobile, v.ActivityId)
+		if err != nil {
+			return
+		}
+	}
+	return
+}

services/activity_signup_detail.go

@@ -32,12 +32,12 @@ func AddctivitySignupDetail(cont context.Context) (err error) {
 	var condition string
 	var pars []interface{}
 	if actLen > 0 {
-		//condition += ` AND activity_id IN (` + utils.GetOrmInReplace(actLen) + `)`
-		//pars = append(pars, activityIds)
+		condition += ` AND activity_id IN (` + utils.GetOrmInReplace(actLen) + `)`
+		pars = append(pars, activityIds)
 	} else {
 		return err
 	}
-	condition = ""
+	//condition = ""
 	//获取当天已经结束了 活动的报名人数
 	signUpList, err := models.GetSignupDetailBySignup(condition, pars)
 	if err != nil && err.Error() != utils.ErrNoRow() {
@@ -66,6 +66,7 @@ func AddctivitySignupDetail(cont context.Context) (err error) {
 				item.ActivityId = v.ActivityId
 				item.CreateTime = v.CreateTime
 				item.Mobile = v.Mobile
+				item.OutboundMobile = v.OutboundMobile
 				item.Email = v.Email
 				item.CompanyId = v.CompanyId
 				item.CompanyName = v.CompanyName
@@ -123,6 +124,20 @@ func AddctivitySignupDetailByJmcj(itemsDetail []*models.CygxActivityAttendanceDe
 			mapsignUpDetai[fmt.Sprint("ActivityId", v.ActivityId, "Mobile", v.Mobile)] = v.Mobile
 		}
 	}
+
+	//获取当天已经结束了 活动的报名人数
+	signUpList, err := models.GetSignupDetailBySignup(condition, pars)
+	if err != nil && err.Error() != utils.ErrNoRow() {
+		return err
+	}
+	//建立外呼号与手机号的绑定
+	mapsignUp := make(map[string]string)
+	if len(signUpList) > 0 {
+		for _, v := range signUpList {
+			mapsignUp[fmt.Sprint(v.OutboundMobile)] = v.Mobile
+		}
+	}
+
 	var itemsAdd []*models.CygxActivitySignupDetail
 	var itemsUpdate []*models.CygxActivitySignupDetail
 
@@ -130,7 +145,13 @@ func AddctivitySignupDetailByJmcj(itemsDetail []*models.CygxActivityAttendanceDe
 		var item = new(models.CygxActivitySignupDetail)
 		item.ActivityId = v.ActivityId
 		item.RealName = v.RealName
-		item.Mobile = v.Mobile
+		//如果手机号存在那么就是报名的，不存在就是直接参与的
+		if _, ok := mapsignUp[v.Mobile]; ok {
+			item.Mobile = mapsignUp[v.Mobile]
+		} else {
+			item.Mobile = v.Mobile
+		}
+		item.OutboundMobile = v.Mobile
 		item.CompanyName = v.CompanyName
 		item.CompanyId = v.CompanyId
 		item.SellerName = v.SellerName
@@ -171,6 +192,9 @@ func AddctivitySignupDetailByJmcj(itemsDetail []*models.CygxActivityAttendanceDe
 
 	return err
 }
+func init() {
+	GetCygxActivityAttendanceDetail()
+}
 
 func GetCygxActivityAttendanceDetail() {
 	listAll, err := models.GetActivityAttendanceDetailListAll()