二开,第三方软件对接数据推送原创
金蝶云社区-Lii_Ji
Lii_Ji
16人赞赏了该文章 112次浏览 未经作者许可,禁止转载编辑于2024年09月14日 15:43:34

     /// <summary>

    /// 数据发送工具类(Post)

    /// </summary>

    public class PostHelper

    {

        /// <summary>

        /// 键值对生成json请求参数

        /// </summary>

        /// <param name="source"></param>

        /// <returns></returns>

        public static string ToPostJson(Dictionary<string, string> source)

        {

            string res = "";

            var buff = new StringBuilder(string.Empty);

            if (source == null)

                throw new ArgumentNullException("source", "Unable to convert object to a dictionary. The source object is null.");

            buff.Append("{");

            foreach (var key in source.Keys)

            {

                string value = source[key];

                if (value != null)

                {

                    buff.Append("\"" + key + "\"" + ":" + "\"" + value + "\"" + ",");

                }

            }

            res = buff.ToString();

            //buff.ToString().Trim(',');

            //buff.Append("}");

            res = res.Trim(',');

            res += "}";

            return res;

        }


        /// <summary>

        /// 请求方法

        /// </summary>

        /// <param name="url"></param>

        /// <param name="postdata"></param>

        /// <returns></returns>

        public static string PostUrl(string url, string postdata)

        {

            string result = "";

            try

            {

                HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);

                req.Method = "POST";//请求方式

                req.ContentType = "application/json";//请求参数的格式

                req.Timeout = 1000 * 10 * 60;//请求超时时间

                byte[] data = Encoding.UTF8.GetBytes(postdata);

                req.ContentLength = data.Length;

                using (Stream reqStream = req.GetRequestStream())

                {

                    reqStream.Write(data, 0, data.Length);

                    reqStream.Close();

                }

                HttpWebResponse resp = (HttpWebResponse)req.GetResponse();

                Stream stream = resp.GetResponseStream();

                using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))//获取响应内容

                {

                    result = reader.ReadToEnd();

                }

            }

            catch (Exception e)

            {


            }

            return result;

        }



     

        /// <summary>  

        /// 请求方法  

        /// </summary>  

        /// <param name="url">请求的URL</param>  

        /// <param name="postdata">POST请求的数据</param>  

        /// <param name="customHeaderName">自定义请求头的名称</param>  

        /// <param name="customHeaderValue">自定义请求头的值</param>  

        /// <returns>响应的字符串</returns>  

        public static string PostUrl(string url, string postdata, string customHeaderName, string customHeaderValue)

        {

            string result = "";

            try

            {

                HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);

                req.Method = "POST"; // 请求方式  

                req.ContentType = "application/json"; // 请求参数的格式  

                req.Timeout = 1000 * 10 * 60; // 请求超时时间  


                // 添加自定义请求头  

                req.Headers[customHeaderName] = customHeaderValue;


                byte[] data = Encoding.UTF8.GetBytes(postdata);

                req.ContentLength = data.Length;


                using (Stream reqStream = req.GetRequestStream())

                {

                    reqStream.Write(data, 0, data.Length);

                }


                HttpWebResponse resp = (HttpWebResponse)req.GetResponse();

                Stream stream = resp.GetResponseStream();

                using (StreamReader reader = new StreamReader(stream, Encoding.UTF8)) // 获取响应内容  

                {

                    result = reader.ReadToEnd();

                }

            }

            catch (Exception e)

            {

                // 这里可以添加异常处理逻辑,比如记录日志  

                // Console.WriteLine(e.ToString());  

            }

            return result;

        }


    }




