From a622695a0cd6ea5aa63869f5c1a891e589909f48 Mon Sep 17 00:00:00 2001
From: 小飞侠 <8277136+liaoxujun@user.noreply.gitee.com>
Date: 星期二, 07 四月 2026 16:14:57 +0800
Subject: [PATCH] no message
---
cylsg/EzInitQ/CY_MessageServiser.cs | 127 ++++++++++++++++++++++++++++++++++++++++++
1 files changed, 127 insertions(+), 0 deletions(-)
diff --git a/cylsg/EzInitQ/CY_MessageServiser.cs b/cylsg/EzInitQ/CY_MessageServiser.cs
new file mode 100644
index 0000000..ecb2543
--- /dev/null
+++ b/cylsg/EzInitQ/CY_MessageServiser.cs
@@ -0,0 +1,127 @@
+锘縰sing 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();
+
+
+
+ }
+
+ }
+
+
+
+
+
+ }
+
+
+
+ }
+}
--
Gitblit v1.9.1