From f26158f0cc158fb7ed7e068ecf830083d7a8fd95 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Fri, 26 Jul 2024 16:19:28 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=8D=95=E4=B8=AA=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E8=80=81=E7=B3=BB=E7=BB=9F=E8=A1=A5=E4=B8=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jobhandle/DistributionDatarepair.java | 20 +++++++++++++++++++ .../mapper/WarehouseMappingDataMapper.java | 1 + .../mapper/WarehouseMappingDataMapper.xml | 5 +++++ 3 files changed, 26 insertions(+) diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java index aae4e8158..b26320df5 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java @@ -205,6 +205,26 @@ public class DistributionDatarepair { return ReturnT.SUCCESS; } + + + /** + * 推送单个 老系统系统 + * @return + */ + @XxlJob("pushNotification") + public ReturnT pushSingleNotification(String params) { + + + Boolean b = distributionSignforClient.clerkCheckPushData(Long.parseLong(params)); + if(b!=null&&b){ + warehouseMappingDataMapper.updateClearSignforStatusBysignforId(Long.parseLong(params), 1); + log.info(">>> 推送成功 {}",Long.parseLong(params)); + }else{ + log.error(">>> 推送失败 id="+Long.parseLong(params)); + } + return ReturnT.SUCCESS; + } + /** * 推送自提签收老系统系统 * @return diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java index 01f043e41..877736ec5 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java @@ -122,5 +122,6 @@ public interface WarehouseMappingDataMapper { List findStockAllocationInfo(); + void updateClearSignforStatusBysignforId(@Param("singnforId")Long singnforId, @Param("dealStatus") Integer dealStatus); } diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml index 1d31d9ead..dc64f4186 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml @@ -348,6 +348,11 @@ set total_num = #{num} where id = #{aLong} + + update clear_singnfor_status_record + set deal_status = #{dealStatus} + where singnfor_id = #{singnforId} +