package cn.com.goldenwater.dcproj.service.impl.waga;

import cn.com.goldenwater.core.service.AbstractCrudService;
import cn.com.goldenwater.dcproj.dao.AttWagaBaseDao;
import cn.com.goldenwater.dcproj.dao.AttWagaBaseImpDao;
import cn.com.goldenwater.dcproj.model.AttWagaBase;
import cn.com.goldenwater.dcproj.model.AttWagaBaseImp;
import cn.com.goldenwater.dcproj.param.AttWagaBaseImpParam;
import cn.com.goldenwater.dcproj.service.AttWagaBaseImpService;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * @author lune
 * @date 2021-4-20
 */
@Service
@Transactional(rollbackFor = Exception.class)
public class AttWagaBaseImpServiceImpl extends AbstractCrudService<AttWagaBaseImp, AttWagaBaseImpParam> implements AttWagaBaseImpService {
    private Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired
    private AttWagaBaseImpDao attWagaBaseImpDao;
    @Autowired
    private AttWagaBaseDao attWagaBaseDao;

    public AttWagaBaseImpServiceImpl(AttWagaBaseImpDao attWagaBaseImpDao) {
        super(attWagaBaseImpDao);
        this.attWagaBaseImpDao = attWagaBaseImpDao;
    }


    @Override
    public void handelData() {
        List<AttWagaBaseImp> list = attWagaBaseImpDao.findAllNew();
        String adCode = "";
        String maxObjCode = "";
        for (AttWagaBaseImp attWagaBaseImp:list) {
            AttWagaBase waga = new AttWagaBase();
            String ad_code = attWagaBaseImp.getAdCode3();
            if(StringUtils.isNotBlank(ad_code)){
                ad_code = ad_code.substring(0,6);
                if(!ad_code.equals(adCode)){
                    adCode = ad_code;
                    String objCode = attWagaBaseImpDao.getMaxObjCode(ad_code);
                    if(StringUtils.isBlank(objCode)){
                        maxObjCode = ad_code+"000001";
                    }else{
                        Long a = Long.parseLong(objCode);
                        a++;
                        maxObjCode = String.valueOf(a);
                    }
                }else{
                    Long a = Long.parseLong(maxObjCode);
                    a++;
                    maxObjCode = String.valueOf(a);
                }
                waga.setObjCode(maxObjCode);
                waga.setGateName(attWagaBaseImp.getGateName());
                waga.setGateAdmName(attWagaBaseImp.getGateAdmName());
                waga.setEngScal(attWagaBaseImp.getEngScal());
                waga.setGateFlow(attWagaBaseImp.getGateFlow());
                waga.setIfGate(attWagaBaseImp.getIfGate());
                waga.setIfDouDile(attWagaBaseImp.getIfDouDile());
                waga.setGateAdmDep(attWagaBaseImp.getGateAdmDep());
                waga.setGateType(attWagaBaseImp.getGateType());
                waga.setEngGrad(attWagaBaseImp.getEngGrad());
                attWagaBaseDao.insert(waga);
            }
        }
        /**
         List<AttWagaBaseImp> list = attWagaBaseImpDao.findAllNullCode();
         for (AttWagaBaseImp waga:list) {
         String name = waga.getGateName();
         String type = waga.getGateType();
         String ad_code = waga.getAdCode3();
         AttWagaBaseParam attWagaBaseParam = new AttWagaBaseParam();
         attWagaBaseParam.setAdCode(ad_code);
         if("引(进)水闸".equals(type)){
         if(name.contains("引水闸")){
         name = name.replaceAll("引水闸","");
         }else if(name.contains("进水闸")){
         name = name.replaceAll("进水闸","");
         }
         }else if("排(退)水闸".equals(type)){
         if(name.contains("排水闸")){
         name = name.replaceAll("排水闸","");
         }else if(name.contains("退水闸")){
         name = name.replaceAll("退水闸","");
         }
         }else{
         if(name.contains(type)){
         name = name.replaceAll(type,"");
         }
         }
         attWagaBaseParam.setGateName(name);
         List<AttWagaBase> attWagaBaseList = attWagaBaseDao.findList(attWagaBaseParam);
         if(attWagaBaseList.size()>0){
         if(attWagaBaseList.size()==1){
         waga.setObjCode(attWagaBaseList.get(0).getObjCode());
         }else{
         for (AttWagaBase attWagaBase:attWagaBaseList) {
         logger.info("重复水闸："+attWagaBase.toString());
         }
         }
         }else{
         if(StringUtils.isNotBlank(ad_code)){
         ad_code = ad_code.substring(0,4);
         attWagaBaseParam.setAdCode(ad_code);
         attWagaBaseList = attWagaBaseDao.findList(attWagaBaseParam);
         if(attWagaBaseList.size()>0){
         if(attWagaBaseList.size()==1){
         waga.setObjCode(attWagaBaseList.get(0).getObjCode());
         }else{
         for (AttWagaBase attWagaBase:attWagaBaseList) {
         logger.info("重复水闸："+attWagaBase.toString());
         }
         }
         }
         }
         }
         attWagaBaseImpDao.update(waga);
         }
         */


    }
}