commit

simulation-resource-sms/pom.xml

@@ -19,6 +19,13 @@
 
     <dependencies>
 
+        <!-- okhttp - 开始 -->
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+        </dependency>
+        <!-- okhttp - 结束 -->
+
         <!-- apache kafka - 开始 -->
         <dependency>
             <groupId>org.apache.kafka</groupId>

simulation-resource-sms/src/main/java/com/css/simulation/resource/sms/consumer/SmsConsumer.java

@@ -15,16 +15,16 @@ import org.springframework.stereotype.Component;
 public class SmsConsumer {
 
     /**
-     * 任务运行前首先判断用户是否拥有可分配资源
+     * 新增用户时发送短信
      *
-     * @param projectRecord 项目启动消息
+     * @param msg 消息
      */
     @KafkaListener(groupId = "simulation-resource-sms", topics = "${sms.topic}")
     @SneakyThrows
-    public void sendShortMessage(ConsumerRecord<String, String> projectRecord) {
-        String smsDTOJson = projectRecord.value();
+    public void sendShortMessage(ConsumerRecord<String, String> msg) {
+        String smsDTOJson = msg.value();
         SmsDTO smsDTO = JsonUtil.jsonToBean(smsDTOJson, SmsDTO.class);
-        log.info("SmsConsumer.sendShortMessage() 准备发送短信：" + smsDTOJson);
+        log.info("准备发送短信：" + smsDTOJson);
         TencentSMSUtil.send(
                 smsDTO.getSecretId(),
                 smsDTO.getSecretKey(),