fj-dc/.svn/pristine/70/707be0eda7348a18824eff39699501097b86ce8b.svn-base

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

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.constValue.StatusEnum;
import cn.com.goldenwater.dcproj.dao.BisInspPblmDao;
import cn.com.goldenwater.dcproj.model.*;
import cn.com.goldenwater.dcproj.param.*;
import cn.com.goldenwater.dcproj.service.*;
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.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;

import java.util.Date;
import java.util.List;

/**
 * @author lune
 * @date 2020-3-27
 */
@Api(value = "BIS 2020农村督查人员与与行政村关系表,用来确定督查人员已督查的行政村管理",tags="BIS 2020农村督查人员与与行政村关系表,用来确定督查人员已督查的行政村管理")
@RestController
@RequestMapping("/bis/new/dcuser/rel/vill")
public class BisNewDcuserRelVillController extends BaseController {

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

    @Autowired
    private BisNewDcuserRelVillService bisNewDcuserRelVillService;
    @Autowired
    private AttAdXBaseService attAdXBaseService;
    @Autowired
    private BisNewCountryFeeService bisNewCountryFeeService;
    @Autowired
    private BisNewWateruserInfoService bisNewWateruserInfoService;
    @Autowired
    private BisInspPblmDao bisInspPblmDao;

    @ApiOperation(value = "添加/修改2020农村督查人员与与行政村关系表,用来确定督查人员已督查的村")
    @RequestMapping(value = "", method = RequestMethod.POST)
    public BaseResponse<BisNewDcuserRelVill> insert(@ApiParam(name = "bisNewDcuserRelVill", value = "BisNewDcuserRelVill", required = true) @RequestBody BisNewDcuserRelVill bisNewDcuserRelVill) {
        bisNewDcuserRelVill.setPersId(getCurrentPersId());
        bisNewDcuserRelVill.setUpdateTime(new Date());
        bisNewDcuserRelVill.setStatus("1");
        if(StringUtils.isBlank(bisNewDcuserRelVill.getId())) {
                String uuid = UuidUtil.uuid();  // 生成uuid
                bisNewDcuserRelVill.setCreateTime(new Date());
                bisNewDcuserRelVill.setId(uuid);
                bisNewDcuserRelVillService.insert(bisNewDcuserRelVill);
        }else{
                bisNewDcuserRelVillService.update(bisNewDcuserRelVill);
        }
        return buildSuccessResponse(bisNewDcuserRelVill);
    }
    @Autowired
    private BisNewVillRgstrService bisNewVillRgstrService;

