using cylsg.Model.ECTEModel;
using cylsg.Model.utilityViewModel;
using ECTESTOA;
using EzCoreNet.Redis;
using Furion.LinqBuilder;
using Models;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;

namespace cylsg.Application.CyOS
{
    /// <summary>
    /// 司机相关
    /// </summary>
    [Authorize]
    [ApiDescriptionSettings("CYOA")]
    public class CyOSSDriver: IDynamicApiController
    {
        private readonly ISqlSugarClient _client;
        private readonly IOAServices _oAServices;
        private readonly IEzCoreNetRedisService _eZCoreNetRedisService;
        private ECTESTOAPermissions Permissions;
        public CyOSSDriver(ISqlSugarClient client, IOAServices oAServices, IEzCoreNetRedisService netRedisService)
        {
            _client = client.AsTenant().GetConnection("ECTESTOADB");
            _oAServices = oAServices;
            _eZCoreNetRedisService = netRedisService;
        }
        /// <summary>
        /// 获取送货单
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task<DeliverOderPageRet> GetDeliverPlans(DeliverPlanSearchParam Param)
        {
            if (!await CheckRols())
            {
                throw Oops.Oh("没有权限");
            }

            Expression<Func<OA_DeliverPlan, bool>> SearchList = (x) => true;
            SearchList = SearchList.And(x => x.FirmId == _oAServices.firmId);
            SearchList = SearchList.And(x => x.DriverId == Permissions.KeyId);//只看自己
            SearchList = SearchList.And(x => x.ShifouDelivery != 2);//过滤有效
            if (Param.DeliverKeyID != null)
            {
                SearchList = SearchList.And(x => x.DriverId == Param.DeliverKeyID);
            }
            //客户名称
            if (!string.IsNullOrEmpty(Param.CorporateClient))
            {
                SearchList = SearchList.And(x => x.CompanyName.Contains(Param.CorporateClient));
            }
            if (Param.TimeStart != null)
            {
                SearchList = SearchList.And(x => x.CreateTime > Param.TimeStart);
            }
            if (Param.TimeEnd != null)
            {
                SearchList = SearchList.And(x => x.CreateTime < Param.TimeEnd.Value.AddDays(1));
            }
            if (Param.DeliveredState != null)
            {
                if (Param.DeliveredState != DeliveredType.Delivered)
                {
                    SearchList = SearchList.And(x => x.Deliveredstatus != DeliveredType.Delivered);
                }
                else
                {
                    SearchList = SearchList.And(x => x.Deliveredstatus == DeliveredType.Delivered);
                }
            }

            //强制增加员工过滤
            RefAsync<int> totle = 0;
            var data = await _client.Queryable<OA_DeliverPlan>().Includes(x=>x.SentStaff)
                .Where(SearchList).OrderByDescending(x => x.CreateTime.Value.Date).OrderBy(x => SqlFunc.Asc(x.Sort)).ToPageListAsync(Param.page.PageIndex, Param.page.PageSize, totle);

            Param.page.TotalCount = totle;


            return new DeliverOderPageRet

            {
                Data = data,
                page = Param.page,

            };


        }
        /// <summary>
        /// 获取DeliverPlan详情
        /// </summary>
        /// <param name="Param"></param>
        /// <returns></returns>
        public async Task<OA_DeliverPlan> GetDeliverPlanInfo(Guid KeyId)
        {
            
            if (!await CheckRols())
            {
                throw Oops.Oh("没有权限");
            }
            return await _client.Queryable<OA_DeliverPlan>().Includes(x=>x.Attachments.Where(y=>y.AttachmentType==3).ToList()).Includes(x=>x.Manager).Includes(x=>x.SentStaff)
                .Where(x => x.DriverId == Permissions.KeyId && x.Keyid == KeyId&&x.ShifouDelivery!=2).FirstAsync();

        }
        

        /// <summary>
        /// 开始配送
        /// </summary>
        /// <param name="KeyId"></param>
        /// <returns></returns>
        public async Task<int > StartDeliverPlan(Guid KeyId)
        {

            if (!await CheckRols())
            {
                throw Oops.Oh("没有权限");
            }
             var a= await _client.Queryable<OA_DeliverPlan>().Where(x => x.DriverId == Permissions.KeyId && x.Keyid == KeyId && x.ShifouDelivery != 2).FirstAsync();
            if(a==null)
                throw Oops.Oh("没有权限");
            if(a.Deliveredstatus!= DeliveredType.Undeliver)
            {
                throw Oops.Oh("已经开始或者结束了");
            }
            a.Deliveredstatus = DeliveredType.Deliver;
            a.Updater = Permissions.MemberId;
            a.LastUpdateTime = DateTime.Now;
            
           return await _client.Updateable(a).ExecuteCommandAsync();


        }


