remove vms class source

src/main/java/com/its/safe/dao/mapper/its/BatchDaoService.java

@@ -1,105 +0,0 @@
-package com.its.safe.dao.mapper.its;
-
-import lombok.Data;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.ibatis.session.ExecutorType;
-import org.apache.ibatis.session.SqlSession;
-import org.apache.ibatis.session.SqlSessionFactory;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-@Data
-@Slf4j
-public abstract class BatchDaoService {
-
-    protected final int MAX_BATCH_SIZE = 1000;
-
-    protected final SqlSessionFactory sqlSessionFactory;
-    protected String serviceName;
-    protected int count;
-
-    public BatchDaoService(SqlSessionFactory sqlSessionFactory) {
-        this.sqlSessionFactory = sqlSessionFactory;
-    }
-
-    public int getCount() {
-        return this.count;
-    }
-
-    public int execute(String mapperName) {
-        int total = 0;
-        SqlSession sqlSession = null;
-        try {
-            sqlSession = this.sqlSessionFactory.openSession(ExecutorType.SIMPLE, false);
-            total = sqlSession.update(mapperName);
-        }
-        finally {
-            if (sqlSession != null) {
-                sqlSession.commit();
-                sqlSession.close();
-            }
-        }
-        return total;
-    }
-
-    public int insertBatch(String mapperName, List<HashMap<String, Object>> lists) {
-        int total = lists.size();
-        if (total == 0) {
-            log.info("[BATCH--DAO] {}:insertBatch: {}: No Data.", this.serviceName, mapperName);
-            return 0;
-        }
-        int jobCnt = 0;
-        SqlSession sqlSession = null;
-        try {
-            sqlSession = this.sqlSessionFactory.openSession(ExecutorType.BATCH, false);
-            for (Map<String, Object> param : lists) {
-                sqlSession.insert(mapperName, param);
-                jobCnt++;
-                if (jobCnt % this.MAX_BATCH_SIZE == 0 || jobCnt == total) {
-                    sqlSession.flushStatements();
-                    sqlSession.clearCache();
-                }
-            }
-        }
-        finally {
-            if (sqlSession != null) {
-                sqlSession.commit();
-                sqlSession.close();
-            }
-        }
-        this.count = total;
-        return this.count;
-    }
-
-    public int updateBatch(String mapperName, List<HashMap<String, Object>> lists) {
-        int total = lists.size();
-        if (total == 0) {
-            log.info("[BATCH--DAO] {}:updateBatch: {}: No Data.", this.serviceName, mapperName);
-            return 0;
-        }
-        int jobCnt = 0;
-        SqlSession sqlSession = null;
-        try {
-            sqlSession = this.sqlSessionFactory.openSession(ExecutorType.BATCH, false);
-            for (Map<String, Object> param : lists) {
-                sqlSession.update(mapperName, param);
-                jobCnt++;
-                if (jobCnt % this.MAX_BATCH_SIZE == 0 || jobCnt == total) {
-                    sqlSession.flushStatements();
-                    sqlSession.clearCache();
-                }
-            }
-        }
-        finally {
-            if (sqlSession != null) {
-                sqlSession.commit();
-                sqlSession.close();
-            }
-        }
-        this.count = total;
-        return this.count;
-    }
-
-}

src/main/java/com/its/safe/dao/mapper/its/NodeLinkMapper.java → src/main/java/com/its/safe/dao/mapper/its/VmsMapper.java

@@ -8,7 +8,7 @@ import org.apache.ibatis.annotations.Mapper;
 import java.util.List;
 
 @Mapper
