배치조회 시 페이징 처리 추가

master
mjkhan21 2 years ago
parent f0c6e9e2dd
commit 46945a08b6

@ -261,7 +261,7 @@ public interface LntrisB10_12Mapper extends AbstractMapper {
* @param b11
* @return
*/
default int insertB11Resps(LntrisB11 b11) {
default int insertB11Resps(LntrisB11 b11, int start) {
String b11Id = b11.getB11Id();
List<LntrisB11.B11RespDetail> resps = b11.getResponse().getResVo1();
if (isEmpty(b11Id) || resps.isEmpty()) return 0;
@ -269,7 +269,7 @@ public interface LntrisB10_12Mapper extends AbstractMapper {
for (int i = 0; i < resps.size(); ++i) {
LntrisB11.B11RespDetail resp = resps.get(i);
resp.setB11Id(b11Id);
resp.setB11Sn(Integer.toString(i + 1));
resp.setB11Sn(Integer.toString(start + i + 1));
}
return insertB11Resps(params().set("resps", resps));
@ -284,7 +284,7 @@ public interface LntrisB10_12Mapper extends AbstractMapper {
for (LntrisB11 b11: b11s) {
affected += insertB11Req(b11)
+ insertB11Resps(b11);
+ insertB11Resps(b11, 0);
}
return affected;

@ -112,7 +112,7 @@ public interface LntrisB13_16Mapper extends AbstractMapper {
* @param b13
* @return
*/
default int insertB13Resps(LntrisB13 b13) {
default int insertB13Resps(LntrisB13 b13, int start) {
String b13Id = b13.getB13Id();
List<LntrisB13.B13RespDetail> resps = b13.getResponse().getResVo1();
if (isEmpty(b13Id) || resps.isEmpty()) return 0;
@ -120,7 +120,7 @@ public interface LntrisB13_16Mapper extends AbstractMapper {
for (int i = 0; i < resps.size(); ++i) {
LntrisB13.B13RespDetail resp = resps.get(i);
resp.setB13Id(b13Id);
resp.setB13Sn(Integer.toString(i + 1));
resp.setB13Sn(Integer.toString(start + i + 1));
}
return insertB13Resps(params().set("resps", resps));
@ -135,7 +135,7 @@ public interface LntrisB13_16Mapper extends AbstractMapper {
for (LntrisB13 b13: b13s) {
affected += insertB13Req(b13)
+ insertB13Resps(b13);
+ insertB13Resps(b13, 0);
}
return affected;
@ -352,7 +352,7 @@ public interface LntrisB13_16Mapper extends AbstractMapper {
* @param b15
* @return
*/
default int insertB15Resps(LntrisB15 b15) {
default int insertB15Resps(LntrisB15 b15, int start) {
String b15Id = b15.getB15Id();
List<LntrisB15.B15RespDetail> resps = b15.getResponse().getResVo1();
if (isEmpty(b15Id) || resps.isEmpty()) return 0;
@ -360,7 +360,7 @@ public interface LntrisB13_16Mapper extends AbstractMapper {
for (int i = 0; i < resps.size(); ++i) {
LntrisB15.B15RespDetail resp = resps.get(i);
resp.setB15Id(b15Id);
resp.setB15Sn(Integer.toString(i + 1));
resp.setB15Sn(Integer.toString(start + i + 1));
}
return insertB15Resps(params().set("resps", resps));
@ -375,7 +375,7 @@ public interface LntrisB13_16Mapper extends AbstractMapper {
for (LntrisB15 b15: b15s) {
affected += insertB15Req(b15)
+ insertB15Resps(b15);
+ insertB15Resps(b15, 0);
}
return affected;

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB01;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB01_03Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB01_03Mapper;
* @author mjkhan
*/
@Component("lntrisB01Bean")
public class LntrisB01Bean extends ScheduledBean {
public class LntrisB01Bean extends LntrisBean {
@Resource(name="lntrisB01_03Mapper")
private LntrisB01_03Mapper b01_03Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB02;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB01_03Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB01_03Mapper;
* @author mjkhan
*/
@Component("lntrisB02Bean")
public class LntrisB02Bean extends ScheduledBean {
public class LntrisB02Bean extends LntrisBean {
@Resource(name="lntrisB01_03Mapper")
private LntrisB01_03Mapper b01_03Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB03;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB01_03Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB01_03Mapper;
* @author mjkhan
*/
@Component("lntrisB03Bean")
public class LntrisB03Bean extends ScheduledBean {
public class LntrisB03Bean extends LntrisBean {
@Resource(name="lntrisB01_03Mapper")
private LntrisB01_03Mapper b01_03Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB04;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB04_06Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB04_06Mapper;
* @author mjkhan
*/
@Component("lntrisB04Bean")
public class LntrisB04Bean extends ScheduledBean {
public class LntrisB04Bean extends LntrisBean {
@Resource(name="lntrisB04_06Mapper")
private LntrisB04_06Mapper b04_06Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB05;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB04_06Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB04_06Mapper;
* @author mjkhan
*/
@Component("lntrisB05Bean")
public class LntrisB05Bean extends ScheduledBean {
public class LntrisB05Bean extends LntrisBean {
@Resource(name="lntrisB04_06Mapper")
private LntrisB04_06Mapper b04_06Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB06;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB04_06Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB04_06Mapper;
* @author mjkhan
*/
@Component("lntrisB06Bean")
public class LntrisB06Bean extends ScheduledBean {
public class LntrisB06Bean extends LntrisBean {
@Resource(name="lntrisB04_06Mapper")
private LntrisB04_06Mapper b04_06Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB07;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB07_09Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB07_09Mapper;
* @author mjkhan
*/
@Component("lntrisB07Bean")
public class LntrisB07Bean extends ScheduledBean {
public class LntrisB07Bean extends LntrisBean {
@Resource(name="lntrisB07_09Mapper")
private LntrisB07_09Mapper b07_09Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB08;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB07_09Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB07_09Mapper;
* @author mjkhan
*/
@Component("lntrisB08Bean")
public class LntrisB08Bean extends ScheduledBean {
public class LntrisB08Bean extends LntrisBean {
@Resource(name="lntrisB07_09Mapper")
private LntrisB07_09Mapper b07_09Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB09;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB07_09Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB07_09Mapper;
* @author mjkhan
*/
@Component("lntrisB09Bean")
public class LntrisB09Bean extends ScheduledBean {
public class LntrisB09Bean extends LntrisBean {
@Resource(name="lntrisB07_09Mapper")
private LntrisB07_09Mapper b07_09Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB10;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB10_12Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB10_12Mapper;
* @author mjkhan
*/
@Component("lntrisB10Bean")
public class LntrisB10Bean extends ScheduledBean {
public class LntrisB10Bean extends LntrisBean {
@Resource(name="lntrisB10_12Mapper")
private LntrisB10_12Mapper b10_12Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB11;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB10_12Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB10_12Mapper;
* @author mjkhan
*/
@Component("lntrisB11Bean")
public class LntrisB11Bean extends ScheduledBean {
public class LntrisB11Bean extends LntrisBean {
@Resource(name="lntrisB10_12Mapper")
private LntrisB10_12Mapper b10_12Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs
@ -77,13 +74,19 @@ public class LntrisB11Bean extends ScheduledBean {
if (b11s.isEmpty()) return;
for (LntrisB11 b11: b11s) {
requestor.request(b11);
pagingRequest(
b11,
info -> info.getResponse().getResVo1(),
(obj, start) -> b10_12Mapper.insertB11Resps(obj, start),
(req, last) -> {
String acbKey = ((LntrisB11.B11RespDetail)last).getFinScrgAcbKey();
((LntrisB11.B11ReqDetail)req).setFinScrgAcbKey(acbKey);
},
0
);
}
InterfaceConfig.databaseActive(() -> {
b11s.forEach(b10_12Mapper::insertB11Resps);
b10_12Mapper.updateB11Reqs(b11s);
});
InterfaceConfig.databaseActive(() -> b10_12Mapper.updateB11Reqs(b11s));
}
/** .

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB12;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB10_12Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB10_12Mapper;
* @author mjkhan
*/
@Component("lntrisB12Bean")
public class LntrisB12Bean extends ScheduledBean {
public class LntrisB12Bean extends LntrisBean {
@Resource(name="lntrisB10_12Mapper")
private LntrisB10_12Mapper b10_12Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB13;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
* @author mjkhan
*/
@Component("lntrisB13Bean")
public class LntrisB13Bean extends ScheduledBean {
public class LntrisB13Bean extends LntrisBean {
@Resource(name="lntrisB13_16Mapper")
private LntrisB13_16Mapper b13_16Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs
@ -77,11 +74,19 @@ public class LntrisB13Bean extends ScheduledBean {
if (b13s.isEmpty()) return;
for (LntrisB13 b13: b13s) {
requestor.request(b13);
pagingRequest(
b13,
info -> info.getResponse().getResVo1(),
(obj, start) -> b13_16Mapper.insertB13Resps(obj, start),
(req, last) -> {
String acbKey = ((LntrisB13.B13RespDetail)last).getPrkgVltAcbKey();
((LntrisB13.B13ReqDetail)req).setPrkgVltAcbKey(acbKey);
},
0
);
}
InterfaceConfig.databaseActive(() -> {
b13s.forEach(b13_16Mapper::insertB13Resps);
b13_16Mapper.updateB13Reqs(b13s);
});
}

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB14;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
* @author mjkhan
*/
@Component("lntrisB14Bean")
public class LntrisB14Bean extends ScheduledBean {
public class LntrisB14Bean extends LntrisBean {
@Resource(name="lntrisB13_16Mapper")
private LntrisB13_16Mapper b13_16Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB15;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
* @author mjkhan
*/
@Component("lntrisB15Bean")
public class LntrisB15Bean extends ScheduledBean {
public class LntrisB15Bean extends LntrisBean {
@Resource(name="lntrisB13_16Mapper")
private LntrisB13_16Mapper b13_16Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs
@ -77,13 +74,19 @@ public class LntrisB15Bean extends ScheduledBean {
if (b15s.isEmpty()) return;
for (LntrisB15 b15: b15s) {
requestor.request(b15);
pagingRequest(
b15,
info -> info.getResponse().getResVo1(),
(obj, start) -> b13_16Mapper.insertB15Resps(obj, start),
(req, last) -> {
String acbKey = ((LntrisB15.B15RespDetail)last).getPrtusCartkVltAcbKey();
((LntrisB15.B15ReqDetail)req).setPrtusCartkVltAcbKey(acbKey);
},
0
);
}
InterfaceConfig.databaseActive(() -> {
b15s.forEach(b13_16Mapper::insertB15Resps);
b13_16Mapper.updateB15Reqs(b15s);
});
InterfaceConfig.databaseActive(() -> b13_16Mapper.updateB15Reqs(b15s));
}
/** .

@ -7,9 +7,8 @@ import javax.annotation.Resource;
import org.springframework.stereotype.Component;
import cokr.xit.foundation.component.ScheduledBean;
import cokr.xit.interfaces.lntris.InterfaceConfig;
import cokr.xit.interfaces.lntris.Requestor;
import cokr.xit.interfaces.lntris.LntrisBean;
import cokr.xit.interfaces.lntris.special.b.LntrisB16;
import cokr.xit.interfaces.lntris.special.b.LntrisBQuery;
import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
@ -18,12 +17,10 @@ import cokr.xit.interfaces.lntris.special.b.dao.LntrisB13_16Mapper;
* @author mjkhan
*/
@Component("lntrisB16Bean")
public class LntrisB16Bean extends ScheduledBean {
public class LntrisB16Bean extends LntrisBean {
@Resource(name="lntrisB13_16Mapper")
private LntrisB13_16Mapper b13_16Mapper;
private Requestor requestor = new Requestor();
/** .
* @param taskSeCd
* @param reqs

Loading…
Cancel
Save