2 * ============LICENSE_START====================================================
4 * ===========================================================================
5 * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
6 * Modifications Copyright (C) 2019 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";
55 private static final String INFO = "info";
57 private Writer approvedW;
59 private static String yr_mon;
61 public ApprovedRpt(AuthzTrans trans) throws APIException, IOException, OrganizationException {
63 trans.info().log("Starting Connection Process");
65 TimeTaken tt0 = trans.start("Cassandra Initialization", Env.SUB);
68 String sdate = Chrono.dateOnlyStamp(now);
69 File file = new File(logDir(),APPR_RPT + sdate +CSV);
70 CSV csv = new CSV(env.access(),file);
71 approvedW = csv.writer(false);
73 historyR = new CSV(env.access(),args()[1]).setDelimiter('|');
82 protected void run(AuthzTrans trans) {
84 Map<String,Boolean> checked = new TreeMap<String, Boolean>();
86 final AuthzTrans transNoAvg = trans.env().newTransNoAvg();
89 GregorianCalendar gc = new GregorianCalendar();
90 gc.add(GregorianCalendar.MONTH, -2);
91 Date begin = gc.getTime();
92 approvedW.comment("date, approver, status, user, role, memo");
94 historyR.visit(row -> {
95 String s = row.get(7);
96 if(s.equals(yr_mon)) {
97 String target = row.get(5);
98 if("user_role".equals(target)) {
99 String action = row.get(1);
102 write("created",row);
105 write("approved",row);
115 } catch (Exception e) {
120 private void write(String a_or_d, List<String> row) {
121 String[] target = Split.splitTrim('|', row.get(4));
123 if(target.length>1) {
124 UUID id = UUID.fromString(row.get(0));
125 Date date = Chrono.uuidToDate(id);
128 String approver = row.get(6);
129 if("batch:JobChange".equals(approver)) {
131 memo = "existing role membership reduced to invoke reapproval";
136 if(!approver.equals(target[0])) {
138 Chrono.niceDateStamp(date),