Merge branch 'release/3.1.0'

ccs_connect_tiktok/__manifest__.py

@@ -32,6 +32,7 @@
         'views/cc_ship_package_view.xml',
         'views/cc_bl_view.xml',
         'views/pda_scan_record_views.xml',
+        'views/bl_patrol_views.xml',
 
     ],
     'demo': [

ccs_connect_tiktok/data/timer.xml

@@ -12,5 +12,18 @@
             <field name="active" eval="False"/>
         </record>
 
+        <record id="cron_bl_patrol" model="ir.cron">
+            <field name="name">提单巡查</field>
+            <field name="model_id" ref="ccs_connect_tiktok.model_bl_patrol"/>
+            <field name="state">code</field>
+            <field name="code">model.cron_bl_patrol()</field>
+            <field name='interval_number'>1</field>
+            <field name='interval_type'>days</field>
+            <field name="numbercall">-1</field>
+            <field name="active" eval="True"/>
+            <field name="nextcall" eval="(DateTime.now().replace(hour=0, minute=0)).strftime('%Y-%m-%d %H:%M:%S')" />
+            <field name="doall" eval="False"/>
+        </record>
+
     </data>
 </odoo>
\ No newline at end of file

ccs_connect_tiktok/models/__init__.py

@@ -9,6 +9,7 @@ from . import cc_bill_loading
 from . import ir_attachment
 from . import http
 from . import pda_scan_record
+from . import bl_patrol
 
 
 

ccs_connect_tiktok/models/bl_patrol.py

+# -*- coding: utf-8 -*-
+import logging
+import re
+from datetime import timedelta
+
+from odoo import models, fields, api
+from odoo.exceptions import UserError
+
+_logger = logging.getLogger(__name__)
+
+
+class BlPatrol(models.Model):
+    _name = 'bl.patrol'
+    _description = '提单巡查'
+    _order = 'create_date desc'
+
+    name = fields.Char('巡查名称', required=True)
+    check_date = fields.Date('巡查日期', required=True, default=fields.Date.today)
+    bl_count = fields.Integer('检查提单数量', default=0)
+    issue_count = fields.Integer('发现问题数量', default=0)
+    state = fields.Selection([
+        ('draft', '草稿'),
+        ('running', '执行中'),
+        ('done', '完成'),
+        ('failed', '失败')
+    ], string='状态', default='draft', required=True)
+
+    # 问题详情
+    package_issues = fields.Text('小包轨迹问题')
+    bl_issues = fields.Text('提单关务节点问题')
+
+    # 邮件发送记录
+    email_sent = fields.Boolean('邮件已发送', default=False)
+    email_sent_time = fields.Datetime('邮件发送时间')
+
+    @api.model
+    def cron_bl_patrol(self):
+        """
+        定时巡查提单
+        """
+        try:
+            # 创建巡查记录
+            patrol = self.create({
+                'name': f'提单巡查_{fields.Date.today()}',
+                'check_date': fields.Date.today(),
+                'state': 'running'
+            })
+
+            # 执行巡查 提单日期为近x天（默认5天），清关中和完成的提单
+            result = patrol._execute_patrol()
+
+            # 更新巡查记录 
+            patrol.write({
+                'state': 'done' if result['success'] else 'failed',
+                'bl_count': result['bl_count'],
+                'issue_count': result['issue_count'],
+                'package_issues': result['package_issues'],
+                'bl_issues': result['bl_issues']
+            })
+
+            # 如果有问题，发送邮件
+            if result['issue_count'] > 0:
+                patrol._send_patrol_email(result)
+
+            _logger.info(f"提单巡查完成: {patrol.name}, 发现问题: {result['issue_count']}")
+
+        except Exception as e:
+            _logger.error(f"提单巡查失败: {str(e)}")
+            raise UserError(f"巡查失败: {str(e)}")
+
+    def _execute_patrol(self):
+        """
+        执行巡查逻辑
+        定时巡查，每天1次，默认巡查时间为北京时间8点开始；
+        检查对象：提单日期为近x天（默认5天），清关中和完成的提单。
+        检查内容：符合要求的提单，提单关务节点同步日志是否出现倒挂
+        （根据配置的清关节点排序，若后一个节点的操作时间，小于前序节点时间，则属于倒挂），
+        是否有漏推（若节点已产生同步日期，但前序节点无同步日期，则属于漏推。是当前节点的节点无需纳入判断）；
+        """
+        # 获取配置
+        config = self.env['ir.config_parameter'].sudo()
+        check_days = int(config.get_param('patrol_check_days', default=5))  # 巡查天数
+        # 计算检查日期范围
+        end_date = fields.Date.today()
+        start_date = end_date - timedelta(days=check_days)
+        # 查找符合条件的提单 提单日期为近x天（默认5天），清关中和完成的提单。
+        bls = self.env['cc.bl'].sudo().search(
+            [('bl_date', '>=', start_date), ('bl_date', '<=', end_date), ('state', 'in', ['ccing', 'done'])])
+        _logger.info(f"开始巡查提单，检查范围: {start_date} 到 {end_date}, 提单数量: {len(bls)}")
+        error_package_issues = []
+        error_bl_issues = []
+        package_issue_counter = 1  # 小包问题独立编号
+        bl_issue_counter = 1  # 提单问题独立编号
+        for bl in bls:
+            # 检查小包轨迹问题
+            bl_package_issues = self._check_package_tracking_issues(bl)
+            if bl_package_issues:
+                # 为小包问题添加独立编号
+                for i, issue in enumerate(bl_package_issues):
+                    # 使用正则表达式匹配任何数字+顿号的格式
+                    if re.match(r'^\d+、', issue):
+                        # 替换开头的编号
+                        bl_package_issues[i] = re.sub(r'^\d+、', f"{package_issue_counter}、", issue, 1)
+                    else:
+                        # 如果没有编号，添加编号
+                        bl_package_issues[i] = f"{package_issue_counter}、{issue}"
+                    package_issue_counter += 1
+                error_package_issues.extend(bl_package_issues)
+
+            # 检查提单关务节点问题
+            bl_node_issues = self._check_bl_node_issues(bl)
+            if bl_node_issues:
+                # 为提单问题添加独立编号
+                for i, blissue in enumerate(bl_node_issues):
+                    # 使用正则表达式匹配任何数字+顿号的格式
+                    if re.match(r'^\d+、', blissue):
+                        # 替换开头的编号
+                        bl_node_issues[i] = re.sub(r'^\d+、', f"{bl_issue_counter}、", blissue, 1)
+                    else:
+                        # 如果没有编号，添加编号
+                        bl_node_issues[i] = f"{bl_issue_counter}、{blissue}"
+                    bl_issue_counter += 1
+                error_bl_issues.extend(bl_node_issues)
+        return {
+            'success': True,
+            'bl_count': len(bls),
+            'issue_count': len(error_package_issues) + len(error_bl_issues),
+            'package_issues': '\n'.join(error_package_issues) if error_package_issues else '',
+            'bl_issues': '\n'.join(error_bl_issues) if error_bl_issues else ''
+        }
+
+    def _check_package_tracking_issues(self, bl):
+        """
+        检查小包轨迹问题 - 只检查真正的小包节点，不检查关务节点
+        """
+        issues = []
+        # 按问题类型分组统计
+        reverse_issues = {}  # 倒挂问题
+        missing_issues = {}  # 漏推问题
+        # 获取该提单下所有小包的同步日志
+        ship_packages = bl.ship_package_ids
+        for package in ship_packages:
+            # 按节点编码分组，根据同步时间降序，得到对应的同步日志对象，然后再根据节点编码的顺序排序，得到同步日志对象数组
+            logs_by_process = {}
+            for log in package.sync_log_ids:
+                if log.process_code not in logs_by_process:
+                    logs_by_process[log.process_code] = log
+                else:
+                    # 如果已有该节点的日志，比较sync_time，保留最新的
+                    if log.sync_time and log.sync_time > logs_by_process[log.process_code].sync_time:
+                        logs_by_process[log.process_code] = log
+            # 方法1: 根据节点的seq进行排序（推荐）
+            sync_logs = []
+            bl_nodes = self.env['cc.node'].sudo().search([('node_type', '=', 'package'),('is_must', '=', True)], order='seq')
+            if bl_nodes:
+                for node in bl_nodes:
+                    if node.is_default:
+                        continue
+                    if node.tk_code in logs_by_process:
+                        sync_logs.append(logs_by_process[node.tk_code])
+            sync_logs = [log for log in sync_logs if log is not None]
+            #根据key排序获取logs
+            if len(sync_logs) >= 2:
+                for i in range(1, len(sync_logs)):
+                    current_log = sync_logs[i]  # 当前日志
+                    previous_log = sync_logs[i - 1]  # 前一个日志
+                    current_time = current_log.operate_time  # 当前日志时间
+                    previous_time = previous_log.operate_time  # 前一个日志时间
+                    if current_time and previous_time and current_time < previous_time:
+                        try:
+                            # 检查节点类型，只处理小包节点
+                            node = self.env['cc.node'].sudo().search([('node_type', '=', 'package'), ('tk_code', '=', current_log.process_code)])
+                            if node:  # 只处理小包节点
+                                progress_name = node.name or "空"
+                                process_code = node.tk_code or "空"
+                                issue_key = f"{progress_name}({process_code})倒挂"
+                                if issue_key not in reverse_issues:
+                                    reverse_issues[issue_key] = []
+                                reverse_issues[issue_key].append(package.logistic_order_no)
+                        except Exception as e:
+                            _logger.warning(f"构建小包倒挂问题描述失败: {str(e)}")
+                            # 如果无法确定节点类型，跳过
+                            continue
+
+            # 检查漏推问题 - 只检查小包节点
+            package_issues = self._check_package_missing_nodes(package, sync_logs)
+            for issue in package_issues:
+                # 提取问题类型
+                if "轨迹漏推" in issue:
+                    try:
+                        # 安全地提取问题类型，避免索引越界
+                        if "，出现" in issue and "，涉及" in issue:
+                            issue_key = issue.split("，出现")[1].split("，涉及")[0]
+                        else:
+                            # 如果格式不匹配，使用整个问题描述作为key
+                            issue_key = issue
+
+                        if issue_key not in missing_issues:
+                            missing_issues[issue_key] = []
+                        missing_issues[issue_key].append(package.logistic_order_no)
+                    except (IndexError, AttributeError) as e:
+                        _logger.warning(f"解析小包问题失败: {issue}, 错误: {str(e)}")
+                        # 使用整个问题描述作为key
+                        issue_key = issue
+                        if issue_key not in missing_issues:
+                            missing_issues[issue_key] = []
+                        missing_issues[issue_key].append(package.logistic_order_no)
+
+        # 格式化倒挂问题
+        issue_counter = 1
+        for issue_type, packages in reverse_issues.items():
+            package_list = self._format_package_list(packages)
+            issues.append(
+                f"{issue_counter}、{bl.bl_no}，出现{issue_type}，涉及小包{len(packages)}，小包追踪号包括{package_list}")
+            issue_counter += 1
+
+        # 格式化漏推问题
+        for issue_type, packages in missing_issues.items():
+            package_list = self._format_package_list(packages)
+            issues.append(
+                f"{issue_counter}、{bl.bl_no}，出现{issue_type}，涉及小包{len(packages)}，小包追踪号包括{package_list}")
+            issue_counter += 1
+
+        return issues
+
+    def _format_package_list(self, packages):
+        """
+        格式化小包列表，最多显示10个
+        """
+        try:
+            # 过滤掉None和空字符串
+            valid_packages = [pkg for pkg in packages if pkg and str(pkg).strip()]
+            if not valid_packages:
+                return "无有效追踪号"
+            if len(valid_packages) <= 10:
+                return "/".join(valid_packages)
+            else:
+                return "/".join(valid_packages[:10]) + "等"
+        except Exception as e:
+            _logger.warning(f"格式化小包列表失败: {str(e)}")
+            return "格式化失败"
+
+    def _check_package_missing_nodes(self, package, sync_logs):
+        """
+        检查小包漏推节点
+        """
+        issues = []
+        # 获取所有小包节点，按顺序排序
+        package_nodes = self.env['cc.node'].sudo().search([('node_type', '=', 'package'),('is_must', '=', True)], order='seq')
+        if not package_nodes:
+            return issues
+        # 检查每个节点是否有对应的同步日志
+        for node in package_nodes:
+            # 跳过当前节点（最后一个节点）
+            if node == package_nodes[-1]:
+                continue
+            # 跳过初始节点（is_default=True）
+            if getattr(node, 'is_default', False):
+                continue
+            # 检查是否有该节点的同步日志
+            has_node_log = any(log.process_code == node.tk_code for log in sync_logs)
+            # 检查后续节点是否有日志
+            next_nodes = package_nodes.filtered(lambda n: n.seq > node.seq)
+            for next_node in next_nodes:
+                has_next_log = any(log.process_code == next_node.tk_code for log in sync_logs)
+                # 如果后续节点有日志但当前节点没有，说明漏推
+                if has_next_log and not has_node_log:
+                    try:
+                        node_name = node.name or "空"
+                        tk_code = node.tk_code or "空"
+                        issues.append(
+                            f"{node_name}({tk_code})轨迹漏推"
+                        )
+                    except Exception as e:
+                        _logger.warning(f"构建小包漏推问题描述失败: {str(e)}")
+                        issues.append("节点轨迹漏推")
+                    break
+
+        return issues
+
+    def _check_bl_node_issues(self, bl):
+        """
+        检查提单关务节点问题
+        """
+        issues = []
+        # 按节点编码分组，根据同步时间降序，得到对应的同步日志对象
+        logs_by_bl_process = {}
+        for log in bl.bl_sync_log_ids:
+            if log.process_code not in logs_by_bl_process:
+                logs_by_bl_process[log.process_code] = log
+            else:
+                # 如果已有该节点的日志，比较sync_time，保留最新的
+                if log.sync_time and log.sync_time > logs_by_bl_process[log.process_code].sync_time:
+                    logs_by_bl_process[log.process_code] = log
+        # 根据节点的seq进行排序
+        sync_logs = []
+        # 获取所有提单节点，按业务顺序排序
+        bl_nodes = self.env['cc.node'].sudo().search([('node_type', '=', 'bl'),('is_must', '=', True)], order='seq')
+        if bl_nodes:
+            for node in bl_nodes:
+                if node.tk_code in logs_by_bl_process.keys():
+                    sync_logs.append(logs_by_bl_process[node.tk_code])
+        # 检查倒挂问题
+        if len(sync_logs) >= 2:
+            # 收集所有有日志的节点及其时间
+            node_logs = {}  # {node_index: (node, log, time)}
+            for i, node in enumerate(bl_nodes):
+                for log in sync_logs:
+                    if log.process_code == node.tk_code:
+                        node_logs[i] = (node, log, log.operate_time)
+                        break
+            # 遍历每个有日志的节点，与前面所有有日志的节点比较
+            for current_idx in sorted(node_logs.keys()):
+                current_node, current_log, current_time = node_logs[current_idx]
+                # 与前面所有有日志的节点比较
+                for prev_idx in sorted(node_logs.keys()):
+                    if prev_idx >= current_idx:  # 跳过自己和自己后面的节点
+                        continue
+                    prev_node, prev_log, prev_time = node_logs[prev_idx]
+                    # 检查时间顺序
+                    if current_time and prev_time:
+                        if current_time < prev_time:
+                            try:
+                                progress_name = current_log.progress_name or "空"
+                                process_code = current_log.process_code or "空"
+                                issues.append(
+                                    f"{bl.bl_no}，出现{progress_name}({process_code})倒挂"
+                                )
+                            except Exception as e:
+                                _logger.warning(f"构建倒序问题描述失败: {str(e)}")
+                                issues.append(f"{bl.bl_no}，出现节点倒挂")
+
+        # 检查漏推问题
+        missing_issues = self._check_bl_missing_nodes(bl, sync_logs)
+        if missing_issues:
+            issues.extend(missing_issues)
+        return issues
+
+    def _check_bl_missing_nodes(self, bl, sync_logs):
+        """
+        检查提单漏推节点
+        """
+        issues = []
+        # 获取所有提单节点，按顺序排序
+        bl_nodes = self.env['cc.node'].sudo().search([('node_type', '=', 'bl'),('is_must', '=', True)], order='seq')
+        if not bl_nodes:
+            return issues
+        # 检查每个节点是否有对应的同步日志
+        for node in bl_nodes:
+            # 跳过当前节点（最后一个节点）
+            if node == bl_nodes[-1]:
+                continue
+            # 跳过初始节点（is_default=True）
+            if getattr(node, 'is_default', False):
+                continue
+            # 检查是否有该节点的同步日志
+            has_node_log = any(log.process_code == node.tk_code for log in sync_logs)
+            # 检查后续节点是否有日志
+            next_nodes = bl_nodes.filtered(lambda n: n.seq > node.seq)
+            for next_node in next_nodes:
+                has_next_log = any(log.process_code == next_node.tk_code for log in sync_logs)
+                # 如果后续节点有日志但当前节点没有，说明漏推
+                if has_next_log and not has_node_log:
+                    try:
+                        node_name = node.name or "空"
+                        tk_code = node.tk_code or "空"
+                        issues.append(
+                            f"{bl.bl_no}，出现{node_name}({tk_code})轨迹漏推"
+                        )
+                    except Exception as e:
+                        _logger.warning(f"构建提单漏推问题描述失败: {str(e)}")
+                        issues.append(f"{bl.bl_no}，出现节点轨迹漏推")
+                    break
+        return issues
+
+    def _send_patrol_email(self, result):
+        """
+        发送巡查邮件
+        """
+        try:
+            # 获取邮件配置
+            config = self.env['ir.config_parameter'].sudo()
+            receiver_emails = config.get_param('patrol_receiver_emails', default='')
+            sender_email = config.get_param('patrol_sender_email', default='')
+            if not receiver_emails or not sender_email:
+                _logger.warning("邮件配置不完整，跳过邮件发送")
+                return
+
+            # 解析接收邮箱
+            receiver_list = [email.strip() for email in receiver_emails.split(';') if email.strip()]
+
+            # 构建邮件内容
+            subject = f"（重要）推送预警/{fields.Date.today()}系统巡查轨迹"
+
+            # 构建邮件内容
+            package_content = result['package_issues'] if result['package_issues'] else ""
+            bl_content = result['bl_issues'] if result['bl_issues'] else ""
+
+            content = f"""您好，经系统巡查。
+
+%s
+%s
+
+%s
+%s
+
+请立即处理！！！""" % ("发现以下提单存在小包轨迹倒挂/轨迹漏推" if package_content else "", package_content if package_content else "", "发现以下提单存在提单关务节点轨迹倒挂/轨迹漏推" if bl_content else "", bl_content if bl_content else "")
+
+            # 发送邮件
+            self.env['mail.mail'].sudo().create({
+                'subject': subject,
+                'body_html': content.replace('\n', '<br/>'),
+                'email_from': sender_email,
+                'email_to': ','.join(receiver_list),
+                'auto_delete': True,
+            }).send()
+
+            # 更新发送记录
+            self.write({
+                'email_sent': True,
+                'email_sent_time': fields.Datetime.now()
+            })
+
+            _logger.info(f"巡查邮件发送成功，接收人: {receiver_list}")
+
+        except Exception as e:
+            _logger.error(f"发送巡查邮件失败: {str(e)}")
+
+    def action_manual_patrol(self):
+        """
+        手动执行巡查
+        """
+        self.ensure_one()
+        if self.state != 'draft':
+            raise UserError('只能对草稿状态的巡查进行手动执行')
+
+        self.cron_bl_patrol()
+        return {
+            'type': 'ir.actions.client',
+            'tag': 'display_notification',
+            'params': {
+                'title': '巡查完成',
+                'message': f'巡查已完成，发现问题: {self.issue_count}',
+                'type': 'success',
+            }
+        }

ccs_connect_tiktok/models/res_config_setting.py

@@ -18,6 +18,12 @@ class ResConfigSettings(models.TransientModel):
     #交货操作晚于提货操作X分钟【默认80分钟】
     delivery_time = fields.Integer('交货操作晚于提货操作X分钟', default=80,config_parameter='delivery_time')
     
+    # 巡查配置
+    patrol_receiver_emails = fields.Char('接收邮件地址', help='多个邮箱地址，用逗号分隔', config_parameter='patrol_receiver_emails')
+    patrol_sender_email = fields.Char('发送邮箱地址', config_parameter='patrol_sender_email')
+    patrol_check_days = fields.Integer('巡查天数', default=5, help='检查近几天的提单', config_parameter='patrol_check_days')
+    patrol_start_hour = fields.Integer('巡查开始时间(小时)', default=8, help='北京时间，24小时制', config_parameter='patrol_start_hour')
+
     @api.model
     def get_values(self):
         """
@@ -32,6 +38,10 @@ class ResConfigSettings(models.TransientModel):
         tt_version = config.get_param('tt_version', default='')
         tt_customer_id = config.get_param('tt_customer_id', default=False)
         delivery_time = config.get_param('delivery_time', default=80)
+        patrol_receiver_emails = config.get_param('patrol_receiver_emails', default='')
+        patrol_sender_email = config.get_param('patrol_sender_email', default='')
+        patrol_check_days = config.get_param('patrol_check_days', default=5)
+        patrol_start_hour = config.get_param('patrol_start_hour', default=8)
         customer = self.env['res.partner'].sudo().search([('id', '=', tt_customer_id)])
         values.update(
             tt_url=tt_url,
@@ -39,7 +49,11 @@ class ResConfigSettings(models.TransientModel):
             tt_app_secret=tt_app_secret,
             tt_version=tt_version,
             tt_customer_id=customer,
-            delivery_time=delivery_time
+            delivery_time=delivery_time,
+            patrol_receiver_emails=patrol_receiver_emails,
+            patrol_sender_email=patrol_sender_email,
+            patrol_check_days=patrol_check_days,
+            patrol_start_hour=patrol_start_hour
         )
         return values
 
@@ -52,3 +66,7 @@ class ResConfigSettings(models.TransientModel):
         ir_config.set_param("tt_version", self.tt_version or "")
         ir_config.set_param("tt_customer_id", self.tt_customer_id.id or False)
         ir_config.set_param("delivery_time", self.delivery_time or 80)
+        ir_config.set_param("patrol_receiver_emails", self.patrol_receiver_emails or "")
+        ir_config.set_param("patrol_sender_email", self.patrol_sender_email or "")
+        ir_config.set_param("patrol_check_days", self.patrol_check_days or 5)
+        ir_config.set_param("patrol_start_hour", self.patrol_start_hour or 8)
\ No newline at end of file

ccs_connect_tiktok/security/ir.model.access.csv

@@ -15,3 +15,6 @@ access_cc_bl_sync_log_ccs_base.group_clearance_of_customs_user,cc_bl_sync_log cc
 access_pda_scan_record_user,pda.scan.record.user,model_pda_scan_record,base.group_user,1,1,1,0
 access_pda_scan_record_manager,pda.scan.record.manager,model_pda_scan_record,base.group_system,1,1,1,1
 
+access_bl_patrol_user,bl.patrol.user,model_bl_patrol,base.group_user,1,0,0,0
+access_bl_patrol_manager,bl.patrol.manager,model_bl_patrol,base.group_system,1,1,1,1
+

ccs_connect_tiktok/test_data.txt

-# 根据空运提单和大包以及小包和产品的关系,生成一组测试数据,每个提单包括2个大包, 每个大包包括2个小包, 每个小包包括2个产品

ccs_connect_tiktok/views/bl_patrol_views.xml

+<?xml version="1.0" encoding="utf-8"?>
+<odoo>
+    <data>
+        <!-- 巡查列表视图 -->
+        <record id="view_bl_patrol_tree" model="ir.ui.view">
+            <field name="name">bl.patrol.tree</field>
+            <field name="model">bl.patrol</field>
+            <field name="arch" type="xml">
+                <tree string="提单巡查">
+                    <field name="name"/>
+                    <field name="check_date"/>
+                    <field name="bl_count"/>
+                    <field name="issue_count"/>
+                    <field name="state"/>
+                    <field name="email_sent"/>
+                    <field name="email_sent_time"/>
+                    <field name="create_date"/>
+                </tree>
+            </field>
+        </record>
+
+        <!-- 巡查表单视图 -->
+        <record id="view_bl_patrol_form" model="ir.ui.view">
+            <field name="name">bl.patrol.form</field>
+            <field name="model">bl.patrol</field>
+            <field name="arch" type="xml">
+                <form string="提单巡查">
+                    <header>
+                        <button name="action_manual_patrol" 
+                                type="object" 
+                                string="手动执行巡查" 
+                                class="oe_highlight"
+                                attrs="{'invisible': [('state', '!=', 'draft')]}"/>
+                        <field name="state" widget="statusbar"/>
+                    </header>
+                    <sheet>
+                        <group>
+                            <group>
+                                <field name="name"/>
+                                <field name="check_date"/>
+                                <field name="bl_count"/>
+                                <field name="issue_count"/>
+                            </group>
+                            <group>
+                                <field name="email_sent"/>
+                                <field name="email_sent_time"/>
+                                <field name="create_date"/>
+                            </group>
+                        </group>
+                        <notebook>
+                            <page string="小包轨迹问题" attrs="{'invisible': [('package_issues', '=', False)]}">
+                                <field name="package_issues" readonly="1"/>
+                            </page>
+                            <page string="提单关务节点问题" attrs="{'invisible': [('bl_issues', '=', False)]}">
+                                <field name="bl_issues" readonly="1"/>
+                            </page>
+                        </notebook>
+                    </sheet>
+                </form>
+            </field>
+        </record>
+
+        <!-- 巡查搜索视图 -->
+        <record id="view_bl_patrol_search" model="ir.ui.view">
+            <field name="name">bl.patrol.search</field>
+            <field name="model">bl.patrol</field>
+            <field name="arch" type="xml">
+                <search string="提单巡查">
+                    <field name="name"/>
+                    <field name="check_date"/>
+                    <filter string="草稿" name="draft" domain="[('state', '=', 'draft')]"/>
+                    <filter string="执行中" name="running" domain="[('state', '=', 'running')]"/>
+                    <filter string="完成" name="done" domain="[('state', '=', 'done')]"/>
+                    <filter string="失败" name="failed" domain="[('state', '=', 'failed')]"/>
+                    <filter string="有问题" name="has_issues" domain="[('issue_count', '>', 0)]"/>
+                    <group expand="0" string="分组">
+                        <filter string="状态" name="group_state" context="{'group_by': 'state'}"/>
+                        <filter string="巡查日期" name="group_check_date" context="{'group_by': 'check_date'}"/>
+                    </group>
+                </search>
+            </field>
+        </record>
+
+        <!-- 巡查动作 -->
+        <record id="action_bl_patrol" model="ir.actions.act_window">
+            <field name="name">提单巡查</field>
+            <field name="res_model">bl.patrol</field>
+            <field name="view_mode">tree,form</field>
+            <field name="context">{'search_default_done': 1}</field>
+            <field name="help" type="html">
+                <p class="o_view_nocontent_smiling_face">
+                    创建第一个巡查记录
+                </p>
+                <p>
+                    系统将自动巡查提单的轨迹问题，包括小包轨迹倒挂和提单关务节点倒挂。
+                </p>
+            </field>
+        </record>
+
+        <!-- 菜单项 -->
+        <menuitem id="menu_bl_patrol"
+                  name="提单巡查"
+                  action="action_bl_patrol"
+                  sequence="22"/>
+    </data>
+</odoo> 
\ No newline at end of file

ccs_connect_tiktok/views/config_settings_views.xml

@@ -31,6 +31,23 @@
                                     </div>
                                 </div>
                             </div>
+                            <div class="col-12 col-lg-6 o_setting_box">
+                                <div class="o_setting_left_pane"/>
+                                <div class="o_setting_right_pane">
+                                    <div class="text-muted">
+                                        <label for="patrol_receiver_emails"/>
+                                        <field name="patrol_receiver_emails"/>
+                                    </div>
+                                    <div class="text-muted">
+                                        <label for="patrol_sender_email"/>
+                                        <field name="patrol_sender_email"/>
+                                    </div>
+                                    <div class="text-muted">
+                                        <label for="patrol_check_days"/>
+                                        <field name="patrol_check_days"/>
+                                    </div>
+                                </div>
+                            </div>
                             <div class="col-12 col-lg-6 o_setting_box">
                                 <div class="o_setting_left_pane"/>
                                 <div class="o_setting_right_pane">