diff --git a/anrui-fin/anrui-fin-api/src/main/java/com/yxt/anrui/fin/api/fintemptimepush/FinTempTimePushFeign.java b/anrui-fin/anrui-fin-api/src/main/java/com/yxt/anrui/fin/api/fintemptimepush/FinTempTimePushFeign.java index 1770b28628..af12b98bd3 100644 --- a/anrui-fin/anrui-fin-api/src/main/java/com/yxt/anrui/fin/api/fintemptimepush/FinTempTimePushFeign.java +++ b/anrui-fin/anrui-fin-api/src/main/java/com/yxt/anrui/fin/api/fintemptimepush/FinTempTimePushFeign.java @@ -18,6 +18,8 @@ public interface FinTempTimePushFeign { @PostMapping("/save") public ResultBean save(@RequestBody FinTempTimePushDto dto); - + @ApiOperation("测试推送凭证") + @PostMapping("/test") + public void test(); } diff --git a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.java b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.java index 8e3d756085..fcb241afec 100644 --- a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.java +++ b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.java @@ -37,4 +37,7 @@ public interface FinTempTimePushMapper extends BaseMapper { List selListByBusType(@Param("busType") String busType); + + + void delBySid(@Param("sid") String sid); } \ No newline at end of file diff --git a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.xml b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.xml index 7a5bd7acdf..2ec038b322 100644 --- a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.xml +++ b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushMapper.xml @@ -1,6 +1,10 @@ + + DELETE FROM fin_temp_time_push + WHERE sid =#{sid} + diff --git a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushRest.java b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushRest.java index 679b5ac352..6ba724668b 100644 --- a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushRest.java +++ b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushRest.java @@ -41,8 +41,16 @@ public class FinTempTimePushRest implements FinTempTimePushFeign { @Autowired private FinTempTimePushService finTempTimePushService; + + @Autowired + private TimingPushService timingPushService; @Override public ResultBean save(FinTempTimePushDto dto) { return finTempTimePushService.saveEntity(dto); } + + @Override + public void test() { + timingPushService.monthlyAccrualVoucher(); + } } diff --git a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushService.java b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushService.java index 94d7a0864d..56a1084deb 100644 --- a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushService.java +++ b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/FinTempTimePushService.java @@ -49,4 +49,8 @@ public class FinTempTimePushService extends MybatisBaseService selListByBusType(String busType) { return baseMapper.selListByBusType(busType); } + + public void delBySid(String sid) { + baseMapper.delBySid(sid); + } } \ No newline at end of file diff --git a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/TimingPushService.java b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/TimingPushService.java index 7d50a25c99..6240775521 100644 --- a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/TimingPushService.java +++ b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fintemptimepush/TimingPushService.java @@ -25,17 +25,16 @@ public class TimingPushService { /** * 定时推送月还计提凭证 */ -// @Scheduled(cron = "0 0 3 2,3,4,5,6,7,8,9,10 * ?") //每月2-10号 3点推送 - @Scheduled(cron = "0 0/3 * * * ?") //每月2-10号 3点推送 + @Scheduled(cron = "0 0 3 2,3,4,5,6,7,8,9,10 * ?") //每月2-10号 3点推送 +// @Scheduled(cron = "0 0/3 * * * ?") //每3分钟推送 public void monthlyAccrualVoucher() { List list = finTempTimePushService.selListByBusType("月还计提"); list.removeAll(Collections.singleton(null)); if (!list.isEmpty()) { for (FinTempTimePush f : list) { loanMonthlyAccrualApplyFeign.rePushVoucher(f.getBusSid()); - finTempTimePushService.deleteBySid(f.getSid()); + finTempTimePushService.delBySid(f.getSid()); } } - } }