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

import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.core.web.BaseResponse;
import cn.com.goldenwater.dcproj.dto.AttCwsBaseDto;
import cn.com.goldenwater.dcproj.model.AttCwsBase;
import cn.com.goldenwater.dcproj.model.AttCwsBaseCrrct;
import cn.com.goldenwater.dcproj.param.AttCwsBaseListParam;
import cn.com.goldenwater.dcproj.param.AttCwsBaseListParamNew;
import cn.com.goldenwater.dcproj.param.AttCwsBaseParam;
import cn.com.goldenwater.dcproj.service.AttCwsBaseCrrctService;
import cn.com.goldenwater.dcproj.service.AttCwsBaseService;
import cn.com.goldenwater.dcproj.service.OlBisInspOrgService;
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.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.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.List;

/**
 * @author zhengdafei
 * @date 2019-2-23
 */
@Api(value = "", tags = "农村饮水工程基本信息")
@RestController
@RequestMapping("/dc/att/cwsBase")
public class AttCwsBaseController extends BaseController {

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

    @Autowired
    private AttCwsBaseService attCwsBaseService;
    @Autowired
    private AttCwsBaseCrrctService attCwsBaseCrrctService;
    @Autowired
    private OlBisInspOrgService olBisInspOrgService;

    @ApiOperation(value = "添加")
    @RequestMapping(value = "/insert", method = RequestMethod.POST)
    public BaseResponse<AttCwsBase> insert(@ApiParam(name = "attCwsBase", value = "AttCwsBase", required = true) @RequestBody AttCwsBase attCwsBase) {
        AttCwsBase one = new AttCwsBase();
        try {
            one = attCwsBaseService.add(attCwsBase);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error(e.getMessage());
            return buildFailResponse(e.getMessage());
        }
        return buildSuccessResponse(one);
    }

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

    @ApiOperation(value = "更新信息")
    @RequestMapping(value = "/update", method = RequestMethod.POST)
    public BaseResponse update(HttpServletRequest request,
                               @ApiParam(name = "attCwsBase", value = "AttCwsBase", required = true) @RequestBody AttCwsBaseCrrct attCwsBase) {
        try {
            String persId = request.getHeader("persId");
            attCwsBaseService.correction(attCwsBase, persId);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error(e.getMessage());
            return buildFailResponse(e.getMessage());
        }
        return buildSuccessResponse(attCwsBase);
    }

    @ApiOperation(value = "根据饮水工程编码获取（单表）")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<AttCwsBase> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        AttCwsBase attCwsBase = attCwsBaseService.get(id);
        if (attCwsBase == null) {
            attCwsBase = new AttCwsBase();
        }
        return buildSuccessResponse(attCwsBase);
    }

    @ApiOperation(value = "获取同组人纠错信息")
    @RequestMapping(value = "/getCrrct", method = RequestMethod.GET)
    public BaseResponse<AttCwsBase> getCrrct(@RequestParam("cwsCode") String cwsCode, @RequestParam("persId") String persId) {
        AttCwsBase attCwsBase = attCwsBaseCrrctService.getCrrct(cwsCode, persId);
        if (attCwsBase == null) {
            attCwsBase = new AttCwsBase();
        }
        return buildSuccessResponse(attCwsBase);
    }

    @ApiOperation(value = "获取列表(分页)")
    @RequestMapping(value = "/queryListByPage", method = {RequestMethod.POST})
    public BaseResponse<PageInfo<AttCwsBase>> queryListByPage(@RequestBody AttCwsBaseParam param) {

        PageInfo<AttCwsBase> list = new PageInfo<>();
        param.setProvince(AdLevelUtil.getAddvcd(olBisInspOrgService.getProvince(getCurrentOrgId())));
        try {
            list = attCwsBaseService.queryListByPage(param);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error(e.getMessage());
            return buildFailResponse(e.getMessage());
        }
        return buildSuccessResponse(list);
    }

    @ApiOperation(value = "更新批量设置人饮基础信息 是否省属")
    @RequestMapping(value = "/provincial", method = {RequestMethod.PUT})
    public BaseResponse updateBatchProvincial(@RequestBody AttCwsBaseParam param) {
        param.setProvince(AdLevelUtil.getAddvcd(olBisInspOrgService.getProvince(getCurrentOrgId())));
        return buildSuccessResponse(attCwsBaseService.updateBatchProvincial(param));
    }

    @ApiOperation(value = "获取列表")
    @RequestMapping(value = "/queryList", method = {RequestMethod.POST})
    public BaseResponse<List<AttCwsBase>> queryList(@RequestBody AttCwsBaseParam param) {
        List<AttCwsBase> list = new ArrayList<>();
        try {
            list = attCwsBaseService.queryList(param);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error(e.getMessage());
            return buildFailResponse(e.getMessage());
        }
        return buildSuccessResponse(list);
    }

    @ApiOperation(value = "根据督查对象ID获取饮水工程列表")
    @RequestMapping(value = "/queryListByObjId", method = {RequestMethod.POST})
    public BaseResponse<PageInfo<AttCwsBaseDto>> queryListByObjId(@RequestBody AttCwsBaseListParam param) {
        PageInfo<AttCwsBaseDto> list = new PageInfo<>();
        try {
            list = attCwsBaseService.queryListByObjId(param);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error(e.getMessage());
            return buildFailResponse(e.getMessage());
        }
        return buildSuccessResponse(list);
    }

    @ApiOperation(value = "根据督查对象ID获取饮水工程列表")
    @RequestMapping(value = "/queryListByObjIdNew", method = {RequestMethod.POST})
    public BaseResponse<PageInfo<AttCwsBase>> queryListByObjIdNew(@RequestBody AttCwsBaseListParamNew param) {
        PageInfo<AttCwsBase> list = new PageInfo<>();
        try {
            list = attCwsBaseService.queryListByObjId(param);
        } catch (Exception e) {
            e.printStackTrace();
            logger.error(e.getMessage());
            return buildFailResponse(e.getMessage());
        }
        return buildSuccessResponse(list);
    }
}