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

controllers/members/card_controller.go

@@ -5,9 +5,11 @@ import (
 	"SCRM/enums"
 	"SCRM/models"
 	"SCRM/service/member_service"
-	"time"
-
+	"SCRM/utils"
+	"encoding/json"
 	"fmt"
+	"reflect"
+	"time"
 
 	"github.com/astaxie/beego"
 	"github.com/bwmarrin/snowflake"
@@ -15,6 +17,10 @@ import (
 
 func CardCtlRegistRouters() {
 	beego.Router("/api/member/card/edit", &CardAPIController{}, "Put:EditMemberCard")
+	beego.Router("/api/membercards", &CardAPIController{}, "Get:GetCards")
+	beego.Router("/api/membercard/create", &CardAPIController{}, "Post:CreateCard")
+	beego.Router("/api/membercard/edit", &CardAPIController{}, "Put:EditCard")
+	beego.Router("/api/membercards/delete", &CardAPIController{}, "Delete:DeleteCard")
 }
 
 type CardAPIController struct {
@@ -79,14 +85,14 @@ func (c *CardAPIController) EditMemberCard() {
 			}
 			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.CardId = card.ID
+		userCard.CardName = card.CardName
 		userCard.UpdatedTime = timeNow
 		userCard.Status = 1
 		err = member_service.SaveUserCard(&userCard, member)
@@ -101,3 +107,336 @@ func (c *CardAPIController) EditMemberCard() {
 	c.ServeSuccessJSON(returnData)
 	return
 }
+
+func (c *CardAPIController) GetCards() {
+
+	adminUserInfo := c.GetAdminUserInfo()
+	cards, _ := member_service.GetCardList(adminUserInfo.CurrentOrgId)
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["cards"] = cards
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *CardAPIController) CreateCard() {
+
+	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
+	}
+
+	var card models.UserMembershipCard
+
+	if dataBody["background_type"] == nil || reflect.TypeOf(dataBody["background_type"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:background_type")
+		return
+	}
+	backgroundType := int64(dataBody["background_type"].(float64))
+	if backgroundType != 1 && backgroundType != 2 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择正确的卡片封面模式")
+		return
+	}
+	card.BackgroundType = backgroundType
+
+	if dataBody["background"] == nil || reflect.TypeOf(dataBody["background"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:background")
+		return
+	}
+	background, _ := dataBody["background"].(string)
+	if len(background) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "卡片封面不能为空")
+		return
+	}
+	if backgroundType == 1 && !utils.CheckHexColor(background) {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "背景色格式不正确")
+		return
+	}
+	card.Background = background
+
+	if dataBody["card_name"] == nil || reflect.TypeOf(dataBody["card_name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:card_name")
+		return
+	}
+	cardName, _ := dataBody["card_name"].(string)
+	if len(cardName) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "会员卡名称不能为空")
+		return
+	}
+	card.CardName = cardName
+
+	if dataBody["use_notice"] != nil && reflect.TypeOf(dataBody["use_notice"]).String() == "string" {
+		useNotice, _ := dataBody["use_notice"].(string)
+		if len([]rune(useNotice)) > 300 {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "使用须知最多可输入300个字符")
+			return
+		}
+		card.UseNotice = useNotice
+	}
+
+	if dataBody["card_right"] != nil && reflect.TypeOf(dataBody["card_right"]).String() == "string" {
+		cardRight, _ := dataBody["card_right"].(string)
+		if len([]rune(cardRight)) > 300 {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "会员权益最多可输入300个字符")
+			return
+		}
+		card.CardRight = cardRight
+	}
+
+	if dataBody["service_phone"] != nil && reflect.TypeOf(dataBody["service_phone"]).String() == "string" {
+		servicePhone, _ := dataBody["service_phone"].(string)
+		if len(servicePhone) > 0 && (!utils.CheckMobile(servicePhone) && !utils.CheckPhone(servicePhone)) {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "客服电话格式不正确")
+			return
+		}
+		card.ServicePhone = servicePhone
+	}
+
+	if dataBody["upgrade_integral"] != nil && reflect.TypeOf(dataBody["upgrade_integral"]).String() == "float64" {
+		upgradeIntegral := int64(dataBody["upgrade_integral"].(float64))
+		if upgradeIntegral < 0 {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "累积积分不能小于0")
+			return
+		}
+		card.UpgradeIntegral = upgradeIntegral
+
+	}
+	card.UserOrgId = adminUserInfo.CurrentOrgId
+	card.Status = 1
+	card.CreatedTime = timeNow
+	card.UpdatedTime = timeNow
+
+	oldCard, err := member_service.FindMemberCardByName(adminUserInfo.CurrentOrgId, card.CardName)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员卡失败:（"+err.Error()+"）")
+		return
+	}
+	if oldCard != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员卡失败:（已经存在同名的会员卡）")
+		return
+	}
+
+	err = member_service.SaveMemberCard(&card)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员卡失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["card"] = card
+	c.ServeSuccessJSON(returnData)
+	return
+
+}
+
+func (c *CardAPIController) EditCard() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+
+	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
+	}
+
+	card, err := member_service.FindOnlyMemberCardByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员卡失败:（"+err.Error()+"）")
+		return
+	}
+	if card == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员卡失败:（会员卡不存在）")
+		return
+	}
+
+	if dataBody["background_type"] == nil || reflect.TypeOf(dataBody["background_type"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:background_type")
+		return
+	}
+	backgroundType := int64(dataBody["background_type"].(float64))
+	if backgroundType != 1 && backgroundType != 2 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择正确的卡片封面模式")
+		return
+	}
+	card.BackgroundType = backgroundType
+
+	if dataBody["background"] == nil || reflect.TypeOf(dataBody["background"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:background")
+		return
+	}
+	background, _ := dataBody["background"].(string)
+	if len(background) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "卡片封面不能为空")
+		return
+	}
+	if backgroundType == 1 && !utils.CheckHexColor(background) {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "背景色格式不正确")
+		return
+	}
+	card.Background = background
+
+	if dataBody["card_name"] == nil || reflect.TypeOf(dataBody["card_name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:card_name")
+		return
+	}
+	cardName, _ := dataBody["card_name"].(string)
+	if len(cardName) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "会员卡名称不能为空")
+		return
+	}
+	card.CardName = cardName
+
+	if dataBody["use_notice"] != nil && reflect.TypeOf(dataBody["use_notice"]).String() == "string" {
+		useNotice, _ := dataBody["use_notice"].(string)
+		if len([]rune(useNotice)) > 300 {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "使用须知最多可输入300个字符")
+			return
+		}
+		card.UseNotice = useNotice
+	}
+
+	if dataBody["card_right"] != nil && reflect.TypeOf(dataBody["card_right"]).String() == "string" {
+		cardRight, _ := dataBody["card_right"].(string)
+		if len([]rune(cardRight)) > 300 {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "会员权益最多可输入300个字符")
+			return
+		}
+		card.CardRight = cardRight
+	}
+
+	if dataBody["service_phone"] != nil && reflect.TypeOf(dataBody["service_phone"]).String() == "string" {
+		servicePhone, _ := dataBody["service_phone"].(string)
+		if len(servicePhone) > 0 && (!utils.CheckMobile(servicePhone) && !utils.CheckPhone(servicePhone)) {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "客服电话格式不正确")
+			return
+		}
+		card.ServicePhone = servicePhone
+	}
+
+	if dataBody["upgrade_integral"] != nil && reflect.TypeOf(dataBody["upgrade_integral"]).String() == "float64" {
+		upgradeIntegral := int64(dataBody["upgrade_integral"].(float64))
+		if upgradeIntegral < 0 {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "累积积分不能小于0")
+			return
+		}
+		card.UpgradeIntegral = upgradeIntegral
+
+	}
+	card.UpdatedTime = timeNow
+
+	oldCard, err := member_service.FindMemberCardByName(adminUserInfo.CurrentOrgId, card.CardName)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员卡失败:（"+err.Error()+"）")
+		return
+	}
+	if oldCard != nil && oldCard.ID != card.ID {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员卡失败:（已经存在同名的会员卡）")
+		return
+	}
+
+	err = member_service.SaveMemberCard(card)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员卡失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["card"] = card
+	c.ServeSuccessJSON(returnData)
+	return
+
+}
+
+func (c *CardAPIController) DeleteCard() {
+	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)
+	}
+
+	count, err := member_service.GetMemebrCardCount(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员卡失败:（"+err.Error()+"）")
+		return
+	}
+	if count <= 1 {
+		c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员卡失败:（只有1张会员卡时不能删除）")
+		return
+	}
+	if count-int64(len(ids)) < 1 {
+		c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员卡失败:（至少需要保留1张会员卡）")
+		return
+	}
+
+	ccs, err := member_service.GetCardsUserCount(adminUserInfo.CurrentOrgId, ids)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员卡失败:（"+err.Error()+"）")
+		return
+	}
+
+	hadUserIds := make([]int64, 0)
+	willIds := make([]int64, 0)
+	if len(ccs) > 0 {
+		ccsMap := make(map[int64]int64, 0)
+		for _, cc := range ccs {
+			if cc.MemberCount > 0 {
+				hadUserIds = append(hadUserIds, cc.CardID)
+				ccsMap[cc.CardID] = cc.MemberCount
+			}
+		}
+		for _, id := range ids {
+			if _, exist := ccsMap[id]; !exist {
+				willIds = append(willIds, id)
+			}
+		}
+		if len(willIds) == 0 {
+			c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员卡失败:（不能删除有会员的会员卡）")
+			return
+		}
+	}
+
+	err = member_service.DeleteMemberShipCards(adminUserInfo.CurrentOrgId, ids)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员卡失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["delete_ids"] = willIds
+	returnData["delete_number"] = len(willIds)
+
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/members/tags_controller.go

