@@ -87,7 +87,7 @@ where t1.stateid!=5 and t1.isdeleted=0 and t2.deliverycount>t2.storagecount").To
/// </summary>
publicstaticvoidSynchroLmsTransferOrder()
{
vartask_name="SynchroLmsTransferOrder_v6";
vartask_name="SynchroLmsTransferOrder_v7";
varconn=_connection;
// 查询最后一次成功抓取的记录
varlast_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});
...
...
@@ -142,7 +142,9 @@ where t1.stateid!=5 and t1.isdeleted=0 and t2.deliverycount>t2.storagecount").To
logistics_name=item.logistics_name??"",
expectarrivaltime=item.expectarrivaltime,
surplus_node_days=item.surplus_node_days,
sys_update_date=DateTime.Now
sys_update_date=DateTime.Now,
quantity=item.quantity,
storage_count=item.storage_count
};
db_data.id=MyMySqlConnection._connection.QueryFirstOrDefault<int?>(" select id from dc_lms_order_transfer_current_node where `data_id`=@data_id and box_id=@box_id and sku=@sku ",new