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

controllers/base_api_controller.go

@@ -2,8 +2,6 @@ package controllers
 
 import (
 	"SCRM/enums"
-	"SCRM/models"
-	"SCRM/service/admin_service"
 )
 
 type BaseAPIController struct {
@@ -53,33 +51,33 @@ type BaseAuthAPIController struct {
 func (this *BaseAuthAPIController) Prepare() {
 	this.BaseAPIController.Prepare()
 	if this.GetAdminUserInfo() == nil {
-		var userAdmin models.AdminUser
-		userAdmin.Id = 380
-		userAdmin.Mobile = "13532250447"
-		userAdmin.IsSuperAdmin = true
-		userAdmin.Status = 1
-		userAdmin.CreateTime = 1530786071
-		userAdmin.ModifyTime = 1530786071
-		var subscibe models.ServeSubscibe
-		subscibe.ID = 1
-		subscibe.OrgId = 4
-		subscibe.PeriodStart = 1538035409
-		subscibe.PeriodEnd = 1569571409
-		subscibe.State = 1
-		subscibe.Status = 1
-		subscibe.CreatedTime = 1538035409
-		subscibe.UpdatedTime = 1538035409
-		subscibes := make(map[int64]*models.ServeSubscibe, 0)
-		subscibes[4] = &subscibe
-		var adminUserInfo admin_service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 4
-		adminUserInfo.CurrentAppId = 5
-		adminUserInfo.AdminUser = &userAdmin
-		adminUserInfo.Subscibes = subscibes
-		this.SetSession("admin_user_info", &adminUserInfo)
+		// var userAdmin models.AdminUser
+		// userAdmin.Id = 380
+		// userAdmin.Mobile = "13532250447"
+		// userAdmin.IsSuperAdmin = true
+		// userAdmin.Status = 1
+		// userAdmin.CreateTime = 1530786071
+		// userAdmin.ModifyTime = 1530786071
+		// var subscibe models.ServeSubscibe
+		// subscibe.ID = 1
+		// subscibe.OrgId = 4
+		// subscibe.PeriodStart = 1538035409
+		// subscibe.PeriodEnd = 1569571409
+		// subscibe.State = 1
+		// subscibe.Status = 1
+		// subscibe.CreatedTime = 1538035409
+		// subscibe.UpdatedTime = 1538035409
+		// subscibes := make(map[int64]*models.ServeSubscibe, 0)
+		// subscibes[4] = &subscibe
+		// var adminUserInfo admin_service.AdminUserInfo
+		// adminUserInfo.CurrentOrgId = 4
+		// adminUserInfo.CurrentAppId = 5
+		// adminUserInfo.AdminUser = &userAdmin
+		// adminUserInfo.Subscibes = subscibes
+		// this.SetSession("admin_user_info", &adminUserInfo)
 
-		//this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotLogin)
-		//this.StopRun()
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotLogin)
+		this.StopRun()
 	}
 }
 

controllers/marketing_tool/activity_controller.go

@@ -0,0 +1,116 @@
+package marketing_tool
+
+import (
+	"SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/marketing_tool_service"
+	"time"
+
+	"github.com/astaxie/beego"
+)
+
+func ActivityCtlRegistRouters() {
+	beego.Router("/api/activities", &ActivityAPIController{}, "get:Activities")
+}
+
+type ActivityAPIController struct {
+	controllers.BaseAuthAPIController
+}
+
+// /api/activities [get]
+// @param page?:int
+// @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
+}

controllers/marketing_tool/router_collector.go

@@ -0,0 +1,5 @@
+package marketing_tool
+
+func RegisterRouters() {
+	ActivityCtlRegistRouters()
+}

controllers/members/card_controller.go

