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

conf/db.conf

 con_protocol = tcp
 
 ; 数据库地址，可以使用IP
-# db_addr      = 47.101.36.130
-db_addr = 192.168.0.122
-# db_addr      = localhost
+; db_addr      = 47.101.36.130
+db_addr        = 192.168.0.122
 # db_addr      = rm-uf6z3z6jq11x653d77o.mysql.rds.aliyuncs.com
 
 ; 端口

conf/log.conf

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

controllers/luckdraw/luckdraw.go

 
 	user := userRaw.(model.TaCustomer)
 	luckdrawid := c.GetString(":id")
-	record, err := c.serv.GetUserLuckDrawByLuckDraw(user, luckdrawid)
+	record, set, err := c.serv.GetUserLuckDrawByLuckDraw(user, luckdrawid)
 	if err != nil {
 		utils.LogError("获取用户抽奖信息失败: " + err.Error())
 		c.ResponseError(errors.New("获取用户抽奖信息失败"))
 		"user":   user,
 		"record": record,
 		"detail": detail,
+		"set":    set,
 	})
 }
 

models/customer/vip.go

 import (
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
+	"time"
 )
 
 // GetValidVIPCards 依据客户ID 获取 VIP 卡
 // 按照过期时间升序, 即 将到期的在最上面
 // VIP 卡可以跨案场使用
 func (m *CustomerDAO) GetValidVIPCards(custID string) (vips []model.TaCustomerVip, err error) {
+	now := time.Now().Local().Format("2006-01-02 15:04:05")
+
 	err = m.db.Where("customer_id=?", custID).
 		And("status=?", models.STATUS_NORMAL).
+		And(`DATE_FORMAT(begin_date, "%Y-%m-%d %T")<=?`, now).
+		And(`DATE_FORMAT(end_date, "%Y-%m-%d %T")>=?`, now).
 		And("balance>0").
 		Asc("end_date").
 		Find(&vips)

models/goods/types.go

 // OrdersDetail 订单详情
 type OrdersDetail struct {
 	model.TaGoodsOrders `xorm:"extends"`
-	Goods               []DetailWithType
-	Coupons             []model.TaGoodsOrdersCoupon
+	Goods               []DetailWithType            `xorm:"-"`
+	Coupons             []model.TaGoodsOrdersCoupon `xorm:"-"`
 }

models/vipcard/vipcard.go

 	change.ChangeId = utils.GetGUID()
 	change.Status = models.STATUS_NORMAL
 	change.CreateDate = time.Now()
+
 	_, err := m.db.Insert(change)
 	return err
 }

service/goods/goods.go

 		custDAO:   customer.NewCustomerDAO(ctx),
 		userDAO:   system.NewUserDAO(ctx),
 		couponDAO: coupon.NewCouponDAO(ctx),
+		vipDAO:    vipcard.NewVipcardDAO(ctx),
 	}
 }
 

service/goods/orders.go

 		if err != nil {
 			return nil, utils.LogError("查询用户VIP卡信息出错", err.Error())
 		}
