Merge branch 'master' of http://git.shengws.com/zhangbj/scrm-go

controllers/article/article_controller.go

@@ -15,12 +15,15 @@ import (
 
 func ArticleRouters() {
 
-	beego.Router("/api/acticle/createacticle",&ArticleManage{},"Get:CreateArticle")
+	beego.Router("/api/acticle/createacticle",&ArticleManage{},"Post:CreateArticle")
 	beego.Router("/api/acticle/getArticleType",&ArticleManage{},"Get:GetArticleType")
 	beego.Router("/api/acticle/getAllArticles",&ArticleManage{},"Get:GetAllArticles")
 	beego.Router("/api/article/addCategory",&ArticleManage{},"Post:AddCategory")
 	beego.Router("/api/acticle/getCategorys",&ArticleManage{},"Get:GetCategorys")
-	beego.Router("/api/acticle/edit",&ArticleManage{},"Put:EditCategorys")
+	beego.Router("/api/acticle/edit",&ArticleManage{},"Post:EditCategorys")
+	beego.Router("/api/acticle/delete",&ArticleManage{},"Delete:DeleteCategorys")
+	beego.Router("/api/acticle/addvido",&ArticleManage{},"Post:Addvido")
+	beego.Router("/api/acticle/savedraft",&ArticleManage{},"Post:SaveDraft")
 }
 
 type ArticleManage struct {
@@ -31,10 +34,40 @@ type ArticleManage struct {
 func (this *ArticleManage) CreateArticle(){
 	adminUserInfo := this.GetAdminUserInfo()
 	userOrgID := int64(adminUserInfo.CurrentOrgId)
-	actname := this.GetString("act_name")
-	actcontent := this.GetString("act_content")
-	orglogo := this.GetString("org_logo")
-	acttype, _ := this.GetInt64("act_type")
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	actname := dataBody["act_name"].(string)
+	if len(actname) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章标题不能为空")
+		return
+	}
+
+	actcontent := dataBody["act_content"].(string)
+	if len(actcontent) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章内容不能为空")
+		return
+	}
+
+	orglogo := dataBody["org_logo"].(string)
+	if len(orglogo) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "封面图片不能为空")
+		return
+	}
+
+	acttype := int64(dataBody["act_type"].(float64))
+	if  acttype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "分类号不能为空")
+		return
+	}
+
 	timenow := time.Now().Unix()
 	fmt.Println("姓名:",actname,"文章内容",actcontent,"图片",orglogo,"文章类型",acttype,userOrgID)
 	articles := models.Articles{
@@ -45,12 +78,17 @@ func (this *ArticleManage) CreateArticle(){
 				UserOrgId:userOrgID,
 				Ctime:timenow,
 				Status:1,
+				Type:1,
+				ArticleStatus:1,
 		}
-		err := article_service.AddAritcle(articles)
+		err = article_service.AddAritcle(articles)
 		if err !=nil{
 			this.ServeFailJsonSend(enums.ErrorCodeDataException, "插入文章失败")
 			return
 		}
+		this.ServeSuccessJSON(map[string]interface{}{
+		"articles":articles,
+		})
 }
 
 func (this *ArticleManage) GetArticleType(){
@@ -124,14 +162,14 @@ func (this *ArticleManage) AddCategory(){
 		return
 	}
 
-	content := dataBody["content"].(string)
+	content := dataBody["summary"].(string)
 	fmt.Println("content是谁?",content)
 	if len(content) == 0 {
     	this.ServeFailJsonSend(enums.ErrorCodeParamWrong,"内容不能为空")
     	return
 	}
 
-	sort := dataBody["sort"].(string)
+	sort := dataBody["order"].(string)
 	sors, _ := strconv.ParseInt(sort, 10, 64)
 	if sors  <=0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "排序不能为空")
