using DataSharing.DaoShu110;
using DataSharing.Extensions;
using DataSharing.RawData;
using DataSharing.Share.Dtos;
using DataSharing.Share.Dtos.DaoShu110;
using DotNetCore.CAP;
using Hotline.Api.Sdk;
using MapsterMapper;
using MediatR;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using System.Net;
using System.Text;
using XF.Domain.Filters;
using XF.Domain.Repository;

namespace DataSharing.Host.Controllers
{
    /// <summary>
    /// 110
    /// </summary>
    public class PoliceDSController : BaseController
    {
        #region 注入
        private readonly IMapper _mapper;
        private readonly ICapPublisher _capPublisher;
        private readonly IMediator _mediator;
        private readonly IChannelConfigurationManager _channelConfigurationManager;
        private readonly IRepository<DsPoliceSendChainAlarmDs> _dsPoliceSendChainAlarmDsRepository;
        private readonly IRepository<DsPoliceSendChainDealDs> _dsPoliceSendChainDealDsRepository;
        private readonly IRepository<DsKnowledgeRawData> _dsKnowledgeRawDataRepository;
        private readonly IRepository<DsOrder> _dsOrderRepository;
        private readonly IRepository<DsReceivePoliceData> _dsReceivePoliceDataRepository;
        private readonly IHotlineClient _hotlineClient;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="mapper"></param>
        /// <param name="capPublisher"></param>
        /// <param name="mediator"></param>
        /// <param name="channelConfigurationManager"></param>
        /// <param name="dsPoliceSendChainAlarmDsRepository"></param>
        /// <param name="dsPoliceSendChainDealDsRepository"></param>
        /// <param name="dsKnowledgeRawDataRepository"></param>
        /// <param name="dsOrderRepository"></param>
        /// <param name="dsReceivePoliceDataRepository"></param>
        /// <param name="hotlineClient"></param>
        public PoliceDSController(IMapper mapper,
            ICapPublisher capPublisher,
            IMediator mediator,
            IChannelConfigurationManager channelConfigurationManager,
            IRepository<DsPoliceSendChainAlarmDs> dsPoliceSendChainAlarmDsRepository,
            IRepository<DsPoliceSendChainDealDs> dsPoliceSendChainDealDsRepository,
            IRepository<DsKnowledgeRawData> dsKnowledgeRawDataRepository,
            IRepository<DsOrder> dsOrderRepository,
            IRepository<DsReceivePoliceData> dsReceivePoliceDataRepository,
            IHotlineClient hotlineClient)
        {
            _mapper = mapper;
            _capPublisher = capPublisher;
            _mediator = mediator;
            _channelConfigurationManager = channelConfigurationManager;
            _dsPoliceSendChainAlarmDsRepository = dsPoliceSendChainAlarmDsRepository;
            _dsPoliceSendChainDealDsRepository = dsPoliceSendChainDealDsRepository;
            _dsKnowledgeRawDataRepository = dsKnowledgeRawDataRepository;
            _dsOrderRepository = dsOrderRepository;
            _dsReceivePoliceDataRepository = dsReceivePoliceDataRepository;
            _hotlineClient = hotlineClient;
        }
        #endregion

        #region receive-工单受理-已完成

