141 lines
4.7 KiB
C#
141 lines
4.7 KiB
C#
using System.Net.Sockets;
|
||
using System.Net;
|
||
using System.Text;
|
||
using IceCoffee.FastSocket.Tcp;
|
||
using langguanApi.Model.Dto;
|
||
using Newtonsoft.Json;
|
||
using langguanApi.Model;
|
||
using langguanApi.Service.HJ212;
|
||
using langguanApi.Extensions.AutoDI;
|
||
|
||
namespace langguanApi.Service
|
||
{
|
||
|
||
public class HJ212SocketServer
|
||
{
|
||
private Hj212Service _hj212Service;
|
||
public HJ212SocketServer(Hj212Service hj212Service)
|
||
{
|
||
_hj212Service = hj212Service;
|
||
}
|
||
/// <summary>
|
||
/// 缓冲器
|
||
/// </summary>
|
||
private byte[] result = new byte[1024];
|
||
/// <summary>
|
||
/// 最大连接数
|
||
/// </summary>
|
||
private int maxClientCount;
|
||
/// <summary>
|
||
/// 服务IP地址
|
||
/// </summary>
|
||
private string ip;
|
||
/// <summary>
|
||
/// 服务端口号
|
||
/// </summary>
|
||
private int port => 5001;
|
||
// 编码
|
||
// private string code;
|
||
/// <summary>
|
||
/// 客户端列表
|
||
/// </summary>
|
||
private List<Socket> ClientSockets;
|
||
/// <summary>
|
||
/// IP终端
|
||
/// </summary>
|
||
private IPEndPoint ipEndPoint;
|
||
/// <summary>
|
||
/// 服务端Socket
|
||
/// </summary>
|
||
private Socket ServerSocket;
|
||
private static NetServer server;
|
||
private static IceCoffee.FastSocket.Tcp.TcpClient client;
|
||
/// <summary>
|
||
/// 启动服务
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task Start()
|
||
{
|
||
ip = IPAddress.Any.ToString();
|
||
server = new NetServer(ip, port);
|
||
server.Started += OnNetServer_Started;
|
||
server.ExceptionCaught += OnNetServer_ExceptionCaught;
|
||
server.SessionStarted += OnNetServer_SessionStarted;
|
||
server.SessionClosed += OnNetServer_SessionClosed;
|
||
server.ReceivedData += OnNetServer_ReceivedData;
|
||
server.SendData += OnNetServer_SendData;
|
||
server.Start();
|
||
}
|
||
private void OnNetServer_Started()
|
||
{
|
||
Console.WriteLine($"开始监听: {ip}:{port}");
|
||
}
|
||
|
||
private void OnNetServer_SendData(NetSession session, NetPackage netPackage, string rawText)
|
||
{
|
||
Console.WriteLine($"发送给: {session.RemoteIPEndPoint}: {rawText}");
|
||
}
|
||
|
||
private void OnNetServer_SessionClosed(TcpSession session)
|
||
{
|
||
Console.WriteLine("会话关闭: " + session.RemoteIPEndPoint + ", 当前会话总数: " + server.SessionCount);
|
||
}
|
||
|
||
private static void OnNetServer_SessionStarted(TcpSession session)
|
||
{
|
||
Console.WriteLine("会话开始: " + session.RemoteIPEndPoint + ", 当前会话总数: " + server.SessionCount);
|
||
}
|
||
|
||
private async void OnNetServer_ReceivedData(TcpSession session, NetPackage netPackage, string rawText)
|
||
{
|
||
Console.WriteLine("收到自: " + session.RemoteIPEndPoint + ": " + rawText);
|
||
HJ212_2017 hj = new HJ212_2017();
|
||
if (hj.DecodeData(rawText))
|
||
{
|
||
var body = JsonConvert.SerializeObject(hj.CP);
|
||
var entity = JsonConvert.DeserializeObject<Model.HJ212>(body);
|
||
entity.deviceMN = hj.DATA_HEAD["MN"];
|
||
//校验通过，开始入库
|
||
await _hj212Service.Add(entity, session.RemoteIPEndPoint.ToString());
|
||
}
|
||
}
|
||
private void OnNetServer_ExceptionCaught(Exception ex)
|
||
{
|
||
Console.WriteLine("Error in NetServer" + ex);
|
||
}
|
||
byte[] CallCRC(byte[] data)
|
||
{
|
||
string ccc = Convert.ToString(getCrc(data), 16).PadLeft(4, '0');
|
||
return Encoding.ASCII.GetBytes(ccc.ToUpper());
|
||
}
|
||
private int getCrc(byte[] data)
|
||
{
|
||
int high;
|
||
int flag;
|
||
|
||
// 16位寄存器，所有数位均为1
|
||
int wcrc = 0xffff;
|
||
for (int i = 0; i < data.Length; i++)
|
||
{
|
||
// 16 位寄存器的高位字节
|
||
high = wcrc >> 8;
|
||
// 取被校验串的一个字节与 16 位寄存器的高位字节进行“异或”运算
|
||
wcrc = high ^ data[i];
|
||
|
||
for (int j = 0; j < 8; j++)
|
||
{
|
||
flag = wcrc & 0x0001;
|
||
// 把这个 16 寄存器向右移一位
|
||
wcrc = wcrc >> 1;
|
||
// 若向右(标记位)移出的数位是 1,则生成多项式 1010 0000 0000 0001 和这个寄存器进行“异或”运算
|
||
if (flag == 1)
|
||
wcrc ^= 0xa001;
|
||
}
|
||
}
|
||
|
||
return wcrc;
|
||
}
|
||
|
||
}
|
||
}
|