<!--
        說明: 下面的兩個釘釘依賴目前來說都需要, 因為新版并沒有完全覆蓋舊版中的功能
        (官方說明: 現(xiàn)狀：舊版服務(wù)端API和新版服務(wù)端API開放的產(chǎn)品能力不同，即新版服務(wù)端API未包含全部的服務(wù)端API的產(chǎn)品能力，請根據(jù)實際需求，選擇需要的API接入)
        資料鏈接: https://open.dingtalk.com/document/orgapp/differences-between-server-apis-and-new-server-apis?spm=ding_open_doc.document.0.0.200e2b49DAUrx4

        -->
        <!-- 釘釘新版SDK模塊 -->
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>dingtalk</artifactId>
            <version>2.2.33</version>
        </dependency>

        <!-- 釘釘舊版SDK模塊 -->
        <!--
        對于老版本依賴包目前來說還沒有辦法從中央倉庫拉取(中央倉庫版本過舊), 只能通過jar包手動的安裝到本地或者服務(wù)器maven倉庫中
        詳情請見: https://open.dingtalk.com/document/isvapp/download-the-server-side-sdk-2
        下載鏈接: https://open-dev.dingtalk.com/download/openSDK/java?spm=ding_open_doc.document.0.0.2ce83ca70MjetW
        -->
        <dependency>
            <groupId>com.taobao.sdk</groupId>
            <artifactId>taobao-sdk-java-auto</artifactId>
            <version>2025.07.17</version>
        </dependency>

        <!-- 釘釘Stream模塊 用于推送和訂閱消息 -->
        <dependency>
            <groupId>com.dingtalk.open</groupId>
            <artifactId>app-stream-client</artifactId>
            <version>1.3.6</version>
        </dependency>

/**
 * @author : Cookie
 * date : 2025/8/8
 */
public class DingDingAPITest {

    private final String appKey = "dingxw1111111kgdb";
    private final String appSecret = "2hN-XXSu7BwpLUSRbvGdeNvEMrfKHjy_1111111111111ThLwYqHFLrL";


    /**
     * 通過appKey和appSecret獲取access_token
     */
    @Test
    public void getAccessTokenTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
            OapiGettokenRequest req = new OapiGettokenRequest();
            req.setAppkey(appKey);
            req.setAppsecret(appSecret);
            req.setHttpMethod("GET");
            OapiGettokenResponse rsp = client.execute(req);
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }


    /**
     * 獲取部門列表
     */
    @Test
    public void getDepartmentListTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsub");
            OapiV2DepartmentListsubRequest req = new OapiV2DepartmentListsubRequest();
            OapiV2DepartmentListsubResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取部門的子部門列表
     */
    @Test
    public void getMessageTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsubid");
            OapiV2DepartmentListsubidRequest req = new OapiV2DepartmentListsubidRequest();
            req.setDeptId(664446160L);
            OapiV2DepartmentListsubidResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取部門用戶userid列表
     */
    @Test
    public void userIdList() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/user/listid");
            OapiUserListidRequest req = new OapiUserListidRequest();
            req.setDeptId(664286346L);
            OapiUserListidResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 根據(jù)系統(tǒng)中的用戶ID查詢用戶信息
     */
    @Test
    public void getUserInfoTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
            OapiV2UserGetRequest req = new OapiV2UserGetRequest();
            req.setUserid("1912096523433372683");
            OapiV2UserGetResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取企業(yè)考勤報表列
     */
    @Test
    public void getAttendanceColumnsTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/attendance/getattcolumns");
            OapiAttendanceGetattcolumnsRequest req = new OapiAttendanceGetattcolumnsRequest();
            OapiAttendanceGetattcolumnsResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取考勤報表列定義
     */
    @Test
    public void getAttendanceRecordColumnsTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/attendance/getattcolumns");
            OapiAttendanceGetattcolumnsRequest req = new OapiAttendanceGetattcolumnsRequest();
            OapiAttendanceGetattcolumnsResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 指定用戶考勤查詢
     */
    @Test
    public void getAttendanceRecordTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/attendance/getcolumnval");
            OapiAttendanceGetcolumnvalRequest req = new OapiAttendanceGetcolumnvalRequest();
            req.setUserid("022762312345635565");
            req.setColumnIdList("281432955,281432956,281432958,281432961");
            req.setFromDate(StringUtils.parseDateTime("2025-07-01 08:00:00"));
            req.setToDate(StringUtils.parseDateTime("2025-07-31 20:00:00"));
            OapiAttendanceGetcolumnvalResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取打卡詳情
     */
    @Test
    public void getCheckinRecordTest() {
        try {
            DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/attendance/listRecord");
            OapiAttendanceListRecordRequest req = new OapiAttendanceListRecordRequest();
            req.setUserIds(Arrays.asList("4952111165934", "0227623222235565", "0225373333171716"));
            req.setCheckDateFrom("2025-08-14 08:00:00");
            req.setCheckDateTo("2025-08-20 08:00:00");
            OapiAttendanceListRecordResponse rsp = client.execute(req, "6d5bd176e2fd3e111111149ae4d104");
            System.out.println(rsp.getBody());
        } catch (ApiException e) {
            e.printStackTrace();
        }
    }

    /**
     * 釘釘Stream模塊測試
     */
    public static void main(String[] args) throws Exception {

        OpenDingTalkStreamClientBuilder
                .custom()
                .credential(new AuthClientCredential("dingxw1111111kgdb", "2hN-XXSu7BwpLUSRbvGdeNvEMrfKHjy_1111111111111ThLwYqHFLrL"))
                //注冊事件監(jiān)聽
                .registerAllEventListener(new GenericEventListener() {
                    public EventAckStatus onEvent(GenericOpenDingTalkEvent event) {
                        try {
                            //事件唯一Id
                            String eventId = event.getEventId();
                            //事件類型
                            String eventType = event.getEventType();
                            //事件產(chǎn)生時間
                            Long bornTime = event.getEventBornTime();
                            //獲取事件體
                            JSONObject bizData = event.getData();
                            //處理事件
//                                process(bizData);
                            System.out.println(bizData);
                            //消費成功
                            return EventAckStatus.SUCCESS;
                        } catch (Exception e) {
                            //消費失敗
                            return EventAckStatus.LATER;
                        }
                    }
                })
                .build().start();
    }
}