@@ -0,0 +1,103 @@
+package members
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/member_service"
+	"time"
+
+	"fmt"
+
+	"github.com/astaxie/beego"
+	"github.com/bwmarrin/snowflake"
+)
+
+func CardCtlRegistRouters() {
+	beego.Router("/api/member/card/edit", &CardAPIController{}, "Put:EditMemberCard")
+}
+
+type CardAPIController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *CardAPIController) EditMemberCard() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	cardID, _ := c.GetInt64("card_id", 0)
+	if cardID <= 0 { //设置为无卡
+		cardID = 0
+	}
+	adminUserInfo := c.GetAdminUserInfo()
+	timeNow := time.Now().Unix()
+	member, err := member_service.GetOnlyMemberByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+		return
+	}
+	if member == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（会员记录不存在）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	if cardID == 0 {
+		err = member_service.DeleteUserCard(adminUserInfo.CurrentOrgId, id)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		returnData["user_card"] = nil
+	} else {
+
+		card, err := member_service.GetCardByID(adminUserInfo.CurrentOrgId, cardID)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		if card == nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（会员卡不存在）")
+			return
+		}
+
+		oldUserCard, err := member_service.GetUserCardByID(adminUserInfo.CurrentOrgId, id)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		var userCard models.UserCard
+		if oldUserCard != nil {
+			userCard = *oldUserCard
+		} else {
+			node, err := snowflake.NewNode(1)
+			if err != nil {
+				c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（生成卡号时出错）")
+				return
+			}
+			cardNo := node.Generate()
+
+			userCard.CardId = card.ID
+			userCard.CardName = card.CardName
+			userCard.CustomerId = id
+			userCard.UserOrgId = adminUserInfo.CurrentOrgId
+			userCard.CreatedTime = timeNow
+			userCard.CardNo = fmt.Sprintf("%s", cardNo)
+		}
+
+		userCard.UpdatedTime = timeNow
+		userCard.Status = 1
+		err = member_service.SaveUserCard(&userCard, member)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		returnData["user_card"] = userCard
+		returnData["member"] = member
+	}
+
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/members/members_controller.go

