表结构

  1. package model
  3. import "time"
  6. type ShoppingCart struct{
  7.     BaseModel
  8.     User int32 `gorm:"type:int;index"`
  9.     Goods int32 `gorm:"type:int;index"`
  10.     Nums int32 `gorm:"type:int"`
  11.     Checked bool
  12. }
  14. func (ShoppingCart) TableName() string {
  15.     return "shoppingcart"
  16. }
  19. type OrderInfo struct{
  20.     BaseModel
  22.     User int32 `gorm:"type:int;index"`
  23.     OrderSn string `gorm:"type:varchar(30);index"`
  24.     PayType string `gorm:"type:varchar(20) comment 'alipay(支付宝)， wechat(微信)'"`
  26.     //status大家可以考虑使用iota来做
  27.     Status string `gorm:"type:varchar(20)  comment 'PAYING(待支付), TRADE_SUCCESS(成功)， TRADE_SUCCESS(超时关闭), WAIT_BUYER_PAY(交易创建), TRADE_FINISHED(交易结束)'"`
  28.     TradeNo string `gorm:"type:varchar(100) comment '交易号'"`
  29.     OrderMount float32
  30.     PayTime time.Time
  32.     Address string `gorm:"type:varchar(100)"`
  33.     SignerName string `gorm:"type:varchar(20)"`
  34.     SingerMobile string `gorm:"type:varchar(11)"`
  35.     Post string `gorm:"type:varchar(20)"`
  36. }
  38. func (OrderInfo) TableName() string {
  39.     return "orderinfo"
  40. }
  42. type OrderGoods struct{
  43.     BaseModel
  45.     Order int32 `gorm:"type:int;index"`
  46.     Goods int32 `gorm:"type:int;index"`
  48.     GoodsName string `gorm:"type:varchar(100);index"`
  49.     GoodsImage string `gorm:"type:varchar(200)"`
  50.     GoodsPrice float32
  51.     Nums int32 `gorm:"type:int"`
  52. }
  54. func (OrderGoods) TableName() string {
  55.     return "ordergoods"
  56. }

proto文件定义

  1. syntax = "proto3";
  2. import "google/protobuf/empty.proto";
  3. option go_package = ".;proto";
  6. service Order {
  7.     //购物车
  8.     rpc CartItemList(UserInfo) returns(CartItemListResponse); //获取用户的购物车信息
  9.     rpc CreateCartItem(CartItemRequest) returns(ShopCartInfoResponse); //添加商品到购物车
  10.     rpc UpdateCartItem(CartItemRequest) returns(google.protobuf.Empty); //修改购物车记录
  12.     //订单
  13.     rpc Create(OrderRequest) returns (OrderInfoResponse); //创建订单
  14.     rpc OrderList(OrderFilterRequest) returns (OrderListResponse); // 订单列表
  15.     rpc OrderDetail(OrderRequest) returns (OrderInfoDetailResponse); // 订单详情
  16.     rpc UpdateOrderStatus(OrderStatus) returns (google.protobuf.Empty); // 修改订单状态
  17. }
  19. message UserInfo {
  20.     int32 id = 1;
  21. }
  23. message OrderStatus {
  24.     int32 id = 1;
  25.     string orderSn = 2;
  26.     string status = 3;
  27. }
  29. message CartItemRequest {
  30.     int32 id = 1;
  31.     int32 userId = 2;
  32.     int32 goodsId = 3;
  33.     string goodsName = 4;
  34.     string goodsImage = 5;
  35.     float goodsPrice = 6;
  36.     int32 nums = 7;
  37.     bool checked = 8;
  38. }
  40. message OrderRequest {
  41.     int32 id = 1;
  42.     int32 userId = 2;
  43.     string address = 3;
  44.     string name = 4;
  45.     string mobile = 5;
  46.     string post = 6;
  47. }
  49. message OrderInfoResponse {
  50.     int32 id = 1;
  51.     int32 userId = 2;
  52.     string orderSn = 3;
  53.     string payType = 4;
  54.     string status = 5;
  55.     string post = 6;
  56.     float total = 7;
  57.     string address = 8;
  58.     string name = 9;
  59.     string mobile = 10;
  60. }
  62. message ShopCartInfoResponse {
  63.     int32 id = 1;
  64.     int32 userId = 2;
  65.     int32 goodsId = 3;
  66.     int32 nums = 4;
  67.     bool checked = 5;
  68. }
  70. message OrderItemResponse {
  71.     int32 id = 1;
  72.     int32 orderId = 2;
  73.     int32 goodsId = 3;
  74.     string goodsName = 4;
  75.     string goodsImage = 5;
  76.     float goodsPrice = 6;
  77.     int32 nums = 7;
  78. }
  80. message OrderInfoDetailResponse {
  81.     OrderInfoResponse orderInfo = 1;
  82.     repeated OrderItemResponse goods = 2;
  83. }
  85. message OrderFilterRequest {
  86.     int32 userId = 1;
  87.     int32 pages = 2;
  88.     int32 pagePerNums = 3;
  89. }
  91. message OrderListResponse {
  92.     int32 total = 1;
  93.     repeated OrderInfoResponse data = 2;
  94. }
  96. message CartItemListResponse {
  97.     int32 total = 1;
  98.     repeated ShopCartInfoResponse data = 2;
  99. }

