micord/ervu-business-metrics
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-9212: фикс

Browse source
This commit is contained in:
adel.kalimullin 2025-06-10 16:31:44 +03:00
parent 579ef5d713
commit 0f2588e7cc
10 changed files with 30 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
backend/src/main/java/ervu_business_metrics/dao/AccountDataDao.java
View file

@ -2,8 +2,10 @@ package ervu_business_metrics.dao;
import java.util.List; import java.util.List;
import ervu_business_metrics.config.KafkaEnabledCondition;
import org.jooq.DSLContext; import org.jooq.DSLContext;
import org.jooq.Table; import org.jooq.Table;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRecord;
@ -13,6 +15,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Repository @Repository
@Conditional(KafkaEnabledCondition.class)
public class AccountDataDao extends AbstractDataDao<AccountRecord> { public class AccountDataDao extends AbstractDataDao<AccountRecord> {
protected AccountDataDao(DSLContext dsl) { protected AccountDataDao(DSLContext dsl) {

3
backend/src/main/java/ervu_business_metrics/dao/AccountRoleDataDao.java
View file

@ -4,9 +4,11 @@ package ervu_business_metrics.dao;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import ervu_business_metrics.config.KafkaEnabledCondition;
import org.jooq.DSLContext; import org.jooq.DSLContext;
import org.jooq.Field; import org.jooq.Field;
import org.jooq.Table; import org.jooq.Table;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRoleRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRoleRecord;
@ -16,6 +18,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Repository @Repository
@Conditional(KafkaEnabledCondition.class)
public class AccountRoleDataDao extends AbstractDataDao<AccountRoleRecord> { public class AccountRoleDataDao extends AbstractDataDao<AccountRoleRecord> {
protected AccountRoleDataDao(DSLContext dsl) { protected AccountRoleDataDao(DSLContext dsl) {

3
backend/src/main/java/ervu_business_metrics/dao/DomainDataDao.java
View file

@ -1,8 +1,10 @@
package ervu_business_metrics.dao; package ervu_business_metrics.dao;
import ervu_business_metrics.config.KafkaEnabledCondition;
import org.jooq.DSLContext; import org.jooq.DSLContext;
import org.jooq.Table; import org.jooq.Table;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.DomainRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.DomainRecord;
@ -11,6 +13,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Repository @Repository
@Conditional(KafkaEnabledCondition.class)
public class DomainDataDao extends AbstractDataDao<DomainRecord> { public class DomainDataDao extends AbstractDataDao<DomainRecord> {
protected DomainDataDao(DSLContext dsl) { protected DomainDataDao(DSLContext dsl) {

3
backend/src/main/java/ervu_business_metrics/dao/PersonDataDao.java
View file

@ -1,7 +1,9 @@
package ervu_business_metrics.dao; package ervu_business_metrics.dao;
import ervu_business_metrics.config.KafkaEnabledCondition;
import org.jooq.DSLContext; import org.jooq.DSLContext;
import org.jooq.Table; import org.jooq.Table;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.PersonRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.PersonRecord;
@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Repository @Repository
@Conditional(KafkaEnabledCondition.class)
public class PersonDataDao extends AbstractDataDao<PersonRecord> { public class PersonDataDao extends AbstractDataDao<PersonRecord> {
protected PersonDataDao(DSLContext dsl) { protected PersonDataDao(DSLContext dsl) {

3
backend/src/main/java/ervu_business_metrics/dao/RoleDataDao.java
View file

@ -1,7 +1,9 @@
package ervu_business_metrics.dao; package ervu_business_metrics.dao;
import ervu_business_metrics.config.KafkaEnabledCondition;
import org.jooq.DSLContext; import org.jooq.DSLContext;
import org.jooq.Table; import org.jooq.Table;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.Tables;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.RoleRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.RoleRecord;
@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Repository @Repository
@Conditional(KafkaEnabledCondition.class)
public class RoleDataDao extends AbstractDataDao<RoleRecord> { public class RoleDataDao extends AbstractDataDao<RoleRecord> {
protected RoleDataDao(DSLContext dsl) { protected RoleDataDao(DSLContext dsl) {

3
backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
View file

@ -5,10 +5,12 @@ import java.util.HashSet;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
import ervu_business_metrics.config.KafkaEnabledCondition;
import ervu_business_metrics.dao.AccountDataDao; import ervu_business_metrics.dao.AccountDataDao;
import ervu_business_metrics.model.ReferenceEntity; import ervu_business_metrics.model.ReferenceEntity;
import ervu_business_metrics.model.idm.AccountData; import ervu_business_metrics.model.idm.AccountData;
import ervu_business_metrics.service.processor.DataProcessor; import ervu_business_metrics.service.processor.DataProcessor;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRecord;
@ -17,6 +19,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Component @Component
@Conditional(KafkaEnabledCondition.class)
public class AccountDataProcessor implements DataProcessor<AccountData, AccountRecord> { public class AccountDataProcessor implements DataProcessor<AccountData, AccountRecord> {
private final AccountDataDao dao; private final AccountDataDao dao;
private final AccountRoleDataProcessor accountRoleDataProcessor; private final AccountRoleDataProcessor accountRoleDataProcessor;

3
backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountRoleDataProcessor.java
View file

@ -5,11 +5,13 @@ import java.util.List;
import java.util.Set; import java.util.Set;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import ervu_business_metrics.config.KafkaEnabledCondition;
import ervu_business_metrics.dao.AccountRoleDataDao; import ervu_business_metrics.dao.AccountRoleDataDao;
import ervu_business_metrics.model.idm.AccountData; import ervu_business_metrics.model.idm.AccountData;
import ervu_business_metrics.model.idm.AccountRoleData; import ervu_business_metrics.model.idm.AccountRoleData;
import ervu_business_metrics.model.idm.RoleData; import ervu_business_metrics.model.idm.RoleData;
import ervu_business_metrics.service.processor.LinkDataProcessor; import ervu_business_metrics.service.processor.LinkDataProcessor;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRoleRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.AccountRoleRecord;
@ -17,6 +19,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Component @Component
@Conditional(KafkaEnabledCondition.class)
public class AccountRoleDataProcessor public class AccountRoleDataProcessor
implements LinkDataProcessor<AccountRoleData, AccountRoleRecord> { implements LinkDataProcessor<AccountRoleData, AccountRoleRecord> {
private final AccountRoleDataDao dao; private final AccountRoleDataDao dao;

3
backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
View file

@ -1,8 +1,10 @@
package ervu_business_metrics.service.processor.impl; package ervu_business_metrics.service.processor.impl;
import ervu_business_metrics.config.KafkaEnabledCondition;
import ervu_business_metrics.dao.DomainDataDao; import ervu_business_metrics.dao.DomainDataDao;
import ervu_business_metrics.model.idm.DomainData; import ervu_business_metrics.model.idm.DomainData;
import ervu_business_metrics.service.processor.DataProcessor; import ervu_business_metrics.service.processor.DataProcessor;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.DomainRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.DomainRecord;
@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Component @Component
@Conditional(KafkaEnabledCondition.class)
public class DomainDataProcessor implements DataProcessor<DomainData, DomainRecord> { public class DomainDataProcessor implements DataProcessor<DomainData, DomainRecord> {
private final DomainDataDao dao; private final DomainDataDao dao;

3
backend/src/main/java/ervu_business_metrics/service/processor/impl/PersonDataProcessor.java
View file

@ -1,8 +1,10 @@
package ervu_business_metrics.service.processor.impl; package ervu_business_metrics.service.processor.impl;
import ervu_business_metrics.config.KafkaEnabledCondition;
import ervu_business_metrics.dao.PersonDataDao; import ervu_business_metrics.dao.PersonDataDao;
import ervu_business_metrics.model.idm.PersonData; import ervu_business_metrics.model.idm.PersonData;
import ervu_business_metrics.service.processor.DataProcessor; import ervu_business_metrics.service.processor.DataProcessor;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.PersonRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.PersonRecord;
@ -10,6 +12,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Component @Component
@Conditional(KafkaEnabledCondition.class)
public class PersonDataProcessor implements DataProcessor<PersonData, PersonRecord> { public class PersonDataProcessor implements DataProcessor<PersonData, PersonRecord> {
private final PersonDataDao dao; private final PersonDataDao dao;
private final AccountDataProcessor accountDataProcessor; private final AccountDataProcessor accountDataProcessor;

3
backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
View file

@ -1,9 +1,11 @@
package ervu_business_metrics.service.processor.impl; package ervu_business_metrics.service.processor.impl;
import ervu_business_metrics.config.KafkaEnabledCondition;
import ervu_business_metrics.dao.RoleDataDao; import ervu_business_metrics.dao.RoleDataDao;
import ervu_business_metrics.model.idm.RoleData; import ervu_business_metrics.model.idm.RoleData;
import ervu_business_metrics.service.processor.DataProcessor; import ervu_business_metrics.service.processor.DataProcessor;
import org.springframework.context.annotation.Conditional;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.RoleRecord; import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.records.RoleRecord;
@ -11,6 +13,7 @@ import ru.micord.webbpm.ervu.business_metrics.db_beans.idm_reconcile.tables.reco
* @author Adel Kalimullin * @author Adel Kalimullin
*/ */
@Component @Component
@Conditional(KafkaEnabledCondition.class)
public class RoleDataProcessor implements DataProcessor<RoleData, RoleRecord> { public class RoleDataProcessor implements DataProcessor<RoleData, RoleRecord> {
private final RoleDataDao dao; private final RoleDataDao dao;