增加采购退货

cdk

2 天以前 9d36af31f3646a9ece38f17fcde31f1320d767ec

 HandleData/AE_MES_ERP.cs

@@ -149,6 +149,7 @@
                case "TB_MESTOERP_WWDDXD"://委外订单下达
                case "TB_MESTOERP_WWLL"://委外领料单
                case "TB_MESTOERP_XSTH"://销售退货
                case "TB_MESTOERP_CGTL"://采购退货
                case "TB_MESTOERP_WWCG"://委外下推采购
                    result = MesToErp(drSource, ref msg, rtaskid);
                    break;
@@ -1211,6 +1212,7 @@
        private bool TB_ERPTOMES_GYS(DataSet ds, string operatype, ref string ErrorMsg)
        {
            string sql = "";
            string dtName = "";
            //用来拼ID集合
            List<string> IDList = new List<string>();

@@ -1238,7 +1240,7 @@
                {
                    #region INSERT
                    //dt.Columns.Add("MAA005", typeof(string));

                    dtName = dt.TableName;
                    foreach (DataRow dr in dt.Rows)
                    {
                        IDList.Add(dr["ERPID"].ToString());
@@ -1263,11 +1265,11 @@
                    colMapping[6] = new SqlBulkCopyColumnMapping("FUseOrgId", "FUseOrgId"); //   内/外销
                    if (dt.Columns.Contains("GYSA006"))
                    {
                        colMapping[7] = new SqlBulkCopyColumnMapping("GYSA006", "GYSA006"); //备注
                        colMapping[7] = new SqlBulkCopyColumnMapping("GYSA006", "GYS006"); //备注
                    }
                    //colMapping[8] = new SqlBulkCopyColumnMapping("AUDITING", "AUDITING");

                    return DataTableToSQLServer(dt, conStr, "GS_GYS", colMapping, ref ErrorMsg);
                    DataTableToSQLServer(dt, conStr, "GS_GYS", colMapping, ref ErrorMsg);
                    #endregion
                }
                else if (operatype == "UPDATE")
@@ -1316,13 +1318,14 @@
                    }
                    sql = string.Format(@" delete from GS_GYS where ERPID in ('{0}'); ", string.Join("','", IDList));

                    return _sqlHelper.ExecuteNonQuery(sql) > 0;
                    _sqlHelper.ExecuteNonQuery(sql);
                    #endregion
                }
                return true;
            }
            catch (Exception ex)
            {
                ErrorMsg = ex.Message;
                ErrorMsg = "[" + dtName + "]" + ex.Message;
                return false;
            }
        }
@@ -3209,7 +3212,7 @@
                // sendt.arg0.
                US.category = task_name;
                US.data = data_inserted;
                US.op = operatype;
                US.op = dr["mesid"].ToString();
                string res = a.Body(US).msg.ToString();

                sql = string.Format(@" update  sysdec set  states='NEW' WHERE TASK_ID='{0}' ", rtaskid);
@@ -3230,10 +3233,6 @@
                    _sqlHelper.ExecuteNonQuery(sql);
                }

                if (string.IsNullOrWhiteSpace(res)) {
                    res = "数据有异常";
                }

                //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"))
                {
@@ -3242,7 +3241,7 @@
                }
                else if(res.Contains("MES单号唯一检测不通过"))
                {
                    ErrorMsg = res;
                    ErrorMsg = "OK-" + res;
                    return true;
                }
                else
@@ -4461,7 +4460,24 @@
                            foreach (DataRow dr in dt.Rows)
                            {
                                IDList.Add(dr["ERPID"].ToString());

                                if (dt.Columns.Contains("XSTHB012"))
                                {
                                    switch (dr["XSTHB012"].ToString())
                                    {
                                        case "Son":
                                            dr["XSTHB012"] = "套件子项";
                                            break;
                                        case "Standard":
                                            dr["XSTHB012"] = "标准产品";
                                            break;
                                        case "Parent":
                                            dr["XSTHB012"] = "套件父项";
                                            break;
                                        case "Service":
                                            dr["XSTHB012"] = "服务";
                                            break;
                                    }
                                }
                                dr["AUDITING"] = "Y";
                            }

@@ -4488,7 +4504,10 @@
                            colMapping[11] = new SqlBulkCopyColumnMapping("XSTHB010", "XSTHB010"); //仓库
                            colMapping[12] = new SqlBulkCopyColumnMapping("XSTHB011", "XSTHB011"); //退货日期
                            colMapping[13] = new SqlBulkCopyColumnMapping("ERP_EntryID", "ID"); //明细ID
                            //colMapping[14] = new SqlBulkCopyColumnMapping("XSTHB006", "XSTHB012"); //明细ID
                            if (dt.Columns.Contains("XSTHB012"))
                            {
                                colMapping[14] = new SqlBulkCopyColumnMapping("XSTHB012", "XSTHB012"); //明细产品类型 
                            }
                            DataTableToSQLServer(dt, conStr, "GS_XSTHB", colMapping, ref ErrorMsg);

                            #endregion
@@ -4691,6 +4710,25 @@
                                    string B = A.ToString();
                                    dr["CGTHB008"] = B;
                                }

                                if (dt.Columns.Contains("CGTHB012"))
                                {
                                    switch (dr["CGTHB012"].ToString())
                                    {
                                        case "Son":
                                            dr["CGTHB012"] = "套件子项";
                                            break;
                                        case "Standard":
                                            dr["CGTHB012"] = "标准产品";
                                            break;
                                        case "Parent":
                                            dr["CGTHB012"] = "套件父项";
                                            break;
                                        case "Service":
                                            dr["CGTHB012"] = "服务";
                                            break;
                                    }
                                }
                            }

                            //插入前先删除重复键
@@ -4716,6 +4754,10 @@
                            colMapping[11] = new SqlBulkCopyColumnMapping("CGTHB010", "CGTHB010"); //计价单位
                            colMapping[12] = new SqlBulkCopyColumnMapping("CGTHB011", "CGTHB011"); //退货原因
                            colMapping[13] = new SqlBulkCopyColumnMapping("ERP_EntryID", "ID"); //明细ID
                            if (dt.Columns.Contains("CGTHB012"))
                            {
                                colMapping[14] = new SqlBulkCopyColumnMapping("CGTHB012", "CGTHB012"); //明细产品类型 
                            }
                            DataTableToSQLServer(dt, conStr, "GS_CGTHB", colMapping, ref ErrorMsg);
                            #endregion
                        }