first commit

南骏 池

4 天以前 72449a1b8699b65712e57fba8abce5a8240e9465

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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
using System.Data;
using System.Data.SqlClient;
using Gs.Toolbox;
using Gs.Toolbox.ApiCore.Abstract.Mvc;
using Gs.Toolbox.ApiCore.Common.Mvc;
using Gs.Toolbox.ApiCore.Group;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using static Gs.Toolbox.UtilityHelper;
 
namespace Gs.Pda.Service
{
 
    [ApiGroup(ApiGroupNames.PDA)]
    public class PqcManager: IRomteService
    {
        private readonly IHttpContextAccessor _http;
        /// <summary>
        /// 用户Code,用户Guid,组织ID
        /// </summary>
        private readonly string _userCode, _userGuid, _orgFids;
        public PqcManager(IHttpContextAccessor httpContextAccessor)
        {
            _http = httpContextAccessor;
            (_userCode, _userGuid, _orgFids) = GetUserGuidAndOrgGuid(_http);
        }
 
        //  LogHelper.Debug("GetUserGuidAndOrgGuid:", ex.Message);
 
        /// <summary>
        /// 首检/巡检输入检验值
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        /// <summary>
        /// 录入检验结果
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<int?> AddIpqcJyz([FromBody] dynamic model)
        {
            string inOrderGuid1 = model.inOrderGuid1; //这是检验单guid
            string inOrderGuid5 = model.inOrderGuid5; //这是抽样的guid
            string inP1 = model.inP1; //这是9，有可能是19，或者0k-19,或者ng-19
            var _outMsg = "";
            int? _outSum = -1;
            using (var conn = new SqlConnection(DbHelperSQL.strConn))
            {
                using (var cmd = new SqlCommand("[ipqc_detect01_panding]", conn))
                {
                    try
                    {
                        conn.Open();
                        cmd.CommandType = CommandType.StoredProcedure;
                        SqlParameter[] parameters =
                        {
                    new("@outMsg", SqlDbType.NVarChar, 300),
                    new("@outSum", SqlDbType.Int),
                    new("@inEdtUserGuid", _userGuid),
                    new("@inOrderGuid1", inOrderGuid1),
                    new("@inOrderGuid5", inOrderGuid5),
                    new("@inP1", inP1),
                };
                        parameters[0].Direction = ParameterDirection.Output;
                        parameters[1].Direction = ParameterDirection.Output;
                        foreach (var parameter in parameters)
                            cmd.Parameters.Add(parameter);
                        cmd.ExecuteNonQuery();
                        _outMsg = parameters[0].Value.ToString();
                        _outSum = int.Parse(parameters[1].Value.ToString());
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Debug(ToString(),
                            "ipqc_detect01_panding error：" + ex.Message);
                        _outMsg = ex.Message;
                        _outSum = -1;
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
            if (_outSum <= 0)
                return ReturnDto<string>.QuickReturn(_outSum,
                    ReturnCode.Exception, _outMsg);
            return ReturnDto<string>.QuickReturn(_outSum,
                ReturnCode.Success, _outMsg);
        }
 
 
 
        /// <summary>
        /// 删除检验结果
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<int?> DeleteIpqcJyz([FromBody] dynamic model)
        {
            string inOrderGuid1 = model.inOrderGuid1; //这是检验单guid
            string inOrderGuid5 = model.inOrderGuid5; //这是抽样的guid
            string inOrderGuid12 = model.inOrderGuid12; //这是抽样的guid
            string inP1 = model.inP1; //这是9，有可能是19，或者0k-19,或者ng-19
            var _outMsg = "";
            int? _outSum = -1;
            using (var conn = new SqlConnection(DbHelperSQL.strConn))
            {
                using (var cmd = new SqlCommand("[ipqc_QADETAIL12_DELETE]", conn))
                {
                    try
                    {
                        conn.Open();
                        cmd.CommandType = CommandType.StoredProcedure;
                        SqlParameter[] parameters =
                        {
                    new("@outMsg", SqlDbType.NVarChar, 300),
                    new("@outSum", SqlDbType.Int),
                    new("@inEdtUserGuid", _userGuid),
                    new("@inOrderGuid1", inOrderGuid1),
                    new("@inOrderGuid5", inOrderGuid5),
                    new("@inOrderGuid12", inOrderGuid12),
                    new("@inP1", inP1),
                };
                        parameters[0].Direction = ParameterDirection.Output;
                        parameters[1].Direction = ParameterDirection.Output;
                        foreach (var parameter in parameters)
                            cmd.Parameters.Add(parameter);
                        cmd.ExecuteNonQuery();
                        _outMsg = parameters[0].Value.ToString();
                        _outSum = int.Parse(parameters[1].Value.ToString());
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Debug(ToString(),
                            "ipqc_detect01_panding error：" + ex.Message);
                        _outMsg = ex.Message;
                        _outSum = -1;
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
            if (_outSum <= 0)
                return ReturnDto<string>.QuickReturn(_outSum,
                    ReturnCode.Exception, _outMsg);
            return ReturnDto<string>.QuickReturn(_outSum,
                ReturnCode.Success, _outMsg);
        }
    }
}