yili-onemap/api/QM.KJGH.CGGL/QM.KJGH.CGGL.NMCGHJ/BYNE/BYNEApi.cs

using Microsoft.AspNetCore.Http;
using QM.KJGH.CGGL.Model.CGSBT;
using QM.KJGH.CGGL.Model.QxCghj;
using QM.KJGH.CGGL.NMCGHJ.QX.Models;
using QM.KJGH.Model.KJGH.CGHJ;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WS;
using WS.AutoMapper;
using WS.Http;
using WS.Log;

namespace QM.KJGH.CGGL.NMCGHJ.QX
{
    public class BYNEApi
    {
        /// <summary>
        /// 登录获取Token接口
        /// </summary>
        /// <param name=""></param>
        /// <returns></returns>
        public static string GetToken()
        {
            RunLog.Info("登录获取Token接口");
            //参数
            Dictionary<string, string> pars = new Dictionary<string, string>();
            pars.Add("grant_type", BYNEConfig.GRANT_TYPE);
            pars.Add("username", BYNEConfig.USERNAME);
            pars.Add("password", BYNEConfig.PASSWORD);
            pars.Add("scope", BYNEConfig.SCOPE);

            var urlParam = ApiHelper.FormatUrlParam(pars, BYNEConfig.URL_TOKEN);
            RunLog.Info("登录获取Token接口请求：" + urlParam);
            var res = HttpHelper.HttpPost(urlParam, string.Empty, GetHeaders());
            RunLog.Info("登录获取Token接口返回：" + res);
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Data == null && string.IsNullOrWhiteSpace(resModel.Msg))
            {
                BYNEResToken token = res.ToModel<BYNEResToken>();
                return token.access_token;
            }
            return "";
        }

        /// <summary>
        /// 统一请求头
        /// </summary>
        public static Dictionary<string, string> GetHeaders(string token = "")
        {
            //设置请求头
            Dictionary<string, string> headers = new Dictionary<string, string>();
            if (string.IsNullOrWhiteSpace(token))
                headers.Add("Authorization", BYNEConfig.AUTHORIZATION);
            else
                headers.Add("Authorization", $"bearer {token}");
            return headers;
        }

