2 * ============LICENSE_START====================================================
4 * ===========================================================================
5 * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
6 * Modifications Copyright (C) 2018 IBM.
7 * ===========================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END====================================================
23 package org.onap.aaf.auth.batch.reports;
26 import java.io.IOException;
27 import java.util.Date;
28 import java.util.GregorianCalendar;
29 import java.util.Iterator;
30 import java.util.List;
32 import java.util.TreeMap;
33 import java.util.UUID;
34 import org.onap.aaf.auth.batch.Batch;
35 import org.onap.aaf.auth.env.AuthzTrans;
36 import org.onap.aaf.auth.org.OrganizationException;
37 import org.onap.aaf.cadi.util.CSV;
38 import org.onap.aaf.cadi.util.CSV.Writer;
39 import org.onap.aaf.misc.env.APIException;
40 import org.onap.aaf.misc.env.Env;
41 import org.onap.aaf.misc.env.TimeTaken;
42 import org.onap.aaf.misc.env.util.Chrono;
43 import org.onap.aaf.misc.env.util.Split;
45 import com.datastax.driver.core.ResultSet;
46 import com.datastax.driver.core.Row;
47 import com.datastax.driver.core.SimpleStatement;
48 import com.datastax.driver.core.Statement;
51 public class ApprovedRpt extends Batch {
53 private static final String APPR_RPT = "ApprovedRpt";
54 private static final String CSV = ".csv";
56 private Writer approvedW;
58 private static String yr_mon;
60 public ApprovedRpt(AuthzTrans trans) throws APIException, IOException, OrganizationException {
62 trans.info().log("Starting Connection Process");
64 TimeTaken tt0 = trans.start("Cassandra Initialization", Env.SUB);
67 String sdate = Chrono.dateOnlyStamp(now);
68 File file = new File(logDir(),APPR_RPT + sdate +CSV);
69 CSV csv = new CSV(env.access(),file);
70 approvedW = csv.writer(false);
72 historyR = new CSV(env.access(),args()[1]).setDelimiter('|');
81 protected void run(AuthzTrans trans) {
84 // Statement stmt = new SimpleStatement( "select dateof(id), approver, status, user, type, memo from authz.approved;" );
85 // results = session.execute(stmt);
86 // Iterator<Row> iter = results.iterator();
89 * while (iter.hasNext()) {
92 d = row.getTimestamp(0);
94 approvedW.row("aprvd",
95 Chrono.dateOnlyStamp(d),
105 GregorianCalendar gc = new GregorianCalendar();
106 gc.add(GregorianCalendar.MONTH, -2);
107 approvedW.comment("date, approver, status, user, role, memo");
108 historyR.visit(row -> {
109 String s = row.get(7);
110 if(s.equals(yr_mon)) {
111 String target = row.get(5);
112 if("user_role".equals(target)) {
113 String action = row.get(1);
116 write("created",row);
119 write("approved",row);
129 } catch (Exception e) {
134 private void write(String a_or_d, List<String> row) {
135 String[] target = Split.splitTrim('|', row.get(4));
137 if(target.length>1) {
138 UUID id = UUID.fromString(row.get(0));
139 Date date = Chrono.uuidToDate(id);
142 String approver = row.get(6);
143 if("batch:JobChange".equals(approver)) {
145 memo = "existing role membership reduced to invoke reapproval";
150 if(!approver.equals(target[0])) {
152 Chrono.niceDateStamp(date),