From b38c91e5cce54e1114ec5968c722c1a1c57bd21a Mon Sep 17 00:00:00 2001
From: 移动系统liao <liaoxujun@qq.com>
Date: 星期五, 21 六月 2024 13:27:00 +0800
Subject: [PATCH] 完成派送订单佣金写入余额逻辑
---
CoreCms.Net.Services/baifenbingfa/DistributorDeliveryServices.cs | 186 ++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 168 insertions(+), 18 deletions(-)
diff --git a/CoreCms.Net.Services/baifenbingfa/DistributorDeliveryServices.cs b/CoreCms.Net.Services/baifenbingfa/DistributorDeliveryServices.cs
index 3406cd0..c88065d 100644
--- a/CoreCms.Net.Services/baifenbingfa/DistributorDeliveryServices.cs
+++ b/CoreCms.Net.Services/baifenbingfa/DistributorDeliveryServices.cs
@@ -21,6 +21,11 @@
using CoreCms.Net.DTO;
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinExpressDeliveryOpenMessageGetDeliveryListResponse.Types;
+using CoreCms.Net.Loging;
+using CoreCms.Net.Model.Entities.baifenbingfa.DistributionSendOder;
+using StackExchange.Redis;
+using Microsoft.Extensions.Logging;
+
namespace CoreCms.Net.Services.baifenbingfa
{
/// <summary>
@@ -39,7 +44,9 @@
private readonly IRedisOperationRepository _redisOperationRepository;
private readonly IHttpContextUser _user;
+
public readonly ICoreCmsDistributionServices _coreCmsDistributionServices;
+ private readonly ICoreCmsOrderServices _orderServices;
public DistributorDeliveryServices(
IUnitOfWork unitOfWork,
@@ -51,7 +58,8 @@
, ICoreCmsSettingServices settingServices
, IRedisOperationRepository redisOperationRepository
, IHttpContextUser user
- ,ICoreCmsDistributionServices coreCmsDistributionServices )
+ ,ICoreCmsDistributionServices coreCmsDistributionServices
+ ,ICoreCmsOrderServices orderServices)
{
this._dal = dal;
base.BaseDal = dal;
@@ -64,6 +72,7 @@
_redisOperationRepository = redisOperationRepository;
_user = user;
_coreCmsDistributionServices = coreCmsDistributionServices;
+ _orderServices = orderServices;
}
public async Task<(List< CoreCmsBillDelivery>,int )> GetDeliveryList(GetDeliveryListPost Param)
@@ -77,7 +86,42 @@
}
if (Param.distributionAcceptStatus != null)
{
- where= where.And(x => x.sendDistributionAccept == Param.distributionAcceptStatus);
+ switch (Param.distributionAcceptStatus)
+ {
+ case sendDistributionAcceptType.Accepted:
+ ///杩涜涓紝鍞悗绌�
+ where = where.And(x => x.sendDistributionAccept == sendDistributionAcceptType.Accepted
+ && x.order.status == (int)GlobalEnumVars.OrderStatus.Normal && !x.order.aftersalesItem1.Any()&& x.order.confirmStatus != (int)GlobalEnumVars.OrderConfirmStatus.ConfirmReceipt);
+ //where = where.And(x => x.sendDistributionAccept == Param.distributionAcceptStatus);
+ break;
+ case sendDistributionAcceptType.NoAccted:
+ ///鏈‘璁ゆ帴鍙楃殑锛屼笉鑳藉敭鍚庣┖
+ where = where.And(x => x.sendDistributionAccept == sendDistributionAcceptType.NoAccted
+ && x.order.status == (int)GlobalEnumVars.OrderStatus.Normal && !x.order.aftersalesItem1.Any());
+ //where = where.And(x => x.sendDistributionAccept == Param.distributionAcceptStatus);
+ break;
+
+ case sendDistributionAcceptType.OderFreeComplete:
+
+ where = where.And(x => x.sendDistributionAccept == sendDistributionAcceptType.Accepted
+ && x.order.status == (int)GlobalEnumVars.OrderStatus.Complete && !x.order.aftersalesItem1.Any());
+ //where = where.And(x => x.sendDistributionAccept == Param.distributionAcceptStatus);
+ break;
+ case sendDistributionAcceptType.Cancelled:
+
+ where = where.And(x =>( x.sendDistributionAccept == sendDistributionAcceptType.Cancelled
+ || x.order.status == (int)GlobalEnumVars.OrderStatus.Cancel || x.order.aftersalesItem1.Any()));
+ //where = where.And(x => x.sendDistributionAccept == Param.distributionAcceptStatus);
+ break;
+ case sendDistributionAcceptType.Delivered:
+ where = where.And(x => x.sendDistributionAccept == sendDistributionAcceptType.Delivered
+ || x.order.confirmStatus == (int)GlobalEnumVars.OrderConfirmStatus.ConfirmReceipt );
+ //where = where.And(x => x.sendDistributionAccept == Param.distributionAcceptStatus);
+ break;
+ default:
+ break;
+ }
+ //where= where.And(x => x.sendDistributionAccept == Param.distributionAcceptStatus);
}
where= where.And(x => x.sendDistributionUserID == _user.ID);
//蹇呴』鏄嚭浜庡彂璐х姸鎬�
@@ -85,20 +129,63 @@
//蹇呴』鏄湁鏁堢姸鎬�
//where= where.And(x => x.order.status == (int)GlobalEnumVars.OrderStatus.Normal);
RefAsync<int> totl = 0;
- var list = await _unitOfWork.GetDbClient().Queryable<CoreCmsBillDelivery>().Includes(x => x.order, order => order.Orderitems, ite => ite.productInfo).Select(x => new CoreCmsBillDelivery
- {
- sendDistributionAccept = x.sendDistributionAccept == sendDistributionAcceptType.NoAccted ?
- //鐢ㄦ埛娌℃湁鍚屾剰浣嗘槸璁㈠崟宸茬粡鍙栨秷浜� 闇�瑕佽祴鍊� 鍙栨秷鐘舵��
- (x.order.status== (int)GlobalEnumVars.OrderStatus.Normal ? sendDistributionAcceptType.NoAccted: sendDistributionAcceptType.Cancelled ):
- (
- x.sendDistributionAccept== sendDistributionAcceptType.Accepted?
- //鐢ㄦ埛宸茬粡鍚屾剰浜�
- (x.order.confirmStatus == (int)GlobalEnumVars.OrderConfirmStatus.ConfirmReceipt? sendDistributionAcceptType.Delivered: sendDistributionAcceptType.Accepted)
- : x.order.status==(int )GlobalEnumVars.OrderStatus.Cancel? sendDistributionAcceptType.Cancelled: x.sendDistributionAccept
- ),
- order=x.order,
- },true).MergeTable()
- .Where(where).OrderByDescending(x => x.createTime)
+ var list = await _unitOfWork.GetDbClient().Queryable<CoreCmsBillDelivery>()
+ .Includes(x => x.order, order => order.Orderitems, ite => ite.productInfo)
+ .Includes(x => x.order, Order => Order.aftersalesItem1)
+ .Where(where)
+ .Select(x => new CoreCmsBillDelivery
+ {
+
+ order = x.order,
+ }, true)
+ .MergeTable()
+ //.Mapper(x => x.order.billAftersalesId = SqlFunc.Subqueryable<CoreCmsBillAftersales>().Where(core => core.orderId == x.orderId).Select(core => core.aftersalesId))
+ .Mapper(
+ x =>
+ {
+ switch (x.sendDistributionAccept)
+ {
+ case sendDistributionAcceptType.Accepted:
+
+ if (x.order.status == (int)GlobalEnumVars.OrderStatus.Cancel)
+ x.sendDistributionAccept = sendDistributionAcceptType.Cancelled;
+ else
+ if (x.order.status == (int)GlobalEnumVars.OrderStatus.Complete && !x.order.aftersalesItem1.Any())
+ x.sendDistributionAccept = sendDistributionAcceptType.OderFreeComplete;
+ if (x.order.status == (int)GlobalEnumVars.OrderStatus.Complete && x.order.aftersalesItem1.Any())
+ x.sendDistributionAccept = sendDistributionAcceptType.Cancelled;
+
+ else if (x.order.status == (int)GlobalEnumVars.OrderStatus.Normal && x.order.aftersalesItem1.Any())
+ x.sendDistributionAccept = sendDistributionAcceptType.Cancelled;
+ else
+ if (x.order.confirmStatus == (int)GlobalEnumVars.OrderConfirmStatus.ConfirmReceipt)
+ x.sendDistributionAccept = sendDistributionAcceptType.Delivered;
+ else
+ x.sendDistributionAccept = x.sendDistributionAccept;
+ break;
+ case sendDistributionAcceptType.NoAccted:
+ ///鏈‘璁ゆ帴鍙楃殑锛屼笉鑳藉敭鍚庣┖
+ if(x.order.status== (int)GlobalEnumVars.OrderStatus.Complete||x.order.status== (int)GlobalEnumVars.OrderStatus.Cancel|| x.order.aftersalesItem1.Any())
+ x.sendDistributionAccept= sendDistributionAcceptType.Cancelled;
+ else
+ x.sendDistributionAccept = x.sendDistributionAccept;
+ break;
+
+ case sendDistributionAcceptType.OderFreeComplete:
+
+ //姘歌繙涓嶄細鍒拌繖
+ break;
+ case sendDistributionAcceptType.Cancelled:
+ //涓嶉渶瑕佸鐞�
+
+ break;
+ default:
+ break;
+ }
+ }
+ )
+
+ .OrderByDescending(x => x.createTime)
.ToPageListAsync(Param.page, Param.limit, totl);
var listdata= new PageList<CoreCmsBillDelivery>(list, Param.page, Param.limit, totl);
@@ -108,16 +195,31 @@
public async Task<int> GetNoAcceptedDeliveryCount()
{
- return await _dal.GetCountAsync(x => x.sendDistributionUserID == _user.ID && x.sendDistributionAccept == sendDistributionAcceptType.NoAccted);
+ var lista= await _unitOfWork.GetDbClient().Queryable<CoreCmsBillDelivery>().Includes(x => x.order,ord=>ord.aftersalesItem1)
+ .Where(x => x.sendDistributionUserID == _user.ID && x.sendDistributionAccept == sendDistributionAcceptType.NoAccted
+ && x.order.status != (int)GlobalEnumVars.OrderStatus.Complete ).ToListAsync();
+
+ return lista.Where(x=>(x.order.aftersalesItem1==null|| x.order.aftersalesItem1.Count()==0)).Count();//鍒犻�夊嚭娌℃湁鍞悗鐢宠鐨勮鍗�
+
+
}
public async Task<bool> GetShowDelivery()
{
return (await _coreCmsDistributionServices.GetCountAsync(x => x.userId == _user.ID && x.verifyStatus == (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes&&x.profession=="鏍″洯浠ｇ悊", isDataCache: true, cacheTimes: 60)>0);
}
- public async Task<WebApiCallBack> SetDeliveryAccepted(sendDistributionAcceptType acceptType, string DeliveryID, string CancelledDec = null)
+ public async Task<WebApiCallBack> SetDeliveryAccepted(sendDistributionAcceptType acceptType, string DeliveryID, string CancelledDec = null)
{
+
WebApiCallBack ret = new WebApiCallBack();
+
+ if (acceptType == sendDistributionAcceptType.OderFreeComplete)
+ {
+ //鍙湁鍦ㄥ畬鎴愯鍗曚腑璁剧疆璇ョ姸鎬侊紝璇ョ姸鎬佷細瀵归厤鍞敹鐩婅繘琛屾彁鍙栨暣鍚�
+ ret.status = false;
+ ret.msg = "鐘舵�佽缃敊璇�";
+ return ret;
+ }
var data = await _dal.QueryByIdAsync(DeliveryID);
if (data == null)
{
@@ -213,5 +315,53 @@
throw;
}
}
+
+ public async Task<WebApiCallBack> FinishOrder(string orderId)
+ {
+
+
+ var jm = new WebApiCallBack();
+
+ var order = await _orderServices.QueryByClauseAsync(p =>
+ p.orderId == orderId && p.status == (int)GlobalEnumVars.OrderStatus.Complete);
+ if (order == null)
+ {
+ jm.msg = "璁㈠崟鏌ヨ澶辫触";
+ return jm;
+ }
+ var distributionSendOder = await _unitOfWork.GetDbClient().Queryable<DistributionSendOder>().Includes(x=>x.delivery)
+ .Where(x=>x.delivery.orderId==order.orderId&&(x.sendDistributionAccept== sendDistributionAcceptType.Accepted|| x.sendDistributionAccept== sendDistributionAcceptType.Shipped||x.sendDistributionAccept== sendDistributionAcceptType.Delivered))
+ .ToListAsync();
+ if( distributionSendOder.Count==1)
+ {
+ //婊¤冻鎵�鏈夋潯浠跺紑濮嬪垎閰嶉�昏緫
+ var mQ = new ActiveDistributionSendOderMQ
+ {
+
+ SendOderActive = sendDistributionAcceptType.OderFreeComplete,
+ deliveryID = distributionSendOder[0].deliveryID,
+ userID = order.userId
+ };
+
+ await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.ActiveDistributionSendOderMQ, JsonConvert.SerializeObject(mQ));
+ jm.status = true;
+
+ }
+ else if( distributionSendOder.Count>1)
+ {
+ jm.status= false;
+ jm.msg = "鍙戠幇澶氫釜閰嶉�佽鍗曪紝闇�瑕佹墜鍔ㄦ帓鏌�";
+ NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.Order, "澶勭悊缁忛攢鍟嗛厤閫佹敹鐩婃椂閿欒", $"璁㈠崟ID{orderId} 鍙戠幇澶氫釜婊¤冻缁忛攢鍟嗘淳閫佸崟锛屾斁寮冨鐞�,闇�鎺掓煡");
+
+ }
+ jm.status = true;
+ return jm;
+
+ //if (order.shipStatus is (int)GlobalEnumVars.OrderShipStatus.No or (int)GlobalEnumVars.OrderShipStatus.PartialYes)
+ // {
+ // return jm;
+ // }
+
+ }
}
}
--
Gitblit v1.9.1