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);
|
}
|
}
|