'功能完善'

admin

2024-06-25 4af40e8ec9315c413fee3dc9f73ad43f9a5dbee9

 local_api/juejin.py

@@ -54,7 +54,30 @@
        持仓查询
        :return:
        """
        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)