@@ -189,7 +227,7 @@ func  (this *ArticleManage) GetCategorys()  {
 }
 
 func (this *ArticleManage) EditCategorys()  {
-	id, _ := this.GetInt64("MenuId", 0)
+	id, _ := this.GetInt64("id", 0)
 	fmt.Println("ID是多少",id)
 	if id <= 0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
@@ -198,18 +236,18 @@ func (this *ArticleManage) EditCategorys()  {
 	adminUserInfo := this.GetAdminUserInfo()
 	userOrgID := adminUserInfo.CurrentOrgId
 	categorys, err := article_service.GetCategorysByID(userOrgID, id)
-	 fmt.Println("err是设么",err)
+	fmt.Println("categorys是?",categorys,err)
 	if err != nil {
-		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（"+err.Error()+"）")
+		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
 		return
 	}
 	if categorys == nil {
-		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（会员记录不存在）")
+		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（会员记录不存在）")
 		return
 	}
-
 	timenow := time.Now().Unix()
 
+
 	dataBody := make(map[string]interface{}, 0)
 	err = json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
 	if err != nil {
@@ -218,28 +256,25 @@ func (this *ArticleManage) EditCategorys()  {
 		return
 	}
 
-	name:= dataBody["Name"].(string)
+	name:= dataBody["name"].(string)
 	fmt.Println("name是谁?",name)
-	if len(name) == 0 {
-		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
-		return
-	}
 
-	content := dataBody["Summary"].(string)
+	content := dataBody["summary"].(string)
 	fmt.Println("content是谁?",content)
 	if len(content) == 0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong,"内容不能为空")
 		return
 	}
 
-	sort := dataBody["Order"].(string)
-	sors, _ := strconv.ParseInt(sort, 10, 64)
-	if sors  <=0 {
+	sors :=int64(dataBody["order"].(float64))
+	//sors, _ := strconv.ParseInt(sort, 10, 64)
+	fmt.Println("sort0",sors)
+	if sors  <= 0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "排序不能为空")
 		return
 	}
-	fmt.Println("soert是谁？",sort)
-	fmt.Println("姓名:",name,"内容",content,"排序",sort)
+	fmt.Println("soert是谁？",sors)
+	fmt.Println("姓名:",name,"内容",content,"排序",sors)
 
 	category := models.ArticleCategory{
 		Name:    name,
@@ -249,14 +284,173 @@ func (this *ArticleManage) EditCategorys()  {
 		Status: 1,
 		Mtime: timenow,
 	}
-	err = article_service.EditCategory(category)
-	fmt.Println("err错误",err)
+	fmt.Println("category是?",category)
+	article_service.EditCategory(&category,userOrgID,id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"category":category,
+	})
+}
+
+func (this *ArticleManage) DeleteCategorys()  {
+	adminUserInfo := this.GetAdminUserInfo()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	idsInters := dataBody["ids"].([]interface{})
+	if len(idsInters) == 0 {
+		if err != nil {
+			this.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（没有选择会员）")
+			return
+		}
+	}
+
+	ids := make([]int64, 0)
+	for _, idsInter := range idsInters {
+		id := int64(idsInter.(float64))
+		ids = append(ids, id)
+	}
+
+	err = article_service.DeleteCategorys(adminUserInfo.CurrentOrgId, ids)
 	if err != nil {
-		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（"+err.Error()+"）")
+		this.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除分类失败:（"+err.Error()+"）")
 		return
 	}
-	fmt.Println(category)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *ArticleManage) Addvido(){
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	vidupload := dataBody["vio_upload"].(string)
+     if len(vidupload) == 0 {
+		 this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频不能为空")
+		 return
+	 }
+     fmt.Println("视频",vidupload)
+	vidname := dataBody["vid_name"].(string)
+	if len(vidname)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频标题不能为空")
+		return
+	}
+    fmt.Println("视频名称",vidname)
+	vidpic := dataBody["vid_pic"].(string)
+	if(vidpic == ""){
+		vidpic = vidupload + "?vframe/jpg/offset/1/w/300/h/200"
+	}
+	if len(vidpic)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频封面不能为空")
+		return
+	}
+    fmt.Println("视频图片",vidpic)
+	vidtype := int64(dataBody["vid_type"].(float64))
+	if vidtype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "所属分类不能为空")
+		return
+	}
+    fmt.Println("视频类型",vidtype)
+	fmt.Println("视频",vidupload,"视频标题",vidname,"视频封面",vidpic,"视频类型",vidtype)
+	timenow := time.Now().Unix()
+	articles := models.Articles{
+       UserOrgId:userOrgID,
+       Ctime:timenow,
+       Type:2,
+       VideoUrl:vidupload,
+       Title:vidname,
+       Imgs:vidpic,
+       ClassId:vidtype,
+       ArticleStatus:1,
+	}
+
+	err = article_service.AddVido(articles)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加分类失败")
+		return
+	}
+
 	this.ServeSuccessJSON(map[string]interface{}{
-		"category":categorys,
+		"vido":articles,
+	})
+}
+
+func (this *ArticleManage) SaveDraft()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	vidupload := dataBody["vio_upload"].(string)
+	if len(vidupload) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频不能为空")
+		return
+	}
+	fmt.Println("视频",vidupload)
+	vidname := dataBody["vid_name"].(string)
+	if len(vidname)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频标题不能为空")
+		return
+	}
+	fmt.Println("视频名称",vidname)
+	vidpic := dataBody["vid_pic"].(string)
+	if(vidpic == ""){
+		vidpic = vidupload + "?vframe/jpg/offset/1/w/300/h/200"
+	}
+	if len(vidpic)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频封面不能为空")
+		return
+	}
+	fmt.Println("视频图片",vidpic)
+	vidtype := int64(dataBody["vid_type"].(float64))
+	if vidtype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "所属分类不能为空")
+		return
+	}
+	fmt.Println("视频类型",vidtype)
+	fmt.Println("视频",vidupload,"视频标题",vidname,"视频封面",vidpic,"视频类型",vidtype)
+	timenow := time.Now().Unix()
+	articles := models.Articles{
+		UserOrgId:userOrgID,
+		Ctime:timenow,
+		Type:2,
+		VideoUrl:vidupload,
+		Title:vidname,
+		Imgs:vidpic,
+		ClassId:vidtype,
+		ArticleStatus:2,
+	}
+
+	err = article_service.AddVido(articles)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加分类失败")
+		return
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"savedraft":articles,
 	})
 }

