package com.basic.security.manager;

import com.basic.security.base.BaseApplication;
import com.basic.security.model.ModelAdapter;
import com.basic.security.model.Person;
import com.basic.security.model.PersonA;
import com.basic.security.utils.Constants;
import com.basic.security.utils.SqlSplit;

import java.util.List;

public class PersonAManager extends BaseManager {
    public static void savePersonAFromPerson(ModelAdapter person) {
        BaseApplication.getApplication().executorService.execute(() -> {
            try {
                ModelAdapter personA = new ModelAdapter();
                personA.setString(PersonA.createBy, DeviceManager.getDeviceId());
                personA.setString(PersonA.faceFeature, person.getString(Person.camera_image_feature));
                personA.setString(PersonA.id, person.getString(Person.id));
                personA.setString(PersonA.personPicUrl, "");
                personA.setString(PersonA.idCard, person.getString(Person.id_card_number));
                personA.setString(PersonA.age, "0"); // ？默认值
                personA.setString(PersonA.personName, person.getString(Person.name));
                personA.setString(PersonA.phoneNum, person.getString(Person.phone));
                personA.setString(PersonA.createTime, ""); //?格式
                personA.setString(PersonA.enable, "1"); // ？默认值
                personA.setString(PersonA.isDelete, "0"); // ？默认值
                personA.setString(PersonA.monitorLevel, ""); // ？默认值
                personA.setString(PersonA.picDesc, "");
                personA.setString(PersonA.reserved, "");
                personA.setString(PersonA.sex, ""); // ？取值
                personA.setString(PersonA.tableId, ""); // ？默认值
                personA.setString(Constants.TABLE, PersonA.tableName); // ？默认值
                personA.setString(PersonA.updateTime, ""); //?格式
                if (PersonCameraImagePathManager.uploadCameraImagePath(personA, person)) {
                    //PersonManager.save(person);
                }
                save(personA);
            } catch (Exception e) {
                e.printStackTrace();
            }
        });

    }

    public static void afterExecutedSql(String sql) {
        try {
            if (sql.toLowerCase().contains(PersonA.tableName.toLowerCase())) {
                if (sql.toLowerCase().trim().contains("insert")) {
                    onAfterInsertPersonA(sql);
                } else if (sql.toLowerCase().trim().contains("delete")) {
                    onAfterDeletePersonA(sql);
                } else if (sql.toLowerCase().trim().contains("update")) {
                    onAfterUpdatePersonA(sql);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void onAfterInsertPersonA(String sql) {
        try {
            String id = SqlSplit.insertToMap(sql).get(PersonA.id);
            ModelAdapter personA = findById(PersonA.tableName, id);
            if (personA != null) {
                PersonManager.insertPersonFromPersonA(personA);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void onAfterUpdatePersonA(String sql) {
        try {
            String id = SqlSplit.updateToMap(sql).get(PersonA.id);
            ModelAdapter personA = findById(PersonA.tableName, id);
            PersonManager.updatePersonFromPersonA(personA);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void onAfterDeletePersonA(String sql) {
        try {
            String id = SqlSplit.deleteToMap(sql).get(PersonA.id);
            ModelAdapter personA = findById(PersonA.tableName, id);
            PersonManager.deletePersonFromPersonA(personA);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static List<ModelAdapter> findPersonAListByPersonATypeId(String personATypeId) {
        return findList("select * from " + PersonA.tableName + " where " + PersonA.tableId + "='" + personATypeId + "'");
    }

    public static ModelAdapter findPersonAById(String personAId) {
        return findById(PersonA.tableName, personAId);
    }

    public static void savePersonA(ModelAdapter personA) {
        personA.setString(Constants.TABLE, PersonA.tableName);
        save(personA);
    }

    public static void deletePersonAByPerson(ModelAdapter person) {
        if (person != null) {
            String personId = person.getString(Person.id);
            ModelAdapter personA = findById(PersonA.tableName, personId);
            if (personA != null) {
                personA.setString(PersonA.isDelete, "1");
                savePersonA(personA);
            }
        }
    }

    public static List<ModelAdapter> findPersonAList(String sql) {
        return findList(sql);
    }
}