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

import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.core.web.BaseResponse;
import cn.com.goldenwater.dcproj.constValue.SplitValue;
import cn.com.goldenwater.dcproj.model.AttAdXBase;
import cn.com.goldenwater.dcproj.model.BisRdwspRgstrRelVill;
import cn.com.goldenwater.dcproj.param.AttAdXBaseParam;
import cn.com.goldenwater.dcproj.param.BisRdwspRgstrRelVillParam;
import cn.com.goldenwater.dcproj.param.CountryParam;
import cn.com.goldenwater.dcproj.service.AttAdXBaseService;
import cn.com.goldenwater.dcproj.service.BisRdwspRgstrRelVillService;
import cn.com.goldenwater.target.CheckException;
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 java.util.Date;
import java.util.List;

/**
 * @author lune
 * @date 2020-10-9
 */
@Api(value = "BIS 农村饮水安全回头看登记表与行政村关系表管理",tags="BIS 农村饮水安全回头看登记表与行政村关系表管理")
@RestController
@RequestMapping("/bis/rdwsp/rgstr/rel/vill")
public class BisRdwspRgstrRelVillController extends BaseController {

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

    @Autowired
    private BisRdwspRgstrRelVillService bisRdwspRgstrRelVillService;
    @Autowired
    private AttAdXBaseService attAdXBaseService;


    @ApiOperation(value = "添加/修改农村饮水安全回头看登记表与行政村关系表")
    @RequestMapping(value = "", method = RequestMethod.POST)
    public BaseResponse<BisRdwspRgstrRelVill> insert(@ApiParam(name = "bisRdwspRgstrRelVill", value = "BisRdwspRgstrRelVill", required = true) @RequestBody BisRdwspRgstrRelVill bisRdwspRgstrRelVill) {
        if(StringUtils.isBlank(bisRdwspRgstrRelVill.getId())) {
            // 生成uuid
            String uuid = UuidUtil.uuid();
            bisRdwspRgstrRelVill.setId(uuid);
            bisRdwspRgstrRelVillService.insert(bisRdwspRgstrRelVill);
        }else{
            bisRdwspRgstrRelVillService.update(bisRdwspRgstrRelVill);
        }
        return buildSuccessResponse(bisRdwspRgstrRelVill);
    }

    @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 = bisRdwspRgstrRelVillService.delete(id);
        return buildSuccessResponse();
    }



    @ApiOperation(value = "根据ID获取农村饮水安全回头看登记表与行政村关系表（单表）")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<BisRdwspRgstrRelVill> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        BisRdwspRgstrRelVill bisRdwspRgstrRelVill = bisRdwspRgstrRelVillService.get(id);
        return buildSuccessResponse(bisRdwspRgstrRelVill);
    }

    @ApiOperation(value = "获取农村饮水安全回头看登记表与行政村关系表（列表所有）")
    @RequestMapping(value = "/list", method = RequestMethod.POST)
    public BaseResponse<List<BisRdwspRgstrRelVill>> list(@ApiParam(name = "bisRdwspRgstrRelVillParam", value = "bisRdwspRgstrRelVillParam", required = true) @RequestBody BisRdwspRgstrRelVillParam bisRdwspRgstrRelVillParam) {
        List<BisRdwspRgstrRelVill> bisRdwspRgstrRelVillList = bisRdwspRgstrRelVillService.findList(bisRdwspRgstrRelVillParam);
        return buildSuccessResponse(bisRdwspRgstrRelVillList);
    }

    @ApiOperation(value = "获取农村饮水安全回头看登记表与行政村关系表（列表--分页）")
    @RequestMapping(value = "/page", method = RequestMethod.POST)
    public BaseResponse<PageInfo<BisRdwspRgstrRelVill>> page(@ApiParam(name = "bisRdwspRgstrRelVillParam", value = "bisRdwspRgstrRelVillParam", required = true) @RequestBody BisRdwspRgstrRelVillParam bisRdwspRgstrRelVillParam) {
        PageInfo<BisRdwspRgstrRelVill> bisRdwspRgstrRelVillList = bisRdwspRgstrRelVillService.findPageInfo(bisRdwspRgstrRelVillParam);
        return buildSuccessResponse(bisRdwspRgstrRelVillList);
    }


    @ApiOperation(value = "批量添加/行政村")
    @RequestMapping(value = "/addbatch", method = RequestMethod.POST)
    public BaseResponse addbatch(@ApiParam(name = "countryParam", value = "countryParam", required = true) @RequestBody List<CountryParam> countryParamList) {
        for(CountryParam countryParam:countryParamList) {
            if (StringUtils.isBlank(countryParam.getCodes())) {
                throw new CheckException("编码不能为空");
            }
            String[] arrays = countryParam.getCodes().split(SplitValue.FENHAO_SPLIT);
            for (String arr : arrays) {
                AttAdXBaseParam attAdXBaseParam=new AttAdXBaseParam();
                attAdXBaseParam.setAdCode(arr);
                List<AttAdXBase> attAdXBaseList = attAdXBaseService.findList(attAdXBaseParam);
                if(attAdXBaseList.isEmpty()){
                    continue;
                }
                AttAdXBase attAdXBase=attAdXBaseList.get(0);
                if (attAdXBase != null) {
                    BisRdwspRgstrRelVillParam newDcuserRelVillParam=new BisRdwspRgstrRelVillParam();
                    newDcuserRelVillParam.setRegstrId(countryParam.getRegstrId());
                    newDcuserRelVillParam.setAdCode(attAdXBase.getAdCode());
                    BisRdwspRgstrRelVill dcuserRelVill =bisRdwspRgstrRelVillService.getBy(newDcuserRelVillParam);
                    if(dcuserRelVill!=null){
                        continue;
                    }
                    dcuserRelVill=new BisRdwspRgstrRelVill();
                    dcuserRelVill.setStatus("1");
                    dcuserRelVill.setId(UuidUtil.uuid());
                    dcuserRelVill.setIntm(new Date());
                    dcuserRelVill.setUptm(new Date());
                    dcuserRelVill.setAdCode(attAdXBase.getAdCode());
                    dcuserRelVill.setPersId(getCurrentPersId());
                    dcuserRelVill.setRegstrId(countryParam.getRegstrId());
                    dcuserRelVill.setVillageNm(attAdXBase.getAdName());
                    dcuserRelVill.setTownName(countryParam.getTownName());
                    bisRdwspRgstrRelVillService.insert(dcuserRelVill);
                }
            }
        }
        return buildSuccessResponse(countryParamList);
    }

}