통계 수정

src/main/java/cokr/xit/fims/cmmn/CodeConverter.java

@@ -0,0 +1,219 @@
+package cokr.xit.fims.cmmn;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+
+import javax.annotation.Resource;
+
+import cokr.xit.base.code.CommonCode;
+import cokr.xit.fims.stat.dao.StatMapper;
+import cokr.xit.foundation.data.DataObject;
+
+
+public class CodeConverter {
+
+	Map<String, List<CommonCode>> commonCodes = new HashMap<String, List<CommonCode>>();
+
+	List<DataObject> sggList = new ArrayList<DataObject>();
+	List<DataObject> deptList = new ArrayList<DataObject>();
+	List<DataObject> vltnList = new ArrayList<DataObject>();
+	List<DataObject> userList = new ArrayList<DataObject>();
+
+	@Resource(name = "statMapper")
+	private StatMapper statMapper;
+
+	public CodeConverter(Map<String, List<CommonCode>> commonCodes){
+		this.commonCodes = commonCodes;
+	}
+
+	/** 코드값으로 코드를 반환한다.
+	 * @param codeGroupName 코드그룹명, value 코드값
+	 * @return 코드
+	 */
+	public String valueToCode(String codeGroupName, String value){
+		String result = "";
+
+		List<CommonCode> commonCodeList = commonCodes.get(codeGroupName);
+
+		for(int i = 0; i < commonCodeList.size(); i++) {
+			if(value.replaceAll(Matcher.quoteReplacement(" "), "").equals(commonCodeList.get(i).getValue().replaceAll(Matcher.quoteReplacement(" "), ""))) {
+				result = commonCodeList.get(i).getCode();
+			}
+		}
+		return result;
+	}
+
+	/** 코드로 코드값을 반환한다.
+	 * @param codeGroupName 코드그룹명, code 코드
+	 * @return 코드값
+	 */
+	public String codeToValue(String codeGroupName, String code){
+		String result = "";
+
+		List<CommonCode> commonCodeList = commonCodes.get(codeGroupName);
+
+		for(int i = 0; i < commonCodeList.size(); i++) {
+			if(code.equals(commonCodeList.get(i).getCode())) {
+				result = commonCodeList.get(i).getValue();
+			}
+		}
+		return result;
+	}
+
+	/** 코드나 코드명이 비어있을 경우 변환하여 값을 채운다.
+	 * @param dataObject 맵 데이터, codeGroupName 코드그룹명, codeName 코드가 저장된 키 이름, valueName 코드값이 저장된 키 이름
+	 * @return
+	 */
+	public void fillIfEmpty(DataObject dataObject, String codeGroupName, String codeName, String valueName) {
+		if(!dataObject.string(valueName).equals("") && dataObject.string(codeName).equals("")) {
+			dataObject.put(codeName, this.valueToCode(codeGroupName, dataObject.string(valueName)));
+		} else if(dataObject.string(valueName).equals("") && !dataObject.string(codeName).equals("")) {
+			dataObject.put(valueName, this.codeToValue(codeGroupName, dataObject.string(codeName)));
+		}
+	}
+
+	/** 위반코드로 위반항목명을 반환한다.
+	 * @param taskSeCd 업무구분코드, vltnCd 위반항목코드
+	 * @return 위반항목명
+	 */
+	public String vltnCdToValue(String taskSeCd, String vltnCd) {
+		String result = "";
+		String codeGroup = "";
+
+		switch(taskSeCd){
+			case "PVS" :
+				codeGroup = "FIM004";
+				break;
+			case "BPV" :
+				codeGroup = "FIM005";
+				break;
+			case "DPV" :
+				codeGroup = "FIM006";
+				break;
+			case "ECA" :
+				codeGroup = "FIM061";
+				break;
+			case "TPV" :
+				codeGroup = "FIM064";
+				break;
+			default :
+				throw new RuntimeException("위반코드 변환 오류");
+		}
+
+		List<CommonCode> commonCodeList = commonCodes.get(codeGroup);
+
+		for(int i = 0; i < commonCodeList.size(); i++) {
+			if(vltnCd.equals(commonCodeList.get(i).getCode())) {
+				result = commonCodeList.get(i).getValue();
+			}
+		}
+
+		return result;
+	}
+
+	/** 위반ID로 위반항목명을 반환한다.
+	 * @param vltnId 위반ID
+	 * @return 위반항목명
+	 */
+	public String vltnIdToValue(String vltnId){
+		String result = "";
+
+		for(int i = 0; i < vltnList.size(); i++) {
+			if(vltnId.equals(vltnList.get(i).string("VLTN_ID"))) {
+				result = vltnList.get(i).string("VLTN_NM");
+			}
+		}
+
+		if(result.equals("")) {
+			DataObject findRow = statMapper.selectVltnById(vltnId);
+
+			if(findRow != null){
+				vltnList.add(findRow);
+				result = findRow.string("VLTN_NM");
+			}
+		}
+
+		return result;
+	}
+
+	/** 시군구코드로 시군구명을 반환한다.
+	 * @param sggCd 시군구코드
+	 * @return 시군구명
+	 */
+	public String sggCodeToValue(String sggCd){
+		String result = "";
+
+		for(int i = 0; i < sggList.size(); i++) {
+			if(sggCd.equals(sggList.get(i).string("SGG_CD"))) {
+				result = sggList.get(i).string("SGG_NM");
+			}
+		}
+
+		if(result.equals("")) {
+			DataObject findRow = statMapper.selectSggByCode(sggCd);
+
+			if(findRow != null){
+				vltnList.add(findRow);
+				result = findRow.string("SGG_NM");
+			}
+		}
+
+		return result;
+	}
+
+	/** 부서코드로 부서명을 반환한다.
+	 * @param deptCd 부서코드
+	 * @return 부서명
+	 */
+	public String deptCodeToValue(String deptCd){
+		String result = "";
+
+		for(int i = 0; i < deptList.size(); i++) {
+			if(deptCd.equals(deptList.get(i).string("DEPT_CD"))) {
+				result = deptList.get(i).string("DEPT_NM");
+			}
+		}
+
+		if(result.equals("")) {
+			DataObject findRow = statMapper.selectDeptByCode(deptCd);
+
+			if(findRow != null){
+				vltnList.add(findRow);
+				result = findRow.string("DEPT_NM");
+			}
+		}
+
+		return result;
+	}
+
+
+	/** 유저ID로 유저이름을 반환한다.
+	 * @param userId 유저ID
+	 * @return 유저이름
+	 */
+	public String userIdToUserName(String userId){
+		String result = "";
+
+		for(int i = 0; i < userList.size(); i++) {
+			if(userId.equals(userList.get(i).string("USER_ID"))) {
+				result = userList.get(i).string("USER_NM");
+			}
+		}
+
+		if(result.equals("")) {
+			DataObject findRow = statMapper.selectUserById(userId);
+
+			if(findRow != null){
+				vltnList.add(findRow);
+				result = findRow.string("USER_NM");
+			}
+		}
+
+		return result;
+	}
+
+
+}

