修改解析

This commit is contained in:
Hinse 2022-03-29 09:33:34 +08:00
parent 50a66a813d
commit 089c1d6fc5
6 changed files with 28 additions and 24 deletions

View File

@ -150,6 +150,15 @@ namespace Waste.Application
{ {
//记录日志 //记录日志
_loggerService.AddLogger($"设备未找到,参数:{data.ToJson()}", 3); _loggerService.AddLogger($"设备未找到,参数:{data.ToJson()}", 3);
return;
}
//计算净重,毛重-皮重=净重如果净重小于等于0则不上报保存
decimal weight = (data.Weight.ToDecimal() - device.Tare).ToDecimal(2);
if (weight <= 0)
{
//记录日志
_loggerService.AddLogger($"净重为0不上报,参数:{data.ToJson()}", 3);
return;
} }
var devicedata = await dbClient.Queryable<W_DeviceData>().FirstAsync(x => x.DeviceId == device.Id); var devicedata = await dbClient.Queryable<W_DeviceData>().FirstAsync(x => x.DeviceId == device.Id);
var resultid = IDGen.NextID(); var resultid = IDGen.NextID();
@ -176,7 +185,7 @@ namespace Waste.Application
city = "", city = "",
area = data.trashcode, area = data.trashcode,
wastetype = data.WasteType, wastetype = data.WasteType,
weigth = data.Weight, weigth = weight,
isheart = data.IsHeart, isheart = data.IsHeart,
tare = device.Tare, tare = device.Tare,
isfrist = isfrist isfrist = isfrist

View File

@ -416,27 +416,17 @@ namespace Waste.Application.ThirdApiInfo
byte[] newval = new byte[databytes.Length + result.databyte.Length]; byte[] newval = new byte[databytes.Length + result.databyte.Length];
databytes.CopyTo(newval, 0); databytes.CopyTo(newval, 0);
result.databyte.CopyTo(newval, databytes.Length); result.databyte.CopyTo(newval, databytes.Length);
var datastr = Encoding.GetEncoding("gb2312").GetString(newval); //解析协议,IC卡数据@垃圾桶编号@厨余垃圾@7.91
datastr.Replace(@"\r\n", ""); var datahex = BytesToHexStr(databytes);
var arr = datastr.Split('@'); datahex = datahex.Replace(" ", "");
string wastetype = arr[2];//垃圾类型 //收到的为16进制,对数据进行解析,0-4预留,5-垃圾种类,6-垃圾桶大小,7-@,8-12垃圾桶编号,13@,14-21垃圾种类汉字,22@,23-结束重量
string weight = arr[3];//重量,kg var trashhex = datahex.Substring(16, 10); //垃圾桶编号
string trashno = string.Empty; //垃圾桶编号 var typehex = datahex.Substring(28, 16); //垃圾种类
string size = string.Empty;//桶大小 var size = datahex.Substring(12, 2);//桶大小,30-小桶,31-大桶
var sizebytes = Encoding.Default.GetBytes(arr[0]); var weighthex = datahex.Substring(46, datahex.Length - 46);
size = Convert.ToHexString(sizebytes); string trashno = HextToDec(trashhex).ToString(); //垃圾桶编号使用10进制
var trashbytes = Encoding.Default.GetBytes(arr[1]); var wastetype = GetChsFromHex(typehex);
//长度为5个字节,后三位为垃圾桶编号(16进制) var weight = GetChsFromHex(weighthex);
if (trashbytes.Length == 5)
{
var typeBytes = new byte[3];
for (var i = 0; i < 3; i++)
{
typeBytes[i] = trashbytes[i + 2];
}
var typeHex = Convert.ToHexString(typeBytes);
trashno = Convert.ToInt32(typeHex, 16).ToString();
}
await _resultService.InsertResultByWifiAsync(new WifiPackage await _resultService.InsertResultByWifiAsync(new WifiPackage
{ {
sn = result.sn, sn = result.sn,
@ -451,7 +441,7 @@ namespace Waste.Application.ThirdApiInfo
else else
{ {
var val = await _cahce.GetAsync(result.sn); var val = await _cahce.GetAsync(result.sn);
var time = new DistributedCacheEntryOptions().SetSlidingExpiration(TimeSpan.FromSeconds(60)); var time = new DistributedCacheEntryOptions().SetSlidingExpiration(TimeSpan.FromSeconds(5));
if (val != null && val.Length > 0) if (val != null && val.Length > 0)
{ {
byte[] newval = new byte[val.Length + result.databyte.Length]; byte[] newval = new byte[val.Length + result.databyte.Length];

View File

@ -1782,6 +1782,11 @@
重量,KG 重量,KG
</summary> </summary>
</member> </member>
<member name="P:Waste.Application.WifiPackage.IsHeart">
<summary>
是否为心跳包
</summary>
</member>
<member name="T:Waste.Application.IResultService"> <member name="T:Waste.Application.IResultService">
<summary> <summary>
投放记录 投放记录

File diff suppressed because one or more lines are too long