fj-dc/.svn/pristine/be/bebacbc2b0d0e02c86b46c7d95567eb6adab6003.svn-base

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

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.AttAdXBase;
import cn.com.goldenwater.dcproj.model.BisZhejiangCountryFee;
import cn.com.goldenwater.dcproj.model.BisZhejiangDcuserRelVill;
import cn.com.goldenwater.dcproj.model.BisZhejiangVillRgstr;
import cn.com.goldenwater.dcproj.param.*;
import cn.com.goldenwater.dcproj.service.AttAdXBaseService;
import cn.com.goldenwater.dcproj.service.BisZhejiangCountryFeeService;
import cn.com.goldenwater.dcproj.service.BisZhejiangDcuserRelVillService;
import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.core.web.BaseResponse;
import cn.com.goldenwater.dcproj.service.BisZhejiangVillRgstrService;
import cn.com.goldenwater.target.CheckException;
import cn.com.goldenwater.id.util.UuidUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.apache.commons.lang3.StringUtils;
import com.github.pagehelper.PageInfo;
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.RestController;

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

/**
 * @author lune
 * @date 2020-5-11
 */
@Api(value = "BIS 2020浙江农村督查人员与与行政村关系表管理",tags="BIS 2020浙江农村督查人员与与行政村关系表管理")
@RestController
@RequestMapping("/bis/zhejiang/dcuser/rel/vill")
public class BisZhejiangDcuserRelVillController extends BaseController {

