PAS/src/main/java/cn/cslg/pas/controller/ImportTaskController.java

package cn.cslg.pas.controller;


import cn.cslg.pas.common.PatentImportErrorLog.ImportErrorLogQueryDTO;
import cn.cslg.pas.common.PatentImportErrorLog.ImportErrorLogQueryVO;
import cn.cslg.pas.common.core.base.Constants;
import cn.cslg.pas.common.dto.ImportTaskDTO;
import cn.cslg.pas.common.model.cronModel.Records;
import cn.cslg.pas.common.model.importPDF.AddImportPDFTaskDTO;
import cn.cslg.pas.common.model.request.StringRequest;
import cn.cslg.pas.common.utils.Response;
import cn.cslg.pas.factorys.businessFactory.Business;
import cn.cslg.pas.factorys.businessFactory.BusinessFactory;
import cn.cslg.pas.service.business.*;
import cn.cslg.pas.service.common.PersonFieldService;
import io.swagger.v3.oas.annotations.Operation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@Slf4j
@RequestMapping(Constants.API_XiaoSHI + "/importTask")
@RestController
public class ImportTaskController {

    @Autowired
    private ImportTaskService importTaskService;

    @Autowired
    private BusinessFactory businessFactory;

    @Autowired
    private PatentImportErrorLogService patentImportErrorLogService;
    @Operation(summary = "查询导入任务")
    @PostMapping("/queryImportTask")
    public Response queryImportTask(@RequestBody StringRequest stringRequest) throws Exception {
        Business business = businessFactory.getClass("importTaskService");
        Records records = (Records) business.queryMessage(stringRequest);
        return Response.success(records);
    }

    @Operation(summary = "添加导入任务")
    @PostMapping("/addImportTask")
    public Response addImportTask(@RequestBody ImportTaskDTO importTaskDTO) throws Exception {
        Business business = businessFactory.getClass("importTaskService");
        Integer id = null;
        try {
            id = (Integer) business.addMessage(importTaskDTO);
        } catch (Exception e) {
            return Response.error(e.getMessage());
        }
        return Response.success(id);
    }

    @Operation(summary = "任务状态更新")
    @GetMapping("/updateImportTaskState")
    public Response updateImportTaskState(Integer taskId,Integer state) throws Exception {
        Business business = businessFactory.getClass("importTaskService");
        ImportTaskService importTaskService =(ImportTaskService)business;
        importTaskService.updateImportTaskState(taskId,state);
        return Response.success("id");
    }


@Operation(summary = "添加pdf导入任务")
@PostMapping("/addPdfTask")
public Response addPdfTask(@RequestBody AddImportPDFTaskDTO addImportPDFTaskDTO) throws Exception {
  Integer id=  importTaskService.addPdfTask(addImportPDFTaskDTO);
    return Response.success(id);
}


    @Operation(summary = "查询任务报错信息")
    @PostMapping("/getPatentImportLog")
    public Response getPatentImportLog(@RequestBody ImportErrorLogQueryDTO importErrorLogQueryDTO) throws Exception {
        Records records=  patentImportErrorLogService.getPatentImportLog(importErrorLogQueryDTO);
        return Response.success(records);
    }
}