@@ -17,6 +17,8 @@ import (
 func MemberCtlRegistRouters() {
 	beego.Router("/api/members", &MembersAPIController{}, "get:GetMembers")
 	beego.Router("/api/member/create", &MembersAPIController{}, "Post:CreateMember")
+	beego.Router("/api/member/edit", &MembersAPIController{}, "Put:EditMember")
+	beego.Router("/api/members/delete", &MembersAPIController{}, "Delete:DeleteMembers")
 }
 
 type MembersAPIController struct {
@@ -350,3 +352,287 @@ func (c *MembersAPIController) CreateMember() {
 	return
 
 }
+
+func (c *MembersAPIController) EditMember() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	adminUserInfo := c.GetAdminUserInfo()
+
+	member, err := member_service.GetOnlyMemberByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+		return
+	}
+	if member == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（会员记录不存在）")
+		return
+	}
+
+	timeNow := time.Now().Unix()
+
+	dataBody := make(map[string]interface{}, 0)
+	err = json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	if dataBody["name"] == nil || reflect.TypeOf(dataBody["name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:姓名")
+		return
+	}
+	name, _ := dataBody["name"].(string)
+	if len(name) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
+		return
+	}
+	member.Name = name
+
+	if dataBody["mobile"] == nil || reflect.TypeOf(dataBody["mobile"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:手机号")
+		return
+	}
+	mobile, _ := dataBody["mobile"].(string)
+	if len(mobile) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "手机号不能为空")
+		return
+	}
+	if !utils.CheckMobile(mobile) {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "手机号格式不正确")
+		return
+	}
+	changeMobile := true
+	if member.Mobile == mobile {
+		changeMobile = false
+	}
+	member.Mobile = mobile
+
+	if dataBody["gender"] == nil || reflect.TypeOf(dataBody["gender"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:性别")
+		return
+	}
+	gender := int64(dataBody["gender"].(float64))
+
+	if gender != 1 && gender != 2 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "性别选择不正确")
+		return
+	}
+	member.Gender = gender
+
+	if dataBody["birthday"] == nil || reflect.TypeOf(dataBody["birthday"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:生日")
+		return
+	}
+	birthday, _ := dataBody["birthday"].(string)
+	if len(birthday) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
+		return
+	}
+
+	timeLayout := "2006-01-02 15:04:05"
+	theTime, err := utils.ParseTimeStringToTime(timeLayout, birthday+" 00:00:00")
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
+		return
+	}
+	member.Birthday = theTime.Unix()
+
+	if dataBody["province_id"] == nil || reflect.TypeOf(dataBody["province_id"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区（省）")
+		return
+	}
+	provinceID := int64(dataBody["province_id"].(float64))
+	if provinceID <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
+		return
+	}
+	member.ProvinceId = provinceID
+
+	if dataBody["city_id"] == nil || reflect.TypeOf(dataBody["city_id"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区（市）")
+		return
+	}
+	cityID := int64(dataBody["city_id"].(float64))
+	if cityID <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
+		return
+	}
+	member.CityId = cityID
+
+	if dataBody["district_id"] == nil || reflect.TypeOf(dataBody["district_id"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区（区/县）")
+		return
+	}
+	districtID := int64(dataBody["district_id"].(float64))
+	if districtID <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
+		return
+	}
+	member.DistrictId = districtID
+
+	if dataBody["illness"] == nil || reflect.TypeOf(dataBody["illness"]).String() != "[]interface {}" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:病种")
+		return
+	}
+	illnessInters := dataBody["illness"].([]interface{})
+	if len(illnessInters) <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择病种")
+		return
+	}
+	member.Illness = make([]*member_service.CustomerIllness, 0)
+	illnessIDS := make([]int64, 0)
+	illnessIDMap := make(map[int64]int64, 0)
+	for _, illnessInter := range illnessInters {
+		id := int64(illnessInter.(float64))
+		illnessIDS = append(illnessIDS, id)
+		illnessIDMap[id] = id
+	}
+	allIllness, err := member_service.GetMemberAllIllness(adminUserInfo.CurrentOrgId, member.ID)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+		return
+	}
+	oldIllIDMap := make(map[int64]int64, 0)
+	for _, illItem := range allIllness {
+		item := *illItem
+		item.Status = 1
+		if _, exist := illnessIDMap[item.IllnessId]; !exist {
+			item.Status = 0
+			item.UpdatedTime = timeNow
+		}
+		member.Illness = append(member.Illness, &item)
+		oldIllIDMap[item.IllnessId] = item.IllnessId
+	}
+
+	for _, id := range illnessIDMap {
+		if _, exist := oldIllIDMap[id]; exist {
+			continue
+		}
+		var illItem member_service.CustomerIllness
+		illItem.UserOrgId = adminUserInfo.CurrentOrgId
+		illItem.IllnessId = id
+		illItem.Status = 1
+		illItem.UpdatedTime = timeNow
+		illItem.CreatedTime = timeNow
+		member.Illness = append(member.Illness, &illItem)
+	}
+
+	if dataBody["ill_date"] == nil || reflect.TypeOf(dataBody["ill_date"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:患病时间")
+		return
+	}
+	illDate, _ := dataBody["ill_date"].(string)
+	if len(illDate) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "患病时间格式不正确")
+		return
+	}
+
+	illDateTime, err := utils.ParseTimeStringToTime(timeLayout, illDate+" 00:00:00")
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "患病时间格式不正确")
+		return
+	}
+	member.IllDate = illDateTime.Unix()
+
+	if dataBody["treat_type"] == nil || reflect.TypeOf(dataBody["treat_type"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:治疗方式")
+		return
+	}
+	treatType := int64(dataBody["treat_type"].(float64))
+	if treatType <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择治疗方式")
+		return
+	}
+	member.TreatType = treatType
+
+	if dataBody["remark"] != nil && reflect.TypeOf(dataBody["remark"]).String() == "string" {
+		remark, _ := dataBody["remark"].(string)
+		if len(remark) > 0 {
+			member.Remark = remark
+		}
+	}
+
+	if dataBody["avatar"] != nil && reflect.TypeOf(dataBody["avatar"]).String() == "string" {
+		avatar, _ := dataBody["avatar"].(string)
+		if len(avatar) > 0 {
+			member.Avatar = avatar
+		}
+	}
+
+	if changeMobile {
+		customer, err := member_service.GetCustomerByMobile(adminUserInfo.CurrentOrgId, member.Mobile)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+			return
+		}
+		if customer != nil && customer.ID != member.ID {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（已经存在该手机号的客户）")
+			return
+		}
+	}
+	member.UpdatedTime = timeNow
+
+	err = member_service.EditMember(member)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+		return
+	}
+
+	illness := member.Illness
+	member.Illness = make([]*member_service.CustomerIllness, 0)
+	for _, ill := range illness {
+		illItem := *ill
+		if illItem.Status == 0 {
+			continue
+		}
+		member.Illness = append(member.Illness, &illItem)
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["member"] = member
+	c.ServeSuccessJSON(returnData)
+	return
+
+}
+
+func (c *MembersAPIController) DeleteMembers() {
+	adminUserInfo := c.GetAdminUserInfo()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	idsInters := dataBody["ids"].([]interface{})
+	if len(idsInters) == 0 {
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（没有选择会员）")
+			return
+		}
+	}
+
+	ids := make([]int64, 0)
+	for _, idsInter := range idsInters {
+		id := int64(idsInter.(float64))
+		ids = append(ids, id)
+	}
+
+	err = member_service.DeleteMembers(adminUserInfo.CurrentOrgId, ids)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/members/router_controller.go

