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
| private void insertCouponItemsToDb(List<TbkDgItemCouponGetResponse.TbkCoupon> results) {
dslContext.transaction((configuration) -> {
InsertValuesStep19<TbkGoodsRecord, Long, Integer,
String, Timestamp, Timestamp,
String, Integer, Integer,
String, String, Long,
String, String, String,
Byte, Integer, BigDecimal,
String, BigDecimal> step =
DSL.using(configuration).insertInto(TBK_GOODS,
TBK_GOODS.NUM_IID,
TBK_GOODS.CATEGORY,
TBK_GOODS.COUPON_CLICK_URL,
TBK_GOODS.COUPON_START_TIME,
TBK_GOODS.COUPON_END_TIME,
TBK_GOODS.COUPON_INFO,
TBK_GOODS.COUPON_REMAIN_COUNT,
TBK_GOODS.COUPON_TOTAL_COUNT,
TBK_GOODS.NICK,
TBK_GOODS.PICT_URL,
TBK_GOODS.SELLER_ID,
TBK_GOODS.SHOP_TITLE,
TBK_GOODS.SMALL_IMAGES,
TBK_GOODS.TITLE,
TBK_GOODS.USER_TYPE,
TBK_GOODS.VOLUME,
TBK_GOODS.ZK_FINAL_PRICE,
TBK_GOODS.ITEM_DESCRIPTION,
TBK_GOODS.TK_RATE
);
results.forEach(tbkCoupon -> {
step.values(tbkCoupon.getNumIid(),
tbkCoupon.getCategory().intValue(),
tbkCoupon.getCouponClickUrl(),
formatTime(tbkCoupon.getCouponStartTime()),
formatTime(tbkCoupon.getCouponEndTime()),
tbkCoupon.getCouponInfo(),
tbkCoupon.getCouponRemainCount().intValue(),
tbkCoupon.getCouponTotalCount().intValue(),
tbkCoupon.getNick(),
tbkCoupon.getPictUrl(),
tbkCoupon.getSellerId(),
tbkCoupon.getShopTitle(),
StringUtil.convertListToArrayStringWithDoubleQuotation(tbkCoupon.getSmallImages()),
tbkCoupon.getTitle(),
tbkCoupon.getUserType().byteValue(),
tbkCoupon.getVolume().intValue(),
BigDecimal.valueOf(Double.parseDouble(tbkCoupon.getZkFinalPrice())),
tbkCoupon.getItemDescription(),
BigDecimal.valueOf(Double.parseDouble(tbkCoupon.getCommissionRate()))
);
});
step.onDuplicateKeyUpdate()
.set(TBK_GOODS.CATEGORY, MyDSL.values(TBK_GOODS.CATEGORY))
.set(TBK_GOODS.COUPON_CLICK_URL, MyDSL.values(TBK_GOODS.COUPON_CLICK_URL))
.set(TBK_GOODS.COUPON_START_TIME, MyDSL.values(TBK_GOODS.COUPON_START_TIME))
.set(TBK_GOODS.COUPON_END_TIME, MyDSL.values(TBK_GOODS.COUPON_END_TIME))
.set(TBK_GOODS.COUPON_INFO, MyDSL.values(TBK_GOODS.COUPON_INFO))
.set(TBK_GOODS.COUPON_REMAIN_COUNT, MyDSL.values(TBK_GOODS.COUPON_REMAIN_COUNT))
.set(TBK_GOODS.NICK, MyDSL.values(TBK_GOODS.NICK))
.set(TBK_GOODS.PICT_URL, MyDSL.values(TBK_GOODS.PICT_URL))
.set(TBK_GOODS.SELLER_ID, MyDSL.values(TBK_GOODS.SELLER_ID))
.set(TBK_GOODS.SHOP_TITLE, MyDSL.values(TBK_GOODS.SHOP_TITLE))
.set(TBK_GOODS.SMALL_IMAGES, MyDSL.values(TBK_GOODS.SMALL_IMAGES))
.set(TBK_GOODS.TITLE, MyDSL.values(TBK_GOODS.TITLE))
.set(TBK_GOODS.USER_TYPE, MyDSL.values(TBK_GOODS.USER_TYPE))
.set(TBK_GOODS.VOLUME, MyDSL.values(TBK_GOODS.VOLUME))
.set(TBK_GOODS.ZK_FINAL_PRICE, MyDSL.values(TBK_GOODS.ZK_FINAL_PRICE))
.set(TBK_GOODS.ITEM_DESCRIPTION, MyDSL.values(TBK_GOODS.ITEM_DESCRIPTION))
.set(TBK_GOODS.TK_RATE, MyDSL.values(TBK_GOODS.TK_RATE))
.executeAsync(executorService);
});
}
private Timestamp formatTime(String time) {
if (Strings.isNullOrEmpty(time)) {
return null;
}
return Timestamp.valueOf(time + " 00:00:00");
}
|