diff --git a/README.md b/README.md
index 90479b9..5de0918 100644
--- a/README.md
+++ b/README.md
@@ -122,7 +122,9 @@ curl -XPOST "127.0.0.1:8080/send"  -H 'Content-Type: application/json'  -d '{"co
 
 3、项目在编写的过程中也经历多次的重构迭代，迭代的内容我是不会将以往文章内容重新修正发布，但语雀的文档内容一定是**及时同步**，文档跟代码是保持一致的
 
-4、除了项目，还可以问我些学习经验、学习路线、简历编写、面试经验等等问题，技术和学习上的知识**知无不言**
+4、干练清爽的项目commit，可一步一步跟着commit还原整个系统的过程
+
+5、除了项目，还可以问我些学习经验、学习路线、简历编写、面试经验等等问题，技术和学习上的知识**知无不言**
 
 详情可以看戳：[我开通了付费渠道](https://mp.weixin.qq.com/s?__biz=MzI4Njg5MDA5NA==&mid=2247505577&idx=1&sn=5114f8f583755899c2946fbea0b22e4b&chksm=ebd497a8dca31ebe8f98344483a00c860863dfc3586e51eed95b25988151427fee8101311f4f&token=319992632&lang=zh_CN#rd)
 
@@ -156,10 +158,11 @@ curl -XPOST "127.0.0.1:8080/send"  -H 'Content-Type: application/json'  -d '{"co
 - [x] 接入PUSH渠道
 - [x] 接入云片短信渠道，并短信支持流量配置，拉取腾讯云短信回执
 - [x] 完成接入钉钉机器人渠道所有类型的消息
+- [x] 完成接入钉钉工作渠道所有类型的消息，包括对文件素材的上传功能
 - [ ] 总体架构已完成，持续做基础建设和优化代码
 
 
-**近期更新时间**：6月3号
+**近期更新时间**：6月8号
 
 **近期更新功能**：完成接入钉钉机器人渠道所有类型的消息
 
diff --git a/austin-common/src/main/java/com/java3y/austin/common/enums/FileType.java b/austin-common/src/main/java/com/java3y/austin/common/enums/FileType.java
new file mode 100644
index 0000000..54a93d0
--- /dev/null
+++ b/austin-common/src/main/java/com/java3y/austin/common/enums/FileType.java
@@ -0,0 +1,33 @@
+package com.java3y.austin.common.enums;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.ToString;
+
+/**
+ * 文件类型
+ *
+ * @author 3y
+ */
+@Getter
+@ToString
+@AllArgsConstructor
+public enum FileType {
+    IMAGE("10", "image"),
+    VOICE("20", "voice"),
+    COMMON_FILE("30", "file"),
+    VIDEO("40", "video"),
+    ;
+    private String code;
+    private String dingDingName;
+
+    public static String dingDingNameByCode(String code) {
+        for (FileType fileType : FileType.values()) {
+            if (fileType.getCode().equals(code)) {
+                return fileType.getDingDingName();
+            }
+        }
+        return null;
+    }
+}
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/Handler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/Handler.java
index c01b1f0..d9c3165 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/Handler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/Handler.java
@@ -1,6 +1,7 @@
 package com.java3y.austin.handler.handler;
 
 import com.java3y.austin.common.domain.TaskInfo;
+import com.java3y.austin.support.domain.MessageTemplate;
 
 /**
  * @author 3y
@@ -10,8 +11,18 @@ public interface Handler {
 
     /**
      * 处理器
+     *
      * @param taskInfo
      */
     void doHandler(TaskInfo taskInfo);
 
+    /**
+     * 撤回消息
+     *
+     * @param messageTemplate
+     * @return
+     */
+    void recall(MessageTemplate messageTemplate);
+
+
 }
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingRobotHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingRobotHandler.java
index 2c92c98..e378215 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingRobotHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingRobotHandler.java
@@ -16,6 +16,7 @@ import com.java3y.austin.handler.domain.dingding.DingDingRobotParam;
 import com.java3y.austin.handler.domain.dingding.DingDingRobotResult;
 import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.utils.AccountUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.binary.Base64;
@@ -62,6 +63,8 @@ public class DingDingRobotHandler extends BaseHandler implements Handler {
         return false;
     }
 
+
+
     private DingDingRobotParam assembleParam(TaskInfo taskInfo) {
 
         // 接收者相关
@@ -132,5 +135,11 @@ public class DingDingRobotHandler extends BaseHandler implements Handler {
         }
         return sign;
     }
+
+
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
+
+    }
 }
 
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingWorkNoticeHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingWorkNoticeHandler.java
index 11b5b87..7b47c2a 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingWorkNoticeHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/DingDingWorkNoticeHandler.java
@@ -1,31 +1,38 @@
 package com.java3y.austin.handler.handler.impl;
 
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.dingtalk.api.DefaultDingTalkClient;
+import com.dingtalk.api.DingTalkClient;
 import com.dingtalk.api.request.OapiMessageCorpconversationAsyncsendV2Request;
+import com.dingtalk.api.request.OapiMessageCorpconversationRecallRequest;
 import com.dingtalk.api.response.OapiMessageCorpconversationAsyncsendV2Response;
+import com.dingtalk.api.response.OapiMessageCorpconversationRecallResponse;
 import com.google.common.base.Throwables;
 import com.java3y.austin.common.constant.AustinConstant;
 import com.java3y.austin.common.constant.SendAccountConstant;
+import com.java3y.austin.common.domain.LogParam;
 import com.java3y.austin.common.domain.TaskInfo;
 import com.java3y.austin.common.dto.account.DingDingWorkNoticeAccount;
-import com.java3y.austin.common.dto.model.DingDingRobotContentModel;
 import com.java3y.austin.common.dto.model.DingDingWorkContentModel;
 import com.java3y.austin.common.enums.ChannelType;
 import com.java3y.austin.common.enums.SendMessageType;
-import com.java3y.austin.handler.domain.dingding.DingDingRobotParam;
 import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
+import com.java3y.austin.support.config.SupportThreadPoolConfig;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.utils.AccountUtils;
+import com.java3y.austin.support.utils.LogUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 
-import java.util.List;
+import java.util.Date;
+import java.util.concurrent.TimeUnit;
 
 /**
  * 钉钉消息自定义机器人 消息处理器
@@ -38,19 +45,22 @@ import java.util.List;
 @Service
 public class DingDingWorkNoticeHandler extends BaseHandler implements Handler {
 
+
     @Autowired
     private AccountUtils accountUtils;
-
     @Autowired
     private StringRedisTemplate redisTemplate;
-
+    @Autowired
+    private LogUtils logUtils;
 
     public DingDingWorkNoticeHandler() {
         channelCode = ChannelType.DING_DING_WORK_NOTICE.getCode();
     }
 
-    private static final String URL = "https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2";
-
+    private static final String SEND_URL = "https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2";
+    private static final String RECALL_URL = "https://oapi.dingtalk.com/topapi/message/corpconversation/recall";
+    private static final String DING_DING_RECALL_KEY_PREFIX = "RECALL_";
+    private static final String RECALL_BIZ_TYPE = "DingDingWorkNoticeHandler#recall";
 
     @Override
     public boolean handler(TaskInfo taskInfo) {
@@ -58,10 +68,15 @@ public class DingDingWorkNoticeHandler extends BaseHandler implements Handler {
             DingDingWorkNoticeAccount account = accountUtils.getAccount(taskInfo.getSendAccount(), SendAccountConstant.DING_DING_WORK_NOTICE_ACCOUNT_KEY, SendAccountConstant.DING_DING_WORK_NOTICE_PREFIX, DingDingWorkNoticeAccount.class);
             OapiMessageCorpconversationAsyncsendV2Request request = assembleParam(account, taskInfo);
             String accessToken = redisTemplate.opsForValue().get(SendAccountConstant.DING_DING_ACCESS_TOKEN_PREFIX + taskInfo.getSendAccount());
-            OapiMessageCorpconversationAsyncsendV2Response response = new DefaultDingTalkClient(URL).execute(request, accessToken);
+            OapiMessageCorpconversationAsyncsendV2Response response = new DefaultDingTalkClient(SEND_URL).execute(request, accessToken);
+
+            // 发送成功后记录TaskId，用于消息撤回(支持当天的)
             if (response.getErrcode() == 0) {
+                redisTemplate.opsForList().leftPush(DING_DING_RECALL_KEY_PREFIX + taskInfo.getMessageTemplateId(), String.valueOf(response.getTaskId()));
+                redisTemplate.expire(DING_DING_RECALL_KEY_PREFIX + taskInfo.getMessageTemplateId(), (DateUtil.endOfDay(new Date()).getTime() - DateUtil.current()) / 1000, TimeUnit.SECONDS);
                 return true;
             }
+
             // 常见的错误 应当 关联至 AnchorState,由austin后台统一透出失败原因
             log.error("DingDingWorkNoticeHandler#handler fail!result:{},params:{}", JSON.toJSONString(response), JSON.toJSONString(taskInfo));
         } catch (Exception e) {
@@ -152,5 +167,33 @@ public class DingDingWorkNoticeHandler extends BaseHandler implements Handler {
         }
         return req;
     }
+
+
+    /**
+     * 在下发的时候存储了messageTemplate -> taskIdList
+     * 只要还存在taskIdList，则将其去除
+     *
+     * @param messageTemplate
+     */
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
+        SupportThreadPoolConfig.getPendingSingleThreadPool().execute(() -> {
+            try {
+                DingDingWorkNoticeAccount account = accountUtils.getAccount(messageTemplate.getSendAccount(), SendAccountConstant.DING_DING_WORK_NOTICE_ACCOUNT_KEY, SendAccountConstant.DING_DING_WORK_NOTICE_PREFIX, DingDingWorkNoticeAccount.class);
+                String accessToken = redisTemplate.opsForValue().get(SendAccountConstant.DING_DING_ACCESS_TOKEN_PREFIX + messageTemplate.getSendAccount());
+                while (redisTemplate.opsForList().size(DING_DING_RECALL_KEY_PREFIX + messageTemplate.getId()) > 0) {
+                    String taskId = redisTemplate.opsForList().leftPop(DING_DING_RECALL_KEY_PREFIX + messageTemplate.getId());
+                    DingTalkClient client = new DefaultDingTalkClient(RECALL_URL);
+                    OapiMessageCorpconversationRecallRequest req = new OapiMessageCorpconversationRecallRequest();
+                    req.setAgentId(Long.valueOf(account.getAgentId()));
+                    req.setMsgTaskId(Long.valueOf(taskId));
+                    OapiMessageCorpconversationRecallResponse rsp = client.execute(req, accessToken);
+                    logUtils.print(LogParam.builder().bizType(RECALL_BIZ_TYPE).object(JSON.toJSONString(rsp)).build());
+                }
+            } catch (Exception e) {
+                log.error("DingDingWorkNoticeHandler#recall fail:{}", Throwables.getStackTraceAsString(e));
+            }
+        });
+    }
 }
 
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EmailHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EmailHandler.java
index f6e8a25..71556cd 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EmailHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EmailHandler.java
@@ -13,6 +13,7 @@ import com.java3y.austin.handler.enums.RateLimitStrategy;
 import com.java3y.austin.handler.flowcontrol.FlowControlParam;
 import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.utils.AccountUtils;
 import com.sun.mail.util.MailSSLSocketFactory;
 import lombok.extern.slf4j.Slf4j;
@@ -73,5 +74,8 @@ public class EmailHandler extends BaseHandler implements Handler {
         }
         return account;
     }
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
 
+    }
 }
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EnterpriseWeChatHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EnterpriseWeChatHandler.java
index c2e9bbf..395fa2e 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EnterpriseWeChatHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/EnterpriseWeChatHandler.java
@@ -10,6 +10,7 @@ import com.java3y.austin.common.dto.model.EnterpriseWeChatContentModel;
 import com.java3y.austin.common.enums.ChannelType;
 import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.utils.AccountUtils;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.error.WxMpErrorMsgEnum;
@@ -97,6 +98,10 @@ public class EnterpriseWeChatHandler extends BaseHandler implements Handler {
                 .content(enterpriseWeChatContentModel.getContent())
                 .build();
     }
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
+
+    }
 
 }
 
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/MiniProgramAccountHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/MiniProgramAccountHandler.java
index f02044a..7b97b24 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/MiniProgramAccountHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/MiniProgramAccountHandler.java
@@ -9,6 +9,7 @@ import com.java3y.austin.handler.domain.wechat.WeChatMiniProgramParam;
 import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
 import com.java3y.austin.handler.wechat.MiniProgramAccountService;
+import com.java3y.austin.support.domain.MessageTemplate;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -59,6 +60,9 @@ public class MiniProgramAccountHandler extends BaseHandler implements Handler {
         miniProgramParam.setData(contentModel.getMap());
         return miniProgramParam;
     }
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
 
+    }
 }
 
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/OfficialAccountHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/OfficialAccountHandler.java
index 1246043..59f8b90 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/OfficialAccountHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/OfficialAccountHandler.java
@@ -9,6 +9,7 @@ import com.java3y.austin.handler.domain.wechat.WeChatOfficialParam;
 import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
 import com.java3y.austin.handler.wechat.OfficialAccountService;
+import com.java3y.austin.support.domain.MessageTemplate;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -53,5 +54,9 @@ public class OfficialAccountHandler extends BaseHandler implements Handler {
         return false;
     }
 
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
+
+    }
 }
 
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/PushHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/PushHandler.java
index 93feeef..fed2a1d 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/PushHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/PushHandler.java
@@ -19,6 +19,7 @@ import com.java3y.austin.handler.domain.push.getui.SendPushParam;
 import com.java3y.austin.handler.domain.push.getui.SendPushResult;
 import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.utils.AccountUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -160,5 +161,8 @@ public class PushHandler extends BaseHandler implements Handler {
         }
         return param;
     }
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
 
+    }
 }
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/SmsHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/SmsHandler.java
index 46a2d90..7e8b336 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/SmsHandler.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/impl/SmsHandler.java
@@ -17,6 +17,7 @@ import com.java3y.austin.handler.handler.BaseHandler;
 import com.java3y.austin.handler.handler.Handler;
 import com.java3y.austin.handler.script.SmsScriptHolder;
 import com.java3y.austin.support.dao.SmsRecordDao;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.domain.SmsRecord;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -156,5 +157,8 @@ public class SmsHandler extends BaseHandler implements Handler {
         }
     }
 
