活动列表接口

controllers/marketing_tool/activity_controller.go

@@ -2,6 +2,10 @@ package marketing_tool
 
 import (
 	"SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/marketing_tool_service"
+	"time"
 
 	"github.com/astaxie/beego"
 )
@@ -19,5 +23,94 @@ type ActivityAPIController struct {
 // @param keyword?:string
 // @param status?:int 1.已发布 2.待发布 3.未通过 4.已结束 其他取全部
 func (this *ActivityAPIController) Activities() {
+	page, _ := this.GetInt("page")
+	keyword := this.GetString("keyword")
+	status, _ := this.GetInt("status")
+	if page <= 0 {
+		page = 1
+	}
+	if status < 1 || status > 4 {
+		status = 0
+	}
 
+	adminUserInfo := this.GetAdminUserInfo()
+	var activities []*models.Activity
+	var totalCount int64
+	var getActivityErr error
+	if status == 1 {
+		activities, totalCount, getActivityErr = marketing_tool_service.GetActivitiesWithStatus(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, keyword, 1, page, 10)
+	} else if status == 2 {
+		activities, totalCount, getActivityErr = marketing_tool_service.GetActivitiesWithStatus(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, keyword, 4, page, 10)
+	} else if status == 3 {
+		activities, totalCount, getActivityErr = marketing_tool_service.GetActivitiesWithStatus(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, keyword, 3, page, 10)
+	} else if status == 4 {
+		activities, totalCount, getActivityErr = marketing_tool_service.GetDidEndedActivities(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, keyword, page, 10)
+	} else {
+		activities, totalCount, getActivityErr = marketing_tool_service.GetValidActivities(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, keyword, page, 10)
+	}
+
+	if getActivityErr != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	activityJSONList := make([]map[string]interface{}, 0, len(activities))
+	for _, activity := range activities {
+		var json map[string]interface{}
+		// 活动状态 1:已发布 2:待审核 3:未通过 4:草稿 9:已删除
+		if activity.Status == 1 { // 已发布/已结束
+			json = this._convertToPublishedActivityViewJSON(activity)
+		} else if activity.Status == 3 { // 未通过
+			json = this._convertToUnapprovedActivityViewJSON(activity)
+		} else if activity.Status == 4 { // 草稿
+			json = this._convertToActivityDraftsViewJSON(activity)
+		}
+		activityJSONList = append(activityJSONList, json)
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"activities": activityJSONList,
+		"total":      totalCount,
+	})
+}
+
+func (this *ActivityAPIController) _convertToPublishedActivityViewJSON(activity *models.Activity) map[string]interface{} {
+	json := make(map[string]interface{})
+	now := time.Now().Unix()
+	if activity.StartTime < now {
+		json["status"] = 4
+	} else {
+		json["status"] = 1
+	}
+	json["id"] = activity.Id
+	json["poster_photo"] = activity.PosterPhoto
+	json["title"] = activity.Title
+	json["is_recommend"] = activity.IsRecommend
+	json["read_num"] = activity.ReadNum
+	json["comment_num"] = activity.CommentNum
+	json["star_num"] = activity.StarNum
+	json["join_num"] = activity.JoinNum
+	json["limit_num"] = activity.LimitNum
+	json["start_time"] = activity.StartTime
+	return json
+}
+
+func (this *ActivityAPIController) _convertToActivityDraftsViewJSON(activity *models.Activity) map[string]interface{} {
+	json := make(map[string]interface{})
+	json["status"] = 2
+	json["id"] = activity.Id
+	json["poster_photo"] = activity.PosterPhoto
+	json["title"] = activity.Title
+	return json
+}
+
+func (this *ActivityAPIController) _convertToUnapprovedActivityViewJSON(activity *models.Activity) map[string]interface{} {
+	json := make(map[string]interface{})
+	json["status"] = 3
+	json["id"] = activity.Id
+	json["poster_photo"] = activity.PosterPhoto
+	json["title"] = activity.Title
+	json["reason"] = activity.Reason
+	json["start_time"] = activity.StartTime
+	return json
 }

models/activity_models.go

