1.警情导出bug修复 2.警情统计接口修改 3.一键报警设备接收报文时修改设备状态

Administrator

2021-05-06 c7d05af4e7ebf92b67308df21bde17282c0c50f1

 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;
   }

}