feats

conf/sms.conf

@@ -4,4 +4,4 @@ method = POST
 contentType = "application/json;charset=UTF-8"
 
 [captcha]
-code = 0113
+message = {"code": "0113", "tel": "%s", "params": [%s]}

controllers/course/course.go

@@ -8,7 +8,7 @@ import (
 
 // CourseController 商品
 type CourseController struct {
-	dao *course.CourseServ
+	serv *course.CourseServ
 	controllers.BaseController
 }
 
@@ -16,7 +16,7 @@ type CourseController struct {
 // @Title Constructor
 // @Description 初始化 Controller, 系统自动调用
 func (c *CourseController) Constructor() {
-	c.dao = course.NewCourseServ(c.Context)
+	c.serv = course.NewCourseServ(c.Context)
 }
 
 // GetCourseList 获取课程列表
@@ -30,7 +30,7 @@ func (c *CourseController) GetCourseList() {
 	pageSize, _ := c.GetInt("pagesize")
 	name := c.GetString("name")
 	typeid := c.GetString("typeid")
-	courses, err := c.dao.GetCourseList(caseids, name, typeid, page, pageSize)
+	courses, err := c.serv.GetCourseList(caseids, name, typeid, page, pageSize)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -40,7 +40,7 @@ func (c *CourseController) GetCourseList() {
 // GetCourseByID 获取课程明细
 func (c *CourseController) GetCourseByID() {
 	courseid := c.GetString(":courseid")
-	info, err := c.dao.GetCourseByID(courseid)
+	info, err := c.serv.GetCourseByID(courseid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -54,7 +54,7 @@ func (c *CourseController) SaveCourse() {
 		c.ResponseError(err)
 	}
 	tagids := c.GetString("tagids")
-	newinfo, err := c.dao.SaveCourse(course, tagids)
+	newinfo, err := c.serv.SaveCourse(course, tagids)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -64,7 +64,7 @@ func (c *CourseController) SaveCourse() {
 // DeleteCourse 删除课程
 func (c *CourseController) DeleteCourse() {
 	courseid := c.GetString(":courseid")
-	err := c.dao.DelCourse(courseid)
+	err := c.serv.DelCourse(courseid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -74,7 +74,7 @@ func (c *CourseController) DeleteCourse() {
 // CoursePublic 课程发布
 func (c *CourseController) CoursePublic() {
 	courseid := c.GetString(":courseid")
-	err := c.dao.CoursePublic(courseid)
+	err := c.serv.CoursePublic(courseid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -84,7 +84,7 @@ func (c *CourseController) CoursePublic() {
 // CourseUnPublic 课程取消发布
 func (c *CourseController) CourseUnPublic() {
 	courseid := c.GetString(":courseid")
-	err := c.dao.CourseUnPublic(courseid)
+	err := c.serv.CourseUnPublic(courseid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -94,7 +94,7 @@ func (c *CourseController) CourseUnPublic() {
 // GetCourseImgs 获取课程图片
 func (c *CourseController) GetCourseImgs() {
 	courseid := c.GetString(":courseid")
-	imgs, err := c.dao.GetCourseImgs(courseid)
+	imgs, err := c.serv.GetCourseImgs(courseid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -107,7 +107,7 @@ func (c *CourseController) SaveCourseImg() {
 	if err := c.ParseForm(&img); err != nil {
 		c.ResponseError(err)
 	}
-	newimg, err := c.dao.SaveCourseImg(img)
+	newimg, err := c.serv.SaveCourseImg(img)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -117,7 +117,7 @@ func (c *CourseController) SaveCourseImg() {
 // DelCourseImg 删除课程图片
 func (c *CourseController) DelCourseImg() {
 	courseid := c.GetString(":courseid")
-	err := c.dao.DelCourseImg(courseid)
+	err := c.serv.DelCourseImg(courseid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -135,7 +135,7 @@ func (c *CourseController) GetCourseSchedule() {
 	date := c.GetString("date")
 	page, _ := c.GetInt("page")
 	pageSize, _ := c.GetInt("pagesize")
-	list, err := c.dao.GetCourseSchedule(name, caseids, date, page, pageSize)
+	list, err := c.serv.GetCourseSchedule(name, caseids, date, page, pageSize)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -146,7 +146,7 @@ func (c *CourseController) GetCourseSchedule() {
 func (c *CourseController) GetDetails() {
 	caseid := c.GetString("caseid")
 	date := c.GetString("date")
-	list, err := c.dao.GetDetails(caseid, date)
+	list, err := c.serv.GetDetails(caseid, date)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -156,7 +156,7 @@ func (c *CourseController) GetDetails() {
 // GetDetailByID 获取单个排课信息
 func (c *CourseController) GetDetailByID() {
 	detailid := c.GetString(":detailid")
-	detail, err := c.dao.GetDetailByID(detailid)
+	detail, err := c.serv.GetDetailByID(detailid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -169,7 +169,7 @@ func (c *CourseController) SaveDetail() {
 	if err := c.ParseForm(&detail); err != nil {
 		c.ResponseError(err)
 	}
-	newdetail, err := c.dao.SaveDetail(detail)
+	newdetail, err := c.serv.SaveDetail(detail)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -179,7 +179,7 @@ func (c *CourseController) SaveDetail() {
 // DelCourseDetail 删除课程明细
 func (c *CourseController) DelCourseDetail() {
 	detailid := c.GetString(":detailid")
-	err := c.dao.DelCourseDetail(detailid)
+	err := c.serv.DelCourseDetail(detailid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -189,7 +189,7 @@ func (c *CourseController) DelCourseDetail() {
 // GetSelectCourseList 获取精选课程
 // func (c *CourseController) GetSelectCourseList() {
 // 	orgid := c.GetString("orgid")
-// 	courses, err := c.dao.GetSelectCourseList(orgid)
+// 	courses, err := c.serv.GetSelectCourseList(orgid)
 // 	if err != nil {
 // 		c.ResponseError(err)
 // 	}
@@ -201,13 +201,13 @@ func (c *CourseController) GetCourseByLocation() {
 	locationid := c.GetString("locationid")
 	orgid := c.GetString("orgid")
 	if locationid == "selected" {
-		courses, err := c.dao.GetSelectCourseList(orgid)
+		courses, err := c.serv.GetSelectCourseList(orgid)
 		if err != nil {
 			c.ResponseError(err)
 		}
 		c.ResponseJSON(courses)
 	}
-	courses, err := c.dao.GetCourseByLocation(orgid, locationid)
+	courses, err := c.serv.GetCourseByLocation(orgid, locationid)
 	if err != nil {
 		c.ResponseError(err)
 	}

controllers/course/order.go

@@ -0,0 +1,39 @@
+package course
+
+import (
+	"encoding/json"
+	"errors"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+)
+
+func (c *CourseController) PostOrder() {
+	// 订单主信息
+	info := c.GetString("info")
+	if info == "" {
+		c.ResponseError(errors.New("无有效订单信息"))
+	}
+
+	// 订单优惠券
+	coupon := c.GetString("coupon")
+
+	//
+	var orderInfo model.TaCourseOrders
+	var orderCoupon []model.TaCourseOrdersCoupon
+
+	if err := json.Unmarshal([]byte(info), &orderInfo); err != nil {
+		utils.LogError("下单转换JSON失败: " + err.Error())
+		c.ResponseError(errors.New("下单数据格式不正确"))
+	}
+
+	if err := json.Unmarshal([]byte(coupon), &orderCoupon); err != nil {
+		utils.LogError("下单优惠转换JSON失败: " + err.Error())
+		c.ResponseError(errors.New("优惠数据格式不正确"))
+	}
+
+	if err := c.serv.Orders(&orderInfo, orderCoupon); err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("ok")
+}

models/constant.go

@@ -46,8 +46,10 @@ const (
 
 // 消费类型
 const (
-	CONSUME_POINTS   = "points"
-	CONSUME_MONEYCHG = "money-of-cheng"
+	CONSUME_INNER   = "sys user"
+	CONSUME_COUPON  = "coupon"
+	CONSUME_POINTS  = "points"
+	CONSUME_COINCHG = "cheng-coin"
 )
 
 // 消费方式
@@ -60,8 +62,10 @@ const (
 const (
 	// 充值
 	ACCSOURCE_RECHARGE = "recharge"
-	// 订单
-	ACCSOURCE_ORDERS = "orders"
+	// 商品订单
+	ACCSOURCE_GOODS_ORDERS = "goods-orders"
+	// 课程订单
+	ACCSOURCE_COURSE_ORDERS = "course-orders"
 	// 注册
 	ACCSOURCE_REGISTER = "register"
 	// 完善资料
@@ -83,3 +87,23 @@ const (
 	// 主管
 	USERTYPE_MANAGER = "manager"
 )
+
+// 课程获取方式
+const (
+	COURSE_GETBY_CARD    = "card"
+	COURSE_GETBY_COUPON  = "coupon"
+	COURSE_GETBY_COINCHG = "cheng-coin"
+)
+
+// 课程订单优惠券类型
+const (
+	COURSE_COUPON_CARD   = "card"
+	COURSE_COUPON_COUPON = "coupon"
+)
+
+// 核销类型
+const (
+	VERIFY_USEABLE = "useable"
+	VERIFY_USED    = "used"
+	VERIFY_LATE    = "late"
+)

models/course/course.go

@@ -1,6 +1,7 @@
 package course
 
 import (
+	"errors"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
@@ -8,6 +9,8 @@ import (
 	"strings"
 	"time"
 
+	"github.com/yl10/kit/guid"
+
 	"github.com/go-xorm/xorm"
 )
 
@@ -374,3 +377,42 @@ func (m *CourseDAO) GetCourseByLocation(orgid, locationid string) ([]CourseDetai
 	err := m.db.Sql(sql).Find(&courses)
 	return courses, err
 }
+
+// GetCourseOfCustomer 获取客户课程
+func (m *CourseDAO) GetCourseOfCustomer(custID, courseID string) (*model.TaCustomerCourse, error) {
+	course := new(model.TaCustomerCourse)
+
+	if _, err := m.db.Where("course_id=?", courseID).And("customer_id=?", custID).Get(course); err != nil {
+		return nil, err
+	}
+
+	return course, nil
+}
+
+// SaveCourseOfCustomer 保存我的课程
+func (m *CourseDAO) SaveCourseOfCustomer(course *model.TaCustomerCourse, details []model.TaCustomerCourseDetail) error {
+	if course == nil || details == nil || len(details) == 0 {
+		return errors.New("没有有效的我的课程信息")
+	}
+
+	course.CustomerCourseId = guid.NewGUIDString()
+	course.Status = models.STATUS_NORMAL
+
+	for i, d := range details {
+		d.CustomerDetailId = guid.NewGUIDString()
+		d.CustomerCourseId = course.CustomerCourseId
+		d.Status = models.STATUS_NORMAL
+
+		details[i] = d
+	}
+
+	if _, err := m.db.Insert(&details); err != nil {
+		return err
+	}
+
+	if _, err := m.db.Insert(course); err != nil {
+		return err
+	}
+
+	return nil
+}

models/course/order.go

@@ -1,22 +1,22 @@
 package course
 
 import (
-	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
-	"strconv"
 	"strings"
 	"time"
+
+	"github.com/yl10/kit/guid"
 )
 
 // SaveCourseOrder 保存订单
-func (m *CourseDAO) SaveCourseOrder(order model.TaCourseOrders) (*model.TaCourseOrders, error) {
-	order.OrdersId = utils.GetGUID()
+func (m *CourseDAO) SaveCourseOrder(order *model.TaCourseOrders) error {
+	order.OrdersId = guid.NewGUIDString()
 	// 当前订单号的随机方式 = 时间 + 个人ID
-	order.OrdersNo = "Customer-" + time.Now().Local().Format("20060102150405") + "-" + strings.Join(utils.GUIID2IntString(order.CustomerId), "")
+	order.OrdersNo = "C-" + time.Now().Local().Format("20060102150405") + "-" + strings.Join(utils.GUIID2IntString(order.CustomerId), "")
 	order.CreateDate = time.Now()
-	_, err := m.db.Insert(&order)
-	return &order, err
+	_, err := m.db.Insert(order)
+	return err
 }
 
 // GetOrderByID 根据id获取订单明细
@@ -33,11 +33,13 @@ func (m *CourseDAO) GetOrderByID(ordersid string) (*model.TaCourseOrders, error)
 }
 
 // SaveCourseOrderDetail 保存订单明细
-func (m *CourseDAO) SaveCourseOrderDetail(courseid, ordersid string) error {
-	sql := `insert into (orders_detail_id,orders_id,course_id,course_detail_id,begin_date,end_date) select UUID(),'` + ordersid +
-		`',course_id,detail_id,begin_date,end_date from ta_course_detail where course_id='` + courseid + `' and status>` + strconv.Itoa(models.STATUS_DEL)
-	_, err := m.db.Insert(sql)
+func (m *CourseDAO) SaveCourseOrderDetail(details []model.TaCourseOrdersDetail) error {
+	for i, d := range details {
+		d.OrdersDetailId = guid.NewGUIDString()
+
+		details[i] = d
+	}
+
+	_, err := m.db.Insert(details)
 	return err
 }
-
-//

models/course/types.go

@@ -0,0 +1 @@
+package course

models/customer/account.go

@@ -57,7 +57,7 @@ func (m *CustomerDAO) InsertAccountRecords(rec *model.TaAccountChange) error {
 	amount, _ := strconv.ParseFloat(rec.Amount, 64)
 	if rec.ChangeType == models.CONSUME_POINTS {
 		points = amount
-	} else if rec.ChangeType == models.CONSUME_MONEYCHG {
+	} else if rec.ChangeType == models.CONSUME_COINCHG {
 		moenyCheng = amount
 	}
 

models/goods/orders.go

@@ -41,7 +41,7 @@ func (m *GoodsDAO) SaveOrders(order *model.TaGoodsOrders) error {
 	order.CouponAmount = "0"
 
 	// 当前订单号的随机方式 = 时间 + 个人ID
-	order.OrdersNo = time.Now().Local().Format("20060102150405") + "-" + strings.Join(utils.GUIID2IntString(order.UserId), "")
+	order.OrdersNo = "G-" + time.Now().Local().Format("20060102150405") + "-" + strings.Join(utils.GUIID2IntString(order.UserId), "")
 
 	if _, err := m.db.Insert(order); err != nil {
 		utils.LogError("保存订单主记录失败: " + err.Error())

models/model/ta_course.go

@@ -7,7 +7,7 @@ import (
 type TaCourse struct {
 	CourseId    string    `xorm:"not null pk VARCHAR(64)"`
 	CourseName  string    `xorm:"VARCHAR(50)"`
-	Price       float32   `xorm:"FLOAT(8,2)"`
+	Price       string    `xorm:"DECIMAL(8,2)"`
 	OrgId       string    `xorm:"VARCHAR(64)"`
 	CaseId      string    `xorm:"VARCHAR(64)"`
 	LocationId  string    `xorm:"VARCHAR(64)"`

models/model/ta_course_orders.go

@@ -8,6 +8,7 @@ type TaCourseOrders struct {
 	OrdersId     string    `xorm:"not null pk VARCHAR(64)"`
 	OrdersNo     string    `xorm:"not null VARCHAR(32)"`
 	CustomerId   string    `xorm:"VARCHAR(64)"`
+	CustomerName string    `xorm:"VARCHAR(200)"`
 	OrgId        string    `xorm:"VARCHAR(64)"`
 	CaseId       string    `xorm:"VARCHAR(64)"`
 	CourseId     string    `xorm:"VARCHAR(64)"`

models/model/ta_course_orders_coupon.go

@@ -7,6 +7,7 @@ import (
 type TaCourseOrdersCoupon struct {
 	OrdersCouponId string    `xorm:"not null pk VARCHAR(64)"`
 	OrdersId       string    `xorm:"VARCHAR(64)"`
+	CouponType     string    `xorm:"VARCHAR(20)"`
 	CouponId       string    `xorm:"VARCHAR(64)"`
 	CouponName     string    `xorm:"VARCHAR(50)"`
 	UsedAmount     string    `xorm:"DECIMAL(8,2)"`

models/model/ta_customer.go

@@ -7,8 +7,8 @@ import (
 type TaCustomer struct {
 	CustomerId    string    `xorm:"not null pk VARCHAR(64)"`
 	OrgId         string    `xorm:"VARCHAR(64)"`
-	CustomerName  string    `xorm:"VARCHAR(50)"`
-	Name          string    `xorm:"VARCHAR(50)"`
+	CustomerName  string    `xorm:"VARCHAR(200)"`
+	Name          string    `xorm:"VARCHAR(200)"`
 	Phone         string    `xorm:"VARCHAR(100)"`
 	Sex           int       `xorm:"SMALLINT(6)"`
 	Headimgurl    string    `xorm:"TEXT"`

models/model/ta_customer_account.go

@@ -7,7 +7,7 @@ import (
 type TaCustomerAccount struct {
 	AccountId    string    `xorm:"not null pk VARCHAR(64)"`
 	CustomerId   string    `xorm:"VARCHAR(64)"`
-	CustomerName string    `xorm:"VARCHAR(50)"`
+	CustomerName string    `xorm:"VARCHAR(200)"`
 	Amount       string    `xorm:"DECIMAL(8,2)"`
 	Points       string    `xorm:"DECIMAL(8,2)"`
 	Status       int       `xorm:"SMALLINT(6)"`

models/model/ta_customer_course.go

@@ -11,15 +11,10 @@ type TaCustomerCourse struct {
 	OrgId            string    `xorm:"VARCHAR(64)"`
 	CaseId           string    `xorm:"VARCHAR(64)"`
 	CourseName       string    `xorm:"VARCHAR(50)"`
-	LocationId       string    `xorm:"VARCHAR(64)"`
-	LocationName     string    `xorm:"VARCHAR(64)"`
-	Price            float32   `xorm:"FLOAT(8,2)"`
+	Price            string    `xorm:"DECIMAL(8,2)"`
 	CourseNum        int       `xorm:"INT(11)"`
 	JoinNum          int       `xorm:"INT(11)"`
 	CreateDate       time.Time `xorm:"DATETIME"`
-	Address          string    `xorm:"VARCHAR(200)"`
-	CourseDate       string    `xorm:"VARCHAR(200)"`
-	Remark           string    `xorm:"TEXT"`
 	CourseObtaimType string    `xorm:"VARCHAR(32)"`
 	SourceId         string    `xorm:"VARCHAR(64)"`
 	Status           int       `xorm:"SMALLINT(6)"`

models/model/ta_goods_orders.go

@@ -20,7 +20,7 @@ type TaGoodsOrders struct {
             coupon 优惠券抵用') VARCHAR(20)"`
 	UserType     string `xorm:"VARCHAR(20)"`
 	UserId       string `xorm:"VARCHAR(64)"`
-	UserName     string `xorm:"VARCHAR(50)"`
+	UserName     string `xorm:"VARCHAR(200)"`
 	OrdersNum    int    `xorm:"INT(11)"`
 	Remark       string `xorm:"TEXT"`
 	IsPay        int    `xorm:"TINYINT(1)"`

service/course/course.go

@@ -4,7 +4,9 @@ import (
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/cases"
 	"spaceofcheng/services/models/course"
+	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/models/system"
 	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
 	"strings"
@@ -17,6 +19,8 @@ type CourseServ struct {
 	ctx     *utils.Context
 	dao     *course.CourseDAO
 	casedao *cases.CaseDAO
+	custDAO *customer.CustomerDAO
+	userDAO *system.UserDAO
 }
 
 // NewCourseServ 初始化
@@ -25,6 +29,8 @@ func NewCourseServ(ctx *utils.Context) *CourseServ {
 		ctx:     ctx,
 		dao:     course.NewCourseDAO(ctx),
 		casedao: cases.NewCaseDAO(ctx),
+		custDAO: customer.NewCustomerDAO(ctx),
+		userDAO: system.NewUserDAO(ctx),
 	}
 }
 
@@ -110,7 +116,7 @@ func (s *CourseServ) SaveCourse(course model.TaCourse, tagids string) (*model.Ta
 	if course.CaseId == "" {
 		return nil, utils.LogError("课程案场不允许为空！")
 	}
-	if course.Price == 0 {
+	if course.Price == "" || course.Price == "0" {
 		return nil, utils.LogError("课程价格不允许为0！")
 	}
 	if course.MinNum == 0 {

service/course/order.go

@@ -1,12 +1,293 @@
 package course
 
 import (
+	"errors"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/course"
 	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"time"
+
+	"github.com/yl10/kit/guid"
 )
 
-func (s *CourseServ) Order(
-	couse *model.TaCourseOrders,
+// Orders 下单
+func (s *CourseServ) Orders(
+	couseOrder *model.TaCourseOrders,
 	coupons []model.TaCourseOrdersCoupon,
 ) error {
+	org := s.ctx.Get("org").(model.SysOrg)
+	cust := s.ctx.Get("customer").(model.TaCustomer)
+
+	// 校验人员
+	if cust.CustomerId != couseOrder.CustomerId {
+		return errors.New("下单人非当前人员")
+	}
+	if cust.UserId != "" {
+		// 内部人员
+		// 如果是内部人员购买或者兑换课程, 卡券或者城币就从内部人员自己的账户走
+		couseOrder.PayType = models.CONSUME_INNER
+	} else {
+		// 默认是卡券支付
+		couseOrder.PayType = models.CONSUME_COUPON
+	}
+
+	// 校验案场
+	caseID := couseOrder.CaseId
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(caseID); err != nil {
+		return err
+	}
+
+	// 校验课程
+	course, err := s.validCourse(couseOrder)
+	if err != nil {
+		return err
+	}
+	if course.CourseDetail == nil || len(course.CourseDetail) > 0 {
+		return errors.New("定单课程尚未排课, 不能下单")
+	}
+
+	if coupons != nil && len(coupons) > 0 {
+		// 校验卡券, 同时进行卡券的注销或者已使用的更新操作
+		// TODO
+	}
+
+	// 课程价格, 即为订单价格
+	couseOrder.Price = course.Price
+	couseOrder.ActualAmount = course.Price
+	couseOrder.CourseName = course.CourseName
+	couseOrder.CourseNum = course.CourseNum
+	couseOrder.OrgId = org.OrgId
+	if cust.Name != "" {
+		couseOrder.CustomerName = cust.Name
+	} else {
+		couseOrder.CustomerName = cust.CustomerName
+	}
+
+	// 校验金额
+	if err := s.validBillCharges(couseOrder, coupons); err != nil {
+		return err
+	}
+
+	// 入库
+	if err := s.dao.SaveCourseOrder(couseOrder); err != nil {
+		utils.LogError("课程下单失败: " + err.Error())
+		return errors.New("下单失败, 请重试")
+	}
+
+	// 实际支付
+	actualAmount, _ := strconv.ParseFloat(couseOrder.ActualAmount, 64)
+
+	// 用户账户
+	if actualAmount > 0 {
+		couseOrder.PayType = models.CONSUME_COINCHG
+		account, err := s.custDAO.GetAccountByCust(cust.CustomerId)
+		if err != nil {
+			utils.LogError("查询用户账户信息出错: " + err.Error())
+			return errors.New("查询用户账户信息出错")
+		}
+		accMoney, _ := strconv.ParseFloat(account.Amount, 64)
+
+		if actualAmount > accMoney {
+			return errors.New("账户余额不足")
+		}
+	}
+
+	return nil
+}
+
+// validCourse 校验课程
+func (s *CourseServ) validCourse(order *model.TaCourseOrders) (*course.CourseDetail, error) {
+	if order.CourseId == "" {
+		return nil, errors.New("没有获取到下单课程")
+	}
+
+	custCourse, err := s.dao.GetCourseOfCustomer(order.CustomerId, order.CourseId)
+	if err != nil {
+		utils.LogError("校验用户课程失败: " + err.Error())
+		return nil, errors.New("校验用户课程失败")
+	}
+
+	if custCourse != nil && custCourse.CustomerCourseId != "" {
+		if custCourse.Status != models.STATUS_DEL {
+			return nil, errors.New("用户已经拥有该课程, 不需要再次下单")
+		}
+	}
+
+	// 课程
+	course, err := s.dao.GetCourseInfo(order.CourseId)
+	if err != nil {
+		utils.LogError("获取课程信息失败: " + err.Error())
+		return nil, errors.New("获取课程信息失败")
+	}
+
+	if course.Status != models.STATUS_NORMAL {
+		return nil, errors.New("课程状态不正确, 不能购买或者兑换")
+	}
+
+	return course, nil
+}
+
+// validCustomer 校验客户
+func (s *CourseServ) validCustomer(custID string) (*model.TaCustomer, error) {
+	if custID == "" {
+		return nil, errors.New("没有获取到下单人员")
+	}
+
+	cust, err := s.custDAO.GetCustomerByID(custID)
+	if err != nil {
+		utils.LogError("查询下单人出错: " + err.Error())
+		return nil, errors.New("验证下单人出错")
+	}
+
+	if cust.Status != models.STATUS_NORMAL {
+		return nil, errors.New("下单人状态不正确, 不能下单")
+	}
+
+	return cust, nil
+}
+
+// validBillCharges 校验各种金额, 数量等
+func (s *CourseServ) validBillCharges(
+	couseOrder *model.TaCourseOrders,
+	coupons []model.TaCourseOrdersCoupon,
+) error {
+	orderCost, _ := strconv.ParseFloat(couseOrder.Price, 64)
+	// 算法开始, 实际支付 == 订单金额
+	actualAmount := orderCost
+	// 优惠金额是 0
+	couponAmount := float64(0.0)
+
+	couseOrder.ActualAmount = strconv.FormatFloat(actualAmount, 'f', -1, 64)
+	couseOrder.CouponAmount = strconv.FormatFloat(couponAmount, 'f', -1, 64)
+
+	// 如果不是使用的卡券
+	if coupons == nil || len(coupons) == 0 {
+		return nil
+	}
+
+	// 目前的业务是, 购买课程只能使用一张卡券
+	// 这里使用的是数组, 相当于做一个拓展
+	for _, coupon := range coupons {
+		// TODO 从卡券字典中获取价格
+		// 目前是前端传过来的
+		dedCharge, err := strconv.ParseFloat(coupon.UsedAmount, 64)
+		if err != nil {
+			utils.LogError("获取卡券抵用金额失败: " + err.Error())
+			return errors.New("获取卡券抵用金额错误")
+		}
+
+		if dedCharge < 0 {
+			return errors.New("卡券抵用金额不能为负值")
+		}
+
+		couponAmount += dedCharge
+	}
+
+	// 如果优惠券金额 > 订单金额
+	if couponAmount > orderCost {
+		couponAmount = orderCost
+		actualAmount = float64(0)
+	} else {
+		actualAmount = orderCost - couponAmount
+	}
+
+	couseOrder.ActualAmount = strconv.FormatFloat(actualAmount, 'f', -1, 64)
+	couseOrder.CouponAmount = strconv.FormatFloat(couponAmount, 'f', -1, 64)
+	return nil
+}
+
+// saveCustomerPayRec 保存账户消费流水
+func (s *CourseServ) saveCustomerPayRec(account *model.TaCustomerAccount, info *model.TaCourseOrders) error {
+	accBill := new(model.TaAccountChange)
+	accBill.AccountId = account.AccountId
+	accBill.Amount = info.ActualAmount
+	accBill.CaseId = info.CaseId
+	accBill.ChangeSource = models.ACCSOURCE_COURSE_ORDERS
+	accBill.ChangeType = models.CONSUME_COINCHG
+	accBill.CustomerId = info.CustomerId
+	accBill.CustomerName = info.CustomerName
+	accBill.FloatType = models.ACCOUNT_SPENT
+	accBill.SourceId = info.OrdersId
+	accBill.SourceName = ""
+
+	return s.custDAO.InsertAccountRecords(accBill)
+}
+
+// SaveOrder 保存订单明细
+func (s *CourseServ) SaveOrder(order *model.TaCourseOrders, coupons []model.TaCourseOrdersCoupon, course *course.CourseDetail) error {
+	// 订单信息
+	if err := s.dao.SaveCourseOrder(order); err != nil {
+		utils.LogError("课程下单失败: " + err.Error())
+		return errors.New("下单失败, 请重试")
+	}
+
+	// 默认城币购买
+	courseObtaimType := models.COURSE_GETBY_COINCHG
+	srcID := ""
+	if coupons != nil && len(coupons) > 0 {
+		for _, c := range coupons {
+			if c.CouponType == models.COURSE_COUPON_CARD {
+				courseObtaimType = models.COURSE_GETBY_CARD
+			} else if c.CouponType == models.COURSE_COUPON_COUPON {
+				courseObtaimType = models.COURSE_GETBY_COUPON
+			}
+
+			srcID = c.CouponId
+		}
+	}
+
+	// 我的课程信息
+	custCourse := model.TaCustomerCourse{
+		CourseId:         order.CourseId,
+		CustomerId:       order.CustomerId,
+		OrgId:            order.OrgId,
+		CaseId:           order.CaseId,
+		CourseName:       course.CourseName,
+		Price:            course.Price,
+		CourseNum:        course.CourseNum,
+		JoinNum:          0,
+		CreateDate:       time.Now().Local(),
+		CourseObtaimType: courseObtaimType,
+		SourceId:         srcID,
+		IsDone:           models.BOOL_FALSE,
+	}
+
+	details := make([]model.TaCourseOrdersDetail, 0)
+	custCourseDetails := make([]model.TaCustomerCourseDetail, 0)
+
+	for _, subCourse := range course.CourseDetail {
+		d1 := model.TaCourseOrdersDetail{
+			OrdersDetailId: guid.NewGUIDString(),
+			OrdersId:       order.OrdersId,
+			CourseId:       course.CourseId,
+			CourseDetailId: subCourse.DetailId,
+			BeginDate:      subCourse.BeginDate,
+			EndDate:        subCourse.EndDate,
+		}
+		details = append(details, d1)
+
+		d2 := model.TaCustomerCourseDetail{
+			CourseId:     course.CourseId,
+			DetailId:     subCourse.DetailId,
+			StartDate:    subCourse.BeginDate,
+			EndDate:      subCourse.EndDate,
+			VerifyStatus: models.VERIFY_USEABLE,
+			CaseId:       order.CaseId,
+		}
+		custCourseDetails = append(custCourseDetails, d2)
+	}
+
+	if err := s.dao.SaveCourseOfCustomer(&custCourse, custCourseDetails); err != nil {
+		utils.LogError("插入我的课程失败: " + err.Error())
+		return errors.New("写入我的课程失败")
+	}
+
+	if err := s.dao.SaveCourseOrderDetail(details); err != nil {
+		utils.LogError("插入课程订单详情: " + err.Error())
+		return errors.New("写入课程订单详情失败")
+	}
+
 	return nil
 }

service/goods/orders.go

@@ -2,6 +2,7 @@ package goods
 
 import (
 	"errors"
+	"math"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/goods"
 	"spaceofcheng/services/models/model"
@@ -36,6 +37,16 @@ func (s *GoodsServ) Orders(
 		return err
 	}
 
+	// 内部人员, 可以直接购买
+	if info.PayType == models.CONSUME_INNER {
+
+		// TODO
+		// 通知后端有新订单 - websocket
+		// utils.SendMessage()
+
+		return nil
+	}
+
 	account, err := s.custDAO.GetAccountByCust(info.UserId)
 	if err != nil {
 		utils.LogError("查询用户账户信息出错: " + err.Error())
@@ -44,10 +55,12 @@ func (s *GoodsServ) Orders(
 
 	// 如果是使用优惠券
 	if coupons != nil && len(coupons) > 0 {
+		info.PayType = models.CONSUME_COUPON
 		// TODO
 		// 校验优惠券相关
 	} else {
 		// 如果是使用城币
+		info.PayType = models.CONSUME_COINCHG
 		accMoney, _ := strconv.ParseFloat(account.Amount, 64)
 		payMoney, _ := strconv.ParseFloat(info.ActualAmount, 64)
 
@@ -68,7 +81,7 @@ func (s *GoodsServ) Orders(
 	}
 
 	// 如果是城币, 则插入用户账户消费记录
-	if info.PayType == models.CONSUME_MONEYCHG {
+	if info.PayType == models.CONSUME_COINCHG {
 		if err := s.saveCustomerPayRec(account, info); err != nil {
 			return err
 		}
@@ -87,8 +100,8 @@ func (s *GoodsServ) saveCustomerPayRec(account *model.TaCustomerAccount, info *m
 	accBill.AccountId = account.AccountId
 	accBill.Amount = info.ActualAmount
 	accBill.CaseId = info.CaseId
-	accBill.ChangeSource = models.ACCSOURCE_ORDERS
-	accBill.ChangeType = models.CONSUME_MONEYCHG
+	accBill.ChangeSource = models.ACCSOURCE_GOODS_ORDERS
+	accBill.ChangeType = models.CONSUME_COINCHG
 	accBill.CustomerId = info.UserId
 	accBill.CustomerName = info.UserName
 	accBill.FloatType = models.ACCOUNT_SPENT
@@ -154,6 +167,9 @@ func (s *GoodsServ) validOrdersInfo(info *model.TaGoodsOrders) error {
 
 	// 如果是管理人员
 	if cust.UserId != "" {
+		// 内部人员
+		info.PayType = models.CONSUME_INNER
+
 		// 查找用户类型
 		userWithTypes, err := s.userDAO.GetUserWithTypeByID(cust.UserId)
 		if err != nil {
@@ -205,7 +221,7 @@ func (s *GoodsServ) validBillCharges(info *model.TaGoodsOrders, details []model.
 
 	caseID := info.CaseId
 
-	orgAmount := float64(0.0)
+	goodsAmount := float64(0.0)
 	for _, item := range details {
 		goods, err := s.dao.GetGoodsWithPriceByID(item.GoodsId, item.SpecId, caseID)
 		if err != nil {
@@ -221,13 +237,13 @@ func (s *GoodsServ) validBillCharges(info *model.TaGoodsOrders, details []model.
 		// 商品暂时无库存
 
 		price, _ := strconv.ParseFloat(item.Price, 64)
-		orgAmount += price * float64(item.Number)
+		goodsAmount += price * float64(item.Number)
 	}
 
 	// 校验总金额
 	orderAmount, _ := strconv.ParseFloat(info.Amount, 64)
 
-	if orgAmount != orderAmount {
+	if math.Abs(orderAmount-goodsAmount) > 0.00001 {
 		return errors.New("商品金额计算错误")
 	}
 

utils/sms.go

@@ -47,17 +47,15 @@ func SendSMS(smsType, tel string, messages ...string) {
 		}
 
 		// 接口内容
-		paramsTpl := `{"code": "%s", "tel": "%s", "params": [%s]}`
+		messageTpl := defaultSMS.setting.String(smsType + "::message")
 		// 发送消息
 		message := strings.Join(messages, `","`)
 		if message != "" {
 			message = fmt.Sprintf(`"%s"`, message)
 		}
 
-		code := defaultSMS.setting.String(smsType + "::code")
-
 		// 接口 data
-		data := bytes.NewBuffer([]byte(fmt.Sprintf(paramsTpl, code, tel, message)))
+		data := bytes.NewBuffer([]byte(fmt.Sprintf(messageTpl, tel, message)))
 
 		// 暂时只支持 post 发送数据
 		if defaultSMS.method == http.MethodPost {