forked from ist-dsi/expenditures
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Enhances ist-dsi#90. Adds api. Check supplier limit on After the Fact…
…. Adds cpv and goodsServicies classification to after the fact.
- Loading branch information
Joao Quiterio
committed
Mar 30, 2014
1 parent
e29576c
commit a5d3efd
Showing
12 changed files
with
2,893 additions
and
2,268 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
204 changes: 204 additions & 0 deletions
204
expenditure-tracking/src/main/java/module/webservice/api/ExpenditureAPIv1.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,204 @@ | ||
| package module.webservice.api; | ||
|
|
||
| import java.math.BigDecimal; | ||
| import java.text.SimpleDateFormat; | ||
| import java.util.Set; | ||
|
|
||
| import javax.ws.rs.GET; | ||
| import javax.ws.rs.Path; | ||
| import javax.ws.rs.Produces; | ||
| import javax.ws.rs.QueryParam; | ||
| import javax.ws.rs.WebApplicationException; | ||
| import javax.ws.rs.core.Response; | ||
| import javax.ws.rs.core.Response.Status; | ||
|
|
||
| import module.finance.domain.SupplierContact; | ||
| import module.workflow.activities.ActivityInformation; | ||
| import module.workflow.activities.WorkflowActivity; | ||
| import module.workflow.domain.WorkflowProcess; | ||
| import module.workflow.domain.WorkflowSystem; | ||
|
|
||
| import org.joda.time.LocalDate; | ||
| import org.joda.time.format.DateTimeFormat; | ||
| import org.joda.time.format.DateTimeFormatter; | ||
| import org.json.simple.JSONObject; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| import pt.ist.bennu.core.domain.MyOrg; | ||
| import pt.ist.bennu.core.domain.exceptions.DomainException; | ||
| import pt.ist.bennu.core.domain.util.Money; | ||
| import pt.ist.expenditureTrackingSystem.domain.acquisitions.AcquisitionItemClassification; | ||
| import pt.ist.expenditureTrackingSystem.domain.acquisitions.CPVReference; | ||
| import pt.ist.expenditureTrackingSystem.domain.acquisitions.afterthefact.AfterTheFactAcquisitionProcess; | ||
| import pt.ist.expenditureTrackingSystem.domain.acquisitions.afterthefact.AfterTheFactAcquisitionType; | ||
| import pt.ist.expenditureTrackingSystem.domain.acquisitions.afterthefact.activities.DeleteAfterTheFactAcquisitionProcess; | ||
| import pt.ist.expenditureTrackingSystem.domain.acquisitions.afterthefact.activities.EditAfterTheFactProcessActivityInformation.AfterTheFactAcquisitionProcessBean; | ||
| import pt.ist.expenditureTrackingSystem.domain.acquisitions.simplified.activities.CancelAcquisitionRequest; | ||
| import pt.ist.expenditureTrackingSystem.domain.organization.Supplier; | ||
|
|
||
| import com.google.gson.Gson; | ||
| import com.google.gson.GsonBuilder; | ||
| import com.google.gson.JsonArray; | ||
| import com.google.gson.JsonObject; | ||
|
|
||
| @Path("expenditures-tracking/v1") | ||
| public class ExpenditureAPIv1 { | ||
|
|
||
| private static final Logger logger = LoggerFactory.getLogger(ExpenditureAPIv1.class); | ||
|
|
||
| public final static String JSON_UTF8 = "application/json; charset=utf-8"; | ||
|
|
||
| DateTimeFormatter formatDayHour = DateTimeFormat.forPattern("dd/MM/yyyy HH:mm"); | ||
|
|
||
| public static final DateTimeFormatter formatDay = DateTimeFormat.forPattern("dd/MM/yyyy"); | ||
| public static final SimpleDateFormat dataFormatDay = new SimpleDateFormat("dd/MM/yyyy"); | ||
| public static final SimpleDateFormat dataFormatHour = new SimpleDateFormat("HH:mm"); | ||
|
|
||
| private static Gson gson; | ||
|
|
||
| static { | ||
| gson = new GsonBuilder().setPrettyPrinting().create(); | ||
| } | ||
|
|
||
| @GET | ||
| @Produces(JSON_UTF8) | ||
| @Path("suppliers") | ||
| public String suppliers() { | ||
| Set<Supplier> suppliers = MyOrg.getInstance().getSuppliersSet(); | ||
| JsonArray toReturn = new JsonArray(); | ||
| for (Supplier supplier : suppliers) { | ||
| if (supplier != null) { | ||
| JsonObject obj = new JsonObject(); | ||
|
|
||
| obj.addProperty("supplierID", supplier.getExternalId()); | ||
| obj.addProperty("fiscalID", supplier.getFiscalIdentificationCode()); | ||
| obj.addProperty("name", supplier.getName()); | ||
| obj.addProperty("shortName", supplier.getAbbreviatedName()); | ||
| obj.addProperty("limit", supplier.getSupplierLimit().toFormatString()); | ||
| JsonArray contacts = new JsonArray(); | ||
| for (SupplierContact contact : supplier.getSupplierContactSet()) { | ||
| JsonObject contactObj = new JsonObject(); | ||
| if (contact.getAddress() != null) { | ||
| JsonObject addressObj = new JsonObject(); | ||
| addressObj.addProperty("line1", contact.getAddress().getLine1()); | ||
| addressObj.addProperty("line2", contact.getAddress().getLine2()); | ||
| addressObj.addProperty("country", contact.getAddress().getCountry()); | ||
| contactObj.add("address", addressObj); | ||
| } | ||
| contactObj.addProperty("phone", contact.getPhone()); | ||
| contactObj.addProperty("fax", contact.getFax()); | ||
| contactObj.addProperty("email", contact.getEmail()); | ||
| contacts.add(contactObj); | ||
| } | ||
| obj.add("contacts", contacts); | ||
| obj.addProperty("totalAllocated", supplier.getTotalAllocated().toFormatString()); | ||
| JsonArray byCpv = new JsonArray(); | ||
| for (CPVReference cpv : supplier.getAllocationsByCPVReference().keySet()) { | ||
| if (cpv != null) { | ||
| JsonObject cpvObj = new JsonObject(); | ||
| cpvObj.addProperty("cpvCode", cpv.getCode()); | ||
| cpvObj.addProperty("cpvDescription", cpv.getDescription()); | ||
| cpvObj.addProperty("totalAllocated", supplier.getTotalAllocated(cpv).toFormatString()); | ||
| byCpv.add(cpvObj);; | ||
|
|
||
| } | ||
| } | ||
| obj.add("allocationsByCPV", byCpv); | ||
| toReturn.add(obj); | ||
| } | ||
| } | ||
|
|
||
| return gson.toJson(toReturn); | ||
| } | ||
|
|
||
| @GET | ||
| @Produces(JSON_UTF8) | ||
| @Path("allocateFunds") | ||
| public String allocateFunds(@QueryParam("supplierID") String supplierID, @QueryParam("value") String value, | ||
| @QueryParam("valueVat") String valueVAT, @QueryParam("cpvCode") String cpvcode, | ||
| @QueryParam("goodsOrService") String goodsOrServices, @QueryParam("description") String description) { | ||
|
|
||
| AfterTheFactAcquisitionProcessBean bean = new AfterTheFactAcquisitionProcessBean(); | ||
|
|
||
| Set<Supplier> suppliers = MyOrg.getInstance().getSuppliersSet(); | ||
| Supplier supplier = null; | ||
|
|
||
| for (Supplier sup : suppliers) { | ||
| if (sup.getExternalId().equals(supplierID)) { | ||
| supplier = sup; | ||
| break; | ||
| } | ||
| } | ||
| if (supplier == null) { | ||
| throw newApplicationError(Status.NOT_FOUND, "resource_not_found", "Can't find the supplier : " + supplierID); | ||
| } | ||
|
|
||
| bean.setSupplier(supplier); | ||
| bean.setAfterTheFactAcquisitionType(AfterTheFactAcquisitionType.PURCHASE); | ||
|
|
||
| Money itemValue = new Money(value); | ||
| bean.setValue(itemValue); | ||
|
|
||
| double VAT = Double.parseDouble(valueVAT); | ||
| bean.setVatValue(new BigDecimal(VAT)); | ||
|
|
||
| bean.setYear(new LocalDate().getYear()); | ||
| bean.setDescription(description); | ||
| bean.setClassification(AcquisitionItemClassification.valueOf(goodsOrServices.toUpperCase())); | ||
| CPVReference cpvReference = CPVReference.getCPVCode(cpvcode); | ||
| if (cpvReference == null) { | ||
| throw newApplicationError(Status.NOT_FOUND, "resource_not_found", "Can't find the cpv code : " + cpvcode); | ||
| } | ||
| bean.setCpvReference(cpvReference); | ||
|
|
||
| AfterTheFactAcquisitionProcess process; | ||
| try { | ||
| process = AfterTheFactAcquisitionProcess.createNewAfterTheFactAcquisitionProcess(bean); | ||
| } catch (DomainException e) { | ||
| throw newApplicationError(Status.PRECONDITION_FAILED, "precondition_failed", e.getLocalizedMessage()); | ||
| } | ||
| JsonObject obj = new JsonObject(); | ||
| obj.addProperty("processID", process.getProcessNumber()); | ||
|
|
||
| return gson.toJson(obj); | ||
| } | ||
|
|
||
| //change to put | ||
| @GET | ||
| @Produces(JSON_UTF8) | ||
| @Path("cancelFundAllocation") | ||
| public String cancelFundAllocation(@QueryParam("processID") String processID) { | ||
| WorkflowSystem ws = WorkflowSystem.getInstance(); | ||
| Set<WorkflowProcess> processes = ws.getProcessesSet(); | ||
| for (WorkflowProcess workflowProcess : processes) { | ||
| if (workflowProcess.getProcessNumber() != null) { | ||
| if (workflowProcess.getProcessNumber().equals(processID)) { | ||
| WorkflowActivity<WorkflowProcess, ActivityInformation<WorkflowProcess>> cancelAcquisitionRequest = | ||
| workflowProcess.getActivity(DeleteAfterTheFactAcquisitionProcess.class.getSimpleName()); | ||
| if (cancelAcquisitionRequest == null) { //is not after the fact | ||
| cancelAcquisitionRequest = workflowProcess.getActivity(CancelAcquisitionRequest.class.getSimpleName()); | ||
| } | ||
| try { | ||
| cancelAcquisitionRequest.execute(new ActivityInformation<WorkflowProcess>(workflowProcess, | ||
| cancelAcquisitionRequest)); | ||
| } catch (Exception e) { | ||
| throw newApplicationError(Status.NOT_ACCEPTABLE, "cancelation_not_acceptable", e.getLocalizedMessage()); | ||
| } | ||
| JsonObject obj = new JsonObject(); | ||
| obj.addProperty("status", Status.OK.toString()); | ||
| return gson.toJson(obj); | ||
| } | ||
| } | ||
| } | ||
| //No process was found | ||
| throw newApplicationError(Status.NOT_FOUND, "resource_not_found", "Can't find the process : " + processID); | ||
| } | ||
|
|
||
| private WebApplicationException newApplicationError(Status status, String error, String description) { | ||
| JSONObject errorObject = new JSONObject(); | ||
| errorObject.put("error", error); | ||
| errorObject.put("description", description); | ||
| return new WebApplicationException(Response.status(status).entity(errorObject.toJSONString()).build()); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.