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"
)

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(busId int64) (contactList []*projModel.BusinessContact, err error) {
	err = p.Dao.As("bus").LeftJoin(custDao.CustCustomerContact.Table, "contact", "bus.contact_id=contact.id").
		Where(p.Dao.Columns.BusId, busId).Fields("bus.id AS id, bus.*, contact.*").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
}