소스 검색

更新检查广联达剩余积分

xiewj 2 년 전
부모
커밋
d7d4644d43

+ 1 - 0
src/main/java/com/fdkk/bim/service/IntegralInfoService.java

@@ -13,4 +13,5 @@ public interface IntegralInfoService extends IService<IntegralInfoEntity> {
 
 
         IntegralInfoEntity findOneByIntegral(Integer integral);
+        IntegralInfoEntity findLastOne();
 }

+ 10 - 2
src/main/java/com/fdkk/bim/service/impl/IntegralInfoServiceImpl.java

@@ -40,10 +40,17 @@ public class IntegralInfoServiceImpl extends ServiceImpl<IntegralInfoMapper, Int
     }
 
     @Override
+    public IntegralInfoEntity findLastOne() {
+        LambdaQueryWrapper<IntegralInfoEntity> wrapper = Wrappers.lambdaQuery();
+        wrapper.orderByDesc(IntegralInfoEntity::getId);
+        return getOne(wrapper);
+    }
+
+    @Override
     public void CheckData(String integral)   {
         if (StrUtil.isNotEmpty(integral)&& NumberUtil.isNumber(integral)){
             int i = NumberUtil.parseInt(integral);
-            IntegralInfoEntity integralInfoEntity = findOneByIntegral(i);
+            IntegralInfoEntity integralInfoEntity = findLastOne();
             if (ObjectUtil.isNull(integralInfoEntity) &&i<bimConfig.getMixIntegral()){
                 DingTalkClient dingTalkClient= SpringUtil.getBean(DingTalkClient.class);
                 DingTalkDTO dto=new DingTalkDTO();
@@ -55,12 +62,13 @@ public class IntegralInfoServiceImpl extends ServiceImpl<IntegralInfoMapper, Int
                 save(integralInfoEntity);
             }else if (ObjectUtil.isNotNull(integralInfoEntity) &&i<bimConfig.getMixIntegral() && integralInfoEntity.getPushCount()<=3){
                 long betweenHour = DateUtils.getDatePoorUnit(DateUtil.date(), integralInfoEntity.getCreateTime(), DateUnit.HOUR);
-                if (betweenHour>8L){
+                if (betweenHour>=4L){
                     DingTalkClient dingTalkClient= SpringUtil.getBean(DingTalkClient.class);
                     DingTalkDTO dto=new DingTalkDTO();
                     dto.setText(new DingTalkTextDTO("BIM:广联达剩余积分小于"+bimConfig.getMixIntegral()+"剩余积分:"+i));
                     dingTalkClient.pushData(dto);
                     integralInfoEntity.setPushCount(integralInfoEntity.getPushCount()+1);
+                    integralInfoEntity.setIntegral(i);
                     updateById(integralInfoEntity);
                 }
             }