From e51d4c53de6e9a3ecfe9542d4bfdef215d613229 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 16 十一月 2023 10:56:55 +0800
Subject: [PATCH] Merge branch 'master' of http://192.168.5.5:10010/r/aps/SRM

---
 api/v1/purchase/purchase.go |   48 +++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 43 insertions(+), 5 deletions(-)

diff --git a/api/v1/purchase/purchase.go b/api/v1/purchase/purchase.go
index 0a5c918..c037be0 100644
--- a/api/v1/purchase/purchase.go
+++ b/api/v1/purchase/purchase.go
@@ -1,6 +1,7 @@
 package purchase
 
 import (
+	"context"
 	"fmt"
 	"github.com/gin-gonic/gin"
 	"go.uber.org/zap"
@@ -10,6 +11,7 @@
 	"srm/model/common/response"
 	"srm/model/purchase"
 	purchaserequest "srm/model/purchase/request"
+	"srm/proto/purchase_wms"
 	"strconv"
 	"strings"
 	"time"
@@ -55,6 +57,7 @@
 	purchaseRecord.Creator = "admin"
 	purchaseRecord.Number = fmt.Sprintf("CG%v", time.Now().Unix())
 	purchaseRecord.Principal = "admin"
+	purchaseRecord.OrderType = "閲囪喘璁㈠崟"
 
 	if !purchaseRecord.WholeDiscountType.IsValid(purchaseRecord.TotalPrice, purchaseRecord.WholeDiscount) {
 		response.FailWithMessage("鏁村崟鎶樻墸鏁板�间笉姝g‘", c)
@@ -230,14 +233,49 @@
 // @Produce   application/json
 // @Param		id	path		int	true	"閲囪喘鍗旾D"
 // @Success   200   {object}  response.Response{msg=string}  "鎻愪氦閲囪喘鍗�"
-// @Router    /purchase/submit/{id} [post]
+// @Router    /purchase/submit [post]
 func (e *PurchaseApi) Submit(c *gin.Context) {
-	id, _ := strconv.Atoi(c.Param("id"))
-	if id == 0 {
-		response.FailWithMessage("鍙傛暟缂哄け", c)
+	var params purchaserequest.SubmitPurchase
+	err := c.ShouldBindJSON(&params)
+	if err != nil {
+		global.GVA_LOG.Error("Submit failed", zap.Error(err))
+		response.FailWithMessage(err.Error(), c)
 		return
 	}
-	err := service.NewPurchaseService().Submit(uint(id))
+	if params.Status == purchase.OrderStatusReceived {
+		data, err := service.NewPurchaseService().GetPurchase(uint(params.Id))
+		if err != nil {
+			global.GVA_LOG.Error("鑾峰彇澶辫触!", zap.Error(err))
+			response.FailWithMessage("鑾峰彇澶辫触", c)
+			return
+		}
+		productList, err := service.NewPurchaseService().GetPurchaseProductList(uint(params.Id))
+		if err != nil {
+			global.GVA_LOG.Error("鑾峰彇澶辫触!", zap.Error(err))
+			response.FailWithMessage("鑾峰彇澶辫触", c)
+			return
+		}
+		product := make([]*purchase_wms.PurchaseProduct, 0)
+		for _, products := range productList {
+			var p purchase_wms.PurchaseProduct
+			p.Id = products.Product.Number
+			p.Amount = products.Amount.IntPart()
+			product = append(product, &p)
+		}
+		client := purchase_wms.NewPurchaseServiceClient(purchase_wms.PurchaseConn)
+		_, err = client.PurchaseToWms(context.Background(), &purchase_wms.PurchaseToWmsRequest{
+			Number:       data.Number,
+			SupplierName: data.Supplier.Name,
+			Product:      product,
+		})
+		if err != nil {
+			global.GVA_LOG.Error("grpc璋冪敤澶辫触!", zap.Error(err))
+			response.FailWithMessage("grpc璋冪敤澶辫触", c)
+			return
+		}
+	}
+
+	err = service.NewPurchaseService().Submit(params.Id, params.Status)
 	if err != nil {
 		global.GVA_LOG.Error("鏇存柊澶辫触!", zap.Error(err))
 		response.FailWithMessage("鏇存柊澶辫触", c)

--
Gitblit v1.8.0