@api.model

    def sync_wechat(self, account_id):

        """

        同步执行改为异步执行

        :param account_id:

        :return:

        """

        t = threading.Thread(target=self._sync_wechat, args=(account_id, ))

        t.start()

​

    @api.model

    def _sync_wechat(self, account_id):

        '''

        同步企业微信部门帐号信息

        :param account_id:

        :return:

        '''

        # 由于主线程env已销毁，创建新env

        with api.Environment.manage():

            with self.pool.cursor() as new_cr:

                self = self.with_env(self.env(cr=new_cr))

                # 根据传入的account_id去查询对应的cropId和secretKey

                start_time = datetime.datetime.now()

                account = self.browse([account_id])

                client = account.get_contact_client(account)

                log_model = self.env['cdtct.wechat.log']

                try:

                    # 同步部门信息

                    self.env['cdtct.wechat.department'].sync_wechat_department(account, client)

                    # 同步用户信息

                    self.env['cdtct.wechat.user'].sync_wechat_users(account, client)

                except WeChatClientException as e:

                    log_model.log_info(u'同步失败', '错误信息：{}'.format(str(e)))

                except Exception as e:

                    log_model.log_info(u'同步失败', '错误信息：{}'.format(str(e)))

​

                end_time = datetime.datetime.now()

                self.env['cdtct.wechat.log']\

                    .log_info(u'同步成功, 用时{use_time}'

                              .format(use_time=(end_time-start_time).total_seconds()))