manyi/apps/web/eventer/dianchuanServer.py

# coding=utf-8
import typing

from apps.web.eventer import EventBuilder
from apps.web.eventer.base import IdStartAckEvent, ComNetPayAckEvent


if typing.TYPE_CHECKING:
    from apps.web.user.models import ConsumeRecord


class builder(EventBuilder):
    def __getEvent__(self, device_event):

        if "order_id" in device_event:

            if device_event["order_type"] == "com_start":
                return DCServerComNetPayAckEvent(self.device.deviceAdapter, device_event)
            if device_event["order_type"] == "id_start":
                return DCServerIdStartAckEvent(self.device.deviceAdapter, device_event)


class DCServerComNetPayAckEvent(ComNetPayAckEvent):

    def do_running_order(self, order, result):  # type: (ConsumeRecord, dict)->None
        pass

    def do_finished_order(self, order, result):
        pass

    def do_finished_event(self, order, sub_orders, merge_order_info):
        pass

    def merge_order(self, master_order, sub_orders):  # type:(ConsumeRecord, list)->dict
        pass

    def _get_finish_reason(self):
        return u"未知原因"


class DCServerIdStartAckEvent(IdStartAckEvent):
    pass