using AlibabaSDK.Api;
using AlibabaSDK.Domain;
using AlibabaSDK.Request;
using CommonUtil;
using DbAccess;
using Operater.DAL;
using Operater.DbModel;
using Operater.DTO.TopMessage;
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
using System.Text;
using YouZanSDKStandard.Api;
using YouZanSDKStandard.Api.Request;

namespace TradeInterflow.Handle
{
    public class AliTradeHandle
    {
        private static string _logName = "1688订单处理error";
        public static ISysSqlHelper dbMain = SysSqlHelper.CreateSqlHelper("db_main");
        public static void HandleExecute(string message)
        {
            try
            {
                BaseAliMessage aliMsg = JSONUtil.JsonToObject<BaseAliMessage>(message);
                switch (aliMsg.type)
                {
                    case "ORDER_BUYER_VIEW_BUYER_MAKE":
                        Console.WriteLine("1688创建订单");
                        CreateTradeMsg(aliMsg.data.ToString());
                        break;
                    case "ORDER_BATCH_PAY":
                        Console.WriteLine("1688订单批量支付状态同步消息");
                        BathPayMsg(aliMsg.data.ToString());
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_PAY":
                        Console.WriteLine("1688交易付款（买家视角）");
                        OrderPay(aliMsg.data.ToString());
                        break;
                    case "ORDER_BUYER_VIEW_ANNOUNCE_SENDGOODS":
                        Console.WriteLine("1688订单发货（买家视角");
                        SendGoods(aliMsg.data.ToString());
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_SELLER_CLOSE":
                        Console.WriteLine("1688卖家关闭订单（买家视角）");
                        OrderSaleCnacle(aliMsg.data.ToString());
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_PRICE_MODIFY":
                        Console.WriteLine("1688修改订单价格（买家视角)");
                        PriceModify(aliMsg.data.ToString());
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_SELLER_MODIFY_ADRESS":
                        Console.WriteLine("商家修改订单地址(买家视角)");
                        AddressModify(aliMsg.data.ToString());
                        break;
                    case "LOGISTICS_MAIL_NO_CHANGE":
                        Console.WriteLine("物流单号修改消息");
                        LogisticsChange(aliMsg.data.ToString());
                        break;
                    case "ORDER_BUYER_VIEW_PART_PART_SENDGOODS":
                        Console.WriteLine("1688订单部分发货（买家视角");
                        SendGoods(aliMsg.data.ToString());
                        break;
                    case "LOGISTICS_BUYER_VIEW_TRACE":
                        Console.WriteLine("1688物流单状态变更（买家视角）");
                        LogisticsSend(aliMsg.data.ToString());
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_SUCCESS":
                        Console.WriteLine("1688交易成功（买家视角）");
                        TradeStatusChange(aliMsg.data.ToString(), "交易成功");
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_BUYER_CLOSE":
                        Console.WriteLine("1688买家关闭订单（买家视角）");
                        TradeStatusChange(aliMsg.data.ToString(), "交易关闭");
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_COMFIRM_RECEIVEGOODS":
                        Console.WriteLine("1688订单确认收货（买家视角）");
                        TradeStatusChange(aliMsg.data.ToString(), "确认收货");
                        break;
                    case "ORDER_BUYER_VIEW_ORDER_BUYER_REFUND_IN_SALES":
                        Console.WriteLine("1688商家退款消息");
                        TradeRefundStatus(aliMsg.data.ToString());
                        break;
                }

            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), _logName);
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }

