增加案场营业及下单次数校验

controllers/cases/case.go

@@ -1,9 +1,12 @@
 package cases
 
 import (
+	"errors"
+	"jcjy/demo/models"
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/cases"
+	"spaceofcheng/services/utils"
 )
 
 // CaseController 信息
@@ -78,3 +81,25 @@ func (c *CaseController) GetOrgCases() {
 
 	c.ResponseJSON(res)
 }
+
+// OpenCaseCoffee 开启
+func (c *CaseController) OpenCaseCoffee() {
+	caseid := c.GetString(":caseid")
+	err := c.dao.UpdateCaseConf(caseid, cases.CONFTYPE_COFFEE, models.STATUS_NORMAL)
+	if err != nil {
+		utils.LogError("开启失败: " + err.Error())
+		c.ResponseError(errors.New("操作失败！"))
+	}
+	c.ResponseJSON("操作成功！")
+}
+
+// CloseCaseCoffee 关闭
+func (c *CaseController) CloseCaseCoffee() {
+	caseid := c.GetString(":caseid")
+	err := c.dao.UpdateCaseConf(caseid, cases.CONFTYPE_COFFEE, models.STATUS_READY)
+	if err != nil {
+		utils.LogError("关闭失败: " + err.Error())
+		c.ResponseError(errors.New("操作失败！"))
+	}
+	c.ResponseJSON("操作成功！")
+}

models/cases/conf.go

