using cylsg.Core;
|
using cylsg.Model.TransferOrder;
|
using cylsg.Model.UserModel;
|
using cylsg.utility.Extend;
|
using EzCoreNet.Redis;
|
using EzInitqMessageDef;
|
using EzWechat;
|
using Furion;
|
using Furion.DatabaseAccessor;
|
using Furion.FriendlyException;
|
using Furion.Logging;
|
using InitQ.Abstractions;
|
using InitQ.Attributes;
|
using Mapster;
|
using MapsterMapper;
|
using Newtonsoft.Json;
|
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Models;
|
using SqlSugar.Extensions;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace EzInitQ
|
{
|
|
|
public class PayServiceMessageQ: IRedisSubscribe
|
{
|
private IEzCoreNetRedisService _ezCoreNetRedisService;
|
private IWecharPayServicecs _wecharPayServicecs;
|
private IMapper _mapper;
|
|
/// <summary>
|
/// 微信转账队列处理
|
/// </summary>
|
[Subscribe(InitQMessages.WxTransferMSQ)]
|
public async void WxTransferMSQInit(string msg)
|
{
|
_ezCoreNetRedisService = App.GetService<IEzCoreNetRedisService>();
|
_wecharPayServicecs = App.GetService<IWecharPayServicecs>();
|
_mapper = App.GetService<IMapper>();
|
|
var userdata= JsonConvert.DeserializeObject<WxTransferMsqModels>(msg);
|
if( userdata != null ) {
|
|
throw Oops.Oh($"队列WxTransferMSQInit 处理失败，没有获取到用户信息+++++++++{msg}");
|
}
|
var UserRs = new BaseRepository<User>();
|
var user = await UserRs.GetByIdAsync(userdata.UserID);
|
if(user !=null)
|
{
|
throw Oops.Oh($"队列WxTransferMSQInit 处理失败，没有获取到用户信息++++++++{msg}");
|
}
|
if(string.IsNullOrEmpty( user.WxOpenId))
|
{
|
throw Oops.Oh($"队列WxTransferMSQInit 处理失败，没有获取到openID+++++++++{msg}");
|
}
|
var uWorkRs = new BaseRepository<UserWorker>();
|
|
|
var UserTiXianDetailwork = new BaseRepository<UserTiXianDetail>();
|
|
var WeChatTransferOrderwork = new BaseRepository<WeChatTransferOrder>();
|
var uWork = await uWorkRs.GetFirstAsync(x=>x.UserId==user.Id);
|
if((uWork != null)& ((uWork.TiXianZonge - uWork.YiTiXianJine) > userdata.money))
|
{
|
var TransferOrder = new WeChatTransferOrder
|
{
|
CreateBy = uWork.UserId.ToString(),
|
CreateTime = DateTime.Now,
|
BatchId = _ezCoreNetRedisService.Get32sn(),
|
OutBatchNumber = _ezCoreNetRedisService.Get32sn(),
|
Remake = "川印工资支付",
|
TransferDetailList = new List<WeChatTransferItem>()
|
|
|
};
|
try
|
{
|
//满足条件，发起支付
|
await UserTiXianDetailwork.AsTenant().BeginTranAsync();
|
|
|
|
|
var moneylist= userdata.money;
|
if(moneylist<=0.3m)
|
{
|
//放弃处理，低于0.3毛不能发起转账
|
throw Oops.Oh($"队列WxTransferMSQInit 处理失败，转账金额低于0.3元+++++++++{msg}");
|
}
|
var maxPayItem = Convert.ToDecimal(App.Configuration["WechartPay:PayMoneyMax"].toInt()); ;
|
while ((moneylist > maxPayItem))
|
{
|
TransferOrder.TransferDetailList.Add(new WeChatTransferItem
|
{
|
CreateBy = uWork.UserId.ToString(),
|
CreateTime = TransferOrder.CreateTime,
|
IsEn = true,
|
OpenId = user.WxOpenId,
|
OutDetailNumber = _ezCoreNetRedisService.Get32sn(),
|
|
TransferAmount = (int )maxPayItem * 100,
|
TransferRemark="川印工资支付",
|
|
});
|
|
moneylist -= maxPayItem;
|
}
|
if (moneylist <= 0.3m)
|
{
|
//如果这里低于0.3毛，将社区预检，留下次处理
|
userdata.money -= moneylist;
|
}
|
else
|
|
{
|
TransferOrder.TransferDetailList.Add(new WeChatTransferItem
|
{
|
CreateBy = uWork.UserId.ToString(),
|
CreateTime = TransferOrder.CreateTime,
|
IsEn = true,
|
OpenId = user.WxOpenId,
|
OutDetailNumber = _ezCoreNetRedisService.Get32sn(),
|
|
TransferAmount = (int)(moneylist * 100),
|
TransferRemark = "川印工资支付",
|
|
});
|
}
|
|
TransferOrder = await WeChatTransferOrderwork.AsSugarClient().InsertNav(TransferOrder).Include(x=>x.TransferDetailList).ExecuteReturnEntityAsync();
|
await UserTiXianDetailwork.InsertAsync(new UserTiXianDetail
|
{
|
CreateBy = uWork.UserId.ToString(),
|
CreateTime = DateTime.Now,
|
UserId = user.Id,
|
ZhiChuShouRu= 0,
|
YiTiXianJine=userdata.money,
|
WeChatTransferOrderID= TransferOrder.Id,
|
|
|
|
});
|
|
|
|
//钱包余额调整
|
|
uWork.YiTiXianJine += userdata.money;
|
uWork.UpDataBy = uWork.UserId.ToString();
|
uWork.UpDataTime = DateTime.Now;
|
await uWorkRs.UpdateAsync(uWork);
|
|
|
await UserTiXianDetailwork.AsTenant().CommitTranAsync();
|
|
|
}
|
catch (Exception)
|
{
|
await UserTiXianDetailwork.AsTenant().RollbackTranAsync();
|
throw;
|
}
|
// 发起支付
|
|
var requit = _mapper.Map<CreateTransferBatchRequest>(TransferOrder);
|
var ret= await _wecharPayServicecs.Transfer(requit);
|
if (ret.IsSuccessful())
|
{
|
var retdata= await WeChatTransferOrderwork.GetByIdAsync(TransferOrder.Id);
|
retdata.BatchId = ret.BatchId;
|
retdata.BatchStatus= ret.BatchStatus;
|
retdata.UpDataBy = "微信付款请求之后";
|
retdata.UpDataTime= DateTime.Now;
|
await WeChatTransferOrderwork.UpdateAsync(retdata);
|
}
|
else
|
throw Oops.Oh($"微信请求付款失败+++++++++++++{ret.ToString()}+++++++++++msg{msg}");
|
|
|
}
|
|
|
}
|
|
[Subscribe(InitQMessages.WxTransfer)]
|
public async void WxTransfer(string msg)
|
{
|
_ezCoreNetRedisService = App.GetService<IEzCoreNetRedisService>();
|
_wecharPayServicecs = App.GetService<IWecharPayServicecs>();
|
_mapper = App.GetService<IMapper>();
|
|
|
var WeChatTransferOrderwork = new BaseRepository<WeChatTransferOrder>();
|
var TransferOrder = await WeChatTransferOrderwork.AsQueryable().Includes(x => x.TransferDetailList).Where(x=>x.Id==msg.toInt()).FirstAsync();
|
if(TransferOrder == null)
|
{
|
Log.Error($"WxTransfer微信支付处理 失败，原因是没有找到TransferOrder ，传递Id为{msg}");
|
|
return;
|
}
|
if(!string.IsNullOrEmpty(TransferOrder.BatchStatus))
|
{
|
|
return;
|
}
|
|
// 发起支付
|
var requit = _mapper.Map<CreateTransferBatchRequest>(TransferOrder);
|
requit.AppId = App.Configuration["WechatAPP:AppId"];
|
requit.BatchName = "小镇临时工工资转账";
|
requit.BatchRemark = "川印临时工工资，操过200的多笔支付";
|
|
var ret = await _wecharPayServicecs.Transfer(requit);
|
if (ret.IsSuccessful())
|
{
|
var retdata = await WeChatTransferOrderwork.GetByIdAsync(TransferOrder.Id);
|
retdata.BatchId = ret.BatchId;
|
retdata.BatchStatus = ret.BatchStatus;
|
retdata.UpDataBy = "微信付款请求之后";
|
retdata.UpDataTime = DateTime.Now;
|
await WeChatTransferOrderwork.UpdateAsync(retdata);
|
}
|
else
|
{
|
var retdata = await WeChatTransferOrderwork.GetByIdAsync(TransferOrder.Id);
|
retdata.ErrorCode = ret.ErrorCode;
|
retdata.ErrorMsg = ret.ErrorMessage;
|
retdata.BatchStatus = ret.BatchStatus;
|
retdata.UpDataBy = "微信付款请求之后";
|
retdata.UpDataTime = DateTime.Now;
|
await WeChatTransferOrderwork.UpdateAsync(retdata);
|
Log.Error($"WxTransfer微信支付处理 失败，传递Id为{msg} 错误原因:{retdata.ErrorMsg}");
|
return;
|
}
|
|
|
}
|
|
|
[Subscribe(InitQMessages.WxTransferAg)]
|
public async void WxTransferAg(string msg)
|
{
|
_ezCoreNetRedisService = App.GetService<IEzCoreNetRedisService>();
|
_wecharPayServicecs = App.GetService<IWecharPayServicecs>();
|
_mapper = App.GetService<IMapper>();
|
|
|
var WeChatTransferOrderwork = new BaseRepository<WeChatTransferOrder>();
|
var TransferOrder = await WeChatTransferOrderwork.AsQueryable().Includes(x => x.TransferDetailList).Where(x => x.Id == msg.toInt()).FirstAsync();
|
if (TransferOrder == null)
|
{
|
Log.Error($" 再次调用WxTransfer微信支付处理 失败，原因是没有找到TransferOrder ，传递Id为{msg}");
|
|
return;
|
}
|
if (!string.IsNullOrEmpty(TransferOrder.BatchStatus))
|
{
|
|
return;
|
}
|
|
// 发起支付
|
var requit = _mapper.Map<CreateTransferBatchRequest>(TransferOrder);
|
requit.AppId = App.Configuration["WechatAPP:AppId"];
|
requit.BatchName = "小镇临时工工资转账";
|
requit.BatchRemark = "川印临时工工资，操过200的多笔支付";
|
|
var ret = await _wecharPayServicecs.Transfer(requit);
|
if (ret.IsSuccessful())
|
{
|
var retdata = await WeChatTransferOrderwork.GetByIdAsync(TransferOrder.Id);
|
retdata.BatchId = ret.BatchId;
|
retdata.BatchStatus = ret.BatchStatus;
|
retdata.UpDataBy = "再次微信付款请求";
|
retdata.UpDataTime = DateTime.Now;
|
await WeChatTransferOrderwork.UpdateAsync(retdata);
|
}
|
else
|
{
|
var retdata = await WeChatTransferOrderwork.GetByIdAsync(TransferOrder.Id);
|
retdata.ErrorCode = ret.ErrorCode;
|
retdata.ErrorMsg = ret.ErrorMessage;
|
retdata.BatchStatus = ret.BatchStatus;
|
retdata.UpDataBy = "再微信付款请求";
|
retdata.UpDataTime = DateTime.Now;
|
await WeChatTransferOrderwork.UpdateAsync(retdata);
|
Log.Error($"WxTransfer微信支付处理 失败，传递Id为{msg} 错误原因:{retdata.ErrorMsg}");
|
return;
|
}
|
|
|
}
|
}
|
}
|