        #region 1688退款状态
        private static void TradeRefundStatus(string message)
        {
            try
            {
                TradeRefundStatusMsg msg = JSONUtil.JsonToObject<TradeRefundStatusMsg>(message);
                YzRefund yzRefund = new YzRefund()
                {
                    AliRefundStatus = msg.currentStatus,
                    AliRefundAction = msg.refundAction
                };
                if (msg.refundAction == "SELLER_AGREE_REFUND")
                {
                    yzRefund.RelationYzRefund = 2;
                    new YzRefundDAL().Update(yzRefund, i => new { i.AliRefundStatus, i.AliRefundAction, i.RelationYzRefund }, t => t.AliRefundId == msg.refundId);
                }
                else
                {
                    new YzRefundDAL().Update(yzRefund, i => new { i.AliRefundStatus, i.AliRefundAction }, t => t.AliRefundId == msg.refundId);
                }

            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688退款状态");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }

        #endregion

        #region 1688订单状态改变
        private static void TradeStatusChange(string message, string statusStr)
        {
            try
            {
                TradeSuccessMsg successMsg = JSONUtil.JsonToObject<TradeSuccessMsg>(message);
                ChangeTradeStatus(successMsg.orderId, successMsg.currentStatus, statusStr);
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688订单状态改变");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }

        #endregion

        #region 物流单状态变更（买家视角）
        private static void LogisticsSend(string message)
        {
            try
            {
                LogisticsSendMsg logisticsSendMsg = JSONUtil.JsonToObject<LogisticsSendMsg>(message);
                foreach (var trd in logisticsSendMsg.OrderLogisticsTracingModel.orderLogsItems)
                {
                    AliLogistics aliLogistics = new AliLogistics()
                    {
                        AliOid = trd.orderEntryId.ToString(),
                        AliTid = trd.orderId.ToString(),
                        CreateTime = DateTime.Now,
                        LogisticsId = logisticsSendMsg.OrderLogisticsTracingModel.logisticsId,
                        CpCode = logisticsSendMsg.OrderLogisticsTracingModel.cpCode,
                        MailNo = logisticsSendMsg.OrderLogisticsTracingModel.mailNo,
                        StatusChanged = logisticsSendMsg.OrderLogisticsTracingModel.statusChanged
                    };
                    var has = new AliLogisticsDAL().GetById(trd.orderEntryId.ToString());
                    if (has.IsNull() || has.AliOid.IsNullOrEmpty())
                    {//新增
                        new AliLogisticsDAL().Insert(aliLogistics);
                    }
                    else
                    {//修改
                        new AliLogisticsDAL().Update(aliLogistics, i => new { i.LogisticsId, i.CpCode, i.MailNo, i.StatusChanged }, t => t.AliOid == trd.orderEntryId.ToString());
                    }
                    if (logisticsSendMsg.OrderLogisticsTracingModel.statusChanged == "CONSIGN")
                    {//发货消息，修改有赞子订单发货状态
                        //var orderRelate = new TradeCreateRelationDAL().ListGet(t => t.AliOid == trd.orderEntryId.ToString());
                        //if (orderRelate.IsNull() || orderRelate.Count == 0)
                        //{
                        //    LogUtil.Info($"1688子订单：{trd.orderEntryId.ToString()},未找到对应有赞子订单信息", "物流单状态变更");
                        //    continue;
                        //}
                        YzOrderinfo yzOrderinfo = new YzOrderinfo()
                        {
                            AliGoodsStatus = 1
                        };
                        new YzOrderinfoDAL().Update(yzOrderinfo, i => new { i.AliGoodsStatus }, t => t.AliOid == trd.orderEntryId.ToString());
                    }
                }
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "物流单状态变更");
                Console.WriteLine("物流单状态变更主线程错误：" + e.ToString());
            }
        }

        #endregion

        #region 1688物流单号修改
        private static void LogisticsChange(string message)
        {
            try
            {
                LogisticsChangeMsg msg = JSONUtil.JsonToObject<LogisticsChangeMsg>(message);
                //获取订单关系
                string reMsg = GetYzTid(msg.MailNoChangeModel.orderLogsItems[0].orderId);
                string Msg = $"1688物流单号修改-1688订单{msg.MailNoChangeModel.orderLogsItems[0].orderId}，对应有赞订单:{reMsg}";
                Msg += $",之前的运单号：{msg.MailNoChangeModel.oldMailNo}，更改后的运单号：{msg.MailNoChangeModel.newMailNo}";
                MessageNotify messageNotify = new MessageNotify()
                {
                    Msg = Msg,
                    Mark = msg.MailNoChangeModel.orderLogsItems[0].orderId,
                    MsgChannel = "1688"
                };
                CommonHandle.RecorderMessage(messageNotify);
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688物流单号修改");
                Console.WriteLine("1688物流单号修改主线程错误：" + e.ToString());
            }
        }

        #endregion

        #region 1688商家修改订单地址
        private static void AddressModify(string message)
        {
            try
            {
                AddressModifyMsg ModifyMsg = JSONUtil.JsonToObject<AddressModifyMsg>(message);
                //获取订单关系
                string msg = GetYzTid(ModifyMsg.orderId);

                MessageNotify messageNotify = new MessageNotify()
                {
                    Msg = $"1688商家修改订单地址-1688订单{ModifyMsg.orderId}，对应有赞订单:{msg}",
                    Mark = ModifyMsg.orderId,
                    MsgChannel = "1688"
                };
                CommonHandle.RecorderMessage(messageNotify);
                //从接口获取订单详情
                AlibabaTradeDetailDomain topTradeInfo = CommonHandle.GetAliTradeDetail(ModifyMsg.orderId);
                if (topTradeInfo.IsNull())
                {
                    return;
                }
                AliTradeinfo aliTradeinfo = new AliTradeinfo()
                {
                    Province = topTradeInfo.nativeLogistics.province,
                    City = topTradeInfo.nativeLogistics.city,
                    Area = topTradeInfo.nativeLogistics.area,
                    Address = topTradeInfo.nativeLogistics.address,
                    Mobile = topTradeInfo.nativeLogistics.mobile,
                    Town = topTradeInfo.nativeLogistics.town
                };
                //修改1688订单收货人信息
                new AliTradeinfoDAL().Update(aliTradeinfo, i => new { i.Province, i.City, i.Area, i.Address, i.Mobile, i.Town }, t => t.Tid == ModifyMsg.orderId);
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688修改订单价格");
                Console.WriteLine("1688修改订单价格主线程错误：" + e.ToString());
            }
        }
        #endregion

        #region 1688修改订单价格
        private static void PriceModify(string message)
        {
            try
            {
                PriceModifyMsg priceModifyMsg = JSONUtil.JsonToObject<PriceModifyMsg>(message);
                //获取订单关系
                string msg = GetYzTid(priceModifyMsg.orderId);
                MessageNotify messageNotify = new MessageNotify()
                {
                    Msg = $"1688商家修改订单价格-1688订单{priceModifyMsg.orderId}，对应有赞订单:{msg}",
                    Mark = priceModifyMsg.orderId,
                    MsgChannel = "1688"
                };
                CommonHandle.RecorderMessage(messageNotify);
                //先删除原1688订单数据
                new AliTradeinfoDAL().Delete(priceModifyMsg.orderId);
                new AliOrderinfoDAL().Delete(t => t.Tid == priceModifyMsg.orderId);
                //重新获取新数据
                TrdeInfoHandle(priceModifyMsg.orderId);
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688修改订单价格");
                Console.WriteLine("1688修改订单价格主线程错误：" + e.ToString());
            }
        }

        #endregion


        #region 1688卖家关闭订单
        private static void OrderSaleCnacle(string message)
        {
            try
            {
                OrderSaleCnacleMsg orderSaleCnacleMsg = JSONUtil.JsonToObject<OrderSaleCnacleMsg>(message);
                ChangeTradeStatus(orderSaleCnacleMsg.orderId, orderSaleCnacleMsg.currentStatus, "交易取消");
                //获取订单关系
              //  string msg = GetYzTid(orderSaleCnacleMsg.orderId);
                //MessageNotify messageNotify = new MessageNotify()
                //{
                //    Msg = $"发货失败-1688订单{orderSaleCnacleMsg.orderId}-商家取消了交易，对应有赞订单：【{msg}】",
                //    Mark = orderSaleCnacleMsg.orderId,
                //    MsgChannel = "1688"
                //};
                //CommonHandle.RecorderMessage(messageNotify);
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688卖家关闭订单");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }

        #endregion

        #region 修改订单状态
        private static void ChangeTradeStatus(string orderId, string currentStatus, string statusStr)
        {
            try
            {
                if (TrdeInfoHandle(orderId))
                {
                    AliTradeinfo aliTradeinfo = new AliTradeinfo()
                    {
                        TradeStatus = currentStatus
                    };
                    new AliTradeinfoDAL().UseTran(() =>
                    {//修改主子订单状态
                        new AliTradeinfoDAL().Update(aliTradeinfo, i => new { i.TradeStatus }, t => t.Tid == orderId);
                        AliOrderinfo aliOrderinfo = new AliOrderinfo()
                        {
                            OrderStatus = currentStatus,
                            StatusStr = statusStr
                        };
                        new AliOrderinfoDAL().Update(aliOrderinfo, i => new { i.OrderStatus, i.StatusStr }, t => t.Tid == orderId);
                    });
                    //修改退款表里1688订单状态
                    YzRefund yzRefund = new YzRefund()
                    {
                        AliTradeStatus = currentStatus
                    };
                    new YzRefundDAL().Update(yzRefund, i => new { i.AliTradeStatus }, t => t.AliTid == orderId);
                }
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "修改订单状态");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }

        #endregion


        #region 1688订单发货
        private static void SendGoods(string message)
        {
            try
            {
                SendGoodsMsg sendGoodsMsg = JSONUtil.JsonToObject<SendGoodsMsg>(message);
                ChangeTradeStatus(sendGoodsMsg.orderId, sendGoodsMsg.currentStatus, "等待买家收货");
                //修改有赞子订单1688订单发货状态
                YzOrderinfo yzOrderinfo = new YzOrderinfo()
                {
                    AliGoodsStatus = 1
                };
                new YzOrderinfoDAL().Update(yzOrderinfo, i => new { i.AliGoodsStatus }, t => t.AliTid == sendGoodsMsg.orderId);
                #region 可调用AliTradeFlowService.AliTradeSendGoods服务
                ////有赞订单发货
                ////获取订单关系
                //var tradeRelat = new TradeRelationDAL().GetById(sendGoodsMsg.orderId);
                //if (tradeRelat.IsNull() || tradeRelat.AliTid.IsNullOrEmpty())
                //{//异常
                //    MessageNotify messageNotify = new MessageNotify()
                //    {
                //        Msg = $"发货失败-订单{sendGoodsMsg.orderId}没有找到对应有赞的订单关系",
                //        Mark = sendGoodsMsg.orderId,
                //        MsgChannel = "1688"
                //    };
                //    CommonHandle.RecorderMessage(messageNotify);
                //    return;
                //}
                ////获取关联的子订单
                //var orderList = new OrderRelationDAL().ListGet(t => t.AliTid == sendGoodsMsg.orderId);
                //if (orderList.IsNull() || orderList.Count == 0)
                //{
                //    MessageNotify messageNotify = new MessageNotify()
                //    {
                //        Msg = $"发货失败-订单{sendGoodsMsg.orderId}没有找到子订单信息",
                //        Mark = sendGoodsMsg.orderId,
                //        MsgChannel = "1688"
                //    };
                //    CommonHandle.RecorderMessage(messageNotify);
                //    return;
                //}
                ////获取1688物流信息
                //AlibabaGetLogisticsInfosRequest alibabaGetLogisticsInfosRequest = new AlibabaGetLogisticsInfosRequest()
                //{
                //    orderId = long.Parse(sendGoodsMsg.orderId),
                //    webSite = "1688",
                //    fields = "company,name,sender,receiver,sendgood"
                //};
                //var alibabaGetLogisticsInfosRes = AliabaClient.Execute(alibabaGetLogisticsInfosRequest, GetAliToken());
                //if (alibabaGetLogisticsInfosRes.IsNull() || !alibabaGetLogisticsInfosRes.Succes || alibabaGetLogisticsInfosRes.result.IsNull())
                //{//获取1688物流信息失败
                //    MessageNotify messageNotify = new MessageNotify()
                //    {
                //        Msg = $"发货失败-订单{sendGoodsMsg.orderId}获取1688物流信息失败：" + (alibabaGetLogisticsInfosRes.IsNull() ? "null" : alibabaGetLogisticsInfosRes.ErrorMsg),
                //        Mark = sendGoodsMsg.orderId,
                //        MsgChannel = "1688"
                //    };
                //    CommonHandle.RecorderMessage(messageNotify);
                //    return;
                //}
                ////获取1688与有赞的快递公司关联关系
                //var expressId = new AliExpressDAL().GetById(alibabaGetLogisticsInfosRes.result.logisticsCompanyId);
                //string outStype = expressId.YzId.ToString();

                ////有赞发货

                ////根据1688子订单获取有赞子订单数据
                //var yzOids = orderList.Where(t => alibabaGetLogisticsInfosRes.result.orderEntryIds.Contains(t.AlisOid)).ToList();
                //if (yzOids.IsNull() || yzOids.Count == 0 || yzOids.Count != alibabaGetLogisticsInfosRes.result.orderEntryIds.Split(',').Length)
                //{
                //    MessageNotify messageNotify = new MessageNotify()
                //    {
                //        Msg = $"发货失败-1688订单{sendGoodsMsg.orderId}获取有赞子订单失败，1688子订单：" + alibabaGetLogisticsInfosRes.result.orderEntryIds,
                //        Mark = sendGoodsMsg.orderId,
                //        MsgChannel = "1688"
                //    };
                //    CommonHandle.RecorderMessage(messageNotify);
                //    return;
                //}
                //var oidArr = yzOids.Select(t => t.YzOid).ToArray();
                //string oids = string.Join(',', oidArr);
                //YouZanLogisticsConfirmRequest yzRequest = new YouZanLogisticsConfirmRequest()
                //{
                //    tid = tradeRelat.YzTid,
                //    out_stype = outStype,
                //    out_sid = alibabaGetLogisticsInfosRes.result.logisticsBillNo,
                //    is_no_express = 0,
                //    oids = oids
                //};
                //var yzResponse = YouZanClient.Execute(yzRequest, GetYzToken());
                //if (yzResponse.IsNull() || !yzResponse.success)
                //{
                //    MessageNotify messageNotify = new MessageNotify()
                //    {
                //        Msg = $"发货失败-1688订单{sendGoodsMsg.orderId}有赞发货失败：" + (yzResponse.IsNull() ? "null" : yzResponse.message),
                //        Mark = sendGoodsMsg.orderId,
                //        MsgChannel = "yz"
                //    };
                //    CommonHandle.RecorderMessage(messageNotify);
                //    return;
                //}
                //LogUtil.Info($"1688订单{sendGoodsMsg.orderId}发货成功：{JSONUtil.ObjectToJson(yzRequest)}", "发货日志");
                //Console.WriteLine("发货成功");
                #endregion
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688订单发货");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }

        #endregion

        #region 1688交易付款（买家视角）

        private static void OrderPay(string message)
        {
            try
            {
                OrderPayMsg orderPayMsg = JSONUtil.JsonToObject<OrderPayMsg>(message);
                ChangeTradeStatus(orderPayMsg.orderId, orderPayMsg.currentStatus, "等待卖家发货");
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688交易付款");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }

        #endregion

        #region 批量支付状态同步消息
        private static void BathPayMsg(string message)
        {
            try
            {
                BathPayMsg msg = JSONUtil.JsonToObject<BathPayMsg>(message);
                foreach (var item in msg.batchPay)
                {

                }
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "批量支付状态同步消息");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }
        #endregion

        #region 创建订单消息
        public static void CreateTradeMsg(string msg)
        {
            try
            {
                AliTradeCreateMsg aliTradeCreateMsg = JSONUtil.JsonToObject<AliTradeCreateMsg>(msg);
                //先处理订单数据
                TrdeInfoHandle(aliTradeCreateMsg.orderId.ToString());
                //if (TrdeInfoHandle(aliTradeCreateMsg.orderId.ToString()))
                //{
                //    //从数据库获取子订单数据，补全子订单关系表
                //    var orderList = new AliOrderinfoDAL().ListGet(t => t.Tid == aliTradeCreateMsg.orderId.ToString());
                //    if (orderList.IsNull() || orderList.Count == 0)
                //    {
                //        return;
                //    }
                //    foreach (var ord in orderList)
                //    {//补全子订单关系表中的1688子订单号
                //        OrderRelation orderRelation = new OrderRelation()
                //        {
                //            AlisOid = ord.Oid
                //        };
                //        var orderRe = new OrderRelationDAL().ListGet(t => t.AliTid == ord.Tid && t.AliSpecid == ord.SpecId);
                //        new OrderRelationDAL().Update(orderRelation, i => new { i.AlisOid }, t => t.AliTid == ord.Tid && t.AliSpecid == ord.SpecId);
                //        //补全有赞子订单表里的1688对应子订单id
                //        YzOrderinfo yzOrderinfo = new YzOrderinfo()
                //        {
                //            AliOid = ord.Oid
                //        };
                //        new YzOrderinfoDAL().Update(yzOrderinfo, i => new { i.AliOid }, t => t.Oid == orderRe[0].YzOid);
                //    }
                //}
            }
            catch (Exception e)
            {
                LogUtil.Info("主线程错误：" + e.ToString(), "1688创建订单消息");
                Console.WriteLine("主线程错误：" + e.ToString());
            }
        }
        #endregion


        #region 处理订单表数据
        private static bool TrdeInfoHandle(string tid)
        {
            try
            {
                //先检查1688订单表数据是否存在
                var dbTradeInfo = new AliTradeinfoDAL().GetById(tid);
                if (!dbTradeInfo.IsNull() && !dbTradeInfo.Tid.IsNullOrEmpty())
                {//数据库中已存在数据
                    return true;
                }
                //从接口获取订单详情
                AlibabaTradeDetailDomain topTradeInfo = CommonHandle.GetAliTradeDetail(tid);
                if (topTradeInfo.IsNull())
                {
                    return false;
                }
                //订单数据入库
                AliTradeinfo aliTradeinfo = new AliTradeinfo()
                {
                    Tid = topTradeInfo.baseInfo.id.ToString(),
                    PayTime = TimeSpanChange(topTradeInfo.baseInfo.payTime),
                    AllDeliveredTime = TimeSpanChange(topTradeInfo.baseInfo.allDeliveredTime),
                    Discount = topTradeInfo.baseInfo.discount / 100,
                    AlipayTradeId = topTradeInfo.baseInfo.alipayTradeId,
                    SumProductPayment = topTradeInfo.baseInfo.sumProductPayment,
                    BuyerFeedback = topTradeInfo.baseInfo.buyerFeedback,
                    BuyerLoginId = topTradeInfo.baseInfo.buyerLoginId,
                    ModifyTime = TimeSpanChange(topTradeInfo.baseInfo.modifyTime),
                    CloseReason = topTradeInfo.baseInfo.closeReason,
                    SellerAlipayId = topTradeInfo.baseInfo.sellerAlipayId,
                    CompleteTime = TimeSpanChange(topTradeInfo.baseInfo.completeTime),
                    SellerLoginid = topTradeInfo.baseInfo.sellerLoginId,
                    BuyerId = topTradeInfo.baseInfo.buyerID,
                    CloseOperateType = topTradeInfo.baseInfo.closeReason,
                    TotalAmount = topTradeInfo.baseInfo.totalAmount,
                    SellerId = topTradeInfo.baseInfo.sellerID,
                    ShippingFee = topTradeInfo.baseInfo.shippingFee,
                    BuyerUserid = topTradeInfo.baseInfo.buyerUserId.ToString(),
                    BuyerMemo = topTradeInfo.baseInfo.buyerMemo,
                    Refund = topTradeInfo.baseInfo.refund,
                    TradeStatus = topTradeInfo.baseInfo.status,
                    RefundPayment = topTradeInfo.baseInfo.refundPayment,
                    CouponFee = topTradeInfo.baseInfo.couponFee,
                    RefundStatus = topTradeInfo.baseInfo.refundStatus,
                    Remark = topTradeInfo.baseInfo.remark,
                    CloseRemark = topTradeInfo.baseInfo.closeRemark,
                    ReceivingTime = TimeSpanChange(topTradeInfo.baseInfo.receivingTime),
                    SellerUserid = topTradeInfo.baseInfo.sellerUserId.ToString(),
                    CreateTime = TimeSpanChange(topTradeInfo.baseInfo.createTime),
                    RefundId = topTradeInfo.baseInfo.refundId,
                    ContactPerson = topTradeInfo.nativeLogistics.contactPerson,
                    Province = topTradeInfo.nativeLogistics.province,
                    City = topTradeInfo.nativeLogistics.city,
                    Area = topTradeInfo.nativeLogistics.area,
                    Address = topTradeInfo.nativeLogistics.address,
                    Mobile = topTradeInfo.nativeLogistics.mobile,
                    Town = topTradeInfo.nativeLogistics.town
                };
                //组装子订单数据
                List<AliOrderinfo> aliOrderinfos = new List<AliOrderinfo>();
                foreach (var ord in topTradeInfo.productItems)
                {
                    AliOrderinfo order = new AliOrderinfo()
                    {
                        Oid = ord.subItemID.ToString(),
                        Tid = topTradeInfo.baseInfo.id.ToString(),
                        ItemAmount = ord.itemAmount,
                        Name = ord.name,
                        Price = ord.price,
                        ProductId = ord.productID.ToString(),
                        ProductImgUrl = ord.productImgUrl[0],
                        ProductSnapshotUrl = ord.productSnapshotUrl,
                        Quantity = ord.quantity,
                        Refund = ord.refund,
                        SkuId = ord.skuID.ToString(),
                        OrderStatus = ord.status,
                        Unit = ord.unit,
                        Weight = ord.weight,
                        WeightUnit = ord.weight_unit,
                        EntryDiscount = ord.entryDiscount / 100,
                        SpecId = ord.specId,
                        StatusStr = ord.statusStr,
                        RefundStatus = ord.refundStatus,
                        CloseReason = ord.closeReason,
                        LogisticsStatus = ord.logisticsStatus,
                        GmtCreate = TimeSpanChange(ord.gmtCreate),
                        GmtModified = TimeSpanChange(ord.gmtModified),
                        GmtCompleted = TimeSpanChange(ord.gmtCompleted),
                        RefundId = ord.refundId,
                        RefundIdForas = ord.refundIdForAs
                    };
                    order.Skuinfos = ord.skuInfos.IsNull() || ord.skuInfos.Count == 0 ? "" : JSONUtil.ObjectToJson(ord.skuInfos);
                    aliOrderinfos.Add(order);
                }
                //使用事务入库处理
                new AliTradeinfoDAL().UseTran(() =>
                {
                    new AliTradeinfoDAL().Insert(aliTradeinfo);
                    new AliOrderinfoDAL().InsertRange(aliOrderinfos);
                });
                return true;
            }
            catch (Exception e)
            {
                LogUtil.Info("处理订单表数据error：" + e.ToString(), _logName);
                Console.WriteLine("处理订单表数据error：" + e.ToString());
            }
            return false;
        }

        #endregion




        #region 1688时间格式转换
        private static DateTime? TimeSpanChange(string timset)
        {
            if (timset.IsNullOrEmpty())
            {
                return null;
            }
            string format = "yyyyMMddHHmmssfffzzz";
            return DateTime.ParseExact(timset, format, CultureInfo.InvariantCulture, DateTimeStyles.None);
        }

        #endregion


        #region 获取1688对应的有赞订单
        private static string GetYzTid(string tid)
        {
            var tradeRelat = new TradeCreateRelationDAL().ListGet(t => t.AliTid == tid);
            string msg = "";
            if (tradeRelat.IsNull() || tradeRelat.Count==0)
            {
                msg = "没有找到对应有赞的订单";
            }
            else
            {
                msg = tradeRelat[0].YzTid;
            }
            return msg;
        }

        #endregion


    }
}