diff --git a/src/main/java/com/spring/modules/part/dao/PartCatalogDao.java b/src/main/java/com/spring/modules/part/dao/PartCatalogDao.java index 7da72eb6..219989b0 100644 --- a/src/main/java/com/spring/modules/part/dao/PartCatalogDao.java +++ b/src/main/java/com/spring/modules/part/dao/PartCatalogDao.java @@ -20,7 +20,7 @@ public interface PartCatalogDao { * @date 2024/9/23 10:27 * @version 1.0 */ - String getMaxIfsRowVersion(); + String getMaxIfsRowVersion(String tableName); /** * @description: 清空缓存表 diff --git a/src/main/java/com/spring/modules/part/dao/impl/PartCatalogDaoImpl.java b/src/main/java/com/spring/modules/part/dao/impl/PartCatalogDaoImpl.java index 221806b3..b2b95ad2 100644 --- a/src/main/java/com/spring/modules/part/dao/impl/PartCatalogDaoImpl.java +++ b/src/main/java/com/spring/modules/part/dao/impl/PartCatalogDaoImpl.java @@ -26,10 +26,10 @@ public class PartCatalogDaoImpl implements PartCatalogDao { private NamedParameterJdbcTemplate parameterJdbcTemplate; @Override - public String getMaxIfsRowVersion() { + public String getMaxIfsRowVersion(String tableName) { StringBuilder sql = new StringBuilder(); Map paramMap = new HashMap(); - sql.append("SELECT MAX(ifs_row_version) ifsRowVersion FROM part_catalog"); + sql.append("SELECT MAX(ifs_row_version) ifsRowVersion FROM "+tableName); //查询结果集 List resultList = parameterJdbcTemplate.query(sql.toString(), paramMap, (rs, rowNum) -> rs.getString("ifsRowVersion")); //判断结果集 @@ -78,7 +78,7 @@ public class PartCatalogDaoImpl implements PartCatalogDao { sql.append(" VALUES "); sql.append(" (:contract, :partNo, :partDesc, :typeCode, :partProductFamily, :partProductCode, :unitMeas, 'Y', :noteText, :primeCommodity, :SecondCommodity, :accountingGroup, :plannerBuyer, "); sql.append(" :engAttribute, 'Y', :typeDesignation, :hazardCode, :assetClass, :dimQuality, :abcClass, :frequencyClass, :LifecycleStage, "); - sql.append(" :countryOfOrigin, :manufLeadtime, :expectedLeadtime, :regionOfOrigin, :durabilityDay, :partStatus, :createDate,"); //添加创建时间字段 + sql.append(" :countryOfOrigin, :manufLeadtime, :expectedLeadtime, :regionOfOrigin, :durabilityDay, :partStatus, :createdDate,"); //添加创建时间字段 sql.append(" '*', :inventoryValuationMethod, :partCostGroupId, :inventoryPartCostLevel, :invoiceConsideration, :zeroCostFlag, 'Y' )"); parameterJdbcTemplate.batchUpdate(sql.toString(), SqlParameterSourceUtils.createBatch(ifsInventoryParts.toArray())); } diff --git a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java index 1eda19c3..b91b2210 100644 --- a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java +++ b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java @@ -3523,9 +3523,10 @@ public class PartInformationServiceImpl extends ServiceImpl ifsInventoryParts; try { ifsInventoryParts = baseSearchBean.getInventoryParts(srv, baseSearchData); diff --git a/src/main/java/com/spring/modules/part/service/impl/PartServiceImpl.java b/src/main/java/com/spring/modules/part/service/impl/PartServiceImpl.java index daf23855..647ae200 100644 --- a/src/main/java/com/spring/modules/part/service/impl/PartServiceImpl.java +++ b/src/main/java/com/spring/modules/part/service/impl/PartServiceImpl.java @@ -43,7 +43,7 @@ public class PartServiceImpl implements PartService { @Override public void syncPartCatalogToPlm() { //查询最大的版本号 - String ifsRowVersion = partCatalogDao.getMaxIfsRowVersion(); + String ifsRowVersion = partCatalogDao.getMaxIfsRowVersion("part_catalog"); PartInformationEntity searchData = new PartInformationEntity(); searchData.setIfsRowVersion(ifsRowVersion);