...
|
...
|
@@ -31,7 +31,11 @@ func (subscriber *MmmOpenApiServiceServiceSubscriber) HandleEvent(domainEvent co |
|
|
employeeRepository = repository
|
|
|
}
|
|
|
uids := make([]int64, 0)
|
|
|
if _, employees, err := employeeRepository.Find(map[string]interface{}{"companyId": taskReleasedEvent.CompanyId}); err != nil {
|
|
|
if _, employees, err := employeeRepository.Find(map[string]interface{}{
|
|
|
"companyId": taskReleasedEvent.CompanyId,
|
|
|
"offset": 0,
|
|
|
"limit": 0,
|
|
|
}); err != nil {
|
|
|
fmt.Println(err.Error())
|
|
|
return nil
|
|
|
} else {
|
...
|
...
|
|