使用钉钉stream模式监听OA审批当审批同意后触发修改数据库数据的代码

使用钉钉Stream模式监听OA审批并触发修改数据库操作，可以按照以下几个步骤来实现：

首先，你需要定义一个事件处理器类，比如`DingTalkApprovalHandler`，并添加对钉钉审批事件的监听：

import com.dingtalk.api.event.OAApprovalEvent;
import com.dingtalk.api.request.OATokenRequest;
import com.dingtalk.api.response.OATokenResponse;

public class DingTalkApprovalHandler {
    private static final String CORP_ID = "your_corp_id";
    private static final String APP_KEY = "your_app_key";
    private static final String APP_SECRET = "your_app_secret";

    // ...其他初始化和认证方法...

    public void listenForApprovalEvents() {
        OATokenRequest tokenRequest = new OATokenRequest(CORP_ID, APP_KEY, APP_SECRET);
        OATokenResponse tokenResponse = dingtalkClient.execute(tokenRequest);

        // 获取access_token和token_type用于后续请求
        String accessToken = tokenResponse.getAccessToken();
        StringTokenType tokenType = tokenResponse.getTokenType();

        // 创建WebSocket连接
        WebSocket webSocket = dingtalkClient.createWebSocket(accessToken, tokenType);
        webSocket.addEventListener(event -> {
            if (event instanceof OAApprovalEvent) {
                OAApprovalEvent approvalEvent = (OAApprovalEvent) event;
                if (approvalEvent.getAction() == ApprovalAction.APPROVED) { // 检查是否审批同意
                    handleApprovedApproval(approvalEvent); // 调用处理审批通过的方法
                }
            }
        });
    }

    private void handleApprovedApproval(OAApprovalEvent approvalEvent) {
        // 根据审批Event获取相关信息，如审批id和申请人等
        Long appId = approvalEvent.getAppId();
        User user = approvalEvent.getUser(); // ...

        // 连接到数据库
        try (Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/your_database", "username", "password")) {
            // 更新审批结果至数据库
            PreparedStatement ps = connection.prepareStatement("UPDATE approvals SET status = 'approved', approver = ? WHERE id = ?");
            ps.setString(1, user.getName());
            ps.setLong(2, appId);
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

这里假设你已经有一个数据库连接以及一个封装好的DingTalk API客户端(`dingtalkClient`)。你需要替换上述代码中的`your_corp_id`, `your_app_key`, `your_app_secret`, `mysql连接信息`等为实际环境变量。