liulb
/
AUCMA_SCADA
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改PLC 定时器位置

Browse Source
dev
liulb@mesnac.com 1 year ago
parent d86071f8dc
commit 93588129a1
5 changed files with 42 additions and 30 deletions
Show Stats Download Patch File Download Diff File

BIN
Admin.Core.Api/obj/Debug/net6.0/Admin.Core.Api.assets.cache
View File

Binary file not shown.

3
Admin.Core.Extensions/Middlewares/PlcMildd.cs
Unescape Escape View File

@ -19,7 +19,8 @@ namespace Admin.Core.Extensions
{ {
if (Appsettings.app("Middleware", "Plc", "Enabled").ObjToBool()) if (Appsettings.app("Middleware", "Plc", "Enabled").ObjToBool())
{ {
await plc.StartPlcAsync(); await plc.StartMelsecPlcAsync();
await plc.StartSiemensPlcAsync();
} }
} }
catch (Exception e) catch (Exception e)

5
Aucma.Core.RunPlc/IRunPlcService.cs
Unescape Escape View File

@ -1,8 +1,9 @@
 
namespace Aucma.Core.RunPlc namespace Aucma.Core.RunPlc
{ {
public interface IRunPlcService public interface IRunPlcService
{ {
Task StartPlcAsync(); Task StartMelsecPlcAsync();
Task StartSiemensPlcAsync();
} }
} }

46
Aucma.Core.RunPlc/RunPlcService.cs
Unescape Escape View File

