package target;
|
|
import java.util.Calendar;
|
|
import foundation.action.ActionProvider;
|
import foundation.dao.DataPackage;
|
import foundation.dao.DataSource;
|
import foundation.dao.Filter;
|
import foundation.data.entity.Entity;
|
import foundation.data.entity.EntitySet;
|
import foundation.data.object.DataObject;
|
import foundation.io.IOContext;
|
import foundation.persist.NamedSQL;
|
import foundation.persist.SQLRunner;
|
|
public class TargetHandler extends ActionProvider {
|
|
@Override
|
protected void publishMethod() {
|
//1. 指标计算
|
addMethod("targetCalculate");
|
|
//2. 经销商指标汇总
|
addMethod("dealerTargetCollection");
|
}
|
|
public void targetCalculate() throws Exception {
|
String targetTypeCode = context.getParam();
|
TargetType targetType = TargetType.parse(targetTypeCode);
|
targetType.loadPackage();
|
SQLRunner.beginTrans();
|
|
try {
|
//1. 删除本年度指标计算
|
Calendar calendar = Calendar.getInstance();
|
|
DataObject dataObject = DataObject.getInstance("business_data_summary");
|
Filter filter = new Filter();
|
filter.add("title_code", targetType.getCode());
|
filter.add("year", calendar.get(Calendar.YEAR));
|
dataObject.deleteEntity(filter);
|
|
NamedSQL namedSQL = NamedSQL.getInstance("summaryMonthTarget");
|
namedSQL = setParams(namedSQL, targetType);
|
|
//1. 分岗位汇总月度（有指标）
|
for (int i = 1; i <= 12; i++) {
|
String month = "_m" + i;
|
namedSQL.setParam("monthAmtTarget", "amt" + month);
|
namedSQL.setParam("monthQtyTarget", "qty" + month);
|
namedSQL.setParam("month", i);
|
|
SQLRunner.execSQL(namedSQL);
|
|
}
|
|
//2. 分岗位汇总月度（无指标）
|
namedSQL = NamedSQL.getInstance("summaryMonthAchieveWithoutTarget");
|
namedSQL = setParams(namedSQL, targetType);
|
|
for (int i = 1; i <= 12; i++) {
|
String month = "_m" + i;
|
namedSQL.setParam("monthAmtTarget", "amt" + month);
|
namedSQL.setParam("monthQtyTarget", "qty" + month);
|
namedSQL.setParam("month", i);
|
|
SQLRunner.execSQL(namedSQL);
|
|
}
|
|
//3. 汇总季度
|
namedSQL = NamedSQL.getInstance("summarySeasonTarget");
|
namedSQL.setParam("code", targetType.getCode());
|
SQLRunner.execSQL(namedSQL);
|
|
//4. 汇总年度
|
namedSQL = NamedSQL.getInstance("summaryYearTarget");
|
namedSQL.setParam("code", targetType.getCode());
|
SQLRunner.execSQL(namedSQL);
|
}catch (Exception e) {
|
SQLRunner.rollback();
|
return ;
|
}
|
|
SQLRunner.commit();
|
}
|
|
public void dealerTargetCollection() throws Exception {
|
String targetTable;
|
DataObject dataObject;
|
TargetType targetType;
|
|
NamedSQL namedSQL = NamedSQL.getInstance("getAuthorizeDealer");
|
Filter filter = new Filter();
|
String operator = dataReader.getOperator();
|
|
if ("importData".equalsIgnoreCase(operator)) {
|
//2. from import
|
IOContext ioContext = context.getContext(IOContext.class);
|
String ioBatchId = ioContext.getIoBatchId();
|
filter.add("io_batch_id", ioBatchId);
|
|
targetTable = context.getDataName();
|
String tempDataName = "temp_" + targetTable;
|
dataObject = DataObject.getInstance(tempDataName);
|
|
|
targetType = TargetType.parseByTableName(targetTable);
|
|
NamedSQL checkImportError = NamedSQL.getInstance("importGetImportErrors");
|
checkImportError.setParam("ioBatchId", ioBatchId);
|
checkImportError.setParam("toTempTable", tempDataName);
|
EntitySet errorSet = checkImportError.getEntitySet();
|
|
if (!errorSet.isEmpty()) {
|
return;
|
}
|
}
|
else {
|
//1. from request
|
DataPackage dataPackage = dataReader.getDataPackage();
|
Entity master = dataPackage.getMasterEntity(DataSource.Request);
|
|
filter.add("temp_md_target_dealer_hospital.hospital_id", master.getString("hospital_id"));
|
filter.add("year", master.getString("year"));
|
|
dataObject = dataPackage.getMasterDataObject();
|
targetTable = dataObject.getTableName();
|
targetType = TargetType.parseByTableName(targetTable);
|
}
|
|
namedSQL.setFilter(filter);
|
namedSQL.setParam("targetTable", dataObject.getTableName());
|
EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
|
|
dataObject = DataObject.getInstance("md_target_dealer");
|
for (Entity entity: entitySet) {
|
SQLRunner.beginTrans();
|
|
try {
|
String orgId = entity.getString("org_id");
|
String buId = entity.getString("bu_id");
|
String companyId = entity.getString("company_id");
|
String year = entity.getString("year");
|
|
Filter deleteFilter = new Filter();
|
deleteFilter.add("org_id", orgId);
|
deleteFilter.add("bu_id", buId);
|
deleteFilter.add("company_id", companyId);
|
deleteFilter.add("year", year);
|
deleteFilter.add("type_code", targetType.getCode());
|
dataObject.deleteEntity(deleteFilter);
|
|
namedSQL = NamedSQL.getInstance("collectDealerTarget");
|
namedSQL.setParam("typeCode", targetType.getCode());
|
namedSQL.setParam("typeName", targetType.getName());
|
namedSQL.setParam("targetTable", targetTable);
|
namedSQL.setParam("orgId", orgId);
|
namedSQL.setParam("buId", buId);
|
namedSQL.setParam("companyId", companyId);
|
namedSQL.setParam("year", year);
|
EntitySet dealerTargets = SQLRunner.getEntitySet(namedSQL);
|
|
for (Entity oneDealerTarget: dealerTargets) {
|
dataObject.saveEntity(oneDealerTarget);
|
}
|
|
}catch (Exception e) {
|
SQLRunner.rollback();
|
}
|
|
SQLRunner.commit();
|
}
|
|
}
|
|
private NamedSQL setParams(NamedSQL namedSQL, TargetType targetType) throws Exception {
|
namedSQL.setParam("code", targetType.getCode());
|
namedSQL.setParam("name", targetType.getName());
|
namedSQL.setParam("joinSql", targetType.getJoinSql());
|
namedSQL.setParam("amtAchieve", targetType.getAmtField());
|
namedSQL.setParam("qtyAchieve", targetType.getQtyField());
|
namedSQL.setParam("targetTable", targetType.getTableName());
|
namedSQL.setParam("positionTable", targetType.getPositionTable());
|
namedSQL.setParam("document", targetType.getDocument());
|
namedSQL.setParam("documentDetail", targetType.getDocumentDetail());
|
namedSQL.setParam("documentPosition", targetType.getDocumentPosition());
|
|
return namedSQL;
|
}
|
|
}
|