        /// <summary>
        /// 工单受理
        /// </summary>
        /// <returns></returns>
        [HttpPost("service/api/ds/110To12345/chainAlarm")]
        [AllowAnonymous]
        public async Task<OpenResponse> ChainAlarm_Receive()
        {
            // 测试JSON
            // {"LSH":"510300202304070001202304070001","JJYBH":"1001","JJDBH":"510300202304070001202304070001","BJDH":"13555555555","BJDHYHM":"李四","LXDH":"13555555555","BJDZ":"报警地址","JQLBDM":"","JQLBMC":"","BJNR":"报警内容","GXDWDM":"","GXDWMC":"","GXDWDH":"","BJSJ":"2023-04-07 10:43:17","TSSJ":"2023-04-07 10:43:21","JJDWDM":"12345","JJDWMC":"12345","JJLX":"1","XZQHDM":"510300"}
            // 测试Base64
            // kKeUhfS8zca5WTA9D2Z7z/GthYLHroPi8jLN2HduG2vK1PCjb56BZ3wLNCiA8V91ARHpOkE50xFdwBJhW+QKB7J2FRjJ6WUrzkKal75G3DCWzl+Fzto+XbkS5U5wUYnII2zSpdo4U6ILrrK2t2u8mFTd1i03+D1Ytv4TlUH5Jwg/xq00AeF/CVhes4+H5PPcxdU/h3KCDMq9Qaoxf6pALQCMBfatQdsDMw4MG0RK5DUbuaCuElOxfCjlDadZTLuVjHWHDw6wWG9sucqN3mrRllxytIDqIsLSdBi1KuCPaW+FhXf5/+v6Eipby8QEXXTPZxOW4m/Kp8cF87+rxBxRE7nIGAjdO2mKDyfiDeipENxKkQs6taTS52U2OG99Prfp+UAU1Uaj69gQ0IShMVqLgnESWhL5b/vIgO2mtYgIIZ7RpwlTuVqVZKxaFfPpjnQtGRFZPDPHVQcqQ7MMT3rjg6/AWVI/Jh7q+pdu18Y6cojl/EGd/XsNVip+uvAeXdCk
            var configurationPoliceDS = _channelConfigurationManager.GetConfigurationPoliceDS();
            var sm4 = configurationPoliceDS.token1_sm4_mw;

            var apiR = new DaoShuDeResponse<string>();
            try
            {
                // 验证dcsm
                string dcsmMsg = CheckDcsm(Request.Headers["dcsm"].ToString(), configurationPoliceDS.token1_dcsm);
                if (!string.IsNullOrEmpty(dcsmMsg))
                {
                    apiR = DaoShuDeResponse<string>.Failed(dcsmMsg);
                }
                else
                {
                    string base64String = await GetStreamBase64(HttpContext.Request);
                    ChainAlarm_DS chainAlarm = new();
                    if (!string.IsNullOrEmpty(base64String))
                    {
                        // 解密：base64通过sm4解密转json
                        string jsonRes = Sm4Crypto.Decrypt_ECB_Base64(sm4, base64String);
                        // json 转 实体类
                        if (!string.IsNullOrEmpty(jsonRes))
                            chainAlarm = System.Text.Json.JsonSerializer.Deserialize<ChainAlarm_DS>(jsonRes);

                        await InitRawData("service/api/ds/110To12345/chainAlarm", base64String, jsonRes, chainAlarm?.AlarmReceiptNumber);
                    }

                    #region 数据验证
                    //数据验证
                    string strResult = chainAlarm.Validate();
                    if (!IsDate(chainAlarm.CallPoliceTime.ToString()))
                        strResult = "【报警时间】不是日期格式 yyyy-MM-dd HH:mm:ss";
                    if (!IsDate(chainAlarm.PushTime.ToString()))
                        strResult = "【推送时间】不是日期格式 yyyy-MM-dd HH:mm:ss";

                    #endregion

                    if (string.IsNullOrEmpty(strResult))
                    {

                        //组装业务系统工单数据
                        Hotline.Share.Dtos.Order.AddOrderDto orderDto = new()
                        {
                            ExternalId = chainAlarm.AlarmReceiptNumber,
                            //   AcceptorStaffNo = policeReceive.RegisterNo,
                            FromPhone = chainAlarm.CallPoliceNumber,
                            FromName = chainAlarm.CallPoliceName,
                            Contact = chainAlarm.PhoneNumber,
                            Content = chainAlarm.CallPoliceContent,
                            IncidentTime = Convert.ToDateTime(chainAlarm.CallPoliceTime),
                            AreaCode = chainAlarm.AreaCode,
                            Street = chainAlarm.CallPoliceAddress,
                            SourceChannel = "宜宾110平台",
                            SourceChannelCode = "YB110"
                        };
                        //业务系统推送数据
                       // await _capPublisher.PublishAsync(DataSharing.Share.Mq.EventNames.SharingOrderCreation, orderDto, cancellationToken: HttpContext.RequestAborted);
                        //调用工单创建接口
                        var result = await _hotlineClient.ReceiveOrderAsync(orderDto, HttpContext.RequestAborted);
                        //if (result != null && !string.IsNullOrEmpty(result.Id))
                        //{
                        //    data.Id = id;
                        //    data.OrderId = result.Id;
                        //    await _policeReceiveChainAlarmDsRepository.UpdateAsync(data, HttpContext.RequestAborted);
                        //    apiR = DaoShuDeResponse<string>.Succeed(null);
                        //}
                        //else
                        //    apiR = DaoShuDeResponse<string>.Failed(null);


                    }
                    else
                        apiR = DaoShuDeResponse<string>.Failed(strResult);
                }
            }
            catch (System.Exception)
            {
                apiR = DaoShuDeResponse<string>.Failed("接口异常");
            }

            #region 处理返回数据
            // 返回数据转Json
            string jsonResult = ModelToJson(apiR);
            // 加密：json通过sm4加密转base64
            string base64 = Sm4Crypto.Encrypt_ECB_Base64(sm4, jsonResult);

            var resp = new HttpResponseMessage(HttpStatusCode.OK);
            resp.Content = new StringContent(base64, System.Text.Encoding.UTF8, "text/plain");
            #endregion

            return OpenResponse.Ok(resp);
        }

        #endregion

        #region receive-工单办结

