30bbef42
 함상기
ai sub Matching 추가
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
|
package com.batch.config;
import java.math.BigDecimal;
import java.math.MathContext;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import com.batch.mapper.primary.MatchingInnerDelingMapper;
import com.batch.util.StatisticsUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@Slf4j
@RequiredArgsConstructor
public class MatchingAiSubProcessorAuto {
private final MatchingInnerDelingMapper matchingInnerDelingMapper;
@SuppressWarnings("unchecked")
public void process(Map paramRec, int iCmbnOwnCnt, int iCmbnTranCnt, int iStartOwn, int iStartTran) throws Exception {
//Job Create Log
UUID uuid = UUID.randomUUID();
HashMap<String, String> mt = new HashMap<String, String>();
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd-hh-mm-ss");
String sDate = dateFormat.format(new Date()) + ":" + uuid.toString();
Map<String, Object> paramLog = new HashMap<String, Object>();
paramLog.put("user_job_id", sDate);
paramLog.put("user_job_name", "AI Sub 조합매칭(" + paramRec.toString() + ",[" + iCmbnOwnCnt + "," + iStartOwn + "],[" + iCmbnTranCnt + "," + iStartTran + "])");
matchingInnerDelingMapper.createUserJob(paramLog);
int iUpdated = 0;
String sSysSe = (String) paramRec.get("sys_se");
String sAccnutYm = (String) paramRec.get("accnut_ym");
String sMtchTy = (String) paramRec.get("mtch_ty");
Long lngMtchKy = (Long) paramRec.get("mtch_ky");
String sCprCode = (String) paramRec.get("cpr_code");
String sPartCpr = (String) paramRec.get("partn_cpr");
String sConds = (String) paramRec.get("conds");
Integer iErrorRange = 0;
if (paramRec.get("error_range") != null) iErrorRange = Integer.parseInt((String) paramRec.get("error_range"));
//작업시작
Map<String, Object> mParam = new HashMap<String, Object>();
mParam.put("sysSe", sSysSe);
mParam.put("accnutYm", sAccnutYm);
mParam.put("mtchTy", sMtchTy);
mParam.put("mtchKy", lngMtchKy);
mParam.put("conds", sConds);
//----------------------------------------------------------------------------
//자기법인 데이타 가져오기
mParam.put("cprCode", sCprCode);
mParam.put("partnCpr", sPartCpr);
List<Map> lMatchingDataOne = matchingInnerDelingMapper.getAiSubDataOne(mParam);
//상대법인 데이타 가져오기
mParam.put("cprCode", sPartCpr);
mParam.put("partnCpr", sCprCode);
List<Map> lMatchingDataTwo = matchingInnerDelingMapper.getAiSubDataTwo(mParam);
//Combination 데이타 만들기
List<Map> compResult = new ArrayList<Map>();
List<List<Map>> llMatchingDataOne = new ArrayList<List<Map>>();
List<List<Map>> llMatchingDataTwo = new ArrayList<List<Map>>();
int iEndOwn = lMatchingDataOne.size();
if (iCmbnOwnCnt == 2) {
iEndOwn = iStartOwn + 1000;
if (iEndOwn > lMatchingDataOne.size()) iEndOwn = lMatchingDataOne.size();
}
if (iCmbnOwnCnt == 3) {
iEndOwn = iStartOwn + 50;
if (iEndOwn > lMatchingDataOne.size()) iEndOwn = lMatchingDataOne.size();
}
if (iCmbnOwnCnt > 3) {
iEndOwn = iStartOwn + 25;
if (iEndOwn > lMatchingDataOne.size()) iEndOwn = lMatchingDataOne.size();
}
int iEndTran = lMatchingDataTwo.size();
if (iCmbnTranCnt == 2) {
iEndTran = iStartTran + 1000;
if (iEndTran > lMatchingDataTwo.size()) iEndTran = lMatchingDataTwo.size();
}
if (iCmbnTranCnt == 3) {
iEndTran = iStartTran + 50;
if (iEndTran > lMatchingDataTwo.size()) iEndTran = lMatchingDataTwo.size();
}
if (iCmbnTranCnt > 3) {
iEndTran = iStartTran + 25;
if (iEndTran > lMatchingDataTwo.size()) iEndTran = lMatchingDataTwo.size();
}
StatisticsUtil.reculsion(lMatchingDataOne, compResult, iStartOwn, iEndOwn, iCmbnOwnCnt, llMatchingDataOne);
StatisticsUtil.reculsion(lMatchingDataTwo, compResult, iStartTran, iEndTran, iCmbnTranCnt, llMatchingDataTwo);
//----------------------------------------------------------------------------
//자기법인 데이타를 맵으로 처리한다.
Map<BigDecimal, List<List<Map>>> mMatchingDataOne = new HashMap<BigDecimal, List<List<Map>>>();
for (List<Map> curlMap : llMatchingDataOne) {
BigDecimal bdKey = BigDecimal.ZERO;
for(Map curMap : curlMap) {
bdKey = bdKey.add((BigDecimal) curMap.get("delng_amt"));
}
List<List<Map>> curllMap = new ArrayList<List<Map>>();
if (mMatchingDataOne.containsKey(bdKey)) curllMap = mMatchingDataOne.get(bdKey);
curllMap.add(curlMap);
mMatchingDataOne.put(bdKey, curllMap);
}
//키를 Ceiling 처리하여 다시 작성
Map<BigDecimal, List<List<Map>>> mMatchingDataOneNew = new HashMap<BigDecimal, List<List<Map>>>();
for (BigDecimal bdKey : mMatchingDataOne.keySet()) {
BigDecimal bdKeyNew = bdKey.setScale(iErrorRange, RoundingMode.HALF_UP);
mMatchingDataOneNew.put(bdKeyNew, mMatchingDataOne.get(bdKey));
}
mMatchingDataOne = mMatchingDataOneNew;
//상대법인 데이타를 맵으로 처리한다.
Map<BigDecimal, List<List<Map>>> mMatchingDataTwo = new HashMap<BigDecimal, List<List<Map>>>();
for (List<Map> curlMap : llMatchingDataTwo) {
BigDecimal bdKey = BigDecimal.ZERO;
for(Map curMap : curlMap) {
bdKey = bdKey.add((BigDecimal) curMap.get("delng_amt"));
}
List<List<Map>> curllMap = new ArrayList<List<Map>>();
if (mMatchingDataTwo.containsKey(bdKey)) curllMap = mMatchingDataTwo.get(bdKey);
curllMap.add(curlMap);
mMatchingDataTwo.put(bdKey, curllMap);
}
//키를 Ceiling 처리하여 다시 작성
Map<BigDecimal, List<List<Map>>> mMatchingDataTwoNew = new HashMap<BigDecimal, List<List<Map>>>();
for (BigDecimal bdKey : mMatchingDataTwo.keySet()) {
BigDecimal bdKeyNew = bdKey.setScale(iErrorRange, RoundingMode.HALF_UP);
mMatchingDataTwoNew.put(bdKeyNew, mMatchingDataTwo.get(bdKey));
}
mMatchingDataTwo = mMatchingDataTwoNew;
//여기서 매칭 비교
//비교 lMatchingDataOne vs mMatchingDataTwo
List<Map> lMatchingResultUpdate = new ArrayList<Map>(); //업데이트할 대상
int mtchNumber = 0;
String mtchSys = "AUTO";
String mtchType = "AI_" + iCmbnOwnCnt + "_" + iCmbnTranCnt;
String mtchTypeName = "자기(" + iCmbnOwnCnt + "건Sum), 상대(" + iCmbnTranCnt + "건Sum), 비교(금액)";
for (BigDecimal curKey : mMatchingDataOne.keySet()) {
if (mMatchingDataTwo.containsKey(curKey)) {
List<List<Map>> llMapOne = mMatchingDataOne.get(curKey);
List<List<Map>> llMapTwo = mMatchingDataTwo.get(curKey);
//위와 관련된 동일 레코드가 있는 리스트 삭제
for (int i=llMapOne.size()-1; i>=0;i--) {
List<Map> curlMap = llMapOne.get(i);
for (Map curMap : lMatchingResultUpdate) {
int curIdx = curlMap.indexOf(curMap);
if (curIdx != -1) {
llMapOne.remove(i);
break;
}
}
}
for (int i=llMapTwo.size()-1; i>=0;i--) {
List<Map> curlMap = llMapTwo.get(i);
for (Map curMap : lMatchingResultUpdate) {
int curIdx = curlMap.indexOf(curMap);
if (curIdx != -1) {
llMapTwo.remove(i);
break;
}
}
}
int iMin = Math.min(llMapOne.size(), llMapTwo.size());
if (iMin > 0) mtchNumber++;
while (iMin > 0) {
List<Map> curlMapOne = llMapOne.get(0);
for (Map curMap : curlMapOne) {
curMap.put("mtch_sys", mtchSys);
curMap.put("mtch_ty", mtchType);
curMap.put("mtch_ty_nm", mtchTypeName);
curMap.put("mtch_ky", mtchNumber);
lMatchingResultUpdate.add(curMap);
}
llMapOne.remove(0);
List<Map> curlMapTwo = llMapTwo.get(0);
for (Map curMap : curlMapTwo) {
curMap.put("mtch_sys", mtchSys);
curMap.put("mtch_ty", mtchType);
curMap.put("mtch_ty_nm", mtchTypeName);
curMap.put("mtch_ky", mtchNumber);
lMatchingResultUpdate.add(curMap);
}
llMapTwo.remove(0);
//위와 관련된 동일 레코드가 있는 리스트 삭제(추가 업데이트 목록)
for (int i=llMapOne.size()-1; i>=0;i--) {
List<Map> curlMap = llMapOne.get(i);
for (Map curMap : curlMapOne) {
int curIdx = curlMap.indexOf(curMap);
if (curIdx != -1) {
llMapOne.remove(i);
break;
}
}
}
for (int i=llMapTwo.size()-1; i>=0;i--) {
List<Map> curlMap = llMapTwo.get(i);
for (Map curMap : curlMapTwo) {
int curIdx = curlMap.indexOf(curMap);
if (curIdx != -1) {
llMapTwo.remove(i);
break;
}
}
}
iMin = Math.min(llMapOne.size(), llMapTwo.size());
}
}
}
//----------------------------------------------------------------------------
//여기서 결과 업데이트
iUpdated = 0;
int limit = 1000; //1000건씩 batch
List<Map> lUpdated = new ArrayList<Map>();
for (Map curMap : lMatchingResultUpdate) {
lUpdated.add(curMap);
if (lUpdated.size() == limit) {
matchingInnerDelingMapper.setExtraResult(Map.of("itemList", lUpdated));
iUpdated = iUpdated + lUpdated.size();
lUpdated.clear();
}
}
if (lUpdated.size() > 0) {
matchingInnerDelingMapper.setExtraResult(Map.of("itemList", lUpdated));
iUpdated = iUpdated + lUpdated.size();
}
log.debug("Updated OrgData : " + iUpdated + "건");
//작업종료에 대한 로그 업데이트
paramLog.put("exit_code", "0");
paramLog.put("exit_message", "");
matchingInnerDelingMapper.finishUserJob(paramLog);
}
}
|
