|
@ -3179,6 +3179,19 @@ public class FinCollectionConfirmationService extends MybatisBaseService<FinColl |
|
|
return rb.setMsg("该申请不存在"); |
|
|
return rb.setMsg("该申请不存在"); |
|
|
} |
|
|
} |
|
|
cashierPushConfirm(sid); |
|
|
cashierPushConfirm(sid); |
|
|
|
|
|
try { |
|
|
|
|
|
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() |
|
|
|
|
|
.setNameFormat("demo-pool-%d").build(); |
|
|
|
|
|
ExecutorService pool = new ThreadPoolExecutor(2, 100, |
|
|
|
|
|
0L, TimeUnit.MILLISECONDS, |
|
|
|
|
|
new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy()); |
|
|
|
|
|
FinCollectionConfirmation finalConfirmation = confirmation; |
|
|
|
|
|
Future future1 = pool.submit(() -> { |
|
|
|
|
|
pushLoanDiff(finalConfirmation); |
|
|
|
|
|
}); |
|
|
|
|
|
} catch (Exception e) { |
|
|
|
|
|
e.printStackTrace(); |
|
|
|
|
|
} |
|
|
return rb.success(); |
|
|
return rb.success(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|