package fine;
|
|
import java.io.File;
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import org.activiti.engine.task.Task;
|
|
import process.service.IServiceCaller;
|
import process.service.IdentityService;
|
import process.service.TaskService;
|
import process.service.HistoryService;
|
import foundation.callable.Callable;
|
import foundation.config.Configer;
|
import foundation.data.Entity;
|
import foundation.data.EntitySet;
|
import foundation.data.Variant;
|
import foundation.file.download.ClientAction;
|
import foundation.file.download.HttpResponseWriter;
|
import foundation.persist.DataHandler;
|
import foundation.persist.sql.NamedSQL;
|
import foundation.persist.sql.SQLRunner;
|
|
public class BusinessConsole extends Callable implements IServiceCaller {
|
|
private TaskService taskService;
|
private HistoryService historyService;
|
private IdentityService identityService;
|
|
|
public BusinessConsole() throws Exception {
|
taskService = new TaskService(this);
|
historyService = new HistoryService(this);
|
identityService = new IdentityService(this);
|
}
|
|
@Override
|
protected void publishMethod() {
|
addMethod("getTodoAgreement");
|
addMethod("newAgreementVersion");
|
addMethod("approveAgreement");
|
addMethod("preview");
|
addMethod("getMyHistotyApprove");
|
addMethod("startProcess");
|
}
|
|
protected void startProcess() throws Exception {
|
Variant dataId = getParameter("id");
|
// type = tablename e.g. agreement
|
String tableName = getParameter("type").getStringValue();
|
Entity entity = DataHandler.getLine(tableName, dataId.getStringValue());
|
String typecode = entity.getString("typecode");
|
dataPool.addParameter("typecode", typecode);
|
|
if (tableName.equalsIgnoreCase("feeslit")) {
|
calculateRebate(tableName,dataId.getStringValue(),typecode,4);
|
|
}
|
String processInstanceId = identityService.startProcess();
|
|
NamedSQL updateNamedSQL = NamedSQL.getInstance("updateById");
|
String fieldNameValues = "workflowId = '" + processInstanceId + "',statuscode='commit'";
|
updateNamedSQL.setParam("tablename", tableName);
|
updateNamedSQL.setParam("fieldNameId", "id");
|
updateNamedSQL.setParam("id", "'"+dataId+"'");
|
updateNamedSQL.setParam("fieldNameValues", fieldNameValues);
|
updateNamedSQL.exec();
|
}
|
|
|
private void calculateRebate(String tableName, String dataId, String typecode,int scale) throws Exception {
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-DD");
|
EntitySet freelitdetailEntitySet = DataHandler.getDataSet(tableName+"detail", "parentid="+dataId);
|
List<Entity> agreementList = new ArrayList<Entity>();
|
|
for (Entity feesLitDetail: freelitdetailEntitySet) {
|
|
//1. update salesflow_month qty
|
String flowId = feesLitDetail.getString("flowid");
|
Entity salesflowMonth = DataHandler.getLine("salesflow_month", flowId);
|
|
BigDecimal qty = feesLitDetail.getBigDecimal("qty");
|
BigDecimal qtyBook = salesflowMonth.getBigDecimal("qty_book");
|
BigDecimal qtyAvailable = salesflowMonth.getBigDecimal("qty_available");
|
BigDecimal qtyUsed = salesflowMonth.getBigDecimal("qty_used");
|
BigDecimal qty_available = qtyAvailable.subtract(qty).subtract(qtyUsed);
|
qtyBook = qtyBook.add(qty);
|
salesflowMonth.set("qty_book", qtyBook);
|
salesflowMonth.set("qty_available", qty_available);
|
DataHandler.updateLine(salesflowMonth);
|
|
//2. calculate rebate
|
|
String agentId = feesLitDetail.getString("agentid");
|
String productId = feesLitDetail.getString("productid");
|
Integer flowYear = feesLitDetail.getInteger("flowyear");
|
Integer flowMonth = feesLitDetail.getInteger("flowmonth");
|
|
EntitySet agreementEntitySet = DataHandler.getDataSet("agreement", "1=1");
|
|
for (Entity agreement : agreementEntitySet) {
|
String statusCode = agreement.getString("statuscode");
|
|
if (statusCode.equalsIgnoreCase("open")) {
|
String agreementTypeCode = agreement.getString("typecode");
|
String agreementAgentId = agreement.getString("agentid");
|
|
if (agreementTypeCode.equalsIgnoreCase(typecode) && agreementAgentId.equalsIgnoreCase(agentId)) {
|
int startYear = Integer.valueOf(dateFormat.format(agreement.getDate("begindate")).split("-")[0]);
|
int startMonth = Integer.valueOf(dateFormat.format(agreement.getDate("begindate")).split("-")[1]);
|
int endYear = Integer.valueOf(dateFormat.format(agreement.getDate("enddate")).split("-")[0]);
|
int endMonth = Integer.valueOf(dateFormat.format(agreement.getDate("enddate")).split("-")[1]);
|
|
if (flowYear >= startYear && flowYear < endYear || flowYear >= startYear && flowYear == endYear && flowMonth >= startMonth && flowMonth <= endMonth) {
|
agreementList.add(agreement);
|
}
|
}
|
}
|
}
|
// size >1 means bad info
|
if (agreementList.size() > 1) {
|
return ;
|
}
|
Entity agrement = agreementList.get(0);
|
EntitySet agreementFineDetailEntitySet = DataHandler.getDataSet("agreementfinedetail", "parentid="+agrement.getString("id"));
|
|
for (Entity agreementFineDetail : agreementFineDetailEntitySet) {
|
String agreementProductid = agreementFineDetail.getString("productid");
|
|
if (agreementProductid.equalsIgnoreCase(productId)) {
|
//1. linked agreementFineDetail and feesLitDetail
|
String agreementFineDetailId = agreementFineDetail.getString("id");
|
feesLitDetail.setString("agreementfinedetailid", agreementFineDetailId);
|
|
//2.calculate
|
if (typecode.equalsIgnoreCase("PurchaseAndSale")) {
|
BigDecimal priceLowest = new BigDecimal(agreementFineDetail.getString("price_lowest"));
|
BigDecimal priceInvoice = new BigDecimal(agreementFineDetail.getString("price_invoice"));
|
BigDecimal rateTax = new BigDecimal(agreementFineDetail.getString("rate_tax"));
|
|
BigDecimal singleRebate = priceInvoice.subtract(priceLowest);
|
BigDecimal preTaxPendingRebate = qty.multiply(singleRebate);
|
BigDecimal taxBigDecimal = BigDecimal.valueOf(1).subtract(rateTax);
|
BigDecimal pendingRebate = preTaxPendingRebate.multiply(taxBigDecimal).setScale(scale);
|
feesLitDetail.set("price_rebate", pendingRebate);
|
}
|
else if (typecode.equalsIgnoreCase("others")) {
|
//TODO other type
|
}
|
DataHandler.updateLine(feesLitDetail);
|
}
|
}
|
}
|
|
|
|
}
|
|
protected void getMyHistotyApprove() throws Exception {
|
|
ArrayList<Entity> result = new ArrayList<Entity>();
|
EntitySet entitySet = DataHandler.getDataSet("agreement", "1=1");
|
List<String> myHistotyApprove = historyService.getMyHistotyApprove();
|
|
for (Entity entity : entitySet) {
|
String id = entity.getString("workflowid");
|
if (myHistotyApprove.contains(id)) {
|
result.add(entity);
|
}
|
}
|
resultPool.addValue(result);
|
}
|
|
protected void getTodoAgreement() throws Exception {
|
|
ArrayList<Entity> result = new ArrayList<Entity>();
|
String filter = getParameter("filter").getStringValue();
|
EntitySet entitySet = DataHandler.getDataSet("agreement", filter);
|
List<String> todoTaskId = taskService.getTodoTask();
|
|
for (Entity entity : entitySet) {
|
String id = entity.getString("id");
|
if (todoTaskId.contains(id)) {
|
result.add(entity);
|
}
|
}
|
resultPool.addValue(result);
|
}
|
|
protected void newAgreementVersion() throws Exception {
|
identityService.startProcess();
|
}
|
|
protected void approveAgreement() throws Exception {
|
Variant dataId = getParameter("id");
|
Variant isReset = getParameter("isReset");
|
String tableName = getParameter("type").getStringValue();
|
|
|
//1.claim
|
String taskid = taskService.claimTask();
|
if (taskid == null) {
|
return;
|
}
|
|
dataPool.addParameter("taskid", taskid);
|
|
//2.complete
|
boolean success = taskService.completeTask();
|
if (!success) {
|
return;
|
}
|
|
if (isReset.getBooleanValue()) {
|
NamedSQL namedSQL = NamedSQL.getInstance("updateTableStatusCodeById");
|
namedSQL.setParam("statuscode", "commit");
|
namedSQL.setParam("id", dataId.getStringValue());
|
namedSQL.setParam("tablename", tableName);
|
namedSQL.exec();
|
}
|
|
Task task = taskService.geTask();
|
if(task != null && task.getTaskDefinitionKey().equalsIgnoreCase("modifyApply")) {
|
NamedSQL namedSQL = NamedSQL.getInstance("updateTableStatusCodeById");
|
namedSQL.setParam("id", dataId.getStringValue());
|
namedSQL.setParam("tablename", tableName);
|
namedSQL.setParam("statuscode", "isReset");
|
namedSQL.exec();
|
}
|
|
|
//3.update status
|
if (historyService.isTaskFinished()) {
|
NamedSQL namedSQL = NamedSQL.getInstance("updateTableStatusCodeById");
|
namedSQL.setParam("id", dataId.getStringValue());
|
namedSQL.setParam("tablename", tableName);
|
if (getParameter("passFlag").getStringValue().equalsIgnoreCase("false")) {
|
namedSQL.setParam("statuscode", "close");
|
}else {
|
namedSQL.setParam("statuscode", "open");
|
}
|
namedSQL.exec();
|
}
|
|
resultPool.success();
|
}
|
|
protected void preview() throws Exception {
|
Variant code = dataPool.getParameter("code");
|
|
NamedSQL namedSQL = NamedSQL.getInstance("getApplicationTemplatePath");
|
namedSQL.setParam("code", code.getStringValue());
|
String path = SQLRunner.getString(namedSQL);
|
String root = Configer.getParam("applicationTemplateRoot");
|
|
File file = new File(root, path);
|
|
if (!file.exists()) {
|
resultPool.error("file not exists: " + file);
|
return;
|
}
|
|
HttpResponseWriter writer = new HttpResponseWriter(response);
|
writer.write(file, ClientAction.AsPDF);
|
}
|
|
@Override
|
public void error(String error) {
|
resultPool.error(error);
|
}
|
|
@Override
|
public Variant getParameter(String name) {
|
return dataPool.getParameter(name);
|
}
|
}
|
