From d7c7a6e9d05eec7b38b41b8ae39f373f650ca891 Mon Sep 17 00:00:00 2001
From: 移动系统liao <liaoxujun@qq.com>
Date: 星期三, 15 五月 2024 14:48:03 +0800
Subject: [PATCH] no message
---
CoreCms.Net.RedisMQ/OrderAgentOrDistributionSubscribe.cs | 26 +++++++++++++++++---------
1 files changed, 17 insertions(+), 9 deletions(-)
diff --git a/CoreCms.Net.RedisMQ/OrderAgentOrDistributionSubscribe.cs b/CoreCms.Net.RedisMQ/OrderAgentOrDistributionSubscribe.cs
index b5112dc..3d0309c 100644
--- a/CoreCms.Net.RedisMQ/OrderAgentOrDistributionSubscribe.cs
+++ b/CoreCms.Net.RedisMQ/OrderAgentOrDistributionSubscribe.cs
@@ -2,6 +2,7 @@
using System.Threading.Tasks;
using CoreCms.Net.Configuration;
using CoreCms.Net.IServices;
+using CoreCms.Net.IServices.baifenbingfa;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.ViewModels.UI;
@@ -17,7 +18,7 @@
namespace CoreCms.Net.RedisMQ
{
/// <summary>
- /// 璁㈠崟瀹岀粨鍚庤蛋浠ｇ悊鎴栧垎閿�鍟嗘彁鎴愬鐞�
+ /// 璁㈠崟瀹岀粨鍚庤蛋浠ｇ悊鎴栫粡閿�鍟嗘彁鎴愬鐞�
/// </summary>
public class OrderAgentOrDistributionSubscribe : IRedisSubscribe
{
@@ -29,8 +30,10 @@
private readonly ICoreCmsUserServices _userServices;
private readonly ICoreCmsAgentOrderServices _agentOrderServices;
+ private readonly IBfbfComAPIService _bfbfComAPIService;
- public OrderAgentOrDistributionSubscribe(ICoreCmsBillPaymentsServices billPaymentsServices, ICoreCmsDistributionOrderServices distributionOrderServices, ICoreCmsDistributionServices distributionServices, ICoreCmsSettingServices settingServices, ICoreCmsUserServices userServices, ICoreCmsAgentOrderServices agentOrderServices)
+
+ public OrderAgentOrDistributionSubscribe(ICoreCmsBillPaymentsServices billPaymentsServices, ICoreCmsDistributionOrderServices distributionOrderServices, ICoreCmsDistributionServices distributionServices, ICoreCmsSettingServices settingServices, ICoreCmsUserServices userServices, ICoreCmsAgentOrderServices agentOrderServices ,IBfbfComAPIService bfbfComAPIService)
{
_billPaymentsServices = billPaymentsServices;
_distributionOrderServices = distributionOrderServices;
@@ -38,10 +41,12 @@
_settingServices = settingServices;
_userServices = userServices;
_agentOrderServices = agentOrderServices;
+ _bfbfComAPIService= bfbfComAPIService;
+
}
/// <summary>
- /// 璁㈠崟瀹岀粨鍚庤蛋浠ｇ悊鎴栧垎閿�鍟嗘彁鎴愬鐞�
+ /// 璁㈠崟瀹岀粨鍚庤蛋浠ｇ悊鎴栫粡閿�鍟嗘彁鎴愬鐞�
/// </summary>
/// <param name="msg"></param>
/// <returns></returns>
@@ -75,14 +80,17 @@
case (int)GlobalEnumVars.CommissionChannel.浠呭垎閿� when openDistribution == 1:
{
var jm = await _distributionOrderServices.AddData(order); //娣诲姞鍒嗕韩鍏宠仈璁㈠崟鏃ュ織
- //鍒ゆ柇鏄惁鍙互鎴愪负鍒嗛攢鍟�
+ //鍒ゆ柇鏄惁鍙互鎴愪负缁忛攢鍟�
//鍏堝垽鏂槸鍚﹀凡缁忔槸缁忛攢鍟嗕簡銆�
+ //鐧惧垎鍏垫硶鍚屾剰鍒ゅ喅缁忛攢鍟�
bool check = await _distributionServices.ExistsAsync(p => p.userId == order.userId);
- var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(0);
+ //bool check = await _bfbfComAPIService.IsDictionary( order.userId);
+
+ var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(0);
if (distributionType == 3) //鏃犻渶瀹℃牳锛屼絾鏄婊¤冻鎻愪氦
{
var info = new CoreCmsDistribution();
- //鍒ゆ柇鏄惁鍒嗛攢鍟�
+ //鍒ゆ柇鏄惁缁忛攢鍟�
if (check == false)
{
await _distributionServices.CheckCondition(allConfigs, info, order.userId);
@@ -121,14 +129,14 @@
}
await _distributionOrderServices.AddData(order); //娣诲姞鍒嗕韩鍏宠仈璁㈠崟鏃ュ織
- //鍒ゆ柇鏄惁鍙互鎴愪负鍒嗛攢鍟�
+ //鍒ゆ柇鏄惁鍙互鎴愪负缁忛攢鍟�
//鍏堝垽鏂槸鍚﹀凡缁忔槸缁忛攢鍟嗕簡銆�
bool check = await _distributionServices.ExistsAsync(p => p.userId == order.userId);
var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(0);
if (distributionType == 3) //鏃犻渶瀹℃牳锛屼絾鏄婊¤冻鎻愪氦
{
var info = new CoreCmsDistribution();
- //鍒ゆ柇鏄惁鍒嗛攢鍟�
+ //鍒ゆ柇鏄惁缁忛攢鍟�
if (check == false)
{
await _distributionServices.CheckCondition(allConfigs, info, order.userId);
@@ -167,7 +175,7 @@
if (distributionType == 3) //鏃犻渶瀹℃牳锛屼絾鏄婊¤冻鎻愪氦
{
var info = new CoreCmsDistribution();
- //鍒ゆ柇鏄惁鍒嗛攢鍟�
+ //鍒ゆ柇鏄惁缁忛攢鍟�
if (check == false)
{
await _distributionServices.CheckCondition(allConfigs, info, order.userId);
--
Gitblit v1.9.1