@ -11,42 +11,44 @@ namespace Aucma.Core.RunPlc
/// </summary> /// </summary>
public class RunPlcService : IRunPlcService public class RunPlcService : IRunPlcService
{ {
System.Timers.Timer timer = new System.Timers.Timer(3000);//创建定时器，设置间隔时间为1000毫秒；
System.Timers.Timer timer1 = new System.Timers.Timer(3000);
#region 构造函数 #region 构造函数
public RunPlcService() public RunPlcService()
{ {
StartMelsecMcPlcServer(); //StartMelsecMcPlcServer();
StartSiemensPlcServer(); //StartSiemensPlcServer();
} }
#endregion #endregion
#region 心跳 #region 心跳
public Task StartPlcAsync() public async Task StartMelsecPlcAsync()
{ {
System.Timers.Timer timer = new System.Timers.Timer(3000);
timer.Elapsed += new System.Timers.ElapsedEventHandler(ExecMelsecMcHeartTask); //到达时间的时候执行事件； timer.Elapsed += new System.Timers.ElapsedEventHandler(ExecMelsecMcHeartTask); //到达时间的时候执行事件；
timer.AutoReset = true;//设置是执行一次（false）还是一直执行(true)； timer.AutoReset = true;//设置是执行一次（false）还是一直执行(true)；
timer.Enabled = true;//需要调用 timer.Start()或者timer.Enabled = true来启动它， timer.Enabled = true;//需要调用 timer.Start()或者timer.Enabled = true来启动它，
timer.Start();//timer.Start()的内部原理还是设置timer.Enabled = true; timer.Start();//timer.Start()的内部原理还是设置timer.Enabled = true;
timer1.Elapsed += new System.Timers.ElapsedEventHandler(ExecSiemensHeartTask); await Task.CompletedTask;
timer1.AutoReset = true;//设置是执行一次（false）还是一直执行(true)； }
timer1.Enabled = true;//需要调用 timer.Start()或者timer.Enabled = true来启动它， public async Task StartSiemensPlcAsync()
timer1.Start();//timer.Start()的内部原理还是设置timer.Enabled = true; {
System.Timers.Timer timer = new System.Timers.Timer(3000);//创建定时器，设置间隔时间为1000毫秒
return Task.CompletedTask; timer.Elapsed += new System.Timers.ElapsedEventHandler(ExecSiemensHeartTask);
timer.AutoReset = true;//设置是执行一次（false）还是一直执行(true)；
timer.Enabled = true;//需要调用 timer.Start()或者timer.Enabled = true来启动它，
timer.Start();//timer.Start()的内部原理还是设置timer.Enabled = true;
await Task.CompletedTask;
} }
private static void StartMelsecMcPlcServer() private static void StartMelsecMcPlcServer()
{ {
var allPlcServices = Appsettings.app<PlcModel>("PLCServer").ToList(); var allPlcServices = Appsettings.app<PlcModel>("PLCServer").ToList();
if (allPlcServices == null) return ; if (allPlcServices == null) return;
var list = allPlcServices.FindAll(d => d.PlcType == "Melsec" && d.Enabled == true); var list = allPlcServices.FindAll(d => d.PlcType == "Melsec" && d.Enabled == true);
for (int i = 1; i <= list.Count; i++) for (int i = 1; i <= list.Count; i++)
{ {
PlcModel model = new PlcModel(); PlcModel model = new PlcModel();
model.Id = list[i-1].Id; model.Id = list[i - 1].Id;
model.EquipName = list[i - 1].EquipName; model.EquipName = list[i - 1].EquipName;
model.IP = list[i - 1].IP; model.IP = list[i - 1].IP;
model.Port = list[i - 1].Port; model.Port = list[i - 1].Port;
@ -54,15 +56,15 @@ namespace Aucma.Core.RunPlc
model.plc = new MelsecPlc(list[i - 1].IP, list[i - 1].Port); model.plc = new MelsecPlc(list[i - 1].IP, list[i - 1].Port);
PlcHelper.melsecList.Add(model); PlcHelper.melsecList.Add(model);
} }
// return Task.CompletedTask; // return Task.CompletedTask;
} }
private static void StartSiemensPlcServer() private static void StartSiemensPlcServer()
{ {
List<PlcModel> allPlcServices = Appsettings.app<PlcModel>("PLCServer").ToList(); List<PlcModel> allPlcServices = Appsettings.app<PlcModel>("PLCServer").ToList();
if (allPlcServices == null) return ; if (allPlcServices == null) return;
var list = allPlcServices.FindAll(d => d.PlcType=="Siemens" && d.Enabled == true); var list = allPlcServices.FindAll(d => d.PlcType == "Siemens" && d.Enabled == true);
foreach (var item in list) foreach (var item in list)
{ {
PlcModel model = new PlcModel(); PlcModel model = new PlcModel();
@ -74,7 +76,7 @@ namespace Aucma.Core.RunPlc
model.plc = new SiemensPlc(item.IP, item.Port); model.plc = new SiemensPlc(item.IP, item.Port);
PlcHelper.siemensList.Add(model); PlcHelper.siemensList.Add(model);
} }
} }
#endregion #endregion
@ -87,8 +89,8 @@ namespace Aucma.Core.RunPlc
{ {
var item = PlcHelper.melsecList.Where(c => c.Id == i).FirstOrDefault(); var item = PlcHelper.melsecList.Where(c => c.Id == i).FirstOrDefault();
if (item == null) continue; if (item == null) continue;
var test = item.plc.ReadInt16("D6050");
if (item.plc.Read("D6050").Result) if (item.plc.Read("M100").Result)
{ {
item.IsConnect = true; item.IsConnect = true;
item.plc.IsConnected = true; item.plc.IsConnected = true;
@ -126,7 +128,7 @@ namespace Aucma.Core.RunPlc
{ {
var item = PlcHelper.siemensList.Where(c => c.Id == i).FirstOrDefault(); var item = PlcHelper.siemensList.Where(c => c.Id == i).FirstOrDefault();
if (item == null) continue; if (item == null) continue;
if (await item.plc.Read("M100")) if (await item.plc.Read("M100"))
{ {
item.IsConnect = true; item.IsConnect = true;

18
Aucma.Core.SheetMetal/Business/SyncModelHandle.cs
Unescape Escape View File

@ -1,4 +1,6 @@
using Admin.Core.IService; using Admin.Core.Common;
using Admin.Core.IService;
using Admin.Core.Model;
using Aucma.Core.HwPLc; using Aucma.Core.HwPLc;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using NetTaste; using NetTaste;
@ -26,10 +28,9 @@ namespace Aucma.Core.SheetMetal.Business
{ {
if (PlcHelper.melsecList!=null) if (PlcHelper.melsecList!=null)
{ {
melsecPlc = PlcHelper.melsecList.FirstOrDefault(d => d.EquipName.Equals("BackPanelPLC"));
do do
{ {
melsecPlc = PlcHelper.melsecList.FirstOrDefault(d => d.EquipName.Equals("BackPanelPLC"));
if (melsecPlc.plc.IsConnected) if (melsecPlc.plc.IsConnected)
{ {
byte[] info = melsecPlc.plc.Read("D6030", 100); byte[] info = melsecPlc.plc.Read("D6030", 100);
@ -39,9 +40,16 @@ namespace Aucma.Core.SheetMetal.Business
continue; continue;
} }
//读取 //读取
string planCode = Encoding.ASCII.GetString(info.Skip(0).Take(20).ToArray()).Replace("\0", "").Trim(); //string model = Encoding.ASCII.GetString(info.Skip(0).Take(20).ToArray()).Replace("\0", "").Trim();
//string productId = Encoding.ASCII.GetString(info.Skip(20).Take(20).ToArray()).Replace("\0", "").Trim();
//int complateAmount = short.Parse(bytesToHexStr(info.Skip(40).Take(1).ToArray(), 1), System.Globalization.NumberStyles.HexNumber); //int complateAmount = short.Parse(bytesToHexStr(info.Skip(40).Take(1).ToArray(), 1), System.Globalization.NumberStyles.HexNumber);
//SmSyncModel syncModel = new SmSyncModel();
//SmSyncModel smSyncModel = _smSyncModelServices.FirstAsync(d => d.SmProductId == productId).Result;
//if (smSyncModel.IsNotEmptyOrNull())
//{
// _smSyncModelServices.AddAsync(model);
//}
//_smSyncModelServices.AddAsync(model);
} }
} while (true); } while (true);
} }

Write Preview
Loading…
Cancel
Save