巡检消息规则推送

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/controller/RiskSourceController.java

@@ -568,7 +568,8 @@ public class RiskSourceController extends BaseController {
     @ApiOperation(httpMethod = "PUT", value = "上传巡检数据", notes = "上传巡检数据")
     @RequestMapping(value = "/data/patroldata", produces = "application/json;charset=UTF-8", method = RequestMethod.PUT)
     public CommonResponse postPatrolData(@RequestBody ProtalDataRo protalData) throws Exception {
-        riskSourceService.processProtalData(getToken(),getProduct(),getAppKey(),protalData);
+    	riskSourceService.protalRuleMessagePush(protalData);
+    	riskSourceService.processProtalData(getToken(),getProduct(),getAppKey(),protalData);
         return CommonResponseUtil.success();
     }
 

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/RiskSourceServiceImpl.java

@@ -620,6 +620,25 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
         }
         iDataRefreshService.refreshViewData(DataRefreshTypeEum.check.getCode());
     }
+    
+    /**
+     * 巡检消息规则推送
+     * @param protalData
+     */
+    @Override
+    @Async
+    public void protalRuleMessagePush(ProtalDataRo protalData){
+        String bacthNo = UUID.randomUUID().toString();
+        protalData.setBatchNo(bacthNo);
+        protalData.setOriginalNodeState(protalData.getNodeState());
+        protalData.setUserName(protalData.getCheckUser());
+        try {
+			ruleTrigger.publish(protalData, "风险管控/patrol", null);
+		} catch (Exception e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+    }
 
     @Override
     public RiskSourceTreeResponse queryRiskSourceDetailById(Long id) {

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IRiskSourceService.java

@@ -78,6 +78,9 @@ public interface IRiskSourceService {
 
     void processProtalData(String toke,String product,String appKey,ProtalDataRo protalData) throws Exception;
 
+    
+    void protalRuleMessagePush(ProtalDataRo protalData);
+    
     RiskSourceTreeResponse queryRiskSourceDetailById(Long id);
 
     /**