hao
2025-05-21 711fd971275401adc48b6a25865ea4594bc7fb75
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
using gdbg.Models;
using gdbg.Services;
using Microsoft.AspNetCore.Mvc;
using Oracle.ManagedDataAccess.Client;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
 
namespace gdbg.Controllers
{
    [ApiController]
    [Route("api/[controller]")]
    public class LogPrintEventController : ControllerBase
    {
        private readonly OracleDbService _oracleDbService;
 
        // 依赖注入 OracleDbService
        public LogPrintEventController(OracleDbService oracleDbService)
        {
            _oracleDbService = oracleDbService;
        }
 
        /// <summary>
        /// 记录打印事件(打印前/打印后 + 打印/补打)
        /// </summary>
        [HttpPost("logEvent")]
        public async Task<IActionResult> LogPrintEvent([FromBody] PrintLogRequest request)
        {
            try
            {
                // 校验参数是否为空
                if (string.IsNullOrEmpty(request.Barcode) ||
                    string.IsNullOrEmpty(request.Worker) ||
                    string.IsNullOrEmpty(request.EventType) ||
                    string.IsNullOrEmpty(request.PrintType) ||
                    string.IsNullOrEmpty(request.OrderNo) ||
                    string.IsNullOrEmpty(request.Line))
                {
                    return BadRequest(new { message = "缺少必要参数" });
                }
 
                // 调用存储过程
                string procedureCall = "BEGIN LogPrintEvent(:p_barcode, :p_worker, :p_eventType, :p_printType, :p_orderNo, :p_line,:p_version); END;";
 
                var parameters = new List<OracleParameter>
            {
                new OracleParameter("p_barcode", request.Barcode),
                new OracleParameter("p_worker", request.Worker),
                new OracleParameter("p_eventType", request.EventType),
                new OracleParameter("p_printType", request.PrintType),
                new OracleParameter("p_orderNo", request.OrderNo),
                new OracleParameter("p_line", request.Line),
                new OracleParameter("p_version", request.Version)
            };
 
                await _oracleDbService.ExecuteProcedureAsync(procedureCall, parameters);
 
                return Ok(new { message = "打印事件记录成功。" });
            }   
            catch (OracleException ex)
            {
                return StatusCode(500, new { message = "数据库错误:" + ex.Message });
            }
            catch (Exception ex)
            {
                return StatusCode(500, new { message = "服务器内部错误", error = ex.Message });
            }
        }
    }
 
    
}