一码通数据初始化同步至es修改

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

@@ -24,4 +24,7 @@ public interface SuperviseInfoMapper extends BaseMapper<SuperviseInfo> {
 	void deleteDataAll(@Param("records") List<String> records);
 
 	EsElevator selectElevatorEsList(String record);
+
+
+	void updateEsRecordBatch(@Param("recordList") List<String> recordList);
 }

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

@@ -9,6 +9,13 @@
         </foreach>
     </update>
 
+    <update id="updateEsRecordBatch">
+        UPDATE idx_biz_jg_use_info SET "IS_NOT_ES" = 1 WHERE "RECORD" IN
+        <foreach collection="recordList" separator="," item="record" open="(" close=")">
+            #{record}
+        </foreach>
+    </update>
+
     <select id="selectUnitCodeList" resultType="java.util.Map">
         SELECT
             ui."USE_UNIT_CREDIT_CODE" unitCode,

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

@@ -1808,7 +1808,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
         System.out.println("批量存入es1000条数据耗时：" + cost);
 
         long start1 = System.currentTimeMillis();
-        superviseInfoMapper.updateRecordBatch(recordList);
+        superviseInfoMapper.updateEsRecordBatch(recordList);
         long end1 = System.currentTimeMillis();
         long cost1 = end1 - start1;
         System.out.println("批量更新1000条业务数据耗时：" + cost1);