Commit d38de261 authored by 吴春's avatar 吴春

提交代码

parent 321b7962
......@@ -119,5 +119,10 @@ namespace Mall.Model.Entity.MarketingCenter
/// </summary>
public string MemberLevel { get; set; }
/// <summary>
/// 店铺id
/// </summary>
public int SmallShopId { get; set; }
}
}
......@@ -53,5 +53,12 @@ namespace Mall.Model.Extend.Product
/// 待返佣金额
/// </summary>
public decimal WaitCommission { get; set; }
/// <summary>
/// 类型,1-订单返佣,2-供应商返佣,3-微店返佣,4-vip购买返佣
/// </summary>
public int CommissionType { get; set; }
}
}
......@@ -142,6 +142,10 @@ namespace Mall.Model.Extend.Product
set;
}
public string SmallShopsName { get; set; }
#region 订单导入
/// <summary>
......
......@@ -895,6 +895,7 @@ namespace Mall.Module.MarketingCenter
return resultModel;
}
//根据发放类型获取对应的优惠券信息
model.SmallShopId = memberUserModel.SmallShopId;
var couponList = discountCouponRepository.GetSelfmotionCouponList(model);
if (couponList != null && couponList.Any(x => x.TotalNum == -1 || x.TotalNum > 0))//存在满足条件的优惠券可以发放
{
......
......@@ -159,7 +159,7 @@ namespace Mall.Module.MarketingCenter
public List<RB_Goods_OrderCommission_Extend> GetByOrderDetailId(RB_Goods_OrderCommission_Extend model)
{
//分销情况
var oclist = goods_OrderCommissionRepository.GetListGroupByUser(model);
var oclist = goods_OrderCommissionRepository.GetListGroupByUser_V2(model);
if (oclist.Any())
{
//获取用户
......@@ -169,13 +169,13 @@ namespace Mall.Module.MarketingCenter
var HpgradeList = new List<RB_Distributor_HPGradeInfo_Extend>();
if (oclist.Where(x => x.Type == 2).Any())
{
string gradeIds = string.Join(",", oclist.Where(x => x.Type == 2).Select(x => x.Grade).Distinct());
string gradeIds = string.Join(",", oclist.Where(x => x.Type == 2 &&(x.CommissionType == 1|| x.CommissionType == 4)).Select(x => x.Grade).Distinct());
HpgradeList = distributor_HPGradeInfoRepository.GetList(new RB_Distributor_HPGradeInfo_Extend() { GradeIds = gradeIds, TenantId = model.TenantId, MallBaseId = model.MallBaseId }, true);
}
var FXGradeList = new List<RB_Distributor_FXGrade_Extend>();
if (oclist.Where(x => x.Type == 3).Any())
{
string gradeIds = string.Join(",", oclist.Where(x => x.Type == 3).Select(x => x.Grade).Distinct());
string gradeIds = string.Join(",", oclist.Where(x => x.Type == 3 && (x.CommissionType == 1 || x.CommissionType == 4)).Select(x => x.Grade).Distinct());
FXGradeList = distributor_FXGradeRepository.GetList(new RB_Distributor_FXGrade_Extend() { GradeIds = gradeIds, TenantId = model.TenantId, MallBaseId = model.MallBaseId });
}
foreach (var item in oclist)
......@@ -184,34 +184,45 @@ namespace Mall.Module.MarketingCenter
item.UserName = umodel?.Name ?? "";
item.Mobile = umodel?.Moblie ?? "";
item.Name = dislist.Where(x => x.UserId == item.UserId).FirstOrDefault()?.Name ?? "";
if (item.Type == 1)
if (item.CommissionType == 1 || item.CommissionType == 4)
{
if (item.Grade == 0)
if (item.Type == 1)
{
item.GradeDescription = "自购返利";
}
else if (item.Grade == 1)
{
item.GradeDescription = "一级佣金";
if (item.Grade == 0)
{
item.GradeDescription = "自购返利";
}
else if (item.Grade == 1)
{
item.GradeDescription = "一级佣金";
}
else if (item.Grade == 2)
{
item.GradeDescription = "二级佣金";
}
else if (item.Grade == 3)
{
item.GradeDescription = "三级佣金";
}
}
else if (item.Grade == 2)
else if (item.Type == 2)
{
item.GradeDescription = "二级佣金";
var hpGModel = HpgradeList.Where(x => x.Id == item.Grade).FirstOrDefault();
item.GradeDescription = hpGModel?.GradeName ?? "暂无等级";
}
else if (item.Grade == 3)
else if (item.Type == 3)
{
item.GradeDescription = "三级佣金";
var fxGModel = FXGradeList.Where(x => x.Id == item.Grade).FirstOrDefault();
item.GradeDescription = fxGModel?.GradeName ?? "暂无等级";
}
}
else if (item.Type == 2)
else if (item.CommissionType == 2)
{
var hpGModel = HpgradeList.Where(x => x.Id == item.Grade).FirstOrDefault();
item.GradeDescription = hpGModel?.GradeName ?? "暂无等级";
item.GradeDescription = "供应商返佣";
}
else if (item.Type == 3)
else if (item.CommissionType == 3)
{
var fxGModel = FXGradeList.Where(x => x.Id == item.Grade).FirstOrDefault();
item.GradeDescription = fxGModel?.GradeName ?? "暂无等级";
item.GradeDescription = "微店返佣";
}
}
}
......
This diff is collapsed.
......@@ -76,6 +76,10 @@ namespace Mall.Module.User
/// </summary>
private readonly RB_Goods_OrderDetailRepository goods_OrderDetailRepository = new RB_Goods_OrderDetailRepository();
private readonly RB_SmallShops_CommissionRepository smallShopsCommissionRepository = new RB_SmallShops_CommissionRepository();
private readonly RB_SmallShops_RemitRepository smallShopsRemitRepository = new RB_SmallShops_RemitRepository();
#region 微店管理
/// <summary>
......@@ -625,7 +629,7 @@ namespace Mall.Module.User
var OModel = smallShopsCustomRepository.GetSmallShopsCustomList(new RB_SmallShops_Custom() { TenantId = demodel.TenantId, MallBaseId = demodel.MallBaseId }).FirstOrDefault();
if (OModel != null)
{
demodel.Id = OModel.Id;
Dictionary<string, object> keyValuePairs = new Dictionary<string, object>() {
{ nameof(RB_SmallShops_Custom.HeadBackImage),demodel.HeadBackImage},
{ nameof(RB_SmallShops_Custom.WithdrawalFilletPX),demodel.WithdrawalFilletPX},
......@@ -658,17 +662,17 @@ namespace Mall.Module.User
List<WhereHelper> whereHelpers = new List<WhereHelper>() {
new WhereHelper(){
FiledName=nameof(RB_SmallShops_Custom.Id),
FiledValue=demodel.Id,
FiledValue=OModel.Id,
OperatorEnum=OperatorEnum.Equal
},
new WhereHelper(){
FiledName=nameof(RB_SmallShops_Custom.TenantId),
FiledValue=demodel.TenantId,
FiledValue=OModel.TenantId,
OperatorEnum=OperatorEnum.Equal
},
new WhereHelper(){
FiledName=nameof(RB_SmallShops_Custom.MallBaseId),
FiledValue=demodel.MallBaseId,
FiledValue=OModel.MallBaseId,
OperatorEnum=OperatorEnum.Equal
}
};
......@@ -737,5 +741,22 @@ namespace Mall.Module.User
// return smallShopsCommissionRepository.GetSmallShopsCommissionPageList(pageIndex, pageSize, out count, dmodel);
}
#endregion
#region 微店提现
/// <summary>
/// 获取分销提现分页列表
/// </summary>
/// <param name="pageIndex"></param>
/// <param name="pageSize"></param>
/// <param name="count"></param>
/// <param name="demodel"></param>
/// <returns></returns>
public List<RB_SmallShops_Remit_Extend> GetSmallShopsRemitPageList(int pageIndex, int pageSize, out long count, RB_SmallShops_Remit_Extend demodel)
{
return smallShopsRemitRepository.GetPageList(pageIndex, pageSize, out count, demodel);
}
#endregion
}
}
......@@ -6227,7 +6227,7 @@ namespace Mall.Module.User
if (userInfo.SmallShopId == 0)
{
return "微店信息错误,请重新登录";
return "微店不存在";
}
var umodel = smallShopsInfoRepository.GetEntity(userInfo.SmallShopId);
......@@ -6287,6 +6287,7 @@ namespace Mall.Module.User
UserId = umodel.Id,
UserName = umodel.Name,
umodel.Logo,
umodel.Notice,
GradeName = "",
CommissionWithdrawal = model.Commission ?? 0,//可提现佣金
TXCommission = commModel?.TXCommission ?? 0,//已提现佣金
......
......@@ -86,8 +86,8 @@ namespace Mall.Repository.AppletWeChat
{
builder.Append($" AND a.{nameof(RB_Live_HouseExtension_Extend.MallBaseId)}={query.MallBaseId}");
}
}
builder.Append($" order by a.{nameof(RB_Live_HouseExtension_Extend.roomid)} desc,a.{nameof(RB_Live_HouseExtension_Extend.start_time)} desc");
return GetPage<RB_Live_HouseExtension_Extend>(pageIndex, pageSize, out rowCount, builder.ToString()).ToList();
}
}
......
......@@ -222,6 +222,14 @@ SELECT a.ID as MemberCouponId,a.UserId,b.`Name`,b.CouponType,b.UseType,b.MinCons
{
userWhere += $" AND {nameof(RB_DiscountCoupon_Extend.UserId)}={query.UserId}";
}
if (query.SmallShopId > 0)
{
where += $" AND ( a.{nameof(RB_DiscountCoupon_Extend.SmallShopId)}={query.SmallShopId} or a.{nameof(RB_DiscountCoupon_Extend.SmallShopId)}=0)";
}
else {
where += $" AND a.{nameof(RB_DiscountCoupon_Extend.SmallShopId)}=0";
}
}
// string sql = @$" SELECT t.*,c.MemberNum from (SELECT a.ID,a.`Name`,a.`Describe`,a.CouponType,a.UseType,a.StartDate,a.EndDate,a.MinConsumePrice,a.MaxDiscountsPrice,a.DiscountsPrice,a.IndateDay,a.IndateType from rb_discountcoupon as a
// {where} and a.IndateType=1
......@@ -329,15 +337,25 @@ on a.CouponId=b.ID {where} ";
{
userWhere += $"and c.UserId={query.UserId}";
}
if (query.SmallShopId > 0)
{
builder.Append($" AND ( a.{nameof(RB_DiscountCoupon_Extend.SmallShopId)}={query.SmallShopId} or a.{nameof(RB_DiscountCoupon_Extend.SmallShopId)}=0)");
}
else
{
builder.Append($" AND a.{nameof(RB_DiscountCoupon_Extend.SmallShopId)}=0");
}
}
string sql = @$"SELECT a.*,b.TriggerType,b.GrantNum from rb_coupon_selfmotion as b LEFT JOIN {TableName} as a on a.ID=b.DiscountCouponId
where (a.IndateType=1 or (a.IndateType=2 and a.StartDate<NOW() and a.EndDate>NOW()))
where (a.IndateType=1 or (a.IndateType=2 and a.EndDate>NOW()))
and a.`Status`=0 and b.`Status`=0 and IsAll=0 {builder.ToString()}
UNION ALL
SELECT a.*,b.TriggerType,b.GrantNum from rb_coupon_selfmotion as b LEFT JOIN rb_discountcoupon as a on a.ID=b.DiscountCouponId
LEFT JOIN rb_coupon_selfmotionmember as c on c.SelfMotionId=b.ID
where (a.IndateType=1 or (a.IndateType=2 and a.StartDate<NOW() and a.EndDate>NOW())) {builder.ToString()}
where (a.IndateType=1 or (a.IndateType=2 and a.EndDate>NOW())) {builder.ToString()}
and a.`Status`=0 and b.`Status`=0 and IsAll=1 {userWhere} ";
return Get<RB_DiscountCoupon_Extend>(sql).ToList();
}
......
......@@ -88,6 +88,50 @@ left join rb_goods_orderaftersale oa on oc.OrderDetailId= oa.OrderDetialId and o
where {where} group by oc.OrderId,oc.UserId,oc.Grade,oc.Type order by oc.Grade asc";
return Get<RB_Goods_OrderCommission_Extend>(sql).ToList();
}
/// <summary>
/// 获取用户返佣
/// </summary>
/// <param name="dmodel"></param>
/// <returns></returns>
public List<RB_Goods_OrderCommission_Extend> GetListGroupByUser_V2(RB_Goods_OrderCommission_Extend dmodel)
{
string where = $" 1=1 and oa.ReOrderId is null";
if (dmodel.TenantId > 0)
{
where += $@" and oc.{nameof(RB_Goods_OrderCommission.TenantId)}={dmodel.TenantId}";
}
if (dmodel.MallBaseId > 0)
{
where += $@" and oc.{nameof(RB_Goods_OrderCommission.MallBaseId)}={dmodel.MallBaseId}";
}
if (dmodel.OrderId > 0)
{
where += $@" and oc.{nameof(RB_Goods_OrderCommission.OrderId)}={dmodel.OrderId}";
}
if (dmodel.UserId > 0)
{
where += $@" and oc.{nameof(RB_Goods_OrderCommission.UserId)}={dmodel.UserId}";
}
if (dmodel.OrderDetailId > 0)
{
where += $@" and oc.{nameof(RB_Goods_OrderCommission.OrderDetailId)}={dmodel.OrderDetailId}";
}
if (!string.IsNullOrEmpty(dmodel.OrderIds))
{
where += $@" and oc.{nameof(RB_Goods_OrderCommission.OrderId)} in({dmodel.OrderIds})";
}
string sql = $@"SELECT oc.OrderId,oc.UserId,oc.Grade,oc.Type,oc.CommissionState,SUM(oc.Commission) as Commission,oc.CommissionType FROM All_Commission oc
left join rb_goods_orderaftersale oa on oc.OrderDetailId= oa.OrderDetialId and oa.Type=1 and oa.Status=0 and oa.ReOrderStatus in (2,3,4,5)
where {where} group by oc.OrderId,oc.UserId,oc.Grade,oc.Type,oc.CommissionType order by oc.Grade asc";
return Get<RB_Goods_OrderCommission_Extend>(sql).ToList();
}
/// <summary>
/// 获取用户返佣
/// </summary>
......
......@@ -112,10 +112,15 @@ namespace Mall.Repository.Product
{
where += $@" and o.{nameof(RB_Goods_Order.Recycled)}={(int)dmodel.Recycled}";
}
if (dmodel.SmallShopsId.HasValue&& dmodel.SmallShopsId > 0)
{
where += $@" and o.{nameof(RB_Goods_Order.SmallShopsId)}={dmodel.SmallShopsId}";
}
string sql = $@"SELECT o.*,u.Name as UserName FROM rb_goods_order o
string sql = $@"SELECT o.*,u.Name as UserName,sshop.`Name` as SmallShopsName FROM rb_goods_order o
INNER JOIN rb_goods_orderdetail od on o.OrderId=od.OrderId
INNER JOIN rb_member_user u on o.UserId=u.Id
LEFT JOIN rb_smallshops_info as sshop on o.SmallShopsId=sshop.Id
where {where} group by o.OrderId order by o.CreateDate desc";
return GetPage<RB_Goods_Order_Extend>(pageIndex, pageSize, out count, sql).ToList();
}
......@@ -1180,6 +1185,18 @@ GROUP BY od.GoodsId,o.OrderId
}
}
// string sql = $@" SELECT B.Id,SUM(b.PaidCostMoney) as PaidCostMoney,MAX(b.OrderId) as OrderId,MAX( a.OrderNo) as OrderNo,MAX(b.GoodsName) as GoodsName,b.Specification,MAX(b.Unit_Price) as Unit_Price,SUM(b.Number) as Number,f.`Name` as SupplierName,
//SUM(b.Final_Price) as Final_Price,SUM(b.FreightMoney) as FreightMoney,SUM(b.Final_Price+b.FreightMoney) as AllPrice ,
//SUM(IFNULL(b.CostMoney,0)*b.Number) as CostMoney,0 as PackingMoney, 0 as CostFreight,0 as GoodsFreight,
//0 as OtherPrice,e.FXCommission,f.RemitFXCommission,0 as Paid
//from rb_goods_orderdetail as b
//LEFT JOIN rb_goods_order as A on a.OrderId=b.OrderId
//LEFT JOIN rb_supplier as f on f.ID=b.SupplierId
//LEFT JOIN (SELECT SUM(Commission) as FXCommission,OrderDetailId from rb_goods_ordercommission GROUP BY OrderDetailId ) as e on b.Id=e.OrderDetailId
//LEFT JOIN (SELECT SUM(Commission) as RemitFXCommission,OrderDetailId from rb_goods_ordercommission where IsRemit=1 GROUP BY OrderDetailId ) as f on b.Id=f.OrderDetailId
//left join rb_goods_orderaftersale oa on b.ID= oa.OrderDetialId and oa.Type=1 and oa.Status=0 and oa.ReOrderStatus in (2,3,4,5) {where}
//GROUP BY b.Id order by b.Id desc";
string sql = $@" SELECT B.Id,SUM(b.PaidCostMoney) as PaidCostMoney,MAX(b.OrderId) as OrderId,MAX( a.OrderNo) as OrderNo,MAX(b.GoodsName) as GoodsName,b.Specification,MAX(b.Unit_Price) as Unit_Price,SUM(b.Number) as Number,f.`Name` as SupplierName,
SUM(b.Final_Price) as Final_Price,SUM(b.FreightMoney) as FreightMoney,SUM(b.Final_Price+b.FreightMoney) as AllPrice ,
SUM(IFNULL(b.CostMoney,0)*b.Number) as CostMoney,0 as PackingMoney, 0 as CostFreight,0 as GoodsFreight,
......@@ -1187,10 +1204,11 @@ SUM(IFNULL(b.CostMoney,0)*b.Number) as CostMoney,0 as PackingMoney, 0 as CostFre
from rb_goods_orderdetail as b
LEFT JOIN rb_goods_order as A on a.OrderId=b.OrderId
LEFT JOIN rb_supplier as f on f.ID=b.SupplierId
LEFT JOIN (SELECT SUM(Commission) as FXCommission,OrderDetailId from rb_goods_ordercommission GROUP BY OrderDetailId ) as e on b.Id=e.OrderDetailId
LEFT JOIN (SELECT SUM(Commission) as RemitFXCommission,OrderDetailId from rb_goods_ordercommission where IsRemit=1 GROUP BY OrderDetailId ) as f on b.Id=f.OrderDetailId
LEFT JOIN (SELECT SUM(Commission) as FXCommission,OrderDetailId from All_Commission GROUP BY OrderDetailId ) as e on b.Id=e.OrderDetailId
LEFT JOIN (SELECT SUM(Commission) as RemitFXCommission,OrderDetailId from All_Commission where IsRemit=1 GROUP BY OrderDetailId ) as f on b.Id=f.OrderDetailId
left join rb_goods_orderaftersale oa on b.ID= oa.OrderDetialId and oa.Type=1 and oa.Status=0 and oa.ReOrderStatus in (2,3,4,5) {where}
GROUP BY b.Id order by b.Id desc";
return GetPage<OrderStatistics_Query>(pageIndex, pageSize, out count, sql).ToList();
}
......@@ -1240,6 +1258,17 @@ GROUP BY b.Id order by b.Id desc";
}
// string sql = $@" SELECT B.Id,SUM(b.PaidCostMoney) as PaidCostMoney,MAX(b.OrderId) as OrderId,MAX( a.OrderNo) as OrderNo,MAX(b.GoodsName) as GoodsName,b.Specification,MAX(b.Unit_Price) as Unit_Price,SUM(b.Number) as Number,f.`Name` as SupplierName,
//SUM(b.Final_Price) as Final_Price,SUM(b.FreightMoney) as FreightMoney,SUM(b.Final_Price+b.FreightMoney) as AllPrice ,
//SUM(IFNULL(b.CostMoney,0)*b.Number) as CostMoney,0 as PackingMoney, 0 as CostFreight,0 as GoodsFreight,
//0 as OtherPrice,e.FXCommission,f.RemitFXCommission,0 as Paid
//from rb_goods_orderdetail as b
//LEFT JOIN rb_goods_order as A on a.OrderId=b.OrderId
//LEFT JOIN rb_supplier as f on f.ID=b.SupplierId
//LEFT JOIN (SELECT SUM(Commission) as FXCommission,OrderDetailId from rb_goods_ordercommission GROUP BY OrderDetailId ) as e on b.Id=e.OrderDetailId
//LEFT JOIN (SELECT SUM(Commission) as RemitFXCommission,OrderDetailId from rb_goods_ordercommission where IsRemit=1 GROUP BY OrderDetailId ) as f on b.Id=f.OrderDetailId
//left join rb_goods_orderaftersale oa on b.ID= oa.OrderDetialId and oa.Type=1 and oa.Status=0 and oa.ReOrderStatus in (2,3,4,5) {where}
//GROUP BY b.Id ";
string sql = $@" SELECT B.Id,SUM(b.PaidCostMoney) as PaidCostMoney,MAX(b.OrderId) as OrderId,MAX( a.OrderNo) as OrderNo,MAX(b.GoodsName) as GoodsName,b.Specification,MAX(b.Unit_Price) as Unit_Price,SUM(b.Number) as Number,f.`Name` as SupplierName,
SUM(b.Final_Price) as Final_Price,SUM(b.FreightMoney) as FreightMoney,SUM(b.Final_Price+b.FreightMoney) as AllPrice ,
SUM(IFNULL(b.CostMoney,0)*b.Number) as CostMoney,0 as PackingMoney, 0 as CostFreight,0 as GoodsFreight,
......@@ -1247,11 +1276,10 @@ SUM(IFNULL(b.CostMoney,0)*b.Number) as CostMoney,0 as PackingMoney, 0 as CostFre
from rb_goods_orderdetail as b
LEFT JOIN rb_goods_order as A on a.OrderId=b.OrderId
LEFT JOIN rb_supplier as f on f.ID=b.SupplierId
LEFT JOIN (SELECT SUM(Commission) as FXCommission,OrderDetailId from rb_goods_ordercommission GROUP BY OrderDetailId ) as e on b.Id=e.OrderDetailId
LEFT JOIN (SELECT SUM(Commission) as RemitFXCommission,OrderDetailId from rb_goods_ordercommission where IsRemit=1 GROUP BY OrderDetailId ) as f on b.Id=f.OrderDetailId
LEFT JOIN (SELECT SUM(Commission) as FXCommission,OrderDetailId from All_Commission GROUP BY OrderDetailId ) as e on b.Id=e.OrderDetailId
LEFT JOIN (SELECT SUM(Commission) as RemitFXCommission,OrderDetailId from All_Commission where IsRemit=1 GROUP BY OrderDetailId ) as f on b.Id=f.OrderDetailId
left join rb_goods_orderaftersale oa on b.ID= oa.OrderDetialId and oa.Type=1 and oa.Status=0 and oa.ReOrderStatus in (2,3,4,5) {where}
GROUP BY b.Id ";
return Get<OrderStatistics_Query>(sql).ToList();
}
......
......@@ -228,7 +228,7 @@ SELECT
FROM
{TableName} AS a
LEFT JOIN {MemberTableName} AS b ON a.UserId = b.Id
LEFT JOIN {DiscountCouponTableName} as c on c.ID=a.CouponId where a.EndDate<NOW() and a.UseState=0 group by a.CouponId,DATE_FORMAT(a.CreateDate, '%Y-%m-%d')) as t WHERE t.CouponId>0 GROUP BY t.CouponId,t.CreateDate ORDER BY t.CreateDate desc ";
LEFT JOIN {DiscountCouponTableName} as c on c.ID=a.CouponId where a.EndDate<NOW() and a.UseState=0 {builder.ToString()} group by a.CouponId,DATE_FORMAT(a.EndDate, '%Y-%m-%d')) as t WHERE t.CouponId>0 GROUP BY t.CouponId,t.CreateDate ORDER BY t.CreateDate desc ";
return GetPage<MemberCoupon_Query>(pageIndex, pageSize, out rowCount, sql).ToList();
}
......@@ -294,7 +294,7 @@ SELECT
FROM
{TableName} AS a
LEFT JOIN {MemberTableName} AS b ON a.UserId = b.Id
LEFT JOIN {DiscountCouponTableName} as c on c.ID=a.CouponId where a.EndDate<NOW() and a.UseState=0 group by a.CouponId,DATE_FORMAT(a.CreateDate, '%Y-%m-%d')) as t WHERE t.CouponId>0 GROUP BY t.CouponId,t.CreateDate ORDER BY t.CreateDate desc";
LEFT JOIN {DiscountCouponTableName} as c on c.ID=a.CouponId where a.EndDate<NOW() and a.UseState=0 {builder.ToString()} group by a.CouponId,DATE_FORMAT(a.EndDate, '%Y-%m-%d')) as t WHERE t.CouponId>0 GROUP BY t.CouponId,t.CreateDate ORDER BY t.CreateDate desc";
// string sql = @$" SELECT t.CouponId,MAX(t.`Name`) as Name,SUM(t.IsSued) as IsSued,SUM(t.Used) as Used,SUM(t.UnUsed) as UnUsed,SUM(t.Voksi) as Voksi,MAX(t.CreateDate)as CreateDate from (SELECT
// DATE_FORMAT(c.CreateDate, '%Y-%m-%d') AS CreateDate,a.CouponId,c.`Name`,count(*) as IsSued,0 as Used,0 as UnUsed,0 as Voksi
//FROM
......
......@@ -327,6 +327,10 @@ where {where}
{
where += $@" and {nameof(RB_Member_User.SuperiorId)}={dmodel.SuperiorId}";
}
if (dmodel.SmallShopId > 0)
{
where += $@" and {nameof(RB_Member_User.SmallShopId)}={dmodel.SmallShopId}";
}
string sql = $@"
select * from RB_Member_User where {where} order by CreateDate desc
";
......@@ -370,6 +374,10 @@ select * from RB_Member_User where {where} order by CreateDate desc
{
where += $@" and {nameof(RB_Member_User.SuperiorId)}={dmodel.SuperiorId}";
}
if (dmodel.SmallShopId > 0)
{
where += $@" and {nameof(RB_Member_User.SmallShopId)}={dmodel.SmallShopId}";
}
if (!string.IsNullOrEmpty(dmodel.UserIds))
{
where += $@" and {nameof(RB_Member_User.Id)} in({dmodel.UserIds})";
......
......@@ -79,6 +79,10 @@ where {where} order by di.CreateDate desc";
{
where += $@" and di.{nameof(RB_SmallShops_Info_Extend.MallBaseId)}={dmodel.MallBaseId}";
}
if (dmodel.Id > 0)
{
where += $@" and di.{nameof(RB_SmallShops_Info_Extend.Id)}={dmodel.Id}";
}
if (dmodel.UserId > 0)
{
where += $@" and di.{nameof(RB_SmallShops_Info_Extend.UserId)}={dmodel.UserId}";
......
......@@ -84,6 +84,19 @@ namespace Mall.WebApi.Controllers.AppletWeChat
return "";
}
}
/// <summary>
/// 将c# DateTime时间格式转换为Unix时间戳格式
/// </summary>
/// <param name="time">时间</param>
/// <returns>long</returns>
public static long ConvertDateTimeToInt(System.DateTime time)
{
System.DateTime startTime = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
long t = (time.Ticks - startTime.Ticks) / 10000; //除10000调整为13位
return t;
}
#endregion
......
......@@ -1175,17 +1175,7 @@ namespace Mall.WebApi.Controllers.MallBase
{
query.ApplyMemberLevel = 0;
}
if (query.PriceType == 1)
{
query.CustomMaxFixedPrice = 0;
query.CustomMinFixedPrice = 0;
}
else if (query.PriceType == 2)
{
query.CustomMinPriceRate = 0;
query.CustomMaxPriceRate = 0;
}
if (query.ID == 0)
{
query.TenantId = UserInfo.TenantId;
......
......@@ -26,7 +26,7 @@ namespace Mall.WebApi.Controllers.MarketingCenter
{
private CouponModule IntegralModule = new CouponModule();
private Module.User.UserModule UserModule = new Module.User.UserModule();
#region 卡券
......@@ -398,6 +398,19 @@ namespace Mall.WebApi.Controllers.MarketingCenter
{
return ApiResult.Failed("请选择发放对象");
}
//获取领取优惠券用户的信息判断是否属于当前店铺
var memberList = new List<RB_Member_User_Extend>();
if (oldLogisticsModel.SmallShopId > 0)
{
memberList = UserModule.GetMemberUserList(new RB_Member_User_Extend { TenantId = UserInfo.TenantId, MallBaseId = parms.MallBaseId, UserIds = query.UserIds });
var notSmallShopList = memberList.Where(x=>x.SmallShopId!= oldLogisticsModel.SmallShopId);
if (notSmallShopList!=null&& notSmallShopList.Any())
{
return ApiResult.Failed(string.Join(",", notSmallShopList.Select(x=>x.Name)+"不属于当前店铺"));
}
}
List<RB_Member_DiscountCoupon_Extend> list = new List<RB_Member_DiscountCoupon_Extend>();
for (int i = 0; i < query.GrantNum; i++)
{
......
......@@ -94,7 +94,8 @@ namespace Mall.WebApi.Controllers.MallBase
y.Final_Price,
y.Number,
y.IsBindExpress,
y.FreeShippingRemarks
y.FreeShippingRemarks,
y.SmallShopsCostPrice
}),
x.Consignee,
x.Mobile,
......@@ -114,6 +115,8 @@ namespace Mall.WebApi.Controllers.MallBase
x.District,
x.TenantId,
x.MallBaseId,
x.SmallShopsId,
x.SmallShopsName,
CreateDate = x.CreateDate.HasValue ? x.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : ""
});
return ApiResult.Success("", pagelist);
......
......@@ -224,7 +224,7 @@ namespace Mall.WebApi.Controllers.User
#endregion
var mmodel = programModule.GetMiniProgramModule(new RB_MiniProgram_Extend() { MallBaseId = umodel.MallBaseId });
//2020-08-12 Add By:W
// var smallShopsInfoModle = userModule.GetSmallShopsInfoList(new RB_SmallShops_Info_Extend { TenantId = umodel.TenantId, MallBaseId = umodel.MallBaseId, UserId = umodel.Id }).OrderByDescending(x => x.CreateDate).FirstOrDefault();
var smallShopsInfoModle = userModule.GetSmallShopsInfoList(new RB_SmallShops_Info_Extend { TenantId = umodel.TenantId, MallBaseId = umodel.MallBaseId, UserId = umodel.Id }).OrderByDescending(x => x.CreateDate).FirstOrDefault();
AppletUserInfo appletUserInfo = new AppletUserInfo()
{
......@@ -240,7 +240,7 @@ namespace Mall.WebApi.Controllers.User
SecretKey = umodel.SecretKey,
SuperiorId = umodel.SuperiorId ?? 0,
Token = token,
SmallShopId =0//(smallShopsInfoModle != null && smallShopsInfoModle.AuditStatus == DistributorAuditStatusEnum.Audited) ? smallShopsInfoModle.Id : 0
SmallShopId =(smallShopsInfoModle != null && smallShopsInfoModle.AuditStatus == DistributorAuditStatusEnum.Audited) ? smallShopsInfoModle.Id : 0
};
UserReidsCache.AppletUserInfoSet(UserModuleCacheKeyConfig.Applet_Login_Info + umodel.Id, appletUserInfo, Config.JwtExpirTime);
return ApiResult.CouponSuccess(ResultCode.Fail, "", "", appletUserInfo);
......
......@@ -951,6 +951,7 @@ namespace Mall.WebApi.Controllers.User
demodel.UserId = userInfo.UserId;
demodel.TenantId = userInfo.TenantId;
demodel.MallBaseId = userInfo.MallBaseId;
demodel.SmallShopId = userInfo.SmallShopId;
var list = couponModule.GetAllCouponList(pagelist.pageIndex, pagelist.pageSize, out long count, demodel);
pagelist.count = Convert.ToInt32(count);
pagelist.pageData = list.Select(x => new
......@@ -996,10 +997,17 @@ namespace Mall.WebApi.Controllers.User
else
{
var oldLogisticsModel = couponModule.GetDiscountCouponList(new RB_DiscountCoupon_Extend { TenantId = query.TenantId, MallBaseId = query.MallBaseId, ID = query.CouponId }).FirstOrDefault();
if (oldLogisticsModel == null || oldLogisticsModel.ID == 0)
{
return ApiResult.Failed("优惠券信息不存在,请核实后再操作");
}
if (oldLogisticsModel.SmallShopId > 0 && oldLogisticsModel.SmallShopId != userInfo.SmallShopId)
{
return ApiResult.Failed("领取优惠券不属于当前店铺");
}
if (oldLogisticsModel.TotalNum != -1)//判断优惠券剩余数量是够足够
{
if (oldLogisticsModel.TotalNum < 1)
......@@ -1711,7 +1719,7 @@ namespace Mall.WebApi.Controllers.User
var req = RequestParm;
var userInfo = AppletUserInfo;
var microShopBasics = MallBaseModule.GetMicroShopBasics(new Model.Entity.BaseSetUp.RB_MicroShop_Basics { TenantId = userInfo.TenantId, MallBaseId = userInfo.MallBaseId });
return ApiResult.Success("", microShopBasics);
}
......@@ -1969,6 +1977,90 @@ namespace Mall.WebApi.Controllers.User
});
return ApiResult.Success("", pagelist);
}
/// <summary>
/// 获取微店提现明细
/// </summary>
/// <returns></returns>
[HttpPost]
public ApiResult GetSmallShopsRemitPageList()
{
var req = RequestParm;
var userInfo = AppletUserInfo;
ResultPageModel pagelist = JsonConvert.DeserializeObject<ResultPageModel>(req.msg.ToString());
RB_SmallShops_Remit_Extend demodel = JsonConvert.DeserializeObject<RB_SmallShops_Remit_Extend>(req.msg.ToString());
demodel.UserId = userInfo.UserId;
demodel.TenantId = userInfo.TenantId;
demodel.MallBaseId = userInfo.MallBaseId;
var list = smallShopsModule.GetSmallShopsRemitPageList(pagelist.pageIndex, pagelist.pageSize, out long count, demodel);
pagelist.count = Convert.ToInt32(count);
pagelist.pageData = list.Select(x => new
{
x.Id,
x.OrderNum,
x.WithdrawalWay,
WithdrawalWayName = x.WithdrawalWay.GetEnumName(),
x.AccountName,
x.AccountNumber,
x.BankName,
x.AppliedMoney,
x.Fee,
x.RemitMoney,
x.AuditRemark,
x.RemitRemark,
x.RejectRemark,
x.AuditStatus,
AuditStatusName = x.AuditStatus.GetEnumName(),
x.TenantId,
CreateDate = x.CreateDate.HasValue ? x.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
AuditDate = x.AuditDate.HasValue ? x.AuditDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
RemitDate = x.RemitDate.HasValue ? x.RemitDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
RejectDate = x.RejectDate.HasValue ? x.RejectDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
});
return ApiResult.Success("", pagelist);
}
/// <summary>
/// 微信小程序获取店铺信息
/// </summary>
/// <param name="requestMsg"></param>
/// <returns></returns>
[HttpPost]
[Microsoft.AspNetCore.Authorization.AllowAnonymous]
public ApiResult GetSmallShopById(object requestMsg)
{
var requestParm = JsonConvert.DeserializeObject<RequestParm>(requestMsg.ToString());
var query = JsonConvert.DeserializeObject<RB_SmallShops_Info_Extend>(requestParm.msg.ToString());
RB_SmallShops_Info_Extend model = new RB_SmallShops_Info_Extend();
if (model.UserId > 0)
{
var userModel = userModule.GetMemberUserInfo(model.UserId ?? 0);
if (userModel != null && userModel.Id > 0 && userModel.SmallShopId > 0)
{
query.Id = userModel.SmallShopId;
}
}
if (query.Id > 0)
{
model = userModule.GetSmallShopsInfoList(new RB_SmallShops_Info_Extend { TenantId = model.TenantId, MallBaseId = model.MallBaseId, Id = query.Id }).OrderByDescending(x => x.CreateDate).FirstOrDefault();
}
if (model==null)
{
model = new RB_SmallShops_Info_Extend();
}
return ApiResult.Success("", model);
}
#endregion
}
}
\ No newline at end of file
......@@ -336,9 +336,10 @@ namespace Mall.WebApi.Controllers.User
if (demodel.Id == 0)
{
demodel.CreateDate = DateTime.Now;
demodel.TenantId = requestParm.TenantId;
demodel.MallBaseId = requestParm.MallBaseId;
}
demodel.TenantId = requestParm.TenantId;
demodel.MallBaseId = requestParm.MallBaseId;
demodel.UpdateDate = DateTime.Now;
bool flag = smallShopsModule.SetSmallShopsCustomInfo(demodel);
if (flag)
......@@ -400,5 +401,54 @@ namespace Mall.WebApi.Controllers.User
}
#endregion
#region 微店提现
/// <summary>
/// 获取分销商提现分页列表
/// </summary>
/// <returns></returns>
[HttpPost]
public ApiResult GetSmallShopsRemitPageList()
{
var parms = RequestParm;
ResultPageModel pagelist = JsonConvert.DeserializeObject<ResultPageModel>(parms.msg.ToString());
RB_SmallShops_Remit_Extend demodel = JsonConvert.DeserializeObject<RB_SmallShops_Remit_Extend>(parms.msg.ToString());
demodel.TenantId = Convert.ToInt32(parms.uid);
demodel.MallBaseId = parms.MallBaseId;
var list = smallShopsModule.GetSmallShopsRemitPageList(pagelist.pageIndex, pagelist.pageSize, out long count, demodel);
pagelist.count = Convert.ToInt32(count);
pagelist.pageData = list.Select(x => new
{
x.Id,
x.OrderNum,
x.UserId,
x.UserName,
x.Photo,
x.Source,
x.WithdrawalWay,
WithdrawalWayName = x.WithdrawalWay.GetEnumName(),
x.AccountName,
x.AccountNumber,
x.BankName,
x.AppliedMoney,
x.Fee,
x.RemitMoney,
x.AuditRemark,
x.RemitRemark,
x.RejectRemark,
x.AuditStatus,
AuditStatusName = x.AuditStatus.GetEnumName(),
SourceName = x.Source.GetEnumName(),
x.TenantId,
CreateDate = x.CreateDate.HasValue ? x.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
AuditDate = x.AuditDate.HasValue ? x.AuditDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
RemitDate = x.RemitDate.HasValue ? x.RemitDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
RejectDate = x.RejectDate.HasValue ? x.RejectDate.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
});
return ApiResult.Success("", pagelist);
}
#endregion
}
}
\ No newline at end of file
......@@ -20,12 +20,12 @@
<ItemGroup>
<PackageReference Include="System.ServiceProcess.ServiceController" Version="4.7.0" />
<PackageReference Include="VT.FW" Version="1.0.1" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\Mall.CacheManager\Mall.CacheManager.csproj" />
<ProjectReference Include="..\Mall.Common\Mall.Common.csproj" />
<ProjectReference Include="..\Mall.DataAccess\Mall.DataAccess.csproj" />
<ProjectReference Include="..\Mall.Model\Mall.Model.csproj" />
<ProjectReference Include="..\Mall.Module.User\Mall.Module.User.csproj" />
<ProjectReference Include="..\Mall.Repository\Mall.Repository.csproj" />
......
using DapperExtensions.Lambda;

