package crm_aps

import (
	"aps_crm/constvar"
	"aps_crm/model"
	"aps_crm/model/grpc_init"
	"context"
	"github.com/shopspring/decimal"
)

type Server struct {
	UnimplementedCrmAndApsGrpcServiceServer
}

func (s *Server) GetCrmSalesDetailsList(ctx context.Context, req *GetCrmSalesDetailsListRequest) (*GetCrmSalesDetailsListResponse, error) {
	search := model.NewSalesDetailsSearch().Orm.Model(model.SalesDetails{})
	if req.StartTime != "" && req.EndTime != "" {
		if req.TimeType == "签约日期" {
			search = search.Where("sign_time between ? and ?", req.StartTime, req.EndTime)
		} else if req.TimeType == "交付日期" {
			search = search.Where("delivery_date between ? and ?", req.StartTime, req.EndTime)
		}
	}
	if req.ClientName != "" {
		search = search.Joins("Client", "LEFT").Where("Client.name like ?", "%"+req.ClientName+"%")
	}
	search = search.Preload("Member").Preload("Client").Where("status = ?", constvar.WaitConfirmed).Where("project_id = ?", "")

	var records = make([]*model.SalesDetails, 0)
	var total int64
	err := search.Count(&total).Error
	if err != nil {
		return nil, err
	}
	if req.Page*req.PageSize > 0 {
		search = search.Limit(int(req.PageSize)).Offset(int((req.Page - 1) * req.PageSize))
	}
	err = search.Order("id desc").Find(&records).Error
	if err != nil {
		return nil, err
	}
	sds := make([]*CrmSalesDetails, 0)
	for _, record := range records {
		var sd CrmSalesDetails
		sd.Number = record.Number
		sd.ClientName = record.Client.Name
		sd.MemberName = record.Member.Username
		sd.SignTime = record.SignTime
		sd.DeliveryDate = record.DeliveryDate
		sds = append(sds, &sd)
	}
	resp := new(GetCrmSalesDetailsListResponse)
	resp.SalesDetails = sds
	resp.Total = total
	return resp, nil
}

func (s *Server) SendSalesDetailsAndProjectToCrm(ctx context.Context, req *SendSalesDetailsAndProjectToCrmRequest) (*SendSalesDetailsAndProjectToCrmResponse, error) {
	details, err := model.NewSalesDetailsSearch().SetNumbers(req.SalesDetailsNumbers).SetPreload(true).FindNotTotal()
	if err != nil {
		return nil, err
	}
	for _, detail := range details {
		m := make(map[string]interface{})
		m["status"] = constvar.WaitOutbound
		m["project_id"] = req.ProjectId

		err := model.NewSalesDetailsSearch().SetNumber(detail.Number).UpdateByMap(m)
		if err != nil {
			return nil, err
		}

		products := make([]*SalesDetailsProduct, 0)
		var total decimal.Decimal
		for _, product := range detail.Products {
			var sp SalesDetailsProduct
			sp.ProductId = product.Number
			sp.Amount = product.Amount.IntPart()
			products = append(products, &sp)
			total = total.Add(product.Amount)
		}

		client := NewCrmAndApsGrpcServiceClient(grpc_init.CrmApsGrpcServiceConn)
		_, err = client.SendSalesDetailsToApsProject(ctx, &SendSalesDetailsToApsProjectRequest{
			Number:       detail.Number,
			ClientName:   detail.Client.Name,
			MemberName:   detail.Member.Username,
			SignTime:     detail.SignTime,
			DeliveryDate: detail.DeliveryDate,
			Source:       detail.Source,
			ProductTotal: total.IntPart(),
			ProjectId:    req.ProjectId,
			Products:     products,
		})
		if err != nil {
			return nil, err
		}
	}
	return new(SendSalesDetailsAndProjectToCrmResponse), nil
}