HEGII.ss.mes.wcf/DK.Service/SAPDataService/SAPDataLogicPartial.cs


using System;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Linq;
using System.Net;
using System.Reflection;
using System.Text;

using Dongke.IBOSS.PRD.Basics.BaseResources;
using Dongke.IBOSS.PRD.Basics.DataAccess;
using Dongke.IBOSS.PRD.Basics.Library;
using Dongke.IBOSS.PRD.Service.BPMDataService;
using Dongke.IBOSS.PRD.Service.DataModels;
using Dongke.IBOSS.PRD.WCF.DataModels;

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

using Oracle.ManagedDataAccess.Client;

namespace Dongke.IBOSS.PRD.Service.SAPHegiiDataService
{
	public partial class SAPDataLogic
	{
		#region 跨车间作业
		/// <summary>
		/// 同步SAP数据（自动）
		/// </summary>
		/// <param name="date"></param>
		public static void CrossWorkshopToSAP(DateTime date, DateTime ndate)
		{
			IDBTransaction oracleConn = null;
			ServiceResultEntity sre = new ServiceResultEntity();
			OracleParameter[] paras = null;
			int logid = 0;
			string message = string.Empty;
			string sqlString = string.Empty;
			try
			{
				#region 生成日志
				paras = new OracleParameter[]
				{
					new OracleParameter("in_dateend", OracleDbType.Date, ndate, ParameterDirection.Input),
					new OracleParameter("out_logid", OracleDbType.Int32, null, ParameterDirection.Output),
					new OracleParameter("out_msg", OracleDbType.NVarchar2, 500, null, ParameterDirection.Output)
				};

				oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
				DataSet ds = oracleConn.ExecStoredProcedure("pro_sap_hegii_workdata_kcjzy", paras);
				int.TryParse(paras[1].Value + "", out logid);
				message = paras[2].Value + "";
				oracleConn.Commit();
				#endregion

				#region 同步SAP
				// 手动推
				//logid = 28;

				oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);

				sqlString = @"
                SELECT TO_CHAR(B.EXECUTEDATEBEGIN, 'yyyymmddhh24miss') AS ZYWKS,
                       TO_CHAR(B.EXECUTEDATEEND - 1 / 24 / 60 / 60, 'yyyymmddhh24miss') AS ZYWJS,
                       TO_CHAR(SYSDATE, 'yyyymmddhh24miss') AS ZMONT,
                       A.WORKCODE AS WERKS,
                       A.SAPCODE AS MATNR,
                       A.GOODSCODE AS GROES,
                       A.WORKSHOP AS ZSCCJ,
                       A.WORKSHOP AS ZSSCJ,
                       A.DATACODE AS ZJDNU,
                       A.ITEM AS ZZYLX,
                       A.NUM AS MENGE,
                       'T' AS ZSCS,
                       CASE WHEN A.TESTMOULDFLAG = 1 THEN 'Y' ELSE 'C' END AS ZSCMS,
                       '' AS ZTYPE1,
                       '' AS ZMSG1
                  FROM TSAP_HEGII_WORKDATA_KCJZY A
                 INNER JOIN TSAP_HEGII_DATALOG_KCJZY B
                    ON B.LOGID = A.LOGID
                 WHERE A.LOGID = :LOGID ";

				paras = new OracleParameter[]
				{
					new OracleParameter(":LOGID", OracleDbType.Int32, logid, ParameterDirection.Input),
				};
				DataTable workData = oracleConn.GetSqlResultToDt(sqlString, paras);

				sqlString = "select SAP_INI_BG from TP_SYS_SAPCONFIG";
				string SAP_ING_NEW = oracleConn.GetSqlResultToStr(sqlString);

				if (workData != null && workData.Rows.Count > 0 && SAP_ING_NEW == "1")
				{
					string postString = "{\"IT_INPUT\":{\"item\":" + JsonHelper.ToJson(ModelConvertHelper<CrossWorkShopToSAP>.ConvertToModel(workData)) + "}}";

					// 配置文件
					INIUtility ini = INIUtility.Instance(INIUtility.IniFile.SAP_HEGII);
					string url033 = ini.ReadIniData("SAP_NEW_INFO", "Url033");

					// 测试
					//string url033 = "http://hgs4podev.hegii.com:50200/RESTAdapter/DKMES/ZPPFM033";

					// 正式
					//string url033 = "http://hgs4powd1.hegii.com:8000/RESTAdapter/DKMES/ZPPFM033";

					string result = PostData(url033, postString, "POST");
					string ztype = JObject.Parse(result)["ZTYPE"].ToString();
					string msg = JObject.Parse(result)["ZMSG"].ToString();
					sqlString = "update TSAP_HEGII_DATALOG_KCJZY t set t.EndTime = sysdate, DataStuts = :DataStuts, DataMSG =:msg where logid = :logid";
					paras = new OracleParameter[]
					{
						new OracleParameter(":logid", OracleDbType.Varchar2, logid, ParameterDirection.Input),
						new OracleParameter(":DataStuts", OracleDbType.Varchar2, ztype, ParameterDirection.Input),
						new OracleParameter(":msg", OracleDbType.Varchar2, msg, ParameterDirection.Input),
					};
					oracleConn.ExecuteNonQuery(sqlString, paras);
					oracleConn.Commit();
				}
				#endregion
			}
			catch (Exception ex)
			{
				OutputLog.TraceLog(LogPriority.Error,
						"CrossWorkshopToSAP",
						"跨车间作业量" + date.ToString("yyyy-MM-dd HH:mm:ss"),
						ex.ToString(),
						LocalPath.LogExePath + "SAP_HEGII\\Error_");
			}
		}

		public static void CrossWorkshopToSAP_test(DateTime date, DateTime ndate)
		{
			IDBTransaction oracleConn = null;
			ServiceResultEntity sre = new ServiceResultEntity();
			int logid = 0;
			string message = string.Empty;
			string sqlString = string.Empty;
			try
			{
				#region 同步SAP
				oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
				//sqlString = "select workcode from tp_mst_account where rownum = 1";
				//string workcode = oracleConn.GetSqlResultToStr(sqlString);
				//workcode = "5000";
				sqlString = @"SELECT
                    to_char(:v_datebegin, 'yyyymmddhh24miss') AS ZYWKS,
                    to_char(:in_dateend, 'yyyymmddhh24miss') AS ZYWJS,
                    to_char(SYSDATE,'yyyymmddhh24miss') AS ZMONT,
					'5000' AS WERKS,
                    MATERIALCODE AS MATNR,
					GOODSCODE AS GROES,
					to_char(WORKSHOP) AS ZSCCJ,
					to_char(DATACODE) AS ZJDNU,
                    to_char(ITEM)  AS ZZYLX,
                    to_char(count( * )) AS MENGE,
                    'T' AS ZSCS,
					 CASE WHEN TESTMOULDFLAG = 1 THEN 'Y' ELSE 'C' END AS ZSCMS,
				    '' AS ZTYPE1,
                    '' AS ZMSG1
                FROM
                    (--产量

                            SELECT

                                GDD.MATERIALCODE,
                                gdd.goodscode,
                                HGDI.WORKSHOP,
                                HGDI.DATACODE,
                                1 AS ITEM,
                                GDD.TESTMOULDFLAG,
                              G.GOODS_LINE_CODE AS ZSCS

                            FROM

                                TP_PM_PRODUCTIONDATA PD

                                INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD.GROUTINGDAILYDETAILID

                                INNER JOIN TP_MST_GOODS G ON PD.GOODSID = G.GOODSID

                                INNER JOIN TP_MST_GOODSTYPE GT ON GT.GOODSTYPEID = G.GOODSTYPEID

                                INNER JOIN TSAP_HEGII_DATAITEM HGDI ON(HGDI.DATACODE = '30' OR HGDI.DATACODE = '40' OR HGDI.DATACODE = '50')

                                AND HGDI.ITEMTYPE = 1

                                AND HGDI.ITEMID = PD.PROCEDUREID

                                AND(HGDI.ITEMID <> 104 OR(PD.ISREFIRE = '0' AND PD.CHECKFLAG = '1'))

                            WHERE

                                PD.VALUEFLAG = 1

                                AND PD.CREATETIME >= :v_datebegin

                                AND PD.CREATETIME < :in_dateend

                                AND(
                                    (HGDI.WORKSHOP = 2 AND INSTR(GDD.GROUTINGLINECODE, 'C') = 1)

                                    OR(
                                        HGDI.WORKSHOP = 3

                                        AND(INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1)
                                    )
                                )

                                AND INSTR(GT.GOODSTYPECODE, '001001' ) = 1

                        UNION ALL

                          --产量撤销

                            SELECT

                                GDD.MATERIALCODE,
								GDD.goodscode,
								HGDI.WORKSHOP,
								HGDI.DATACODE AS DATACODE,
								2 AS ITEM,
                                GDD.TESTMOULDFLAG,
								G.GOODS_LINE_CODE AS ZSCS
                            FROM

                                TP_PM_PRODUCTIONDATA PD

                                INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD.GROUTINGDAILYDETAILID

                                INNER JOIN TP_MST_GOODS G ON PD.GOODSID = G.GOODSID

                                INNER JOIN TP_MST_GOODSTYPE GT ON GT.GOODSTYPEID = G.GOODSTYPEID

                                INNER JOIN TSAP_HEGII_DATAITEM HGDI ON(HGDI.DATACODE = '30' OR HGDI.DATACODE = '40' OR HGDI.DATACODE = '50')

                                AND HGDI.ITEMID = PD.PROCEDUREID

                                AND(HGDI.ITEMID <> 104 OR(PD.ISREFIRE = '0' AND PD.CHECKFLAG = '1'))

                            WHERE

                                PD.VALUEFLAG = 0

                                AND PD.BACKOUTTIME >= :v_datebegin

                                AND PD.BACKOUTTIME < :in_dateend

                                AND(
                                    (HGDI.WORKSHOP = 2 AND INSTR(GDD.GROUTINGLINECODE, 'C') = 1)

                                    OR(
                                        HGDI.WORKSHOP = 3

                                        AND(INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1)
                                    )
								) 
								AND INSTR(GT.GOODSTYPECODE, '001001' ) = 1-- 工序报损
                          UNION ALL
                          SELECT

                                GDD.MATERIALCODE,
								GDD.goodscode,
								HGDI.WORKSHOP,
								HGDI.DATACODE AS DATACODE,
								3 AS ITEM,
                                GDD.TESTMOULDFLAG,
							  G.GOODS_LINE_CODE AS ZSCS
                            FROM

                                TP_PM_SCRAPPRODUCT SP

                                INNER JOIN tp_pm_productiondata pd ON pd.productiondataid = sp.productiondataid

                                INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD.GROUTINGDAILYDETAILID

                                INNER JOIN TP_MST_GOODS G ON PD.GOODSID = G.GOODSID

                                INNER JOIN TP_MST_GOODSTYPE GT ON GT.GOODSTYPEID = G.GOODSTYPEID

                                INNER JOIN TSAP_HEGII_DATAITEM HGDI ON(HGDI.DATACODE = '30' OR HGDI.DATACODE = '40' OR HGDI.DATACODE = '50')

                                AND HGDI.ITEMTYPE = 2

                                AND HGDI.ITEMID = PD.PROCEDUREID

                                AND(HGDI.ITEMID <> 104 OR(PD.ISREFIRE = '0' AND PD.CHECKFLAG = '1'))

                            WHERE

                                SP.AUDITSTATUS = 1

                                AND SP.AUDITDATE >= :v_datebegin

                                AND SP.AUDITDATE < :in_dateend

                                AND(
                                    (HGDI.WORKSHOP = 2 AND INSTR(GDD.GROUTINGLINECODE, 'C') = 1)

                                    OR(
                                        HGDI.WORKSHOP = 3

                                        AND(INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1)
                                    )
								) 
								AND INSTR(GT.GOODSTYPECODE, '001001' ) = 1-- 工序报损撤销
                          UNION ALL
                          SELECT

                                GDD.MATERIALCODE,
								GDD.goodscode,
								HGDI.WORKSHOP,
								HGDI.DATACODE AS DATACODE,
								4 AS ITEM,
                                GDD.TESTMOULDFLAG,
							  G.GOODS_LINE_CODE AS ZSCS
                            FROM

                                TP_PM_SCRAPPRODUCT SP

                                INNER JOIN tp_pm_productiondata pd ON pd.productiondataid = sp.productiondataid

                                INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD.GROUTINGDAILYDETAILID

                                INNER JOIN TP_MST_GOODS G ON PD.GOODSID = G.GOODSID

                                INNER JOIN TP_MST_GOODSTYPE GT ON GT.GOODSTYPEID = G.GOODSTYPEID

                                INNER JOIN TSAP_HEGII_DATAITEM HGDI ON(HGDI.DATACODE = '30' OR HGDI.DATACODE = '40' OR HGDI.DATACODE = '50')

                                AND HGDI.ITEMTYPE = 2

                                AND HGDI.ITEMID = PD.PROCEDUREID

                                AND(HGDI.ITEMID <> 104 OR(PD.ISREFIRE = '0' AND PD.CHECKFLAG = '1'))

                            WHERE

                                SP.AUDITSTATUS = 1

                                AND SP.VALUEFLAG = '0'

                                AND SP.BACKOUTTIME >= :v_datebegin

                                AND SP.BACKOUTTIME < :in_dateend

                                AND(
                                    (HGDI.WORKSHOP = 2 AND INSTR(GDD.GROUTINGLINECODE, 'C') = 1)

                                    OR(
                                        HGDI.WORKSHOP = 3

                                        AND(INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1)
                                    )
								) 
								AND INSTR(GT.GOODSTYPECODE, '001001' ) = 1-- 盘点清除
                          UNION ALL
                          SELECT

                                GDD.MATERIALCODE,
								GDD.GOODSCODE,
								HGDI.WORKSHOP,
								HGDI.DATACODE,
								5 AS ITEM,
                                GDD.TESTMOULDFLAG ,
								G.GOODS_LINE_CODE AS ZSCS
                            FROM

                                TP_PM_GOODSCHANGEHISTORY GH

                                INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = GH.GROUTINGDAILYDETAILID

                                INNER JOIN TP_MST_GOODS G ON GH.GOODSID = G.GOODSID

                                INNER JOIN TP_MST_GOODSTYPE GT ON GT.GOODSTYPEID = G.GOODSTYPEID

                                INNER JOIN TSAP_HEGII_DATAITEM HGDI ON(HGDI.DATACODE = '30' OR HGDI.DATACODE = '40' OR HGDI.DATACODE = '50')

                                AND HGDI.ITEMTYPE = 2

                                AND HGDI.ITEMID = GH.OTHERID

                            WHERE

                                GH.CREATETIME >= :v_datebegin

                                AND GH.CREATETIME < :in_dateend

                                AND GH.DATATYPE IN( 11, 12 ) 
								AND(
                                    (HGDI.WORKSHOP = 2 AND INSTR(GDD.GROUTINGLINECODE, 'C') = 1)

                                    OR(
                                        HGDI.WORKSHOP = 3

                                        AND(INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1)
                                    )
								) 
								AND INSTR(GT.GOODSTYPECODE, '001001' ) = 1-- 干补
                          UNION ALL
                          SELECT

                                GDD.MATERIALCODE,
								GDD.GOODSCODE,
								HGDI.WORKSHOP,
								HGDI.DATACODE,
								6 AS ITEM,
                                GDD.TESTMOULDFLAG,
							  G.GOODS_LINE_CODE AS ZSCS
                            FROM

                                TP_PM_SCRAPPRODUCT SP

                                INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = SP.GROUTINGDAILYDETAILID

                                INNER JOIN TP_MST_GOODS G ON SP.GOODSID = G.GOODSID

                                INNER JOIN TP_MST_GOODSTYPE GT ON GT.GOODSTYPEID = G.GOODSTYPEID

                                INNER JOIN TSAP_HEGII_DATAITEM HGDI ON(HGDI.DATACODE = '30' OR HGDI.DATACODE = '40' OR HGDI.DATACODE = '50')

                                AND HGDI.ITEMTYPE = 2

                                AND HGDI.ITEMID = SP.PROCEDUREID

                            WHERE

                                SP.AUDITSTATUS = 1

                                AND SP.VALUEFLAG = '1'

                                AND SP.GOODSLEVELTYPEID = 9

                                AND SP.SPECIALREPAIRTIME >= :v_datebegin

                                AND SP.SPECIALREPAIRTIME < :in_dateend

                                AND(
                                    (HGDI.WORKSHOP = 2 AND INSTR(GDD.GROUTINGLINECODE, 'C') = 1)

                                    OR(
                                        HGDI.WORKSHOP = 3

                                        AND(INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1)
                                    )
								) 
								AND INSTR(GT.GOODSTYPECODE, '001001' ) = 1-- 回收
                          UNION ALL
                          SELECT

                                GDD.MATERIALCODE,
								GDD.GOODSCODE,
								HGDI.WORKSHOP,
								HGDI.DATACODE,
								7 AS ITEM,
                                GDD.TESTMOULDFLAG,
							  G.GOODS_LINE_CODE AS ZSCS
                            FROM

                                TP_PM_SCRAPPRODUCT SP

                                INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = SP.GROUTINGDAILYDETAILID

                                INNER JOIN TP_MST_GOODS G ON SP.GOODSID = G.GOODSID

                                INNER JOIN TP_MST_GOODSTYPE GT ON GT.GOODSTYPEID = G.GOODSTYPEID

                                INNER JOIN TSAP_HEGII_DATAITEM HGDI ON(HGDI.DATACODE = '30' OR HGDI.DATACODE = '40' OR HGDI.DATACODE = '50')

                                AND HGDI.ITEMTYPE = 2

                                AND HGDI.ITEMID = SP.PROCEDUREID

                            WHERE

                                SP.AUDITSTATUS = 1

                                AND SP.VALUEFLAG = '1'

                                AND SP.RECYCLINGFLAG = '1'

                                AND SP.RECYCLINGTIME >= :v_datebegin

                                AND SP.RECYCLINGTIME < :in_dateend

                                AND(
                                    (HGDI.WORKSHOP = 2 AND INSTR(GDD.GROUTINGLINECODE, 'C') = 1)

                                    OR(
                                        HGDI.WORKSHOP = 3

                                        AND(INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1)
                                    )
								) 
								AND INSTR(GT.GOODSTYPECODE, '001001' ) = 1
							) 
						GROUP BY

                            MATERIALCODE,
							GOODSCODE,
							WORKSHOP,
							DATACODE,
							ITEM,
							TESTMOULDFLAG,
							ZSCS
                        ORDER BY
                            DATACODE,
                            ITEM,
                            WORKSHOP";
				OracleParameter[] paras = new OracleParameter[]
				{
					new OracleParameter(":v_datebegin", OracleDbType.Date, date, ParameterDirection.Input),
					new OracleParameter(":in_dateend", OracleDbType.Date, ndate, ParameterDirection.Input),
				};
				DataTable workData = oracleConn.GetSqlResultToDt(sqlString, paras);

				sqlString = "select SAP_INI_BG from TP_SYS_SAPCONFIG";
				string SAP_ING_NEW = oracleConn.GetSqlResultToStr(sqlString);

				if (workData != null && workData.Rows.Count > 0 && SAP_ING_NEW == "0")
				{
					string postString = "{\"IT_INPUT\":{\"item\":" + JsonHelper.ToJson(ModelConvertHelper<CrossWorkShopToSAP>.ConvertToModel(workData)) + "}}";
					//INIUtility ini = INIUtility.Instance(INIUtility.IniFile.SAP_HEGII);
					//string url033 = ini.ReadIniData("SAP_NEW_INFO", "Url033");
					string url033 = "http://hgs4podev.hegii.com:50200/RESTAdapter/DKMES/ZPPFM033";
					string result = PostData(url033, postString, "POST");
					string ztype = JObject.Parse(result)["ZTYPE"].ToString();
					string msg = JObject.Parse(result)["ZMSG"].ToString();
					//sqlString = "update TSAP_HEGII_DATALOG_KCJZY t set t.EndTime = sysdate, DataStuts = :DataStuts, DataMSG =:msg where logid = :logid";
					//paras = new OracleParameter[]
					//{
					//    new OracleParameter(":logid", OracleDbType.Varchar2, logid, ParameterDirection.Input),
					//    new OracleParameter(":DataStuts", OracleDbType.Varchar2, ztype, ParameterDirection.Input),
					//    new OracleParameter(":msg", OracleDbType.Varchar2, msg, ParameterDirection.Input),
					//};
					//oracleConn.ExecuteNonQuery(sqlString, paras);
					oracleConn.Commit();
				}
				#endregion
			}
			catch (Exception ex)
			{
				OutputLog.TraceLog(LogPriority.Error,
						"CrossWorkshopToSAP",
						"跨车间作业量" + date.ToString("yyyy-MM-dd HH:mm:ss"),
						ex.ToString(),
						LocalPath.LogExePath + "SAP_HEGII\\Error_");
			}
		}