-------------------------------------------------------------------------------------------------------------------------------------------------------------


    [HotUpdate]

    [Description("【执行计划】 钉钉付款申请单同步")]

    public class KingdeeTBDD : AbstractBillPlugIn

    {


        public class TokenResponse

        {

            public int? ExpireIn { get; set; }

            public string AccessToken { get; set; }

        }


        public class InstanceIdsResponse

        {

            public bool Success { get; set; }

            public Result Resul { get; set; }


            // 内部类来存储result对象的属性  

            public class Result

            {

                public int? NextToken { get; set; }

                public List<string> List { get; set; }

            }

        }


        private string accessToken;


        private List<string> instanceIds;


        public override void AfterBarItemClick(AfterBarItemClickEventArgs e)

        {

            base.AfterBarItemClick(e);

            if (e.BarItemKey.EqualsIgnoreCase("F_YDL_DDTB"))

            {


                Dictionary<string, string> kv = new Dictionary<string, string>();

                kv.Add("appKey", "");

                kv.Add("appSecret", "");


                var TOKEN = PostHelper.PostUrl("https://api.dingtalk.com/v1.0/oauth2/accessToken", PostHelper.ToPostJson(kv));


                TokenResponse root = JsonConvert.DeserializeObject<TokenResponse>(TOKEN);


                // 检查expireIn是否存在且为7200  

                if (root?.ExpireIn.HasValue == true && root.ExpireIn.Value == 7200)

                {

                    // 如果条件满足,获取并使用accessToken  

                    accessToken = root.AccessToken;


                }

                else

                {

                    Logger.Info("API接口提示:TOKEN返回错误请检查APPKEY和APPSERCRET的数据!", TOKEN);

                    return;

                }


                if (!accessToken.IsNullOrEmptyOrWhiteSpace())

                {


                    // 获取当前UTC时间  

                    DateTime utcNow = DateTime.UtcNow;

                    var endTime = (utcNow - new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc)).TotalMilliseconds;


                    DateTime utcTwoHoursAgo = utcNow.AddHours(-60);

                    var startTime = (utcTwoHoursAgo - new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc)).TotalMilliseconds;


                    Dictionary<string, object> kk = new Dictionary<string, object>();

                    kk.Add("startTime", startTime);

                    kk.Add("endTime", endTime);

                    kk.Add("processCode", "PROC-63643A59-18F0-4FBA-B9E2-C7E2FBDE3C7A");

                    kk.Add("nextToken", 0);

                    kk.Add("maxResults", 20);

                    kk.Add("statuses", new List<string> { "COMPLETED" });

                    string json = JsonConvert.SerializeObject(kk);

                    var SLID = PostHelper.PostUrl("https://api.dingtalk.com/v1.0/workflow/processes/instanceIds/query", json, "x-acs-dingtalk-access-token", accessToken);


                    InstanceIdsResponse response = JsonConvert.DeserializeObject<InstanceIdsResponse>(SLID);


                    // 假设 response 已经被正确反序列化为 InstanceIdsResponse 类型的对象  

                    if (response?.Success == true) // 或者简单地写作 if (response?.Success ?? false)  

                    {

                        // 如果 success 为 true,则访问 result.list  

                        if (response.Resul?.List != null)

                        {

                            foreach (var instanceId in response.Resul.List)

                            {

                                // 将 instanceId 添加到新数组中  

                                instanceIds.Add(instanceId);


                            }

                        }

                        else

                        {

                            // 如果 result.List 为 null,则记录日志(可选)  

                            Logger.Info("API接口返回的实例ID列表为空!", SLID);

                        }

                    }

                    else

                    {

                        // 如果 success 不为 true,则记录日志  

                        Logger.Info("API接口提示:获取审批实例ID列表异常!", SLID);

                        return;  

                    }



                }


       

            }

        }

    }


图标赞 16
16人点赞
还没有人点赞,快来当第一个点赞的人吧!
图标打赏
0人打赏
还没有人打赏,快来当第一个打赏的人吧!

您的鼓励与嘉奖将成为创作者们前进的动力,如果觉得本文还不错,可以给予作者创作打赏哦!

请选择打赏金币数 *

10金币20金币30金币40金币50金币60金币
可用金币: 0