From 1f21ae66324a24f0181b5aa748ff38cb6fce28e1 Mon Sep 17 00:00:00 2001 From: YXY <932687738@qq.com> Date: Fri, 13 Oct 2023 09:49:01 +0800 Subject: [PATCH] =?UTF-8?q?=E6=81=A2=E5=A4=8D=E6=99=9A=E9=97=B4=E5=88=A0?= =?UTF-8?q?=E9=99=A4=E9=87=8D=E6=96=B0=E5=90=8C=E6=AD=A5=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../task/CJT/SyncAccountsJobAbstract.java | 37 +++++++++---------- 1 file changed, 18 insertions(+), 19 deletions(-) diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java index 282378e..6a7388a 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java @@ -91,26 +91,25 @@ public abstract class SyncAccountsJobAbstract { private static final String REQUEST_GENERATE_TOKEN_PATH = REQUEST_ROOT_PATH + "/v1/common/auth/selfBuiltApp/generateToken"; private Boolean asynchronousCheck(LocalDateTime now, String cjt) { + int hour = now.getHour(); + if ((hour == 1 && CjtAccountEnum.ONE.getCode().equals(cjt)) + || (hour == 3 && CjtAccountEnum.TWO.getCode().equals(cjt))) { + //目前只给畅捷通账号二加工单开补偿 +// if ((AppType.SYNC_CJT_MANUFACTURE_ORDER_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode()) +// && CjtAccountEnum.TWO.getCode().equals(cjt)) || (AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode()) +// && CjtAccountEnum.ONE.getCode().equals(cjt))) { + String asynchronous = getAsynchronousKey(cjt); + Object cacheObject = redisCache.getCacheObject(asynchronous); + if (cacheObject != null) { + return Boolean.FALSE; + } + redisCache.setCacheObject(asynchronous, asynchronous, 2, TimeUnit.HOURS); + return Boolean.TRUE; +// } else { +// return false; +// } + } return false; -// int hour = now.getHour(); -// if ((hour == 1 && CjtAccountEnum.ONE.getCode().equals(cjt)) -// || (hour == 3 && CjtAccountEnum.TWO.getCode().equals(cjt))) { -// //目前只给畅捷通账号二加工单开补偿 -//// if ((AppType.SYNC_CJT_MANUFACTURE_ORDER_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode()) -//// && CjtAccountEnum.TWO.getCode().equals(cjt)) || (AppType.SYNC_CJT_SALE_DISPATCH_DATA_TO_MULTI_TABLE.getCode().equals(syncLarkAppType().getCode()) -//// && CjtAccountEnum.ONE.getCode().equals(cjt))) { -// String asynchronous = getAsynchronousKey(cjt); -// Object cacheObject = redisCache.getCacheObject(asynchronous); -// if (cacheObject != null) { -// return Boolean.FALSE; -// } -// redisCache.setCacheObject(asynchronous, asynchronous, 2, TimeUnit.HOURS); -// return Boolean.TRUE; -//// } else { -//// return false; -//// } -// } -// return false; } private String getAsynchronousKey(String cjt) {