@@ -2,36 +2,33 @@ package models
 
 // 表
 type Activity struct {
-	Id       int    `gorm:"PRIMARY_KEY;AUTO_INCREMENT"` // 活动 ID
-	Title    string // 活动标题
-	Subtitle string // 活动副标题
-	CityId   int    `gorm:"column:city_id"` // 活动地点 ID
-	Address  string // 活动详细地址
-	Lng      string `gorm:"column:longitude"` // 活动位置的经度
-	Lat      string `gorm:"column:latitude"`  // 活动位置的纬度
-	// SignUpStart int64  `gorm:"column:sign_up_start"` // 报名开始时间戳
-	SignUpDeadline int64  `gorm:"column:sign_up_deadline"` // 报名截止时间戳
-	SignUpNotice   string `gorm:"column:sign_up_notice"`   // 报名须知
-	StartTime      int64  `gorm:"column:start_time"`       // 活动开始时间戳
-	// EndTime          int64  `gorm:"column:end_time"`            // 活动结束时间戳
-	PosterPhoto      string `gorm:"column:poster_photo"`        // 活动海报
-	PosterPhotoThumb string `gorm:"column:poster_photo_thumb"`  // 活动海报缩略图
-	LimitNum         int    `gorm:"column:limit_num;default:0"` // 限制报名人数，0表示无限制
-	JoinNum          int    `gorm:"column:join_num"`            // 已报名人数
-	PhoneNumber      string `gorm:"column:phone_number"`        // 联系方式
-	Type             int8   // 活动形式
-	// Content		string	// 活动内容
-	IsInsurance int8   `gorm:"column:is_insurance;default:0"` // 是否提供保险:报名不需要保险0:否;报名需要保险1:是;2不需要报名
-	Status      int    // 活动状态 1:已发布 2:待审核 3:未通过 4:草稿 9:已删除
-	Reason      string // 审核原因
-	IsRecommend int8   `gorm:"column:is_recommend;default:0"` // 0:未推荐;1:已推荐
-	CreateTime  int64  `gorm:"column:ctime"`                  // 创建时间
-	ModifyTime  int64  `gorm:"column:mtime"`                  // 修改时间
-	UserOrgId   int    `gorm:"column:user_org_id"`            // 所属发布机构 ID
-	UserAppId   int    `gorm:"column:user_app_id"`            // 所属发布应用 ID
-	CommentNum  int    `gorm:"column:comment_num;default:0"`  // 评论数
-	StarNum     int    `gorm:"column:star_num;default:0"`     // 点赞书
-	ReadNum     int    `gorm:"column:read_num;default:0"`     // 阅读数
+	Id               int    `gorm:"column:id" json:"id"`                                 // 活动 ID
+	Title            string `json:"title"`                                               // 活动标题
+	Subtitle         string `json:"subtitle"`                                            // 活动副标题
+	CityId           int    `gorm:"column:city_id" json:"city_id"`                       // 活动地点 ID
+	Address          string `json:"address"`                                             // 活动详细地址
+	Lng              string `gorm:"column:longitude" json:"lng"`                         // 活动位置的经度
+	Lat              string `gorm:"column:latitude" json:"lat"`                          // 活动位置的纬度
+	SignUpDeadline   int64  `gorm:"column:sign_up_deadline" json:"sign_up_deadline"`     // 报名截止时间戳
+	SignUpNotice     string `gorm:"column:sign_up_notice" json:"sign_up_notice"`         // 报名须知
+	StartTime        int64  `gorm:"column:start_time" json:"start_time"`                 // 活动开始时间戳
+	PosterPhoto      string `gorm:"column:poster_photo" json:"poster_photo"`             // 活动海报
+	PosterPhotoThumb string `gorm:"column:poster_photo_thumb" json:"poster_photo_thumb"` // 活动海报缩略图
+	LimitNum         int    `gorm:"column:limit_num;" json:"limit_num"`                  // 限制报名人数，0表示无限制
+	JoinNum          int    `gorm:"column:join_num" json:"join_num"`                     // 已报名人数
+	PhoneNumber      string `gorm:"column:phone_number" json:"phone_number"`             // 联系方式
+	Type             int8   `json:"type"`                                                // 活动形式
+	IsInsurance      int8   `gorm:"column:is_insurance;" json:"is_insurance"`            // 是否提供保险:报名不需要保险0:否;报名需要保险1:是;2不需要报名
+	Status           int    `json:"status"`                                              // 活动状态 1:已发布 2:待审核 3:未通过 4:草稿 9:已删除
+	Reason           string `json:"reason"`                                              // 审核原因
+	IsRecommend      int8   `gorm:"column:is_recommend;" json:"is_recommend"`            // 0:未推荐;1:已推荐
+	CreateTime       int64  `gorm:"column:ctime" json:"-"`                               // 创建时间
+	ModifyTime       int64  `gorm:"column:mtime" json:"-"`                               // 修改时间
+	UserOrgId        int    `gorm:"column:user_org_id" json:"-"`                         // 所属发布机构 ID
+	UserAppId        int    `gorm:"column:user_app_id" json:"-"`                         // 所属发布应用 ID
+	CommentNum       int    `gorm:"column:comment_num;" json:"comment_num"`              // 评论数
+	StarNum          int    `gorm:"column:star_num" json:"star_num"`                     // 点赞书
+	ReadNum          int    `gorm:"column:read_num;" json:"read_num"`                    // 阅读数
 }
 
 func (Activity) TableName() string {

service/marketing_tool_service/activity_service.go

@@ -0,0 +1,90 @@
+package marketing_tool_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+	"time"
+)
+
+func GetValidActivities(orgID int64, appID int64, keyWord string, page int, count int) ([]*models.Activity, int64, error) {
+	if count <= 0 {
+		return []*models.Activity{}, 0, nil
+	}
+	if page < 1 {
+		page = 1
+	}
+
+	var activities []*models.Activity
+	var totalCount int64
+	db := service.PatientReadDB().Model(&models.Activity{}).Where("user_org_id = ? AND user_app_id = ? AND status <> 9", orgID, appID)
+	if len(keyWord) > 0 {
+		likeParam := "%" + keyWord + "%"
+		db = db.Where("title LIKE ?", likeParam)
+	}
+
+	err := db.
+		Count(&totalCount).
+		Order("ctime desc").Limit(count).Offset((page - 1) * count).Find(&activities).
+		Error
+
+	if err == nil {
+		return activities, totalCount, nil
+	} else {
+		return nil, 0, err
+	}
+}
+
+func GetActivitiesWithStatus(orgID int64, appID int64, keyWord string, status int, page int, count int) ([]*models.Activity, int64, error) {
+	if count <= 0 {
+		return []*models.Activity{}, 0, nil
+	}
+	if page < 1 {
+		page = 1
+	}
+
+	var activities []*models.Activity
+	var totalCount int64
+	db := service.PatientReadDB().Model(&models.Activity{}).Where("user_org_id = ? AND user_app_id = ? AND status = ?", orgID, appID, status)
+	if len(keyWord) > 0 {
+		likeParam := "%" + keyWord + "%"
+		db = db.Where("title LIKE ?", likeParam)
+	}
+	err := db.
+		Count(&totalCount).
+		Order("ctime desc").Limit(count).Offset((page - 1) * count).Find(&activities).
+		Error
+
+	if err == nil {
+		return activities, totalCount, nil
+	} else {
+		return nil, 0, err
+	}
+}
+
+func GetDidEndedActivities(orgID int64, appID int64, keyWord string, page int, count int) ([]*models.Activity, int64, error) {
+	if count <= 0 {
+		return []*models.Activity{}, 0, nil
+	}
+	if page < 1 {
+		page = 1
+	}
+
+	var activities []*models.Activity
+	var totalCount int64
+	now := time.Now().Unix()
+	db := service.PatientReadDB().Model(&models.Activity{}).Where("user_org_id = ? AND user_app_id = ? AND status = 1 AND start_time < ?", orgID, appID, now)
+	if len(keyWord) > 0 {
+		likeParam := "%" + keyWord + "%"
+		db = db.Where("title LIKE ?", likeParam)
+	}
+	err := db.
+		Count(&totalCount).
+		Order("ctime desc").Limit(count).Offset((page - 1) * count).Find(&activities).
+		Error
+
+	if err == nil {
+		return activities, totalCount, nil
+	} else {
+		return nil, 0, err
+	}
+}