%%%-------------------------------------------------------------------
%%% @author pansen
%%% @copyright (C) 2018, <COMPANY>
%%% @doc
%%%
%%% @end
%%% Created : 01. 八月 2018 16:01
%%%-------------------------------------------------------------------
-module(syncDB).
-author("pansen").
-compile(export_all).
%%-include("DbTool.hrl").
-include("nodeTool.hrl").

test() ->
  io:format("start test 12333 ~n"),
  mnesia:start(),
  lager:start(),
  ok.
test1() ->
  syncDB_sqlite3:test1(),
  syncDB_sqlite3:createDatabase(person, tt123666, '1', '1', '2018-01-01 01:02:00', '2018-12-31 01:02:00').
test2() ->
  syncDB_sqlite3:test1(),
  UUid = syncTool:getUUIDString(),
  sys_o_tables_esql:add_sys_table(UUid, " ", UUid,
    " ", person, '0096ee77-1f50-48e2-a08a-42536a754970@192.168.1.124', "2018-01-01 01:02:00", "2018-12-31 01:02:00"),
  sys_o_tables_esql:add_sys_table(syncTool:getUUIDString(), " ", syncTool:getUUIDString(), " ", person, '0096ee77-1f50-48e2-a08a-42536a754970@192.168.1.124', "2018-01-01 01:02:00", "2018-12-31 01:02:00").

bitStrToStr2([]) -> [];
bitStrToStr2([Value | T]) ->
  Val = binary:bin_to_list(Value),
  [Val | bitStrToStr2(T)].
test3() ->
%%  syncDB_sqlite3:test1(),
  %% Test that when the row-names are added..
  ok.



setCNode(CNode) ->
  Ret = mochiglobal:put('cNodeName', CNode),
  case Ret of
    ok ->
      Res = [{atomic, ok}];
    _ ->
      Res = [{aborted, notok}]
  end,
  Res.

sendMessage() ->
  syncDB_sqlite3:sendMessage().

testCreateCluster() ->
	syncDB:startNode('xuxiuxilaptop@192.168.1.159', ' ', 'xuxiuxilaptop', '1', 'jq').
	
testJoinCluster() ->
	syncDB:startNode('xuxiuxilaptop1@192.168.1.159', 'xuxiuxilaptop@192.168.1.159', 'xuxiuxilaptop1', '1', 'jq').
  
%%
%%  启动节点并自动连接到集群
%%  新节点自动进行初始化
%%
startNode(NodeName, FatherNodeName, DeviceId, ClusterId, ClusterName) ->
%%  configToBeam:config_to_beam(),
  syncDB_sqlite3:startNode(NodeName, FatherNodeName, DeviceId, ClusterId, ClusterName).

modifyCluName(CluId, CluName) ->
  syncDB_sqlite3:modifyCluName(CluId, CluName).

removeNode() ->
  syncDB_sqlite3:removeNode().

findAllNode() ->
  syncDB_sqlite3:findAllNode().


%%  创建底库
%% 创建底库 表类型，表名，同步状态，黑白名单
createDatabase(TableType, TableName, SyncType, BwType, StartTime, EndTime) ->
  syncDB_sqlite3:createDatabase(TableType, TableName, SyncType, BwType, StartTime, EndTime).

%%  c底库
%% 创建底库 表类型，表名，同步状态，黑白名单
updateDatabase(Uuid, TableType, TableName, SyncType, BwType, StartTime, EndTime) ->
  syncDB_sqlite3:updateDatabase(Uuid, TableType, TableName, SyncType, BwType, StartTime, EndTime).


%% shanchu底库
%% shanchu底库 表类型，表名
deleteDatabase(TableType, TableName) ->
  syncDB_sqlite3:deleteDatabase(TableType, TableName).

findAllDatabase() ->
  syncDB_sqlite3:findAllDatabase().

findAllTypeInfo() ->
  todo.


%%  插入人
%%  TableName, ID, PersonName, Age, Sex, IdCard, PhoneNum
%%  TableName, Feature
addPersonData(TableName, PersonName, Age, Sex, IdCard, PhoneNum, Img, UUID, Feature) ->
  syncDB_sqlite3:addPersonData(TableName, PersonName, Age, Sex, IdCard, PhoneNum, Img, UUID, Feature).

addPersonDatas(TableUuid, PersonLists) ->
  syncDB_sqlite3:addPersonDatas(TableUuid, PersonLists).

%%  删除人
%%  TableName, UUID
deletePersonData(TableName, UUID) ->
  syncDB_sqlite3:delPersonData(TableName, UUID).


%%  插入车
addCarData() ->
  ok.

%%  加载人脸数据库
loadFaceFeaData(TableName) ->
  syncDB_sqlite3:loadFaceFeaData(TableName).

%%  加载人脸数据库2 no feature
loadFaceFeaData2(TableName) ->
  syncDB_sqlite3:loadFaceFeaData2(TableName).

singlePersonIsExists(PersonId) ->
  syncDB_sqlite3:singlePersonIsExists(PersonId).

singlePersonUpdate(NewPerId, OldId, Idcard, PerPicUrl, PerFea) ->
  syncDB_sqlite3:singlePersonUpdate(NewPerId, OldId, Idcard, PerPicUrl, PerFea).