        /// <summary>
        /// 完成订单
        /// </summary>
        /// <param name="Param"></param>
        /// <returns></returns>
        public async Task<bool> FinishDeliverPlan(OA_DeliverPlan Param)
        {
            if(Param.Keyid==null)
                throw Oops.Oh("ID错误");
            if((Param.Deliveredstatus != DeliveredType.Delivered)&&(Param.Deliveredstatus != DeliveredType.Reject))
                throw Oops.Oh("接受状态错误");

            if (!await CheckRols())
            {
                throw Oops.Oh("没有权限");
            }
            var a = await _client.Queryable<OA_DeliverPlan>().Where(x => x.DriverId == Permissions.KeyId && x.Keyid == Param.Keyid && x.ShifouDelivery != 2).FirstAsync();
            if (a == null)
                throw Oops.Oh("没有权限");
            if (a.Deliveredstatus != DeliveredType.Deliver)
            {
                throw Oops.Oh("订单状态结束");
            }
            foreach (var item in Param.Attachments)
            {
                if(string.IsNullOrWhiteSpace(item.PlanAttachment))
                {
                    throw Oops.Oh("有附件地址为空");
                }

                // URL 正则表达式
                string urlPattern = @"^(https?|ftp):\/\/[^\s/$.?#].[^\s]*$";
                if(! Regex.IsMatch(item.PlanAttachment, urlPattern))
                {
                    throw Oops.Oh("请输入正确的附件地址");

                }
                if (item.Keyid>0)
                {
                    item.OA_Id = a.Keyid;
                    item.AttachmentType = 3;
                    
                }
                else
                {
                    item.OA_Id=a.Keyid;
                    item.AttachmentType = 3;
                    item.CreateTime = DateTime.Now;
                    item.Operator = Permissions.Name;
                }
            }
            a.Deliveredstatus = DeliveredType.Deliver;
            a.Updater = Permissions.MemberId;
            a.LastUpdateTime = DateTime.Now;
            if(Param.Deliveredstatus== DeliveredType.Delivered)
            a.DeliveredTime = DateTime.Now;
            a.Wentifankui = Param.Wentifankui;
            a.Deliveredstatus= Param.Deliveredstatus;
            a.Attachments = Param.Attachments;
            return await _client.UpdateNav(a).Include(x=>x.Attachments,new SqlSugar.UpdateNavOptions()
                { 
                   OneToManyInsertOrUpdate = true,//配置启用 插入、更新或删除模式
                }).ExecuteCommandAsync();


        }

        /// <summary>
        /// 上班打卡 上下班打卡都调用一个字段
        /// </summary>     
        /// <returns></returns>
        [HttpPost]
        public async Task<bool > Clock(OA_DriverRecord Param)
        {
            if (Param.ClockType == DriverClockType.Unknown)
                throw Oops.Oh("类型不可为未知");
            Param.Id =  Guid.NewGuid();
            if (Param.Attachments!=null)
            foreach (var item in Param.Attachments)
            {
                    if (string.IsNullOrWhiteSpace(item.PlanAttachment))
                    {
                        throw Oops.Oh("有附件地址为空");
                    }

                    // URL 正则表达式
                    string urlPattern = @"^(https?|ftp):\/\/[^\s/$.?#].[^\s]*$";
                    if (!Regex.IsMatch(item.PlanAttachment, urlPattern))
                    {
                        throw Oops.Oh("请输入正确的附件地址");

                    }
                    item.AttachmentType =4;
                    item.CreateTime = DateTime.Now;
                    item.Operator = Permissions.Name;
                    
                    
                }
             if(Param.CarConditionAttachments!=null)
                foreach (var item in Param.CarConditionAttachments)
                {
                    if (string.IsNullOrWhiteSpace(item.PlanAttachment))
                    {
                        throw Oops.Oh("有附件地址为空");
                    }

                    // URL 正则表达式
                    string urlPattern = @"^(https?|ftp):\/\/[^\s/$.?#].[^\s]*$";
                    if (!Regex.IsMatch(item.PlanAttachment, urlPattern))
                    {
                        throw Oops.Oh("请输入正确的附件地址");

                    }
                    item.AttachmentType = 5;
                    item.CreateTime = DateTime.Now;
                    item.Operator = Permissions.Name;


                }
            Param.CreatTime = DateTime.Now;
            Param.CreaterID = Permissions.MemberId;
            Param.Creater = Permissions.Name;
           return await  _client.InsertNav(Param).Include(x => x.Attachments).Include(x => x.Attachments).ExecuteCommandAsync();
           

        }
        /// <summary>
        /// 判断是否具有权限
        /// </summary>
        /// <returns></returns>
        private async Task<bool> CheckRols()
        {
            var pr = await _oAServices.GetOAPermissions();
            Permissions = pr;
            if (pr != null && pr.MemberId != null)
            {
                if (pr.BF_IsDriver == true)


                    return true;
                else
                    return false;

            }
            else
                return false;
        }

    }
}