単独実行
アプリケーションの翻訳変換
このプログラムの目的は、omfファイルのベース言語を置き換えることであり、使用する前にパラメーターの最初の4行を修正する必要があります。
例えば、test_flow.omfは繁体字中国語で設計されたアプリケーションであり、既にOMFLOWの内蔵機能によって各言語の翻訳がアップロードされています。英語を用いる利用者がこのアプリケーションを利用する必要がある場合、プログラムで「設計」の言語を繁体字中国語から英語に変更することができます。
※ omfファイルには、対応する翻訳が含まれている必要があることに注意してください。このプログラムは、翻訳を置き換えるだけであり、自動翻訳ではありません。
import json
path = '/some_path/test_flow.omf' #実際のパスと名前に従って修正してください
trans_to_path = '/some_path/test_flow.omf'
original_language = 'zh-hant' #実際のニーズに従って修正してください
replace_language = 'ja'
translator_onlytitle_formitem_type_list = ['box12','box6','areabox','n_user','n_group','u_gps','label']
translator_titleplaceholder_formitem_type_list = ['h_title','inputbox','date','datetime','subquery','inputcaculate','file']
translator_lists_formitem_type_list = ['h_level','h_status','list','checkbox']
translator_special_formitem_type_list = ['subtable']
def loopFlowObject(lan_dict, flowobject):
try:
items = flowobject.get('items',[])
for i in items:
item_type = i['type']
if item_type != 'line':
config = i['config']
item_text = lan_dict.get(i['text'],'')
if item_text:
i['text'] = item_text
if item_type in ['start','python','setform']:
loop_list = ['input','output']
loopInOutPut(lan_dict, loop_list, config)
elif item_type == 'end':
loop_list = ['output']
loopInOutPut(lan_dict, loop_list, config)
elif item_type in ['outflow','inflow','subflow']:
loop_list = ['subflow_input','subflow_output']
loopInOutPut(lan_dict, loop_list, config)
elif item_type == 'form':
loop_list = ['input','output','subflow_input','subflow_output','input1','input2']
loopInOutPut(lan_dict, loop_list, config)
action1_text = lan_dict.get(config['action1_text'], '')
if action1_text:
config['action1_text'] = action1_text
action2_text = lan_dict.get(config['action2_text'], '')
if action2_text:
config['action2_text'] = action2_text
form_object = config.get('form_object',{})
if form_object:
if form_object.get('items',[]):
loopFormObject(lan_dict, form_object)
elif item_type in ['async','switch']:
pass
except:
pass
def loopFormObject(lan_dict, formobject):
try:
items = formobject.get('items',[])
for i in items:
item_type = i['type']
config = i['config']
if item_type in translator_onlytitle_formitem_type_list:
title = lan_dict.get(config['title'],'')
if title:
config['title'] = title
elif item_type in translator_titleplaceholder_formitem_type_list:
title = lan_dict.get(config['title'],'')
if title:
config['title'] = title
placeholder = lan_dict.get(config['placeholder'],'')
if placeholder:
config['placeholder'] = placeholder
elif item_type == 'h_group':
group_title = lan_dict.get(config['group_title'],'')
if group_title:
config['group_title'] = group_title
user_title = lan_dict.get(config['user_title'],'')
if user_title:
config['user_title'] = user_title
elif item_type in translator_lists_formitem_type_list:
title = lan_dict.get(config['title'],'')
if title:
config['title'] = title
lists = config['lists']
for l in lists:
text = lan_dict.get(l['text'],'')
if text:
l['text'] = text
elif item_type in translator_special_formitem_type_list:
title = lan_dict.get(config['title'],'')
if title:
config['title'] = title
loopFormObject(lan_dict, config['form_object'])
except:
pass
def loopInOutPut(lan_dict, loop_list, config):
try:
for i in loop_list:
n_lst = config[i]
for n in n_lst:
des = lan_dict.get(n['des'],'')
if des:
n['des'] = des
except:
pass
try:
with open(path, "r", encoding="utf-8") as f:
content = f.read()
f.close()
omf_list = json.loads(content)
for omflow_app_dict in omf_list:
this_app_language_package = omflow_app_dict.get('language_package',{})
this_app_language_package = json.loads(this_app_language_package) if isinstance(this_app_language_package, str) else this_app_language_package
zh_hant = this_app_language_package.get('zh-hant',{})
en = this_app_language_package.get('en',{})
ja = this_app_language_package.get('ja',{})
zh_hans = this_app_language_package.get('zh-hans',{})
replace_dict = this_app_language_package.get(replace_language,{}).copy()
this_app_name = replace_dict.get(omflow_app_dict.get('app_name',''),'')
if this_app_name:
omflow_app_dict['app_name'] = this_app_name
this_app_flow_list = omflow_app_dict.get('flow_list',{})
for flow in this_app_flow_list:
this_flow_name = replace_dict.get(flow['flow_name'],'')
if this_flow_name:
flow['flow_name'] = this_flow_name
this_description = replace_dict.get(flow['description'],'')
if this_description:
flow['description'] = this_description
this_flowobject = flow.get('flowobject',{})
loopFlowObject(replace_dict, this_flowobject)
this_formobject = flow.get('formobject',{})
if not this_formobject:
this_formobject = this_flowobject.get('form_object',{})
loopFormObject(replace_dict, this_formobject)
this_subflow_list = this_flowobject.get('subflow',[])
for subflow in this_subflow_list:
this_subflow_name = replace_dict.get(subflow['name'],'')
if this_subflow_name:
subflow['name'] = this_subflow_name
this_subflow_description = replace_dict.get(subflow['description'],'')
if this_subflow_description:
subflow['description'] = this_subflow_description
loopFlowObject(replace_dict, subflow)
new_dict = {}
new_lan = ''
for origin_text in replace_dict:
replace_text = replace_dict[origin_text]
if replace_text:
if origin_text in zh_hant:
trans_text = zh_hant.pop(origin_text)
zh_hant[replace_text] = trans_text
if replace_language == 'zh-hant':
new_dict[replace_text] = origin_text
if origin_text in en:
trans_text = en.pop(origin_text)
en[replace_text] = trans_text
if replace_language == 'en':
new_dict[replace_text] = origin_text
if origin_text in ja:
trans_text = ja.pop(origin_text)
ja[replace_text] = trans_text
if replace_language == 'ja':
new_dict[replace_text] = origin_text
if origin_text in zh_hans:
trans_text = zh_hans.pop(origin_text)
zh_hans[replace_text] = trans_text
if replace_language == 'zh-hans':
new_dict[replace_text] = origin_text
this_app_language_package[original_language] = new_dict
omflow_app_dict['language_package'] = json.dumps(this_app_language_package)
result = json.dumps(omf_list)
with open(trans_to_path, "w", encoding="utf-8") as f:
f.write(result)
f.close()
except Exception as e:
print(e.__str__())
組織図上で特定の職務/権限を持つユーザーを見つけ出す
組織図上で特定の職務/権限を持つユーザーを整理してcsvファイルに保存します。
システムから組織図ファイルとレポートからユーザー情報をエクスポートし、それらの情報をユーザーの権限/職務に組み合わせます。
import json
f = open("mainOrg.omf", "r", encoding='UTF-8')
orgobject = f.read()
orgobject = json.loads(orgobject)
#職務コンポーネントで指定した名前に所属した権限に連結しているコンポーネントを見つける
sirList = []
for org_item in orgobject['items']:
if org_item['type'] == 'role' and '主管' in org_item['config']['responsibility']:
for line_item in orgobject['items']:
if line_item['type'] == 'line' and line_item['config']['source_item'] == org_item['id']:
sirList.append(line_item['config']['target_item'])
#前のコンポーネントのユーザーidを見つける
peopleList = []
for org_item in orgobject['items']:
if org_item['type'] == 'people' and org_item['id'] in sirList:
if not org_item['config']['noid'] in peopleList:
peopleList.append(org_item['config']['noid'])
import csv
#レポートによって生成されたユーザーcsvを開き、ユーザーidを比較して新しいcsvを生成する
readyList = []
with open('syscomUser.csv', newline='', encoding='UTF-8') as syscomUserfile:
spamreader = csv.reader(syscomUserfile, delimiter=',', quotechar='|')
for row in spamreader:
if row[0] in peopleList:
readyList.append(row[1:])
with open('syscomUserWithSir.csv', 'w', newline='', encoding='UTF-8') as syscomUserWithSirfile:
spamwriter = csv.writer(syscomUserWithSirfile, delimiter=',',
quotechar='|', quoting=csv.QUOTE_MINIMAL)
for row in readyList:
spamwriter.writerow(row)フォームデータのエクスポート
この節では、Pythonコードを提供し、OMFLOWフォームとその添付ファイルを1つのPDFファイルにエクスポートする方法を説明します。
パッケージのインストール
Scriptを実行する前に以下の条件を満たす必要があります：
Pythonパッケージ：
pip install requests
pip install pdfkitPDF ソフトウェア： 公式サイトから（ https://wkhtmltopdf.org ）現在の環境に適用できるインストールファイルをダウンロードし、インストールしてください。
スクリプトの実行
import requests, os, pdfkit, shutil, zipfile, threading, time
from datetime import datetime
stop_thread = False
def zip_folder(folder_path, zip_filename='data.zip'):
with zipfile.ZipFile(zip_filename, 'w', zipfile.ZIP_DEFLATED) as zipf:
for foldername, subfolders, filenames in os.walk(folder_path):
for filename in filenames:
file_path = os.path.join(foldername, filename)
arcname = os.path.relpath(file_path, folder_path)
zipf.write(file_path, arcname=arcname)
def your_while_loop(token_url, user, token):
while not stop_thread:
time.sleep(10)
response = requests.request("GET", token_url, auth=( user, token ))
ann = '''
#######################################################
# OMFLOW EXPORT TOOL #
# #
# Please make sure the current environment already #
# has the following packages. #
# #
# python package: requests, pdfkit. #
# pdf software: wkhtmltopdf.(https://wkhtmltopdf.org) #
# #
#######################################################
'''
try:
print(ann)
#user input param
server = input("Enter the OMFLOW server domain (ex. https://10.1.15.3:443):")
if server:
if server[-1] == '/':
server = server[:-1]
user = input("Enter the OMFLOW administrator username:")
token = input("Enter the password:")
api_path = input("Enter the API_PATH:")
print('')
print('Enter the wkhtmltopdf path or press enter to skip.')
print('ex. C:\\\\Program Files\\\\wkhtmltopdf\\\\bin\\\\wkhtmltopdf.exe')
path_wkhtmltopdf = input("wkhtmltopdf path:")
print('')
if path_wkhtmltopdf:
pdfkit_config = pdfkit.configuration(wkhtmltopdf=path_wkhtmltopdf)
else:
pdfkit_config = None
script_path = os.path.abspath(__file__)
script_directory = os.path.dirname(script_path)
download_directory_path = os.path.join(script_directory, 'data')
if not os.path.exists(download_directory_path):
os.makedirs(download_directory_path)
token_url = f'{server}/accounts/api/security/get/'
server_version_url = f'{server}/rest/app/server-version/get/'
list_omdata_url = f'{server}/rest/flowmanage/api/omdata/list/{api_path}'
html_url = f'{server}/rest/flowmanage/api/print-form/'
list_file_url = f'{server}/rest/api/files/list/'
get_mapping_url = f'{server}/rest/api/mapping-path/get/'
download_url = f'{server}/'
#param
total_size = 0
script_start_time = datetime.now()
#get token
response = requests.request("GET", token_url, auth=( user, token ))
response_dict = response.json()
this_status = response_dict.get('status', 404)
if this_status != 200:
raise Exception(f"OMFLOW return status code {this_status} when get security. error message: {response_dict.get('message','')}")
security = response_dict.get("result", {}).get("security")
#anothrt thread to get token
extra_thread = threading.Thread(target=your_while_loop, args=(token_url, user, token))
extra_thread.start()
#check Server version at least 1.2.0.0
values={
"security" : security,
"omflow_restapi" : 1
}
response = requests.post(server_version_url, json=values)
response_dict = response.json()
this_status = response_dict.get('status', 404)
if this_status != 200:
raise Exception(f"OMFLOW return status code {this_status} when get server version. error message: {response_dict.get('message','')}")
server_version = response_dict.get('result',{}).get('version','')
if server_version < 1002000000:
raise Exception(f"OMFLOW sever version at least 1.2.0.0")
#get flow_uuid
search_conditions = []
values={
"security" : security,
"omflow_restapi" : 1,
"search_conditions" : search_conditions,
"search_columns" : ['flow_uuid'],
"exclude_conditions" : [],
"order_columns" : [],
"limit" : 1,
"start" : 0
}
response = requests.post(list_omdata_url, json=values)
response_dict = response.json()
this_status = response_dict.get('status', 404)
if this_status != 200:
raise Exception(f"OMFLOW return status code {this_status} when list omdata. error message: {response_dict.get('message','')}")
result = response_dict.get('result')
if result:
flow_uuid = result[0]['flow_uuid'].replace('-','')
#get list
search_conditions = []
search_conditions.append({'column':'history','condition':'=','value':False})
search_conditions.append({'column':'running','condition':'=','value':False})
search_conditions.append({'column':'error','condition':'=','value':False})
search_conditions.append({'column':'closed','condition':'=','value':True})
values={
"security" : security,
"omflow_restapi" : 1,
"search_conditions" : search_conditions,
"search_columns" : ['id','data_no'],
"exclude_conditions" : [],
"order_columns" : ['-data_no','id'],
"limit" : 0,
"start" : 0
}
response = requests.post(list_omdata_url, json=values)
result = response.json().get('result')
total_count = len(result)
print(f'The total number of records for the target flow is {total_count}.')
print('Start to export omdata ...')
loop_count = 1
for omdata in result:
data_no = omdata['data_no']
data_id = omdata['id']
#check folder exists
data_no_directory_path = os.path.join(download_directory_path, data_no)
if not os.path.exists(data_no_directory_path):
os.makedirs(data_no_directory_path)
#check pdf exists
pdf_file_path = os.path.join(data_no_directory_path, f'{data_no}.pdf')
if not os.path.exists(pdf_file_path):
#get html
this_html_url = html_url + f'{flow_uuid}/{data_no}/{data_id}/'
values={
"security" : security,
"omflow_restapi" : 1,
}
response = requests.post(this_html_url, json=values)
if response.status_code != 200:
raise Exception(f'OMFLOW return status code {response.status_code} when get omdata html.')
this_html_content = response.content.decode('utf-8')
this_html_content = this_html_content.replace('window.print();window.close();','')
this_html_content = this_html_content.replace('<link rel="stylesheet" href="/static/plugins/fontawesome-free-5.13.0-web/css/all.css">','')
#html to pdf
if pdfkit_config:
pdfkit.from_string(this_html_content, pdf_file_path, configuration=pdfkit_config)
else:
pdfkit.from_string(this_html_content, pdf_file_path)
#amount size
total_size += os.path.getsize(pdf_file_path)
#get file path
this_file_search_conditions = []
this_file_search_conditions.append({'column':'flow_uuid','condition':'=','value':flow_uuid})
this_file_search_conditions.append({'column':'data_no','condition':'=','value':data_no})
this_file_search_conditions.append({'column':'delete','condition':'=','value':False})
values={
"security" : security,
"omflow_restapi" : 1,
"app_name" : 'omformflow',
"search_conditions" : this_file_search_conditions,
"search_columns" : ['file_name','data_id','formitm_id'],
"limit" : 0
}
response = requests.post(list_file_url, json=values)
response_dict = response.json()
this_status = response_dict.get('status', 404)
if this_status != 200:
raise Exception(f"OMFLOW return status code {this_status} when get mapping url. error message: {response_dict.get('message','')}")
this_file_list = response_dict.get('result')
for this_file in this_file_list:
#check file exists
this_file_path = os.path.join(data_no_directory_path, this_file['file_name'])
if not os.path.exists(this_file_path):
#get mapping path
if this_file['formitm_id']:
this_rel_path = os.path.join('omformflow', flow_uuid, data_no, str(this_file['data_id']), this_file['formitm_id'], this_file['file_name'])
else:
this_rel_path = os.path.join('omformflow', flow_uuid, data_no, str(this_file['data_id']), this_file['file_name'])
values={
"security" : security,
"omflow_restapi" : 1,
"path" : this_rel_path,
"path_type" : 'download_files'
}
response = requests.post(get_mapping_url, json=values)
response_dict = response.json()
this_status = response_dict.get('status', 404)
if this_status != 200:
raise Exception(f"OMFLOW return status code {this_status} when get mapping url. error message: {response_dict.get('message','')}")
mapping_path = response_dict.get('result')
#download file
this_download_url = download_url + mapping_path
response = requests.get(this_download_url)
if response.status_code != 200:
raise Exception(f'OMFLOW return status code {response.status_code} when download files.')
#write file
this_file_content = response.content
with open(this_file_path, 'wb') as f:
f.write(this_file_content)
f.close()
#amount size
total_size += os.path.getsize(this_file_path)
#print info every 10 records
if loop_count % 10 == 0:
now_time = datetime.now()
print(f'Currently, {loop_count} records have been exported, consuming {total_size / (1024 ** 2):.2f} MB of space.')
t, u, f = shutil.disk_usage(script_directory)
print(f'There is still {f / (1024 ** 3):.2f} GB of space available on the disk')
x = (total_count - loop_count) / loop_count
print(f'Anticipated additional requirement of {x * total_size / (1024 ** 3):.2f} GB.')
time_difference = now_time - script_start_time
minutes_difference = float(time_difference.total_seconds() / 60)
print(f'Anticipated additional time required: {x * minutes_difference:.2f} minutes.')
loop_count += 1
#zip folder
print('Export OmData finished. Start to zip folder.')
zip_file_path = os.path.join(script_directory, 'data.zip')
if os.path.exists(zip_file_path):
os.remove(zip_file_path)
#print info
now_time = datetime.now()
time_difference = now_time - script_start_time
minutes_difference = float(time_difference.total_seconds() / 60)
print(f'Anticipated additional time required: {4 * minutes_difference:.2f} minutes.')
zip_folder(download_directory_path, zip_file_path)
#remove folder
shutil.rmtree(download_directory_path)
else:
print(f'Unable to retrieve any data from {api_path}.')
#stop thread
stop_thread = True
extra_thread.join()
print('OMFLOW data export finish!')
except Exception as e:
#stop thread
stop_thread = True
extra_thread.join()
print('OMFLOW data export error: ',e.__str__())
Scriptの実行ステップは以下のとおりです：
以下の情報を入力してください：
OMFLOW サーバーのドメイン/IP:port（例 https://10.1.15.3:443）
管理者権限を持つアカウント（OMFLOW管理者）
ユーザーパスワード
エクスポートしたいプロセスのAPIパス
wkhtmltopdf.exe のパスがすでに環境変数(PATH)に追加されている場合は、Enterを押してスキップできます
実行中、画面にはプロセスのクローズドレコードの総数が表示され、同時にダウンロードタスクが実行されます。 10件のレコードが処理されるごとに、以下の情報が提供されます：
現在の空き容量
現在の環境で利用可能な容量
ダウンロードに必要な推定スペース
ダウンロードに必要な推定時間
※ 上記の項目3と4で提供される予想は、タスクを完了させるためのリソース消費量に基づくため、完全に正確ではない可能性があります。
ダウンロード条件の変更
このスクリプトはOMFLOW APIで完成するもので、必要に応じて内容を変更することができます。
まだクローズしていないデータをダウンロードしたい場合は、元のスクリプトの117行目から以下の部分を削除します。
search_conditions.append({'column':'closed','condition':'=','value':True})'formitm_1' フィールド イコール'SYSCOM' の記録だけを検索したい場合は、以下の内容を追加します。
search_conditions.append({'column':' formitm_1','condition':'=','value': ' SYSCOM'})検索条件の詳細については、【フォーム検索】を参照してください。
LDAP変更同期スクリプト
このスクリプトは、OMFLOWシステムでLDAPを変更し、新しいLDAPユーザや部署が元のフォームやタスクを正しく取得できるようにします。 以下のスクリプトのパラメータは、実際のLDAP環境に応じて変更する必要があります：
接続情報
ldapdata：JSON形式で、「新しいユーザー、古いユーザー、新しい部門、古い部門 」の4つの設定が含まれており、各設定は、次のパラメータを調整する必要があります：
ldap_client_server：LDAP ServerのIPアドレスを記入する
ldap_client_server_port：LDAP ServerのPortを記入する
ldap_base_dn：LDAPサーバーのベースDNを記入する。例：
"DC=dcname,DC=com"ldap_search_dn：填入LDAP Serverの検索範囲を記入する。例：
"OU=ouname"ldap_bind_user：填入LDAP Serverのユーザー名をを記入する
ldap_bind_user_password：填入LDAP Serverのユーザーパスワード記入する
search_filter：同期オブジェクトの検索条件を記入する。例：
"(&(|(objectclass=user)(objectclass=person))"
同期パラメータ
nickname：レポートを生成する際にユーザーの表示名として使用する属性のこと。例：
'cn'username：古いユーザーと新しいユーザーが同一人物かどうかを比較する属性のこと。例：
'sAMAccountName'groupname：レポートを作成する際に部門の表示名として使用する属性のこと。例：
'name'groupno：古い部門と新しい部門が同一部門かどうかを比較する属性のこと。例：
'sAMAccountName'
※ 注意：このスクリプトは「OMFLOWが新しいLDAPと同期」の前に実行する必要があり、事前にデータベースをバックアップする必要があります。
from ldap3 import Server, Connection, ALL
import ast, re
from openpyxl import Workbook
from omuser.models import OmUser, OmGroup
from django.contrib.auth.models import Group
from omflow.syscom.default_logger import error
#変更必要なパラメーター
nickname = 'cn'
username = 'sAMAccountName'
groupname = 'name'
groupno = 'sAMAccountName'
#変更必要なパラメーター
ldapdata = [{'name':'ad_user_old','ldap_client_server': "<IP>", 'ldap_client_server_port': <Port>, 'ldap_base_dn': "<DC=dcname,DC=com>", 'ldap_search_dn': "<OU=ou_name>", 'ldap_bind_user': '<LDAP_username>', 'ldap_bind_user_password': "<LDAP_password>","search_filter":"<search_filter>"},
{'name':'ad_user_new','ldap_client_server': "<IP>", 'ldap_client_server_port': <Port>, 'ldap_base_dn': "<DC=dcname,DC=com>", 'ldap_search_dn': "<OU=ou_name>", 'ldap_bind_user': '<LDAP_username>', 'ldap_bind_user_password': "<LDAP_password>","search_filter":"<search_filter>"},
{'name':'ad_group_old','ldap_client_server': "<IP>", 'ldap_client_server_port': <Port>, 'ldap_base_dn': "<DC=dcname,DC=com>", 'ldap_search_dn': "<OU=ou_name>", 'ldap_bind_user': '<LDAP_username>', 'ldap_bind_user_password': "<LDAP_password>","search_filter":"<search_filter>"},
{'name':'ad_group_new','ldap_client_server': "<IP>", 'ldap_client_server_port': <Port>, 'ldap_base_dn': "<DC=dcname,DC=com>", 'ldap_search_dn': "<OU=ou_name>", 'ldap_bind_user': '<LDAP_username>', 'ldap_bind_user_password': "<LDAP_password>","search_filter":"<search_filter>"}]
ad_user_o = []
ad_user_n = []
ad_group_o = []
ad_group_n = []
for ldapdata_json in ldapdata:
name = ldapdata_json.get('name','')
result = []
ldap_search_dn_list = []
ldap_client_server = ldapdata_json['ldap_client_server']
ldap_client_server_port = ldapdata_json['ldap_client_server_port']
ldap_base_dn = ldapdata_json['ldap_base_dn']
ldap_search_dn = ldapdata_json.get('ldap_search_dn','')
ldap_bind_user = ldapdata_json['ldap_bind_user']
ldap_bind_user_password = ldapdata_json['ldap_bind_user_password']
ldap_search_filter = ldapdata_json['search_filter']
#検索必要のルートを整理する
if ldap_search_dn:
new_ldap_dn = ldap_search_dn + ',' + ldap_base_dn
else:
new_ldap_dn = ldap_base_dn
if 'user' in name:
attributes_list = ['sAMAccountname','objectSid','cn']
elif 'group' in name:
attributes_list = ['sAMAccountname','objectGUID','name']
#create connection
server = Server(host=ldap_client_server,port=int(ldap_client_server_port),get_info=ALL,connect_timeout=3)
conn = Connection(server, ldap_bind_user, ldap_bind_user_password, auto_bind='NONE', version=3, authentication='SIMPLE', client_strategy='SYNC', auto_referrals=True, check_names=True, read_only=False, lazy=False, raise_exceptions=False)
conn.bind()
ldap_object = conn.extend.standard.paged_search(search_base=new_ldap_dn,
search_filter=ldap_search_filter,
attributes=attributes_list,
get_operational_attributes=True)
for ldap in ldap_object:
result.append(ldap.copy())
conn.unbind()
result_data=[]
for idx in range(len(result)):
result_data.append(result[idx]['attributes'])
if name == 'ad_user_old':
ad_user_o = result_data
elif name =='ad_user_new':
ad_user_n = result_data
elif name == 'ad_group_old':
ad_group_o = result_data
elif name == 'ad_group_new':
ad_group_n = result_data
try:
##ad_user compare and record
wb = Workbook()
ws = wb.active
ws.title = 'AD_user_compare'
ws.append(['cn','objectSid','sAMAccountName','','result','','new_cn','new_objectSid','new_sAMAccountName'])
n_sAMAccountName = []
o_sAMAccountName = []
log = []
#NEW ADの純sAMAccountName list取得する
for adUser in ad_user_n:
n_sAMAccountName.append(adUser[username])
#ad_user mapping and change sid
for adUser in ad_user_o:
user_sAMAccountName = adUser[username]
o_sAMAccountName.append(user_sAMAccountName)
user_sid = adUser['objectSid']
try:
search_idx = n_sAMAccountName.index(user_sAMAccountName)
if user_sid != ad_user_n[search_idx]['objectSid']:
try:
user = OmUser.objects.get(username=user_sAMAccountName)
user.ad_sid = ad_user_n[search_idx]['objectSid']
user.save()
result = 'ADユーザーを変更ad_sid'
ws.append([adUser[nickname],adUser['objectSid'],adUser[username],'',result,'',ad_user_n[search_idx][nickname],ad_user_n[search_idx]['objectSid'],ad_user_n[search_idx][username]])
log.append(f'ユーザー：{user.username} はad_sidを変更完了')
except Exception as e:
log.append(f'DBにユーザーが見つかりません：{user_sAMAccountName}，データベースに異動があるかご確認ください'+e.__str__())
else:
result = '変更なし更'
ws.append([adUser[nickname],adUser['objectSid'],adUser[username],'',result,'',ad_user_n[search_idx][nickname],ad_user_n[search_idx]['objectSid'],ad_user_n[search_idx][username]])
log.append(f'ユーザー：{user_sAMAccountName}，ADを移動しても保持され、DBのad_noは変更されません')
except ValueError :
result = 'ADユーザーの削除'
ws.append([adUser[nickname],adUser['objectSid'],adUser[username],'',result])
log.append(f'ユーザー：{user_sAMAccountName}，AD同期後に削除されます')
n_user_set = set(n_sAMAccountName)
o_user_set = set(o_sAMAccountName)
blance = n_user_set - o_user_set
if len(blance)>0:
for newUser in blance:
for sa in ad_user_n:
if newUser == sa.get('sAMAccountName',''):
result = 'ADユーザーの追加'
ws.append(['','','','',result,'',sa.get('cn',''),sa.get('objectSid',''),newUser])
log.append(f'ユーザー：{newUser}，AD同期後に追加されます')
break
#ad_group compare and record
ws2 = wb.create_sheet(title='AD_group_compare')
ws2.append(['name','objectGUID','sAMAccountName','','result','','new_name','new_objectGUID','new_sAMAccountName'])
n_sAMAccountName =[]
o_sAMAccountName =[]
for adGroup in ad_group_n:
n_sAMAccountName.append(adGroup[groupno])
for adGroup in ad_group_o:
group_sAMAccountName = adGroup[groupno]
o_sAMAccountName.append(group_sAMAccountName)
group_guid = adGroup['objectGUID']
try:
search_idx = n_sAMAccountName.index(group_sAMAccountName)
if group_guid != ad_group_n[search_idx]['objectGUID']:
try:
group = Group.objects.get(name=group_guid)
group.name = ad_group_n[search_idx]['objectGUID']
group.save()
result = 'AD部門の変更'
ws2.append([adGroup[groupname],adGroup['objectGUID'],adGroup[groupno],'',result,'',ad_group_n[search_idx][groupname],ad_group_n[search_idx]['objectGUID'],ad_group_n[search_idx][groupno]])
log.append(f'部門：{group.name} name変更完了')
except Exception as e:
log.append(f'DBに部門が見つかりません：{group_guid}，データベースに異動があるかご確認ください'+e.__str__())
else:
result = '変更なし'
ws2.append([adGroup[groupname],adGroup['objectGUID'],adGroup[groupno],'',result,'',ad_group_n[search_idx][groupname],ad_group_n[search_idx]['objectGUID'],ad_group_n[search_idx][groupno]])
log.append(f'部門：{group_guid}，ADを移動しても保持され，DBのnameは変更されません')
except ValueError :
result = 'AD部門の削除'
ws2.append([adGroup[groupname],adGroup['objectGUID'],adGroup[groupno],'',result])
log.append(f'部門：{group_guid}，AD同期後に削除されます')
n_group_set = set(n_sAMAccountName)
o_group_set = set(o_sAMAccountName)
group_blance = n_group_set - o_group_set
if len(group_blance)>0:
for newgroup in group_blance:
result = 'AD部門の追加'
ws2.append(['','','',result,'','',newgroup])
log.append(f'部門：sAMAccountNameは{newgroup}の部門で，AD同期後に追加されます')
wb.save(r'C:\Users\futures\moveADserver.xlsx')
except Exception as e:
log.append('DB接続に失敗')
error(str(e))
with open(r'C:\Users\futures\moveADlog.txt','w',encoding='UTF-8') as file3:
for line in log:
file3.write(str(line)+'\n')
Last updated
