package proj

import (
	"context"
	custDao "dashoo.cn/micro/app/dao/cust"
	projDao "dashoo.cn/micro/app/dao/proj"
	projModel "dashoo.cn/micro/app/model/proj"
	"dashoo.cn/micro/app/service"
	"github.com/gogf/gf/frame/g"
)

type businessContactService struct {
	*service.ContextService
	Dao *projDao.ProjBusinessContactDao
}

func NewBusinessContactService(ctx context.Context) (svc *businessContactService, err error) {
	svc = new(businessContactService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = projDao.NewProjBusinessContactDao(svc.Tenant)
	return svc, nil
}

func (p *businessContactService) GetList(req *projModel.BusinessReq) (total int, contactList []*projModel.BusinessContact, err error) {
	db := p.Dao.As("bus").LeftJoin(custDao.CustCustomerContact.Table, "contact", "bus.contact_id=contact.id").
		Where("bus."+p.Dao.Columns.BusId, req.BusId)
	if req.CuctId != 0 {
		db = db.Where("contact.cuct_id", req.CuctId)
	}
	if req.CuctName != "" {
		db = db.Where("contact.cuct_name", req.BusId)
	}
	total, err = db.Count()
	if err != nil {
		g.Log().Error(err)
		return
	}

	err = db.Fields("bus.id AS id, bus.*, contact.*").Page(req.GetPage()).Order("bus.id desc").Scan(&contactList)
	return
}

func (p *businessContactService) Create(req *projModel.BusinessContactReq) (err error) {
	contactList := make([]*projModel.ProjBusinessContact, 0)
	for _, v := range req.ContactIds {
		data := new(projModel.ProjBusinessContact)
		data.BusId = req.BusId
		data.ContactId = v
		data.Remark = req.Remark
		service.SetCreatedInfo(data, p.GetCxtUserId(), p.GetCxtUserName())
		contactList = append(contactList, data)
	}
	_, err = p.Dao.Insert(&contactList)
	return
}

func (p *businessContactService) DeleteByIds(ids []int64) (err error) {
	_, err = p.Dao.WhereIn(projDao.ProjBusinessContact.Columns.Id, ids).Delete()
	return
}