package com.ruoyi.web.controller.task;

import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.system.domain.SysTask;
import com.ruoyi.system.domain.SysTaskAttachment;
import com.ruoyi.system.service.ISysTaskService;
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.system.service.ITaskAttachmentSyncService;
import com.ruoyi.system.task.ITaskAttachmentService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * 任务附件同步Controller
 * 用于将任务附件同步到ImageData表
 * 
 * @author ruoyi
 */
@RestController
@RequestMapping("/task/attachment/sync")
public class TaskAttachmentSyncController extends BaseController {
    
    @Autowired
    private ITaskAttachmentSyncService taskAttachmentSyncService;

    @Autowired
    private ITaskAttachmentService taskAttachmentService;
    
    @Autowired
    private ISysTaskService sysTaskService;

    @Autowired
    private ISysUserService sysUserService;

    /**
     * 手动同步单个任务的附件到ImageData
     * 
     * @param taskId 任务ID
     * @return 同步结果
     */
    @PreAuthorize("@ss.hasPermi('task:general:edit')")
    @Log(title = "任务附件同步", businessType = BusinessType.OTHER)
    @PostMapping("/task/{taskId}")
    public AjaxResult syncTaskAttachments(@PathVariable("taskId") Long taskId) {
        try {
            // 查询任务详情
            SysTask task = sysTaskService.getTaskDetail(taskId);
            SysUser user = sysUserService.selectUserById(task.getCreatorId());
            Integer oaUserId=user.getOaUserId();
            if (task == null) {
                return error("任务不存在");
            }
            
            // 获取serviceOrderId和dispatchOrdId
            Long serviceOrderId = null;
            Long dispatchOrdId = null;
            
            if (task.getEmergencyInfo() != null) {
                serviceOrderId = task.getEmergencyInfo().getLegacyServiceOrdId();
                dispatchOrdId = task.getEmergencyInfo().getLegacyDispatchOrdId();
            }
            
            if (serviceOrderId == null && dispatchOrdId == null) {
                return error("任务未关联服务单或调度单，无法同步");
            }
            List<SysTaskAttachment> attachmentList=sysTaskService.getAttachmentsByTaskId(taskId);
            // 执行同步
            List<SysTaskAttachment> attachments = taskAttachmentSyncService.syncTaskAttachmentsToImageData(
                    attachmentList, serviceOrderId, dispatchOrdId,oaUserId);

            for(SysTaskAttachment attachment:attachments){

                taskAttachmentService.updateAttachment(attachment);
            }

            return success("成功同步 " + attachments.stream().count() + " 个附件");
        } catch (Exception e) {
            logger.error("同步任务附件失败", e);
            return error("同步失败：" + e.getMessage());
        }
    }


    /**
     * 检查附件是否已同步
     * 
     * @param attachmentId 附件ID
     * @return 同步状态
     */
    @PreAuthorize("@ss.hasPermi('task:general:query')")
    @GetMapping("/check/{attachmentId}")
    public AjaxResult checkAttachmentSynced(@PathVariable("attachmentId") Long attachmentId) {
        try {
            boolean synced = taskAttachmentService.isAttachmentSynced(attachmentId);
            return AjaxResult.success(synced ? "已同步" : "未同步", synced);
        } catch (Exception e) {
            logger.error("检查附件同步状态失败", e);
            return error("检查失败：" + e.getMessage());
        }
    }
}