key1_beacon_api/ARW.Service/Business/BusinessService/OrderManage/Orders/OrderService.cs
2023-08-29 18:24:11 +08:00

138 lines
5.0 KiB
C#

using Infrastructure.Attribute;
using Microsoft.AspNetCore.Http;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Infrastructure;
using ARW.Model;
using ARW.Repository;
using ARW.Repository.Business.OrderManage.Orders;
using ARW.Service.Business.IBusinessService.OrderManage.Orders;
using ARW.Model.Dto.Business.OrderManage.Orders;
using ARW.Model.Models.Business.OrderManage.Orders;
using ARW.Model.Vo.Business.OrderManage.Orders;
namespace ARW.Service.Business.BusinessService.OrderManage.Orders
{
/// <summary>
/// 订单接口实现类
///
/// @author lwh
/// @date 2023-08-29
/// </summary>
[AppService(ServiceType = typeof(IOrderService), ServiceLifetime = LifeTime.Transient)]
public class OrderServiceImpl : BaseService<Order>, IOrderService
{
private readonly OrderRepository _OrderRepository;
public OrderServiceImpl(OrderRepository OrderRepository)
{
this._OrderRepository = OrderRepository;
}
#region
/// <summary>
/// 查询订单分页列表
/// </summary>
public async Task<PagedInfo<OrderVo>> GetOrderList(OrderQueryDto parm)
{
//开始拼装查询条件d
var predicate = Expressionable.Create<Order>();
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.OrderNumber), s => s.OrderNumber.Contains(parm.OrderNumber));
predicate = predicate.AndIF(parm.PayType != null, s => s.PayType == parm.PayType);
predicate = predicate.AndIF(parm.PayStatus != null, s => s.PayStatus == parm.PayStatus);
predicate = predicate.AndIF(parm.DeliveryType != null, s => s.DeliveryType == parm.DeliveryType);
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.LogisticsTrackingNumber), s => s.LogisticsTrackingNumber.Contains(parm.LogisticsTrackingNumber));
predicate = predicate.AndIF(parm.DeliveryStatus != null, s => s.DeliveryStatus == parm.DeliveryStatus);
predicate = predicate.AndIF(parm.ReceiptStatus != null, s => s.ReceiptStatus == parm.ReceiptStatus);
predicate = predicate.AndIF(parm.OrderStatus != null, s => s.OrderStatus == parm.OrderStatus);
var query = _OrderRepository
.Queryable()
.Where(predicate.ToExpression())
.OrderBy(s => s.Create_time,OrderByType.Desc)
.Select(s => new OrderVo
{
OrderId = s.OrderId,
OrderGuid = s.OrderGuid,
GoodsGuid = s.GoodsGuid,
PaymentGuid = s.PaymentGuid,
CustomerGuid = s.CustomerGuid,
ShopGuid = s.ShopGuid,
OrderNumber = s.OrderNumber,
GoodsTotalAmoun = s.GoodsTotalAmoun,
OrderAmount = s.OrderAmount,
CouponGuid = s.CouponGuid,
CouponMoney = s.CouponMoney,
PointsMoney = s.PointsMoney,
PointsNum = s.PointsNum,
PayPrice = s.PayPrice,
UpdatePrice = s.UpdatePrice,
OrderRemark = s.OrderRemark,
PayType = s.PayType,
PayStatus = s.PayStatus,
PayTime = s.PayTime,
DeliveryType = s.DeliveryType,
ExpressPrice = s.ExpressPrice,
LogisticsCompanyGuid = s.LogisticsCompanyGuid,
LogisticsCompany = s.LogisticsCompany,
LogisticsTrackingNumber = s.LogisticsTrackingNumber,
DeliveryStatus = s.DeliveryStatus,
DeliveryTime = s.DeliveryTime,
ReceiptStatus = s.ReceiptStatus,
ReceiptTime = s.ReceiptTime,
OrderStatus = s.OrderStatus,
PointsBonus = s.PointsBonus,
IsSettled = s.IsSettled,
TransactionId = s.TransactionId,
IsComment = s.IsComment,
OrderSource = s.OrderSource,
});
return await query.ToPageAsync(parm);
}
/// <summary>
/// 添加或修改订单
/// </summary>
public async Task<string> AddOrUpdateOrder(Order model)
{
if (model.OrderId != 0)
{
var response = await _OrderRepository.UpdateAsync(model);
return "修改成功!";
}
else
{
var response = await _OrderRepository.InsertReturnSnowflakeIdAsync(model);
return "添加成功!";
}
}
#region Excel处理
/// <summary>
/// Excel数据导出处理
/// </summary>
public async Task<List<OrderVo>> HandleExportData(List<OrderVo> data)
{
return data;
}
#endregion
#endregion
}
}