        /// <summary>
        /// 工单办结
        /// </summary>
        /// <returns></returns>
        [HttpPost("service/api/ds/110To12345/chainDeal")]
        [AllowAnonymous]
        public async Task<OpenResponse> ChainDeal_Receive()
        {
            // 测试 办结 {"JJDBH":"510300202304070001202304070001","CZLX":"1","FKSJ":"2023-04-07 10:52:44","CJCZQK":"办理结果","JQCLJGSM":"办理结果","FKYBH":"1001","FKYXM":"1001","FKDWDM":"","FKDWMC":"","HFSJ":"","DHHFHSQK":"","CLJGDM":"","CLJGMC":"","HANDLEUSERNAME":"","HANDLEBMNAME":"","HANDLEOPINION":"","HANDLETIME":"","TSSJ":"2023-04-07 10:53:19"}
            // 测试 退回 {"JJDBH":"510300202304070001202304070001","CZLX":"2","FKSJ":"","CJCZQK":"","JQCLJGSM":"","FKYBH":"","FKYXM":"","FKDWDM":"","FKDWMC":"","HFSJ":"","DHHFHSQK":"","CLJGDM":"","CLJGMC":"","HANDLEUSERNAME":"退回人","HANDLEBMNAME":"退回姓名","HANDLEOPINION":"退回原因","HANDLETIME":"2023-04-07 10:53:19","TSSJ":"2023-04-07 10:53:19"}
            // 测试 回访 {"JJDBH":"510300202304070001202304070001","CZLX":"3","FKSJ":"","CJCZQK":"","JQCLJGSM":"","FKYBH":"","FKYXM":"","FKDWDM":"","FKDWMC":"","HFSJ":"2023-04-07 10:54:23","DHHFHSQK":"回访情况","CLJGDM":"2","CLJGMC":"回访内容","HANDLEUSERNAME":"","HANDLEBMNAME":"","HANDLEOPINION":"","HANDLETIME":"","TSSJ":"2023-04-07 10:53:19"}

            // 测试Base64
            // 办结 Jv5JJHwByfD4CXMb1l4PtPsgC6UmNeRfws6mEKz24rackMA28z27tu2GRlIyq0qmbeYeEM0nY783aUxb0jlqSQlk+xtc6cop/CvZI5vczHIsXhtfNozkW/hlx/R43ecuKEvyMzEHwf3EuBZ7jsY1zGuJe61K6YTkmCt6+Xndbd585ZMluNJNIA0qZPbT08jVDiI+wa9ot3HA7AEuDqNxJwfU7NfqoTk6Ml5nnuPkdmp55VKeoLZspAgBflEtFJyppIsN0VQyJkrn+ADQFOPcTpedx5H6+V+2MYM9+5pE/Re17S+s3cA53vWHsf6KhHnCm3M9qtbocu0TtpAEfyMEBQOIRn4pSEJ1i98fpD3xjzuxddkGPOBvhYrh8Tf3IbNTNpNozEda2a0RFmBCQyfzLvEdk4ZK/obYDKncePIRrE3ZtO2QAeAa3H6V532MxcniZJ4mIqHsKShR2Q8uxdsR5Q==
            // 退回 Jv5JJHwByfD4CXMb1l4PtPsgC6UmNeRfws6mEKz24rackMA28z27tu2GRlIyq0qm1U2lexAxHJK7Bhoyw7CNiEXjiobQjSKF2RWOrUHZINPed01DQRTw2pIL03EFsrQpEjsslviumN+BTn/cuJQp8zD2ifPclM87jEJfP2EY6D+UGvUfSebT9mMghSo2VaUeqFzlRKpJmcU6XjV7C65zddc8DEXuYzt0zqATyhac9AO3RGB5SEw9MX1olV8WwPgV4h3OkTTVZ+Dq5co/eb28YIBN+Rshjpv82RusV2thgfvudOyCDZcRDbjh6pEdtj/lvVH/BU2cDo3ch17KtzsPE+xkQvJ68zaAnS8f/klQrFrDHlkmTMi6rEa605yUhhPZFz0Jba+Axizil38YbHV9A1YoxoJNjFXIyL90yCMznb4joMQPRRddp5ky/CbT9r0q283gKBdAY6/v+ywPdalFjg==
            // 回访 Jv5JJHwByfD4CXMb1l4PtPsgC6UmNeRfws6mEKz24rackMA28z27tu2GRlIyq0qmvLqUgIfd0QkyZbzT0iQZwEXjiobQjSKF2RWOrUHZINPed01DQRTw2pIL03EFsrQpEjsslviumN+BTn/cuJQp8zD2ifPclM87jEJfP2EY6D8cMxuK/4X9pyxRWKIQtLFdh4ieC9bhojhr2XxStPHmDV4c3oNEybczbb7IXsaW2FCGMI4SLF7Z+VXDSpCGpFX+0dyUUQPnoRrgU7wndkn/6VYi2Axm19MBkwK+Wm5v85oVQ1HFptf5leUiSXomF9XCPtgWbLOFzu313JW7WQvjgllM7usjI2mbyGtQ5EMXyOGJ/AmAupELpMYVwjoGAKy6B/GE1HFyPiLAazsUE3jfaLPxn/Gld0Ef2glG1SQ/vakDtyvyoJDE83pYvBesmQMx
            var configurationPoliceDS = _channelConfigurationManager.GetConfigurationPoliceDS();
            string sm4 = configurationPoliceDS.token4_sm4_mw;

            var apiR = new DaoShuDeResponse<string>();
            try
            {
                // 验证dcsm
                string dcsmMsg = CheckDcsm(Request.Headers["dcsm"].ToString(), configurationPoliceDS.token4_dcsm);
                if (!string.IsNullOrEmpty(dcsmMsg))
                {
                    apiR = DaoShuDeResponse<string>.Failed(dcsmMsg);
                }
                else
                {
                    ChainDeal_DS chainDeal = new();

                    string base64String = await GetStreamBase64(HttpContext.Request);
                    if (!string.IsNullOrEmpty(base64String))
                    {
                        // 解密：base64通过sm4解密转json
                        string jsonRes = Sm4Crypto.Decrypt_ECB_Base64(sm4, base64String);
                        if (!string.IsNullOrEmpty(jsonRes))
                            // json 转 实体类
                            chainDeal = System.Text.Json.JsonSerializer.Deserialize<ChainDeal_DS>(jsonRes);

                        await InitRawData("service/api/ds/110To12345/chainDeal", base64String, jsonRes, chainDeal?.AlarmReceiptNumber);
                    }

                    #region 数据验证
                    string strResult = chainDeal.Validate();
                    if (chainDeal.FeedbackTime == "")
                        chainDeal.FeedbackTime = null;
                    if (chainDeal.ReturnTime == "")
                        chainDeal.ReturnTime = null;
                    if (chainDeal.RevisitTime == "")
                        chainDeal.RevisitTime = null;
                    #endregion

                    if (string.IsNullOrEmpty(strResult))
                    {
                        //这里组装数据推送到业务系统
                        await InitChainDeal(chainDeal);
                        apiR = DaoShuDeResponse<string>.Succeed(null);
                    }
                    else
                        apiR = DaoShuDeResponse<string>.Failed(null);

                }
            }
            catch (System.Exception)
            {
                apiR = DaoShuDeResponse<string>.Failed("接口异常");
            }

            // 返回数据转Json
            string jsonResult = ModelToJson(apiR);
            // 加密：json通过sm4加密转base64
            string base64 = Sm4Crypto.Encrypt_ECB_Base64(sm4, jsonResult);

            var resp = new HttpResponseMessage(HttpStatusCode.OK);
            resp.Content = new StringContent(base64, System.Text.Encoding.UTF8, "text/plain");
            return OpenResponse.Ok(resp);
        }

