package com.chinacreator.videoalliance.order.dao;

import com.chinacreator.videoalliance.common.util.DataSource;
import com.chinacreator.videoalliance.order.bean.BackBusiOrderRec;
import com.frameworkset.common.poolman.SQLExecutor;

import org.springframework.stereotype.Component;

import java.sql.SQLException;

/**
 * 铂源数据推送
 */
@Component
public class BoYuanSyncDao {

    public boolean isBoYuanSync(String cpid,String spid) throws SQLException {
        String sql="SELECT count(1)  FROM TB_BAOYUAN_SYNC_CONF  WHERE CPID= ? and spid= ? and status='0'";
        return  Integer.parseInt(SQLExecutor.queryFieldWithDBName(DataSource.NET3G, sql,cpid, spid))>0;
    }


    public void insertBackSync(BackBusiOrderRec backBusiOrderRec) throws SQLException {
      String sql="INSERT INTO  TD_BAOYUAN_SYNC_ORDER(ID,USERID,CPID,SPID,TYPE,STATUS) " +
                  "VALUES(#[id],#[userid],#[cpid],#[spid],#[type],'1')";
      SQLExecutor.insertBean(DataSource.NET3G,sql,backBusiOrderRec);
    }
}