智慧保安后台管理项目备份
Administrator
2021-12-02 71ca853ee10f712055bd7b9a7eaf2c71c4d9b5c8
src/main/java/org/springblade/modules/investigate/Investigate.java
@@ -1,21 +1,25 @@
package org.springblade.modules.investigate;
import com.alibaba.druid.support.json.JSONUtils;
import com.alibaba.fastjson.JSON;
import lombok.AllArgsConstructor;
import org.json.JSONArray;
import org.json.JSONObject;
import org.springblade.common.utils.InvestigateUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.jackson.JsonUtil;
import org.springblade.modules.location.vo.GunLiveLocationVO;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springframework.retry.backoff.Sleeper;
import org.springframework.web.bind.annotation.*;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
import java.util.stream.Collectors;
/**
 * @author zhongrj
@@ -116,6 +120,7 @@
            }
//            System.out.println("cardid = " + user.getCardid());
            String body = InvestigateUtil.httpGetOne(user.getCardid());
//            System.out.println("body = " + body);
            if (null != body && !body.equals("")) {
               JSONObject jsonObject = new JSONObject(body);
               Object data = jsonObject.get("data");
@@ -126,9 +131,12 @@
               if (res.length() == 0) {
                  //没有数据正常
                  user.setExaminationType("0");
//                  System.out.println("审查正常:user.getExaminationType() = " + user.getExaminationType());
               } else {
                  int count = 0;
                  user.setExaminationType("1");
//                  System.out.println("审查异常:user.getExaminationType() = " + user.getExaminationType());
                  for (int i = 0; i < res.length(); i++) {
                     if (res.getJSONObject(i).get("zdrylbjh").toString() != null
                        && res.getJSONObject(i).get("zdrylbjh").toString() != ""
@@ -169,6 +177,7 @@
                     if (count == res.length()) {
                        //更新用户数据,设为正常
                        user.setExaminationType("0");
//                        System.out.println("审查有数据,数据为空 = user.getExaminationType() " + user.getExaminationType());
                        userService.updateById(user);
                     }
                  }
@@ -241,4 +250,30 @@
      }
      return null;
   }
   /**
    * 数据反向测试 -- 枪支
    * @param body 数据反向测试
    * @return
    */
   @PostMapping("/investigate/testBodyGun")
   public R testBodyGun(@RequestBody String body){
      JSONObject jsonObject = new JSONObject(body);
      Object data = jsonObject.get("data");
      JSONObject jsonData = new JSONObject(data.toString());
      JSONArray res = jsonData.getJSONArray("res");
      //转换string
      String resToString = res.toString();
      if (res.length()>0){
         List<GunLiveLocationVO> gunLiveLocationVOS = JSON.parseArray(resToString, GunLiveLocationVO.class);
         System.out.println("gunLiveLocationVOS = " + gunLiveLocationVOS);
         //按时间排序(reversed降序)
         List<GunLiveLocationVO> gunLiveLocationVOList =
            gunLiveLocationVOS.stream().sorted(Comparator.comparing(GunLiveLocationVO::getDwsj).reversed()).collect(Collectors.toList());
         GunLiveLocationVO gunLiveLocationVO = gunLiveLocationVOList.get(0);
         System.out.println("gunLiveLocationVO = " + gunLiveLocationVO);
      }
      return null;
   }
}