src/main/java/cokr/xit/fims/crdn/parsing/CodeConverter.java

@@ -1,53 +0,0 @@
-package cokr.xit.fims.crdn.parsing;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.regex.Matcher;
-
-import cokr.xit.base.code.CommonCode;
-import cokr.xit.foundation.data.DataObject;
-
-
-public class CodeConverter {
-
-	Map<String, List<CommonCode>> commonCodes = new HashMap<String, List<CommonCode>>();
-
-	public CodeConverter(Map<String, List<CommonCode>> commonCodes){
-		this.commonCodes = commonCodes;
-	}
-
-	public String valueToCode(String codeGroupName, String value){
-		String result = "";
-
-		List<CommonCode> commonCodeList = commonCodes.get(codeGroupName);
-
-		for(int i = 0; i < commonCodeList.size(); i++) {
-			if(value.replaceAll(Matcher.quoteReplacement(" "), "").equals(commonCodeList.get(i).getValue().replaceAll(Matcher.quoteReplacement(" "), ""))) {
-				result = commonCodeList.get(i).getCode();
-			}
-		}
-		return result;
-	}
-
-	public String codeToValue(String codeGroupName, String code){
-		String result = "";
-
-		List<CommonCode> commonCodeList = commonCodes.get(codeGroupName);
-
-		for(int i = 0; i < commonCodeList.size(); i++) {
-			if(code.equals(commonCodeList.get(i).getCode())) {
-				result = commonCodeList.get(i).getValue();
-			}
-		}
-		return result;
-	}
-
-	public void fillIfEmpty(DataObject dataObject, String codeGroupName, String codeName, String valueName) {
-		if(!dataObject.string(valueName).equals("") && dataObject.string(codeName).equals("")) {
-			dataObject.put(codeName, this.valueToCode(codeGroupName, dataObject.string(valueName)));
-		} else if(dataObject.string(valueName).equals("") && !dataObject.string(codeName).equals("")) {
-			dataObject.put(valueName, this.codeToValue(codeGroupName, dataObject.string(codeName)));
-		}
-	}
-}

src/main/java/cokr/xit/fims/crdn/parsing/LayoutParser.java

@@ -15,6 +15,7 @@ import org.apache.commons.io.FilenameUtils;
 
 import cokr.xit.base.code.CommonCode;
 import cokr.xit.fims.cmmn.CmmnUtil;
+import cokr.xit.fims.cmmn.CodeConverter;
 import cokr.xit.foundation.data.DataObject;
 import net.minidev.json.JSONArray;
 import net.minidev.json.JSONObject;

