ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/TAppUserController.java
@@ -1120,9 +1120,8 @@ if (count==0){ R<TIntegralRule> set = integralRuleClient.getSet(); TIntegralRule data = set.getData(); if(null != data){ JSONObject jsonObject = JSON.parseObject(data.getAddVehiclesEarnsPoints()); Integer point = 0; //增加车牌50分,必填 point = point+jsonObject.getInteger("num1"); @@ -1154,9 +1153,8 @@ //增加积分记录 pointDetailUtil.addDetail(byId.getPoints(),byId.getPoints()+point,5,userId,appUserCar.getLicensePlate(),"",""); byId.setPoints(byId.getPoints()+point); } byId.setFirstAdd(1); } CarNumDto carNumDto = CarUtil.carNum(appUserCar.getLicensePlate()); if (carNumDto==null){ ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java
@@ -263,6 +263,8 @@ return AjaxResult.error("设备编号已存在"); } TChargingPile tChargingPile = this.getById(chargingPile.getId()); //桩号不相同,需要重新绑定设备 if(!tChargingPile.getCode().equals(chargingPile.getCode())){ ShowDeviceResp showDeviceResp = iotInterfaceClient.showDeviceRequest(tChargingPile.getCode()).getData(); if(null != showDeviceResp){ DeleteDeviceResp deleteDeviceResp = iotInterfaceClient.deleteDevice(tChargingPile.getCode()).getData(); @@ -270,8 +272,6 @@ return AjaxResult.error("删除设备异常,请查看华为设备管理"); } } //调用华为Iot创建设备 AddDevice addDevice = new AddDevice(); addDevice.setProductId("66da68d21837002b28b34ec0"); @@ -290,6 +290,7 @@ }else{ return AjaxResult.error("华为创建设备失败"); } } this.updateById(chargingPile); List<TChargingGun> list = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>().eq(TChargingGun::getChargingPileId, chargingPile.getId()).eq(TChargingGun::getDelFlag, 0)); ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java
@@ -99,8 +99,7 @@ pong.setCharging_pile_code(pingMessage.getCharging_pile_code()); pong.setCharging_gun_code(pingMessage.getCharging_gun_code()); pong.setCharging_gun_status(0); result = iotMessageProduce.sendMessage(pong.getCharging_pile_code(), ServiceIdMenu.PONG.getKey(), messageUtil.pong(pong)); log.info("充电桩心跳包-返回结果:{}",result); iotMessageProduce.sendMessage(pong.getCharging_pile_code(), ServiceIdMenu.PONG.getKey(), messageUtil.pong(pong)); sendResult = enhanceProduce.chargingMessage(chargingMessage); break; case SendTagConstant.END_CHARGE: ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java
@@ -1,5 +1,6 @@ package com.ruoyi.integration.iotda.utils.produce; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson2.JSONObject; import com.huaweicloud.sdk.core.exception.ConnectionException; import com.huaweicloud.sdk.core.exception.RequestTimeoutException; @@ -41,8 +42,6 @@ public String sendMessage(String code, String name, JSONObject message){ log.info("消息下发至设备:code={},name={},message={}", code, name, message); CreateMessageRequest request = new CreateMessageRequest(); System.err.println(code); System.err.println(JSONObject.toJSONString(config)); request.withDeviceId(code); DeviceMessageRequest body = new DeviceMessageRequest(); body.withMessageId(UUID.randomUUID().toString()); @@ -51,19 +50,14 @@ request.withBody(body); try { CreateMessageResponse response = iotBuilder.buildIot().createMessage(request); System.out.println(response.toString()); } catch (ConnectionException e) { log.info("消息下发至设备结果:{}", JSON.toJSONString(response)); return JSON.toJSONString(response); } catch (Exception e) { e.printStackTrace(); } catch (RequestTimeoutException e) { e.printStackTrace(); } catch (ServiceResponseException e) { e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId()); System.out.println(e.getErrorCode()); System.out.println(e.getErrorMsg()); log.info("消息下发至设备异常:code---{},msg---{}", code, e.getMessage()); log.error("消息下发至设备异常:code---{},msg---{}", code, e.getMessage()); return e.getMessage(); } return null; } } ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TOrderEvaluateServiceImpl.java
@@ -291,25 +291,6 @@ siteIds = data; } } }else{ siteIds.add(pageList.getSiteId()); } if (siteIds.isEmpty()){ siteIds.add(-1); }else{ List<Integer> integers = new ArrayList<>(); for (Integer siteId : siteIds) { // 校验有没有这个站点的权限 List<Boolean> t1= partnerClient.chargeEvaluation(sysUser.getObjectId(),siteId).getData(); Boolean b = t1.get(0); if (b){ integers.add(siteId); } } siteIds = integers; } if (siteIds.isEmpty()){ siteIds.add(-1); } List<GetOrderEvaluatePageListDTO> list = this.baseMapper.getPageList(pageList, evaluationTagIds, siteIds, pageInfo); for (GetOrderEvaluatePageListDTO dto : list) { ruoyi-service/ruoyi-order/src/main/resources/mapper/order/TOrderEvaluateMapper.xml
@@ -114,7 +114,7 @@ <if test="null != query.content and '' != query.content"> and a.content like CONCAT('%', #{query.content}, '%') </if> <if test="null != query.evaluateType"> <if test="null != evaluationTagIds and evaluationTagIds.size() > 0"> and a.id in (select order_evaluate_id from t_order_evaluate_tag where evaluation_tag_id in <foreach collection="evaluationTagIds" item="item" index="index" open="(" separator="," close=")"> #{item} ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/TIntegralRuleController.java
@@ -140,6 +140,27 @@ } @GetMapping("/getInfo1") @ApiOperation(tags = {"小程序-积分管理"},value = "type 1=积分规则说明," + "2=会员折扣说明," + "3=优惠券说明," + "4=双倍积分说明," + "5=商城专享价说明," + "6=会员协议," + "7=用户协议," + "8=隐私协议," + "9=邀请好友说明," + "10=资质证明," + "11=开票说明") public R<String> getInfo1(Integer type) { THtml g = htmlService.getOne(new QueryWrapper<THtml>().eq("type",type)); if (g == null){ return R.ok(""); } return R.ok(g.getContent()); } @RequiresPermissions(value = {"/vipSetting/html"}, logical = Logical.OR) @PostMapping("/saveInfo")