using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using AlibabaSDK.Api;
|
using AlibabaSDK.Request;
|
using CommonUtil;
|
using DbAccess;
|
using Operater.DAL;
|
using Operater.DbModel;
|
using Operater.DTO.TopMessage;
|
using Operater.Service.System;
|
using YouZanSDKStandard.Api;
|
using YouZanSDKStandard.Api.Domain;
|
using YouZanSDKStandard.Api.Request;
|
|
namespace TradeInterflow.Handle
|
{
|
/// <summary>
|
/// 有赞订单处理
|
/// </summary>
|
///
|
public class YzTradeHandle
|
{
|
private static string _logName = "有赞订单处理error";
|
public static ISysSqlHelper dbMain = SysSqlHelper.CreateSqlHelper("db_main");
|
public static void HandleExecute(string message)
|
{
|
try
|
{
|
YouZanMsgModel yzMsgModel = JSONUtil.JsonToObject<YouZanMsgModel>(message);
|
string tradeBody = yzMsgModel.msg.ToUrlDecode();
|
switch (yzMsgModel.type)
|
{
|
case "trade_TradeCreate"://交易创建
|
Console.WriteLine("【有赞】订单创建");
|
TradeCreate(yzMsgModel.id);
|
break;
|
case "trade_TradeBuyerPay":
|
Console.WriteLine("【有赞】买家付款(即商家待发货)");
|
TradeDetailResult tradeInfo = JSONUtil.JsonToObject<TradeDetailResult>(tradeBody);
|
TradeStatusUp(yzMsgModel.id, "WAIT_SELLER_SEND_GOODS", "待发货", tradeInfo.full_order_info.order_info.update_time);
|
break;
|
case "trade_TradeSellerShip":
|
Console.WriteLine("【有赞】卖家发货");
|
TradeStatusUpMsg ship_msg = JSONUtil.JsonToObject<TradeStatusUpMsg>(tradeBody);
|
TradeStatusUp(yzMsgModel.id, "WAIT_BUYER_CONFIRM_GOODS", "已发货", ship_msg.update_time);
|
break;
|
case "trade_TradeSuccess":
|
Console.WriteLine("【有赞】交易成功");
|
TradeStatusUpMsg success_msg = JSONUtil.JsonToObject<TradeStatusUpMsg>(tradeBody);
|
TradeStatusUp(yzMsgModel.id, "TRADE_SUCCESS", "已完成", success_msg.update_time);
|
break;
|
case "trade_TradeClose":
|
Console.WriteLine("【有赞】交易关闭");
|
TradeColse(tradeBody);
|
break;
|
case "trade_refund_BuyerCreated":
|
Console.WriteLine("【有赞】买家发起退款");
|
UpdateRefundStatus(tradeBody, "REFUND_WAIT_SELLER_AGREE");
|
break;
|
case "trade_refund_RefundBuyerReturnGoods":
|
Console.WriteLine("【有赞】买家退货给卖家");
|
UpdateRefundStatus(tradeBody, "REFUND_WAIT_SELLER_CONFIRM_GOODS");
|
break;
|
case "trade_refund_RefundSuccess":
|
Console.WriteLine("【有赞】买家退货成功(终态)");
|
UpdateRefundStatus(tradeBody, "REFUND_SUCCESS");
|
break;
|
case "trade_refund_RefundSellerAgree":
|
Console.WriteLine("【有赞】卖家同意退款（终态）");
|
UpdateRefundStatus(tradeBody, "REFUND_SUCCESS");
|
break;
|
case "trade_refund_RefundSellerRefuse":
|
Console.WriteLine("【有赞】卖家拒绝退款");
|
UpdateRefundStatus(tradeBody, "REFUND_SELLER_REFUSE_BUYER");
|
break;
|
case "trade_refund_RefundClosed":
|
Console.WriteLine("【有赞】买家取消退款");
|
UpdateRefundStatus(tradeBody, "REFUND_CANCLE");
|
break;
|
case "trade_refund_RefundSellerRefuseBuyerReturnGoods":
|
Console.WriteLine("【有赞】卖家拒绝退货");
|
UpdateRefundStatus(tradeBody, "SELLER_REFUSE_BUYER_RETURN_GOODS");
|
break;
|
case "trade_refund_RefundSellerAgreeReturnGoods":
|
Console.WriteLine("【有赞】卖家同意退款退货");
|
UpdateRefundStatus(tradeBody, "WAIT_BUYER_RETURN_GOODS");
|
break;
|
case "trade_refund_YouzanInterApplied":
|
Console.WriteLine("【有赞】买家申请客服介入");
|
//UpdateRefundStatus(tradeBody, "WAIT_BUYER_RETURN_GOODS");
|
break;
|
case "trade_refund_SysRefund":
|
Console.WriteLine("【有赞】一键退款/系统退款");
|
//UpdateRefundStatus(tradeBody, "WAIT_BUYER_RETURN_GOODS");
|
break;
|
case "trade_refund_RefundAgain":
|
Console.WriteLine("【有赞】买家再次发起退款");
|
UpdateRefundStatus(tradeBody, "WAIT_SELLER_AGREE");
|
break;
|
}
|
|
}
|
catch (Exception e)
|
{
|
LogUtil.Info("主线程错误：" + e.ToString(), _logName);
|
}
|
}
|
|
#region 补有赞订单
|
public static void BuHandleExecute(string message)
|
{
|
BuYzTradeMoedel msg = JSONUtil.JsonToObject<BuYzTradeMoedel>(message);
|
if (TradeUpdate(msg.Tid))
|
{//修改订单状态
|
YzTradeinfo yzTradeinfo = new YzTradeinfo()
|
{
|
Status = msg.Status,
|
StatusStr = msg.StatusStr,
|
UpdateTime = msg.UpdateTime
|
};
|
|
new YzTradeinfoDAL().Update(yzTradeinfo, i => new { i.Status, i.StatusStr, i.UpdateTime }, t => t.Tid == msg.Tid);
|
YzOrderinfo yzOrderinfo = new YzOrderinfo()
|
{
|
TradeStatus = msg.Status
|
};
|
new YzOrderinfoDAL().Update(yzOrderinfo, i => new { i.TradeStatus }, t => t.Tid == msg.Tid);
|
}
|
}
|
#endregion
|
|
#region 更新退货状态
|
private static void UpdateRefundStatus(string message, string status)
|
{
|
try
|
{
|
RefundBuerCreateMsg refundMsg = JSONUtil.JsonToObject<RefundBuerCreateMsg>(message);
|
RefundInDb(refundMsg, status);
|
|
}
|
catch (Exception e)
|
{
|
LogUtil.Info("主线程错误：" + e.ToString(), "更新退货状态");
|
}
|
}
|
|
#endregion
|
|
#region yz退款消息入库
|
|
//yz退款消息入库
|
private static bool RefundInDb(RefundBuerCreateMsg msg, string refundStatus)
|
{
|
var refund = new YzRefundDAL().GetById(msg.refund_id);
|
YzRefund yzRefund = new YzRefund()
|
{
|
RefundId = msg.refund_id,
|
YzOid = msg.oids,
|
YzTid = msg.tid,
|
RefundedFee = decimal.Parse(msg.refunded_fee),
|
RefundReason = msg.refund_reason,
|
RefundReasonDesc = msg.refund_reason_desc,
|
RefundType = msg.refund_type,
|
UpdateTime = Convert.ToDateTime(msg.update_time),
|
Version = msg.version.ToString(),
|
YzRefundStaus = refundStatus
|
};
|
yzRefund.RelationYzRefund = refundStatus == "REFUND_WAIT_SELLER_AGREE" ? 0 : refund.RelationYzRefund;
|
|
if (refund.IsNull() || refund.YzOid.IsNullOrEmpty())
|
{//新增
|
//获取1688订单关系
|
var relation = new TradeCreateRelationDAL().GetById(msg.oids);
|
if (!relation.IsNull() && !relation.YzOid.IsNullOrEmpty())
|
{
|
yzRefund.AliTid = relation.AliTid;
|
yzRefund.AliOid = relation.AliOid;
|
}
|
new YzRefundDAL().Insert(yzRefund);
|
}
|
else
|
{//修改
|
yzRefund.RelationYzRefund = refundStatus == "REFUND_WAIT_SELLER_CONFIRM_GOODS" ? 3 : refund.RelationYzRefund;
|
new YzRefundDAL().Update(yzRefund, i => new { i.RefundedFee, i.RefundReason, i.RefundReasonDesc, i.RefundType, i.YzRefundStaus, i.RelationYzRefund, i.UpdateTime, i.Version }, t => t.YzOid == msg.oids);
|
}
|
return true;
|
}
|
|
#endregion
|
|
#region 交易关闭
|
private static void TradeColse(string message)
|
{
|
try
|
{
|
TradeColseMsg tradeColseMsg = JSONUtil.JsonToObject<TradeColseMsg>(message);
|
if (TradeUpdate(tradeColseMsg.tid))
|
{
|
YzTradeinfo yzTradeinfo = new YzTradeinfo()
|
{
|
Status = "TRADE_CLOSED",
|
StatusStr = "已关闭",
|
UpdateTime = tradeColseMsg.update_time,
|
CloseType = tradeColseMsg.close_type
|
};
|
new YzTradeinfoDAL().Update(yzTradeinfo, i => new { i.Status, i.StatusStr, i.UpdateTime, i.CloseType }, t => t.Tid == tradeColseMsg.tid);
|
YzOrderinfo yzOrderinfo = new YzOrderinfo()
|
{
|
TradeStatus = "TRADE_CLOSED"
|
};
|
new YzOrderinfoDAL().Update(yzOrderinfo, i => new { i.TradeStatus }, t => t.Tid == tradeColseMsg.tid);
|
//判断是否已创建1688订单
|
var rela = new TradeRelationDAL().ListGet(t => t.YzTid == tradeColseMsg.tid && t.CreateStatus != 0);
|
if (rela.IsNull() || rela.Count == 0)
|
{
|
return;
|
}
|
//需要取消1688订单
|
foreach (var reTid in rela)
|
{
|
AlibabaTradeCancelRequest req = new AlibabaTradeCancelRequest()
|
{
|
webSite = "1688",
|
tradeID = reTid.AliTid,
|
cancelReason = "buyerCancel"
|
};
|
var rsp = AliabaClient.Execute(req, CommonHandle.GetAliToken());
|
if (rsp.IsNull() || !rsp.Success)
|
{
|
MessageNotify errmessageNotify = new MessageNotify()
|
{
|
Msg = $"有赞订单[{tradeColseMsg.tid}]交易取消，取消1688订单[{reTid.AliTid}]失败:" + (rsp.IsNull() ? "null" : rsp.ErrorMsg),
|
Mark = tradeColseMsg.tid
|
};
|
CommonHandle.RecorderMessage(errmessageNotify);
|
return;
|
}
|
MessageNotify messageNotify = new MessageNotify()
|
{
|
Msg = $"有赞订单[{tradeColseMsg.tid}]交易取消，取消1688订单[{reTid.AliTid}]成功！",
|
Mark = tradeColseMsg.tid
|
};
|
CommonHandle.RecorderMessage(messageNotify);
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
LogUtil.Info("message:" + message + "----" + e.ToString(), "交易关闭");
|
}
|
}
|
|
#endregion
|
|
#region 修改订单状态
|
public static void TradeStatusUp(string tid, string status, string statusStr, DateTime upDateTime)
|
{
|
if (TradeUpdate(tid))
|
{//修改订单状态
|
YzTradeinfo yzTradeinfo = new YzTradeinfo()
|
{
|
Status = status,
|
StatusStr = statusStr,
|
UpdateTime = upDateTime
|
};
|
|
new YzTradeinfoDAL().Update(yzTradeinfo, i => new { i.Status, i.StatusStr, i.UpdateTime }, t => t.Tid == tid);
|
YzOrderinfo yzOrderinfo = new YzOrderinfo()
|
{
|
TradeStatus = status
|
};
|
new YzOrderinfoDAL().Update(yzOrderinfo, i => new { i.TradeStatus }, t => t.Tid == tid);
|
}
|
}
|
#endregion
|
|
#region 订单创建
|
public static void TradeCreate(string tid)
|
{
|
TradeUpdate(tid);
|
}
|
#endregion
|
|
#region 订单更新入库
|
private static bool TradeUpdate(string tid)
|
{
|
//先判断表里是否有订单数据
|
bool isExit = new YzTradeinfoDAL().IsExist(t => t.Tid == tid);
|
if (isExit)
|
{
|
return true;
|
}
|
//订单不存在 从接口获取
|
YouZanTradeDetailGetRequest yzDetail = new YouZanTradeDetailGetRequest()
|
{
|
tid = tid
|
};
|
var yzRsp = YouZanClient.Execute(yzDetail, CommonHandle.GetYzToken());
|
if (yzRsp.IsNull() || !yzRsp.success)
|
{
|
LogUtil.Info("获取有赞订单详情失败：" + tid + "--" + (yzRsp.IsNull() ? "null" : JSONUtil.ObjectToJson(yzRsp)), "有赞处理错误");
|
return false;
|
}
|
//有赞订单解密
|
YzDecryptInfo yzDecryptInfo = new TradeCreateService().DecryptTrade(yzRsp.data.full_order_info, CommonHandle.GetYzToken());
|
var orderInfo = yzRsp.data.full_order_info.order_info;
|
var tradeInfo = yzRsp.data;
|
YzTradeinfo yzTradeinfo = new YzTradeinfo()
|
{
|
Tid = orderInfo.tid,
|
CreateTime = orderInfo.created,
|
YzOpenId = tradeInfo.full_order_info.buyer_info.yz_open_id,
|
OuterUserId = tradeInfo.full_order_info.buyer_info.outer_user_id,
|
PayTime = orderInfo.pay_time,
|
CloseType = orderInfo.close_type,
|
ConfirmTime = orderInfo.confirm_time,
|
ConsignTime = orderInfo.consign_time,
|
ExpiredTime = orderInfo.expired_time,
|
ExpressType = orderInfo.express_type,
|
PayType = orderInfo.pay_type,
|
RefundState = orderInfo.refund_state,
|
Status = orderInfo.status,
|
StatusStr = orderInfo.status_str,
|
SuccessTime = orderInfo.success_time,
|
Type = orderInfo.type,
|
UpdateTime = orderInfo.update_time,
|
BuyerMessage = tradeInfo.full_order_info.remark_info.buyer_message,
|
TradeMemo = tradeInfo.full_order_info.remark_info.trade_memo,
|
Star = tradeInfo.full_order_info.remark_info.star,
|
BuyerPhone = yzDecryptInfo.BuyerPhone,
|
FansNickname = tradeInfo.full_order_info.buyer_info.fans_nickname,
|
FansId = tradeInfo.full_order_info.buyer_info.fans_id.ToString(),
|
DeliveryAddress = yzDecryptInfo.DeliveryAddress,
|
DeliveryCity = tradeInfo.full_order_info.address_info.delivery_city,
|
DeliveryDistrict = tradeInfo.full_order_info.address_info.delivery_district,
|
DeliveryPostalCode = tradeInfo.full_order_info.address_info.delivery_postal_code,
|
DeliveryProvince = tradeInfo.full_order_info.address_info.delivery_province,
|
ReceiverName = yzDecryptInfo.ReceiverName,
|
ReceiverTel = yzDecryptInfo.ReceiverTel,
|
PayTypeStr = orderInfo.pay_type_str,
|
Payment = PriceTran(tradeInfo.full_order_info.pay_info.payment),
|
RealPay = PriceTran(tradeInfo.full_order_info.pay_info.real_payment),
|
PostFee = PriceTran(tradeInfo.full_order_info.pay_info.post_fee),
|
TotalFee = PriceTran(tradeInfo.full_order_info.pay_info.total_fee),
|
AdjustFee = PriceTran(tradeInfo.order_promotion.adjust_fee),
|
};
|
//子订单数据
|
List<YzOrderinfo> oidList = new List<YzOrderinfo>();
|
foreach (var oid in tradeInfo.full_order_info.orders)
|
{
|
decimal payment = oid.payment.IsNullOrEmpty() ? 0 : decimal.Parse(oid.payment);
|
YzOrderinfo yzOrderinfo = new YzOrderinfo()
|
{
|
Oid = oid.oid,
|
Tid = orderInfo.tid,
|
ItemId = oid.item_id.ToString(),
|
IsPreSale = oid.is_pre_sale,
|
Price = decimal.Parse(oid.price),
|
Title = oid.title,
|
SkuNo = oid.sku_no,
|
ItemNo = oid.item_no,
|
TariffRule = oid.tariff_rule,
|
Payment = PriceTran(oid.payment),
|
FenxiaoDiscountPrice = PriceTran(oid.fenxiao_discount_price),
|
ItemProps = oid.item_props,
|
IsPresent = oid.is_present ? 1 : 0,
|
ItemType = oid.item_type,
|
OuterItemId = oid.outer_item_id,
|
OuterSkuId = oid.outer_sku_id,
|
TotalFee = PriceTran(oid.total_fee),
|
SkuId = oid.sku_id.ToString(),
|
CreateTime = orderInfo.created,
|
Num = oid.num,
|
PicPath = oid.pic_path,
|
GoodsUrl = oid.goods_url,
|
DiscountPrice = PriceTran(oid.discount_price),
|
PointsPrice = oid.points_price.IsNullOrEmpty() ? 0 : int.Parse(oid.points_price),
|
SkuPropertiesName = oid.sku_properties_name,
|
Alias = oid.alias,
|
TradeStatus = orderInfo.status
|
};
|
oidList.Add(yzOrderinfo);
|
}
|
new YzTradeinfoDAL().UseTran(() =>
|
{
|
new YzTradeinfoDAL().Insert(yzTradeinfo);
|
new YzOrderinfoDAL().InsertRange(oidList);
|
});
|
return true;
|
}
|
#endregion
|
private static decimal PriceTran(string price)
|
{
|
return price.IsNullOrEmpty() ? 0 : decimal.Parse(price);
|
}
|
|
}
|
}
|
