using CoreCms.Net.Auth.HttpContextUser;
|
using CoreCms.Net.Caching.AutoMate.RedisCache;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.DTO.WeChatShipping;
|
using CoreCms.Net.IRepository.UnitOfWork;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.IServices.CYOAServices;
|
using CoreCms.Net.Model.Entities.Expression;
|
using CoreCms.Net.Model.FromBody;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using CoreCms.Net.Utility.Extensions;
|
using EC_SeckillInfo;
|
using EnumsNET;
|
using Essensoft.Paylink.Alipay.Domain;
|
using Nest;
|
using Newtonsoft.Json;
|
using NPOI.SS.Formula.Functions;
|
using SqlSugar;
|
using SqlSugar.Extensions;
|
using StackExchange.Redis;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinExpressDeliveryOpenMessageGetDeliveryListResponse.Types;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinGetCurrentSelfMenuInfoResponse.Types;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinQrcodeCreateRequest.Types.Action.Types;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinTagsMembersGetBlackListResponse.Types;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinUserInfoBatchGetRequest.Types;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.ScanProductAddV2Request.Types.Product.Types;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.SemanticSemproxySearchResponse.Types;
|
using static SKIT.FlurlHttpClient.Wechat.Api.Models.WxaServiceMarketServiceGetServiceBuyerListResponse.Types.Buyer.Types;
|
|
namespace CoreCms.Net.Services.CYOAServices
|
{
|
/// <summary>
|
/// 川印相关服务
|
/// </summary>
|
public class CyinOAService: ICyinOAService
|
{
|
/// <summary>
|
/// 是否是司机key
|
/// </summary>
|
const string IsCYDbDbKey = "IsCYDbDbKey:";
|
|
/// <summary>
|
/// 是否拥有川印教育局订单管理
|
/// </summary>
|
const string IsSchoolID = "IsShoodsID:";
|
|
const string IsDeliverManageKey = "IsDeliverManageKey:";
|
private readonly ISqlSugarClient _CyDbClient;
|
private readonly IUnitOfWork _UnitOfWork;
|
private readonly IHttpContextUser _User;
|
private readonly ICoreCmsUserServices _coreCmsUserServices;
|
private readonly IRedisOperationRepository _redisOperationRepository;
|
private readonly string _UserMoble;
|
private string? _DriveName { get; set; }
|
|
|
public CyinOAService( IUnitOfWork unitOfWork,IHttpContextUser contextUser,ICoreCmsUserServices coreCmsUserServices,
|
IRedisOperationRepository redisOperationRepository,ICoreCmsUserServices coreCmsUser) {
|
|
_UnitOfWork = unitOfWork;
|
_CyDbClient = unitOfWork.GetDbClient().GetConnection(AppSettingsConstVars.CYDbDbID);
|
_User = contextUser;
|
_coreCmsUserServices = coreCmsUserServices;
|
_redisOperationRepository = redisOperationRepository;
|
_coreCmsUserServices= coreCmsUserServices;
|
|
_UserMoble = _coreCmsUserServices.QueryById(_User.ID).mobile??"没有找到用户";
|
}
|
|
|
/// <summary>
|
/// 是否是学校方
|
/// </summary>
|
/// <returns></returns>
|
public async Task<bool > IsSchooler()
|
{
|
|
if (_User?.ID == null)
|
{
|
|
|
throw new Exception("登录信息错误，请重新登录");
|
|
}
|
|
|
var user = _coreCmsUserServices.QueryById(_User.ID);
|
if (user == null)
|
{
|
|
throw new Exception("登录信息错误，请重新登录");
|
}
|
var isdrive = await _redisOperationRepository.Get(IsSchoolID + user.mobile);
|
if (string.IsNullOrEmpty(isdrive))
|
{
|
//没有键值
|
|
|
|
|
|
var data = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Where(x => x.userMobile == user.mobile).FirstAsync();
|
|
if (data != null)
|
{
|
isdrive = "true";
|
}
|
else
|
isdrive = "false";
|
await _redisOperationRepository.StringSetAsync(IsSchoolID + user.mobile, isdrive, TimeSpan.FromMinutes(1));
|
}
|
|
//db.DbFirst.IsCreateAttribute().CreateClassFile("c:\\Demo\\5", "EC_SeckillInfo"); ;
|
//var data= db.Queryable<EC_PrizeInfo>().ToList();
|
//ret.data= data;
|
if (isdrive == "true")
|
{
|
return true;
|
|
}
|
else
|
{
|
return false;
|
}
|
|
}
|
/// <summary>
|
/// 是否是送货管理员
|
/// </summary>
|
/// <returns></returns>
|
/// <exception cref="Exception"></exception>
|
public async Task<bool> IsDeliverManage()
|
{
|
var ret = new WebApiCallBack();
|
if (_User?.ID == null)
|
{
|
|
throw new Exception("登录信息错误，请重新登录");
|
|
}
|
var user = _coreCmsUserServices.QueryById(_User.ID);
|
if (user == null)
|
{
|
|
throw new Exception("登录信息错误，请重新登录");
|
}
|
var isdrive = await _redisOperationRepository.Get(IsDeliverManageKey + user.mobile);
|
if (string.IsNullOrEmpty(isdrive))
|
{
|
|
|
var FirmIds = AppSettingsConstVars.CyOsFirmIds;
|
var firmidlist = FirmIds?.Split(",")?.Select(x => new Guid(x));
|
|
|
var data = await _CyDbClient.Queryable<OA_Staff>().Where(x => x.Status == "在职" && x.MobieNum == user.mobile && x.BF_IsDeliverManage == true).FirstAsync();
|
|
if (data != null)
|
{
|
isdrive = "true";
|
}
|
else
|
isdrive = "false";
|
await _redisOperationRepository.StringSetAsync(IsDeliverManageKey + user.mobile, isdrive, TimeSpan.FromMinutes(1));
|
}
|
|
//db.DbFirst.IsCreateAttribute().CreateClassFile("c:\\Demo\\5", "EC_SeckillInfo"); ;
|
//var data= db.Queryable<EC_PrizeInfo>().ToList();
|
//ret.data= data;
|
if (isdrive == "true")
|
{
|
return true;
|
|
}
|
else
|
{
|
return false;
|
}
|
}
|
/// <summary>
|
/// 是否是司机
|
/// </summary>
|
/// <returns></returns>
|
public async Task<bool > IsDrive()
|
{
|
var ret = new WebApiCallBack();
|
if (_User?.ID == null)
|
{
|
|
throw new Exception("登录信息错误，请重新登录");
|
|
}
|
var user = _coreCmsUserServices.QueryById(_User.ID);
|
if (user == null)
|
{
|
|
throw new Exception("登录信息错误，请重新登录");
|
}
|
var isdrive = await _redisOperationRepository.Get(IsCYDbDbKey + user.mobile);
|
if (string.IsNullOrEmpty(isdrive))
|
{
|
|
|
var FirmIds = AppSettingsConstVars.CyOsFirmIds;
|
var firmidlist = FirmIds?.Split(",")?.Select(x => new Guid(x));
|
|
|
var data = await _CyDbClient.Queryable<OA_Staff>().Where(x => x.Status == "在职" && x.MobieNum == user.mobile && x.BF_IsDriver==true).FirstAsync();
|
|
if (data != null)
|
{
|
_DriveName = data.Name;
|
isdrive = "true";
|
}
|
else
|
{
|
_DriveName =null;
|
isdrive = "false";
|
}
|
|
await _redisOperationRepository.StringSetAsync(IsCYDbDbKey + user.mobile, isdrive, TimeSpan.FromMinutes(1));
|
}
|
|
//db.DbFirst.IsCreateAttribute().CreateClassFile("c:\\Demo\\5", "EC_SeckillInfo"); ;
|
//var data= db.Queryable<EC_PrizeInfo>().ToList();
|
//ret.data= data;
|
if (isdrive == "true")
|
{
|
|
|
return true;
|
|
}
|
else
|
{
|
return false;
|
}
|
|
|
}
|
#region 学校端列表
|
/// <summary>
|
/// 获取学校账号端的School
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetOderListOfSchool(FMPageByWhereOrder entity)
|
{
|
|
var rt = await IsSchooler();
|
if (rt == false)
|
{
|
throw new Exception("没有权限访问");
|
}
|
var user = await _coreCmsUserServices.QueryByIdAsync(_User.ID);
|
if (user == null)
|
{
|
throw new Exception("没有权限访问");
|
}
|
|
var where = PredicateBuilder.True<CoreCmsPlanOrder>();
|
|
if (!string.IsNullOrWhiteSpace(entity.where))
|
{
|
var obj = JsonConvert.DeserializeAnonymousType(entity.where, new
|
{
|
quxianId = "",
|
sheng = "",
|
shi="",
|
quxian="",
|
pianqu = "",
|
shipAddress = "",
|
DeliverState = ""
|
|
});
|
if (!string.IsNullOrWhiteSpace(obj.sheng))
|
{
|
|
|
where = where.And(p => p.sheng == obj.sheng);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.shi))
|
{
|
|
|
where = where.And(p => p.shi == obj.shi);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.quxian))
|
{
|
|
|
where = where.And(p => p.quxian == obj.quxian);
|
|
}
|
|
if (!string.IsNullOrWhiteSpace(obj.quxianId))
|
{
|
var quxianId = obj.quxianId.ObjToInt(0);
|
if (quxianId >= 0)
|
{
|
|
where = where.And(p => p.quxianId == quxianId);
|
}
|
}
|
|
if (!string.IsNullOrWhiteSpace(obj.pianqu))
|
{
|
var pianqu = obj.pianqu;
|
|
|
where = where.And(p => pianqu.Contains(p.pianqu));
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.shipAddress))
|
{
|
var shipAddress = obj.shipAddress;
|
|
|
where = where.And(p => shipAddress.Contains(p.shipAddress));
|
}
|
|
if (!string.IsNullOrWhiteSpace(obj.DeliverState))
|
{
|
|
if (Enum.TryParse(obj.DeliverState, out DeliverStateType result))
|
{
|
where = where.And(p => p.DeliverState == result);
|
}
|
|
|
|
}
|
|
|
|
|
|
|
}
|
where = where.And(p => user.mobile == p.userMobile);
|
where = where.And(n => n.isdelete == false);
|
RefAsync<int> totalNumbe = 0;
|
|
var list = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Where(where).OrderBy(p => p.quxianId).Select(p => new CoreCmsPlanOrderListDto(), true).ToPageListAsync(entity.page, entity.limit, totalNumbe);
|
|
//.QueryPageByDTOAsync(where, entity.page, entity.limit, true);
|
return new WebApiCallBack()
|
{
|
status = true,
|
data = new
|
{
|
list,
|
entity.page,
|
totalNumbe,
|
entity.limit,
|
entity.where,
|
|
}
|
|
};
|
|
|
|
|
}
|
/// <summary>
|
/// 获取订单详情
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetOderInfo(FMIntId entity)
|
{
|
var rt = await IsSchooler();
|
var rtb = await IsDrive();
|
if (rt == false && rtb == false)
|
{
|
throw new Exception("没有权限访问");
|
}
|
|
|
var list = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Includes(x=>x.items)
|
.Includes(x=>x.DeliverOrderItems,o=>o.items)
|
.Where(x => x.id == entity.id)
|
.Mapper(x=>
|
{
|
|
|
x.deliverOrder = x.DeliverOrderItems.OrderByDescending(de=>de.CreateTime).FirstOrDefault();
|
}).FirstAsync();
|
|
var countList = await CountLessCount(list.DeliverOrderItems);
|
|
foreach (var item in list.items)
|
{
|
|
item.DeliveredCount = countList.Where(x => x.name == item.name && x.Specification == item.specification).Select(x => x.OverCount).FirstOrDefault(0);
|
if (item.nums - item.DeliveredCount > 0)
|
item.unDeliveredCount = item.nums - item.DeliveredCount;
|
else
|
item.unDeliveredCount = 0;
|
|
}
|
|
|
return
|
new WebApiCallBack()
|
{
|
status = true,
|
data = list,
|
};
|
}
|
|
|
|
public async Task<WebApiCallBack> SetOderOfSchool(CoreCmsPlanOrderInfoDto planOrderInfoDto)
|
{
|
|
var rt = await IsSchooler();
|
if (rt == false)
|
{
|
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "你没有权限操作"
|
};
|
}
|
var oldOder = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Includes(x => x.items).Where(x => x.id == planOrderInfoDto.id).FirstAsync();
|
if(oldOder.status==2)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "已经锁单"
|
};
|
}
|
decimal auturo = 0;
|
foreach (var item in oldOder.items)
|
{
|
item.nums = planOrderInfoDto.items.Where(x => x.id == item.id).FirstOrDefault().nums;
|
|
item.amount = item.price * item.nums;
|
auturo += item.amount;
|
|
}
|
oldOder.shipMobile = planOrderInfoDto.shipMobile;
|
oldOder.shipName = planOrderInfoDto.shipName;
|
oldOder.orderAmount = auturo;
|
|
await _CyDbClient.AsTenant().BeginTranAsync();
|
try
|
{
|
await _CyDbClient.Updateable(oldOder).ExecuteCommandAsync();
|
await _CyDbClient.Updateable(oldOder.items).ExecuteCommandAsync();
|
await _CyDbClient.AsTenant().CommitTranAsync();
|
}
|
catch (Exception )
|
{
|
|
await _CyDbClient.AsTenant().RollbackTranAsync();
|
throw ;
|
}
|
//await _CyDbClient.UpdateNav(oldOder).Include(x => x.items,new UpdateNavOptions
|
//{
|
// OneToOneSaveByPrimaryKey=true,
|
//}).ExecuteCommandAsync();
|
|
|
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.CyDeliverOAjisuanjine,oldOder.orderkeyid?.ToString());
|
return new WebApiCallBack()
|
{
|
status = true,
|
data = true
|
};
|
}
|
|
public async Task<WebApiCallBack> GetDeliveryOrderInfoOfSchool(FMStringId entity)
|
{
|
|
var rt = await IsSchooler();
|
if (rt == false)
|
{
|
throw new Exception("没有权限访问");
|
}
|
var data = _CyDbClient.Queryable<CoreDeliverOrder>()
|
.Where(x=>x.id==new Guid(entity.id))
|
.Includes(x => x.items)
|
.Includes(x => x.tracks)
|
.Includes(x=>x.Oreder,o=>o.items)
|
.Includes(x => x.Oreder, o => o.DeliverOrderItems)
|
.Select(x => new CoreDeliverOrder()
|
{
|
DeliveryMoble = "",
|
|
|
|
}, true).Mapper(x=>
|
{
|
|
}).FirstAsync();
|
|
|
|
return new WebApiCallBack()
|
{
|
status = true,
|
data = data
|
};
|
}
|
|
public async Task <WebApiCallBack> SetDeliveryDataOfschool(SetDeliveryDataDto entity)
|
{
|
if(await IsSchooler()==false)
|
{
|
return new WebApiCallBack()
|
{
|
status = true,
|
msg = "无权限"
|
};
|
|
}
|
|
|
var olddata= await _CyDbClient.Queryable<CoreCmsPlanOrder>()
|
.Includes(x=>x.items)
|
.Includes(x=>x.DeliverOrderItems,de=>de.items)
|
. Where(x => x.id == entity.PlanOrderId)
|
.Mapper(x=>x.deliverOrder= x.DeliverOrderItems.Where(y=>y.OrderState== CoreDeliverOrderType.UnStart).FirstOrDefault())
|
.FirstAsync();
|
|
if(olddata==null)
|
{
|
return new WebApiCallBack()
|
{
|
status = false,
|
msg = "没有找到相关订单"
|
};
|
}
|
if(olddata.DeliverState == DeliverStateType.CompletedDelivery)
|
{
|
return new WebApiCallBack()
|
{
|
status = false,
|
msg = "已经完成配送不可修改"
|
};
|
}
|
var user = await _coreCmsUserServices.QueryByIdAsync(_User.ID);
|
await _CyDbClient.AsTenant().BeginTranAsync();
|
try
|
{
|
if (entity.MakeTime != null)
|
{
|
if(olddata.deliverOrder==null)
|
{
|
//没有配送单 新建
|
olddata.deliverOrder = await CreatDeliverItem(olddata);
|
olddata.deliverOrder.MakeTime=entity.MakeTime;
|
|
await _CyDbClient.InsertNav(olddata.deliverOrder).Include(x => x.items).ExecuteCommandAsync();
|
|
}
|
else
|
{
|
if (olddata.deliverOrder.MakeTime != entity.MakeTime)
|
{ //有配送单
|
olddata.deliverOrder.MakeTime = entity.MakeTime;
|
olddata.upDataBy = _UserMoble;
|
olddata.upDataTime = DateTime.Now;
|
await _CyDbClient.Updateable(olddata.deliverOrder).ExecuteCommandAsync();
|
}
|
}
|
}
|
|
if (olddata.DeliverRemark != entity.DeliverRemark)
|
|
{
|
olddata.DeliverRemark = entity.DeliverRemark;
|
olddata.upDataBy=_UserMoble;
|
olddata.upDataTime= DateTime.Now;
|
await _CyDbClient.Updateable(olddata).ExecuteCommandAsync();
|
}
|
await _CyDbClient.AsTenant().CommitTranAsync();
|
return new WebApiCallBack()
|
{
|
status = true,
|
|
};
|
}
|
catch (Exception)
|
{
|
await _CyDbClient.AsTenant().RollbackTranAsync();
|
throw;
|
}
|
|
|
}
|
public async Task<WebApiCallBack> GetDeliveryTracksOfSchool(FMStringId entity)
|
{
|
var rt = await IsSchooler();
|
if (rt == false)
|
{
|
throw new Exception("没有权限访问");
|
}
|
var data = await _CyDbClient.Queryable<CoreDeliveryOrderTracks>().Where(x => x.OrderID == new Guid(entity.id)).ToListAsync();
|
|
return new WebApiCallBack()
|
{
|
status = true,
|
data = data
|
};
|
}
|
|
|
|
public async Task<WebApiCallBack> GetDriverPhoneOfSchool(FMStringId entity)
|
{
|
|
if (!Guid.TryParse(entity.id, out Guid guid))
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "id格式错误"
|
|
};
|
}
|
var data = await _CyDbClient.Queryable<CoreDeliverOrder>().Where(x => x.id == guid).FirstAsync();
|
if (data != null && !string.IsNullOrEmpty(data.DeliveryMoble))
|
{
|
return new WebApiCallBack
|
{
|
status = true,
|
data = data.DeliveryMoble
|
};
|
}
|
else
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没有找到联系电话"
|
};
|
}
|
}
|
#endregion
|
|
|
#region 送货管理相关
|
public async Task<WebApiCallBack> GetOderListOfDeliveryManage(FMPageByWhereOrder entity)
|
{
|
if (!await IsDeliverManage())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "你没有权限操作"
|
};
|
|
var where = PredicateBuilder.True<CoreCmsPlanOrder>();
|
if (!string.IsNullOrWhiteSpace(entity.where))
|
{
|
var obj = JsonConvert.DeserializeAnonymousType(entity.where, new
|
{
|
quxianId = "",
|
pianqu = "",
|
shipAddress = "",
|
isScheduled = "",
|
sheng = "",
|
shi = "",
|
quxian = "",
|
|
|
});
|
if (!string.IsNullOrWhiteSpace(obj.sheng))
|
{
|
|
|
where = where.And(n => n.sheng == obj.sheng);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.shi))
|
{
|
|
|
where = where.And(n => n.shi == obj.shi);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.quxian))
|
{
|
|
|
where = where.And(n => n.quxian == obj.quxian);
|
|
}
|
if (!string.IsNullOrEmpty(obj.isScheduled))
|
{
|
if (obj.isScheduled == "1")
|
where = where.And(n => n.IngDeliverOrderID != null);
|
else
|
where = where.And(n => n.IngDeliverOrderID == null);
|
}
|
|
if (!string.IsNullOrEmpty(obj.quxianId))
|
{
|
var ad = obj.quxianId.ToInt32OrDefault(0);
|
if (ad > 0)
|
{
|
where = where.And(n => n.quxianId == ad);
|
}
|
|
}
|
|
|
if (!string.IsNullOrEmpty(obj.pianqu))
|
{
|
|
where = where.And(n => n.pianqu.Contains(obj.pianqu));
|
|
|
}
|
|
if (!string.IsNullOrEmpty(obj.shipAddress))
|
{
|
|
where = where.And(n => n.shipAddress.Contains(obj.shipAddress));
|
|
|
}
|
|
}
|
where = where.And(n => n.isdelete == false);
|
RefAsync<int> totalNumbe = 0;
|
var dlist = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Where(n => n.DeliverState != DeliverStateType.CompletedDelivery)
|
.Select((n) => new CoreCmsPlanOrder
|
{
|
|
IngDeliverOrderID = SqlFunc.Subqueryable<CoreDeliverOrder>().Where(x => x.OrderId == n.id
|
&& x.OrderState != CoreDeliverOrderType.Faile
|
&& x.OrderState != CoreDeliverOrderType.Completed
|
&& (x.DeliveryMoble != "" || x.DeliveryMoble != null)).OrderByDesc(x => x.CreateTime).Select(x=>x.id),
|
deliverOrder = SqlFunc.Subqueryable<CoreDeliverOrder>().Where(x => x.OrderId == n.id
|
&& x.OrderState != CoreDeliverOrderType.Faile
|
&& x.OrderState != CoreDeliverOrderType.Completed
|
&& (x.DeliveryMoble != "" || x.DeliveryMoble != null)).OrderByDesc(x => x.CreateTime).First()
|
},
|
|
true
|
).MergeTable().Where(where).ToPageListAsync(entity.page, entity.limit, totalNumbe);
|
|
var data = dlist.Select(x => new
|
{
|
id = x.id,
|
MakeTime = x.deliverOrder?.MakeTime,
|
shipAddress = x.shipAddress,
|
isScheduled = x.deliverOrder != null ? "1" : "0",
|
|
}).ToList();
|
return new WebApiCallBack
|
{
|
status = true,
|
data= new
|
{
|
totalNumbe,
|
data,
|
}
|
|
};
|
}
|
public async Task<WebApiCallBack> GetSendDeliveryOderListOfDeliveryManage(FMPageByWhereOrder entity)
|
{
|
if (!await IsDeliverManage())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "你没有权限操作"
|
};
|
|
var where = PredicateBuilder.True<CoreCmsPlanOrder>();
|
if (!string.IsNullOrWhiteSpace(entity.where))
|
{
|
var obj = JsonConvert.DeserializeAnonymousType(entity.where, new
|
{
|
quxianId = "",
|
pianqu = "",
|
shipAddress = "",
|
MakeTime = "",
|
sheng = "",
|
shi = "",
|
quxian = "",
|
|
|
});
|
if (!string.IsNullOrWhiteSpace(obj.sheng))
|
{
|
|
|
where = where.And(n => n.sheng == obj.sheng);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.shi))
|
{
|
|
|
where = where.And(n => n.shi == obj.shi);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.quxian))
|
{
|
|
|
where = where.And(n => n.quxian == obj.quxian);
|
|
}
|
if (!string.IsNullOrEmpty(obj.MakeTime))
|
{
|
var date = obj.MakeTime.ParseDateTimeRange();
|
if (date.StartDate != null && date.EndDate != null)
|
{
|
|
where = where.And(n => n.deliverOrder.MakeTime > date.StartDate && n.deliverOrder.MakeTime < date.EndDate);
|
}
|
}
|
|
if (!string.IsNullOrEmpty(obj.quxianId))
|
{
|
var ad = obj.quxianId.ToInt32OrDefault(0);
|
if (ad > 0)
|
{
|
where = where.And(n => n.quxianId == ad);
|
}
|
|
}
|
|
|
if (!string.IsNullOrEmpty(obj.pianqu))
|
{
|
|
where = where.And(n => n.pianqu.Contains(obj.pianqu));
|
|
|
}
|
|
if (!string.IsNullOrEmpty(obj.shipAddress))
|
{
|
|
where = where.And(n => n.shipAddress.Contains(obj.shipAddress));
|
|
|
}
|
|
}
|
where = where.And(n => n.isdelete == false);
|
RefAsync<int> totalNumbe = 0;
|
var dlist = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Where(n => n.DeliverState != DeliverStateType.CompletedDelivery)
|
.Select((n) => new CoreCmsPlanOrder
|
{
|
|
deliverOrder = SqlFunc.Subqueryable<CoreDeliverOrder>().Where(x => x.OrderId == n.id
|
&& x.OrderState != CoreDeliverOrderType.Faile
|
&& x.OrderState != CoreDeliverOrderType.Completed
|
&& (x.DeliveryMoble != "" || x.DeliveryMoble != null)).OrderByDesc(x => x.CreateTime).First(),
|
MakeTime= SqlFunc.Subqueryable<CoreDeliverOrder>().Where(x => x.OrderId == n.id
|
&& x.OrderState != CoreDeliverOrderType.Faile
|
&& x.OrderState != CoreDeliverOrderType.Completed
|
&& (x.DeliveryMoble != "" || x.DeliveryMoble != null)).OrderByDesc(x => x.CreateTime).Select(x=>x.MakeTime)
|
}
|
|
,true
|
).MergeTable().Where(where).ToPageListAsync(entity.page, entity.limit, totalNumbe);
|
|
|
return new WebApiCallBack
|
{
|
status = true,
|
data = new
|
{
|
totalNumbe,
|
data = dlist.Select(x => new
|
{
|
id = x.id.ToString(),
|
x.shipAddress,
|
x.quxian,
|
x.pianqu,
|
x.deliverOrder
|
|
|
}).ToList()
|
}
|
};
|
}
|
public async Task<WebApiCallBack> GetDeliveryOderInfoOfDeliveryManage(FMIntId entity)
|
{
|
if (!await IsDeliverManage())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "你没有权限操作"
|
};
|
|
var data= await _CyDbClient.Queryable<CoreCmsPlanOrder>().Includes(x=>x.items).Includes(x=>x.DeliverOrderItems,itm=>itm.items)
|
.Where(x=>x.isdelete==false&&x.id==entity.id)
|
.FirstAsync();
|
if(data==null)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "订单已失效或者不可更改"
|
};
|
};
|
|
//只统计已经开始配送的，和已经配送完成的订单
|
var DeliverOrderlist = data.DeliverOrderItems.Where(x => x.OrderState == CoreDeliverOrderType.Start || x.OrderState == CoreDeliverOrderType.Completed).ToList();
|
|
var DeliverOrderItemList = new List<CoreDeliverOrderItem>();
|
foreach (var Deliveritem in DeliverOrderlist)
|
{
|
DeliverOrderItemList.AddRange(Deliveritem.items);
|
|
}
|
|
// 按 ZYBName 和 ZYBSpecification 分组，并统计每个分组的 Number 总和
|
var groupedItems = DeliverOrderItemList
|
.GroupBy(item => new { item.ZYBName, item.ZYBSpecification })
|
.Select(group => new CoreDeliverOrderItem
|
{
|
ZYBName = group.Key.ZYBName,
|
ZYBSpecification = group.Key.ZYBSpecification,
|
Number = group.Sum(item => item.Number)
|
})
|
.ToList();
|
///有并且未执行配送的订单
|
var UndoDeliver = DeliverOrderlist.Where(x => x.OrderState == CoreDeliverOrderType.UnStart).FirstOrDefault();
|
//配送单列表详情
|
var orderItm = new List<CoreCmsPlanOrderItemDto>();
|
|
foreach (var item in data.items)
|
{
|
var unDeliver = groupedItems.Where(x => x.ZYBName == item.name && x.ZYBSpecification == item.specification).FirstOrDefault()?.Number ?? 0;
|
unDeliver = item.nums - unDeliver;
|
if (unDeliver < 0)
|
unDeliver = 0;
|
int DeliveredCount = UndoDeliver?.items.Where(x=>x.ZYBSpecification== item.name&&x.ZYBName==item.name).FirstOrDefault()?.Number??
|
unDeliver;
|
orderItm.Add(new CoreCmsPlanOrderItemDto
|
{
|
amount = item.amount,
|
id = item.id,
|
name = item.name,
|
nums = item.nums,
|
price = item.price,
|
specification = item.specification,
|
isOld = item.isOld,
|
unDeliveredCount = unDeliver,
|
DeliveredCount = DeliveredCount
|
});
|
}
|
|
var deliveryList = await _CyDbClient.Queryable<OA_Staff>().Where(x => x.Status == "在职" && x.BF_IsDriver == true).Select(x=>new
|
{
|
deliveryMoble= x.MobieNum,
|
name= x.Name,
|
|
}).ToListAsync();
|
|
return new WebApiCallBack
|
{
|
status = true,
|
data = new
|
{
|
id =UndoDeliver?.id,
|
OrderId = data.id,
|
//司机电话
|
DeliveryMoble = UndoDeliver?.DeliveryMoble,
|
items = orderItm,
|
UndoDeliver?.MakeTime,
|
//司机列表
|
deliveryList
|
|
}
|
};
|
|
}
|
public async Task<WebApiCallBack> SetDeliveryOderOfDeliveryManage(DeliveryOrderDto entity)
|
{
|
if (!await IsDeliverManage())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "你没有权限操作"
|
};
|
|
var planOrder= await _CyDbClient.Queryable<CoreCmsPlanOrder>().Includes(x=>x.items).Where(x => x.id == entity.OrderId).FirstAsync();
|
if (planOrder == null)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没找到订单",
|
};
|
}
|
|
|
if (entity.id!=null)
|
{
|
//是修改
|
|
var DeliverOrder = await _CyDbClient.Queryable<CoreDeliverOrder>().Includes(x=>x.items).Where(x => x.id == entity.id ).FirstAsync();
|
if(DeliverOrder== null)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没找到订单",
|
};
|
}
|
if(entity.MakeTime!=null)
|
|
DeliverOrder.MakeTime = entity.MakeTime;
|
if(entity.items!=null&&entity.items.Count>0)
|
{
|
foreach (var item in DeliverOrder.items)
|
{
|
var newitem= entity.items.Where(x=>x.name==item.ZYBName&&x.specification==item.ZYBSpecification).FirstOrDefault();
|
if(newitem!=null)
|
{
|
if (item.Number != newitem.nums)
|
{
|
item.Number = newitem.nums;
|
item.UpDataBy = _UserMoble;
|
item.UpdataTime = DateTime.Now;
|
}
|
|
|
}
|
}
|
}
|
//DeliverOrder.items= entity.items;
|
if(!string.IsNullOrEmpty( entity.DeliveryMoble))
|
DeliverOrder.DeliveryMoble = entity.DeliveryMoble;
|
DeliverOrder.UpDataBy = _coreCmsUserServices.QueryById(_User.ID)?.mobile;
|
|
DeliverOrder.UpdataTime = DateTime.Now;
|
|
await _CyDbClient.UpdateNav(DeliverOrder).Include(x => x.items).ExecuteCommandAsync();
|
|
|
|
}
|
else
|
|
{
|
|
var olddeliver = await _CyDbClient.Queryable<CoreDeliverOrder>().Includes(x => x.items).Where(x => x.OrderId==entity.OrderId&&x.OrderState== CoreDeliverOrderType.UnStart).FirstAsync();
|
if (olddeliver != null)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "配送单已经改变，请刷新后重新配置新的配送单",
|
};
|
}
|
//新建
|
var DeliverOrder = new CoreDeliverOrder()
|
{
|
MakeTime = entity.MakeTime,
|
OrderId = entity.OrderId,
|
CreateTime = DateTime.Now,
|
CreateBy = _UserMoble,
|
DeliveryMoble = entity.DeliveryMoble,
|
id = Guid.NewGuid(),
|
OrderState = CoreDeliverOrderType.UnStart,
|
items = new List<CoreDeliverOrderItem>()
|
};
|
if (entity.items != null && entity.items.Count > 0)
|
{
|
foreach (var item in entity.items)
|
{
|
DeliverOrder.items.Add(new CoreDeliverOrderItem()
|
{
|
CreateBy = _UserMoble,
|
CreateTime = DateTime.Now,
|
id = Guid.NewGuid(),
|
Number = item.nums,
|
OrderID= DeliverOrder.id,
|
ZYBName= item.name,
|
ZYBSpecification= item.specification,
|
|
|
});
|
|
}
|
|
}
|
|
await _CyDbClient.InsertNav(DeliverOrder).Include(x => x.items).ExecuteCommandAsync();
|
}
|
return new WebApiCallBack()
|
{
|
status = true,
|
data = true
|
};
|
|
}
|
|
#endregion
|
#region 司机端
|
|
public async Task<WebApiCallBack> GetDeliverOderListOfDrver(FMPageByWhereOrder entity)
|
{
|
if (!await IsDrive())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "你没有权限操作"
|
};
|
var where = PredicateBuilder.True<CoreCmsPlanOrder>();
|
if (!string.IsNullOrWhiteSpace(entity.where))
|
{
|
var obj = JsonConvert.DeserializeAnonymousType(entity.where, new
|
{
|
quxianId = "",
|
sheng="",
|
pianqu = "",
|
shipAddress = "",
|
shi = "",
|
quxian = "",
|
DeliverState=""
|
|
|
|
});
|
if (!string.IsNullOrWhiteSpace(obj.DeliverState))
|
{
|
var ad = obj.DeliverState.ToInt32OrDefault(0);
|
|
where = where.And(n => n.DeliverState == (DeliverStateType)ad );
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.sheng))
|
{
|
|
|
where = where.And(n => n.sheng == obj.sheng);
|
|
}
|
|
if (!string.IsNullOrWhiteSpace(obj.shi))
|
{
|
|
|
where = where.And(n => n.shi == obj.shi);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.quxian))
|
{
|
|
|
where = where.And(n => n.quxian == obj.quxian);
|
|
}
|
if (!string.IsNullOrEmpty(obj.quxianId))
|
{
|
var ad = obj.quxianId.ToInt32OrDefault(0);
|
if (ad > 0)
|
{
|
where = where.And(n => n.quxianId == ad);
|
}
|
|
}
|
|
|
if (!string.IsNullOrEmpty(obj.pianqu))
|
{
|
|
where = where.And(n => n.pianqu.Contains(obj.pianqu));
|
|
|
}
|
|
if (!string.IsNullOrEmpty(obj.shipAddress))
|
{
|
|
where = where.And(n => n.shipAddress.Contains(obj.shipAddress));
|
|
|
}
|
|
}
|
where = where.And(n => n.isdelete == false);
|
var user = _coreCmsUserServices.QueryById(_User.ID);
|
if (user == null)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "登录信息错误"
|
};
|
}
|
RefAsync<int> totalNumbe = 0;
|
var lisdata = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Where(where).Select(n => new CoreCmsPlanOrder
|
{
|
|
IngDeliverOrderID = SqlFunc.Subqueryable<CoreDeliverOrder>().Where(x => x.OrderId == n.id && (x.OrderState == CoreDeliverOrderType.UnStart || x.OrderState == CoreDeliverOrderType.Start)
|
&& x.DeliveryMoble == user.mobile).Select(x => x.id),
|
deliverOrder = SqlFunc.Subqueryable<CoreDeliverOrder>().Where(x => x.OrderId == n.id && (x.OrderState == CoreDeliverOrderType.UnStart || x.OrderState == CoreDeliverOrderType.Start)
|
&& x.DeliveryMoble == user.mobile).First()
|
|
}, true).MergeTable().Where(x=>x.IngDeliverOrderID != null).ToPageListAsync( entity.page,entity.limit, totalNumbe);
|
return new WebApiCallBack
|
{
|
status = true,
|
data = new
|
{
|
totalNumbe,
|
data= lisdata
|
}
|
};
|
}
|
public async Task<WebApiCallBack> ManageDeliverOderListOfDrver(FMPageByWhereOrder entity)
|
{
|
if (!await IsDrive())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "你没有权限操作"
|
};
|
|
var where = PredicateBuilder.True<CoreDeliverOrder>();
|
if (!string.IsNullOrWhiteSpace(entity.where))
|
{
|
var obj = JsonConvert.DeserializeAnonymousType(entity.where, new
|
{
|
quxianId = "",
|
sheng = "",
|
pianqu = "",
|
shipAddress = "",
|
shi = "",
|
quxian = "",
|
OrderState = "",
|
StartTimeZone="",
|
EndTimeStartZone= "",
|
|
|
});
|
if (!string.IsNullOrWhiteSpace(obj.OrderState))
|
{
|
var ad = obj.OrderState.ToInt32OrDefault(0);
|
|
where = where.And(n => n.OrderState == (CoreDeliverOrderType)ad);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.sheng))
|
{
|
|
|
where = where.And(n => n.Oreder.sheng == obj.sheng);
|
|
}
|
|
if (!string.IsNullOrWhiteSpace(obj.shi))
|
{
|
|
|
where = where.And(n => n.Oreder.shi == obj.shi);
|
|
}
|
if (!string.IsNullOrWhiteSpace(obj.quxian))
|
{
|
|
|
where = where.And(n => n.Oreder.quxian == obj.quxian);
|
|
}
|
|
|
|
if (!string.IsNullOrEmpty(obj.pianqu))
|
{
|
|
where = where.And(n => n.Oreder.pianqu.Contains(obj.pianqu));
|
|
|
}
|
|
if (!string.IsNullOrEmpty(obj.shipAddress))
|
{
|
|
where = where.And(n => n.Oreder.shipAddress.Contains(obj.shipAddress));
|
|
|
}
|
|
|
if (!string.IsNullOrEmpty(obj.EndTimeStartZone))
|
{
|
var date = obj.EndTimeStartZone.ParseDateTimeRange();
|
if (date.StartDate != null && date.EndDate != null)
|
|
where = where.And(n => n.OverTime<date.EndDate&&n.OverTime>date.EndDate);
|
|
|
}
|
if (!string.IsNullOrEmpty(obj.StartTimeZone))
|
{
|
var date = obj.StartTimeZone.ParseDateTimeRange();
|
if (date.StartDate != null && date.EndDate != null)
|
where = where.And(n => n.StartTime < date.EndDate && n.StartTime > date.EndDate);
|
|
|
}
|
|
}
|
where = where.And(n => n.DeliveryMoble == _UserMoble);
|
RefAsync<int> totalNumbe = 0;
|
var data= await _CyDbClient.Queryable<CoreDeliverOrder>().Includes(n=>n.Oreder).Where(where).OrderByDescending(n=>n.StartTime).ToPageListAsync( entity.page,entity.limit, totalNumbe);
|
//var datalist= await _CyDbClient.Queryable<CoreCmsPlanOrder>().Includes(x => x.DeliverOrderItems).Where(where).Select(x => new CoreCmsPlanOrder
|
//{
|
// IngDeliverOrderID = SqlFunc.Subqueryable<CoreDeliverOrder>().Where(ide => ide.DeliveryMoble == _UserMoble && ide.OrderId == x.id).Select(ide => ide.id)
|
//},true).MergeTable().Where(x => x.IngDeliverOrderID != null).Mapper(x=>
|
//{
|
// x.DeliverOrderItems.Where(x => x.DeliveryMoble == _UserMoble).ToList();
|
// x.IngDeliverOrderID = null;
|
//}).ToListAsync();
|
return new WebApiCallBack()
|
{
|
status = true,
|
data = new
|
{
|
list= data,
|
totalNumbe
|
}
|
};
|
|
}
|
|
public async Task<WebApiCallBack> GetDeliverInfoOfDrver(FMStringId entity)
|
{
|
|
|
if (!Guid.TryParse(entity.id, out Guid guid))
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "id格式错误"
|
|
};
|
}
|
|
var data= await _CyDbClient.Queryable<CoreDeliverOrder>()
|
.Where(x => x.id == guid && x.OrderState != CoreDeliverOrderType.Faile)
|
.Includes(x => x.items).Includes(x=>x.Oreder,or=>or.items).FirstAsync();
|
if(data==null)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没有配送订单可以操作"
|
};
|
}
|
var DeliverOrderlist = await _CyDbClient.Queryable<CoreDeliverOrder>().Where(x => x.OrderId == data.OrderId).ToListAsync();
|
var lessdata = await CountLessCount(DeliverOrderlist);
|
|
var ret = new DeliveryOrderDto()
|
{
|
MakeTime = data.MakeTime,
|
DeliveryMoble = data.DeliveryMoble,
|
OrderState = data.OrderState,
|
PlanOrdInfo = new CoreCmsPlanOrderInfoDto()
|
{
|
pianqu = data.Oreder.pianqu,
|
quxianId = data.Oreder.quxianId,
|
shipMobile = data.Oreder.shipMobile,
|
shipAddress = data.Oreder.shipAddress,
|
shouhuoAddress = data.Oreder.shipAddress,
|
DeliverRemark = data.Oreder.DeliverRemark,
|
shipName= data.Oreder.shipName,
|
sheng= data.Oreder.sheng,
|
shi= data.Oreder.shi,
|
quxian= data.Oreder.quxian,
|
DeliveryOderID=data.id,
|
|
|
|
},
|
items = new List<CoreCmsPlanOrderItemDto>()
|
|
};
|
foreach (var item in data.Oreder.items)
|
{
|
var count = lessdata.Where(x => x.name == item.name && x.Specification == item.specification).Select(x => x.OverCount).FirstOrDefault(0);
|
var thisNumber = data.items.Where(x => x.ZYBName == item.name && x.ZYBSpecification == item.specification).FirstOrDefault();
|
ret.items.Add(new CoreCmsPlanOrderItemDto()
|
{
|
name = item.name,
|
specification = item.specification,
|
nums = item.nums,
|
DeliveredCount = count,
|
Number = thisNumber?.Number ?? count,
|
unDeliveredCount = item.nums > count ? item.nums - count : 0,
|
LessNumber= thisNumber.LessNumber,
|
});
|
|
|
}
|
return new WebApiCallBack()
|
{
|
status = true,
|
data = ret
|
};
|
|
}
|
|
public async Task<WebApiCallBack> StartDeliverOrderOfDrver(FMStringId entity)
|
{
|
|
if (!Guid.TryParse(entity.id, out Guid guid))
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "id格式错误"
|
|
};
|
}
|
|
var data = await _CyDbClient.Queryable<CoreDeliverOrder>()
|
.Where(x => x.id == guid && x.OrderState == CoreDeliverOrderType.UnStart )
|
.FirstAsync();
|
if (data == null)
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没有数据，或者是没有权限可操作"
|
};
|
data.OrderState = CoreDeliverOrderType.Start;
|
data.UpDataBy = _UserMoble;
|
data.UpdataTime = DateTime.Now;
|
data.StartTime = DateTime.Now;
|
await _CyDbClient.Updateable(data).ExecuteCommandAsync();
|
return new WebApiCallBack()
|
{
|
status = true
|
};
|
|
}
|
|
public async Task<WebApiCallBack> SetDeliverOrdeOfDrver(DeliveryOrderDto entity)
|
{
|
|
if (!await IsDrive())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没有权限操作"
|
};
|
var data= await _CyDbClient.Queryable<CoreDeliverOrder>().Includes(x=>x.items).Includes(x=>x.Oreder).Where(x => x.id == entity.id && x.OrderState != CoreDeliverOrderType.Faile && x.DeliveryMoble==_UserMoble).FirstAsync();
|
if(data==null)
|
{
|
return new WebApiCallBack()
|
{
|
status = false,
|
msg = "没有权限或者状态已经锁定不可更改"
|
};
|
}
|
var deliverlist = await _CyDbClient.Queryable<CoreDeliverOrder>().Includes(x=>x.items).Where(x => x.OrderId == data.OrderId).ToListAsync();
|
var countlist = await CountLessCount(deliverlist);
|
|
if(!string.IsNullOrEmpty( data.Oreder?.DeliverRemark))
|
{
|
if (data.Oreder.DeliverRemark != data.Oreder?.DeliverRemark)
|
{
|
data.Oreder.DeliverRemark = data.Oreder?.DeliverRemark;
|
data.Oreder.upDataTime = DateTime.Now;
|
data.Oreder.upDataBy = _UserMoble;
|
}
|
}
|
foreach (var item in data.items)
|
{
|
var it = entity.items.Where(x => x.name == item.ZYBName && x.specification == item.ZYBSpecification).FirstOrDefault();
|
if (it?.LessNumber != null)
|
if (item.LessNumber!=it.LessNumber)
|
{
|
item.LessNumber = it.LessNumber??0;
|
item.UpDataBy = _UserMoble;
|
item.UpdataTime = DateTime.Now;
|
|
|
}
|
// 送货数量是否能超过预定数量？
|
//item.Number- countlist.Where(x=>x.name==item.ZYBName&&x.Specification==item.ZYBSpecification).Select(x=>x.OverCount).FirstOrDefault(0)
|
if(it?.nums!=null)
|
if (item.Number!=it.Number )
|
{
|
item.Number = it.Number??0;
|
item.UpDataBy = _UserMoble;
|
item.UpdataTime = DateTime.Now;
|
}
|
}
|
await _CyDbClient.UpdateNav(data).Include(x => x.Oreder).Include(x => x.items).ExecuteCommandAsync();
|
|
return new WebApiCallBack
|
{
|
status = true
|
};
|
|
}
|
|
public async Task<WebApiCallBack> FinishDeliverOrdeOfDrver(FMStringId entity)
|
{
|
|
if (!Guid.TryParse(entity.id, out Guid guid))
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "id格式错误"
|
|
};
|
}
|
if (!await IsDrive())
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没有权限操作"
|
};
|
|
var data = await _CyDbClient.Queryable<CoreDeliverOrder>()
|
.Where(x => x.id == guid && x.OrderState == CoreDeliverOrderType.Start)
|
.FirstAsync();
|
if (data == null)
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没有数据，或者是没有权限可操作"
|
};
|
|
var order = await _CyDbClient.Queryable<CoreCmsPlanOrder>().Where(x => x.id == data.OrderId).Includes(x => x.items)
|
.Includes(x => x.DeliverOrderItems, deo => deo.items).FirstAsync();
|
if(order == null)
|
{
|
return new WebApiCallBack
|
{
|
status = false,
|
msg = "没有找到订单"
|
};
|
}
|
var countlist = await CountLessCount(order.DeliverOrderItems);
|
await _CyDbClient.AsTenant().BeginTranAsync();
|
try
|
{
|
if (countlist != null)
|
{
|
//修改订单状态
|
DeliverStateType isOver = DeliverStateType.CompletedDelivery;
|
for (int i = 0; i < order.items.Count; i++)
|
{
|
|
var dcount = countlist.Where(x => x.name == order.items[i].name && x.Specification == order.items[i].specification).FirstOrDefault();
|
if (dcount != null)
|
{
|
|
if (order.items[i].nums > (dcount.OverCount + dcount.IngCount))
|
|
{
|
isOver = DeliverStateType.PartialDelivery;
|
break;
|
}
|
}
|
}
|
|
|
if (countlist.Count == 0)
|
{
|
|
isOver = DeliverStateType.NoDelivery;
|
}
|
if (order.DeliverState != isOver)
|
|
{
|
order.DeliverState = isOver;
|
order.upDataBy = _UserMoble;
|
order.upDataTime = DateTime.Now;
|
await _CyDbClient.Updateable(order).ExecuteCommandAsync();
|
}
|
|
|
}
|
data.OrderState = CoreDeliverOrderType.Completed;
|
data.UpDataBy = _UserMoble;
|
data.UpdataTime = DateTime.Now;
|
data.OverTime = DateTime.Now;
|
await _CyDbClient.Updateable(data).ExecuteCommandAsync();
|
|
await _CyDbClient.AsTenant().CommitTranAsync();
|
return new WebApiCallBack()
|
{
|
status = true
|
};
|
|
}
|
catch (Exception)
|
{
|
await _CyDbClient.AsTenant().RollbackTranAsync();
|
throw;
|
}
|
|
}
|
public async Task<WebApiCallBack> SetTarcks(TracksDto entity)
|
{
|
|
if( ! await IsDrive())
|
{
|
|
return new WebApiCallBack()
|
{
|
status= false,
|
|
msg= "非司机端不集坐标数据",
|
};
|
}
|
entity.Moble = _UserMoble;
|
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.CyDeliverOrderTarcks, JsonConvert.SerializeObject(entity));
|
return new WebApiCallBack()
|
{
|
status = true,
|
};
|
}
|
|
|
#endregion
|
#region 其他接口函数
|
public async Task<List<Sys_CitySite>> GetZoneList(Sys_CitySite cyte = null)
|
{
|
if (cyte == null)
|
return await _CyDbClient.Queryable<Sys_CitySite>().Where(x => x.CityLevel == 1 && x.IsDisplay == true && x.ProvinceId == 0&&x.CityId==0).OrderBy(x => x.OrderNum).ToListAsync();
|
if (cyte.CityLevel == 3)
|
return new List<Sys_CitySite>();
|
if(cyte.CityLevel==2)
|
//区
|
return await _CyDbClient.Queryable<Sys_CitySite>().Where(x => x.CityLevel == 3 && x.IsDisplay == true && x.ProvinceId == cyte.ProvinceId && x.CityId == cyte.Keyid).OrderBy(x => x.OrderNum).ToListAsync();
|
if (cyte.CityLevel == 1)
|
//查市级
|
return await _CyDbClient.Queryable<Sys_CitySite>().Where(x => x.CityLevel == 2 && x.IsDisplay == true && x.ProvinceId == cyte.Keyid && x.CityId == 0).OrderBy(x => x.OrderNum).ToListAsync();
|
return new List<Sys_CitySite>();
|
}
|
|
public async Task<List<Sys_CitySite>> GetZoneListALL()
|
{
|
return await _CyDbClient.Queryable<Sys_CitySite>().Where(x => x.IsDisplay == true ).ToListAsync();
|
}
|
|
#endregion
|
|
#region 其他函数
|
/// <summary>
|
/// 创建新的配送单列表，会根据当前订单情况创建订单
|
/// </summary>
|
/// <param name="order"></param>
|
/// <returns></returns>
|
private async Task< CoreDeliverOrder> CreatDeliverItem( CoreCmsPlanOrder order)
|
{
|
if(order.items==null)
|
order.items= await _CyDbClient.Queryable<CoreCmsPlanOrderItem>().Where(x=>x.orderId==order.id).ToListAsync();
|
if(order.DeliverOrderItems == null)
|
order.DeliverOrderItems= await _CyDbClient.Queryable<CoreDeliverOrder>().Where(x=>x.OrderId==order.id).Includes(x=>x.items).ToListAsync();
|
|
var countlist = await CountLessCount(order.DeliverOrderItems);
|
var DeliverOrder = new CoreDeliverOrder()
|
{
|
CreateBy = _UserMoble,
|
CreateTime = DateTime.Now,
|
OrderId = order.id,
|
id = Guid.NewGuid(),
|
|
};
|
var ret= new List<CoreDeliverOrderItem>();
|
|
foreach (var item in order.items)
|
{
|
var Number = item.nums -= countlist.Where(x => x.name == item.name && x.Specification == item.specification).Select(x => x.OverCount + x.IngCount).FirstOrDefault(0);
|
if(Number<0)
|
Number = 0;
|
|
ret.Add(new CoreDeliverOrderItem()
|
{
|
CreateBy = _UserMoble,
|
CreateTime = DateTime.Now,
|
Number = Number,
|
ZYBName = item.name,
|
ZYBSpecification = item.specification,
|
id = Guid.NewGuid(),
|
OrderID= DeliverOrder.id,
|
|
});
|
}
|
DeliverOrder.items= ret;
|
return DeliverOrder;
|
}
|
/// <summary>
|
/// 已配送货物统计
|
/// </summary>
|
/// <param name=""></param>
|
/// <returns></returns>
|
private async Task< List<SendCountDto> > CountLessCount(List<CoreDeliverOrder> datain)
|
{
|
|
var OverCountlistdata = new List<CoreDeliverOrderItem>();
|
//统计已经完结的单
|
foreach (var item in datain.Where(x=>x.OrderState== CoreDeliverOrderType.Completed).ToList())
|
{
|
//先统计已经完结的配送单
|
if(item.items==null||item.items.Count==0)
|
{
|
item.items= await _CyDbClient.Queryable<CoreDeliverOrderItem>().Where(x=>x.OrderID==item.id).ToListAsync();
|
}
|
OverCountlistdata.AddRange(item.items);
|
}
|
|
var overlist= OverCountlistdata.GroupBy(x => new
|
{
|
x.ZYBName,
|
x.ZYBSpecification
|
}).Select(x => new
|
{
|
name = x.Key.ZYBName,
|
Specification = x.Key.ZYBSpecification,
|
num = x.Sum(x => x.Number)
|
|
}).ToList();
|
|
//统计未完成的单
|
var ingCountlistdata = new List<CoreDeliverOrderItem>();
|
foreach (var item in datain.Where(x => x.OrderState == CoreDeliverOrderType.UnStart||x.OrderState== CoreDeliverOrderType.Start).ToList())
|
{
|
//先统计已经完结的配送单
|
if (item.items == null || item.items.Count == 0)
|
{
|
item.items = await _CyDbClient.Queryable<CoreDeliverOrderItem>().Where(x => x.OrderID == item.id).ToListAsync();
|
}
|
ingCountlistdata.AddRange(item.items);
|
}
|
|
var inglist= ingCountlistdata.GroupBy(x => new
|
{
|
x.ZYBName,
|
x.ZYBSpecification
|
}).Select(x => new
|
{
|
name = x.Key.ZYBName,
|
Specification = x.Key.ZYBSpecification,
|
num = x.Sum(x => x.Number)
|
|
}).ToList();
|
var retlist = new List<SendCountDto>();
|
foreach (var item in overlist)
|
{
|
retlist.Add(new SendCountDto
|
{
|
name = item.name,
|
Specification = item.Specification,
|
OverCount = item.num,
|
IngCount = inglist.Where(x => x.name == item.name && x.Specification == item.Specification).Select(x => x.num).FirstOrDefault(0)
|
});
|
}
|
|
return retlist;
|
|
}
|
|
|
|
|
#endregion
|
}
|
class SendCountDto
|
{
|
/// <summary>
|
/// 名称
|
/// </summary>
|
public string name { get; set; }
|
/// <summary>
|
/// 开本
|
/// </summary>
|
public string Specification { get; set; }
|
/// <summary>
|
/// 已完成配送
|
/// </summary>
|
public int OverCount { get; set; }
|
/// <summary>
|
/// 已设置或者未完成
|
/// </summary>
|
public int IngCount { get; set; }
|
}
|
|
|
}
|