@@ -2,4 +2,6 @@ package members
 
 func RegisterRouters() {
 	MemberCtlRegistRouters()
+	TagCtlRegistRouters()
+	CardCtlRegistRouters()
 }

controllers/members/tags_controller.go

@@ -0,0 +1,241 @@
+package members
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/member_service"
+	"SCRM/utils"
+	"reflect"
+	"time"
+
+	"encoding/json"
+
+	"github.com/astaxie/beego"
+)
+
+func TagCtlRegistRouters() {
+	beego.Router("/api/member/tag/edit", &TagAPIController{}, "Post:EditMemberTags")
+	beego.Router("/api/members/tags/add", &TagAPIController{}, "Post:AddMembersTags")
+	beego.Router("/api/members/tags", &TagAPIController{}, "Get:GetTags")
+}
+
+type TagAPIController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *TagAPIController) EditMemberTags() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	adminUserInfo := c.GetAdminUserInfo()
+	member, err := member_service.GetOnlyMemberByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败:（"+err.Error()+"）")
+		return
+	}
+	if member == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败:（会员记录不存在）")
+		return
+	}
+
+	timeNow := time.Now().Unix()
+
+	dataBody := make(map[string]interface{}, 0)
+	err = json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	if dataBody["tags"] == nil || reflect.TypeOf(dataBody["tags"]).String() != "[]interface {}" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:tags")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+
+	tagsInters := dataBody["tags"].([]interface{})
+	if len(tagsInters) == 0 {
+		err = member_service.DeleteMemeberAllTags(adminUserInfo.CurrentOrgId, member.ID)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败：（"+err.Error()+"）")
+			return
+		}
+		returnData["tags"] = nil
+	} else {
+		userTags := make([]*models.UserTagLinks, 0)
+		tagIds := make([]int64, 0)
+		tagIDMap := make(map[int64]int64, 0)
+		for _, tagsInter := range tagsInters {
+			id := int64(tagsInter.(float64))
+			tagIds = append(tagIds, id)
+			tagIDMap[id] = id
+		}
+		allTags, err := member_service.GetMemberAllTags(adminUserInfo.CurrentOrgId, member.ID)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败：（"+err.Error()+"）")
+			return
+		}
+		oldTagIDMap := make(map[int64]int64, 0)
+		for _, tagItem := range allTags {
+			item := *tagItem
+			item.Status = 1
+			if _, exist := tagIDMap[item.TagId]; !exist {
+				item.Status = 0
+				item.UpdatedTime = timeNow
+			}
+			userTags = append(userTags, &item)
+			oldTagIDMap[item.TagId] = item.TagId
+		}
+
+		for _, id := range tagIDMap {
+			if _, exist := oldTagIDMap[id]; exist {
+				continue
+			}
+			var tagItem models.UserTagLinks
+			tagItem.UserOrgId = adminUserInfo.CurrentOrgId
+			tagItem.TagId = id
+			tagItem.UserLinkId = member.ID
+			tagItem.Status = 1
+			tagItem.UpdatedTime = timeNow
+			tagItem.CreatedTime = timeNow
+			userTags = append(userTags, &tagItem)
+		}
+		err = member_service.SaveMemberTags(userTags)
+
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败：（"+err.Error()+"）")
+			return
+		}
+
+		returnData["tags"] = tagIds
+	}
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *TagAPIController) AddMembersTags() {
+	adminUserInfo := c.GetAdminUserInfo()
+	timeNow := time.Now().Unix()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	if dataBody["tags"] == nil || reflect.TypeOf(dataBody["tags"]).String() != "[]interface {}" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:tags")
+		return
+	}
+
+	idsInters := dataBody["ids"].([]interface{})
+	if len(idsInters) == 0 {
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败:（没有选择会员）")
+			return
+		}
+	}
+
+	ids := make([]int64, 0)
+	idsMap := make(map[int64]int64, 0)
+	for _, idsInter := range idsInters {
+		id := int64(idsInter.(float64))
+		ids = append(ids, id)
+		idsMap[id] = id
+	}
+
+	tagsInters := dataBody["tags"].([]interface{})
+	if len(tagsInters) == 0 {
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败:（没有选择标签）")
+			return
+		}
+	}
+	tagIds := make([]int64, 0)
+	tagIDMap := make(map[int64]int64, 0)
+	for _, tagsInter := range tagsInters {
+		id := int64(tagsInter.(float64))
+		tagIds = append(tagIds, id)
+		tagIDMap[id] = id
+	}
+
+	allTags, err := member_service.GetMembersAllTags(adminUserInfo.CurrentOrgId, ids)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败:（"+err.Error()+"）")
+		return
+	}
+
+	userTags := make([]*models.UserTagLinks, 0)
+	oldTagIDMap := make(map[int64]map[int64]int64, 0)
+	for _, tagItem := range allTags {
+		_, exist := tagIDMap[tagItem.TagId]
+		_, uexist := idsMap[tagItem.UserLinkId]
+		if exist && uexist {
+			item := *tagItem
+			item.Status = 1
+			item.UpdatedTime = timeNow
+			userTags = append(userTags, &item)
+			if _, oex := oldTagIDMap[item.UserLinkId]; !oex {
+				oldTagIDMap[item.UserLinkId] = make(map[int64]int64, 0)
+			}
+			oldTagIDMap[item.UserLinkId][item.TagId] = item.TagId
+		}
+	}
+
+	for _, userid := range idsMap {
+		for _, tagid := range tagIDMap {
+			if _, exist := oldTagIDMap[userid]; exist {
+				if _, exist := oldTagIDMap[userid][tagid]; exist {
+					continue
+				}
+			}
+			var tagItem models.UserTagLinks
+			tagItem.UserOrgId = adminUserInfo.CurrentOrgId
+			tagItem.TagId = tagid
+			tagItem.UserLinkId = userid
+			tagItem.Status = 1
+			tagItem.UpdatedTime = timeNow
+			tagItem.CreatedTime = timeNow
+			userTags = append(userTags, &tagItem)
+		}
+	}
+	err = member_service.SaveMemberTags(userTags)
+
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败：（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *TagAPIController) GetTags() {
+	page, _ := c.GetInt64("page", 1)
+	limit, _ := c.GetInt64("limit", 10)
+	searchKey := c.GetString("search", "")
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+
+	adminUserInfo := c.GetAdminUserInfo()
+	tags, _ := member_service.GetPageTagList(adminUserInfo.CurrentOrgId, page, limit, searchKey)
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["tags"] = tags
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/短信模块临时备注

@@ -0,0 +1,2 @@
+修改个人信息
+权限管理中添加管理员

models/activity_models.go

@@ -0,0 +1,85 @@
+package models
+
+// 表
+type Activity struct {
+	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 {
+	return "sgj_patient_activity"
+}
+
+type ActivityParagraph struct {
+	Id         int `gorm:"PRIMARY_KEY;AUTO_INCREMENT"` // 记录 ID
+	ActivityId int `gorm:"column:activity_id"`         // 活动 ID
+	Title      string
+	Text       string
+	Image      string
+	Status     int8  // 状态 0.无效 1.有效
+	CreateTime int64 `gorm:"column:ctime"` // 创建时间
+	ModifyTime int64 `gorm:"column:mtime"` // 修改时间
+}
+
+func (ActivityParagraph) TableName() string {
+	return "sgj_patient_activity_paragraph"
+}
+
+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"` // 修改时间
+}
+
+func (ActivityUser) TableName() string {
+	return "sgj_patient_activity_user"
+}
+
+type ActivityWxShare struct {
+	Id         int `gorm:"PRIMARY_KEY;AUTO_INCREMENT"` // 记录 ID
+	ActivityId int `gorm:"column:activity_id"`         // 活动 ID
+	Title      string
+	Subtitle   string
+	Image      string
+	Status     int8   // 状态 0.无效 1.有效
+	CreateTime int64  `gorm:"column:ctime"`     // 创建时间
+	ModifyTime int64  `gorm:"column:mtime"`     // 修改时间
+	ShortURL   string `gorm:"column:short_url"` // 短链接
+}
+
+func (ActivityWxShare) TableName() string {
+	return "sgj_patient_activity_wx_share"
+}

routers/router.go

@@ -2,14 +2,15 @@ package routers
 
 import (
 	"SCRM/controllers/admin_user"
+	"SCRM/controllers/article"
 	"SCRM/controllers/global"
 	"SCRM/controllers/login"
+	"SCRM/controllers/marketing_tool"
+	"SCRM/controllers/members"
 	"SCRM/controllers/role"
 
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego/plugins/cors"
-	"SCRM/controllers/article"
-	"SCRM/controllers/members"
 )
 
 func init() {
@@ -25,6 +26,7 @@ func init() {
 	admin_user.RegisterRouters()
 	login.RegisterRouters()
 	role.RegisterRouters()
+	members.RegisterRouters()
+	marketing_tool.RegisterRouters()
 	article.RegisterRouters()
-    members.RegisterRouters()
 }

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
+	}
+}

