From c7d05af4e7ebf92b67308df21bde17282c0c50f1 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Thu, 06 May 2021 21:44:06 +0800
Subject: [PATCH] 1.警情导出bug修复 2.警情统计接口修改 3.一键报警设备接收报文时修改设备状态
---
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/parcel/service/impl/ParcelServiceImpl.java | 57 +++++++++++++++++++++++++++++++++++++++------------------
1 files changed, 39 insertions(+), 18 deletions(-)
diff --git a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/parcel/service/impl/ParcelServiceImpl.java b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/parcel/service/impl/ParcelServiceImpl.java
index 4be1cbe..d8e61a2 100644
--- a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/parcel/service/impl/ParcelServiceImpl.java
+++ b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/parcel/service/impl/ParcelServiceImpl.java
@@ -3,23 +3,20 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
-import com.alibaba.nacos.common.utils.JacksonUtils;
-import io.swagger.models.auth.In;
import org.springblade.jfpt.alarm.constant.AlarmTimeConstant;
import org.springblade.jfpt.animalheat.util.ImageUtil;
import org.springblade.jfpt.parcel.service.ParcelService;
import org.springblade.jfpt.parcel.util.*;
import org.springblade.jfpt.parcel.vo.ConditionVo;
-import org.springblade.jfpt.parcel.vo.ParcelExcel;
-import org.springblade.jfpt.parcel.vo.ParcelKindExcel;
+import org.springblade.common.entity.ParcelExcel;
+import org.springblade.common.entity.ParcelKindExcel;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
-import javax.validation.constraints.NotBlank;
-import java.lang.reflect.Array;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
+import java.util.concurrent.*;
import java.util.stream.Collectors;
import static org.springblade.core.tool.utils.DateUtil.now;
@@ -28,7 +25,7 @@
* 包裹服务实现层
*/
@Service
-public class ParcelServiceImpl implements ParcelService {
+public class ParcelServiceImpl implements ParcelService{
@Value("${PARCEL_KEY}")
private String PARCEL_KEY;
@@ -353,7 +350,6 @@
map.put("imgKey",imgKey);
//执行http远程调用
String s = HttpClientUtils.doGetHeaderPictureBase64(PARCEL_PICTURE_URL, PARCEL_KEY, PARCEL_SECRET, map);
- System.out.println("s = " + s);
if (null==s || s=="" || s.isEmpty()){
return null;
}
@@ -688,19 +684,29 @@
*/
@Override
public List<ParcelExcel> exportParcel(ConditionVo conditionVo) {
- ArrayList<List<ParcelExcel>> parcelExcelList = new ArrayList<>();
+ List<List<ParcelExcel>> parcelExcelList = new ArrayList<>();
//设置页码数
conditionVo.setCurrentPage(1);
- conditionVo.setPageSize(100);
+ conditionVo.setPageSize(1000);
+ if(null==conditionVo.getDecisioDiagramResult() || conditionVo.getDecisioDiagramResult()=="" || conditionVo.getDecisioDiagramResult().equals("undefined") ){
+ conditionVo.setDecisioDiagramResult(null);
+ }
+ if(null==conditionVo.getStartTime() || conditionVo.getStartTime()==""|| conditionVo.getStartTime().equals("undefined") ){
+ conditionVo.setStartTime(null);
+ }
+ if(null==conditionVo.getEndTime() || conditionVo.getEndTime()=="" || conditionVo.getEndTime().equals("undefined") ){
+ conditionVo.setEndTime(null);
+ }
+ System.out.println("conditionVo 后 = " + conditionVo);
//获取数据
Map<String,Object> result =(Map<String,Object>)getParcelDataPageList(conditionVo, PARCEL_DETAIL_RUL, PARCEL_KEY, PARCEL_SECRET).get("result");
if (null!=result) {
String data = result.get("data").toString();
List<ParcelExcel> dataList = JsonUtils.jsonToList(data, ParcelExcel.class);
parcelExcelList.add(dataList);
- //取第一次获取到的数据总数，每次取100条，多于100分批次取
+ //取第一次获取到的数据总数，每次取1000条，多于1000分批次取
int totalSize = Integer.parseInt(result.get("totalSize").toString());
- int i = totalSize/100+1;
+ int i = totalSize/1000+1;
if (i>1){
for (int j=1;j<i;j++) {
conditionVo.setCurrentPage(j+1);
@@ -713,7 +719,6 @@
}
//合并集合
List<ParcelExcel> parcelExcels = parcelExcelList.stream().flatMap(List::stream).collect(Collectors.toList());
- System.out.println("parcelExcels = " + parcelExcels);
return parcelExcels;
}
return null;
@@ -725,7 +730,6 @@
*/
@Override
public List<ParcelKindExcel> exportParcelKind(ConditionVo conditionVo) {
- System.out.println("conditionVo = " + conditionVo);
List<List<ParcelKindExcel>> parcelKindExcelList = new ArrayList<>();
List<ParcelKindExcel> list = new ArrayList<>();
if(null!=conditionVo.getTimeDesc() && conditionVo.getTimeDesc()!="" && !conditionVo.getTimeDesc().equals("undefined") ){
@@ -733,9 +737,15 @@
ConditionVo vo = new ConditionVo();
vo.setCurrentPage(1);
vo.setPageSize(100);
- vo.setDecisioDiagramResult(conditionVo.getDecisioDiagramResult());
- vo.setStartTime(conditionVo.getStartTime());
- vo.setEndTime(conditionVo.getEndTime());
+ if(null!=conditionVo.getDecisioDiagramResult() && conditionVo.getDecisioDiagramResult()!="" && !conditionVo.getDecisioDiagramResult().equals("undefined") ){
+ vo.setDecisioDiagramResult(conditionVo.getDecisioDiagramResult());
+ }
+ if(null!=conditionVo.getStartTime() && conditionVo.getStartTime()!="" && !conditionVo.getStartTime().equals("undefined") ) {
+ vo.setStartTime(conditionVo.getStartTime());
+ }
+ if(null!=conditionVo.getEndTime() && conditionVo.getEndTime()!="" && !conditionVo.getEndTime().equals("undefined") ) {
+ vo.setEndTime(conditionVo.getEndTime());
+ }
Map<String,Object> result =(Map<String,Object>) getParcelDataPageList(vo, PARCEL_KIND_URL, PARCEL_KEY, PARCEL_SECRET).get("result");
if (null!=result){
String data = result.get("data").toString();
@@ -764,6 +774,15 @@
}else {
conditionVo.setCurrentPage(1);
conditionVo.setPageSize(100);
+ if(null==conditionVo.getDecisioDiagramResult() || conditionVo.getDecisioDiagramResult()=="" || conditionVo.getDecisioDiagramResult().equals("undefined") ){
+ conditionVo.setDecisioDiagramResult(null);
+ }
+ if(null==conditionVo.getStartTime() || conditionVo.getStartTime()=="" || conditionVo.getStartTime().equals("undefined") ){
+ conditionVo.setStartTime(null);
+ }
+ if(null==conditionVo.getEndTime() || conditionVo.getEndTime()=="" || conditionVo.getEndTime().equals("undefined") ){
+ conditionVo.setEndTime(null);
+ }
Map<String,Object> result =(Map<String,Object>) getParcelDataPageList(conditionVo, PARCEL_KIND_URL, PARCEL_KEY, PARCEL_SECRET).get("result");
//获取违禁品数据
if (null!=result) {
@@ -784,7 +803,8 @@
}
}
//合并集合并返回
- return parcelKindExcelList.stream().flatMap(List::stream).collect(Collectors.toList());
+ List<ParcelKindExcel> parcelKindExcels = parcelKindExcelList.stream().flatMap(List::stream).collect(Collectors.toList());
+ return parcelKindExcels;
}
}
return null;
@@ -868,4 +888,5 @@
}
return list;
}
+
}
--
Gitblit v1.9.3