feats

conf/db.conf

@@ -11,10 +11,10 @@ db_addr      = localhost
 db_port      = 3306
 
 ; 用户名
-username     = h5-template
+username     = spaceofcheng
 
 ; 密码
-password     = h5-template
+password     = spaceofcheng
 
 ; 数据库名或者schema
 database     = spaceofcheng

log/common.log

@@ -18,3 +18,5 @@
 2018/08/21 13:39:24 [E] 您没有该案场的权限！
 2018/08/21 13:41:04 [E] 用户没有设置默认案场
 2018/08/21 13:41:04 [E] 您没有该案场的权限！
+2018/08/21 14:26:22 [E] 用户登录失败: dial tcp 192.168.0.62:3306: connectex: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond.
+2018/08/21 14:27:06 [E] 用户登录失败: dial tcp 192.168.0.62:3306: connectex: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond.

models/constant.go

@@ -34,3 +34,38 @@ const (
 	USERMAP_USER     = "user"
 	USERMAP_CUSTOMER = "customer"
 )
+
+// 人员禁止内容
+const (
+	// 禁止下单
+	FORBID_ORDER = "order"
+
+	// 禁止发卡, 发券
+	FORBID_COUPON = "coupon"
+)
+
+// 消费类型
+const (
+	CONSUME_POINTS   = "points"
+	CONSUME_MONEYCHG = "money-of-cheng"
+)
+
+// 消费方式
+const (
+	ACCOUNT_INCOME = "+"
+	ACCOUNT_SPENT  = "-"
+)
+
+// 账户消费来源
+const (
+	// 充值
+	ACCSOURCE_RECHARGE = "recharge"
+	// 订单
+	ACCSOURCE_ORDERS = "orders"
+	// 注册
+	ACCSOURCE_REGISTER = "register"
+	// 完善资料
+	ACCSOURCE_COMPLETE_PROFILE = "complete_profile"
+	// 推荐
+	ACCSOURCE_RECOMMEND = "recommend"
+)

models/customer/account.go

@@ -0,0 +1,123 @@
+package customer
+
+import (
+	"errors"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"time"
+
+	"github.com/yl10/kit/guid"
+)
+
+// SaveAccount 保存账户信息
+func (m *CustomerDAO) SaveAccount(account *model.TaCustomerAccount) error {
+	if account.CustomerId == "" {
+		return errors.New("账户未关联人员")
+	}
+
+	account.Status = models.STATUS_NORMAL
+	account.CreateDate = time.Now().Local()
+	account.AccountId = guid.NewGUIDString()
+
+	_, err := m.db.Insert(account)
+	return err
+}
+
+// InsertAccountRecords 新增账户消费记录
+func (m *CustomerDAO) InsertAccountRecords(rec *model.TaAccountChange) error {
+	if rec.AccountId == "" {
+		return errors.New("无法确定消费账户")
+	}
+
+	if rec.CaseId == "" {
+		return errors.New("无法确定消费案场")
+	}
+
+	acc, err := m.GetAccountByID(rec.AccountId)
+	if err != nil {
+		utils.LogError("获取人员账户失败: " + err.Error())
+		return errors.New("找不到账户消费记录")
+	}
+
+	if acc.Status != models.STATUS_NORMAL {
+		return errors.New("人员账户状态不正常")
+	}
+
+	// 补充部分字段
+	rec.DetailId = guid.NewGUIDString()
+	rec.CreateDate = time.Now().Local()
+	rec.Status = models.STATUS_NORMAL
+	rec.OrgId = acc.OrgId
+
+	// 消费内容
+	points := float64(0.0)
+	moenyCheng := float64(0.0)
+	amount, _ := strconv.ParseFloat(rec.Amount, 64)
+	if rec.ChangeType == models.CONSUME_POINTS {
+		points = amount
+	} else if rec.ChangeType == models.CONSUME_MONEYCHG {
+		moenyCheng = amount
+	}
+
+	// 反向更新账户表
+	accAmount, _ := strconv.ParseFloat(acc.Amount, 64)
+	accPoints, _ := strconv.ParseFloat(acc.Points, 64)
+	accPayedAmount, _ := strconv.ParseFloat(acc.PayedAmount, 64)
+	accPayedPoints, _ := strconv.ParseFloat(acc.PayedPoints, 64)
+
+	if rec.FloatType == models.ACCOUNT_SPENT {
+		accPayedAmount += moenyCheng
+		accPayedPoints += points
+
+		accAmount -= moenyCheng
+		accPoints -= points
+	}
+
+	// 账户不能为负
+	if accAmount < 0 || accPoints < 0 {
+		return errors.New("账户不足, 不能消费")
+	}
+
+	acc.Amount = strconv.FormatFloat(accAmount, 'f', -1, 64)
+	acc.Points = strconv.FormatFloat(accPoints, 'f', -1, 64)
+	acc.PayedAmount = strconv.FormatFloat(accPayedAmount, 'f', -1, 64)
+	acc.PayedPoints = strconv.FormatFloat(accPayedPoints, 'f', -1, 64)
+
+	if _, err := m.db.Insert(rec); err != nil {
+		utils.LogError("插入消费记录失败: " + err.Error())
+		return errors.New("记录消费记录失败")
+	}
+
+	if _, err := m.db.Where("account_id=?", acc.AccountId).
+		Cols([]string{"amount", "points", "payed_amount", "payed_points"}...).
+		Update(acc); err != nil {
+		utils.LogError("更新账户信息失败: " + err.Error())
+		return errors.New("更新消费信息失败")
+	}
+
+	return nil
+}
+
+// GetAccountByID 获取账户信息
+func (m *CustomerDAO) GetAccountByID(id string) (*model.TaCustomerAccount, error) {
+	acc := new(model.TaCustomerAccount)
+
+	if _, err := m.db.Where("account_id=?", id).Get(acc); err != nil {
+		return nil, err
+	}
+
+	return acc, nil
+}
+
+// GetAccountByCust 获取账户信息
+func (m *CustomerDAO) GetAccountByCust(id string) (*model.TaCustomerAccount, error) {
+	acc := new(model.TaCustomerAccount)
+
+	if _, err := m.db.Where("customer_id=?", id).Get(acc); err != nil {
+		return nil, err
+	}
+
+	return acc, nil
+}

