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
}