package com.ydtech.modules.fnc.controller;


import com.ydtech.core.page.HttpResult;
import com.ydtech.exception.SystemException;
import com.ydtech.modules.esm.model.EsmInsCompany;
import com.ydtech.modules.fnc.entity.ImportResult;
import com.ydtech.modules.fnc.entity.InsPlyIncome;
import com.ydtech.modules.fnc.service.ImportAsyncService;
import com.ydtech.modules.fnc.vo.ImportResultVo;
import com.ydtech.modules.fnc.vo.InsPlyIncomeVo;
import com.ydtech.modules.order.entity.BasePageResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;
import java.util.List;

@Api(tags = "异步导出")
@RequestMapping("/fnc/importAsync")
@RestController
public class ImportAsyncController {
    @Autowired
    private ImportAsyncService importAsyncService;

    @PostMapping("/query")
    @ApiOperation(value = "导入任务列表查询")
    public HttpResult<BasePageResult<ImportResult>> query(@RequestBody @Valid ImportResultVo importResultVo) {

        HttpResult<BasePageResult<ImportResult>> result=importAsyncService.selectAll(importResultVo);
        return result;
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/9/27 19:01
     *  @Description: 查询任务列表中的公司机构列表
     */
    @GetMapping("/queryPartnerCompaniesList")
    @ApiOperation(value = "查询任务列表中的公司机构列表")
    public HttpResult<List<EsmInsCompany>> queryPartnerCompaniesList(String status) {
        if(StringUtils.isBlank(status)){
            throw  new SystemException("类型不能为空！！！");
        }

        List<EsmInsCompany> result=importAsyncService.queryPartnerCompaniesList(status);
        return HttpResult.ok(result);
    }
}