using CommonUtil;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Operater.DAL;
using Operater.DbModel;
using Operater.DTO.System;
using Operater.Service;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading.Tasks;

namespace Api.Operater.Controllers
{
    [Route(TopConstants.API_ROUTE)]
    public class TradeController : BaseController
    {
        public ITradeCreateService _itradeCreateService;
        public ILoginUserInfoService _iloginUserInfoService;
        public ISendGoodsService _isendGoodsService;

        public TradeController(ITradeCreateService tradeCreateService, ILoginUserInfoService loginUserInfoService, ISendGoodsService sendGoodsService)
        {
            _itradeCreateService = tradeCreateService;
            _iloginUserInfoService = loginUserInfoService;
            _isendGoodsService = sendGoodsService;
        }

        /// <summary>
        /// 创建1688订单
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult CreateAliTrade([FromBody] CreateAliTradeRequest request)
        {
            var userInfo = _iloginUserInfoService.GetUserInfo();
            //查询是否已经创建任务
            var relaHis = new TradeCreateRelationDAL().ListGet(t => t.YzTid == request.YzTid);
            if (!relaHis.IsNull() && relaHis.Count > 0)
            {
                var errorHis = relaHis.Where(t => t.RunStatus == 3).ToList();
                if (errorHis.IsNull() || errorHis.Count == 0)
                {
                    return Error("该有赞订单已经创建了1688订单，请勿重复操作！");
                }
                //失败的任务激活
                TradeCreateRelation tradeCreateRelation = new TradeCreateRelation()
                {
                    RunStatus = 0,
                    Memo = ""
                };
                new TradeCreateRelationDAL().Update(tradeCreateRelation, i => new { i.RunStatus, i.Memo }, t => t.YzTid == request.YzTid && t.RunStatus == 3);
            }
            else
            {//创建订单关系
                var yzOrder = new YzOrderinfoDAL().ListGet(t => t.Tid == request.YzTid);
                List<TradeCreateRelation> relationList = new List<TradeCreateRelation>();
                foreach (var order in yzOrder)
                {
                    TradeCreateRelation relate = new TradeCreateRelation()
                    {
                        YzOid = order.Oid,
                        YzTid = order.Tid,
                        CreatTime = DateTime.Now,
                        RunStatus = 0,
                        TaskId = Guid.NewGuid().ToString()
                    };
                    relationList.Add(relate);
                }
                new TradeCreateRelationDAL().InsertRange(relationList);
            }
            AliTradeCreateRequest re = new AliTradeCreateRequest()
            {
                YzToken = userInfo.YzToken,
                AliToken = userInfo.AlibabaToken,
                YzTradeId = request.YzTid,
                YzShopId=userInfo.YzShopId
            };
            var res = _itradeCreateService.AliTradeCreate(re);
            if (res.Success)
            {
                return Success(true);
            }
            return Error(res.ErrorMsg);
        }

        /// <summary>
        /// 获取有赞订单信息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult ListPageGetYzTrade([FromBody] ListPageGetYzTradeRequest request)
        {
            List<ListPageGetYzTradeRequestResponse> listRsp = new List<ListPageGetYzTradeRequestResponse>();
            var expression = Expressionable.Create<YzTradeinfo>().AndIF(!request.TradeStatus.IsNullOrEmpty(), t => t.Status == request.TradeStatus)
                                                                 .AndIF(!request.Tid.IsNullOrEmpty(), t => t.Tid == request.Tid)
                                                                 .AndIF(!request.ReceiveMobile.IsNullOrEmpty(), t => t.ReceiverTel == request.ReceiveMobile)
                                                                 .ToExpression();
            int totalCount = 0;
            var tradeList = new YzTradeinfoDAL().ListPageGet(expression, t => t.CreateTime, DbEnum.OrderType.Desc, request.PageNo, request.PageSize, ref totalCount);
            if (tradeList.IsNull() || tradeList.Count == 0)
            {
                return Success(listRsp, request.PageNo, request.PageSize, 0);
            }
            var ids = tradeList.Select(i => i.Tid).ToList();
            var orderList = new YzOrderinfoDAL().ListGet(t => ids.Contains(t.Tid));
            foreach (var tradeItem in tradeList)
            {
                var order = orderList.Where(t => t.Tid == tradeItem.Tid).ToList();
                ListPageGetYzTradeRequestResponse rsp = new ListPageGetYzTradeRequestResponse()
                {
                    TradeInfo = tradeItem,
                    OrderInfo = order
                };
                listRsp.Add(rsp);
            }
            return Success(listRsp, request.PageNo, request.PageSize, totalCount);
        }