        #endregion

        #region send-工单受理-已完成

        /// <summary>
        /// 工单受理
        /// </summary>
        /// <returns></returns>
        [HttpPost("service/api/ds/12345To110/chainAlarm")]
        [AllowAnonymous]
        public async Task<OpenResponse> ChainAlarm_Send()
        {
            //{"startDate":"2023-04-01 10:43:17","endDate":"2023-04-17 10:43:17"}
            //gzWXSn3A2ZW9u3k9yrHdEqE5zRzto/Rud6LZ6JRJ1k59ou5nWABc8t8fR/sWU89lGweFQMsZkefowEBYzArADnSXjbKwfQj19UoF5RN/0mI=
            var configurationPoliceDS = _channelConfigurationManager.GetConfigurationPoliceDS();
            string sm4 = configurationPoliceDS.token3_sm4_mw;

            var apiR = new DaoShuDeResponse<string>();
            try
            {
                // 验证dcsm
                string dcsmMsg = CheckDcsm(Request.Headers["dcsm"].ToString(), configurationPoliceDS.token3_dcsm);
                if (!string.IsNullOrEmpty(dcsmMsg))
                {
                    apiR = DaoShuDeResponse<string>.Failed(dcsmMsg);
                }
                else
                {
                    OpenData openData = new();
                    string base64String = await GetStreamBase64(HttpContext.Request);
                    if (!string.IsNullOrEmpty(base64String))
                    {
                        // 解密：base64通过sm4解密转json
                        string jsonRes = Sm4Crypto.Decrypt_ECB_Base64(sm4, base64String);
                        if (!string.IsNullOrEmpty(jsonRes))
                            // json 转 实体类
                            openData = System.Text.Json.JsonSerializer.Deserialize<OpenData>(jsonRes);

                        await InitRawData("service/api/ds/12345To110/chainAlarm", base64String, jsonRes, openData?.AlarmReceiptNumber);
                    }
                    bool bRun = true;
                    if (string.IsNullOrEmpty(openData.StartDate) || !IsDate(openData.StartDate))
                    {
                        bRun = false;
                        apiR = DaoShuDeResponse<string>.Failed("【创建开始时间】不是日期格式 yyyy-MM-dd HH:mm:ss");
                    }
                    if (string.IsNullOrEmpty(openData.EndDate) || !IsDate(openData.EndDate))
                    {
                        bRun = false;
                        apiR = DaoShuDeResponse<string>.Failed("【创建结束时间】不是日期格式 yyyy-MM-dd HH:mm:ss");
                    }
                    if (bRun)
                    {
                        var listData = await _dsPoliceSendChainAlarmDsRepository.Queryable()
                             .WhereIF(!string.IsNullOrEmpty(openData.StartDate), p => p.CallPoliceTime >= Convert.ToDateTime(openData.StartDate))
                             .WhereIF(!string.IsNullOrEmpty(openData.EndDate), p => p.CallPoliceTime >= Convert.ToDateTime(openData.EndDate))
                             .OrderBy(p => p.CallPoliceTime)
                             .Take(50)
                             .ToListAsync();

                        if (null == listData)
                            apiR = DaoShuDeResponse<string>.Failed(null);
                        else
                        {
                            var dto = _mapper.Map<IReadOnlyList<ChainAlarm_DS>>(listData);
                            // 返回数据
                            apiR = DaoShuDeResponse<string>.Succeed(System.Text.Json.JsonSerializer.Serialize(dto), "调用成功");
                        }
                    }
                }
            }
            catch (System.Exception)
            {
                apiR = DaoShuDeResponse<string>.Failed("接口异常");
            }

            // 返回数据转Json
            string jsonResult = ModelToJson(apiR);
            // 加密：json通过sm4加密转base64
            string base64 = Sm4Crypto.Encrypt_ECB_Base64(sm4, jsonResult);

            var resp = new HttpResponseMessage(HttpStatusCode.OK);
            resp.Content = new StringContent(base64, System.Text.Encoding.UTF8, "text/plain");
            return OpenResponse.Ok(resp);
        }

