feats

conf/db.conf

@@ -15,7 +15,7 @@ db_port      = 3306
 username     = spaceofcheng
 
 ; 密码
-password     = c;a|vK)Xv/=L@c[6Fx,v[ITD5;WpR}+Y
+password     = spaceofcheng
 
 ; 数据库名或者schema
 database     = spaceofcheng

conf/log.conf

@@ -1,4 +1,4 @@
 [common]
-filename="E:\\GoProjects\\src\\spaceofcheng\\services\\log\\common.log"
+filename="E:\\GoProject\\src\\spaceofcheng\\services\\log\\common.log"
 # log level "emergency", "alert", "critical", "error", "warning", "notice", "info", "debug"
 level="debug"

controllers/customer/customer.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"net/http"
 	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/customer"
 	"spaceofcheng/services/utils"
@@ -72,6 +73,13 @@ func (c *CustomerController) GetCustWXByID() {
 		c.ResponseError(errors.New("获取用户信息失败, 请重试"))
 	}
 
+	if cust.MapUser != "" && cust.BelongCaseStatus != models.STATUS_NORMAL {
+		c.ResponseError(
+			errors.New("案场状态异常！"),
+			http.StatusMethodNotAllowed,
+		)
+	}
+
 	c.ResponseJSON(map[string]interface{}{
 		"customer": cust,
 	})

controllers/goods/order.go

@@ -4,7 +4,7 @@ import (
 	"encoding/json"
 	"errors"
 	"net/http"
-	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/goods"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 	"strconv"
@@ -183,7 +183,6 @@ func (c *GoodsController) GetOrdersByRecord() {
 				order.UserName,
 				strconv.Itoa(good.Number),
 				good.Price,
-				strconv.Itoa(good.Number),
 			})
 
 			price, err := strconv.ParseFloat(good.Price, 64)
@@ -199,9 +198,17 @@ func (c *GoodsController) GetOrdersByRecord() {
 
 			excel.SetCell(row, strconv.FormatFloat(charge, 'f', -1, 64))
 
-			status := "未完成"
-			if order.Status == models.STATUS_NORMAL {
-				status = "已完成"
+			status := "已完成"
+			switch order.MakeStatus {
+			case goods.MAKESTATUS_NOTSTARTED:
+				status = "制作中"
+				break
+			case goods.MAKESTATUS_DOING:
+				status = "制作中"
+				break
+			case goods.MAKESTATUS_CANCEL:
+				status = "已取消"
+				break
 			}
 			excel.SetCell(row, status)
 			excel.SetCell(row, order.CreateDate.Format("2006-01-02 15:04:05"))
@@ -262,3 +269,13 @@ func (c *GoodsController) CancelMake() {
 	}
 	c.ResponseJSON("操作成功！")
 }
+
+// UpdateOrdersIntimidate 更新订单打单状态
+func (c *GoodsController) UpdateOrdersIntimidate() {
+	id := c.GetString(":id")
+	err := c.serv.UpdateOrdersIntimidate(id)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("操作成功！")
+}

controllers/statistics/goods.go

@@ -132,14 +132,13 @@ func (c *StatisticsController) GetGoodsOrdersStatisticsExcel() {
 		"订单状态",
 		"商品",
 		"数量",
-		"金额",
+		"单价",
 		"桌位",
 		"下单人",
 		"电话",
 	})
 
 	for _, item := range list {
-		row := excel.InsertRow()
 		usertype := ""
 		switch item.UserType {
 		case "customer":
@@ -160,10 +159,16 @@ func (c *StatisticsController) GetGoodsOrdersStatisticsExcel() {
 			orderStatus = "已取消"
 		}
 		for _, detail := range item.Details {
+			row := excel.InsertRow()
 			name := detail.GoodsName
 			if detail.SpecName != "" {
 				name = name + "(" + detail.SpecName + ")"
 			}
+			// price, err := strconv.ParseFloat(detail.Price, 64)
+			// if err != nil {
+			// 	c.ResponseError(errors.New("金额类型不正确！"))
+			// }
+			// amount := price * float64(detail.Number)
 			excel.SetCell(row, []string{
 				item.OrdersNo,
 				item.CaseName,
@@ -172,6 +177,7 @@ func (c *StatisticsController) GetGoodsOrdersStatisticsExcel() {
 				orderStatus,
 				name,
 				strconv.Itoa(detail.Number),
+				detail.Price,
 				item.AreaName + item.TableNo,
 				item.CustomerName,
 				item.Phone,

log/common.log

@@ -0,0 +1,118 @@
+<<<<<<< HEAD
+=======
+2018/09/21 00:04:05 [E] 用户没有设置默认案场
+2018/09/21 00:04:05 [E] 用户没有设置默认案场
+2018/09/21 00:04:05 [E] 用户没有设置默认案场
+2018/09/21 00:04:14 [E] 用户没有设置默认案场
+2018/09/21 00:04:17 [E] 用户没有设置默认案场
+2018/09/21 00:04:19 [E] 用户没有设置默认案场
+2018/09/21 00:05:17 [E] 用户没有设置默认案场
+2018/09/21 00:05:26 [E] 用户没有设置默认案场
+2018/09/21 00:05:26 [E] 用户没有设置默认案场
+2018/09/21 00:30:14 [E] 用户没有设置默认案场
+2018/09/21 00:30:14 [E] 用户没有设置默认案场
+2018/09/21 00:30:37 [E] 用户没有设置默认案场
+2018/09/21 00:30:45 [E] 用户没有设置默认案场
+2018/09/21 00:30:46 [E] 用户没有设置默认案场
+2018/09/21 00:32:11 [E] 用户没有设置默认案场
+2018/09/21 00:36:16 [E] 用户没有设置默认案场
+2018/09/21 00:36:16 [E] 用户没有设置默认案场
+2018/09/21 00:36:16 [E] 用户没有设置默认案场
+2018/09/21 00:36:39 [E] 用户没有设置默认案场
+2018/09/21 00:36:45 [E] 用户没有设置默认案场
+2018/09/21 00:36:49 [E] 用户没有设置默认案场
+2018/09/21 00:36:58 [E] 用户没有设置默认案场
+2018/09/21 00:37:04 [E] 用户没有设置默认案场
+2018/09/21 00:37:36 [E] 用户没有设置默认案场
+2018/09/21 00:37:36 [E] 用户没有设置默认案场
+2018/09/21 00:37:38 [E] 用户没有设置默认案场
+2018/09/21 00:37:40 [E] 用户没有设置默认案场
+2018/09/21 00:37:43 [E] 用户没有设置默认案场
+2018/09/21 00:37:53 [E] 用户没有设置默认案场
+2018/09/21 00:38:05 [E] 用户没有设置默认案场
+2018/09/21 00:38:08 [E] 用户没有设置默认案场
+2018/09/21 00:38:12 [E] 用户没有设置默认案场
+2018/09/21 00:38:15 [E] 用户没有设置默认案场
+2018/09/21 00:38:49 [E] 用户没有设置默认案场
+2018/09/21 00:38:51 [E] 用户没有设置默认案场
+2018/09/21 00:38:53 [E] 用户没有设置默认案场
+2018/09/21 00:38:53 [E] 用户没有设置默认案场
+2018/09/21 00:38:55 [E] 用户没有设置默认案场
+2018/09/21 00:38:56 [E] 用户没有设置默认案场
+2018/09/21 00:38:59 [E] 用户没有设置默认案场
+2018/09/21 00:39:02 [E] 用户没有设置默认案场
+2018/09/21 00:39:12 [E] 用户没有设置默认案场
+2018/09/21 00:39:24 [E] 用户没有设置默认案场
+2018/09/21 00:45:56 [E] 用户没有设置默认案场
+2018/09/21 00:45:56 [E] 用户没有设置默认案场
+2018/09/21 00:46:37 [E] 用户没有设置默认案场
+2018/09/21 00:46:37 [E] 用户没有设置默认案场
+2018/09/21 00:47:06 [E] 用户没有设置默认案场
+2018/09/21 00:47:06 [E] 用户没有设置默认案场
+2018/09/21 00:47:47 [E] 用户没有设置默认案场
+2018/09/21 00:47:47 [E] 用户没有设置默认案场
+2018/09/21 00:48:12 [E] 用户没有设置默认案场
+2018/09/21 00:49:04 [E] 用户没有设置默认案场
+2018/09/21 00:53:33 [E] 用户没有设置默认案场
+2018/09/21 00:53:33 [E] 用户没有设置默认案场
+2018/09/21 00:53:51 [E] 用户没有设置默认案场
+2018/09/21 00:53:52 [E] 用户没有设置默认案场
+2018/09/21 00:53:52 [E] 用户没有设置默认案场
+2018/09/21 00:53:56 [E] 用户没有设置默认案场
+2018/09/21 00:53:58 [E] 用户没有设置默认案场
+2018/09/21 00:54:12 [E] 用户没有设置默认案场
+2018/09/21 00:54:12 [E] 用户没有设置默认案场
+2018/09/21 01:01:20 [E] 用户没有设置默认案场
+2018/09/21 01:03:52 [E] 用户没有设置默认案场
+2018/09/21 01:03:52 [E] 用户没有设置默认案场
+2018/09/21 01:04:06 [E] 用户没有设置默认案场
+2018/09/21 01:42:44 [E] 用户没有设置默认案场
+2018/09/21 01:44:00 [E] 用户没有设置默认案场
+2018/09/21 01:44:00 [E] 用户没有设置默认案场
+2018/09/21 01:44:05 [E] 用户没有设置默认案场
+2018/09/21 01:44:08 [E] 用户没有设置默认案场
+2018/09/21 01:44:08 [E] 用户没有设置默认案场
+2018/09/21 01:44:10 [E] 用户没有设置默认案场
+2018/09/21 01:44:19 [E] 用户没有设置默认案场
+2018/09/21 01:45:42 [E] 用户没有设置默认案场
+2018/09/21 01:45:45 [E] 用户没有设置默认案场
+2018/09/21 01:47:37 [E] 用户没有设置默认案场
+2018/09/21 01:47:37 [E] 用户没有设置默认案场
+2018/09/21 02:10:32 [E] 用户没有设置默认案场
+2018/09/21 02:10:32 [E] 用户没有设置默认案场
+2018/09/21 02:10:36 [E] 用户没有设置默认案场
+2018/09/21 02:10:37 [E] 用户没有设置默认案场
+2018/09/21 02:10:37 [E] 用户没有设置默认案场
+2018/09/21 02:10:38 [E] 用户没有设置默认案场
+2018/09/21 02:10:41 [E] 用户没有设置默认案场
+2018/09/21 02:10:53 [E] 用户没有设置默认案场
+2018/09/21 02:11:07 [E] 用户没有设置默认案场
+2018/09/21 02:11:08 [E] 用户没有设置默认案场
+2018/09/21 02:11:12 [E] 用户没有设置默认案场
+2018/09/21 02:11:12 [E] 用户没有设置默认案场
+2018/09/21 02:11:29 [E] 用户没有设置默认案场
+2018/09/21 02:11:31 [E] 用户没有设置默认案场
+2018/09/21 02:11:43 [E] 用户没有设置默认案场
+2018/09/21 02:11:53 [E] 用户没有设置默认案场
+2018/09/21 02:11:57 [E] 用户没有设置默认案场
+2018/09/21 02:11:57 [E] 用户没有设置默认案场
+2018/09/21 02:12:12 [E] 用户没有设置默认案场
+2018/09/21 02:12:39 [E] 用户没有设置默认案场
+2018/09/21 02:12:40 [E] 用户没有设置默认案场
+2018/09/21 02:12:40 [E] 用户没有设置默认案场
+2018/09/21 02:12:40 [E] 用户没有设置默认案场
+2018/09/21 02:12:43 [E] 用户没有设置默认案场
+2018/09/21 02:12:47 [E] 用户没有设置默认案场
+2018/09/21 02:13:47 [E] 用户没有设置默认案场
+2018/09/21 02:13:47 [E] 用户没有设置默认案场
+2018/09/21 02:14:10 [E] 用户没有设置默认案场
+2018/09/21 02:14:17 [E] 用户没有设置默认案场
+2018/09/21 02:14:19 [E] 用户没有设置默认案场
+2018/09/21 02:14:20 [E] 用户没有设置默认案场
+2018/09/21 02:14:58 [E] 用户没有设置默认案场
+2018/09/21 02:15:01 [E] 用户没有设置默认案场
+2018/09/21 02:15:02 [E] 用户没有设置默认案场
+2018/09/21 02:15:03 [E] 用户没有设置默认案场
+2018/09/21 02:15:03 [E] 用户没有设置默认案场
+2018/09/21 02:15:03 [E] 用户没有设置默认案场
+>>>>>>> 443c1728ef51dbf0d939a5f62ed7e34f0f6708a8

models/cases/cases.go

@@ -59,9 +59,15 @@ func (m *CaseDAO) GetCaseCount(caseids, casename string) (int, error) {
 
 // GetCaseByID 根据ID获取案场信息
 func (m *CaseDAO) GetCaseByID(caseid string) (*model.SysCase, error) {
-	cs := new(model.SysCase)
-	_, err := m.db.Where("status>?", models.STATUS_DEL).And("case_id=?", caseid).Get(cs)
-	return cs, err
+	var cases []model.SysCase
+	err := m.db.Where("status>?", models.STATUS_DEL).And("case_id=?", caseid).Find(&cases)
+	if err != nil {
+		return nil, err
+	}
+	if len(cases) > 0 {
+		return &cases[0], nil
+	}
+	return nil, err
 }
 
 // AddCase 新增案场信息

models/customer/types.go

@@ -12,4 +12,5 @@ type CustWithWX struct {
 	Points              int
 	MapUser             string
 	BelongCaseId        string
+	BelongCaseStatus    int
 }

models/goods/orders.go

@@ -15,6 +15,9 @@ import (
 const (
 	USERTPE_SALES     = "sales"
 	USERTYPE_CUSTOMER = "customer"
+
+	INTIMIDATE_NO  = 0
+	INTIMIDATE_YES = 1
 )
 
 // GetOrdersByCases 获取案场订单列表
@@ -44,6 +47,7 @@ func (m *GoodsDAO) SaveOrders(order *model.TaGoodsOrders) error {
 	order.Status = models.STATUS_NORMAL
 	order.IsPay = models.BOOL_TRUE // 默认已支付
 	order.CouponAmount = "0"
+	order.IsIntimidate = INTIMIDATE_NO
 
 	// 当前订单号的随机方式 = 时间 + 个人ID
 	ordersno := "G-" + time.Now().Local().Format("20060102150405") + "-" + strings.Join(utils.GUIID2IntString(order.UserId), "")
@@ -56,6 +60,20 @@ func (m *GoodsDAO) SaveOrders(order *model.TaGoodsOrders) error {
 	return nil
 }
 
+// UpdateOrdersIntimidate 更新订单已打单
+func (m *GoodsDAO) UpdateOrdersIntimidate(id string) error {
+	var orders = model.TaGoodsOrders{
+		OrdersId:     id,
+		IsIntimidate: INTIMIDATE_YES,
+	}
+	var cols = []string{
+		"spec_name",
+		"case_id",
+	}
+	_, err := m.db.Cols(cols...).Where("orders_id=?", orders.OrdersId).Update(orders)
+	return err
+}
+
 // SaveOrdersDetail 保存订单明细
 func (m *GoodsDAO) SaveOrdersDetail(list []model.TaGoodsOrdersDetail, ordersID string) error {
 	for inx := range list {
@@ -222,7 +240,7 @@ func (m *GoodsDAO) GetCustomerOrders(custID string, page, pageSize int) ([]Order
 	sql := `select a.*, c.case_name from ta_goods_orders a 
 	inner join sys_case c on a.case_id=c.case_id
 	where a.user_id='` + custID +
-		`' and c.status=` + strconv.Itoa(models.STATUS_NORMAL) + ` and a.status=` + strconv.Itoa(models.STATUS_NORMAL)
+		`' and a.status=` + strconv.Itoa(models.STATUS_NORMAL)
 	sql += ` order by a.create_date desc limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
 	err := m.db.Sql(sql).Find(&orderList)
 	if err != nil {
@@ -244,7 +262,7 @@ func (m *GoodsDAO) GetCustomerOrdersCount(custID string) (int, error) {
 	sql := `select a.*, c.case_name from ta_goods_orders a 
 	inner join sys_case c on a.case_id=c.case_id
 	where a.user_id='` + custID +
-		`' and c.status=` + strconv.Itoa(models.STATUS_NORMAL) + ` and a.status=` + strconv.Itoa(models.STATUS_NORMAL)
+		`' and a.status=` + strconv.Itoa(models.STATUS_NORMAL)
 	err := m.db.Sql(sql).Find(&orderList)
 	if err != nil {
 		return 0, err

models/model/ta_goods_orders.go

@@ -27,4 +27,5 @@ type TaGoodsOrders struct {
 	IsPay        int    `xorm:"TINYINT(1)"`
 	ActualAmount string `xorm:"DECIMAL(8,2)"`
 	CouponAmount string `xorm:"DECIMAL(8,2)"`
+	IsIntimidate int    `xorm:"SMALLINT(6)"`
 }

models/statistics/goods.go

@@ -167,8 +167,7 @@ func (m *StatisticsDAO) GetGoodsOrderStatistics(status, usertype, caseids, begin
 		return nil, err
 	}
 	for inx, item := range orders {
-		var details []model.TaGoodsOrdersDetail
-		err := m.db.Where("orders_id=?", item.OrdersId).Find(&details)
+		details, err := m.GetGoodsOrderDetailByOrderId(item.OrdersId)
 		if err != nil {
 			return nil, err
 		}
@@ -177,6 +176,13 @@ func (m *StatisticsDAO) GetGoodsOrderStatistics(status, usertype, caseids, begin
 	return orders, err
 }
 
+// GetGoodsOrderDetailByOrderId 获取商品详情
+func (m *StatisticsDAO) GetGoodsOrderDetailByOrderId(ordersid string) ([]model.TaGoodsOrdersDetail, error) {
+	var details []model.TaGoodsOrdersDetail
+	err := m.db.Where("orders_id=?", ordersid).Find(&details)
+	return details, err
+}
+
 // GetGoodsOrderStatisticsCount 获取商品订单Count
 func (m *StatisticsDAO) GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate string) ([]GoodsOrdersStatistics, error) {
 	var orders []GoodsOrdersStatistics
@@ -213,7 +219,6 @@ func (m *StatisticsDAO) GetGoodsOrderStatisticsCount(status, usertype, caseids,
 	if status != "" {
 		sql = sql + ` and a.make_status='` + status + `'`
 	}
-
 	err := m.db.Sql(sql).Find(&orders)
 	return orders, err
 }

routers/common.go

@@ -247,6 +247,7 @@ func getCommonRoutes() beego.LinkNamespace {
 
 		beego.NSRouter("/order/goods/finish/:id", &goods.GoodsController{}, "put:FinishMake"),
 		beego.NSRouter("/order/goods/cancel/:id", &goods.GoodsController{}, "put:CancelMake"),
+		beego.NSRouter("/order/goods/intimidate/:id", &goods.GoodsController{}, "put:UpdateOrdersIntimidate"),
 
 		// 优惠券
 		beego.NSRouter("/coupon", &coupon.CouponController{}, "get:ListByCase"),

service/coupon/coupon.go

@@ -544,6 +544,15 @@ func (s *CouponServ) ReceiveCoupon(id, saleid, serialcode string) error {
 		return errors.New("log-error-该优惠券已被领取！")
 	}
 
+	// 计算卡券有效期
+	startDate := coupon.StartDate
+	endDate := coupon.EndDate
+	if coupon.ValidDays > 0 {
+		startDate = time.Now().Local()
+		hs := int64(coupon.ValidDays * 24)
+		endDate = time.Now().Local().Add(time.Hour * time.Duration(hs))
+	}
+
 	// 领取
 	var customerCoupon = model.TaCustomerCoupon{
 		CouponId:           coupon.CouponId,
@@ -551,8 +560,8 @@ func (s *CouponServ) ReceiveCoupon(id, saleid, serialcode string) error {
 		CustomerId:         customer.CustomerId,
 		SalesId:            saler.UserId,
 		SalesName:          saler.UserName,
-		StartDate:          coupon.StartDate,
-		EndDate:            coupon.EndDate,
+		StartDate:          startDate,
+		EndDate:            endDate,
 		CaseId:             coupon.CaseId,
 		OrgId:              coupon.OrgId,
 		SerialCode:         serialcode,
@@ -611,13 +620,22 @@ func (s *CouponServ) ChannelReceiveCoupon(id string) error {
 		return errors.New("log-error-您已领取过该优惠券！")
 	}
 
+	// 计算卡券有效期
+	startDate := coupon.StartDate
+	endDate := coupon.EndDate
+	if coupon.ValidDays > 0 {
+		startDate = time.Now().Local()
+		hs := int64(coupon.ValidDays * 24)
+		endDate = time.Now().Local().Add(time.Hour * time.Duration(hs))
+	}
+
 	// 领取
 	var customerCoupon = model.TaCustomerCoupon{
 		CouponId:           coupon.CouponId,
 		CustomerCouponName: coupon.CouponName,
 		CustomerId:         customer.CustomerId,
-		StartDate:          coupon.StartDate,
-		EndDate:            coupon.EndDate,
+		StartDate:          startDate,
+		EndDate:            endDate,
 		CaseId:             coupon.CaseId,
 		OrgId:              coupon.OrgId,
 		ReceivingType:      models.RECEIVEING_TYPE_CHANNEL,

service/course/order.go

@@ -107,7 +107,7 @@ func (s *CourseServ) Orders(
 		var isdy = false
 		if coupon.IsAll == 1 {
 			isdy = true
-			couseOrder.CouponAmount = couseOrder.Price
+			couseOrder.CouponAmount = coupon.Price
 		} else {
 			for _, target := range coupon.Targets {
 				if target.TargetId == course.CourseId {

service/customer/customer.go

@@ -74,6 +74,7 @@ func (s *CustomerServ) GetCustUserByOpenID(openid string) (*customer.CustWithWX,
 			return nil, err
 		}
 		cust.BelongCaseId = caseinfo.CaseId
+		cust.BelongCaseStatus = caseinfo.Status
 	}
 
 	return cust, nil

service/goods/orders.go

@@ -545,3 +545,13 @@ func (s *GoodsServ) CancelMake(id string) error {
 	err := s.dao.UpdateOrdersMake(orders)
 	return err
 }
+
+// UpdateOrdersIntimidate 更新订单打单
+func (s *GoodsServ) UpdateOrdersIntimidate(id string) error {
+	err := s.dao.UpdateOrdersIntimidate(id)
+	if err != nil {
+		utils.LogError("更新失败：", err)
+		return err
+	}
+	return nil
+}

service/statistics/goods.go

@@ -92,6 +92,12 @@ func (s *StatisticsServ) GetGoodsOrdersStatisticsExcel(status, usertype, caseids
 		utils.LogError("获取商品订单统计数据失败: " + err.Error())
 		return nil, errors.New("获取商品订单统计数据失败")
 	}
-
+	for inx, item := range all {
+		details, err := s.dao.GetGoodsOrderDetailByOrderId(item.OrdersId)
+		if err != nil {
+			return nil, err
+		}
+		all[inx].Details = details
+	}
 	return all, nil
 }

service/verify/verify.go

@@ -86,7 +86,7 @@ func (s *VerifyServ) GetCustomerCourseDetailByTel(tel, caseids string, page, pag
 		return nil, errors.New("获取课程列表失败")
 	}
 	if len(customerDetail) == 0 {
-		return nil, errors.New("今日无可核销课程")
+		return nil, nil
 	}
 	customerID := customerDetail[0].CustomerId
 	total, err := s.dao.GetCustomerCourseListByTelCount(tel, caseids)