sap同步数据条数

DK.Service/SAPDataService/SAPDataLogic.cs

@@ -381,6 +381,7 @@ namespace Dongke.IBOSS.PRD.Service.SAPHegiiDataService
                         }
                     }
                     //:msg||chr(13)||DataMSG
+                    result.Zmsg = $"{result.Zmsg}({sapParameter.Zsum})";
                     sqlString = "update tsap_hegii_datalog t set t.EndTime = sysdate, DataStuts = :DataStuts, DataMSG =nvl2(:msg,:msg||' '||chr(13)||DataMSG,DataMSG) where logid = :logid";
                     oracleParameter = new OracleParameter[]
                     {
@@ -898,6 +899,7 @@ namespace Dongke.IBOSS.PRD.Service.SAPHegiiDataService
                         }
                     }
                     //:msg||chr(13)||DataMSG nvl2(:msg,:msg||chr(13)||DataMS,DataMS)
+                    result.Zmsg = $"{result.Zmsg}({sapParameter.Zsum})";
                     sqlString = "update tsap_hegii_datalog t set t.EndTime = sysdate, DataStuts = :DataStuts, DataMSG =:msg where logid = :logid";
                     oracleParameter = new OracleParameter[]
                     {
@@ -1134,14 +1136,16 @@ namespace Dongke.IBOSS.PRD.Service.SAPHegiiDataService
                 foreach (Zppfm010 sapParameter in sapParameterList)
                 {
                     ZPPFM010Response result = HGSAPDK_ZPPFM010(sapParameter, yyyymmdd);
-                    sre.Message = result.ZMSG;
+                    //sre.Message = result.ZMSG;
+                    sre.Message = $"{result.ZMSG}({sapParameter.ZSUM})";
                     sre.Result = result.ZTYPE;
 
                     sqlString = "update tsap_hegii_datalog t set t.EndTime = sysdate, DataStuts = :DataStuts, DataMSG =:msg where logid = :logid";
                     oracleParameter = new OracleParameter[]
                     {
                         new OracleParameter(":DataStuts",OracleDbType.Varchar2, result.ZTYPE, ParameterDirection.Input),
-                        new OracleParameter(":msg",OracleDbType.Varchar2, result.ZMSG, ParameterDirection.Input),
+                        //new OracleParameter(":msg",OracleDbType.Varchar2, result.ZMSG, ParameterDirection.Input),
+                        new OracleParameter(":msg",OracleDbType.Varchar2, sre.Message, ParameterDirection.Input),
                         new OracleParameter(":logid",OracleDbType.Int32, logid, ParameterDirection.Input),
                     };
                     r = oracleConn.ExecuteNonQuery(sqlString, oracleParameter);