修改bug

puzhibing

2026-01-31 65fc0825721e217743177b7febb0570a4a162a95

修改bug

 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/TAppCouponController.java

@@ -2,6 +2,7 @@


import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.account.api.dto.CouponListDto;
import com.ruoyi.account.api.dto.GrantCouponDto;
@@ -101,6 +102,11 @@
    @PostMapping(value = "/scan/addCar")
    public AjaxResult addCar(@RequestBody TAppUserCar dto) {
        dto.setAppUserId(tokenService.getLoginUserApplet().getUserId());
        TAppUserCar one = appUserCarService.getOne(new LambdaQueryWrapper<TAppUserCar>().eq(TAppUserCar::getLicensePlate, dto.getLicensePlate())
                .eq(TAppUserCar::getDelFlag, 0));
        if(null != one){
            return AjaxResult.warn("车辆已存在");
        }
        appUserCarService.save(dto);
        return AjaxResult.success();
    }

 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/TAppUserCarController.java

@@ -69,5 +69,26 @@
        return R.ok(collect);
    }


    /**
     * 手动删除重复数据
     * @return
     */
    @PostMapping(value = "/t-app-user-car/delRepetitiveVehicles")
    public R delRepetitiveVehicles(){
        List<String> list = appUserCarService.queryRepetitiveVehicles();
        for (String s : list) {
            List<TAppUserCar> list1 = appUserCarService.list(new LambdaQueryWrapper<TAppUserCar>().eq(TAppUserCar::getLicensePlate, s)
                    .eq(TAppUserCar::getDelFlag, 0).orderByDesc(TAppUserCar::getCreateTime));
            for (int i = 0; i < list1.size(); i++) {
                if(i == list1.size() - 1){
                    break;
                }
                appUserCarService.removeById(list1.get(i).getId());
            }
        }
        return R.ok();
    }

}


 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/mapper/TAppUserCarMapper.java

@@ -3,6 +3,8 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ruoyi.account.api.model.TAppUserCar;

import java.util.List;

/**
 * <p>
 *  Mapper 接口
@@ -13,4 +15,6 @@
 */
public interface TAppUserCarMapper extends BaseMapper<TAppUserCar> {

    List<String> queryRepetitiveVehicles();

}

 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/TAppUserCarService.java

@@ -3,6 +3,8 @@
import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.account.api.model.TAppUserCar;

import java.util.List;

/**
 * <p>
 *  服务类
@@ -13,4 +15,7 @@
 */
public interface TAppUserCarService extends IService<TAppUserCar> {


    List<String> queryRepetitiveVehicles();

}

 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/TAppUserCarServiceImpl.java

@@ -6,6 +6,9 @@
import com.ruoyi.account.service.TAppUserCarService;
import org.springframework.stereotype.Service;

import java.util.Collections;
import java.util.List;

/**
 * <p>
 *  服务实现类
@@ -17,4 +20,9 @@
@Service
public class TAppUserCarServiceImpl extends ServiceImpl<TAppUserCarMapper, TAppUserCar> implements TAppUserCarService {


    @Override
    public List<String> queryRepetitiveVehicles() {
        return this.baseMapper.queryRepetitiveVehicles();
    }
}

 ruoyi-service/ruoyi-account/src/main/resources/mapper/account/TAppUserCarMapper.xml

@@ -20,4 +20,8 @@
        id, app_user_id, license_plate, vehicle_brand, vehicle_model, vehicle_use, endurance, create_time, del_flag
    </sql>


    <select id="queryRepetitiveVehicles" resultType="String">
        select license_plate from (select license_plate, count(license_plate) as num from t_app_user_car where del_flag = 0 group by license_plate) as aa where aa.num > 1
    </select>
</mapper>

 ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/mqtt/util/MqttPushUtil.java

@@ -82,18 +82,18 @@
            mqttClient.setCallback(new MqttCallback() {
                @Override
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost, reconnecting...");
                    log.info("Connection lost, reconnecting...");
                    reconnect();
                }

                @Override
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Message arrived: " + new String(message.getPayload()));
                    log.info("Message arrived: " + new String(message.getPayload()));
                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken token) {
                    System.out.println("Delivery complete");
                    log.info("Delivery complete");
                }
            });
            mqttClient.connect(options);
@@ -153,9 +153,9 @@
                // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制
                options.setKeepAliveInterval(KEEP_ALIVE);//默认：60
                mqttClient.connect(options);
                System.out.println("重连成功");
                log.info("重连成功");
            } catch (MqttException e) {
                System.out.println("重连失败");
                log.info("重连失败");
                log.info("connectionLost e:{}", e.getMessage());
                e.printStackTrace();
            }
@@ -179,7 +179,7 @@
        message.setPayload(message1.getBytes());
        MqttTopic mTopic = mqttClient.getTopic(topic);
        if (null == mTopic) {
            System.err.println("topic not exist");
            log.info("topic not exist");
            log.error("topic not exist");
        }
        MqttDeliveryToken token;

 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java

@@ -3371,7 +3371,8 @@
    public TChargingOrder getChargingOrderByLicensePlate(GetChargingOrderByLicensePlate query) {
        TChargingOrder one = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getPlateNum, query.getLicensePlate())
                .eq(TChargingOrder::getDelFlag, 0).between(TChargingOrder::getStartTime, query.getStartTime(), LocalDateTime.now())
                .eq(TChargingOrder::getRechargePaymentStatus, 2).in(TChargingOrder::getStatus, Arrays.asList(4, 5)));
                .eq(TChargingOrder::getRechargePaymentStatus, 2).in(TChargingOrder::getStatus, Arrays.asList(4, 5))
                .last(" order by start_time desc limit 0, 1"));
        return one;
    }