Commit e607efa7 by guanzhenshan

调整资产负债表

parent 726e5662
......@@ -50,60 +50,73 @@ namespace Bailun.DC.LogicWareHouse
{
Console.WriteLine("进去方法," + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString + "Allow User Variables=True;");
var cn_read = new MySqlConnection(Common.GlobalConfig.ConnectionString_read + "Allow User Variables=True;");
try
{
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString+ "Allow User Variables=True;"))
if (cn.State == System.Data.ConnectionState.Closed)
{
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
cn.Open();
}
cn.Execute("TRUNCATE dc_skuwarehouse_stock_sales", 20 * 60);
cn.Execute("TRUNCATE dc_skuwarehouse_stock_sales", 20 * 60);
var page = 1;
var pagesize = 5000;
//var listcount = cn.QueryFirstOrDefault<int>("select count(id) from dc_base_stock");
var resultcount = 0;
var page = 1;
var pagesize = 5000;
//var listcount = cn.QueryFirstOrDefault<int>("select count(id) from dc_base_stock");
var resultcount = 0;
while (page == 1 || (resultcount > 0))
while (page == 1 || (resultcount > 0))
{
if(cn_read.State== System.Data.ConnectionState.Closed)
{
var strlimit = (((page - 1) * pagesize) + "," + pagesize);
var sql = $@"select t1.bailun_sku,t1.warehouse_code,t4.warehouse_name,t4.hq_type,(t1.usable_stock) usable_stock,((t1.usable_stock)*t1.unit_price) amount_stock,(t2.quantity_purchase) quantity_purchase,(t2.quantity_purchase*t1.unit_price) purchase_amount,(t2.quantity_transfer) quantity_transfer,(t2.quantity_transfer*t1.unit_price) amount_transit,(t5.oneday_total_sales) oneday_total_sales,(t5.sevenday_total_sales) sevenday_total_sales,(t5.fourteenday_total_sales) fourteenday_total_sales,(t5.thirtyday_total_sales) thirtyday_total_sales,t6.quantity_transfer as quantity_tuneout_onway,t6.quantity_transfer_delivery as quantity_tuneout_30days,(t6.quantity_transfer_delivery*t1.unit_price) as amount_tuneout_30days,t7.quantity_transfer_inbound as quantity_tunein_30days,(t7.quantity_transfer_inbound*t1.unit_price) as amount_tunein_30days,(t5.thirtyday_total_sales/(t1.usable_stock)) as pin_rate_stock,t5.oneday_total_sales_amount as amount_onedaysale,t5.sevenday_total_sales_amount as sevenday_total_sales_amount,t5.fourteenday_total_sales_amount as fourteenday_total_sales_amount,t5.thirtyday_total_sales_amount as thirtyday_total_sales_amount
from (select t01.bailun_sku,t01.warehouse_code,(t01.usable_stock+t01.occupy_stock) as usable_stock,t02.unit_price from dc_base_stock t01
join dc_base_sku t02 on t01.bailun_sku=t02.bailun_sku and t02.company_id=1 order by t01.id
limit {strlimit}) t1
left join dc_daily_transit t2 on t1.warehouse_code=t2.warehouse_code and t1.bailun_sku=t2.bailun_sku and t2.record_time='{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}'
left join dc_daily_sales t5 on t5.record_date = '{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' and t1.warehouse_code=t5.warehouse_code and t1.bailun_sku =t5.bailun_sku
join dc_base_warehouse t4 on t1.warehouse_code=t4.warehouse_code
left join (select t0.bailun_sku,t0.source_warehouse_code,sum(quantity_transfer_delivery) as quantity_transfer_delivery,sum(quantity_transfer) as quantity_transfer from dc_daily_transit_from t0 where t0.record_time='{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' group by t0.bailun_sku,t0.source_warehouse_code) t6 on t1.warehouse_code=t6.source_warehouse_code and t1.bailun_sku=t6.bailun_sku
left join (select t0.bailun_sku,t0.warehouse_code,sum(quantity_transfer_delivery) as quantity_transfer_delivery,sum(quantity_transfer_inbound) as quantity_transfer_inbound from dc_daily_transit_from t0 where t0.record_time='{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' group by t0.bailun_sku,t0.warehouse_code) t7 on t1.warehouse_code=t7.warehouse_code and t1.bailun_sku=t7.bailun_sku
";
cn_read.Open();
}
var strlimit = (((page - 1) * pagesize) + "," + pagesize);
var sql = $@"select t1.bailun_sku,t1.warehouse_code,t4.warehouse_name,t4.hq_type,(t1.usable_stock) usable_stock,((t1.usable_stock)*t1.unit_price) amount_stock,(t2.quantity_purchase) quantity_purchase,(t2.quantity_purchase*t1.unit_price) purchase_amount,(t2.quantity_transfer) quantity_transfer,(t2.quantity_transfer*t1.unit_price) amount_transit,(t5.oneday_total_sales) oneday_total_sales,(t5.sevenday_total_sales) sevenday_total_sales,(t5.fourteenday_total_sales) fourteenday_total_sales,(t5.thirtyday_total_sales) thirtyday_total_sales,t6.quantity_transfer as quantity_tuneout_onway,t6.quantity_transfer_delivery as quantity_tuneout_30days,(t6.quantity_transfer_delivery*t1.unit_price) as amount_tuneout_30days,t7.quantity_transfer_inbound as quantity_tunein_30days,(t7.quantity_transfer_inbound*t1.unit_price) as amount_tunein_30days,(t5.thirtyday_total_sales/(t1.usable_stock)) as pin_rate_stock,t5.oneday_total_sales_amount as amount_onedaysale,t5.sevenday_total_sales_amount as sevenday_total_sales_amount,t5.fourteenday_total_sales_amount as fourteenday_total_sales_amount,t5.thirtyday_total_sales_amount as thirtyday_total_sales_amount
from (select t01.bailun_sku,t01.warehouse_code,(t01.usable_stock+t01.occupy_stock) as usable_stock,t02.unit_price from dc_base_stock t01
join dc_base_sku t02 on t01.bailun_sku=t02.bailun_sku and t02.company_id=1 order by t01.id
limit {strlimit}) t1
left join dc_daily_transit t2 on t1.warehouse_code=t2.warehouse_code and t1.bailun_sku=t2.bailun_sku and t2.record_time='{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}'
left join dc_daily_sales t5 on t5.record_date = '{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' and t1.warehouse_code=t5.warehouse_code and t1.bailun_sku =t5.bailun_sku
join dc_base_warehouse t4 on t1.warehouse_code=t4.warehouse_code
left join (select t0.bailun_sku,t0.source_warehouse_code,sum(quantity_transfer_delivery) as quantity_transfer_delivery,sum(quantity_transfer) as quantity_transfer from dc_daily_transit_from t0 where t0.record_time='{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' group by t0.bailun_sku,t0.source_warehouse_code) t6 on t1.warehouse_code=t6.source_warehouse_code and t1.bailun_sku=t6.bailun_sku
left join (select t0.bailun_sku,t0.warehouse_code,sum(quantity_transfer_delivery) as quantity_transfer_delivery,sum(quantity_transfer_inbound) as quantity_transfer_inbound from dc_daily_transit_from t0 where t0.record_time='{DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}' group by t0.bailun_sku,t0.warehouse_code) t7 on t1.warehouse_code=t7.warehouse_code and t1.bailun_sku=t7.bailun_sku
";
var liststock = cn.Query<DC.Models.Warehouse.dc_skuwarehouse_stock_sales>(sql, null, null, true, 30 * 60);
resultcount = liststock.AsList().Count;
var liststock = cn_read.Query<DC.Models.Warehouse.dc_skuwarehouse_stock_sales>(sql, null, null, true, 30 * 60);
var str = @"insert dc_skuwarehouse_stock_sales (bailun_sku,warehouse_code,warehouse_name,hq_type,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,pin_rate_stock,sevenday_total_sales_amount,fourteenday_total_sales_amount,thirtyday_total_sales_amount,amount_tuneout_30days,amount_tunein_30days) values ";
foreach (var item in liststock)
{
str += $@"('{item.bailun_sku}','{item.warehouse_code}','{item.warehouse_name}','{item.hq_type}',{item.usable_stock ?? 0},{item.amount_stock ?? 0},{(item.quantity_purchase ?? 0)},{item.purchase_amount ?? 0},{item.quantity_transfer ?? 0},{item.amount_transit ?? 0},{(item.oneday_total_sales ?? 0)},{item.amount_onedaysale ?? 0},{item.sevenday_total_sales ?? 0},{item.fourteenday_total_sales ?? 0},{item.thirtyday_total_sales ?? 0},{item.quantity_tuneout_onway??0},{item.quantity_tuneout_30days??0},{item.quantity_tunein_30days??0},{item.pin_rate_stock??0},{(item.sevenday_total_sales_amount)},{(item.fourteenday_total_sales_amount??0)},{(item.thirtyday_total_sales_amount??0)},{(item.amount_tuneout_30days??0)},{(item.amount_tunein_30days??0)}),";
}
if (resultcount > 0)
{
str = str.Substring(0, str.Length - 1);
resultcount = liststock.AsList().Count;
cn.Execute(str, null, null, 5 * 60);
Console.WriteLine("当前页:" + page + ",每页记录:" + pagesize + ";" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")+",当前记录数:"+ resultcount);
}
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
page++;
var str = @"insert dc_skuwarehouse_stock_sales (bailun_sku,warehouse_code,warehouse_name,hq_type,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,pin_rate_stock,sevenday_total_sales_amount,fourteenday_total_sales_amount,thirtyday_total_sales_amount,amount_tuneout_30days,amount_tunein_30days) values ";
foreach (var item in liststock)
{
str += $@"('{item.bailun_sku}','{item.warehouse_code}','{item.warehouse_name}','{item.hq_type}',{item.usable_stock ?? 0},{item.amount_stock ?? 0},{(item.quantity_purchase ?? 0)},{item.purchase_amount ?? 0},{item.quantity_transfer ?? 0},{item.amount_transit ?? 0},{(item.oneday_total_sales ?? 0)},{item.amount_onedaysale ?? 0},{item.sevenday_total_sales ?? 0},{item.fourteenday_total_sales ?? 0},{item.thirtyday_total_sales ?? 0},{item.quantity_tuneout_onway??0},{item.quantity_tuneout_30days??0},{item.quantity_tunein_30days??0},{item.pin_rate_stock??0},{(item.sevenday_total_sales_amount)},{(item.fourteenday_total_sales_amount??0)},{(item.thirtyday_total_sales_amount??0)},{(item.amount_tuneout_30days??0)},{(item.amount_tunein_30days??0)}),";
}
if (resultcount > 0)
{
str = str.Substring(0, str.Length - 1);
cn.Execute(str, null, null, 5 * 60);
Console.WriteLine("当前页:" + page + ",每页记录:" + pagesize + ";" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")+",当前记录数:"+ resultcount);
}
page++;
}
Console.WriteLine("成品运行成功,时间:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
Console.WriteLine("成品运行成功,时间:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
}
//半成品库存
SemiStock();
......@@ -521,30 +534,5 @@ select DATE_SUB(curdate(),INTERVAL 1 DAY) as day,t1.* from (select t1.hq_type,t1
}
}
public void test()
{
var sql = $@"select t1.bailun_sku,t1.warehouse_code,t4.warehouse_name,t4.hq_type,(t1.usable_stock) usable_stock,((t1.usable_stock)*t1.unit_price) amount_stock,(t2.quantity_purchase) quantity_purchase,(t2.quantity_purchase*t1.unit_price) purchase_amount,(t2.quantity_transfer) quantity_transfer,(t2.quantity_transfer*t1.unit_price) amount_transit,(t5.oneday_total_sales) oneday_total_sales,(t5.sevenday_total_sales) sevenday_total_sales,(t5.fourteenday_total_sales) fourteenday_total_sales,(t5.thirtyday_total_sales) thirtyday_total_sales,t6.quantity_transfer as quantity_tuneout_onway,t6.quantity_transfer_delivery as quantity_tuneout_30days,(t6.quantity_transfer_delivery*t1.unit_price) as amount_tuneout_30days,t7.quantity_transfer_inbound as quantity_tunein_30days,(t7.quantity_transfer_inbound*t1.unit_price) as amount_tunein_30days,(t5.thirtyday_total_sales/(t1.usable_stock)) as pin_rate_stock,t5.oneday_total_sales_amount as amount_onedaysale,t5.sevenday_total_sales_amount as sevenday_total_sales_amount,t5.fourteenday_total_sales_amount as fourteenday_total_sales_amount,t5.thirtyday_total_sales_amount as thirtyday_total_sales_amount
from (select t01.bailun_sku,t01.warehouse_code,t01.usable_stock,t02.unit_price from dc_base_stock t01 join dc_base_sku t02 on t01.bailun_sku=t02.bailun_sku and t02.company_id=1 where t01.warehouse_code='GZBLWH' and t01.bailun_sku='214334801' order by t01.id limit 1000) t1
join dc_base_warehouse t4 on t1.warehouse_code=t4.warehouse_code
left join dc_daily_transit t2 on t1.warehouse_code=t2.warehouse_code and t1.bailun_sku=t2.bailun_sku and t2.record_time='2020-09-24'
left join dc_daily_sales t5 on t5.record_date = '2020-09-24' and t1.warehouse_code=t5.warehouse_code and t1.bailun_sku =t5.bailun_sku
left join (select t0.bailun_sku,t0.source_warehouse_code,sum(quantity_transfer_delivery) as quantity_transfer_delivery,sum(quantity_transfer) as quantity_transfer from dc_daily_transit_from t0 where t0.record_time='2020-09-24' group by t0.bailun_sku,t0.source_warehouse_code) t6 on t1.warehouse_code=t6.source_warehouse_code and t1.bailun_sku=t6.bailun_sku
left join (select t0.bailun_sku,t0.warehouse_code,sum(quantity_transfer_delivery) as quantity_transfer_delivery,sum(quantity_transfer_inbound) as quantity_transfer_inbound from dc_daily_transit_from t0 where t0.record_time='2020-09-24' group by t0.bailun_sku,t0.warehouse_code) t7 on t1.warehouse_code=t7.warehouse_code and t1.bailun_sku=t7.bailun_sku
;";
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if(cn.State== System.Data.ConnectionState.Closed)
{
cn.Open();
}
var liststock = cn.Query<DC.Models.Warehouse.dc_skuwarehouse_stock_sales>(sql, null, null, true, 30 * 60);
Console.WriteLine(liststock);
}
}
}
}
......@@ -209,14 +209,14 @@
function Save(col, val, mon) {
var obj = {
"statisticalTime": mon.split('T')[0]
"statistical_time": mon.split('T')[0]
};
obj[col] = val;
$.submit({
url: 'http://api.dcjava.bailuntec.com/balanceSheetModify/record',
paramData: '{"statisticalTime":"' + mon.split('T')[0] + '","' + col + '":' + val +',"companyValue":0,"companyName":"百伦供应链"}',
paramData: '{"statistical_time":"' + mon.split('T')[0] + '","' + col + '":' + val +',"company_value":0,"company_name":"百伦供应链"}',
contenttype:'application/json',
type:'POST',
func: function (result) {
......
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