Skip to content

D
DataCenter_Core2.1_20190520
Commit 736a76bf by guanzhenshan
Options

每日逻辑仓库数据增加产品分类

parent 8bc6d2a9
Showing with 39 additions and 5 deletions
Bailun.DC.LogicWareHouse/Services.cs
......@@ -142,6 +142,8 @@ namespace Bailun.DC.LogicWareHouse
//更新半年以上库龄的sku数量
UpdateStockAge();
//更新sku产品分类
UpdateSkuCategory();
return true;
......@@ -508,8 +510,8 @@ namespace Bailun.DC.LogicWareHouse
{
Console.WriteLine("开始执行保存逻辑仓库的每日快照信息 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
var sql = @"insert into dc_daily_logic_wh_statistic (day,hq_type,warehouse_code,warehouse_name,usable_stock,amount_stock,quantity_purchase,purchase_amount,quantity_transfer,amount_transit,oneday_total_sales,amount_onedaysale,sevenday_total_sales,fourteenday_total_sales,thirtyday_total_sales,quantity_tuneout_onway,quantity_tuneout_30days,quantity_tunein_30days,nostockcount,noshippingcount,cash_in_30days,cash_out_30days,cash_net,pin_rate_stock,sevenday_total_sales_amount,fourteenday_total_sales_amount,thirtyday_total_sales_amount,amount_tuneout_30days,amount_tunein_30days)
select DATE_SUB(curdate(),INTERVAL 1 DAY) as day,t1.* from (select t1.hq_type,t1.warehouse_code,t1.warehouse_name,sum(t1.usable_stock) usable_stock,sum(t1.amount_stock) amount_stock,sum(t1.quantity_purchase) quantity_purchase,sum(t1.purchase_amount) purchase_amount,sum(t1.quantity_transfer) quantity_transfer,sum(t1.amount_transit) amount_transit,sum(t1.oneday_total_sales) oneday_total_sales,sum(t1.amount_onedaysale) amount_onedaysale,sum(t1.sevenday_total_sales) sevenday_total_sales,sum(t1.fourteenday_total_sales) fourteenday_total_sales,sum(t1.thirtyday_total_sales) thirtyday_total_sales,sum(quantity_tuneout_onway) quantity_tuneout_onway,sum(t1.quantity_tuneout_30days) quantity_tuneout_30days,sum(t1.quantity_tunein_30days) quantity_tunein_30days,sum(nostockcount) as nostockcount,sum(noshippingcount) as noshippingcount,sum(cash_in_30days) as cash_in_30days,sum(cash_out_30days) as cash_out_30days,sum(cash_net) as cash_net,(sum(thirtyday_total_sales)/sum(usable_stock)) as pin_rate_stock,sum(sevenday_total_sales_amount) as sevenday_total_sales_amount,sum(fourteenday_total_sales_amount) as fourteenday_total_sales_amount,sum(thirtyday_total_sales_amount) as thirtyday_total_sales_amount,sum(amount_tuneout_30days) as amount_tuneout_30days,sum(amount_tunein_30days) as amount_tunein_30days from dc_skuwarehouse_stock_sales t1 group by warehouse_code) t1";
var sql = @"insert into dc_daily_logic_wh_statistic (day,hq_type,warehouse_code,warehouse_name,usable_stock,amount_stock,quantity_purchase,purchase_amount,quantity_transfer,amount_transit,oneday_total_sales,amount_onedaysale,sevenday_total_sales,fourteenday_total_sales,thirtyday_total_sales,quantity_tuneout_onway,quantity_tuneout_30days,quantity_tunein_30days,nostockcount,noshippingcount,cash_in_30days,cash_out_30days,cash_net,pin_rate_stock,sevenday_total_sales_amount,fourteenday_total_sales_amount,thirtyday_total_sales_amount,amount_tuneout_30days,amount_tunein_30days,skucategory)
select DATE_SUB(curdate(),INTERVAL 1 DAY) as day,t1.* from (select t1.hq_type,t1.warehouse_code,t1.warehouse_name,sum(t1.usable_stock) usable_stock,sum(t1.amount_stock) amount_stock,sum(t1.quantity_purchase) quantity_purchase,sum(t1.purchase_amount) purchase_amount,sum(t1.quantity_transfer) quantity_transfer,sum(t1.amount_transit) amount_transit,sum(t1.oneday_total_sales) oneday_total_sales,sum(t1.amount_onedaysale) amount_onedaysale,sum(t1.sevenday_total_sales) sevenday_total_sales,sum(t1.fourteenday_total_sales) fourteenday_total_sales,sum(t1.thirtyday_total_sales) thirtyday_total_sales,sum(quantity_tuneout_onway) quantity_tuneout_onway,sum(t1.quantity_tuneout_30days) quantity_tuneout_30days,sum(t1.quantity_tunein_30days) quantity_tunein_30days,sum(nostockcount) as nostockcount,sum(noshippingcount) as noshippingcount,sum(cash_in_30days) as cash_in_30days,sum(cash_out_30days) as cash_out_30days,sum(cash_net) as cash_net,(sum(thirtyday_total_sales)/sum(usable_stock)) as pin_rate_stock,sum(sevenday_total_sales_amount) as sevenday_total_sales_amount,sum(fourteenday_total_sales_amount) as fourteenday_total_sales_amount,sum(thirtyday_total_sales_amount) as thirtyday_total_sales_amount,sum(amount_tuneout_30days) as amount_tuneout_30days,sum(amount_tunein_30days) as amount_tunein_30days,skucategory from dc_skuwarehouse_stock_sales t1 group by warehouse_code,skucategory) t1";
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString + "Allow User Variables=True;"))
{
......@@ -540,7 +542,7 @@ select DATE_SUB(curdate(),INTERVAL 1 DAY) as day,t1.* from (select t1.hq_type,t1
public void UpdateStockAge()
{
Console.WriteLine("【开始】更新库龄超过6个月的库存数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
Console.WriteLine("【开始】成品更新库龄超过6个月的库存数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
var sql = $@"update (select bailun_sku,warehouse_code,sum(stock) stock from dc_mid_stock_age where day<'{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' group by bailun_sku,warehouse_code) t1
join dc_skuwarehouse_stock_sales t2 on t1.bailun_sku=t2.bailun_sku and t1.warehouse_code=t2.warehouse_code and t2.hq_type!='半成品仓'
......@@ -562,11 +564,43 @@ select DATE_SUB(curdate(),INTERVAL 1 DAY) as day,t1.* from (select t1.hq_type,t1
}
catch (Exception ex)
{
Console.WriteLine("更新库龄超过6个月的库存数据服务失败，异常信息：" + ex.Message);
Console.WriteLine("成品更新库龄超过6个月的库存数据服务失败，异常信息：" + ex.Message);
UpdateStockAge();
}
Console.WriteLine("【完成】更新库龄超过6个月的库存数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
Console.WriteLine("【完成】成品更新库龄超过6个月的库存数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
}
public void UpdateSkuCategory()
{
Console.WriteLine("【开始】成品更新sku分类数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
var sql = $@"update dc_skuwarehouse_stock_sales t1
join dc_base_sku t2 on t1.bailun_sku=t2.bailun_sku
join dc_base_sku_finance_category t3 on t3.bailuncategoryid=t2.bailun_category_id
set t1.skucategory=t3.financecategoryname
where hq_type!='半成品仓'";
try
{
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
cn.Execute(sql, null, null, 6 * 60);
}
}
catch (Exception ex)
{
Console.WriteLine("成品更新sku分类数据服务失败，异常信息：" + ex.Message);
UpdateStockAge();
}
Console.WriteLine("【完成】成品更新sku分类数据数据 " + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
}
}
}
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