This commit is contained in:
parent
4994af50bd
commit
c32d430483
3 changed files with 16 additions and 10 deletions
|
|
@ -49,15 +49,17 @@ public class FidNameUpdater implements Handler<SubjectPayload, SubjectPayload> {
|
|||
List<Long> notFoundFidPhones = new ArrayList<>();
|
||||
subjects.forEach(subjectProfile -> {
|
||||
Name name = nameByPhone.get(CTUtil.normalizePhoneNumber(subjectProfile.getPhone()));
|
||||
if (subjectProfile.getFid() == null && name == null) {
|
||||
if (name != null) {
|
||||
if (subjectProfile.getFid() == null || !subjectProfile.getFid().equals(name.getFid())) {
|
||||
subjectProfile.setFid(name.getFid());
|
||||
subjectProfile.getNameData().setFirstName(name.getFirst());
|
||||
subjectProfile.getNameData().setLastName(name.getLast());
|
||||
subjectProfile.getNameData().setMiddleName(name.getMiddle());
|
||||
subjectProfile.getNameData().setBirthDate(name.getBirthDate());
|
||||
changingFidPhones.add(subjectProfile);
|
||||
}
|
||||
} else if (subjectProfile.getFid() != null) {
|
||||
notFoundFidPhones.add(subjectProfile.getPhone());
|
||||
} else if (subjectProfile.getFid() == null || !subjectProfile.getFid().equals(name.getFid())) {
|
||||
subjectProfile.setFid(name.getFid());
|
||||
subjectProfile.getNameData().setFirstName(name.getFirst());
|
||||
subjectProfile.getNameData().setLastName(name.getLast());
|
||||
subjectProfile.getNameData().setMiddleName(name.getMiddle());
|
||||
subjectProfile.getNameData().setBirthDate(name.getBirthDate());
|
||||
changingFidPhones.add(subjectProfile);
|
||||
}
|
||||
});
|
||||
List<Long> changingFids = new ArrayList<>();
|
||||
|
|
|
|||
|
|
@ -28,7 +28,10 @@
|
|||
FROM json_to_recordset(#{json}::json) AS t(
|
||||
phone bigint
|
||||
))
|
||||
select distinct (package_id) from signals_packages_records where phone_l in (select * from src)
|
||||
select distinct (package_id)
|
||||
from signals_packages_records spr
|
||||
join signals_user_packages sup on sup.id = spr.package_id
|
||||
where spr.phone_l in (select * from src) and sup.status = 'ON_MONITORING'
|
||||
</select>
|
||||
|
||||
<select id="registerJson" parameterType="string" resultType="long">
|
||||
|
|
|
|||
|
|
@ -194,7 +194,8 @@
|
|||
id_type = null,
|
||||
flag_debt5000 = null,
|
||||
flag_90_12 = null,
|
||||
calculated_at = null
|
||||
calculated_at = null,
|
||||
searched_at = now()
|
||||
FROM json_to_recordset(#{json}::json) AS src(
|
||||
phone bigint)
|
||||
where dst.phone = src.phone
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue