OpenClaw 只能命令行触发?自研企业微信实现“发消息即执行“

# 命令行触发openclaw run --prompt "登录系统，填写表单"# 或者调用 APIcurl -X POST http://localhost:3000/api/run \  -d '{"prompt": "登录系统，填写表单"}'

报修 空调不制冷 3楼302 张三

# application.ymlsmartclaw:  wechat:    work:      enabled: true      corp-id: wwxxxxxxxxxxxxx      agent-id: 1000001      agent-secret: xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx      token: SmartClaw2026      encoding-aes-key: xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx

@RestController@RequestMapping("/api/wechat/work")@Slf4jpublic class WechatWorkCallbackController {    @Autowired    private WxMsgDecryptService decryptService;    @Autowired    private WechatMessageDispatcher dispatcher;    /**     * 企业微信验证 URL 有效性（GET 请求）     */    @GetMapping("/callback")    public String verify(            @RequestParam String msg_signature,            @RequestParam String timestamp,            @RequestParam String nonce,            @RequestParam String echostr) {        log.info("Verifying URL: timestamp={}, nonce={}", timestamp, nonce);        try {            // 验签 + 解密 echostr            String decryptedEchostr = decryptService.verifyUrl(                msg_signature, timestamp, nonce, echostr            );            log.info("URL verification successful");            return decryptedEchostr;  // 必须原样返回        } catch (Exception e) {            log.error("URL verification failed", e);            return "fail";        }    }    /**     * 接收企业微信推送消息（POST 请求）     */    @PostMapping("/callback")    public String callback(            @RequestBody String rawXml,            @RequestParam String msg_signature,            @RequestParam String timestamp,            @RequestParam String nonce) {        log.info("Received message: timestamp={}", timestamp);        try {            // 1. 验签 + 解密            WxWorkMessage message = decryptService.decryptMessage(                rawXml, msg_signature, timestamp, nonce            );            log.info("Decrypted message: from={}, content={}",                      message.getFromUserName(), message.getContent());            // 2. 只处理文本消息            if ("text".equalsIgnoreCase(message.getMsgType())) {                // 3. 异步 dispatch，避免阻塞企业微信回调                dispatcher.dispatchAsync(message);            }            // 4. 必须返回 success，否则企业微信会重试            return "success";        } catch (Exception e) {            log.error("Callback processing failed", e);            // 即使失败也要返回 success，避免企业微信无限重试            return "success";        }    }}

<!-- pom.xml --><dependency>    <groupId>com.github.binarywang</groupId>    <artifactId>weixin-java-cp</artifactId>    <version>4.5.0</version></dependency>

@Service@Slf4jpublic classWxMsgDecryptService{    @Value("{smartclaw.wechat.work.encoding-aes-key}")    private String encodingAesKey;    @Value("',    'store-repair-ticket-v1',    '["issue","location","reporter"]',    100);

@Service@Slf4jpublic class MessageRuleService {    @Autowired    private MessageRuleRepository ruleRepository;    @Autowired    private TaskDispatchService dispatchService;    /**     * 匹配消息并触发任务     */    public Optional<DispatchResult> matchAndDispatch(WxWorkMessage message) {        String content = message.getContent().trim();        String sender = message.getFromUserName();        log.info("Matching message: content={}, sender={}", content, sender);        // 1. 从数据库加载启用的规则（按优先级排序）        List<MessageRule> rules = ruleRepository.findEnabledRulesOrderByPriorityDesc();        for (MessageRule rule : rules) {            // 2. 正则匹配            Matcher matcher = Pattern.compile(rule.getPattern()).matcher(content);            if (matcher.matches()) {                log.info("Rule matched: ruleName={}", rule.getName());                // 3. 提取命名捕获组作为变量                Map<String, String> variables = extractNamedGroups(matcher, rule);                // 4. 注入发送者信息                variables.put("_senderUserId", sender);                variables.put("_msgId", message.getMsgId());                // 5. 构建 dispatch 请求                DispatchRequest request = DispatchRequest.builder()                    .templateId(rule.getTemplateId())                    .variables(variables)                    .idempotencyKey("wechat_work:" + message.getMsgId())                    .source("WECHAT_WORK")                    .requesterOpenId(sender)                    .build();                // 6. 下发任务                DispatchResult result = dispatchService.dispatch(request);                log.info("Task dispatched: runId={}", result.getRunId());                return Optional.of(result);            }        }        log.warn("No rule matched for message: {}", content);        // 无匹配规则：发送默认回复        sendDefaultReply(sender, content);        return Optional.empty();    }    /**     * 提取正则命名捕获组     */    private Map<String, String> extractNamedGroups(Matcher matcher, MessageRule rule) {        Map<String, String> vars = new HashMap<>();        // 解析 variable_names JSON 数组        List<String> varNames = parseJsonArray(rule.getVariableNames());        for (String groupName : varNames) {            try {                String value = matcher.group(groupName);                vars.put(groupName, value);                log.debug("Extracted variable: {}={}", groupName, value);            } catch (IllegalArgumentException e) {                log.warn("Group not found: {}", groupName);            }        }        return vars;    }    private List<String> parseJsonArray(String jsonArray) {        // 使用 Jackson 或 Gson 解析 JSON        try {            return objectMapper.readValue(                jsonArray,                 new TypeReference<List<String>>() {}            );        } catch (Exception e) {            log.error("Failed to parse JSON array", e);            return Collections.emptyList();        }    }}

@Service@Slf4jpublic class WechatMessageDispatcher {    @Autowired    private MessageRuleService ruleService;    @Autowired    private WechatWorkApiClient wechatApiClient;    /**     * 异步 dispatch（避免阻塞企业微信回调）     */    @Async("wechatExecutor")    public void dispatchAsync(WxWorkMessage message) {        try {            Optional<DispatchResult> result = ruleService.matchAndDispatch(message);            if (result.isPresent()) {                log.info("Message processed successfully: msgId={}", message.getMsgId());            } else {                log.warn("Message not matched: msgId={}", message.getMsgId());            }        } catch (Exception e) {            log.error("Message dispatch failed: msgId={}", message.getMsgId(), e);            // 发送错误回复            wechatApiClient.sendText(                message.getFromUserName(),                "❌ 处理失败：" + e.getMessage()            );        }    }}

@Service@Slf4jpublic class WechatWorkApiClient {    private static final String TOKEN_URL =         "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={}&corpsecret={}";    private static final String SEND_URL =         "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={}";    @Value("{smartclaw.wechat.work.agent-secret}")    private String agentSecret;    @Value("// 提取变量issue = "空调不制冷"location = "3楼302"reporter = "张三"

DispatchRequest request = DispatchRequest.builder()    .templateId("store-repair-ticket-v1")    .variables(Map.of(        "issue", "空调不制冷",        "location", "3楼302",        "reporter", "张三"    ))    .idempotencyKey("wechat_work:1234567890")    .source("WECHAT_WORK")    .requesterOpenId("ZhangSan")    .build();dispatchService.dispatch(request);

steps:  - stepId: s1    action: navigate    params:      url: "https://support.example.com/ticket/new"  - stepId: s2    action: fill    params:      selector: "input[name='name']"      value: "{issue}"  # 空调不制冷  - stepId: s4    action: fill    params:      selector: "input[name='room']"      value: "${location}"  # 3楼302  - stepId: s5    action: clickRole    params:      role: "button"      name: "提交工单"  - stepId: s6    action: waitText    params:      text: "工单已创建"      timeoutMs: 8000

✅ **自动化任务完成**> 任务：门店报修派单> 流水号：c6efed0a> 耗时：4823ms> 时间：04-27 14:32:11

LoadingCache<String, String> tokenCache = CacheBuilder.newBuilder()    .expireAfterWrite(7000, TimeUnit.SECONDS)  // 7000 秒过期    .build(CacheLoader.from(this::fetchAccessToken));

@Async("wechatExecutor")public void dispatchAsync(WxWorkMessage message) {    // 异步处理，立即返回 success}

@Configurationpublic class WechatExecutorConfig {    @Bean("wechatExecutor")    public Executor wechatExecutor() {        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();        executor.setCorePoolSize(5);        executor.setMaxPoolSize(10);        executor.setQueueCapacity(100);        executor.setThreadNamePrefix("wechat-");        executor.initialize();        return executor;    }}

.idempotencyKey("wechat_work:" + message.getMsgId())