		/// <summary>
		/// 查询跨车间作业同步日志
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetDataLog_kczzy(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);

			ServiceResultEntity sre = new ServiceResultEntity();
			try
			{
				string sqlString = "SELECT\n" +
						"	dl.logid,\n" +
						"	dl.begintime,\n" +
						"	dl.endtime,\n" +
						"	dl.yyyymmdd,\n" +
						"	dl.workcode,\n" +
						"	dl.datastuts,\n" +
						"	dl.datamsg,\n" +
						"	dl.executedatebegin,\n" +
						"	dl.executedateend,\n" +
						"	u.usercode synusercode\n" +
						"FROM\n" +
						"	tsap_hegii_datalog_kcjzy dl\n" +
						"	LEFT JOIN tp_mst_user u ON u.userid = dl.createuserid \n" +
						"WHERE\n" +
						"	dl.EXECUTEDATEBEGIN >= :datebegin \n" +
						"	AND dl.EXECUTEDATEEND <= :dateend \n";

				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":datebegin",OracleDbType.Date, cre.Properties["datebegin"], ParameterDirection.Input),
					new OracleParameter(":dateend",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
				};

				string datastuts = cre.Properties["datastuts"] + "";
				if (!string.IsNullOrEmpty(datastuts))
				{
					sqlString += "   and dl.datastuts in (" + datastuts + ")\n";
				}
				sqlString += "ORDER BY dl.logid DESC\n";

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}

		/// <summary>
		/// 查询同步明细
		/// </summary>
		/// <param name="logid"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetWorkData_kczzy(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);

			ServiceResultEntity sre = new ServiceResultEntity();
			try
			{
				int logid = Convert.ToInt32(cre.Request);
				string sqlString = "\n" +
				"select wd.workshop\n" +
				"	   ,case when wd.workshop = 2 then '二车间' when wd.workshop = 3 then '三车间' else '-' end workshopname\n " +
				"	   ,case when wd.item = 1 then '产量' when wd.item = 2 then '产量撤销' when wd.item = 3 then '工序报损' when wd.item = 4 then '工序报损撤销' \n" +
				"       when wd.item = 5 then '盘点清除' when wd.item = 6 then '干补' when wd.item = 7 then '回收' else '-' end as itemname\n" +
				"      ,item\n" +
				"      ,wd.datacode\n" +
				"      ,dc.datacodename\n" +
				"      ,wd.goodscode\n" +
				"      ,wd.sapcode\n" +
				"      ,wd.num\n" +
				"      ,wd.createtime\n" +
				"      ,wd.testmouldflag\n" +
				"      ,wd.zscs\n" +
				"      ,case when wd.zscs = 'L' then '立浇【L】' when wd.zscs = 'G' then '高压【G】' when wd.zscs = 'M' then '粘接高压（三水厂）【M】' when wd.zscs = 'Q' then '吊装线【Q】' else '-' end as zscsname\n" +
				"      ,wd.logid\n" +
				"  from tsap_hegii_workdata_kcjzy wd\n" +
				" inner join tsap_hegii_datacode dc\n" +
				"    on dc.datacode = wd.datacode\n";
				if (logid > 0)
				{
					sqlString += " where wd.logid = :logid \n";
				}
				else
				{
					sqlString += " inner join tsap_hegii_datalog_kcjzy dl\n" +
								 "   on wd.logid=dl.logid \n" +
								 " where dl.EXECUTEDATEBEGIN>= :datebegin \n" +
								 " and dl.EXECUTEDATEEND<= :dateend \n";
				}
				sqlString += " order by wd.datacode,wd.item,wd.workshop \n";
				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":logid",OracleDbType.Int32, logid, ParameterDirection.Input),
					new OracleParameter(":datebegin",OracleDbType.Date, cre.Properties["datebegin"], ParameterDirection.Input),
					new OracleParameter(":dateend",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
				};

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);

				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}
		#endregion

		#region 报工

		///// <summary>
		///// 同步SAP数据（自动）
		///// </summary>
		///// <param name="date"></param>
		//public static void AutoWorkDataToSAP5000(DateTime date, string funCode)
		//{
		//    if (string.IsNullOrWhiteSpace(funCode))
		//    {
		//        //return;
		//        funCode = "ALL";
		//    }
		//    funCode = "," + funCode + ",";
		//    ServiceResultEntity sre = null;
		//    // 10 模具
		//    if (funCode == ",ALL," || funCode.Contains(",10,"))
		//    {
		//        try
		//        {
		//            sre = SetWorkData10_50(date, "10", 0);
		//            if (sre.Status != Constant.ServiceResultStatus.Success ||
		//                "S" != sre.Result + "")
		//            {
		//                OutputLog.TraceLog(LogPriority.Warning,
		//                        "AutoWorkDataToSAP",
		//                        "10 模具 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                        JsonHelper.ToJson(sre),
		//                        LocalPath.LogExePath + "SAP_HEGII\\Warn_");
		//            }
		//        }
		//        catch (Exception ex)
		//        {
		//            OutputLog.TraceLog(LogPriority.Error,
		//                    "AutoWorkDataToSAP",
		//                    "10 模具 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                    ex.ToString(),
		//                    LocalPath.LogExePath + "SAP_HEGII\\Error_");
		//        }
		//    }
		//    // 20 湿坯
		//    if (funCode == ",ALL," || funCode.Contains(",20,"))
		//    {
		//        try
		//        {
		//            sre = SetWorkData10_50(date, "20", 0);
		//            if (sre.Status != Constant.ServiceResultStatus.Success ||
		//                "S" != sre.Result + "")
		//            {
		//                OutputLog.TraceLog(LogPriority.Warning,
		//                        "AutoWorkDataToSAP",
		//                        "20 湿坯 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                        JsonHelper.ToJson(sre),
		//                        LocalPath.LogExePath + "SAP_HEGII\\Warn_");
		//            }
		//        }
		//        catch (Exception ex)
		//        {
		//            OutputLog.TraceLog(LogPriority.Error,
		//                    "AutoWorkDataToSAP",
		//                    "20 湿坯 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                    ex.ToString(),
		//                    LocalPath.LogExePath + "SAP_HEGII\\Error_");
		//        }
		//    }
		//    // 30 精坯
		//    if (funCode == ",ALL," || funCode.Contains(",30,"))
		//    {
		//        try
		//        {
		//            sre = SetWorkData10_50(date, "30", 0);
		//            if (sre.Status != Constant.ServiceResultStatus.Success ||
		//                "S" != sre.Result + "")
		//            {
		//                OutputLog.TraceLog(LogPriority.Warning,
		//                        "AutoWorkDataToSAP",
		//                        "30 精坯 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                        JsonHelper.ToJson(sre),
		//                        LocalPath.LogExePath + "SAP_HEGII\\Warn_");
		//            }
		//        }
		//        catch (Exception ex)
		//        {
		//            OutputLog.TraceLog(LogPriority.Error,
		//                    "AutoWorkDataToSAP",
		//                    "30 精坯 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                    ex.ToString(),
		//                    LocalPath.LogExePath + "SAP_HEGII\\Error_");
		//        }
		//    }
		//    // 40 釉坯
		//    if (funCode == ",ALL," || funCode.Contains(",40,"))
		//    {
		//        try
		//        {
		//            sre = SetWorkData10_50(date, "40", 0);
		//            if (sre.Status != Constant.ServiceResultStatus.Success ||
		//                "S" != sre.Result + "")
		//            {
		//                OutputLog.TraceLog(LogPriority.Warning,
		//                        "AutoWorkDataToSAP",
		//                        "40 釉坯 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                        JsonHelper.ToJson(sre),
		//                        LocalPath.LogExePath + "SAP_HEGII\\Warn_");
		//            }
		//        }
		//        catch (Exception ex)
		//        {
		//            OutputLog.TraceLog(LogPriority.Error,
		//                    "AutoWorkDataToSAP",
		//                    "40 釉坯 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                    ex.ToString(),
		//                    LocalPath.LogExePath + "SAP_HEGII\\Error_");
		//        }
		//    }
		//    // 50 烧成
		//    if (funCode == ",ALL," || funCode.Contains(",50,"))
		//    {
		//        try
		//        {
		//            sre = SetWorkData10_50(date, "50", 0);
		//            if (sre.Status != Constant.ServiceResultStatus.Success ||
		//                "S" != sre.Result + "")
		//            {
		//                OutputLog.TraceLog(LogPriority.Warning,
		//                        "AutoWorkDataToSAP",
		//                        "50 烧成 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                        JsonHelper.ToJson(sre),
		//                        LocalPath.LogExePath + "SAP_HEGII\\Warn_");
		//            }
		//        }
		//        catch (Exception ex)
		//        {
		//            OutputLog.TraceLog(LogPriority.Error,
		//                    "AutoWorkDataToSAP",
		//                    "50 烧成 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//                    ex.ToString(),
		//                    LocalPath.LogExePath + "SAP_HEGII\\Error_");
		//        }
		//    }
		//    //// 6001 成品明细
		//    //if (funCode == ",ALL," || funCode.Contains(",6001,"))
		//    //{
		//    //    try
		//    //    {
		//    //        sre = SetFP6001(date, 0);
		//    //        if (sre.Status != Constant.ServiceResultStatus.Success ||
		//    //            "S" != sre.Result + "")
		//    //        {
		//    //            OutputLog.TraceLog(LogPriority.Warning,
		//    //                    "AutoWorkDataToSAP",
		//    //                    "6001 成品明细 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//    //                    JsonHelper.ToJson(sre),
		//    //                    LocalPath.LogExePath + "SAP_HEGII\\Warn_");
		//    //        }
		//    //    }
		//    //    catch (Exception ex)
		//    //    {
		//    //        OutputLog.TraceLog(LogPriority.Error,
		//    //                "AutoWorkDataToSAP",
		//    //                "6001 成品明细 " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//    //                ex.ToString(),
		//    //                LocalPath.LogExePath + "SAP_HEGII\\Error_");
		//    //    }
		//    //}
		//    //// 6001 成品明细(小时)-20分钟
		//    //if (funCode == ",6002,")
		//    //{
		//    //    try
		//    //    {
		//    //        sre = SetFP6002(date, 0);
		//    //        if (sre.Status != Constant.ServiceResultStatus.Success ||
		//    //            "S" != sre.Result + "")
		//    //        {
		//    //            OutputLog.TraceLog(LogPriority.Warning,
		//    //                    "AutoWorkDataToSAP",
		//    //                    "6002 成品明细(小时) " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//    //                    JsonHelper.ToJson(sre),
		//    //                    LocalPath.LogExePath + "SAP_HEGII\\Warn_");
		//    //        }
		//    //    }
		//    //    catch (Exception ex)
		//    //    {
		//    //        OutputLog.TraceLog(LogPriority.Error,
		//    //                "AutoWorkDataToSAP",
		//    //                "6002 成品明细(小时) " + date.ToString("yyyy-MM-dd HH:mm:ss"),
		//    //                ex.ToString(),
		//    //                LocalPath.LogExePath + "SAP_HEGII\\Error_");
		//    //    }
		//    //}
		//}

		/// <summary>
		/// 同步SAP数据（自动）(重载)
		/// </summary>
		/// <param name="date">当前时间</param>
		/// <param name="funCode">工序码</param>
		/// <param name="ndate">本次要执行到的时间</param>
		public static void AutoWorkDataToSAP5000(string funCode, DateTime ndate)
		{
			if (string.IsNullOrWhiteSpace(funCode))
			{
				//return;
				funCode = "ALL";
			}
			funCode = "," + funCode + ",";
			ServiceResultEntity sre = null;
			// 10 模具
			if (funCode == ",ALL," || funCode.Contains(",10,"))
			{
				try
				{
					sre = SetWorkData10_50_5000("10", ndate);
					if (sre.Status != Constant.ServiceResultStatus.Success ||
						"S" != sre.Result + "")
					{
						OutputLog.TraceLog(LogPriority.Warning,
								"AutoWorkDataToSAP5000",
								"10 模具 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
								JsonHelper.ToJson(sre),
								LocalPath.LogExePath + "SAP_HEGII\\Warn_");
					}
				}
				catch (Exception ex)
				{
					OutputLog.TraceLog(LogPriority.Error,
							"AutoWorkDataToSAP5000",
							"10 模具 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
							ex.ToString(),
							LocalPath.LogExePath + "SAP_HEGII\\Error_");
				}
			}
			// 20 湿坯
			if (funCode == ",ALL," || funCode.Contains(",20,"))
			{
				try
				{
					sre = SetWorkData10_50_5000("20", ndate);
					if (sre.Status != Constant.ServiceResultStatus.Success ||
						"S" != sre.Result + "")
					{
						OutputLog.TraceLog(LogPriority.Warning,
								"AutoWorkDataToSAP5000",
								"20 湿坯 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
								JsonHelper.ToJson(sre),
								LocalPath.LogExePath + "SAP_HEGII\\Warn_");
					}
				}
				catch (Exception ex)
				{
					OutputLog.TraceLog(LogPriority.Error,
							"AutoWorkDataToSAP5000",
							"20 湿坯 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
							ex.ToString(),
							LocalPath.LogExePath + "SAP_HEGII\\Error_");
				}
			}
			// 30 精坯
			if (funCode == ",ALL," || funCode.Contains(",30,"))
			{
				try
				{
					sre = SetWorkData10_50_5000("30", ndate);
					if (sre.Status != Constant.ServiceResultStatus.Success ||
						"S" != sre.Result + "")
					{
						OutputLog.TraceLog(LogPriority.Warning,
								"AutoWorkDataToSAP5000",
								"30 精坯 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
								JsonHelper.ToJson(sre),
								LocalPath.LogExePath + "SAP_HEGII\\Warn_");
					}
				}
				catch (Exception ex)
				{
					OutputLog.TraceLog(LogPriority.Error,
							"AutoWorkDataToSAP5000",
							"30 精坯 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
							ex.ToString(),
							LocalPath.LogExePath + "SAP_HEGII\\Error_");
				}
			}
			// 40 釉坯
			if (funCode == ",ALL," || funCode.Contains(",40,"))
			{
				try
				{
					sre = SetWorkData10_50_5000("40", ndate);
					if (sre.Status != Constant.ServiceResultStatus.Success ||
						"S" != sre.Result + "")
					{
						OutputLog.TraceLog(LogPriority.Warning,
								"AutoWorkDataToSAP5000",
								"40 釉坯 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
								JsonHelper.ToJson(sre),
								LocalPath.LogExePath + "SAP_HEGII\\Warn_");
					}
				}
				catch (Exception ex)
				{
					OutputLog.TraceLog(LogPriority.Error,
							"AutoWorkDataToSAP5000",
							"40 釉坯 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
							ex.ToString(),
							LocalPath.LogExePath + "SAP_HEGII\\Error_");
				}
			}
			// 50 烧成
			if (funCode == ",ALL," || funCode.Contains(",50,"))
			{
				try
				{
					sre = SetWorkData10_50_5000("50", ndate);
					if (sre.Status != Constant.ServiceResultStatus.Success ||
						"S" != sre.Result + "")
					{
						OutputLog.TraceLog(LogPriority.Warning,
								"AutoWorkDataToSAP5000",
								"50 烧成 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
								JsonHelper.ToJson(sre),
								LocalPath.LogExePath + "SAP_HEGII\\Warn_");
					}
				}
				catch (Exception ex)
				{
					OutputLog.TraceLog(LogPriority.Error,
							"AutoWorkDataToSAP5000",
							"50 烧成 " + ndate.ToString("yyyy-MM-dd HH:mm:ss"),
							ex.ToString(),
							LocalPath.LogExePath + "SAP_HEGII\\Error_");
				}
			}
		}

		/// <summary>
		/// 执行与推送
		/// </summary>
		/// <param name="datacode"></param>
		/// <param name="ndate"></param>
		/// <returns></returns>
		public static ServiceResultEntity SetWorkData10_50_5000(string datacode, DateTime ndate)
		{
			ServiceResultEntity sre = new ServiceResultEntity();
			IDBTransaction oracleConn = null;
			try
			{
				#region 事务1，执行存储过程
				OracleParameter[] paras = null;
				int logid = 0;
				string message = string.Empty;

				// 10 模具
				if ("10".Equals(datacode))
				{
					paras = new OracleParameter[]
					{
						new OracleParameter("in_dateend", OracleDbType.Date, ndate, ParameterDirection.Input),
						new OracleParameter("out_logid", OracleDbType.Int32, null, ParameterDirection.Output),
						new OracleParameter("out_msg", OracleDbType.NVarchar2, 500, null, ParameterDirection.Output)
					};

					oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
					DataSet ds = oracleConn.ExecStoredProcedure("PRO_SAP_HEGII_WORKDATA_BG10", paras);
					int.TryParse(paras[1].Value + "", out logid);
					message = paras[2].Value + "";
					oracleConn.Commit();
				}
				// 20 湿坯
				else if ("20".Equals(datacode))
				{
					paras = new OracleParameter[]
					{
						new OracleParameter("in_dateend", OracleDbType.Date, ndate, ParameterDirection.Input),
						new OracleParameter("out_logid", OracleDbType.Int32, null, ParameterDirection.Output),
						new OracleParameter("out_msg", OracleDbType.NVarchar2, 500, null, ParameterDirection.Output)
					};

					oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
					DataSet ds = oracleConn.ExecStoredProcedure("PRO_SAP_HEGII_WORKDATA_BG20", paras);
					int.TryParse(paras[1].Value + "", out logid);
					message = paras[2].Value + "";
					oracleConn.Commit();
				}
				// 30 精坯、40 釉坯
				else if ("30".Equals(datacode) || "40".Equals(datacode))
				{
					paras = new OracleParameter[]
					{
						new OracleParameter("in_dateend", OracleDbType.Date, ndate, ParameterDirection.Input),
						new OracleParameter("in_datacode", OracleDbType.Varchar2, datacode, ParameterDirection.Input),
						new OracleParameter("out_logid", OracleDbType.Int32, null, ParameterDirection.Output),
						new OracleParameter("out_msg", OracleDbType.NVarchar2, 500, null, ParameterDirection.Output)
					};

					oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
					DataSet ds = oracleConn.ExecStoredProcedure("PRO_SAP_HEGII_WORKDATA_BG", paras);
					int.TryParse(paras[2].Value + "", out logid);
					message = paras[3].Value + "";
					oracleConn.Commit();
				}
				// 50 烧成
				else if ("50".Equals(datacode))
				{
					paras = new OracleParameter[]
					{
						new OracleParameter("in_dateend", OracleDbType.Date, ndate, ParameterDirection.Input),
						new OracleParameter("in_datacode", OracleDbType.Varchar2, datacode, ParameterDirection.Input),
						new OracleParameter("out_logid", OracleDbType.Int32, null, ParameterDirection.Output),
						new OracleParameter("out_msg", OracleDbType.NVarchar2, 500, null, ParameterDirection.Output)
					};

					oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
					DataSet ds = oracleConn.ExecStoredProcedure("PRO_SAP_HEGII_WORKDATA_BG50", paras);
					int.TryParse(paras[2].Value + "", out logid);
					message = paras[3].Value + "";
					oracleConn.Commit();
				}

				// 如果logid为0，则数据没有生成
				if (logid == 0)
				{
					sre.Status = Constant.ServiceResultStatus.Other;
					sre.Message = message;
					return sre;
				}
				#endregion

				// 事物2，同步SAP接口
				string sqlString = "select SAP_INI_BG from TP_SYS_SAPCONFIG";
				string SAP_ING_NEW = oracleConn.GetSqlResultToStr(sqlString);

				if (SAP_ING_NEW == "1")
				{
					sre = SyncSap5000(ndate, datacode);
				}
				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
			finally
			{
				if (oracleConn != null &&
					oracleConn.ConnState == ConnectionState.Open)
				{
					oracleConn.Disconnect();
				}
			}
		}

		/// <summary>
		/// 同步SAP接口5000端口新
		/// </summary>
		/// <param name="date"></param>
		/// <param name="datacode"></param>
		/// <param name="userid"></param>
		/// <param name="logid"></param>
		/// <returns></returns>
		public static ServiceResultEntity SyncSap5000(DateTime date, string datacode)
		{
			ServiceResultEntity sre = new ServiceResultEntity();
			IDBTransaction oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);

			try
			{
				OracleParameter[] paras = null;
				int r = 0;

				// 查询当前节点所有不为S的日志
				string sqlString = @"
                SELECT DL.LOGID
                  FROM TSAP_HEGII_DATALOG_BG DL
                 WHERE 1 = 1
                   AND DL.DATASTUTS = 'F'
                   AND DL.LOGID > 6
                   AND DL.DATACODE = :DATACODE ";

				paras = new OracleParameter[]
				{
					new OracleParameter(":DATACODE", datacode),
				};

				DataTable dtLogID = oracleConn.GetSqlResultToDt(sqlString, paras);
				string logIDs = "," + string.Join(",", dtLogID.AsEnumerable().Select(d => d.Field<decimal>("LOGID")).ToArray()) + ",";

				sqlString = @"
                SELECT TO_CHAR(WD.YYYYMMDD) YYYYMMDD,
                       WD.WORKCODE AS WERKS,
                       TO_CHAR(WD.GOODSCODE) GROES,
                       TO_CHAR(WD.SAPCODE) MATNR,
                       TO_CHAR(WD.USERCODE) ZGHNU,
                       TO_CHAR(WD.DATACODE) ZJDNU,
                       TO_CHAR(WD.YYYYMMDD) ZSCNU,
                       TO_CHAR(DL.EXECUTEDATEBEGIN, 'HH24MISS') ZKSSJ,
                       TO_CHAR(DL.EXECUTEDATEEND, 'YYYYMMDDHH24MISS') ZJSRQ,
                       TO_CHAR(WD.ORDERCODE) VBELN,
                       TO_CHAR(WD.ORDERITEM) POSNR,
                       TO_CHAR(WD.OUTPUTNUM) ZCLNG,
                       TO_CHAR(WD.SCRAPNUM) ZSPNG,
                       TO_CHAR(WD.CLEANUPNUM) ZQCNG,
                       TO_CHAR(WD.RECOVERYNUM) ZHSNG,
                       TO_CHAR(WD.REPAIRNUM) ZGBNG,
                       TO_CHAR(WD.TESTMOULDFLAG) ZSCMS,
                       DECODE(:DATACODE, 20, TO_CHAR(WD.ZSCS), 'T') AS ZSCS,
                       TO_CHAR(WD.WORKSHOP) ZSCCJ,
                       WD.CHARG,
                       TO_CHAR(:DATACODE) DATACODE,
                       WD.WORKCODE || WD.CHARG || LPAD(DL.LOGID, 10,'0') AS ZID
                  FROM TSAP_HEGII_WORKDATA_BG WD
                 INNER JOIN TSAP_HEGII_DATALOG_BG DL
                    ON WD.LOGID = DL.LOGID
                 WHERE INSTR(:LOGIDS, ',' || WD.LOGID || ',') > 0 ";

				paras = new OracleParameter[]
				{
					new OracleParameter(":DATACODE",datacode),
					new OracleParameter(":LOGIDS", OracleDbType.Varchar2, logIDs, ParameterDirection.Input),
				};

				DataTable workData = oracleConn.GetSqlResultToDt(sqlString, paras);
				int num = workData.Rows.Count;
				// 调用SAP接口
				string postString = "{\"ZSUM\":" + num.ToString() + ",\"TABLE_IN\":{\"item\":" + JsonHelper.ToJson(ModelConvertHelper<BGToSAP>.ConvertToModel(workData)) + "}}";
				INIUtility ini = INIUtility.Instance(INIUtility.IniFile.SAP_HEGII);

				// 配置文件
				string url030 = ini.ReadIniData("SAP_NEW_INFO", "Url030");

				// 测试
				// string url030 = "http://hgs4podev.hegii.com:50200/RESTAdapter/DKMES/ZPPFM030";

				// 正式
				//string url030 = "http://hgs4powd1.hegii.com:8000/RESTAdapter/DKMES/ZPPFM030";


				string result = PostData(url030, postString, "POST");

				sqlString = @"
                UPDATE TSAP_HEGII_DATALOG_BG T
                   SET T.ENDTIME = SYSDATE,
                       DATASTUTS = :DATASTUTS,
                       DATAMSG   = :MSG
                 WHERE INSTR(:LOGIDS, ',' || LOGID || ',') > 0 ";
				paras = new OracleParameter[]
				{
					new OracleParameter(":DATASTUTS",OracleDbType.Varchar2, JObject.Parse(result)["ZTYPE"].ToString(), ParameterDirection.Input),
					new OracleParameter(":MSG",OracleDbType.Varchar2, JObject.Parse(result)["ZMSG"].ToString(), ParameterDirection.Input),
					new OracleParameter(":LOGIDS", OracleDbType.Varchar2, logIDs, ParameterDirection.Input),
				};
				r = oracleConn.ExecuteNonQuery(sqlString, paras);

				oracleConn.Commit();

				sre.Message = JObject.Parse(result)["ZMSG"].ToString();
				sre.Result = JObject.Parse(result)["ZTYPE"].ToString();
				return sre;
			}
			catch (Exception ex)
			{
				OutputLog.TraceLog(LogPriority.Error,
						"BGToSAP",
						"报工" + date.ToString("yyyy-MM-dd HH:mm:ss"),
						ex.ToString(),
						LocalPath.LogExePath + "SAP_HEGII\\Error_");
				throw ex;
			}
			finally
			{
				if (oracleConn != null &&
					oracleConn.ConnState == ConnectionState.Open)
				{
					oracleConn.Disconnect();
				}
			}
		}

		/// <summary>
		/// 查询同步日志
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetDataLog_BG(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);

			ServiceResultEntity sre = new ServiceResultEntity();
			try
			{
				string sqlString =
					"select dl.logid\n" +
					"      ,dl.logtype\n" +
					"      ,dl.begintime\n" +
					"      ,dl.endtime\n" +
					"      ,dl.yyyymmdd\n" +
					"      ,dl.workcode\n" +
					"      ,dl.datacode\n" +
					"      ,dc.datacodename\n" +
					"      ,dl.datastuts\n" +
					"      ,dl.datamsg\n" +
					"      ,dl.datalogid\n" +
					"      ,dl.executedatebegin\n" +
					"      ,dl.executedateend\n" +
					"      ,u.usercode synusercode\n" +
					"  from TSAP_HEGII_DATALOG_BG dl\n" +
					" inner join tsap_hegii_datacode dc\n" +
					"    on dc.datacode = dl.datacode\n" +
					"  left join tp_mst_user u\n" +
					"    on u.userid = dl.createuserid\n" +
					" where dl.logtype IN('2','3')\n" +
					"   and dl.executedatebegin >= :DATEBEGIN\n" +
					"   and dl.executedateend < :DATEEND\n" +
					"   and (-1= :DATACODE or dl.datacode=:DATACODE )";//add xiacm 2022-10-12

				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":DATEBEGIN",OracleDbType.Date, cre.Properties["datebegin"], ParameterDirection.Input),
					new OracleParameter(":DATEEND",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
					new OracleParameter(":DATACODE",OracleDbType.Varchar2, cre.Properties["datacode"], ParameterDirection.Input),
				};

				sqlString += "ORDER BY dl.logid DESC\n";

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}

		/// <summary>
		/// 查询同步明细
		/// </summary>
		/// <param name="logid"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetWorkData_BG(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
			ServiceResultEntity sre = new ServiceResultEntity();
			try
			{
				int logid = Convert.ToInt32(cre.Request);
				string sqlString = "\n" +
				"select wd.yyyymmdd\n" +
				"      ,wd.workcode\n" +
				"      ,wd.datacode\n" +
				"      ,dc.datacodename\n" +
				"      ,wd.goodscode\n" +
				"      ,wd.sapcode\n" +
				"      ,wd.usercode\n" +
				"      ,wd.ordercode\n" +
				"      ,wd.orderitem\n" +
				"      ,to_number(wd.outputnum) outputnum\n" +
				"      ,to_number(wd.scrapnum) scrapnum\n" +
				"      ,to_number(wd.cleanupnum) cleanupnum\n" +
				"      ,to_number(wd.recoverynum) recoverynum\n" +
				"      ,to_number(wd.repairnum) repairnum\n" +
				"      ,wd.createtime\n" +
				"      ,wd.ztype\n" +
				"      ,wd.zmsg\n" +
				"      ,wd.ztime\n" +
				"      ,wd.testmouldflag\n" +
				"      ,wd.zscs\n" +
				"      ,wd.logid\n" +
				"  from tsap_hegii_workdata_BG wd\n" +
				" inner join TSAP_HEGII_DATALOG_BG dl\n" +
				"    on dl.logid = wd.logid\n" +
				" inner join tsap_hegii_datacode dc\n" +
				"    on dc.datacode = wd.datacode\n";
				//update xiacm 2022-10-12
				if (logid > 0)
				{
					sqlString += " where wd.logid = :logid \n";
				}
				else
				{
					sqlString += " where dl.executedatebegin >= :DATEBEGIN and dl.executedateend < :DATEEND";
					sqlString += " and (-1= :DATACODE OR wd.datacode = :DATACODE)";
				}
				sqlString += " order by wd.goodscode,wd.sapcode,wd.usercode,wd.ordercode,wd.outputnum \n";
				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":logid",OracleDbType.Int32, logid, ParameterDirection.Input),
					new OracleParameter(":DATEBEGIN",OracleDbType.Date, cre.Properties["datebegin"], ParameterDirection.Input),
					new OracleParameter(":DATEEND",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
					new OracleParameter(":DATACODE",OracleDbType.Varchar2, cre.Properties["datacode"], ParameterDirection.Input),
				};
				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}

		/// <summary>
		/// 报工汇总 add xiacm 2022-10-12
		/// </summary>
		/// <param name="cre"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetDataLogTotal_BG(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
			ServiceResultEntity sre = new ServiceResultEntity();

			try
			{
				string sqlString = @"
                SELECT T1.DATACODE,
                       T1.ACTUALOUTPUT,
                       T2.OUTPUT,
                       T2.SCRAPNUM,
                       T2.CLEANNUPNUM,
                       T2.RECOVERYNUM,
                       T2.REPAIRNUM,
                       T3.DRCXFDRJJDCCP,
                       T4.DRJJBQTRCXDCCP,
                       T1.ACTUALOUTPUT + NVL(T4.DRJJBQTRCXDCCP, 0) - NVL(T3.DRCXFDRJJDCCP, 0) -
                       (T2.OUTPUT + T2.RECOVERYNUM) AS DIFFER
                  FROM (
                        -- 业务数据汇总
                        -- 10
                        SELECT '10' AS DATACODE,
                                SUM(DECODE(MHH.OPERATIONTYPE, 1, M.STANDARDGROUTINGSUM, 0)) AS ACTUALOUTPUT
                          FROM (SELECT MH.GOODSID,
                                        MH.MOULDID,
                                        MH.OPERATIONTYPE,
                                        MH.GROUTINGNUM
                                   FROM TP_PC_MOULDCHANGEHISTORY MH
                                  WHERE MH.OPERATIONTYPE IN (1, 2, 3, 9, 11, -1)
                                    AND MH.CREATETIME >= :DATEBEGIN
                                    AND MH.CREATETIME < :DATEEND
                                 UNION ALL
                                 SELECT MH.GOODSIDAFTER,
                                        MH.MOULDID,
                                        0,
                                        MH.GROUTINGNUM
                                   FROM TP_PC_MOULDCHANGEHISTORY MH
                                  WHERE MH.OPERATIONTYPE = -1
                                    AND MH.CREATETIME >= :DATEBEGIN
                                    AND MH.CREATETIME < :DATEEND) MHH
                         INNER JOIN TP_PC_MOULD M
                            ON M.MOULDID = MHH.MOULDID
                        UNION ALL
                        -- 20
                        SELECT '20' AS DATACODE,
                                SUM(DECODE(GH.DATATYPE, 1, 1, -1)) BUSINESSOUTPUT
                          FROM TP_PM_GOODSCHANGEHISTORY GH
                         INNER JOIN TP_MST_GOODS G
                            ON G.GOODSID = GH.GOODSID
                         WHERE GH.CREATETIME >= :DATEBEGIN
                           AND GH.CREATETIME < :DATEEND
                           AND GH.DATATYPE IN (1, 2)
                           AND G.SCRAPSUMFLAG = '1'
                        UNION ALL
                        -- 30
                        SELECT '30' AS DATACODE,
                                SUM(T1.CC) AS BUSINESSOUTPUT
                          FROM (SELECT 1 AS CC
                                   FROM TP_PM_PRODUCTIONDATA P
                                  WHERE P.PROCEDUREID IN (53, 97)
                                    AND P.CREATETIME >= :DATEBEGIN
                                    AND P.CREATETIME < :DATEEND
                                 UNION ALL
                                 SELECT -1 AS CC
                                   FROM TP_PM_PRODUCTIONDATA P
                                  WHERE P.PROCEDUREID IN (53, 97)
                                    AND P.VALUEFLAG = '0'
                                    AND P.BACKOUTTIME >= :DATEBEGIN
                                    AND P.BACKOUTTIME < :DATEEND) T1
                        UNION ALL
                        -- 40
                        SELECT '40' AS DATACODE,
                                SUM(T1.CC) AS BUSINESSOUTPUT
                          FROM (SELECT 1 AS CC
                                   FROM TP_PM_PRODUCTIONDATA P
                                  WHERE P.PROCEDUREID IN (65, 99)
                                    AND P.CREATETIME >= :DATEBEGIN
                                    AND P.CREATETIME < :DATEEND
                                 UNION ALL
                                 SELECT -1 AS CC
                                   FROM TP_PM_PRODUCTIONDATA P
                                  WHERE P.PROCEDUREID IN (65, 99)
                                    AND P.VALUEFLAG = '0'
                                    AND P.BACKOUTTIME >= :DATEBEGIN
                                    AND P.BACKOUTTIME < :DATEEND) T1
                        UNION ALL
                        -- 50
                        SELECT '50' AS DATACODE,
                                SUM(T1.CC) AS BUSINESSOUTPUT
                          FROM (SELECT COUNT(DISTINCT P.BARCODE) AS CC
                                   FROM TP_PM_PRODUCTIONDATA P
                                  WHERE P.PROCEDUREID IN (11, 104)
                                    AND ((P.PROCEDUREID <> 104 AND P.VALUEFLAG = '1') OR
                                        (P.PROCEDUREID = 104 AND P.ISREFIRE = '0' AND P.CHECKFLAG = '1'))
                                    AND P.CREATETIME >= :DATEBEGIN
                                    AND P.CREATETIME < :DATEEND
                                 UNION ALL
                                 SELECT -1 AS CC
                                   FROM TP_PM_PRODUCTIONDATA P
                                  WHERE P.PROCEDUREID IN (11, 104)
                                    AND P.VALUEFLAG = '0'
                                    AND P.PROCEDUREID <> 104
                                    AND P.ISREFIRE = '0'
                                    AND P.BACKOUTTIME >= :DATEBEGIN
                                    AND P.BACKOUTTIME < :DATEEND) T1
                        UNION ALL
                        -- 60
                        SELECT '60' AS DATACODE,
                                COUNT(1) AS BUSINESSOUTPUT
                          FROM TP_PM_FINISHEDPRODUCT GH
                         WHERE GH.FHTIME >= :DATEBEGIN
                           AND GH.FHTIME < :DATEEND) T1
                  LEFT JOIN (
                             -- 当日推送日志数据汇总
                             SELECT DATACODE AS DATACODETD,
                                     SUM(TO_NUMBER(OUTPUTNUM)) AS OUTPUT,
                                     SUM(TO_NUMBER(SCRAPNUM)) AS SCRAPNUM,
                                     SUM(TO_NUMBER(CLEANUPNUM)) AS CLEANNUPNUM,
                                     SUM(TO_NUMBER(RECOVERYNUM)) AS RECOVERYNUM,
                                     SUM(TO_NUMBER(REPAIRNUM)) AS REPAIRNUM
                               FROM TSAP_HEGII_WORKDATA_BG
                              WHERE LOGID IN (SELECT LOGID
                                                FROM TSAP_HEGII_DATALOG_BG T
                                               WHERE DATASTUTS = 'S'
                                                 AND EXECUTEDATEBEGIN >= :DATEBEGIN
                                                 AND EXECUTEDATEEND <= :DATEEND)
                              GROUP BY DATACODE
                              ORDER BY DATACODE) T2
                    ON T2.DATACODETD = T1.DATACODE
                  LEFT JOIN (
                             -- 当日撤销非当日交接的产成品
                             SELECT '60' AS DATACODE,
                                     COUNT(WL.CODEI) AS DRCXFDRJJDCCP
                               FROM TP_WMS_LOG WL
                              WHERE LOGTYPE = 2
                                AND EXISTS (SELECT 1
                                       FROM TP_WMS_LOG WL1
                                      WHERE WL1.CODEI = WL.CODEI
                                        AND WL1.LOGTYPE = 1
                                        AND TRUNC(WL1.CREATETIME) < TRUNC(WL.CREATETIME))
                                AND WL.CREATETIME >= :DATEBEGIN
                                AND WL.CREATETIME < :DATEEND) T3
                    ON T3.DATACODE = T1.DATACODE
                  LEFT JOIN (
                             -- 当日交接被其他日撤销的产成品
                             SELECT '60' AS DATACODE,
                                     COUNT(WL.CODEI) AS DRJJBQTRCXDCCP
                               FROM TP_WMS_LOG WL
                              WHERE LOGTYPE = 1
                                AND EXISTS (SELECT 1
                                       FROM TP_WMS_LOG WL1
                                      WHERE WL1.CODEI = WL.CODEI
                                        AND WL1.LOGTYPE = 2
                                        AND TRUNC(WL1.CREATETIME) > TRUNC(WL.CREATETIME))
                                AND WL.CREATETIME >= :DATEBEGIN
                                AND WL.CREATETIME < :DATEEND) T4
                    ON T4.DATACODE = T1.DATACODE
                 WHERE (-1 = :DATACODE OR T1.DATACODE = :DATACODE)
                 ORDER BY T1.DATACODE ";

				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":DATEBEGIN",OracleDbType.Date, cre.Properties["datebegin"], ParameterDirection.Input),
					new OracleParameter(":DATEEND",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
					new OracleParameter(":DATACODE",OracleDbType.Varchar2, cre.Properties["datacode"], ParameterDirection.Input),
				};

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;

			}
			catch (Exception ex)
			{
				throw ex;
			}

		}

		/// <summary>
		/// 半成品库存 add xiacm 2022-11-09
		/// </summary>
		/// <param name="cre"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetDataIVITotal_BC(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
			ServiceResultEntity sre = new ServiceResultEntity();

			try
			{
				string sqlString = @"SELECT semi.DATACODE ,
                                           semi.WORKSHOP ,
                                           semi.MATERIALCODE ,
                                           semi.GOODSCODE ,
                                           semi.GOODSNAME ,
                                           COUNT(1) AS INVENTORYQUANTITY,
                                           SYSDATE AS CREATETIME
                                      FROM (
                                            --配置表里的所有工序
                                            SELECT DI.DATACODE,
                                                    CASE
                                                        WHEN DI.WORKSHOP = 0
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'SK1' THEN
                                                         1
                                                        WHEN DI.WORKSHOP = 0
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'SK2' THEN
                                                         2
                                                        WHEN DI.WORKSHOP = 0
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'SK3' THEN
                                                         3
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'TK1' THEN
                                                         1
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'TK2' THEN
                                                         2
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 2
                                                             AND INSTR(GT.GOODSTYPECODE, '001001') = 1 THEN
                                                         2
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 2
                                                             AND INSTR(GT.GOODSTYPECODE, '001002') = 1 THEN
                                                         1
                                                        WHEN DI.WORKSHOP = 3 THEN
                                                         3
                                                        ELSE
                                                         0
                                                    END WORKSHOP,
                                                    GDD.MATERIALCODE,
                                                    G.GOODSCODE,
                                                    G.GOODSNAME
                                              FROM TP_PM_INPRODUCTION IP
                                             INNER JOIN TSAP_HEGII_DATAITEM_SSKC DI
                                                ON IP.PROCEDUREID = DI.ITEMID
                                             INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD
                                                ON IP.BARCODE = GDD.BARCODE
                                             INNER JOIN TP_MST_GOODS G
                                                ON G.GOODSID = GDD.GOODSID
                                             INNER JOIN TP_MST_GOODSTYPE GT
                                                ON GT.GOODSTYPEID = G.GOODSTYPEID
                                            UNION ALL
                                            --10-0干补
                                            SELECT DI.DATACODE,
                                                    CASE
                                                        WHEN DI.WORKSHOP = 0
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'SK1' THEN
                                                         1
                                                        WHEN DI.WORKSHOP = 0
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'SK2' THEN
                                                         2
                                                        WHEN DI.WORKSHOP = 0
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'SK3' THEN
                                                         3
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'TK1' THEN
                                                         1
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 1
                                                             AND IP.KILNCODE = 'TK2' THEN
                                                         2
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 2
                                                             AND INSTR(GT.GOODSTYPECODE, '001001') = 1 THEN
                                                         2
                                                        WHEN DI.WORKSHOP = 2
                                                             AND DI.ITEMTYPE = 2
                                                             AND INSTR(GT.GOODSTYPECODE, '001002') = 1 THEN
                                                         1
                                                        WHEN DI.WORKSHOP = 3 THEN
                                                         3
                                                        ELSE
                                                         0
                                                    END WORKSHOP,
                                                    GDD.MATERIALCODE,
                                                    G.GOODSCODE,
                                                    G.GOODSNAME
                                              FROM TP_PM_INPRODUCTION IP
                                             INNER JOIN TSAP_HEGII_DATAITEM_SSKC DI
                                                ON IP.FLOWPROCEDUREID = DI.ITEMID
                                             INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD
                                                ON IP.BARCODE = GDD.BARCODE
                                             INNER JOIN TP_MST_GOODS G
                                                ON G.GOODSID = GDD.GOODSID
                                             INNER JOIN TP_MST_GOODSTYPE GT
                                                ON GT.GOODSTYPEID = G.GOODSTYPEID
                                             WHERE PROCEDUREID = 18
                                            UNION ALL
                                            --未交坯
                                            SELECT '20' DATACODE,
                                                    CASE
                                                        WHEN INSTR(GT.GOODSTYPECODE, '001001') = 1
                                                             AND
                                                             (INSTR(GDD.GROUTINGLINECODE, 'B') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1) THEN
                                                         2
                                                        WHEN INSTR(GT.GOODSTYPECODE, '001002') = 1
                                                             AND
                                                             (INSTR(GDD.GROUTINGLINECODE, 'A') = 1 OR INSTR(GDD.GROUTINGLINECODE, 'D') = 1) THEN
                                                         1
                                                        WHEN INSTR(GDD.GROUTINGLINECODE, 'C') = 1 THEN
                                                         3
                                                        ELSE
                                                         0
                                                    END WORKSHOP,
                                                    GDD.MATERIALCODE,
                                                    G.GOODSCODE,
                                                    G.GOODSNAME
                                              FROM TP_PM_GROUTINGDAILYDETAIL GDD
                                             INNER JOIN TP_MST_GOODS G
                                                ON GDD.GOODSID = G.GOODSID
                                             INNER JOIN TP_MST_GOODSTYPE GT
                                                ON GT.GOODSTYPEID = G.GOODSTYPEID
                                             WHERE GDD.VALUEFLAG = 1
                                               AND GDD.BARCODE IS NOT NULL
                                               AND GDD.BEGINNINGFLAG = 0
                                               AND GDD.DELIVERFLAG = 0
                                               AND GDD.SCRAPFLAG = 0) semi
                                    where  (:DATACODE is null or :DATACODE ='' or :DATACODE ='-1' or instr(','||:DATACODE||',',','||semi.DATACODE||',')>0)
                                    and (:WORKSHOP is null or :WORKSHOP = '' or instr(','||:WORKSHOP||',',','||semi.WORKSHOP||',')>0)
                                    and (:MATERIALCODE is null or :MATERIALCODE = '' or instr(','||:MATERIALCODE||',',','||semi.MATERIALCODE||',')>0)
                                     GROUP BY DATACODE,
                                              WORKSHOP,
                                              MATERIALCODE,
                                              GOODSCODE,
                                              GOODSNAME
                                     ORDER BY DATACODE,
                                              WORKSHOP,
                                              MATERIALCODE,
                                              GOODSCODE,
                                              GOODSNAME";
				OracleParameter[] oracleParameter = new OracleParameter[]
			   {
					new OracleParameter(":WORKSHOP",OracleDbType.Varchar2, cre.Properties["WORKSHOP"], ParameterDirection.Input),
					new OracleParameter(":MATERIALCODE",OracleDbType.Varchar2, cre.Properties["MATERIALCODE"], ParameterDirection.Input),
					new OracleParameter(":DATACODE",OracleDbType.Varchar2, cre.Properties["datacode"], ParameterDirection.Input),
			   };

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}

		/// <summary>
		/// 查询报损数据
		/// </summary>
		/// <param name="cre"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetDataBARCODEIDNRKSCRAP(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
			ServiceResultEntity sre = new ServiceResultEntity();

			try
			{
				string sqlString = @"SELECT 0 as check1
                                          ，bis.scrapid
                                          ,bis.barcode
                                          ,bis.matnr
                                          ,bis.idnrk
                                          ,bis.meins
                                          ,bis.menge
                                          ,bis.idnrkname
                                          ,bis.idnrkonlycode
                                          ,bis.charg
                                          ,bis.lgort
                                          ,CASE
                                               WHEN bis.scraptype = 1 THEN
                                                '报损'
                                               ELSE
                                                '撤销报损'
                                           END scraptypename ，case WHEN bis.checkflag = 0 THEN '未确认' ELSE '已确认' END checkflagname
                                          ,bis.checktime
                                          ,CASE
                                               WHEN bis.syncflag = 0 THEN
                                                '未同步'
                                               WHEN bis.syncflag = 1 THEN
                                                '已同步'
                                               when bis.syncflag = 2 THEN
                                                'BPM系统审批不通过'
                                               when bis.syncflag = 3 THEN
                                                'BPM系统审批通过'
                                           END syncflagname
                                          ,mu.username createusername
                                          ,bis.createtime
                                          ,bis.costcenter
                                          ,bis.costcentername
                                          ,bis.incident
                                          ,bis.documentno
                                          ,bis.errormessage
                                          ,mdd.remarks meinsname
                                      FROM tp_pm_barcodeidnrkscrap bis
                                      LEFT JOIN tp_mst_user mu
                                        ON mu.userid = bis.createuserid
                                      LEFT JOIN tp_mst_datadictionary  mdd
                                        on mdd.dictionaryvalue = bis.meins and mdd.dictionarytype = 'TPC012'
                                     WHERE bis.createtime >= :dateagin
                                       AND bis.createtime < :dateend
                                       AND (:checkflag is null or :checkflag = '-1' OR instr(',' || :checkflag || ',', ',' || bis.checkflag || ',') > 0)
                                       AND (:syncflag is null or :syncflag = '-1' OR instr(',' || :syncflag || ',', ',' || bis.syncflag || ',') > 0)
                                       Order by bis.createtime desc";
				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":dateagin",OracleDbType.Date, cre.Properties["dateagin"], ParameterDirection.Input),
					new OracleParameter(":dateend",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
					new OracleParameter(":checkflag",OracleDbType.Varchar2, cre.Properties["CheckFlag"], ParameterDirection.Input),
					new OracleParameter(":syncflag",OracleDbType.Varchar2, cre.Properties["SyncFlag"], ParameterDirection.Input),
				};

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{

				throw ex;
			}
		}

		/// <summary>
		/// 确认组件报损
		/// </summary>
		/// <param name="cre"></param>
		/// <returns></returns>
		public static ServiceResultEntity SaveConfirmIdnrkScrap(ClientRequestEntity cre, SUserInfo userInfo)
		{
			ServiceResultEntity sre = new ServiceResultEntity();
			DataTable IdnrkScrapDt = cre.Data.Tables[0];

			int returnRows = 0;
			IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);

			try
			{
				if (IdnrkScrapDt != null && IdnrkScrapDt.Rows.Count > 0)
				{
					foreach (DataRow item in IdnrkScrapDt.Rows)
					{
						string sqlString = @"select 1 from tp_pm_barcodeidnrkscrap bis
													where  bis.scraptype=1
													and bis.checkflag = 0
													and bis.syncflag = 0
													and bis.scrapid =  :scrapid";
						OracleParameter[] Paras = new OracleParameter[] {
							new OracleParameter(":scrapid",OracleDbType.Int32,Convert.ToInt32( item["SCRAPID"]),ParameterDirection.Input),
						};
						DataTable dt = oracleTrConn.GetSqlResultToDt(sqlString, Paras);

						if(dt==null || dt.Rows.Count==0)
						{
							sre.Message = "数据状态已改变！";
							sre.OtherStatus = -999;
							return sre;
						}

						sqlString = @"UPDATE tp_pm_barcodeidnrkscrap
                                                   SET checkflag    = 1
                                                      ,updateuserid = :userid
                                                      ,checktime    = SYSDATE
                                                      ,updatetime   = SYSDATE
                                                 WHERE scrapid = :scrapid
                                                   AND scraptype = 1";
						 Paras = new OracleParameter[] {
							new OracleParameter(":scrapid",OracleDbType.Int32,Convert.ToInt32( item["SCRAPID"]),ParameterDirection.Input),
							new OracleParameter(":userid",OracleDbType.Int32,userInfo.UserID,ParameterDirection.Input),
						};
						returnRows += oracleTrConn.ExecuteNonQuery(sqlString, Paras);
					}
				}
				sre.OtherStatus = returnRows;
				oracleTrConn.Commit();
			}
			catch (Exception ex)
			{

				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Rollback();
					oracleTrConn.Disconnect();
				}
				throw ex;
			}
			finally
			{
				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Disconnect();
				}
			}
			return sre;
		}

		/// <summary>
		/// 撤销确认组件报损
		/// </summary>
		/// <param name="cre"></param>
		/// <returns></returns>
		public static ServiceResultEntity SaveUNConfirmIdnrkScrap(ClientRequestEntity cre, SUserInfo userInfo)
		{
			ServiceResultEntity sre = new ServiceResultEntity();
			DataTable IdnrkScrapDt = cre.Data.Tables[0];

			int returnRows = 0;
			IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);

			try
			{
				if (IdnrkScrapDt != null && IdnrkScrapDt.Rows.Count > 0)
				{
					foreach (DataRow item in IdnrkScrapDt.Rows)
					{
						string sqlString = @"UPDATE tp_pm_barcodeidnrkscrap
                                                   SET checkflag    = 0
                                                      ,updateuserid = :userid
                                                      ,checktime    = null
                                                      ,updatetime   = SYSDATE
                                                 WHERE scrapid = :scrapid
                                                   AND scraptype = 1";
						OracleParameter[] Paras = new OracleParameter[] {
							new OracleParameter(":scrapid",OracleDbType.Int32,Convert.ToInt32( item["SCRAPID"]),ParameterDirection.Input),
							new OracleParameter(":userid",OracleDbType.Int32,userInfo.UserID,ParameterDirection.Input),
						};
						returnRows += oracleTrConn.ExecuteNonQuery(sqlString, Paras);
					}
				}
				sre.OtherStatus = returnRows;
				oracleTrConn.Commit();
			}
			catch (Exception ex)
			{

				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Rollback();
					oracleTrConn.Disconnect();
				}
				throw ex;
			}
			finally
			{
				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Disconnect();
				}
			}
			return sre;
		}

		/// <summary>
		/// 校验同一BPM流程实例报损是否全部勾选
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity CheckScrap(ClientRequestEntity cre, SUserInfo userInfo)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
			ServiceResultEntity sre = new ServiceResultEntity();

			try
			{
				string sqlString = @"SELECT 1
                                          FROM tp_pm_barcodeidnrkscrap bis
                                         INNER JOIN (SELECT bs.incident
                                                       FROM tp_pm_barcodeidnrkscrap bs
                                                      WHERE instr( :scrapids , ',' || bs.scrapid || ',') > 0
             
                                                     ) t
                                            ON bis.incident = t.incident
                                         WHERE bis.valueflag = 1
                                           AND bis.accountid = :accountid
                                           AND instr( :scrapids , ',' || bis.scrapid || ',') <= 0";
				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":scrapids",OracleDbType.Varchar2, cre.Properties["SCRAPIDs"], ParameterDirection.Input),
					new OracleParameter(":accountid",OracleDbType.Int32, userInfo.AccountID, ParameterDirection.Input),
				};

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{

				throw ex;
			}
		}

		/// <summary>
		/// 同步bpm
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity SynIdnrkScrap(ClientRequestEntity cre, SUserInfo userInfo)
		{
			ServiceResultEntity sre = new ServiceResultEntity();
			DataTable IdnrkScrapDt = cre.Data.Tables[0];

			int returnRows = 0;
			IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
			try
			{
				#region 首次推送
				DataRow[] drs = IdnrkScrapDt.Select("INCIDENT is null");
				if (drs.Length > 0)
				{
					string scrapids = ",";
					foreach (DataRow item in IdnrkScrapDt.Rows)
					{
						scrapids += item["SCRAPID"].ToString() + ",";
					}
					//校验是否存在状态改变数据
					string sqlString = @"SELECT 1
                                          FROM tp_pm_barcodeidnrkscrap bis
                                         WHERE instr(:scrapid,',' || bis.scrapid || ',') > 0
                                           AND bis.accountid = :accountid
                                           AND (valueflag = 0 OR checkflag = 0 OR bis.syncflag =1 OR bis.scraptype = 2 OR
                                                bis.incident IS NOT NULL)";
					OracleParameter[] oracleParameter = new OracleParameter[]
			   {
					new OracleParameter(":accountid",OracleDbType.Int32, userInfo.AccountID, ParameterDirection.Input),
					new OracleParameter(":scrapid",OracleDbType.NVarchar2, scrapids, ParameterDirection.Input),
			   };

					DataTable NoneDt = oracleTrConn.GetSqlResultToDt(sqlString, oracleParameter);
					if (NoneDt != null && NoneDt.Rows.Count > 0)
					{
						sre.Status = Constant.ServiceResultStatus.DataChanged;
						sre.Message = "数据状态已被修改！";
						return sre;
					}

					//生成推送数据
					sqlString = @"SELECT wmsys.wm_concat(bis.scrapid) scrapids
                                               ,bis.idnrk
                                              ,bis.idnrkname
                                              ,SUM(menge) menge
                                              ,bis.meins
                                              ,mdd.remarks meinsname
                                              ,bis.lgort
                                              ,bis.charg
                                              ,bis.INCIDENT 
                                          FROM tp_pm_barcodeidnrkscrap bis
                                          LEFT JOIN tp_mst_datadictionary mdd
                                            ON mdd.dictionaryvalue = bis.meins
                                           AND mdd.dictionarytype = 'TPC012'
                                           where instr(:scrapids,','||bis.scrapid||',')>0
                                         GROUP BY bis.idnrk
                                                 ,bis.idnrkname
                                                 ,meins
                                                 ,mdd.remarks 
                                                 ,bis.lgort
                                                 ,bis.INCIDENT
                                                 ,bis.charg";
					oracleParameter = new OracleParameter[]
				 {
						new OracleParameter(":scrapids",OracleDbType.NVarchar2, scrapids, ParameterDirection.Input),
				 };
					DataTable NoneInfo = oracleTrConn.GetSqlResultToDt(sqlString, oracleParameter);
					if (NoneInfo != null && NoneInfo.Rows.Count > 0)
					{
						foreach (DataRow item in NoneInfo.Rows)
						{
							string strResult = BPMDataLogic.PushBPM(item);
							Dictionary<string, object> data = JsonConvert.DeserializeObject<Dictionary<string, object>>(strResult);
							string isSeccess = "0";//bpm 同步失败
							if (data["Result"].ToString() == "1")
							{
								isSeccess = "1";

								//更新报损履历
								sqlString = @" UPDATE tp_pm_barcodeidnrkscrap
												SET syncflag     = :syncflag
												   ,errormessage = :message
												   ,documentno   = :documentno
												   ,incident     = :incident
											  WHERE instr(',' || :scrapids || ',',',' || scrapid || ',') > 0";
								oracleParameter = new OracleParameter[]
							 {
								new OracleParameter(":scrapids",OracleDbType.NVarchar2, item["scrapids"].ToString(), ParameterDirection.Input),
								new OracleParameter(":syncflag",OracleDbType.NVarchar2, isSeccess,ParameterDirection.Input),
								new OracleParameter(":message",OracleDbType.NVarchar2, data["ErrorMessage"].ToString(),ParameterDirection.Input),
								new OracleParameter(":documentno",OracleDbType.NVarchar2, data["DOCUMENTNO"].ToString(),ParameterDirection.Input),
								new OracleParameter(":incident",OracleDbType.NVarchar2, data["Incident"].ToString(),ParameterDirection.Input),
							 };
								returnRows += oracleTrConn.ExecuteNonQuery(sqlString, oracleParameter);
							}
							else
							{
								//更新报损履历
								sqlString = @" UPDATE tp_pm_barcodeidnrkscrap
												SET syncflag     = :syncflag
												   ,errormessage = :message
												   ,incident     = :incident
											  WHERE instr( ',' || :scrapids || ',',',' || scrapid || ',') > 0";
								oracleParameter = new OracleParameter[]
							 {
								new OracleParameter(":scrapids",OracleDbType.NVarchar2, item["scrapids"].ToString(), ParameterDirection.Input),
								new OracleParameter(":syncflag",OracleDbType.NVarchar2, isSeccess,ParameterDirection.Input),
								new OracleParameter(":message",OracleDbType.NVarchar2, data["ErrorMessage"].ToString(),ParameterDirection.Input),
								new OracleParameter(":incident",OracleDbType.NVarchar2, data["Incident"].ToString(),ParameterDirection.Input),
							 };
								sre.OtherStatus = -1;
								sre.Message = data["ErrorMessage"].ToString();
								return sre;
							}
							
						}
					}
				}
				#endregion

				#region 再次推送
				DataRow[] pushagin = IdnrkScrapDt.Select("INCIDENT is not null");
				if(pushagin.Length>0)
				{
					string scrapids = ",";
					foreach (DataRow item in IdnrkScrapDt.Rows)
					{
						scrapids += item["SCRAPID"].ToString() + ",";
					}

					//校验是否存在状态改变数据
					string sqlString = @"SELECT 1
                                          FROM tp_pm_barcodeidnrkscrap bis
                                         WHERE instr(:scrapid,',' || bis.scrapid || ',') > 0
                                           AND bis.accountid = :accountid
                                           AND (valueflag = 0 OR checkflag = 0 OR bis.syncflag = 1 OR bis.scraptype = 2 OR
                                                bis.incident IS  NULL)";
					OracleParameter[] oracleParameter = new OracleParameter[]
			   {
					new OracleParameter(":accountid",OracleDbType.Int32, userInfo.AccountID, ParameterDirection.Input),
					new OracleParameter(":scrapid",OracleDbType.NVarchar2, scrapids, ParameterDirection.Input),
			   };

					DataTable NoneDt = oracleTrConn.GetSqlResultToDt(sqlString, oracleParameter);
					if (NoneDt != null && NoneDt.Rows.Count > 0)
					{
						sre.Status = Constant.ServiceResultStatus.DataChanged;
						sre.Message = "数据状态已被修改！";
						return sre;
					}

					//获取推送数据
						sqlString = @"SELECT wmsys.wm_concat(bis.scrapid) scrapids
                                               ,bis.idnrk
                                              ,bis.idnrkname
                                              ,SUM(menge) menge
                                              ,bis.meins
                                              ,mdd.remarks meinsname
                                              ,bis.lgort
                                              ,bis.charg
                                              ,bis.INCIDENT
                                          FROM tp_pm_barcodeidnrkscrap bis
                                          LEFT JOIN tp_mst_datadictionary mdd
                                            ON mdd.dictionaryvalue = bis.meins
                                           AND mdd.dictionarytype = 'TPC012'
                                           where instr(:scrapids ,','||bis.scrapid||',')>0
                                         GROUP BY bis.idnrk
                                                 ,bis.idnrkname
                                                 ,meins
                                                 ,mdd.remarks 
                                                 ,bis.lgort
                                                 ,bis.INCIDENT
                                                 ,bis.charg";

					 oracleParameter = new OracleParameter[]
				 {
						new OracleParameter(":scrapids",OracleDbType.NVarchar2, scrapids, ParameterDirection.Input),
				 };
					DataTable NoneInfo = oracleTrConn.GetSqlResultToDt(sqlString, oracleParameter);
					if (NoneInfo != null && NoneInfo.Rows.Count > 0)
					{
						foreach (DataRow item in NoneInfo.Rows)
						{
							string strResult = BPMDataLogic.PushBPM(item);
							Dictionary<string, object> data = JsonConvert.DeserializeObject<Dictionary<string, object>>(strResult);
							string isSeccess = "0";//bpm 审批不通过
							if (data["Result"].ToString() == "1")
							{
								isSeccess = "1";
								//更新报损履历
								sqlString = @" UPDATE tp_pm_barcodeidnrkscrap
												SET syncflag     = :syncflag
												   ,errormessage = :message
												   ,documentno   = :documentno
												   ,incident     = :incident
											  WHERE instr( ',' || :scrapids || ',',',' || scrapid || ',') > 0";
								oracleParameter = new OracleParameter[]
							 {
								new OracleParameter(":scrapids",OracleDbType.NVarchar2, item["scrapids"].ToString(), ParameterDirection.Input),
								new OracleParameter(":syncflag",OracleDbType.NVarchar2, isSeccess,ParameterDirection.Input),
								new OracleParameter(":message",OracleDbType.NVarchar2, data["ErrorMessage"].ToString(),ParameterDirection.Input),
								new OracleParameter(":documentno",OracleDbType.NVarchar2, data["DOCUMENTNO"].ToString(),ParameterDirection.Input),
								new OracleParameter(":incident",OracleDbType.NVarchar2, data["Incident"].ToString(),ParameterDirection.Input),
							 };
								returnRows += oracleTrConn.ExecuteNonQuery(sqlString, oracleParameter);
							}
							else
							{
								//更新报损履历
								sqlString = @" UPDATE tp_pm_barcodeidnrkscrap
												SET syncflag     = :syncflag
												   ,errormessage = :message
												   ,incident     = :incident
											  WHERE instr( ',' || :scrapids || ',',',' || scrapid || ',') > 0";
								oracleParameter = new OracleParameter[]
							 {
								new OracleParameter(":scrapids",OracleDbType.NVarchar2, item["scrapids"].ToString(), ParameterDirection.Input),
								new OracleParameter(":syncflag",OracleDbType.NVarchar2, isSeccess,ParameterDirection.Input),
								new OracleParameter(":message",OracleDbType.NVarchar2, data["ErrorMessage"].ToString(),ParameterDirection.Input),
								new OracleParameter(":incident",OracleDbType.NVarchar2, data["Incident"].ToString(),ParameterDirection.Input),
							 };
								sre.OtherStatus = -1;
								sre.Message = data["ErrorMessage"].ToString();
								return sre;
							}
							
						}
					}
				}
				#endregion

				sre.OtherStatus = returnRows;
				oracleTrConn.Commit();
			}
			catch (Exception ex)
			{

				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Rollback();
					oracleTrConn.Disconnect();
				}
				throw ex;
			}
			finally
			{
				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Disconnect();
				}
			}
			return sre;
		}

		/// <summary>
		/// 撤销bpm同步数据
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity CancelSynIdnrkScrap(ClientRequestEntity cre, SUserInfo userInfo)
		{
			ServiceResultEntity sre = new ServiceResultEntity();
			DataTable IdnrkScrapDt = cre.Data.Tables[0];

			int returnRows = 0;
			IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);

			try
			{
				string scrapids = ",";
				foreach (DataRow item in IdnrkScrapDt.Rows)
				{
					scrapids += item["SCRAPID"].ToString() + ",";
				}

				//获取待撤销bpm 实例号
				string sqlString = @"SELECT wmsys.wm_concat(bis.scrapid) scrapids
											  ,bis.incident
										  FROM tp_pm_barcodeidnrkscrap bis
										 WHERE instr( :scrapids ,',' || bis.scrapid || ',') > 0
										   AND bis.syncflag = 1
										   group by incident";

				OracleParameter [] oracleParameter = new OracleParameter[]
				 {
						new OracleParameter(":scrapids",OracleDbType.NVarchar2, scrapids, ParameterDirection.Input),
				 };
				DataTable Info = oracleTrConn.GetSqlResultToDt(sqlString, oracleParameter);

				if(Info!=null&&Info.Rows.Count>0)
				{
					foreach (DataRow item in Info.Rows)
					{
						string strResult = BPMDataLogic.CancelPushBPM(Convert.ToInt32( item["incident"]));
						Dictionary<string, object> data = JsonConvert.DeserializeObject<Dictionary<string, object>>(strResult);
						string isSeccess = "0";//bpm 审批不通过
						if (data["Result"].ToString() == "1")
						{
							isSeccess = "0";

							//更新报损履历
							sqlString = @" UPDATE tp_pm_barcodeidnrkscrap
												SET syncflag     = :syncflag
												   ,errormessage = :message
												   ,incident     = :incident
											  WHERE instr(  ',' || :scrapids || ',', ',' || scrapid || ',' ) > 0";
							oracleParameter = new OracleParameter[]
						 {
								new OracleParameter(":scrapids",OracleDbType.NVarchar2, item["scrapids"].ToString(), ParameterDirection.Input),
								new OracleParameter(":syncflag",OracleDbType.NVarchar2, isSeccess,ParameterDirection.Input),
								new OracleParameter(":message",OracleDbType.NVarchar2, data["ErrorMessage"].ToString(),ParameterDirection.Input),
								new OracleParameter(":incident",OracleDbType.NVarchar2, data["Incident"].ToString(),ParameterDirection.Input),
						 };
							returnRows += oracleTrConn.ExecuteNonQuery(sqlString, oracleParameter);
						}
						else
						{
							//更新报损履历
							sqlString = @" UPDATE tp_pm_barcodeidnrkscrap
												SET 
												   errormessage = :message
												   ,incident     = :incident
											  WHERE instr(  ',' || :scrapids || ',', ',' || scrapid || ',' ) > 0";
							oracleParameter = new OracleParameter[]
						 {
								new OracleParameter(":scrapids",OracleDbType.NVarchar2, item["scrapids"].ToString(), ParameterDirection.Input),
								new OracleParameter(":message",OracleDbType.NVarchar2, data["ErrorMessage"].ToString(),ParameterDirection.Input),
								new OracleParameter(":incident",OracleDbType.NVarchar2, data["Incident"].ToString(),ParameterDirection.Input),
						 };
							oracleTrConn.ExecuteNonQuery(sqlString, oracleParameter);
							sre.Message = data["ErrorMessage"].ToString();
							sre.OtherStatus = -999;
						}
						
					}
				}
				sre.OtherStatus = returnRows;
				oracleTrConn.Commit();
			}
			catch (Exception ex)
			{
				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Rollback();
					oracleTrConn.Disconnect();
				}
				throw ex;
			}
			finally
			{
				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Disconnect();
				}
			}
			return sre;
		}

		/// <summary>
		/// 查询成本中心（BPM）
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetCostCenter(ClientRequestEntity cre, SUserInfo userInfo)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
			ServiceResultEntity sre = new ServiceResultEntity();
			try
			{
				string sqlString = @"SELECT 0 check1
                                          ,t.dictionaryvalue COSTCENTER
                                          ,t.remarks COSTCENTERNAME
                                      FROM tp_mst_datadictionary t
                                     WHERE t.valueflag = 1
                                       AND t.dictionarytype = 'TPC013'
                                       AND t.accountid = :accountid
                                       AND (:dictionaryvalue IS NULL OR :dictionaryvalue = '' OR
                                           instr(t.dictionaryvalue, :dictionaryvalue) > 0)
                                       AND (:remark IS NULL OR :remark = '' OR instr(t.remarks, :remark) > 0)";
				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":accountid",OracleDbType.Int32, userInfo.AccountID, ParameterDirection.Input),
					new OracleParameter(":dictionaryvalue",OracleDbType.Varchar2, cre.Properties["CostCenter"], ParameterDirection.Input),
					new OracleParameter(":remark",OracleDbType.Varchar2, cre.Properties["CostcenterName"], ParameterDirection.Input),
				};

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{

				throw ex;
			}
		}

		/// <summary>
		/// 保存报损履历成本中心
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity SaveCostCenter(ClientRequestEntity cre, SUserInfo userInfo)
		{
			ServiceResultEntity sre = new ServiceResultEntity();

			int returnRows = 0;
			IDBTransaction oracleTrConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
			string sqlString = string.Empty;
			try
			{
				string CostCenter = cre.Properties["CostCenter"].ToString();
				string CostCenterName = cre.Properties["CostCenterName"].ToString();

				DataTable data = cre.Data.Tables[0];

				DataRow[] rows = data.Select("INCIDENT is null");
				if (rows.Length > 0)
				{
					foreach (DataRow item in rows)
					{
						sqlString = @"update TP_PM_BARCODEIDNRKSCRAP
                                        set COSTCENTERNAME =:COSTCENTERNAME
                                        ,costcenter = :costcenter
                                        where SCRAPID = :SCRAPID";
						OracleParameter[] oracleParameter = new OracleParameter[]
					   {
							new OracleParameter(":SCRAPID",OracleDbType.Int32, item["SCRAPID"], ParameterDirection.Input),
							new OracleParameter(":COSTCENTERNAME",OracleDbType.Varchar2, CostCenterName, ParameterDirection.Input),
							new OracleParameter(":costcenter",OracleDbType.Varchar2, CostCenter, ParameterDirection.Input),
					   };
						returnRows += oracleTrConn.ExecuteNonQuery(sqlString, oracleParameter);

					}
				}
				//BPM流程实例，相同实例数据同时更新
				DataRow[] drs = data.Select("INCIDENT is not null");
				if (drs.Length > 0)
				{
					string SCRAPIDs = ",";
					//传入拼接报损履历主键id
					foreach (DataRow item in drs)
					{
						SCRAPIDs += item["SCRAPID"].ToString() + ",";
					}

					//查询报损履历数据
					sqlString = @"SELECT bs.scrapid
                                          ,bs.idnrk
                                          ,bs.incident
                                      FROM tp_pm_barcodeidnrkscrap bs
                                     INNER JOIN (SELECT bis.idnrk
                                                       ,bis.incident
                                                   FROM tp_pm_barcodeidnrkscrap bis
                                                  WHERE instr( ',' || :scrapids || ',', ',' || bis.scrapid || ',') > 0
                                                  GROUP BY bis.idnrk
                                                          ,bis.incident) t
                                        ON bs.idnrk = t.idnrk
                                       AND bs.incident = t.incident";
					OracleParameter[] oracleParameter = new OracleParameter[]
					  {
							new OracleParameter(":scrapids",OracleDbType.Int32, SCRAPIDs, ParameterDirection.Input),
					  };
					DataTable bsdt = oracleTrConn.GetSqlResultToDt(sqlString, oracleParameter);

					if (bsdt != null && bsdt.Rows.Count > 0)
					{
						foreach (DataRow item in bsdt.Rows)
						{
							sqlString = @"update TP_PM_BARCODEIDNRKSCRAP
                                        set COSTCENTERNAME =:COSTCENTERNAME
                                        ,costcenter = :costcenter
                                        where SCRAPID = :SCRAPID";
							oracleParameter = new OracleParameter[]
						   {
							new OracleParameter(":SCRAPID",OracleDbType.Int32, item["SCRAPID"], ParameterDirection.Input),
							new OracleParameter(":COSTCENTERNAME",OracleDbType.Varchar2, CostCenterName, ParameterDirection.Input),
							new OracleParameter(":costcenter",OracleDbType.Varchar2, CostCenter, ParameterDirection.Input),
						   };
							returnRows += oracleTrConn.ExecuteNonQuery(sqlString, oracleParameter);

						}
					}
				}

				sre.OtherStatus = returnRows;
				oracleTrConn.Commit();
			}
			catch (Exception ex)
			{

				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Rollback();
					oracleTrConn.Disconnect();
				}
				throw ex;
			}
			finally
			{
				if (oracleTrConn.ConnState == System.Data.ConnectionState.Open)
				{
					oracleTrConn.Disconnect();
				}
			}
			return sre;
		}
		#endregion

		#region 报工移库
		/// <summary>
		/// 报工移库_同步SAP数据（自动）
		/// </summary>
		/// <param name="date"></param>
		public static void BGYKToSAP(DateTime date, DateTime ndate)
		{
			IDBTransaction oracleConn = null;
			ServiceResultEntity sre = new ServiceResultEntity();
			int logid = 0;
			string message = string.Empty;
			string sqlString = string.Empty;
			try
			{
				#region 生成日志
				OracleParameter[] paras = new OracleParameter[]
				{
					new OracleParameter("in_dateend", OracleDbType.Date, ndate, ParameterDirection.Input),
					new OracleParameter("out_logid", OracleDbType.Int32, null, ParameterDirection.Output),
					new OracleParameter("out_msg", OracleDbType.NVarchar2, 500, null, ParameterDirection.Output)
				};

				oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);
				DataSet ds = oracleConn.ExecStoredProcedure("PRO_SAP_HEGII_WORKDATA_BGYK", paras);
				int.TryParse(paras[1].Value + "", out logid);
				message = paras[2].Value + "";
				oracleConn.Commit();
				#endregion

				#region 同步SAP
				oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);

				//2022年9月8日11:38:51 更改 by fy
				//sqlString = @"
				//SELECT WERKS,
				//	   MATNR,
				//	   ZJDNU,
				//	   ZSCS,
				//	   ZSCCJ,
				//	   ZSCMS,
				//	   CHARG,
				//	   MENGE,
				//	   ZMLID
				//  FROM TSAP_HEGII_WORKDATA_BGYK
				// WHERE LOGID = :LOGID ";
				sqlString = @"SELECT
                                A.WERKS,
	                            A.MATNR,
	                            A.ZJDNU,
	                            -- A.ZSCS,
	                            'T' AS ZSCS,
	                            A.ZSCCJ,
	                            A.ZSCMS,
	                            A.CHARG,
	                            A.MENGE,
	                            A.ZMLID,
	                            to_char(B.EXECUTEDATEBEGIN, 'yyyymmddhh24miss') AS ZYWKS,
                                to_char(B.EXECUTEDATEEND, 'yyyymmddhh24miss' ) AS ZYWJS,
                                to_char(SYSDATE, 'yyyymmdd' ) AS ZBUDAT,
                                to_char(SYSDATE, 'yyyymmddhh24miss' ) AS ZMONT,
                                '' AS ZTYPE1,
                                '' AS ZMSG1
                            FROM
                                TSAP_HEGII_WORKDATA_BGYK A
                                INNER JOIN TSAP_HEGII_DATALOG_BGYK B ON B.LOGID = A.LOGID
                            WHERE
                                A.LOGID = :LOGID";

				paras = new OracleParameter[]
				{
					new OracleParameter(":LOGID", OracleDbType.Int32, logid, ParameterDirection.Input),
				};

				DataTable workData = oracleConn.GetSqlResultToDt(sqlString, paras);

				//获取报工SAP接口是否开启
				sqlString = "select SAP_INI_BG from TP_SYS_SAPCONFIG";
				string SAP_ING_NEW = oracleConn.GetSqlResultToStr(sqlString);

				if (workData != null && workData.Rows.Count > 0 && SAP_ING_NEW == "1")
				{
					string postString = "{\"IT_INPUT\":{\"item\":" + JsonHelper.ToJson(ModelConvertHelper<BGYKToSAP>.ConvertToModel(workData)) + "}}";
					INIUtility ini = INIUtility.Instance(INIUtility.IniFile.SAP_HEGII);
					string url034 = ini.ReadIniData("SAP_NEW_INFO", "Url034");
					//url034 = "http://hgs4podev.hegii.com:50200/RESTAdapter/DKMES/ZPPFM034";
					string result = PostData(url034, postString, "POST");
					string ztype = JObject.Parse(result)["ZTYPE"].ToString();
					string zmsg = JObject.Parse(result)["ZMSG"].ToString();
					sqlString = "update TSAP_HEGII_DATALOG_BGYK t set t.EndTime = sysdate, ZTYPE = :ZTYPE, ZMSG =:ZMSG where logid = :logid";
					paras = new OracleParameter[]
					{
						new OracleParameter(":logid", OracleDbType.Varchar2, logid, ParameterDirection.Input),
						new OracleParameter(":ZTYPE", OracleDbType.Varchar2, ztype, ParameterDirection.Input),
						new OracleParameter(":ZMSG", OracleDbType.Varchar2, zmsg, ParameterDirection.Input),
					};
					oracleConn.ExecuteNonQuery(sqlString, paras);
					oracleConn.Commit();
				}
				#endregion
			}
			catch (Exception ex)
			{
				OutputLog.TraceLog(LogPriority.Error,
						"BGYKToSAP",
						"报工移库" + date.ToString("yyyy-MM-dd HH:mm:ss"),
						ex.ToString(),
						LocalPath.LogExePath + "SAP_HEGII\\Error_");
			}
		}

		public static void BGYKToSAP_TEST(DateTime date, DateTime ndate)
		{
			IDBTransaction oracleConn = null;
			ServiceResultEntity sre = new ServiceResultEntity();
			int logid = 0;
			string message = string.Empty;
			string sqlString = string.Empty;
			try
			{
				#region 同步SAP
				oracleConn = ClsDbFactory.CreateDBTransaction(DataBaseType.ORACLE, DataManager.ConnectionString);

				//2022年9月8日11:38:51 更改 by fy
				//sqlString = @"
				//SELECT WERKS,
				//	   MATNR,
				//	   ZJDNU,
				//	   ZSCS,
				//	   ZSCCJ,
				//	   ZSCMS,
				//	   CHARG,
				//	   MENGE,
				//	   ZMLID
				//  FROM TSAP_HEGII_WORKDATA_BGYK
				// WHERE LOGID = :LOGID ";

				sqlString = @"SELECT '5000' WERKS,MATNR,to_char(ZJDNU) ZJDNU,'T' AS ZSCS,to_char(ZSCCJ) ZSCCJ,to_char(ZSCMS) ZSCMS,to_char(CHARG)CHARG,
                                to_char(MENGE) MENGE,to_char(ZMLID) ZMLID,
                                to_char(:V_DATEBEGIN, 'yyyymmddhh24miss') AS ZYWKS,
                                to_char(:IN_DATEEND, 'yyyymmddhh24miss' ) AS ZYWJS,
                                to_char(SYSDATE, 'yyyymmdd' ) AS ZBUDAT,
                                to_char(SYSDATE, 'yyyymmddhh24miss' ) AS ZMONT FROM (
                        SELECT
	                        T.MATNR,
	                        '30' AS ZJDNU,
	                        G.GOODS_LINE_CODE AS ZSCS,
	                        '2' AS ZSCCJ,
	                        T.ZSCMS,
	                        TO_CHAR( SYSDATE, 'yyyymm' ) AS CHARG,
	                        SUM( T.MENGE ) AS MENGE,
	                        '3' AS ZMLID 
                        FROM
	                        (-- 3-3线上施釉（3）到3#刮登（99）
	                        SELECT
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE AS MATNR,
		                        DECODE( GDD.TESTMOULDFLAG, '1', 'Y', 'C' ) AS ZSCMS,
		                        COUNT( 1 ) AS MENGE 
	                        FROM
		                        TP_PM_PRODUCTIONDATA PD1
		                        INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD1.GROUTINGDAILYDETAILID 
	                        WHERE
		                        PD1.CREATETIME >= :V_DATEBEGIN 
		                        AND PD1.CREATETIME < :IN_DATEEND 
		                        AND PD1.PROCEDUREID = 99 
		                        AND PD1.VALUEFLAG = '1' 
		                        AND EXISTS ( SELECT 1 FROM TP_PM_PRODUCTIONDATA PD2 WHERE PD2.BARCODE = PD1.BARCODE AND PD2.PROCEDUREID = 3 ) 
	                        GROUP BY
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE,
		                        GDD.TESTMOULDFLAG UNION ALL-- 3-3线上施釉（3）到3#刮登（99）撤销了的
	                        SELECT
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE AS MATNR,
		                        DECODE( GDD.TESTMOULDFLAG, '1', 'Y', 'C' ) AS ZSCMS,
		                        - COUNT( 1 ) AS MENGE 
	                        FROM
		                        TP_PM_PRODUCTIONDATA PD1
		                        INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD1.GROUTINGDAILYDETAILID 
	                        WHERE
		                        PD1.BACKOUTTIME >= :V_DATEBEGIN 
		                        AND PD1.BACKOUTTIME < :IN_DATEEND 
		                        AND PD1.PROCEDUREID = 99 
		                        AND PD1.VALUEFLAG = '0' 
		                        AND EXISTS ( SELECT 1 FROM TP_PM_PRODUCTIONDATA PD2 WHERE PD2.BARCODE = PD1.BARCODE AND PD2.PROCEDUREID = 3 ) 
	                        GROUP BY
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE,
		                        GDD.TESTMOULDFLAG 
	                        ) T
	                        LEFT JOIN TP_MST_GOODS G ON G.GOODSID = T.GOODSID 
                        GROUP BY
	                        T.MATNR,
	                        T.ZSCMS,
	                        G.GOODS_LINE_CODE UNION ALL
                        SELECT
	                        T.MATNR,
	                        '40' AS ZJDNU,
	                        G.GOODS_LINE_CODE AS ZSCS,
	                        '2' AS ZSCCJ,
	                        T.ZSCMS,
	                        TO_CHAR( SYSDATE, 'yyyymm' ) AS CHARG,
	                        SUM( T.MENGE ) AS MENGE,
	                        '3' AS ZMLID 
                        FROM
	                        (-- 3#卸窑（103）到7-1成检出窑交接（11）
	                        SELECT
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE AS MATNR,
		                        DECODE( GDD.TESTMOULDFLAG, '1', 'Y', 'C' ) AS ZSCMS,
		                        COUNT( 1 ) AS MENGE 
	                        FROM
		                        TP_PM_PRODUCTIONDATA PD1
		                        INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD1.GROUTINGDAILYDETAILID 
	                        WHERE
		                        PD1.CREATETIME >= :V_DATEBEGIN 
		                        AND PD1.CREATETIME < :IN_DATEEND 
		                        AND PD1.PROCEDUREID = 11 
		                        AND PD1.VALUEFLAG = '1' 
		                        AND EXISTS ( SELECT 1 FROM TP_PM_PRODUCTIONDATA PD2 WHERE PD2.BARCODE = PD1.BARCODE AND PD2.PROCEDUREID = 103 ) 
	                        GROUP BY
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE,
		                        GDD.TESTMOULDFLAG UNION ALL-- 3-3线上施釉（3）到3#刮登（99）撤销了的
	                        SELECT
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE AS MATNR,
		                        DECODE( GDD.TESTMOULDFLAG, '1', 'Y', 'C' ) AS ZSCMS,
		                        - COUNT( 1 ) AS MENGE 
	                        FROM
		                        TP_PM_PRODUCTIONDATA PD1
		                        INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD1.GROUTINGDAILYDETAILID 
	                        WHERE
		                        PD1.BACKOUTTIME >= :V_DATEBEGIN 
		                        AND PD1.BACKOUTTIME < :IN_DATEEND 
		                        AND PD1.PROCEDUREID = 11 
		                        AND PD1.VALUEFLAG = '0' 
		                        AND EXISTS ( SELECT 1 FROM TP_PM_PRODUCTIONDATA PD2 WHERE PD2.BARCODE = PD1.BARCODE AND PD2.PROCEDUREID = 103 ) 
	                        GROUP BY
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE,
		                        GDD.TESTMOULDFLAG 
	                        ) T
	                        LEFT JOIN TP_MST_GOODS G ON G.GOODSID = T.GOODSID 
                        GROUP BY
	                        T.MATNR,
	                        T.ZSCMS,
	                        G.GOODS_LINE_CODE UNION ALL
                        SELECT
	                        T.MATNR,
	                        '40' AS ZJDNU,
	                        G.GOODS_LINE_CODE AS ZSCS,
	                        '3' AS ZSCCJ,
	                        T.ZSCMS,
	                        TO_CHAR( SYSDATE, 'yyyymm' ) AS CHARG,
	                        SUM( T.MENGE ) AS MENGE,
	                        '2' AS ZMLID 
                        FROM
	                        (-- 6-1卸窑（10）到3#成检交接（104）
	                        SELECT
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE AS MATNR,
		                        DECODE( GDD.TESTMOULDFLAG, '1', 'Y', 'C' ) AS ZSCMS,
		                        COUNT( 1 ) AS MENGE 
	                        FROM
		                        TP_PM_PRODUCTIONDATA PD1
		                        INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD1.GROUTINGDAILYDETAILID 
	                        WHERE
		                        PD1.CREATETIME >= :V_DATEBEGIN 
		                        AND PD1.CREATETIME < :IN_DATEEND 
		                        AND PD1.PROCEDUREID = 104 
		                        AND PD1.VALUEFLAG = '1' 
		                        AND EXISTS ( SELECT 1 FROM TP_PM_PRODUCTIONDATA PD2 WHERE PD2.BARCODE = PD1.BARCODE AND PD2.PROCEDUREID = 10 ) 
	                        GROUP BY
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE,
		                        GDD.TESTMOULDFLAG UNION ALL-- 6-1卸窑（10）到3#成检交接（104）撤销了的
	                        SELECT
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE AS MATNR,
		                        DECODE( GDD.TESTMOULDFLAG, '1', 'Y', 'C' ) AS ZSCMS,
		                        - COUNT( 1 ) AS MENGE 
	                        FROM
		                        TP_PM_PRODUCTIONDATA PD1
		                        INNER JOIN TP_PM_GROUTINGDAILYDETAIL GDD ON GDD.GROUTINGDAILYDETAILID = PD1.GROUTINGDAILYDETAILID 
	                        WHERE
		                        PD1.BACKOUTTIME >= :V_DATEBEGIN 
		                        AND PD1.BACKOUTTIME < :IN_DATEEND 
		                        AND PD1.PROCEDUREID = 104 
		                        AND PD1.VALUEFLAG = '0' 
		                        AND EXISTS ( SELECT 1 FROM TP_PM_PRODUCTIONDATA PD2 WHERE PD2.BARCODE = PD1.BARCODE AND PD2.PROCEDUREID = 10 ) 
	                        GROUP BY
		                        GDD.GOODSID,
		                        GDD.MATERIALCODE,
		                        GDD.TESTMOULDFLAG 
	                        ) T
	                        LEFT JOIN TP_MST_GOODS G ON G.GOODSID = T.GOODSID 
                        GROUP BY
	                        T.MATNR,
	                        T.ZSCMS,
	                        G.GOODS_LINE_CODE
                        ) WHERE MENGE > 0";

				OracleParameter[] paras = new OracleParameter[]
				{
					new OracleParameter(":V_DATEBEGIN",OracleDbType.Date, date, ParameterDirection.Input),
					new OracleParameter(":IN_DATEEND",OracleDbType.Date, ndate, ParameterDirection.Input),
				};

				DataTable workData = oracleConn.GetSqlResultToDt(sqlString, paras);

				//获取报工SAP接口是否开启
				sqlString = "select SAP_INI_BG from TP_SYS_SAPCONFIG";
				string SAP_ING_NEW = oracleConn.GetSqlResultToStr(sqlString);

				if (workData != null && workData.Rows.Count > 0 && SAP_ING_NEW == "0")
				{
					string postString = "{\"IT_INPUT\":{\"item\":" + JsonHelper.ToJson(ModelConvertHelper<BGYKToSAP>.ConvertToModel(workData)) + "}}";
					//INIUtility ini = INIUtility.Instance(INIUtility.IniFile.SAP_HEGII);
					//string url034 = ini.ReadIniData("SAP_NEW_INFO", "Url034");
					string url034 = "http://hgs4podev.hegii.com:50200/RESTAdapter/DKMES/ZPPFM034";
					string result = PostData(url034, postString, "POST");
					string ztype = JObject.Parse(result)["ZTYPE"].ToString();
					string zmsg = JObject.Parse(result)["ZMSG"].ToString();
					//sqlString = "update TSAP_HEGII_DATALOG_BGYK t set t.EndTime = sysdate, ZTYPE = :ZTYPE, ZMSG =:ZMSG where logid = :logid";
					//paras = new OracleParameter[]
					//{
					//    new OracleParameter(":logid", OracleDbType.Varchar2, logid, ParameterDirection.Input),
					//    new OracleParameter(":ZTYPE", OracleDbType.Varchar2, ztype, ParameterDirection.Input),
					//    new OracleParameter(":ZMSG", OracleDbType.Varchar2, zmsg, ParameterDirection.Input),
					//};
					//oracleConn.ExecuteNonQuery(sqlString, paras);
					oracleConn.Commit();
				}
				#endregion
			}
			catch (Exception ex)
			{
				OutputLog.TraceLog(LogPriority.Error,
						"BGYKToSAP",
						"报工移库" + date.ToString("yyyy-MM-dd HH:mm:ss"),
						ex.ToString(),
						LocalPath.LogExePath + "SAP_HEGII\\Error_");
			}
		}

		/// <summary>
		/// 查询同步日志
		/// </summary>
		/// <param name="cre"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetDataLog_BGYK(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);

			ServiceResultEntity sre = new ServiceResultEntity();
			try
			{
				string sqlString = @"
                SELECT DL.LOGID,
                       DL.BEGINTIME,
                       DL.ENDTIME,
                       DL.YYYYMMDD,
                       DL.ZTYPE,
                       DL.ZMSG,
                       U.USERCODE SYNUSERCODE
                  FROM TSAP_HEGII_DATALOG_BGYK DL
                  LEFT JOIN TP_MST_USER U
                    ON U.USERID = DL.CREATEUSERID
                 WHERE DL.EXECUTEDATEBEGIN >= :DATEBEGIN
                   AND DL.EXECUTEDATEEND <= :DATEEND ";

				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":DATEBEGIN",OracleDbType.Date, cre.Properties["datebegin"], ParameterDirection.Input),
					new OracleParameter(":DATEEND",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
				};

				sqlString += "ORDER BY dl.logid DESC\n";

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}

		/// <summary>
		/// 查询同步明细
		/// </summary>
		/// <param name="logid"></param>
		/// <param name="userInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity GetWorkData_BGYK(ClientRequestEntity cre)
		{
			IDBConnection oracleConn = ClsDbFactory.CreateDBConnection(DataBaseType.ORACLE, DataManager.ConnectionString);
			ServiceResultEntity sre = new ServiceResultEntity();
			try
			{
				//add xiacm 2022-10-21
				int logid = Convert.ToInt32(cre.Request);
				string sqlString = @" 
                SELECT WERKS,
                       MATNR,
                       ZJDNU,
                       ZSCS,
                       ZSCCJ,
                       ZSCMS,
                       CHARG,
                       MENGE,
                       ZMLID
                  FROM TSAP_HEGII_WORKDATA_BGYK WD ";
				if (logid > 0)
				{
					sqlString += "WHERE WD.LOGID = :LOGID ";
				}
				else
				{
					sqlString += @" INNER JOIN TSAP_HEGII_DATALOG_BGYK DL 
                                        ON WD.LOGID = DL.LOGID
                                     WHERE DL.EXECUTEDATEBEGIN >= :DATEBEGIN
                                        AND DL.EXECUTEDATEEND <= :DATEEND ";
				}

				OracleParameter[] oracleParameter = new OracleParameter[]
				{
					new OracleParameter(":LOGID",OracleDbType.Int32, logid, ParameterDirection.Input),
					new OracleParameter(":DATEBEGIN",OracleDbType.Date, cre.Properties["datebegin"], ParameterDirection.Input),
					new OracleParameter(":DATEEND",OracleDbType.Date, cre.Properties["dateend"], ParameterDirection.Input),
				};

				sre.Data = oracleConn.GetSqlResultToDs(sqlString, oracleParameter);
				return sre;
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}
		#endregion

		#region PostData 请求
		public static string PostData(string url, string data, string method)
		{
			//将单引号转义成双引号
			data = data.Replace("'", "\"");
			//创建Web访问对象
			HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
			//把用户传过来的数据转成“UTF-8”的字节流
			byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(data);

			myRequest.Method = method;
			myRequest.ContentLength = buf.Length;
			myRequest.ContentType = "application/json;charset=UTF-8";
			//myRequest.MaximumAutomaticRedirections = 1;
			myRequest.AllowAutoRedirect = true;

			//UTF8标准转码加密
			INIUtility ini = INIUtility.Instance(INIUtility.IniFile.SAP_HEGII);
			// 配置文件
			string userName = ini.ReadIniData("SAP_NEW_INFO", "userName");

			// 测试
			//string userName = "hgsapdk:Sapdk#240";

			// 正式
			//string userName = "PODKMES:Sapdk#800";


			string base64Header = Convert.ToBase64String(Encoding.UTF8.GetBytes(userName));
			myRequest.Headers.Add("Authorization", "Basic " + base64Header);

			//发送请求
			Stream stream = myRequest.GetRequestStream();
			stream.Write(buf, 0, buf.Length);
			stream.Close();

			//获取接口返回值
			//通过Web访问对象获取响应内容
			HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
			//通过响应内容流创建StreamReader对象，因为StreamReader更高级更快
			StreamReader reader = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8);
			//string returnXml = HttpUtility.UrlDecode(reader.ReadToEnd());//如果有编码问题就用这个方法
			string returnXml = reader.ReadToEnd();//利用StreamReader就可以从响应内容从头读到尾
			reader.Close();
			myResponse.Close();

			// 结果
			OutputLog.TraceLog(LogPriority.Information,
					"报工030", method, data,
					LocalPath.LogExePath + "SAP_HEGII\\Info_030");

			return returnXml;
		}
		#endregion

		#region 转换
		public class ModelConvertHelper<T> where T : new()
		{
			public static List<T> ConvertToModel(DataTable dt)
			{
				// 定义集合
				List<T> ts = new List<T>();
				// 获得此模型的类型
				Type type = typeof(T);
				string tempName = "";
				foreach (DataRow dr in dt.Rows)
				{
					T t = new T();
					// 获得此模型的公共属性
					PropertyInfo[] propertys = t.GetType().GetProperties();

					foreach (PropertyInfo pi in propertys)
					{
						tempName = pi.Name;
						// 检查DataTable是否包含此列
						if (dt.Columns.Contains(tempName))
						{
							// 判断此属性是否有Setter
							if (!pi.CanWrite) continue;
							object value = dr[tempName];
							if (value != DBNull.Value)
								pi.SetValue(t, value, null);
						}
					}
					ts.Add(t);
				}
				return ts;
			}
		}
		#endregion
	}
}