using Mall.CacheManager.AppletWeChat;
using Mall.Common;
using Mall.Common.Enum.Goods;
......@@ -128,6 +128,8 @@ namespace Mall.WindowsService.Module
try
{
string str = financeConfigurineRepository.ConnectionStr;
Helper.LogHelper.Write("数据库连接:" + str);
//先查询规则
var financeConfigurineList = financeConfigurineRepository.GetList(new RB_Finance_Configurine_Extend { Type = 1 });
......@@ -336,8 +338,8 @@ and DATE_FORMAT(b.PaymentTime,'%y-%m-%d')<DATE_FORMAT('{endDate}','%y-%m-%d') A
}
catch (Exception ex)
{
Helper.LogHelper.Write(ex.Message);
string str = financeConfigurineRepository.ConnectionStr;
Helper.LogHelper.Write("数据库连接1:" + str+"错误日志"+ ex.Message);
}
return flag;
......@@ -1670,7 +1672,7 @@ and DATE_FORMAT(b.PaymentTime,'%y-%m-%d')<DATE_FORMAT('{endDate}','%y-%m-%d') A
if (fxGradeVipModel != null && fxGradeModel != null)
{
var financeConfigurineList = distributor_InfoRepository.GetOverTimeVipList(new RB_Distributor_Info_Extend { TenantId = itemBase.TenantId, MallBaseId = itemBase.MallBaseId, IsSelectOverTime = 1, AuditStatus = DistributorAuditStatusEnum.Audited, FXGradeId = fxGradeVipModel.Id });//获取过期的粉象vip
if (financeConfigurineList!=null&&financeConfigurineList.Any())
if (financeConfigurineList != null && financeConfigurineList.Any())
{
foreach (var item in financeConfigurineList)
{
......
......@@ -27,7 +27,7 @@ namespace Mall.WindowsService
Helper.LogHelper.Write("主服务开始运行......");
TimersHelper helper = new TimersHelper();
timer1 = new System.Timers.Timer();
timer1.Interval = 1000 * (60 * 0.5); //60分钟
timer1.Interval = 1000 * (60 * 30); //60分钟
timer1.Elapsed += new System.Timers.ElapsedEventHandler(helper.RevenueFinance);
timer1.Enabled = true;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment