短信计费

gic-platform-enterprise-service/src/main/java/com/gic/enterprise/service/outer/impl/SmsRecordApiServiceImpl.java

@@ -123,8 +123,8 @@ public class SmsRecordApiServiceImpl implements SmsRecordApiService {
             try {
                 String json = JSON.toJSONString(smsRecordDTO);
 //                logger.info("收到国内短信计费信息：{}", json);
-//                client.sendMessage("smsMq", json);
-            this.run(json);
+                client.sendMessage("smsMq", json);
+//            this.run(json);
             } catch (Exception e) {
                 logger.warn("调用mq失败", e);
             }
@@ -160,8 +160,8 @@ public class SmsRecordApiServiceImpl implements SmsRecordApiService {
             billingSmsRecordService.updateCacheStatus(smsRecordDTO.getSmsRecordId());
             smsRecordDTO.setCacheStatus(1);
             // 队列
-//            client.sendMessage("smsDbMq", JSON.toJSONString(smsRecordDTO));
-            this.executeDatabase(JSON.toJSONString(smsRecordDTO));
+            client.sendMessage("smsDbMq", JSON.toJSONString(smsRecordDTO));
+//            this.executeDatabase(JSON.toJSONString(smsRecordDTO));
         } catch (Exception e) {
             logger.warn("调用mq失败", e);
         }