Added calculated_at updating for signals_phone_fid_map

This commit is contained in:
Mikhail Trofimov 2025-06-25 12:12:05 +03:00
parent 389eeb4356
commit 7f9d682ece
3 changed files with 4 additions and 3 deletions

View file

@ -26,7 +26,7 @@ public interface SignalMapper {
void insertPackage(@Param("request") MonitoringRequest request, @Param("creadedAt") LocalDateTime creadedAt, @Param("status") String status); void insertPackage(@Param("request") MonitoringRequest request, @Param("creadedAt") LocalDateTime creadedAt, @Param("status") String status);
void registerSubjectsFidAndDebts(@Param("id") Integer id, @Param("fid") Integer fid, @Param("flagDebt5000") Integer flagDebt5000, @Param("flag90") Integer flag90); void registerSubjectsFidAndDebts(@Param("id") Integer id, @Param("fid") Integer fid, @Param("flagDebt5000") Integer flagDebt5000, @Param("flag90") Integer flag90, @Param("calculatedAt") LocalDateTime calculatedAt);
void setPackageStatus(@Param("packageId") Integer packageId, @Param("status") String status); void setPackageStatus(@Param("packageId") Integer packageId, @Param("status") String status);

View file

@ -64,9 +64,10 @@ public class SignalService {
public List<PhoneService.FidsPhoneData> registerSubjectsFidAndDebts(Integer packageId) { public List<PhoneService.FidsPhoneData> registerSubjectsFidAndDebts(Integer packageId) {
List<SubjectData> subjects = mapper.findSubjectsData(packageId); List<SubjectData> subjects = mapper.findSubjectsData(packageId);
List<PhoneService.FidsPhoneData> fidsPhoneDataList = phoneService.findFidsPhoneData(subjects); List<PhoneService.FidsPhoneData> fidsPhoneDataList = phoneService.findFidsPhoneData(subjects);
LocalDateTime calculatedAt = LocalDateTime.now();
fidsPhoneDataList.forEach(phoneData -> { fidsPhoneDataList.forEach(phoneData -> {
FlagsService.FlagsFidData flagsData = flagsService.findFlags(phoneData.getFid()); FlagsService.FlagsFidData flagsData = flagsService.findFlags(phoneData.getFid());
mapper.registerSubjectsFidAndDebts(phoneData.getId(), phoneData.getFid(), flagsData.getFlagDebt5000(), flagsData.getFlag90days()); mapper.registerSubjectsFidAndDebts(phoneData.getId(), phoneData.getFid(), flagsData.getFlagDebt5000(), flagsData.getFlag90days(), calculatedAt);
}); });
return fidsPhoneDataList; return fidsPhoneDataList;

View file

@ -72,7 +72,7 @@
<update id="registerSubjectsFidAndDebts"> <update id="registerSubjectsFidAndDebts">
UPDATE signals_phone_fid_map UPDATE signals_phone_fid_map
SET fid = #{fid}, flag_debt5000 = #{flagDebt5000}, flag_90_12 = #{flag90} SET fid = #{fid}, flag_debt5000 = #{flagDebt5000}, flag_90_12 = #{flag90}, calculated_at = #{calculatedAt}
WHERE id = #{id} WHERE id = #{id}
</update> </update>