258 lines
10 KiB
C#
258 lines
10 KiB
C#
using DotNetCore.CAP;
|
||
using Furion.DependencyInjection;
|
||
using Furion.DistributedIDGenerator;
|
||
using Microsoft.Extensions.Caching.Distributed;
|
||
using Nirvana.Common;
|
||
using Senparc.Weixin.MP.AdvancedAPIs;
|
||
using Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage;
|
||
using Senparc.Weixin.Open.Containers;
|
||
using SqlSugar;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using YBDevice.Core;
|
||
using YBDevice.Entity;
|
||
|
||
namespace YBDevice.NApi.Application.BodyInfo
|
||
{
|
||
/// <summary>
|
||
/// 八电极处理接口
|
||
/// </summary>
|
||
public class BodyService : IBodyService, ITransient
|
||
{
|
||
public string component_AppId = Senparc.Weixin.Config.SenparcWeixinSetting.Component_Appid;
|
||
public string component_Secret = Senparc.Weixin.Config.SenparcWeixinSetting.Component_Secret;
|
||
public string component_Token = Senparc.Weixin.Config.SenparcWeixinSetting.Component_Token;
|
||
public string component_EncodingAESKey = Senparc.Weixin.Config.SenparcWeixinSetting.Component_EncodingAESKey;
|
||
private readonly ISqlSugarRepository<YB_WifiBind> repository;
|
||
private readonly SqlSugarClient dbClient;
|
||
private readonly ILoggerService _loggerService;
|
||
private readonly INoticeService _noticeService;
|
||
private readonly IDistributedCache _cache;
|
||
private readonly ICapPublisher _capBus;
|
||
public BodyService(ISqlSugarRepository<YB_WifiBind> sqlSugarRepository, ILoggerService loggerService, INoticeService noticeService, IDistributedCache cache, ICapPublisher capPublisher)
|
||
|
||
{
|
||
repository = sqlSugarRepository;
|
||
dbClient = repository.Context;
|
||
_loggerService = loggerService;
|
||
_noticeService = noticeService;
|
||
_cache = cache;
|
||
_capBus = capPublisher;
|
||
}
|
||
/// <summary>
|
||
/// 数据包解析
|
||
/// </summary>
|
||
/// <param name="data"></param>
|
||
/// <returns></returns>
|
||
private BodyAnalyDto AnalyProto(BodyRequstDto data)
|
||
{
|
||
BodyAnalyDto dto = new BodyAnalyDto();
|
||
//检查是否为有效的base64数据
|
||
if (!AESEncrypt.IsBase64(data.@params))
|
||
{
|
||
dto.data = data.@params;
|
||
return dto;
|
||
}
|
||
//数据为base64加密
|
||
byte[] resultByte = Convert.FromBase64String(data.@params);
|
||
dto.data = resultByte.BytesToHexStr();
|
||
_loggerService.AddLogger($"八电极wifi结果推送,解析出的数据:{dto.data}");
|
||
int len = resultByte.Count();//数据总长度
|
||
//长度格式是否正确,固定长度为36位
|
||
if (len < 33)
|
||
{
|
||
return dto;
|
||
}
|
||
//前15个字节为sn。中间以 00 分隔。后面为测量结果数据 AA 00 01 F4 00 64 00 64 00 64 00 64 02 30 06 A4 00 00 00 00
|
||
int i = 0;
|
||
byte[] snbyte = new byte[15];
|
||
for (i = 0; i < 15; i++)
|
||
{
|
||
snbyte[i] = resultByte[i];
|
||
}
|
||
dto.sn = snbyte.BytesToHexStr().Replace(" ", "");
|
||
dto.splitstr = resultByte[i].ByteToHexStr();
|
||
int datalen = len - 16;//数据体长度
|
||
byte[] databyte = new byte[datalen];
|
||
i++;
|
||
for (int j = 0; j < datalen; j++)
|
||
{
|
||
databyte[j] = resultByte[i];
|
||
i++;
|
||
}
|
||
dto.Header = databyte[0].ByteToHexStr();
|
||
if (dto.Header != "A1" && dto.Header != "A2") //第一条数据为A1，第二条数据为A2
|
||
{
|
||
return dto;
|
||
}
|
||
dto.ischecked = true;
|
||
string tmpstr = "";
|
||
for (int j = 1; j < datalen; j++)
|
||
{
|
||
tmpstr += databyte[j].ByteToHexStr();
|
||
if (dto.Header == "A1")
|
||
{
|
||
if (j == 3)
|
||
{
|
||
dto.Weight = tmpstr.HexToDesc();
|
||
tmpstr = "";
|
||
}
|
||
if (j == 7)
|
||
{
|
||
dto.lefthandimp = tmpstr.HexToDesc();
|
||
tmpstr = "";
|
||
}
|
||
if (j == 11)
|
||
{
|
||
dto.righthandimp = tmpstr.HexToDesc();
|
||
tmpstr = "";
|
||
}
|
||
if (j == 15)
|
||
{
|
||
dto.leftfootimp = tmpstr.HexToDesc();
|
||
tmpstr = "";
|
||
}
|
||
}
|
||
if (dto.Header == "A2")
|
||
{
|
||
|
||
if (j == 4)
|
||
{
|
||
dto.rightfootimp = tmpstr.HexToDesc();
|
||
tmpstr = "";
|
||
}
|
||
if (j == 8)
|
||
{
|
||
dto.bodyimp = tmpstr.HexToDesc();
|
||
tmpstr = "";
|
||
}
|
||
if (j == 10)
|
||
{
|
||
dto.height = tmpstr.HexToDesc();
|
||
tmpstr = "";
|
||
}
|
||
}
|
||
}
|
||
return dto;
|
||
}
|
||
///<summary>
|
||
/// 处理wifi模块发送过来的数据
|
||
/// </summary>
|
||
/// <param name="data"></param>
|
||
/// <returns></returns>
|
||
public async Task<int> HandlerBodyDataAsync(BodyRequstDto data)
|
||
{
|
||
//记录发送过来的数据
|
||
_loggerService.AddLogger($"八电极发送原始数据,data={data.ToJson()}", 3);
|
||
var result = AnalyProto(data);
|
||
if (!result.ischecked)
|
||
{
|
||
return -1;
|
||
}
|
||
//数据分两条发送,首先保存第一条,然后根据二条的数据间隔进行保存
|
||
//保存到redis
|
||
var sn = result.sn;
|
||
var key = $"YBDeviceCache:Container:{sn}";
|
||
if (result.Header == "A1")
|
||
{
|
||
var param1 = $"{result.ToJson()}";
|
||
var param1byte = Encoding.UTF8.GetBytes(param1);
|
||
await _cache.SetAsync(key, param1byte, new DistributedCacheEntryOptions().SetSlidingExpiration(TimeSpan.FromSeconds(5)));
|
||
return 0;
|
||
}
|
||
else
|
||
{
|
||
var existsbyte = await _cache.GetAsync(key);
|
||
if (existsbyte != null && existsbyte.Length > 0)
|
||
{
|
||
var firstdata = Encoding.UTF8.GetString(existsbyte);
|
||
var firstjsondata = firstdata.ToObject<BodyAnalyDto>();
|
||
result.Weight = firstjsondata.Weight;
|
||
result.lefthandimp = firstjsondata.lefthandimp;
|
||
result.righthandimp = firstjsondata.righthandimp;
|
||
result.leftfootimp = firstjsondata.leftfootimp;
|
||
}
|
||
else
|
||
{
|
||
return -1;
|
||
}
|
||
}
|
||
|
||
//检查设备是否存在
|
||
var equ = await dbClient.Queryable<YB_Device>().FirstAsync(x => x.Ecode == result.sn);
|
||
if (equ == null)
|
||
{
|
||
_loggerService.AddLogger($"八电极wifi结果推送,设备未找到,参数:{result.ToJson()}", 3);
|
||
return -1;
|
||
}
|
||
//获取设备绑定的用户列表
|
||
var list = await dbClient.Queryable<YB_WifiBind>().Where(x => x.DevCode == result.sn && x.Subscribe == 1).ToListAsync();
|
||
if (list.Count == 0)
|
||
{
|
||
_loggerService.AddLogger($"八电极wifi结果推送,未绑定用户或均已取关,参数:{result.ToJson()}", 3);
|
||
return -1;
|
||
}
|
||
//由于传送过来的体重为实际*100,身高为实际*10
|
||
decimal weight = (result.Weight*1.0 / 100.0).ToDecimal();
|
||
decimal height = (result.height * 1.0 / 10.0).ToDecimal();
|
||
#region 记录数据
|
||
//记录测量记录
|
||
var ybresult = new YB_nResult {
|
||
BusinessId = equ.BusinessId,
|
||
Weight = weight,
|
||
Id =IDGen.NextID(),
|
||
SourceType = 3,
|
||
CreateTime = DateTime.Now,
|
||
DevType = equ.Type,
|
||
EquId = equ.Id,
|
||
Height = height,
|
||
Imp = result.bodyimp,
|
||
LeftArmImp = result.lefthandimp,
|
||
LeftLegImp = result.leftfootimp,
|
||
RightArmImp = result.righthandimp,
|
||
RightLegImp = result.rightfootimp
|
||
};
|
||
await dbClient.Insertable(ybresult).ExecuteCommandAsync();
|
||
|
||
//添加一条认领记录
|
||
await dbClient.Insertable(new YB_nUserResult {
|
||
Id = ybresult.Id,
|
||
CreateTime = ybresult.CreateTime,
|
||
DevType = equ.Type,
|
||
FamilyId = 0,
|
||
FansId = null,
|
||
UserId = 0
|
||
}).ExecuteCommandAsync();
|
||
await _capBus.PublishAsync("result.service.updaterealdata", new UpdateRealDataS2SDtO {
|
||
DevId = equ.Id,
|
||
IsUserTake=false
|
||
});
|
||
#endregion
|
||
//发送模版消息
|
||
decimal mheight = height/ 100.0m;
|
||
var tpldata = new
|
||
{
|
||
first = new TemplateDataItem($"收到新的测量结果"),
|
||
keyword1 = new TemplateDataItem($"{DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss")}"),
|
||
keyword2 = new TemplateDataItem($"{height}"),
|
||
keyword3 = new TemplateDataItem($"{weight}"),
|
||
keyword4 = new TemplateDataItem($"{(((weight / (mheight * mheight)) * 10.0m) / 10.0m).ToDecimal(1)}"),
|
||
remark = new TemplateDataItem($"点击查看您的测量报告")
|
||
};
|
||
var token = await AuthorizerContainer.TryGetAuthorizerAccessTokenAsync(component_AppId, "wxda671f842dfda2b8");
|
||
string url = $"https://ybapi.ybhdmob.com/body/br?d={result.sn}|{weight}|{height}|{result.lefthandimp}|{result.righthandimp}|{result.leftfootimp}|{result.rightfootimp}|{result.bodyimp}|{ybresult.Id}";
|
||
|
||
foreach(var item in list)
|
||
{
|
||
SendTemplateMessageResult results = await TemplateApi.SendTemplateMessageAsync(token, item.OpenId, "0P6GebIlc5vjYJnO272DNt94VS1SDqxDxRgNzAQTmDA", url, tpldata);
|
||
//记录发送结果
|
||
_loggerService.AddLogger($"八电极wifi结果推送,模版消息推送,参数:{result.ToJson()}\r\n结果:{results.ToJson()}", 3);
|
||
}
|
||
return 0;
|
||
}
|
||
}
|
||
}
|