+
 		if vips != nil && len(vips) > 0 {
 			for _, vip := range vips {
 				vipMoney, _ := strconv.ParseFloat(vip.Balance, 64)

service/luckdraw/luckdraw.go

 }
 
 // GetUserLuckDrawByLuckDraw 获取用户抽奖信息
-func (s *LuckdrawServ) GetUserLuckDrawByLuckDraw(user model.TaCustomer, luckdrawid string) (*model.TaLuckdrawRecord, error) {
+func (s *LuckdrawServ) GetUserLuckDrawByLuckDraw(user model.TaCustomer, luckdrawid string) (*model.TaLuckdrawRecord, *model.TaLuckdrawCustomer, error) {
 	// 获取用户抽奖设置信息
-	_, err := s.dao.GetUserLuckDrawSet(user, luckdrawid)
+	customerSet, err := s.dao.GetUserLuckDrawSet(user, luckdrawid)
 	if err != nil {
 		utils.LogError("获取用户抽奖设置失败: " + err.Error())
-		return nil, errors.New("获取用户抽奖设置失败")
+		return nil, nil, errors.New("获取用户抽奖设置失败")
 	}
 	record, err := s.dao.GetUserLuckDrawByLuckDraw(user.CustomerId, luckdrawid)
 	if err != nil {
 		utils.LogError("获取用户的抽奖信息失败: " + err.Error())
-		return nil, errors.New("获取用户的抽奖信息失败")
+		return nil, nil, errors.New("获取用户的抽奖信息失败")
 	}
-	return record, nil
+	return record, customerSet, nil
 }
 
 func (s *LuckdrawServ) GetDetailByRecord(recordid string) (*model.TaPrizeDetail, error) {

tests/cases_test.go

 func TestGetCmsCaseList(t *testing.T) {
 
 	Convey("获取案场列表", t, func() {
-
 		Convey("正常业务", func() {
 			params := url.Values{}
 			params.Add("orgid", "1")
 			So(err, ShouldBeNil)
 
 			// 业务返回判断
-			Convey("结果码 200", func() {
-				So(result.Code, ShouldEqual, http.StatusOK)
-			})
-
-			Convey("结果不为空", func() {
-				So(result.Result, ShouldNotBeEmpty)
-			})
+			So(result.Code, ShouldEqual, http.StatusOK)
+			So(result.Result, ShouldNotBeEmpty)
 		})
 
 		Convey("机构不传报错", func() {
 			So(err, ShouldBeNil)
 
 			// 业务返回判断
-			Convey("结果码 不是200", func() {
-				So(result.Code, ShouldNotEqual, http.StatusOK)
-			})
+			So(result.Code, ShouldNotEqual, http.StatusOK)
 		})
 
 	})

tests/goodsorder_test.go

 package tests
 
 import (
+	"net/http"
 	"net/url"
+	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/utils"
 	"testing"
+	"time"
 
 	. "github.com/smartystreets/goconvey/convey"
 )
 
-func TestGetCmsCaseList(t *testing.T) {
+func TestPreGoodsOrder(t *testing.T) {
 	Convey("商品下单", t, func() {
+
 		Convey("正常下单", func() {
 			params := url.Values{}
 			params.Add("info", `{"CaseId":"1","AreaId":"12","AreaName":"吧台","TableId":"28","TableNo":"城咖啡水吧台","Amount":"23","OrdersNum":1,"Remark":"","OrgId":"1","UserName":"奥利奥","PayType":"coupon"}`)
 			params.Add("detail", `[{"GoodsId":"61","GoodsName":"美式","SpecId":"40","SpecName":"去冰","Number":1,"Price":"23"}]`)
 
-			token, _ := utils.CreateToken(map[string]interface{}{})
+			result := &controllers.JSONMessage{}
+			api := "/api/wechat/MQ/order/goods"
+
+			token := &utils.JWTToken{
+				Guest:   false,
+				ID:      "oMOpz0kgTrasoAA3G70R7phomn1g", // openid
+				Expire:  time.Now().Local().Add(24 * 30 * time.Hour),
+				BatchNo: "",
+			}
+
+			code, _, err := NewRequestMock().
+				AddToken(token.ToMap()).
+				AddWechatUA().
+				Request(http.MethodPost, api, params, result)
 
-			wechatUA := "Mozilla/5.0 (iPhone; CPU iPhone OS 8_0 like Mac OS X) AppleWebKit/600.1.4 (KHTML, like Gecko) Mobile/12A365 MicroMessenger/5.4.1 NetType/WIFI"
+			So(code, ShouldEqual, http.StatusOK)
+			So(err, ShouldBeNil)
 
+			// 业务返回判断
+			So(result.Code, ShouldEqual, http.StatusOK)
+			So(result.Result, ShouldNotBeEmpty)
 		})
 	})
 }
+
+func TestConfirmOrders(t *testing.T) {
+	orderID := "cc84338e-488e-463b-a33e-7dc7f2cd10b6"
+
+	Convey("下单确认", t, func() {
+		result := &controllers.JSONMessage{}
+		api := "/api/wechat/MQ/order/goods/" + orderID
+
+		token := &utils.JWTToken{
+			Guest:   false,
+			ID:      "oMOpz0kgTrasoAA3G70R7phomn1g", // openid
+			Expire:  time.Now().Local().Add(24 * 30 * time.Hour),
+			BatchNo: "",
+		}
+
+		code, _, err := NewRequestMock().
+			AddToken(token.ToMap()).
+			AddWechatUA().
+			Request(http.MethodPut, api, nil, result)
+
+		So(code, ShouldEqual, http.StatusOK)
+		So(err, ShouldBeNil)
+
+		// 业务返回判断
+		So(result.Code, ShouldEqual, http.StatusOK)
+	})
+
+}

tests/tests.go

 	"spaceofcheng/services/utils"
 	"testing"
 
-	_ "spaceofcheng/services/routers"
-
 	"github.com/astaxie/beego"
 	. "github.com/smartystreets/goconvey/convey"
 )

tests/utils.go

 	code = w.Code
 	body, _ = ioutil.ReadAll(w.Result().Body)
 
-	beego.Trace("testing", meth+" - "+addr, body)
+	beego.Trace("testing", meth+" - "+addr)
 
 	if result != nil {
 		err = json.Unmarshal(body, result)

utils/utils.go

 	"net/http"
 	"os"
 	"path/filepath"
+	"runtime"
 	"strconv"
 	"strings"
 	"time"
 	return str[:strLen-1] + strconv.Itoa(lastNum)
 }
 
+// 当前运行环境
+var processEnv string
+var appRoot string
+
 // GetAppRoot 获取系统根目录
 func GetAppRoot() string {
-	appRoot, _ := filepath.Abs(filepath.Dir(os.Args[0]))
+	if appRoot != "" {
+		return appRoot
+	}
+
+	if processEnv == "" {
+		for _, arg := range os.Args {
+			if strings.Index(arg, "-test.run") > -1 {
+				processEnv = "test"
+				break
+			}
+		}
+
+		if processEnv == "" {
+			processEnv = "production"
+		}
+	}
+
+	if processEnv == "test" {
+		_, file, _, _ := runtime.Caller(1)
+		appRoot, _ = filepath.Abs(filepath.Dir(filepath.Join(file, ".."+string(filepath.Separator))))
+	} else {
+		appRoot, _ = filepath.Abs(filepath.Dir(os.Args[0]))
+	}
+
 	return appRoot
 }