controllers/marketing_tool/activity_controller.go

@@ -16,6 +16,8 @@ func ActivityCtlRegistRouters() {
 	beego.Router("/api/activities", &ActivityAPIController{}, "get:Activities")
 	beego.Router("/api/activity", &ActivityAPIController{}, "get:GetActivity")
 	beego.Router("/api/activity/submit", &ActivityAPIController{}, "post:ActivitySubmit")
+	beego.Router("/api/activity/detailview", &ActivityAPIController{}, "get:GetActivityDetailView")
+	beego.Router("/api/activity/signups", &ActivityAPIController{}, "get:SignupUsers")
 }
 
 type ActivityAPIController struct {
@@ -209,6 +211,12 @@ func (this *ActivityAPIController) ActivitySubmit() {
 			return
 		}
 	}
+
+	if activity.Status == 1 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeActivityPublishedCannotModify)
+		return
+	}
+
 	if len(activityForm.Title) == 0 || len(activityForm.Subtitle) == 0 || len(activityForm.PosterPhoto) == 0 || len(activityForm.Address) == 0 || len(activityForm.SignUpDeadline) == 0 || len(activityForm.StartTime) == 0 {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
@@ -329,3 +337,79 @@ func (this *ActivityAPIController) ActivitySubmit() {
 		"activity_id": activity.Id,
 	})
 }
