yanjinhui
2025-05-16 dd5b18ba20b6863ec91c364dff0aa3b9353e54b9
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
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
using System;
using System.Collections.Generic;
using System.DirectoryServices;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using AutoMapper;
using SqlSugar;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.BaseRepository;
using WIDESEAWCS_Core.BaseServices;
using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_DTO.Telescopic;
using WIDESEAWCS_ITelescopicService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
 
 
namespace WIDESEAWCS_TelescopicService
{
    public class ParametersService : ServiceBase<Dt_Parameters, IRepository<Dt_Parameters>>, IParametersService
    {
        public IRepository<Dt_Parameters> Repository => BaseDal;
        private readonly IRepository<Sys_User> _user;
 
        public ParametersService(IRepository<Dt_Parameters> BaseDal, IRepository<Sys_User> user) : base(BaseDal)
        {
            _user = user;   
        }
 
 
        /// <summary>
        /// 自动控制伸缩杆的伸出和缩回速度
        /// </summary>
        /// <param name="ExtendedState">伸/出状态</param>
        /// <returns></returns>
        public WebResponseContent automation(string ExtendedState)
        {
            try
            {
 
                //根据int.TryParse(AppSettings.Get("DepartmentID")读取到当前是轨道几,所有人都只能操作当前
                if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
                {
                    return new WebResponseContent { Status = false, Message = "配置项 DepartmentID 无法转换为整数" };
                };
                var devices = GetDevicesByDeptId(deid);
 
                //找到Dt_Parameters中的最新一条数据
                var para = BaseDal.QueryData().Where(x=>x.Deptid== deid).OrderByDescending(x => x.CreateDate).FirstOrDefault();
                if (para == null)
                    return new WebResponseContent { Status = false, Message = "未找到参数配置" };
 
                int ext = (int)para.ExtendSpeed;//左PLC自动伸出缩回速度
                int ret = (int)para.RetractionSpeed;//右PLC自动伸出缩回速度
                int liftPosition= (int)para.LeftPosition;//左伸出位置
                int rigtpostition= (int)para.RightPosition;//右伸出位置
 
                if (ExtendedState == "伸出")
                {
                    devices.Value.left.Communicator.Write<int>("D1001", ext);//左PLC自动伸出缩回速度
                    devices.Value.left.Communicator.Write<bool>("M102", true);//伸出按钮
                    devices.Value.left.Communicator.Write<int>("D1002", liftPosition);//左伸出位置
                    devices.Value.right.Communicator.Write<int>("D1001", ret);//右PLC自动伸出缩回速度
                    devices.Value.right.Communicator.Write<bool>("M102", true);//伸出按钮
                    devices.Value.right.Communicator.Write<int>("D1002", rigtpostition);//右伸出位置
                    Console.WriteLine($"自动伸缩杆伸出 {ext},右伸出位置{liftPosition},右伸出位置{rigtpostition}");
                }
                else if (ExtendedState == "缩回")
                {
                    devices.Value.left.Communicator.Write<int>("D1001", ext);//左PLC自动伸出缩回速度
                    devices.Value.left.Communicator.Write<bool>("M103", true);//缩回按钮
                    devices.Value.right.Communicator.Write<int>("D1001", ret);//右PLC自动伸出缩回速度
                    devices.Value.right.Communicator.Write<bool>("M103", true);//缩回按钮
                    Console.WriteLine($"自动伸缩杆缩回 {ret}");
                }
                else
                {
                    return new WebResponseContent { Status = false, Message = "未知的操作命令" };
                }
 
                return new WebResponseContent { Status = true, Message = "成功",
                    Data = new
                    {
                        ExtendSpeed = ext,//
                        RetractionSpeed = ret,
                       
                    }
                };
            }
            catch (Exception ex)
            {
                return new WebResponseContent { Status = false, Message = ex.Message };
            }
        }
 
 
 
 
 
