liujiandao
2023-12-15 5b8f003464bd55678862534232228f61745ffafe
提示信息修改
2个文件已修改
34 ■■■■ 已修改文件
api/v1/product.go 26 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
api/v1/salesDetails.go 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
api/v1/product.go
@@ -62,6 +62,16 @@
        ProductNumber: params.ProductNumber,
        ProductName:   params.ProductName,
    })
    if err != nil {
        logx.Errorf("grpc GetProductList err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
        return
    }
    if getProductListResponse.Code != 0 {
        logx.Errorf("grpc GetProductList err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
        return
    }
    rawProductList := getProductListResponse.List
    productList := make([]model.Product, len(rawProductList))
@@ -74,16 +84,6 @@
        productList[k].Unit = v.Unit
    }
    if err != nil {
        logx.Errorf("GetProductList err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
        return
    }
    if getProductListResponse.Code != 0 {
        logx.Errorf("GetProductList err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
        return
    }
    ctx.OkWithDetailed(response.ListResponse{
        Data:  productList,
        Count: getProductListResponse.Total,
@@ -109,12 +109,12 @@
    getProductInfoResponse, err := cli.GetProductInfo(ctx.GetCtx(), &product.GetProductInfoRequest{ProductId: productId})
    if err != nil {
        logx.Errorf("GetProductInfo err: %v", err.Error())
        logx.Errorf(" grpc GetProductInfo err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
        return
    }
    if getProductInfoResponse.Code != 0 {
        logx.Errorf("GetProductInfo err: %v", err.Error())
        logx.Errorf("grpc GetProductInfo err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
        return
    }
@@ -143,7 +143,7 @@
    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())
        logx.Errorf("grpc GetProductOrder err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
        return
    }
api/v1/salesDetails.go
@@ -305,7 +305,8 @@
    client := crm_aps.NewCrmAndApsGrpcServiceClient(grpc_init.CrmApsGrpcServiceConn)
    projectList, err := client.GetApsProjectList(c, &crm_aps.GetApsProjectListRequest{})
    if err != nil {
        ctx.FailWithMsg(ecode.UnknownErr, "grpc调用错误: "+err.Error())
        logx.Errorf("grpc GetApsProjectList err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "获取aps项目列表失败")
        return
    }
    ctx.OkWithDetailed(projectList.List)
@@ -354,7 +355,7 @@
        ProductList: wmsProducts,
    })
    if err != nil {
        logx.Errorf("CreateOperation err: %v", err.Error())
        logx.Errorf("grpc CreateOperation err: %v", err.Error())
    }
    //推送到aps
@@ -384,7 +385,8 @@
        //状态还原
        m["status"] = constvar.WaitConfirmed
        _ = model.NewSalesDetailsSearch().SetNumber(params.Number).UpdateByMap(m)
        ctx.FailWithMsg(ecode.UnknownErr, "grpc调用错误: "+err.Error())
        logx.Errorf("grpc SendSalesDetailsToApsProject err: %v", err.Error())
        ctx.FailWithMsg(ecode.UnknownErr, "推送失败,请检查参数是否正确")
        return
    }
    ctx.Ok()