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.dao.AttAdXBaseDao;
import cn.com.goldenwater.dcproj.dao.AttRsBaseDao;
import cn.com.goldenwater.dcproj.dao.AttRsBaseFjDao;
import cn.com.goldenwater.dcproj.dto.ExcelInspRsDto;
import cn.com.goldenwater.dcproj.model.ImpRsInfo;
import cn.com.goldenwater.dcproj.param.ImpRsInfoParam;
import cn.com.goldenwater.dcproj.service.AttRsBaseService;
import cn.com.goldenwater.dcproj.service.ImpRsInfoService;
import cn.com.goldenwater.dcproj.utils.LoadExcel;
import cn.com.goldenwater.dcproj.utils.impexcel.ImpRsExcel;
import cn.com.goldenwater.id.util.UuidUtil;
import com.github.pagehelper.PageInfo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.util.HashMap;
import java.util.List;

/**
 * @author lune
 * @date 2019-7-23
 */
@Api(value = "IMP 检查小型水库名称及分布情况表管理", tags = "IMP 检查小型水库名称及分布情况表管理")
@RestController
@RequestMapping("/imp/rs/info")
public class ImpRsInfoController extends BaseController {

    private Logger logger = LoggerFactory.getLogger(getClass());

    @Autowired
    private ImpRsInfoService impRsInfoService;
    @Autowired
    private AttRsBaseFjDao attRsBaseFjDao;
    @Autowired
    private AttAdXBaseDao attAdXBaseDao;
    @Autowired
    private AttRsBaseService attRsBaseService;
    @Autowired
    private AttRsBaseDao attRsBaseDao;


    @ApiOperation(value = "添加/修改检查小型水库名称及分布情况表")
    @RequestMapping(value = "", method = RequestMethod.POST)
    public BaseResponse<ImpRsInfo> insert(@ApiParam(name = "impRsInfo", value = "ImpRsInfo", required = true) @RequestBody ImpRsInfo impRsInfo) {
        if (StringUtils.isBlank(impRsInfo.getId())) {
            String uuid = UuidUtil.uuid();  // 生成uuid
            impRsInfo.setId(uuid);
            impRsInfoService.insert(impRsInfo);
        } else {
            impRsInfoService.update(impRsInfo);
        }
        return buildSuccessResponse(impRsInfo);
    }

    @ApiOperation(value = "根据ID删除检查小型水库名称及分布情况表")
    @RequestMapping(value = "/del/{id}", method = RequestMethod.GET)
    public BaseResponse delete(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        int ret = impRsInfoService.delete(id);
        return buildSuccessResponse();
    }


    @ApiOperation(value = "根据ID获取检查小型水库名称及分布情况表（单表）")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<ImpRsInfo> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        ImpRsInfo impRsInfo = impRsInfoService.get(id);
        return buildSuccessResponse(impRsInfo);
    }

    @ApiOperation(value = "获取检查小型水库名称及分布情况表（列表所有）")
    @RequestMapping(value = "/list", method = RequestMethod.POST)
    public BaseResponse<List<ImpRsInfo>> list(@ApiParam(name = "impRsInfoParam", value = "impRsInfoParam", required = true) @RequestBody ImpRsInfoParam impRsInfoParam) {
        List<ImpRsInfo> impRsInfoList = impRsInfoService.findList(impRsInfoParam);
        return buildSuccessResponse(impRsInfoList);
    }

    @ApiOperation(value = "获取检查小型水库名称及分布情况表（列表--分页）")
    @RequestMapping(value = "/page", method = RequestMethod.POST)
    public BaseResponse<PageInfo<ImpRsInfo>> page(@ApiParam(name = "impRsInfoParam", value = "impRsInfoParam", required = true) @RequestBody ImpRsInfoParam impRsInfoParam) {
        PageInfo<ImpRsInfo> impRsInfoList = impRsInfoService.findPageInfo(impRsInfoParam);
        return buildSuccessResponse(impRsInfoList);
    }

    @ApiOperation(value = "根据月份批量插入小型水库名称及分布情况信息")
    @RequestMapping(value = "insertList/{mnth}", method = RequestMethod.POST)
    public BaseResponse<String> insertList(@ApiParam(name = "mnth", value = "mnth", required = true) @PathVariable String mnth, @RequestParam("file") MultipartFile file) {
        try {
            List<ExcelInspRsDto> list = LoadExcel.getRsvrObjListByFile(file);
            impRsInfoService.insertList(list,mnth);
        }catch (Exception e){
            e.printStackTrace();
        }
        return buildSuccessResponse("执行结束！！！");
    }

    @ApiOperation(value = "根据月份批量处理小型水库名称及分布情况信息")
    @RequestMapping(value = "handleRsData", method = RequestMethod.POST)
    public BaseResponse<String> handleRsData(@ApiParam(name = "mnth", value = "月份", required = true) @RequestParam String mnth, @ApiParam(name = "orgId", value = "机构ID", required = true) @RequestParam String orgId) {
        try {
            impRsInfoService.handleRsData(mnth,orgId);
        }catch (Exception e){
            e.printStackTrace();
        }
        return buildSuccessResponse("执行结束！！！");
    }

    @ApiOperation(value = "插入福建省百日攻坚河湖四乱问题数据")
    @RequestMapping(value = "insertFlkdisList", method = RequestMethod.POST)
    public BaseResponse<String> insertFlkdisList(@RequestParam("file") MultipartFile file) {
        try {
            impRsInfoService.insertFlkdisList(file);
        }catch (Exception e){
            e.printStackTrace();
        }
        return buildSuccessResponse("执行结束！！！");
    }
    @ApiOperation(value = "插入福建省百日攻坚水政项目问题数据")
    @RequestMapping(value = "insertWaterList", method = RequestMethod.POST)
    public BaseResponse<String> insertWaterList(@RequestParam("file") MultipartFile file) {
        try {
            impRsInfoService.insertWaterList(file);
        }catch (Exception e){
            e.printStackTrace();
        }
        return buildSuccessResponse("执行结束！！！");
    }
    @ApiOperation(value = "插入福建省百日攻坚中央环保督查问题数据")
    @RequestMapping(value = "insertEcofrdList", method = RequestMethod.POST)
    public BaseResponse<String> insertEcofrdList(@RequestParam("file") MultipartFile file) {
        try {
            impRsInfoService.insertEcofrdList(file);
        }catch (Exception e){
            e.printStackTrace();
        }
        return buildSuccessResponse("执行结束！！！");
    }
    @ApiOperation(value = "批量处理福建水库名录")
    @RequestMapping(value = "importFjRsList", method = RequestMethod.POST)
    public BaseResponse<String> importFjRsList(@ApiParam(name = "filePath", value = "路径", required = true) @RequestParam String filePath) {
        try {
            ImpRsExcel impRsExcel = new ImpRsExcel();
            impRsExcel.doImportExcel(filePath,1,0,true, HashMap.class, "", "sk",attAdXBaseDao,attRsBaseFjDao,attRsBaseService,attRsBaseDao);
        }catch (Exception e){
            e.printStackTrace();
        }
        return buildSuccessResponse("执行结束！！！");
    }
}