| | |
|---|
| | | datas.append(_queue.get()) |
|---|
| | | if datas: |
|---|
| | | # 上传数据 |
|---|
| | | middle_api_protocol.request(middle_api_protocol.get_big_orders(datas)) |
|---|
| | | requests.post("http://192.168.84.71:12881/upload_deal_big_orders", json.dumps(datas)) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | finally: |
|---|
| | |
|---|
| | | fdata = {"type": "get_third_blocks", |
|---|
| | | "data": {"ctype": "get_third_blocks", "data": {"code": code, "source": source}}} |
|---|
| | | return fdata |
|---|
| | | |
|---|
| | | |
|---|
| | | # ------------------------------成交大单上传------------------------------------ |
|---|
| | | def get_big_orders(datas): |
|---|
| | | fdata = {"type": "upload_deal_big_orders", "data": {"ctype": "upload_deal_big_orders", "data": datas}} |
|---|
| | | return fdata |
|---|
