后台导出车辆信息

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/BranchCompanyVehicleCountBiz.java

@@ -11,30 +11,18 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.Iterator;
-import java.util.List;
-
 @Service
 @Slf4j
 public class BranchCompanyVehicleCountBiz extends BaseBiz<BranchCompanyVehicleCountMapper, BranchCompanyVehicleCount> {
 	@Autowired
 	VehicleInformationDownloadBiz vehicleInformationDownloadBiz;
-	public ObjectRestResponse add(List<BranchCompanyVehicleCount> branchCompanyVehicleCounts) {
-		if (branchCompanyVehicleCounts == null) {
+	public ObjectRestResponse add(BranchCompanyVehicleCount branchCompanyVehicleCount) {
+		if (branchCompanyVehicleCount == null) {
 			return ObjectRestResponse.paramIsEmpty();
 		}
-		Iterator<BranchCompanyVehicleCount> iterator = branchCompanyVehicleCounts.iterator();
-		while (iterator.hasNext()) {
-			BranchCompanyVehicleCount newValue = iterator.next();
-			if(newValue != null) {
-				BranchCompanyVehicleCount oldValue = selectOne(newValue);
-				if (oldValue != null) {
-					iterator.remove();
-				}
-			}
-		}
-		if(branchCompanyVehicleCounts != null && branchCompanyVehicleCounts.size() > 0) {
-			insertMultiSelective(branchCompanyVehicleCounts);
+		BranchCompanyVehicleCount oldValue = selectOne(branchCompanyVehicleCount);
+		if (oldValue == null) {
+			insertSelectiveRe(branchCompanyVehicleCount);
 		}
 		return ObjectRestResponse.succ();
 	}

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleInformationDownloadBiz.java

@@ -109,7 +109,6 @@ public class VehicleInformationDownloadBiz extends BaseBiz<VehicleMapper, Vehicl
 
     @Scheduled(cron = "0 0 */2 * * *")
     public void add() {
-        ArrayList<BranchCompanyVehicleCount> arrayList = Lists.newArrayList();
         List<BranchCompanyVehicleCountVo> branchCompanyVehicleCountVos = vehicleBiz.getAllVehicleInfo();
         branchCompanyVehicleCountVos.parallelStream().forEach(result->{
             try {
@@ -119,12 +118,11 @@ public class VehicleInformationDownloadBiz extends BaseBiz<VehicleMapper, Vehicl
                 DateTime dateTime = DateTime.now();
                 String dateStr = dateTime.toString(DATE_TIME_FORMATTER);
                 branchCompanyVehicleCount.setCountDate(DateTime.parse(dateStr).toDate());
-                arrayList.add(branchCompanyVehicleCount);
+                branchCompanyVehicleCountBiz.add(branchCompanyVehicleCount);
             } catch (Exception e) {
                 log.error(e.getMessage(), e);
             }
         });
-        branchCompanyVehicleCountBiz.add(arrayList);
     }
 
 }