+    @Override
+    public void recall(MessageTemplate messageTemplate) {
 
+    }
 }
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receipt/DingDingWorkReceipt.java b/austin-handler/src/main/java/com/java3y/austin/handler/receipt/DingDingWorkReceipt.java
new file mode 100644
index 0000000..8420a07
--- /dev/null
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/receipt/DingDingWorkReceipt.java
@@ -0,0 +1,51 @@
+package com.java3y.austin.handler.receipt;
+
+
+import cn.hutool.core.util.StrUtil;
+import com.dingtalk.api.DefaultDingTalkClient;
+import com.dingtalk.api.DingTalkClient;
+import com.dingtalk.api.request.OapiMessageCorpconversationGetsendresultRequest;
+import com.dingtalk.api.response.OapiMessageCorpconversationGetsendresultResponse;
+import com.java3y.austin.common.constant.SendAccountConstant;
+import com.java3y.austin.common.dto.account.DingDingWorkNoticeAccount;
+import com.java3y.austin.support.utils.AccountUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Component;
+
+/**
+ * 拉取钉钉工作消息回执信息
+ *
+ * @author 3y
+ */
+@Component
+@Slf4j
+public class DingDingWorkReceipt {
+
+    private static final String URL = "https://oapi.dingtalk.com/topapi/message/corpconversation/getsendresult";
+    @Autowired
+    private StringRedisTemplate redisTemplate;
+
+    @Autowired
+    private AccountUtils accountUtils;
+    public void pull() {
+//        try {
+//            for (int index = SendAccountConstant.START; true; index = index + SendAccountConstant.STEP) {
+//                DingDingWorkNoticeAccount account = accountUtils.getAccount(index, SendAccountConstant.DING_DING_WORK_NOTICE_ACCOUNT_KEY, SendAccountConstant.DING_DING_WORK_NOTICE_PREFIX, DingDingWorkNoticeAccount.class);
+//                if (account == null) {
+//                    break;
+//                }
+//                String accessToken = redisTemplate.opsForValue().get(SendAccountConstant.DING_DING_ACCESS_TOKEN_PREFIX + index);
+//                DingTalkClient client = new DefaultDingTalkClient(URL);
+//                OapiMessageCorpconversationGetsendresultRequest req = new OapiMessageCorpconversationGetsendresultRequest();
+//                req.setAgentId(Long.valueOf(account.getAgentId()));
+//                req.setTaskId(456L);
+//                OapiMessageCorpconversationGetsendresultResponse rsp = client.execute(req, accessToken);
+//                System.out.println(rsp.getBody());
+//            }
+//        } catch (Exception e) {
+//            log.error("DingDingWorkReceipt#pull");
+//        }
+    }
+}
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receipt/SmsReceipt.java b/austin-handler/src/main/java/com/java3y/austin/handler/receipt/MessageReceipt.java
similarity index 93%
rename from austin-handler/src/main/java/com/java3y/austin/handler/receipt/SmsReceipt.java
rename to austin-handler/src/main/java/com/java3y/austin/handler/receipt/MessageReceipt.java
index 53cfda4..00f955f 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/receipt/SmsReceipt.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/receipt/MessageReceipt.java
@@ -31,7 +31,7 @@ import java.util.List;
  */
 @Component
 @Slf4j
-public class SmsReceipt {
+public class MessageReceipt {
 
     @Autowired
     private TencentSmsReceipt tencentSmsReceipt;
@@ -45,8 +45,8 @@ public class SmsReceipt {
             while (true) {
 
                 // TODO 回执这里自行打开(免得报错)
-                // tencentSmsReceipt.pull();
-                // yunPianSmsReceipt.pull();
+//                tencentSmsReceipt.pull();
+//                yunPianSmsReceipt.pull();
                 try {
                     Thread.sleep(200);
                 } catch (InterruptedException e) {
diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/Receiver.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/Receiver.java
index 305c0e5..29465ea 100644
--- a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/Receiver.java
+++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/Receiver.java
@@ -6,9 +6,11 @@ import com.java3y.austin.common.domain.AnchorInfo;
 import com.java3y.austin.common.domain.LogParam;
 import com.java3y.austin.common.domain.TaskInfo;
 import com.java3y.austin.common.enums.AnchorState;
+import com.java3y.austin.handler.handler.HandlerHolder;
 import com.java3y.austin.handler.pending.Task;
 import com.java3y.austin.handler.pending.TaskPendingHolder;
 import com.java3y.austin.handler.utils.GroupIdMappingUtils;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.utils.LogUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -33,6 +35,7 @@ import java.util.Optional;
 @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
 public class Receiver {
     private static final String LOG_BIZ_TYPE = "Receiver#consumer";
+    private static final String LOG_BIZ_RECALL_TYPE = "Receiver#recall";
     @Autowired
     private ApplicationContext context;
 
@@ -42,13 +45,20 @@ public class Receiver {
     @Autowired
     private LogUtils logUtils;
 
+    @Autowired
+    private HandlerHolder handlerHolder;
+
+    /**
+     * 发送消息
+     * @param consumerRecord
+     * @param topicGroupId
+     */
     @KafkaListener(topics = "#{'${austin.business.topic.name}'}")
     public void consumer(ConsumerRecord<?, String> consumerRecord, @Header(KafkaHeaders.GROUP_ID) String topicGroupId) {
         Optional<String> kafkaMessage = Optional.ofNullable(consumerRecord.value());
         if (kafkaMessage.isPresent()) {
 
             List<TaskInfo> taskInfoLists = JSON.parseArray(kafkaMessage.get(), TaskInfo.class);
-
             String messageGroupId = GroupIdMappingUtils.getGroupIdByTaskInfo(CollUtil.getFirst(taskInfoLists.iterator()));
 
             /**
@@ -63,4 +73,18 @@ public class Receiver {
             }
         }
     }
+
+    /**
+     * 撤回消息
+     * @param consumerRecord
+     */
+    @KafkaListener(topics = "#{'${austin.business.recall.topic.name}'}",groupId = "#{'${austin.business.recall.group.name}'}")
+    public void recall(ConsumerRecord<?,String> consumerRecord){
+        Optional<String> kafkaMessage = Optional.ofNullable(consumerRecord.value());
+        if(kafkaMessage.isPresent()){
+            MessageTemplate messageTemplate = JSON.parseObject(kafkaMessage.get(), MessageTemplate.class);
+            logUtils.print(LogParam.builder().bizType(LOG_BIZ_RECALL_TYPE).object(messageTemplate).build());
+            handlerHolder.route(messageTemplate.getSendChannel()).recall(messageTemplate);
+        }
+    }
 }
diff --git a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/AssembleAction.java b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/AssembleAction.java
index ef0ecdf..9e0692c 100644
--- a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/AssembleAction.java
+++ b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/AssembleAction.java
@@ -5,6 +5,7 @@ import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.google.common.base.Throwables;
 import com.java3y.austin.common.constant.AustinConstant;
 import com.java3y.austin.common.domain.TaskInfo;
@@ -13,6 +14,7 @@ import com.java3y.austin.common.enums.ChannelType;
 import com.java3y.austin.common.enums.RespStatusEnum;
 import com.java3y.austin.common.vo.BasicResultVO;
 import com.java3y.austin.service.api.domain.MessageParam;
+import com.java3y.austin.service.api.enums.BusinessCode;
 import com.java3y.austin.service.api.impl.domain.SendTaskModel;
 import com.java3y.austin.support.dao.MessageTemplateDao;
 import com.java3y.austin.support.domain.MessageTemplate;
@@ -50,9 +52,12 @@ public class AssembleAction implements BusinessProcess<SendTaskModel> {
                 context.setNeedBreak(true).setResponse(BasicResultVO.fail(RespStatusEnum.TEMPLATE_NOT_FOUND));
                 return;
             }
-
-            List<TaskInfo> taskInfos = assembleTaskInfo(sendTaskModel, messageTemplate.get());
-            sendTaskModel.setTaskInfo(taskInfos);
+            if (BusinessCode.COMMON_SEND.getCode().equals(context.getCode())) {
+                List<TaskInfo> taskInfos = assembleTaskInfo(sendTaskModel, messageTemplate.get());
+                sendTaskModel.setTaskInfo(taskInfos);
+            } else if (BusinessCode.RECALL.getCode().equals(context.getCode())) {
+                sendTaskModel.setMessageTemplate(messageTemplate.get());
+            }
         } catch (Exception e) {
             context.setNeedBreak(true).setResponse(BasicResultVO.fail(RespStatusEnum.SERVICE_ERROR));
             log.error("assemble task fail! templateId:{}, e:{}", messageTemplateId, Throwables.getStackTraceAsString(e));
diff --git a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java
index 8a4ad69..7711a7e 100644
--- a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java
+++ b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/action/SendMqAction.java
@@ -6,6 +6,7 @@ import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.google.common.base.Throwables;
 import com.java3y.austin.common.enums.RespStatusEnum;
 import com.java3y.austin.common.vo.BasicResultVO;
+import com.java3y.austin.service.api.enums.BusinessCode;
 import com.java3y.austin.service.api.impl.domain.SendTaskModel;
 import com.java3y.austin.support.pipeline.BusinessProcess;
 import com.java3y.austin.support.pipeline.ProcessContext;
@@ -27,15 +28,22 @@ public class SendMqAction implements BusinessProcess<SendTaskModel> {
     private KafkaUtils kafkaUtils;
 
     @Value("${austin.business.topic.name}")
-    private String topicName;
+    private String sendMessageTopic;
+
+    @Value("${austin.business.recall.topic.name}")
+    private String austinRecall;
 
     @Override
     public void process(ProcessContext<SendTaskModel> context) {
         SendTaskModel sendTaskModel = context.getProcessModel();
-        String message = JSON.toJSONString(sendTaskModel.getTaskInfo(), new SerializerFeature[]{SerializerFeature.WriteClassName});
-
         try {
-            kafkaUtils.send(topicName, message);
+            if (BusinessCode.COMMON_SEND.getCode().equals(context.getCode())) {
+                String message = JSON.toJSONString(sendTaskModel.getTaskInfo(), new SerializerFeature[]{SerializerFeature.WriteClassName});
+                kafkaUtils.send(sendMessageTopic, message);
+            } else if (BusinessCode.RECALL.getCode().equals(context.getCode())) {
+                String message = JSON.toJSONString(sendTaskModel.getMessageTemplate(), new SerializerFeature[]{SerializerFeature.WriteClassName});
+                kafkaUtils.send(austinRecall, message);
+            }
         } catch (Exception e) {
             context.setNeedBreak(true).setResponse(BasicResultVO.fail(RespStatusEnum.SERVICE_ERROR));
             log.error("send kafka fail! e:{},params:{}", Throwables.getStackTraceAsString(e)
diff --git a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/config/PipelineConfig.java b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/config/PipelineConfig.java
index 662888b..6dec68c 100644
--- a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/config/PipelineConfig.java
+++ b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/config/PipelineConfig.java
@@ -48,6 +48,19 @@ public class PipelineConfig {
         return processTemplate;
     }
 
+    /**
+     * 普通发送执行流程
+     * 1.组装参数
+     * 2.发送MQ
+     * @return
+     */
+    @Bean("recallMessageTemplate")
+    public ProcessTemplate recallMessageTemplate() {
+        ProcessTemplate processTemplate = new ProcessTemplate();
+        processTemplate.setProcessList(Arrays.asList(assembleAction, sendMqAction));
+        return processTemplate;
+    }
+
     /**
      * pipeline流程控制器
      * 目前暂定只有 普通发送的流程
@@ -60,6 +73,7 @@ public class PipelineConfig {
         ProcessController processController = new ProcessController();
         Map<String, ProcessTemplate> templateConfig = new HashMap<>(4);
         templateConfig.put(BusinessCode.COMMON_SEND.getCode(), commonSendTemplate());
+        templateConfig.put(BusinessCode.RECALL.getCode(), recallMessageTemplate());
         processController.setTemplateConfig(templateConfig);
         return processController;
     }
diff --git a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/domain/SendTaskModel.java b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/domain/SendTaskModel.java
index f0e6fe2..2182430 100644
--- a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/domain/SendTaskModel.java
+++ b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/domain/SendTaskModel.java
@@ -2,6 +2,7 @@ package com.java3y.austin.service.api.impl.domain;
 
 import com.java3y.austin.common.domain.TaskInfo;
 import com.java3y.austin.service.api.domain.MessageParam;
+import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.support.pipeline.ProcessModel;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -36,5 +37,9 @@ public class SendTaskModel implements ProcessModel {
      */
     private List<TaskInfo> taskInfo;
 
+    /**
+     * 撤回任务的信息
+     */
+    private MessageTemplate messageTemplate;
 
 }
diff --git a/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/service/RecallServiceImpl.java b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/service/RecallServiceImpl.java
new file mode 100644
index 0000000..7b89e48
--- /dev/null
+++ b/austin-service-api-impl/src/main/java/com/java3y/austin/service/api/impl/service/RecallServiceImpl.java
@@ -0,0 +1,37 @@
+package com.java3y.austin.service.api.impl.service;
+
+import com.java3y.austin.common.vo.BasicResultVO;
+import com.java3y.austin.service.api.domain.SendRequest;
+import com.java3y.austin.service.api.domain.SendResponse;
+import com.java3y.austin.service.api.impl.domain.SendTaskModel;
+import com.java3y.austin.service.api.service.RecallService;
+import com.java3y.austin.support.pipeline.ProcessContext;
+import com.java3y.austin.support.pipeline.ProcessController;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+
+/**
+ * 撤回接口
+ * @author 3y
+ */
+@Service
+public class RecallServiceImpl implements RecallService {
+
+    @Autowired
+    private ProcessController processController;
+
+    @Override
+    public SendResponse recall(SendRequest sendRequest) {
+        SendTaskModel sendTaskModel = SendTaskModel.builder()
+                .messageTemplateId(sendRequest.getMessageTemplateId())
+                .build();
+        ProcessContext context = ProcessContext.builder()
+                .code(sendRequest.getCode())
+                .processModel(sendTaskModel)
+                .needBreak(false)
+                .response(BasicResultVO.success()).build();
+        ProcessContext process = processController.process(context);
+        return new SendResponse(process.getResponse().getStatus(), process.getResponse().getMsg());
+    }
+}
diff --git a/austin-service-api/src/main/java/com/java3y/austin/service/api/domain/SendRequest.java b/austin-service-api/src/main/java/com/java3y/austin/service/api/domain/SendRequest.java
index 62d06ca..3651ed2 100644
--- a/austin-service-api/src/main/java/com/java3y/austin/service/api/domain/SendRequest.java
+++ b/austin-service-api/src/main/java/com/java3y/austin/service/api/domain/SendRequest.java
@@ -8,7 +8,7 @@ import lombok.NoArgsConstructor;
 import lombok.experimental.Accessors;
 
 /**
- * 发送接口的参数
+ * 发送/撤回接口的参数
  * @author 3y
  */
 @Data
@@ -19,18 +19,22 @@ import lombok.experimental.Accessors;
 public class SendRequest {
 
     /**
-     * 执行业务类型(默认填写 "send")
+     * 执行业务类型
+     * send:发送消息
+     * recall:撤回消息
      */
     private String code;
 
     /**
      * 消息模板Id
+     * 【必填】
      */
     private Long messageTemplateId;
 
 
     /**
      * 消息相关的参数
+     * 当业务类型为"send"，必传
      */
     private MessageParam messageParam;
 
diff --git a/austin-service-api/src/main/java/com/java3y/austin/service/api/service/RecallService.java b/austin-service-api/src/main/java/com/java3y/austin/service/api/service/RecallService.java
new file mode 100644
index 0000000..95a2897
--- /dev/null
+++ b/austin-service-api/src/main/java/com/java3y/austin/service/api/service/RecallService.java
@@ -0,0 +1,22 @@
+package com.java3y.austin.service.api.service;
+
+import com.java3y.austin.service.api.domain.BatchSendRequest;
+import com.java3y.austin.service.api.domain.SendRequest;
+import com.java3y.austin.service.api.domain.SendResponse;
+
+/**
+ * 撤回接口
+ *
+ * @author 3y
+ */
+public interface RecallService {
+
+
+    /**
+     * 根据模板ID撤回消息
+     *
+     * @param sendRequest
+     * @return
+     */
+    SendResponse recall(SendRequest sendRequest);
+}
diff --git a/austin-support/src/main/java/com/java3y/austin/support/domain/MessageTemplate.java b/austin-support/src/main/java/com/java3y/austin/support/domain/MessageTemplate.java
index 21d2c85..d856c88 100644
--- a/austin-support/src/main/java/com/java3y/austin/support/domain/MessageTemplate.java
+++ b/austin-support/src/main/java/com/java3y/austin/support/domain/MessageTemplate.java
@@ -129,8 +129,8 @@ public class MessageTemplate implements Serializable {
 
     /**
      * 是否删除
-     * 0：已删除
-     * 1：删除
+     * 0：未删除
+     * 1：已删除
      */
     private Integer isDeleted;
 
diff --git a/austin-web/src/main/java/com/java3y/austin/web/controller/MaterialController.java b/austin-web/src/main/java/com/java3y/austin/web/controller/MaterialController.java
new file mode 100644
index 0000000..5ef2cc4
--- /dev/null
+++ b/austin-web/src/main/java/com/java3y/austin/web/controller/MaterialController.java
@@ -0,0 +1,61 @@
+package com.java3y.austin.web.controller;
+
+
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSON;
+import com.dingtalk.api.DefaultDingTalkClient;
+import com.dingtalk.api.DingTalkClient;
+import com.dingtalk.api.request.OapiMediaUploadRequest;
+import com.dingtalk.api.response.OapiMediaUploadResponse;
+import com.java3y.austin.common.constant.SendAccountConstant;
+import com.java3y.austin.common.enums.ChannelType;
+import com.java3y.austin.common.enums.FileType;
+import com.java3y.austin.common.vo.BasicResultVO;
+import com.java3y.austin.web.service.MaterialService;
+import com.java3y.austin.web.vo.DataParam;
+import com.java3y.austin.web.vo.amis.UserTimeLineVo;
+import com.taobao.api.FileItem;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+
+/**
+ * 素材管理接口
+ * @author 3y
+ */
+@Slf4j
+@RestController
+@RequestMapping("/material")
+@Api("素材管理接口")
+@CrossOrigin(origins = "http://localhost:3000", allowCredentials = "true", allowedHeaders = "*")
+public class MaterialController {
+
+
+    @Autowired
+    private MaterialService materialService;
+
+
+    /**
+     * 素材上传接口
+     *
+     * @param file        文件内容
+     * @param sendAccount 发送账号
+     * @param sendChannel 发送渠道
+     * @param fileType    文件类型
+     * @return
+     */
+    @PostMapping("/upload")
+    @ApiOperation("/素材上传接口")
+    public BasicResultVO uploadMaterial(@RequestParam("file") MultipartFile file, String sendAccount, Integer sendChannel, String fileType) {
+        if (ChannelType.DING_DING_WORK_NOTICE.getCode().equals(sendChannel)) {
+            return materialService.dingDingMaterialUpload(file, sendAccount, fileType);
+        }
+        return BasicResultVO.success();
+    }
+
+}
diff --git a/austin-web/src/main/java/com/java3y/austin/web/controller/MessageTemplateController.java b/austin-web/src/main/java/com/java3y/austin/web/controller/MessageTemplateController.java
index 6c7940f..7b6dc3d 100644
--- a/austin-web/src/main/java/com/java3y/austin/web/controller/MessageTemplateController.java
+++ b/austin-web/src/main/java/com/java3y/austin/web/controller/MessageTemplateController.java
@@ -11,6 +11,7 @@ import com.java3y.austin.service.api.domain.MessageParam;
 import com.java3y.austin.service.api.domain.SendRequest;
 import com.java3y.austin.service.api.domain.SendResponse;
 import com.java3y.austin.service.api.enums.BusinessCode;
+import com.java3y.austin.service.api.service.RecallService;
 import com.java3y.austin.service.api.service.SendService;
 import com.java3y.austin.support.domain.MessageTemplate;
 import com.java3y.austin.web.service.MessageTemplateService;
@@ -50,6 +51,9 @@ public class MessageTemplateController {
     @Autowired
     private SendService sendService;
 
+    @Autowired
+    private RecallService recallService;
+
     @Value("${austin.business.upload.crowd.path}")
     private String dataPath;
 
@@ -131,6 +135,22 @@ public class MessageTemplateController {
         return BasicResultVO.success(response);
     }
 
+    /**
+     * 测试发送接口
+     */
+    @PostMapping("recall/{id}")
+    @ApiOperation("/撤回消息接口")
+    public BasicResultVO recall(@PathVariable("id") String id) {
+
+        SendRequest sendRequest = SendRequest.builder().code(BusinessCode.RECALL.getCode()).
+                messageTemplateId(Long.valueOf(id)).build();
+        SendResponse response = recallService.recall(sendRequest);
+        if (response.getCode() != RespStatusEnum.SUCCESS.getCode()) {
+            return BasicResultVO.fail(response.getMsg());
+        }
+        return BasicResultVO.success(response);
+    }
+
 
     /**
      * 启动模板的定时任务
diff --git a/austin-web/src/main/java/com/java3y/austin/web/service/MaterialService.java b/austin-web/src/main/java/com/java3y/austin/web/service/MaterialService.java
new file mode 100644
index 0000000..8a8ffe8
--- /dev/null
+++ b/austin-web/src/main/java/com/java3y/austin/web/service/MaterialService.java
@@ -0,0 +1,30 @@
+package com.java3y.austin.web.service;
+
+
+import com.java3y.austin.common.vo.BasicResultVO;
+import com.java3y.austin.support.domain.MessageTemplate;
+import com.java3y.austin.web.vo.MessageTemplateParam;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+
+/**
+ * 素材接口
+ *
+ * @author 3y
+ */
+public interface MaterialService {
+
+
+    /**
+     * 钉钉素材上传
+     * @param file
+     * @param sendAccount
+     * @param fileType
+     * @return
+     */
+    BasicResultVO dingDingMaterialUpload(MultipartFile file, String sendAccount, String fileType);
+
+
+
+}
diff --git a/austin-web/src/main/java/com/java3y/austin/web/service/impl/MaterialServiceImpl.java b/austin-web/src/main/java/com/java3y/austin/web/service/impl/MaterialServiceImpl.java
new file mode 100644
index 0000000..5ceec77
--- /dev/null
+++ b/austin-web/src/main/java/com/java3y/austin/web/service/impl/MaterialServiceImpl.java
@@ -0,0 +1,57 @@
+package com.java3y.austin.web.service.impl;
+
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSON;
+import com.dingtalk.api.DefaultDingTalkClient;
+import com.dingtalk.api.DingTalkClient;
+import com.dingtalk.api.request.OapiMediaUploadRequest;
+import com.dingtalk.api.response.OapiMediaUploadResponse;
+import com.google.common.base.Throwables;
+import com.java3y.austin.common.constant.SendAccountConstant;
+import com.java3y.austin.common.enums.FileType;
+import com.java3y.austin.common.enums.RespStatusEnum;
+import com.java3y.austin.common.vo.BasicResultVO;
+import com.java3y.austin.web.service.MaterialService;
+import com.java3y.austin.web.vo.UploadResponseVo;
+import com.taobao.api.FileItem;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+
+/**
+ * @author 3y
+ */
+@Slf4j
+@Service
+public class MaterialServiceImpl implements MaterialService {
+
+    @Autowired
+    private StringRedisTemplate redisTemplate;
+    private static final String DING_DING_URL = "https://oapi.dingtalk.com/media/upload";
+
+    @Override
+    public BasicResultVO dingDingMaterialUpload(MultipartFile file, String sendAccount, String fileType) {
+        OapiMediaUploadResponse rsp;
+        try {
+            String accessToken = redisTemplate.opsForValue().get(SendAccountConstant.DING_DING_ACCESS_TOKEN_PREFIX + sendAccount);
+            DingTalkClient client = new DefaultDingTalkClient(DING_DING_URL);
+            OapiMediaUploadRequest req = new OapiMediaUploadRequest();
+            FileItem item = new FileItem(new StringBuilder().append(IdUtil.fastSimpleUUID()).append(file.getOriginalFilename()).toString(),
+                    file.getInputStream());
+            req.setMedia(item);
+            req.setType(FileType.dingDingNameByCode(fileType));
+            rsp = client.execute(req, accessToken);
+            if (rsp.getErrcode() == 0L) {
+                return new BasicResultVO(RespStatusEnum.SUCCESS, UploadResponseVo.builder().id(rsp.getMediaId()).build());
+            }
+            log.error("MaterialService#dingDingMaterialUpload fail:{}", rsp.getErrmsg());
+        } catch (Exception e) {
+            log.error("MaterialService#dingDingMaterialUpload fail:{}", Throwables.getStackTraceAsString(e));
+        }
+        return BasicResultVO.fail("未知错误，联系管理员");
+    }
+
+}
diff --git a/austin-web/src/main/java/com/java3y/austin/web/vo/UploadResponseVo.java b/austin-web/src/main/java/com/java3y/austin/web/vo/UploadResponseVo.java
new file mode 100644
index 0000000..459e965
--- /dev/null
+++ b/austin-web/src/main/java/com/java3y/austin/web/vo/UploadResponseVo.java
@@ -0,0 +1,18 @@
+package com.java3y.austin.web.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+
+/**
+ * 上传后成功返回素材的Id
+ */
+@Builder
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class UploadResponseVo {
+    private String id;
+}
diff --git a/austin-web/src/main/resources/application.properties b/austin-web/src/main/resources/application.properties
index ef0bf5f..9b8f82e 100644
--- a/austin-web/src/main/resources/application.properties
+++ b/austin-web/src/main/resources/application.properties
@@ -52,6 +52,8 @@ spring.redis.password=${austin-redis-password}
 
 ##################### business properties #####################
 austin.business.topic.name=austinBusiness
+austin.business.recall.topic.name=austinRecall
+austin.business.recall.group.name=recallGroupId
 austin.business.log.topic.name=austinLog
 austin.business.graylog.ip=${austin-grayLog-ip}
 # TODO if windows os ,replace path !