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

import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.core.web.BaseResponse;
import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
import cn.com.goldenwater.dcproj.constValue.CommonLabel;
import cn.com.goldenwater.dcproj.dto.BisInspRsvrRgstrPcDto;
import cn.com.goldenwater.dcproj.dto.BisInspVillRgstrDto;
import cn.com.goldenwater.dcproj.model.AttRsBase;
import cn.com.goldenwater.dcproj.model.BisInspPblm;
import cn.com.goldenwater.dcproj.model.BisInspPblmPlist;
import cn.com.goldenwater.dcproj.model.BisInspRsvrRgstr;
import cn.com.goldenwater.dcproj.param.AttRsBaseParam;
import cn.com.goldenwater.dcproj.param.BisInspPblmParam;
import cn.com.goldenwater.dcproj.param.BisInspRsmlRgstrParam;
import cn.com.goldenwater.dcproj.param.BisInspRsvrRgstrParam;
import cn.com.goldenwater.dcproj.param.TypeParam;
import cn.com.goldenwater.dcproj.service.BisInspPblmService;
import cn.com.goldenwater.dcproj.service.BisInspRsmlRgstrService;
import cn.com.goldenwater.dcproj.service.BisInspRsvrRgstrService;
import cn.com.goldenwater.dcproj.service.BisInspVillRgstrService;
import cn.com.goldenwater.dcproj.service.OlBisInspOrgService;
import cn.com.goldenwater.dcproj.target.Authority;
import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
import cn.com.goldenwater.id.util.UuidUtil;
import cn.com.goldenwater.util.common.SqlUtils;
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.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * @author lune
 * @date 2019-2-18
 */
@Api(value = "APP 督查水库登记管理", tags = "APP 督查水库登记管理")
@RestController
@RequestMapping("/dc/insp/rsvrRgstr")
public class BisInspRsvrRgstrController extends BaseController {

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

    @Autowired
    private BisInspRsvrRgstrService bisInspRsvrRgstrService;

    @Autowired
    private BisInspVillRgstrService bisInspVillRgstrService;

    @Autowired
    private BisInspPblmService bisInspPblmService;

    @Autowired
    private OlBisInspOrgService olBisInspOrgService;

    @Autowired
    private BisInspRsmlRgstrService bisInspRsmlRgstrService;

    @ApiOperation(value = "添加督查水库登记")
    @RequestMapping(value = "", method = RequestMethod.POST)
    public BaseResponse<BisInspRsvrRgstr> insert(@ApiParam(name = "bisInspRsvrRgstr", value = "BisInspRsvrRgstr", required = true)
                                                 @RequestBody BisInspRsvrRgstr bisInspRsvrRgstr) {
        String uuid = UuidUtil.uuid();
        bisInspRsvrRgstr.setState("0");
        bisInspRsvrRgstr.setRgstrId(uuid);
        bisInspRsvrRgstr.setDataStat("0");
        bisInspRsvrRgstr.setUptm(new Date());
        bisInspRsvrRgstr.setOrgId(getCurrentOrgId());
        bisInspRsvrRgstr.setIntm(new Date());
        int ret = bisInspRsvrRgstrService.insert(bisInspRsvrRgstr);
        return buildSuccessResponse(bisInspRsvrRgstr);
    }


    @ApiOperation(value = "提交督查水库登记，变更水库登记表状态")
    @RequestMapping(value = "/submit/{rgstrId}", method = RequestMethod.POST)
    public BaseResponse<String> submit(@ApiParam(name = "rgstrId", value = "rgstrId", required = true) @PathVariable String rgstrId) {
        BisInspRsvrRgstr rsvrRgstr = new BisInspRsvrRgstr();
        rsvrRgstr.setRgstrId(rgstrId);
        rsvrRgstr.setState("2");
        rsvrRgstr.setUptm(new Date());
        bisInspRsvrRgstrService.updateRG(rsvrRgstr);
        return buildSuccessResponse(rgstrId);
    }

    @ApiOperation(value = "根据ID删除水库登记")
    @RequestMapping(value = "/delete/{id}", method = RequestMethod.GET)
    public BaseResponse delete(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        int ret = bisInspRsvrRgstrService.deleteInFlag(id);
        return buildSuccessResponse();
    }

    @ApiOperation(value = "更新水库登记信息，提交")
    @RequestMapping(value = "/update", method = RequestMethod.POST)
    public BaseResponse update(@ApiParam(name = "bisInspRsvrRgstr", value = "BisInspRsvrRgstr", required = true) @RequestBody BisInspRsvrRgstr bisInspRsvrRgstr) {
        bisInspRsvrRgstr.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        bisInspRsvrRgstr.setPersId(getCurrentPersId());
        bisInspRsvrRgstr.setOrgId(getCurrentOrgId());
        int ret = bisInspRsvrRgstrService.update(bisInspRsvrRgstr);
        return buildSuccessResponse(bisInspRsvrRgstr);
    }

    @ApiOperation(value = "根据ID获取督查水库登记（单表）,详细信息,包含填报状态")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<BisInspRsvrRgstr> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        BisInspRsvrRgstr bisInspRsvrRgstr = bisInspRsvrRgstrService.get(id);

        return buildSuccessResponse(bisInspRsvrRgstr);
    }

    @ApiOperation(value = "获取水库信息督查表,如果不存在则创建登记表，对象objId,水库resCode")
    @RequestMapping(value = "/getBy/{objId}/{resCode}", method = RequestMethod.GET)
    public BaseResponse<BisInspRsvrRgstr> getBy(@ApiParam(name = "objId", value = "objId", required = true) @PathVariable String objId,
                                                @ApiParam(name = "resCode", value = "resCode", required = true) @PathVariable String resCode, HttpServletRequest request) {
        BisInspRsvrRgstrParam inspRsvrRgstrParam = new BisInspRsvrRgstrParam();
        inspRsvrRgstrParam.setRsCode(resCode);
        inspRsvrRgstrParam.setObjId(objId);
        String persId = request.getHeader("persId");
        inspRsvrRgstrParam.setRecPersId(persId);
        inspRsvrRgstrParam.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        BisInspRsvrRgstr bisInspRsvrRgstr = bisInspRsvrRgstrService.getByRsvrRgstr(inspRsvrRgstrParam);
        return buildSuccessResponse(bisInspRsvrRgstr);
    }

    @ApiOperation(value = "督查问题清单,根据ID获取督查当前督查的所有问题")
    @RequestMapping(value = "/list/{rgstrId}", method = RequestMethod.GET)
    public BaseResponse<PageInfo<BisInspPblm>> list(@ApiParam(name = "rgstrId", value = "rgstrId", required = true) @PathVariable String rgstrId) {
        BisInspPblmParam pblmParam = new BisInspPblmParam();
        pblmParam.setRegid(rgstrId);
        PageInfo<BisInspPblm> inspPblmList = bisInspPblmService.findPageInfo(pblmParam);
        return buildSuccessResponse(inspPblmList);
    }

    @ApiOperation(value = "获取督查水库登记（分页表）")
    @RequestMapping(value = "/pageList", method = RequestMethod.POST)
    public BaseResponse<PageInfo<BisInspRsvrRgstr>> pageList(@ApiParam(name = "bisInspRsvrRgstrParam",
            value = "bisInspRsvrRgstrParam", required = true) @RequestBody BisInspRsvrRgstrParam bisInspRsvrRgstrParam) {
        bisInspRsvrRgstrParam.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        PageInfo<BisInspRsvrRgstr> bisInspRsvrRgstrPageInfo = bisInspRsvrRgstrService.findPageInfo(bisInspRsvrRgstrParam);
        return buildSuccessResponse(bisInspRsvrRgstrPageInfo);
    }


    @Authority
    @ApiOperation(value = "根据记录人员id获取农水填录信息")
    @RequestMapping(value = "/findTree", method = RequestMethod.POST)
    public Object findTree(@RequestBody TypeParam typeParam) {
        typeParam.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        typeParam.setOrgId(getCurrentOrgId());
        if (BisInspEnum.VILL.getKey().equals(typeParam.getType())) {
            List<BisInspVillRgstrDto> inspVillRgstrs = bisInspVillRgstrService.findTree(typeParam);
            return buildSuccessResponse(inspVillRgstrs);

        }
        return buildFailResponse("无重要列表信息!!");
    }


    @ApiOperation(value = "根据用户persId,状态state,行政区话编码code,主要争对督查表操作")
    @RequestMapping(value = "/list/page", method = RequestMethod.POST)
    public Object page(@RequestBody TypeParam typeParam) {
        typeParam.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        typeParam.setOrgId(getCurrentOrgId());
        if (StringUtils.isBlank(typeParam.getTabType())) {
            typeParam.setTabType(CommonLabel.TAB_TYPE);
        }
        String nowTime = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        typeParam.setNowTime(nowTime);
        typeParam.setInIdsSql(SqlUtils.getinIdsSql(getCurrentPersId(), typeParam.getProvince()));

        PageInfo<BisInspRsvrRgstrPcDto> rsvrRgstrPcDtoPageInfo = bisInspRsvrRgstrService.findPcPage(typeParam);
        return buildSuccessResponse(rsvrRgstrPcDtoPageInfo);
    }

    @ApiOperation(value = "小水库基本信息（分页表）")
    @RequestMapping(value = "/attRsBase", method = RequestMethod.POST)
    public BaseResponse<PageInfo<AttRsBase>> pageList(@ApiParam(name = "attRsBase", value = "attRsBase", required = true)
                                                      @RequestBody AttRsBaseParam attRsBaseParam) {
        attRsBaseParam.setProvince(AdLevelUtil.getAddvcd(olBisInspOrgService.getProvince(getCurrentOrgId())));
        PageInfo<AttRsBase> bisInspRsvrRgstrPageInfo = bisInspRsvrRgstrService.findAttBaseInfo(attRsBaseParam);
        return buildSuccessResponse(bisInspRsvrRgstrPageInfo);
    }
    @ApiOperation(value = "小水库基本信息设置是否省属")
    @RequestMapping(value = "/attRsBase/provincial", method = RequestMethod.PUT)
    public BaseResponse provincialSet(@ApiParam(name = "attRsBase", value = "attRsBase", required = true)
                                          @RequestBody AttRsBaseParam attRsBaseParam) {
        attRsBaseParam.setProvince(AdLevelUtil.getAddvcd(olBisInspOrgService.getProvince(getCurrentOrgId())));

        return buildSuccessResponse(bisInspRsvrRgstrService.updateBatchProvincial(attRsBaseParam));
    }

    @ApiOperation(value = "根据rgstrId获取水库督查管理责任体系表（单表）")
    @RequestMapping(value = "/getBy/{rgstrId}", method = RequestMethod.GET)
    public BaseResponse getByRgstrId(@ApiParam(name = "rgstrId", value = "rgstrId", required = true) @PathVariable String rgstrId) {
        BisInspRsvrRgstr bisInspRsvrRgstr = bisInspRsvrRgstrService.get(rgstrId);
        if (bisInspRsvrRgstr != null) {
            return buildSuccessResponse(bisInspRsvrRgstr);
        }
        BisInspRsmlRgstrParam param = new BisInspRsmlRgstrParam();
        param.setId(rgstrId);
        return buildSuccessResponse(bisInspRsmlRgstrService.getBy(param));
    }


    @ApiOperation(value = "根据监控点编号获取实时监控预览地址")
    @RequestMapping(value = "/get/camera/play/{cameraIndexCode}", method = RequestMethod.GET)
    public BaseResponse getMonitorVideoUrlByCameraIndexCode(@ApiParam(name = "cameraIndexCode", value = "cameraIndexCode", required = true) @PathVariable String cameraIndexCode) {
        Map<String,Object> resultJson = bisInspRsvrRgstrService.getMonitorVideoUrlByCameraIndexCode(cameraIndexCode);
        resultJson.put("cameraIndexCode",cameraIndexCode);
        return buildSuccessResponse(resultJson);
    }

    @ApiOperation(value = "编辑水库注册登记号")
    @RequestMapping(value = "/update/regcode", method = RequestMethod.POST)
    public BaseResponse modifyDamRegCode(@ApiParam(name = "bisInspRsvrRgstr", value = "BisInspRsvrRgstr", required = true)
                                                 @RequestBody BisInspPblmPlist inspPblmPlist) {
        bisInspRsvrRgstrService.updateRsvrDamRegCode(inspPblmPlist);
        return buildSuccessResponse();
    }

}