fj-dc/.svn/pristine/97/97627f4de62ba70e38ef584000d03c990ccad07d.svn-base

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

import cn.com.goldenwater.dcproj.constValue.CommonLabel;
import cn.com.goldenwater.dcproj.dto.BisInspGrwDataQualityDto;
import cn.com.goldenwater.dcproj.dto.BisInspGrwDetailDto;
import cn.com.goldenwater.dcproj.dto.BisInspGrwMainTainDataDto;
import cn.com.goldenwater.dcproj.dto.BisInspGrwNormalDto;
import cn.com.goldenwater.dcproj.enums.EnumResultBean;
import cn.com.goldenwater.dcproj.enums.GetEnumService;
import cn.com.goldenwater.dcproj.enums.GrwStateEnum;
import cn.com.goldenwater.dcproj.model.BisInspGrw;
import cn.com.goldenwater.dcproj.param.*;
import cn.com.goldenwater.dcproj.service.BisInspGrwService;
import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.core.web.BaseResponse;
import cn.com.goldenwater.dcproj.service.OlBisInspOrgService;
import cn.com.goldenwater.dcproj.target.VerifyBean;
import cn.com.goldenwater.dcproj.utils.GrwScoreRule;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import com.github.pagehelper.PageInfo;
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 java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import com.alibaba.fastjson.JSONObject;

import javax.servlet.http.HttpServletRequest;

/**
 * @author zhengdafei
 * @date 2019-3-29
 */
@Api(value = "地下水监测站登记表管理", tags = "地下水监测站登记表管理")
@RestController
@RequestMapping("/dc/insp/grw")
public class BisInspGrwController extends BaseController {

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

    @Autowired
    private BisInspGrwService bisInspGrwService;

    @ApiOperation(value = "添加地下水监测站登记表")
    @RequestMapping(value = "/insert", method = RequestMethod.POST)
    public BaseResponse<BisInspGrw> insert(@ApiParam(name = "bisInspGrw", value = "BisInspGrw", required = true) @RequestBody BisInspGrw bisInspGrw)
            throws Exception {
        BisInspGrw bean = bisInspGrwService.add(bisInspGrw);
        return buildSuccessResponse(bean);
    }

    @ApiOperation(value = "根据ID删除地下水监测站登记表")
    @RequestMapping(value = "/{id}", method = RequestMethod.POST)
    public BaseResponse delete(HttpServletRequest req,
                               @ApiParam(name = "id", value = "id", required = true) @PathVariable String id) throws Exception {
        bisInspGrwService.remove(id);
        JSONObject json = new JSONObject();
        json.put("code", 200);
        return buildSuccessResponse(json);
    }

    
    @VerifyBean
    @ApiOperation(value = "更新地下水监测站登记表")
    @RequestMapping(value = "/update", method = RequestMethod.POST)
    public BaseResponse<BisInspGrw> update(HttpServletRequest req,
                                           @ApiParam(name = "bisInspGrw", value = "BisInspGrw", required = true) @RequestBody BisInspGrw p) throws Exception {
        BisInspGrw bean = bisInspGrwService.modify(p);
        return buildSuccessResponse(bean);
    }

    @ApiOperation(value = "根据ID获取地下水监测站登记表（单表）")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<BisInspGrw> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) throws Exception {
        BisInspGrw bisInspGrw = bisInspGrwService.get(id);
        return buildSuccessResponse(bisInspGrw);
    }

    @ApiOperation(value = "获取地下水监测站登记表列表(分页)")
    @RequestMapping(value = "/pageInfo", method = {RequestMethod.POST})
    public BaseResponse<PageInfo<BisInspGrw>> queryListByPage(@RequestBody BisInspGrwParam param) throws Exception {
        PageInfo<BisInspGrw> list = new PageInfo<>();
        list = bisInspGrwService.findPageInfo(param);
        return buildSuccessResponse(list);
    }

    @ApiOperation(value = "获取地下水监测站登记表列表")
    @RequestMapping(value = "/list", method = {RequestMethod.POST})
    public BaseResponse<List<BisInspGrw>> queryList(@RequestBody BisInspGrwParam param) throws Exception {
        List<BisInspGrw> list = new ArrayList<>();
        list = bisInspGrwService.findList(param);
        return buildSuccessResponse(list);
    }

    @ApiOperation(value = "获取一个地下水监测站登记表")
    @RequestMapping(value = "/getBy", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrw> getBy(@RequestBody BisInspGrwParam param) throws Exception {
        BisInspGrw one = new BisInspGrw();
        one = bisInspGrwService.getBy(param);
        return buildSuccessResponse(one);
    }

    @ApiOperation(value = "获取监测数据质量和到报率")
    @RequestMapping(value = "/getDataQuality", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrwDataQualityDto> getDataQuality(@ApiParam(name = "id", value = "登记表id", required = true) @RequestParam(value = "id") String id) throws Exception {
        BisInspGrwDataQualityDto one = new BisInspGrwDataQualityDto();
        one = bisInspGrwService.getDataQuality(id);
        return buildSuccessResponse(one);
    }

    @ApiOperation(value = "更新监测数据质量和到报率")
    @RequestMapping(value = "/updateDataQuality", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrw> updateDataQuality(@RequestBody BisInspGrwDataQualityDto p) throws Exception {
        BisInspGrw one = new BisInspGrw();
        one = bisInspGrwService.updateDataQuality(p);
        return buildSuccessResponse(one);
    }

    @Autowired
    private OlBisInspOrgService olBisInspOrgService;

    @VerifyBean
    @ApiOperation(value = "添加水检测站到督查列表")
    @RequestMapping(value = "/addDCst", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrw> addDCst(@RequestBody AddDCstParam param) throws Exception {
        param.setOrgId(getCurrentOrgId());
        param.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        return buildSuccessResponse(bisInspGrwService.addDCst(param));
    }

    @ApiOperation(value = "更新检查人员评价")
    @RequestMapping(value = "/updateCkComment", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrw> updateCkComment(@RequestBody GrwupdateCkCommentParam param) throws Exception {
        BisInspGrw one = new BisInspGrw();
        one.setId(param.getId());
        one.setCheckComment(param.getCheckComment());
        one.setCheckPid(param.getCheckPid());
        one.setCheckPname(param.getCheckPname());
        one.setInspState(GrwStateEnum.ING.getValue());
        one = bisInspGrwService.modify(one);
        return buildSuccessResponse(one);
    }

    @ApiOperation(value = "获取检查人员评价")
    @RequestMapping(value = "/getCkComment", method = {RequestMethod.GET})
    public BaseResponse<JSONObject> getCkComment(@ApiParam(name = "id", value = "登记表id", required = true) @RequestParam("id") String id) throws Exception {
        BisInspGrw one = new BisInspGrw();
        one = bisInspGrwService.get(id);
        if (one == null) {
            throw new Exception("此数据不存在");
        }
        JSONObject json = new JSONObject();
        json.put("checkComment", one.getCheckComment());
        return buildSuccessResponse(json);
    }


    @ApiOperation(value = "获取测站维护管理信息")
    @RequestMapping(value = "/getMainTainData", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrwMainTainDataDto> getMainTainData(@ApiParam(name = "id", value = "登记表id", required = true) @RequestParam(value = "id") String id) throws Exception {
        BisInspGrwMainTainDataDto one = new BisInspGrwMainTainDataDto();
        one = bisInspGrwService.getMainTainData(id);
        return buildSuccessResponse(one);
    }

    @ApiOperation(value = "上传测站维护管理信息")
    @RequestMapping(value = "/updateMainTainData", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrw> updateMainTainData(@RequestBody BisInspGrwMainTainDataDto p) throws Exception {
        BisInspGrw one = new BisInspGrw();
        one = bisInspGrwService.updateMainTainData(p);
        return buildSuccessResponse(one);
    }

    @ApiOperation(value = "提交地下水登记表信息")
    @RequestMapping(value = "/submitData", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrw> submitData(@RequestBody GrwSubmitParam p) throws Exception {
        BisInspGrw one = new BisInspGrw();
        one = bisInspGrwService.submitData(p);
        return buildSuccessResponse(one);
    }

    @ApiOperation(value = "获取地下水自动监测站现场检查表信息")
    @RequestMapping(value = "/getNormalData", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrwNormalDto> getNormalData(@ApiParam(name = "id", value = "登记表id", required = true) @RequestParam(value = "id") String id) throws Exception {
        BisInspGrwNormalDto one = new BisInspGrwNormalDto();
        one = bisInspGrwService.getNormalData(id);
        return buildSuccessResponse(one);
    }

    @ApiOperation(value = "获取打分规则")
    @RequestMapping(value = "/getScoreRule", method = {RequestMethod.GET})
    public BaseResponse<JSONObject> getScoreRule() throws Exception {
        GrwScoreRule one = new GrwScoreRule();
        return buildSuccessResponse(one.getRuleJson());
    }

    @ApiOperation(value = "获取督查列表（带经纬度、问题列表、分页）")
    @RequestMapping(value = "/queryDetailListWithPblm", method = {RequestMethod.POST})
    public BaseResponse<PageInfo<BisInspGrwDetailDto>> queryDetailListWithPblm(@RequestBody GetPageByNodeIdParam param) throws Exception {
        PageInfo<BisInspGrwDetailDto> page = new PageInfo<>();
        if(StringUtils.isBlank(param.getTabType())){
            param.setTabType(CommonLabel.TAB_TYPE);
        }
        param.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        String nowTime=new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        param.setNowTime(nowTime);
        page = bisInspGrwService.queryDetailListWithPblm(param);
        return buildSuccessResponse(page);
    }

    @ApiOperation(value = "获取地下水业务字典")
    @RequestMapping(value = "/getGrwDic", method = {RequestMethod.POST})
    public BaseResponse<EnumResultBean> getGrwDic() throws Exception {
        EnumResultBean enumResultBean = GetEnumService.getEnums();
        return buildSuccessResponse(enumResultBean);
    }

    @ApiOperation(value = "更改测站类型（省级必须先设置手动自动再督查）")
    @RequestMapping(value = "/setProvSttp", method = {RequestMethod.POST})
    public BaseResponse<BisInspGrw> setProvSttp(@RequestBody BisInspGrwSetSttpParam bisInspGrwSetSttpParam) throws Exception {
        BisInspGrw bisInspGrw = bisInspGrwService.setProvSttp(bisInspGrwSetSttpParam);
        return buildSuccessResponse(bisInspGrw);
    }
}