From e297f06943046e983664c7b1f401abc74531715b Mon Sep 17 00:00:00 2001 From: furunxin <864795252@qq.com> Date: Thu, 23 Jul 2020 10:51:44 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E5=90=88=E5=90=8C=E7=BB=AD=E7=AD=BE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/contract/WxRentContractExtensionController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxRentContractExtensionController.java b/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxRentContractExtensionController.java index 941099e39..f14e20a26 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxRentContractExtensionController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/contract/WxRentContractExtensionController.java @@ -139,6 +139,6 @@ public class WxRentContractExtensionController extends BaseController { if(wxRentContract.getRentStartType()!=null && wxRentContract.getRentStartType().equals(EnumRentStartType.STARTTIME.getCode())){ wxRentContract.setRentalStartDate(wxRentContract.getStartDate()); } - return wxRentContractService.updateFile(wxRentContract, user.getId(),user.getName(),oldDate); + return wxRentContractService.extensionUpdateFile(wxRentContract, user.getId(),user.getName(),oldDate); } } From ca2582fed749787c6e84b99129504ec7bc0eedea Mon Sep 17 00:00:00 2001 From: xiaohanzi Date: Thu, 23 Jul 2020 11:53:36 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9rabbitmqbug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/mq/impl/RabbitMqConsumer.java | 20 +++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java index 343777e32..d81e189c1 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java @@ -16,7 +16,7 @@ import javax.annotation.PostConstruct; @Profile(MQConfig.Impl.RABBIT_MQ) public class RabbitMqConsumer extends MqBaseConsumer { //String queueName = "topic-1"; - String queuenames = ""; + private String[] queuenames = null; @Autowired private AmqpAdmin amqpAdmin; @@ -30,10 +30,6 @@ public class RabbitMqConsumer extends MqBaseConsumer { amqpAdmin.declareExchange(exchange); amqpAdmin.declareQueue(queue); amqpAdmin.declareBinding(binding); - queuenames = queuenames +","+topic.getCode(); - } - if (queuenames.length()>0) { - queuenames = queuenames.substring(0, queuenames.length()-1); } } @@ -46,11 +42,19 @@ public class RabbitMqConsumer extends MqBaseConsumer { @Bean - public Queue fmRabbitmaQueue(){ - return new Queue(queuenames,true); + public String[] fmRabbitmaQueues(){ + if (null == queuenames) { + queuenames = new String[EnumMsgMqTopic.values().length]; + int i = 0 ; + for (EnumMsgMqTopic topic: EnumMsgMqTopic.values()) { + queuenames[i] = topic.getCode(); + i ++; + } + } + return queuenames; } - @RabbitListener(queues = "#{fmRabbitmaQueue.name}") + @RabbitListener(queues = {"#{fmRabbitmaQueues}"}) public void onMessage(String message) { doMessage(message); }