Skip to content

D
DataCenter_Core2.1_20190520
Commit 2d4a1bef by guanzhenshan
Options

调整物流供应商往来统计服务

parent 5f1c9f3d
Showing with 246 additions and 35 deletions
Bailun.DC.DailyLogisticSupplierTransaction/Bailun.DC.DailyLogisticSupplierTransaction.csproj
...@@ -14,6 +14,7 @@ ...@@ -14,6 +14,7 @@
<ItemGroup> <ItemGroup>
<ProjectReference Include="..\Bailun.DC.Common\Bailun.DC.Common.csproj" /> <ProjectReference Include="..\Bailun.DC.Common\Bailun.DC.Common.csproj" />
<ProjectReference Include="..\Bailun.DC.Services\Bailun.DC.Services.csproj" />
</ItemGroup> </ItemGroup>
</Project> </Project>
Bailun.DC.DailyLogisticSupplierTransaction/Program.cs
...@@ -12,31 +12,31 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction ...@@ -12,31 +12,31 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
/// </summary> /// </summary>
/// <param name="args"></param> /// <param name="args"></param>
/// <returns></returns> /// <returns></returns>
//static async Task Main(string[] args) static async Task Main(string[] args)
//{ {
// Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); Console.WriteLine("启动服务 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
// var builder = new HostBuilder().ConfigureServices((hostContext, services) => var builder = new HostBuilder().ConfigureServices((hostContext, services) =>
// { {
// services.AddHostedService<Services>(); services.AddHostedService<Services>();
// }); });
// await builder.RunConsoleAsync(); await builder.RunConsoleAsync();
//} }
static void Main(string[] args) //static void Main(string[] args)
{ //{
var _services = new Services(); // var _services = new Services();
var start = DateTime.Parse("2020-11-01"); // var start = DateTime.Parse("2020-11-01");
_services.Init(start); // _services.Init(start);
return; // return;
while (start.AddDays(1) < DateTime.Now) // while (start.AddDays(1) < DateTime.Now)
{ // {
Console.WriteLine(start); // Console.WriteLine(start);
_services.Init(start); // _services.Init(start);
start = start.AddDays(1); // start = start.AddDays(1);
} // }
} //}
} }
} }
Bailun.DC.DailyLogisticSupplierTransaction/Services.cs
...@@ -32,8 +32,8 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction ...@@ -32,8 +32,8 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); Console.WriteLine("开始启动 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
var day = DateTime.Parse(now.ToShortDateString()); var day = DateTime.Parse(now.ToShortDateString());
Init(day); //Init(day);
new Bailun.DC.Services.LogisticsServices().LogisticsSupplierTransaction(day);
Console.WriteLine("任务运行完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")); Console.WriteLine("任务运行完成 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
} }
...@@ -43,7 +43,8 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction ...@@ -43,7 +43,8 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
while (day.AddDays(1) < DateTime.Now) while (day.AddDays(1) < DateTime.Now)
{ {
Console.WriteLine(day); Console.WriteLine(day);
Init(day); //Init(day);
new Bailun.DC.Services.LogisticsServices().LogisticsSupplierTransaction(day);
Console.WriteLine("重跑 " + day.ToString("yyyy-MM-dd HH:mm:ss") + " 完成"); Console.WriteLine("重跑 " + day.ToString("yyyy-MM-dd HH:mm:ss") + " 完成");
day = day.AddDays(1); day = day.AddDays(1);
} }
...@@ -56,12 +57,12 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction ...@@ -56,12 +57,12 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
} }
} }
List<string> arrSanTong = new List<string> { "SPRING", "华得士国际货运代理有限公司", "DHL eCommerce (HK) Ltd", "Globavend", "华得士国际货运代理有限公司(中法)", "DHL ECOMMERCE", "中国邮政集团公司广州市分公司", "华得士国际货运代理有限公司(西班牙)", "华得士国际货运代理有限公司(意大利)", "VALUE ADD SERVICE LIMITED（D）", "金羊城国际物流代理有限公司（T）", "深圳大森林国际货运代理有限公司（T）", "深圳市乐递供应链有限公司（T）", "深圳昊泽货运代理有限公司（T）", "深圳市天纵供应商管理有限公司（T）", "中外运－敦豪广东分公司（T）", "优比速包裹运送（广东）有限公司（T）", "天地国际运输代理（中国）有限公司广州分公司（T）", "HK TWELVE INTERNATIONAL CO., LIMITED（T）", "香港宇通供应链科技有限公司", "深圳市天纵供应商管理有限公司", "香港杜斯塔克科技有限公司", "深圳昊泽货运代理有限公司（T)" }; //List<string> arrSanTong = new List<string> { "SPRING", "华得士国际货运代理有限公司", "DHL eCommerce (HK) Ltd", "Globavend", "华得士国际货运代理有限公司(中法)", "DHL ECOMMERCE", "中国邮政集团公司广州市分公司", "华得士国际货运代理有限公司(西班牙)", "华得士国际货运代理有限公司(意大利)", "VALUE ADD SERVICE LIMITED（D）", "金羊城国际物流代理有限公司（T）", "深圳大森林国际货运代理有限公司（T）", "深圳市乐递供应链有限公司（T）", "深圳昊泽货运代理有限公司（T）", "深圳市天纵供应商管理有限公司（T）", "中外运－敦豪广东分公司（T）", "优比速包裹运送（广东）有限公司（T）", "天地国际运输代理（中国）有限公司广州分公司（T）", "HK TWELVE INTERNATIONAL CO., LIMITED（T）", "香港宇通供应链科技有限公司", "深圳市天纵供应商管理有限公司", "香港杜斯塔克科技有限公司", "深圳昊泽货运代理有限公司（T)" };
List<string> arrMidland = new List<string> { "Midlands Associates Ltd", "Midlands Associates Ltd（B）" }; //List<string> arrMidland = new List<string> { "Midlands Associates Ltd", "Midlands Associates Ltd（B）" };
List<string> arrHuaYu = new List<string> { "橙联平台充值", "江苏天地华宇物联科技有限公司" }; //List<string> arrHuaYu = new List<string> { "橙联平台充值", "江苏天地华宇物联科技有限公司" };
List<string> arrRongHeng = new List<string> { "深圳荣恒国际物流有限公司（美金）", "深圳荣恒国际物流有限公司（人民币）", "深圳荣恒国际物流有限公司" }; //List<string> arrRongHeng = new List<string> { "深圳荣恒国际物流有限公司（美金）", "深圳荣恒国际物流有限公司（人民币）", "深圳荣恒国际物流有限公司" };
List<string> arrXingXing = new List<string> { "SHENZHEN KINGKONG INTERNATIONAL SUPPLY CHAIN TECHNOLOGY LIMITED", "深圳市猩猩国际供应链科技有限公司美元", "深圳市猩猩国际供应链科技有限公司" }; //List<string> arrXingXing = new List<string> { "SHENZHEN KINGKONG INTERNATIONAL SUPPLY CHAIN TECHNOLOGY LIMITED", "深圳市猩猩国际供应链科技有限公司美元", "深圳市猩猩国际供应链科技有限公司" };
List<string> arrRongHui = new List<string> { "黄红玲", "深圳市荣辉快运国际物流有限公司" }; //List<string> arrRongHui = new List<string> { "黄红玲", "深圳市荣辉快运国际物流有限公司" };
public void Init(DateTime day) public void Init(DateTime day)
{ {
...@@ -315,8 +316,8 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction ...@@ -315,8 +316,8 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
//合并处理数据 //合并处理数据
foreach(var item in listMerge) foreach(var item in listMerge)
{ {
var listObj = list.Where(a => a.suppliername == item.Key || item.Select(a => a.suppliername).Contains(a.suppliername)); var listObj = list.Where(a => a.suppliername == item.Key || item.Select(a => a.suppliername).Contains(a.suppliername)).ToList();
if(listObj.Count()>0) if(listObj.Count>0)
{ {
var newObj = new dc_daily_logistics_supplier_transaction() var newObj = new dc_daily_logistics_supplier_transaction()
{ {
...@@ -336,9 +337,9 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction ...@@ -336,9 +337,9 @@ namespace Bailun.DC.DailyLogisticSupplierTransaction
lastupdateusername = "admin" lastupdateusername = "admin"
}; };
foreach (var o in listObj) for(var i=0;i<listObj.Count;i++)
{ {
list.Remove(o); list.Remove(listObj[i]);
} }
list.Add(newObj); list.Add(newObj);
......
Bailun.DC.Services/LogisticsServices.cs
...@@ -419,5 +419,214 @@ namespace Bailun.DC.Services ...@@ -419,5 +419,214 @@ namespace Bailun.DC.Services
} }
} }
/// <summary>
/// 重新计算物流供应商往来
/// </summary>
/// <param name="day">日期</param>
public void LogisticsSupplierTransaction(DateTime day)
{
//业务逻辑
var listHappen = new List<Models.dc_base_logistics>();
var listPay = new List<dc_base_logistics>();
var listRecevice = new List<dc_base_logistics>();
var list = new List<dc_daily_logistics_supplier_transaction>();
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString_read))
{
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
//发生额
var sql = $"select t1.company_name,sum(t1.amount_rmb) as merchant_shipment_cost_cny from dc_base_logistics t1 where ((t1.reconciliation_type='跟踪号对账' and t1.diff_state_type!=0) or (t1.reconciliation_type='单独费用')) and t1.merchant_reconciliation_time>='{day.ToString("yyyy-MM-dd")}' and t1.merchant_reconciliation_time<'{day.AddDays(1).ToString("yyyy-MM-dd")}' and t1.company_name!='广州嘉和货运代理有限公司' group by t1.company_name";
listHappen = cn.Query<Models.dc_base_logistics>(sql).AsList();
//付款额
sql = $@"select sum(cashier_paymoneyrmb) as merchant_shipment_cost_cny,tradeb_bjectname as company_name from dc_base_finance_cashier t1 where t1.cashier_status=1 and t1.cashier_type=1 and t1.type_name='销售费用/物流费' and t1.sourcecode='newCost' and t1.cashier_time>='{day.ToString("yyyy-MM-dd")}' and t1.cashier_time<'{day.AddDays(1).ToString("yyyy-MM-dd")}' group by tradeb_bjectname";
listPay = cn.Query<dc_base_logistics>(sql).AsList();
//收款额
sql = $@"select sum(cashier_paymoneyrmb) as merchant_shipment_cost_cny,tradeb_bjectname as company_name from dc_base_finance_cashier t1 where t1.cashier_status=1 and t1.cashier_type=2 and t1.type_name='销售费用/物流费' and t1.sourcecode='newCost' and t1.cashier_time>='{day.ToString("yyyy-MM-dd")}' and t1.cashier_time<'{day.AddDays(1).ToString("yyyy-MM-dd")}' group by tradeb_bjectname";
listRecevice = cn.Query<dc_base_logistics>(sql).AsList();
var listSupplier = new List<string>();
listSupplier.AddRange(listHappen.Select(a => a.company_name));
listSupplier.AddRange(listPay.Select(a => a.company_name));
listSupplier.AddRange(listRecevice.Select(a => a.company_name));
listSupplier = listSupplier.Distinct().ToList();
foreach (var item in listSupplier)
{
var m = new dc_daily_logistics_supplier_transaction()
{
amount_end = 0,
amount_happen = 0,
amount_other = 0,
amount_pay = 0,
amount_receipt = 0,
amount_start = 0,
createtime = DateTime.Now,
day = day,
lastupdatetime = DateTime.Now,
lastupdateuserid = 0,
lastupdateusername = "admin",
supplierid = 0,
suppliername = item,
};
var objHappen = listHappen.Where(a => a.company_name == item).FirstOrDefault();
if (objHappen != null)
{
m.amount_happen = objHappen.merchant_shipment_cost_cny;
}
var objPay = listPay.Where(a => a.company_name == item).FirstOrDefault();
if (objPay != null)
{
m.amount_pay = objPay.merchant_shipment_cost_cny;
}
var objReceive = listRecevice.Where(a => a.company_name == item).FirstOrDefault();
if (objReceive != null)
{
m.amount_receipt = objReceive.merchant_shipment_cost_cny;
}
list.Add(m);
}
}
Save(list);
}
private void Save(List<dc_daily_logistics_supplier_transaction> list)
{
if (list.Count == 0)
{
return;
}
var listSupplierConfig = new List<dc_logistics_supplier_config>();
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString_read))
{
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
listSupplierConfig = cn.Query<dc_logistics_supplier_config>("select * from dc_logistics_supplier_config where delstatus=0").ToList();
}
var _sql = "insert dc_daily_logistics_supplier_transaction (day,supplierid,suppliername,amount_start,amount_happen,amount_pay,amount_receipt,amount_other,amount_end,createtime,lastupdatetime,lastupdateuserid,lastupdateusername) values ";
var s = "";
//增加新处理逻辑 读取配置表
var listMerge = listSupplierConfig.Where(a => a.type == 1).ToList().GroupBy(a => a.parentsuppliername); //需合并的
var listDelete = listSupplierConfig.Where(a => a.type == 2).ToList(); //需删除的
//合并处理数据
foreach (var item in listMerge)
{
var listObj = list.Where(a => a.suppliername == item.Key || item.Select(a => a.suppliername).Contains(a.suppliername)).ToList();
if (listObj.Count > 0)
{
var newObj = new dc_daily_logistics_supplier_transaction()
{
amount_happen = listObj.Count() > 0 ? listObj.Sum(a => a.amount_happen) : 0,
amount_pay = listObj.Count() > 0 ? listObj.Sum(a => a.amount_pay) : 0,
amount_receipt = listObj.Count() > 0 ? listObj.Sum(a => a.amount_receipt) : 0,
amount_other = listObj.Count() > 0 ? listObj.Sum(a => a.amount_other) : 0,
suppliername = item.Key,
supplierid = 0,
amount_end = 0,
amount_start = 0,
createtime = DateTime.Now,
day = list.FirstOrDefault().day,
lastupdatetime = DateTime.Now,
lastupdateuserid = 0,
lastupdateusername = "admin"
};
for (var i = 0; i < listObj.Count; i++)
{
list.Remove(listObj[i]);
}
list.Add(newObj);
}
}
//删除数据
foreach (var item in listDelete)
{
var objList = list.Where(a => a.suppliername == item.suppliername);
foreach (var o in objList)
{
list.Remove(o);
}
}
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
foreach (var item in list)
{
//获取期初
var sql = $"select * from dc_daily_logistics_supplier_transaction where suppliername='{item.suppliername}' and day<'{item.day.ToString("yyyy-MM-dd")}' order by day desc limit 1";
var objStart = cn.QueryFirstOrDefault<dc_daily_logistics_supplier_transaction>(sql);
if (objStart != null)
{
item.amount_start = objStart.amount_end;
}
//查看是否有本期数据
sql = $"select * from dc_daily_logistics_supplier_transaction where suppliername='{item.suppliername}' and day='{item.day.ToString("yyyy-MM-dd")}'";
var obj = cn.QueryFirstOrDefault<dc_daily_logistics_supplier_transaction>(sql);
if (obj != null)
{
item.amount_other = obj.amount_other;
}
cn.Execute($"delete from dc_daily_logistics_supplier_transaction where day='{item.day.ToString("yyyy-MM-dd")}' and suppliername='{item.suppliername}'");
//期末 = 期初+发生额-付款额+收款额（绝对值）+其他金额（手工导入数据）
item.amount_end = item.amount_start + item.amount_happen - item.amount_pay + System.Math.Abs(item.amount_receipt) + item.amount_other;
s += ($"('{item.day.ToString("yyyy-MM-dd")}',{item.supplierid},'{item.suppliername}',{item.amount_start},{item.amount_happen},{item.amount_pay},{item.amount_receipt},{item.amount_other},{item.amount_end},'{item.createtime.ToString("yyyy-MM-dd HH:mm:ss")}','{item.lastupdatetime.ToString("yyyy-MM-dd HH:mm:ss")}',{item.lastupdateuserid},'{item.lastupdateusername}'),");
}
if (s.Length > 0)
{
s = s.Substring(0, s.Length - 1);
cn.Execute(_sql + s);
}
}
}
} }
} }
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