创建订单

  1. func (*OrderServer) CreateOrder(ctx context.Context, req *proto.OrderRequest) (*proto.OrderInfoResponse, error) {
  2.     /*
  3.         新建订单
  4.             1. 从购物车中获取到选中的商品
  5.             2. 商品的价格自己查询 - 访问商品服务 (跨微服务)
  6.             3. 库存的扣减 - 访问库存服务 (跨微服务)
  7.             4. 订单的基本信息表 - 订单的商品信息表
  8.             5. 从购物车中删除已购买的记录
  9.     */
  10.     //定一个切片用来保存购物车商品数据
  11.     var shopCarts []model.ShoppingCart
  12.     //定义一个切片存放购物车下的商品id
  13.     var goodsIds []int32
  14.     //定义商品数据字典
  15.     goodsNumsMap := make(map[int32]int32)
  16.     if result := global.DB.Where(&model.ShoppingCart{User: req.UserId, Checked: true}).Find(&shopCarts); result.RowsAffected == 0 {
  17.         return nil, status.Errorf(codes.Internal, "没有选中任何商品")
  18.     }
  20.     //得到购物车的所有商品id
  21.     for _, shopCart := range shopCarts {
  22.         goodsIds = append(goodsIds, shopCart.Goods)
  23.         goodsNumsMap[shopCart.Goods] = shopCart.Nums
  24.     }
  26.     //去商品微服务查询商品价格
  27.     goods, err := global.GoodsSrvClient.BatchGetGoods(context.Background(), &proto.BatchGoodsIdInfo{
  28.         Id: goodsIds,
  29.     })
  30.     if err != nil {
  31.         return nil, status.Errorf(codes.NotFound, "没有任何商品信息")
  32.     }
  34.     //订单的总金额 = 所有商品的金额加一起 (商品的价格（goods）*购物车商品的数量(shopCarts.nums))
  35.     var orderMount float32
  36.     //定义一个切片 保存扣减商品和数量信息
  37.     var goodsInvInfo []*proto.GoodsInvInfo
  38.     //定义一个切片 保存订单购买的所有商品
  39.     var orderGoods []*model.OrderGoods
  41.     for _, good := range goods.Data {
  42.         orderMount += good.ShopPrice * float32(goodsNumsMap[good.Id])
  44.         orderGoods = append(orderGoods, &model.OrderGoods{
  45.             Goods:      good.Id,
  46.             GoodsName:  good.Name,
  47.             GoodsImage: good.GoodsFrontImage,
  48.             GoodsPrice: good.ShopPrice,
  49.             Nums:       goodsNumsMap[good.Id],
  50.         })
  52.         goodsInvInfo = append(goodsInvInfo, &proto.GoodsInvInfo{
  53.             GoodsId: good.Id,
  54.             Num:     goodsNumsMap[good.Id],
  55.         })
  56.     }
  58.     //库存的扣减
  59.     _, err = global.InventorySrvClient.Sell(context.Background(), &proto.SellInfo{
  60.         GoodsInfo: goodsInvInfo,
  61.     })
  62.     if err != nil {
  63.         return nil, status.Errorf(codes.NotFound, "库存扣减失败")
  64.     }
  66.     tx := global.DB.Begin()
  67.     //创建订单基本信息表
  68.     OrderInfo := model.OrderInfo{
  69.         User:         req.UserId,
  70.         OrderSn:      GenerateOrderSn(req.UserId),
  71.         Status:       "PAYING",
  72.         OrderMount:   orderMount,
  73.         Address:      req.Address,
  74.         SignerName:   req.Name,
  75.         SingerMobile: req.Mobile,
  76.         Post:         req.Post,
  77.     }
  79.     if result := tx.Create(&OrderInfo); result.RowsAffected == 0 {
  80.         tx.Rollback()
  81.         return nil, status.Errorf(codes.Internal, "创建订单失败")
  82.     }
  84.     //创建订单商品表
  85.     for _, orderGood := range orderGoods {
  86.         orderGood.Order = OrderInfo.ID
  87.     }
  88.     //多条数据，最好不要循环入库，来使用批量入库
  89.     if result := tx.CreateInBatches(orderGoods, 100); result.RowsAffected == 0 {
  90.         tx.Rollback()
  91.         return nil, status.Errorf(codes.Internal, "创建订单商品失败")
  92.     }
  94.     //从购物车中删除已购买的记录
  95.     if result := tx.Where(&model.ShoppingCart{User: req.UserId, Checked: true}).Delete(&shopCarts); result.RowsAffected == 0 {
  96.         tx.Rollback()
  97.         return nil, status.Errorf(codes.Internal, "删除购物车商品失败")
  98.     }
  100.     //返回结果
  101.     OrderInfoResponse := &proto.OrderInfoResponse{
  102.         Id:      OrderInfo.ID,
  103.         UserId:  OrderInfo.User,
  104.         OrderSn: OrderInfo.OrderSn,
  105.         PayType: OrderInfo.PayType,
  106.         Status:  OrderInfo.Status,
  107.         Post:    OrderInfo.Post,
  108.         Total:   OrderInfo.OrderMount,
  109.         Address: OrderInfo.Address,
  110.         Name:    OrderInfo.SignerName,
  111.         Mobile:  OrderInfo.SingerMobile,
  112.         AddTime: OrderInfo.CreatedAt.Format("2006-01-02 15:04:05"),
  113.     }
  114.     tx.Commit()
  115.     return OrderInfoResponse, nil
  116. }