diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java
index c95599b1..821be30e 100644
--- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java
+++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/AbnormalBillServiceImpl.java
@@ -10,10 +10,10 @@ import com.foreverwin.mesnac.anomaly.mapper.AbnormalBillDisposeMapper;
 import com.foreverwin.mesnac.anomaly.mapper.AbnormalBillMapper;
 import com.foreverwin.mesnac.anomaly.model.*;
 import com.foreverwin.mesnac.anomaly.service.*;
-import com.foreverwin.mesnac.common.enums.AnomalyConstant;
 import com.foreverwin.mesnac.common.constant.Constants;
 import com.foreverwin.mesnac.common.dto.ScrapDto;
 import com.foreverwin.mesnac.common.dto.UsrDto;
+import com.foreverwin.mesnac.common.enums.AnomalyConstant;
 import com.foreverwin.mesnac.common.enums.HandleEnum;
 import com.foreverwin.mesnac.common.helper.NextNumberHelper;
 import com.foreverwin.mesnac.common.mapper.MessageMapper;
@@ -132,6 +132,9 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
     @Autowired
     private NcCodeService ncCodeService;
 
+    @Autowired
+    private DataFieldListMapper dataFieldListMapper;
+
 
 
     @Override
@@ -1086,6 +1089,56 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
             messageMap.put("ncCodeDescription",ncCodeDescription);
         }
         messageMap.put("shutDown",AnomalyConstant.ShutDown.msg(messageContent.getShutDown()));
+
+        //判断该异常单的状态是否是纠防确认
+        if(Constants.CORRECTION_CONFIRM.equals(messageContent.getStatus())){
+
+            DataField dataField = new DataField();
+            dataField.setSite(site);
+            //原因分类
+            String dutyCauseType = messageContent.getDutyType();
+            if(!StringUtil.isBlank(dutyCauseType)){
+                List<String> dutyCauseTypeList = Arrays.asList(dutyCauseType.split(","));
+                dataField.setDataField("REASON_CATEGORY");
+                dataField.setDataValue(dutyCauseTypeList);
+                String dutyCauseTypeDescription = dataFieldListMapper.findDataFieldListByDataField(dataField, locale);
+                messageMap.put("dutyCauseType",dutyCauseTypeDescription);
+            }else{
+                messageMap.put("dutyCauseType","");
+            }
+            //责任部门
+            String dutyDepart = messageContent.getDutyDepart();
+            if(!StringUtil.isBlank(dutyDepart)){
+                List<String> dutyDepartList = Arrays.asList(dutyDepart.split(","));
+                dataField.setDataField("RESPONSIBILITY_DEPARTMENT");
+                dataField.setDataValue(dutyDepartList);
+                String dutyDepartDescription = dataFieldListMapper.findDataFieldListByDataField(dataField, locale);
+                messageMap.put("dutyDepart",dutyDepartDescription);
+            }else{
+                messageMap.put("dutyDepart","");
+            }
+            //责任分类
+            String dutyType = messageContent.getDutyDepart();
+            if(!StringUtil.isBlank(dutyType)){
+                List<String> dutyTypeList = Arrays.asList(dutyType.split(","));
+                dataField.setDataField("RESPONSIBILITY_TYPE");
+                dataField.setDataValue(dutyTypeList);
+                String dutyDepartDescription = dataFieldListMapper.findDataFieldListByDataField(dataField, locale);
+                messageMap.put("dutyType",dutyDepartDescription);
+            }else{
+                messageMap.put("dutyType","");
+            }
+            List<UsrDto> list = userService.findList(messageContent.getPrincipalUser());
+            if(list.size() > 0){
+                messageMap.put("principalUser",list.get(0).getFullName());
+            }
+            messageMap.put("dutyCauseDescription",messageContent.getDutyCauseDescription());
+        }
+
+        if(Constants.PROGRAM_CONFIRM.equals(messageContent.getStatus())){
+
+        }
+
         //格式化之后的消息
         return StringUtils.format(messageBody, messageMap);
     }
diff --git a/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml b/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml
index 189c2dfd..2ceb97ef 100644
--- a/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml
+++ b/anomaly/src/main/resources/mapper/AbnormalBillMapper.xml
@@ -964,25 +964,46 @@
                 </if>
                 <choose>
                     <when test="userGroupList != null and userGroupList.size != 0">
