cron.py 文件源码

def process(self):
        event = models.AgitationEvent.objects.select_related('place__region', 'cubeusageinevent').filter(id=self._event_id).first()
        if not event or event.is_canceled or not event.need_cube:
            return
        region = event.place.region
        if not region.registrations_chat_id:
            return
        if self._prev_message_id:
            utils.safe_delete_message(self._bot, region.registrations_chat_id, self._prev_message_id)
        cube_usage = event.cube_usage
        if cube_usage and cube_usage.shipped_to and cube_usage.shipped_by:
            return
        new_message = self._bot.send_message(region.registrations_chat_id,
                                             '?????????? ?????? ??? ????? %s %s' % (event.show(), event.place.show()),
                                             parse_mode='Markdown',
                                             reply_markup=InlineKeyboardMarkup([[
                                                InlineKeyboardButton(
                                                    '????????????',
                                                    callback_data=TRANSFER_CUBE_TO_EVENT + str(event.id))]]))
        self._prev_message_id = new_message.message_id
        return self.repeat()