ChongnoTaskProcessor 정의 및 적용

src/main/java/cokr/xit/fims/chongno/ChongnoTaskProcessor.java

@@ -0,0 +1,64 @@
+package cokr.xit.fims.chongno;
+
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import cokr.xit.fims.crdn.Crdn;
+import cokr.xit.fims.crdn.CrdnQuery;
+import cokr.xit.fims.levy.LevyQuery;
+import cokr.xit.fims.levy.dao.LevyMapper;
+import cokr.xit.fims.mngt.service.bean.TaskProcessor;
+import cokr.xit.foundation.data.DataObject;
+
+public class ChongnoTaskProcessor extends TaskProcessor {
+	private static final String TASK_SE_CD = "RVS";
+
+	@Override
+	public String getVltnCdGrp(String taskSeCd) {
+		if (TASK_SE_CD.equals(taskSeCd))
+			return "FIM090";
+		return super.getVltnCdGrp(taskSeCd);
+	}
+
+	@Override
+	public String[] getExtraCdGrps(String taskSeCd) {
+		if (TASK_SE_CD.equals(taskSeCd))
+			return new String[] {"FIM002"};
+		return super.getExtraCdGrps(taskSeCd);
+	}
+
+	@Resource(name = "levyMapper")
+	private LevyMapper levyMapper;
+
+	@Override
+	public int[] getBasicAmt(Crdn crdn) {
+		String taskSeCd = crdn.getTaskSeCd();
+		if (TASK_SE_CD.equals(taskSeCd)) {
+			String crdnYmd = crdn.getCrdnYmd();
+			String sggCd = crdn.getSggCd();
+			List<DataObject> levies = levyMapper.selectPrevLevyList(
+				new LevyQuery()
+				   .setSchVhrno(crdn.getVhrno())
+				   .setSchVltnCd(crdn.getVltnCd())
+				   .setRtpyrId(crdn.getRtpyrId())
+				   .setDate(crdnYmd)
+				   .setSggCd(sggCd)
+				   .setTaskSeCd(taskSeCd)
+			);
+			String vcount = "0" + Math.min(levies.size() + 1, 3); // 위반횟수
+
+			CrdnQuery query = new CrdnQuery()
+				.setAplcnYmd(crdnYmd)
+				.setAmtDcsnCdGroupId("FIM090")
+				.setAmtDcsnCd("01")
+				.setDtlAmtDcsnGroupId("FIM091")
+				.setDtlAmtDcsnCd(vcount)
+				.setTaskSeCd(taskSeCd)
+				.setSggCd(sggCd);
+			int amt = toInt(crdnStngMapper.selectBasicAmt(query));
+			return new int[] {amt, amt};
+		}
+		return super.getBasicAmt(crdn);
+	}
+}

src/main/java/cokr/xit/fims/chongno/MainApplication.java

@@ -5,17 +5,18 @@ import java.util.List;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 
 import cokr.xit.base.ServletCustomizer;
 import cokr.xit.fims.FimsConf;
 import cokr.xit.fims.SpringBootApplicationBridge;
+import cokr.xit.fims.mngt.service.bean.TaskProcessor;
 import cokr.xit.fims.task.TaskMvcConfig;
 
 @ImportAutoConfiguration({ServletCustomizer.class,TaskMvcConfig.class})
 @ComponentScan(basePackageClasses = cokr.xit.applib.HttpStatusCodeExceptionControllerAdvice.class)
 public class MainApplication extends SpringBootApplicationBridge {
-
 	public static void main(String[] args) {
 		allowRestrictedHeaders();
 		System.setProperty("sgg", FimsConf.get().getSgg());
@@ -41,4 +42,9 @@ public class MainApplication extends SpringBootApplicationBridge {
 		}
 		System.setProperty("jdk.httpclient.allowRestrictedHeaders", allowRestrictedHeaders);
 	}
-}
+
+	@Bean("taskProcessor")
+	public TaskProcessor taskProcessor() {
+		return ChongnoTaskProcessor.get(ChongnoTaskProcessor::new);
+	}
+}