%%%------------------------------------------------------------------- %%% @author pansen %%% @copyright (C) 2018, %%% @doc %%% %%% @end %%% Created : 01. 八月 2018 16:01 %%%------------------------------------------------------------------- -module(syncDB_mnesia). -author("pansen"). -compile(export_all). %%-include("DbTool.hrl"). -include("nodeTool.hrl"). test() -> io:format("start test 12333 ~n"), mnesia:start(), lager:start(), ok. setCNode(CNode) -> Ret = mochiglobal:put('cNodeName', CNode), case Ret of ok -> Res = [{atomic, ok}]; _ -> Res = [{aborted, notok}] end, Res. % setCNode(CNode) -> % io:format("setCNode name ~p ",[CNode]), % % BerPid = mochiglobal:get('sendMessToCNodePID'), % % case BerPid of % % undefined -> % % io:format("BerPid is ~p ",[BerPid]), % % Pid = spawn(fun() -> % % callCNode:loop(CNode) % % end), % % mochiglobal:put('sendMessToCNodePID',Pid); % % _-> % % io:format("BerPid is ~p ",[BerPid]), % % BerPid ! stop, % % Pid = spawn(fun() -> % % callCNode:loop(CNode) % % end), % % mochiglobal:put('sendMessToCNodePID',Pid) % % end, % Pid = spawn(fun() -> % callCNode:loop(CNode) % end), % case whereis(sendMessToCNodePID) of % undefined -> % ok; % _-> % unregister(sendMessToCNodePID) % end, % Ret = register(sendMessToCNodePID, Pid), % case Ret of % true -> % io:format("register staus ~p, Pid is ~p",[Ret,Pid]), % Res =[{atomic, ok}]; % _-> % io:format("register staus ~p, Pid is ~p",[Ret,Pid]), % Res=[{aborted,notok}] % end, % Res. %%注册进程名字 % %% mochiglobal:put('cNPid', Pid). sendMessage() -> Nodes = mnesia:system_info(running_db_nodes), io:format("sendMessage ~p", [Nodes]), Res = syncTool:rpcSendMessToCNode(Nodes, {call, 'update', 1}), case Res of null -> io:format("send ok"), Ret = [{atomic, ok}]; _ -> io:format("send error"), Ret = [{aborted, notok}] end, Ret. % sendMessage()-> % Nodes=mnesia:system_info(running_db_nodes), % io:format("sendMessage ~p",[Nodes]), % Res = syncTool:rpcSendMessToCNode(Nodes, {call, 'update', 1}), % case Res of % null -> % io:format("send ok"), % Ret=[{atomic, ok}]; % _ -> % io:format("send error"), % Ret=[{aborted,notok}] % end, % Ret. %% %% 启动节点并自动连接到集群 %% 新节点自动进行初始化 %% startNode(NodeName, FatherNodeName, DeviceId, ClusterId, ClusterName) -> lager:start(), io:format("start Node"), %% setCNode('c1@127.0.0.1'), mnesiaDbStart(1000), TableList = mnesia:system_info(tables), try case TableList of [schema] -> if FatherNodeName == ' ' -> Ret = initLocalFathNodeDB(NodeName), io:format("initLocalFathNodeDB is : ~p ~p~n", [FatherNodeName, Ret]), %%%#todo add device_rec to db clusterInfo:add_ClusterInfo(ClusterId, ClusterName), device_info:add_deviceInfo(uuid:to_string(uuid:uuid5(uuid:uuid4(), "NodeName")), DeviceId, NodeName, ClusterId); true -> Ret = initLocalSubNodeDB(NodeName, FatherNodeName), io:format("initLocalSubNodeDB is : ~p ~p~n", [FatherNodeName, Ret]), %%%#todo add device_rec to db device_info:add_deviceInfo(uuid:to_string(uuid:uuid5(uuid:uuid4(), "NodeName")), DeviceId, NodeName, ClusterId) end, mnesiaDbStart(10000) end catch Ex:Type -> {Ex, Type, erlang:get_stacktrace()}, io:format("table list is ~p,~p,~p ~n", [Ex, Type, TableList]) end, io:format("mnesia info tables ~p~n", [mnesia:info()]), %% try VE = syncDB:findAllNode(), if is_tuple(VE) == true -> RSRET = {faile, notok}; is_list(VE) == true -> RSRET = {atomic, ok} end, RSRET. modifyCluName(CluId, CluName) -> Tmp = clusterInfo:add_ClusterInfo(CluId, CluName), if Tmp == ok -> RET = [{atomic, ok}]; true -> RET = [{aborted, message}] end, RET. removeNode() -> %% #todo 集群的最后一个节点退出时,删除集群信息 [Node | Nodes] = mnesia:system_info(running_db_nodes), if Node == node() -> io:format("Node eq node() ~n"), device_info:del_DevInfo(Node), mnesia:stop(), {atomic, ok}; true -> rpc:call(Node, syncDB, rpcDeleteNode, [node()]) end. findAllNode() -> device_info:deviceOnlineList2Maps(device_info:findDeviceOnlineList('device_info', mnesia:system_info(running_db_nodes))). %%???? getNodeOrTable(TableName, SyncType) -> if SyncType == '1' -> NewTableName = TableName, Nodes = mnesia:system_info(running_db_nodes); true -> %% #todo NewTableName = "", Nodes = [node()] end, {Nodes, NewTableName}. %% 创建底库 %% 创建底库 表类型，表名，同步状态，黑白名单 createDatabase(TableType, TableName, SyncType, BwType, StartTime, EndTime) -> io:format("createDatabase ~p ~p ~p ~p ~p ~p ~n", [TableType, TableName, SyncType, BwType, StartTime, EndTime]), Uuid = "", Tup = getNodeOrTable(TableName, SyncType), if TableType == 'person' -> %% Ret = person_info:create_personInfo(element(1, Tup), element(2, Tup)), %% Ret2 = person_info_feature:create_personFeature(element(1, Tup), element(2, Tup)), Ret = person_info:create_personInfo(element(1, Tup), TableName), PerFea = addFea2TableName(TableName), Ret2 = person_info_feature:create_personFeature(element(1, Tup), PerFea), io:format("Ret ~p ~n", [Ret]), if Ret == {atomic, ok} -> tableType:add_tableType(Uuid, TableName, BwType), %%todo time sys_o_tables:add_sys_table(Uuid, TableName, 'test', TableType, StartTime, EndTime), %% #todo send message PerRet = [Ret | [Ret2]]; true -> Z = element(1, element(2, Ret)), io:format("Z ~p ~n", [Z]), if Z == already_exists -> tableType:add_tableType(Uuid, TableName, BwType), %%todo time sys_o_tables:add_sys_table(Uuid, TableName, 'test', TableType, StartTime, EndTime), %% #todo send message PerRet = [{atomic, ok} | [{atomic, ok}]]; true -> PerRet = [Ret | [Ret2]] end end; TableType == 'car' -> %% Ret = car_info:create_carInfo(element(1, Tup), element(2, Tup)), Ret = car_info:create_carInfo(element(1, Tup), TableName), tableType:add_tableType(Uuid, TableName, BwType), %%todo time sys_o_tables:add_sys_table(Uuid, TableName, 'test', TableType, StartTime, EndTime), %% PerRet = [Ret], io:format("Ret ~p ~n", [Ret]), if Ret == {atomic, ok} -> PerRet = [Ret]; true -> Z = element(1, element(2, Ret)), io:format("Z ~p ~n", [Z]), if Z == already_exists -> PerRet = [{atomic, ok} | [{atomic, ok}]]; true -> PerRet = [Ret] end end; true -> PerRet = [{aborted, {'tableType_error', TableType}}], io:format("Error ~p ~n", [TableType]) end, %% tableType:add_tableType(element(2, Tup), BwType), %% if %% SyncType == '1' -> %% %% end, io:format("PerRet ~p ~n", [PerRet]), PerRet. %% c底库 %% 创建底库 表类型，表名，同步状态，黑白名单 updateDatabase(Uuid, TableType, TableName, SyncType, BwType, StartTime, EndTime) -> io:format("createDatabase ~p ~p ~p ~p ~p ~p ~n", [TableType, TableName, SyncType, BwType, StartTime, EndTime]), Tup = getNodeOrTable(TableName, SyncType), if TableType == 'person' -> tableType:add_tableType(Uuid, TableName, BwType), %%todo time sys_o_tables:add_sys_table(Uuid, TableName, 'test', TableType, StartTime, EndTime), %% #todo send message PerRet = [{atomic, ok}]; TableType == 'car' -> %% Ret = car_info:create_carInfo(element(1, Tup), element(2, Tup)), %% Ret = car_info:create_carInfo(element(1, Tup), TableName), tableType:add_tableType(Uuid, TableName, BwType), %%todo time sys_o_tables:add_sys_table(Uuid, TableName, 'test', TableType, StartTime, EndTime), %% #todo send message PerRet = [{atomic, ok}]; true -> PerRet = [{aborted, {'tableType_error', TableType}}], io:format("Error ~p ~n", [TableType]) end, io:format("PerRet ~p ~n", [PerRet]), PerRet. %% shanchu底库 %% shanchu底库 表类型，表名 deleteDatabase(TableType, TableName) -> io:format("deleteDatabase ~p ~p ~n", [TableType, TableName]), %% case of %% ->; %%end, Ret = mnesia:clear_table(TableName), if TableType == 'person' -> case Ret of {atomic, ok} -> PerFea = addFea2TableName(TableName), Ret2 = mnesia:clear_table(PerFea), case Ret2 of {atomic, ok} -> tableType:del_TableTypeInfo(TableName), sys_o_tables:del_SysTabInfo(TableName), mnesia:delete_table(TableName), mnesia:delete_table(PerFea); %% #todo send message _ -> io:format("") end; _ -> Ret2 = {aborted, notok}, io:format("") end, PerRet = [Ret | [Ret2]]; TableType == 'car' -> tableType:del_TableTypeInfo(TableName), sys_o_tables:del_SysTabInfo(TableName), mnesia:delete_table(TableName), PerRet = [Ret]; true -> PerRet = [{aborted, {'tableType_error', TableType}}], tableType:del_TableTypeInfo(TableName), sys_o_tables:del_SysTabInfo(TableName), io:format("Error ~p ~n", [TableType]) end, %% tableType:add_tableType(element(2, Tup), BwType), io:format("PerRet ~p ~n", [PerRet]), PerRet. findAllDatabase() -> sys_o_tables:sysTabformat2Mat(sys_o_tables:findAllSysTableInfo('sys_o_tables')). findAllTypeInfo() -> tableType:tableTypeformat2Mat(tableType:findAllTableTypeInfo('tableType')). %% 插入人 %% TableName, ID, PersonName, Age, Sex, IdCard, PhoneNum %% TableName, Feature addPersonData(TableName, PersonName, Age, Sex, IdCard, PhoneNum, Img, UUID, Feature) -> if UUID == '' -> io:format("UUID is ~p ~n", [UUID]), ID = syncTool:getUUIDStr(); true -> ID = UUID end, PerFea = addFea2TableName(TableName), Uid = person_info_feature:add_personFea(ID, PerFea, Feature, Img, IdCard), if Uid == '' -> Ret = {aborted, {add_error, Feature}}; true -> Ret = person_info:add_personInfo(TableName, Uid, PersonName, Age, Sex, IdCard, PhoneNum) % case Ret of % '' -> % ok; % _ -> % syncTool:rpcSendMessToCNode(mnesia:system_info(running_db_nodes), {call, 'bar', 65}) % end end, io:format("Ret ~p ~n", [Ret]), Ret. %% 删除人 %% TableName, UUID deletePersonData(TableName, UUID) -> PerFea = addFea2TableName(TableName), DelRet = person_info_feature:del_personFea(PerFea, UUID), if DelRet == {atomic, ok} -> Ret = [person_info:del_personInfo(TableName, UUID)]; true -> Ret = {aborted, {del_error, {TableName, UUID}}} end, io:format("Ret ~p ~n", [Ret]), Ret. findSinglePersonInfo(TableName, UUID) -> person_info:personInfoFormat2Mat(person_info:findPersonInfo(TableName, UUID)). testFunc(PersonId, []) -> []; testFunc(PersonId, [TN | T]) -> io:format("table is ~p ", [TN]), TableName = element(1, TN), Records = person_info:findPersonInfo(TableName, PersonId), case Records of [] -> TemMaps = #{"tableName"=>TableName, "Uuid"=>"null"}; _ -> [TRco | TRecords] = Records, io:format("TRco is ~p ", [TRco]), TemMaps = #{"tableName"=>TableName, "Uuid"=>element(1, TRco)} end, [maps:to_list(TemMaps) | testFunc(PersonId, T)]. %% 判断集群内某人是否存在 singlePersonIsExists(PersonId) -> TableLists = sys_o_tables:findAllSysTableInfo('sys_o_tables'), testFunc(PersonId, TableLists). testFunc2(NewPerId, OldId, Idcard, PerPicUrl, []) -> []; testFunc2(NewPerId, OldId, Idcard, PerPicUrl, [TableRec | T]) -> io:format("table is ~p ~n", [TableRec]), TableName = element(1, TableRec), NewRecords = person_info:findPersonInfo(TableName, NewPerId), case NewRecords of [] -> io:format("~p have no newId ~p will search oldId ~n", [TableName, NewPerId]), OldRecords = person_info:findPersonInfo(TableName, OldId), case OldRecords of [] -> io:format("~p have no oldId ~p ~n", [TableName, OldId]), ResRetMaps = #{"tableName"=>TableName, "result"=>"notexist"}, %% no action ok; _ -> io:format("~p have oldId ~p will update record~n", [TableName, OldId]), %% update oldRecord Ret = {}, case Ret of [] -> %% ok? ResRetMaps = #{"tableName"=>TableName, "result"=>"true"}, ok; _ -> %% not ok ResRetMaps = #{"tableName"=>TableName, "result"=>"false"}, ok end, ok end; _ -> io:format("~p have newId ~p will update newId ~n", [TableName, NewPerId]), %% update newRecord OldRecords = person_info:findPersonInfo(TableName, OldId), case OldRecords of [] -> %% no action io:format("~p have no oldId ~p ~n", [TableName, OldId]), ok; _ -> %% delete oldRecord io:format("~p have oldId ~p will delete record~n", [TableName, OldId]), deletePersonData(TableName, OldId), ok end, ResRetMaps = #{"tableName"=>TableName, "result"=>"true"}, ok end, [maps:to_list(ResRetMaps) | testFunc2(NewPerId, OldId, Idcard, PerPicUrl, T)]. singlePersonUpdate(NewPerId, OldId, Idcard, PerPicUrl) -> TableLists = sys_o_tables:findAllSysTableInfo('sys_o_tables'), testFunc2(NewPerId, OldId, Idcard, PerPicUrl, TableLists). %% 插入车 addCarData() -> ok. %% 加载人脸数据库 loadFaceFeaData(TableName) -> PerFea = addFea2TableName(TableName), Results = person_info_feature:findAllPersonFea(PerFea), person_info_feature:personFeaFormat2Mat(Results). %% 加载人脸数据库2 no feature loadFaceFeaData2(TableName) -> PerFea = addFea2TableName(TableName), Results = person_info_feature:findAllPersonFea(PerFea), person_info_feature:personNoFeaFormat2Mat(Results).