F2_OFD/src/main/java/com/example/duplicate/controller/TaskController.java

package com.example.duplicate.controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.example.duplicate.controller.param.UploadBatchFileParam;
import com.example.duplicate.controller.param.updateTaskDto;
import com.example.duplicate.controller.param.FileUpload;
import com.example.duplicate.service.TaskService;
import com.example.utils.CommonResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

/**
 * @ClassName TaskController
 * @Description 任务接口
 * @Author linjj
 * @Date 2024/8/5 14:21
 * @Version 1.0
 */
@RestController
@RequestMapping("/task")
@Api(value = "任务接口", tags = "任务对外接口")
@Slf4j
public class TaskController {

    @Autowired
    private TaskService taskService;

    /**
     * @description: 获取任务接口
     * @params: collectid
     * @return: data
     * @author linjj
     * @date: 2024/8/5 14:46
     */
    @PostMapping("/getTask")
    @ApiOperation("获取任务接口")
    @ResponseBody
    public CommonResult<?> GetTask(@RequestParam @ApiParam(required = false, name = "collectId", value = "采集器id") String collectId) {
        return taskService.GetTask(collectId);
    }

    /**
     * @description: 补偿患者所有采集任务接口
     * @params: masterId
     * @return: data
     * @author linjj
     * @date: 2024/8/5 15:31
     */
    //补偿接口
    @PostMapping(value = "repairTask")
    @ApiOperation("补偿患者所有采集任务接口")
    @ResponseBody
    public CommonResult<?> repairTask(@RequestParam @ApiParam(required = false, name = "masterId", value = "患者masterId") String masterId) {
        if (StringUtils.isBlank(masterId)) {
            return CommonResult.failed("masterId不能为空");
        }
        return taskService.repairTask(masterId);
    }

    /**
     * @description: 补偿患者单个采集任务接口
     * @params: masterId
     * @params: collectId
     * @return: CommonResult
     * @author linjj
     * @date: 2024/8/6 9:15
     */
    @PostMapping(value = "repairTaskByCollectId")
    @ApiOperation("补偿患者单个采集任务接口")
    @ResponseBody
    public CommonResult<?> repairTask(@RequestParam @ApiParam(required = false, name = "masterId", value = "患者masterId") String masterId,
                                      @RequestParam @ApiParam(required = false, name = "collectId", value = "采集器id") String collectId) {
        if (StringUtils.isBlank(masterId)) {
            return CommonResult.failed("masterId不能为空");
        }
        if (StringUtils.isBlank(collectId)) {
            return CommonResult.failed("collectId不能为空");
        }
        return taskService.repairTaskByCollectId(masterId, collectId);
    }

    /**
     * @description: 根据采集器id患者id删除单据
     * @params: masterId
     * @params: collectId
     * @author linjj
     * @date: 2024/12/26 14:30
     */
    @PostMapping(value = "delFileBySource")
    @ApiOperation("根据采集器id患者id删除单据")
    @ResponseBody
    public CommonResult<?> delFileBySource(@RequestParam @ApiParam(required = false, name = "masterId", value = "患者masterId") String masterId,
                                           @RequestParam @ApiParam(required = false, name = "collectId", value = "采集器id") String collectId) {
        if (StringUtils.isBlank(masterId)) {
            return CommonResult.failed("masterId不能为空");
        }
        if (StringUtils.isBlank(collectId)) {
            return CommonResult.failed("collectId不能为空");
        }
        return taskService.delFileBySource(masterId,collectId);
    }

    /**
     * @description: 维护任务表接口
     * @params: updateTaskDto
     * @return: CommonResult
     * @author linjj
     * @date: 2024/8/6 9:17
     */
    @PostMapping(value = "updateTask")
    @ApiOperation("维护任务表接口")
    @ResponseBody
    public CommonResult<?> updateTask(updateTaskDto dto) {
        return taskService.updateTask(dto);
    }