    @ApiOperation(value = "批量添加/行政村")
    @RequestMapping(value = "/addbatch", method = RequestMethod.POST)
    public BaseResponse addbatch(@ApiParam(name = "countryParam", value = "countryParam", required = true) @RequestBody List<CountryParam> countryParamList) {
        boolean setStatus=true;
        for(CountryParam countryParam:countryParamList) {
            if (StringUtils.isBlank(countryParam.getCodes())) {
                throw new CheckException("编码不能为空");
            }
            String[] arrays = countryParam.getCodes().split(SplitValue.FENHAO_SPLIT);
            if(setStatus) {
                BisNewVillRgstr villRgstr = new BisNewVillRgstr();
                villRgstr.setId(countryParam.getRegstrId());
                villRgstr.setWaterSafeOrPay("1");
                villRgstr.setState(StatusEnum.START.getStatus());
                bisNewVillRgstrService.update(villRgstr);
                setStatus=false;
            }
            int size=0;
            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) {
                    BisNewDcuserRelVillParam newDcuserRelVillParam=new BisNewDcuserRelVillParam();
                    newDcuserRelVillParam.setRegstrId(countryParam.getRegstrId());
                    newDcuserRelVillParam.setAdCode(attAdXBase.getAdCode());
                    BisNewDcuserRelVill dcuserRelVill =bisNewDcuserRelVillService.getBy(newDcuserRelVillParam);
                    if(dcuserRelVill!=null){
                        continue;
                    }
                    dcuserRelVill=new BisNewDcuserRelVill();
                    dcuserRelVill.setStatus("1");
                    dcuserRelVill.setId(UuidUtil.uuid());
                    dcuserRelVill.setCreateTime(new Date());
                    dcuserRelVill.setAdCode(attAdXBase.getAdCode());
                    dcuserRelVill.setPersId(getCurrentPersId());
                    dcuserRelVill.setRegstrId(countryParam.getRegstrId());
                    dcuserRelVill.setVillageNm(attAdXBase.getAdName());
                    dcuserRelVill.setTownName(countryParam.getTownName());
                    bisNewDcuserRelVillService.insert(dcuserRelVill);
                    size=size+1;
                }
            }
            if(size!=0) {
                BisNewVillRgstr bisNewVillRgstr = bisNewVillRgstrService.get(countryParam.getRegstrId());
                int villNum = bisNewVillRgstr.getVillNum() + size;
                bisNewVillRgstr.setVillNum(villNum);
                bisNewVillRgstrService.updateVillSum(bisNewVillRgstr);
            }
        }

        return buildSuccessResponse(countryParamList);
    }


    @ApiOperation(value = "根据ID删除2020农村督查人员与与行政村关系表,用来确定督查人员已督查的村")
    @RequestMapping(value = "/del/{id}", method = RequestMethod.GET)
    @Transactional
    public BaseResponse delete(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {

        BisNewDcuserRelVill newDcuserRelVill=bisNewDcuserRelVillService.get(id);
        BisNewVillRgstr bisNewVillRgstr = bisNewVillRgstrService.get(newDcuserRelVill.getRegstrId());
        int villNum=bisNewVillRgstr.getVillNum()-1;
        bisNewVillRgstr.setVillNum(villNum);

        int ret = bisNewDcuserRelVillService.delete(id);
        BisNewWateruserInfoParam newWateruserInfoParam=new BisNewWateruserInfoParam();
        newWateruserInfoParam.setAdCode(newDcuserRelVill.getAdCode());
        List<BisNewWateruserInfo> wateruserInfoList=bisNewWateruserInfoService.findList(newWateruserInfoParam);
        int waterNum=bisNewVillRgstr.getWaterNum()-wateruserInfoList.size();
        bisNewVillRgstr.setWaterNum(waterNum);
        if(!wateruserInfoList.isEmpty()) {
            for (int i = 0; i < wateruserInfoList.size(); i++) {
                BisInspPblmParam bisInspPblmParam = new BisInspPblmParam();
                bisInspPblmParam.setWaterUserId(wateruserInfoList.get(i).getId());
                bisInspPblmParam.setRegid(wateruserInfoList.get(i).getRegstrId());
                bisInspPblmDao.deleteBy(bisInspPblmParam);
            }
        }
        bisNewWateruserInfoService.deleteBy(newWateruserInfoParam);
        BisNewCountryFeeParam newCountryFeeParam=new BisNewCountryFeeParam();
        newCountryFeeParam.setAdCode(newDcuserRelVill.getAdCode());
        List<BisNewCountryFee> newCountryFeeList=bisNewCountryFeeService.findList(newCountryFeeParam);
        int proNum=bisNewVillRgstr.getProNum()-newCountryFeeList.size();
        bisNewVillRgstr.setProNum(proNum);
        bisNewVillRgstrService.updateAllNum(bisNewVillRgstr);
        for(int i=0;i<newCountryFeeList.size();i++){
            BisInspPblmParam bisInspPblmParam = new BisInspPblmParam();
            bisInspPblmParam.setCwsCode(newCountryFeeList.get(i).getId());
            bisInspPblmParam.setRegid(newCountryFeeList.get(i).getRegstrId());
            bisInspPblmDao.deleteBy(bisInspPblmParam);
        }
        bisNewCountryFeeService.deleteBy(newCountryFeeParam);
        return buildSuccessResponse();
    }



    @ApiOperation(value = "根据ID获取2020农村督查人员与与行政村关系表,用来确定督查人员已督查的村（单表）")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<BisNewDcuserRelVill> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        BisNewDcuserRelVill bisNewDcuserRelVill = bisNewDcuserRelVillService.get(id);
        return buildSuccessResponse(bisNewDcuserRelVill);
    }

    @ApiOperation(value = "获取2020农村督查人员与与行政村关系表,用来确定督查人员已督查的村（列表所有）")
    @RequestMapping(value = "/list", method = RequestMethod.POST)
    public BaseResponse<List<BisNewDcuserRelVill>> list(@ApiParam(name = "bisNewDcuserRelVillParam", value = "bisNewDcuserRelVillParam", required = true) @RequestBody BisNewDcuserRelVillParam bisNewDcuserRelVillParam) {
        List<BisNewDcuserRelVill> bisNewDcuserRelVillList = bisNewDcuserRelVillService.findList(bisNewDcuserRelVillParam);
        return buildSuccessResponse(bisNewDcuserRelVillList);
    }

    @ApiOperation(value = "获取2020农村督查人员与与行政村关系表,用来确定督查人员已督查的村（列表--分页）")
    @RequestMapping(value = "/page", method = RequestMethod.POST)
    public BaseResponse<PageInfo<BisNewDcuserRelVill>> page(@ApiParam(name = "bisNewDcuserRelVillParam", value = "bisNewDcuserRelVillParam", required = true) @RequestBody BisNewDcuserRelVillParam bisNewDcuserRelVillParam) {
        PageInfo<BisNewDcuserRelVill> bisNewDcuserRelVillList = bisNewDcuserRelVillService.findPageInfo(bisNewDcuserRelVillParam);
        return buildSuccessResponse(bisNewDcuserRelVillList);
    }



}