Finish ems

db/sys_ems_callback.sql

@@ -21,6 +21,8 @@ CREATE TABLE `sys_ems_callback`  (
   `subject` VARCHAR(255) COMMENT '邮件标题',
   `message_id` VARCHAR(200) COMMENT 'smtp 协议头中的 Message-ID',
   `create_time` DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT '接收时间',
-  UNIQUE KEY (`message_id`)
+  UNIQUE KEY (`message_id`),
+  INDEX `idx_event` (`event`),
+  INDEX `idx_email` (`email`)
 ) ENGINE = INNODB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COMMENT = '邮件回调记录表';
 

src/main/java/com/backendsys/modules/sdk/tencentcloud/ems/controller/TencentEmsController.java

@@ -30,13 +30,13 @@ public class TencentEmsController {
     @Autowired
     private TencentEmsCallbackService tencentEmsCallbackService;
 
-    @Anonymous
-    @Operation(summary = "邮件推送 (测试)")
-    @GetMapping("/api/ems/send")
-    public Result send(String email) {
-        String templateParamSet = "{ \"code\": \"123456\", \"minute\": \"5\" }";
-        return Result.success().put("data", tencentEmsService.send("邮件测试", 140698L, templateParamSet, email));
-    }
+    //@Anonymous
+    //@Operation(summary = "邮件推送 (测试)")
+    //@GetMapping("/api/ems/send")
+    //public Result send(String email) {
+    //    String templateParamSet = "{ \"code\": \"123456\", \"minute\": \"5\" }";
+    //    return Result.success().put("data", tencentEmsService.send("邮件测试", 140698L, templateParamSet, email));
+    //}
 
     /**
      * [回调] 邮件通知事件
@@ -46,12 +46,10 @@ public class TencentEmsController {
     @Operation(summary = "邮件推送通知事件回调")
     @PostMapping("/api/ems/callback")
     public Result receiveCallback(@RequestBody TencentEmsCallbackParams tencentEmsCallbackParams) {
-
-        System.out.println("===============================");
-        System.out.println("邮件推送通知事件回调");
-        System.out.println("body 参数: " + tencentEmsCallbackParams);
-        System.out.println("===============================");
-
+        //System.out.println("===============================");
+        //System.out.println("邮件推送通知事件回调");
+        //System.out.println("body 参数: " + tencentEmsCallbackParams);
+        //System.out.println("===============================");
         tencentEmsCallbackService.receiveCallback(tencentEmsCallbackParams);
         return Result.success();
     }

src/main/java/com/backendsys/modules/sdk/tencentcloud/ems/service/impl/TencentEmsCallbackServiceImpl.java

@@ -42,7 +42,7 @@ public class TencentEmsCallbackServiceImpl implements TencentEmsCallbackService
                 entity.setMessage_id(messageId);
                 // 保存记录
                 tencentEmsCallbackDao.insert(entity);
-                System.out.println("邮件推送回调成功");
+                System.out.println("邮件推送回调成功 From: " + email);
 
             }