    /**
     * @description: 文件上传接口
     * @params: files
     * @params: uploadBatchFileParam
     * @return: CommonResult
     * @author linjj
     * @date: 2024/8/6 14:13
     */
    @PostMapping(value = "fileUpload")
    @ApiOperation("文件上传接口")
    @ResponseBody
    public CommonResult<?> fileUpload(@RequestPart("files") MultipartFile[] files, UploadBatchFileParam uploadBatchFileParam) {
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String format = dateFormat.format(new Date());
        //成功流水号id
        List<String> serialNumberIds = new ArrayList<>();
        //失败流水号id
        List<String> failIds = new ArrayList<>();
        if (Objects.isNull(uploadBatchFileParam) || Objects.isNull(uploadBatchFileParam.getUploadFileParams())) {
            log.info(format + "文件上传参数为空！");
            return CommonResult.failed("文件上传参数为空！");
        }
        log.info(format + "本次文件上传传输参数为:" + JSONObject.toJSONString(uploadBatchFileParam));
        List<FileUpload> fileUpload = JSONArray.parseArray(uploadBatchFileParam.getUploadFileParams(), FileUpload.class);
        for (FileUpload dto : fileUpload) {
            if (StringUtils.isBlank(dto.getMasterid())) {
                log.info(format + "病案主键不能为空！");
                return CommonResult.failed("病案主键不能为空");
            }
            if (StringUtils.isBlank(dto.getAssortid())) {
                log.info(format + "文件分段id不能为空！");
                return CommonResult.failed("文件分段id不能为空");
            }
            if (StringUtils.isBlank(dto.getSource())) {
                log.info(format + "文件来源不能为空！");
                return CommonResult.failed("文件来源不能为空");
            }
            if (StringUtils.isBlank(dto.getSubassort())) {
                log.info(format + "文件MD5码不能为空不能为空！");
                return CommonResult.failed("文件MD5码不能为空不能为空");
            }
            if (StringUtils.isBlank(dto.getTitle())) {
                log.info(format + "保存数据库文件名不能为空！");
                return CommonResult.failed("保存数据库文件名不能为空");
            }
            if (StringUtils.isBlank(dto.getFileName())) {
                log.info(format + "真实文件名不能为空！");
                return CommonResult.failed("真实文件名不能为空");
            }
            if (StringUtils.isBlank(dto.getSerialNumber())) {
                log.info(format + "文件MD5码不能为空不能为空！");
                return CommonResult.failed("文件MD5码不能为空不能为空");
            }
            if (StringUtils.isBlank(dto.getSoleKey())) {
                log.info(format + "SoleKey值不能为空！");
                return CommonResult.failed("文件MD5码不能为空不能为空");
            }
        }
        if (fileUpload.size() != files.length) {
            log.info(format + "文件上传参数为空！");
            return CommonResult.failed("文件上传数量与参数不一致");
        }
        // 参数不含上传的，不匹配
        List<String> originalFileNames = fileUpload.stream().map(item -> String.valueOf(item.getFileName())).collect(Collectors.toList());
        for (MultipartFile file : files) {
            if (!originalFileNames.contains(file.getOriginalFilename())) {
                log.info(format + "文件上传参数为空！");
                return CommonResult.failed("原文件名不匹配！");
            }
        }
        for (MultipartFile file : files) {
            for (FileUpload uploadFileParam : fileUpload) {
                if (uploadFileParam.getFileName().equals(file.getOriginalFilename())) {
                    if (taskService.fileUpload(file, uploadFileParam)) {
                        serialNumberIds.add(uploadFileParam.getSubassort());
                    } else {
                        failIds.add(uploadFileParam.getSubassort());
                    }
                }
            }
        }
        log.info("本次文件上传传输完成,成功流水号:" + JSONObject.toJSONString(serialNumberIds));
        log.info("本次文件上传传输完成,失败流水号:" + JSONObject.toJSONString(failIds));
        return CommonResult.success("本次文件上传传输完成");
    }

    /**
     * @description: 根据时间补偿采集器接口
     * @author linjj
     * @date: 2024/8/19 4:32
     */
    @PostMapping(value = "compensate")
    @ApiOperation("根据时间补偿采集器接口")
    @ResponseBody
    public CommonResult<?> compensate(@RequestParam @ApiParam(required = true, name = "startTime", value = "补偿开始时间") String startTime,
                                      @RequestParam @ApiParam(required = true, name = "entTime", value = "补偿开始时间") String entTime,
                                      @RequestParam @ApiParam(required = true, name = "collectId", value = "采集器id") String collectId) {
        taskService.compensate(startTime,entTime,collectId);
        return CommonResult.success("补偿完成");
    }

}