This commit is contained in:
parent
995a97a69c
commit
8475bb5f37
6 changed files with 21 additions and 18 deletions
|
|
@ -98,17 +98,6 @@ public class PersonFactoryBuilderV2 {
|
||||||
} else {
|
} else {
|
||||||
return switch (idType) {
|
return switch (idType) {
|
||||||
case "21" -> "21";
|
case "21" -> "21";
|
||||||
case "22" -> "22.1";
|
|
||||||
case "09" -> "22.2";
|
|
||||||
case "26" -> "23";
|
|
||||||
case "04" -> "24";
|
|
||||||
case "07" -> "25";
|
|
||||||
case "14", "03" -> "27";
|
|
||||||
case "10" -> "31";
|
|
||||||
case "15" -> "32";
|
|
||||||
case "13" -> "37";
|
|
||||||
case "06", "27" -> "28";
|
|
||||||
case "01", "02" -> "999";
|
|
||||||
default -> {
|
default -> {
|
||||||
log.warn("ID_TYPE2 is blank and no matching found for ID_TYPE {}", idType);
|
log.warn("ID_TYPE2 is blank and no matching found for ID_TYPE {}", idType);
|
||||||
yield "";
|
yield "";
|
||||||
|
|
|
||||||
|
|
@ -70,6 +70,9 @@ public class MonitoringRequestValidator {
|
||||||
request -> {
|
request -> {
|
||||||
try {
|
try {
|
||||||
validationService.validateMonitoringRequest(request);
|
validationService.validateMonitoringRequest(request);
|
||||||
|
} catch (SignalException e) {
|
||||||
|
validationResult.addError(new MonitoringValidationError(-1, "", e));
|
||||||
|
} finally {
|
||||||
if (request.getPackageName() != null && validationResult.getPackageName() == null) {
|
if (request.getPackageName() != null && validationResult.getPackageName() == null) {
|
||||||
validationResult.setPackageName(request.getPackageName());
|
validationResult.setPackageName(request.getPackageName());
|
||||||
}
|
}
|
||||||
|
|
@ -83,9 +86,6 @@ public class MonitoringRequestValidator {
|
||||||
&& validationResult.getSignalTypes().isEmpty()) {
|
&& validationResult.getSignalTypes().isEmpty()) {
|
||||||
validationResult.setSignalTypes(request.getSignalTypes());
|
validationResult.setSignalTypes(request.getSignalTypes());
|
||||||
}
|
}
|
||||||
request.getSubjects().getSubject().clear();
|
|
||||||
} catch (SignalException e) {
|
|
||||||
validationResult.addError(new MonitoringValidationError(-1, "", e));
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
request -> request.getSubjects().getSubject().isEmpty(),
|
request -> request.getSubjects().getSubject().isEmpty(),
|
||||||
|
|
|
||||||
|
|
@ -116,6 +116,12 @@ public class PipelinePackageOrchestrator {
|
||||||
log.error(ExceptionUtils.getStackTrace(e));
|
log.error(ExceptionUtils.getStackTrace(e));
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
if (res.signalXmlFilePath() == null) {
|
||||||
|
log.info("No one fid was found by packageId : {}; xml file won't be sent", packageId);
|
||||||
|
userPackageMapper.updatePackageOnMonitoringSuccess(packageId, LocalDateTime.now());
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
userPackageMapper.setLastSearchedDt(packageId);
|
userPackageMapper.setLastSearchedDt(packageId);
|
||||||
log.trace("Signal file by path: {} is completed", res.signalXmlFilePath());
|
log.trace("Signal file by path: {} is completed", res.signalXmlFilePath());
|
||||||
boolean success = signalRestService.setupMonitoring(res.signalXmlFilePath());
|
boolean success = signalRestService.setupMonitoring(res.signalXmlFilePath());
|
||||||
|
|
|
||||||
|
|
@ -83,6 +83,9 @@ public class FidIdEnricher implements Handler<SubjectPayload, PartFilePayload> {
|
||||||
packageRecordsService.updateIdCache(idCacheOnUpdate);
|
packageRecordsService.updateIdCache(idCacheOnUpdate);
|
||||||
log.debug("personOnProcessing size: {}", personOnProcessing.size());
|
log.debug("personOnProcessing size: {}", personOnProcessing.size());
|
||||||
Long packageId = taskPayload.getPackageId();
|
Long packageId = taskPayload.getPackageId();
|
||||||
|
if (personOnProcessing.isEmpty()) {
|
||||||
|
return new PartFilePayload(null, packageId, taskPayload.getMemberCode(), taskPayload.getPackageName());
|
||||||
|
}
|
||||||
Path partPath = writeSignals(personOnProcessing, taskPayload);
|
Path partPath = writeSignals(personOnProcessing, taskPayload);
|
||||||
return new PartFilePayload(partPath, packageId, taskPayload.getMemberCode(), taskPayload.getPackageName());
|
return new PartFilePayload(partPath, packageId, taskPayload.getMemberCode(), taskPayload.getPackageName());
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -74,7 +74,9 @@ public class FidNameEnricher implements Handler<SubjectPayload, SubjectPayload>
|
||||||
cacheMisses.incrementAndGet();
|
cacheMisses.incrementAndGet();
|
||||||
Name name = nameByPhone.get(CTUtil.normalizePhoneNumber(phone.toString()));
|
Name name = nameByPhone.get(CTUtil.normalizePhoneNumber(phone.toString()));
|
||||||
if (name == null) {
|
if (name == null) {
|
||||||
return Stream.empty();
|
return Stream.of(PhonesMap.builder()
|
||||||
|
.phone(phone)
|
||||||
|
.build());
|
||||||
}
|
}
|
||||||
fillByName(subject, name);
|
fillByName(subject, name);
|
||||||
return Stream.of(PhonesMap.builder()
|
return Stream.of(PhonesMap.builder()
|
||||||
|
|
|
||||||
|
|
@ -55,6 +55,7 @@
|
||||||
<foreach item="phone" collection="phones" open="(" separator="," close=")">
|
<foreach item="phone" collection="phones" open="(" separator="," close=")">
|
||||||
#{phone}
|
#{phone}
|
||||||
</foreach>
|
</foreach>
|
||||||
|
and fid is not null
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<select id="registerJson" parameterType="string">
|
<select id="registerJson" parameterType="string">
|
||||||
|
|
@ -75,13 +76,14 @@
|
||||||
))
|
))
|
||||||
INSERT
|
INSERT
|
||||||
INTO signals_phones_map
|
INTO signals_phones_map
|
||||||
(fid, phone, name_1, first, middle, birth_dt)
|
(fid, phone, name_1, first, middle, birth_dt, searched_at)
|
||||||
SELECT fid,
|
SELECT fid,
|
||||||
phone,
|
phone,
|
||||||
name_1,
|
name_1,
|
||||||
first,
|
first,
|
||||||
middle,
|
middle,
|
||||||
birth_dt
|
birth_dt,
|
||||||
|
now()
|
||||||
FROM src
|
FROM src
|
||||||
ON CONFLICT (phone) DO UPDATE
|
ON CONFLICT (phone) DO UPDATE
|
||||||
SET fid = EXCLUDED.fid,
|
SET fid = EXCLUDED.fid,
|
||||||
|
|
@ -107,7 +109,8 @@
|
||||||
<update id="updateFlagCachedData" parameterType="string">
|
<update id="updateFlagCachedData" parameterType="string">
|
||||||
update signals_phones_map dst
|
update signals_phones_map dst
|
||||||
set flag_debt5000 = src.flag_debt5000,
|
set flag_debt5000 = src.flag_debt5000,
|
||||||
flag_90_12 = src.flag_90_12
|
flag_90_12 = src.flag_90_12,
|
||||||
|
calculated_at = now()
|
||||||
FROM json_to_recordset(#{json}::json) AS src(
|
FROM json_to_recordset(#{json}::json) AS src(
|
||||||
phone bigint,
|
phone bigint,
|
||||||
flag_debt5000 smallint,
|
flag_debt5000 smallint,
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue