SampleClosingProcess表yangpinsqslhi字段没值问题

src/main/java/com/huazheng/project/greenplum/service/impl/DeleteUpdateJobServiceImpl.java

@@ -49,6 +49,7 @@ import cn.hutool.core.thread.ThreadUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
 import cn.hutool.json.JSONUtil;
+import cn.hutool.core.util.NumberUtil;
 import lombok.extern.log4j.Log4j2;
 
 @Log4j2
@@ -1487,6 +1488,10 @@ public class DeleteUpdateJobServiceImpl {
 						source.setHashResult(shash);
 						while (true) {
 							try {
+								if (NumberUtil.isNumber(source.getYangPinSQSLH())) { 
+									int yangPinSQSLHi = Integer.parseInt(source.getYangPinSQSLH());
+									source.setYangPinSQSLHi(yangPinSQSLHi); 
+									}
 								gpMapper.updateSampleClosingProcess(source); // 更新数据到数仓中
 								break;
 							} catch (RuntimeException e) {

src/main/java/com/huazheng/project/mssql/model/SampleClosingProcess.java

@@ -29,7 +29,7 @@ public class SampleClosingProcess implements Serializable {
 	private Integer sYS_INCIDENT    ; // 流程编号
 	private String yangPinSQSLH    ; // 样品申请实例号
 	
-	private Integer yangPinSQSLHi; // 不从源库种读取，处理过程中转换
+	private Integer yangPinSQSLHi;
 	private Integer sYS_INCSTATUS; 
 	
 	@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") // 页面写入数据库时格式化

src/main/resources/mapper/mssql/CrmMapper_mssql.xml

@@ -34,7 +34,10 @@
     </select>
     <select id="selectSampleClosingProcessNew" parameterType="SampleClosingProcess" resultType="SampleClosingProcess">
 		select top 20 
-			id,sYS_INCIDENT,yangPinSQSLH,sYS_INCSTATUS,sys_updatetime,sys_starttime
+			id,sYS_INCIDENT,yangPinSQSLH,sYS_INCSTATUS,sys_updatetime,sys_starttime, CASE
+			 WHEN yangPinSQSLH = '' THEN null 
+			 ELSE yangPinSQSLH
+			 END AS yangPinSQSLH1
 		from "Biz_样品结案流程"
 		where id &gt; #{id}
     </select>
@@ -100,7 +103,10 @@
     </select>
     <select id="selectSampleClosingProcessCheckByUpdate" parameterType="SampleClosingProcess" resultType="SampleClosingProcess">
     	select top 20 
-			id,sYS_INCIDENT,yangPinSQSLH,sYS_INCSTATUS,sys_updatetime,sys_starttime
+			id,sYS_INCIDENT,yangPinSQSLH,sYS_INCSTATUS,sys_updatetime,sys_starttime, CASE
+			 WHEN yangPinSQSLH = '' THEN null 
+			 ELSE yangPinSQSLH
+			 END AS yangPinSQSLH1
 		from "Biz_样品结案流程"
 		where id &gt; #{id} 
 			and sys_updatetime is not null and CONVERT(varchar(10),sys_updatetime,120) = CONVERT(varchar(10),GETDATE(),120)
@@ -159,7 +165,10 @@
     	where id = #{id}
     </select>
     <select id="selectSampleClosingProcessById" parameterType="SampleClosingProcess" resultType="SampleClosingProcess">
-    	select id,sYS_INCIDENT,yangPinSQSLH,sYS_INCSTATUS,sys_updatetime,sys_starttime
+    	select id,sYS_INCIDENT,yangPinSQSLH,sYS_INCSTATUS,sys_updatetime,sys_starttime, CASE
+		 WHEN yangPinSQSLH = '' THEN null 
+		 ELSE yangPinSQSLH
+		 END AS yangPinSQSLH1
     	from "Biz_样品结案流程" 
     	where id = #{id}
     </select>