From 002539c8dc7eae6e64da1608245be01a889c061c Mon Sep 17 00:00:00 2001 From: liujiandao <274878379@qq.com> Date: 星期六, 02 十二月 2023 14:48:14 +0800 Subject: [PATCH] 修改销售明细 --- api/v1/product.go | 79 +++++++++++++++++++-------------------- 1 files changed, 39 insertions(+), 40 deletions(-) diff --git a/api/v1/product.go b/api/v1/product.go index f1d1f7b..9cca9e4 100644 --- a/api/v1/product.go +++ b/api/v1/product.go @@ -1,44 +1,39 @@ package v1 import ( - "aps_crm/conf" "aps_crm/model" + "aps_crm/model/grpc_init" "aps_crm/model/request" "aps_crm/model/response" "aps_crm/pkg/contextx" "aps_crm/pkg/ecode" "aps_crm/pkg/logx" "aps_crm/proto/product" - "aps_crm/utils" - "fmt" "github.com/gin-gonic/gin" "github.com/shopspring/decimal" "github.com/spf13/cast" - "google.golang.org/grpc" - "google.golang.org/grpc/credentials/insecure" ) type ProductApi struct{} -var ( - productServiceConn *grpc.ClientConn -) - -func InitProductServiceConn() { - fmt.Println(conf.Conf.GrpcServiceAddr.Aps) - var err error - productServiceConn, err = grpc.Dial(conf.Conf.GrpcServiceAddr.Aps, grpc.WithTransportCredentials(insecure.NewCredentials())) - if err != nil { - logx.Errorf("grpc dial product service error: %v", err.Error()) - return - } -} - -func CloseProductServiceConn() { - if productServiceConn != nil { - productServiceConn.Close() - } -} +//var ( +// productServiceConn *grpc.ClientConn +//) +// +//func InitProductServiceConn() { +// var err error +// productServiceConn, err = grpc.Dial(conf.Conf.GrpcServiceAddr.Aps, grpc.WithTransportCredentials(insecure.NewCredentials())) +// if err != nil { +// logx.Errorf("grpc dial product service error: %v", err.Error()) +// return +// } +//} +// +//func CloseProductServiceConn() { +// if productServiceConn != nil { +// productServiceConn.Close() +// } +//} // List // @@ -60,7 +55,7 @@ return } - cli := product.NewProductServiceClient(productServiceConn) + cli := product.NewProductServiceClient(grpc_init.CrmApsGrpcServiceConn) getProductListResponse, err := cli.GetProductList(ctx.GetCtx(), &product.GetProductListRequest{ Page: cast.ToInt32(params.Page), PageSize: cast.ToInt32(params.PageSize), @@ -76,6 +71,7 @@ productList[k].Price = decimal.NewFromFloat(v.SalePrice).Round(2) productList[k].Amount = decimal.NewFromFloat(1) productList[k].Total = productList[k].Price.Mul(productList[k].Amount).Round(2) + productList[k].Unit = v.Unit } if err != nil { @@ -109,7 +105,7 @@ // 鑾峰彇浜у搧ID productId := c.Query("productNumber") - cli := product.NewProductServiceClient(productServiceConn) + cli := product.NewProductServiceClient(grpc_init.CrmApsGrpcServiceConn) getProductInfoResponse, err := cli.GetProductInfo(ctx.GetCtx(), &product.GetProductInfoRequest{ProductId: productId}) if err != nil { @@ -140,25 +136,28 @@ return } number := c.Param("number") - first, err := model.NewSalesDetailsSearch().SetNumber(number).SetPreload(true).First() - if err != nil { - ctx.FailWithMsg(ecode.UnknownErr, "鏄庣粏璇︽儏鏌ユ壘澶辫触") + if number == "" || number == "undefined" { + ctx.Ok() return } - params := make([]*product.Info, 0) - for _, p := range first.Products { - var pa product.Info - pa.ProductId = p.Number - pa.StartTime = utils.TimeToString(first.UpdatedAt) - pa.EndTime = first.DeliveryDate - params = append(params, &pa) - } - client := product.NewProductServiceClient(productServiceConn) - info, err := client.GetProductOrder(ctx.GetCtx(), &product.GetProductOrderRequest{Params: params}) + client := product.NewProductServiceClient(grpc_init.CrmApsGrpcServiceConn) + info, err := client.GetProductOrder(ctx.GetCtx(), &product.GetProductOrderRequest{SalesDetailsNumber: number}) if err != nil { logx.Errorf("GetProductOrder err: %v", err.Error()) ctx.FailWithMsg(ecode.UnknownErr, "鍐呴儴閿欒") return } - ctx.OkWithDetailed(info.List) + var list []response.WorkOrderInfo + for _, orderInfo := range info.List { + var wo response.WorkOrderInfo + wo.OrderId = orderInfo.OrderId + wo.ProductName = orderInfo.ProductName + wo.OrderStatus = orderInfo.OrderStatus + wo.WorkOrderId = orderInfo.WorkOrderId + wo.WorkOrderStatus = orderInfo.WorkOrderStatus + wo.StartTime = orderInfo.StartTime + wo.EndTime = orderInfo.EndTime + list = append(list, wo) + } + ctx.OkWithDetailed(list) } -- Gitblit v1.8.0