|
|
|
|
@ -1478,6 +1478,146 @@ public class GenericOperationDAOImpl implements OperationDAO {
|
|
|
|
|
return operations;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public List<? extends Operation> getOperationsForDeviceByDeviceIdentifier(DeviceIdentifier deviceId, PaginationRequest request)
|
|
|
|
|
throws OperationManagementDAOException {
|
|
|
|
|
Operation operation;
|
|
|
|
|
List<Operation> operations = new ArrayList<>();
|
|
|
|
|
String createdTo = null;
|
|
|
|
|
String createdFrom = null;
|
|
|
|
|
DateFormat simple = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
|
|
|
|
|
boolean isCreatedDayProvided = false;
|
|
|
|
|
boolean isUpdatedDayProvided = false; //updated day = received day
|
|
|
|
|
boolean isOperationCodeProvided = false;
|
|
|
|
|
boolean isStatusProvided = false;
|
|
|
|
|
if (request.getOperationLogFilters().getCreatedDayFrom() != null) {
|
|
|
|
|
createdFrom = simple.format(request.getOperationLogFilters().getCreatedDayFrom());
|
|
|
|
|
}
|
|
|
|
|
if (request.getOperationLogFilters().getCreatedDayTo() != null) {
|
|
|
|
|
createdTo = simple.format(request.getOperationLogFilters().getCreatedDayTo());
|
|
|
|
|
}
|
|
|
|
|
Long updatedFrom = request.getOperationLogFilters().getUpdatedDayFrom();
|
|
|
|
|
Long updatedTo = request.getOperationLogFilters().getUpdatedDayTo();
|
|
|
|
|
List<String> operationCode = request.getOperationLogFilters().getOperationCode();
|
|
|
|
|
List<String> status = request.getOperationLogFilters().getStatus();
|
|
|
|
|
StringBuilder sql = new StringBuilder("SELECT " +
|
|
|
|
|
"o.ID, " +
|
|
|
|
|
"TYPE, " +
|
|
|
|
|
"o.CREATED_TIMESTAMP, " +
|
|
|
|
|
"o.RECEIVED_TIMESTAMP, " +
|
|
|
|
|
"o.OPERATION_CODE, " +
|
|
|
|
|
"o.INITIATED_BY, " +
|
|
|
|
|
"om.STATUS, " +
|
|
|
|
|
"om.ID AS OM_MAPPING_ID, " +
|
|
|
|
|
"om.UPDATED_TIMESTAMP " +
|
|
|
|
|
"FROM " +
|
|
|
|
|
"DM_OPERATION o " +
|
|
|
|
|
"INNER JOIN " +
|
|
|
|
|
"(SELECT dm.OPERATION_ID, " +
|
|
|
|
|
"dm.ID, " +
|
|
|
|
|
"dm.STATUS, " +
|
|
|
|
|
"dm.UPDATED_TIMESTAMP " +
|
|
|
|
|
"FROM " +
|
|
|
|
|
"DM_ENROLMENT_OP_MAPPING dm " +
|
|
|
|
|
"WHERE " +
|
|
|
|
|
"dm.DEVICE_IDENTIFICATION = ?");
|
|
|
|
|
|
|
|
|
|
if (updatedFrom != null && updatedFrom != 0 && updatedTo != null && updatedTo != 0) {
|
|
|
|
|
sql.append(" AND dm.UPDATED_TIMESTAMP BETWEEN ? AND ?");
|
|
|
|
|
isUpdatedDayProvided = true;
|
|
|
|
|
}
|
|
|
|
|
sql.append(") om ON o.ID = om.OPERATION_ID ");
|
|
|
|
|
if (createdFrom != null && !createdFrom.isEmpty() && createdTo != null && !createdTo.isEmpty()) {
|
|
|
|
|
sql.append(" WHERE o.CREATED_TIMESTAMP BETWEEN ? AND ?");
|
|
|
|
|
isCreatedDayProvided = true;
|
|
|
|
|
}
|
|
|
|
|
if ((isCreatedDayProvided) && (status != null && !status.isEmpty())) {
|
|
|
|
|
int size = status.size();
|
|
|
|
|
sql.append(" AND (om.STATUS = ? ");
|
|
|
|
|
for (int i = 0; i < size - 1; i++) {
|
|
|
|
|
sql.append(" OR om.STATUS = ?");
|
|
|
|
|
}
|
|
|
|
|
sql.append(")");
|
|
|
|
|
isStatusProvided = true;
|
|
|
|
|
} else if ((!isCreatedDayProvided) && (status != null && !status.isEmpty())) {
|
|
|
|
|
int size = status.size();
|
|
|
|
|
sql.append(" WHERE (om.STATUS = ? ");
|
|
|
|
|
for (int i = 0; i < size - 1; i++) {
|
|
|
|
|
sql.append(" OR om.STATUS = ?");
|
|
|
|
|
}
|
|
|
|
|
sql.append(")");
|
|
|
|
|
isStatusProvided = true;
|
|
|
|
|
}
|
|
|
|
|
if ((isCreatedDayProvided || isStatusProvided) && (operationCode != null && !operationCode.isEmpty())) {
|
|
|
|
|
int size = operationCode.size();
|
|
|
|
|
sql.append(" AND (o.OPERATION_CODE = ? ");
|
|
|
|
|
for (int i = 0; i < size - 1; i++) {
|
|
|
|
|
sql.append(" OR o.OPERATION_CODE = ?");
|
|
|
|
|
}
|
|
|
|
|
sql.append(")");
|
|
|
|
|
isOperationCodeProvided = true;
|
|
|
|
|
} else if ((!isCreatedDayProvided && !isStatusProvided) && (operationCode != null && !operationCode.isEmpty())) {
|
|
|
|
|
int size = operationCode.size();
|
|
|
|
|
sql.append(" WHERE (o.OPERATION_CODE = ? ");
|
|
|
|
|
for (int i = 0; i < size - 1; i++) {
|
|
|
|
|
sql.append(" OR o.OPERATION_CODE = ?");
|
|
|
|
|
}
|
|
|
|
|
sql.append(")");
|
|
|
|
|
isOperationCodeProvided = true;
|
|
|
|
|
}
|
|
|
|
|
sql.append(" ORDER BY o.CREATED_TIMESTAMP DESC LIMIT ?,?");
|
|
|
|
|
try {
|
|
|
|
|
Connection conn = OperationManagementDAOFactory.getConnection();
|
|
|
|
|
try (PreparedStatement stmt = conn.prepareStatement(sql.toString())) {
|
|
|
|
|
int paramIndex = 1;
|
|
|
|
|
stmt.setString(paramIndex++, deviceId.getId());
|
|
|
|
|
if (isUpdatedDayProvided) {
|
|
|
|
|
stmt.setLong(paramIndex++, updatedFrom);
|
|
|
|
|
stmt.setLong(paramIndex++, updatedTo);
|
|
|
|
|
}
|
|
|
|
|
if (isCreatedDayProvided) {
|
|
|
|
|
stmt.setString(paramIndex++, createdFrom);
|
|
|
|
|
stmt.setString(paramIndex++, createdTo);
|
|
|
|
|
}
|
|
|
|
|
if (isStatusProvided) {
|
|
|
|
|
for (String s : status) {
|
|
|
|
|
stmt.setString(paramIndex++, s);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (isOperationCodeProvided) {
|
|
|
|
|
for (String s : operationCode) {
|
|
|
|
|
stmt.setString(paramIndex++, s);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
stmt.setInt(paramIndex++, request.getStartIndex());
|
|
|
|
|
stmt.setInt(paramIndex, request.getRowCount());
|
|
|
|
|
try (ResultSet rs = stmt.executeQuery()) {
|
|
|
|
|
while (rs.next()) {
|
|
|
|
|
operation = new Operation();
|
|
|
|
|
operation.setId(rs.getInt("ID"));
|
|
|
|
|
operation.setType(Operation.Type.valueOf(rs.getString("TYPE")));
|
|
|
|
|
operation.setCreatedTimeStamp(new Timestamp(rs.getLong("CREATED_TIMESTAMP") * 1000L).toString());
|
|
|
|
|
if (rs.getLong("UPDATED_TIMESTAMP") == 0) {
|
|
|
|
|
operation.setReceivedTimeStamp("");
|
|
|
|
|
} else {
|
|
|
|
|
operation.setReceivedTimeStamp(
|
|
|
|
|
new Timestamp((rs.getLong("UPDATED_TIMESTAMP") * 1000)).toString());
|
|
|
|
|
}
|
|
|
|
|
operation.setCode(rs.getString("OPERATION_CODE"));
|
|
|
|
|
operation.setInitiatedBy(rs.getString("INITIATED_BY"));
|
|
|
|
|
operation.setStatus(Operation.Status.valueOf(rs.getString("STATUS")));
|
|
|
|
|
OperationDAOUtil.setActivityId(operation, rs.getInt("ID"));
|
|
|
|
|
operations.add(operation);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} catch (SQLException e) {
|
|
|
|
|
throw new OperationManagementDAOException("SQL error occurred while retrieving the operation " +
|
|
|
|
|
"available for the device'" + deviceId + "' with status '", e);
|
|
|
|
|
}
|
|
|
|
|
return operations;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public int getOperationCountForDevice(int enrolmentId, PaginationRequest request)
|
|
|
|
|
throws OperationManagementDAOException {
|
|
|
|
|
@ -1584,6 +1724,112 @@ public class GenericOperationDAOImpl implements OperationDAO {
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public int getOperationCountForDeviceWithDeviceIdentifier(DeviceIdentifier deviceId, PaginationRequest request)
|
|
|
|
|
throws OperationManagementDAOException {
|
|
|
|
|
String createdTo = null;
|
|
|
|
|
String createdFrom = null;
|
|
|
|
|
DateFormat simple = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
|
|
|
|
|
if (request.getOperationLogFilters().getCreatedDayFrom() != null) {
|
|
|
|
|
createdFrom = simple.format(request.getOperationLogFilters().getCreatedDayFrom());
|
|
|
|
|
}
|
|
|
|
|
if (request.getOperationLogFilters().getCreatedDayTo() != null) {
|
|
|
|
|
createdTo = simple.format(request.getOperationLogFilters().getCreatedDayTo());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Long updatedFrom = request.getOperationLogFilters().getUpdatedDayFrom();
|
|
|
|
|
Long updatedTo = request.getOperationLogFilters().getUpdatedDayTo();
|
|
|
|
|
List<String> operationCodes = request.getOperationLogFilters().getOperationCode();
|
|
|
|
|
List<String> status = request.getOperationLogFilters().getStatus();
|
|
|
|
|
boolean isCreatedDayProvided = false;
|
|
|
|
|
boolean isUpdatedDayProvided = false;
|
|
|
|
|
boolean isOperationCodeProvided = false;
|
|
|
|
|
boolean isStatusProvided = false;
|
|
|
|
|
|
|
|
|
|
String sql = "SELECT "
|
|
|
|
|
+ "COUNT(o.ID) AS OPERATION_COUNT "
|
|
|
|
|
+ "FROM "
|
|
|
|
|
+ "DM_OPERATION o "
|
|
|
|
|
+ "INNER JOIN "
|
|
|
|
|
+ "(SELECT dm.OPERATION_ID, "
|
|
|
|
|
+ "dm.ID, "
|
|
|
|
|
+ "dm.STATUS, "
|
|
|
|
|
+ "dm.UPDATED_TIMESTAMP "
|
|
|
|
|
+ "FROM "
|
|
|
|
|
+ "DM_ENROLMENT_OP_MAPPING dm "
|
|
|
|
|
+ "WHERE "
|
|
|
|
|
+ "dm.DEVICE_IDENTIFICATION = ?";
|
|
|
|
|
|
|
|
|
|
if (updatedFrom != null && updatedFrom != 0 && updatedTo != null && updatedTo != 0) {
|
|
|
|
|
sql += " AND dm.UPDATED_TIMESTAMP BETWEEN ? AND ?";
|
|
|
|
|
isUpdatedDayProvided = true;
|
|
|
|
|
}
|
|
|
|
|
sql += ") om ON o.ID = om.OPERATION_ID ";
|
|
|
|
|
if (createdFrom != null && !createdFrom.isEmpty() && createdTo != null && !createdTo.isEmpty()) {
|
|
|
|
|
sql += " WHERE o.CREATED_TIMESTAMP BETWEEN ? AND ?";
|
|
|
|
|
isCreatedDayProvided = true;
|
|
|
|
|
}
|
|
|
|
|
if (status != null && !status.isEmpty()) {
|
|
|
|
|
if (isCreatedDayProvided) {
|
|
|
|
|
sql += " AND (om.STATUS = ? ";
|
|
|
|
|
} else {
|
|
|
|
|
sql += " WHERE (om.STATUS = ? ";
|
|
|
|
|
}
|
|
|
|
|
sql = IntStream.range(0, status.size() - 1).mapToObj(i -> " OR om.STATUS = ?")
|
|
|
|
|
.collect(Collectors.joining("", sql, ""));
|
|
|
|
|
sql += ")";
|
|
|
|
|
isStatusProvided = true;
|
|
|
|
|
}
|
|
|
|
|
if (operationCodes != null && !operationCodes.isEmpty()) {
|
|
|
|
|
if (isCreatedDayProvided || isStatusProvided) {
|
|
|
|
|
sql += " AND (o.OPERATION_CODE = ? ";
|
|
|
|
|
} else {
|
|
|
|
|
sql += " WHERE (o.OPERATION_CODE = ? ";
|
|
|
|
|
}
|
|
|
|
|
sql = IntStream.range(0, operationCodes.size() - 1).mapToObj(i -> " OR o.OPERATION_CODE = ?")
|
|
|
|
|
.collect(Collectors.joining("", sql, ""));
|
|
|
|
|
sql += ")";
|
|
|
|
|
isOperationCodeProvided = true;
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
Connection conn = OperationManagementDAOFactory.getConnection();
|
|
|
|
|
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
|
|
|
|
|
int paramIndex = 1;
|
|
|
|
|
stmt.setString(paramIndex++, deviceId.getId());
|
|
|
|
|
if (isUpdatedDayProvided) {
|
|
|
|
|
stmt.setLong(paramIndex++, updatedFrom);
|
|
|
|
|
stmt.setLong(paramIndex++, updatedTo);
|
|
|
|
|
}
|
|
|
|
|
if (isCreatedDayProvided) {
|
|
|
|
|
stmt.setString(paramIndex++, createdFrom);
|
|
|
|
|
stmt.setString(paramIndex++, createdTo);
|
|
|
|
|
}
|
|
|
|
|
if (isStatusProvided) {
|
|
|
|
|
for (String s : status) {
|
|
|
|
|
stmt.setString(paramIndex++, s);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (isOperationCodeProvided) {
|
|
|
|
|
for (String s : operationCodes) {
|
|
|
|
|
stmt.setString(paramIndex++, s);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
try (ResultSet rs = stmt.executeQuery()) {
|
|
|
|
|
if (rs.next()) {
|
|
|
|
|
return rs.getInt("OPERATION_COUNT");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} catch (SQLException e) {
|
|
|
|
|
String msg = "SQL error occurred while retrieving the operation count of the device" + deviceId
|
|
|
|
|
+ " for search query";
|
|
|
|
|
log.error(msg, e);
|
|
|
|
|
throw new OperationManagementDAOException(msg, e);
|
|
|
|
|
}
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public Operation getNextOperation(int enrolmentId, Operation.Status status) throws OperationManagementDAOException {
|
|
|
|
|
PreparedStatement stmt = null;
|
|
|
|
|
|
