You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
381 lines
18 KiB
381 lines
18 KiB
using BBWYB.Common.Extensions;
|
|
using BBWYB.Common.Http;
|
|
using BBWYB.Common.Log;
|
|
using BBWYB.Common.Models;
|
|
using BBWYB.Server.Business.Extensions;
|
|
using BBWYB.Server.Model;
|
|
using BBWYB.Server.Model.Db;
|
|
using BBWYB.Server.Model.Dto;
|
|
using FreeSql;
|
|
using Newtonsoft.Json;
|
|
using SDKAdapter;
|
|
using SDKAdapter.OperationPlatform.Client;
|
|
using SDKAdapter.OperationPlatform.Models;
|
|
using System.Linq.Expressions;
|
|
using System.Security.Cryptography;
|
|
using Yitter.IdGenerator;
|
|
|
|
namespace BBWYB.Server.Business
|
|
{
|
|
public class OrderBusiness : BaseBusiness, IDenpendency
|
|
{
|
|
private OP_PlatformClientFactory opPlatformClientFactory;
|
|
private RestApiService restApiService;
|
|
public OrderBusiness(IFreeSql fsql, NLogManager nLogManager, IIdGenerator idGenerator, OP_PlatformClientFactory opPlatformClientFactory, RestApiService restApiService) : base(fsql, nLogManager, idGenerator)
|
|
{
|
|
this.opPlatformClientFactory = opPlatformClientFactory;
|
|
this.restApiService = restApiService;
|
|
}
|
|
|
|
private ISelect<Order, OrderConsignee, OrderCost> GetOrderListQueryConditions(QueryOrderRequest request)
|
|
{
|
|
var select = fsql.Select<Order, OrderConsignee, OrderCost>()
|
|
.LeftJoin((o, ocs, oct) => o.Id == ocs.OrderId)
|
|
.LeftJoin((o, ocs, oct) => o.Id == oct.OrderId);
|
|
if (!string.IsNullOrEmpty(request.OrderId))
|
|
{
|
|
select = select.Where((o, ocs, oct) => o.Id == request.OrderId);
|
|
}
|
|
else
|
|
{
|
|
if (!string.IsNullOrEmpty(request.Sku) || !string.IsNullOrEmpty(request.SourceSku) || !string.IsNullOrEmpty(request.ProductId))
|
|
{
|
|
var childSelect = fsql.Select<OrderSku>().As("osku")
|
|
.WhereIf(!string.IsNullOrEmpty(request.Sku), osku => osku.SkuId == request.Sku)
|
|
.WhereIf(!string.IsNullOrEmpty(request.SourceSku), osku => osku.BelongSkuId == request.SourceSku)
|
|
.WhereIf(!string.IsNullOrEmpty(request.ProductId), osku => osku.ProductId == request.ProductId);
|
|
select = select.Where((o, ocs, oct) => childSelect.Where(osku => osku.OrderId == o.Id).Any());
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(request.PurchaseOrderId))
|
|
{
|
|
var childSelect = fsql.Select<OrderPurchaseInfo>().As("opi")
|
|
.Where(opi => opi.PurchaseOrderId == request.PurchaseOrderId);
|
|
select = select.Where((o, ocs, oct) => childSelect.Where(opi => opi.OrderId == o.Id).Any());
|
|
}
|
|
|
|
select = select.WhereIf(request.OrderState != null, (o, ocs, oct) => o.OrderState == request.OrderState)
|
|
.WhereIf(request.IsWaitConfig, (o, ocs, oct) => o.OrderState != Enums.OrderState.已取消 && o.IsPurchased == true)
|
|
.WhereIf(request.StartDate != null, (o, ocs, oct) => o.StartTime >= request.StartDate)
|
|
.WhereIf(request.EndDate != null, (o, ocs, oct) => o.StartTime <= request.EndDate)
|
|
.WhereIf(!string.IsNullOrEmpty(request.ClientOrderId), (o, ocs, oct) => o.ClientOrderId == request.ClientOrderId)
|
|
.WhereIf(!string.IsNullOrEmpty(request.SourceShopName), (o, ocs, oct) => o.SourceShopName == request.SourceShopName);
|
|
}
|
|
|
|
select = select.WhereIf(request.ShopId != null, (o, ocs, oct) => o.ShopId == request.ShopId);
|
|
|
|
//select = select.Where((o, ocs, oct) => o.ShopId == searchOrderRequest.ShopId);
|
|
|
|
return select;
|
|
}
|
|
|
|
private Expression<Func<Order, OrderConsignee, OrderCost, Order>> GetOrderListField()
|
|
{
|
|
return (o, ocs, oct) => new Order()
|
|
{
|
|
Id = o.Id,
|
|
OrderSn = o.OrderSn,
|
|
EndTime = o.EndTime,
|
|
FreightPrice = o.FreightPrice,
|
|
ModifyTime = o.ModifyTime,
|
|
OrderPayment = o.OrderPayment,
|
|
OrderSellerPrice = o.OrderSellerPrice,
|
|
OrderState = o.OrderState,
|
|
OrderTotalPrice = o.OrderTotalPrice,
|
|
OrderType = o.OrderType,
|
|
PayType = o.PayType,
|
|
Platform = o.Platform,
|
|
ShopId = o.ShopId,
|
|
StartTime = o.StartTime,
|
|
VenderRemark = o.VenderRemark,
|
|
PurchaseRemark = o.PurchaseRemark,
|
|
BuyerRemark = o.BuyerRemark,
|
|
//WaybillNo = o.WaybillNo,
|
|
SellerPreferentialAmount = o.SellerPreferentialAmount,
|
|
PreferentialAmount = o.PreferentialAmount,
|
|
ClientOrderId = o.ClientOrderId,
|
|
SourceShopName = o.SourceShopName,
|
|
//SourceSku = o.SourceSku,
|
|
//ExpressName = o.ExpressName,
|
|
IsPurchased = o.IsPurchased,
|
|
BuyerAccount = o.BuyerAccount,
|
|
InPackAmount = o.InPackAmount,
|
|
IsWaitPack = o.IsWaitPack,
|
|
|
|
ContactName = ocs.ContactName,
|
|
Address = ocs.Address,
|
|
Province = ocs.Province,
|
|
County = ocs.County,
|
|
Town = ocs.Town,
|
|
City = ocs.City,
|
|
Mobile = ocs.Mobile,
|
|
TelePhone = ocs.TelePhone,
|
|
|
|
DeliveryExpressFreight = oct.DeliveryExpressFreight,
|
|
PlatformCommissionAmount = oct.PlatformCommissionAmount,
|
|
PlatformCommissionRatio = oct.PlatformCommissionRatio,
|
|
Profit = oct.Profit,
|
|
PurchaseAmount = oct.PurchaseAmount,
|
|
IsManualEdited = oct.IsManualEdited,
|
|
PackConfigState = o.PackConfigState,
|
|
};
|
|
}
|
|
|
|
public OrderListResponse GetOrderList(QueryOrderRequest request)
|
|
{
|
|
if (request.EndDate != null)
|
|
request.EndDate = request.EndDate.Value.Date.AddDays(1).AddSeconds(-1);
|
|
|
|
var select = GetOrderListQueryConditions(request).OrderByDescending((o, ocs, oct) => o.StartTime)
|
|
.Count(out var total)
|
|
.Page(request.PageIndex, request.PageSize);
|
|
|
|
var orderSourceList = select.ToList(GetOrderListField());
|
|
var orderList = orderSourceList.Map<IList<OrderResponse>>();
|
|
var orderIdList = orderList.Select(o => o.Id).ToList();
|
|
|
|
if (orderList.Count() > 0)
|
|
{
|
|
#region 处理Sku
|
|
var orderSkuList = fsql.Select<OrderSku>().Where(osku => osku.Price != 0 &&
|
|
orderIdList.Contains(osku.OrderId)).ToList<OrderSkuResponse>();
|
|
foreach (var order in orderList)
|
|
{
|
|
order.ItemList = orderSkuList.Where(osku => osku.OrderId == order.Id).ToList();
|
|
}
|
|
#endregion
|
|
|
|
#region 处理订单成本明细
|
|
var orderCostDetailList = fsql.Select<OrderCostDetail>().Where(ocd => orderIdList.Contains(ocd.OrderId) && ocd.IsEnabled == true).ToList<OrderCostDetailResponse>();
|
|
foreach (var order in orderList)
|
|
order.OrderCostDetailList = orderCostDetailList.Where(ocd => ocd.OrderId == order.Id).ToList();
|
|
#endregion
|
|
|
|
#region 处理采购信息
|
|
var orderPurchaseInfoList = fsql.Select<OrderPurchaseInfo>().Where(op => orderIdList.Contains(op.OrderId) && op.IsEnabled == true).ToList<OrderPurchaseInfoResponse>();
|
|
var orderPurchaseSkuInfoList = fsql.Select<OrderPurchaseSkuInfo>().Where(o => orderIdList.Contains(o.OrderId)).ToList();
|
|
|
|
foreach (var order in orderList)
|
|
{
|
|
order.OrderPurchaseInfoList = orderPurchaseInfoList.Where(op => op.OrderId == order.Id).ToList();
|
|
foreach (var purchaseOrder in order.OrderPurchaseInfoList)
|
|
{
|
|
purchaseOrder.ExpressState = orderPurchaseSkuInfoList.FirstOrDefault(x => !string.IsNullOrEmpty(x.ExpressState) &&
|
|
x.PurchaseOrderId == purchaseOrder.PurchaseOrderId)?.ExpressState;
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
}
|
|
return new OrderListResponse()
|
|
{
|
|
Count = total,
|
|
Items = orderList
|
|
};
|
|
}
|
|
|
|
public void OutStock(OutStockRequest request)
|
|
{
|
|
var dbOrder = fsql.Select<Order>(request.OrderId).ToOne();
|
|
if (dbOrder == null)
|
|
throw new BusinessException($"订单{request.OrderId}不存在");
|
|
|
|
var dbOrderPurchaseInfoList = fsql.Select<OrderPurchaseInfo>().Where(opi => opi.OrderId == request.OrderId && opi.IsEnabled == true).ToList();
|
|
var dbOrderPurchaseInfo = dbOrderPurchaseInfoList.FirstOrDefault(opi => opi.PurchaseOrderId == request.PurchaseOrderId);
|
|
|
|
dbOrderPurchaseInfo.WaybillNo = request.WayBillNo;
|
|
dbOrderPurchaseInfo.SourceExpressId = request.SourceExpressId;
|
|
dbOrderPurchaseInfo.SourceExpressName = request.SourceExpressName;
|
|
dbOrderPurchaseInfo.TargetExpressId = request.TargetExpressId;
|
|
dbOrderPurchaseInfo.TargetExpressName = request.TargetExpressName;
|
|
dbOrderPurchaseInfo.OrderState = Enums.PurchaseOrderState.待收货;
|
|
|
|
#region 订单状态
|
|
dbOrder.CalculationOrderState(fsql, null, dbOrderPurchaseInfoList);
|
|
#endregion
|
|
|
|
if (!string.IsNullOrEmpty(request.TargetExpressId))
|
|
{
|
|
#region 订阅快递100
|
|
|
|
#endregion
|
|
|
|
//try
|
|
//{
|
|
// opPlatformClientFactory.GetClient((AdapterEnums.PlatformType)request.Platform)
|
|
// .OutStock(new OP_OutStockRequest()
|
|
// {
|
|
// AppKey = request.AppKey,
|
|
// AppSecret = request.AppSecret,
|
|
// AppToken = request.AppToken,
|
|
// ExpressId = request.TargetExpressId,
|
|
// ExpressName = request.TargetExpressName,
|
|
// OrderId = request.OrderId,
|
|
// Platform = (AdapterEnums.PlatformType)request.Platform,
|
|
// WayBillNo = request.WayBillNo
|
|
// });
|
|
//}
|
|
//catch (Exception ex)
|
|
//{
|
|
// nLogManager.Default().Error(ex, $"OutStock Request {JsonConvert.SerializeObject(request)}");
|
|
//}
|
|
}
|
|
|
|
#region 通知C端出库
|
|
//通知C端
|
|
try
|
|
{
|
|
restApiService.SendRequest("https://bbwy.qiyue666.com",
|
|
"/Api/PurchaseOrder/QuanTanSendGoodsCallback",
|
|
new
|
|
{
|
|
OrderId = request.OrderId,
|
|
ExpressId = request.SourceExpressId,
|
|
ExpressName = request.SourceExpressName,
|
|
request.WayBillNo
|
|
},
|
|
null,
|
|
HttpMethod.Post);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
|
|
}
|
|
#endregion
|
|
|
|
fsql.Transaction(() =>
|
|
{
|
|
fsql.Update<OrderPurchaseInfo>().SetSource(dbOrderPurchaseInfo).ExecuteAffrows();
|
|
fsql.Update<Order>(request.OrderId).Set(o => o.OrderState, dbOrder.OrderState).ExecuteAffrows();
|
|
});
|
|
}
|
|
|
|
public void CancelOrder(CancelOrderRequest request, string mdsToken)
|
|
{
|
|
opPlatformClientFactory.GetClient((AdapterEnums.PlatformType)request.Platform).CancelOrder(new OP_CancelOrderRequest()
|
|
{
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
OrderId = request.OrderId,
|
|
Platform = (AdapterEnums.PlatformType)request.Platform,
|
|
Remark = request.Remark
|
|
});
|
|
|
|
fsql.Update<Order>(request.OrderId).Set(o => o.OrderState, Enums.OrderState.已取消).ExecuteAffrows();
|
|
|
|
var sql = $"update purchaseorderv2 set OrderState=7 where Id='{request.OrderId}'";
|
|
//取消C端采购单
|
|
restApiService.SendRequest("https://bbwy.qiyue666.com",
|
|
"/Api/Sql/ExecuteNonQuery",
|
|
new { sql = sql.AESEncrypt() },
|
|
new Dictionary<string, string>() { { "Authorization", $"{mdsToken}" } },
|
|
HttpMethod.Post);
|
|
|
|
try
|
|
{
|
|
//取消齐库的任务
|
|
var qikuResponse = restApiService.SendRequest("http://qiku.qiyue666.com/",
|
|
$"/api/PackPurchaseTask/CancelOrderPackTask?orderId={request.OrderId}",
|
|
null,
|
|
null,
|
|
HttpMethod.Post);
|
|
if (qikuResponse.StatusCode != System.Net.HttpStatusCode.OK)
|
|
throw new Exception(qikuResponse.Content);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
nLogManager.GetLogger($"取消打包任务-{request.OrderId}").Error(ex, JsonConvert.SerializeObject(request));
|
|
}
|
|
}
|
|
|
|
public void EditPrice(OP_EditPriceRequest request)
|
|
{
|
|
var client = opPlatformClientFactory.GetClient(request.Platform);
|
|
client.EditPrice(new OP_EditPriceRequest()
|
|
{
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
OrderId = request.OrderId,
|
|
EditItems = request.EditItems
|
|
});
|
|
|
|
var orderListResponse = client.GetOrderList(new OP_QueryOrderRequest()
|
|
{
|
|
AppKey = request.AppKey,
|
|
AppSecret = request.AppSecret,
|
|
AppToken = request.AppToken,
|
|
OrderId = request.OrderId,
|
|
PageIndex = 1,
|
|
PageSize = 1,
|
|
SortTimeField = AdapterEnums.SortTimeField.Modify,
|
|
SortType = AdapterEnums.SortType.Desc
|
|
});
|
|
|
|
var order = orderListResponse.Items.FirstOrDefault();
|
|
var orderCost = fsql.Select<OrderCost>(request.OrderId).ToOne();
|
|
|
|
IList<IUpdate<OrderSku>> updates_orderSku = new List<IUpdate<OrderSku>>();
|
|
IUpdate<OrderCost> updateOrderCost = null;
|
|
foreach (var orderSku in order.OrderSkuList)
|
|
{
|
|
updates_orderSku.Add(fsql.Update<OrderSku>(orderSku.Id).Set(osku => osku.Price, orderSku.SkuPrice)
|
|
.Set(osku => osku.BuyerPayFreight, orderSku.FreightAmount)
|
|
.Set(osku => osku.InPackAmount, orderSku.PackAmount));
|
|
}
|
|
|
|
if (orderCost != null)
|
|
{
|
|
orderCost.CalculationOrderCostCostAndProfit(order.OrderTotalAmount,
|
|
orderCost.SkuAmount ?? 0M,
|
|
orderCost.PurchaseFreight ?? 0M,
|
|
orderCost.OutPackAmount ?? 0M,
|
|
orderCost.DeliveryExpressFreight ?? 0M);
|
|
updateOrderCost = fsql.Update<OrderCost>().SetSource(orderCost);
|
|
}
|
|
|
|
|
|
fsql.Transaction(() =>
|
|
{
|
|
fsql.Update<Order>(request.OrderId).Set(o => o.OrderTotalPrice, order.OrderTotalAmount)
|
|
.Set(o => o.OrderSellerPrice, order.OrderProductAmount)
|
|
.Set(o => o.FreightPrice, order.FreightAmount)
|
|
.ExecuteAffrows();
|
|
updateOrderCost?.ExecuteAffrows();
|
|
|
|
if (updates_orderSku.Count() > 0)
|
|
{
|
|
foreach (var update in updates_orderSku)
|
|
update.ExecuteAffrows();
|
|
}
|
|
});
|
|
|
|
#region 通知C端
|
|
restApiService.SendRequest("https://bbwy.qiyue666.com",
|
|
"/Api/PurchaseOrder/QuanTanEditPriceCallback",
|
|
new { orderId = request.OrderId },
|
|
null,
|
|
HttpMethod.Post);
|
|
#endregion
|
|
}
|
|
|
|
public void EditVenderRemark(EditVenderRemarkRequest request)
|
|
{
|
|
fsql.Update<Order>(request.OrderId).Set(o => o.VenderRemark, request.VenderRemark).ExecuteAffrows();
|
|
}
|
|
|
|
public void EditOrderSkuRemark(EditOrderSkuRemarkRequest request)
|
|
{
|
|
fsql.Update<OrderSku>().Set(osku => osku.Remark, request.Remark)
|
|
.Where(osku => osku.OrderId == request.OrderId)
|
|
.Where(osku => osku.SkuId == request.SkuId)
|
|
.ExecuteAffrows();
|
|
}
|
|
|
|
public void QiKuPublishPackAmount(QiKuPublishPackAmountRequest request)
|
|
{
|
|
|
|
}
|
|
}
|
|
}
|
|
|