活动编辑接口

controllers/base_controller.go

@@ -2,6 +2,7 @@ package controllers
 
 import (
 	service "SCRM/service/admin_service"
+	"SCRM/utils"
 
 	"github.com/astaxie/beego"
 )
@@ -21,20 +22,25 @@ func (this *BaseController) GetAdminUserInfo() *service.AdminUserInfo {
 
 func (this *BaseController) ErrorLog(format string, a ...interface{}) {
 	//beego.Error(fmt.Sprintf(format, a...))
+	utils.ErrorLog(format, a...)
 }
 
 func (this *BaseController) WarnLog(format string, a ...interface{}) {
 	//beego.Warn(fmt.Sprintf(format, a...))
+	utils.WarningLog(format, a...)
 }
 
 func (this *BaseController) InfoLog(format string, a ...interface{}) {
 	//beego.Info(fmt.Sprintf(format, a...))
+	utils.InfoLog(format, a...)
 }
 
 func (this *BaseController) DebugLog(format string, a ...interface{}) {
 	//beego.Debug(fmt.Sprintf(format, a...))
+	utils.InfoLog(format, a...)
 }
 
 func (this *BaseController) TraceLog(format string, a ...interface{}) {
 	//beego.Trace(fmt.Sprintf(format, a...))
+	utils.TraceLog(format, a...)
 }

controllers/marketing_tool/activity_controller.go

@@ -5,6 +5,8 @@ import (
 	"SCRM/enums"
 	"SCRM/models"
 	"SCRM/service/marketing_tool_service"
+	"SCRM/utils"
+	"encoding/json"
 	"time"
 
 	"github.com/astaxie/beego"
@@ -13,6 +15,7 @@ import (
 func ActivityCtlRegistRouters() {
 	beego.Router("/api/activities", &ActivityAPIController{}, "get:Activities")
 	beego.Router("/api/activity", &ActivityAPIController{}, "get:GetActivity")
+	beego.Router("/api/activity/submit", &ActivityAPIController{}, "post:ActivitySubmit")
 }
 
 type ActivityAPIController struct {
@@ -143,11 +146,9 @@ func (this *ActivityAPIController) GetActivity() {
 		return
 	}
 
-	paragraphID := int64(0)
 	paragraphTitle := ""
 	paragraphContent := ""
 	if paragraph != nil {
-		paragraphID = paragraph.Id
 		paragraphTitle = paragraph.Title
 		paragraphContent = paragraph.Text
 	}
@@ -155,7 +156,6 @@ func (this *ActivityAPIController) GetActivity() {
 	this.ServeSuccessJSON(map[string]interface{}{
 		"activity": activity,
 		"paragraph": map[string]interface{}{
-			"id":      paragraphID,
 			"title":   paragraphTitle,
 			"content": paragraphContent,
 		},
@@ -164,9 +164,9 @@ func (this *ActivityAPIController) GetActivity() {
 
 // /api/activity/submit [post]
 // @param publish:bool 是否发布
-// @data activity:json
+// @data 如下格式
 /*
-activity: {
+{
 	id?:int
 	title:string
 	subtitle:string
@@ -184,3 +184,148 @@ activity: {
 	}
 }
 */
+func (this *ActivityAPIController) ActivitySubmit() {
+	publish, _ := this.GetBool("publish")
+
+	var activityForm ActivityForm
+	parseErr := json.Unmarshal(this.Ctx.Input.RequestBody, &activityForm)
+	if parseErr != nil {
+		this.ErrorLog("解析 activity form 失败：%v", parseErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+		return
+	}
+
+	adminUserInfo := this.GetAdminUserInfo()
+	var activity *models.Activity
+	if activityForm.ID > 0 {
+		var getActivityErr error
+		activity, getActivityErr = marketing_tool_service.GetActivityWithID(adminUserInfo.CurrentOrgId, activityForm.ID)
+		if getActivityErr != nil {
+			this.ErrorLog("获取活动失败：%v", getActivityErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		} else if activity == nil || activity.Status == 9 {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeActivityNotExist)
+			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
+	}
+	timeFmt := "2006-01-02 15:04"
+	signUpDeadlineTime, parseSUDErr := utils.ParseTimeStringToTime(timeFmt, activityForm.SignUpDeadline)
+	if parseSUDErr != nil {
+		this.ErrorLog("解析报名截止时间失败:%v", parseSUDErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+		return
+	}
+	activityTime, parseActivityTimeErr := utils.ParseTimeStringToTime(timeFmt, activityForm.StartTime)
+	if parseActivityTimeErr != nil {
+		this.ErrorLog("解析活动开始时间失败:%v", parseActivityTimeErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+		return
+	}
+
+	if len(activityForm.PhoneNumber) > 0 {
+		if utils.PhoneRegexp().MatchString(activityForm.PhoneNumber) == false {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
+			return
+		}
+	}
+	if activityForm.LimitNum < 0 {
+		activityForm.LimitNum = 0
+	}
+
+	if activity == nil {
+		activity = &models.Activity{
+			UserOrgId:        adminUserInfo.CurrentOrgId,
+			UserAppId:        adminUserInfo.CurrentAppId,
+			Title:            activityForm.Title,
+			Subtitle:         activityForm.Subtitle,
+			Address:          activityForm.Address,
+			SignUpDeadline:   signUpDeadlineTime.Unix(),
+			SignUpNotice:     activityForm.SignUpNotice,
+			StartTime:        activityTime.Unix(),
+			PosterPhoto:      activityForm.PosterPhoto,
+			PosterPhotoThumb: activityForm.PosterPhoto,
+			LimitNum:         activityForm.LimitNum,
+			PhoneNumber:      activityForm.PhoneNumber,
+			CreateTime:       time.Now().Unix(),
+		}
+	} else {
+		activity.Title = activityForm.Title
+		activity.Subtitle = activityForm.Subtitle
+		activity.Address = activityForm.Address
+		activity.SignUpDeadline = signUpDeadlineTime.Unix()
+		activity.SignUpNotice = activityForm.SignUpNotice
+		activity.StartTime = activityTime.Unix()
+		activity.PosterPhoto = activityForm.PosterPhoto
+		activity.PosterPhotoThumb = activityForm.PosterPhoto
+		activity.LimitNum = activityForm.LimitNum
+		activity.PhoneNumber = activityForm.PhoneNumber
+	}
+	activity.ModifyTime = time.Now().Unix()
+	if publish {
+		activity.Status = 1
+	} else {
+		activity.Status = 4
+	}
+
+	var paragraph *models.ActivityParagraph
+	if activity.Id > 0 {
+		var getPErr error
+		paragraph, getPErr = marketing_tool_service.GetActivityParagraphByActivityID(activity.Id)
+		if getPErr != nil {
+			this.ErrorLog("获取活动段落失败：%v", getPErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+	}
+	if len(activityForm.Paragraph.Title) > 0 {
+		if paragraph == nil {
+			paragraph = &models.ActivityParagraph{
+				Title:      activityForm.Paragraph.Title,
+				Text:       activityForm.Paragraph.Content,
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				ModifyTime: time.Now().Unix(),
+			}
+		} else {
+			paragraph.Title = activityForm.Paragraph.Title
+			paragraph.Text = activityForm.Paragraph.Content
+			paragraph.ModifyTime = time.Now().Unix()
+		}
+	} else {
+		if paragraph != nil {
+			paragraph.Status = 0
+			paragraph.ModifyTime = time.Now().Unix()
+		}
+	}
+
+	saveErr := marketing_tool_service.SaveActivityAndParagraph(activity, paragraph)
+	if saveErr != nil {
+		this.ErrorLog("保存活动失败:%v", saveErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	wxShareModel, getWxShareErr := marketing_tool_service.GetActivityWxShareByActivityID(activity.Id)
+	if getWxShareErr != nil {
+		this.ErrorLog("获取活动微信分享信息失败:%v", getWxShareErr)
+	} else if wxShareModel != nil {
+		wxShareModel.ModifyTime = time.Now().Unix()
+		wxShareModel.Status = 1
+		wxShareModel.Title = activity.Title
+		wxShareModel.Subtitle = activity.Subtitle
+		wxShareModel.Image = activity.PosterPhoto
+		saveWxShareErr := marketing_tool_service.SaveActivityWxShare(wxShareModel)
+		if saveWxShareErr != nil {
+			this.ErrorLog("更新活动微信分享信息失败:%v", saveWxShareErr)
+		}
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"activity_id": activity.Id,
+	})
+}

controllers/marketing_tool/activity_vms.go

@@ -0,0 +1,19 @@
+package marketing_tool
+
+type ActivityForm struct {
+	ID             int64  `json:"id"`
+	Title          string `json:"title"`
+	Subtitle       string `json:"subtitle"`
+	PosterPhoto    string `json:"poster_photo"`
+	Address        string `json:"address"`
+	LimitNum       int    `json:"limit_num"`
+	SignUpDeadline string `json:"sign_up_deadline"`
+	StartTime      string `json:"start_time"`
+	PhoneNumber    string `json:"phone_number"`
+	SignUpNotice   string `json:"sign_up_notice"`
+
+	Paragraph struct {
+		Title   string `json:"title"`
+		Content string `json:"content"`
+	} `json:"paragraph"`
+}

models/activity_models.go

@@ -24,8 +24,8 @@ type Activity struct {
 	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
+	UserOrgId        int64  `gorm:"column:user_org_id" json:"-"`                         // 所属发布机构 ID
+	UserAppId        int64  `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"`                    // 阅读数
@@ -37,7 +37,7 @@ func (Activity) TableName() string {
 
 type ActivityParagraph struct {
 	Id         int64  `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"`  // 记录 ID
-	ActivityId int    `gorm:"column:activity_id" json:"activity_id"` // 活动 ID
+	ActivityId int64  `gorm:"column:activity_id" json:"activity_id"` // 活动 ID
 	Title      string `json:"title"`
 	Text       string `json:"text"`
 	// Image      string `json:"image"` // 该字段实际上已经没用了

service/marketing_tool_service/activity_service.go

@@ -120,3 +120,47 @@ func GetActivityParagraphByActivityID(activityID int64) (*models.ActivityParagra
 	}
 	return &paragraph, nil
 }
+
+func GetActivityWxShareByActivityID(activityID int64) (*models.ActivityWxShare, error) {
+	var model models.ActivityWxShare
+	err :=
+		service.PatientReadDB().Model(&models.ActivityWxShare{}).
+			Where("activity_id = ?", activityID).
+			First(&model).
+			Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, err
+		}
+	}
+	return &model, nil
+}
+
+func SaveActivityAndParagraph(activity *models.Activity, paragraph *models.ActivityParagraph) error {
+	tx := service.PatientWriteDB().Begin()
+	saveActivityErr := tx.Save(activity).Error
+	if saveActivityErr != nil {
+		tx.Rollback()
+		return saveActivityErr
+	}
+	if paragraph != nil {
+		if paragraph.Id == 0 {
+			paragraph.ActivityId = activity.Id
+		}
+
+		saveParagraphErr := tx.Save(paragraph).Error
+		if saveParagraphErr != nil {
+			tx.Rollback()
+			return saveParagraphErr
+		}
+	}
+
+	tx.Commit()
+	return nil
+}
+
+func SaveActivityWxShare(model *models.ActivityWxShare) error {
+	return service.PatientWriteDB().Save(model).Error
+}