New Samples Update. Modbus Coil Read Write Fix.

2016-11-01 14:25:21 +08:00
parent e7e0a7795d
commit 47b7ae324c
591 changed files with 95743 additions and 21528 deletions
--- a/Samples/TaskManager/Controllers/HomeController.cs
+++ b/Samples/TaskManager/Controllers/HomeController.cs
@@ -0,0 +1,95 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Web;
+using System.Web.Mvc;
+using Modbus.Net;
+using Modbus.Net.Modbus;
+using TaskManager.Models;
+
+namespace TaskManager.Controllers
+{
+    public class HomeController : Controller
+    {
+        private static IEnumerable<TaskViewModel> values = new List<TaskViewModel>();
+        private static Modbus.Net.TaskManager task;
+
+        public ActionResult Index()
+        {
+            if (task == null)
+            {
+                StartTask();
+            }
+            return View(values.ToList());
+        }
+
+        private void StartTask()
+        {
+            
+            //增加需要通信的PLC地址
+            List<AddressUnit> addressUnits = new List<AddressUnit>
+            {
+                new AddressUnit() {Id = "d0", Name="Variable 1", Area = "4X", Address = 1, CommunicationTag = "D1", DataType = typeof (ushort)},
+                new AddressUnit() {Id = "d1", Name="Variable 2", Area = "4X", Address = 2, CommunicationTag = "D2", DataType = typeof (ushort)},
+                new AddressUnit() {Id = "d2", Name="Variable 3", Area = "4X", Address = 3, CommunicationTag = "D3", DataType = typeof (ushort)},
+                new AddressUnit() {Id = "d3", Name="Variable 4", Area = "4X", Address = 4, CommunicationTag = "D4", DataType = typeof (ushort)},
+            };
+
+            values = from unitValue in addressUnits
+                     select
+                         new TaskViewModel()
+                         {
+                             Id = unitValue.Id,
+                             Name = unitValue.Name,
+                             Address = unitValue.Address.ToString(),
+                             Value = 0,
+                             Type = unitValue.DataType.Name
+                         };
+
+            //初始化任务管理器
+            task = new Modbus.Net.TaskManager(10, 300, true);
+            //向任务管理器中添加设备
+            task.AddMachine(new ModbusMachine(ModbusType.Tcp, "192.168.3.10", addressUnits,
+            true, 2, 0));
+            //增加值返回时的处理函数
+            task.ReturnValues += (returnValues) =>
+            {
+                //唯一的参数包含返回值，是一个唯一标识符（machine的第二个参数），返回值（类型ReturnUnit）的键值对。
+                if (returnValues.ReturnValues != null)
+                { 
+                    lock (values)
+                    {
+                        var unitValues = from val in returnValues.ReturnValues select new Tuple<AddressUnit, double?>(addressUnits.FirstOrDefault(p => p.CommunicationTag == val.Key), val.Value.PlcValue);
+                        values = from unitValue in unitValues
+                            select
+                                new TaskViewModel()
+                                {
+                                    Id = unitValue.Item1.Id,
+                                    Name = unitValue.Item1.Name,
+                                    Address = unitValue.Item1.Address.ToString(),
+                                    Value = unitValue.Item2 ?? 0,
+                                    Type = unitValue.Item1.DataType.Name
+                                };
+                    }
+                }
+                else
+                {
+                    Console.WriteLine($"ip {returnValues.MachineId} not return value");
+                }
+            };
+            //启动任务
+            task.TaskStart();
+        }
+
+        [HttpGet]
+        public JsonResult Get()
+        {
+            List<TaskViewModel> ans;
+            lock (values)
+            {
+                ans = values.ToList();
+            }
+            return Json(ans, JsonRequestBehavior.AllowGet);
+        }
+    }
+}