525 lines
16 KiB
C#
525 lines
16 KiB
C#
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.ComponentModel;
|
|||
|
|
using System.Data;
|
|||
|
|
using System.Drawing;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Windows.Forms;
|
|||
|
|
using System.ServiceModel;
|
|||
|
|
using elelab;
|
|||
|
|
using System.ServiceModel.Description;
|
|||
|
|
using System.Threading;
|
|||
|
|
using System.Net;
|
|||
|
|
using System.IO;
|
|||
|
|
using System.Runtime.Serialization.Json;
|
|||
|
|
namespace DNLightSvr
|
|||
|
|
{
|
|||
|
|
public partial class form1 : Form
|
|||
|
|
{
|
|||
|
|
static log4net.ILog log = log4net.LogManager.GetLogger("light");
|
|||
|
|
private ServiceHost host = null;
|
|||
|
|
public static List<ELabel> labelPool = new List<ELabel>();
|
|||
|
|
string svrUrl = "http://127.0.0.1:9998/DNlightSvc";
|
|||
|
|
string wmsUrl = "";
|
|||
|
|
string postUrl = "";
|
|||
|
|
|
|||
|
|
public form1()
|
|||
|
|
{
|
|||
|
|
InitializeComponent();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void Form1_Load(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
//StartPosition = FormStartPosition.CenterParent;
|
|||
|
|
|
|||
|
|
startHost();
|
|||
|
|
//btnTest.Visible = false;
|
|||
|
|
}
|
|||
|
|
void startHost()
|
|||
|
|
{
|
|||
|
|
// lbStatus.Text = "服务启动失败";
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
initPorts();
|
|||
|
|
svrUrl = System.Configuration.ConfigurationManager.AppSettings["BaseUri"];
|
|||
|
|
wmsUrl = System.Configuration.ConfigurationManager.AppSettings["WMSuri"];
|
|||
|
|
Uri baseAddress = new Uri(svrUrl);
|
|||
|
|
LightService service = new LightService();
|
|||
|
|
service.clearO += this.clearOrder;
|
|||
|
|
service.lightUp += this.lightUp;
|
|||
|
|
|
|||
|
|
host = new ServiceHost(service, baseAddress);
|
|||
|
|
elelab.DNLights.lightOffEvent += testPicked;
|
|||
|
|
|
|||
|
|
WebHttpBinding binding = new WebHttpBinding();
|
|||
|
|
ServiceEndpoint endpoint = host.AddServiceEndpoint(typeof(ILightService), binding, baseAddress);
|
|||
|
|
WebHttpBehavior httpBehavior = new WebHttpBehavior();
|
|||
|
|
endpoint.Behaviors.Add(httpBehavior);
|
|||
|
|
host.Opened += delegate
|
|||
|
|
{
|
|||
|
|
addLog("服务已启动");
|
|||
|
|
if (InvokeRequired)
|
|||
|
|
{
|
|||
|
|
this.Invoke(new showStatus(delegate()
|
|||
|
|
{
|
|||
|
|
lbStatus.Text = "服务已启动";
|
|||
|
|
lbUrl.Text ="亮灯服务地址:" + svrUrl + "\r\n\nWMS回传地址: " + wmsUrl;
|
|||
|
|
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
lbStatus.Text = "服务已启动";
|
|||
|
|
lbUrl.Text = "亮灯服务地址:" + svrUrl + "\r\n\nWMS回传地址: " + wmsUrl;
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
host.Open();
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
catch (Exception e)
|
|||
|
|
{
|
|||
|
|
addLog("启动服务失败: " + e.Message);
|
|||
|
|
MessageBox.Show("启动服务失败: " + e.Message);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void initPorts()
|
|||
|
|
{
|
|||
|
|
elelab.DNLights.initPort();
|
|||
|
|
|
|||
|
|
List<int> ports = elelab.DNLights.getActiveComports();
|
|||
|
|
if (ports.Count > 0)
|
|||
|
|
{
|
|||
|
|
lbPorts.Text = "活动端口：";
|
|||
|
|
foreach (int i in ports)
|
|||
|
|
{
|
|||
|
|
lbPorts.Text += " com" +i + ",";
|
|||
|
|
}
|
|||
|
|
lbPorts.Text = lbPorts.Text.Substring(0, lbPorts.Text.Length - 1);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
lbPorts.Text = "请检查控制器连接,并重启服务";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
bool lightUp(ELabel[] labels)
|
|||
|
|
{
|
|||
|
|
//TODO： 把传来的实体按portNo分组，按portNo 分别点亮
|
|||
|
|
|
|||
|
|
Dictionary<int, List<ELabel>> lbsOrder = new Dictionary<int, List<ELabel>>(); //按orderNo 分组
|
|||
|
|
Dictionary<int, List<ELabel>> lbsPort ; //按port分组
|
|||
|
|
foreach (ELabel el in labels)
|
|||
|
|
{
|
|||
|
|
if (el == null)
|
|||
|
|
{
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (el.orderNo > 200 || el.orderNo < 1)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
// addLog( "orderNo 只能取1-200范围的值");
|
|||
|
|
// addLog("eorderNo 错误：" + getJson(el));
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// lbsPort.ContainsKey(el.port);
|
|||
|
|
// if (!lbsPort.Keys.Contains(el.port))
|
|||
|
|
if (!lbsOrder.ContainsKey(el.orderNo))
|
|||
|
|
{
|
|||
|
|
lbsOrder[el.orderNo] = new List<ELabel>();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
lbsOrder[el.orderNo].Add(el);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
foreach (int keyOrder in lbsOrder.Keys)
|
|||
|
|
{
|
|||
|
|
List<ELabel> lbs = lbsOrder[keyOrder];
|
|||
|
|
lbsPort = new Dictionary<int, List<ELabel>>();
|
|||
|
|
foreach (ELabel el in lbs)
|
|||
|
|
{
|
|||
|
|
// lbsPort.ContainsKey(el.port);
|
|||
|
|
// if (!lbsPort.Keys.Contains(el.port))
|
|||
|
|
if (!lbsPort.ContainsKey(el.port))
|
|||
|
|
{
|
|||
|
|
lbsPort[el.port] = new List<ELabel>();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
lbsPort[el.port].Add(el);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
foreach (int keyPort in lbsPort.Keys)
|
|||
|
|
{
|
|||
|
|
Thread.Sleep(100);
|
|||
|
|
if (!doLightUp(keyOrder,keyPort, lbsPort[keyPort]))
|
|||
|
|
{
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return true;
|
|||
|
|
// int port = 5;
|
|||
|
|
// doLightUp(port, lables);
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
bool doLightUp(int orderNo,int portNo, List<ELabel> lables)
|
|||
|
|
{
|
|||
|
|
int[] ids = new int[lables.Count];
|
|||
|
|
int[] address = new int[lables.Count]; ;//标签坐标（行、列）
|
|||
|
|
int[] counts = new int[lables.Count]; ;//显示数量
|
|||
|
|
int[] colors = new int[lables.Count]; ;
|
|||
|
|
|
|||
|
|
|
|||
|
|
for (int i = 0; i < lables.Count; i++)
|
|||
|
|
{
|
|||
|
|
ids[i] = lables[i].labelId;
|
|||
|
|
address[i] = lables[i].address;
|
|||
|
|
counts[i] = lables[i].count;
|
|||
|
|
colors[i] = lables[i].color;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
//elelab.DNLights.initPort();
|
|||
|
|
|
|||
|
|
bool result = false;
|
|||
|
|
if (orderNo == 0)
|
|||
|
|
{
|
|||
|
|
result = DNLights.lightLabels(portNo, colors, ids, address, counts);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
result = DNLights.lightLabels(orderNo, portNo, colors, ids, address, counts);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
if (!result)
|
|||
|
|
{
|
|||
|
|
addLog(string.Format("亮灯失败： orderNo {0},portNo{1} ",orderNo,portNo));
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return result;
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
delegate void showStatus();
|
|||
|
|
void testPicked(int orderNo, int eleId, int color, int eleAddress, int count)
|
|||
|
|
{
|
|||
|
|
if (InvokeRequired)
|
|||
|
|
{
|
|||
|
|
this.Invoke(new showStatus(delegate()
|
|||
|
|
{
|
|||
|
|
returnResult(orderNo, eleId, color, eleAddress, count);
|
|||
|
|
}));
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
returnResult(orderNo, eleId, color, eleAddress, count);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void returnResult(int orderNo, int eleId, int color, int eleAddress, int count)
|
|||
|
|
{
|
|||
|
|
//to show result
|
|||
|
|
|
|||
|
|
//to call client and send data
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
ELabel lb = new ELabel();
|
|||
|
|
lb.count = count;
|
|||
|
|
lb.color = color;
|
|||
|
|
lb.address = eleAddress;
|
|||
|
|
lb.orderNo = orderNo;
|
|||
|
|
lb.labelId = eleId;
|
|||
|
|
String url = svrUrl + "testPost";
|
|||
|
|
addLog("收到按键返回事件，开始回传...");
|
|||
|
|
addLog(getJson(lb));
|
|||
|
|
|
|||
|
|
|
|||
|
|
// String s = getJson(lb);
|
|||
|
|
postUrl = wmsUrl;
|
|||
|
|
Thread threadPreProcess = new Thread(new ParameterizedThreadStart(HttpPost));
|
|||
|
|
threadPreProcess.IsBackground = true;
|
|||
|
|
threadPreProcess.Start(lb);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void btnStart_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
Thread threadPreProcess = new Thread(startHost);
|
|||
|
|
threadPreProcess.IsBackground = true;
|
|||
|
|
threadPreProcess.Start();
|
|||
|
|
//startHost();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// GET请求与获取结果
|
|||
|
|
/// </summary>
|
|||
|
|
public void HttpGet(string Url, string postDataStr)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Url + (string.IsNullOrEmpty(postDataStr) ? "" : "?") + postDataStr);
|
|||
|
|
request.Method = "GET";
|
|||
|
|
request.ContentType = "text/html;charset=UTF-8";
|
|||
|
|
request.Timeout = 10000;
|
|||
|
|
request.BeginGetResponse(new AsyncCallback(Compleate), request);
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
|
|||
|
|
Stream myResponseStream = response.GetResponseStream();
|
|||
|
|
StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.UTF8);
|
|||
|
|
string retString = myStreamReader.ReadToEnd();
|
|||
|
|
myStreamReader.Close();
|
|||
|
|
myResponseStream.Close();
|
|||
|
|
return retString;
|
|||
|
|
*/
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
addLog("http get error: "+ ex.Message);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void HttpPost(Object ticket)
|
|||
|
|
{
|
|||
|
|
//string Url = svrUrl + "testPost";
|
|||
|
|
DataContractJsonSerializer serializer = new DataContractJsonSerializer(ticket.GetType());
|
|||
|
|
MemoryStream stream = new MemoryStream();
|
|||
|
|
serializer.WriteObject(stream, ticket);
|
|||
|
|
byte[] dataBytes = new byte[stream.Length];
|
|||
|
|
stream.Position = 0;
|
|||
|
|
stream.Read(dataBytes, 0, (int)stream.Length);
|
|||
|
|
string param = Encoding.UTF8.GetString(dataBytes);
|
|||
|
|
byte[] bs = Encoding.ASCII.GetBytes(param);
|
|||
|
|
HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(postUrl);
|
|||
|
|
req.Method = "POST";
|
|||
|
|
req.ContentType = "application/json";
|
|||
|
|
req.ContentLength = bs.Length;
|
|||
|
|
using (Stream reqStream = req.GetRequestStream())
|
|||
|
|
{
|
|||
|
|
reqStream.Write(bs, 0, bs.Length);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
req.BeginGetResponse(new AsyncCallback(Compleate), req);
|
|||
|
|
/*
|
|||
|
|
HttpWebResponse hwr = req.GetResponse() as HttpWebResponse;
|
|||
|
|
System.IO.StreamReader myreader = new System.IO.StreamReader(hwr.GetResponseStream(), Encoding.UTF8);
|
|||
|
|
string responseText = myreader.ReadToEnd();
|
|||
|
|
Console.WriteLine( responseText);
|
|||
|
|
* */
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public void Compleate(IAsyncResult asyncResult)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
HttpWebRequest req = (asyncResult.AsyncState as HttpWebRequest);
|
|||
|
|
HttpWebResponse res = req.EndGetResponse(asyncResult) as HttpWebResponse;
|
|||
|
|
StreamReader reader = new StreamReader(res.GetResponseStream());
|
|||
|
|
string responseText = reader.ReadToEnd();
|
|||
|
|
Console.WriteLine(responseText);
|
|||
|
|
this.Invoke(new showStatus(delegate()
|
|||
|
|
{
|
|||
|
|
addLog( "收到服务器响应：\n" + responseText);
|
|||
|
|
}));
|
|||
|
|
|
|||
|
|
|
|||
|
|
Console.WriteLine(responseText);
|
|||
|
|
// MessageBox.Show(reader.ReadToEnd());
|
|||
|
|
}
|
|||
|
|
catch(Exception e)
|
|||
|
|
{
|
|||
|
|
addLog("错误消息：" +e.Message);
|
|||
|
|
string errStack = "";
|
|||
|
|
foreach (char s in e.StackTrace)
|
|||
|
|
{
|
|||
|
|
errStack += s;
|
|||
|
|
}
|
|||
|
|
addLog(errStack);
|
|||
|
|
|
|||
|
|
//MessageBox.Show("获取失败.");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
private void btnBack_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
postUrl = wmsUrl;
|
|||
|
|
addLog("开始测试回传WMS");
|
|||
|
|
Thread threadPreProcess = new Thread(new ParameterizedThreadStart(HttpPost));
|
|||
|
|
threadPreProcess.IsBackground = true;
|
|||
|
|
threadPreProcess.Start(new ELabel());
|
|||
|
|
|
|||
|
|
//HttpPost(url,lb);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void btnTestrequest_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
String url ="http://127.0.0.1:9998/DNlightSvc/test";
|
|||
|
|
HttpGet(url, null);
|
|||
|
|
}
|
|||
|
|
public string getJson(ELabel label)
|
|||
|
|
{
|
|||
|
|
string json = String.Format("\"labelId\":{0},\"address\":{1},\"count\":{2},\"color\":{3},\"port\":{4},\"orderNo\":{5}"
|
|||
|
|
, label.labelId, label.address, label.count, label.color, label.port,label.orderNo);
|
|||
|
|
// Console.Write("get the lable: " + json);
|
|||
|
|
|
|||
|
|
return "{"+ json +"}";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
void addLog(string info)
|
|||
|
|
{
|
|||
|
|
if (InvokeRequired)
|
|||
|
|
{
|
|||
|
|
this.Invoke(new showStatus(delegate()
|
|||
|
|
{
|
|||
|
|
doLogTxt(info);
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
doLogTxt(info);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
void doLogTxt(string info)
|
|||
|
|
{
|
|||
|
|
if (this.textLog.Lines.Length > 100)
|
|||
|
|
{
|
|||
|
|
this.textLog.Text = "";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
while (info.Length < 100)
|
|||
|
|
{
|
|||
|
|
info += " ";
|
|||
|
|
}
|
|||
|
|
log.Debug(getMsg("ServiceForm", info));
|
|||
|
|
|
|||
|
|
info = " " + System.DateTime.Now +" "+ info;
|
|||
|
|
this.textLog.Text = info + "\r\n" + this.textLog.Text;
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
static string getMsg(string className, string msg)
|
|||
|
|
{
|
|||
|
|
return string.Format("{0} {1}",className,msg);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void btnTest_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
int color = 0;
|
|||
|
|
for (int i = 1; i < 6; i++)
|
|||
|
|
{
|
|||
|
|
color++;
|
|||
|
|
if (color > 7)
|
|||
|
|
{
|
|||
|
|
color = 0;
|
|||
|
|
}
|
|||
|
|
testLight(i+1, color);
|
|||
|
|
Thread.Sleep(100);
|
|||
|
|
//break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
void testLight(int orderNo,int color)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
ELabel[] els = new ELabel[9];
|
|||
|
|
|
|||
|
|
for (int i = 1; i < 10; i++)
|
|||
|
|
{
|
|||
|
|
ELabel el = new ELabel();
|
|||
|
|
|
|||
|
|
el.labelId = i;
|
|||
|
|
el.count = new Random().Next(1, 8888);
|
|||
|
|
el.address = new Random().Next(1, 88);
|
|||
|
|
el.color = color;// new Random().Next(1, 6);
|
|||
|
|
el.port = 6;
|
|||
|
|
el.orderNo = orderNo;
|
|||
|
|
|
|||
|
|
els[i-1] = el;
|
|||
|
|
Thread.Sleep(100);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/*for (int i = 5; i < 9; i++)
|
|||
|
|
{
|
|||
|
|
ELabel el1 = new ELabel();
|
|||
|
|
el1.labelId = i;// new Random().Next(5, 9);
|
|||
|
|
el1.count = new Random().Next(1, 8666);
|
|||
|
|
el1.address = new Random().Next(1, 86);
|
|||
|
|
el1.color = color; //new Random().Next(1, 6);
|
|||
|
|
el1.port = 9;
|
|||
|
|
el1.orderNo = orderNo;
|
|||
|
|
|
|||
|
|
els[i-1] = el1;
|
|||
|
|
}
|
|||
|
|
*/
|
|||
|
|
postUrl = svrUrl + "lightLabels";
|
|||
|
|
addLog("开始测试亮灯");
|
|||
|
|
Thread threadPreProcess = new Thread(new ParameterizedThreadStart(HttpPost));
|
|||
|
|
threadPreProcess.IsBackground = true;
|
|||
|
|
threadPreProcess.Start(els);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
bool clearOrder(ClearOrder order)
|
|||
|
|
{
|
|||
|
|
foreach (int port in order.ports)
|
|||
|
|
{
|
|||
|
|
if (!elelab.DNLights.clearOrder(order.orderNo, port))
|
|||
|
|
{
|
|||
|
|
addLog("清除订单失败");
|
|||
|
|
addLog(string.Format("端口: {0}，订单：{1}",port,order.orderNo));
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void btnRefresh_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
System.Diagnostics.Process.Start(System.Reflection.Assembly.GetExecutingAssembly().Location);
|
|||
|
|
System.Environment.Exit(0);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void btnClear_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
elelab.DNLights.clearOrder(1, 6);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void btnReset_Click(object sender, EventArgs e)
|
|||
|
|
{
|
|||
|
|
elelab.DNLights.resetDevice();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void form1_FormClosing(object sender, FormClosingEventArgs e)
|
|||
|
|
{
|
|||
|
|
elelab.DNLights.resetDevice();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|