-- 车辆和人员变更重新同步定时任务配置SQL
-- 在sys_job表中添加定时任务
-- 调用旧系统 admin_save_25.asp 接口更新调度单
-- 
-- 需要重新同步的变更类型：
--   1. 车辆变更：修改了分配的车辆
--   2. 执行人员变更：修改了执行人员（司机、医生、护士）
--   3. 地址变更：修改了转出医院地址或转入医院地址
--   4. 成交价变更：修改了转运费用（transfer_price）

-- 重新同步车辆和人员变更的任务到旧系统
INSERT INTO sys_job (job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, status, create_by, create_time, remark)
VALUES 
('同步服务调度到旧系统变更', 'DEFAULT', 'legacySystemSyncTask.resyncVehicleAndPersonnel', '0 0/5 * * * ?', '3', '1', '0', 'admin', sysdate(), 
'每5分钟自动重新同步车辆、人员、地址、成交价发生变更的任务到旧系统。当任务的车辆、人员、地址或费用被修改后，会标记need_resync=1，定时任务会将这些变更同步到旧系统调度单表。');

-- 说明：
-- job_name: 任务名称
-- job_group: 任务组名（DEFAULT为默认组）
-- invoke_target: 调用目标字符串（Bean名称.方法名）
--   - legacySystemSyncTask.resyncVehicleAndPersonnel() 重新同步车辆和人员变更
--
-- cron_expression: cron表达式
--   - '0 0/5 * * * ?' = 每5分钟执行一次（推荐）
--   - '0 0/10 * * * ?' = 每10分钟执行一次
--   - '0 0/3 * * * ?' = 每3分钟执行一次（仅在变更频繁时使用）
--
-- misfire_policy: 错过执行策略
--   - 1=立即执行
--   - 2=执行一次
--   - 3=放弃执行（推荐）
--
-- concurrent: 是否并发
--   - 0=允许并发
--   - 1=禁止并发（推荐，避免重复同步）
--
-- status: 状态
--   - 0=正常（启用）
--   - 1=暂停（停用）

-- 使用场景：
-- 1. 车辆信息变更：
--    - 任务分配的车辆被更换
--    - 车辆信息（车牌号等）被修改
--
-- 2. 人员信息变更：
--    - 执行人员（司机、医生、护士等）被重新分配
--    - 人员信息被修改
--
-- 3. 地址信息变更：
--    - 转出医院地址被修改
--    - 转入医院地址被修改
--
-- 4. 成交价变更：
--    - 转运费用（transfer_price）被修改
--
-- 3. 同步流程：
--    - 在修改车辆、人员、地址或成交价时，设置 need_resync = 1
--    - 定时任务查询 need_resync = 1 且 dispatch_sync_status = 2 的任务
--    - 调用旧系统 admin_save_25.asp 接口重新同步调度单信息（而非 admin_save_24.gds）
--    - 同步成功后设置 need_resync = 0
--
-- 4. 性能优化：
--    - 每批次限制100条记录
--    - 每条记录间隔1秒
--    - 禁止并发执行
--    - 只同步未完成和未取消的任务

-- 监控查询示例：

-- 查看需要重新同步的任务数量：
-- SELECT COUNT(*) FROM sys_task_emergency
-- WHERE need_resync = 1
--   AND dispatch_sync_status = 2
--   AND legacy_dispatch_ord_id IS NOT NULL;

-- 查看重新同步状态统计：
-- SELECT 
--     need_resync,
--     CASE need_resync
--         WHEN 0 THEN '无需重新同步'
--         WHEN 1 THEN '需要重新同步'
--     END AS resync_status,
--     COUNT(*) AS count
-- FROM sys_task_emergency
-- WHERE dispatch_sync_status = 2
-- GROUP BY need_resync;

-- 查看今日重新同步失败的记录：
-- SELECT te.*, t.task_code, t.task_status
-- FROM sys_task_emergency te
-- JOIN sys_task t ON te.task_id = t.task_id
-- WHERE te.need_resync = 1
--   AND te.dispatch_sync_status = 2
--   AND DATE(te.dispatch_sync_time) = CURDATE()
--   AND te.dispatch_sync_error_msg IS NOT NULL;