From fc8a5f61874a2f2c40f470d745fff0072d49d9c6 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期四, 05 十月 2023 17:25:41 +0800
Subject: [PATCH] 完成入库代码
---
src/main/java/com/smartearth/poiexcel/service/EntService.java | 36 ++++++++++++++++++++++++++++++++----
1 files changed, 32 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/smartearth/poiexcel/service/EntService.java b/src/main/java/com/smartearth/poiexcel/service/EntService.java
index 94165f8..ab9f5c3 100644
--- a/src/main/java/com/smartearth/poiexcel/service/EntService.java
+++ b/src/main/java/com/smartearth/poiexcel/service/EntService.java
@@ -1,7 +1,9 @@
package com.smartearth.poiexcel.service;
import com.alibaba.fastjson.JSONObject;
+import com.google.common.collect.Lists;
import com.smartearth.poiexcel.entity.*;
+import com.smartearth.poiexcel.mapper.BasicMapper;
import com.smartearth.poiexcel.mapper.EntMapper;
import com.smartearth.poiexcel.utils.RestHelper;
import org.apache.commons.logging.Log;
@@ -49,16 +51,19 @@
try {
String url = String.format(generateToken, host);
- Map<String, Object> map = new HashMap<>(2);
+ Map<String, String> map = new HashMap<>(2);
map.put("userName", user);
map.put("passWord", pwd);
+ //String map = "userName=shikong001&passWord=123!@#qwe";
+ // String str = RestHelper.postForRest(url, map)
Result rs = postForRest(url, map, Result.class);
if (null == rs || StaticData.I200 != rs.getCode()) {
return null;
}
- TokenResult tr = JSONObject.parseObject(rs.getData(), TokenResult.class);
+ // TokenResult tr = JSONObject.parseObject(rs.getData().toJSONString(), TokenResult.class)
+ TokenResult tr = rs.getData().toJavaObject(TokenResult.class);
return tr.getCtoken();
} catch (Exception ex) {
@@ -88,12 +93,35 @@
return null;
}
- EntResult er = JSONObject.parseObject(rs.getData(), EntResult.class);
+ // EntResult er = JSONObject.parseObject(rs.getData().toJSONString(), EntResult.class)
+ EntResult er = rs.getData().toJavaObject(EntResult.class);
return er.getPd().getList();
} catch (Exception ex) {
log.error(ex.getMessage(), ex);
return null;
+ }
+ }
+
+ /**
+ * 鎻掑叆浼佷笟
+ */
+ public Integer insertEnts(List<EntEntity> list) {
+ try {
+ int rows = 0;
+ List<List<EntEntity>> subLists = Lists.partition(list, StaticData.I200);
+ for (List<EntEntity> sub : subLists) {
+ try {
+ rows += entMapper.insertBatch(sub);
+ } catch (Exception ex) {
+ log.error(ex);
+ }
+ }
+
+ return rows;
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ return 0;
}
}
@@ -109,7 +137,7 @@
/**
* post璇锋眰锛圧est锛�
*/
- public <T> T postForRest(String url, Map<String, Object> map, Class<T> clazz) {
+ public <T> T postForRest(String url, Object map, Class<T> clazz) {
RestTemplate rest = RestHelper.getRestTemplate();
return rest.postForObject(url, map, clazz);
--
Gitblit v1.9.3