From ed0579f1afa35f4d849095bb60c21e23d1a9379a Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Wed, 26 Jun 2024 17:53:06 +0800 Subject: [PATCH] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=A2=A6?= =?UTF-8?q?=E5=A4=A9=E7=AD=BE=E6=94=B6=E6=89=AB=E6=8F=8F=E6=89=8B=E5=8A=A8?= =?UTF-8?q?=E5=9B=9E=E4=BC=A0=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/factory/jobhandler/MengTianPushDataJob.java | 2 +- .../java/com/logpm/factory/mt/mapper/MtPushDataMapper.java | 2 ++ .../java/com/logpm/factory/mt/mapper/MtPushDataMapper.xml | 6 ++++++ 3 files changed, 9 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/MengTianPushDataJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/MengTianPushDataJob.java index b1de43b3b..24fd8ea54 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/MengTianPushDataJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/MengTianPushDataJob.java @@ -102,7 +102,7 @@ public class MengTianPushDataJob { map.put("messageData", entries); log.info("梦天手动回推签收扫描数据：{}", JSONUtil.toJsonStr(map)); rabbitTemplate.convertAndSend(RabbitConstant.MT_BUSINESS_DATA_2_FACTORY_EXCHANGE, RabbitConstant.MT_BUSINESS_DATA_2_FACTORY_ROUTING, map); - mtPushDataMapper.customPushNodeDataSended(js.getStr("sendTaskId"), 1); + mtPushDataMapper.customPushNodeDataSendedScan(js.getStr("unitNo"), 1); return ReturnT.SUCCESS; } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.java index 9db326954..9dc90ce0a 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.java @@ -16,4 +16,6 @@ public interface MtPushDataMapper extends BaseMapper { List customPushNodeDataImage(String sendTaskId); void customPushNodeDataSended(@Param("sendTaskId") String sendTaskId, @Param("pushType") int pushType); + + void customPushNodeDataSendedScan(@Param("unitNo") String unitNo, @Param("pushType") int pushType); } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.xml b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.xml index cf85318da..55ffafb3c 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.xml +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/mapper/MtPushDataMapper.xml @@ -43,4 +43,10 @@ set sendStatus = 1 where sendTaskId = #{sendTaskId} and push_type = #{pushType} + + + update mt_custom_push_data_package + set sendStatus = 1 + where unitNo = #{unitNo} and push_type = #{pushType} +