%%%-------------------------------------------------------------------
%%% @author ps
%%% @copyright (C) 2018, <COMPANY>
%%% @doc
%%%
%%% @end
%%% Created : 06. Dec 2018 上午12:34
%%%-------------------------------------------------------------------
-module(person_info_esql).
-author("ps").

%% API
-export([create_personInfo/2, add_personInfo/7, del_personInfo/2, upd_personInfo/7]).
-export([findAllpersonInfoNotFea/1]).
%%-export([findAllpersonInfo/1, personInfoFormat2Mat/1, findPersonInfo/2]).
-export([findPersonInfo/2]).

-include("esqltool.hrl").


create_personInfo(Nodes, TabName) ->
  StrTableName = syncTool:change2Str(TabName),
  io:format("TableName is ~p", [StrTableName]),
  Sql = ["CREATE TABLE '", StrTableName, "' (
                           uuid        varchar(255) PRIMARY KEY,
                           personName  varchar(255) DEFAULT NULL,
                           age         varchar(255) DEFAULT NULL,
                           sex         varchar(255) DEFAULT NULL,
                           idCard      varchar(255) DEFAULT NULL,
                           phoneNum    varchar(255) DEFAULT NULL,
                           create_time BLOB         DEFAULT (datetime('now', 'localtime')),
                           update_time DATETIME     DEFAULT NULL,
                           create_by   varchar(255) DEFAULT NULL,
                           del_flag    INTEGER      DEFAULT 0
                           );"],
  executeSqlLocalyAndSaveToCacheAndSendSql(Sql),
  {StrTableName, TabName}.


add_personInfo(TableName, Uuid, PersonName, Age, Sex, IdCard, PhoneNum) ->
  io:format("TableName ~p, ~n", [TableName]),
  CreateUser = node(),
  if
    Uuid == " " ->
      ID = syncTool:getUUIDString();
    Uuid == "" ->
      ID = syncTool:getUUIDString();
    true ->
      ID = Uuid
  end,
  UpdateTime = syncTool:getTimeStr(),
  CreateUser = node(),
  StrUuid = syncTool:change2Str(ID),
  StrTableName = syncTool:change2Str(TableName),
  StrPersonName = syncTool:change2Str(PersonName),
  StrAge = syncTool:change2Str(Age),
  StrSex = syncTool:change2Str(Sex),
  StrIdCard = syncTool:change2Str(IdCard),
  StrPhoneNum = syncTool:change2Str(PhoneNum),
  StrCreateUser = syncTool:change2Str(CreateUser),

  Sql = ["delete from '", StrTableName, "' where uuid ='", StrUuid, "';", "INSERT INTO '", StrTableName, "' (uuid, personName, age, sex, idCard, phoneNum,
       update_time, create_by) VALUES ('", StrUuid, "', '", StrPersonName, "', '", StrAge, "', '",
    StrSex, "', '", StrIdCard, "', '", StrPhoneNum, "', '", UpdateTime, "', '", StrCreateUser,
    "');"],
  Ret = executeSqlLocalyAndSaveToCacheAndSendSql(Sql),
  io:format("add_personFea ~p~n", [Ret]),
  if
    Ret == {atomic, ok} ->
      Result = ID;
    true ->
      Result = ''
  end,
  Result.

del_personInfo(TableName, Uuid) ->
  UpdateTime = syncTool:getTimeStr(),
  StrUuid = syncTool:change2Str(Uuid),
  StrTableName = syncTool:change2Str(TableName),
  Sql = ["UPDATE '", StrTableName, "' SET del_flag = '1',
                          update_time = '", UpdateTime, "' where Uuid = '", StrUuid, "';"],

  Ret = executeSqlLocalyAndSaveToCacheAndSendSql(Sql),
  io:format("del_personFea ~p~n", [Ret]),
  if
    Ret == {atomic, ok} ->
      Result = {atomic, ok};
    true ->
      Result = {}
  end,
  Result.

findAllpersonInfoNotFea(TableName) ->
  StrTableName = syncTool:change2Str(TableName),
  Sql = ["Select b.uuid as id,b.faceUrl as img,a.idCard as idcard
                     from '", StrTableName, "' as a,
                     '", StrTableName, "_fea' As b
                     where a.uuid = b.uuid and ( a.del_flag=0 AND b.del_flag=0);"],
  Maps = selectSomeInfoWithSql(Sql),
  if
    is_list(Maps) ->
      Res = Maps;
    is_tuple(Maps) ->
      Res = [];
    true ->
      Res = []
  end,
  Res.

findPersonInfo(TableName, PersonId) ->
  StrTableName = syncTool:change2Str(TableName),
  StrPersonId = syncTool:change2Str(PersonId),
  Sql = ["Select * from '", StrTableName, "'
                     where uuid = '", StrPersonId, "' AND del_flag=0;"],
  Maps = selectSomeInfoWithSql(Sql),
  if
    is_list(Maps) ->
      Res = Maps;
    is_tuple(Maps) ->
      Res = [];
    true ->
      Res = []
  end,
  Res.

upd_personInfo(TableName, Uuid, PersonName, Age, Sex, IdCard, PhoneNum) ->
  UpdateTime = syncTool:getTimeStr(),
  StrUuid = syncTool:change2Str(Uuid),
  StrTableName = syncTool:change2Str(TableName),
  StrPersonName = syncTool:change2Str(PersonName),
  StrAge = syncTool:change2Str(Age),
  StrSex = syncTool:change2Str(Sex),
  StrIdCard = syncTool:change2Str(IdCard),
  StrPhoneNum = syncTool:change2Str(PhoneNum),

  Sql = ["UPDATE '", StrTableName, "' SET idCard = '", StrIdCard, "',update_time = '",
    UpdateTime, "',del_flag = '0'  where Uuid = '", StrUuid, "';"],
  Ret = executeSqlLocalyAndSaveToCacheAndSendSql(Sql),
  if
    Ret == {atomic, ok} ->
      Result = Uuid;
    true ->
      Result = ''
  end,
  Result.