大家好,欢迎来到IT知识分享网。
一、软件环境
1.1 所需软件
1、 大疆智图:点击下载;
2、 ArcGIS Pro 3.1.5:点击下载,建议使用IDM或Aria2等多线程下载器;
3、 IDM下载器:点击下载,或自行搜索;
4、 FastCopy:自行搜索;
5、 Rclone:自行搜索配置;
6、 Python:安装软件ArcGIS Pro 3.1.5过程已安装,或自行搜索安装。
1.2 软件介绍
1、 大疆智图:进行空三、二维重建,软件需授权。无有效授权使用其他同替软件;
2、 ArcGIS Pro 3.1.5:使用Python脚本进行金字塔构建;
3、 FastCopy:局域网内成果快速拷贝;
4、 Rclone:配置账号成果上传分发;
以上软件按需使用。
二、大疆智图软件操作
2.1 软件启动
鼠标双击桌面“DJI Terra”图标,登录账号后进入软件。
2.2 任务创建
鼠标点击“新建任务”,选择“可见光”。
输入“任务名称”后点击“确定”。
2.3 导入照片
点击“添加照片”或“添加文件夹”,等待照片导入。
2.4 空三(建议操作,可跳过)
点击“空三”,“场景”:普通场景,点击“高级设置”—“像控点管理”。
点击“坐标系”,“水平设置”:建议与二维重建坐标系一致;“高程设置”:按需设置。
点击“空三”,等待重建。
2.5 空三质量报告导出(建议操作,可跳过)
空三重建完成后,核实无误。点击“空三质量报告”,点击“导出PDF”。
2.6 二维重建
“分辨率”:高;“场景”:测绘场景(一般为测绘场景,农田无高差可选农田场景);
点击“高级设置”,“水平设置”:选择所需坐标系;“高程设置”:按需设置。
点击“开始重建”,等待重建。
三、成果传输操作
鼠标右键点击“影像_构建金字塔.py”;
选择“Run with ArcGIS Pro”,或选择“Edit with IDLE(ArcGIS Pro)”后按键盘“F5”按键。
输入“1”后,按“回车”键确认。
输入或粘贴局域网存放成果的路径。
构建金字塔运行情况。
四、代码
复制以下代码,并修改(注释、删除)以下(或者更多)参数,确保脚本能够正确执行。
#拼接大疆任务目录
dom_path
# 设置 7-Zip 可执行文件路径
seven_zip_path
# 设置 fcp 可执行文件路径
fcp_path
# 设置 rclone 可执行文件路径
rclone_path
# 设置 rclone 上传文件路径
rclone_up_path
#压缩至E盘根目录
compressed_file
# -*- coding: cp936 -*- import arcpy import os import time import datetime import subprocess import concurrent.futures # 判断指定目录是否存在 def check_path_exists(dir_path): if not os.path.exists(dir_path): print(f"指定目录:{
dir_path} 不存在!") exit() # 判断金字塔文件是否存在 def check_pyramids_file_exists(file_path): if os.path.isfile(f"{
file_path}.ovr"): print(f"已经存在:{
file_path} 金字塔文件") check_pyramids_file(file_path) else: pyramids_file(file_path) # 检查金字塔文件是否正确 def check_pyramids_file(file_path): result = arcpy.management.CheckPyramids(file_path) if result: print(f"检查文件:{
file_path} 金字塔文件正确") else: print(f"检查文件:{
file_path} 金字塔文件错误") pyramids_file(file_path) # 构建金字塔文件 def pyramids_file(file_path): print(f"开始构建:{
file_path} 金字塔文件") start_time = time.time() arcpy.management.BuildPyramids(file_path) end_time = time.time() execution_time = end_time - start_time td = datetime.timedelta(seconds=execution_time) hh, mm, ss = str(td).split(":") # 将时间差转换为时分秒 print(f"构建用时:{
file_path} 构建{
hh}小时{
mm}分钟{
ss}秒") # fascoy同步最新日期目录 def sync_update_folder(source_path, destination_path): print(f"正在同步:{
source_path}") cmd = f'{
fcp_path} /cmd=sync_update /force_close {
source_path} /to="{
destination_path}"' startupinfo = subprocess.STARTUPINFO() startupinfo.dwFlags |= subprocess.STARTF_USESHOWWINDOW subprocess.run(cmd, startupinfo=startupinfo, shell=True) # fascoy同步目录 def sync_folder(source_path, destination_path): print(f"正在同步:{
source_path}") cmd = f'{
fcp_path} /cmd=sync /force_close {
source_path} /to="{
destination_path}"' startupinfo = subprocess.STARTUPINFO() startupinfo.dwFlags |= subprocess.STARTF_USESHOWWINDOW subprocess.run(cmd, startupinfo=startupinfo, shell=True) # rclone同步文件 def upload_file(compressed_file, rclone_up_path): print(f"正在上传:{
compressed_file}") cmd = f"{
rclone_path} sync {
compressed_file} {
rclone_up_path} --progress" startupinfo = subprocess.STARTUPINFO() startupinfo.dwFlags |= subprocess.STARTF_USESHOWWINDOW subprocess.run(cmd, startupinfo=startupinfo, shell=True) print(f"上传成功:{
compressed_file}") # 7Z压缩目录 def seven_zip_file(dom_path): # 获取文件名 cmd = f'{
rclone_path} ls "{
rclone_up_path}"' process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True) output, error = process.communicate() # 解析输出,将文件名存入列表中 rclone_list = [line.split()[-1] for line in output.decode('utf-8').splitlines() if line.split()[-1]] for foldername in os.listdir(dom_path): folder_path = os.path.join(dom_path, foldername) if f"{
foldername}.7z" not in rclone_list: compressed_file = f"E:\{
foldername}.7z"#压缩至E盘根目录 compressed_files.append(compressed_file) command = f'"{
seven_zip_path} u {
compressed_file} "{
os.path.join(folder_path, "map", "result*.*")}"' print(f"正在压缩:{
foldername}") startupinfo = subprocess.STARTUPINFO() startupinfo.dwFlags |= subprocess.STARTF_USESHOWWINDOW subprocess.run(command, startupinfo=startupinfo, shell=True) else: print(f"已经存在:{
foldername} ;如需更新,请先删除 {
rclone_up_path} 中同名文件。") # 删除本地 7z 文件 def delete_file(compressed_file): for file in compressed_files: os.remove(file) print(f"本地文件:{
file} 已删除!") # 多线程处理map目录下dsm.tif与result.tif文件 def process_folder(foldername): folder_path = os.path.join(dom_path, foldername) if os.path.isdir(folder_path): check_pyramids_file_exists(os.path.join(folder_path, r"map\dsm.tif")) check_pyramids_file_exists(os.path.join(folder_path, r"map\result.tif")) # 选择目录 choice = input("待构建金字塔文件DOM路径为:\n1、所在目录\n2、指定目录\n请选择:") if choice == "1": current_file_path = os.path.abspath(__file__) folder_path = os.path.dirname(current_file_path) #拼接大疆任务目录 dom_path = os.path.join(folder_path, "PCGSPRO\\xxx") else: dom_path = input("请输入指定目录:") check_path_exists(dom_path) # 局域网存放路径 dst_path = input("请输入存放路径:") check_path_exists(dst_path) if __name__ == "__main__": # 设置 7-Zip 可执行文件路径 seven_zip_path = f'"C:/Program Files/7-Zip/7z.exe"' # 设置 fcp 可执行文件路径 fcp_path = f'"C:/Program Files/FastCopy5.7.10_x64/fcp.exe"' # 设置 rclone 可执行文件路径 rclone_path = f'"D:/Program Files/rclone/rclone.exe"' # 设置 rclone 上传文件路径 rclone_up_path = "OneDrive:/成果数据" # 压缩文件的列表 compressed_files = [] # 创建线程池,最大线程为4,构建金字塔文件 with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor: executor.map(process_folder, os.listdir(dom_path)) # 局域网同步目录 for foldername in os.listdir(dom_path): folder_path = os.path.join(dom_path, foldername) if os.path.isdir(folder_path): #获取乡镇名称 #town_name = folder_path.split("\\")[-1].split("_")[0] #成果拷贝_乡镇名称子目录 #sync_folder(f'"{os.path.join(folder_path, "map", "dsm*.*")}" "{os.path.join(folder_path, "map", "result*.*")}"', os.path.join(dst_path, town_name, foldername)) #sync_folder(f'"{os.path.join(folder_path, "map", "*_质量报告.pdf")}" "{os.path.join(folder_path, r"AT/report/POS_residual_of_camera.csv")}"', os.path.join(dst_path, town_name, foldername, "空三")) #成果拷贝_大疆任务名称 sync_folder(f'"{
os.path.join(folder_path, "map", "dsm*.*")}" "{
os.path.join(folder_path, "map", "result*.*")}"', os.path.join(dst_path, foldername)) sync_folder(f'"{
os.path.join(folder_path, "map", "*_质量报告.pdf")}" "{
os.path.join(folder_path, r"AT/report/POS_residual_of_camera.csv")}"', os.path.join(dst_path, foldername, "空三")) #压缩文件 seven_zip_file(dom_path) # 异步上传文件 with concurrent.futures.ThreadPoolExecutor() as executor: futures = [executor.submit(upload_file, file, rclone_up_path) for file in compressed_files] concurrent.futures.wait(futures) #删除压缩文件 delete_file(compressed_file) print("\nOVER!") input("按任意键继续...")
五、说明
1、大疆智图空三丢失图片:
因空三导入的区域不连续,并且接壤的地方没有重叠。导致空三时,无法获取到对应的特征点,从而重建缺失或者失败。只能单独重建或补飞。见官方说明,与客服沟通情况。
2、构建金字塔:
默认使用4线程操作,最大线程数量可修改;
3、局域网同步:
sync_update_folder或sync_folder可选,考虑硬盘读写情况,使用FastCopy顺序同步;
FastCopy同步:支持通配符,无需额外搭建环境;
Rclone同步:自用更倾向于搭建webdav等方式同步,速度尚可;
4、压缩文件:
7Z参数可修改,考虑硬盘读写情况,使用7Z顺序压缩;
5、脚本文件使用:
需要键入参数适合人工交互处理,修改代码固定参数之后便于定时任务自动化处理。
六、更新
:
1、调整脚本文件代码顺序,便于注释、删除功能;
2、修改金字塔文件验证方式。
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://haidsoft.com/146715.html