整合钉钉和企业微信

tjx

5 天以前 bf871e3e73b048d1368ff7cc77ac720905c91167

整合钉钉和企业微信

 src/main/java/com/gs/dingtalk/config/DataAcquisitionConfiguration.java

@@ -3,25 +3,6 @@

public class DataAcquisitionConfiguration {

    //测试环境
    public static final String TEST_COMPANY_CODE = "55958795";

    public static final String TEST_APP_KEY = "ab2d86b6dffabcc81dca6855c727c246";

    public static final String TEST_APP_SECRET = "01b17babe2a96d5ebd802e67709f33d1";

    public static final String TEST_ERP_CODE = "Z106";

    //正式环境
    public static final String COMPANY_CODE = "72505985";

    public static final String APP_KEY = "a2866f03bb7f76387bfb1a98001f0e31";

    public static final String APP_SECRET = "f13bd1bcb130f0090ed92dc021e5f4e1";

    public static final String ERP_CODE = "Z106";


    /**
     * 应用的 AgentId
     */

 src/main/java/com/gs/dingtalk/service/SimpleExample.java

@@ -61,7 +61,7 @@
        try {
            Long timestamp = System.currentTimeMillis();
            System.out.println(timestamp);
            String secret = DataAcquisitionConfiguration.SECRET;
            String secret = DataAcquisitionConfiguration.TALK_APP_SECRET;
            String stringToSign = timestamp + "\n" + secret;
            Mac mac = Mac.getInstance("HmacSHA256");
            mac.init(new SecretKeySpec(secret.getBytes("UTF-8"), "HmacSHA256"));
@@ -164,8 +164,8 @@
    public String getAccessToken() throws Exception {
        Client client = createClient();
        GetAccessTokenRequest getAccessTokenRequest = new GetAccessTokenRequest()
                .setAppKey(DataAcquisitionConfiguration.APP_KEY)
                .setAppSecret(DataAcquisitionConfiguration.APP_SECRET);
                .setAppKey(DataAcquisitionConfiguration.TALK_APP_KEY)
                .setAppSecret(DataAcquisitionConfiguration.TALK_APP_SECRET);
        try {
            GetAccessTokenResponse accessToken = client.getAccessToken(getAccessTokenRequest);
            return accessToken.body.getAccessToken();
@@ -208,20 +208,20 @@
    }


    public OapiV2UserGetbymobileResponse getOapiV2UserGetbymobileResponse(SendDingtalk s, String accessToken) {
        DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/getbymobile");
        OapiV2UserGetbymobileRequest req = new OapiV2UserGetbymobileRequest();
        req.setMobile(s.getTelephone());
        req.setSupportExclusiveAccountSearch(true);
        OapiV2UserGetbymobileResponse rsp = null;

        try {
            rsp = client.execute(req, accessToken);
        } catch (ApiException e) {
            throw new RuntimeException(e);
        }
        return rsp;
    }
    //    public OapiV2UserGetbymobileResponse getOapiV2UserGetbymobileResponse(SendDingtalk s, String accessToken) {
//        DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/getbymobile");
//        OapiV2UserGetbymobileRequest req = new OapiV2UserGetbymobileRequest();
//        req.setMobile(s.getTelephone());
//        req.setSupportExclusiveAccountSearch(true);
//        OapiV2UserGetbymobileResponse rsp = null;
//
//        try {
//            rsp = client.execute(req, accessToken);
//        } catch (ApiException e) {
//            throw new RuntimeException(e);
//        }
//        return rsp;
//    }

    public OapiV2UserGetbymobileResponse getOapiV2UserGetbymobileResponse(String mobile, String accessToken) {
        DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/getbymobile");

 src/test/java/com/gs/dingtalk/DeviceReceivingApplicationTests.java

@@ -33,21 +33,21 @@
    void testExportAndSendProductionData() throws Exception {
        System.out.println("=== 开始测试导出生产数据并发送钉钉 ===");

//        try {
//            boolean result = vwCjScSjTsBbService.exportAndSendToDingtalk();
//
//            if (result) {
//                System.out.println("✓ 生产数据导出并发送成功");
//                System.out.println("  - 数据已从 VW_CJ_SC_SJ_TS_BB 表查询");
//                System.out.println("  - Excel 文件已生成并保存到 D:\\BIFile\\");
//                System.out.println("  - 钉钉文件消息已发送");
//            } else {
//                System.out.println("✗ 生产数据导出或发送失败");
//            }
//        } catch (Exception e) {
//            System.out.println("✗ 导出并发送时发生异常: " + e.getMessage());
//            e.printStackTrace();
//        }
        try {
            boolean result = vwCjScSjTsBbService.exportAndSendToDingtalk();

            if (result) {
                System.out.println("✓ 生产数据导出并发送成功");
                System.out.println("  - 数据已从 VW_CJ_SC_SJ_TS_BB 表查询");
                System.out.println("  - Excel 文件已生成并保存到 D:\\BIFile\\");
                System.out.println("  - 钉钉文件消息已发送");
            } else {
                System.out.println("✗ 生产数据导出或发送失败");
            }
        } catch (Exception e) {
            System.out.println("✗ 导出并发送时发生异常: " + e.getMessage());
            e.printStackTrace();
        }

        System.out.println("=== 测试结束 ===");
    }