代码检查

This commit is contained in:
attiya 2025-05-22 09:29:21 +08:00
parent a58697c75a
commit ae1fac7951
14 changed files with 15 additions and 23 deletions

View File

@ -136,8 +136,6 @@ public class CustomCipherTextFilter implements GlobalFilter, Ordered {
// log.error("密文过滤器加解密错误", e); // log.error("密文过滤器加解密错误", e);
// return Mono.empty(); // return Mono.empty();
return chain.filter(exchange); return chain.filter(exchange);
} finally {
} }
} }
} }

View File

@ -33,13 +33,13 @@ public class MqttConfig {
// 连接池参数 // 连接池参数
@Getter @Getter
private static int poolMaxTotal = 20; private static final int poolMaxTotal = 20;
@Getter @Getter
private static int poolMaxIdle = 10; private static final int poolMaxIdle = 10;
@Getter @Getter
private static int poolMinIdle = 5; private static final int poolMinIdle = 5;
@Value("${mqtt.host}") @Value("${mqtt.host}")
public void setHost(String host) { public void setHost(String host) {

View File

@ -21,11 +21,7 @@ public class EbikeUsersSever {
queryWrapper.eq("phone", username); queryWrapper.eq("phone", username);
// queryWrapper.eq("password", password); // queryWrapper.eq("password", password);
long l = ebikeUsersMapper.selectCountByQuery(queryWrapper); long l = ebikeUsersMapper.selectCountByQuery(queryWrapper);
if (l > 0) { return l > 0;
return true;
} else{
return false;
}
} }
public EbikeUsers getUserInfo (String username, String password){ public EbikeUsers getUserInfo (String username, String password){

View File

@ -22,7 +22,7 @@ public class ReqEbikeComponentEnterRecordsDto {
private String region; private String region;
/** /**
* 部件类型 * 部件类型
*/; */
private String componentType; private String componentType;
/** /**
* 状态 * 状态

View File

@ -22,7 +22,7 @@ public class ReqEbikeComponentOutRecordsDto {
private String region; private String region;
/** /**
* 部件类型 * 部件类型
*/; */
private String componentType; private String componentType;
/** /**

View File

@ -22,7 +22,7 @@ public class ReqEbikeComponentProductionDto {
private String region; private String region;
/** /**
* 部件类型 * 部件类型
*/; */
private String componentType; private String componentType;
/** /**
* 供应商 * 供应商

View File

@ -400,7 +400,7 @@ public class RedisUtil {
* @param areaId areaId * @param areaId areaId
*/ */
public String getPolygonFromWKT(Long suffixId,String areaId,String key) { public String getPolygonFromWKT(Long suffixId,String areaId,String key) {
return "POLYGON ((" + (String)redisTemplate.opsForHash().get(key + suffixId, "vertices"+areaId)+"))"; return "POLYGON ((" + redisTemplate.opsForHash().get(key + suffixId, "vertices"+areaId) +"))";
} }
/** /**

View File

@ -407,7 +407,7 @@ public class RedisUtil {
* @param areaId areaId * @param areaId areaId
*/ */
public String getPolygonFromWKT(Long orgId, String areaId, String key) { public String getPolygonFromWKT(Long orgId, String areaId, String key) {
return "POLYGON ((" + (String) redisTemplate.opsForHash().get(key + orgId, "vertices" + areaId) + "))"; return "POLYGON ((" + redisTemplate.opsForHash().get(key + orgId, "vertices" + areaId) + "))";
} }
/** /**
@ -417,7 +417,7 @@ public class RedisUtil {
* @param areaId areaId * @param areaId areaId
*/ */
public String getPolygonFromWKT(String areaId, String key) { public String getPolygonFromWKT(String areaId, String key) {
return "POLYGON ((" + (String) redisTemplate.opsForHash().get(key, "vertices" + areaId) + "))"; return "POLYGON ((" + redisTemplate.opsForHash().get(key, "vertices" + areaId) + "))";
} }
/** /**

View File

@ -80,7 +80,6 @@ public class ResApplyRefundDto {
* 骑行设备编号 * 骑行设备编号
*/ */
private String ebikeCode; private String ebikeCode;
;
/** /**
* 骑行开始时间 * 骑行开始时间

View File

@ -89,7 +89,7 @@ public class ResCloseRefundDto {
/** /**
* 骑行设备编号 * 骑行设备编号
*/ */
private String ebikeCode;; private String ebikeCode;
/** /**
* 骑行开始时间 * 骑行开始时间

View File

@ -84,7 +84,7 @@ public class ResHandleRefundDto {
/** /**
* 骑行设备编号 * 骑行设备编号
*/ */
private String ebikeCode;; private String ebikeCode;
/** /**
* 骑行开始时间 * 骑行开始时间

View File

@ -110,7 +110,6 @@ public class ResProcessedRefundDto {
* 骑行设备编号 * 骑行设备编号
*/ */
private String ebikeCode; private String ebikeCode;
;
/** /**
* 骑行开始时间 * 骑行开始时间

View File

@ -36,7 +36,7 @@ public class EbikePaymentServiceImpl extends ServiceImpl<EbikePaymentMapper, Ebi
public List<EbikePayment> getNoPayOrderByDuration(int duration) { public List<EbikePayment> getNoPayOrderByDuration(int duration) {
// trade_state 等于 NOTPAY未支付的 并且创建时间未超过duration分钟的订单 // trade_state 等于 NOTPAY未支付的 并且创建时间未超过duration分钟的订单
String timeFilter = String.format("%s(%s, %s(%s))<%s()", ADDTIME, EBIKE_PAYMENT.CREATE_TIME.getName(), SEC_TO_TIME String timeFilter = String.format("%s(%s, %s(%s))<%s()", ADDTIME, EBIKE_PAYMENT.CREATE_TIME.getName(), SEC_TO_TIME
, String.valueOf(duration * 60), NOW); , duration * 60, NOW);
QueryWrapper query = QueryWrapper.create() QueryWrapper query = QueryWrapper.create()
.where(EBIKE_PAYMENT.TRADE_STATE.eq(Transaction.TradeStateEnum.NOTPAY.ordinal())) .where(EBIKE_PAYMENT.TRADE_STATE.eq(Transaction.TradeStateEnum.NOTPAY.ordinal()))
.and(timeFilter); .and(timeFilter);
@ -47,7 +47,7 @@ public class EbikePaymentServiceImpl extends ServiceImpl<EbikePaymentMapper, Ebi
public List<EbikePayment> getExpireOrderByDuration(int duration) { public List<EbikePayment> getExpireOrderByDuration(int duration) {
// trade_state 等于 NOTPAY未支付的 并且创建时间超过duration分钟的订单 // trade_state 等于 NOTPAY未支付的 并且创建时间超过duration分钟的订单
String timeFilter = String.format("%s(%s, %s(%s))>=%s()", ADDTIME, EBIKE_PAYMENT.CREATE_TIME.getName(), SEC_TO_TIME String timeFilter = String.format("%s(%s, %s(%s))>=%s()", ADDTIME, EBIKE_PAYMENT.CREATE_TIME.getName(), SEC_TO_TIME
, String.valueOf(duration * 60), NOW); , duration * 60, NOW);
QueryWrapper query = QueryWrapper.create() QueryWrapper query = QueryWrapper.create()
.where(EBIKE_PAYMENT.TRADE_STATE.eq(Transaction.TradeStateEnum.NOTPAY.ordinal())) .where(EBIKE_PAYMENT.TRADE_STATE.eq(Transaction.TradeStateEnum.NOTPAY.ordinal()))
.and(timeFilter); .and(timeFilter);

View File

@ -50,7 +50,7 @@ public class EbikeRefundServiceImpl extends ServiceImpl<EbikeRefundMapper, Ebike
public List<EbikeRefund> getNoSuccessRefundOrderByDuration(int duration) { public List<EbikeRefund> getNoSuccessRefundOrderByDuration(int duration) {
// trade_state 等于 PROCESSING正在退款中的 并且创建时间超过duration分钟的订单 // trade_state 等于 PROCESSING正在退款中的 并且创建时间超过duration分钟的订单
String timeFilter = String.format("%s(%s, %s(%s))>=%s()", ADDTIME, EBIKE_REFUND.CREATE_TIME.getName(), SEC_TO_TIME String timeFilter = String.format("%s(%s, %s(%s))>=%s()", ADDTIME, EBIKE_REFUND.CREATE_TIME.getName(), SEC_TO_TIME
, String.valueOf(duration * 60), NOW); , duration * 60, NOW);
QueryWrapper query = QueryWrapper.create() QueryWrapper query = QueryWrapper.create()
.where(EBIKE_REFUND.STATUS.eq(Status.PROCESSING.ordinal())) .where(EBIKE_REFUND.STATUS.eq(Status.PROCESSING.ordinal()))
.and(timeFilter); .and(timeFilter);