fix(jg):添加批量删除设备接口

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/DataHandlerController.java

@@ -361,4 +361,18 @@ public class DataHandlerController extends BaseController {
     public ResponseModel<String> refreshXianData2ES(@RequestParam(value = "isUpdate", defaultValue = "false") boolean isUpdate) throws IOException {
         return ResponseHelper.buildResponse(dataHandlerService.refreshXianData2ES(isUpdate));
     }
+
+    /**
+     * @return
+     * @apiNote 删除不等于已认领的设备
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "PUT", value = "删除不等于已认领的设备", notes = "删除不等于已认领的设备")
+    @PutMapping(value = "/equip/deleteEquipIsNotClaimed")
+    public ResponseModel<Integer> deleteEquip(@RequestParam(value = "useUnitCreditCode") String useUnitCreditCode,
+                                              @RequestParam(value = "equList") String equList,
+                                              @RequestParam(value = "dataSource", defaultValue = "jg_pl") String dataSource,
+                                              @RequestParam(value = "isDelete", defaultValue = "false") boolean isDelete) {
+        return ResponseHelper.buildResponse(dataHandlerService.deleteEquipIsNotClaimed(useUnitCreditCode, equList, dataSource, isDelete));
+    }
 }
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/DataHandlerServiceImpl.java

@@ -2279,4 +2279,21 @@ public class DataHandlerServiceImpl {
                 .filter(Objects::nonNull)
                 .collect(Collectors.toList());
     }
+
+    public Integer deleteEquipIsNotClaimed(String useUnitCreditCode, String equList,
+                                           String dataSource, boolean isDelete) {
+        List<IdxBizJgRegisterInfo> jgRegisterInfoList = registerInfoMapper.selectDeleteEquipIsNotClaimed(useUnitCreditCode, equList, dataSource );
+        List<String> records = Optional.ofNullable(jgRegisterInfoList)
+                .orElse(Collections.emptyList())
+                .stream()
+                .filter(Objects::nonNull)
+                .map(IdxBizJgRegisterInfo::getRecord)
+                .filter(Objects::nonNull)
+                .collect(Collectors.toList());
+        if (!records.isEmpty() && isDelete) {
+            superviseInfoMapper.deleteDataAll(records);
+            this.deleteFromEs(records);
+        }
+        return records.size();
+    }
 }

amos-boot-system-tzs/amos-boot-module-ymt/amos-boot-module-ymt-api/src/main/java/com/yeejoin/amos/boot/module/ymt/api/mapper/IdxBizJgRegisterInfoMapper.java

@@ -78,4 +78,8 @@ public interface IdxBizJgRegisterInfoMapper extends CustomBaseMapper<IdxBizJgReg
             "    AND (jri.car_number = CAST(#{carNumber} AS VARCHAR) OR CAST(#{carNumber} AS VARCHAR) IS NULL)\n" +
             "    AND (jri.use_org_code <> CAST(#{useOrgCode} AS VARCHAR) OR CAST(#{useOrgCode} AS VARCHAR) IS NULL)")
     Integer checkCarNumberUniqueness(@Param("carNumber") String carNumber, @Param("useOrgCode") String useOrgCode);
+
+    List<IdxBizJgRegisterInfo> selectDeleteEquipIsNotClaimed(@Param("useUnitCreditCode") String useUnitCreditCode,
+                                                             @Param("equList")String equList,
+                                                             @Param("dataSource")String dataSource);
 }

amos-boot-system-tzs/amos-boot-module-ymt/amos-boot-module-ymt-api/src/main/resources/mapper/IdxBizJgRegisterInfoMapper.xml

@@ -67,6 +67,16 @@
 			#{equCode}
 		</foreach>
 	</update>
+
+	<select id="selectDeleteEquipIsNotClaimed" resultType="com.yeejoin.amos.boot.module.ymt.api.entity.IdxBizJgRegisterInfo">
+		SELECT jri.RECORD
+		FROM idx_biz_jg_register_info jri
+		JOIN idx_biz_jg_use_info jui ON jri.record = jui.record
+		WHERE jui.STATUS = '待删除'
+		AND jri.EQU_LIST = #{equList}
+		AND jui.DATA_SOURCE = #{dataSource}
+		AND jui.USE_UNIT_CREDIT_CODE = #{useUnitCreditCode}
+    </select>
 </mapper>