接收激活数据队列bug修复

kxs-stat/kxs-stat-biz/src/main/java/com/kxs/stat/biz/mq/RabbitKxsActQueueListener.java

@@ -46,6 +46,7 @@ public class RabbitKxsActQueueListener {
             BeanUtils.copyProperties(parse, campOpenNumStatDTO);
             remoteSysService.campOpenNumStat(campOpenNumStatDTO, SecurityConstants.FROM_IN);
 
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
         } catch (Exception e) {
             log.error("客小爽激活队列消费失败:{}", JSON.toJSONString(msg), e);
             try {

kxs-system/kxs-system-biz/src/main/java/com/kxs/system/biz/service/impl/KxsCampServiceImpl.java

@@ -343,6 +343,7 @@ public class KxsCampServiceImpl extends ServiceImpl<KxsCampMapper, KxsCamp> impl
         }
         //判断绑定时间
         if (kxsCamp.getStartTime().isAfter(bindTime)) {
+            log.info("机具绑定时间不在训练营之内:{}", JSON.toJSONString(param));
             return;
         }
         int sourceNum = param.getActType() == 4 ? 2 : 1;
@@ -379,7 +380,7 @@ public class KxsCampServiceImpl extends ServiceImpl<KxsCampMapper, KxsCamp> impl
             case 3, 4 -> kxsCampBonusLog.setSourceType(CampSourceTypeEnum.S_LKB.getType());
         }
         campBonusLogService.save(kxsCampBonusLog);
-        log.info("用户{}参加训练营{},开机数+1", param.getUserId(), kxsCamp.getId());
+        log.info("用户/上级{}参加训练营{},开机数+1", param.getUserId(), kxsCamp.getId());
     }
 
     @Override