-public interface NodeLinkMapper {
+public interface VmsMapper {
 
     List<TbNode> selectNodeAll();
     List<TbNodeRgn> selectNodeRgnAll();

src/main/java/com/its/safe/dao/mapper/its/batch/NodeLinkDao.java

@@ -1,74 +0,0 @@
-package com.its.safe.dao.mapper.its.batch;
-
-import com.its.app.utils.Elapsed;
-import com.its.safe.dao.mapper.its.BatchDaoService;
-import com.its.safe.entity.its.TbVmsCtlrStts;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.ibatis.session.SqlSessionFactory;
-import org.springframework.stereotype.Repository;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-
-@Slf4j
-@Repository
-public class NodeLinkDao extends BatchDaoService {
-
-    public NodeLinkDao(SqlSessionFactory sqlSessionFactory) {
-        super(sqlSessionFactory);
-        this.serviceName = "NodeLinkDao";//this.getClass().getName();
-    }
-
-    public List<HashMap<String, Object>> getSttsList(List<TbVmsCtlrStts> req) {
-        List<HashMap<String, Object>> lists = new ArrayList<>();
-        req.forEach(obj -> {
-            HashMap<String, Object> param = new HashMap<>();
-
-            param.put("vmsCtlrNmbr",    obj.getVmsCtlrNmbr());
-            param.put("updtDt",         obj.getUpdtDt());
-            param.put("cmncSttsCd",     obj.getCmncSttsCd());
-            param.put("pwerSttsCd",     obj.getPwerSttsCd());
-            param.put("modlSttsCd",     obj.getModlSttsCd());
-            param.put("cboxDoorSttsCd", obj.getCboxDoorSttsCd());
-            param.put("fanSttsCd",      obj.getFanSttsCd());
-            param.put("hetrSttsCd",     obj.getHetrSttsCd());
-            param.put("cboxTmpr",       obj.getCboxTmpr());
-            param.put("brghVal",        obj.getBrghVal());
-            param.put("commSttsCd",     obj.getCommSttsCd());
-            param.put("modlStts",       obj.getModlStts());
-            param.put("pwerStts",       obj.getPwerStts());
-            param.put("cboxHum",        obj.getCboxHum());
-            param.put("cboxFanSttsCd",  obj.getCboxFanSttsCd());
-            param.put("cboxHetrSttsCd", obj.getCboxHetrSttsCd());
-            param.put("tmpr",           obj.getTmpr());
-            param.put("hum",            obj.getHum());
-            param.put("doorSttsCd",     obj.getDoorSttsCd());
-            param.put("brghMode",       obj.getBrghMode());
-            param.put("brghCurr",       obj.getBrghCurr());
-            param.put("brghWeek",       obj.getBrghWeek());
-            param.put("brghNght",       obj.getBrghNght());
-            param.put("pwerOnOffCd",    obj.getPwerOnOffCd());
-
-            lists.add(param);
-        });
-        return lists;
-    }
-
-    public int updateStts(List<TbVmsCtlrStts> req, boolean isHistory) {
-        log.info("{}.updateStts: START. {} EA. History {}", this.serviceName, req.size(), isHistory);
-        Elapsed elapsed = new Elapsed();
-        int total = updateBatch("batchUpdateCtlrStts", getSttsList(req));
-        log.info("{}.updateStts: ..END. {} EA. {} ms.", this.serviceName, total, elapsed.milliSeconds());
-        return total;
-    }
-
-    public int insertStts(List<TbVmsCtlrStts> req) {
-        log.info("{}.insertStts: START. {} EA.", this.serviceName, req.size());
-        Elapsed elapsed = new Elapsed();
-        int total = insertBatch("batchInsertCtlrSttsHs", getSttsList(req));
-        log.info("{}.insertStts: ..END. {} EA. {} ms.", this.serviceName, total, elapsed.milliSeconds());
-        return total;
-    }
-
-}

src/main/java/com/its/safe/entity/its/TbVmsCtlr.java

@@ -1,144 +0,0 @@
-package com.its.safe.entity.its;
-
-import com.its.safe.dto.its.TbVmsCtlrDto;
-import lombok.Builder;
-import lombok.Data;
-
-import java.io.Serializable;
-
-/**
- *  DTO Class
- */
-@Data
-@Builder
-public class TbVmsCtlr implements Serializable {
-    private static final long serialVersionUID = 1L;
-
-    private Long vmsCtlrNmbr;
-    private Integer vmsCtlrLocalNo;
-    private String vmsCtlrId;
-    private String vmsNm;
-    private String vmsCtlrIp;
-    private String vmsUsagTypeCd;
-    private String vmsFrmTypeCd;
-    private String vmsTypeCd;
-    private String vmsModlTypeCd;
-    private String vmsCtlrPort;
-    private String operMode;
-    private Integer cmncFailRate;
-    private Integer brghNghtStep;
-    private Integer brghWeekStep;
-    private Integer defPhseChngCycl;
-    private Integer modlErrRate;
-    private Integer cmncfailSlotNmbr;
-    private Integer pwerFailSlotNmbr;
-    private String cmtrinfrCnctYn;
-    private String wthrinfrCnctYn;
-    private String envrinfrCnctYn;
-    private Integer vmsMaxPhseNum;
-    private String panlOnTime;
-    private String panlOffTime;
-    private Integer panlPwerMode;
-    private Integer brghMode;
-    private String istlLctnNm;
-    private String trfcStrgUseYn;
-    private Long vmsLocIfscId;
-    private Integer fanRunTmpr;
-    private Integer hetrRunTmpr;
-    private Integer fanMode;
-    private Integer hetrMode;
-    private Integer brghCurrStep;
-    private String istlLctnAddr;
-    private Integer protocolVer;
-    private String delYn;
-
-    private int vmsWidth;
-    private int vmsHeight;
-    private int modlRowNum;
-    private int modlColNum;
-    private int powrRowNum;
-    private int powrColNum;
-
-    public TbVmsCtlrDto toDto() {
-        if (this.vmsCtlrIp == null) this.vmsCtlrIp = "";
-        this.vmsCtlrIp = this.vmsCtlrIp.trim();
-
-        if (this.cmncFailRate == null) this.cmncFailRate = 10;
-        if (this.brghNghtStep == null) this.brghNghtStep = 0;
-        if (this.brghWeekStep == null) this.brghWeekStep = 10;
-        if (this.defPhseChngCycl == null) this.defPhseChngCycl = 10;
-        if (this.modlErrRate == null) this.modlErrRate = 10;
-        if (this.cmncfailSlotNmbr == null) this.cmncfailSlotNmbr = 0;
-        if (this.pwerFailSlotNmbr == null) this.pwerFailSlotNmbr = 0;
-        if (this.vmsMaxPhseNum == null) this.vmsMaxPhseNum = 10;
-        if (this.vmsLocIfscId == null) this.vmsLocIfscId = 0L;
-        if (this.fanRunTmpr == null) this.fanRunTmpr = 0;
-        if (this.hetrRunTmpr == null) this.hetrRunTmpr = 0;
-        if (this.fanMode == null) this.fanMode = 10;
-        if (this.hetrMode == null) this.hetrMode = 10;
-        if (this.brghCurrStep == null) this.brghCurrStep = 10;
-        if (this.protocolVer == null) this.protocolVer = 0;
-        if (!"A".equals(this.operMode) && !"F".equals(this.operMode) && !"B".equals(this.operMode)) {
-            this.operMode = "A";
-        }
-
-        if (this.panlOnTime == null) this.panlOnTime = "9999";
-        if (this.panlOffTime == null) this.panlOffTime = "9999";
-        if ("9999".equals(this.panlOnTime) || this.panlOnTime.length()  != 4) {
-            this.panlOnTime  = "0000";
-        }
-        if ("9999".equals(this.panlOffTime) || this.panlOffTime.length()  != 4) {
-            this.panlOffTime  = "0000";
-        }
-
-        TbVmsCtlrDto obj = TbVmsCtlrDto.builder()
-                .vmsCtlrNmbr(this.vmsCtlrNmbr)
-                .ctlrLocalNo(this.vmsCtlrLocalNo)
-                .ctlrId(this.vmsCtlrId)
-                .name(this.vmsNm)
-                .ctlrIp(this.vmsCtlrIp)
-                .usagTypeCd(this.vmsUsagTypeCd)
-                .frmTypeCd(this.vmsFrmTypeCd)
-                .typeCd(this.vmsTypeCd)
-                .modlTypeCd(this.vmsModlTypeCd)
-                .ctlrPort(this.vmsCtlrPort)
-                .operMode(this.operMode)
-                .cmncFailRate(this.cmncFailRate)
-                .brghNghtStep(this.brghNghtStep)
-                .brghWeekStep(this.brghWeekStep)
-                .defPhseChngCycl(this.defPhseChngCycl)
-                .modlErrRate(this.modlErrRate)
-                .cmncfailSlotNmbr(this.cmncfailSlotNmbr)
-                .pwerFailSlotNmbr(this.pwerFailSlotNmbr)
-                 .cmtrinfrCnctYn(this.cmtrinfrCnctYn)
-                .wthrinfrCnctYn(this.wthrinfrCnctYn)
-                .envrinfrCnctYn(this.envrinfrCnctYn)
-                .maxPhaseNum(this.vmsMaxPhseNum)
-                .panlOnTime(this.panlOnTime)
-                .panlOffTime(this.panlOffTime)
-                .panlPwerMode(this.panlPwerMode)
-                .brghMode(this.brghMode)
-                .istlLctnNm(this.istlLctnNm)
-                .trfcStrgUseYn(this.trfcStrgUseYn)
-                .locIfscId(this.vmsLocIfscId)
-                .fanRunTmpr(this.fanRunTmpr)
-                .hetrRunTmpr(this.hetrRunTmpr)
-                .fanMode(this.fanMode)
-                .hetrMode(this.hetrMode)
-                .brghCurrStep(this.brghCurrStep)
-                .istlLctnAddr(this.istlLctnAddr)
-                .protocolVer(this.protocolVer)
-                .delYn(this.delYn)
-                .vmsWidth(this.vmsWidth)
-                .vmsHeight(this.vmsHeight)
-                .modlRowNum(this.modlRowNum)
-                .modlColNum(this.modlColNum)
-                .powrRowNum(this.powrRowNum)
-                .powrColNum(this.powrColNum)
-                .build();
-
-//        obj.init();
-        return obj;
-    }
-
-}

src/main/java/com/its/safe/process/DbmsDataProcess.java

@@ -2,7 +2,7 @@ package com.its.safe.process;
 
 import com.its.app.AppUtils;
 import com.its.safe.config.ThreadPoolInitializer;
-import com.its.safe.dao.mapper.its.NodeLinkMapper;
+import com.its.safe.dao.mapper.its.VmsMapper;
 import com.its.safe.dao.mapper.its.UnitSystMapper;
 import com.its.safe.entity.its.TbUnitSystStts;
 import lombok.RequiredArgsConstructor;
@@ -24,7 +24,7 @@ public class DbmsDataProcess {
     private final DbmsDataAsyncTask asyncTask;
 
     private final UnitSystMapper unitSystMapper;
-    private final NodeLinkMapper nodeLinkMapper;
+    private final VmsMapper vmsMapper;
     private final ThreadPoolInitializer threadPoolInitializer;
 
     public void run() {

src/main/java/com/its/safe/service/NodeLinkService.java

@@ -3,7 +3,7 @@ package com.its.safe.service;
 import com.its.app.utils.Elapsed;
 import com.its.app.utils.SysUtils;
 import com.its.safe.config.ServerConfig;
-import com.its.safe.dao.mapper.its.NodeLinkMapper;
+import com.its.safe.dao.mapper.its.VmsMapper;
 import com.its.safe.dto.its.TbLinkDto;
 import com.its.safe.dto.its.TbNodeDto;
 import com.its.safe.entity.its.MakeTrafParam;
@@ -28,7 +28,7 @@ public class NodeLinkService {
 
     private final ServerConfig config;
     private final AppRepositoryService repoService;
-    private final NodeLinkMapper mapper;
+    private final VmsMapper mapper;
     private final DbmsDataProcess dbmsDataProcess;
 
     @PostConstruct

src/main/resources/mybatis/mapper/its/NodeLinkMapper.xml → src/main/resources/mybatis/mapper/its/VmsMapper.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 
-<mapper namespace="com.its.safe.dao.mapper.its.NodeLinkMapper">
+<mapper namespace="com.its.safe.dao.mapper.its.VmsMapper">
 
     <select id="selectNodeAll" resultType="com.its.safe.entity.its.TbNode" fetchSize="1000">
     <![CDATA[