| | |
| | | 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 |
| | |
| | | } |
| | | // 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"); |
| | |
| | | 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() != "" |
| | |
| | | if (count == res.length()) { |
| | | //更新用户数据,设为正常 |
| | | user.setExaminationType("0"); |
| | | // System.out.println("审查有数据,数据为空 = user.getExaminationType() " + user.getExaminationType()); |
| | | userService.updateById(user); |
| | | } |
| | | } |
| | |
| | | } |
| | | 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; |
| | | } |
| | | } |