@@ -18,6 +18,9 @@ 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")
+	beego.Router("/api/members/tag/create", &TagAPIController{}, "Post:CreateTag")
+	beego.Router("/api/members/tag/edit", &TagAPIController{}, "Put:EditTag")
+	beego.Router("/api/members/tags/delete", &TagAPIController{}, "Delete:DeleteTag")
 }
 
 type TagAPIController struct {
@@ -232,10 +235,161 @@ func (c *TagAPIController) GetTags() {
 	}
 
 	adminUserInfo := c.GetAdminUserInfo()
-	tags, _ := member_service.GetPageTagList(adminUserInfo.CurrentOrgId, page, limit, searchKey)
+	tags, total, _ := member_service.GetPageTagList(adminUserInfo.CurrentOrgId, page, limit, searchKey)
 
 	returnData := make(map[string]interface{}, 0)
 	returnData["tags"] = tags
+	returnData["total"] = total
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *TagAPIController) CreateTag() {
+	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
+	}
+
+	var tag models.UserTags
+
+	if dataBody["tag_name"] == nil || reflect.TypeOf(dataBody["tag_name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:标签名")
+		return
+	}
+	tagName, _ := dataBody["tag_name"].(string)
+	if len(tagName) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "标签名不能为空")
+		return
+	}
+	tag.TagName = tagName
+
+	oldTag, err := member_service.FindTagByName(adminUserInfo.CurrentOrgId, tagName)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加标签失败:（"+err.Error()+"）")
+		return
+	}
+	if oldTag != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加标签失败:（已经存在同名的标签）")
+		return
+	}
+	tag.Status = 1
+	tag.UserOrgId = adminUserInfo.CurrentOrgId
+	tag.CreatedTime = timeNow
+	tag.UpdatedTime = timeNow
+
+	err = member_service.SaveTag(&tag)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加标签失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["tag"] = tag
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *TagAPIController) EditTag() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	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
+	}
+
+	tag, err := member_service.FindOnlyTagByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑标签失败:（"+err.Error()+"）")
+		return
+	}
+	if tag == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑标签失败:（标签不存在）")
+		return
+	}
+
+	if dataBody["tag_name"] == nil || reflect.TypeOf(dataBody["tag_name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:标签名")
+		return
+	}
+	tagName, _ := dataBody["tag_name"].(string)
+	if len(tagName) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "标签名不能为空")
+		return
+	}
+	tag.TagName = tagName
+
+	oldTag, err := member_service.FindTagByName(adminUserInfo.CurrentOrgId, tagName)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "编辑标签失败:（"+err.Error()+"）")
+		return
+	}
+	if oldTag != nil && oldTag.ID != tag.ID {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "编辑标签失败:（已经存在同名的标签）")
+		return
+	}
+	tag.UpdatedTime = timeNow
+
+	err = member_service.SaveTag(tag)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "编辑标签失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["tag"] = tag
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *TagAPIController) DeleteTag() {
+	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.DeleteTags(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
 }

service/member_service/cards_service.go

@@ -9,7 +9,7 @@ import (
 )
 
 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
+	err = service.UserReadDB().Model(&models.UserMembershipCard{}).Where("status=1 and user_org_id=?", orgID).Find(&cards).Error
 	return
 }
 
