Commit ed95bc24 by 泽锋 李

fix

parent e3a43299
...@@ -28,7 +28,7 @@ namespace AutoTurnOver.Purchase.AverageTarget ...@@ -28,7 +28,7 @@ namespace AutoTurnOver.Purchase.AverageTarget
//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();
} }
catch (Exception ex) catch (Exception ex)
{ {
......
...@@ -729,7 +729,7 @@ where t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code and t1.isp ...@@ -729,7 +729,7 @@ where t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code and t1.isp
/// </summary> /// </summary>
public static void SynchroTransferTransportType() public static void SynchroTransferTransportType()
{ {
var task_name = $"SynchroTransferTransportType_v2"; var task_name = $"SynchroTransferTransportType_v3";
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 });
...@@ -761,6 +761,7 @@ where t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code and t1.isp ...@@ -761,6 +761,7 @@ where t1.bailun_sku=@bailun_sku and t1.warehouse_code=@warehouse_code and t1.isp
where t2.hq_type not in ('国内仓') and t1.gmt_modified>=@btime and t1.gmt_modified <=@etime where t2.hq_type not in ('国内仓') and t1.gmt_modified>=@btime and t1.gmt_modified <=@etime
order by t1.gmt_modified asc order by t1.gmt_modified asc
limit {(page-1)*rows},{rows} ",new { btime = new_task_synchro_log.start_time,etime = new_task_synchro_log.end_time }).ToList(); limit {(page-1)*rows},{rows} ",new { btime = new_task_synchro_log.start_time,etime = new_task_synchro_log.end_time }).ToList();
page++;
if (datas.Count <= 0) { break; } if (datas.Count <= 0) { break; }
foreach (var orderItem in datas) foreach (var orderItem in datas)
{ {
......
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