package com.bcxin.backend.tasks;

import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.Statement;

@Component
public class TmpSyncDataJobTask  extends TaskAbstract{
    private final DataSource dataSource;
    private final String UPDATE_SQL="update obpm2.tenant_users c, obpm2.t_user d\n" +
            "set \n" +
            "authenticated_status =(case d.Field21 when '已认证' then 3 when '认证失败' then 2 else 0 end),\n" +
            "authenticated_result =d.Field23\n" +
            "where c.id =d.id ";

    public TmpSyncDataJobTask(@Qualifier("baoanDataSource") DataSource dataSource) {
        this.dataSource = dataSource;
    }


    @Override
    protected void runCore() {
    }

    @Override
    public String getTaskName() {
        return "sync.temp.obpm2baibaodunflow";
    }
}