初版功能基本完成

src/main/java/com/xs/core/config/i18n/LocaleConfig.java

@@ -12,8 +12,8 @@ public class LocaleConfig {
     @Bean
     public LocaleResolver localeResolver() {
         SessionLocaleResolver slr = new SessionLocaleResolver();
-//        slr.setDefaultLocale(Locale.ENGLISH);
-        slr.setDefaultLocale(Locale.TRADITIONAL_CHINESE); // 设置默认语言为繁体中文
+        slr.setDefaultLocale(Locale.ENGLISH);//设置默认语言为英文
+//        slr.setDefaultLocale(Locale.TRADITIONAL_CHINESE); // 设置默认语言为繁体中文
         return slr;
     }
 }

src/main/java/com/xs/core/mq/consumer/GoldCoinProductMessageConsumer.java

@@ -40,6 +40,8 @@ public class GoldCoinProductMessageConsumer {
     public void handleCalculation(Message m, Channel channel) throws IOException {
         CoinProducerMessage message = null;
         boolean completed = false;
+        //是否继续计算
+        boolean calculateFlag = false;
         CoinProducerMessage newMessage = null;
         try {
             String msg = new String(m.getBody());
@@ -62,6 +64,7 @@ public class GoldCoinProductMessageConsumer {
                         BeanUtils.copyProperties(coinProdState, newMessage);
                         //重新设置消息id
                         newMessage.setMsgId(IdWorker.getIdStr());
+                        calculateFlag = true;
                     } else {
                         //发送金币结算消息
                         newMessage = new CoinProducerMessage();
@@ -72,10 +75,12 @@ public class GoldCoinProductMessageConsumer {
                     }
                 }
             }
-            //如过没有发生异常才发送下一次延迟计算消息
+            //如果计算结束则发送计算完成的消息
             if (completed) {
                 goldCoinProducer.sendCalculationCompleteMessage(newMessage);
-            } else {
+            }
+            //如果需要继续计算则发送继续计算的消息
+            if (calculateFlag) {
                 goldCoinProducer.sendDelayCalculationMessage(newMessage);
             }
             channel.basicAck(m.getMessageProperties().getDeliveryTag(), false);