DEMOMySql/MicroServices/Business/Business.HttpApi/Controllers/SqeController.cs

using Business.Sqe;
using Business.StructuredDB;
using Business.StructuredDB.Sqe;
using Business.VSM;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NLog.Fluent;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading.Tasks;
using Volo.Abp;
using Volo.Abp.AspNetCore.Mvc;

namespace Business.Controllers
{
    /// <summary>
    /// 价值流接口
    /// </summary>
    [RemoteService]
    [Area("Sqe")]
    [Route("api/business/sqe")]
    public class SqeController : AbpController
    {

        public IJwtService _jwtService { set; get; }

        private IConfiguration _configuration;

        private readonly ISqeExcelService _SqeExcelService;

        public SqeController(ISqeExcelService SqeExcelService, IJwtService jwtService, IConfiguration configuration)
        {
            _SqeExcelService = SqeExcelService;
            _jwtService = jwtService;
            _configuration = configuration;
        }

        private String CheckToken(string token)
        {
            try
            {
                JwtOptions jwtOptions = new JwtOptions();
                jwtOptions.ExpireSeconds = Convert.ToInt32(_configuration["JWT:ExpireSeconds"]);
                jwtOptions.Issuer = _configuration["JWT:Issuer"];
                jwtOptions.Audience = _configuration["JWT:Audience"];
                jwtOptions.Key = _configuration["JWT:Key"];
                String data = _jwtService.ValidateToken(token, jwtOptions);
                if (!string.IsNullOrEmpty(data))
                {
                    return data;
                }
            }
            catch (Exception ex)
            {
            }
            return null;
        }



        [HttpGet]
        [Route("import_test")]
        public string Import_test(int file_id)
        {
            String s = _SqeExcelService.Import_Test_From_Data(file_id, "测试用户", DateTime.Now, "测试组织");
            return s;
        }

        [HttpGet]
        [Route("import_process")]
        public string Import_process(int file_id)
        {
            String s = _SqeExcelService.Import_Process_From_Data(file_id, "测试用户", DateTime.Now, "测试组织");
            return s;
        }

        [HttpGet]
        [Route("import_oqc")]
        public string Import_oqc(int file_id)
        {
            String s = _SqeExcelService.Import_Oqc_From_Data(file_id, "测试用户", DateTime.Now, "测试组织");
            return s;
        }

        [HttpGet]
        [Route("import_op")]
        public string Import_op(int file_id)
        {
            String s = _SqeExcelService.Import_Op_From_Data(file_id, "测试用户", DateTime.Now, "测试组织");
            return s;
        }

        [HttpGet]
        [Route("import_fpy")]
        public string Import_fpy(int file_id)
        {
            String s = _SqeExcelService.Import_Fpy_From_Data(file_id, "测试用户", DateTime.Now, "测试组织");
            return s;
        }

        [HttpGet]
        [Route("UploadProductionTestData")]
        public string Import_fct(String data, String token)
        {
            String userid = CheckToken(token);
            JObject json = new JObject();
            if (userid != null)
            {
                String s = _SqeExcelService.Import_Fct_From_Data(data, userid, DateTime.Now, userid);
                if (s == null || s.Length == 0)
                {
                    json["resultCode"] = "OK";
                    json["resultMessage"] = "成功";
                }
                else
                {
                    json["resultCode"] = "NG";
                    json["resultMessage"] = s;
                }
                return json.ToString();
            }
            else
            {
                json["resultCode"] = "NG";
                json["resultMessage"] = "传入配置未通过授权!";
                return json.ToString();
            }
        }
    }
}