Revision 61450
Added by Konstantinos Spyrou over 2 years ago
| PiWikServiceImpl.java | ||
|---|---|---|
| 67 | 67 |
|
| 68 | 68 |
@Override |
| 69 | 69 |
public PiwikInfo getPiwikSiteForRepo(String repositoryId) {
|
| 70 |
try{
|
|
| 70 |
try {
|
|
| 71 | 71 |
return new JdbcTemplate(dataSource).queryForObject(GET_PIWIK_SITE, new String[]{repositoryId}, new int[]{Types.VARCHAR}, piwikRowMapper);
|
| 72 |
}catch (EmptyResultDataAccessException e){
|
|
| 72 |
} catch (EmptyResultDataAccessException e) {
|
|
| 73 | 73 |
return null; |
| 74 | 74 |
} |
| 75 | 75 |
} |
| ... | ... | |
| 86 | 86 |
|
| 87 | 87 |
@Override |
| 88 | 88 |
public List<PiwikInfo> getPiwikSitesForRepos(OrderByField orderByField, OrderByType orderByType, int from, int quantity, String searchField) {
|
| 89 |
try{
|
|
| 90 |
String finalizedQuery = GET_PIWIK_SITES + " where ("+
|
|
| 89 |
try {
|
|
| 90 |
String finalizedQuery = GET_PIWIK_SITES + " where (" +
|
|
| 91 | 91 |
" repositoryid ilike ? " + |
| 92 | 92 |
" or siteid ilike ?" + |
| 93 | 93 |
" or requestorname ilike ?" + |
| 94 | 94 |
" or requestoremail ilike ?" + |
| 95 | 95 |
" or comment ilike ?" + |
| 96 |
" or repositoryname ilike ?"+ |
|
| 96 |
" or repositoryname ilike ?" +
|
|
| 97 | 97 |
" or country ilike ?" |
| 98 |
+") order by "+orderByField + " " + orderByType + " offset ? limit ?";
|
|
| 98 |
+ ") order by " + orderByField + " " + orderByType + " offset ? limit ?";
|
|
| 99 | 99 |
|
| 100 | 100 |
return new JdbcTemplate(dataSource).query(finalizedQuery, preparedStatement -> {
|
| 101 |
preparedStatement.setString(1,"%"+searchField+"%");
|
|
| 102 |
preparedStatement.setString(2,"%"+searchField+"%");
|
|
| 103 |
preparedStatement.setString(3,"%"+searchField+"%");
|
|
| 104 |
preparedStatement.setString(4,"%"+searchField+"%");
|
|
| 105 |
preparedStatement.setString(5,"%"+searchField+"%");
|
|
| 106 |
preparedStatement.setString(6,"%"+searchField+"%");
|
|
| 107 |
preparedStatement.setString(7,"%"+searchField+"%");
|
|
| 108 |
preparedStatement.setInt(8,from); |
|
| 109 |
preparedStatement.setInt(9,quantity); |
|
| 101 |
preparedStatement.setString(1, "%" + searchField + "%");
|
|
| 102 |
preparedStatement.setString(2, "%" + searchField + "%");
|
|
| 103 |
preparedStatement.setString(3, "%" + searchField + "%");
|
|
| 104 |
preparedStatement.setString(4, "%" + searchField + "%");
|
|
| 105 |
preparedStatement.setString(5, "%" + searchField + "%");
|
|
| 106 |
preparedStatement.setString(6, "%" + searchField + "%");
|
|
| 107 |
preparedStatement.setString(7, "%" + searchField + "%");
|
|
| 108 |
preparedStatement.setInt(8, from);
|
|
| 109 |
preparedStatement.setInt(9, quantity);
|
|
| 110 | 110 |
}, piwikRowMapper); |
| 111 |
}catch (EmptyResultDataAccessException e){
|
|
| 111 |
} catch (EmptyResultDataAccessException e) {
|
|
| 112 | 112 |
return null; |
| 113 | 113 |
} |
| 114 | 114 |
|
| 115 | 115 |
} |
| 116 | 116 |
|
| 117 | 117 |
@Override |
| 118 |
public int getPiwikSitesTotals(String searchField){
|
|
| 119 |
try{
|
|
| 120 |
String finalizedQuery = GET_PIWIK_SITES_TOTAL + " where ("+
|
|
| 118 |
public int getPiwikSitesTotals(String searchField) {
|
|
| 119 |
try {
|
|
| 120 |
String finalizedQuery = GET_PIWIK_SITES_TOTAL + " where (" +
|
|
| 121 | 121 |
" repositoryid ilike ? " + |
| 122 | 122 |
" or siteid ilike ?" + |
| 123 | 123 |
" or requestorname ilike ?" + |
| 124 | 124 |
" or requestoremail ilike ?" + |
| 125 | 125 |
" or comment ilike ?" + |
| 126 |
" or repositoryname ilike ?"+ |
|
| 126 |
" or repositoryname ilike ?" +
|
|
| 127 | 127 |
" or country ilike ?)"; |
| 128 | 128 |
|
| 129 | 129 |
return new JdbcTemplate(dataSource).query(finalizedQuery, preparedStatement -> {
|
| 130 |
preparedStatement.setString(1,"%"+searchField+"%");
|
|
| 131 |
preparedStatement.setString(2,"%"+searchField+"%");
|
|
| 132 |
preparedStatement.setString(3,"%"+searchField+"%");
|
|
| 133 |
preparedStatement.setString(4,"%"+searchField+"%");
|
|
| 134 |
preparedStatement.setString(5,"%"+searchField+"%");
|
|
| 135 |
preparedStatement.setString(6,"%"+searchField+"%");
|
|
| 136 |
preparedStatement.setString(7,"%"+searchField+"%");
|
|
| 137 |
},rowMapper -> {
|
|
| 130 |
preparedStatement.setString(1, "%" + searchField + "%");
|
|
| 131 |
preparedStatement.setString(2, "%" + searchField + "%");
|
|
| 132 |
preparedStatement.setString(3, "%" + searchField + "%");
|
|
| 133 |
preparedStatement.setString(4, "%" + searchField + "%");
|
|
| 134 |
preparedStatement.setString(5, "%" + searchField + "%");
|
|
| 135 |
preparedStatement.setString(6, "%" + searchField + "%");
|
|
| 136 |
preparedStatement.setString(7, "%" + searchField + "%");
|
|
| 137 |
}, rowMapper -> {
|
|
| 138 | 138 |
rowMapper.next(); |
| 139 | 139 |
return rowMapper.getInt("totals");
|
| 140 | 140 |
}); |
| 141 |
}catch (EmptyResultDataAccessException e){
|
|
| 141 |
} catch (EmptyResultDataAccessException e) {
|
|
| 142 | 142 |
return 0; |
| 143 | 143 |
} |
| 144 | 144 |
} |
| ... | ... | |
| 146 | 146 |
@Override |
| 147 | 147 |
@PreAuthorize("hasAuthority('SUPER_ADMINISTRATOR') or hasAuthority('CONTENT_PROVIDER_DASHBOARD_ADMINISTRATOR')")
|
| 148 | 148 |
public ResponseEntity<Object> approvePiwikSite(String repositoryId) {
|
| 149 |
new JdbcTemplate(dataSource).update(APPROVE_PIWIK_SITE, new Object[] {repositoryId}, new int[] {Types.VARCHAR});
|
|
| 150 |
return new ResponseEntity<>("OK",HttpStatus.OK);
|
|
| 149 |
new JdbcTemplate(dataSource).update(APPROVE_PIWIK_SITE, new Object[]{repositoryId}, new int[]{Types.VARCHAR});
|
|
| 150 |
return new ResponseEntity<>("OK", HttpStatus.OK);
|
|
| 151 | 151 |
} |
| 152 | 152 |
|
| 153 | 153 |
@Override |
| ... | ... | |
| 175 | 175 |
LOGGER.error("Error while sending email to administrator or user about the enabling of metrics", e);
|
| 176 | 176 |
emailUtils.reportException(e); |
| 177 | 177 |
} |
| 178 |
return new ResponseEntity<>("OK",HttpStatus.OK);
|
|
| 178 |
return new ResponseEntity<>("OK", HttpStatus.OK);
|
|
| 179 | 179 |
} |
| 180 | 180 |
|
| 181 | 181 |
@Override |
| ... | ... | |
| 188 | 188 |
+ URLEncoder.encode(repoWebsite, "UTF-8"); |
| 189 | 189 |
Map map = new ObjectMapper().readValue(new URL(URL), Map.class); |
| 190 | 190 |
String siteId = null; |
| 191 |
if(map.get("value")!=null) {
|
|
| 191 |
if (map.get("value") != null) {
|
|
| 192 | 192 |
siteId = map.get("value").toString();
|
| 193 | 193 |
} |
| 194 | 194 |
piwikInfo.setSiteId(siteId); |
| ... | ... | |
| 217 | 217 |
return piwikInfo; |
| 218 | 218 |
} |
| 219 | 219 |
|
| 220 |
@Override |
|
| 221 |
public Integer getTotal() {
|
|
| 222 |
return new JdbcTemplate(dataSource).queryForObject(GET_PIWIK_SITES_TOTAL, new Object[]{}, Integer.class);
|
|
| 223 |
} |
|
| 220 | 224 |
|
| 225 |
@Override |
|
| 226 |
public Integer getValidated(boolean validated) {
|
|
| 227 |
String finalizedQuery = GET_PIWIK_SITES_TOTAL + " where validated = ?"; |
|
| 228 |
return new JdbcTemplate(dataSource).queryForObject(finalizedQuery, new Object[]{validated}, Integer.class);
|
|
| 229 |
} |
|
| 221 | 230 |
} |
Also available in: Unified diff
created prometheus reports and /metrics