1.增加发送规则代码

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/biz/service/impl/CylinderInfoServiceImpl.java

@@ -12,6 +12,7 @@ import com.yeejoin.amos.boot.module.tzs.flc.api.dto.*;
 import com.yeejoin.amos.boot.module.tzs.flc.api.entity.*;
 import com.yeejoin.amos.boot.module.tzs.flc.api.mapper.CylinderInfoMapper;
 import com.yeejoin.amos.boot.module.tzs.flc.api.service.ICylinderInfoService;
+import com.yeejoin.amos.component.rule.RuleTrigger;
 import com.yeejoin.amos.feign.systemctl.Systemctl;
 import com.yeejoin.amos.feign.systemctl.model.RegionModel;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -88,6 +89,9 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind
     @Autowired
     MsgLogServiceImpl msgLogService;
 
+    @Autowired
+    private RuleTrigger ruleTrigger;
+
     /**
      * 分页查询
      */
@@ -599,7 +603,8 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind
             result.getRecords().forEach(r -> {
                 try {
                     int interval = DateUtils.dateBetweenIncludeToday(r.getNextInspectionDate(), now);
-                    // TODO 循环调用规则 触发计算等级及发送消息
+                    // TODO 循环调用规则 触发计算等级
+                    // ruleTrigger.publish(equipmentInputItemRo, packageld, null);
                 } catch (ParseException e) {
                     log.error(JSON.toJSONString(r) + "格式化失败");
                 }
@@ -637,6 +642,7 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind
             cylinderInfo.setNextInspectionDate(c.getNextInspectionDate());
             cylinderInfos.add(cylinderInfo);
             // TODO 循环调用规则 触发计算等级及发送消息
+            // ruleTrigger.publish(equipmentInputItemRo, packageld, null);
         });
         if(!cylinderInfos.isEmpty()){
             this.updateBatchById(cylinderInfos);