ds8-solution-pro/ds-wms-service/DS.Module.PrintModule/PrintService.cs

using DS.Module.Core;
using DS.Module.Core.Data;
using DS.Module.Core.Extensions;
using DS.Module.UserModule;
using Microsoft.Extensions.DependencyInjection;
using Newtonsoft.Json;
using NLog;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DS.Module.PrintModule
{
    public class PrintService: IPrintService
    {
        private readonly IServiceProvider _serviceProvider;
        private readonly ISqlSugarClient db;
        private readonly IUser user;
        private readonly string ip;
        private readonly int port;
        private readonly string accessKey;
        private readonly string accessSecret;
        private readonly string moduleUrl;
        private readonly string templateUrl;
        private readonly string jsonPrintInfoUrl;
        private readonly string jsonPrintStreamUrl;
        private static readonly Logger Logger = LogManager.GetCurrentClassLogger();

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="serviceProvider"></param>
        public PrintService(IServiceProvider serviceProvider)
        {
            _serviceProvider = serviceProvider;
            db = _serviceProvider.GetRequiredService<ISqlSugarClient>();
            user = _serviceProvider.GetRequiredService<IUser>();

            ip = AppSetting.app(new string[] { "PrintService", "IP" }).ObjToString();
            port = AppSetting.app(new string[] { "PrintService", "Port" }).ToInt();
            accessKey = AppSetting.app(new string[] { "PrintService", "AccessKey" }).ObjToString();
            accessSecret = AppSetting.app(new string[] { "PrintService", "AccessSecret" }).ObjToString();
            moduleUrl = AppSetting.app(new string[] { "PrintService", "GetModuleListUrl" }).ObjToString();
            templateUrl = AppSetting.app(new string[] { "PrintService", "GetTemplateListUrl" }).ObjToString();
            jsonPrintInfoUrl = AppSetting.app(new string[] { "PrintService", "GetJsonPrintInfoUrl" }).ObjToString();
            jsonPrintStreamUrl = AppSetting.app(new string[] { "PrintService", "GetJsonPrintStreamUrl" }).ObjToString();
        }


        /// <summary>
        /// 获取打印模块列表
        /// </summary>
        /// <returns></returns>
        public DataResult GetOpenPrintModuleList()
        {
            // 只要平台信息参数一致，多个请求只需设置一次参数
            HttpUtillib.SetPlatformInfo(accessKey, accessSecret, ip, port, false);
            DataResult res = new DataResult();

            // 发起POST请求，超时时间15秒，返回响应字节数组
            string result = HttpUtillib.HttpGet(moduleUrl, 15);
            if (null == result)
            {
                res = DataResult.Failed("请求失败,请联系管理员");
                // 请求失败
                // Console.WriteLine("/artemis/api/resource/v1/cameras/indexCode: POST fail");
            }
            else
            {
                res = JsonConvert.DeserializeObject<DataResult>(result);
                // Console.WriteLine(System.Text.Encoding.UTF8.GetString(result));
            }

            return res;
        }

        /// <summary>
        /// 获取打印模板列表
        /// </summary>
        /// <param name="id">模块id</param>
        /// <returns></returns>
        public DataResult GetOpenPrintTemplateList(string id)
        {
            // 只要平台信息参数一致，多个请求只需设置一次参数
            HttpUtillib.SetPlatformInfo(accessKey, accessSecret, ip, port, false);
            DataResult res = new DataResult();

            // 发起POST请求，超时时间15秒，返回响应字节数组
            string result = HttpUtillib.HttpGet(templateUrl+"?id=" + id, 15);
            if (null == result)
            {
                res = DataResult.Failed("请求失败,请联系管理员");
                // 请求失败
                // Console.WriteLine("/artemis/api/resource/v1/cameras/indexCode: POST fail");
            }
            else
            {
                res = JsonConvert.DeserializeObject<DataResult>(result);
                // Console.WriteLine(System.Text.Encoding.UTF8.GetString(result));
            }

            return res;
        }

        /// <summary>
        /// 获取打印模板列表
        /// </summary>
        /// <param name="id">模块id</param>
        /// <returns></returns>
        public async Task<DataResult> GetOpenPrintTemplateListAsync(string id)
        {
            // 只要平台信息参数一致，多个请求只需设置一次参数
            HttpUtillib.SetPlatformInfo(accessKey, accessSecret, ip, port, false);
            DataResult res = new DataResult();

            var url = templateUrl + "?id=" + id;
            // 发起POST请求，超时时间15秒，返回响应字节数组
            var result = await HttpUtillib.HttpGetAsync(url,15);
            if (null == result)
            {
                res = DataResult.Failed("请求失败,请联系管理员");
                // 请求失败
                // Console.WriteLine("/artemis/api/resource/v1/cameras/indexCode: POST fail");
            }
            else
            {
                res = JsonConvert.DeserializeObject<DataResult>(result);
                // Console.WriteLine(System.Text.Encoding.UTF8.GetString(result));
            }

            return res;
        }
        /// <summary>
        /// 获取Json打印信息
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>
        public DataResult GetOpenJsonPrintInfo(OpenJsonPrintReq req)
        {
            // 只要平台信息参数一致，多个请求只需设置一次参数
            HttpUtillib.SetPlatformInfo(accessKey, accessSecret, ip, port, false);
            DataResult res = new DataResult();

            // 发起POST请求，超时时间15秒，返回响应字节数组
            string result = HttpUtillib.HttpPost(jsonPrintInfoUrl, JsonConvert.SerializeObject(req), 30);
            if (null == result)
            {
                res = DataResult.Failed("请求失败,请联系管理员");
                // 请求失败
                // Console.WriteLine("/artemis/api/resource/v1/cameras/indexCode: POST fail");
            }
            else
            {
                res = JsonConvert.DeserializeObject<DataResult>(result);
                // Console.WriteLine(System.Text.Encoding.UTF8.GetString(result));
            }

            return res;
        }

        /// <summary>
        /// 获取Json打印信息-异步
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>
        public async Task<DataResult> GetOpenJsonPrintInfoAsync(OpenJsonPrintReq req)
        {
            // 只要平台信息参数一致，多个请求只需设置一次参数
            HttpUtillib.SetPlatformInfo(accessKey, accessSecret, ip, port, false);
            DataResult res = new DataResult();

            // 发起POST请求，超时时间15秒，返回响应字节数组
            string result = await HttpUtillib.HttpPostAsync(jsonPrintInfoUrl, JsonConvert.SerializeObject(req), 30);
            if (null == result)
            {
                res = DataResult.Failed("请求失败,请联系管理员");
                // 请求失败
                // Console.WriteLine("/artemis/api/resource/v1/cameras/indexCode: POST fail");
            }
            else
            {
                res = JsonConvert.DeserializeObject<DataResult>(result);
                // Console.WriteLine(System.Text.Encoding.UTF8.GetString(result));
            }

            return res;
        }
        /// <summary>
        /// 获取Json打印信息
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>
        public DataResult<PrintStreamRes> GetOpenJsonPrintStream(OpenJsonPrintReq req)
        {
            // 只要平台信息参数一致，多个请求只需设置一次参数
            HttpUtillib.SetPlatformInfo(accessKey, accessSecret, ip, port, false);
            //DataResult res = new DataResult();

            // 发起POST请求，超时时间15秒，返回响应字节数组
            string result = HttpUtillib.HttpPost(jsonPrintStreamUrl, JsonConvert.SerializeObject(req), 30);
            if (null == result)
            {
                throw new Exception("请求失败,请联系管理员");
                // 请求失败
                // Console.WriteLine("/artemis/api/resource/v1/cameras/indexCode: POST fail");
            }
            else
            {
                var  res = JsonConvert.DeserializeObject<DataResult>(result);
                if (!res.Succeeded)
                {
                    return DataResult<PrintStreamRes>.Failed(res.Message);
                }
                else
                { 
                   var printRes = JsonConvert.DeserializeObject<PrintStreamRes>(res.Data.ToString());
                   return DataResult<PrintStreamRes>.Success(printRes);
                }
            }

            //return res;
        }
    }
}