-                        AND (ZAB.REPORT_SEND_USER_GROUP IN
+                         AND ZAB.REPORT_SEND_USER_GROUP IN
                         <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">
                             UPPER(#{item.userGroup})
                         </foreach>
-                        OR
-                        ZAB.CANCEL_SEND_USER_GROUP IN
-                        <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">
-                            UPPER(#{item.userGroup})
-                        </foreach>
-                        OR
-                        ZABD.DUTY_SEND_USER_GROUP IN
-                        <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">
-                            UPPER(#{item.userGroup})
-                        </foreach>
-                        OR
-                        ZABD.RESOLVE_SEND_USER_GROUP IN
-                        <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">
-                            UPPER(#{item.userGroup})
-                        </foreach>)
+
+<!--                        OR ZAB.STATUS =-->
+<!--                        CASE WHEN ZAB.STATUS = 'X' AND ZAB.REPORT_SEND_USER_GROUP IN-->
+<!--                        <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">-->
+<!--                            UPPER(#{item.userGroup})-->
+<!--                        </foreach>-->
+<!--                        THEN-->
+<!--                        'X'-->
+<!--                        END-->
+
+<!--                        OR ZAB.STATUS =-->
+<!--                        CASE WHEN ZAB.STATUS = 'Q' AND ZAB.CANCEL_SEND_USER_GROUP IN-->
+<!--                        <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">-->
+<!--                            UPPER(#{item.userGroup})-->
+<!--                        </foreach>-->
+<!--                        THEN-->
+<!--                        'Q'-->
+<!--                        END-->
+
+<!--                        OR ZAB.STATUS =-->
+<!--                        CASE WHEN ZAB.STATUS = 'J' AND ZABD.DUTY_SEND_USER_GROUP IN-->
+<!--                        <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">-->
+<!--                            UPPER(#{item.userGroup})-->
+<!--                        </foreach>-->
+<!--                        THEN-->
+<!--                        'J'-->
+<!--                        END-->
+
+<!--                        OR ZAB.STATUS =-->
+<!--                        CASE WHEN ZAB.STATUS = 'F' AND ZABD.RESOLVE_SEND_USER_GROUP IN-->
+<!--                        <foreach item="item" index="index" collection="userGroupList" separator="," open="(" close=")">-->
+<!--                            UPPER(#{item.userGroup})-->
+<!--                        </foreach>-->
+<!--                        THEN-->
+<!--                        'F'-->
+<!--                        END)-->
                     </when>
                     <otherwise>
                         <if test="userGroupList == null">
diff --git a/console/src/main/resources/application-local.yml b/console/src/main/resources/application-local.yml
index 8c046671..1908b688 100644
--- a/console/src/main/resources/application-local.yml
+++ b/console/src/main/resources/application-local.yml
@@ -39,13 +39,22 @@ spring:
           slow-sql-millis: 100
   activemq:
     enabled: false
-    brokerUrl: tcp://121.36.58.109:61616?wireFormat.maxInactivityDuration=0
+    brokerUrl: tcp://localhost:61616?wireFormat.maxInactivityDuration=0
     password: admin
     user: admin
     pool:
       enabled: true
       max-connections: 10
 
+#发送消息
+activemq:
+  brokerUrl: tcp://localhost:61616?wireFormat.maxInactivityDuration=0
+  password: admin
+  user: admin
+  pool:
+    enabled: true
+    max-connections: 10
+
 #WebService
 ws:
   erp:
diff --git a/console/src/main/resources/application-prd.yml b/console/src/main/resources/application-prd.yml
index 73c8dd67..caf9f021 100644
--- a/console/src/main/resources/application-prd.yml
+++ b/console/src/main/resources/application-prd.yml
@@ -16,6 +16,15 @@ spring:
       enabled: true
       max-connections: 10
 
+#发送消息
+activemq:
+  brokerUrl: tcp://172.16.251.164:61616?wireFormat.maxInactivityDuration=0
+  password: admin
+  user: admin
+  pool:
+    enabled: true
+    max-connections: 10
+
 #WebService
 ws:
   erp:
diff --git a/console/src/main/resources/application-qas.yml b/console/src/main/resources/application-qas.yml
index 88e183c5..36883dd6 100644
--- a/console/src/main/resources/application-qas.yml
+++ b/console/src/main/resources/application-qas.yml
@@ -9,13 +9,22 @@ spring:
           jndi-name: jdbc/jts/wipPool
   activemq:
     enabled: false
-    brokerUrl: tcp://121.36.58.109:61616?wireFormat.maxInactivityDuration=0
+    brokerUrl: tcp://172.16.251.133:61616?wireFormat.maxInactivityDuration=0
     password: admin
     user: admin
     pool:
       enabled: true
       max-connections: 10
 
+#发送消息
+activemq:
+  brokerUrl: tcp://172.16.251.133:61616?wireFormat.maxInactivityDuration=0
+  password: admin
+  user: admin
+  pool:
+    enabled: true
+    max-connections: 10
+
 #WebService
 ws:
   erp: