web.assets_common.js:3556 Server application error
 Error code: 200 
 Error message: Odoo Server Error 
 Error data message:
 bus.Bus unavailable 
 Error data debug:
 Traceback (most recent call last):
  File "/usr/lib/python3/dist-packages/odoo/http.py", line 656, in _handle_exception
    return super(JsonRequest, self)._handle_exception(exception)
  File "/usr/lib/python3/dist-packages/odoo/http.py", line 314, in _handle_exception
    raise pycompat.reraise(type(exception), exception, sys.exc_info()[2])
  File "/usr/lib/python3/dist-packages/odoo/tools/pycompat.py", line 87, in reraise
    raise value
  File "/usr/lib/python3/dist-packages/odoo/http.py", line 698, in dispatch
    result = self._call_function(**self.params)
  File "/usr/lib/python3/dist-packages/odoo/http.py", line 346, in _call_function
    return checked_call(self.db, *args, **kwargs)
  File "/usr/lib/python3/dist-packages/odoo/service/model.py", line 97, in wrapper
    return f(dbname, *args, **kwargs)
  File "/usr/lib/python3/dist-packages/odoo/http.py", line 339, in checked_call
    result = self.endpoint(*a, **kw)
  File "/usr/lib/python3/dist-packages/odoo/http.py", line 941, in __call__
    return self.method(*args, **kw)
  File "/usr/lib/python3/dist-packages/odoo/http.py", line 519, in response_wrap
    response = f(*args, **kw)
  File "/usr/lib/python3/dist-packages/odoo/addons/bus/controllers/main.py", line 37, in poll
    raise Exception("bus.Bus unavailable")
Exception: bus.Bus unavailable

    response = f(*args, **kw)
  File "/mnt/hgfs/Code/odoo-11.0/odoo-11.0/addons/web/controllers/main.py", line 684, in selector
    return self._render_template(manage=False)
  File "/mnt/hgfs/Code/odoo-11.0/odoo-11.0/addons/web/controllers/main.py", line 674, in _render_template
    d['incompatible_databases'] = odoo.service.db.list_db_incompatible(d['databases'])
  File "/mnt/hgfs/Code/odoo-11.0/odoo-11.0/odoo/service/db.py", line 400, in list_db_incompatible
    cr.execute("SELECT latest_version FROM ir_module_module WHERE name=%s", ('base',))
  File "/mnt/hgfs/Code/odoo-11.0/odoo-11.0/odoo/sql_db.py", line 155, in wrapper
    return f(self, *args, **kwargs)
  File "/mnt/hgfs/Code/odoo-11.0/odoo-11.0/odoo/sql_db.py", line 232, in execute
    res = self._obj.execute(query, params)
psycopg2.errors.InsufficientPrivilege: permission denied for relation ir_module_module

def _get_wechatpay(self):
    """获取微信支付客户端"""
    try:
        # WeChatPay has no sandbox enviroment.
        wechatpay = WeChatPay(self.wechatpay_appid,
                                self.wechatpay_app_key,
                                self.wechatpay_mch_id,
                                mch_cert=self.wechatpay_mch_cert,
                                mch_key=self.wechatpay_mch_key)
        return wechatpay
    except Exception as err:
        _logger.exception(f"生成微信支付客户端失败:{err}")

@api.model
def wechatpy_query_pay(self, order):
    """
    主动去微信支付查询支付结果
    用户支付前没有transcation_id因此，只能用商户自有订单号去查
    只有SUCCESS支付成功，其他状态均不成功
    """
    wechatpay = self._get_wechatpay()
    res = wechatpay.order.query(out_trade_no=order)
    _logger.info("主动查询微信支付结果:{}".format(res))
    if res["return_code"] == "SUCCESS" and res["result_code"] == "SUCCESS":
        if res["trade_state"] == "SUCCESS":
            transaction = self.env["payment.transaction"].sudo().search(
                [('reference', '=', order)], limit=1)
            if transaction.state in ('draft', 'pending', 'authorized'):
                # 将支付结果设置完成
                result = {
                    "acquirer_reference": res['transaction_id']
                }
                transaction.write(result)
                transaction._set_transaction_done()
                return True
            elif transaction.state == 'done':
                return True
            else:
                return False
    return False

def _verify_wechatpay(self, data):
    """验证微信支付服务器返回的信息"""
    try:
        wechatpay = self._get_wechatpay()
        result = wechatpay.parse_payment_result(data)
        _logger.info("解析微信支付返回结果：{}".format(result))
        if result['result_code'] == 'SUCCESS' and result['return_code'] == 'SUCCESS':
            # 支付校验成功
            transaction = self.env["payment.transaction"].sudo().search(
                [('reference', '=', result["out_trade_no"])], limit=1)
            if transaction.state in ('draft', 'pending', 'authorized'):
                # 将支付结果设置完成
                result = {
                    "acquirer_reference": result['transaction_id']
                }
                transaction.write(result)
                transaction._set_transaction_done()
                return True
            elif transaction.state == 'done':
                return True
            else:
                return False
        return False
    except Exception as err:
        _logger.error("解析微信支付推送消息失败:{}".format(traceback.format_exc()))
        return False

ValueError: No possible route found for incoming message from <microsoft@outlook-address.com> to "'Administrator'" <my_address@gmail.com> (Message-Id <000f01d39516$e032a170$a097e450$@outlook-address.com>:). Create an appropriate mail.alias or force the destination model.

mail_thread model is meant to be inherited by any model that needs to
act as a discussion topic on which messages can be attached. Public
methods are prefixed with ``message_`` in order to avoid name
collisions with methods of the models that will inherit from this class.

``mail.thread`` defines fields used to handle and display the
communication history. ``mail.thread`` also manages followers of
inheriting classes. All features and expected behavior are managed
by mail.thread. Widgets has been designed for the 7.0 and following
versions of Odoo.

Inheriting classes are not required to implement any method, as the
default implementation will work for any model. However it is common
to override at least the ``message_new`` and ``message_update``
methods (calling ``super``) to add model-specific behavior at
creation and update of a thread when processing incoming emails.

class res_partner(models.Model):
    _inherit = "res.partner"

    @api.multi
    def message_update(self, msg_dict, update_vals=None):
        pass

$ rabbitmqadmin -f tsv -q list queues name > q.txt

$ while read -r name; do rabbitmqadmin -q delete queue name="${name}"; done < q.txt

rabbitmqadmin --host=localhost -u xxxxx -p xxxxx -f tsv -q list queues name > q.txt

2019-11-19 06:53:11,381 10002 INFO ? odoo.sql_db: ConnectionPool(used=0/count=0/max=64): Closed 4 connections to 'user=odoo password=xxx dbname=erp host=172.19.0.12 port=5432 sslmode=prefer' 
2019-11-19 06:53:11,399 10002 INFO ? odoo.sql_db: ConnectionPool(used=0/count=0/max=64): Closed 1 connections to 'user=odoo password=xxx dbname=erp-dev host=172.19.0.12 port=5432 sslmode=prefer' 
2019-11-19 06:53:11,417 10002 INFO ? odoo.sql_db: ConnectionPool(used=0/count=0/max=64): Closed 1 connections to 'user=odoo password=xxx dbname=odoo host=172.19.0.12 port=5432 sslmode=prefer' 
2019-11-19 06:53:11,434 10002 INFO ? odoo.sql_db: ConnectionPool(used=0/count=0/max=64): Closed 1 connections to 'user=odoo password=xxx dbname=demo host=172.19.0.12 port=5432 sslmode=prefer' 
2019-11-19 06:53:16,247 10003 INFO erp odoo.addons.base.models.ir_cron: Starting job `Backup scheduler`. 
2019-11-19 06:53:16,273 10003 INFO erp odoo.modules.registry: Invalidating all model caches after database signaling. 
2019-11-19 06:53:16,280 10003 ERROR erp odoo.addons.base.models.ir_cron: Call from cron Backup scheduler for server action #762 failed in Job #24 
Traceback (most recent call last):
  File "/usr/lib/python3/dist-packages/odoo/addons/base/models/ir_cron.py", line 102, in _callback
--
ERROR: cursor already closed 
2019-11-19 06:55:21,297 10002 INFO ? odoo.sql_db: ConnectionPool(used=0/count=0/max=64): Closed 5 connections to 'user=odoo password=xxx dbname=erp host=172.19.0.12 port=5432 sslmode=prefer' 
2019-11-19 06:55:21,307 10002 ERROR erp odoo.addons.orssica_erp.models.consumer: Traceback (most recent call last):
  File "/home/ubuntu/odoo/odoo-dev/custom/he_addons/orssica_erp/models/consumer.py", line 127, in handler_output
    picking = picking_obj.create(picking_data)
  File "<decorator-gen-394>", line 2, in create
  File "/usr/lib/python3/dist-packages/odoo/api.py", line 430, in _model_create_single
    return create(self, arg)
  File "/home/ubuntu/odoo/odoo-dev/custom/he_addons/pos_retail/models/stock/stock_picking.py", line 15, in create
    picking = super(stock_picking, self).create(vals)
  File "<decorator-gen-194>", line 2, in create
--
psycopg2.InterfaceError: cursor already closed

limit_time_cpu = 7200
limit_time_real = 7200
; limit_request = 200
workers = 4 
limit_memory_hard = 1610612736
limit_memory_soft = 4294967296  
; list_db = False

@locked
def close_all(self, dsn=None):
    count = 0
    last = None
    for i, (cnx, used) in tools.reverse_enumerate(self._connections):
        if dsn is None or cnx._original_dsn == dsn:
            cnx.close()
            last = self._connections.pop(i)[0]
            count += 1
    _logger.info('%r: Closed %d connections %s', self, count,
                (dsn and last and 'to %r' % last.dsn) or '')

def process_work(self):
    rpc_request = logging.getLogger('odoo.netsvc.rpc.request')
    rpc_request_flag = rpc_request.isEnabledFor(logging.DEBUG)
    _logger.debug("WorkerCron (%s) polling for jobs", self.pid)
    db_names = self._db_list()
    if len(db_names):
        self.db_index = (self.db_index + 1) % len(db_names)
        db_name = db_names[self.db_index]
        self.setproctitle(db_name)
        if rpc_request_flag:
            start_time = time.time()
            start_memory = memory_info(psutil.Process(os.getpid()))

        from odoo.addons import base
        base.models.ir_cron.ir_cron._acquire_job(db_name)

        # dont keep cursors in multi database mode
        if len(db_names) > 1:
            odoo.sql_db.close_db(db_name)
        if rpc_request_flag:
            run_time = time.time() - start_time
            end_memory = memory_info(psutil.Process(os.getpid()))
            vms_diff = (end_memory - start_memory) / 1024
            logline = '%s time:%.3fs mem: %sk -> %sk (diff: %sk)' % \
                (db_name, run_time, start_memory / 1024, end_memory / 1024, vms_diff)
            _logger.debug("WorkerCron (%s) %s", self.pid, logline)

        self.request_count += 1
        if self.request_count >= self.request_max and self.request_max < len(db_names):
            _logger.error("There are more dabatases to process than allowed "
                            "by the `limit_request` configuration variable: %s more.",
                            len(db_names) - self.request_max)
    else:
        self.db_index = 0

import pika

credential = pika.PlainCredentials("test", "test")

conn = pika.BlockingConnection(
    pika.ConnectionParameters(host="rabbitmq.test.com", credentials=credential, heartbeat=60))
channel = conn.channel()
channel.queue_declare("test", durable=True)

def call_back(ch, method, properties, body):
    print(f"收到消息..{body.decode('utf-8')}")


channel.basic_consume("test", call_back, auto_ack=True)
channel.start_consuming()

def run(self):
    try:
        channel = self.get_client()
        self.state = 'running'
        _logger.info(f"运行RabbitMQ消费者:{self.name}")
        t = threading.Thread(target=channel.start_consuming)
        t.setDaemon(True)
        t.start()
    except Exception as err:
        self.state = 'stopped'
        _logger.error(f"启动线程失败：{traceback.format_exc()}")

class AcquirerAlipay(models.Model):
    _inherit = 'payment.acquirer'

    provider = fields.Selection(selection_add=[('alipay', "AliPay")])
    seller_id = fields.Char("Alipay Seller Id", required=True)
    alipay_appid = fields.Char("Alipay AppId", required=True)
    alipay_secret = fields.Binary("Merchant Private Key")
    alipay_public_key = fields.Binary("Alipay Public Key")
    alipay_sign_type = fields.Selection(
        selection=[('rsa', 'RSA'), ('rsa2', 'RSA2')], string="Sign Type")

@api.multi
def alipay_get_form_action_url(self):
    return "/payment_alipay/jump"

@http.route('/payment_alipay/jump', auth='public')
def index(self, **kw):
    """跳转至支付宝付款页面"""
    kw["csrf_token"] = request.csrf_token()
    kw["notify_url"] = self._notify_url
    alipay = request.env["payment.acquirer"].sudo().search(
        [('provider', '=', 'alipay')], limit=1)
    return redirect_with_hash(alipay._get_alipay_url(kw))

@api.model
def _get_alipay_url(self, params=None):
    """Alipay URL"""
    base_url = self.env['ir.config_parameter'].sudo(
    ).get_param('web.base.url')
    # 额外的参数
    passback_params = quote_plus("&".join(
        f"{k}={v}" for k, v in params.items() if v)) if params else None
    alipay = self._get_alipay()
    alipay.return_url = f'{base_url}{params["return_url"]}'
    alipay.notify_url = f'{base_url}{params["notify_url"]}'

    return alipay.pay.trade_page_pay(params["reference"], params["amount"],
                                        params["reference"], product_code="FAST_INSTANT_TRADE_PAY",
                                        passback_params=passback_params)

@api.multi
def _alipay_form_validate(self, data):
    """验证支付"""
    if self.state == 'done':
        _logger.info(f"支付已经验证：{data['out_trade_no']}")
        return True
    result = {
        "acquirer_reference": data["trade_no"]
    }
    # 根据支付宝同步返回的信息，去支付宝服务器查询
    payment = self.env["payment.acquirer"].sudo().search(
        [('provider', '=', 'alipay')], limit=1)
    alipay = payment._get_alipay()
    res = alipay.pay.trade_query(out_trade_no=data["out_trade_no"])
    # 校验结果
    if res["code"] == "10000" and res["trade_status"] in ("TRADE_SUCCESS", "TRADE_FINISHED"):
        _logger.info(f"支付单：{data['out_trade_no']} 已成功付款")
        self._set_transaction_done()
    if res["code"] == "10000" and res["trade_status"] == "WAIT_BUYER_PAY":
        _logger.info(f"支付单：{data['out_trade_no']} 正等待付款...")
        self._set_transaction_pending()
    if res["code"] == "10000" and res["trade_status"] == "TRADE_CLOSED":
        _logger.info(f"支付单：{data['out_trade_no']} 已关闭或已退款.")
        self._set_transaction_cancel()
    return self.write(result)

def _verify_pay(self, data):
    """
    验证支付宝返回的信息
    """
    alipay = self._get_alipay()
    # 验证是否符合验签逻辑
    if not alipay.comm.validate_sign(data):
        _logger.warn(f"支付宝推送支付结果验签失败：{data}")
        return False
    # 校验收款方
    if self.alipay_appid != data["app_id"]:
        _logger.warn(f"支付宝推送AppID校验失败:{data['app_id']}")
        return False
    if self.seller_id != data["seller_id"]:
        _logger.warn(f"支付宝推送卖家ID校验失败:{data['seller_id']}")
        return False
    # 校验支付信息
    transaction = self.env["payment.transaction"].sudo().search(
        [('reference', '=', data["out_trade_no"])], limit=1)
    if float(transaction.amount) != float(data["total_amount"]):
        _logger.warn(
            f"支付宝推送金额{float(transaction.amount)}与系统订单不符:{float(data['total_amount'])}")
        return False
    # 将支付结果设置完成
    if transaction.state != "done" and data["trade_status"] == "TRADE_SUCCESS":
        transaction.acquirer_reference = data["trade_no"]
        transaction._set_transaction_done()
    return True

not all arguments converted during string formatting

The transaction %s with %s for %s has been confirmed. The related payment is posted: %s

%s的%s交易%s已确认。等待获取发送付款状态......