models/customer/customer.go

@@ -201,3 +201,25 @@ func (m *CustomerDAO) SaveCustomer(cust *model.TaCustomer) error {
 	_, err := m.db.Insert(cust)
 	return err
 }
+
+// GetCustomerByID 依据ID获取客户
+func (m *CustomerDAO) GetCustomerByID(id string) (*model.TaCustomer, error) {
+	cust := new(model.TaCustomer)
+
+	if _, err := m.db.Where("customer_id=?", id).Get(cust); err != nil {
+		return nil, err
+	}
+
+	return cust, nil
+}
+
+// GetForbidUserByUserID 查询禁用人员
+func (m *CustomerDAO) GetForbidUserByUserID(userID string) ([]model.TaForbidUser, error) {
+	var fbUsers []model.TaForbidUser
+
+	if err := m.db.Where("user_id=?", userID).Find(&fbUsers); err != nil {
+		return nil, err
+	}
+
+	return fbUsers, nil
+}

models/goods/goods.go

@@ -63,6 +63,28 @@ func (m *GoodsDAO) GetGoodsByID(id, caseID string) (*model.TaGoods, error) {
 	return goods, nil
 }
 
+// GetGoodsWithPriceByID 依据ID 获取商品
+func (m *GoodsDAO) GetGoodsWithPriceByID(id, spec, caseID string) (*GoodsWithPrice, error) {
+	goods := new(GoodsWithPrice)
+	query := `
+		SELECT *
+		FROM
+			ta_goods t
+		JOIN ta_goods_spec s ON t.goods_id = s.goods_id
+		WHERE
+			t.goods_id = ?
+		AND t.case_id = ?
+		AND s.spec_id = ?
+		AND t.status = ?
+	`
+
+	if _, err := m.db.SQL(query, id, caseID, spec, models.STATUS_NORMAL).Get(goods); err != nil {
+		return nil, err
+	}
+
+	return goods, nil
+}
+
 // UpdateGoods 更新商品
 func (m *GoodsDAO) UpdateGoods(goods *model.TaGoods, cols []string) error {
 	if _, err := m.db.Where("goods_id=?", goods.GoodsId).Cols(cols...).Update(goods); err != nil {

models/goods/orders.go

@@ -5,6 +5,7 @@ import (
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
+	"strconv"
 	"strings"
 	"time"
 
@@ -31,10 +32,73 @@ func (m *GoodsDAO) SaveOrders(order *model.TaGoodsOrders) error {
 	order.OrgId = caseInfo.OrgId
 	order.CreateDate = time.Now().Local()
 	order.Status = models.STATUS_NORMAL
+	order.IsPay = models.BOOL_TRUE // 默认已支付
+	order.CouponAmount = "0"
 
 	// 当前订单号的随机方式 = 时间 + 个人ID
 	order.OrdersNo = time.Now().Local().Format("20060102150405") + "-" + strings.Join(utils.GUIID2IntString(order.UserId), "")
 
+	if _, err := m.db.Insert(order); err != nil {
+		utils.LogError("保存订单主记录失败: " + err.Error())
+
+		return errors.New("保存订单主记录失败")
+	}
+	return nil
+}
+
+// SaveOrdersDetail 保存订单明细
+func (m *GoodsDAO) SaveOrdersDetail(list []model.TaGoodsOrdersDetail, ordersID string) error {
+	for inx := range list {
+		list[inx].OrdersId = ordersID
+	}
+
+	if _, err := m.db.Insert(list); err != nil {
+		utils.LogError("保存订单明细失败: " + err.Error())
+
+		return errors.New("保存订单明细失败")
+	}
+
+	return nil
+}
+
+// SaveOrdersCoupon 保存订单优惠券
+func (m *GoodsDAO) SaveOrdersCoupon(coupons []model.TaGoodsOrdersCoupon, order *model.TaGoodsOrders) error {
+	if order.OrdersId == "" {
+		return errors.New("内部错误, 订单事务顺序出错")
+	}
+
+	var couponAmount float64 = 0
+
+	// 补充优惠券表字段
+	for inx := range coupons {
+		coupons[inx].OrdersCouponId = guid.NewGUIDString()
+		coupons[inx].OrdersId = order.OrdersId
+		coupons[inx].OrdersNo = order.OrdersNo
+		coupons[inx].OrgId = order.OrgId
+		coupons[inx].Status = models.STATUS_NORMAL
+		coupons[inx].CreateDate = time.Now().Local()
+
+		userAmount, _ := strconv.ParseFloat(coupons[inx].UsedAmount, 64)
+		couponAmount += userAmount
+	}
+
+	// 反向更新 订单主表
+	totalAmount, _ := strconv.ParseFloat(order.Amount, 64)
+
+	order.CouponAmount = strconv.FormatFloat(couponAmount, 'f', -1, 32)
+	order.ActualAmount = strconv.FormatFloat((totalAmount - couponAmount), 'f', -1, 32)
+
+	if _, err := m.db.Insert(&coupons); err != nil {
+		return err
+	}
+
+	if _, err := m.db.
+		Where("orders_id=?", order.OrdersId).
+		Cols([]string{"coupon_amount", "actual_amount"}...).
+		Update(&order); err != nil {
+		return err
+	}
+
 	return nil
 }
 

models/goods/types.go

@@ -15,3 +15,9 @@ type GoodsWithSpec struct {
 	model.TaGoods
 	Specs []SpecWithPrice
 }
+
+// GoodsWithPrice 含规格商品
+type GoodsWithPrice struct {
+	model.TaGoods     `xorm."extends"`
+	model.TaGoodsSpec `xorm."extends"`
+}

models/model/ta_account_change.go

@@ -7,15 +7,15 @@ import (
 type TaAccountChange struct {
 	DetailId     string    `xorm:"not null pk VARCHAR(64)"`
 	AccountId    string    `xorm:"VARCHAR(64)"`
-	UserId       string    `xorm:"VARCHAR(64)"`
-	UserName     string    `xorm:"VARCHAR(50)"`
+	CustomerId   string    `xorm:"VARCHAR(64)"`
+	CustomerName string    `xorm:"VARCHAR(50)"`
 	OrgId        string    `xorm:"VARCHAR(64)"`
 	CaseId       string    `xorm:"VARCHAR(64)"`
 	ChangeType   string    `xorm:"comment('integral 积分 amount 城币') VARCHAR(20)"`
 	ChangeSource string    `xorm:"comment('vip vip卡充值 orders 订单消费 register 注册 perfect 完善资料 recommend 推荐') VARCHAR(20)"`
 	SourceId     string    `xorm:"VARCHAR(64)"`
 	SourceName   string    `xorm:"VARCHAR(255)"`
-	Amount       float32   `xorm:"FLOAT(8,2)"`
+	Amount       string    `xorm:"DECIMAL(8,2)"`
 	FloatType    string    `xorm:"comment('+ -') VARCHAR(5)"`
 	CreateDate   time.Time `xorm:"DATETIME"`
 	CreateUser   string    `xorm:"VARCHAR(64)"`

models/model/ta_coupon_card2.go

@@ -1,28 +0,0 @@
-package model
-
-import (
-	"time"
-)
-
-type TaCouponCard2 struct {
-	CardId           string    `xorm:"not null pk VARCHAR(64)"`
-	CardTypeId       string    `xorm:"VARCHAR(64)"`
-	SendType         int       `xorm:"comment('0案场 1渠道') SMALLINT(6)"`
-	VideoUrl         string    `xorm:"TEXT"`
-	CoverUrl         string    `xorm:"TEXT"`
-	Price            float32   `xorm:"FLOAT(64)"`
-	StartDate        time.Time `xorm:"DATETIME"`
-	EndDate          time.Time `xorm:"DATETIME"`
-	ShareDescription string    `xorm:"VARCHAR(255)"`
-	RuleDescription  string    `xorm:"VARCHAR(400)"`
-	UseDescription   string    `xorm:"TEXT"`
-	TotalCount       int       `xorm:"INT(11)"`
-	SentCount        int       `xorm:"INT(11)"`
-	UsedCount        int       `xorm:"INT(11)"`
-	Status           int       `xorm:"comment('0未发布 1发布 2过期') SMALLINT(6)"`
-	CaseId           string    `xorm:"VARCHAR(64)"`
-	OrgId            string    `xorm:"VARCHAR(64)"`
-	CreateDate       time.Time `xorm:"DATETIME"`
-	CreateUser       string    `xorm:"VARCHAR(64)"`
-	IsOver           int       `xorm:"TINYINT(1)"`
-}

models/model/ta_coupon_card_target2.go → models/model/ta_coupon_target.go

@@ -1,7 +1,7 @@
 package model
 
-type TaCouponCardTarget2 struct {
+type TaCouponTarget struct {
 	TargetId   string `xorm:"not null pk VARCHAR(64)"`
-	CardId     string `xorm:"VARCHAR(64)"`
+	CouponId   string `xorm:"VARCHAR(64)"`
 	TargetName string `xorm:"VARCHAR(255)"`
 }

models/model/ta_customer_account.go

@@ -5,14 +5,14 @@ import (
 )
 
 type TaCustomerAccount struct {
-	AccountId     string    `xorm:"not null pk VARCHAR(64)"`
-	UserId        string    `xorm:"VARCHAR(64)"`
-	UserName      string    `xorm:"VARCHAR(50)"`
-	Amount        float32   `xorm:"FLOAT(8,2)"`
-	Integral      float32   `xorm:"FLOAT(8,2)"`
-	Status        int       `xorm:"SMALLINT(6)"`
-	OrgId         string    `xorm:"VARCHAR(64)"`
-	CreateDate    time.Time `xorm:"DATETIME"`
-	PayedAmount   float32   `xorm:"FLOAT(8,2)"`
-	PayedIntegral float32   `xorm:"FLOAT(8,2)"`
+	AccountId    string    `xorm:"not null pk VARCHAR(64)"`
+	CustomerId   string    `xorm:"VARCHAR(64)"`
+	CustomerName string    `xorm:"VARCHAR(50)"`
+	Amount       string    `xorm:"DECIMAL(8,2)"`
+	Points       string    `xorm:"DECIMAL(8,2)"`
+	Status       int       `xorm:"SMALLINT(6)"`
+	OrgId        string    `xorm:"VARCHAR(64)"`
+	CreateDate   time.Time `xorm:"DATETIME"`
+	PayedAmount  string    `xorm:"DECIMAL(8,2)"`
+	PayedPoints  string    `xorm:"DECIMAL(8,2)"`
 }

models/model/ta_forbid_user.go

@@ -0,0 +1,16 @@
+package model
+
+import (
+	"time"
+)
+
+type TaForbidUser struct {
+	ForbidId   string    `xorm:"not null pk VARCHAR(64)"`
+	UserId     string    `xorm:"VARCHAR(64)"`
+	UserType   string    `xorm:"VARCHAR(64)"`
+	ForbidType string    `xorm:"VARCHAR(20)"`
+	BeginDate  time.Time `xorm:"DATETIME"`
+	EndDate    time.Time `xorm:"DATETIME"`
+	Status     int       `xorm:"SMALLINT(6)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+}

models/model/ta_goods_orders.go

@@ -5,25 +5,24 @@ import (
 )
 
 type TaGoodsOrders struct {
-	OrdersId   string    `xorm:"not null pk VARCHAR(64)"`
-	OrdersNo   string    `xorm:"VARCHAR(32)"`
-	OrgId      string    `xorm:"VARCHAR(64)"`
-	CaseId     string    `xorm:"VARCHAR(64)"`
-	AreaId     string    `xorm:"VARCHAR(64)"`
-	AreaName   string    `xorm:"VARCHAR(50)"`
-	TableId    string    `xorm:"VARCHAR(64)"`
-	TableNo    string    `xorm:"VARCHAR(50)"`
-	Amount     string    `xorm:"DECIMAL(8,2)"`
-	CreateDate time.Time `xorm:"DATETIME"`
-	Status     int       `xorm:"SMALLINT(6)"`
-	PayType    string    `xorm:"comment('vip VIP卡城币抵用
-            coupon 优惠券抵用') VARCHAR(20)"`
-	UserType     string `xorm:"VARCHAR(20)"`
-	UserId       string `xorm:"VARCHAR(64)"`
-	UserName     string `xorm:"VARCHAR(50)"`
-	OrdersNum    int    `xorm:"INT(11)"`
-	Remark       string `xorm:"TEXT"`
-	IsPay        int    `xorm:"TINYINT(1)"`
-	ActualAmount string `xorm:"DECIMAL(8,2)"`
-	CouponAmount string `xorm:"DECIMAL(8,2)"`
+	OrdersId     string    `xorm:"not null pk VARCHAR(64)"`
+	OrdersNo     string    `xorm:"VARCHAR(32)"`
+	OrgId        string    `xorm:"VARCHAR(64)"`
+	CaseId       string    `xorm:"VARCHAR(64)"`
+	AreaId       string    `xorm:"VARCHAR(64)"`
+	AreaName     string    `xorm:"VARCHAR(50)"`
+	TableId      string    `xorm:"VARCHAR(64)"`
+	TableNo      string    `xorm:"VARCHAR(50)"`
+	Amount       string    `xorm:"DECIMAL(8,2)"`
+	CreateDate   time.Time `xorm:"DATETIME"`
+	Status       int       `xorm:"SMALLINT(6)"`
+	PayType      string    `xorm:"comment('vip VIP卡城币抵用 coupon 优惠券抵用') VARCHAR(20)"`
+	UserType     string    `xorm:"VARCHAR(20)"`
+	UserId       string    `xorm:"VARCHAR(64)"`
+	UserName     string    `xorm:"VARCHAR(50)"`
+	OrdersNum    int       `xorm:"INT(11)"`
+	Remark       string    `xorm:"TEXT"`
+	IsPay        int       `xorm:"TINYINT(1)"`
+	ActualAmount string    `xorm:"DECIMAL(8,2)"`
+	CouponAmount string    `xorm:"DECIMAL(8,2)"`
 }

models/model/ta_goods_orders_coupon.go

@@ -13,7 +13,7 @@ type TaGoodsOrdersCoupon struct {
 	OrgId          string    `xorm:"VARCHAR(64)"`
 	GoodsId        string    `xorm:"VARCHAR(64)"`
 	GoodsName      string    `xorm:"VARCHAR(50)"`
-	UsedAmount     float32   `xorm:"FLOAT(8,2)"`
+	UsedAmount     string    `xorm:"DECIMAL(8,2)"`
 	Status         int       `xorm:"SMALLINT(6)"`
 	CreateDate     time.Time `xorm:"DATETIME"`
 }

models/model/ta_goods_spec.go

@@ -1,7 +1,7 @@
 package model
 
 type TaGoodsSpec struct {
-	SpecId     string  `xorm:"not null pk VARCHAR(64)"`
-	GoodsId    string  `xorm:"not null pk VARCHAR(64)"`
-	GoodsPrice float32 `xorm:"FLOAT(8,2)"`
+	SpecId     string `xorm:"not null pk VARCHAR(64)"`
+	GoodsId    string `xorm:"not null pk VARCHAR(64)"`
+	GoodsPrice string `xorm:"DECIMAL(8,2)"`
 }

models/model/ta_stop_user.go

@@ -1,14 +0,0 @@
-package model
-
-import (
-	"time"
-)
-
-type TaStopUser struct {
-	StopId    string    `xorm:"not null pk VARCHAR(64)"`
-	UserId    string    `xorm:"VARCHAR(64)"`
-	UserType  string    `xorm:"VARCHAR(64)"`
-	StopType  int       `xorm:"SMALLINT(6)"`
-	BeginDate time.Time `xorm:"DATETIME"`
-	EndDate   time.Time `xorm:"DATETIME"`
-}

service/customer/customer.go

@@ -246,7 +246,20 @@ func (s *CustomerServ) SaveNewCustomer(wxInfo map[string]interface{}, caseID, ar
 
 	if err := s.dao.SaveCustomer(&cust); err != nil {
 		utils.LogError("更新客户信息失败: " + err.Error())
-		beego.Error(err)
+		return nil, errors.New("更新客户信息失败")
+	}
+
+	account := new(model.TaCustomerAccount)
+	account.CustomerId = cust.CustomerId
+	account.CustomerName = cust.CustomerName
+	account.OrgId = cust.OrgId
+	account.Amount = "0"
+	account.Points = "0"
+	account.PayedAmount = "0"
+	account.PayedPoints = "0"
+
+	if err := s.dao.SaveAccount(account); err != nil {
+		utils.LogError("插入账户信息失败: " + err.Error())
 		return nil, errors.New("更新客户信息失败")
 	}
 

service/goods/goods.go

@@ -1,20 +1,26 @@
 package goods
 
 import (
+	"spaceofcheng/services/models/cases"
+	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/goods"
 	"spaceofcheng/services/utils"
 )
 
 // GoodsServ 系统处理
 type GoodsServ struct {
-	ctx *utils.Context
-	dao *goods.GoodsDAO
+	ctx     *utils.Context
+	dao     *goods.GoodsDAO
+	caseDAO *cases.CaseDAO
+	custDAO *customer.CustomerDAO
 }
 
 // NewGoodsServ 初始化
 func NewGoodsServ(ctx *utils.Context) *GoodsServ {
 	return &GoodsServ{
-		ctx: ctx,
-		dao: goods.NewGoodsDAO(ctx),
+		ctx:     ctx,
+		dao:     goods.NewGoodsDAO(ctx),
+		caseDAO: cases.NewCaseDAO(ctx),
+		custDAO: customer.NewCustomerDAO(ctx),
 	}
 }

service/goods/orders.go

@@ -0,0 +1,204 @@
+package goods
+
+import (
+	"errors"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+)
+
+// Orders 下单
+func (s *GoodsServ) Orders(
+	info *model.TaGoodsOrders,
+	details []model.TaGoodsOrdersDetail,
+	coupons []model.TaGoodsOrdersCoupon) error {
+
+	// 校验下单内容
+	if err := s.validOrdersInfo(info); err != nil {
+		return err
+	}
+
+	// 校验各种金额
+	if err := s.validBillCharges(info, details); err != nil {
+		return err
+	}
+
+	// 保存主订单
+	if err := s.dao.SaveOrders(info); err != nil {
+		return err
+	}
+
+	// 保存订单明细
+	if err := s.dao.SaveOrdersDetail(details, info.OrdersId); err != nil {
+		return err
+	}
+
+	account, err := s.custDAO.GetAccountByCust(info.UserId)
+	if err != nil {
+		utils.LogError("查询用户账户信息出错: " + err.Error())
+		return errors.New("查询用户账户信息出错")
+	}
+
+	// 如果是使用优惠券
+	if coupons != nil && len(coupons) > 0 {
+		// TODO
+		// 校验优惠券相关
+	} else {
+		// 如果是使用城币
+		accMoney, _ := strconv.ParseFloat(account.Amount, 64)
+		payMoney, _ := strconv.ParseFloat(info.ActualAmount, 64)
+
+		if accMoney < payMoney {
+			return errors.New("账户余额不足")
+		}
+	}
+
+	// 保存优惠券使用记录
+	if coupons != nil && len(coupons) > 0 {
+		if err := s.dao.SaveOrdersCoupon(coupons, info); err != nil {
+			utils.LogError("保存优惠信息出错: " + err.Error())
+			return errors.New("保存优惠信息出错")
+		}
+
+		// TODO
+		// 核销优惠券
+	}
+
+	// 如果是城币, 则插入用户账户消费记录
+	if info.PayType == models.CONSUME_MONEYCHG {
+		if err := s.saveCustomerPayRec(account, info); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+// saveCustomerPayRec 保存账户消费流水
+func (s *GoodsServ) saveCustomerPayRec(account *model.TaCustomerAccount, info *model.TaGoodsOrders) error {
+	accBill := new(model.TaAccountChange)
+	accBill.AccountId = account.AccountId
+	accBill.Amount = info.ActualAmount
+	accBill.CaseId = info.CaseId
+	accBill.ChangeSource = models.ACCSOURCE_ORDERS
+	accBill.ChangeType = models.CONSUME_MONEYCHG
+	accBill.CustomerId = info.UserId
+	accBill.CustomerName = info.UserName
+	accBill.FloatType = models.ACCOUNT_SPENT
+	accBill.SourceId = info.OrdersId
+	accBill.SourceName = ""
+
+	return s.custDAO.InsertAccountRecords(accBill)
+}
+
+// validOrdersInfo 校验下单内容
+// 没有对金额, 数量的关系进行校验
+func (s *GoodsServ) validOrdersInfo(info *model.TaGoodsOrders) error {
+
+	caseID := info.CaseId
+	if caseID == "" {
+		return errors.New("未指定消费案场")
+	}
+
+	areaID := info.AreaId
+	if areaID == "" {
+		return errors.New("未指定消费区域")
+	}
+
+	tableID := info.TableId
+	if tableID == "" {
+		return errors.New("未指定消费桌位")
+	}
+
+	custID := info.UserId
+	if custID == "" {
+		return errors.New("未指定下单人员")
+	}
+
+	// 验证区域
+	caseArea, err := s.caseDAO.GetCaseAreaByID(areaID)
+	if err != nil {
+		utils.LogError("查询案场区域出错: " + err.Error())
+		return errors.New("验证案场区域出错")
+	}
+
+	info.AreaName = caseArea.AreaName
+	info.OrgId = caseArea.OrgId
+
+	// 验证桌位
+	table, err := s.caseDAO.GetCaseTableByID(tableID)
+	if err != nil {
+		utils.LogError("查询案场桌位出错: " + err.Error())
+		return errors.New("验证案场桌位出错")
+	}
+
+	info.TableNo = table.TableNo
+
+	// 验证人员
+	cust, err := s.custDAO.GetCustomerByID(custID)
+	if err != nil {
+		utils.LogError("查询下单人出错: " + err.Error())
+		return errors.New("验证下单人出错")
+	}
+
+	if cust.Status != models.STATUS_NORMAL {
+		return errors.New("下单人状态不正确, 不能下单")
+	}
+
+	// 如果是管理人员
+	if cust.UserId != "" {
+		fibUsers, err := s.custDAO.GetForbidUserByUserID(cust.UserId)
+		if err != nil {
+			utils.LogError("查询下单人是否被禁出错: " + err.Error())
+			return errors.New("验证下单人出错")
+		}
+
+		if fibUsers != nil && len(fibUsers) > 0 {
+			for _, u := range fibUsers {
+				if u.ForbidType == models.FORBID_ORDER && u.Status == models.STATUS_NORMAL {
+					return errors.New("当前下单人被禁止点单")
+				}
+			}
+		}
+	}
+
+	return nil
+}
+
+// validBillCharges 验证下单各种金额
+func (s *GoodsServ) validBillCharges(info *model.TaGoodsOrders, details []model.TaGoodsOrdersDetail) error {
+	if details == nil || len(details) == 0 {
+		return errors.New("没有发现下单明细")
+	}
+
+	caseID := info.CaseId
+
+	orgAmount := float64(0.0)
+	for _, item := range details {
+		goods, err := s.dao.GetGoodsWithPriceByID(item.GoodsId, item.SpecId, caseID)
+		if err != nil {
+			utils.LogError("查询商品详情失败: " + err.Error())
+			return errors.New("校验商品信息失败")
+		}
+
+		if goods.GoodsPrice != item.Price {
+			return errors.New("商品金额计算错误")
+		}
+
+		// TODO 校验库存
+		// 商品暂时无库存
+
+		price, _ := strconv.ParseFloat(item.Price, 64)
+		orgAmount += price * float64(item.Number)
+	}
+
+	// 校验总金额
+	orderAmount, _ := strconv.ParseFloat(info.Amount, 64)
+
+	if orgAmount != orderAmount {
+		return errors.New("商品金额计算错误")
+	}
+
+	return nil
+}