gp_low_suction.git

			@@ -54,7 +54,30 @@
			持仓查询
			:return:
			"""
			return self.context.account().positions()
			try:
			return self.context.account().positions()
			except:
			return []

			def queryUnfinishOrders(self):
			"""
			查询未完成委托
			:return:
			"""
			try:
			return get_unfinished_orders()
			except:
			return []

			def cancelOrders(self, local_id, account_id):
			"""
			撤单
			:param local_id: 本地订单ID
			:param account_id: 账号ID
			:return:
			"""
			async_log_util.info(logger_trade, f"撤单：{local_id}-{account_id}")
			return order_cancel([{"cl_ord_id": local_id, "account_id": account_id}])


			__JueJinTradeManager = JueJinTradeManager()
			@@ -75,6 +98,7 @@
			def on_execution_report(context, execrpt):
			logger_trade.info(f"on_execution_report：{execrpt}")
			logger_print.info(f"on_execution_report：{execrpt}")


			def on_error(context, execrpt):
			logger_print.info(f"on_error：{execrpt}")
			@@ -98,6 +122,12 @@
			elif type == 'position':
			results = __JueJinTradeManager.queryPosition()
			__send_request_response(request_id, results)
			elif type == 'get_unfinish_orders':
			results = __JueJinTradeManager.queryUnfinishOrders()
			__send_request_response(request_id, results)
			elif type == 'cancel_order':
			__JueJinTradeManager.cancelOrders(data["local_order_id"], data["account_id"])
			__send_request_response(request_id, {})
			except Exception as e:
			logger_print.exception(e)