package crm_srm
|
|
import (
|
"context"
|
"errors"
|
"srm/global"
|
"srm/model/purchase"
|
)
|
|
type Server struct {
|
UnimplementedCrmAndSrmServiceServer
|
}
|
|
func (s *Server) CrmGetPurchaseInfo(ctx context.Context, req *CrmGetPurchaseInfoRequest) (*CrmGetPurchaseInfoResponse, error) {
|
if req.SalesDetailsNumber == "" {
|
return nil, errors.New("采购单编码不能为空")
|
}
|
var ps purchase.Purchase
|
err := global.GVA_DB.Model(&purchase.Purchase{}).Where("source_order = ?", req.SalesDetailsNumber).Preload("Supplier").First(&ps).Error
|
if err != nil {
|
return nil, err
|
}
|
pps := make([]*purchase.PurchaseProducts, 0)
|
err = global.GVA_DB.Model(&purchase.PurchaseProducts{}).Where("purchase_id = ?", ps.ID).Preload("Product").Find(&pps).Error
|
if err != nil {
|
return nil, err
|
}
|
info := make([]*CrmGetPurchaseInfo, 0)
|
flag := false
|
if ps.Status == purchase.OrderStatusStored || ps.Status == purchase.OrderStatusCompleted {
|
flag = true
|
}
|
for _, pp := range pps {
|
var cgpi CrmGetPurchaseInfo
|
cgpi.ProductId = pp.Product.Number
|
cgpi.Amount = pp.Amount.IntPart()
|
if flag {
|
cgpi.FinishAmount = cgpi.Amount
|
}
|
info = append(info, &cgpi)
|
}
|
resp := new(CrmGetPurchaseInfoResponse)
|
resp.Info = info
|
return resp, nil
|
}
|
