| | |
|---|
| | | from trade import trade_manager, l2_trade_util, trade_data_manager, trade_constant |
|---|
| | | import l2_data_util as l2_data_util_old |
|---|
| | | from trade.buy_money_count_setting import BuyMoneyAndCountSetting, RadicalBuyBlockCodeCountManager |
|---|
| | | from trade.buy_radical import block_special_codes_manager |
|---|
| | | |
|---|
| | | from trade.huaxin import huaxin_trade_api, huaxin_trade_data_update, \ |
|---|
| | | huaxin_trade_record_manager, huaxin_trade_order_processor, huaxin_sell_util |
|---|
| | |
|---|
| | | source_origin_dict = copy.deepcopy(CodeThirdBlocksManager().get_source_blocks_origin(code)) |
|---|
| | | if not source_origin_dict: |
|---|
| | | source_origin_dict = {} |
|---|
| | | kpl_blocks = RadicalBuyBlockManager.get_code_kpl_blocks(code) |
|---|
| | | kpl_blocks = set() |
|---|
| | | if kpl_blocks is None: |
|---|
| | | kpl_blocks = set() |
|---|
| | | if not kpl_blocks: |
|---|
| | | KPLCodeJXBlockManager().load_jx_blocks_radical(code) |
|---|
| | | |
|---|
| | | filter_blocks, match_blocks = RadicalBuyBlockManager.get_code_blocks(code) |
|---|
| | | source_origin_dict[SOURCE_TYPE_KPL] = kpl_blocks |
|---|
| | |
|---|
| | | self.send_response({"code": 0, "data": list(codes), "msg": f""}, |
|---|
| | | client_id, |
|---|
| | | request_id) |
|---|
| | | |
|---|
| | | elif ctype == "async_radical_buy_special_codes": |
|---|
| | | # 同步扫入买的辨识度代码 |
|---|
| | | count = block_special_codes_manager.update_block_special_codes() |
|---|
| | | self.send_response({"code": 0, "msg": f"更新成功数量：{count}"}, |
|---|
| | | client_id, |
|---|
| | | request_id) |
|---|
| | | |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | logger_debug.exception(e) |
|---|
