阿里巴巴代码规范检测整改

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/constant/MQSendTypeEnum.java

@@ -16,14 +16,14 @@
 package com.jeequan.jeepay.components.mq.constant;
 
 /**
-* 定义MQ消息类型：
-* QUEUE - 点对点 （只有1个消费者可消费。 ActiveMQ的queue模式 ）
-* BROADCAST - 订阅模式 (所有接收者都可接收到。 ActiveMQ的topic模式, RabbitMQ的fanout类型的交换机, RocketMQ的广播模式  )
-*
+* 定义MQ消息类型
 * @author terrfly
 * @site https://www.jeepay.vip
 * @date 2021/7/23 16:49
 */
 public enum MQSendTypeEnum {
-    QUEUE, BROADCAST
+    /** QUEUE - 点对点 （只有1个消费者可消费。 ActiveMQ的queue模式 ） **/
+    QUEUE,
+    /** BROADCAST - 订阅模式 (所有接收者都可接收到。 ActiveMQ的topic模式, RabbitMQ的fanout类型的交换机, RocketMQ的广播模式  ) **/
+    BROADCAST
 }

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/activemq/receive/CleanMchLoginAuthCacheActiveMQReceiver.java

@@ -43,6 +43,7 @@ public class CleanMchLoginAuthCacheActiveMQReceiver implements IMQMsgReceiver {
     private CleanMchLoginAuthCacheMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     @Async(MqThreadExecutor.EXECUTOR_PAYORDER_MCH_NOTIFY)
     @JmsListener(destination = CleanMchLoginAuthCacheMQ.MQ_NAME)
     public void receiveMsg(String msg){

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/activemq/receive/PayOrderMchNotifyActiveMQReceiver.java

@@ -43,6 +43,7 @@ public class PayOrderMchNotifyActiveMQReceiver implements IMQMsgReceiver {
     private PayOrderMchNotifyMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     @Async(MqThreadExecutor.EXECUTOR_PAYORDER_MCH_NOTIFY)
     @JmsListener(destination = PayOrderMchNotifyMQ.MQ_NAME)
     public void receiveMsg(String msg){

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/activemq/receive/PayOrderReissueActiveMQReceiver.java

@@ -43,6 +43,7 @@ public class PayOrderReissueActiveMQReceiver implements IMQMsgReceiver {
     private PayOrderReissueMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     @Async(MqThreadExecutor.EXECUTOR_PAYORDER_MCH_NOTIFY)
     @JmsListener(destination = PayOrderReissueMQ.MQ_NAME)
     public void receiveMsg(String msg){

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/activemq/receive/ResetAppConfigActiveMQReceiver.java

@@ -42,6 +42,7 @@ public class ResetAppConfigActiveMQReceiver implements IMQMsgReceiver {
     private ResetAppConfigMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 MQSendTypeEnum.BROADCAST  】 广播类型的消息 **/
+    @Override
     @JmsListener(destination = ResetAppConfigMQ.MQ_NAME, containerFactory = ActiveMQConfig.TOPIC_LISTENER_CONTAINER)
     public void receiveMsg(String msg){
         mqReceiver.receive(ResetAppConfigMQ.parse(msg));

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/activemq/receive/ResetIsvMchAppInfoActiveMQReceiver.java

@@ -42,6 +42,7 @@ public class ResetIsvMchAppInfoActiveMQReceiver implements IMQMsgReceiver {
     private ResetIsvMchAppInfoConfigMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 MQSendTypeEnum.BROADCAST  】 广播类型的消息 **/
+    @Override
     @JmsListener(destination = ResetIsvMchAppInfoConfigMQ.MQ_NAME, containerFactory = ActiveMQConfig.TOPIC_LISTENER_CONTAINER)
     public void receiveMsg(String msg){
         mqReceiver.receive(ResetIsvMchAppInfoConfigMQ.parse(msg));

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rabbitmq/receive/CleanMchLoginAuthCacheRabbitMQReceiver.java

@@ -43,6 +43,7 @@ public class CleanMchLoginAuthCacheRabbitMQReceiver implements IMQMsgReceiver {
     private CleanMchLoginAuthCacheMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     @Async(MqThreadExecutor.EXECUTOR_PAYORDER_MCH_NOTIFY)
     @RabbitListener(queues = CleanMchLoginAuthCacheMQ.MQ_NAME)
     public void receiveMsg(String msg){

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rabbitmq/receive/PayOrderMchNotifyRabbitMQReceiver.java

@@ -43,6 +43,7 @@ public class PayOrderMchNotifyRabbitMQReceiver implements IMQMsgReceiver {
     private PayOrderMchNotifyMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     @Async(MqThreadExecutor.EXECUTOR_PAYORDER_MCH_NOTIFY)
     @RabbitListener(queues = PayOrderMchNotifyMQ.MQ_NAME)
     public void receiveMsg(String msg){

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rabbitmq/receive/PayOrderReissueRabbitMQReceiver.java

@@ -43,6 +43,7 @@ public class PayOrderReissueRabbitMQReceiver implements IMQMsgReceiver {
     private PayOrderReissueMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     @Async(MqThreadExecutor.EXECUTOR_PAYORDER_MCH_NOTIFY)
     @RabbitListener(queues = PayOrderReissueMQ.MQ_NAME)
     public void receiveMsg(String msg){

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rabbitmq/receive/ResetAppConfigRabbitMQReceiver.java

@@ -55,6 +55,7 @@ public class ResetAppConfigRabbitMQReceiver implements IMQMsgReceiver {
      *   参考： https://bbs.csdn.net/topics/392509262?list=70088931
      *
      * **/
+    @Override
     @RabbitListener(
             bindings = {@QueueBinding(value = @Queue(), // 注意这里不要定义队列名称,系统会随机产生
             exchange = @Exchange(name = RabbitMQConfig.FANOUT_EXCHANGE_NAME_PREFIX + ResetAppConfigMQ.MQ_NAME,

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rabbitmq/receive/ResetIsvMchAppInfoRabbitMQReceiver.java

@@ -55,6 +55,7 @@ public class ResetIsvMchAppInfoRabbitMQReceiver implements IMQMsgReceiver {
      *   参考： https://bbs.csdn.net/topics/392509262?list=70088931
      *
      * **/
+    @Override
     @RabbitListener(
             bindings = {@QueueBinding(value = @Queue(), // 注意这里不要定义队列名称,系统会随机产生
             exchange = @Exchange(name = RabbitMQConfig.FANOUT_EXCHANGE_NAME_PREFIX + ResetIsvMchAppInfoConfigMQ.MQ_NAME,

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rocketmq/receive/CleanMchLoginAuthCacheRocketMQReceiver.java

@@ -43,6 +43,7 @@ public class CleanMchLoginAuthCacheRocketMQReceiver implements IMQMsgReceiver, R
     private CleanMchLoginAuthCacheMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     public void receiveMsg(String msg){
         mqReceiver.receive(CleanMchLoginAuthCacheMQ.parse(msg));
     }

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rocketmq/receive/PayOrderMchNotifyRocketMQReceiver.java

@@ -45,6 +45,7 @@ public class PayOrderMchNotifyRocketMQReceiver implements IMQMsgReceiver, Rocket
     private PayOrderMchNotifyMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     public void receiveMsg(String msg){
         mqReceiver.receive(PayOrderMchNotifyMQ.parse(msg));
     }

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rocketmq/receive/PayOrderReissueRocketMQReceiver.java

@@ -45,6 +45,7 @@ public class PayOrderReissueRocketMQReceiver implements IMQMsgReceiver, RocketMQ
     private PayOrderReissueMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 queue 】 类型的消息 **/
+    @Override
     public void receiveMsg(String msg){
         mqReceiver.receive(PayOrderReissueMQ.parse(msg));
     }

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rocketmq/receive/ResetAppConfigRocketMQReceiver.java

@@ -44,6 +44,7 @@ public class ResetAppConfigRocketMQReceiver implements IMQMsgReceiver, RocketMQL
     private ResetAppConfigMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 MQSendTypeEnum.BROADCAST  】 广播类型的消息 **/
+    @Override
     public void receiveMsg(String msg){
         mqReceiver.receive(ResetAppConfigMQ.parse(msg));
     }

jeepay-components/jeepay-components-mq/src/main/java/com/jeequan/jeepay/components/mq/vender/rocketmq/receive/ResetIsvMchAppInfoRocketMQReceiver.java

@@ -44,6 +44,7 @@ public class ResetIsvMchAppInfoRocketMQReceiver implements IMQMsgReceiver, Rocke
     private ResetIsvMchAppInfoConfigMQ.IMQReceiver mqReceiver;
 
     /** 接收 【 MQSendTypeEnum.BROADCAST  】 广播类型的消息 **/
+    @Override
     public void receiveMsg(String msg){
         mqReceiver.receive(ResetIsvMchAppInfoConfigMQ.parse(msg));
     }

jeepay-components/jeepay-components-oss/src/main/java/com/jeequan/jeepay/components/oss/ctrl/OssFileController.java

@@ -44,7 +44,9 @@ public class OssFileController extends AbstractCtrl {
     @PostMapping("/{bizType}")
     public ApiRes singleFileUpload(@RequestParam("file") MultipartFile file, @PathVariable("bizType") String bizType) {
 
-        if( file == null ) return ApiRes.fail(ApiCodeEnum.SYSTEM_ERROR, "选择文件不存在");
+        if( file == null ) {
+            return ApiRes.fail(ApiCodeEnum.SYSTEM_ERROR, "选择文件不存在");
+        }
         try {
 
             OssFileConfig ossFileConfig = OssFileConfig.getOssFileConfigByBizType(bizType);

jeepay-components/jeepay-components-oss/src/main/java/com/jeequan/jeepay/components/oss/service/LocalFileService.java

@@ -53,7 +53,9 @@ public class LocalFileService implements IOssService{
 
             //如果文件夹不存在则创建文件夹
             File dir = saveFile.getParentFile();
-            if(!dir.exists()) dir.mkdirs();
+            if(!dir.exists()) {
+                dir.mkdirs();
+            }
             multipartFile.transferTo(saveFile);
 
         } catch (Exception e) {

jeepay-core/src/main/java/com/jeequan/jeepay/core/beans/RequestKitBean.java

@@ -88,7 +88,9 @@ public class RequestKitBean {
                     body += str;
                 }
 
-                if(StringUtils.isEmpty(body)) return returnObject;
+                if(StringUtils.isEmpty(body)) {
+                    return returnObject;
+                }
                 return JSONObject.parseObject(body);
 
             } catch (Exception e) {

jeepay-core/src/main/java/com/jeequan/jeepay/core/cache/RedisUtil.java

@@ -51,7 +51,9 @@ public class RedisUtil {
 
     /** 获取缓存数据, String类型 */
     public static String getString(String key) {
-        if(key == null) return null;
+        if(key == null) {
+            return null;
+        }
         return  (String)getStringRedisTemplate().opsForValue().get(key);
     }