        /// <summary>
        /// 有赞订单发货
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult SendYzGoods([FromBody] SendYzGoodsRequest request)
        {
            var userInfo = _iloginUserInfoService.GetUserInfo();
            int errorCount = 0;
            foreach (var yzOid in request.YzOid)
            {
                YzSendGoodsRequest yzSendGoodsRequest = new YzSendGoodsRequest()
                {
                    YzOid = yzOid,
                    YzToken = userInfo.YzToken
                };
                var res = _isendGoodsService.YzSendGoods(yzSendGoodsRequest);
                if (!res.IsSuccess)
                {
                    return Error(res.ErrorMsg);
                }
            }
            //if (errorCount > 0)
            //{
            //    return Error(errorCount + "笔子订单发货失败！");
            //}
            return Success(true);
        }


        /// <summary>
        /// 获取待创建/待发货1688订单
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult GetWaiteCreateTrade([FromBody] GetWaiteCreateTradeRequest request)
        {
            List<GetWaiteCreateTradeResponse> response = new List<GetWaiteCreateTradeResponse>();
            string where = $" ali_trade_status='0' AND trade_status='WAIT_SELLER_SEND_GOODS' ";
          
            if (request.SearchType == 1)
            {//获取待发货
                where = $" ali_goods_status='1' and yz_goods_status='0' ";
            }
            where += request.YzTid.IsNullOrEmpty() ? "" : $" and tid='{request.YzTid}' ";

            DataTable countDt = new YzOrderinfoDAL().SearchBySqlDataTable("", $"select count(1) as count from yz_orderinfo where {where}");
            if (countDt.IsNull() || countDt.Rows.Count == 0 || countDt.Rows[0]["count"].ToString() == "0")
            {
                return Success(response, request.PageNo, request.PageSize, 0);
            }
            string searchField = "tid,create_time,pay_time,status,status_str,update_time,delivery_address,delivery_city,delivery_district,delivery_province,receiver_name,receiver_tel,total_fee,payment";

            string searchSql = $"select {searchField} from yz_tradeinfo where tid in (select a.* from (select distinct(tid) as tid from yz_orderinfo where {where} order by create_time desc limit {request.PageSize} offset {(request.PageNo - 1) * request.PageSize}) a)";
            DataTable TidDt = new YzOrderinfoDAL().SearchBySqlDataTable("", searchSql);
            if (TidDt.IsNull() || TidDt.Rows.Count == 0)
            {
                return Success(response, request.PageNo, request.PageSize, 0);
            }
            //var orders = new YzOrderinfoDAL().ListPageGet(t => t.AliTradeStatus == 0, t => t.CreateTime, DbEnum.OrderType.Desc, t => t.Tid, request.PageNo, request.PageSize, ref totalCount).Select(t => t.Tid);

            foreach (DataRow tid in TidDt.Rows)
            {
                var expression = Expressionable.Create<YzOrderinfo>().And(t => t.Tid == tid["tid"].ToString())
                                                                  .AndIF(request.SearchType == 0, t => t.AliTradeStatus == 0)
                                                                .AndIF(request.SearchType == 1, t => t.AliTradeStatus == 1)
                                                                .ToExpression();
                var oids = new YzOrderinfoDAL().ListGet(expression);
                DateTime? paytime;
                if (tid["pay_time"].IsNull() || tid["pay_time"].ToString().IsNullOrEmpty())
                {
                    paytime = null;
                }
                else
                {
                    paytime = Convert.ToDateTime(tid["pay_time"].ToString());
                }
                string ss = tid["pay_time"] == null ? "" : "";
                GetWaiteCreateTradeResponse resItem = new GetWaiteCreateTradeResponse()
                {
                    Tid = tid["tid"].ToString(),
                    create_time = Convert.ToDateTime(tid["create_time"].ToString()),
                    pay_time = paytime,
                    status_str = tid["status_str"].ToString(),
                    update_time = Convert.ToDateTime(tid["update_time"].ToString()),
                    delivery_address = tid["delivery_address"].ToString(),
                    delivery_city = tid["delivery_city"].ToString(),
                    delivery_district = tid["delivery_district"].ToString(),
                    delivery_province = tid["delivery_province"].ToString(),
                    receiver_name = tid["receiver_name"].ToString(),
                    receiver_tel = tid["receiver_tel"].ToString(),
                    total_fee = tid["total_fee"].ToString(),
                    payment = tid["payment"].ToString(),
                    Orders = oids
                };
                response.Add(resItem);
            }


            return Success(response, request.PageNo, request.PageSize, int.Parse(countDt.Rows[0]["count"].ToString()));
        }
    }
}