treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/BKI-3241

Browse source
This commit is contained in:
etreschenkov 2026-02-12 16:09:08 +03:00
parent 06370d4aa7
commit 5e984bd628
4 changed files with 1 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pom.xml
View file

@ -10,7 +10,7 @@
</parent> </parent>
<groupId>ru.nbch</groupId> <groupId>ru.nbch</groupId>
<artifactId>credit-tracker</artifactId> <artifactId>credit-tracker</artifactId>
<version>2.21.4</version> <version>2.21.5</version>
<name>credit_tracker</name> <name>credit_tracker</name>
<description>Credit Tracker Application</description> <description>Credit Tracker Application</description>

2
src/main/java/ru/nbch/credit_tracker/mapper/signal/UserPackageMapper.java
View file

@ -21,7 +21,6 @@ public interface UserPackageMapper {
void updatePackageOnMonitoringSuccess(@Param("id") Long id, @Param("monitoringAt") LocalDateTime monitoringAt); void updatePackageOnMonitoringSuccess(@Param("id") Long id, @Param("monitoringAt") LocalDateTime monitoringAt);
void updateNoFidMonitoring(@Param("id") Long id); void updateNoFidMonitoring(@Param("id") Long id);
void setLastSearchedDt(@Param("id") Long id);
void setFidChanged(@Param("packageIds") List<Long> id); void setFidChanged(@Param("packageIds") List<Long> id);
UserPackage findPackage(@Param("id") Long id); UserPackage findPackage(@Param("id") Long id);
@ -38,5 +37,4 @@ public interface UserPackageMapper {
@Param("packageName") String packageName); @Param("packageName") String packageName);
void setRejectedStatus(@Param("id") Long id, @Param("status") String status); void setRejectedStatus(@Param("id") Long id, @Param("status") String status);
boolean hasOldRow(@Param("packageId") Long packageId, @Param("daysCount") Integer daysCount);
} }

1
src/main/java/ru/nbch/credit_tracker/service/task/PipelinePackageOrchestrator.java
View file

@ -122,7 +122,6 @@ public class PipelinePackageOrchestrator {
return; return;
} }
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());
if (success) { if (success) {

22
src/main/resources/mybatis/mapper/signal/UserPackageMapper.xml
View file

@ -101,12 +101,6 @@
WHERE id = #{id} WHERE id = #{id}
</update> </update>
<update id="setLastSearchedDt">
UPDATE signals_user_packages
SET last_searched_at = now()
WHERE id = #{id}
</update>
<update id="setRejectedStatus"> <update id="setRejectedStatus">
UPDATE signals_user_packages UPDATE signals_user_packages
SET reject_status = #{status} SET reject_status = #{status}
@ -122,7 +116,6 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
@ -139,7 +132,6 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
@ -156,7 +148,6 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
@ -172,7 +163,6 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
@ -189,7 +179,6 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
@ -210,7 +199,6 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
@ -227,7 +215,6 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
@ -246,19 +233,10 @@
deactivated_at, deactivated_at,
last_downloaded_report, last_downloaded_report,
monitoring_at, monitoring_at,
last_searched_at,
reject_status, reject_status,
signal_types signal_types
FROM signals_user_packages FROM signals_user_packages
WHERE LEFT(membercode, 6) = #{memberCode} AND package_name = #{packageName} WHERE LEFT(membercode, 6) = #{memberCode} AND package_name = #{packageName}
</select> </select>
<select id="hasOldRow" resultType="java.lang.Boolean">
select EXISTS(SELECT 1
FROM signals_user_packages
WHERE id = #{packageId}
AND last_searched_at &lt; now() - make_interval(days => #{daysCount})
)
</select>
</mapper> </mapper>