+
+// /api/activity/detailview [get]
+// @param id:int
+func (this *ActivityAPIController) GetActivityDetailView() {
+	activityID, _ := this.GetInt64("id")
+	if activityID <= 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	adminUserInfo := this.GetAdminUserInfo()
+	activity, getActivityErr := marketing_tool_service.GetActivityWithID(adminUserInfo.CurrentOrgId, activityID)
+	if getActivityErr != nil {
+		this.ErrorLog("获取活动失败:%v", getActivityErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if activity == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeActivityNotExist)
+		return
+	}
+	if activity.Status != 1 && activity.Status != 4 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeActivityNotExist)
+		return
+	}
+
+	signupUsers, _, getUsersErr := marketing_tool_service.GetValidActivitySignupUsers(activityID, "", 1)
+	if getUsersErr != nil {
+		this.ErrorLog("获取活动报名客户失败：%v", getUsersErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"activity": activity,
+		"users":    signupUsers,
+	})
+}
+
+// /api/activity/signups [get]
+// @param id:int
+// @param keyword?:string
+// @param page?:int
+func (this *ActivityAPIController) SignupUsers() {
+	activityID, _ := this.GetInt64("id")
+	if activityID <= 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	page, _ := this.GetInt("page")
+	if page <= 0 {
+		page = 1
+	}
+	keyword := this.GetString("keyword")
+
+	adminUserInfo := this.GetAdminUserInfo()
+	activity, getActivityErr := marketing_tool_service.GetActivityWithID(adminUserInfo.CurrentOrgId, activityID)
+	if getActivityErr != nil {
+		this.ErrorLog("获取活动失败：%v", getActivityErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if activity == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeActivityNotExist)
+		return
+	}
+
+	signupUsers, total, getUsersErr := marketing_tool_service.GetValidActivitySignupUsers(activityID, keyword, page)
+	if getUsersErr != nil {
+		this.ErrorLog("获取活动报名客户失败：%v", getUsersErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"users": signupUsers,
+		"total": total,
+	})
+}

enums/error_code.go