        #region 规划成果
        /// <summary>
        /// 接口1：检查文件分片信息
        /// </summary>
        /// <returns></returns>
        public static BYNECghjView Md5(BYNECghjMd5Io input)
        {
            //请求头
            var token = GetToken();
            var headers = GetHeaders(token);
            //参数
            Dictionary<string, string> pars = input.ToDictionary<string>();

            var urlParam = ApiHelper.FormatUrlParam(pars);
            RunLog.Info($"检查文件分片信息：{BYNEConfig.URL_RESULTS_MD5} => {urlParam}");
            var res = HttpHelper.HttpGet(BYNEConfig.URL_RESULTS_MD5, urlParam, headers);
            RunLog.Info($"检查文件分片信息返回：" + res.ToJson());
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Code == 200)
                {
                var qx = resModel.Data.ToJson().ToModel<BYNECghjView>();
                qx.token = token;
                return qx;
            }
            else
            {
                RunLog.Debug("检查文件分片信息失败=>" + res);
                throw new UseArgumentException("检查文件分片信息失败：" + resModel.Msg);
            }
        }
        /// <summary>
        /// 接口2：上传成果包
        /// </summary>
        /// <param name="input"></param>
        /// <param name="upfile">成果包压缩包（ZIP格式）</param>
        /// <returns></returns>
        public static string Upload(BYNECghjFpIo_QX input, string upfile)
        {
            //请求头
            var headers = GetHeaders(input.token);
            //BodyFormat参数
            var bodys = input.MapTo<BYNECghjFpIo>().ToDictionary<string>();
            //文件
            var files = new Dictionary<string, string>();
            files.Add("upfile", upfile);

            RunLog.Info($"上传成果包接口：{BYNEConfig.URL_RESULTS_UPLOAD} => {input.ToJson()} =>{upfile}");
            var res = ApiHelper.HttpPostFormdata(BYNEConfig.URL_RESULTS_UPLOAD, headers: headers, postData:bodys, files:files, timeOut: BYNEConfig.TIME_OUT);
            RunLog.Info("上传成果包接口返回：" + res);
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Code == 200)
            {
                return resModel.Data.ToString();
            }
            else
            {
                RunLog.Debug("分片上传成果包失败=>" + res);
                throw new UseArgumentException("操作失败：" + resModel.Msg);
            }
        }

        /// <summary>
        /// 接口3：大文件分片合并
        /// </summary>
        /// <returns></returns>
        public static string Merge(BYNECghjMergeIo input, string token)
        {
            //请求头
            var headers = GetHeaders(token);
            //参数
            Dictionary<string, string> pars = input.ToDictionary<string>();

            #region 20230523 修改接口参数方式
            //var urlParam = ApiHelper.FormatUrlParam(pars, BYNEConfig.URL_RESULTS_MERGE);
            //RunLog.Info($"文件分片合并：{urlParam}");
            //var res = HttpHelper.HttpPost(urlParam, string.Empty, headers);
            RunLog.Info($"上报成果包信息：{BYNEConfig.URL_RESULTS_MERGE} => {input.ToJson()}");
            var res = HttpHelper.HttpPost(BYNEConfig.URL_RESULTS_MERGE, input.ToJson(), headers);
            #endregion
            RunLog.Info($"文件分片合并返回：" + res.ToJson());
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Code == 200)
            {
                return resModel.Data.ToString();
            }
            else
            {
                RunLog.Debug("文件分片合并失败=>" + res);
                throw new UseArgumentException("文件分片合并失败：" + resModel.Msg);
            }
        }

        /// <summary>
        /// 接口4：上报成果包信息
        /// </summary>
        /// <returns></returns>
        public static bool Complete(BYNECghjIo input, string zjbgFile, string token)
        {
            //请求头
            var headers = GetHeaders(token);
            //参数
            Dictionary<string, string> bodys = input.ToDictionary<string>();
            
            //文件
            var files = new Dictionary<string, string>();
            files.Add("zjbgFile", zjbgFile);

            RunLog.Info($"上报成果包信息：{BYNEConfig.URL_RESULTS_COMPLETE} => {input.ToJson()} =>{zjbgFile}");
            var res = ApiHelper.HttpPostFormdata(BYNEConfig.URL_RESULTS_COMPLETE, headers: headers, postData:bodys, files:files, timeOut: BYNEConfig.TIME_OUT);
            RunLog.Info($"上报成果包信息返回：" + res.ToJson());
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Code == 200)
            {
                return true;
            }
            else
            {
                RunLog.Debug("上报成果包信息失败=>" + res);
                throw new UseArgumentException("上报成果包信息失败：" + resModel.Msg);
            }
        }
        #endregion


        #region 监测指标
        /// <summary>
        /// 规划值导入模板下载
        /// </summary>
        /// <returns></returns>
        public static string GetGhzTemplate(string path)
        {
            var file = ApiHelper.HttpDownFile(BYNEConfig.URL_JCYJ_GHZ_TEMPLATE, path, GetHeaders(GetToken()), timeOut: BYNEConfig.TIME_OUT);
            if(string.IsNullOrWhiteSpace(file) || !File.Exists(file))
            {
                throw new UseArgumentException("规划值导入模板下载失败");
            }
            return file;
        }
        /// <summary>
        /// 规划值导入
        /// </summary>
        /// <returns></returns>
        public static bool JcyjGhzUpload(string file)
        {
            var files = new Dictionary<string, string>();
            files.Add("file", file);
            RunLog.Info($"规划值导入接口：{file}");
            string res = string.Empty;
            if(BYNEConfig.GRANT_TYPE == "GET")
                res = ApiHelper.HttpGetFormdata(BYNEConfig.URL_JCYJ_GHZ, headers: GetHeaders(GetToken()), files:files, timeOut: BYNEConfig.TIME_OUT);
            else
                res = ApiHelper.HttpPostFormdata(BYNEConfig.URL_JCYJ_GHZ, headers: GetHeaders(GetToken()), files:files, timeOut: BYNEConfig.TIME_OUT);

            RunLog.Info("规划值导入接口返回：" + res);
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Code == 200)
            {
                return true;
            }
            else
            {
                RunLog.Debug("规划值导入失败=>" + res);
                throw new UseArgumentException("规划值导入失败：" + resModel.Msg);
            }
        }

        /// <summary>
        /// 监测值导入模板下载
        /// </summary>
        /// <returns></returns>
        public static string GetJczTemplate(string path)
        {
            var file = ApiHelper.HttpDownFile(BYNEConfig.URL_JCYJ_JCZ_TEMPLATE, path, GetHeaders(GetToken()), timeOut: BYNEConfig.TIME_OUT);
            if (string.IsNullOrWhiteSpace(file) || !File.Exists(file))
            {
                throw new UseArgumentException("监测值导入模板下载失败");
            }
            return file;
        }
        /// <summary>
        /// 监测值导入
        /// </summary>
        /// <returns></returns>
        public static bool JcyjJczUpload(string file)
        {
            var files = new Dictionary<string, string>();
            files.Add("file", file);
            RunLog.Info($"监测值导入接口：{file}");
            //var res = ApiHelper.HttpPostFormdata(BYNEConfig.URL_JCYJ_JCZ, headers: GetHeaders(GetToken()), files: files);
            string res = string.Empty;
            if(BYNEConfig.GRANT_TYPE == "GET")
                res = ApiHelper.HttpGetFormdata(BYNEConfig.URL_JCYJ_JCZ, headers: GetHeaders(GetToken()), files: files, timeOut: BYNEConfig.TIME_OUT);
            else
                res = ApiHelper.HttpPostFormdata(BYNEConfig.URL_JCYJ_JCZ, headers: GetHeaders(GetToken()), files: files, timeOut: BYNEConfig.TIME_OUT);
            RunLog.Info("监测值导入接口返回：" + res);
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Code == 200)
            {
                return true;
            }
            else
            {
                RunLog.Debug("监测值导入失败=>" + res);
                throw new UseArgumentException("监测值导入失败：" + resModel.Msg);
            }
        }
        #endregion

        #region 成果包查询接口
        /// <summary>
        /// 4.1 查询已办成果流程
        /// </summary>
        /// <returns></returns>
        public static List<CghjCgsbrwYbcg> GetYbcg(BYNECgcxIo input, ref string token)
        {
            token = GetToken();
            var headers = GetHeaders(token);
            //参数
            Dictionary<string, string> pars = input.ToDictionary<string>();

            var urlParam = ApiHelper.FormatUrlParam(pars);
            RunLog.Info($"查询已办成果流程接口请求：{BYNEConfig.URL_LANDMYATTENDSDATA} => {urlParam}");
            var res = HttpHelper.HttpGet(BYNEConfig.URL_LANDMYATTENDSDATA, urlParam, headers);
            RunLog.Info("查询已办成果流程接口返回：" + res);
            var resModel = res.ToModel<BYNEResponseCgApiModel>();
            if (resModel.Code == 200)
            {
                var qx = resModel.Data.records.ToJson().ToModel<List<CghjCgsbrwYbcg>>();
                return qx;
            }
            else
            {
                RunLog.Debug("查询已办成果流程失败=>" + res);
                throw new UseArgumentException("查询已办成果流程失败：" + resModel.Msg);
            }
        }

        /// <summary>
        /// 4.2 查询待办成果列表
        /// </summary>
        /// <returns></returns>
        public static List<CghjCgsbrwDbcg> GetDbcg(BYNECgcxIo input, ref string token)
        {
            token = GetToken();
            var headers = GetHeaders(token);
            //参数
            Dictionary<string, string> pars = input.ToDictionary<string>();

            var urlParam = ApiHelper.FormatUrlParam(pars);
            RunLog.Info($"查询待办成果列表接口请求：{BYNEConfig.URL_LANDGETALLTASKS} => {urlParam}");
            var res = HttpHelper.HttpGet(BYNEConfig.URL_LANDGETALLTASKS, urlParam, headers);
            RunLog.Info("查询待办成果列表接口返回：" + res);
            var resModel = res.ToModel<BYNEResponseCgApiModel>();
            if (resModel.Code == 200)
            {
                var qx = resModel.Data.records.ToJson().ToModel<List<CghjCgsbrwDbcg>>();
                return qx;
            }
            else
            {
                RunLog.Debug("查询待办成果列表失败=>" + res);
                throw new UseArgumentException("查询待办成果列表失败：" + resModel.Msg);
            }
        }

        /// <summary>
        /// 4.3 查询已办成果审批记录
        /// </summary>
        /// <returns></returns>
        public static List<CghjCgsbrwSpjl> GetSpjl(BYNECgcxSpjlIo input)
        {
            var headers = GetHeaders(input.token);
            //参数
            Dictionary<string, string> pars = input.ToDictionary<string>();
            pars.Remove("token");

            var urlParam = ApiHelper.FormatUrlParam(pars);
            RunLog.Info($"查询已办成果审批记录接口请求：{BYNEConfig.URL_LANDTASKSTATUS} => {urlParam}");
            var res = HttpHelper.HttpGet(BYNEConfig.URL_LANDTASKSTATUS, urlParam, headers);
            RunLog.Info("查询已办成果审批记录接口返回：" + res);
            var resModel = res.ToModel<BYNEResponseApiModel>();
            if (resModel.Code == 200)
            {
                List<CghjCgsbrwSpjl> list = new List<CghjCgsbrwSpjl>();
                var jls = resModel.Data.ToJson().ToModel<List<CghjCgsbrwSpjlView>>();
                foreach (var item in jls)
                {
                    CghjCgsbrwSpjl spjl = item.MapTo<CghjCgsbrwSpjl>();
                    if (item.COMMENTS != null && item.COMMENTS.Count > 0)
                    {
                        spjl.COMMENTS = item.COMMENTS.ToJson();
                    }
                    else
                    {
                        spjl.COMMENTS = null;
                    }
                    spjl.ID = Guid.NewGuid().ToStringN();
                    spjl.JLID = input.id;
                    spjl.INSTID = input.instId;
                    list.Add(spjl);
                }
                return list;
            }
            else
            {
                RunLog.Debug("查询已办成果审批记录失败=>" + res);
                throw new UseArgumentException("查询已办成果审批记录失败：" + resModel.Msg);
            }
        }
        #endregion
    }
}