1222 lines
78 KiB
C#
1222 lines
78 KiB
C#
|
using Api.Framework.Enums;
|
|||
|
|
using Api.Framework.Model;
|
|||
|
|
using Api.Framework.SDK;
|
|||
|
|
using Api.Framework.Utils;
|
|||
|
|
using CsharpHttpHelper;
|
|||
|
|
using SqlSugar;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Data;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
using static Api.Framework.Cps.AlimamaApi;
|
|||
|
|
|
|||
|
|
namespace Api.Framework.Tools
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 变量替换
|
|||
|
|
/// </summary>
|
|||
|
|
public class VariateReplace
|
|||
|
|
{
|
|||
|
|
private static List<string> pddlist = new List<string>() { "[拼多多待结算数量]", "[拼多多待结算金额]", "[拼多多冻结金额]", "[拼多多冻结订单数]", "[拼多多未收货金额]", "[拼多多未收货订单数]" };
|
|||
|
|
private static List<string> tblist = new List<string>() { "[淘宝待结算数量]", "[淘宝待结算金额]", "[淘宝冻结金额]", "[淘宝冻结订单数]", "[淘宝未收货金额]", "[淘宝未收货订单数]" };
|
|||
|
|
private static List<string> jdlist = new List<string>() { "[京东待结算数量]", "[京东待结算金额]", "[京东冻结金额]", "[京东冻结订单数]", "[京东未收货金额]", "[京东未收货订单数]" };
|
|||
|
|
private static List<string> wphlist = new List<string>() { "[唯品会待结算数量]", "[唯品会待结算金额]", "[唯品会冻结金额]", "[唯品会冻结订单数]", "[唯品会未收货金额]", "[唯品会未收货订单数]" };
|
|||
|
|
private static List<string> dylist = new List<string>() { "[抖音待结算数量]", "[抖音待结算金额]", "[抖音冻结金额]", "[抖音冻结订单数]", "[抖音未收货金额]", "[抖音未收货订单数]" };
|
|||
|
|
private static List<string> snlist = new List<string>() { "[苏宁待结算数量]", "[苏宁待结算金额]", "[苏宁冻结金额]", "[苏宁冻结订单数]", "[苏宁未收货金额]", "[苏宁未收货订单数]" };
|
|||
|
|
private static List<string> kslist = new List<string>() { "[快手待结算数量]", "[快手待结算金额]", "[快手冻结金额]", "[快手冻结订单数]", "[快手未收货金额]", "[快手未收货订单数]" };
|
|||
|
|
private static List<string> list = new List<string>() { "[待结算总数数量]", "[待结算总数金额]", "[待收货积分]", "[未收货积分]", "[未收货总金额]", "[待结算积分]", "[冻结总金额]", "[待收货订单数]", "[未收货订单数]", "[待结算订单数]", "[冻结订单数]" };
|
|||
|
|
|
|||
|
|
|
|||
|
|
StringBuilder mess = null;
|
|||
|
|
private object lock_replace = new object();
|
|||
|
|
private void Replace(string key, string value)
|
|||
|
|
{
|
|||
|
|
if (mess != null)
|
|||
|
|
{
|
|||
|
|
lock (lock_replace) mess = mess.Replace(key, value);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 通用替换变量
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="_mess">替换的内容</param>
|
|||
|
|
/// <param name="objs">与变量有关联的对象</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public string CommonReplace(string _mess, params object[] objs)
|
|||
|
|
{
|
|||
|
|
if (string.IsNullOrEmpty(_mess)) return string.Empty;
|
|||
|
|
mess = new StringBuilder(_mess);
|
|||
|
|
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Replace("[积分名称]", ApiClient.Setting.SystemConfig.PointName);
|
|||
|
|
List<Action> actions = new List<Action>();
|
|||
|
|
|
|||
|
|
//List<Task> tasks = new List<Task>();
|
|||
|
|
foreach (var item in objs)
|
|||
|
|
{
|
|||
|
|
var type = item.GetType();
|
|||
|
|
if (type == typeof(fl_order_alimama))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_alimama;
|
|||
|
|
|
|||
|
|
Replace("[订单号]", order.trade_parent_id);
|
|||
|
|
Replace("[商品标题]", order.item_title);
|
|||
|
|
Replace("[子订单号]", order.trade_id);
|
|||
|
|
Replace("[付款金额]", order.alipay_total_price.ToString());
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
|
|||
|
|
#region [原始返利积分] [维权金额] 淘宝变量
|
|||
|
|
if (order != null)
|
|||
|
|
{
|
|||
|
|
var session = ApiClient.GetSession();
|
|||
|
|
if (_mess.Contains("[维权金额]"))
|
|||
|
|
{
|
|||
|
|
var refund_alimama = session.Find<fl_order_refund_alimama>("select * from fl_order_refund_alimama where tbtradeparentid = @tbtradeparentid and tbtradeid = @tbtradeid", new { tbtradeparentid = order.trade_parent_id, tbtradeid = order.trade_id }).FirstOrDefault();
|
|||
|
|
if (refund_alimama != null)
|
|||
|
|
Replace("[维权金额]", refund_alimama.refundfee.ToString());
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (_mess.Contains("[原始返利积分]"))
|
|||
|
|
{
|
|||
|
|
if (order.db_userid != 0)
|
|||
|
|
{
|
|||
|
|
var member = session.FindMemberInfoById(order.db_userid);
|
|||
|
|
if (member != null)
|
|||
|
|
{
|
|||
|
|
////获取历史的增加积分
|
|||
|
|
//var pointHists = session.Find<fl_point_hist>("select * from fl_point_hist where uid = @uid and type = @pointType_name and message = @message", new { uid = order.db_userid, pointType_name = PointType.消费补贴, message = $"淘宝购买：{order.item_title} - ({order.trade_parent_id}) - ({order.trade_id})" });
|
|||
|
|
|
|||
|
|
//var histAddPoint = 0d;
|
|||
|
|
////if (pointHists != null && pointHists.Count == 1)
|
|||
|
|
//if (pointHists != null && pointHists.Count != 0)
|
|||
|
|
//{
|
|||
|
|
// pointHists = pointHists.OrderByDescending(f => f.crt_time).ToList();
|
|||
|
|
// histAddPoint = pointHists[0].point;
|
|||
|
|
//}
|
|||
|
|
//if (histAddPoint != 0)
|
|||
|
|
//{
|
|||
|
|
// Replace("[原始返利积分]", histAddPoint.ToString("0.00"));
|
|||
|
|
//}
|
|||
|
|
//else
|
|||
|
|
//{
|
|||
|
|
// var itempoint = session.FindItemPoint(member, (double)(Math.Round((decimal)order.alipay_total_price * (decimal)order.income_rate, 2, MidpointRounding.AwayFromZero)), order.item_num, CpsType.阿里妈妈);//重新计算阿里妈妈给的佣金
|
|||
|
|
// if (itempoint != null)
|
|||
|
|
// {
|
|||
|
|
// Replace("[原始返利积分]", itempoint.UserPoint.ToString());
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
var isReplace = false;
|
|||
|
|
var rhPoint = session.FindRefundHistPoint(order.trade_parent_id, order.trade_id, CpsType.阿里妈妈);
|
|||
|
|
if (rhPoint != null)
|
|||
|
|
{
|
|||
|
|
//获取积分信息
|
|||
|
|
var point = HttpHelper.JsonToObject<ItemPoint>(rhPoint.db_point) as ItemPoint;
|
|||
|
|
if (point != null)
|
|||
|
|
{
|
|||
|
|
Replace("[原始返利积分]", point.UserPoint.ToString("0.00"));
|
|||
|
|
isReplace = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (!isReplace)
|
|||
|
|
{
|
|||
|
|
#region 其他方案
|
|||
|
|
//获取历史的增加积分
|
|||
|
|
var pointHists = session.Find<fl_point_hist>("select * from fl_point_hist where uid = @uid and type = @pointType_name and message = @message", new { uid = order.db_userid, pointType_name = PointType.消费补贴.ToString(), message = $"淘宝购买：{order.item_title} - ({order.trade_parent_id}) - ({order.trade_id})" });
|
|||
|
|
|
|||
|
|
var histAddPoint = 0d;
|
|||
|
|
//if (pointHists != null && pointHists.Count == 1)
|
|||
|
|
if (pointHists != null && pointHists.Count != 0)
|
|||
|
|
{
|
|||
|
|
pointHists = pointHists.OrderByDescending(f => f.crt_time).ToList();
|
|||
|
|
histAddPoint = pointHists[0].point;
|
|||
|
|
}
|
|||
|
|
if (histAddPoint != 0)
|
|||
|
|
{
|
|||
|
|
Replace("[原始返利积分]", histAddPoint.ToString("0.00"));
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
var itempoint = session.FindItemPoint(member, (double)(Math.Round((decimal)order.alipay_total_price * (decimal)order.income_rate, 2, MidpointRounding.AwayFromZero)), order.item_num, CpsType.阿里妈妈);//重新计算阿里妈妈给的佣金
|
|||
|
|
if (itempoint != null)
|
|||
|
|
{
|
|||
|
|
Replace("[原始返利积分]", itempoint.UserPoint.ToString());
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
Replace("[原始返利积分]", "0.00");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
if (type == typeof(fl_order_jingdong))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_jingdong;
|
|||
|
|
Replace("[订单号]", order.orderId.ToString());
|
|||
|
|
Replace("[商品标题]", order.skuName);
|
|||
|
|
Replace("[付款金额]", order.estimateCosPrice.ToString());
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
}
|
|||
|
|
if (type == typeof(fl_order_pinduoduo))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_pinduoduo;
|
|||
|
|
Replace("[订单号]", order.order_sn);
|
|||
|
|
Replace("[商品标题]", order.goods_name);
|
|||
|
|
Replace("[付款金额]", order.order_amount.ToString());
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
}
|
|||
|
|
if (type == typeof(fl_order_douyin))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_douyin;
|
|||
|
|
Replace("[订单号]", order.order_id);
|
|||
|
|
Replace("[商品标题]", order.product_name);
|
|||
|
|
Replace("[付款金额]", Util.ConvertDouble_FenToYuan(order.total_pay_amount).ToString("0.00"));
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
}
|
|||
|
|
if (type == typeof(fl_order_weipinhui))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_weipinhui;
|
|||
|
|
Replace("[订单号]", order.orderSn);
|
|||
|
|
Replace("[商品标题]", order.goodsName);
|
|||
|
|
Replace("[付款金额]", order.goodsFinalPrice.ToString());
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
}
|
|||
|
|
if (type == typeof(fl_order_douyin))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_douyin;
|
|||
|
|
Replace("[订单号]", order.order_id);
|
|||
|
|
Replace("[商品标题]", order.product_name);
|
|||
|
|
Replace("[付款金额]", Util.ConvertDouble_FenToYuan(order.total_pay_amount).ToString());
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
}
|
|||
|
|
if (type == typeof(fl_order_suning))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_suning;
|
|||
|
|
Replace("[订单号]", order.orderCode);
|
|||
|
|
Replace("[商品标题]", order.productName);
|
|||
|
|
Replace("[付款金额]", Util.ConvertDouble_FenToYuan((int)(double.Parse(order.payAmount) * 100)).ToString("0.00"));
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
}
|
|||
|
|
if (type == typeof(fl_order_kuaishou))
|
|||
|
|
{
|
|||
|
|
var order = item as fl_order_kuaishou;
|
|||
|
|
Replace("[订单号]", order.oid.ToString());
|
|||
|
|
Replace("[商品标题]", order.itemTitle);
|
|||
|
|
Replace("[付款金额]", order.paymentFee.ToString("0.00"));
|
|||
|
|
Replace("[结算时间]", order.db_endtime.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[下级订单状态]", order.db_status.ToString());
|
|||
|
|
}
|
|||
|
|
else if (type == typeof(fl_robot_info))
|
|||
|
|
{
|
|||
|
|
var robot = item as fl_robot_info;
|
|||
|
|
Replace("[机器人账号]", robot.name);
|
|||
|
|
Replace("[机器人昵称]", robot.nick);
|
|||
|
|
}
|
|||
|
|
else if (type == typeof(fl_member_info))
|
|||
|
|
{
|
|||
|
|
var session = ApiClient.GetSession();
|
|||
|
|
var member = item as fl_member_info;
|
|||
|
|
if (_mess.Contains("[上级昵称]"))
|
|||
|
|
{
|
|||
|
|
var m = session.FindMemberInfoById(member.inviter_id);
|
|||
|
|
if (m != null)
|
|||
|
|
Replace("[上级昵称]", m.realnick);
|
|||
|
|
else
|
|||
|
|
Replace("[上级昵称]", "无");
|
|||
|
|
}
|
|||
|
|
Replace("[消费者昵称]", member.realnick);
|
|||
|
|
Replace("[限制兑换时间]", member.ban_exchange_time.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
Replace("[可兑换积分]", "[剩余积分]");
|
|||
|
|
Replace("[剩余积分]", member.cur_point.ToString());
|
|||
|
|
Replace("[账号]", member.username);
|
|||
|
|
Replace("[昵称]", member.realnick);
|
|||
|
|
Replace("[累计积分]", member.sum_point.ToString());
|
|||
|
|
Replace("[提成积分]", member.ext_point.ToString());
|
|||
|
|
Replace("[其他积分]", member.rew_point.ToString());
|
|||
|
|
Replace("[消费积分]", member.buy_point.ToString());
|
|||
|
|
Replace("[推广积分]", ((decimal)member.rew_point + (decimal)member.ext_point).ToString());
|
|||
|
|
Replace("[支付宝账号]", member.alipay_num);
|
|||
|
|
Replace("[支付宝姓名]", member.alipay_name);
|
|||
|
|
Replace("[身份证号]", member.identity_card);
|
|||
|
|
Replace("[身份证号码]", member.identity_card);
|
|||
|
|
Replace("[姓名]", member.identity_name);
|
|||
|
|
Replace("[身份证姓名]", member.identity_name);
|
|||
|
|
Replace("[平台类型]", member.robot_type.ToString());
|
|||
|
|
|
|||
|
|
#region 今日订单信息/已退款订单数/今日总积分/已退款积分
|
|||
|
|
if (_mess.Contains("[订单总数]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var data = session1.FindRow($@"select COALESCE(SUM(num),0) as num from (
|
|||
|
|
select count(*) as num from fl_order_alimama where db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_pinduoduo where db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_jingdong where db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_weipinhui where db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_suning where db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_douyin where db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_kuaishou where db_userid = @userid
|
|||
|
|
) as temp", new { userid = member.id });
|
|||
|
|
Replace("[订单总数]", data["num"].ToString());
|
|||
|
|
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"订单总数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[今日总订单]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var data = session1.FindRow($@"select COALESCE(SUM(num),0) as num from (
|
|||
|
|
select count(*) as num from fl_order_alimama where @begin_time < create_time and create_time <= @end_time and db_userid = @userid
|
|||
|
|
UNION All
|
|||
|
|
select count(*) as num from fl_order_pinduoduo where @begin_time < order_create_time and order_create_time <= @end_time and db_userid = @userid
|
|||
|
|
UNION All
|
|||
|
|
select count(*) as num from fl_order_jingdong where @begin_time < orderTime and orderTime <= @end_time and db_userid = @userid
|
|||
|
|
UNION All
|
|||
|
|
select count(*) as num from fl_order_suning where @begin_time < orderSubmitTime and orderSubmitTime <= @end_time and db_userid = @userid
|
|||
|
|
UNION All
|
|||
|
|
select count(*) as num from fl_order_weipinhui where @begin_time1 < orderTime and orderTime <= @end_time1 and db_userid = @userid
|
|||
|
|
UNION All
|
|||
|
|
select count(*) as num from fl_order_douyin where @begin_time2 < pay_time and pay_time <= @end_time2 and db_userid = @userid
|
|||
|
|
UNION All
|
|||
|
|
select count(*) as num from fl_order_kuaishou where @begin_time < payTime and payTime <= @end_time and db_userid = @userid
|
|||
|
|
) as temp", new
|
|||
|
|
{
|
|||
|
|
begin_time = DateTime.Today.AddSeconds(-1).ToString("yyyy-MM-dd HH:mm:ss"),
|
|||
|
|
end_time = DateTime.Today.AddDays(1).AddSeconds(-1).ToString("yyyy-MM-dd HH:mm:ss"),
|
|||
|
|
begin_time1 = Util.GetTimeSpan(DateTime.Today.AddSeconds(-1), true),
|
|||
|
|
end_time1 = Util.GetTimeSpan(DateTime.Today.AddDays(1).AddSeconds(-1), true),
|
|||
|
|
begin_time2 = Util.GetTimeSpan(DateTime.Today.AddSeconds(-1), false),
|
|||
|
|
end_time2 = Util.GetTimeSpan(DateTime.Today.AddDays(1).AddSeconds(-1), false),
|
|||
|
|
userid = member.id
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
Replace("[今日总订单]", data["num"].ToString());
|
|||
|
|
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"今日总订单:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[已退款订单数]"))
|
|||
|
|
{
|
|||
|
|
Replace("[已退款订单数]", FindOrderInfoByState(999, member.id, OrderStateType.退款订单数));
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[今日总积分]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var result = session1.FindRow($@"select COALESCE(SUM(num),0) as num from (
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_alimama where @begin_time < create_time and create_time <= @end_time and db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_pinduoduo where @begin_time < order_create_time and order_create_time <= @end_time and db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_jingdong where @begin_time < orderTime and orderTime <= @end_time and db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_suning where @begin_time < orderSubmitTime and orderSubmitTime <= @end_time and db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_weipinhui where @begin_time1 < orderTime and orderTime <= @end_time1 and db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_douyin where @begin_time2 < pay_time and pay_time <= @end_time2 and db_userid = @userid
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_kuaishou where @begin_time < payTime and payTime <= @end_time and db_userid = @userid
|
|||
|
|
) as temp", new
|
|||
|
|
{
|
|||
|
|
begin_time = DateTime.Today.AddSeconds(-1).ToString("yyyy-MM-dd HH:mm:ss"),
|
|||
|
|
end_time = DateTime.Today.AddDays(1).AddSeconds(-1).ToString("yyyy-MM-dd HH:mm:ss"),
|
|||
|
|
begin_time1 = Util.GetTimeSpan(DateTime.Today.AddSeconds(-1), true),
|
|||
|
|
end_time1 = Util.GetTimeSpan(DateTime.Today.AddDays(1).AddSeconds(-1), true),
|
|||
|
|
begin_time2 = Util.GetTimeSpan(DateTime.Today.AddSeconds(-1), false),
|
|||
|
|
end_time2 = Util.GetTimeSpan(DateTime.Today.AddDays(1).AddSeconds(-1), false),
|
|||
|
|
userid = member.id
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
Replace("[今日总积分]", double.Parse(result["num"].ToString()).ToString());
|
|||
|
|
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"今日总积分:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[已退款积分]"))
|
|||
|
|
Replace("[已退款积分]", FindOrderInfoByState(999, member.id, OrderStateType.退款总金额));
|
|||
|
|
if (_mess.Contains("[已兑换积分]") || _mess.Contains("[已兑换总额]"))
|
|||
|
|
{
|
|||
|
|
Replace("[已兑换总额]", "[已兑换积分]");
|
|||
|
|
Replace("[已兑换积分]", FindAlreadyExchange(member.id));
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[兑换中积分]"))
|
|||
|
|
Replace("[兑换中积分]", session.FindRow($"select COALESCE(SUM(point),0) as num from fl_exchange_info where uid = @uid and state = 1", new { uid = member.id })["num"].ToString());
|
|||
|
|
if (_mess.Contains("[下级总提成]"))
|
|||
|
|
Replace("[下级总提成]", member.ext_point.ToString("0.00"));
|
|||
|
|
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 各种订单金额数量查询
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
//[拼多多待结算数量]、[拼多多待结算金额]、[淘宝待结算数量]、[淘宝待结算金额]、[京东待结算数量]、[京东待结算金额]、[待结算总数数量]、[待结算总数金额]、[淘宝售后中订单数]、[京东售后中订单数]
|
|||
|
|
decimal pddPendingPoint_sleep, pddPendingPoint_pay, pddPendingPoint, alimamaPendingPoint_sleep, alimamaPendingPoint_pay, alimamaPendingPoint, jdPendingPoint_sleep, jdPendingPoint_pay, jdPendingPoint, wphPendingPoint_sleep, wphPendingPoint_pay, wphPendingPoint, dyPendingPoint_sleep, dyPendingPoint_pay, dyPendingPoint, snPendingPoint_sleep, snPendingPoint_pay, snPendingPoint, ksPendingPoint_sleep, ksPendingPoint_pay, ksPendingPoint, sumPendingPoint;
|
|||
|
|
|
|||
|
|
pddPendingPoint_sleep = pddPendingPoint_pay = pddPendingPoint = alimamaPendingPoint_sleep = alimamaPendingPoint_pay = alimamaPendingPoint = jdPendingPoint_sleep = jdPendingPoint_pay = jdPendingPoint = wphPendingPoint_sleep = wphPendingPoint_pay = wphPendingPoint = dyPendingPoint_sleep = dyPendingPoint_pay = dyPendingPoint = snPendingPoint_sleep = snPendingPoint_pay = snPendingPoint = ksPendingPoint_sleep = ksPendingPoint_pay = ksPendingPoint = sumPendingPoint = 0m;
|
|||
|
|
|
|||
|
|
int pddPendingCount_sleep, pddPendingCount_pay, pddPendingCount, alimamaPendingCount_sleep, alimamaPendingCount_pay, alimamaPendingCount, jdPendingCount_sleep, jdPendingCount_pay, jdPendingCount, wphPendingCount_sleep, wphPendingCount_pay, wphPendingCount, dyPendingCount_sleep, dyPendingCount_pay, dyPendingCount, snPendingCount_sleep, snPendingCount_pay, snPendingCount, ksPendingCount_sleep, ksPendingCount_pay, ksPendingCount, sumPendingCount, alimamaReturnNum, jingdongReturnNum, weipinhuiReturnNum, douyinReturnNum, suningReturnNum, kuaishouReturnNum;
|
|||
|
|
|
|||
|
|
pddPendingCount_sleep = pddPendingCount_pay = pddPendingCount = alimamaPendingCount_sleep = alimamaPendingCount_pay = alimamaPendingCount = jdPendingCount_sleep = jdPendingCount_pay = jdPendingCount = wphPendingCount_sleep = wphPendingCount_pay = wphPendingCount = dyPendingCount_sleep = dyPendingCount_pay = dyPendingCount = snPendingCount_sleep = snPendingCount_pay = snPendingCount = ksPendingCount_sleep = ksPendingCount_pay = ksPendingCount = sumPendingCount = alimamaReturnNum = jingdongReturnNum = weipinhuiReturnNum = douyinReturnNum = suningReturnNum = kuaishouReturnNum = 0;
|
|||
|
|
|
|||
|
|
Dictionary<string, decimal> pddDic = null;
|
|||
|
|
Dictionary<string, decimal> tbDic = null;
|
|||
|
|
Dictionary<string, decimal> jdDic = null;
|
|||
|
|
Dictionary<string, decimal> wphDic = null;
|
|||
|
|
Dictionary<string, decimal> dyDic = null;
|
|||
|
|
Dictionary<string, decimal> snDic = null;
|
|||
|
|
Dictionary<string, decimal> ksDic = null;
|
|||
|
|
|
|||
|
|
if (pddlist.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
pddDic = FindOrderTotalInfo("fl_order_pinduoduo", member.id);
|
|||
|
|
if (pddDic != null)
|
|||
|
|
{
|
|||
|
|
pddPendingPoint_sleep = pddDic["point_sleep"];
|
|||
|
|
pddPendingCount_sleep = (int)pddDic["count_sleep"];
|
|||
|
|
pddPendingPoint_pay = pddDic["point_pay"];
|
|||
|
|
pddPendingCount_pay = (int)pddDic["count_pay"];
|
|||
|
|
pddPendingPoint = pddDic["point"];
|
|||
|
|
pddPendingCount = (int)pddDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"A_pinduoduo:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (tblist.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
tbDic = FindOrderTotalInfo("fl_order_alimama", member.id);
|
|||
|
|
if (tbDic != null)
|
|||
|
|
{
|
|||
|
|
alimamaPendingPoint_sleep = tbDic["point_sleep"];
|
|||
|
|
alimamaPendingCount_sleep = (int)tbDic["count_sleep"];
|
|||
|
|
alimamaPendingPoint_pay = tbDic["point_pay"];
|
|||
|
|
alimamaPendingCount_pay = (int)tbDic["count_pay"];
|
|||
|
|
alimamaPendingPoint = tbDic["point"];
|
|||
|
|
alimamaPendingCount = (int)tbDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"A_alimama:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (jdlist.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
jdDic = FindOrderTotalInfo("fl_order_jingdong", member.id);
|
|||
|
|
if (jdDic != null)
|
|||
|
|
{
|
|||
|
|
jdPendingPoint_sleep = jdDic["point_sleep"];
|
|||
|
|
jdPendingCount_sleep = (int)jdDic["count_sleep"];
|
|||
|
|
jdPendingPoint_pay = jdDic["point_pay"];
|
|||
|
|
jdPendingCount_pay = (int)jdDic["count_pay"];
|
|||
|
|
jdPendingPoint = jdDic["point"];
|
|||
|
|
jdPendingCount = (int)jdDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"A_jingdong:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (wphlist.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
wphDic = FindOrderTotalInfo("fl_order_weipinhui", member.id);
|
|||
|
|
if (wphDic != null)
|
|||
|
|
{
|
|||
|
|
wphPendingPoint_sleep = wphDic["point_sleep"];
|
|||
|
|
wphPendingCount_sleep = (int)wphDic["count_sleep"];
|
|||
|
|
wphPendingPoint_pay = wphDic["point_pay"];
|
|||
|
|
wphPendingCount_pay = (int)wphDic["count_pay"];
|
|||
|
|
wphPendingPoint = wphDic["point"];
|
|||
|
|
wphPendingCount = (int)wphDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"A_weipinhui:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (dylist.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
dyDic = FindOrderTotalInfo("fl_order_douyin", member.id);
|
|||
|
|
if (dyDic != null)
|
|||
|
|
{
|
|||
|
|
dyPendingPoint_sleep = dyDic["point_sleep"];
|
|||
|
|
dyPendingCount_sleep = (int)dyDic["count_sleep"];
|
|||
|
|
dyPendingPoint_pay = dyDic["point_pay"];
|
|||
|
|
dyPendingCount_pay = (int)dyDic["count_pay"];
|
|||
|
|
dyPendingPoint = dyDic["point"];
|
|||
|
|
dyPendingCount = (int)dyDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"A_douyin:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (snlist.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
snDic = FindOrderTotalInfo("fl_order_suning", member.id);
|
|||
|
|
if (snDic != null)
|
|||
|
|
{
|
|||
|
|
snPendingPoint_sleep = snDic["point_sleep"];
|
|||
|
|
snPendingCount_sleep = (int)snDic["count_sleep"];
|
|||
|
|
snPendingPoint_pay = snDic["point_pay"];
|
|||
|
|
snPendingCount_pay = (int)snDic["count_pay"];
|
|||
|
|
snPendingPoint = snDic["point"];
|
|||
|
|
snPendingCount = (int)snDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"A_suning:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (kslist.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
ksDic = FindOrderTotalInfo("fl_order_kuaishou", member.id);
|
|||
|
|
if (ksDic != null)
|
|||
|
|
{
|
|||
|
|
ksPendingPoint_sleep = ksDic["point_sleep"];
|
|||
|
|
ksPendingCount_sleep = (int)ksDic["count_sleep"];
|
|||
|
|
ksPendingPoint_pay = ksDic["point_pay"];
|
|||
|
|
ksPendingCount_pay = (int)ksDic["count_pay"];
|
|||
|
|
ksPendingPoint = ksDic["point"];
|
|||
|
|
ksPendingCount = (int)ksDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"A_suning:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
if (list.FirstOrDefault(f => _mess.Contains(f)) != null)
|
|||
|
|
{
|
|||
|
|
if (pddDic == null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
pddDic = FindOrderTotalInfo("fl_order_pinduoduo", member.id);
|
|||
|
|
if (pddDic != null)
|
|||
|
|
{
|
|||
|
|
pddPendingPoint_sleep = pddDic["point_sleep"];
|
|||
|
|
pddPendingCount_sleep = (int)pddDic["count_sleep"];
|
|||
|
|
pddPendingPoint_pay = pddDic["point_pay"];
|
|||
|
|
pddPendingCount_pay = (int)pddDic["count_pay"];
|
|||
|
|
pddPendingPoint = pddDic["point"];
|
|||
|
|
pddPendingCount = (int)pddDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"B_pinduoduo:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (tbDic == null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
tbDic = FindOrderTotalInfo("fl_order_alimama", member.id);
|
|||
|
|
if (tbDic != null)
|
|||
|
|
{
|
|||
|
|
alimamaPendingPoint_sleep = tbDic["point_sleep"];
|
|||
|
|
alimamaPendingCount_sleep = (int)tbDic["count_sleep"];
|
|||
|
|
alimamaPendingPoint_pay = tbDic["point_pay"];
|
|||
|
|
alimamaPendingCount_pay = (int)tbDic["count_pay"];
|
|||
|
|
alimamaPendingPoint = tbDic["point"];
|
|||
|
|
alimamaPendingCount = (int)tbDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"B_alimama:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (jdDic == null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
jdDic = FindOrderTotalInfo("fl_order_jingdong", member.id);
|
|||
|
|
if (jdDic != null)
|
|||
|
|
{
|
|||
|
|
jdPendingPoint_sleep = jdDic["point_sleep"];
|
|||
|
|
jdPendingCount_sleep = (int)jdDic["count_sleep"];
|
|||
|
|
jdPendingPoint_pay = jdDic["point_pay"];
|
|||
|
|
jdPendingCount_pay = (int)jdDic["count_pay"];
|
|||
|
|
jdPendingPoint = jdDic["point"];
|
|||
|
|
jdPendingCount = (int)jdDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"B_jingdong:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (wphDic == null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
wphDic = FindOrderTotalInfo("fl_order_weipinhui", member.id);
|
|||
|
|
if (wphDic != null)
|
|||
|
|
{
|
|||
|
|
wphPendingPoint_sleep = wphDic["point_sleep"];
|
|||
|
|
wphPendingCount_sleep = (int)wphDic["count_sleep"];
|
|||
|
|
wphPendingPoint_pay = wphDic["point_pay"];
|
|||
|
|
wphPendingCount_pay = (int)wphDic["count_pay"];
|
|||
|
|
wphPendingPoint = wphDic["point"];
|
|||
|
|
wphPendingCount = (int)wphDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"B_weipinhui:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (dyDic == null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
dyDic = FindOrderTotalInfo("fl_order_douyin", member.id);
|
|||
|
|
if (dyDic != null)
|
|||
|
|
{
|
|||
|
|
dyPendingPoint_sleep = dyDic["point_sleep"];
|
|||
|
|
dyPendingCount_sleep = (int)dyDic["count_sleep"];
|
|||
|
|
dyPendingPoint_pay = dyDic["point_pay"];
|
|||
|
|
dyPendingCount_pay = (int)dyDic["count_pay"];
|
|||
|
|
dyPendingPoint = dyDic["point"];
|
|||
|
|
dyPendingCount = (int)dyDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"B_douyin:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (snDic == null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
snDic = FindOrderTotalInfo("fl_order_suning", member.id);
|
|||
|
|
if (snDic != null)
|
|||
|
|
{
|
|||
|
|
snPendingPoint_sleep = snDic["point_sleep"];
|
|||
|
|
snPendingCount_sleep = (int)snDic["count_sleep"];
|
|||
|
|
snPendingPoint_pay = snDic["point_pay"];
|
|||
|
|
snPendingCount_pay = (int)snDic["count_pay"];
|
|||
|
|
snPendingPoint = snDic["point"];
|
|||
|
|
snPendingCount = (int)snDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"B_suning:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (ksDic == null)
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
ksDic = FindOrderTotalInfo("fl_order_kuaishou", member.id);
|
|||
|
|
if (ksDic != null)
|
|||
|
|
{
|
|||
|
|
ksPendingPoint_sleep = ksDic["point_sleep"];
|
|||
|
|
ksPendingCount_sleep = (int)ksDic["count_sleep"];
|
|||
|
|
ksPendingPoint_pay = ksDic["point_pay"];
|
|||
|
|
ksPendingCount_pay = (int)ksDic["count_pay"];
|
|||
|
|
ksPendingPoint = ksDic["point"];
|
|||
|
|
ksPendingCount = (int)ksDic["count"];
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"B_kuaishou:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
sumPendingPoint = pddPendingPoint + alimamaPendingPoint + jdPendingPoint + wphPendingPoint + dyPendingPoint + snPendingPoint + ksPendingPoint;
|
|||
|
|
sumPendingCount = pddPendingCount + alimamaPendingCount + jdPendingCount + wphPendingCount + dyPendingCount + snPendingCount + ksPendingCount;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (_mess.Contains("[淘宝售后中订单数]"))
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
var result = session1.FindRow("select count(*) as count from fl_order_alimama where db_userid = @id and db_status = 1000", new { id = member.id });
|
|||
|
|
alimamaReturnNum = int.Parse(result["count"].ToString());
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"淘宝售后中订单数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[京东售后中订单数]"))
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
var result = session1.FindRow("select count(*) as count from fl_order_jingdong where db_userid = @id and db_status = 1000", new { id = member.id });
|
|||
|
|
jingdongReturnNum = int.Parse(result["count"].ToString());
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"京东售后中订单数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[唯品会售后中订单数]"))
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
var result = session1.FindRow("select count(*) as count from fl_order_weipinhui where db_userid = @id and db_status = 1000", new { id = member.id });
|
|||
|
|
weipinhuiReturnNum = int.Parse(result["count"].ToString());
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"唯品会售后中订单数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[抖音售后中订单数]"))
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
var result = session1.FindRow("select count(*) as count from fl_order_douyin where db_userid = @id and db_status = 1000", new { id = member.id });
|
|||
|
|
douyinReturnNum = int.Parse(result["count"].ToString());
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"抖音售后中订单数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[苏宁售后中订单数]"))
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
var result = session1.FindRow("select count(*) as count from fl_order_suning where db_userid = @id and db_status = 1000", new { id = member.id });
|
|||
|
|
suningReturnNum = int.Parse(result["count"].ToString());
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"苏宁售后中订单数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[快手售后中订单数]"))
|
|||
|
|
{
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
var result = session1.FindRow("select count(*) as count from fl_order_kuaishou where db_userid = @id and db_status = 1000", new { id = member.id });
|
|||
|
|
kuaishouReturnNum = int.Parse(result["count"].ToString());
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"快手售后中订单数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
Replace("[淘宝售后中订单数]", alimamaReturnNum.ToString());
|
|||
|
|
Replace("[京东售后中订单数]", jingdongReturnNum.ToString());
|
|||
|
|
Replace("[唯品会售后中订单数]", weipinhuiReturnNum.ToString());
|
|||
|
|
Replace("[抖音售后中订单数]", douyinReturnNum.ToString());
|
|||
|
|
Replace("[苏宁售后中订单数]", suningReturnNum.ToString());
|
|||
|
|
Replace("[快手售后中订单数]", kuaishouReturnNum.ToString());
|
|||
|
|
Replace("[拼多多待结算数量]", pddPendingCount.ToString());
|
|||
|
|
Replace("[拼多多待结算金额]", pddPendingPoint.ToString("0.00"));
|
|||
|
|
Replace("[淘宝待结算数量]", alimamaPendingCount.ToString());
|
|||
|
|
Replace("[淘宝待结算金额]", alimamaPendingPoint.ToString("0.00"));
|
|||
|
|
Replace("[京东待结算数量]", jdPendingCount.ToString());
|
|||
|
|
Replace("[京东待结算金额]", jdPendingPoint.ToString("0.00"));
|
|||
|
|
Replace("[唯品会待结算数量]", wphPendingCount.ToString());
|
|||
|
|
Replace("[唯品会待结算金额]", wphPendingPoint.ToString("0.00"));
|
|||
|
|
Replace("[抖音待结算数量]", dyPendingCount.ToString());
|
|||
|
|
Replace("[抖音待结算金额]", dyPendingPoint.ToString("0.00"));
|
|||
|
|
Replace("[苏宁待结算数量]", snPendingCount.ToString());
|
|||
|
|
Replace("[苏宁待结算金额]", snPendingPoint.ToString("0.00"));
|
|||
|
|
Replace("[快手待结算数量]", ksPendingCount.ToString());
|
|||
|
|
Replace("[快手待结算金额]", ksPendingPoint.ToString("0.00"));
|
|||
|
|
Replace("[待结算总数数量]", sumPendingCount.ToString());
|
|||
|
|
Replace("[待结算总数金额]", sumPendingPoint.ToString("0.00"));
|
|||
|
|
|
|||
|
|
Replace("[淘宝冻结金额]", alimamaPendingPoint_sleep.ToString("0.00"));
|
|||
|
|
Replace("[拼多多冻结金额]", pddPendingPoint_sleep.ToString("0.00"));
|
|||
|
|
Replace("[京东冻结金额]", jdPendingPoint_sleep.ToString("0.00"));
|
|||
|
|
Replace("[唯品会冻结金额]", wphPendingPoint_sleep.ToString("0.00"));
|
|||
|
|
Replace("[抖音冻结金额]", dyPendingPoint_sleep.ToString("0.00"));
|
|||
|
|
Replace("[苏宁冻结金额]", snPendingPoint_sleep.ToString("0.00"));
|
|||
|
|
Replace("[快手冻结金额]", ksPendingPoint_sleep.ToString("0.00"));
|
|||
|
|
Replace("[淘宝冻结订单数]", alimamaPendingCount_sleep.ToString());
|
|||
|
|
Replace("[拼多多冻结订单数]", pddPendingCount_sleep.ToString());
|
|||
|
|
Replace("[京东冻结订单数]", jdPendingCount_sleep.ToString());
|
|||
|
|
Replace("[唯品会冻结订单数]", wphPendingCount_sleep.ToString());
|
|||
|
|
Replace("[抖音冻结订单数]", dyPendingCount_sleep.ToString());
|
|||
|
|
Replace("[苏宁冻结订单数]", snPendingCount_sleep.ToString());
|
|||
|
|
Replace("[快手冻结订单数]", ksPendingCount_sleep.ToString());
|
|||
|
|
|
|||
|
|
Replace("[淘宝未收货金额]", alimamaPendingPoint_pay.ToString("0.00"));
|
|||
|
|
Replace("[拼多多未收货金额]", pddPendingPoint_pay.ToString("0.00"));
|
|||
|
|
Replace("[京东未收货金额]", jdPendingPoint_pay.ToString("0.00"));
|
|||
|
|
Replace("[唯品会未收货金额]", wphPendingPoint_pay.ToString("0.00"));
|
|||
|
|
Replace("[抖音未收货金额]", dyPendingPoint_pay.ToString("0.00"));
|
|||
|
|
Replace("[苏宁未收货金额]", snPendingPoint_pay.ToString("0.00"));
|
|||
|
|
Replace("[快手未收货金额]", ksPendingPoint_pay.ToString("0.00"));
|
|||
|
|
Replace("[淘宝未收货订单数]", alimamaPendingCount_pay.ToString());
|
|||
|
|
Replace("[拼多多未收货订单数]", pddPendingCount_pay.ToString());
|
|||
|
|
Replace("[京东未收货订单数]", jdPendingCount_pay.ToString());
|
|||
|
|
Replace("[唯品会未收货订单数]", wphPendingCount_pay.ToString());
|
|||
|
|
Replace("[抖音未收货订单数]", dyPendingCount_pay.ToString());
|
|||
|
|
Replace("[苏宁未收货订单数]", snPendingCount_pay.ToString());
|
|||
|
|
Replace("[快手未收货订单数]", ksPendingCount_pay.ToString());
|
|||
|
|
|
|||
|
|
Replace("[未收货积分]", "[未收货总金额]");
|
|||
|
|
Replace("[待收货积分]", "[未收货总金额]");
|
|||
|
|
Replace("[未收货总金额]", (alimamaPendingPoint_pay + pddPendingPoint_pay + jdPendingPoint_pay + wphPendingPoint_pay + dyPendingPoint_pay + snPendingPoint_pay + ksPendingPoint_pay).ToString("0.00"));
|
|||
|
|
Replace("[待结算积分]", "[冻结总金额]");
|
|||
|
|
Replace("[冻结总金额]", (alimamaPendingPoint_sleep + pddPendingPoint_sleep + jdPendingPoint_sleep + wphPendingPoint_sleep + dyPendingPoint_sleep + snPendingPoint_sleep + ksPendingPoint_sleep).ToString("0.00"));
|
|||
|
|
Replace("[待收货订单数]", "[未收货订单数]");
|
|||
|
|
Replace("[未收货订单数]", (alimamaPendingCount_pay + pddPendingCount_pay + jdPendingCount_pay + wphPendingCount_pay + dyPendingCount_pay + snPendingCount_pay + ksPendingCount_pay).ToString());
|
|||
|
|
Replace("[待结算订单数]", "[冻结订单数]");
|
|||
|
|
Replace("[冻结订单数]", (alimamaPendingCount_sleep + pddPendingCount_sleep + jdPendingCount_sleep + wphPendingCount_sleep + dyPendingCount_sleep + snPendingCount_sleep + ksPendingCount_sleep).ToString());
|
|||
|
|
}));
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 统计邀请数据
|
|||
|
|
if (_mess.Contains("[下级人数]") || _mess.Contains("[推荐人数]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var temp = session1.FindRow($"select count(id) as num from fl_member_info where inviter_id = @id", new { id = member.id })["num"].ToString();
|
|||
|
|
Replace("[下级人数]", "[推荐人数]");
|
|||
|
|
Replace("[推荐人数]", temp);
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"下级人数|推荐人数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (_mess.Contains("[完成首单人数]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var temp = session1.FindRow($"select count(id) as num from fl_member_info where inviter_id = @id and finish_order != @finish_order", new { id = member.id, finish_order = 0 })["num"].ToString();
|
|||
|
|
Replace("[完成首单人数]", temp);
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"完成首单人数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
string UnfinishOrderNum = "0";//完成订单数
|
|||
|
|
if (_mess.Contains("[未完成首单人数]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var temp = session1.FindRow($"select count(id) as num from fl_member_info where inviter_id = @id and finish_order = @finish_order", new { id = member.id, finish_order = 0 })["num"].ToString();
|
|||
|
|
Replace("[未完成首单人数]", temp);
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"未完成首单人数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
if (_mess.Contains("[三级邀请人数]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var temp = session1.FindRow($@"select count(*) as num from (
|
|||
|
|
select id from fl_member_info where inviter_id = @id
|
|||
|
|
UNION all
|
|||
|
|
select id from fl_member_info where inviter_id in (select id from fl_member_info where inviter_id = @id ) and inviter_id != '0'
|
|||
|
|
UNION all
|
|||
|
|
select id from fl_member_info where inviter_id in (select id from fl_member_info where inviter_id in (select id from fl_member_info where inviter_id = @id) and inviter_id != '0') and inviter_id != '0'
|
|||
|
|
) as temp", new { id = member.id })["num"].ToString();
|
|||
|
|
Replace("[三级邀请人数]", temp);
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"三级邀请人数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (_mess.Contains("[三级有效人数]"))
|
|||
|
|
{
|
|||
|
|
actions.Add(new Action(delegate
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
var session1 = ApiClient.GetSession();
|
|||
|
|
var temp = session1.FindRow($@"select count(*) as num from (
|
|||
|
|
select id from fl_member_info where inviter_id = @id and finish_order != 0
|
|||
|
|
UNION all
|
|||
|
|
select id from fl_member_info where inviter_id in (select id from fl_member_info where inviter_id = @id) and inviter_id != '0' and finish_order != 0
|
|||
|
|
UNION all
|
|||
|
|
select id from fl_member_info where inviter_id in (select id from fl_member_info where inviter_id in (select id from fl_member_info where inviter_id = @id) and inviter_id != '0') and inviter_id != '0' and finish_order != 0
|
|||
|
|
) as temp", new { id = member.id })["num"].ToString();
|
|||
|
|
Replace("[三级有效人数]", temp);
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"三级有效人数:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 获取订单记录
|
|||
|
|
if (_mess.Contains("[订单记录]"))
|
|||
|
|
{
|
|||
|
|
var timeNow = DateTime.Now;
|
|||
|
|
var _dics = new List<object>();
|
|||
|
|
//查阿里妈妈订单
|
|||
|
|
//var list_alimama = session.Queryable<fl_order_alimama>().Where(f => f.db_userid == member.id).OrderBy(f => f.id, SqlSugar.OrderByType.Desc).ToPageList(1, 30);
|
|||
|
|
var list_alimama = session.Find<fl_order_alimama>("select * from fl_order_alimama where db_userid=@uid order by id desc limit 0,30", new { uid = member.id });
|
|||
|
|
//this.OnLog("阿里妈妈数量:"+list_alimama.Count+",您的ID:"+ id);
|
|||
|
|
foreach (var aimama in list_alimama)
|
|||
|
|
{
|
|||
|
|
_dics.Add(new
|
|||
|
|
{
|
|||
|
|
orderId = aimama.trade_parent_id,
|
|||
|
|
title = aimama.item_title,
|
|||
|
|
status = aimama.db_status.ToString(),
|
|||
|
|
money = aimama.alipay_total_price.ToString("0.00"),
|
|||
|
|
fanli = aimama.db_userpoint.ToString("0.00"),
|
|||
|
|
nums = aimama.item_num,
|
|||
|
|
crtTime = aimama.create_time.ToString("yyyy-MM-dd HH:mm:ss")
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"AA:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
//查最近拼多多订单
|
|||
|
|
var list_pinduoduo = session.Find<fl_order_pinduoduo>("select * from fl_order_pinduoduo where db_userid=@uid order by id desc limit 0,30", new { uid = member.id });
|
|||
|
|
foreach (var pdd in list_pinduoduo)
|
|||
|
|
{
|
|||
|
|
_dics.Add(new
|
|||
|
|
{
|
|||
|
|
orderId = pdd.order_sn,
|
|||
|
|
title = pdd.goods_name,
|
|||
|
|
status = pdd.db_status.ToString(),
|
|||
|
|
money = pdd.order_amount.ToString("0.00"),
|
|||
|
|
fanli = pdd.db_userpoint.ToString("0.00"),
|
|||
|
|
nums = pdd.goods_quantity,
|
|||
|
|
crtTime = pdd.order_create_time.ToString("yyyy-MM-dd HH:mm:ss")
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"BB:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
//查最近京东订单
|
|||
|
|
var list_jingdong = session.Find<fl_order_jingdong>("select * from fl_order_jingdong where db_userid=@uid order by id desc limit 0,30", new { uid = member.id });
|
|||
|
|
foreach (var jd in list_jingdong)
|
|||
|
|
{
|
|||
|
|
_dics.Add(new
|
|||
|
|
{
|
|||
|
|
orderId = jd.orderId,
|
|||
|
|
title = jd.skuName,
|
|||
|
|
status = jd.db_status.ToString(),
|
|||
|
|
money = jd.estimateCosPrice.ToString("0.00"),
|
|||
|
|
fanli = jd.db_userpoint.ToString("0.00"),
|
|||
|
|
nums = jd.skuNum,
|
|||
|
|
crtTime = jd.orderTime.ToString("yyyy-MM-dd HH:mm:ss")
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"CC:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
//查最近唯品会订单
|
|||
|
|
var list_weipinhui = session.Find<fl_order_weipinhui>("select * from fl_order_weipinhui where db_userid=@uid order by id desc limit 0,30", new { uid = member.id });
|
|||
|
|
foreach (var wph in list_weipinhui)
|
|||
|
|
{
|
|||
|
|
_dics.Add(new
|
|||
|
|
{
|
|||
|
|
orderId = wph.orderSn,
|
|||
|
|
title = wph.goodsName,
|
|||
|
|
status = wph.db_status.ToString(),
|
|||
|
|
money = wph.commission.ToString("0.00"),
|
|||
|
|
fanli = wph.db_userpoint.ToString("0.00"),
|
|||
|
|
nums = wph.goodsCount,
|
|||
|
|
crtTime = Util.GetDateTime(wph.orderTime).ToString("yyyy-MM-dd HH:mm:ss")
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//查最近抖音订单
|
|||
|
|
var list_douyin = session.Find<fl_order_douyin>("select * from fl_order_douyin where db_userid=@uid order by id desc limit 0,30", new { uid = member.id });
|
|||
|
|
foreach (var dy in list_douyin)
|
|||
|
|
{
|
|||
|
|
_dics.Add(new
|
|||
|
|
{
|
|||
|
|
orderId = dy.order_id,
|
|||
|
|
title = dy.product_name,
|
|||
|
|
status = dy.db_status.ToString(),
|
|||
|
|
money = Util.ConvertDouble_FenToYuan(dy.estimated_comission),
|
|||
|
|
fanli = dy.db_userpoint.ToString("0.00"),
|
|||
|
|
nums = 1,
|
|||
|
|
crtTime = Util.GetDateTime(dy.pay_time).ToString("yyyy-MM-dd HH:mm:ss")
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//查最近苏宁订单
|
|||
|
|
var list_suning = session.Find<fl_order_suning>("select * from fl_order_suning where db_userid=@uid order by id desc limit 0,30", new { uid = member.id });
|
|||
|
|
foreach (var sn in list_suning)
|
|||
|
|
{
|
|||
|
|
_dics.Add(new
|
|||
|
|
{
|
|||
|
|
orderId = sn.orderCode,
|
|||
|
|
title = sn.productName,
|
|||
|
|
status = sn.db_status.ToString(),
|
|||
|
|
money = double.Parse(sn.prePayCommission).ToString("0.00"),
|
|||
|
|
fanli = sn.db_userpoint.ToString("0.00"),
|
|||
|
|
nums = sn.saleNum,
|
|||
|
|
crtTime = sn.payTime.ToString("yyyy-MM-dd HH:mm:ss")
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//查最近苏宁订单
|
|||
|
|
var list_kuaishou = session.Find<fl_order_kuaishou>("select * from fl_order_kuaishou where db_userid=@uid order by id desc limit 0,30", new { uid = member.id });
|
|||
|
|
foreach (var ks in list_kuaishou)
|
|||
|
|
{
|
|||
|
|
_dics.Add(new
|
|||
|
|
{
|
|||
|
|
orderId = ks.oid.ToString(),
|
|||
|
|
title = ks.itemTitle,
|
|||
|
|
status = ks.db_status.ToString(),
|
|||
|
|
money = ks.estimatedIncome.ToString("0.00"),
|
|||
|
|
fanli = ks.db_userpoint.ToString("0.00"),
|
|||
|
|
nums = ks.num,
|
|||
|
|
crtTime = ks.payTime.ToString("yyyy-MM-dd HH:mm:ss")
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"DD:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
timeNow = DateTime.Now;
|
|||
|
|
|
|||
|
|
// var count = list_alimama.Count + list_pinduoduo.Count + list_jingdong.Count;
|
|||
|
|
if (_dics.Count == 0)
|
|||
|
|
Replace("[订单记录]", "暂无记录");
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
string key = HttpHelper.ToMD5("aliorder_" + member.username).ToLower();
|
|||
|
|
var _url = FindTransferAddress(TargetType.订单页, true);
|
|||
|
|
var url = GetOrderList(_url, key, HttpHelper.ObjectToJson(_dics));
|
|||
|
|
if (string.IsNullOrWhiteSpace(url))
|
|||
|
|
Replace("[订单记录]", "查询失败");
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
var url_ = string.Empty;
|
|||
|
|
if (ApiClient.Setting.SystemConfig.dwz_type != DwzType.不缩短域名)
|
|||
|
|
url_ = ApiClient.ShortURL(url).Result;
|
|||
|
|
else
|
|||
|
|
url_ = ApiClient.ShortURL(url, DwzType.快站短网址).Result;
|
|||
|
|
Replace("[订单记录]", url_);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
LogHelper.GetSingleObj().Debug("", $"订单记录:{(DateTime.Now - timeNow).TotalSeconds}\r\n");
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 邀请列表
|
|||
|
|
|
|||
|
|
if (_mess.Contains("[下级列表]"))
|
|||
|
|
{
|
|||
|
|
var subordinate = new StringBuilder();
|
|||
|
|
var memberList = session.Find<fl_member_info>("select * from fl_member_info where inviter_id = @uid order by crt_time desc", new { uid = member.id }).Take(10).ToList();
|
|||
|
|
for (int i = 0; i < memberList.Count; i++)
|
|||
|
|
{
|
|||
|
|
subordinate.AppendLine($"{i + 1}.{memberList[i].realnick}");
|
|||
|
|
}
|
|||
|
|
Replace("[下级列表]", subordinate.ToString());
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
else if (type == typeof(ItemPoint))
|
|||
|
|
{
|
|||
|
|
var point = item as ItemPoint;
|
|||
|
|
Replace("[返利积分]", point.UserPoint.ToString("0.00"));
|
|||
|
|
Replace("[总积分]", point.SumPoint.ToString("0.00"));
|
|||
|
|
Replace("[总佣金]", point.Commission.ToString("0.00"));
|
|||
|
|
Replace("[三级提成积分]", point.AwardThree.ToString("0.00"));
|
|||
|
|
Replace("[二级提成积分]", point.AwardTwo.ToString("0.00"));
|
|||
|
|
Replace("[一级提成积分]", point.AwardOne.ToString("0.00"));
|
|||
|
|
Replace("[群负责人提成积分]", point.AwardCreate.ToString("0.00"));
|
|||
|
|
Replace("[维权返利积分]", point.UserPoint.ToString("0.00"));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
int excute_num = 0;
|
|||
|
|
object lock_action = new object();
|
|||
|
|
if (actions.Count > 0)
|
|||
|
|
{
|
|||
|
|
Parallel.ForEach(actions, action => action.Invoke());
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
Replace("[创建时间]", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
EventClient.OnEvent(null, $"{ex.Message} - {ex.StackTrace}");
|
|||
|
|
}
|
|||
|
|
return mess.ToString();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 统计阿里妈妈,京东,拼多多,(付款状态订单合计/冻结状态订单合计/付款和冻结状态订单合计)
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="tableName">表名</param>
|
|||
|
|
/// <param name="uid">用户id</param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
private Dictionary<string, decimal> FindOrderTotalInfo(string tableName, long uid)
|
|||
|
|
{
|
|||
|
|
var sql = string.Empty;
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var sqlwhere = string.Empty;
|
|||
|
|
switch (tableName)
|
|||
|
|
{
|
|||
|
|
case "fl_order_pinduoduo":
|
|||
|
|
sqlwhere += $" and '{DateTime.Now.AddYears(-1).ToString("yyyy-MM-dd HH:mm:ss")}' <= order_create_time";
|
|||
|
|
break;
|
|||
|
|
case "fl_order_alimama":
|
|||
|
|
sqlwhere += $" and '{DateTime.Now.AddYears(-1).ToString("yyyy-MM-dd HH:mm:ss")}' <= create_time";
|
|||
|
|
break;
|
|||
|
|
case "fl_order_jingdong":
|
|||
|
|
sqlwhere += $" and '{DateTime.Now.AddYears(-1).ToString("yyyy-MM-dd HH:mm:ss")}' <= orderTime";
|
|||
|
|
break;
|
|||
|
|
case "fl_order_weipinhui": //下单时间为 int
|
|||
|
|
sqlwhere += $" and '{HttpExtend.GetTimeStamp(DateTime.Now.AddYears(-1))}' <= orderTime";
|
|||
|
|
break;
|
|||
|
|
case "fl_order_douyin": //下单时间为 int
|
|||
|
|
sqlwhere += $" and '{HttpExtend.GetTimeStamp(DateTime.Now.AddYears(-1))}' <= pay_time";
|
|||
|
|
break;
|
|||
|
|
case "fl_order_suning":
|
|||
|
|
sqlwhere += $" and '{DateTime.Now.AddYears(-1).ToString("yyyy-MM-dd HH:mm:ss")}' <= payTime";
|
|||
|
|
break;
|
|||
|
|
case "fl_order_kuaishou":
|
|||
|
|
sqlwhere += $" and '{DateTime.Now.AddYears(-1).ToString("yyyy-MM-dd HH:mm:ss")}' <= payTime";
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var session = ApiClient.GetSession();
|
|||
|
|
|
|||
|
|
sql = $"select round(COALESCE(sum(db_userpoint),0) ,2) as sum ,count(id) as count from {tableName} where db_userid = @id and db_status = 1001 {sqlwhere} UNION ALL select round(COALESCE(sum(db_userpoint), 0), 2) as sum, count(id) as count from {tableName} where db_userid = @id and db_status = 1005 {sqlwhere}";
|
|||
|
|
var result = session.FindTable(sql, new { id = uid });
|
|||
|
|
if (result.Rows.Count != 0 && result.Rows.Count == 2)
|
|||
|
|
{
|
|||
|
|
var dic = new Dictionary<string, decimal>();
|
|||
|
|
|
|||
|
|
var point_sleep = decimal.Parse(result.Rows[0]["sum"].ToString());
|
|||
|
|
var count_sleep = int.Parse(result.Rows[0]["count"].ToString());
|
|||
|
|
var point_pay = decimal.Parse(result.Rows[1]["sum"].ToString());
|
|||
|
|
var count_pay = int.Parse(result.Rows[1]["count"].ToString());
|
|||
|
|
|
|||
|
|
dic.Add("point_sleep", point_sleep);
|
|||
|
|
dic.Add("count_sleep", count_sleep);
|
|||
|
|
dic.Add("point_pay", point_pay);
|
|||
|
|
dic.Add("count_pay", count_pay);
|
|||
|
|
dic.Add("point", point_sleep + point_pay);
|
|||
|
|
dic.Add("count", count_sleep + count_pay);
|
|||
|
|
|
|||
|
|
return dic;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
EventClient.OnEvent("", $"查询积分异常:{tableName} - {uid} - {ex.Message} - {ex.StackTrace}");
|
|||
|
|
LogHelper.GetSingleObj().Error("", $"查询积分异常:{tableName} - {uid} - {ex.Message} - {ex.StackTrace} - {sql}");
|
|||
|
|
}
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private enum OrderStateType
|
|||
|
|
{
|
|||
|
|
退款总金额 = 0,
|
|||
|
|
退款订单数 = 1
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 已退款积分
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="status_id"></param>
|
|||
|
|
/// <param name="uid"></param>
|
|||
|
|
/// <param name="stateType"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
private string FindOrderInfoByState(int status_id, long uid, OrderStateType stateType)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
//key == "[待收货积分]" ? 1005 : key == "[已退款积分]" ? 1003 : 1001
|
|||
|
|
|
|||
|
|
var session = ApiClient.GetSession();
|
|||
|
|
var sql = string.Empty;
|
|||
|
|
if (uid != 999)
|
|||
|
|
{
|
|||
|
|
if (stateType == OrderStateType.退款总金额)
|
|||
|
|
{
|
|||
|
|
sql = $@"select COALESCE(SUM(num),0) as num from (select COALESCE(SUM(db_userpoint),0) as num from fl_order_alimama where db_userid = @userid and db_status = @status
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_pinduoduo where db_userid = @userid and db_status = @status
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_jingdong where db_userid = @userid and db_status = @status) as temp";
|
|||
|
|
return double.Parse(session.FindRow(sql, new { userid = uid, status = status_id })["num"].ToString()).ToString("0.00");
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
sql = $@"select COALESCE(SUM(num),0) as num from (select count(*) as num from fl_order_alimama where db_userid = @userid and db_status = @status
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_pinduoduo where db_userid = @userid and db_status = @status
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_jingdong where db_userid = @userid and db_status = @status) as temp";
|
|||
|
|
return session.FindRow(sql, new { userid = uid, status = status_id })["num"].ToString();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (stateType == OrderStateType.退款总金额)
|
|||
|
|
{
|
|||
|
|
sql = $@"select COALESCE(SUM(num),0) as num from (select COALESCE(SUM(db_userpoint),0) as num from fl_order_alimama where db_userid = @userid and (db_status = @status or db_status = @status2)
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_pinduoduo where db_userid = @userid and (db_status = @status or db_status = @status2)
|
|||
|
|
UNION all
|
|||
|
|
select COALESCE(SUM(db_userpoint),0) as num from fl_order_jingdong where db_userid = @userid and (db_status = @status or db_status = @status2)) as temp";
|
|||
|
|
return double.Parse(session.FindRow(sql, new { userid = uid, status = status_id, status2 = 1003 })["num"].ToString()).ToString("0.00");
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
sql = $@"select COALESCE(SUM(num),0) as num from (select count(*) as num from fl_order_alimama where db_userid = @userid and (db_status = @status or db_status = @status2)
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_pinduoduo where db_userid = @userid and (db_status = @status or db_status = @status2)
|
|||
|
|
UNION all
|
|||
|
|
select count(*) as num from fl_order_jingdong where db_userid = @userid and (db_status = @status or db_status = @status2)) as temp";
|
|||
|
|
|
|||
|
|
return session.FindRow(sql, new { userid = uid, status = status_id, status2 = 1003 })["num"].ToString();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{ }
|
|||
|
|
return "0";
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#region 已兑换积分
|
|||
|
|
private string FindAlreadyExchange(long uid)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var session = ApiClient.GetSession();
|
|||
|
|
var sumPoint = double.Parse(session.FindRow("select COALESCE(SUM(point),0) as num from fl_point_hist where uid = @uid and type = '提现扣除'", new { uid = uid })["num"].ToString());
|
|||
|
|
var thSumPoint = double.Parse(session.FindRow("select COALESCE(SUM(point),0) as num from fl_point_hist where uid = @uid and type = '退回积分'", new { uid = uid })["num"].ToString());
|
|||
|
|
return (sumPoint + thSumPoint).ToString("0.00").Replace("-", "");
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
EventClient.OnEvent(null, $"查询已兑换总额异常：{ex.Message} - {ex.StackTrace}");
|
|||
|
|
}
|
|||
|
|
return "-1";
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取订单详情
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="key"></param>
|
|||
|
|
/// <param name="json"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
private string GetOrderList(string _url, string key, string json)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var http = new HttpHelper();
|
|||
|
|
var item = http.GetItem("http://api.view.52cmg.cn/api/util.asmx/SetCache");
|
|||
|
|
item.Postdata = "key=" + key + "&json=" + HttpHelper.URLEncode(json, Encoding.UTF8);
|
|||
|
|
item.Encoding = Encoding.UTF8;
|
|||
|
|
item.Method = "post";
|
|||
|
|
var result = http.GetHtml(item);
|
|||
|
|
if (!string.IsNullOrWhiteSpace(ApiClient.Setting.SystemConfig.URLTbDdxq))
|
|||
|
|
_url = ApiClient.Setting.SystemConfig.URLTbDdxq;
|
|||
|
|
return _url.Replace("[key]", key);
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
EventClient.OnEvent(this, $"获取订单详情：{ex.Message}");
|
|||
|
|
}
|
|||
|
|
return string.Empty;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 用户自定义变量替换
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="str">替换的原内容</param>
|
|||
|
|
/// <returns>替换后的内容,报错将返回原内容</returns>
|
|||
|
|
internal string ReplaceUserVariate(string str)
|
|||
|
|
{
|
|||
|
|
StringBuilder strb = new StringBuilder();
|
|||
|
|
strb.Append(str);
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var session = ApiClient.GetSession();
|
|||
|
|
var uservariaters = session.FindUserVariates();
|
|||
|
|
if (uservariaters != null && uservariaters.Count != 0)
|
|||
|
|
{
|
|||
|
|
foreach (var variater in uservariaters)
|
|||
|
|
{
|
|||
|
|
strb = strb.Replace(variater.variate, variater.data);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return strb.ToString();
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{ }
|
|||
|
|
return str;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|