diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java
index 820cdb07..2d21173d 100644
--- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java
+++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/AbnormalBillController.java
@@ -167,7 +167,8 @@ public class AbnormalBillController {
 
     /**
      * 初始化
-     * @param messageType
+     * @param messageType  暂时不用
+     * @param  type 异常的类型
      * @return
      */
     @GetMapping("/init")
diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/UploadPicturesController.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/UploadPicturesController.java
index 4eddbb96..73f41898 100644
--- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/UploadPicturesController.java
+++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/controller/UploadPicturesController.java
@@ -13,7 +13,7 @@ import java.util.List;
 
 /**
  *
- * @author Leon.L
+ * @author 赵嘉伟
  * @since 2021-07-11
  */
 @RestController
diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java
index 743f02bd..b9793b22 100644
--- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java
+++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/mapper/AbnormalBillMapper.java
@@ -28,4 +28,6 @@ public interface AbnormalBillMapper extends BaseMapper<AbnormalBill> {
      */
     AbnormalBillDto findAllByAbnormalNoDevice(@Param("abnormalBill")AbnormalBill abnormalBill, @Param("language")String language);
 
+
+
 }
\ No newline at end of file
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 d5d3387b..64ccfa30 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
@@ -97,6 +97,9 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
     @Autowired
     private SfcMapper sfcMapper;
 
+    @Autowired
+    private NcCodeMapper ncCodeMapper;
+
 
 
     @Override
@@ -183,10 +186,10 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
     public String anomalyReportDevice(AbnormalBill abnormalBill,AbnormalBillDispose abnormalBillDispose) {
         String message = this.generateAbnormalBill(abnormalBill, abnormalBillDispose, null, null);
 
-        List<NcCode> ncByNG = ncCodeService.findNcByNG(abnormalBill.getMessageType(), abnormalBill.getNcCode());
-        if(ncByNG == null || ncByNG.size() <= 0){
-            throw BusinessException.build("该消息类型下没有该不良代码");
-        }
+//        List<NcCode> ncByNG = ncCodeService.findNcByNG(abnormalBill.getMessageType(), abnormalBill.getNcCode());
+//        if(ncByNG == null || ncByNG.size() <= 0){
+//            throw BusinessException.build("该消息类型下没有该不良代码");
+//        }
         this.saveOrUpdate(abnormalBill);
         abnormalBillDisposeService.saveOrUpdate(abnormalBillDispose);
         return message;
@@ -197,10 +200,9 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
         HashMap<String, Object> hashMap = new HashMap<>();
         String site = CommonMethods.getSite();
         //消息类型
-        if(!StringUtil.isBlank(messageType)){
-            List<NcCode> ncByNG = ncCodeService.findNcByNG(messageType,null);
-
-            hashMap.put("ncByNG",ncByNG);
+        if("Z".equals(type)){
+            List<NcCode> category = ncCodeService.findNcByCategory(messageType,null);
+            hashMap.put("ncByNG",category);
         }
         //工作中心
         WorkCenter workCenter = new WorkCenter();
@@ -405,7 +407,7 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
         abnormalBillDispose.setDutyDateTime(currentTime);
 
         ArrayList<AbnormalCause> causeTypes = new ArrayList<>();
-        //判断原因分类是否为空
+        //判断原因分类是否为空,如果不为空，把它放进Z_ABNORMAL_CAUSE表里面
         if(dutyCauseType != null && dutyCauseType.size() >= 1){
             for(String cause:dutyCauseType){
                 AbnormalCause abnormalCause = new AbnormalCause();
@@ -428,8 +430,21 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
                 causeTypes.add(abnormalCause);
             }
         }
+
+        /**
+         * 判断设备传递的不良代码是否有误
+         */
+        if(!StringUtil.isBlank(abnormalBill.getNcCode()) && Constants.ABNORMAL_RESRCE.equals(abnormalBill.getType())){
+            List<String> ncCodes = Arrays.asList(abnormalBill.getNcCode().split(","));
+            Integer length = ncCodeMapper.checkNcCode(ncCodes,site,"FAILURE");
+            if(ncCodes.size() != length){
+                throw BusinessException.build("不良代码传递有误");
+            }
+        }
+
+
         ArrayList<AbnormalDuty> dutyTypes = new ArrayList<>();
-        //判断责任分类是否为空
+        //判断责任分类是否为空,如果不为空，把它放进Z_ABNORMAL_DUTY表里面
         if(dutyType != null && dutyType.size() >= 1){
             for(String duty:dutyType){
                 AbnormalDuty abnormalDuty = new AbnormalDuty();
@@ -465,24 +480,30 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
         abnormalBillDispose.setModifiedDateTime(currentTime);
         abnormalBillDispose.setModifiedUser(user);
 
-        //判断SFC、设备编号、消息类型是否不正确或为空
-        if(StringUtil.isBlank(abnormalBill.getSfc()) && !"S".equals(abnormalBill.getType())){
+        /**
+         * 判断SFC ，设备异常提交，sfc可以为空
+         * 设备编号
+         * 是否为空
+         */
+        if(StringUtil.isBlank(abnormalBill.getSfc()) && !Constants.ABNORMAL_RESRCE.equals(abnormalBill.getType())){
             throw BusinessException.build("产品条码不能为空");
         }
 //        if(StringUtil.isBlank(abnormalBill.getResrce())){
 //            throw BusinessException.build("设备编号不能为空");
 //        }
-        if(!StringUtil.isBlank(abnormalBill.getMessageType())){
-            NcGroup messageType = ncGroupMapper.selectById(HandleEnum.NC_GROUP.getHandle(site, abnormalBill.getMessageType()));
-            if(messageType == null){
-                throw BusinessException.build("该消息类型不存在");
+//        if(!StringUtil.isBlank(abnormalBill.getMessageType())){
+//            NcGroup messageType = ncGroupMapper.selectById(HandleEnum.NC_GROUP.getHandle(site, abnormalBill.getMessageType()));
+//            if(messageType == null){
+//                throw BusinessException.build("该消息类型不存在");
+//            }
+//        }
+
+        if(!StringUtil.isBlank(abnormalBill.getResrce()) && Constants.ABNORMAL_RESRCE.equals(abnormalBill.getType())){
+            Resrce resrce = resrceMapper.selectById(HandleEnum.RESOURCE.getHandle(site, abnormalBill.getResrce()));
+            if(resrce == null){
+                throw BusinessException.build("该设备编号不存在");
             }
         }
-
-//        Resrce resrce = resrceMapper.selectById(HandleEnum.RESOURCE.getHandle(site, abnormalBill.getResrce()));
-//        if(resrce == null){
-//            throw BusinessException.build("该设备编号不存在");
-//        }
         //判断不良品数量和问题数量是否为正整数
         try {
             if(!StringUtil.isBlank(abnormalBill.getNcQty()) && Integer.parseInt(abnormalBill.getNcQty()) < 0) {
@@ -503,7 +524,7 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
         if(causeTypes.size() > 0){
             abnormalCauseService.saveOrUpdateBatch(causeTypes);
         }
-        if(StringUtil.isBlank(abnormalBill.getFileName())){
+        if(!StringUtil.isBlank(abnormalBill.getFileName())){
             //放置图片
             this.fileUpload(abnormalBill);
         }
@@ -626,16 +647,16 @@ public class AbnormalBillServiceImpl extends ServiceImpl<AbnormalBillMapper, Abn
 
         //判断工单，sfc，资源是否传递正确
         Sfc sfc1 = sfcMapper.selectById(HandleEnum.SFC.getHandle(site, sfc));
-        if(sfc == null){
+        if(sfc1 == null){
             throw new BaseException("sfc传递有误");
         }else {
             if(!HandleEnum.SHOP_ORDER.getHandle(site,shopOrder).equals(sfc1.getShopOrderBo())){
                 throw new BaseException("工单传递有误");
             }
-            Resrce resrce = resrceMapper.selectById(HandleEnum.RESOURCE.getHandle(site, resource));
-            if(resrce == null){
-                throw new BaseException("资源传递有误");
-            }
+//            Resrce resrce = resrceMapper.selectById(HandleEnum.RESOURCE.getHandle(site, resource));
+//            if(resrce == null){
+//                throw new BaseException("资源传递有误");
+//            }
         }
         this.saveOrUpdate(abnormalBill);
         abnormalBillDisposeService.saveOrUpdate(abnormalBillDispose);
diff --git a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/FileUploadedServiceImpl.java b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/FileUploadedServiceImpl.java
index a5e970f1..e05bc4f9 100644
--- a/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/FileUploadedServiceImpl.java
+++ b/anomaly/src/main/java/com/foreverwin/mesnac/anomaly/service/impl/FileUploadedServiceImpl.java
@@ -3,6 +3,7 @@ package com.foreverwin.mesnac.anomaly.service.impl;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.extra.ftp.Ftp;
 import com.foreverwin.mesnac.anomaly.service.FileUploadedService;
+import com.foreverwin.mesnac.common.util.StringUtil;
 import com.foreverwin.modular.core.exception.BusinessException;
 import com.foreverwin.modular.core.util.CommonMethods;
 import org.apache.commons.net.ftp.FTP;
@@ -54,7 +55,7 @@ public class FileUploadedServiceImpl implements FileUploadedService {
      */
     @Override
     public void uploadAttachment(MultipartFile fileItem,String site,String taskNo,String fileType) {
-        if (StrUtil.isBlank(site)) {
+        if (StringUtil.isBlank(site)) {
             site = CommonMethods.getSite();
         }
         //上传附件目录：年/月/日
@@ -163,5 +164,28 @@ public class FileUploadedServiceImpl implements FileUploadedService {
         }
     }
 
+    public void uploadImage(MultipartFile fileItem, HttpServletRequest request){
+        String site = request.getParameter("site");
+        String taskNo = request.getParameter("taskNo");
+        String fileType = request.getParameter("fileType");
+
+        if (StringUtil.isBlank(site)) {
+            site = CommonMethods.getSite();
+        }
+        //上传附件目录：年/月/日
+        String path =  LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd"))+"/"+taskNo;
+        //上传附件名称
+        String fileName = fileItem.getOriginalFilename();
+        try {
+            Ftp ftp = new Ftp(host, port,username,password);
+
+            ftp.upload(path, fileName, fileItem.getInputStream());
+            ftp.close();
+        } catch (IOException e) {
+            logger.info(e.getMessage());
+            throw BusinessException.build("" + e.getMessage());
+        }
+    }
+
 
 }
diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/NcCodeController.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/NcCodeController.java
index bb8e07f6..9fb677dc 100644
--- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/NcCodeController.java
+++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/controller/NcCodeController.java
@@ -135,9 +135,9 @@ public class NcCodeController {
     /**
      * 根据不良代码组找出它下面的所有的不良代码，并且是主要代码
      */
-    @GetMapping("/findNcByNG")
-    public R findNcByNG(String messageType,String ncCode){
-        return R.ok(ncCodeService.findNcByNG(messageType,ncCode));
+    @GetMapping("/findNcByCategory")
+    public R findNcByCategory(String category,String code){
+        return R.ok(ncCodeService.findNcByCategory(category,code));
     }
 
     @GetMapping("findSecondaryNcByNc")
diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java
index 10ba35df..6527e30f 100644
--- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java
+++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/mapper/NcCodeMapper.java
@@ -20,12 +20,18 @@ import java.util.List;
  */
 @Repository
 public interface NcCodeMapper extends BaseMapper<NcCode> {
-    List<NcCode> findNcByNG(@Param("site")String site,
+    List<NcCode> findNcByCategory(@Param("site")String site,
                             @Param("locale")String locale,
                             @Param("messageType")String messageType,
-                            @Param("ncCode")String ncCode);
+                            @Param("code")String code);
 
     List<NcCode> findSecondaryNcByNc(@Param("site")String site,@Param("locale")String locale,@Param("ncCode")String ncCode);
 
     IPage selectPageByNcGroup(Page<NcGroup> pagePlus,@Param("ncGroupBO") String ncGroupBO,@Param("globalQuery") String globalQuery,@Param("locale") String locale);
+
+    /**
+     * 判断不良代码是否正确
+     * @return
+     */
+    Integer checkNcCode(@Param("NcCodeList")List<String> ncCodes,@Param("site")String site,@Param("category")String category);
 }
\ No newline at end of file
diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/NcCodeService.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/NcCodeService.java
index 8ddb2a1b..bed1fd1d 100644
--- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/NcCodeService.java
+++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/NcCodeService.java
@@ -28,7 +28,7 @@ public interface NcCodeService extends IService<NcCode> {
 
     List<NcCode> selectList(NcCode ncCode);
 
-    List<NcCode> findNcByNG(String messageType,String ncCode);
+    List<NcCode> findNcByCategory(String category,String code);
 
     List<NcCode> findSecondaryNcByNc(String ncCode);
 
diff --git a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/NcCodeServiceImpl.java b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/NcCodeServiceImpl.java
index e3c11b6e..7ddc9ed7 100644
--- a/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/NcCodeServiceImpl.java
+++ b/meapi/src/main/java/com/foreverwin/mesnac/meapi/service/impl/NcCodeServiceImpl.java
@@ -51,10 +51,10 @@ public class NcCodeServiceImpl extends ServiceImpl<NcCodeMapper, NcCode> impleme
     }
 
     @Override
-    public List<NcCode> findNcByNG(String messageType,String ncCode) {
+    public List<NcCode> findNcByCategory(String messageType,String code) {
         String site = CommonMethods.getSite();
         String locale = LocaleContextHolder.getLocale().getLanguage();
-        return ncCodeMapper.findNcByNG(site,locale,messageType,ncCode);
+        return ncCodeMapper.findNcByCategory(site,locale,messageType,code);
     }
 
     @Override
diff --git a/meapi/src/main/resources/mapper/NcCodeMapper.xml b/meapi/src/main/resources/mapper/NcCodeMapper.xml
index 8f7cbce3..1a14cb98 100644
--- a/meapi/src/main/resources/mapper/NcCodeMapper.xml
+++ b/meapi/src/main/resources/mapper/NcCodeMapper.xml
@@ -346,20 +346,19 @@
 
     <!-- BaseMapper标准查询/修改/删除 -->
 
-    <select id="findNcByNG" resultMap="BaseResultMap">
+    <select id="findNcByCategory" resultMap="BaseResultMap">
         SELECT NC.NC_CODE , NCT.DESCRIPTION
-        FROM NC_GROUP NG
-                 INNER JOIN NC_GROUP_MEMBER NGM ON NG.HANDLE = NGM.NC_GROUP_BO
-                 INNER JOIN NC_CODE NC ON NC.HANDLE = NGM.NC_CODE_OR_GROUP_GBO
-                 INNER JOIN NC_CODE_DEF NCD ON NC.HANDLE = NCD.NC_CODE_OR_GROUP_GBO AND NCD.CAN_BE_PRIMARY_CODE = 'true'
-                 INNER JOIN NC_CODE_T NCT ON  NCT.NC_CODE_BO = NC.HANDLE AND NCT.LOCALE = #{locale}
+        FROM NC_CODE NC
+        INNER JOIN NC_CODE_DEF NCD ON NC.HANDLE = NCD.NC_CODE_OR_GROUP_GBO AND NCD.CAN_BE_PRIMARY_CODE = 'true'
+        INNER JOIN NC_CODE_T NCT ON  NCT.NC_CODE_BO = NC.HANDLE AND NCT.LOCALE = #{locale}
         <where>
-            NG.SITE = #{site}
+            NC.SITE = #{site}
+            AND NCD.CAN_BE_PRIMARY_CODE = 'true'
             <if test="messageType != null and messageType != ''">
-                AND NG.NC_GROUP =#{messageType}
+                AND NC.NC_CATEGORY =#{messageType}
             </if>
-            <if test="ncCode != null and ncCode != ''">
-                AND NC.NC_CODE = #{ncCode}
+            <if test="code != null and code != ''">
+                AND NC.NC_CDDE = #{code}
             </if>
         </where>
     </select>
@@ -382,4 +381,19 @@
             AND (nc.NC_CODE LIKE '%${globalQuery}%' or nct.DESCRIPTION  LIKE '%${globalQuery}%')
         </if>
     </select>
+
+    <select id="checkNcCode" resultType="integer">
+        SELECT count(*)
+        FROM NC_CODE
+        WHERE NC_CODE IN
+        <foreach collection="NcCodeList" index="index" item="item" separator="," open="(" close=")">
+            UPPER(#{item})
+        </foreach>
+        <if test="site != null and site != ''">
+            AND SITE = #{site}
+        </if>
+        <if test="category != null and category != ''">
+            AND NC_CATEGORY = #{category}
+        </if>
+    </select>
 </mapper>