service/member_service/cards_service.go

@@ -3,10 +3,65 @@ package member_service
 import (
 	"SCRM/models"
 	"SCRM/service"
+	"time"
+
+	"github.com/jinzhu/gorm"
 )
 
 func GetCardList(orgID int64) (cards []*models.UserMembershipCard, err error) {
 	err = service.UserReadDB().Model(&models.UserMembershipCard{}).Where("status=1 and user_org_id=?", orgID).Order("card_level asc, id asc ").Find(&cards).Error
+	return
+}
+
+func GetCardByID(orgID, cardID int64) (*models.UserMembershipCard, error) {
+	var card models.UserMembershipCard
+	var err error
+	err = service.UserReadDB().Model(&models.UserMembershipCard{}).Where("id=? and user_org_id=? and status=1", cardID, orgID).First(&card).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &card, nil
+}
+
+func GetUserCardByID(orgID, customerID int64) (*models.UserCard, error) {
+	var card models.UserCard
+	var err error
+	err = service.UserReadDB().Model(&models.UserCard{}).Where("user_org_id=? and customer_id=? and status=1", orgID, customerID).First(&card).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &card, nil
+}
+
+func DeleteUserCard(orgID, customerID int64) (err error) {
+	err = service.UserWriteDB().Model(&models.UserCard{}).Where("user_org_id=? and customer_id=? ", orgID, customerID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	return
+}
+
+func SaveUserCard(card *models.UserCard, member *Members) (err error) {
+	if member.Membership == 1 {
+		err = service.UserWriteDB().Save(card).Error
+	} else {
+		tx := service.UserWriteDB().Begin()
+		err = service.UserWriteDB().Save(card).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+
+		err = service.UserWriteDB().Model(&models.UserCustomer{}).Where("id=? and user_org_id=? ", member.ID, member.UserOrgId).Update(map[string]interface{}{"Membership": 1, "UpdatedTime": time.Now().Unix()}).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+		tx.Commit()
+	}
 
 	return
 }

service/member_service/illness_service.go

@@ -1,12 +1,22 @@
 package member_service
 
 import (
-	"SCRM/service"
 	"SCRM/models"
+	"SCRM/service"
 )
 
-
 func GetIllnessList() (ills []*models.Illness, err error) {
 	err = service.UserReadDB().Where("status=1").Find(&ills).Error
 	return
 }
+
+func GetMemberAllIllnessByIllIDs(orgID, customerID int64, ids []int64) (ills []*CustomerIllness, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and customer_id =? and illness_id IN (?) ", orgID, customerID, ids).Find(&ills).Error
+	return
+}
+
+//GetMemberAllIllness 取所有(包括已经软删除的记录)
+func GetMemberAllIllness(orgID, customerID int64) (ills []*CustomerIllness, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and customer_id =? ", orgID, customerID).Find(&ills).Error
+	return
+}

service/member_service/member_service.go

@@ -5,6 +5,8 @@ import (
 	"SCRM/service"
 	"strings"
 
+	"time"
+
 	"github.com/jinzhu/gorm"
 )
 
@@ -42,6 +44,7 @@ func GetMemberList(orgID, page, limit, level, source, tag, startTime, endTime in
 			return db.Where("user_org_id=? and status=1", orgID)
 		}).
 		Preload("UserCard.Card", "user_org_id=? and status=1", orgID).