@@ -44,7 +44,8 @@ const ( // ErrorCode
 	ErrorCodeCannotRemoveRole       = 9006
 	ErrorCodeRoleMobileIsSuperAdmin = 9007
 
-	ErrorCodeActivityNotExist = 9100
+	ErrorCodeActivityNotExist              = 9100
+	ErrorCodeActivityPublishedCannotModify = 9101
 
 	ErrorCodeGetQiniuUpToken = 1001
 
@@ -99,7 +100,8 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeCannotRemoveRole:       "存在该角色的管理员，不能删除该角色",
 	ErrorCodeRoleMobileIsSuperAdmin: "该手机号已注册为超级管理员",
 
-	ErrorCodeActivityNotExist: "活动不存在",
+	ErrorCodeActivityNotExist:              "活动不存在",
+	ErrorCodeActivityPublishedCannotModify: "已发布的活动不可更改",
 
 	ErrorCodeGetQiniuUpToken: "获取七牛uptoken失败",
 

models/activity_models.go

@@ -51,17 +51,17 @@ func (ActivityParagraph) TableName() string {
 }
 
 type ActivityUser struct {
-	Id          int    `gorm:"PRIMARY_KEY;AUTO_INCREMENT"` // 记录 ID
-	ActivityId  int    `gorm:"column:activity_id"`         // 活动 ID
-	UserId      int    `gorm:"column:user_id"`             // 参与者 ID
-	IDCardNo    string `gorm:"column:idcard_no"`           // 身份证号
-	Mobile      string
-	Realname    string
-	Avatar      string
-	AvatarThumb string
-	Status      int8  // 状态 0.无效 1.有效
-	CreateTime  int64 `gorm:"column:ctime"` // 报名时间
-	ModifyTime  int64 `gorm:"column:mtime"` // 修改时间
+	Id          int    `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"` // 记录 ID
+	ActivityId  int    `gorm:"column:activity_id" json:"-"`          // 活动 ID
+	UserId      int    `gorm:"column:user_id" json:"-"`              // 参与者 ID
+	IDCardNo    string `gorm:"column:idcard_no" json:"idcard_no"`    // 身份证号
+	Mobile      string `json:"mobile"`
+	Realname    string `json:"real_name"`
+	Avatar      string `json:"avatar"`
+	AvatarThumb string `json:"avatar_thumb"`
+	Status      int8   `json:"-"`                         // 状态 0.无效 1.有效
+	CreateTime  int64  `gorm:"column:ctime" json:"ctime"` // 报名时间
+	ModifyTime  int64  `gorm:"column:mtime" json:"-"`     // 修改时间
 }
 
 func (ActivityUser) TableName() string {

models/article_models.go

@@ -2,16 +2,16 @@ package models
 
 type ArticleCategory struct{
 	//对应数据库中的字段
-	MenuId    int64  `gorm:"column:id" `
-	Name      string `gorm:"column:name" `
-	Order     int64  `gorm:"column:order" `
-	Status    int64  `gorm:"column:status" `
-	Summary   string `gorm:"column:summary" `
-	Type      int64  `gorm:"column:type"`
-	Mtime     int64  `gorm:"column:mtime"`
-	Ctime     int64  `gorm:"column:ctime"`
-	UserOrgId int64  `gorm:"column:user_org_id"`
-	Num       int64  `gorm:"column:num" json:"num"`
+	IMenuId int64 `gorm:"column:id" json:"id" form:"id"`
+	Name string `gorm:"column:name" json:"name" form:"Name"`
+	Order int64 `gorm:"column:order" json:"order" form:"order"`
+	Status int64 `gorm:"column:status" json:"status" form:"status"`
+	Summary string `gorm:"column:summary" json:"summary" form:"summary"`
+	Type int64 `gorm:"column:type" json:"type" form:"type"`
+	UserOrgId int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Mtime int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Ctime int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Num int64 `gorm:"column:num" json:"num" form:"num"`
 
 }
 

service/article_service/article_category_service.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"github.com/jinzhu/gorm"
 
+	"time"
 )
 
 func FindArticleCategoryType (userOrgId int64)(*[]models.ArticleCategory,error){
@@ -83,7 +84,20 @@ func GetCategorysByID(orgID int64,id int64)(categorys []*models.ArticleCategory,
 	return categorys,err
 }
 
-func EditCategory(category models.ArticleCategory)(err error)  {
-	err = service.PatientWriteDB().Save(&category).Error
-	return err
+func EditCategory(cat *models.ArticleCategory,orgID int64,id int64){
+	 service.PatientWriteDB().Model(cat).Where("user_org_id =? AND id =? AND status = ?", orgID, id, 1).Update(map[string]interface{}{"Name": cat.Name, "Summary": cat.Summary, "Order": cat.Order, "mtime": cat.Mtime})
+}
+
+func DeleteCategorys(orgID int64,ids[] int64)(err error){
+     if len(ids) ==1{
+      err =	service.PatientWriteDB().Model(&models.ArticleCategory{}).Where( "id=? and user_org_id = ?",ids[0],orgID).Update(map[string]interface{}{"Status":0,"mtime":time.Now().Unix()}).Error
+	 }else {
+	  err =	service.PatientWriteDB().Model(&models.ArticleCategory{}).Where("id IN (?) and user_org_id = ?",ids,orgID).Update(map[string]interface{}{"Status":0,"mtime":time.Now().Unix()}).Error
+	 }
+	 return
+}
+
+func AddVido(articles models.Articles) error  {
+	err := service.PatientWriteDB().Create(&articles).Error
+	return  err
 }

service/marketing_tool_service/activity_service.go

@@ -164,3 +164,25 @@ func SaveActivityAndParagraph(activity *models.Activity, paragraph *models.Activ
 func SaveActivityWxShare(model *models.ActivityWxShare) error {
 	return service.PatientWriteDB().Save(model).Error
 }
+
+func GetValidActivitySignupUsers(activityID int64, keyWord string, page int) ([]*models.ActivityUser, int, error) {
+	var users []*models.ActivityUser
+	countPerPage := 10
+	var totalCount int
+	db := service.PatientReadDB().Model(&models.ActivityUser{}).Where("activity_id = ? AND status = 1", activityID)
+	if len(keyWord) > 0 {
+		likeParam := "%" + keyWord + "%"
+		db = db.Where("mobile LIKE ? OR realname LIKE ?", likeParam, likeParam)
+	}
+	err := db.
+		Count(&totalCount).
+		Order("id asc").Limit(countPerPage).Offset((page - 1) * countPerPage).
+		Find(&users).
+		Error
+
+	if err == nil {
+		return users, totalCount, nil
+	} else {
+		return nil, 0, err
+	}
+}