package com.ruoyi.system.controller;

import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.system.service.ILegacyTransferSyncService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

/**
 * 任务同步控制器
 * 
 * @author ruoyi
 */
@RestController
@RequestMapping("/task")
public class TaskSyncController {
    
    private static final Logger log = LoggerFactory.getLogger(TaskSyncController.class);
    
    @Autowired
    private ILegacyTransferSyncService legacyTransferSyncService;
    
    /**
     * 从旧系统同步数据到新系统
     * 
     * @param serviceOrdID 服务单ID
     * @param dispatchOrdID 调度单ID
     * @return 同步结果
     */
    @PostMapping("/syncFromLegacySystem")
    public AjaxResult syncFromLegacySystem(@RequestBody SyncRequest request) {
        try {
            Long serviceOrdID = request.getServiceOrdID();
            Long dispatchOrdID = request.getDispatchOrdID();
            
            // 参数验证
            if (serviceOrdID == null || serviceOrdID <= 0) {
                return AjaxResult.error("服务单ID不能为空且必须大于0");
            }
            
            if (dispatchOrdID == null || dispatchOrdID <= 0) {
                return AjaxResult.error("调度单ID不能为空且必须大于0");
            }
            
            log.info("开始从旧系统同步数据到新系统: ServiceOrdID={}, DispatchOrdID={}", serviceOrdID, dispatchOrdID);
            
            // 调用同步服务
            boolean result = legacyTransferSyncService.syncSingleTransferOrder(serviceOrdID, dispatchOrdID);
            
            if (result) {
                log.info("从旧系统同步数据成功: ServiceOrdID={}, DispatchOrdID={}", serviceOrdID, dispatchOrdID);
                return AjaxResult.success("同步成功");
            } else {
                log.error("从旧系统同步数据失败: ServiceOrdID={}, DispatchOrdID={}", serviceOrdID, dispatchOrdID);
                return AjaxResult.error("同步失败");
            }
            
        } catch (Exception e) {
            log.error("从旧系统同步数据异常: ServiceOrdID={}, DispatchOrdID={}", 
                     request.getServiceOrdID(), request.getDispatchOrdID(), e);
            return AjaxResult.error("同步异常: " + e.getMessage());
        }
    }
    
    /**
     * 同步请求参数类
     */
    public static class SyncRequest {
        private Long serviceOrdID;
        private Long dispatchOrdID;
        
        public Long getServiceOrdID() {
            return serviceOrdID;
        }
        
        public void setServiceOrdID(Long serviceOrdID) {
            this.serviceOrdID = serviceOrdID;
        }
        
        public Long getDispatchOrdID() {
            return dispatchOrdID;
        }
        
        public void setDispatchOrdID(Long dispatchOrdID) {
            this.dispatchOrdID = dispatchOrdID;
        }
    }
}