diff --git a/mallinkAdmin/src/main/resources/db/migration/V201904180909__ADD_FLOW.sql b/mallinkAdmin/src/main/resources/db/migration/V201904180909__ADD_FLOW.sql new file mode 100644 index 000000000..daee928c2 --- /dev/null +++ b/mallinkAdmin/src/main/resources/db/migration/V201904180909__ADD_FLOW.sql @@ -0,0 +1,3 @@ + + +alter table `wx_msg_record` modify column status_message text; \ No newline at end of file diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index eca04fa9c..b364f852a 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -30,8 +30,6 @@ public class MqBaseConsumer { private SendMpMsgServiceImpl sendMpMsgService; @Autowired private SendWeappUniformMsgServiceImpl sendWeappUniformMsgService; -// @Autowired -// private MqBaseProducer mqBaseProducer; public void doMessage(String message) { log.info("received message: {}", message); @@ -61,14 +59,13 @@ public class MqBaseConsumer { } baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_SUCC.getCode()); wxMsgRecordMapper.update(baseMsg); - }catch (Exception e){ + }catch (Throwable e){ try { - log.error("consum received error:{} ", e.getMessage()); log.error("consum received error: ", e); - //baseMsg.setStatusMessage(e.getMessage()); + baseMsg.setStatusMessage(e.getMessage()); baseMsg.setMsgStatus(EnumMsgRecordStatus.CONSUME_FAIL.getCode()); wxMsgRecordMapper.update(baseMsg); - }catch (Exception e1){ + }catch (Throwable e1){ log.error("更新db状态error: ", e1); }