using cylsg.Core;
|
using cylsg.Model.ECTEModel;
|
using EzCoreNet.Redis;
|
using EzInitqMessageDef;
|
using EzWechat;
|
using Furion;
|
using Furion.FriendlyException;
|
using InitQ.Abstractions;
|
using InitQ.Attributes;
|
using MapsterMapper;
|
using Models;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using StackExchange.Profiling.Internal;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace EzInitQ
|
{
|
/// <summary>
|
/// 川印 消息队列处理函数
|
/// </summary>
|
public class CY_MessageServiser: IRedisSubscribe
|
{
|
|
/// <summary>
|
/// 川印厂商ID
|
/// </summary>
|
public Guid firmId => new Guid("88B49967-D590-452C-93C6-0049A75FA5FF");
|
/// <summary>
|
/// 司机问题反馈 分发问题
|
/// </summary>
|
/// <param name="msg"></param>
|
[Subscribe(InitQMessages.CYOSDeiverWentiFankuai)]
|
public async void CYOSDeiverWentiFanKui(string msg)
|
{
|
|
ISqlSugarClient _OAsqlSugarClient = App.GetService<ISqlSugarClient>().AsTenant().GetConnection("ECTESTOADB");
|
|
|
var userdata = JsonConvert.DeserializeObject<CY_OSDeiverWentiFankuaiModes>(msg);
|
|
if(userdata ==null)
|
throw Oops.Oh($"队列CYOSDeiverWentiFankuai 处理失败，请检查消息格式++++++++{msg}");
|
if(userdata.OA_DeliverPlanPaicheID==null)
|
throw Oops.Oh($"队列CYOSDeiverWentiFankuai 处理失败，没有获取到派车ID+++++++++{msg}");
|
|
//var DbC = new BaseRepository<OA_DeliverPlanPaiche>();
|
var data= await _OAsqlSugarClient.Queryable<OA_DeliverPlanPaiche>().Includes(x=>x.Driver).Where(x=>x.Keyid==userdata.OA_DeliverPlanPaicheID).FirstAsync();
|
if(data==null)
|
throw Oops.Oh($"队列CYOSDeiverWentiFankuai 处理失败，没有获取到派车信息+++++++++{msg}");
|
|
if(data.Driver==null)
|
{
|
throw Oops.Oh($"队列CYOSDeiverWentiFankuai 处理失败，没有获取到司机信息+++++++++{msg}");
|
|
}
|
|
//var WorkReminderDb = new BaseRepository<OA_WorkReminder>();
|
//订单ID
|
var SellerOrderId = await _OAsqlSugarClient.Queryable<OA_DeliverPlan>().Where(x => x.DeliverPlanPaicheid == data.Keyid).Select(x=>x.SellerOrderId).FirstAsync();
|
string? orderDocumentName = null;
|
if (SellerOrderId != null)
|
orderDocumentName = await _OAsqlSugarClient.Queryable<EC_OrderBasic>().Where(x => x.SellerOrderId == SellerOrderId).Select(x => x.DocumentName).FirstAsync();
|
|
//创建人
|
var creerter = await _OAsqlSugarClient.Queryable<OaStaff>().Where(x => x.MemberId == data.Creater).Select(x => x.Name).FirstAsync();
|
if(creerter!=null)
|
{
|
await _OAsqlSugarClient.Insertable(new OA_WorkReminder
|
{
|
Content = $" 派送:{data.CompanyName} 地址:{data.Dizhi}, {data.Remark??""} {orderDocumentName??""}。 送货反馈:{userdata.WenTi}",
|
RemenderObject = creerter,
|
Remender = data.Driver.Name,
|
RemenderTime= userdata.CreateTime
|
|
}).ExecuteCommandAsync();
|
}
|
|
//派车任务
|
var PaiCheRenwu= await _OAsqlSugarClient.Queryable<OA_DeliverTixing>().Includes(x=>x.SentStaff).Where(x=>x.DeliverPlanPaicheId==data.Keyid).FirstAsync();
|
if(PaiCheRenwu!=null)
|
{
|
await _OAsqlSugarClient.Insertable(new OA_WorkReminder
|
{
|
Content = $" 派送:{data.CompanyName} 地址:{data.Dizhi}, {data.Remark ?? ""} {orderDocumentName ?? ""}。 送货反馈:{userdata.WenTi}",
|
Remender = data.Driver.Name ,
|
RemenderObject = PaiCheRenwu?.SentStaff?.Name??"",
|
RemenderTime = userdata.CreateTime
|
|
}).ExecuteCommandAsync();
|
}
|
|
if (data.Zerenren!=null)
|
{
|
//var zherenrenDb = new BaseRepository<OaStaff>();
|
var zherenren = await _OAsqlSugarClient.Queryable<OaStaff>().Where(x=>x.Keyid==data.Zerenren&&x.FirmId== firmId).Select(x=>x.Name).FirstAsync();
|
if(zherenren!=null)
|
{
|
await _OAsqlSugarClient.Insertable(new OA_WorkReminder
|
{
|
Content = $" 派送:{data.CompanyName} 地址:{data.Dizhi}, {data.Remark ?? ""} {orderDocumentName ?? ""}。 送货反馈:{userdata.WenTi}",
|
RemenderObject = zherenren,
|
Remender = data.Driver.Name,
|
RemenderTime = userdata.CreateTime
|
|
}).ExecuteCommandAsync();
|
|
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
|
|
}
|
}
|
