Commit 000c5d2e by 泽锋 李

生产在途数据,只需从去年5月抓起

parent 662f0877
...@@ -1319,7 +1319,38 @@ where id=@id ...@@ -1319,7 +1319,38 @@ where id=@id
var sql = ""; var sql = "";
if (search_data.isSum || search_data.is_warehouse_sum) if (search_data.isSum || search_data.is_warehouse_sum)
{ {
throw new Exception("暂不做汇总处理"); sql = @"
select
sum(ifnull(t4.usable_stock,0)) as 'stock',
t1.purchase_id as 'purchase_id',
sum(ifnull(t1.quantity_purchase)) as 'quantity_purchase',
sum(ifnull(t1.`quantity_arrival`)) as 'quantity_arrival',
sum(ifnull(t1.`quantity_inbound`)) as 'quantity_inbound',
sum(ifnull(t1.`quantity_not_inbound`)) as 'quantity_not_inbound',
sum(ifnull(t8.distribution_quantity)) as 'prod_distribution_quantity',
sum(ifnull(( t8.order_quantity - t8.distribution_quantity))) as 'prod_not_distribution_quantity',
sum(ifnull(t8.prod_quantity)) as 'prod_quantity'
from dc_base_purchase_details as t1
left join dc_base_warehouse as t2 on t1.warehouse_code = t2.warehouse_code
left join dc_base_sku as t3 on t1.bailun_sku = t3.bailun_sku
left join dc_base_stock as t4 on t1.bailun_sku = t4.bailun_sku and t1.warehouse_code = t4.warehouse_code
left join dc_mid_transit as t5 on t1.bailun_sku = t5.bailun_sku and t1.warehouse_code = t5.warehouse_code
left join dc_auto_turnover as t6 on t1.bailun_sku = t6.bailun_sku and t1.warehouse_code = t6.warehouse_code
left join dc_auto_forecast_fluctuation as t7 on t1.bailun_sku = t7.bailun_sku and t1.warehouse_code = t7.warehouse_code
left join dc_base_prod_order as t8 on t1.bailun_sku = t8.bailun_sku and t1.purchase_id = t8.purchase_no
";
if (search_data.has_tort != null)
{
sql += " left join dc_base_tort as t9 on t1.bailun_sku = t9.bailun_sku ";
}
if (search_data.monitor_status != null)
{
sql += " left join dc_auto_config_sku_warehouse as t10 on t1.bailun_sku = t10.bailun_sku and t1.warehouse_code = t10.warehouse_code ";
}
sql += " where t1.`status` not in (-1,4) and t1.has_delete =0 and t1.quantity_not_inbound > 0 ";
} }
else else
{ {
...@@ -1376,7 +1407,7 @@ left join dc_base_prod_order as t8 on t1.bailun_sku = t8.bailun_sku and t1.purch ...@@ -1376,7 +1407,7 @@ left join dc_base_prod_order as t8 on t1.bailun_sku = t8.bailun_sku and t1.purch
{ {
sql += " left join dc_auto_config_sku_warehouse as t10 on t1.bailun_sku = t10.bailun_sku and t1.warehouse_code = t10.warehouse_code "; sql += " left join dc_auto_config_sku_warehouse as t10 on t1.bailun_sku = t10.bailun_sku and t1.warehouse_code = t10.warehouse_code ";
} }
sql += " where t1.`status` not in (-1,4) and t1.quantity_not_inbound > 0 "; sql += " where t1.`status` not in (-1,4) and t1.has_delete =0 and t1.quantity_not_inbound > 0 ";
} }
...@@ -1400,7 +1431,7 @@ left join dc_base_warehouse as t2 on t1.warehouse_code = t2.warehouse_code ...@@ -1400,7 +1431,7 @@ left join dc_base_warehouse as t2 on t1.warehouse_code = t2.warehouse_code
countSql += " left join dc_auto_config_sku_warehouse as t10 on t1.bailun_sku = t10.bailun_sku and t1.warehouse_code = t10.warehouse_code "; countSql += " left join dc_auto_config_sku_warehouse as t10 on t1.bailun_sku = t10.bailun_sku and t1.warehouse_code = t10.warehouse_code ";
} }
countSql += " where t1.`status` not in (-1,4) and t1.quantity_not_inbound > 0 "; countSql += " where t1.`status` not in (-1,4) and t1.has_delete =0 and t1.quantity_not_inbound > 0 ";
......
...@@ -10,7 +10,7 @@ namespace AutoTurnOver.DB ...@@ -10,7 +10,7 @@ namespace AutoTurnOver.DB
{ {
public static void SynchroData() public static void SynchroData()
{ {
var task_name = "SynchroProdData_v1"; var task_name = "SynchroProdData_v2";
var conn = _connection; var conn = _connection;
// 查询最后一次成功抓取的记录 // 查询最后一次成功抓取的记录
var last_task_synchro_log = conn.QuerySingleOrDefault<task_synchro_log>(" select * from task_synchro_log where task_name=@task_name and status=1 order by end_time desc limit 1 ", new { task_name = task_name }); var last_task_synchro_log = conn.QuerySingleOrDefault<task_synchro_log>(" select * from task_synchro_log where task_name=@task_name and status=1 order by end_time desc limit 1 ", new { task_name = task_name });
...@@ -29,7 +29,7 @@ namespace AutoTurnOver.DB ...@@ -29,7 +29,7 @@ namespace AutoTurnOver.DB
} }
else else
{ {
new_task_synchro_log.start_time = new DateTime(2018, 05, 14); new_task_synchro_log.start_time = new DateTime(2020, 05, 14);
} }
if((new_task_synchro_log.end_time- new_task_synchro_log.start_time).TotalDays > 90) if((new_task_synchro_log.end_time- new_task_synchro_log.start_time).TotalDays > 90)
......
...@@ -7,6 +7,7 @@ using System.Threading.Tasks; ...@@ -7,6 +7,7 @@ using System.Threading.Tasks;
using AutoTurnOver.Common; using AutoTurnOver.Common;
using AutoTurnOver.DB; using AutoTurnOver.DB;
using AutoTurnOver.Models; using AutoTurnOver.Models;
using AutoTurnOver.Models.Report;
using AutoTurnOver.Services; using AutoTurnOver.Services;
using AutoTurnOver.Utility; using AutoTurnOver.Utility;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
...@@ -181,7 +182,17 @@ namespace AutoTurnOver.Controllers ...@@ -181,7 +182,17 @@ namespace AutoTurnOver.Controllers
return new JsonResult(list == null || list.Count <= 0 ? new dc_base_stock_fba_dto() : list[0]); return new JsonResult(list == null || list.Count <= 0 ? new dc_base_stock_fba_dto() : list[0]);
} }
public JsonResult FullLinkPurchaseSumFooter([FromQuery]dc_base_stock_search_dto search_data)
{
var services = new DailyServices();
var total = 0;
search_data.isSum = true;
var list = services.FullLinkPurchaseList(search_data, ref total);
return new JsonResult(list == null || list.Count <= 0 ? new full_link_purchase_dto() : list[0]);
}
/// <summary> /// <summary>
/// 缺货推送记录 /// 缺货推送记录
......
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