|
@@ -41,10 +41,14 @@ group by sku_id
|
|
delete from ruixuan.kwaixiaodian_jst_purchase_items_range where sku_id='{sku_id}'
|
|
delete from ruixuan.kwaixiaodian_jst_purchase_items_range where sku_id='{sku_id}'
|
|
""".format(sku_id=sku_id)
|
|
""".format(sku_id=sku_id)
|
|
self.conn.Operate(sku_range_delete)
|
|
self.conn.Operate(sku_range_delete)
|
|
- sku_sql = """select sku_id,qty,price,po_date ,poi_id,po_id
|
|
|
|
- from ruixuan.kwaixiaodian_jst_purchase_items
|
|
|
|
- where sku_id='{sku_id}'
|
|
|
|
- order by po_date """.format(sku_id=sku_id)
|
|
|
|
|
|
+ sku_sql = """select sku_id,qty,price,a.po_date ,poi_id,a.po_id
|
|
|
|
+ from ruixuan.kwaixiaodian_jst_purchase_items a
|
|
|
|
+ left join ruixuan.kwaixiaodian_jst_purchase b
|
|
|
|
+ on a.po_id=b.po_id
|
|
|
|
+ where sku_id='{sku_id}' and b.status in('Finished','Confirmed' )
|
|
|
|
+ and b.po_id is not null
|
|
|
|
+order by po_date
|
|
|
|
+""".format(sku_id=sku_id)
|
|
data_list = self.conn.QueryAll(sql=sku_sql)
|
|
data_list = self.conn.QueryAll(sql=sku_sql)
|
|
sumqty = 0
|
|
sumqty = 0
|
|
end_qty = 0
|
|
end_qty = 0
|