        /// <summary>
        /// 手动控制,伸缩杆的缩回和伸出速度
        /// </summary>
        /// <param name="position">伸缩杆的位置(左右)</param>
        /// <param name="ExtendedState">伸/缩状态</param>
        /// <returns></returns>
        /// 
        public WebResponseContent ManualOperation(string position, string ExtendedState)
        {
            try
            {
                if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
                {
                    return new WebResponseContent { Status = false, Message = "配置项 DepartmentID 无法转换为整数" };
                }
                var devices = GetDevicesByDeptId(deid);
 
                //俩个plc左右各一个
                //OtherDevice liftotherDevice = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == "SSG001");
                //OtherDevice rightotherDevice = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == "SSG002");
 
                //找到Dt_Parameters中的最新一条数据根据当前的deid
                var para = BaseDal.QueryData().Where(x => x.Deptid == deid).OrderByDescending(x => x.CreateDate).FirstOrDefault();
                int ext = (int)para.ManualExtend;//左PLC手动伸出缩回速度
                int ret = (int)para.ManualRetraction;//右PLC手动伸出缩回速度
                if (position == "左" && ExtendedState == "伸出")
                {
                    devices.Value.left.Communicator.Write<int>("D1000", ext);//左PLC手动伸出缩回速度
                    devices.Value.left.Communicator.Write<bool>("M100", true);//伸出按钮
                    Console.WriteLine($"{position}伸缩杆手动伸出缩回{ext}");
                }
                else if (position == "左" && ExtendedState == "缩回")
                {
                    devices.Value.left.Communicator.Write<int>("D1000", ext);//左PLC手动伸出缩回速度
                    devices.Value.left.Communicator.Write<bool>("M101", true);
                 
                    Console.WriteLine($"{position}伸缩杆手动伸出缩回{ext}");
                }
                else if (position == "右" && ExtendedState == "伸出")
                {
                    devices.Value.right.Communicator.Write<int>("D1000", ret);//右PLC手动伸出缩回速度
                    devices.Value.right.Communicator.Write<bool>("M100", true);
                    Console.WriteLine($"{position}伸缩杆手动伸出{ret}");
                }
                else if (position == "右" && ExtendedState == "缩回")
                {
                    devices.Value.right.Communicator.Write<int>("D1000", ret);//右PLC手动伸出缩回速度
                    devices.Value.right.Communicator.Write<bool>("M101", true);
                    Console.WriteLine($"{position}伸缩杆手动缩回{ret}");
                }
                return new WebResponseContent { Status = true, 
                    Message = "成功" ,
                    Data = new
                    {
                        ManualExtend = ext,
                        ManualRetraction = ret
                    }
                };//这里要加返回速度
            }
            catch (Exception ex)
            {
                return new WebResponseContent { Status = false, Message = ex.Message };
 
            }
 
        }
 
 
        /// <summary>
        /// 根据用户添加速度
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public  WebResponseContent AddSpeed(SpeedDTO entity)
        {
            try
            {
                // 获取当前登录用户
                var user = _user.QueryData(x => x.UserName == entity.account).FirstOrDefault();
               // 判断:如果不是管理员 && Dept_Id 为空,则提示错误
                if (user.UserName != "admin" && user.Dept_Id == null)
                {
                    return new WebResponseContent { Status = false, Message = "你的账号没有设置轨道站号,无法添加,请联系管理员" };
                }
               
                var dept = user.Dept_Id;
 
                //  获取配置文件中的 DepartmentID(管理员专用)
                if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
                {
                    return new WebResponseContent
                    {
                        Status = false,
                        Message = "配置项 DepartmentID 无法转换为整数"
                    };
                }
 
 
                // 判断是否为管理员账号
                bool isAdmin = user?.UserName?.Equals("admin") == true; //如果当前用户不为空,且用户名是 "admin",就认为这个用户是管理员
 
                // 根据是否是管理员决定使用哪个 Deptid
                var parmet = new Dt_Parameters
                {
                    ExtendSpeed = entity.ExtendSpeed,
                    RetractionSpeed = entity.RetractionSpeed,
                    ManualExtend = entity.ManualExtend,
                    ManualRetraction = entity.ManualRetraction,
                    LeftPosition = entity.LeftPosition,
                    RightPosition = entity.RightPosition,   
                    Deptid = isAdmin ? deid : dept.GetValueOrDefault()//如果当前用户是管理员,就用配置文件中的 DepartmentID,否则用传入的 entity 参数中的 Deptid
                };
                // 添加数据
                AddData(parmet);
 
 
                return new WebResponseContent
                {
                    Status = true,
                    Message = "添加成功",
                    Data = parmet
                };
            }
            catch (Exception ex)
            {
 
                return new WebResponseContent { Status = false, Message = ex.Message };
            }
        }
 
 
        /// <summary>
        ///当自动伸出需要暂停时,暂停按钮
        /// </summary>
        /// <returns></returns>
        public WebResponseContent PauseButton()
        {
            try
            {
                //根据int.TryParse(AppSettings.Get("DepartmentID")读取到当前是轨道几,所有人都只能操作当前
                if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
                {
                    return new WebResponseContent { Status = false, Message = "配置项 DepartmentID 无法转换为整数" };
                };
                var devices = GetDevicesByDeptId(deid);
                devices.Value.left.Communicator.Write<bool>("M104", true);
                devices.Value.right.Communicator.Write<bool>("M104", true);
                return new WebResponseContent { Status =true,Message="暂停成功",Data = devices};
            }
            catch (Exception ex)
            {
 
                return new WebResponseContent { Status = false, Message = ex.Message };
            }
        }
 
 
 
        /// <summary>
        /// 获取设备号
        /// </summary>
        /// <param name="deptId"></param>
        /// <returns></returns>
        public (OtherDevice left, OtherDevice right)? GetDevicesByDeptId(int deptId)
        {
            // 左设备号:1 -> 001,2 -> 003,3 -> 005...
            int baseCode = 1 + (deptId - 1) * 2;
            string leftCode = $"SSG{baseCode.ToString("D3")}";
            string rightCode = $"SSG{(baseCode + 1).ToString("D3")}";
 
            var left = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == leftCode);
            var right = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == rightCode);
 
            if (left == null || right == null)
                return null;
 
            return (left, right);
        }
 
 
 
        public WebResponseContent BackfillSpeed()
        {
            try
            {
                if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
                {
                    return new WebResponseContent { Status = false, Message = "配置项 DepartmentID 无法转换为整数" };
 
                }
                var para = BaseDal.QueryData().Where(x => x.Deptid == deid).OrderByDescending(x => x.CreateDate).FirstOrDefault();
                if (para==null)
                {
                    return new WebResponseContent { Message = "你还没有配置速度" };
                }
                return new WebResponseContent { Status = true, Data = para };
            }
            catch (Exception ex)
            {
 
                return new WebResponseContent { Status = false, Message = ex.Message };
            }
        }
 
     
    }
 
}