@@ -88,7 +88,7 @@ where t1.stateid!=5 and t1.isdeleted=0 and t2.deliverycount>t2.storagecount ").T
/// </summary>
publicstaticvoidSynchroLmsTransferOrder()
{
vartask_name="SynchroLmsTransferOrder_v12";
vartask_name="SynchroLmsTransferOrder_v14";
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});
...
...
@@ -148,6 +148,14 @@ where t1.stateid!=5 and t1.isdeleted=0 and t2.deliverycount>t2.storagecount ").T
storage_count=item.storage_count,
sign_time=item.sign_time,
put_time=item.put_time,
collect_time=item.collect_time,
flight_time=item.flight_time,
transport_time=item.transport_time,
ascan_time=item.ascan_time,
arrival_time=item.arrival_time,
clearance_time=item.clearance_time,
sail_time=item.sail_time
};
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