package com.common.core.domain;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.annotation.JSONType;
import com.common.core.exception.BizException;
import com.common.core.utils.DateUtils;
import com.common.security.utils.SecurityUtils;
import com.jfinal.plugin.activerecord.TableMapping;
import lombok.extern.slf4j.Slf4j;
import java.lang.reflect.Field;
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

/**
 * @author 廖振钦
 * @date 2022-01-29
 */
@Slf4j
@JSONType(ignores = {"tableName","id","isDelete","updateTime","createTime","createBy","updateBy"})
public abstract class EntityModel<M extends EntityModel> extends BaseModel<M> {

    @Override
    public boolean save(){
        Field[] fields = getClass().getDeclaredFields();
        for(Field f : fields){
            f.setAccessible(true);
            try {
                Object o = f.get(this);
                if(null != o) {
                    if (RecordAttrHas(humpToLine2(f.getName()))) {
                        set(humpToLine2(f.getName()), f.get(this));
                    } else if (RecordAttrHas(f.getName())) {
                        set(f.getName(), f.get(this));
                    }
                }
            } catch (IllegalAccessException e) {

            }
        }
        String appid = SecurityUtils.byId();
        setIsDelete(0);
        setCreateTime(DateUtils.now());
        setUpdateTime(DateUtils.now());
        setCreateBy(appid);
        setUpdateBy(appid);
        return super.save();
    }

    @Override
    public boolean update(){
        Field[] fields = getClass().getDeclaredFields();
        for(Field f : fields){
            f.setAccessible(true);
            if(!"id".equals(f.getName())) {
                try {
                    Object o = f.get(this);
                    if(null != o) {
                        if (RecordAttrHas(humpToLine2(f.getName()))) {
                            set(humpToLine2(f.getName()), f.get(this));
                        } else if (RecordAttrHas(f.getName())) {
                            set(f.getName(), f.get(this));
                        }
                    }
                } catch (IllegalAccessException e) {
                    log.error(e.getMessage(), e);
                }
            }
        }
        String appid = SecurityUtils.byId();
        setIsDelete(0);
        setCreateTime(DateUtils.now());
        setUpdateTime(DateUtils.now());
        setCreateBy(appid);
        setUpdateBy(appid);
        return super.update();
    }

    @Override
    public boolean saveOrUpdate(){
        if(null == getId()){
            return this.save();
        } else{
            return this.update();
        }
    }

    @Override
    public M findFirst(String sql){
        M m  = super.findFirst(sql);
        if(null == m){
            return null;
        }
        RelectionField(m);
        return m;
    }

    @Override
    public M findFirst(String sql,Object...params){
        M m  = super.findFirst(sql, params);
        if(null == m){
            return null;
        }
        RelectionField(m);
        return m;
    }

    @Override
    public M findById(Object id){
        return this.findFirst("select * from "+getTableName()+" where id = ? and is_delete='0'",id);
    }

    @Override
    public List<M> findAll(){
        List<M> list = super.findAll();
        List<M> returnlist = new ArrayList<M>();
        for(M m : list){
            RelectionField(m);
            returnlist.add(m);
        }
        return returnlist;
    }

    @Override
    public List<M> find(String sql){
        List<M> list  = super.find(sql);
        List<M> returnlist = Collections.emptyList();
        for(M m : list){
            RelectionField(m);
            returnlist.add(m);
        }
        return returnlist;
    }

    @Override
    public List<M> find(String sql,Object...params){
        List<M> list  = super.find(sql, params);
        List<M> returnlist = new ArrayList<M>();
        for(M m : list){
            RelectionField(m);
            returnlist.add(m);
        }
        return returnlist;
    }

    private void RelectionField(M m){
        Field[] fields = m.getClass().getDeclaredFields();
        for(Field f : fields) {
            f.setAccessible(true);
            try {
                if(RecordAttrHas(humpToLine2(f.getName()))){
                    f.set(m, m.get(humpToLine2(f.getName())));
                }else if(RecordAttrHas(f.getName())){
                    f.set(m, m.get(f.getName()));
                }
            } catch (IllegalAccessException e) {

            }
        }
    }




    private String humpToLine2(String str) {
        Pattern humpPattern = Pattern.compile("[A-Z]");
        Matcher matcher = humpPattern.matcher(str);
        StringBuffer sb = new StringBuffer();
        while (matcher.find()) {
            matcher.appendReplacement(sb, "_" + matcher.group(0).toLowerCase());
        }
        matcher.appendTail(sb);
        return sb.toString();

    }

    private String lineToHump(String str) {
        Pattern linePattern = Pattern.compile("_(\\w)");
        str = str.toLowerCase();
        Matcher matcher = linePattern.matcher(str);
        StringBuffer sb = new StringBuffer();
        while (matcher.find()) {
            matcher.appendReplacement(sb, matcher.group(1).toUpperCase());
        }
        matcher.appendTail(sb);
        return sb.toString();
    }

    private Boolean RecordAttrHas(String columnName){
        Set<String> names = TableMapping.me().getTable(this.getClass()).getColumnNameSet();
        if(names.contains(columnName)){
            return true;
        }
        return false;
    }

    public String json(){
        return JSONObject.toJSONString(this);
    }

    public JSONObject jsonObject(){
        return JSONObject.parseObject(json());
    }

}