巡检点小区服务帧听

CommunityService/src/main/java/com/java110/community/listener/inspectionPoint/AbstractInspectionBusinessServiceDataFlowListener.java

@@ -15,16 +15,16 @@ import java.util.List;
 import java.util.Map;
 
 /**
- *
  * 巡检点 服务侦听 父类
  * Created by wuxw on 2018/7/4.
  */
-public abstract class AbstractInspectionBusinessServiceDataFlowListener extends AbstractBusinessServiceDataFlowListener{
+public abstract class AbstractInspectionBusinessServiceDataFlowListener extends AbstractBusinessServiceDataFlowListener {
     private static Logger logger = LoggerFactory.getLogger(AbstractInspectionBusinessServiceDataFlowListener.class);
 
 
     /**
      * 获取 DAO工具类
+     *
      * @return
      */
     public abstract IInspectionServiceDao getInspectionServiceDaoImpl();
@@ -32,53 +32,47 @@ public abstract class AbstractInspectionBusinessServiceDataFlowListener extends
     /**
      * 刷新 businessInspectionInfo 数据
      * 主要将 数据库 中字段和 接口传递字段建立关系
+     *
      * @param businessInspectionInfo
      */
-    protected void flushBusinessInspectionInfo(Map businessInspectionInfo,String statusCd){
+    protected void flushBusinessInspectionInfo(Map businessInspectionInfo, String statusCd) {
         businessInspectionInfo.put("newBId", businessInspectionInfo.get("b_id"));
-        businessInspectionInfo.put("inspectionId",businessInspectionInfo.get("inspection_id"));
-businessInspectionInfo.put("machineId",businessInspectionInfo.get("machine_id"));
-businessInspectionInfo.put("operate",businessInspectionInfo.get("operate"));
-businessInspectionInfo.put("remark",businessInspectionInfo.get("remark"));
-businessInspectionInfo.put("inspectionName",businessInspectionInfo.get("inspection_name"));
-businessInspectionInfo.put("communityId",businessInspectionInfo.get("community_id"));
-businessInspectionInfo.remove("bId");
+        businessInspectionInfo.put("inspectionId", businessInspectionInfo.get("inspection_id"));
+        businessInspectionInfo.put("machineId", businessInspectionInfo.get("machine_id"));
+        businessInspectionInfo.put("operate", businessInspectionInfo.get("operate"));
+        businessInspectionInfo.put("remark", businessInspectionInfo.get("remark"));
+        businessInspectionInfo.put("inspectionName", businessInspectionInfo.get("inspection_name"));
+        businessInspectionInfo.put("communityId", businessInspectionInfo.get("community_id"));
+        businessInspectionInfo.remove("bId");
         businessInspectionInfo.put("statusCd", statusCd);
     }
 
 
     /**
      * 当修改数据时，查询instance表中的数据 自动保存删除数据到business中
+     *
      * @param businessInspection 巡检点信息
      */
-    protected void autoSaveDelBusinessInspection(Business business, JSONObject businessInspection){
-//自动插入DEL
+    protected void autoSaveDelBusinessInspection(Business business, JSONObject businessInspection) {
+        //自动插入DEL
         Map info = new HashMap();
-        info.put("inspectionId",businessInspection.getString("inspectionId"));
-        info.put("statusCd",StatusConstant.STATUS_CD_VALID);
+        info.put("inspectionId", businessInspection.getString("inspectionId"));
+        info.put("statusCd", StatusConstant.STATUS_CD_VALID);
         List<Map> currentInspectionInfos = getInspectionServiceDaoImpl().getInspectionInfo(info);
-        if(currentInspectionInfos == null || currentInspectionInfos.size() != 1){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"未找到需要修改数据信息，入参错误或数据有问题，请检查"+info);
+        if (currentInspectionInfos == null || currentInspectionInfos.size() != 1) {
+            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR, "未找到需要修改数据信息，入参错误或数据有问题，请检查" + info);
         }
-
         Map currentInspectionInfo = currentInspectionInfos.get(0);
-
-        currentInspectionInfo.put("bId",business.getbId());
-
-        currentInspectionInfo.put("inspectionId",currentInspectionInfo.get("inspection_id"));
-currentInspectionInfo.put("machineId",currentInspectionInfo.get("machine_id"));
-currentInspectionInfo.put("operate",currentInspectionInfo.get("operate"));
-currentInspectionInfo.put("remark",currentInspectionInfo.get("remark"));
-currentInspectionInfo.put("inspectionName",currentInspectionInfo.get("inspection_name"));
-currentInspectionInfo.put("communityId",currentInspectionInfo.get("community_id"));
-
-
-        currentInspectionInfo.put("operate",StatusConstant.OPERATE_DEL);
+        currentInspectionInfo.put("bId", business.getbId());
+        currentInspectionInfo.put("inspectionId", currentInspectionInfo.get("inspection_id"));
+        currentInspectionInfo.put("machineId", currentInspectionInfo.get("machine_id"));
+        currentInspectionInfo.put("operate", currentInspectionInfo.get("operate"));
+        currentInspectionInfo.put("remark", currentInspectionInfo.get("remark"));
+        currentInspectionInfo.put("inspectionName", currentInspectionInfo.get("inspection_name"));
+        currentInspectionInfo.put("communityId", currentInspectionInfo.get("community_id"));
+        currentInspectionInfo.put("operate", StatusConstant.OPERATE_DEL);
         getInspectionServiceDaoImpl().saveBusinessInspectionInfo(currentInspectionInfo);
     }
 
 
-
-
-
 }

CommunityService/src/main/java/com/java110/community/listener/inspectionPoint/DeleteInspectionInfoListener.java

@@ -61,10 +61,10 @@ public class DeleteInspectionInfoListener extends AbstractInspectionBusinessServ
         Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
 
         //处理 businessInspection 节点
-        if(data.containsKey("businessInspection")){
+        if(data.containsKey("businessInspectionPoint")){
             //处理 businessInspection 节点
-            if(data.containsKey("businessInspection")){
-                Object _obj = data.get("businessInspection");
+            if(data.containsKey("businessInspectionPoint")){
+                Object _obj = data.get("businessInspectionPoint");
                 JSONArray businessInspections = null;
                 if(_obj instanceof JSONObject){
                     businessInspections = new JSONArray();

CommunityService/src/main/java/com/java110/community/listener/inspectionPoint/SaveInspectionInfoListener.java

@@ -53,8 +53,8 @@ public class SaveInspectionInfoListener extends AbstractInspectionBusinessServic
         Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
 
         //处理 businessInspection 节点
-        if(data.containsKey("businessInspection")){
-            Object bObj = data.get("businessInspection");
+        if(data.containsKey("businessInspectionPoint")){
+            Object bObj = data.get("businessInspectionPoint");
             JSONArray businessInspections = null;
             if(bObj instanceof JSONObject){
                 businessInspections = new JSONArray();

CommunityService/src/main/java/com/java110/community/listener/inspectionPoint/UpdateInspectionInfoListener.java

@@ -62,10 +62,10 @@ public class UpdateInspectionInfoListener extends AbstractInspectionBusinessServ
         Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
 
         //处理 businessInspection 节点
-        if(data.containsKey("businessInspection")){
+        if(data.containsKey("businessInspectionPoint")){
             //处理 businessInspection 节点
-            if(data.containsKey("businessInspection")){
-                Object _obj = data.get("businessInspection");
+            if(data.containsKey("businessInspectionPoint")){
+                Object _obj = data.get("businessInspectionPoint");
                 JSONArray businessInspections = null;
                 if(_obj instanceof JSONObject){
                     businessInspections = new JSONArray();