diff --git a/fastbee-open-api/src/main/java/com/fastbee/data/controller/DeviceController.java b/fastbee-open-api/src/main/java/com/fastbee/data/controller/DeviceController.java index 4d60e54..65f9eba 100644 --- a/fastbee-open-api/src/main/java/com/fastbee/data/controller/DeviceController.java +++ b/fastbee-open-api/src/main/java/com/fastbee/data/controller/DeviceController.java @@ -166,19 +166,19 @@ public class DeviceController extends BaseController { public AjaxResult getInfo(@PathVariable("deviceId") Long deviceId) { Device device = deviceService.selectDeviceByDeviceId(deviceId); // 判断当前用户是否有设备分享权限 (设备所属机构管理员和设备所属用户有权限) - LoginUser loginUser = getLoginUser(); - List roles = loginUser.getUser().getRoles(); - //判断当前用户是否为设备所属机构管理员 - if (roles.stream().anyMatch(a -> "admin".equals(a.getRoleKey()))) { - device.setIsOwner(1); - } else { - //判断当前用户是否是设备所属用户 - if (Objects.equals(device.getTenantId(), loginUser.getUserId())) { - device.setIsOwner(1); - } else { - device.setIsOwner(0); - } - } +// LoginUser loginUser = getLoginUser(); +// List roles = loginUser.getUser().getRoles(); +// //判断当前用户是否为设备所属机构管理员 +// if (roles.stream().anyMatch(a -> "admin".equals(a.getRoleKey()))) { +// device.setIsOwner(1); +// } else { +// //判断当前用户是否是设备所属用户 +// if (Objects.equals(device.getTenantId(), loginUser.getUserId())) { +// device.setIsOwner(1); +// } else { +// device.setIsOwner(0); +// } +// } return AjaxResult.success(device); } diff --git a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaGuangaiRecordServiceImpl.java b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaGuangaiRecordServiceImpl.java index a9d7590..a133249 100644 --- a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaGuangaiRecordServiceImpl.java +++ b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaGuangaiRecordServiceImpl.java @@ -5,6 +5,7 @@ import java.util.Collection; import java.util.Date; import java.util.List; +import cn.hutool.core.util.NumberUtil; import cn.hutool.http.HttpUtil; import cn.hutool.json.JSON; import cn.hutool.json.JSONArray; @@ -96,16 +97,22 @@ public class MaGuangaiRecordServiceImpl implements IMaGuangaiRecordService MaGuangaiRecord record = new MaGuangaiRecord(); record.setDevSn(item.get("dev_sn").toString()); if(StringUtils.isNotEmpty(item.get("start_time").toString())){ - Date date = new Date(Long.parseLong(item.get("start_time").toString())*1000); - record.setStartTime(date); + if(NumberUtil.isNumber(item.get("start_time").toString())) { + Date date = new Date(Long.parseLong(item.get("start_time").toString()) * 1000); + record.setStartTime(date); + } } if(StringUtils.isNotEmpty(item.get("end_time").toString())){ - Date date = new Date(Long.parseLong(item.get("end_time").toString())*1000); - record.setEndTime(date); + if(NumberUtil.isNumber(item.get("end_time").toString())){ + Date date = new Date(Long.parseLong(item.get("end_time").toString())*1000); + record.setEndTime(date); + } } if(StringUtils.isNotEmpty(item.get("last_time").toString())){ - Date date = new Date(Long.parseLong(item.get("last_time").toString())*1000); - record.setLastTime(date); + if(NumberUtil.isNumber(item.get("last_time").toString())) { + Date date = new Date(Long.parseLong(item.get("last_time").toString()) * 1000); + record.setLastTime(date); + } } record.setCurEle(item.get("cur_ele").toString()); record.setCardId(item.get("card_id").toString()); @@ -115,8 +122,10 @@ public class MaGuangaiRecordServiceImpl implements IMaGuangaiRecordService record.setCurEle(item.get("cur_ele").toString()); record.setStatus(Integer.parseInt(item.get("status").toString())); if(StringUtils.isNotEmpty(item.get("create_time").toString())){ - Date date = new Date(Long.parseLong(item.get("create_time").toString())*1000); - record.setCreateTime(date); + if(NumberUtil.isNumber(item.get("create_time").toString())) { + Date date = new Date(Long.parseLong(item.get("create_time").toString()) * 1000); + record.setCreateTime(date); + } } list.add(record); } diff --git a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaRechargerecordServiceImpl.java b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaRechargerecordServiceImpl.java index bc787a0..2c751b2 100644 --- a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaRechargerecordServiceImpl.java +++ b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaRechargerecordServiceImpl.java @@ -3,6 +3,8 @@ package com.fastbee.waterele.service.impl; import java.util.Date; import java.util.List; +import cn.hutool.http.HttpUtil; +import cn.hutool.json.JSONObject; import com.fastbee.common.utils.DateUtils; import com.fastbee.common.utils.StringUtils; import com.fastbee.waterele.domain.vo.UnchargeAmountVo; @@ -54,7 +56,18 @@ public class MaRechargerecordServiceImpl implements IMaRechargerecordService { @Override public int insertMaRechargerecord(MaRechargerecord maRechargerecord) { maRechargerecord.setCreateTime(DateUtils.getNowDate()); - return maRechargerecordMapper.insertMaRechargerecord(maRechargerecord); +// https://zhwly.sdhzwl.cn/api/java/xinjiangup/recharge?cardNum=1&areaCode=123&jine=20 + String url = "https://zhwly.sdhzwl.cn/api/java/xinjiangup/recharge?cardNum=" + + maRechargerecord.getCardNum()+"&areaCode="+maRechargerecord.getAreaCode()+"&jine="+maRechargerecord.getInvestval(); + String result = HttpUtil.get(url); + JSONObject jsonObject = new JSONObject(result); + if(jsonObject != null){ + if(jsonObject.containsKey("code") && Integer.parseInt(jsonObject.get("code").toString()) == 200){ + return maRechargerecordMapper.insertMaRechargerecord(maRechargerecord); + } + } + return 0; + } /** diff --git a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java index 9a372a0..137d85b 100644 --- a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java +++ b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java @@ -2,6 +2,7 @@ package com.fastbee.waterele.service.impl; import java.util.*; +import cn.hutool.core.util.NumberUtil; import cn.hutool.http.HttpUtil; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; @@ -107,12 +108,16 @@ public class MaWatereleRecordServiceImpl implements IMaWatereleRecordService record.setAreacode(item.get("areaCode").toString()); record.setAction(item.get("action").toString()); if(StringUtils.isNotEmpty(item.get("create_time").toString())){ - Date date = new Date(Long.parseLong(item.get("create_time").toString())*1000); - record.setCreateTime(date); + if(NumberUtil.isNumber(item.get("create_time").toString())) { + Date date = new Date(Long.parseLong(item.get("create_time").toString()) * 1000); + record.setCreateTime(date); + } } if(StringUtils.isNotEmpty(item.get("update_time").toString())){ - Date date = new Date(Long.parseLong(item.get("update_time").toString())*1000); - record.setUpdateTime(date); + if(NumberUtil.isNumber(item.get("update_time").toString())) { + Date date = new Date(Long.parseLong(item.get("update_time").toString()) * 1000); + record.setUpdateTime(date); + } } list.add(record); }