using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Diagnostics;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using RJCP.IO.Ports;
|
using WIDESEA_ISerialPortRepository;
|
using WIDESEA_ISerialPortService;
|
using WIDESEA_SerialPortTestService;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_Core.BaseServices;
|
using WIDESEAWCS_Model.Models.SerialPort;
|
|
namespace WIDESEA_SerialPortService
|
{
|
public class SerialPortService : ServiceBase<Dt_TorqueOp, ISerialPortRepository>, ISerialPortService
|
{
|
private SerialPortTestService _serialPortTestService; // 串口服务
|
public SerialPortService(ISerialPortRepository BaseDal) : base(BaseDal)
|
{
|
|
//_serialPortTestService = new SerialPortTestService("COM3");
|
// 传递 SerialPortService 到 SerialPortTestService
|
_serialPortTestService = new SerialPortTestService("COM3", this);
|
}
|
|
public WebResponseContent AddSerialPort(Dt_TorqueOp TorqueOp)
|
{
|
WebResponseContent content = new WebResponseContent();
|
//BaseDal.Db.Insertable(TorqueOp).ExecuteCommand();
|
|
BaseDal.AddData(TorqueOp);
|
|
content = WebResponseContent.Instance.OK("成功");
|
return content;
|
}
|
|
|
// 启动串口通信
|
public void StartSerialPortCom()
|
{
|
//WebResponseContent content = new WebResponseContent();
|
|
// 打开串口并开始发送数据
|
_serialPortTestService.OpenSerialPort();
|
|
//return content;
|
}
|
|
|
|
// 停止串口通信
|
public void StopSerialPortCom()
|
{
|
//WebResponseContent content = new WebResponseContent();
|
_serialPortTestService.CloseSerialPort(); // 关闭串口
|
//return content;
|
}
|
|
|
public List<string> GetSerialPortCom()
|
{
|
|
return _serialPortTestService.GetReceivedData();
|
|
}
|
|
|
}
|
}
|
