DEMOMySql/MicroServices/Procurement/Procurement.Host/Controllers/WMS/ScanStorageConfirmController.cs

using Procurement.Enums;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Threading.Tasks;
using Volo.Abp.AspNetCore.Mvc;
using Procurement.EntityFrameworkCore.SqlRepositories;
using Procurement.ViewModel;
using Procurement.Helpers;
using System.Text.Json;
using System.Data.SqlClient;

namespace Procurement.Controllers
{
    [Produces("application/json")]
    [Route("api/wms/[controller]")]
    public class ScanStorageConfirmController : AbpController
    {
        private readonly ISqlRepository _repository;

        public ScanStorageConfirmController(ISqlRepository sqlRepository)
        {
            _repository = sqlRepository;
        }

        /// <summary>
        /// 悵湔�＇偌等
        /// </summary>
        /// <returns></returns>
        [Route("confirm")]
        [HttpPost]
        public async Task<IActionResult> Confirm([FromBody] JsonElement jsonElement)
        {
            if (jsonElement.ValueKind == JsonValueKind.Undefined || jsonElement.ValueKind == JsonValueKind.Null)
            {
                return BadRequest();
            }
            ResultCode code = ResultCode.Fail, subCode = ResultCode.Fail;
            string subMsg = "";
            try
            {
                string proc = "pr_WMS_SaveProductStorage";
                SqlParameter[] sqlParams = SqlHelper.CreateSqlParameters(jsonElement);
                var resultData = await _repository.GetResultByProcAsync(proc, sqlParams);
                subMsg = resultData.msg;
                if (resultData.isSuccess)
                {
                    code = ResultCode.Success;
                    subCode = ResultCode.Success;
                }
            }
            catch (Exception ex)
            {
                subMsg = ex.Message;
                code = ResultCode.Fail;
                subCode = ResultCode.Fail;
            }
            ResultViewModel result = ResultHelper.CreateResult(code, null, subCode, subMsg);
            return Ok(result);
        }

        /// <summary>
        /// 悵湔豖隙
        /// </summary>
        /// <returns></returns>
        [Route("cancel")]
        [HttpPost]
        public async Task<IActionResult> Cancel([FromBody] JsonElement jsonElement)
        {
            if (jsonElement.ValueKind == JsonValueKind.Undefined || jsonElement.ValueKind == JsonValueKind.Null)
            {
                return BadRequest();
            }
            ResultCode code = ResultCode.Fail, subCode = ResultCode.Fail;
            string subMsg = "";
            try
            {
                string proc = "pr_WMS_BPM_SaveScanStorageCancel";
                SqlParameter[] sqlParams = SqlHelper.CreateSqlParameters(jsonElement);
                var resultData = await _repository.GetResultByProcAsync(proc, sqlParams);
                subMsg = resultData.msg;
                if (resultData.isSuccess)
                {
                    code = ResultCode.Success;
                    subCode = ResultCode.Success;
                }
            }
            catch (Exception ex)
            {
                subMsg = ex.Message;
                code = ResultCode.Fail;
                subCode = ResultCode.Fail;
            }
            ResultViewModel result = ResultHelper.CreateResult(code, null, subCode, subMsg);
            return Ok(result);
        }

        /// <summary>
        /// 悵湔�＇偌眊
        /// </summary>
        /// <returns></returns>
        [Route("confirmbox")]
        [HttpPost]
        public async Task<IActionResult> ConfirmBox([FromBody] JsonElement jsonElement)
        {
            if (jsonElement.ValueKind == JsonValueKind.Undefined || jsonElement.ValueKind == JsonValueKind.Null)
            {
                return BadRequest();
            }
            ResultCode code = ResultCode.Fail, subCode = ResultCode.Fail;
            string subMsg = "";
            try
            {
                string proc = "pr_WMS_SaveProductStorageByBox";
                SqlParameter[] sqlParams = SqlHelper.CreateSqlParameters(jsonElement);
                var resultData = await _repository.GetResultByProcAsync(proc, sqlParams);
                subMsg = resultData.msg;
                if (resultData.isSuccess)
                {
                    code = ResultCode.Success;
                    subCode = ResultCode.Success;
                }
            }
            catch (Exception ex)
            {
                subMsg = ex.Message;
                code = ResultCode.Fail;
                subCode = ResultCode.Fail;
            }
            ResultViewModel result = ResultHelper.CreateResult(code, null, subCode, subMsg);
            return Ok(result);
        }

    }
}