@@ -65,3 +65,60 @@ func SaveUserCard(card *models.UserCard, member *Members) (err error) {
 
 	return
 }
+
+func FindMemberCardByName(orgID int64, name string) (*models.UserMembershipCard, error) {
+	var card models.UserMembershipCard
+	var err error
+	err = service.UserReadDB().Model(&models.UserMembershipCard{}).Where("card_name = ? AND user_org_id=? AND status=1", name, orgID).First(&card).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &card, nil
+}
+
+func SaveMemberCard(card *models.UserMembershipCard) (err error) {
+	err = service.UserWriteDB().Save(card).Error
+	return
+}
+
+func FindOnlyMemberCardByID(orgID, id 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", id, orgID).First(&card).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &card, nil
+}
+
+func GetMemebrCardCount(orgID int64) (count int64, err error) {
+	err = service.UserReadDB().Model(&models.UserMembershipCard{}).Where("user_org_id=? AND status=1", orgID).Count(&count).Error
+	return
+}
+
+func GetCardUserCount(orgID, id int64) (count int64, err error) {
+	err = service.UserReadDB().Table("sgj_user_user_card as uc").Joins("JOIN sgj_user_customer as c ON c.id=uc.customer_id AND uc.user_org_id=? AND c.user_org_id=? AND uc.card_id=?", orgID, orgID, id).Where("uc.card_id=? AND uc.status=1 AND c.status=1", id).Count(&count).Error
+
+	return
+}
+
+func GetCardsUserCount(orgID int64, ids []int64) (counts []*CardsMemberCount, err error) {
+	err = service.UserReadDB().Table("sgj_user_user_card as uc").Joins("JOIN sgj_user_customer as c ON c.id=uc.customer_id AND uc.user_org_id=? AND c.user_org_id=?", orgID, orgID).Where("uc.card_id IN (?) AND uc.status=1 AND c.status=1", ids).Select("uc.card_id, COUNT(uc.card_id) AS member_count").Group("uc.card_id").Scan(&counts).Error
+
+	return
+}
+
+func DeleteMemberShipCards(orgID int64, ids []int64) (err error) {
+	if len(ids) == 1 {
+		err = service.UserWriteDB().Model(&models.UserMembershipCard{}).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.UserMembershipCard{}).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

@@ -38,7 +38,7 @@ func (CustomerIllness) TableName() string {
 type Tags struct {
 	models.UserTags
 
-	MemberCount int64
+	MemberCount int64 `json:"member_count"`
 }
 
 func (Tags) TableName() string {
@@ -50,3 +50,7 @@ type TagsMemberCount struct {
 	TagID       int64 `gorm:"tag_id"`
 }
 
+type CardsMemberCount struct {
+	MemberCount int64 `gorm:"member_count"`
+	CardID      int64 `gorm:"card_id"`
+}

service/member_service/tags_service.go

@@ -6,6 +6,8 @@ import (
 	"errors"
 	"strings"
 	"time"
+
+	"github.com/jinzhu/gorm"
 )
 
 func GetTagList(orgID int64) (tags []*models.UserTags, err error) {
@@ -90,7 +92,7 @@ func SaveMemberTags(tags []*models.UserTagLinks) (err error) {
 	return
 }
 
-func GetPageTagList(orgID, page, limit int64, search string) (tags []*Tags, err error) {
+func GetPageTagList(orgID, page, limit int64, search string) (tags []*Tags, total int64, err error) {
 	db := service.UserReadDB().Model(&models.UserTags{}).Where("user_org_id=? and status=1", orgID)
 
 	if len(search) > 0 {
@@ -99,15 +101,72 @@ func GetPageTagList(orgID, page, limit int64, search string) (tags []*Tags, err
 	}
 	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
+	err = db.Count(&total).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)
-		// }
+		var tmcs []*TagsMemberCount
+		tagIDs := make([]int64, 0)
+		for _, tag := range tags {
+			tagIDs = append(tagIDs, tag.ID)
+		}
+		err = service.UserReadDB().Table("sgj_user_tag_links as utl").Joins("JOIN sgj_user_tags AS ut ON ut.id=utl.tag_id and utl.user_org_id=? and ut.user_org_id=?", orgID, orgID).Select("utl.tag_id, COUNT(utl.tag_id) AS member_count").Where("utl.tag_id IN (?)", tagIDs).Group("utl.tag_id").Scan(&tmcs).Error
+		if err != nil {
+			return
+		}
+		if len(tmcs) > 0 {
+			tmcsMap := make(map[int64]int64, 0)
+			for _, tmc := range tmcs {
+				tmcsMap[tmc.TagID] = tmc.MemberCount
+			}
+
+			for index, tag := range tags {
+				if _, exist := tmcsMap[tag.ID]; exist {
+					tags[index].MemberCount = tmcsMap[tag.ID]
+				}
+			}
+
+		}
+
+	}
+	return
+}
+
+func FindTagByName(orgID int64, name string) (*models.UserTags, error) {
+	var tag models.UserTags
+	var err error
+	err = service.UserReadDB().Model(&models.UserTags{}).Where("tag_name=? and user_org_id=? and status=1", name, orgID).First(&tag).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &tag, nil
+}
+
+func SaveTag(tag *models.UserTags) (err error) {
+	err = service.UserWriteDB().Save(tag).Error
+	return
+}
+
+func FindOnlyTagByID(orgID, id int64) (*models.UserTags, error) {
+	var tag models.UserTags
+	var err error
+	err = service.UserReadDB().Model(&models.UserTags{}).Where("id=? and user_org_id=? and status=1", id, orgID).First(&tag).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &tag, nil
+}
 
+func DeleteTags(orgID int64, ids []int64) (err error) {
+	if len(ids) == 1 {
+		err = service.UserWriteDB().Model(&models.UserTags{}).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.UserTags{}).Where("id IN (?) and user_org_id =?", ids, orgID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
 	}
 	return
 }

utils/tools.go

@@ -43,6 +43,16 @@ func CheckMobile(mobile string) (match bool) {
 	return
 }
 
+func CheckPhone(phone string) (match bool) {
+	reg, _ := regexp.MatchString("^0[0-9]{2,3}-?[0-9]{7,8}$", phone)
+	return reg
+}
+
+func CheckHexColor(color string) (match bool) {
+	reg, _ := regexp.MatchString("^#([0-9a-fA-F]{6})$", color)
+	return reg
+}
+
 func RandCode(min, max int64) string {
 	if min >= max || min == 0 || max == 0 {
 		return strconv.FormatInt(max, 10)