Merge remote-tracking branch 'origin/developer' into developer

amos-boot-system-tzs/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/api/service/ICylinderFillingRecordService.java

@@ -4,6 +4,8 @@ package com.yeejoin.amos.boot.module.tzs.flc.api.service;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.module.tzs.api.entity.ESCylinderFillingRecordDto;
 
+import java.util.List;
+
 /**
  * 液化气体气瓶充装信息-充装记录接口类
  *
@@ -17,4 +19,6 @@ public interface ICylinderFillingRecordService {
     Page<ESCylinderFillingRecordDto> getCyinderFillingRecord(Page<ESCylinderFillingRecordDto> cylinderFillingRecordDto);
 
     Page<ESCylinderFillingRecordDto> queryByKeys(ESCylinderFillingRecordDto esCylinderFillingRecordDto, int pageNum, int pageSize);
+
+    void saveCylinderFillingRecord2ES(List<ESCylinderFillingRecordDto> records);
 }

amos-boot-system-tzs/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/api/service/ICylinderInfoService.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.module.tzs.api.entity.ESCylinderInfoDto;
 import com.yeejoin.amos.boot.module.tzs.flc.api.dto.CylinderInfoDto;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -49,4 +50,6 @@ public interface ICylinderInfoService {
 	ESCylinderInfoDto saveCylinderInfoToES(CylinderInfoDto ci);
 
     Page<ESCylinderInfoDto> queryByKeys(CylinderInfoDto cylinderInfoDto, int pageNum, int pageSize);
+
+    void saveCylinderInfo2ES(List<CylinderInfoDto> records);
 }

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/biz/controller/CylinderInfoController.java

@@ -581,9 +581,12 @@ public class CylinderInfoController extends BaseController {
             cylinderInfoPage.setCurrent(i);
             cylinderInfoPage.setSize(1000);
             cylinderInfoPage = cylinderInfoServiceImpl.getCyinderInfoList(cylinderInfoPage);
-            for (CylinderInfoDto ci : cylinderInfoPage.getRecords()) {
-                cylinderInfoServiceImpl.saveCylinderInfoToES(ci);
-            }
+			if(!ObjectUtils.isEmpty(cylinderInfoPage)){
+				cylinderInfoServiceImpl.saveCylinderInfo2ES(cylinderInfoPage.getRecords());
+			}
+//            for (CylinderInfoDto ci : cylinderInfoPage.getRecords()) {
+//                cylinderInfoServiceImpl.saveCylinderInfoToES(ci);
+//            }
         }
     }
 
@@ -655,9 +658,12 @@ public class CylinderInfoController extends BaseController {
 //				cylinderFillingRecordDto.setAppId("9B150BB7D0C21A7A62BD6837E14A44BF");
 //			}
             Page<ESCylinderFillingRecordDto> cyinderFillingRecord = cylinderFillingRecordServiceImpl.getCyinderFillingRecord(recordDtoPage);
-            for (ESCylinderFillingRecordDto ci : cyinderFillingRecord.getRecords()) {
-                cylinderFillingRecordServiceImpl.saveCylinderFillingRecordToES(ci);
-            }
+			if(!ObjectUtils.isEmpty(cyinderFillingRecord)){
+				cylinderFillingRecordServiceImpl.saveCylinderFillingRecord2ES(cyinderFillingRecord.getRecords());
+			}
+//            for (ESCylinderFillingRecordDto ci : cyinderFillingRecord.getRecords()) {
+//                cylinderFillingRecordServiceImpl.saveCylinderFillingRecordToES(ci);
+//            }
         }
     }
 

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

@@ -25,6 +25,7 @@ import org.elasticsearch.client.RestHighLevelClient;
 import org.elasticsearch.index.query.BoolQueryBuilder;
 import org.elasticsearch.index.query.QueryBuilders;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -33,6 +34,7 @@ import org.springframework.util.ObjectUtils;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 
 import java.io.IOException;
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.LinkedList;
 import java.util.List;
@@ -159,8 +161,11 @@ public class CylinderFillingRecordServiceImpl extends BaseService<CylinderFillin
                     return item;
                 }).collect(Collectors.toList());
             }
-            for (ESCylinderFillingRecordDto ci : cylinderFillingRecordPage.getRecords()) {
-                saveCylinderFillingRecordToES(ci);
+//            for (ESCylinderFillingRecordDto ci : cylinderFillingRecordPage.getRecords()) {
+//                saveCylinderFillingRecordToES(ci);
+//            }
+            if(!ObjectUtils.isEmpty(cylinderFillingRecordPage)){
+                saveCylinderFillingRecord2ES(cylinderFillingRecordPage.getRecords());
             }
         }
     }
@@ -353,6 +358,20 @@ public class CylinderFillingRecordServiceImpl extends BaseService<CylinderFillin
     }
 
     @Override
+    public void saveCylinderFillingRecord2ES(List<ESCylinderFillingRecordDto> records) {
+        List<CylinderFillingRecord> cylinderFillingRecordList = new ArrayList<>();
+        for (ESCylinderFillingRecordDto record : records) {
+            CylinderFillingRecord cylinderFillingRecord = new CylinderFillingRecord();
+            BeanUtils.copyProperties(record,cylinderFillingRecord);
+            cylinderFillingRecord.setIsNotEs("1");
+            cylinderFillingRecord.setSequenceNbr(record.getSequenceNbr());
+            cylinderFillingRecordList.add(cylinderFillingRecord);
+        }
+        esCylinderFillingRecordRepository.saveAll(records);
+        this.saveOrUpdateBatch(cylinderFillingRecordList);
+    }
+
+    @Override
     public ESCylinderFillingRecordDto saveCylinderFillingRecordToES(ESCylinderFillingRecordDto ci) {
 
         ESCylinderFillingRecordDto recordDto = esCylinderFillingRecordRepository.save(ci);

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

@@ -706,16 +706,37 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind
 			}
 		}
 		for (int i = 0; i <= times; i++) {
-			cylinderInfoPage.setCurrent(i);
+			cylinderInfoPage.setCurrent(1);
 			cylinderInfoPage.setSize(1000);
 			cylinderInfoPage = cylinderInfoMapper.getCyinderInfoList(cylinderInfoPage);
-			for (CylinderInfoDto ci : cylinderInfoPage.getRecords()) {
-				saveCylinderInfoToES(ci);
+			if(!ObjectUtils.isEmpty(cylinderInfoPage)){
+				saveCylinderInfo2ES(cylinderInfoPage.getRecords());
 			}
+//			for (CylinderInfoDto ci : cylinderInfoPage.getRecords()) {
+//				saveCylinderInfoToES(ci);
+//			}
 		}
 	}
 
 	@Override
+	public void saveCylinderInfo2ES(List<CylinderInfoDto> records) {
+		List<ESCylinderInfoDto> esCylinderInfoDto = new ArrayList<>();
+		List<CylinderInfo> CylinderInfoList = new ArrayList<>();
+		for (CylinderInfoDto record : records) {
+			ESCylinderInfoDto esCylinderInfo = new ESCylinderInfoDto();
+			BeanUtils.copyProperties(record,esCylinderInfo);
+			esCylinderInfoDto.add(esCylinderInfo);
+			CylinderInfo cylinderInfo = new CylinderInfo();
+			BeanUtils.copyProperties(record,cylinderInfo);
+			cylinderInfo.setSequenceNbr(record.getSequenceNbr());
+			cylinderInfo.setIsNotEs("1");
+			CylinderInfoList.add(cylinderInfo);
+		}
+		esCylinderInfoRepository.saveAll(esCylinderInfoDto);
+		this.saveOrUpdateBatch(CylinderInfoList);
+	}
+
+	@Override
 	public ESCylinderInfoDto saveCylinderInfoToES(CylinderInfoDto ci) {
 		ESCylinderInfoDto esCylinderInfoDto = new ESCylinderInfoDto();
 		BeanUtils.copyProperties(ci,esCylinderInfoDto);