        #endregion

        #region send-工单办结

        /// <summary>
        /// 工单办结
        /// </summary>
        /// <returns></returns>
        [HttpPost("service/api/ds/12345To110/chainDeal")]
        [AllowAnonymous]
        public async Task<OpenResponse> ChainDeal_Send()
        {
            // 测试JSON
            // {"JJDBH":"510300202304070001202304070001","CZLX":"1"}

            // 测试Base64
            // 6RB6Hat8dpBfvCTtEpwotd/MlonxdmqZaa3TcLaua/xcjFv1SZJzKZPrhgsux63Gq/DXxtAQ25buLsI1fgFv3g==
            var configurationPoliceDS = _channelConfigurationManager.GetConfigurationPoliceDS();
            string sm4 = configurationPoliceDS.token2_sm4_mw;

            var apiR = new DaoShuDeResponse<string>();
            try
            {
                // 验证dcsm
                string dcsmMsg = CheckDcsm(Request.Headers["dcsm"].ToString(), configurationPoliceDS.token2_dcsm);
                if (!string.IsNullOrEmpty(dcsmMsg))
                {
                    apiR = DaoShuDeResponse<string>.Failed(dcsmMsg);
                }
                else
                {
                    string base64String = await GetStreamBase64(HttpContext.Request);
                    OpenData openData = new();
                    if (!string.IsNullOrEmpty(base64String))
                    {
                        // 解密：base64通过sm4解密转json
                        string jsonRes = Sm4Crypto.Decrypt_ECB_Base64(sm4, base64String);
                        if (!string.IsNullOrEmpty(jsonRes))
                            // json 转 实体类
                            openData = System.Text.Json.JsonSerializer.Deserialize<OpenData>(jsonRes);

                        await InitRawData("service/api/ds/12345To110/chainDeal", base64String, jsonRes, openData?.AlarmReceiptNumber);
                    }
                    bool bRun = true;

                    if (!string.IsNullOrEmpty(openData.StartDate) && !IsDate(openData.StartDate))
                    {
                        bRun = false;
                        apiR = DaoShuDeResponse<string>.Failed("【创建开始时间】不是日期格式 yyyy-MM-dd HH:mm:ss");
                    }
                    if (!string.IsNullOrEmpty(openData.EndDate) && !IsDate(openData.EndDate))
                    {
                        bRun = false;
                        apiR = DaoShuDeResponse<string>.Failed("【创建结束时间】不是日期格式 yyyy-MM-dd HH:mm:ss");
                    }

                    if (bRun)
                    {
                        var listData = await _dsPoliceSendChainDealDsRepository.Queryable()
                                 .WhereIF(!string.IsNullOrEmpty(openData.StartDate), p => p.WarehousingTime >= Convert.ToDateTime(openData.StartDate))
                                 .WhereIF(!string.IsNullOrEmpty(openData.EndDate), p => p.WarehousingTime >= Convert.ToDateTime(openData.EndDate))
                                 .WhereIF(!string.IsNullOrEmpty(openData.AlarmReceiptNumber), p => p.AlarmReceiptNumber == openData.AlarmReceiptNumber)
                                 .Where(p => p.DisposalType == openData.DisposalType)
                                 .OrderBy(p => p.WarehousingTime)
                                 .Take(50)
                                 .ToListAsync();

                        if (null == listData)
                            apiR = DaoShuDeResponse<string>.Failed(null);
                        else
                        {
                            var dto = _mapper.Map<IReadOnlyList<ChainDeal_DS>>(listData);
                            // 返回数据
                            apiR = DaoShuDeResponse<string>.Succeed(System.Text.Json.JsonSerializer.Serialize(dto), "调用成功");
                        }
                    }
                }
            }
            catch (System.Exception)
            {
                apiR = DaoShuDeResponse<string>.Failed("接口异常");
            }

            // 返回数据转Json
            string jsonResult = ModelToJson(apiR);
            // 加密：json通过sm4加密转base64
            string base64 = Sm4Crypto.Encrypt_ECB_Base64(sm4, jsonResult);

            var resp = new HttpResponseMessage(HttpStatusCode.OK);
            resp.Content = new StringContent(base64, System.Text.Encoding.UTF8, "text/plain");
            return OpenResponse.Ok(resp);
        }

        #endregion

        #region send-知识库列表-已完成

        /// <summary>
        /// 查询知识库列表
        /// </summary>
        /// <returns></returns>
        [HttpPost("service/api/ds/get_knowledge_info")]
        [AllowAnonymous]
        public async Task<OpenResponse> Get_Knowledge_Info()
        {
            // 测试Json
            // {"createTimeBegin":"2003-04-07 10:59:14","createTimeEnd":"2023-12-07 10:59:21","keyWord":"市民"}
            // {"createTimeBegin":"2003-04-07 10:59:14","createTimeEnd":"2023-12-07 10:59:21","keyWord":""}

            // 测试Base64
            // sVGPN7BDsKnDLrd6NzrGx+2IH6vVAo6bjGSenIgCJATssZduYxBOLdQi7TVdsBCy7AGk15xjKRVe4AdovL6r49fxDvWjyDlxS8K4qkukEOtYs/VyP6WIdiKQL6PC3i/T
            // sVGPN7BDsKnDLrd6NzrGx+2IH6vVAo6bjGSenIgCJATssZduYxBOLdQi7TVdsBCy7AGk15xjKRVe4AdovL6r49fxDvWjyDlxS8K4qkukEOuaeRL4jMcFsN7HoUTHfDrk
            var configurationPoliceDS = _channelConfigurationManager.GetConfigurationPoliceDS();
            string sm4 = configurationPoliceDS.token5_sm4_mw;

            var apiR = new DaoShuDeResponse<string>();
            try
            {
                // 验证dcsm
                string dcsmMsg = CheckDcsm(Request.Headers["dcsm"].ToString(), configurationPoliceDS.token5_dcsm);
                if (!string.IsNullOrEmpty(dcsmMsg))
                {
                    apiR = DaoShuDeResponse<string>.Failed(dcsmMsg);
                }
                else
                {
                    string base64String = await GetStreamBase64(HttpContext.Request);

                    Get_Knowledge get_Knowledge = new Get_Knowledge();
                    if (!string.IsNullOrEmpty(base64String))
                    {
                        // 解密：base64通过sm4解密转json
                        string jsonRes = Sm4Crypto.Decrypt_ECB_Base64(sm4, base64String);
                        if (!string.IsNullOrEmpty(jsonRes))
                            // json 转 实体类
                            get_Knowledge = System.Text.Json.JsonSerializer.Deserialize<Get_Knowledge>(jsonRes);

                        await InitRawData("service/api/ds/get_knowledge_info", base64String, jsonRes, null);
                    }

                    bool bRun = true;
                    if (string.IsNullOrEmpty(get_Knowledge.createTimeBegin) || !IsDate(get_Knowledge.createTimeBegin))
                    {
                        bRun = false;
                        apiR = DaoShuDeResponse<string>.Failed("【创建开始时间】不是日期格式 yyyy-MM-dd HH:mm:ss");
                    }
                    if (string.IsNullOrEmpty(get_Knowledge.createTimeEnd) || !IsDate(get_Knowledge.createTimeEnd))
                    {
                        bRun = false;
                        apiR = DaoShuDeResponse<string>.Failed("【创建结束时间】不是日期格式 yyyy-MM-dd HH:mm:ss");
                    }
                    if (bRun)
                    {
                        var listData = await _dsKnowledgeRawDataRepository
                        .Queryable()
                        .WhereIF(!string.IsNullOrEmpty(get_Knowledge.createTimeBegin), p => p.CreatDate >= Convert.ToDateTime(get_Knowledge.createTimeBegin))
                          .WhereIF(!string.IsNullOrEmpty(get_Knowledge.createTimeEnd), p => p.CreatDate <= Convert.ToDateTime(get_Knowledge.createTimeEnd))
                          .WhereIF(!string.IsNullOrEmpty(get_Knowledge.keyWord), p => p.KName.Contains(get_Knowledge.keyWord))
                         .OrderByDescending(p => p.CreatDate)
                          .ToListAsync();

                        if (null == listData)
                            apiR = DaoShuDeResponse<string>.Failed(null);
                        else
                        {
                            var dto = _mapper.Map<IReadOnlyList<KnowledgeDto>>(listData);
                            // 返回数据
                            apiR = DaoShuDeResponse<string>.Succeed(System.Text.Json.JsonSerializer.Serialize(dto), "调用成功");
                        }
                    }
                }
            }
            catch (System.Exception)
            {
                apiR = DaoShuDeResponse<string>.Failed("接口异常");
            }

            // 返回数据转Json
            string jsonResult = ModelToJson(apiR);
            // 加密：json通过sm4加密转base64
            string base64 = Sm4Crypto.Encrypt_ECB_Base64(sm4, jsonResult);

            var resp = new HttpResponseMessage(HttpStatusCode.OK);
            resp.Content = new StringContent(base64, System.Text.Encoding.UTF8, "text/plain");
            return OpenResponse.Ok(resp);
        }