src/main/java/cokr/xit/fims/stat/dao/StatMapper.java

@@ -0,0 +1,19 @@
+package cokr.xit.fims.stat.dao;
+
+import org.egovframe.rte.psl.dataaccess.mapper.Mapper;
+
+import cokr.xit.foundation.component.AbstractMapper;
+import cokr.xit.foundation.data.DataObject;
+
+@Mapper("statMapper")
+public interface StatMapper extends AbstractMapper {
+
+	DataObject selectVltnById(String vltnId);
+
+	DataObject selectSggByCode(String sggCd);
+
+	DataObject selectDeptByCode(String deptCd);
+
+	DataObject selectUserById(String userId);
+
+}

src/main/java/cokr/xit/fims/stat/service/bean/StatBean.java

@@ -13,7 +13,7 @@ import org.springframework.stereotype.Component;
 
 import cokr.xit.base.code.CommonCode;
 import cokr.xit.fims.cmmn.CmmnQuery;
-import cokr.xit.fims.crdn.parsing.CodeConverter;
+import cokr.xit.fims.cmmn.CodeConverter;
 import cokr.xit.fims.stat.Stat;
 import cokr.xit.fims.stat.StatItem;
 import cokr.xit.fims.stat.StatQuery;
@@ -69,23 +69,7 @@ public class StatBean extends AbstractComponent {
 		statQuery.setCompositeNumberValueSeperator(compositeNumberValueSeperator);
 
 		//통계 항목별 그룹핑
-		String[] categorizations = statQuery.getCategorization();
+		Map<String, List<DataObject>> group = this.grouping(queryResult, statQuery);
-
-		Map<String, List<DataObject>> group = queryResult.stream()
-					.collect(
-							Collectors.groupingBy(
-								(item) -> {
-									String result = "";
-									for(int i = 0; i < categorizations.length; i++) {
-										if(i != 0) {
-											result += ",";
-										}
-										result += item.string(categorizations[i]);
-									}
-									return result;
-								}
-							)
-					);
 
 
 		//고정 항목 설정
@@ -118,6 +102,32 @@ public class StatBean extends AbstractComponent {
 		return stat;
 	}
 
+	/**통계요청에 따라 데이터목록을 그룹핑한다.
+	 * @param queryResult SQL쿼리 처리 결과, statQuery 통계 요청
+	 * @return 통계 항목별로 그룹핑된 목록
+	 */
+	public Map<String, List<DataObject>> grouping(List<DataObject> queryResult, StatQuery statQuery){
+		String[] categorizations = statQuery.getCategorization();
+
+		Map<String, List<DataObject>> group = queryResult.stream()
+				.collect(
+						Collectors.groupingBy(
+							(item) -> {
+								String result = "";
+								for(int i = 0; i < categorizations.length; i++) {
+									if(i != 0) {
+										result += ",";
+									}
+									result += item.string(categorizations[i]);
+								}
+								return result;
+							}
+						)
+				);
+
+		return group;
+	}
+
 	/** 통계에 고정적으로 표시할 항목을 설정한다.
 	 * @param group 그룹핑한 데이터 목록, fixedItemId 고정적으로 표시할 통계 항목 ID;
 	 * @return
@@ -205,30 +215,75 @@ public class StatBean extends AbstractComponent {
 	}
 
 	/** 특정 범주로 묶인 통계 항목에 항목명을 추가한다.
-	 * @param statItems 통계 항목 목록, categoryNameConverter 항목명 변환 처리용 코드그룹명, allCode 코드 목록
+	 * @param statItems 통계 항목 목록, statQuery 통계 요청, allCode 코드 목록
 	 * @return
 	 */
-	public void attachItemName(List<StatItem> statItems, String[] categoryNameConverter, Map<String, List<CommonCode>> allCode) {
+	public void attachItemName(List<StatItem> statItems, StatQuery statQuery, Map<String, List<CommonCode>> allCode) {
 
 		CodeConverter codeConverter = new CodeConverter(allCode);
 
-		String[] nameConverters = categoryNameConverter;
+		String[] nameConverters = statQuery.getCategoryNameConverter();
+
+		int taskSeCdIndex = -1;
+		for(int i=0; i < nameConverters.length; i++) {
+			if(nameConverters[i].equals("code=FIM054")) {
+				taskSeCdIndex = i;
+			}
+		}
+
 		for(StatItem statItem : statItems) {
 
 			String[] compositeItemId = statItem.getItemId();
 			String[] compositeItemName = new String[compositeItemId.length];
+
 			for(int i=0; i < compositeItemId.length ;i++) {
-				if(nameConverters[i].equals("") || nameConverters[i].equals("plain")) {
+
+				if(nameConverters[i].equals("") || nameConverters[i].equals("plain")) { //일반텍스트
 					compositeItemName[i] = compositeItemId[i];
-				} else if(nameConverters[i].startsWith("code=")){
+					continue;
-					String itemName = codeConverter.codeToValue(nameConverters[i].split("=")[1], compositeItemId[i]);
+				}
-					compositeItemName[i] = itemName;
+
+
+				String itemName = "";
+
+				if(nameConverters[i].startsWith("code=")){ //공통코드
+
+					itemName = codeConverter.codeToValue(nameConverters[i].split("=")[1], compositeItemId[i]);
+
+				} else if(nameConverters[i].startsWith("otherCode=")) { //비공통코드
+
+					if(nameConverters[i].equals("otherCode=VLTN_CD")) {
+
+						String taskSeCd = "";
+						if(taskSeCdIndex != -1) {
+							taskSeCd = compositeItemId[taskSeCdIndex];
+						} else if(!statQuery.getTaskSeCd().equals("")) {
+							taskSeCd = statQuery.getTaskSeCd();
+						}
+
+						if(taskSeCd.equals("")) {
+							throw new RuntimeException("위반코드 변환 오류");
+						}
+
+						itemName = codeConverter.vltnCdToValue(taskSeCd, compositeItemId[i]);
+					} else if(nameConverters[i].equals("otherCode=VLTN_ID")) {
+						itemName = codeConverter.vltnIdToValue(compositeItemId[i]);
+					} else if(nameConverters[i].equals("otherCode=SGG_CD")) {
+						itemName = codeConverter.sggCodeToValue(compositeItemId[i]);
+					} else if(nameConverters[i].equals("otherCode=DEPT_CD")) {
+						itemName = codeConverter.deptCodeToValue(compositeItemId[i]);
+					} else if(nameConverters[i].equals("otherCode=USER_ID")) {
+						itemName = codeConverter.userIdToUserName(compositeItemId[i]);
+					}
+
 				}
+
+				compositeItemName[i] = itemName;
 			}
-			statItem.setItemName(compositeItemName);
-		}
 
+			statItem.setItemName(compositeItemName);
 
+		}
 	}
 
 	/** 통계의 일부 항목을 합쳐 새 범주로 묶는다.

src/main/java/cokr/xit/fims/stat/service/bean/StatServiceBean.java

@@ -193,7 +193,7 @@ public class StatServiceBean extends AbstractServiceBean implements StatService
 
 			stat = statBean.groupByCartegory(queryResult, statQuery);
 
-			statBean.attachItemName(stat.getStatItems(), statQuery.getCategoryNameConverter(), commonCodes);
+			statBean.attachItemName(stat.getStatItems(), statQuery, commonCodes);
 
 			if(statQuery.getRegroupInfos() != null){
 				statBean.regroupItem(stat.getStatItems(), statQuery.getRegroupInfos());

src/main/java/cokr/xit/fims/stat/web/StatController.java

@@ -47,6 +47,17 @@ public class StatController extends ApplicationController {
 		for(int i=0; i < categoryNameConverter.length; i++) {
 			if(categoryNameConverter[i].startsWith("code=")) {
 				codeGroup.add(categoryNameConverter[i].split("=")[1]);
+			} else if(categoryNameConverter[i].startsWith("otherCode=")) {
+
+				if(categoryNameConverter[i].equals("otherCode=VLTN_CD")) {
+					codeGroup.add("FIM054");
+					codeGroup.add("FIM004");
+					codeGroup.add("FIM005");
+					codeGroup.add("FIM006");
+					codeGroup.add("FIM061");
+					codeGroup.add("FIM064");
+				}
+
 			}
 		}
 

src/main/resources/sql/mapper/fims/stat/stat-mapper.xml

@@ -0,0 +1,33 @@
+<?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="cokr.xit.fims.stat.dao.StatMapper">
+
+<select id="selectVltnById" parameterType="string" resultType="dataobject">
+SELECT VLTN_ID
+     , VLTN_NM
+FROM TB_VLTN_INFO
+WHERE VLTN_ID = #{vltnId}
+</select>
+
+<select id="selectSggByCode" parameterType="string" resultType="dataobject">
+SELECT SGG_CD
+     , SGG_NM
+FROM TB_SGG_INFO
+WHERE SGG_CD = #{sggCd}
+</select>
+
+<select id="selectDeptByCode" parameterType="string" resultType="dataobject">
+SELECT DEPT_CD
+     , DEPT_NM
+FROM TB_DEPT_INFO
+WHERE DEPT_CD = #{deptCd}
+</select>
+
+<select id="selectUserById" parameterType="string" resultType="dataobject">
+SELECT USER_ID
+     , USER_NM
+FROM TB_USER
+WHERE USER_ID = #{userId}
+</select>
+
+</mapper>