@@ -87,7 +87,7 @@ where t1.stateid!=5 and t1.isdeleted=0 and t2.deliverycount>t2.storagecount").To
/// </summary>
publicstaticvoidSynchroLmsTransferOrder()
{
vartask_name="SynchroLmsTransferOrder_v1";
vartask_name="SynchroLmsTransferOrder_v2";
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});
...
...
@@ -130,13 +130,16 @@ where t1.stateid!=5 and t1.isdeleted=0 and t2.deliverycount>t2.storagecount").To
{
box_id=item.box_id??"",
data_id=item.data_id,
sku=item.sku??"",
node_date=item.node_date,
lms_update_date=item.update_date,
node_name=item.node_name??"",
sign_exe=item.sign_exe,
system_order_no=item.system_order_no,
trackingno=item.trackingno??"",
transfer_no=item.transfer_no??""
transfer_no=item.transfer_no??"",
logistics_code=item.logistics_code??"",
logistics_name=item.logistics_name??""
};
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 ",new