fix

2026-08-28 11:12:23 +08:00
parent cd8a571f57
commit ae143c21ad
8 changed files with 243 additions and 23 deletions
@@ -2,6 +2,13 @@ package logic

 import (
 	"context"
+	"lone-services/pkg/modelbase"
+	"lone-services/pkg/utils"
+	"lone-services/services/order/internal/dao"
+	"lone-services/services/order/internal/model"
+	"lone-services/services/order/validator"
+	"strconv"
+	"strings"

 	"lone-services/rpc/order/pb"
 	"lone-services/services/order/internal/svc"
@@ -25,7 +32,133 @@ func NewOrderCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Order
 }

 func (l *OrderCreateLogic) OrderCreate(in *order.AdminCreateOrderRequest) (*order.Response, error) {
-	// todo: add your logic here and delete this line
+	var v validator.AdminOrderCreateValidator
+	if fail := l.checkParams(in, &v); fail != nil {
+		return fail, nil
+	}
+	adminInfo := utils.GetUserFromCtx(l.ctx)
+	if adminInfo.ID < utils.NumberOne {
+		return l.fail(utils.ErrorNoLoginInfo)
+	}

-	return &order.Response{}, nil
+	w := modelbase.Params{
+		Eq: map[string]string{
+			"id":        strconv.FormatInt(in.AddressId, utils.NumberTen),
+			"type":      strconv.Itoa(dao.OrderTypeStore),
+			"target_id": strconv.FormatInt(adminInfo.ID, utils.NumberTen),
+		},
+	}
+	var address dao.Address
+	err := model.AddressModel{}.Init().GetOne(w, &address)
+	if err != nil {
+		return l.fail(utils.Fail)
+	}
+	if address.Id < utils.NumberOne {
+		return l.out(utils.Fail, "地址不存在")
+	}
+
+	data := dao.OrderCreate{
+		Note:         in.Note,
+		Mobile:       address.Mobile,
+		VerifyStatus: model.VerifyCheckIn,
+		Address:      address.Address,
+		Addressee:    address.Name,
+		DistrictIds:  address.DistrictIds,
+	}
+
+	ww := modelbase.Params{
+		Eq: map[string]string{
+			"type": strconv.Itoa(dao.OrderTypeStore),
+		},
+	}
+	data.StoreId = int(adminInfo.ID)
+	data.StoreName = adminInfo.Name
+	data.SaleId = int(adminInfo.SaleId)
+	data.GroupId = int(adminInfo.GroupId)
+	data.SaleMobile = adminInfo.SaleMobile
+	data.SaleProvince = int(adminInfo.SaleProvince)
+	data.CreateType = dao.OrderTypeStore
+	data.Type = dao.OrderTypeStore
+	ww.Eq["store_id"] = strconv.FormatInt(adminInfo.ID, utils.NumberTen)
+	data.OrderSn = svc.GetOrderSn(strconv.Itoa(dao.OrderTypeStore), adminInfo.ID)
+
+	var cart dao.Cart
+
+	ids, pErr := svc.GetCartInfo(in.Info)
+	if pErr != utils.Ok {
+		return l.fail(utils.Fail)
+	}
+	products, pErr := svc.GetCartData(l.svcCtx.ProductSvcName, ids)
+	if pErr != utils.Ok {
+		return l.fail(utils.Fail)
+	}
+	keys := make([]string, utils.NumberZero, len(products.Items))
+	var totalPrice float64
+	errData := make(map[int64]int64)
+	productItems := []dao.OrderProductCreate{}
+	for _, item := range products.Items {
+		if buyNum, ok := ids[item.Id]; ok {
+			if buyNum > int64(item.Number) {
+				errData[item.Id] = int64(item.Number)
+				return l.out(utils.Fail,
+					item.Name+"购买数量超出库存,目前可以够买:"+strconv.Itoa(int(item.Number)))
+			} else {
+				keys = append(keys, strconv.Itoa(int(item.Id)))
+				totalPrice += item.Price * float64(buyNum)
+				productItems = append(productItems, dao.OrderProductCreate{
+					OrderSn:     data.OrderSn,
+					ProductId:   int(item.Id),
+					ProductName: item.Name,
+					Price:       item.Price,
+					Number:      int(buyNum),
+				})
+			}
+		}
+	}
+	if len(keys) < utils.NumberOne {
+		return l.out(utils.Fail, "购买信息不存在")
+	}
+	data.ProductIds = strings.Join(keys, utils.DecollatorComma)
+	data.TotalPrice = totalPrice
+	mobileObj := model.OrderModel{}.Init()
+
+	mobileObj.Begin()
+	err = mobileObj.Create(&data)
+	if err != nil {
+		mobileObj.Rollback()
+		return l.fail(utils.Fail)
+	}
+
+	for _, item := range productItems {
+		err = model.OrderProductModel{}.Init().Create(&item)
+		if err != nil {
+			mobileObj.Rollback()
+			return l.fail(utils.Fail)
+		}
+	}
+
+	_, err = model.CartModel{}.Init().Del(ww, &cart)
+	if err != nil {
+		mobileObj.Rollback()
+		return l.fail(utils.Fail)
+	}
+
+	//TODO 扣库存接口
+	//cli, err := svc.GetRpcClient(l.svcCtx.ProductSvcName)
+	//if err != nil {
+	//	mobileObj.Rollback()
+	//	return l.fail(utils.Fail)
+	//}
+
+	//productClient := product.NewProductClient(cli.Conn())
+	//_, err = productClient.Number(l.ctx, &product.NumberReq{Id: item.Id, Type: utils.NumberOne, Number: buyNum})
+	//if err != nil {
+	//	mobileObj.Rollback()
+	//	logx.Errorf("get products err: %v", err)
+	//	return l.fail(utils.Fail, "产品库存不足")
+	//}
+
+	mobileObj.Commit()
+
+	return l.ok(utils.NumberOne)
 }