| | |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.github.pagehelper.PageInfo; |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
| | | import com.ruoyi.common.core.redis.RedisCache; |
| | | import com.ruoyi.common.utils.SecurityUtils; |
| | | import com.ruoyi.common.utils.uuid.IdUtils; |
| | | import com.ruoyi.sy.domain.ArdAccessFence; |
| | | import com.ruoyi.sy.param.ArdSyCarParam; |
| | | import com.ruoyi.sy.vo.ArdSyCarVo; |
| | | import com.ruoyi.utils.gis.GisUtil; |
| | | import com.ruoyi.utils.gis.Point; |
| | | import com.ruoyi.scheduling.domian.SchedulingParam; |
| | |
| | | @Override |
| | | public List<ArdSyCar> selectArdSyCarList(ArdSyCar ardSyCar) { |
| | | return ardSyCarMapper.selectArdSyCarList(ardSyCar); |
| | | } |
| | | |
| | | @Override |
| | | public AjaxResult ardSyCarList(ArdSyCarParam ardSyCarParam,Map<String,Object> result) { |
| | | QueryWrapper<ArdSyCar> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.like(ardSyCarParam.getCarBrand()!=null,"car_brand",ardSyCarParam.getCarBrand()) |
| | | .like(ardSyCarParam.getCarType()!=null,"car_type",ardSyCarParam.getCarType()); |
| | | List<ArdSyCar> ardSyCars = ardSyCarMapper.selectList(queryWrapper); |
| | | List<ArdSyCarVo> ardSyCarVoList = new ArrayList<>(); |
| | | if(((String)result.get("code")).equals("200")){ |
| | | List<Map<String,Object>> list = (List<Map<String, Object>>) result.get("data"); |
| | | for (int i = 0; i < ardSyCars.size(); i++) { |
| | | ArdSyCar ardSyCar = ardSyCars.get(i); |
| | | String carId = ardSyCar.getCarId(); |
| | | for (int j = 0; j < list.size(); j++) { |
| | | String carId31 = (String) list.get(j).get("carId"); |
| | | if(carId.equals(carId31)){ |
| | | ArdSyCarVo ardSyCarVo = new ArdSyCarVo(); |
| | | ardSyCarVo.setId(ardSyCar.getId()); |
| | | ardSyCarVo.setCarId(carId); |
| | | ardSyCarVo.setCarBrand(ardSyCar.getCarBrand()); |
| | | ardSyCarVo.setCarModel(ardSyCar.getCarModel()); |
| | | ardSyCarVo.setCarPicture(ardSyCar.getCarPicture()); |
| | | ardSyCarVo.setCarType(ardSyCar.getCarType()); |
| | | ardSyCarVo.setDeptId(ardSyCar.getDeptId()); |
| | | ardSyCarVo.setRemark(ardSyCar.getRemark()); |
| | | ardSyCarVo.setCarPlate((String) list.get(j).get("carPlate")); |
| | | ardSyCarVoList.add(ardSyCarVo); |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if(ardSyCarParam.getCarPlate()!=null){ |
| | | List<ArdSyCarVo> newList = new ArrayList<>(); |
| | | for (int i = 0; i < ardSyCarVoList.size(); i++) { |
| | | String carPlate = ardSyCarVoList.get(i).getCarPlate(); |
| | | if(!carPlate.contains(ardSyCarParam.getCarPlate())){ |
| | | newList.add(ardSyCarVoList.get(i)); |
| | | } |
| | | } |
| | | ardSyCarVoList.removeAll(newList); |
| | | } |
| | | return AjaxResult.success(new PageInfo<>(ardSyCarVoList)); |
| | | }else { |
| | | return AjaxResult.error("31平台连接失败,车牌号获取失败!",new PageInfo<>(ardSyCars)); |
| | | } |
| | | } |
| | | |
| | | /** |
| | |
| | | * @return |
| | | */ |
| | | @Override |
| | | public Map<String, Object> allListByUser(ArdSyUser ardSyUser, String syURL, String usersId) { |
| | | public Map<String, Object> allListByUser(ArdSyUser ardSyUser, String syURL, String usersId, List<Long> deptList) { |
| | | Map<String, Object> result0 = new HashMap(); |
| | | //判断关联表是否有数据 |
| | | if (ardSyUser != null) { |
| | |
| | | map.put("list", new ArrayList()); |
| | | return map; |
| | | } |
| | | QueryWrapper<ArdSyCar> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.in("dept_id", deptList); |
| | | List<ArdSyCar> carListTable = ardSyCarMapper.selectList(queryWrapper); |
| | | int online = 0; |
| | | for (Map<String, Object> map : (List<Map<String, Object>>) result0.get("list")) { |
| | | Map<String, Object> resultMap = sYClient.getTeamCarList(syURL, (String) map.get("teamId"), result.get("sessionId")); |
| | | List<Map<String, Object>> carList = (List<Map<String, Object>>) resultMap.get("carList"); |
| | | if(carList.size()>0){ |
| | | for (int i = 0; i < carList.size(); i++) { |
| | | String carId = (String) carList.get(i).get("carId"); |
| | | Boolean isCar = false; |
| | | for (int j = 0; j < carListTable.size(); j++) { |
| | | ArdSyCar ardSyCar = carListTable.get(j); |
| | | if (carId.equals(ardSyCar.getCarId())) { |
| | | isCar = true; |
| | | break; |
| | | } |
| | | } |
| | | if(!isCar){ |
| | | carList.remove(carList.get(i)); |
| | | } |
| | | } |
| | | } |
| | | for (Map<String, Object> m : carList) { |
| | | if (((String) m.get("stateCn")).contains("在线")) { |
| | | online = online + 1; |
| | |
| | | continue; |
| | | } |
| | | } |
| | | for (Map<String, Object> m : (List<Map<String, Object>>) result0.get("list")) { |
| | | if (((String) m.get("teamId")).equals(((String) map.get("teamId")))) { |
| | | map.put("count", Integer.parseInt((String) m.get("carNum"))); |
| | | } |
| | | } |
| | | // for (Map<String, Object> m : (List<Map<String, Object>>) result0.get("list")) { |
| | | // if (((String) m.get("teamId")).equals(((String) map.get("teamId")))) { |
| | | // map.put("count", Integer.parseInt((String) m.get("carNum"))); |
| | | // } |
| | | // } |
| | | map.put("count", carList.size()); |
| | | map.put("online", online); |
| | | online = 0; |
| | | } |
| | |
| | | queryWrapper.in("dept_id", deptList); |
| | | List<ArdSyCar> carList = ardSyCarMapper.selectList(queryWrapper); |
| | | //对比把匹配到的数据添加到list中 |
| | | for (Map<String, String> m : list) { |
| | | String carId = m.get("carId"); |
| | | for (int i = 0; i < carList.size(); i++) { |
| | | ArdSyCar ardSyCar = carList.get(i); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | String carId = list.get(i).get("carId"); |
| | | Boolean isCar = false; |
| | | for (int j = 0; j < carList.size(); j++) { |
| | | ArdSyCar ardSyCar = carList.get(j); |
| | | if (carId.equals(ardSyCar.getCarId())) { |
| | | /*String url = ""; |
| | | if (ardSyCar.getCarPicture() != null) { |
| | |
| | | url = ardSyCar.getCarPicture().split("sycar")[0]; |
| | | } |
| | | }*/ |
| | | m.put("carModel", this.minioEndpoint + "/" + ardSyCar.getCarModel());//zns |
| | | list.get(i).put("carModel", this.minioEndpoint + "/" + ardSyCar.getCarModel());//zns |
| | | //m.put("carModel",ardSyCar.getCarModel()); |
| | | m.put("carTypeArd", ardSyCar.getCarType()); |
| | | m.put("carBrand", ardSyCar.getCarBrand()); |
| | | m.put("carPicture", ardSyCar.getCarPicture()); |
| | | list.get(i).put("carTypeArd", ardSyCar.getCarType()); |
| | | list.get(i).put("carBrand", ardSyCar.getCarBrand()); |
| | | list.get(i).put("carPicture", ardSyCar.getCarPicture()); |
| | | isCar = true; |
| | | break; |
| | | } |
| | | } |
| | | if(!isCar){ |
| | | list.remove(list.get(i)); |
| | | } |
| | | } |
| | | return list; |
| | |
| | | |
| | | @Override |
| | | public Map<String, Object> getCarGPSBycarId(String usersId, String carId, String syURL, ArdSyUser ardSyUser) { |
| | | Map<String, String> result = logInMap.get(Integer.parseInt(usersId)); |
| | | // Map<String, String> result = logInMap.get(Integer.parseInt(usersId)); |
| | | //31用户名密码 |
| | | String username31 = ardSyUser.getUserId(); |
| | | String password31 = ardSyUser.getPassword(); |
| | | String passwordMd5 = DigestUtils.md5Hex(password31); |
| | | Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31); |
| | | result = new HashMap(); |
| | | Map<String, String> result = new HashMap(); |
| | | result.put("userId", username31); |
| | | result.put("sessionId", (String) result1.get("sessionId")); |
| | | return sYClient.getCarNearPositionByCarId(syURL, carId, result.get("userId"), result.get("sessionId")); |