@@ -9,7 +9,6 @@ import (
 // GetConfByCase 获取配置信息
 func (m *CaseDAO) GetConfByCase(caseid, conftype string) (*model.SysCaseConf, error) {
 	var conf = new(model.SysCaseConf)
-	conf.Status = models.STATUS_NORMAL
 	has, err := m.db.Where("case_id=?", caseid).And("conf_type=?", conftype).Get(&conf)
 	if err != nil {
 		return nil, err
@@ -23,6 +22,7 @@ func (m *CaseDAO) GetConfByCase(caseid, conftype string) (*model.SysCaseConf, er
 // SaveCaseConf 保存案场配置信息
 func (m *CaseDAO) SaveCaseConf(conf model.SysCaseConf) (*model.SysCaseConf, error) {
 	conf.ConfId = utils.GetGUID()
+	conf.Status = models.STATUS_READY
 	_, err := m.db.Insert(conf)
 	return &conf, err
 }
@@ -32,6 +32,6 @@ func (m *CaseDAO) UpdateCaseConf(conf model.SysCaseConf) error {
 	cols := []string{
 		"status",
 	}
-	_, err := m.db.Cols(cols...).Where("conf_id=?", conf.ConfId).Update(conf)
+	_, err := m.db.Cols(cols...).Where("case_id=?", conf.ConfId).And("conf_type=?", conf.ConfType).Update(conf)
 	return err
 }

models/cases/record.go

@@ -18,6 +18,11 @@ type CaseRecord struct {
 	LeftNum             int
 }
 
+const (
+	ISOVER   = 1
+	ISNOOVER = 0
+)
+
 // GetCaseRecord 获取案场月记录
 func (m *CaseDAO) GetCaseRecord(caseids string, page, pageSize int) ([]CaseRecord, error) {
 	var records []CaseRecord
@@ -65,7 +70,7 @@ func (m *CaseDAO) AddRecord(record model.SysCaseRecord) (*model.SysCaseRecord, e
 	record.CreateDate = time.Now()
 	record.RecordId = utils.GetGUID()
 	record.Status = models.STATUS_NORMAL
-	record.IsOver = 1
+	record.IsOver = ISOVER
 	_, err := m.db.Insert(record)
 	return &record, err
 }
@@ -96,22 +101,46 @@ func (m *CaseDAO) GetRecordByID(recordid string) (*CaseRecord, error) {
 	}
 	if len(records) > 0 {
 		var record = records[0]
-		orders := new(model.TaGoodsOrders)
-		total, err := m.db.Where("case_id=?", record.CaseId).And("status=?", models.STATUS_NORMAL).And("user_type=?", goods.USERTPE_SALES).And("date_format(create_date,'%Y-%m')=?", record.Month).Sums(orders, "orders_num")
-		if err != nil {
-			return nil, err
-		}
-		record.ActrualNum = int(total[0])
-		var overnum int
-		var leftnum int
-		if record.ActrualNum > record.Num {
-			overnum = record.ActrualNum - record.Num
-		} else {
-			leftnum = record.Num - record.ActrualNum
-		}
-		record.OverNum = overnum
-		record.LeftNum = leftnum
-		return &record, err
+		info, err := m.GetRecordWithNum(record)
+		return info, err
+	}
+
+	return nil, nil
+}
+
+// GetRecordWithNum 获取月记录对应信息
+func (m *CaseDAO) GetRecordWithNum(record CaseRecord) (*CaseRecord, error) {
+	orders := new(model.TaGoodsOrders)
+	total, err := m.db.Where("case_id=?", record.CaseId).And("status=?", models.STATUS_NORMAL).And("user_type=?", goods.USERTPE_SALES).And("date_format(create_date,'%Y-%m')=?", record.Month).Sums(orders, "orders_num")
+	if err != nil {
+		return nil, err
+	}
+	record.ActrualNum = int(total[0])
+	var overnum int
+	var leftnum int
+	if record.ActrualNum > record.Num {
+		overnum = record.ActrualNum - record.Num
+	} else {
+		leftnum = record.Num - record.ActrualNum
+	}
+	record.OverNum = overnum
+	record.LeftNum = leftnum
+	return &record, err
+}
+
+// GetRecordByCase 获取案场当月记录信息
+func (m *CaseDAO) GetRecordByCase(caseid string) (*CaseRecord, error) {
+	var records []CaseRecord
+	sql := `select * from sys_case_record where month = date_format(NOW(),'%Y-%m') and case_id='` + caseid + `'`
+
+	err := m.db.Sql(sql).Find(&records)
+	if err != nil {
+		return nil, err
+	}
+	if len(records) > 0 {
+		var record = records[0]
+		info, err := m.GetRecordWithNum(record)
+		return info, err
 	}
 
 	return nil, nil

routers/common.go

@@ -121,6 +121,8 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/case/info", &cases.CaseController{}, "post:SaveCase"),
 		beego.NSRouter("/case/info", &cases.CaseController{}, "put:SaveCase"),
 		beego.NSRouter("/case/info/:id", &cases.CaseController{}, "delete:DelCase"),
+		beego.NSRouter("/case/open/:caseid", &cases.CaseController{}, "put:OpenCaseCoffee"),
+		beego.NSRouter("/case/close/:caseid", &cases.CaseController{}, "put:CloseCaseCoffee"),
 
 		// casekey 案场钥匙
 		beego.NSRouter("/case/key", &cases.CaseController{}, "get:GetKeyList"),

service/cases/cases.go

@@ -158,3 +158,14 @@ func (s *CaseServ) GetCaseConf(caseid, conftype string) (*model.SysCaseConf, err
 	}
 	return conf, nil
 }
+
+// UpdateCaseConf 修改案场配置信息
+func (s *CaseServ) UpdateCaseConf(caseid, conftype string, status int) error {
+	var conf = model.SysCaseConf{
+		CaseId:   caseid,
+		ConfType: conftype,
+		Status:   status,
+	}
+	err := s.dao.UpdateCaseConf(conf)
+	return err
+}

service/goods/orders.go

@@ -4,8 +4,10 @@ import (
 	"errors"
 	"math"
 	"spaceofcheng/services/models"
+	casemodel "spaceofcheng/services/models/cases"
 	"spaceofcheng/services/models/goods"
 	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/cases"
 	"spaceofcheng/services/utils"
 	"strconv"
 	"time"
@@ -22,6 +24,11 @@ func (s *GoodsServ) Orders(
 		return err
 	}
 
+	// 校验案场信息
+	if err := s.validOrdersCase(info); err != nil {
+		return err
+	}
+
 	// 校验各种金额
 	if err := s.validBillCharges(info, details); err != nil {
 		return err
@@ -310,3 +317,27 @@ func (s *GoodsServ) GetOrdersByRecord(recordid string) ([]goods.OrdersWithGoods,
 	}
 	return orders, nil
 }
+
+// validOrdersCase 校验案场信息
+func (s *GoodsServ) validOrdersCase(info *model.TaGoodsOrders) error {
+	conf, err := s.caseDAO.GetConfByCase(info.CaseId, cases.CONFTYPE_COFFEE)
+	if err != nil {
+		utils.LogError("获取配置信息失败： " + err.Error())
+		return errors.New("获取配置信息失败")
+	}
+
+	if conf.Status != models.STATUS_NORMAL {
+		return errors.New("当前案场不为营业！不允许下单！")
+	}
+
+	// 获取当月记录
+	record, err := s.caseDAO.GetRecordByCase(info.CaseId)
+	if err != nil {
+		utils.LogError("获取月记录失败: " + err.Error())
+		return errors.New("获取月记录失败")
+	}
+	if record != nil && record.IsOver == casemodel.ISNOOVER && record.LeftNum < info.OrdersNum {
+		return errors.New("超出案场限制的本月下单次数！不允许下单！")
+	}
+	return nil
+}