Merge branch 'dev' of http://git.ycjcjy.com/SpaceOfCheng/services into dev

controllers/channel/channel.go

@@ -0,0 +1,66 @@
+package channel
+
+import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/channel"
+)
+
+// CaseController 信息
+type ChannelController struct {
+	dao *channel.ChannelServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *ChannelController) Constructor() {
+	c.dao = channel.NewChannelServ(c.Context)
+}
+
+// GetChannelList获取渠道列表
+func (c *ChannelController) GetChannelList() {
+	cases := c.Context.Get("cases").([]model.SysUserCase)
+	caseIDs := c.GetCaseIDs(cases)
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetChannelList(caseIDs, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetChannelById根据id获取渠道
+func (c *ChannelController) GetChannelById() {
+	caseid := c.GetString(":caseid")
+	channel, err := c.dao.GetChannelById(caseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(channel)
+}
+
+// SaveChannel 保存渠道信息
+func (c *ChannelController) SaveChannel() {
+	channel := model.TaChannel{}
+	if err := c.ParseForm(&channel); err != nil {
+		c.ResponseError(err)
+	}
+	newChannel, err := c.dao.SaveChannel(channel)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newChannel)
+}
+
+// DeleteChannel 删除渠道
+func (c *ChannelController) DeleteChannel() {
+	channelId := c.GetString(":channelId")
+	err := c.dao.DeleteChannel(channelId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功")
+}

models/channel/channel.go

@@ -0,0 +1,97 @@
+package channel
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/go-xorm/xorm"
+)
+
+// ChannelDAO 当前数据库操作对象
+type ChannelDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewChannelDAO New Inst
+func NewChannelDAO(ctx *utils.Context) *ChannelDAO {
+	return &ChannelDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+type Channel struct {
+	model.TaChannel `xorm:"extends"`
+	CaseName        string
+}
+
+// GetChannelsCount 获取渠道总数
+func (m *ChannelDAO) GetChannelsCount(caseid string) (int, error) {
+	var channels []model.TaChannel
+	dao := m.db.Where("status >" + strconv.Itoa(models.STATUS_DEL)).And("case_id in ('" + strings.Replace(caseid, ",", "','", -1) + "')")
+	err := dao.Find(&channels)
+	return len(channels), err
+}
+
+// GetChannels 根据案场获取渠道
+func (m *ChannelDAO) GetChannels(caseid string, page int, pageSize int) ([]Channel, error) {
+	var channels []Channel
+	sql := `
+	select a.*,b.case_name 
+	from ta_channel a 
+	inner join sys_case b on a.case_id = b.case_id 
+	where a.case_id in(` + strings.Replace(caseid, ",", "','", -1) + `) and status > ` + strconv.Itoa(models.STATUS_DEL)
+	err := m.db.Sql(sql).Find(&channels)
+	return channels, err
+}
+
+// GetChannelById 根据渠道id获取渠道
+func (m *ChannelDAO) GetChannelById(channelId string) (*model.TaChannel, error) {
+	var channel []model.TaChannel
+	err := m.db.Where("channel_id = ", channelId).And("status > ?", models.STATUS_DEL).Find(&channel)
+	if err != nil {
+		return nil, err
+	}
+	if len(channel) > 0 {
+		return &channel[0], nil
+	}
+	return nil, nil
+}
+
+// AddNewChannel 新增渠道
+func (m *ChannelDAO) AddNewChannel(channel model.TaChannel) (*model.TaChannel, error) {
+	channel.ChannelId = utils.GetGUID()
+	channel.CreateDate = time.Now()
+	channel.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(channel)
+	return &channel, err
+}
+
+// UpdateChannel 修改渠道
+func (m *ChannelDAO) UpdateChannel(channel model.TaChannel) error {
+	var cols = []string{
+		"channel_name",
+		"case_id",
+		"org_id",
+	}
+	_, err := m.db.Cols(cols...).Where("channel_id=?", channel.ChannelId).Update(channel)
+	return err
+}
+
+// DeleteChannel 删除渠道
+func (m *ChannelDAO) DeleteChannel(channelId string) error {
+	var channel = model.TaChannel{
+		ChannelId: channelId,
+		Status:    models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("channel_id", channel.ChannelId).Update(channel)
+	return err
+}

models/vipcard/vipcard.go

@@ -0,0 +1,94 @@
+package vipcard
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/go-xorm/xorm"
+)
+
+// ChannelDAO 当前数据库操作对象
+type VipcardDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewVipcardDAO New Inst
+func NewVipcardDAO(ctx *utils.Context) *VipcardDAO {
+	return &VipcardDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+type VipChild struct {
+	model.TaVipCardChild `xorm:"extendes"`
+	CaesName             string
+	CustomerName         string
+}
+
+// GetVipCardList获取VIP卡列表
+func (m *VipcardDAO) GetVipCardList(caseid string) ([]VipChild, error) {
+	var vipcards []VipChild
+	sql := `SELECT
+	vcc.*,
+	sc.case_name,
+	tc.customer_name
+FROM
+	ta_vip_card_child vcc
+	INNER JOIN ta_vip_card vc ON vcc.vip_card_id = vc.vip_card_id
+	INNER JOIN sys_case sc ON vc.case_id = sc.case_id 
+	INNER JOIN ta_customer tc on vcc.customer_id = tc.customer_id
+WHERE
+	vcc.status > 0 ` + strconv.Itoa(models.STATUS_DEL) +
+		`AND sc.case_id IN(` + strings.Replace(caseid, ",", "','", -1) + `) `
+	err := m.db.Sql(sql).Find(&vipcards)
+	return vipcards, err
+}
+
+// AddVipCard 新增VIP卡
+func (m *VipcardDAO) AddVipCard(vipCard model.TaVipCard) (*model.TaVipCard, error) {
+	vipCard.VipCardId = utils.GetGUID()
+	vipCard.CreateDate = time.Now()
+	vipCard.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(vipCard)
+	return &vipCard, err
+
+}
+
+// AddVipChildCard 新增VIP子卡
+func (m *VipcardDAO) AddVipChildCard(vipChild model.TaVipCardChild) (*model.TaVipCardChild, error) {
+	vipChild.CreateDate = time.Now()
+	vipChild.VipCardChildId = utils.GetGUID()
+	vipChild.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(vipChild)
+	return &vipChild, err
+}
+
+// GetVipChildByCode 通过code获取VIP子卡
+func (m *VipcardDAO) GetVipChildByCode(vipCode string) (*model.TaVipCardChild, error) {
+	var vipChild []model.TaVipCardChild
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("vip_card_child_code =?", vipCode).Find(&vipChild)
+	if err != nil {
+		return nil, err
+	}
+	if len(vipChild) > 0 {
+		return &vipChild[0], nil
+	}
+	return nil, nil
+}
+
+// UpdateVipChild 更新子卡
+func (m *VipcardDAO) UpdateVipChild(vipChild model.TaVipCardChild) error {
+	var cols = []string{
+		"customer_id",
+		"customer_tel",
+		"active_date",
+	}
+	_, err := m.db.Cols(cols...).Where("vip_card_child_id", vipChild.VipCardChildId).Update(vipChild)
+	return err
+}

routers/common.go

@@ -3,6 +3,7 @@ package routers
 import (
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/controllers/cases"
+	"spaceofcheng/services/controllers/channel"
 	"spaceofcheng/services/controllers/course"
 	"spaceofcheng/services/controllers/customer"
 	"spaceofcheng/services/controllers/goods"
@@ -125,6 +126,12 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/case/table", &cases.CaseController{}, "put:SaveCaseTable"),
 		beego.NSRouter("/case/table/:tableid", &cases.CaseController{}, "delete:DelCaseTable"),
 
+		beego.NSRouter("/channel", &channel.ChannelController{}, "get:GetChannelList"),
+		beego.NSRouter("/channel/:channelId", &channel.ChannelController{}, "get:GetChannelById"),
+		beego.NSRouter("/channel", &channel.ChannelController{}, "post:SaveChannel"),
+		beego.NSRouter("/channel", &channel.ChannelController{}, "put:SaveChannel"),
+		beego.NSRouter("/channel/:channelId", &channel.ChannelController{}, "delete:DeleteChannel"),
+
 		// role 角色
 		beego.NSRouter("/role", &system.RoleController{}, "get:GetRoleList"),
 		beego.NSRouter("/role/:roleid", &system.RoleController{}, "get:GetRoleByID"),

service/channel/channel.go

@@ -0,0 +1,68 @@
+package channel
+
+import (
+	"spaceofcheng/services/models/channel"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
+)
+
+// ChannelServ 系统处理
+type ChannelServ struct {
+	ctx *utils.Context
+	dao *channel.ChannelDAO
+}
+
+// NewChannelServ 初始化
+func NewChannelServ(ctx *utils.Context) *ChannelServ {
+	return &ChannelServ{
+		ctx: ctx,
+		dao: channel.NewChannelDAO(ctx),
+	}
+}
+
+// GetChannelList 获取渠道列表
+func (s *ChannelServ) GetChannelList(caseid string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	channels, err := s.dao.GetChannels(caseid, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetChannelsCount(caseid)
+	if err != nil {
+		return nil, err
+	}
+	return map[string]interface{}{
+		"list":     channels,
+		"pageSize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetChannelById 根据渠道id获取渠道
+func (s *ChannelServ) GetChannelById(channelId string) (*model.TaChannel, error) {
+	channel, err := s.dao.GetChannelById(channelId)
+	return channel, err
+}
+
+// SaveChannel 保存渠道
+func (s *ChannelServ) SaveChannel(channel model.TaChannel) (*model.TaChannel, error) {
+	var newChannel *model.TaChannel
+	var err error
+	if channel.ChannelId == "" {
+		newChannel, err = s.dao.AddNewChannel(channel)
+	} else {
+		err = s.dao.UpdateChannel(channel)
+		newChannel = &channel
+	}
+	return newChannel, err
+}
+
+// DeleteChannel 删除渠道
+func (s *ChannelServ) DeleteChannel(caseid string) error {
+	err := s.dao.DeleteChannel(caseid)
+	return err
+}

service/vipcard/vipcard.go

@@ -0,0 +1,20 @@
+package vipcard
+
+import (
+	"spaceofcheng/services/models/vipcard"
+	"spaceofcheng/services/utils"
+)
+
+// CaseServ 系统处理
+type VipcardServ struct {
+	ctx *utils.Context
+	dao *vipcard.VipcardDAO
+}
+
+// NewVipcardServ 初始化
+func NewVipcardServ(ctx *utils.Context) *VipcardServ {
+	return &VipcardServ{
+		ctx: ctx,
+		dao: vipcard.NewVipcardDAO(ctx),
+	}
+}