import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
private static Timestamp getLastExportTimestamp(SQLProcessor sqlproc) throws GenericDataSourceException, GenericEntityException, SQLException {
    if (sqlproc == null) {
        throw new IllegalArgumentException();
    }
    Timestamp lastTimestamp = null;
    String qStr = "SELECT last_successful_synch_time FROM ENTITY_SYNC WHERE  entity_sync_id = 'exportContactsToCrm2'";
    sqlproc.prepareStatement(qStr);
    ResultSet result = sqlproc.executeQuery();

    if (result != null && result.next()) {
        lastTimestamp = result.getTimestamp("last_successful_synch_time");

        result.close();
    }

    return lastTimestamp;
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
/**
 * Commit all modifications
 *
 * @throws GenericDataSourceException
 */
public void commit() throws GenericDataSourceException {
    if (_connection == null) {
        return;
    }

    if (Debug.verboseOn()) Debug.logVerbose("SQLProcessor:commit() _manualTX=" + _manualTX, module);

    if (_manualTX) {
        try {
            _connection.commit();
            if (Debug.verboseOn()) Debug.logVerbose("SQLProcessor:commit() : called commit on connection", module);
        } catch (SQLException sqle) {
            Debug.logError(sqle, "Error committing transaction: " + sqle.toString());
            try {
                rollback();
            } catch (GenericDataSourceException rbsqle) {
                Debug.logError(rbsqle, "Got another error when trying to rollback after error committing transaction: " + sqle.toString());
            }
            throw new GenericDataSourceException("SQL Exception occurred on commit", sqle);
        }
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
/**
 * Rollback all modifications
 */
public void rollback() throws GenericDataSourceException {
    if (_connection == null) {
        return;
    }

    if (Debug.verboseOn()) Debug.logVerbose("SQLProcessor:rollback() _manualTX=" + _manualTX, module);

    try {
        if (_manualTX) {
            _connection.rollback();
            if (Debug.verboseOn()) Debug.logVerbose("SQLProcessor:rollback() : _manualTX=" + _manualTX, module);
        } else {
            try {
                TransactionUtil.setRollbackOnly("rollback called in Entity Engine SQLProcessor", new Exception("Current Location Stack"));
                if (Debug.verboseOn()) Debug.logVerbose("SQLProcessor:rollback() : _manualTX=" + _manualTX, module);
            } catch (GenericTransactionException e) {
                Debug.logError(e, "Error setting rollback only", module);
                throw new GenericDataSourceException("Error setting rollback only", e);
            }
        }
    } catch (SQLException sqle2) {
        Debug.logWarning("[SQLProcessor.rollback]: SQL Exception while rolling back insert. Error was:" + sqle2, module);
        Debug.logWarning(sqle2, module);
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
private static ResultSet getContactUserLoginSet(SQLProcessor sqlproc, Timestamp lastTimestamp, Timestamp now, String partyId) throws GenericDataSourceException, GenericEntityException, SQLException {
    if (sqlproc == null || lastTimestamp == null || now == null || partyId == null) {
        throw new IllegalArgumentException();
    }
    ResultSet result = null;

    StringBuilder qStr =  new StringBuilder("SELECT UL.user_login_id, UL.party_id, UL.current_password, UL.password_hint, UL.enabled, ULSG.group_id, SGP.permission_id FROM USER_LOGIN UL ")
         .append("JOIN USER_LOGIN_SECURITY_GROUP ULSG ON ULSG.user_login_id = UL.user_login_id ")
         .append("JOIN SECURITY_GROUP_PERMISSION SGP ON SGP.group_id = ULSG.group_id ")
         .append("WHERE UL.party_id = ? ")
         .append("AND (UL.enabled = 'Y' OR UL.enabled is null) ")
         .append("AND SGP.permission_id in ('FINANCIALS_ADMIN', 'FINANCIALS_VIEW', 'CRMSFA_VIEW') ")
         .append("AND ULSG.created_stamp >= ? ")
         .append("AND (ULSG.from_date <= ? AND (ULSG.thru_date >= ? OR ULSG.thru_date is null)) ");

    sqlproc.prepareStatement(qStr.toString());
    sqlproc.setValue(partyId);
    sqlproc.setValue(lastTimestamp);
    sqlproc.setValue(now);
    sqlproc.setValue(now);

    result = sqlproc.executeQuery();

    return result;
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
public int updateByCondition(Delegator delegator, ModelEntity modelEntity, Map<String, ? extends Object> fieldsToSet, EntityCondition condition) throws GenericEntityException {
    SQLProcessor sqlP = new SQLProcessor(delegator, helperInfo);

    try {
        return updateByCondition(modelEntity, fieldsToSet, condition, sqlP);
    } catch (GenericDataSourceException e) {
        sqlP.rollback();
        throw new GenericDataSourceException("Generic Entity Exception occurred in updateByCondition", e);
    } finally {
        sqlP.close();
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
public int delete(GenericEntity entity) throws GenericEntityException {
    SQLProcessor sqlP = new SQLProcessor(entity.getDelegator(), helperInfo);

    try {
        return delete(entity, sqlP);
    } catch (GenericDataSourceException e) {
        sqlP.rollback();
        throw new GenericDataSourceException("Exception while deleting the following entity: " + entity.toString(), e);
    } finally {
        sqlP.close();
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
public int deleteByCondition(Delegator delegator, ModelEntity modelEntity, EntityCondition condition) throws GenericEntityException {
    SQLProcessor sqlP = new SQLProcessor(delegator, helperInfo);

    try {
        return deleteByCondition(modelEntity, condition, sqlP);
    } catch (GenericDataSourceException e) {
        sqlP.rollback();
        throw new GenericDataSourceException("Generic Entity Exception occurred in deleteByCondition", e);
    } finally {
        sqlP.close();
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
/**
 * Prepare a statement. In case no connection has been given, allocate a
 * new one.
 *
 * @param sql  The SQL statement to be executed
 *
 * @throws GenericDataSourceException
 * @throws GenericEntityException
 */
public void prepareStatement(String sql, boolean specifyTypeAndConcur, int resultSetType, int resultSetConcurrency, int fetchSize, int maxRows) throws GenericDataSourceException, GenericEntityException {
    if (Debug.verboseOn()) Debug.logVerbose("[SQLProcessor.prepareStatement] sql=" + sql, module);

    if (_connection == null) {
        getConnection();
    }

    try {
        _sql = sql;
        _ind = 1;
        if (specifyTypeAndConcur) {
            _ps = _connection.prepareStatement(sql, resultSetType, resultSetConcurrency);
            if (Debug.verboseOn()) Debug.logVerbose("[SQLProcessor.prepareStatement] _ps=" + _ps, module);
        } else {
            _ps = _connection.prepareStatement(sql);
            if (Debug.verboseOn()) Debug.logVerbose("[SQLProcessor.prepareStatement] (def) _ps=" + _ps, module);
        }
        if (maxRows > 0) {
            _ps.setMaxRows(maxRows);
            if (Debug.verboseOn()) Debug.logVerbose("[SQLProcessor.prepareStatement] max rows set : " + maxRows, module);
        }
        this.setFetchSize(_ps, fetchSize);
    } catch (SQLException sqle) {
        throw new GenericDataSourceException("SQL Exception while executing the following:" + sql, sqle);
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
/**
 * Execute a query based on the prepared statement
 *
 * @return The result set of the query
 * @throws GenericDataSourceException
 */
public ResultSet executeQuery() throws GenericDataSourceException {
    try {
        // if (Debug.verboseOn()) Debug.logVerbose("[SQLProcessor.executeQuery] ps=" + _ps.toString(), module);
        _rs = _ps.executeQuery();
    } catch (SQLException sqle) {
        this.checkLockWaitInfo(sqle);
        throw new GenericDataSourceException("SQL Exception while executing the following:" + _sql, sqle);
    }

    return _rs;
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
/**
 * Execute updates
 *
 * @return  The number of rows updated
 * @throws GenericDataSourceException
 */
public int executeUpdate() throws GenericDataSourceException {
    try {
        // if (Debug.verboseOn()) Debug.logVerbose("[SQLProcessor.executeUpdate] ps=" + _ps.toString(), module);
        //TransactionUtil.printAllThreadsTransactionBeginStacks();
        return _ps.executeUpdate();
    } catch (SQLException sqle) {
        this.checkLockWaitInfo(sqle);
        // don't display this here, may not be critical, allow handling further up... Debug.logError(sqle, "SQLProcessor.executeUpdate() : ERROR : ", module);
        throw new GenericDataSourceException("SQL Exception while executing the following:" + _sql, sqle);
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
/**
 * Test if there more records available
 *
 * @return true, if there more records available
 *
 * @throws GenericDataSourceException
 */
public boolean next() throws GenericDataSourceException {
    try {
        return _rs.next();
    } catch (SQLException sqle) {
        throw new GenericDataSourceException("SQL Exception while executing the following:" + _sql, sqle);
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
public int updateByCondition(ModelEntity modelEntity, Map<String, ? extends Object> fieldsToSet, EntityCondition condition) throws GenericEntityException {
    SQLProcessor sqlP = new SQLProcessor(helperInfo);

    try {
        return updateByCondition(modelEntity, fieldsToSet, condition, sqlP);
    } catch (GenericDataSourceException e) {
        sqlP.rollback();
        throw new GenericDataSourceException("Generic Entity Exception occured in updateByCondition", e);
    } finally {
        sqlP.close();
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
public int delete(GenericEntity entity) throws GenericEntityException {
    SQLProcessor sqlP = new SQLProcessor(helperInfo);

    try {
        return delete(entity, sqlP);
    } catch (GenericDataSourceException e) {
        sqlP.rollback();
        throw new GenericDataSourceException("Exception while deleting the following entity: " + entity.toString(), e);
    } finally {
        sqlP.close();
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
public int deleteByCondition(ModelEntity modelEntity, EntityCondition condition) throws GenericEntityException {
    SQLProcessor sqlP = new SQLProcessor(helperInfo);

    try {
        return deleteByCondition(modelEntity, condition, sqlP);
    } catch (GenericDataSourceException e) {
        sqlP.rollback();
        throw new GenericDataSourceException("Generic Entity Exception occured in deleteByCondition", e);
    } finally {
        sqlP.close();
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
private static void saveLastExportTimestamp(SQLProcessor sqlproc, Timestamp lastTimestamp, boolean firstExport) throws GenericDataSourceException, GenericEntityException, SQLException {
    if (lastTimestamp == null) {
        throw new IllegalArgumentException();
    }

    String qStr = "";
    if (firstExport) {
        qStr = "INSERT INTO ENTITY_SYNC (entity_sync_id, last_successful_synch_time) VALUES ('exportContactsToCrm2', ?)";
    } else {
        qStr = "UPDATE ENTITY_SYNC SET last_successful_synch_time = ? WHERE entity_sync_id = 'exportContactsToCrm2'";
    }
    sqlproc.prepareStatement(qStr);
    sqlproc.setValue(lastTimestamp);
    sqlproc.executeUpdate();
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
private static void exportUsers(String contactId, String partyId, String exportUserUrl, String authToken, String clientDomain, SQLProcessor sqlproc, Timestamp lastTimestamp, Timestamp now) throws GenericDataSourceException, GenericEntityException, SQLException, HttpClientException {
    ResultSet userLoginSet = getContactUserLoginSet(sqlproc, lastTimestamp, now, partyId);
    List<String> userIdList = new ArrayList<String>();
    if (userLoginSet != null) {
        while (userLoginSet.next()) {
            String userId = userLoginSet.getString("user_login_id");
            if (!userIdList.contains(userId)) {
                exportUser(userId, "INTERNAL", contactId, exportUserUrl, authToken, clientDomain);
                userIdList.add(userId);
            }
        }
    }
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
private static ResultSet getContactsSet(SQLProcessor sqlproc, Timestamp lastTimestamp, Timestamp now, String partyId) throws GenericDataSourceException, GenericEntityException, SQLException {
    if (sqlproc == null || lastTimestamp == null || now == null) {
        throw new IllegalArgumentException();
    }
    ResultSet result = null;

    StringBuilder qStr =  new StringBuilder("SELECT PCM.party_id, PS.first_name, PS.last_name, PCM.contact_mech_id, CM.info_string, PCMP.contact_mech_purpose_type_id FROM PARTY_CONTACT_MECH AS PCM ")
        .append("JOIN CONTACT_MECH AS CM ON PCM.contact_mech_id = CM.contact_mech_id ")
        .append("LEFT JOIN PARTY_CONTACT_MECH_PURPOSE AS PCMP ON PCM.party_id = PCMP.party_id AND PCM.contact_mech_id = PCMP.contact_mech_id ")
        .append("JOIN PERSON as PS ON PCM.party_id = PS.party_id ");
    if (UtilValidate.isEmpty(partyId)) {
        qStr.append("JOIN ")
            .append("(SELECT party_id FROM (SELECT PCM.party_id FROM PARTY_CONTACT_MECH AS PCM ")
            .append("WHERE PCM.last_updated_stamp >= ? ")
            .append("UNION ")
            .append("SELECT PS.party_id FROM PERSON AS PS ")
            .append("WHERE PS.last_updated_stamp >= ? ")
            .append(") AS NEW_P) AS NEW_ITEM ON PCM.party_id = NEW_ITEM.party_id ");
    }
    qStr.append("WHERE PCM.from_date <= ? ")
        .append("AND (PCM.thru_date >= ? OR PCM.thru_date is null) ")
        .append("AND ((PCMP.from_date <= ? AND (PCMP.thru_date >= ? OR PCMP.thru_date is null)) OR PCMP.contact_mech_purpose_type_id IS NULL ) ")
        .append("AND CM.contact_mech_type_id = 'EMAIL_ADDRESS' ");
    if (UtilValidate.isNotEmpty(partyId)) {
        qStr.append("AND PCM.party_id = ? ");
    }
    qStr.append("ORDER BY PCM.party_id, PCM.contact_mech_id ");

    sqlproc.prepareStatement(qStr.toString());
    if (UtilValidate.isEmpty(partyId)) {
        sqlproc.setValue(lastTimestamp);
        sqlproc.setValue(lastTimestamp);
    }
    sqlproc.setValue(now);
    sqlproc.setValue(now);
    sqlproc.setValue(now);
    sqlproc.setValue(now);
    if (UtilValidate.isNotEmpty(partyId)) {
        sqlproc.setValue(partyId);
    }

    result = sqlproc.executeQuery();

    return result;
}
 

import org.ofbiz.entity.GenericDataSourceException; //导入依赖的package包/类
private static ResultSet getPartyGroupsSet(SQLProcessor sqlproc, Timestamp lastTimestamp, Timestamp now, String partyId) throws GenericDataSourceException, GenericEntityException, SQLException {
    if (sqlproc == null || lastTimestamp == null || now == null) {
        throw new IllegalArgumentException();
    }
    ResultSet result = null;

    StringBuilder qStr =  new StringBuilder("SELECT PCM.party_id, PS.group_name, PCM.contact_mech_id, CM.info_string, PCMP.contact_mech_purpose_type_id FROM PARTY_CONTACT_MECH AS PCM ")
        .append("JOIN CONTACT_MECH AS CM ON PCM.contact_mech_id = CM.contact_mech_id ")
        .append("LEFT JOIN PARTY_CONTACT_MECH_PURPOSE AS PCMP ON PCM.party_id = PCMP.party_id AND PCM.contact_mech_id = PCMP.contact_mech_id ")
        .append("JOIN PARTY_GROUP as PS ON PCM.party_id = PS.party_id ");
    if (UtilValidate.isEmpty(partyId)) {
        qStr.append("JOIN ")
            .append("(SELECT party_id FROM (SELECT PCM.party_id FROM PARTY_CONTACT_MECH AS PCM ")
            .append("WHERE PCM.last_updated_stamp >= ? ")
            .append("UNION ")
            .append("SELECT PS.party_id FROM PARTY_GROUP AS PS ")
            .append("WHERE PS.last_updated_stamp >= ? ")
            .append(") AS NEW_P) AS NEW_ITEM ON PCM.party_id = NEW_ITEM.party_id ");
    }
    qStr.append("WHERE PCM.from_date <= ? ")
        .append("AND (PCM.thru_date >= ? OR PCM.thru_date is null) ")
        .append("AND ((PCMP.from_date <= ? AND (PCMP.thru_date >= ? OR PCMP.thru_date is null)) OR PCMP.contact_mech_purpose_type_id IS NULL ) ")
        .append("AND CM.contact_mech_type_id = 'EMAIL_ADDRESS' ");
    if (UtilValidate.isNotEmpty(partyId)) {
        qStr.append("AND PCM.party_id = ? ");
    }
    qStr.append("ORDER BY PCM.party_id, PCM.contact_mech_id ");

    sqlproc.prepareStatement(qStr.toString());
    if (UtilValidate.isEmpty(partyId)) {
        sqlproc.setValue(lastTimestamp);
        sqlproc.setValue(lastTimestamp);
    }
    sqlproc.setValue(now);
    sqlproc.setValue(now);
    sqlproc.setValue(now);
    sqlproc.setValue(now);
    if (UtilValidate.isNotEmpty(partyId)) {
        sqlproc.setValue(partyId);
    }

    result = sqlproc.executeQuery();

    return result;
}