1.收料通知单

南骏 池

2024-12-10 f35e2bfe37af2efa93ee6c8d986379325bdd0e84

 HandleData/AE_MES_ERP.cs

@@ -126,6 +126,7 @@
                case "TB_MESTOERP_WWRK"://MESWWRK金蝶条码入库（委外入库）(同步推送)
                case "TB_MESTOERP_QTRK"://MESQTRK金蝶条码入库（其他入库）(同步推送)
                case "TB_MESTOERP_CPRK"://MESCPRK金蝶条码入库（产品入库）(同步推送)
                case "TB_MESTOERP_SLTZ"://MESCPRK金蝶（收料通知单）(同步推送)
                case "TB_MESTOERP_CGRK"://MESCPRK金蝶条码入库（采购入库）(同步推送)
                case "TB_MESTOERP_XSCK"://MESCPRK金蝶条码出库（销售出库）(同步推送)
                case "TB_MESTOERP_WLQDBB"://MESGCBOM金蝶高冲用料变更(同步推送)
@@ -144,6 +145,8 @@
                case "TB_MESTOERP_SCDDXD"://推送审核送货单
                case "TB_MESTOERP_TransferIn"://分布式调入单
                case "TB_MESTOERP_ZJDB"://直接调拨单
                case "TB_MESTOERP_WWDDXD"://委外订单下达
                case "TB_MESTOERP_WWCG"://委外下推采购
                    result = MesToErp(drSource, ref msg, rtaskid);
                    break;
                case "TB_MESTOERP_GDRK"://ERP工单入库查询
@@ -1221,7 +1224,7 @@
            try
            {
                DataTable dt = ds.Tables[0];
                if (operatype == "INSERT")
                if (operatype == "INSERT" || operatype == "UPDATE")
                {
                    #region INSERT
                    //dt.Columns.Add("MAA005", typeof(string));
@@ -1268,7 +1271,7 @@
                                        GYS005='{5}',
                                        FUseOrgld='{6}'
                                    where ERPID='{0}'; ", dr["ERPID"]
                                                        , dr["GYS001"], dr["GYS002"], dr["GYS003"], dr["GYS004"], dr["GYS005"], dr["FUseOrgld"]);
                                                        , dr["GYSA001"], dr["GYSA002"], dr["GYSA003"], dr["GYSA004"], dr["GYSA005"], dr["FUseOrgld"]);
                    }
                    return _sqlHelper.ExecuteNonQuery(sql) > 0;
                    #endregion
@@ -1881,11 +1884,21 @@
                                if (dr.Table.Columns.Contains("CGAORG"))
                                {
                                    org = "丽德";
                                 
                                    string UP = string.Format(@"EXEC [WMS_CGLD_TOJX] '{0}' ", rtaskid);
                                    _sqlHelper.ExecuteNonQuery(UP);
                                    dr["NEWERPID"] = "LD"+dr["ERPID"].ToString();
                                    IDList.Add("LD"+dr["ERPID"].ToString());
                                    dr["NEWERPID"] = "LD" + dr["ERPID"].ToString();
                                    IDList.Add("LD" + dr["ERPID"].ToString());

                                    if (dr["CGA0018"].ToString() == "103")
                                    {
                                        string UP = string.Format(@"EXEC [WMS_CGLD_TOJX] '{0}' ", rtaskid);
                                        _sqlHelper.ExecuteNonQuery(UP);

                                        string SYSDEC = string.Format(@"UPDATE SYSDEC SET STATES='IGNORE' WHERE task_name='TB_ERPTOMES_CG' AND  STATES='NEW' AND TASK_ID ='{0}'", rtaskid);
                                        _sqlHelper.ExecuteNonQuery(SYSDEC);

                                        return true;
                                    }


                                }
                                else
                                {
@@ -2240,7 +2253,22 @@
                            {
                                if (dF["TLA020"].ToString().Contains("装配"))
                                {
                                    if (dF["TLA023"].ToString().Contains("-"))
                                    if (dF["TLA023"].ToString().Contains("*"))
                                    {
                                        string[] tr = dF["TLA023"].ToString().Split('*');

                                        //int i = dF["TLA023"].ToString().LastIndexOf('-');
                                        string StrNew = tr[1].ToString();//dF["TLA023"].ToString().Substring(i + 1, 10);
                                        string SQLT = string.Format(@"SELECT TOP 1 * FROM WOMCAA(NOLOCK) WHERE CAA018='{0}' ", StrNew);
                                        DataTable CAA = _sqlHelper.ExecuteDataTable(SQLT);
                                        if (CAA.Rows.Count > 0)
                                        {
                                            string UP = string.Format(@"UPDATE WOMCAA SET CAA016='{0}',CAA017='{1}',CAA018='{2}' WHERE CAA002='{3}'  ", CAA.Rows[0]["CAA016"].ToString(), CAA.Rows[0]["CAA017"].ToString(), CAA.Rows[0]["CAA018"].ToString(), dF["TLA002"].ToString());
                                            _sqlHelper.ExecuteNonQuery(UP);
                                        }

                                    }
                                    else if (dF["TLA023"].ToString().Contains("-"))
                                    {
                                        string[] tr = dF["TLA023"].ToString().Split('-');

@@ -3172,7 +3200,6 @@
                string res = a.Body(US).msg.ToString();

                sql = string.Format(@" update  sysdec set  states='NEW' WHERE TASK_ID='{0}' ", rtaskid);

                _sqlHelper.ExecuteNonQuery(sql);
                //string res = a.arg0.ws.MES_TO_ERP_DataTransport(task_name, descript, create_time, creator, operatype, source_table, target_table, data, data_inserted, data_deleted);
                if (res.Contains("OK"))
@@ -3982,7 +4009,10 @@
                            colMapping[23] = new SqlBulkCopyColumnMapping("FHB022", "DFB022"); //出库下线
                            colMapping[24] = new SqlBulkCopyColumnMapping("FHB023", "DFB023"); //是否控制出库数量
                            colMapping[25] = new SqlBulkCopyColumnMapping("FHB024", "DFB024"); //累计出库数
                            colMapping[26] = new SqlBulkCopyColumnMapping("ERP_EntryID", "ID"); //明细ID
                            colMapping[26] = new SqlBulkCopyColumnMapping("FHB025", "DFB025"); //产品类型    
                            colMapping[27] = new SqlBulkCopyColumnMapping("FHB026", "DFB026"); //父标识
                            colMapping[28] = new SqlBulkCopyColumnMapping("FHB027", "DFB027"); //标识列
                            colMapping[29] = new SqlBulkCopyColumnMapping("ERP_EntryID", "ID"); //明细ID
                            DataTableToSQLServer(dt, conStr, "COMDFB", colMapping, ref ErrorMsg);
                            #endregion
                        }