fj-dc/.svn/pristine/c3/c366ab091ab38c5cea453a44131c3432948dcded.svn-base

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

import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.core.web.BaseResponse;
import cn.com.goldenwater.dcproj.dto.VillRgstrEngIdDto;
import cn.com.goldenwater.dcproj.model.AttGrwBase;
import cn.com.goldenwater.dcproj.model.BisInspObj;
import cn.com.goldenwater.dcproj.model.OlBisInspOrg;
import cn.com.goldenwater.dcproj.param.InGroupGrwParam;
import cn.com.goldenwater.dcproj.param.InspObjParam;
import cn.com.goldenwater.dcproj.param.PagePersObjParam;
import cn.com.goldenwater.dcproj.param.PersObjParam;
import cn.com.goldenwater.dcproj.service.BisInspObjService;
import cn.com.goldenwater.dcproj.service.OlBisInspOrgService;
import cn.com.goldenwater.dcproj.util.CheckUtil;
import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
import com.github.pagehelper.PageInfo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author lune
 * @date 2019-2-18
 */
@Api(value = "督查与对象关系管理", tags = "督查与对象关系管理")
@RestController
@RequestMapping("/dc/insp/obj")
public class BisInspObjController extends BaseController {

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

    @Autowired
    private BisInspObjService bisInspObjService;
    @Autowired
    private OlBisInspOrgService olBisInspOrgService;

    @ApiOperation(value = "新增督查与对象关系")
    @RequestMapping(value = "addDcAndObjRel", method = RequestMethod.POST)
    public BaseResponse addDcAndObjRel(
            HttpServletRequest request,
            @RequestParam("objId") String objId,
            @RequestParam("objType") String objType,
            @RequestParam("inspGroupId") String inspGroupId,
            @RequestParam("objName") String objName,
            @RequestParam("objLttd") String objLttd,
            @RequestParam("objLgtd") String objLgtd,
            @RequestParam("objProvincial") String objProvincial) {
        String persId = request.getHeader("persId");
        Map<String, Object> ret = bisInspObjService.addDcAndObjRel(objId, objType, inspGroupId, objName, objLttd, objLgtd, objProvincial,persId, getCurrentOrgId());
        if ("200".equals(ret.get("code"))) {
            return buildSuccessOrFailResponse(200, ret.get("mess").toString(), true);
        } else {
            return buildSuccessOrFailResponse(201, ret.get("mess").toString(), false);
        }
    }

    @ApiOperation(value = "地图点击图标直接新增督查与对象关系")
    @RequestMapping(value = "addDcAndObjReldt", method = RequestMethod.POST)
    public BaseResponse addDcAndObjReldt(
            HttpServletRequest request,
            @RequestParam("objId") String objId,
            @RequestParam("objType") String objType,
            @RequestParam("inspGroupId") String inspGroupId,
            @RequestParam("objName") String objName,
            @RequestParam("objLttd") String objLttd,
            @RequestParam("objLgtd") String objLgtd,
            @RequestParam("objProvincial") String objProvincial) {
        String persId = request.getHeader("persId");
        Map<String, Object> ret = bisInspObjService.addDcAndObjRel(objId, objType, inspGroupId, objName, objLttd, objLgtd, objProvincial,persId, getCurrentOrgId());
        if ("200".equals(ret.get("code"))) {
            Map<String, String> result = new HashMap<>();
            result.put("rgstrId", ret.get("rgstrId").toString());
            result.put("codes", ret.get("codes").toString());
            return buildSuccessResponse(200, ret.get("mess").toString(), result);
        } else {
            return buildFailResponse(201, ret.get("mess").toString());
        }
    }

    @ApiOperation(value = "根据督查组id及督查类型查询督查范围内的对象")
    @RequestMapping(value = "/getObjListByGroupIdAndType", method = RequestMethod.GET)
    public BaseResponse<Object> getObjListByGroupIdAndType(@ApiParam(name = "pagePersObjParam", value = "PagePersObjParam")
                                                                   PagePersObjParam pagePersObjParam) {
        pagePersObjParam.setProvince(olBisInspOrgService.getProvinceFlag(getCurrentOrgId()));
        pagePersObjParam.setOrgId(getCurrentOrgId());
        pagePersObjParam.setPersId(getCurrentPersId());
        Object pageInfo = bisInspObjService.getObjListByGroupIdAndType(pagePersObjParam);
        return buildSuccessResponse(pageInfo);
    }

