package com.product.data.entity;

import com.product.common.lang.StringUtils;
import com.product.core.entity.FieldSetEntity;
import com.product.data.config.CmnConst;

import java.util.Date;

/**
 * @Author cheng
 * @Date 2022/2/11 9:38
 * @Desc 执行记录
 */
public class SyncExecuteRecordEntity {
    /**
     * 同步任务uuid
     */
    private String syncTaskUuid;
    /**
     * 同步类型
     */
    private int syncType;
    /**
     * 开始索引位置
     */
    private int startPosition = -1;
    /**
     * 结束索引位置
     */
    private int endPosition = -1;
    /**
     * 增量数量
     */
    private int increaseNumber = 0;
    /**
     * 更新数量
     */
    private int updateNumber = 0;
    /**
     * 错误数量
     */
    private int errorNumber = 0;
    /**
     * 错误信息
     */
    private StringBuilder errorInfo;
    /**
     * 执行完成时间 （来源数据库系统时间戳）
     */
    private Object finishSourceTime;


    private FieldSetEntity logRecord;
    /**
     * 插入查询条件（增量）
     * 用于更新完成后使用
     */
    private String insertQueryFilter;
    /**
     * 更新查询条件（增量）
     * 用于更新完成后使用
     */
    private String updateQueryFilter;


    public SyncExecuteRecordEntity(String syncTaskUuid, int syncType) {
        this.syncTaskUuid = syncTaskUuid;
        this.syncType = syncType;

    }

    public String getRecordUuid() {
        return this.logRecord != null ? this.logRecord.getUUID() : null;
    }

    public SyncExecuteRecordEntity(FieldSetEntity fse) {
        this.logRecord = fse;
        this.syncTaskUuid = fse.getString("sync_task_uuid");
        this.syncType = fse.getInteger("sync_type");
        this.startPosition = fse.getInteger("start_position");
        this.endPosition = fse.getInteger("end_position");
        this.increaseNumber = fse.getInteger("increase_number");
        this.updateNumber = fse.getInteger("update_number");
        this.errorNumber = fse.getInteger("error_number");
        Date finish_source_time = fse.getDate("finish_source_time");
        if (finish_source_time != null) {
            this.finishSourceTime = fse.getObject("finish_source_time");
        }
        String error_info = fse.getString("error_info");
        if (!StringUtils.isEmpty(error_info)) {
            this.errorInfo = new StringBuilder(error_info);
        }

    }

    public String getInsertQueryFilter() {
        return insertQueryFilter;
    }

    public void setInsertQueryFilter(String insertQueryFilter) {
        this.insertQueryFilter = insertQueryFilter;
    }

    public String getUpdateQueryFilter() {
        return updateQueryFilter;
    }

    public void setUpdateQueryFilter(String updateQueryFilter) {
        this.updateQueryFilter = updateQueryFilter;
    }

    public void setStartPosition(int startPosition) {
        this.startPosition = startPosition;
        if (startPosition >= endPosition && endPosition != -1) {
            this.startPosition = endPosition;
        }
        if (logRecord != null) {
            this.logRecord.setValue("start_position", this.startPosition);
        }
    }

    public void setEndPosition(int endPosition) {
        this.endPosition = endPosition;
        if (startPosition >= endPosition) {
            startPosition = endPosition;
        }
        if (logRecord != null) {
            this.logRecord.setValue("end_position", this.endPosition);
        }
    }

    public FieldSetEntity getRecord(int endPosition, Long finishSourceTime) {
        this.endPosition = endPosition;
        if (startPosition >= endPosition) {
            startPosition = endPosition;
        }
        this.finishSourceTime = finishSourceTime;
        if (this.logRecord == null) {
            this.logRecord = new FieldSetEntity();
            this.logRecord.setTableName(CmnConst.TABLE_SYNC_MANAGER_LOG);
            this.logRecord.setValue(CmnConst.CREATED_BY, 1);
            this.logRecord.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
            this.logRecord.setValue(CmnConst.ORG_LEVEL_UUID, "/");
        } else {
            this.logRecord.setValue(CmnConst.UPDATED_BY, 1);
            this.logRecord.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
        }
        this.logRecord.setValue("sync_task_uuid", this.syncTaskUuid);
        this.logRecord.setValue("sync_type", this.syncType);
        this.logRecord.setValue("start_position", this.startPosition);
        this.logRecord.setValue("end_position", this.endPosition);
        this.logRecord.setValue("increase_number", this.increaseNumber);
        this.logRecord.setValue("update_number", this.updateNumber);
        this.logRecord.setValue("error_number", this.errorNumber);
        this.logRecord.setValue("error_info", this.errorInfo != null ? this.errorInfo.toString() : null);
        this.logRecord.setValue("finish_source_time", this.finishSourceTime);
        return this.logRecord;
    }

    public void addIncreaseNumber(int number) {
        this.increaseNumber += number;
        if (logRecord != null) {
            this.logRecord.setValue("increase_number", this.increaseNumber);
        }
    }

    public void addErrorNumber(int number) {
        this.errorNumber += number;
        if (logRecord != null) {
            this.logRecord.setValue("error_number", this.errorNumber);
        }
    }

    public void addUpdateNumber(int number) {
        this.updateNumber += number;
        if (logRecord != null) {
            this.logRecord.setValue("update_number", this.updateNumber);
        }
    }

    public void addErrorInfo(String errorMsg) {
        if (this.errorInfo == null) {
            errorInfo = new StringBuilder();
        }
        if (errorMsg.length() > 0) {
            errorInfo.append("\n");
        }
        errorInfo.append(errorMsg);
        if (logRecord != null) {
            this.logRecord.setValue("error_info", this.errorInfo != null ? this.errorInfo.toString() : null);
        }

    }

    public String getSyncTaskUuid() {
        return syncTaskUuid;
    }

    public int getSyncType() {
        return syncType;
    }

    public int getStartPosition() {
        return startPosition;
    }

    public int getEndPosition() {
        return endPosition;
    }

    public int getIncreaseNumber() {
        return increaseNumber;
    }

    public int getUpdateNumber() {
        return updateNumber;
    }

    public int getErrorNumber() {
        return errorNumber;
    }

    public StringBuilder getErrorInfo() {
        return errorInfo;
    }

    public Object getFinishSourceTime() {
        return finishSourceTime;
    }

    public FieldSetEntity getLogRecord() {
        return logRecord;
    }
}