667 lines
29 KiB
C#
667 lines
29 KiB
C#
using Aliyun.OSS;
|
||
using Aliyun.OSS.Common;
|
||
using BizCom;
|
||
using ICSharpCode.SharpZipLib.Zip;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Configuration;
|
||
using System.Data;
|
||
using System.Diagnostics;
|
||
using System.IO;
|
||
using System.IO.Compression;
|
||
using System.Runtime.InteropServices;
|
||
using System.Security.Principal;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using System.Web;
|
||
|
||
|
||
public partial class supplierBuildFile : System.Web.UI.Page
|
||
{
|
||
public static string upPath = ConfigurationManager.AppSettings["upPath"];
|
||
public static string copyPath = ConfigurationManager.AppSettings["copyPath"];
|
||
|
||
public static string siteUrl = ConfigurationManager.AppSettings["OriSiteUrl"];
|
||
|
||
[DllImport("DrvInterface64.dll", CharSet = CharSet.Unicode)]
|
||
public static extern uint DecFile(string filename);
|
||
|
||
[DllImport("DrvInterface64.dll", CharSet = CharSet.Unicode)]
|
||
public static extern int IsFileEncrypted(string filename);//返回1为加密，0为未被加密
|
||
[DllImport("DrvInterface64.dll", CharSet = CharSet.Ansi)]
|
||
public static extern void CreateUserKey(StringBuilder key, int len);
|
||
[DllImport("DrvInterface64.dll", CharSet = CharSet.Ansi)]
|
||
public static extern int InitAesKey(StringBuilder key, int len);
|
||
|
||
[DllImport("DrvInterface64.dll")]
|
||
public static extern int IsInitedAesKey();
|
||
|
||
private void conErc(string msg)
|
||
{
|
||
XLog.SaveLog(0, msg);
|
||
Response.Write(msg);
|
||
//Response.StatusCode = (int)HttpStatusCode.NotFound;
|
||
//Response.End();
|
||
}
|
||
|
||
private void conSuc(string msg)
|
||
{
|
||
Response.Write("{\"type\":\"success\",\"result\":\"" + msg + "\"}");
|
||
//Response.End();
|
||
}
|
||
|
||
protected void Page_Load(object sender, EventArgs e)
|
||
{
|
||
if (!IsPostBack)
|
||
{
|
||
Response.Buffer = true;
|
||
downloadMore();
|
||
}
|
||
}
|
||
|
||
private string getCanDownFile(string fileName)
|
||
{
|
||
string[] extArr = new string[] { ".cdr", ".zip", ".rar", ".pdf" };
|
||
foreach (string ext in extArr)
|
||
{
|
||
string fname = fileName + ext;
|
||
if (File.Exists(fname))
|
||
{
|
||
return ext;
|
||
}
|
||
}
|
||
|
||
return "";
|
||
}
|
||
static bool running = false;
|
||
|
||
private void downloadMore()
|
||
{
|
||
if (running)
|
||
{
|
||
conSuc("运行中！");
|
||
return;
|
||
}
|
||
running = true;
|
||
|
||
var identity = WindowsIdentity.GetCurrent();
|
||
var principal = new WindowsPrincipal(identity);
|
||
Task.Run(async () =>
|
||
{
|
||
using (identity.Impersonate())
|
||
{
|
||
StringBuilder sql = new StringBuilder();
|
||
sql.AppendFormat("select * from CE_ErpPackData WITH(nolock) where upStatus = 0");
|
||
int userId = 1;
|
||
DataTable dt = CeErpTradeCell.ExecuteDataset(sql.ToString()).Tables[0];
|
||
string updateSql = "";
|
||
if (dt != null && dt.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow dr in dt.Rows)
|
||
{
|
||
string zipFileName = dr["fileName"].ToString();
|
||
int supplierId = 0;
|
||
string packId = dr["ID"].ToString();
|
||
try
|
||
{
|
||
CeErpTradeLog.ExecuteNonQuery(string.Format("update CE_ErpPackData set upStatus = 1 where ID= {0} ;", packId));
|
||
DataTable itemData = CeErpTradeCell.ExecuteDataset(string.Format("select ctid,seller_memo,FinishDesignTime,OrderState,SupplierName,OrderSn,tid,SupplierId from view_erptradecell where FinishDesignTime is not null and ctid in (SELECT ctid FROM CE_ErpPackDataItem WHERE packId = {0})", packId)).Tables[0];
|
||
List<string> files = new List<string>();
|
||
List<string> tids = new List<string>();
|
||
int upStatus = 3;
|
||
string url = "";
|
||
if (itemData != null && itemData.Rows.Count > 0)
|
||
{
|
||
string suppierName = "";
|
||
foreach (DataRow row in itemData.Rows)
|
||
{
|
||
supplierId = Convert.ToInt32(row["SupplierId"].ToString());
|
||
string finishDesignTime = getDesignTime(row["FinishDesignTime"]);
|
||
string ctid = row["ctid"].ToString();
|
||
string df_name = upPath + "\\" + finishDesignTime + "\\" + formatMemo(row["seller_memo"]);
|
||
string ext = getCanDownFile(df_name);
|
||
suppierName = row["SupplierName"].ToString();
|
||
if (string.IsNullOrEmpty(ext))
|
||
{
|
||
//不存在则打包失败
|
||
updateSql += string.Format("update CE_ErpPackDataItem set message = '文件不存在!' where packId= {0} and ctid='{1}' ;", packId, ctid);
|
||
files = new List<string>();
|
||
supplierId = 0;
|
||
break;
|
||
}
|
||
string fname = df_name + ext;
|
||
if (Convert.ToInt16(row["OrderState"]) != 6)
|
||
{
|
||
updateSql += string.Format("update CE_ErpPackDataItem set message = '订单状态不正确!' where packId= {0} and ctid='{1}' ;", packId, ctid);
|
||
continue;
|
||
}
|
||
int IsFileEncrypt = IsFileEncrypted(fname);
|
||
if (IsFileEncrypt == 1 && File.Exists(fname))
|
||
{
|
||
string key = "gBQnlxiBb7MthH9644V0W0pFwqYZgyy7";
|
||
var sb = new StringBuilder(key);
|
||
|
||
//Linux系统的接口要调用一次，Windows系统要调用两次
|
||
CreateUserKey(sb, key.Length);
|
||
CreateUserKey(sb, key.Length); //破解用dse生成的文件，需要调2次。
|
||
int result = InitAesKey(sb, sb.Length);
|
||
result = IsInitedAesKey();
|
||
if (result != 1)
|
||
{
|
||
addLog(ctid, userId, "初始化秘钥失败" + result, 0);
|
||
updateSql += string.Format("update CE_ErpPackDataItem set message = '解密失败!' where packId= {0} and ctid='{1}' ;", packId, ctid);
|
||
continue;
|
||
}
|
||
uint a = DecFile(fname);
|
||
if (a != 0)
|
||
{
|
||
addLog(ctid, userId, "解密失败" + a, 0);
|
||
updateSql += string.Format("update CE_ErpPackDataItem set message = '解密失败!' where packId= {0} and ctid='{1}' ;", packId, ctid);
|
||
continue;
|
||
}
|
||
}
|
||
if (string.IsNullOrEmpty(fname))
|
||
{
|
||
updateSql += string.Format("update CE_ErpPackDataItem set message = '解密失败!' where packId= {0} and ctid='{1}' ;", packId, ctid);
|
||
continue;
|
||
}
|
||
try
|
||
{
|
||
copyFile(getDesignDate(row["FinishDesignTime"]), suppierName, fname, zipFileName.Replace(".zip", ""));
|
||
files.Add(fname);
|
||
supplierId = 0;
|
||
tids.Add("'" + ctid + "'");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
writeLog("打包复制文件出错！" + ex.Message);
|
||
updateSql += string.Format("update CE_ErpPackDataItem set message = '复制文件出错!{2}' where packId= {0} and ctid='{1}' ;", packId, ctid, ex.Message);
|
||
files = new List<string>();//清空数据
|
||
supplierId = 0;
|
||
break;
|
||
}
|
||
}
|
||
if (files.Count == 0)
|
||
{
|
||
updateSql += string.Format("update CE_ErpPackData set upStatus = 3,message='没有可打包文件！' where ID= {0} ;", packId);
|
||
continue;
|
||
}
|
||
else
|
||
{
|
||
|
||
string sourceFolder = getCopyPath(getDesignDate(""), suppierName, zipFileName.Replace(".zip", ""));
|
||
string zipFilePath = getCopyPath(getDesignDate(""), suppierName) + "\\" + zipFileName;
|
||
ZipLargeFolder(sourceFolder, zipFilePath, supplierId);
|
||
url = FileOssUpV2(zipFilePath, zipFileName);
|
||
|
||
if (url != null)
|
||
{
|
||
upStatus = 2;
|
||
updateSql += string.Format("insert into CE_ErpTradeLog(tid,orderstate,userid,operatetime,con) select ctid,{1},{2},getdate(),'{3}' from ce_erptradecell where ctid in ({0}) ;", string.Join(",", tids), (int)OrderState.下单完成, 0, "下载设计文件");
|
||
updateSql += string.Format("update ce_erptradecell set UpdateTime=getdate() where ctid in ({0}) ;", string.Join(",", tids));
|
||
}
|
||
}
|
||
|
||
}
|
||
updateSql += string.Format("update CE_ErpPackData set upStatus = {1},fileUrl='{2}' where ID= {0} ;", packId, upStatus, url);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
writeLog("打包文件出错！" + ex.Message);
|
||
updateSql += string.Format("update CE_ErpPackData set upStatus = 3 where ID= {0} ;", packId);
|
||
}
|
||
CeErpTradeLog.ExecuteNonQuery(updateSql);
|
||
updateSql = "";
|
||
}
|
||
}
|
||
running = false;
|
||
}
|
||
});
|
||
|
||
conSuc("运行结束！");
|
||
//FileOssUp();
|
||
}
|
||
|
||
private static string dealMemoName(string name)
|
||
{
|
||
string[] al = name.Split('-');
|
||
List<string> list = new List<string>();
|
||
string pa = string.Empty;
|
||
for (int i = 0; i < al.Length; i++)
|
||
{
|
||
if (i == 1)
|
||
{
|
||
if (al[i].Contains("(") || al[i].Contains("（"))
|
||
{
|
||
string tname = al[i].Replace(")", "").Replace("）", "").Replace("（", "").Replace("(", "");
|
||
if (!string.IsNullOrEmpty(tname))
|
||
{
|
||
pa = al[i];
|
||
}
|
||
continue;
|
||
}
|
||
|
||
}
|
||
list.Add(al[i]);
|
||
}
|
||
if (!string.IsNullOrEmpty(pa))
|
||
{
|
||
list.Insert(3, pa);
|
||
}
|
||
name = string.Join("-", list);
|
||
return name;
|
||
}
|
||
private string formatMemo(object memo)
|
||
{
|
||
string m = memo.ToString();
|
||
m = m.Replace("\\", "").Replace("/", "").Replace(":", "").Replace("*", "").Replace("?", "").Replace("<", "").Replace(">", "").Replace("|", "");
|
||
return m;
|
||
}
|
||
|
||
private void copyFile(string date, string supplier, string file, string zipName = "")
|
||
{
|
||
string path = getCopyPath(date, supplier, zipName);
|
||
|
||
if (!Directory.Exists(path)) Directory.CreateDirectory(path);
|
||
string fname = Path.GetFileName(file);
|
||
File.Copy(file, path + "\\" + fname, true);
|
||
if (!File.Exists(path + "\\" + fname))
|
||
{
|
||
File.Copy(file, path + "\\" + fname, true);
|
||
}
|
||
}
|
||
|
||
private string getCopyPath(string date, string supplier, string zipName = "")
|
||
{
|
||
string path = copyPath + "\\" + date + "\\" + supplier + "\\" + "车间下载";
|
||
if (!string.IsNullOrEmpty(zipName))
|
||
{
|
||
path = path + "\\" + zipName;
|
||
}
|
||
return path;
|
||
}
|
||
|
||
private string getDesignTime(object v)
|
||
{
|
||
if (v.ToString() == "") return "";
|
||
return Convert.ToDateTime(v).ToString("yyyyMMdd");
|
||
}
|
||
|
||
private string getDesignDate(object v)
|
||
{
|
||
int year = DateTime.Now.Year;
|
||
int month = DateTime.Now.Month;
|
||
int day = DateTime.Now.Day;
|
||
return year + "\\" + month + "\\" + day;
|
||
/*if (v.ToString() == "") return "";
|
||
return Convert.ToDateTime(v).ToString("yyyy-MM-dd");*/
|
||
}
|
||
|
||
private string FileOssUp(byte[] buffer, string fileName)
|
||
{
|
||
// yourEndpoint填写Bucket所在地域对应的Endpoint。以华东1（杭州）为例，Endpoint填写为https://oss-cn-hangzhou.aliyuncs.com。
|
||
var endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
|
||
// 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
|
||
var accessKeyId = "LTAI5tE7wuNkeT9jZ42bQnyr";
|
||
var accessKeySecret = "NnutvWhKl4HbQFSad3HosYbCkEkbjN";
|
||
// 填写Bucket名称，例如examplebucket。
|
||
var bucketName = "ltcloudfile";
|
||
int year = DateTime.Now.Year;
|
||
int month = DateTime.Now.Month;
|
||
int day = DateTime.Now.Day;
|
||
// 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
|
||
var objectName = "supplierFile/" + year + "/" + month + "/" + day + "/" + fileName;
|
||
|
||
// 填写Bucket所在地域对应的Region。以华东1（杭州）为例，Region填写为cn-hangzhou。
|
||
string region = "cn-hangzhou";
|
||
|
||
// 创建ClientConfiguration实例，按照您的需要修改默认参数。
|
||
var conf = new ClientConfiguration();
|
||
|
||
// 设置v4签名。
|
||
conf.SignatureVersion = SignatureVersion.V4;
|
||
|
||
// 创建OssClient实例。
|
||
var client = new OssClient(endpoint, accessKeyId, accessKeySecret, conf);
|
||
client.SetRegion(region);
|
||
try
|
||
{
|
||
|
||
MemoryStream requestContent = new MemoryStream(buffer);
|
||
// 上传文件。
|
||
client.PutObject(bucketName, objectName, requestContent);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
writeLog("打包文件上传oss出错！" + ex.Message);
|
||
return null;
|
||
}
|
||
|
||
return "https://ltcloudfile.oss-cn-hangzhou.aliyuncs.com/" + objectName;
|
||
}
|
||
|
||
private string FileOssUpV2(string filePath, string fileName)
|
||
{
|
||
// yourEndpoint填写Bucket所在地域对应的Endpoint。以华东1（杭州）为例，Endpoint填写为https://oss-cn-hangzhou.aliyuncs.com。
|
||
var endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
|
||
// 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
|
||
var accessKeyId = "LTAI5tE7wuNkeT9jZ42bQnyr";
|
||
var accessKeySecret = "NnutvWhKl4HbQFSad3HosYbCkEkbjN";
|
||
// 填写Bucket名称，例如examplebucket。
|
||
var bucketName = "ltcloudfile";
|
||
int year = DateTime.Now.Year;
|
||
int month = DateTime.Now.Month;
|
||
int day = DateTime.Now.Day;
|
||
// 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
|
||
var objectName = "supplierFile/" + year + "/" + month + "/" + day + "/" + fileName;
|
||
|
||
// 填写Bucket所在地域对应的Region。以华东1（杭州）为例，Region填写为cn-hangzhou。
|
||
string region = "cn-hangzhou";
|
||
|
||
// 创建ClientConfiguration实例，按照您的需要修改默认参数。
|
||
var conf = new ClientConfiguration();
|
||
|
||
// 设置v4签名。
|
||
conf.SignatureVersion = SignatureVersion.V4;
|
||
|
||
// 创建OssClient实例。
|
||
var client = new OssClient(endpoint, accessKeyId, accessKeySecret, conf);
|
||
client.SetRegion(region);
|
||
var uploadId = "";
|
||
try
|
||
{
|
||
// 定义上传的文件及所属Bucket的名称。您可以在InitiateMultipartUploadRequest中设置ObjectMeta，但不必指定其中的ContentLength。
|
||
var request = new InitiateMultipartUploadRequest(bucketName, objectName);
|
||
var result = client.InitiateMultipartUpload(request);
|
||
uploadId = result.UploadId;
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
|
||
writeLog("Init multi part upload failed, {0}" + ex.Message);
|
||
Environment.Exit(1);
|
||
}
|
||
// 计算分片总数。
|
||
// 分片最小值为100 KB，最大值为5 GB。最后一个分片的大小允许小于100 KB。
|
||
var partSize = 10 * 1024 * 1024;
|
||
var fi = new FileInfo(filePath);
|
||
var fileSize = fi.Length;
|
||
var partCount = fileSize / partSize;
|
||
if (fileSize % partSize != 0)
|
||
{
|
||
partCount++;
|
||
}
|
||
|
||
var partETags = new List<PartETag>();
|
||
try
|
||
{
|
||
using (var fs = File.Open(filePath, FileMode.Open))
|
||
{
|
||
for (var i = 0; i < partCount; i++)
|
||
{
|
||
var skipBytes = (long)partSize * i;
|
||
// 定位到本次上传的起始位置。
|
||
fs.Seek(skipBytes, 0);
|
||
// 计算本次上传的分片大小，最后一片为剩余的数据大小。
|
||
var size = (partSize < fileSize - skipBytes) ? partSize : (fileSize - skipBytes);
|
||
var request = new UploadPartRequest(bucketName, objectName, uploadId)
|
||
{
|
||
InputStream = fs,
|
||
PartSize = size,
|
||
PartNumber = i + 1
|
||
};
|
||
// 调用UploadPart接口执行上传功能，返回结果中包含了这个数据片的ETag值。
|
||
var result = client.UploadPart(request);
|
||
partETags.Add(result.PartETag);
|
||
writeLog(string.Format(fileName + "：finish {0}/{1}", partETags.Count, partCount));
|
||
}
|
||
writeLog(string.Format(fileName + "：Put multi part upload succeeded"));
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
writeLog(string.Format("Put multi part upload failed, {0}", ex.Message));
|
||
Environment.Exit(1);
|
||
}
|
||
// 当分片上传成功后，合并分片。
|
||
try
|
||
{
|
||
var completeMultipartUploadRequest = new CompleteMultipartUploadRequest(bucketName, objectName, uploadId);
|
||
foreach (var partETag in partETags)
|
||
{
|
||
completeMultipartUploadRequest.PartETags.Add(partETag);
|
||
}
|
||
var result = client.CompleteMultipartUpload(completeMultipartUploadRequest);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
writeLog(string.Format("complete multi part failed, {0}", ex.Message));
|
||
Environment.Exit(1);
|
||
}
|
||
|
||
return "https://ltcloudfile.oss-cn-hangzhou.aliyuncs.com/" + objectName;
|
||
}
|
||
|
||
|
||
|
||
/// 批量进行多个文件压缩到一个文件
|
||
/// </summary>
|
||
/// <param name="files">文件列表(绝对路径)</param> 这里用的数组，你可以用list 等或者
|
||
/// <param name="zipFileName">生成的zip文件名称</param>
|
||
private void ZipFileDownload(int userId, List<string> ctidLst, List<string> files, string zipFileName, int onlyDownFile, int isFromClient)
|
||
{
|
||
|
||
// yourEndpoint填写Bucket所在地域对应的Endpoint。以华东1（杭州）为例，Endpoint填写为https://oss-cn-hangzhou.aliyuncs.com。
|
||
var endpoint = "https://oss-cn-fuzhou.aliyuncs.com";
|
||
// 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
|
||
var accessKeyId = "LTAI5tE7wuNkeT9jZ42bQnyr";
|
||
var accessKeySecret = "NnutvWhKl4HbQFSad3HosYbCkEkbjN";
|
||
// 填写Bucket名称，例如examplebucket。
|
||
var bucketName = "dfdiyfile";
|
||
// 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
|
||
var objectName = "exampledir/exampleobject.txt";
|
||
// 填写字符串。
|
||
var objectContent = "More than just cloud.";
|
||
// 填写Bucket所在地域对应的Region。以华东1（杭州）为例，Region填写为cn-hangzhou。
|
||
const string region = "oss-cn-fuzhou";
|
||
|
||
// 创建ClientConfiguration实例，按照您的需要修改默认参数。
|
||
var conf = new ClientConfiguration();
|
||
|
||
// 设置v4签名。
|
||
conf.SignatureVersion = SignatureVersion.V4;
|
||
|
||
// 创建OssClient实例。
|
||
var client = new OssClient(endpoint, accessKeyId, accessKeySecret, conf);
|
||
client.SetRegion(region);
|
||
try
|
||
{
|
||
MemoryStream ms = new MemoryStream();
|
||
byte[] buffer = null;
|
||
using (ZipFile file = ZipFile.Create(ms))
|
||
{
|
||
|
||
file.BeginUpdate();
|
||
//file.NameTransform = new ZipNameTransform();
|
||
file.NameTransform = new MyNameTransfom();
|
||
|
||
file.Add("C:\\Users\\231010\\Downloads\\setup.exe");
|
||
file.CommitUpdate();
|
||
buffer = new byte[ms.Length];
|
||
ms.Position = 0;
|
||
ms.Read(buffer, 0, buffer.Length); //读取文件内容(1次读ms.Length/1024M)
|
||
ms.Flush();
|
||
ms.Close();
|
||
|
||
}
|
||
MemoryStream requestContent = new MemoryStream(buffer);
|
||
// 上传文件。
|
||
client.PutObject(bucketName, objectName, requestContent);
|
||
Console.WriteLine("Put object succeeded");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
Console.WriteLine("Put object failed, {0}", ex.Message);
|
||
}
|
||
|
||
|
||
conSuc("上传成功！");
|
||
return;
|
||
//for (int i = 0; i < addFiles.Count; i++)
|
||
//{
|
||
// updateIsDownSuccess(userId, addCtid[i]);
|
||
//}
|
||
//StringBuilder sql = new StringBuilder();
|
||
//string tids = string.Join(",", addCtid);
|
||
//sql.AppendFormat("update CE_ErpTradeCell set OrderState = 6 where ctid in ({0}) ;", ("'" + tids.Replace(",", "','") + "'"));
|
||
//CeErpTradeCell.ExecuteNonQuery(sql.ToString());
|
||
//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.Replace(",", "','") + "'"), (int)OrderState.下单完成, userId, "下载设计文件");
|
||
//CeErpTradeCell.ExecuteNonQuery(sql.ToString());
|
||
}
|
||
|
||
//public static object downfileObj = new object();
|
||
private void downLoadFile(int userId, string ctid, string file, int onlyDownFile, int isFromClient)
|
||
{
|
||
string filePath = file;
|
||
string dfile = Path.GetFileName(file);
|
||
|
||
FileStream fs = new FileStream(filePath, FileMode.Open);
|
||
byte[] bytes = new byte[(int)fs.Length];
|
||
fs.Read(bytes, 0, bytes.Length);
|
||
fs.Close();
|
||
|
||
|
||
Response.Clear();
|
||
//
|
||
Response.ClearContent();
|
||
Response.ClearHeaders();
|
||
|
||
Response.ContentType = "application/octet-stream";
|
||
//通知浏览器下载文件而不是打开\\fileDownload=true; path=/
|
||
Response.AddHeader("Set-Cookie", "fileDownload=true; path=/;");
|
||
//Response.AddHeader("Cache-Control", "no-cache, no-store, must-revalidate");
|
||
Response.AddHeader("Content-Disposition", "attachment; filename=" + HttpUtility.UrlEncode(dfile, System.Text.Encoding.UTF8));
|
||
Response.AddHeader("Content-Length", bytes.Length.ToString());
|
||
Response.AddHeader("Access-Control-Expose-Headers", "Content-Disposition");
|
||
Response.BinaryWrite(bytes);
|
||
Response.Flush();
|
||
|
||
//updateIsDownSuccess(userId, ctid);
|
||
//StringBuilder sql = new StringBuilder();
|
||
//string tids = string.Join(",", ctid);
|
||
//sql.AppendFormat("update CE_ErpTradeCell set OrderState = 6 where ctid in ({0}) ;", ("'" + tids.Replace(",", "','") + "'"));
|
||
//CeErpTradeCell.ExecuteNonQuery(sql.ToString());
|
||
//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.Replace(",", "','") + "'"), (int)OrderState.下单完成, userId, "下载设计文件");
|
||
//CeErpTradeCell.ExecuteNonQuery(sql.ToString());
|
||
}
|
||
|
||
/// <summary>
|
||
/// 压缩大文件夹（分块处理）
|
||
/// </summary>
|
||
public static void ZipLargeFolder(string sourceFolder, string zipFilePath, int supplierId, CompressionLevel compressionLevel = CompressionLevel.Optimal)
|
||
{
|
||
// 参数验证
|
||
if (string.IsNullOrEmpty(sourceFolder))
|
||
throw new ArgumentNullException("sourceFolder", "源文件夹路径不能为空");
|
||
|
||
if (string.IsNullOrEmpty(zipFilePath))
|
||
throw new ArgumentNullException("zipFilePath", "压缩文件路径不能为空");
|
||
|
||
if (!Directory.Exists(sourceFolder))
|
||
{
|
||
throw new DirectoryNotFoundException("源文件夹不存在: " + sourceFolder);
|
||
}
|
||
|
||
// 确保目标目录存在
|
||
var zipDir = Path.GetDirectoryName(zipFilePath);
|
||
if (!string.IsNullOrEmpty(zipDir) && !Directory.Exists(zipDir))
|
||
{
|
||
Directory.CreateDirectory(zipDir);
|
||
}
|
||
if (File.Exists(zipFilePath))
|
||
{
|
||
File.Delete(zipFilePath);
|
||
}
|
||
|
||
// 使用 EnumerateFiles 减少内存使用
|
||
var files = Directory.EnumerateFiles(sourceFolder, "*.*", SearchOption.AllDirectories);
|
||
|
||
using (var fileStream = new FileStream(zipFilePath, FileMode.Create, FileAccess.Write, FileShare.None, 8192))
|
||
using (var zipArchive = new ZipArchive(fileStream, ZipArchiveMode.Create, true))
|
||
{
|
||
foreach (var file in files)
|
||
{
|
||
try
|
||
{
|
||
string fileName = Path.GetFileName(file);
|
||
if (supplierId == 14)
|
||
{
|
||
fileName = dealMemoName(fileName);
|
||
}
|
||
// 获取相对路径
|
||
string relativePath = GetRelativePath(sourceFolder, file);
|
||
|
||
// 创建zip条目
|
||
var entry = zipArchive.CreateEntry(fileName, compressionLevel);
|
||
|
||
// 使用流写入文件内容
|
||
using (var entryStream = entry.Open())
|
||
using (var stream = File.OpenRead(file))
|
||
{
|
||
// 使用更大的缓冲区提高性能
|
||
stream.CopyTo(entryStream, 81920);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
// 记录错误但继续处理其他文件
|
||
writeLog("压缩文件失败: 错误: " + ex);
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
// 辅助方法：获取相对路径
|
||
private static string GetRelativePath(string basePath, string fullPath)
|
||
{
|
||
Uri baseUri = new Uri(basePath + Path.DirectorySeparatorChar);
|
||
Uri fullUri = new Uri(fullPath);
|
||
Uri relativeUri = baseUri.MakeRelativeUri(fullUri);
|
||
return Uri.UnescapeDataString(relativeUri.ToString()).Replace('\\', '/');
|
||
}
|
||
|
||
|
||
public static void addLog(string ctid, int userid, string con, int orderState = 0, int aftersaleState = 0)
|
||
{
|
||
CeErpTradeLog log = new CeErpTradeLog();
|
||
log.tid = ctid;
|
||
log.UserId = userid;
|
||
log.Con = con;
|
||
log.OrderState = orderState;
|
||
log.AfterSaleState = aftersaleState;
|
||
log.OperateTime = DateTime.Now;
|
||
log.Create();
|
||
}
|
||
private static string logPath = ConfigurationManager.AppSettings["curPath"] + "\\log";
|
||
private static object logFlag = new object();
|
||
public static void writeLog(string log)
|
||
{
|
||
lock (logFlag)
|
||
{
|
||
using (FileStream fileStream = new FileStream(logPath + "\\" + DateTime.Now.ToString("yy-MM-dd") + ".log", FileMode.Append, FileAccess.Write))
|
||
{
|
||
using (StreamWriter sw = new StreamWriter(fileStream, Encoding.Default))
|
||
{
|
||
sw.Write(log + " ------时间：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\r\n");
|
||
sw.Flush();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|