using BizCom; using ICSharpCode.SharpZipLib.Zip; using SQLData; using System; using System.Collections.Generic; using System.Configuration; using System.Data; using System.Data.SqlClient; using System.IO; using System.Text; using System.Web; using System.Web.UI; using System.Web.UI.WebControls; public partial class autocopy : System.Web.UI.Page { public static string upPath = ConfigurationManager.AppSettings["upPath"]; public static string copyPath = ConfigurationManager.AppSettings["copyPath"]; private void conErc(string msg) { Response.Write("{\"type\":\"error\",\"result\":\"" + msg + "\"}"); //Response.End(); } private void conSuc(string msg) { Response.Write("{\"type\":\"success\",\"result\":\"" + msg + "\"}"); //Response.End(); } protected void Page_Load(object sender, EventArgs e) { if (Request["hexdata"] != null) { string tids = Request["hexdata"]; if (tids.Trim() == "") { conErc("无法下载"); return; } int userId = 0; if (Request["userid"] != null) { userId = Convert.ToInt32(Request["userid"]); } try { string[] tArr = tids.Split(','); if (tArr.Length != 2) { conErc("订单ID不对，无法下载"); return; } string oldctid = tArr[0].ToString(); string newctid = tArr[1].ToString(); StringBuilder sql = new StringBuilder(); sql.AppendFormat("select ctid,tid,seller_memo,FinishDesignTime,OrderState,SupplierId,SupplierName from view_erptradecell where ctid='{0}'", oldctid); DataTable dt = CeErpTradeCell.ExecuteDataset(sql.ToString()).Tables[0]; if (dt == null || dt.Rows.Count < 1) { conErc("没有找到相关订单" + oldctid); return; } StringBuilder sqlnew = new StringBuilder(); sqlnew.AppendFormat("select ctid,tid,seller_memo,FinishDesignTime,OrderState,SupplierId,SupplierName,orderSn from view_erptradecell where (orderstate=3 or orderstate=4) and ctid='{0}'", newctid); DataTable dtnew = CeErpTradeCell.ExecuteDataset(sqlnew.ToString()).Tables[0]; if (dtnew == null || dtnew.Rows.Count < 1) { conErc("没有找到相关new新订单" + newctid); return; } List files = new List(); string oldDesignTime = ""; string oldFilename = ""; string df_name = ""; string[] extArr = new string[] { ".cdr", ".zip", ".rar", ".pdf" }; string oldTag = ".cdr"; List noFileLst = new List(); List errorFileLst = new List(); DataRow dr = dt.Rows[0]; if (dr["FinishDesignTime"].ToString() == "") { conErc("没有找到相关old老订单附件,FinishDesignTime为空"); return; } DateTime ftime = Convert.ToDateTime(dr["FinishDesignTime"]); DateTime splitTime = new DateTime(2023, 06, 27, 15, 30, 0); if (ftime.CompareTo(splitTime) > 0) { oldDesignTime = getDesignTimeWithDay(dr["FinishDesignTime"]); } else oldDesignTime = getDesignTime(dr["FinishDesignTime"]); //oldDesignTime = getDesignTime(dr["FinishDesignTime"]); df_name = upPath + "\\" + oldDesignTime + "\\" + formatMemo(dr["seller_memo"]); foreach (string ext in extArr) { oldFilename = df_name + ext; oldTag = ext; if (File.Exists(oldFilename)) { break; //if (!isUpdateError) //{ // files.Add(fname); // copyFile(getDesignDate(dr["FinishDesignTime"]), dr["SupplierName"].ToString(), fname); // fc++; //} } else oldFilename = ""; } if (oldFilename == "") { conErc("没有找到相关old老订单附件"); return; //noFileLst.Add("'" + dr["ctid"].ToString() + "'"); } //if (hasFile) //{ // fname = upPath + "\\" + dTime + "\\" + formatMemo(dr["seller_memo"]) + ".png"; // if (File.Exists(fname)) // { // files.Add(fname); // copyFile(getDesignDate(dr["FinishDesignTime"]), dr["SupplierName"].ToString(), fname); // } //} //sql = new StringBuilder(); //sql.AppendFormat("insert into CE_ErpTradeLog(tid,orderstate,userid,operatetime,con) select ctid,{1},{2},getdate(),'{3}' from ce_erptradecell where ctid in ({0}) ;", tids, (int)OrderState.下单完成, userId, "下载设计文件"); //sql.AppendFormat("update ce_erptradecell set FinishPlaceTime=getdate(),OrderState={0},IsReturn=0 where ctid in ({1}) and orderstate={2} and IsReturn<>2 and seller_memo not like '%电子稿%' ;", (int)OrderState.下单完成, tids, (int)OrderState.设计完成); //sql.AppendFormat("update ce_erptradecell set FinishPlaceTime=getdate(),OrderState={0},IsReturn=0 where ctid in ({1}) and orderstate={2} and IsReturn<>2 and seller_memo like '%电子稿%' ;", (int)OrderState.已发货, tids, (int)OrderState.设计完成); //CeErpTradeCell.ExecuteNonQuery(sql.ToString()); DataRow newDr = dtnew.Rows[0]; string newMemo = newDr["seller_memo"].ToString(); newMemo = newMemo.Replace("（", "("); newMemo = newMemo.Replace("）", ")"); string newmemoctid = MidStrEx(newMemo, "(", ")").Trim(); string orderSn = newDr["orderSn"].ToString(); if (newctid.IndexOf("C") != -1) { /*if (newMemo.IndexOf("[") != -1 && newMemo.IndexOf("C") != -1) { if (newmemoctid.IndexOf("S_") != -1) // (S_S_1962772776865084101)[C1] 对应ctid是 S_S_C1_1962772776865084101 { int lastIndex = newmemoctid.LastIndexOf("S_"); //最后一个S_的位置 string sPre = newmemoctid.Substring(0, lastIndex + 2); //S_S_ string initTid = newmemoctid.Substring(lastIndex + 2, newmemoctid.Length - lastIndex - 2); //1962772776865084101 string pre_ctid = MidStrEx(newMemo, "[", "]"); //C1 if (pre_ctid.IndexOf("+") != -1) { pre_ctid = "C" + pre_ctid.Split('+')[1]; } newmemoctid = sPre + pre_ctid + "_" + initTid; //S_S_ + C1 + _ +1962772776865084101 } else { string pre_ctid = MidStrEx(newMemo, "[", "]"); if (pre_ctid.IndexOf("+") != -1) { pre_ctid = "C" + pre_ctid.Split('+')[1]; } if (newmemoctid.IndexOf('C') == -1) { newmemoctid = pre_ctid + "_" + newmemoctid; } } }*/ } if (string.IsNullOrEmpty(newmemoctid)) { conErc("上传的文件名格式不正确"); return; } if (orderSn != newmemoctid) { conErc("新订单备注中的订单号不正确"); return; } string newUpDesignTime = getDesignTimeWithDay(DateTime.Now); //string newDfName = upPath + "\\" + newUpDesignTime + "\\" + formatMemo(newDr["seller_memo"])+oldTag; string newPathFileName = ""; copyUpFile(newUpDesignTime, oldFilename, formatMemo(newDr["seller_memo"]) + oldTag, ref newPathFileName); //copyFile(getDesignDate(DateTime.Now), dr["SupplierName"].ToString(), oldFilename, formatMemo(newDr["seller_memo"]) + oldTag); CeErpTradeCell.UpdateRelationOrder(newctid); StringBuilder up_sql = new StringBuilder(); up_sql.AppendFormat("update ce_erptradecell with(rowlock) set orderstate=5,IsReturn=0,StartDesignTime=getdate(),SupplierId={1},FinishDesignTime=getdate() where ctid='{0}'", newctid, dr["SupplierId"]); CeErpTradeCell.ExecuteNonQuery(up_sql.ToString()); if (oldTag == ".cdr") { //string sqlpng = string.Format("insert into s_cdrtopng(name,addtime)values('{0}',getdate()) ;", newPathFileName); //CeErpTradeLog.ExecuteNonQuery(sqlpng); } CeErpTradeLog.AddLog(newctid, 5, userId, "自动上传老客户文件-" + newPathFileName); string fileSql = string.Format("INSERT INTO [dbo].[CE_ErpTradeCellFile]([tid], [ctid], [isDel], [url], [createtime], [type]) SELECT '{0}', '{1}', isDel ,url,getdate(),type FROM [dbo].[CE_ErpTradeCellFile] WHERE tid='{2}' and ctid='{3}' and isDel = 0 and type = 'AUTH_FILE'", dtnew.Rows[0]["tid"], dtnew.Rows[0]["ctid"], dt.Rows[0]["tid"], dt.Rows[0]["ctid"]); CeErpTradeCell.ExecuteNonQuery(fileSql); conSuc("文件已上传到共享目录"); return; } catch (Exception ex) { conErc("错误的下载访问" + ex.Message); XLog.SaveLog(0, "autocopydown," + ex.Message); return; } } } public static string MidStrEx(string sourse, string startstr, string endstr) { string result = string.Empty; int startindex, endindex; try { startindex = sourse.IndexOf(startstr); if (startindex == -1) return result; string tmpstr = sourse.Substring(startindex + startstr.Length); endindex = tmpstr.IndexOf(endstr); if (endindex == -1) return result; result = tmpstr.Remove(endindex); } catch (Exception ex) { Console.WriteLine("MidStrEx Err:" + ex.Message); } return result; } private string formatMemo(object memo) { string m = memo.ToString(); m = m.Replace("\\", "").Replace("/", "").Replace(":", "").Replace("*", "").Replace("?", "").Replace("<", "").Replace(">", "").Replace("|", ""); return m; } private void copyUpFile(string date, string oldfile, string newfilename, ref string newPathFileName) { try { string path = upPath + "\\" + date; if (!Directory.Exists(path)) Directory.CreateDirectory(path); //string fname = Path.GetFileName(file); File.Copy(oldfile, path + "\\" + newfilename, true); newPathFileName = path + "\\" + newfilename; if (!File.Exists(path + "\\" + newfilename)) { File.Copy(oldfile, path + "\\" + newfilename, true); } } catch (Exception ex) { XLog.SaveLog(0, "自动复制上传文件发生错误," + newfilename + "," + ex.Message); throw ex; } } private void copyFile(string date, string supplier, string oldfile, string newFileName) { try { string path = copyPath + "\\" + date + "\\" + supplier; if (!Directory.Exists(path)) Directory.CreateDirectory(path); //string fname = Path.GetFileName(file); File.Copy(oldfile, path + "\\" + newFileName, true); if (!File.Exists(path + "\\" + newFileName)) { File.Copy(oldfile, path + "\\" + newFileName, true); } } catch (Exception ex) { XLog.SaveLog(0, "自动复制下载文件发生错误," + oldfile + "," + ex.Message); } } private string getDesignTime(object v) { if (v.ToString() == "") return ""; return Convert.ToDateTime(v).ToString("yyyyMM"); } private string getDesignTimeWithDay(object v) { if (v.ToString() == "") return ""; return Convert.ToDateTime(v).ToString("yyyyMMdd"); } private string getDesignDate(object v) { return DateTime.Now.ToString("yyyy-MM-dd"); if (v.ToString() == "") return ""; return Convert.ToDateTime(v).ToString("yyyy-MM-dd"); } /// 批量进行多个文件压缩到一个文件 /// /// 文件列表(绝对路径) 这里用的数组，你可以用list 等或者 /// 生成的zip文件名称 private void ZipFileDownload(List files, string zipFileName) { MemoryStream ms = new MemoryStream(); byte[] buffer = null; using (ZipFile file = ZipFile.Create(ms)) { file.BeginUpdate(); //file.NameTransform = new ZipNameTransform(); file.NameTransform = new MyNameTransfom(); foreach (var item in files) { if (File.Exists(item)) file.Add(item); } file.CommitUpdate(); buffer = new byte[ms.Length]; ms.Position = 0; ms.Read(buffer, 0, buffer.Length); //读取文件内容(1次读ms.Length/1024M) ms.Flush(); ms.Close(); } Response.Clear(); Response.Buffer = true; Response.ContentType = "application/x-zip-compressed"; Response.AddHeader("Set-Cookie", "fileDownload=true; path=/"); Response.AddHeader("content-disposition", "attachment;filename=" + HttpUtility.UrlEncode(zipFileName)); Response.BinaryWrite(buffer); Page.Response.Flush(); Page.Response.SuppressContent = true; HttpContext.Current.ApplicationInstance.CompleteRequest(); //ScriptManager.RegisterStartupScript(Page, Page.GetType(), "popup", "alert('123');", true); //Response.Flush(); //Response.End(); } private void downLoadFile(string file) { string filePath = Server.MapPath("d/" + file);//路径 //以字符流的形式下载文件 FileStream fs = new FileStream(filePath, FileMode.Open); byte[] bytes = new byte[(int)fs.Length]; fs.Read(bytes, 0, bytes.Length); fs.Close(); Response.ContentType = "application/octet-stream"; //通知浏览器下载文件而不是打开 Response.AddHeader("Content-Disposition", "attachment; filename=" + HttpUtility.UrlEncode(file, System.Text.Encoding.UTF8)); Response.BinaryWrite(bytes); Response.Flush(); Response.End(); } }