    @ApiOperation(value = "查询不在督查组督查范围内的督查对象")
    @RequestMapping(value = "/getObjListNotInspGroupId", method = RequestMethod.GET)
    public BaseResponse<Object> getObjListNotInspGroupId(@ApiParam(name = "InspObjParam", value = "InspObjParam") InspObjParam inspObjParam) {
        OlBisInspOrg org = olBisInspOrgService.get(getCurrentOrgId());
        CheckUtil.notNull(org, "机构ID错误", getCurrentOrgId());
        inspObjParam.setProvince(AdLevelUtil.getAddvcd(org.getAdCode()));
        Object pageInfo = bisInspObjService.getObjListNotInspGroupId(inspObjParam);
        return buildSuccessResponse(pageInfo);
    }

    @ApiOperation(value = "根据ID删除xxx")
    @RequestMapping(value = "/{id}", method = RequestMethod.POST)
    public BaseResponse delete(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        int ret = bisInspObjService.delete(id);
        return buildSuccessResponse();
    }

    @ApiOperation(value = "更新xxx信息")
    @RequestMapping(value = "/update", method = RequestMethod.POST)
    public BaseResponse update(@ApiParam(name = "bisInspObj", value = "BisInspObj", required = true) @RequestBody BisInspObj bisInspObj) {
        int ret = bisInspObjService.update(bisInspObj);
        return buildSuccessResponse();
    }

    @ApiOperation(value = "根据ID获取xxx（单表）")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<BisInspObj> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        BisInspObj bisInspObj = bisInspObjService.get(id);
        return buildSuccessResponse(bisInspObj);
    }

    @ApiOperation(value = "删除督查对象")
    @RequestMapping(value = "/deleteInspObj", method = RequestMethod.POST)
    public BaseResponse deleteInspObj(@ApiParam(name = "bisInspObj", value = "BisInspObj", required = true) BisInspObj bisInspObj) {
        int i = bisInspObjService.deleteInspObj(bisInspObj);
        if (i == 0) {
            return buildFailResponse(1001, "请先删除登记表");
        }
        return buildSuccessResponse();
    }

    @ApiOperation(value = "根据人员id以及对象类型获取对象", notes = "根据人员id以及对象类型获取对象")
    @GetMapping(value = "/getObjByPersId")
    public BaseResponse<List<Object>> getObjByPersId(@ApiParam(name = "persObjParam", value = "PersObjParam")
                                                             PersObjParam persObjParam,
                                                     HttpServletResponse response) {
        persObjParam.setProvince(AdLevelUtil.getAddvcd(olBisInspOrgService.getProvince(getCurrentOrgId())));
        persObjParam.setOrgId(getCurrentOrgId());
        return buildSuccessResponse(bisInspObjService.getObjByPersId(persObjParam, response));
    }

    @ApiOperation(value = "根据人员id以及对象类型获取对象（分页）", notes = "根据人员id以及对象类型获取对象（分页）")
    @GetMapping(value = "/getPageByPersId")
    public BaseResponse<PageInfo<Object>> getPageByPersId(@ApiParam(name = "persObjParam", value = "PersObjParam") PersObjParam persObjParam, HttpServletResponse response) {
        persObjParam.setProvince(olBisInspOrgService.getProvince(getCurrentOrgId()));
        persObjParam.setOrgId(getCurrentOrgId());
        PageInfo<Object> bisInspGroupInfoDtos = bisInspObjService.getPageByPersId(persObjParam, response);
        return buildSuccessResponse(bisInspGroupInfoDtos);
    }

    @ApiOperation(value = "根据code查询对象是否登记", notes = "根据code查询对象是否登记")
    @GetMapping(value = "/getRgstrByCode")
    public BaseResponse<VillRgstrEngIdDto> getRgstrByCode(@ApiParam(name = "code", value = "code", required = true) @RequestParam String code, @RequestParam String type) {
        VillRgstrEngIdDto bisInspGroupInfoDtos = bisInspObjService.getRgstrByCode(code, type, getCurrentOrgId());
        return buildSuccessResponse(bisInspGroupInfoDtos);
    }

    @ApiOperation(value = "获取不在某督查组的地下水信息", notes = "获取不在某督查组的地下水信息")
    @PostMapping(value = "/getGrwNotInGroup")
    public BaseResponse<PageInfo<AttGrwBase>> getGrwNotInGroup(@RequestBody InGroupGrwParam inGroupGrwParam) {
        inGroupGrwParam.setProvince(olBisInspOrgService.getProvinceFlag(getCurrentOrgId()));
        PageInfo<AttGrwBase> attGrwBasePageInfo = this.bisInspObjService.getGrwNotInGroup(inGroupGrwParam);
        return buildSuccessResponse(attGrwBasePageInfo);
    }


}