crash class remove and source update

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

@@ -1,105 +0,0 @@
-package com.its.bis.dao.mapper;
-
-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/bis/dao/mapper/batch/NodeLinkDao.java

@@ -1,74 +0,0 @@
-package com.its.bis.dao.mapper.batch;
-
-import com.its.app.utils.Elapsed;
-import com.its.bis.dao.mapper.BatchDaoService;
-import com.its.bis.entity.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/bis/dto/TbVmsCtlrDto.java

@@ -1,99 +0,0 @@
-package com.its.bis.dto;
-
-import com.its.bis.entity.TbVmsCtlrStts;
-import io.netty.channel.Channel;
-import lombok.*;
-import lombok.extern.slf4j.Slf4j;
-
-import java.io.Serializable;
-import java.net.InetSocketAddress;
-
-@Slf4j
-@Getter
-@Setter
-@ToString
-@Builder
-@NoArgsConstructor//(access = AccessLevel.PROTECTED)
-@AllArgsConstructor
-public class TbVmsCtlrDto implements Serializable {
-    private static final long serialVersionUID = 1L;
-
-    private int  index;
-    private Long vmsCtlrNmbr;
-    private Long groupNo;
-    private Integer ctlrLocalNo;
-    private String ctlrId;
-    private String name;
-    private String ctlrIp;
-    private String ctlrPort;
-    private String usagTypeCd;
-    private String frmTypeCd;
-    private String typeCd;
-    private String modlTypeCd;
-    private String operMode;
-    private Integer cmncfailSlotNmbr;
-    private Integer pwerFailSlotNmbr;
-    private String cmtrinfrCnctYn;
-    private String wthrinfrCnctYn;
-    private String envrinfrCnctYn;
-    private Integer maxPhaseNum;
-    private String istlLctnNm;
-    private String istlLctnAddr;
-    private String trfcStrgUseYn;
-    private Long locIfscId;
-
-    private Integer defPhseChngCycl;    // 기본메시지주기
-    private String panlOnTime;          // 전광판 ON TIME
-    private String panlOffTime;         // 전광판 OFF TIME
-    private Integer panlPwerMode;        // 전광판 전원 모드(0x00:꺼짐,0x01:켜짐,0x02:자동,0x09:알수없음)
-    private Integer fanMode;            // FAN 동작모드(0x00:꺼짐,0x01:켜짐,0x02:자동,0x09:알수없음)
-    private Integer fanRunTmpr;          // 팬 동작 온도
-    private Integer hetrMode;           // 히터 동작모드(0x00:꺼짐,0x01:켜짐,0x02:자동,0x09:알수없음)
-    private Integer hetrRunTmpr;         // 히터 동작 온도
-    private Integer brghMode;           // 휘도 모드(0x00:주간,0x01:야간,0x02:자동,0x09:수동)
-    private Integer brghCurrStep;       // 휘도 현재 단계(0~100)
-    private Integer brghWeekStep;       // 휘도 주간 단계(0~100)
-    private Integer brghNghtStep;       // 휘도 야간 단계(0~100)
-    private Integer modlErrRate;        // VMS 모듈 오류 율
-    private Integer cmncFailRate;       // VMS 통신 오류 기본 값
-
-    private Integer protocolVer;
-    private String delYn;
-
-    private int vmsWidth;
-    private int vmsHeight;
-    private int modlRowNum;
-    private int modlColNum;
-    private int powrRowNum;
-    private int powrColNum;
-
-    private String localFormDir;
-    private String ftpFormDir;
-    private boolean ftpDownload;
-    private boolean symbolDownload;
-
-    private int maxCngstForm;        // 정체폼 생성 최대 갯수
-    private int cngstForms;
-    private boolean existCngsForm;
-    private boolean provide;
-    private boolean evehIngForm;
-    private boolean evehEndForm;
-
-    private byte txtOpCode;
-
-    private TbVmsCtlrStts     stts;
-    private int 			  netState;
-    private boolean           isDupCon;
-    private boolean           isDupLogin;
-    private String 		      dstIpAddr;
-    private Channel           channel = null;
-    private Channel           dupChannel = null;
-    private InetSocketAddress cliReq;
-    private long              syncTime;
-
-    public String getLogKey() {
-        return this.ctlrId;
-    }
-
-}
-

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

