Commit e9211ef0 by 泽锋 李

更新周转利润分析的时候,要重算一次调拨平均值

parent 747f5558
...@@ -1990,6 +1990,8 @@ where t1.gmt_modified>=@btime and t1.gmt_modified<=@etime ...@@ -1990,6 +1990,8 @@ where t1.gmt_modified>=@btime and t1.gmt_modified<=@etime
/// </summary> /// </summary>
public static void CalculationProfitAnalysis(string bailun_sku, string warehouse_code) public static void CalculationProfitAnalysis(string bailun_sku, string warehouse_code)
{ {
dc_base_transfer_freight_dao.CalculationSingle(bailun_sku, warehouse_code);
var warehouse_data = _connection.QueryFirstOrDefault<dc_base_warehouse>(" select * from dc_base_warehouse where warehouse_code=@warehouse_code ", new { warehouse_code = warehouse_code }); var warehouse_data = _connection.QueryFirstOrDefault<dc_base_warehouse>(" select * from dc_base_warehouse where warehouse_code=@warehouse_code ", new { warehouse_code = warehouse_code });
if (warehouse_data.hq_type == "国内仓") if (warehouse_data.hq_type == "国内仓")
{ {
...@@ -2072,7 +2074,7 @@ from dc_base_oms_sku where bailun_sku=@bailun_sku and warehouse_code=@warehouse_ ...@@ -2072,7 +2074,7 @@ from dc_base_oms_sku where bailun_sku=@bailun_sku and warehouse_code=@warehouse_
/// </summary> /// </summary>
public static void SynchroCalculationProfitAnalysis() public static void SynchroCalculationProfitAnalysis()
{ {
var task_name = $"SynchroCalculationProfitAnalysis_v16"; var task_name = $"SynchroCalculationProfitAnalysis_v17";
var conn = MyMySqlConnection._connection; ; var conn = MyMySqlConnection._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 });
...@@ -2098,6 +2100,8 @@ from dc_base_oms_sku where bailun_sku=@bailun_sku and warehouse_code=@warehouse_ ...@@ -2098,6 +2100,8 @@ from dc_base_oms_sku where bailun_sku=@bailun_sku and warehouse_code=@warehouse_
int count = 0; int count = 0;
int page = 1; int page = 1;
int rows = 1000; int rows = 1000;
var now = DateTime.Now;
while (true) while (true)
{ {
var datas = conn.Query<sku_warehouse_code_dto>($@" select t1.bailun_sku,t1.warehouse_code from dc_auto_turnover as t1 left join dc_base_warehouse as t2 on t1.warehouse_code =t2.warehouse_code var datas = conn.Query<sku_warehouse_code_dto>($@" select t1.bailun_sku,t1.warehouse_code from dc_auto_turnover as t1 left join dc_base_warehouse as t2 on t1.warehouse_code =t2.warehouse_code
......
...@@ -116,7 +116,6 @@ namespace AutoTurnOver.DB ...@@ -116,7 +116,6 @@ namespace AutoTurnOver.DB
public static void Calculation(order_transfer_status_log log_data) public static void Calculation(order_transfer_status_log log_data)
{ {
CalculationSingle(log_data.bailun_sku, log_data.warehouse_code); CalculationSingle(log_data.bailun_sku, log_data.warehouse_code);
} }
/// <summary> /// <summary>
......
...@@ -24,12 +24,13 @@ namespace AutoTurnOver.Purchase.AverageTarget ...@@ -24,12 +24,13 @@ namespace AutoTurnOver.Purchase.AverageTarget
try try
{ {
//report.ResetTransExpectArrivaltime(); //report.ResetTransExpectArrivaltime();
PurchaseAverageTargetServices.CalculationTransfer("217632401", days: (360 * 3)); //PurchaseAverageTargetServices.CalculationTransfer("217632401", days: (360 * 3));
//PurchaseAverageTargetServices.Calculation("942517901", days: (360 * 3)); //PurchaseAverageTargetServices.Calculation("942517901", days: (360 * 3));
//ApiUtility.GetLmsTransportCountList(new Models.ApiDto.api_transport_count_order_transfer_query_dto { bailun_sku= "LM-EO-007", targetwareno= "MMDUSFBA" }); //ApiUtility.GetLmsTransportCountList(new Models.ApiDto.api_transport_count_order_transfer_query_dto { bailun_sku= "LM-EO-007", targetwareno= "MMDUSFBA" });
//PurchaseAverageTargetServices.SynchroTransferTransportType(); //PurchaseAverageTargetServices.SynchroTransferTransportType();
//PurchaseAverageTargetServices.CalculationTransfer(days: (360 * 3), has_transfer: true); //PurchaseAverageTargetServices.CalculationTransfer(days: (360 * 3), has_transfer: true);
//dc_base_transfer_freight_dao.CalculationSingle("803597202", "MMDUSFBA");
} }
catch (Exception ex) catch (Exception ex)
{ {
......
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