库存件 数据更新BUG 修复

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: 清空缓存表

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<String, Object> paramMap = new HashMap<String, Object>();
-        sql.append("SELECT MAX(ifs_row_version) ifsRowVersion FROM part_catalog");
+        sql.append("SELECT MAX(ifs_row_version) ifsRowVersion FROM "+tableName);
         //查询结果集
         List<String> 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()));
     }

src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java

@@ -3523,9 +3523,10 @@ public class PartInformationServiceImpl extends ServiceImpl<PartInformationMappe
         // 获取连接
         Server srv = ifsServer.getIfsServer(ifsUsername, ifsPassword);
         BaseSearchData baseSearchData = new BaseSearchData();
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
-        String s = sdf.format(DateUtil.getAddDate(new Date(), -1));
-        baseSearchData.setIfsRowVersion(s);
+        //SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
+        String ifsRowVersion = partCatalogDao.getMaxIfsRowVersion("part");
+        //String s = sdf.format(DateUtil.getAddDate(new Date(), -1));
+        baseSearchData.setIfsRowVersion(ifsRowVersion);
         List<PartIfsInventory> ifsInventoryParts;
         try {
             ifsInventoryParts = baseSearchBean.getInventoryParts(srv, baseSearchData);

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);