@@ -1,144 +0,0 @@
-package com.its.bis.entity;
-
-import com.its.bis.dto.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/bis/entity/TbVmsCtlrStts.java

@@ -1,149 +0,0 @@
-package com.its.bis.entity;
-
-import com.its.app.utils.SysUtils;
-import lombok.Data;
-
-import java.io.Serializable;
-
-/**
- *  DTO Class
- */
-@Data
-public class TbVmsCtlrStts implements Serializable {
-    private static final long serialVersionUID = 1L;
-
-    private Long vmsCtlrNmbr;
-    private String updtDt;
-    private String cmncSttsCd;      // 통신 상태 코드('CMS')
-    private String pwerSttsCd;      // 전원 상태 코드('PWS')
-    private String modlSttsCd;      // 모듈(LED) 상태 코드
-    private String cboxDoorSttsCd;  // 함체 문 상태 코드('CDS')
-    private String fanSttsCd;       // 팬 상태 코드('PAS')
-    private String hetrSttsCd;      // 히터 상태 코드('HTS')
-    private Integer cboxTmpr;       // 함체 온도
-    private Integer brghVal;        // 휘도값
-    private String commSttsCd;      // 통신 상태 코드('CMS')
-    private String modlStts;        // 모듈상태(문자열, 0: 꺼짐, 1: 켜짐, 9: 알수없음)
-    private String pwerStts;        // 전원상태(문자열, 0: 꺼짐, 1: 켜짐, 9: 알수없음)
-
-    private Integer cboxHum;        //CBOX_HUM	N	NUMBER(3)	Y	0		함체 습도
-    private String cboxFanSttsCd;   //CBOX_FAN_STTS_CD	N	VARCHAR2(7)	Y			함체 팬 상태 코드
-    private String cboxHetrSttsCd;  //CBOX_HETR_STTS_CD	N	VARCHAR2(7)	Y			함체 히터 상태 코드
-    private Integer tmpr;           //TMPR	N	NUMBER(3)	Y	0		표출부 온도
-    private Integer hum;            //HUM	N	NUMBER(3)	Y	0		표출부 습도
-    private String doorSttsCd;      //DOOR_STTS_CD	N	VARCHAR2(7)	Y			표출부 문 상태 코드
-    private Integer brghMode;       //BRGH_MODE	N	NUMBER(3)	Y	0		표출부 휘도모드(0:주간, 1:야간, 2: 자동, 3: 수동)
-    private Integer brghCurr;       //BRGH_CURR	N	NUMBER(3)	Y	0		표출부 현재 휘도값
-    private Integer brghWeek;       //BRGH_WEEK	N	NUMBER(3)	Y	0		표출부 주간 휘도값
-    private Integer brghNght;       //BRGH_NGHT	N	NUMBER(3)	Y	0		표출부 야간 휘도값
-    private String pwerOnOffCd;     //PWER_ONOFF_CD	N	VARCHAR2(7)	Y			표출부 전원 ON/OFF 코드
-
-    public TbVmsCtlrStts(Long vmsCtlrNmbr) {
-        this.vmsCtlrNmbr = vmsCtlrNmbr;
-        initUnknown();
-    }
-
-    public TbVmsCtlrStts clone() {
-        TbVmsCtlrStts dto = new TbVmsCtlrStts(this.vmsCtlrNmbr);
-        dto.setUpdtDt(this.updtDt);
-        dto.setCmncSttsCd(this.cmncSttsCd);
-        dto.setPwerSttsCd(this.pwerSttsCd);
-        dto.setModlSttsCd(this.modlSttsCd);
-        dto.setCboxDoorSttsCd(this.cboxDoorSttsCd);
-        dto.setFanSttsCd(this.fanSttsCd);
-        dto.setHetrSttsCd(this.hetrSttsCd);
-        dto.setCboxTmpr(this.cboxTmpr);
-        dto.setBrghVal(this.brghVal);
-        dto.setCommSttsCd(this.commSttsCd);
-        dto.setModlStts(this.modlStts);
-        dto.setPwerStts(this.pwerStts);
-
-        dto.setCboxHum(this.cboxHum);
-        dto.setCboxFanSttsCd(this.cboxFanSttsCd);
-        dto.setCboxHetrSttsCd(this.cboxHetrSttsCd);
-        dto.setTmpr(this.tmpr);
-        dto.setHum(this.hum);
-        dto.setDoorSttsCd(this.doorSttsCd);
-        dto.setBrghMode(this.brghMode);
-        dto.setBrghCurr(this.brghCurr);
-        dto.setBrghWeek(this.brghWeek);
-        dto.setBrghNght(this.brghNght);
-        dto.setPwerOnOffCd(this.pwerOnOffCd);
-
-        return dto;
-    }
-    public void initStts(boolean isConnected) {
-        if (isConnected) {
-            initUnknown();
-        } else {
-            initError();
-        }
-    }
-    public void initUnknown() {
-        this.updtDt = SysUtils.getSysTime();
-        this.cmncSttsCd = "CMS2";
-        this.commSttsCd = "CMS2";
-
-        this.pwerSttsCd = "PWS2";
-        this.modlSttsCd = "MOS2";
-        this.cboxDoorSttsCd = "CDS2";
-        this.fanSttsCd = "PAS2";
-        this.hetrSttsCd = "HTS2";
-        this.cboxTmpr = 0;
-        this.brghVal = 0;
-        this.modlStts = "11111111111111111111";
-        this.pwerStts = "11111111111111111111";
-
-        this.cboxHum = 0;
-        this.cboxFanSttsCd = "PAS2";
-        this.cboxHetrSttsCd = "HTS2";
-        this.tmpr = 0;
-        this.hum = 0;
-        this.doorSttsCd = "CDS2";
-        this.brghMode = 0;
-        this.brghCurr = 0;
-        this.brghWeek = 0;
-        this.brghNght = 0;
-        this.pwerOnOffCd = "PWO2";
-    }
-    public void initError() {
-        initUnknown();
-        this.cmncSttsCd = "CMS1";
-        this.commSttsCd = "CMS1";
-    }
-
-    public void initNormal() {
-        initUnknown();
-        this.cmncSttsCd = "CMS0";
-        this.commSttsCd = "CMS0";
-    }
-
-    public void updateStts(TbVmsCtlrStts dto) {
-        this.updtDt = dto.getUpdtDt();
-        this.cmncSttsCd = dto.getCmncSttsCd();
-        this.pwerSttsCd = dto.getPwerSttsCd();
-        this.modlSttsCd = dto.getModlSttsCd();
-        this.cboxDoorSttsCd = dto.getCboxDoorSttsCd();
-        this.fanSttsCd = dto.getFanSttsCd();
-        this.hetrSttsCd = dto.getHetrSttsCd();
-        this.cboxTmpr = dto.getCboxTmpr();
-        this.brghVal = dto.getBrghVal();
-        this.commSttsCd = dto.getCommSttsCd();
-        this.modlStts = dto.getModlStts();
-        this.pwerStts = dto.getPwerStts();
-
-        this.cboxHum = dto.getCboxHum();
-        this.cboxFanSttsCd = dto.getCboxFanSttsCd();
-        this.cboxHetrSttsCd = dto.getCboxHetrSttsCd();
-        this.tmpr = dto.getTmpr();
-        this.hum = dto.getHum();
-        this.doorSttsCd = dto.getDoorSttsCd();
-        this.brghMode = dto.getBrghMode();
-        this.brghCurr = dto.getBrghCurr();
-        this.brghWeek = dto.getBrghWeek();
-        this.brghNght = dto.getBrghNght();
-        this.pwerOnOffCd = dto.getPwerOnOffCd();
-    }
-
-
-}