    private Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired
    private BisZhejiangVillRgstrService bisZhejiangVillRgstrService;
    @Autowired
    private AttAdXBaseService attAdXBaseService;
    @Autowired
    private BisInspPblmDao bisInspPblmDao;
    @Autowired
    private BisZhejiangCountryFeeService bisZhejiangCountryFeeService;
    @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) {
                BisZhejiangVillRgstr villRgstr = new BisZhejiangVillRgstr();
                villRgstr.setId(countryParam.getRegstrId());
                villRgstr.setWaterSafeOrPay("1");
                villRgstr.setState(StatusEnum.START.getStatus());
                bisZhejiangVillRgstrService.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) {
                    BisZhejiangDcuserRelVillParam newDcuserRelVillParam=new BisZhejiangDcuserRelVillParam();
                    newDcuserRelVillParam.setRgstrId(countryParam.getRegstrId());
                    newDcuserRelVillParam.setAdCode(attAdXBase.getAdCode());
                    BisZhejiangDcuserRelVill dcuserRelVill =bisZhejiangDcuserRelVillService.getBy(newDcuserRelVillParam);
                    if(dcuserRelVill!=null){
                        continue;
                    }
                    dcuserRelVill=new BisZhejiangDcuserRelVill();
                    dcuserRelVill.setStatus("1");
                    dcuserRelVill.setId(UuidUtil.uuid());
                    dcuserRelVill.setCreateTime(new Date());
                    dcuserRelVill.setAdCode(attAdXBase.getAdCode());
                    dcuserRelVill.setPersId(getCurrentPersId());
                    dcuserRelVill.setRgstrId(countryParam.getRegstrId());
                    dcuserRelVill.setVillageNm(attAdXBase.getAdName());
                    dcuserRelVill.setTownName(countryParam.getTownName());
                    dcuserRelVill.setUpdateTime(new Date());
                    bisZhejiangDcuserRelVillService.insert(dcuserRelVill);
                    size=size+1;
                }
            }
            if(size!=0) {
                BisZhejiangVillRgstr bisNewVillRgstr = bisZhejiangVillRgstrService.get(countryParam.getRegstrId());
                int villNum = bisNewVillRgstr.getVillNum() + size;
                bisNewVillRgstr.setVillNum(villNum);
                bisZhejiangVillRgstrService.updateVillSum(bisNewVillRgstr);
            }
        }

        return buildSuccessResponse(countryParamList);
    }

    @Autowired
    private BisZhejiangDcuserRelVillService bisZhejiangDcuserRelVillService;


    @ApiOperation(value = "添加/修改2020浙江农村督查人员与与行政村关系表")
    @RequestMapping(value = "", method = RequestMethod.POST)
    public BaseResponse<BisZhejiangDcuserRelVill> insert(@ApiParam(name = "bisZhejiangDcuserRelVill", value = "BisZhejiangDcuserRelVill", required = true) @RequestBody BisZhejiangDcuserRelVill bisZhejiangDcuserRelVill) {
        bisZhejiangDcuserRelVill.setPersId(getCurrentPersId());
        bisZhejiangDcuserRelVill.setUpdateTime(new Date());
        bisZhejiangDcuserRelVill.setStatus("1");
        if(StringUtils.isBlank(bisZhejiangDcuserRelVill.getId())) {
                String uuid = UuidUtil.uuid();  // 生成uuid
            bisZhejiangDcuserRelVill.setCreateTime(new Date());
                bisZhejiangDcuserRelVill.setId(uuid);
                bisZhejiangDcuserRelVillService.insert(bisZhejiangDcuserRelVill);
        }else{
                bisZhejiangDcuserRelVillService.update(bisZhejiangDcuserRelVill);
        }
        return buildSuccessResponse(bisZhejiangDcuserRelVill);
    }

    @ApiOperation(value = "根据ID删除2020浙江农村督查人员与与行政村关系表")
    @RequestMapping(value = "/del/{id}", method = RequestMethod.GET)
    public BaseResponse delete(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        BisZhejiangDcuserRelVill newDcuserRelVill=bisZhejiangDcuserRelVillService.get(id);
        BisZhejiangVillRgstr bisNewVillRgstr = bisZhejiangVillRgstrService.get(newDcuserRelVill.getRgstrId());
        int villNum=bisNewVillRgstr.getVillNum()-1;
        bisNewVillRgstr.setVillNum(villNum);
        int ret = bisZhejiangDcuserRelVillService.delete(id);
        BisZhejiangCountryFeeParam newCountryFeeParam=new BisZhejiangCountryFeeParam();
        newCountryFeeParam.setAdCode(newDcuserRelVill.getAdCode());
        List<BisZhejiangCountryFee> newCountryFeeList=bisZhejiangCountryFeeService.findList(newCountryFeeParam);
        int proNum=bisNewVillRgstr.getProNum()-newCountryFeeList.size();
        bisNewVillRgstr.setProNum(proNum);
        bisZhejiangVillRgstrService.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).getRgstrId());
            bisInspPblmDao.deleteBy(bisInspPblmParam);
        }
        bisZhejiangCountryFeeService.deleteBy(newCountryFeeParam);
        return buildSuccessResponse();
    }



    @ApiOperation(value = "根据ID获取2020浙江农村督查人员与与行政村关系表（单表）")
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public BaseResponse<BisZhejiangDcuserRelVill> get(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) {
        BisZhejiangDcuserRelVill bisZhejiangDcuserRelVill = bisZhejiangDcuserRelVillService.get(id);
        return buildSuccessResponse(bisZhejiangDcuserRelVill);
    }

    @ApiOperation(value = "获取2020浙江农村督查人员与与行政村关系表（列表所有）")
    @RequestMapping(value = "/list", method = RequestMethod.POST)
    public BaseResponse<List<BisZhejiangDcuserRelVill>> list(@ApiParam(name = "bisZhejiangDcuserRelVillParam", value = "bisZhejiangDcuserRelVillParam", required = true) @RequestBody BisZhejiangDcuserRelVillParam bisZhejiangDcuserRelVillParam) {
        List<BisZhejiangDcuserRelVill> bisZhejiangDcuserRelVillList = bisZhejiangDcuserRelVillService.findList(bisZhejiangDcuserRelVillParam);
        return buildSuccessResponse(bisZhejiangDcuserRelVillList);
    }

    @ApiOperation(value = "获取2020浙江农村督查人员与与行政村关系表（列表--分页）")
    @RequestMapping(value = "/page", method = RequestMethod.POST)
    public BaseResponse<PageInfo<BisZhejiangDcuserRelVill>> page(@ApiParam(name = "bisZhejiangDcuserRelVillParam", value = "bisZhejiangDcuserRelVillParam", required = true) @RequestBody BisZhejiangDcuserRelVillParam bisZhejiangDcuserRelVillParam) {
        PageInfo<BisZhejiangDcuserRelVill> bisZhejiangDcuserRelVillList = bisZhejiangDcuserRelVillService.findPageInfo(bisZhejiangDcuserRelVillParam);
        return buildSuccessResponse(bisZhejiangDcuserRelVillList);
    }

}