package cn.com.goldenwater.dcproj.controller.importex;

import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.core.web.BaseResponse;
import cn.com.goldenwater.dcproj.service.ImpPblmService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletResponse;
import java.util.Map;

/**
 * <p>
 * 导入水库问题的Controller
 * 策略：下载，上传，解析，入库
 * </p>
 *
 * @author liyz
 * @date 2019/7/10 14:32
 **/
@Api(value = "导出导入问题接口", tags = "导出导入问题接口")
@RestController
@RequestMapping("/dc/imp/pblm")
public class ImpPblmController extends BaseController {


    @Autowired
    private ImpPblmService impPblmService;

    @ApiOperation(value = "下载问题模板的接口")
    @RequestMapping(value = "/download", method = {RequestMethod.GET, RequestMethod.POST})
    public BaseResponse<String> downloadTemplate(HttpServletResponse response,
                                                 @ApiParam("userId") @RequestParam() String userId,
                                                 @ApiParam("orgType") @RequestParam() String orgType,
                                                 @ApiParam("orgIds") @RequestParam() String orgIds,
                                                 @ApiParam("datas") @RequestParam(required = false) String datas) {
        try {
            impPblmService.downloadTemplate(response, userId, orgType, orgIds, datas,getCurrentOrgId());
        } catch (Exception e) {
            e.printStackTrace();
            return buildSuccessResponse("N");
        }
        return buildSuccessResponse("Y");
    }

    @ApiOperation(value = "上传接口")
    @RequestMapping(value = "/upload", method = {RequestMethod.GET, RequestMethod.POST})
    public BaseResponse<String> uploadTemplate(@ApiParam("数据流") @RequestParam() MultipartFile[] file) {
        // 返回[存储路径]
        return buildSuccessResponse(impPblmService.uploadFile(file));
    }

    @ApiOperation(value = "解析问题模板的接口")
    @RequestMapping(value = "/parse", method = {RequestMethod.GET})
    public BaseResponse<Map<String, Object>> parseTemplate(@ApiParam("存储路径") @RequestParam() String filePath,
                                                           @ApiParam("用户编码") @RequestParam(required = false) String userId,
                                                           @ApiParam("督查编码") @RequestParam(required = false) String orgType) {
        // 返回 数据集 和 cacheId
        return buildSuccessResponse(impPblmService.parseTemplate(filePath,userId,orgType));
    }

    @ApiOperation(value = "入库问题模板的接口")
    @RequestMapping(value = "/insert", method = {RequestMethod.GET})
    public BaseResponse<Boolean> insertTemplate(@ApiParam("cacheId") @RequestParam() String cacheId,
                                                @ApiParam("userId") @RequestParam() String userId,
                                                @ApiParam("updateState：1普通新增 0覆盖新增（先删后增）") @RequestParam() String updateState,
                                                @ApiParam("orgType 001,002,003,004,005,006") @RequestParam() String orgType) {
        // 返回 成功或失败
        try {
            impPblmService.insertTemplate(cacheId, userId, updateState, orgType);
        } catch (Exception e) {
            e.printStackTrace();
            return buildSuccessResponse(false);
        }
        return buildSuccessResponse(true);

    }

    @ApiOperation(value = "入库问题模板的接口")
    @RequestMapping(value = "/insert/info", method = {RequestMethod.GET})
    public BaseResponse<String> insertTemplateInfo(@ApiParam("cacheId") @RequestParam() String cacheId,
                                                @ApiParam("userId") @RequestParam() String userId,
                                                @ApiParam("updateState：1普通新增 0覆盖新增（先删后增）") @RequestParam() String updateState,
                                                @ApiParam("orgType 001,002,003,004,005,006") @RequestParam() String orgType) {
        // 返回 成功或失败
        String info = "";
        try {
            info = impPblmService.insertTemplateInfo(cacheId, userId, updateState, orgType);
        } catch (Exception e) {
            e.printStackTrace();
            return buildSuccessResponse(info);
        }
        return buildSuccessResponse(info);

    }


}