+		Preload("Illness", "user_org_id=? and status=1", orgID).
 		Select("c.id, c.user_org_id, c.user_id, c.mobile, c.name, c.gender, c.province_id, c.city_id, c.address, c.birthday, c.treat_type, c.relationship, c.illness_id, c.wechat_openid, c.membership, c.sources, c.status, c.created_time, c.updated_time, c.avatar, c.wechat_unionid, c.remark, c.medical_diagnose, c.yz_uid, c.ill_date, c.district_id").Find(&members).Error
 	if err != nil {
 		return
@@ -81,11 +84,29 @@ func GetUserByMobile(mobile string) (*models.User, error) {
 	return &user, nil
 }
 
+func GetOnlyMemberByID(orgID, id int64) (*Members, error) {
+	var member Members
+	var err error
+	err = service.UserReadDB().Where("id =? and user_org_id=? and status=1", id, orgID).Find(&member).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &member, nil
+}
+
 func CreateMember(member *Members) (err error) {
 	err = service.UserWriteDB().Create(member).Error
 	return
 }
 
+func EditMember(member *Members) (err error) {
+	err = service.UserWriteDB().Save(member).Error
+	return
+}
+
 func CreateMemberWithUser(member *Members, user *models.User) (err error) {
 	tx := service.UserWriteDB().Begin()
 	err = tx.Create(user).Error
@@ -104,3 +125,12 @@ func CreateMemberWithUser(member *Members, user *models.User) (err error) {
 
 	return
 }
+
+func DeleteMembers(orgID int64, ids []int64) (err error) {
+	if len(ids) == 1 {
+		err = service.UserWriteDB().Model(&models.UserCustomer{}).Where("id =? and user_org_id =?", ids[0], orgID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	} else {
+		err = service.UserWriteDB().Model(&models.UserCustomer{}).Where("id IN (?) and user_org_id =?", ids, orgID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	}
+	return
+}

service/member_service/models.go

@@ -34,4 +34,36 @@ type CustomerIllness struct {
 func (CustomerIllness) TableName() string {
 	return "sgj_user_customer_illness"
 }
+<<<<<<< .mine
 
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+=======
+
+type Tags struct {
+	models.UserTags
+
+	MemberCount int64
+}
+
+func (Tags) TableName() string {
+	return "sgj_user_tags"
+}
+
+type TagsMemberCount struct {
+	MemberCount int64 `gorm:"member_count"`
+	TagID       int64 `gorm:"tag_id"`
+}
+>>>>>>> .theirs

service/member_service/tags_service.go

@@ -3,10 +3,111 @@ package member_service
 import (
 	"SCRM/models"
 	"SCRM/service"
+	"errors"
+	"strings"
+	"time"
 )
 
 func GetTagList(orgID int64) (tags []*models.UserTags, err error) {
-	err = service.UserReadDB().Model(&models.UserTags{}).Where("status=1 and user_org_id=?", orgID).Order("id asc").Find(&tags).Error
+	err = service.UserReadDB().Model(&models.UserTags{}).Where("user_org_id=? and status=1", orgID).Order("id asc").Find(&tags).Error
 
 	return
 }
+
+//GetMemberAllTags 取所有(包括已经软删除的记录)
+func GetMemberAllTags(orgID, customerID int64) (tags []*models.UserTagLinks, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and user_link_id =? ", orgID, customerID).Find(&tags).Error
+	return
+}
+
+//GetMembersAllTags 取所有(包括已经软删除的记录)
+func GetMembersAllTags(orgID int64, customerIDs []int64) (tags []*models.UserTagLinks, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and user_link_id in (?) ", orgID, customerIDs).Find(&tags).Error
+	return
+}
+
+//DeleteMemeberAllTags 删除会员所有标签
+func DeleteMemeberAllTags(orgID, customerID int64) (err error) {
+	err = service.UserWriteDB().Model(&models.UserTagLinks{}).Where("user_org_id = ? and user_link_id =? ", orgID, customerID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	return
+}
+
+func SaveMemberTags(tags []*models.UserTagLinks) (err error) {
+	if len(tags) == 0 {
+		err = errors.New("NotRecordToUpdate")
+		return
+	}
+
+	insertSql := "INSERT INTO sgj_user_tag_links (tag_id, user_link_id, status, created_time, updated_time, user_org_id) VALUES "
+	insertParams := make([]string, 0)
+	insertData := make([]interface{}, 0)
+	updateIds := make([]int64, 0)
+	deleteIds := make([]int64, 0)
+	for _, tag := range tags {
+		if tag.ID == 0 {
+			insertParams = append(insertParams, "(?,?,?,?,?,?)")
+			insertData = append(insertData, tag.TagId)
+			insertData = append(insertData, tag.UserLinkId)
+			insertData = append(insertData, tag.Status)
+			insertData = append(insertData, tag.CreatedTime)
+			insertData = append(insertData, tag.UpdatedTime)
+			insertData = append(insertData, tag.UserOrgId)
+		} else {
+			if tag.Status == 1 {
+				updateIds = append(updateIds, tag.ID)
+			} else {
+				deleteIds = append(deleteIds, tag.ID)
+			}
+		}
+	}
+
+	tx := service.UserWriteDB().Begin()
+	if len(insertParams) > 0 {
+		insertSql += strings.Join(insertParams, ", ")
+		err = tx.Exec(insertSql, insertData...).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+	}
+
+	if len(updateIds) > 0 {
+		err = service.UserWriteDB().Model(&models.UserTagLinks{}).Where("id IN (?)", updateIds).Update(map[string]interface{}{"Status": 1, "UpdatedTime": time.Now().Unix()}).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+	}
+	if len(deleteIds) > 0 {
+		err = service.UserWriteDB().Model(&models.UserTagLinks{}).Where("id IN (?)", deleteIds).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+	}
+
+	tx.Commit()
+	return
+}
+
+func GetPageTagList(orgID, page, limit int64, search string) (tags []*Tags, err error) {
+	db := service.UserReadDB().Model(&models.UserTags{}).Where("user_org_id=? and status=1", orgID)
+
+	if len(search) > 0 {
+		searchKey := "%" + search + "%"
+		db = db.Where("tag_name LIKE ?", searchKey)
+	}
+	offset := (page - 1) * limit
+
+	err = service.UserReadDB().Model(&models.UserTags{}).Where("user_org_id=? and status=1", orgID).Order("id desc").Offset(offset).Limit(limit).Find(&tags).Error
+
+	if len(tags) > 0 {
+		// var tmcs []*TagsMemberCount
+		// tagIDs := make([]int64, 0)
+		// for _, tag := range tags {
+		// 	tagIDs = append(tagIDs, tag.ID)
+		// }
+
+	}
+	return
+}