This commit is contained in:
邱贞招 2024-12-10 21:47:44 +08:00
parent 9ceda280a6
commit 33b7e15b09
2 changed files with 15 additions and 14 deletions

View File

@ -49,6 +49,7 @@ import java.util.List;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import static com.ruoyi.common.constant.HttpStatus.ERROR_CODE_DEVICE_ALREADY_EXISTS_MSG;
import static com.ruoyi.common.utils.SecurityUtils.getUsername; import static com.ruoyi.common.utils.SecurityUtils.getUsername;
/** /**
@ -2824,6 +2825,7 @@ public class AsDeviceServiceImpl extends ServiceImpl<AsDeviceMapper, AsDevice> i
if(StringUtils.isNotNull(device)){ if(StringUtils.isNotNull(device)){
throw new ServiceException("该MAC号已经存在"); throw new ServiceException("该MAC号已经存在");
}else{ }else{
try{
// 调用onenet接口 // 调用onenet接口
CreateDeviceVo createDeviceVo = new CreateDeviceVo(); CreateDeviceVo createDeviceVo = new CreateDeviceVo();
createDeviceVo.setDevice_name(asDevice.getMac()); createDeviceVo.setDevice_name(asDevice.getMac());
@ -2833,11 +2835,10 @@ public class AsDeviceServiceImpl extends ServiceImpl<AsDeviceMapper, AsDevice> i
JSONObject paramsObj = JSON.parseObject(result); JSONObject paramsObj = JSON.parseObject(result);
String code = paramsObj.getString("code"); String code = paramsObj.getString("code");
//记录命令 //记录命令
if (!HttpStatus.IOT_SUCCESS.equals(code)) if (!HttpStatus.IOT_SUCCESS.equals(code) && !ERROR_CODE_DEVICE_ALREADY_EXISTS_MSG.equals(code))
{ {
throw new ServiceException(code+"-----"+ paramsObj.getString("msg")); throw new ServiceException(code+"-----"+ paramsObj.getString("msg"));
} }
try{
int insert = asDeviceMapper.insert(asDevice); int insert = asDeviceMapper.insert(asDevice);
if(insert==0){ if(insert==0){
throw new ServiceException("该SN已经存在请勿重复绑定"); throw new ServiceException("该SN已经存在请勿重复绑定");

View File

@ -173,7 +173,7 @@ public class WxPayService implements IWxPayService {
if(StrUtil.isNotBlank(order.getOutTradeNo())){ if(StrUtil.isNotBlank(order.getOutTradeNo())){
// 关闭订单 // 关闭订单
tmPayService.closeOrder(channelVO,order.getOutTradeNo()); TmPayService.closeOrder(channelVO,order.getOutTradeNo());
} }
Payable payable = new Payable(); Payable payable = new Payable();
payable.setAmount(order.getPayFee().multiply(new BigDecimal(100)).longValue()); payable.setAmount(order.getPayFee().multiply(new BigDecimal(100)).longValue());