You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
80 lines
2.3 KiB
80 lines
2.3 KiB
import datetime
|
|
|
|
from odoo import api, exceptions, fields, models, tools
|
|
from odoo.tools.translate import _
|
|
|
|
|
|
class FetchMailServer(models.Model):
|
|
_inherit = "fetchmail.server"
|
|
_name = "fetchmail.server"
|
|
|
|
_last_updated = None
|
|
|
|
run_time = fields.Datetime(string="Launch time")
|
|
|
|
def _run_time(self):
|
|
if not self._last_updated:
|
|
self._last_updated = tools.datetime.now()
|
|
|
|
src_tstamp_str = self._last_updated.strftime(
|
|
tools.misc.DEFAULT_SERVER_DATETIME_FORMAT
|
|
)
|
|
src_format = tools.misc.DEFAULT_SERVER_DATETIME_FORMAT
|
|
dst_format = tools.misc.DEFAULT_SERVER_DATETIME_FORMAT
|
|
dst_tz_name = self._context.get("tz") or self.env.user.tz
|
|
_now = tools.misc.server_to_local_timestamp(
|
|
src_tstamp_str, src_format, dst_format, dst_tz_name
|
|
)
|
|
|
|
return _now
|
|
|
|
@api.model
|
|
def _fetch_mails(self):
|
|
|
|
if self._context.get("run_fetchmail_manually"):
|
|
# if interval less than 5 seconds
|
|
if self._last_updated and (
|
|
datetime.datetime.now() - self._last_updated
|
|
) < datetime.timedelta(0, 5):
|
|
raise exceptions.Warning(
|
|
_("Error"), _("Task can be started no earlier than 5 seconds.")
|
|
)
|
|
|
|
super(FetchMailServer, self)._fetch_mails()
|
|
|
|
res = (
|
|
self.env["fetchmail.server"]
|
|
.sudo()
|
|
.with_context(tz=self.env.user.tz)
|
|
.search([("state", "=", "done")])
|
|
)
|
|
if res:
|
|
res[0].run_time = self._run_time()
|
|
|
|
|
|
class FetchMailImmediately(models.AbstractModel):
|
|
|
|
_name = "fetch_mail.imm"
|
|
|
|
@api.model
|
|
def get_last_update_time(self):
|
|
res = (
|
|
self.env["fetchmail.server"]
|
|
.sudo()
|
|
.with_context(tz=self.env.user.tz)
|
|
.search([("state", "=", "done")])
|
|
)
|
|
array = [r.run_time for r in res]
|
|
if array:
|
|
return array[0]
|
|
else:
|
|
return None
|
|
|
|
@api.model
|
|
def run_fetchmail_manually(self):
|
|
|
|
fetchmail_task = self.env.ref("fetchmail.ir_cron_mail_gateway_action")
|
|
fetchmail_model = self.env["fetchmail.server"].sudo()
|
|
|
|
fetchmail_task._try_lock()
|
|
fetchmail_model.with_context(run_fetchmail_manually=True)._fetch_mails()
|