合同：外贸、加工合同目的地历史数据处理

@@ -738,6 +738,74 @@ public class ContractDistributorStandardController extends DefaultBaseController
         return InvokeResultBuilder.success();
     }
 
+    @ApiOperation("历史数据目的地迁移")
+    @PostMapping("/migrateForeignDestination")
+    public InvokeResult<Integer> migrateForeignDestination() {
+        List<String> contractTypes = Arrays.asList(
+                "INTL_STD_CONTRACT",
+                "INTL_INVENTORY_AGMT",
+                "INTL_OPEN_SPEC_AGMT",
+                "PROCESS_STD_AGMT"
+        );
+        Wrapper<ContractDistributorStandard> wrapper = Wrappers.lambdaQuery(ContractDistributorStandard.class)
+                .in(ContractDistributorStandard::getType, contractTypes)
+                .and(w -> w.isNull(ContractDistributorStandard::getForeignDestination)
+                        .or()
+                        .eq(ContractDistributorStandard::getForeignDestination, ""))
+                .isNotNull(ContractDistributorStandard::getDestination)
+                .ne(ContractDistributorStandard::getDestination, "");
+        List<ContractDistributorStandard> contractList = contractDistributorStandardService.list(wrapper);
+        if (CollectionUtils.isEmpty(contractList)) {
+            return InvokeResultBuilder.success(0);
+        }
+
+        List<DicCityDto> allCity = dicCityService.getAll();
+        int updated = 0;
+        for (ContractDistributorStandard contract : contractList) {
+            if (contract == null || StringUtils.isBlank(contract.getId())) {
+                continue;
+            }
+            String destination = contract.getDestination();
+            if (StringUtils.isBlank(destination)) {
+                continue;
+            }
+            String foreignDestination = buildDestinationText(destination, allCity);
+            if (StringUtils.isBlank(foreignDestination)) {
+                continue;
+            }
+            Wrapper<ContractDistributorStandard> updateWrapper = Wrappers.lambdaUpdate(ContractDistributorStandard.class)
+                    .set(ContractDistributorStandard::getForeignDestination, foreignDestination)
+                    .eq(ContractDistributorStandard::getId, contract.getId());
+            if (contractDistributorStandardService.update(updateWrapper)) {
+                updated++;
+                contractDistributorStandardService.cleanCacheByKey(contract.getId());
+            }
+        }
+
+        return InvokeResultBuilder.success(updated);
+    }
+
+    private String buildDestinationText(String destination, List<DicCityDto> allCity) {
+        if (StringUtils.isBlank(destination) || CollectionUtils.isEmpty(allCity)) {
+            return "";
+        }
+        List<DicCityDto> fullPath = dicCityService.getFullPath(destination, allCity);
+        if (CollectionUtils.isEmpty(fullPath)) {
+            return "";
+        }
+        StringBuilder destinationBuilder = new StringBuilder();
+        for (DicCityDto cityDto : fullPath) {
+            if (cityDto == null || StringUtils.isBlank(cityDto.getName())) {
+                continue;
+            }
+            destinationBuilder.append(cityDto.getName()).append(",");
+        }
+        if (destinationBuilder.length() > 0) {
+            destinationBuilder.setLength(destinationBuilder.length() - 1);
+        }
+        return destinationBuilder.toString();
+    }
+
     /**
      * 标准合同模版打印
      */