        #endregion

        #region send-知识库内容-已完成

        /// <summary>
        /// 查询知识库内容
        /// </summary>
        /// <returns></returns>
        [HttpPost("service/api/ds/get_knowledge_content")]
        [AllowAnonymous]
        public async Task<OpenResponse> Get_Knowledge_Content()
        {
            var configurationPoliceDS = _channelConfigurationManager.GetConfigurationPoliceDS();
            string sm4 = configurationPoliceDS.token6_sm4_mw;

            var apiR = new DaoShuDeResponse<string>();
            try
            {
                // 验证dcsm
                string dcsmMsg = CheckDcsm(Request.Headers["dcsm"].ToString(), configurationPoliceDS.token6_dcsm);
                if (!string.IsNullOrEmpty(dcsmMsg))
                    apiR = DaoShuDeResponse<string>.Failed(dcsmMsg);
                else
                {
                    string base64String = await GetStreamBase64(HttpContext.Request);

                    Get_Knowledge get_Knowledge = new Get_Knowledge();
                    if (!string.IsNullOrEmpty(base64String))
                    {
                        // 解密：base64通过sm4解密转json
                        string jsonRes = Sm4Crypto.Decrypt_ECB_Base64(sm4, base64String);
                        if (!string.IsNullOrEmpty(jsonRes))
                            // json 转 实体类
                            get_Knowledge = System.Text.Json.JsonSerializer.Deserialize<Get_Knowledge>(jsonRes);

                        await InitRawData("service/api/ds/get_knowledge_content", base64String, jsonRes, null);
                    }

                    if (string.IsNullOrEmpty(get_Knowledge.id))
                    {
                        apiR = DaoShuDeResponse<string>.Failed("【知识库ID】不能为空");
                    }
                    else
                    {
                        var data = await _dsKnowledgeRawDataRepository.GetAsync(p => p.Id == get_Knowledge.id);
                        if (null == data)
                            apiR = DaoShuDeResponse<string>.Failed(null);
                        else
                        {
                            var dto = _mapper.Map<KnowledgeContent>(data);
                            // 返回数据
                            apiR = DaoShuDeResponse<string>.Succeed(System.Text.Json.JsonSerializer.Serialize(dto), "调用成功");
                        }
                    }
                }
            }
            catch (System.Exception)
            {
                apiR = DaoShuDeResponse<string>.Failed("接口异常");
            }

            // 返回数据转Json
            string jsonResult = ModelToJson(apiR);
            // 加密：json通过sm4加密转base64
            string base64 = Sm4Crypto.Encrypt_ECB_Base64(sm4, jsonResult);

            var resp = new HttpResponseMessage(HttpStatusCode.OK);
            resp.Content = new StringContent(base64, System.Text.Encoding.UTF8, "text/plain");
            return OpenResponse.Ok(resp);
        }

        #endregion

        #region 私有方法

        #region 工单办结

        /// <summary>
        /// 工单办结
        /// </summary>
        /// <param name="policeReceiveChainDealDs"></param>
        /// <returns></returns>
        private async Task InitChainDeal(ChainDeal_DS policeReceiveChainDealDs)
        {
            var orderData = await _dsOrderRepository.GetAsync(p => p.ExternalId == policeReceiveChainDealDs.AlarmReceiptNumber);
            if (orderData is null)
                return;

            if (policeReceiveChainDealDs.DisposalType == 1)//正常办理
            {
                Hotline.Share.Dtos.DataSharing.PusherHotlineDto.OrderResultDto orderResultDto = new()
                {
                    OrderId = orderData.OrderId,
                    FinishType = "1",
                    Opinion = policeReceiveChainDealDs.DisposalSituation
                };
                await _capPublisher.PublishAsync(DataSharing.Share.Mq.EventNames.SharingOrderReultSend, orderResultDto, cancellationToken: HttpContext.RequestAborted);

            }
            else if (policeReceiveChainDealDs.DisposalType == 2)//退回 
            {
                Hotline.Share.Dtos.DataSharing.PusherHotlineDto.OrderResultDto orderResultDto = new()
                {
                    OrderId = orderData.OrderId,
                    FinishType = "0",
                    Opinion = policeReceiveChainDealDs.ReturnOpinion
                };
                //向业务系统推送消息
                await _capPublisher.PublishAsync(DataSharing.Share.Mq.EventNames.SharingOrderReultSend, orderResultDto, cancellationToken: HttpContext.RequestAborted);

            }
            else if (policeReceiveChainDealDs.DisposalType == 3)//回访 
            {
                Hotline.Share.Dtos.Order.ProvinceOrderVisitDto orderVisitDto = new()
                {
                    ProvinceNo = orderData.ProvinceNo,
                    VisitTime = Convert.ToDateTime(policeReceiveChainDealDs.RevisitTime),
                    VisitContent = policeReceiveChainDealDs.VisitContent,
                    OrgProcessingResults = policeReceiveChainDealDs.VisitResult,
                    VisitType = Hotline.Share.Enums.Order.EVisitType.ArtificialVisit
                };

                //向业务系统推送消息
                await _capPublisher.PublishAsync(DataSharing.Share.Mq.EventNames.SharingOrderEvlResult, orderVisitDto, cancellationToken: HttpContext.RequestAborted);
            }
        }

        #endregion

        #region 写入原始数据
        /// <summary>
        /// 写入原始数据
        /// </summary>
        /// <param name="externalId"></param>
        /// <param name="serviceInterface"></param>
        /// <param name="receiveRawData"></param>
        /// <param name="receiveData"></param>
        /// <returns></returns>
        private async Task InitRawData(string serviceInterface, string receiveRawData, string receiveData, string? externalId)
        {
            DsReceivePoliceData dsReceivePoliceData = new()
            {
                ExternalId = externalId,
                ServiceInterface = serviceInterface,
                ReceiveRawData = receiveRawData,
                ReceiveData = receiveData
            };
            await _dsReceivePoliceDataRepository.AddAsync(dsReceivePoliceData, HttpContext.RequestAborted);
        }
        #endregion

        #region 获取RAW传入的Base64_Json
        /// <summary>
        /// 获取RAW传入的Base64_Json
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        private static async Task<string> GetStreamBase64(HttpRequest request)
        {
            string base64String = "";
            try
            {
                request.EnableBuffering();
                request.Body.Position = 0;
                using (var stream = new StreamReader(request.Body, Encoding.UTF8))
                {
                    base64String = await stream.ReadToEndAsync();
                }
            }
            catch (Exception)
            {
            }
            return base64String;
        }
        #endregion

        #region 验证DCSM是否正确

        /// <summary>
        /// 验证DCSM是否正确
        /// </summary>
        /// <param name="headrs"></param>
        /// <param name="dcsmIn"></param>
        /// <returns></returns>
        private static string CheckDcsm(string headrs, string dcsmIn)
        {
            string result = "";
            string dcsm = "";
            try
            {
                dcsm = headrs.ToString();
                if (dcsm != dcsmIn)
                {
                    result = "【dcsm】错误";
                }
            }
            catch (System.Exception)
            {
                result = "【dcsm】不能为空";
            }
            return result;
        }

        #endregion

        #region 验证日期
        private static bool IsDate(string strDate)
        {
            try
            {
                if (strDate.Contains('.') == true || strDate.Contains(',') == true)
                {
                    return false;
                }
                DateTime.Parse(strDate);  //不是字符串时会出现异常
                return true;
            }
            catch
            {
                return false;
            }
        }

        #endregion

        #region 转Json
        /// <summary>
        /// 转Json
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        private static string ModelToJson(object obj)
        {
            string jsonstr = "";
            try
            {
                IsoDateTimeConverter timejson = new IsoDateTimeConverter
                {
                    DateTimeFormat = "yyyy'-'MM'-'dd' 'HH':'mm':'ss"
                    //如果是年月日的话就是 ：DateTimeFormat = "yyyy'-'MM'-'dd" 注意第一个y前面没有单引号 最后一个d后面也没有单引号
                };
                jsonstr = JsonConvert.SerializeObject(obj, timejson);
            }
            catch (Exception)
            {
            }
            return jsonstr;
        }
        #endregion

        #endregion
    }
}