sticker/app_config.json 不存在,创建 tmp
This commit is contained in:
@@ -826,9 +826,9 @@ fn request_download_for_app(
|
||||
r#"{{"Type":"DownloadFile","Data":{{"filename":"{}","offset":{}}}}}"#,
|
||||
relative_path, offset
|
||||
);
|
||||
let ts = chrono::Local::now().format("%Y-%m-%d %H:%M:%S%.3f");
|
||||
log_print!("{} [应用] 请求下载: {} (offset {})", ts, relative_path, offset);
|
||||
log_print!("{} 发送消息:{}", ts, msg_str);
|
||||
// let ts = chrono::Local::now().format("%Y-%m-%d %H:%M:%S%.3f");
|
||||
// log_print!("{} [应用] 请求下载: {} (offset {})", ts, relative_path, offset);
|
||||
// log_print!("{} 发送消息:{}", ts, msg_str);
|
||||
sender.send(msg_str);
|
||||
}
|
||||
|
||||
@@ -1760,13 +1760,15 @@ async fn run_updater(debug_mode: bool) -> bool {
|
||||
if let Some(ref lm) = local_md5 {
|
||||
if lm != server_md5 {
|
||||
log_print!("{} [AllFile] {} MD5不一致 (本地={}, 服务端={}),创建 tmp", ts, filename, lm, server_md5);
|
||||
// 先创建目录
|
||||
let _ = fs::create_dir_all(&upgrade_base);
|
||||
// 先创建文件的父目录
|
||||
if let Some(parent) = tmp_path.parent() {
|
||||
let _ = fs::create_dir_all(parent);
|
||||
}
|
||||
// 创建空 tmp 文件标记需要下载
|
||||
if let Ok(_) = File::create(&tmp_path) {
|
||||
log_print!("{} [AllFile] 创建空 tmp 文件: {}", ts, tmp_filename);
|
||||
// 为这个正式文件发送下载请求
|
||||
log_print!("{} [AllFile] 请求下载 {}", ts, filename);
|
||||
// log_print!("{} [AllFile] 请求下载 {}", ts, filename);
|
||||
request_download_for_app(&sender, filename, 0);
|
||||
update_performed_clone2.store(true, std::sync::atomic::Ordering::SeqCst);
|
||||
}
|
||||
@@ -1777,8 +1779,10 @@ async fn run_updater(debug_mode: bool) -> bool {
|
||||
} else {
|
||||
// 文件不存在,创建空 tmp
|
||||
log_print!("{} [AllFile] {} 不存在,创建 tmp", ts, filename);
|
||||
// 先创建目录
|
||||
let _ = fs::create_dir_all(&upgrade_base);
|
||||
// 先创建文件的父目录
|
||||
if let Some(parent) = tmp_path.parent() {
|
||||
let _ = fs::create_dir_all(parent);
|
||||
}
|
||||
if let Ok(_) = File::create(&tmp_path) {
|
||||
log_print!("{} [AllFile] 创建空 tmp 文件: {}", ts, tmp_filename);
|
||||
// 为这个正式文件发送下载请求
|
||||
@@ -1801,7 +1805,7 @@ async fn run_updater(debug_mode: bool) -> bool {
|
||||
request_download_for_app(&sender, original_filename, file_size);
|
||||
} else {
|
||||
// tmp 不存在,重新下载
|
||||
log_print!("{} [AllFile] 请求下载 {}", ts, original_filename);
|
||||
// log_print!("{} [AllFile] 请求下载 {}", ts, original_filename);
|
||||
request_download_for_app(&sender, original_filename, 0);
|
||||
}
|
||||
update_performed_clone2.store(true, std::sync::atomic::Ordering::SeqCst);
|
||||
|
||||
Reference in New Issue
Block a user