From d856b2d3c85f39a2908de47ad1934e34805591e4 Mon Sep 17 00:00:00 2001
From: liaoxujun@qq.com <liaoxujun@qq.com>
Date: 星期五, 22 三月 2024 14:00:32 +0800
Subject: [PATCH] 完成供应商货博主管理页面

---
 CoreCms.Net.Services/Order/CoreCmsOrderServices.cs |   35 +++++++++++++++++++++++++++++------
 1 files changed, 29 insertions(+), 6 deletions(-)

diff --git a/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs b/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs
index 18a9a99..6fd72f7 100644
--- a/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs
+++ b/CoreCms.Net.Services/Order/CoreCmsOrderServices.cs
@@ -1,10 +1,10 @@
 /***********************************************************************
- *            Project: CoreCms
- *        ProjectName: 鏍稿績鍐呭绠$悊绯荤粺                                
- *                Web: https://www.corecms.net                      
- *             Author: 澶х伆鐏�                                          
- *              Email: jianweie@163.com                                
- *         CreateTime: 2021/1/31 21:45:10
+ *            Project: baifenBinfa
+ *        ProjectName: 鐧惧垎鍏垫硶绠$悊绯荤粺                               
+ *                Web: http://chuanyin.com                     
+ *             Author:                                        
+ *              Email:                               
+ *         CreateTime: 202403/02   
  *        Description: 鏆傛棤
  ***********************************************************************/
 
@@ -38,6 +38,7 @@
 using SKIT.FlurlHttpClient.Wechat.Api.Models;
 using SqlSugar;
 using Yitter.IdGenerator;
+using static SKIT.FlurlHttpClient.Wechat.Api.Models.ChannelsECLeagueHeadSupplierOrderGetResponse.Types.CommssionOrder.Types.OrderDetail.Types;
 
 
 namespace CoreCms.Net.Services
@@ -2121,7 +2122,29 @@
                     createTime = DateTime.Now
                 };
                 await _orderLogServices.InsertAsync(orderLog);
+                //鐧惧垎鍏垫硶鐗规畩濂栧姳
+                var allConfigs = await _settingServices.GetConfigDictionaries();
+                var pointExchangeModel = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DictionaryAchievementOnOff).ObjectToInt();
+                if (pointExchangeModel == 1)
+                {
+                    //寮�鍚笟缁╁鍔辨ā寮�
+                    var user = await _userServices.QueryByIdAsync(orderInfo.userId, isDataCache: true, cacheTimes: 1);
+                    if (user.parentId != 0)
+                    {
+                        //濡傛灉鏄�
+                        CreateDAOrderInParam data = new CreateDAOrderInParam
+                        {
+                            Money = money,
+                            OderId = orderInfo.orderId,
+                            SourceTypes = GlobalEnumVars.UserBalanceSourceTypes.GoodsOder,
+                            UserID = user.parentId,
 
+
+                        };
+                        //缁忛攢鍟嗕笟鍔¤鍗曠粨绠�
+                        await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.DistributionAchievementOder, JsonConvert.SerializeObject(data));
+                    }
+                }
                 //璁㈠崟瀹屾垚缁撶畻璁㈠崟
                 await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.OrderFinishCommand, orderInfo.orderId);
 

--
Gitblit v1.9.1