|
@@ -24,8 +24,8 @@ import java.util.stream.Collectors;
|
|
|
public class DataComparisonQueryService {
|
|
public class DataComparisonQueryService {
|
|
|
private static final Log logger = LogFactory.getLog(DataComparisonQueryService.class);
|
|
private static final Log logger = LogFactory.getLog(DataComparisonQueryService.class);
|
|
|
private static final String SINSURTASK = "hcsi_sinsurtask";
|
|
private static final String SINSURTASK = "hcsi_sinsurtask";
|
|
|
- String[] leftFields = new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type", "personSysValue", "companySysValue"};
|
|
|
|
|
- String[] rightFields = new String[]{"personOutValue", "companyOutValue"};
|
|
|
|
|
|
|
+ String[] leftFields = new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type", "personSysValue", "personSysValuea", "companySysValue", "companySysValuea"};
|
|
|
|
|
+ String[] rightFields = new String[]{"personOutValue", "personOutValuea","companyOutValue", "companyOutValuea"};
|
|
|
IDataModel model = null;
|
|
IDataModel model = null;
|
|
|
IFormView view = null;
|
|
IFormView view = null;
|
|
|
public DataComparisonQueryService(IDataModel model,IFormView view) {
|
|
public DataComparisonQueryService(IDataModel model,IFormView view) {
|
|
@@ -97,17 +97,17 @@ public class DataComparisonQueryService {
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
public DataSet groupCalPersonDetail (DataSet calPersonDataSet) {
|
|
public DataSet groupCalPersonDetail (DataSet calPersonDataSet) {
|
|
|
- calPersonDataSet.groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value");
|
|
|
|
|
|
|
+ calPersonDataSet.groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value").sum("value1");
|
|
|
DataSet dataSet1 = calPersonDataSet.copy();
|
|
DataSet dataSet1 = calPersonDataSet.copy();
|
|
|
DataSet dataSet2 = calPersonDataSet.copy();
|
|
DataSet dataSet2 = calPersonDataSet.copy();
|
|
|
|
|
|
|
|
// 按照类型分组汇总
|
|
// 按照类型分组汇总
|
|
|
- DataSet sumSet1 = dataSet1.filter("type = '1'").groupBy(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type"}).sum("value").finish();
|
|
|
|
|
- DataSet sumSet2 = dataSet2.filter("type = '2'").groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value").finish();
|
|
|
|
|
|
|
+ DataSet sumSet1 = dataSet1.filter("type = '1'").groupBy(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type"}).sum("value").sum("value1").finish();
|
|
|
|
|
+ DataSet sumSet2 = dataSet2.filter("type = '2'").groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value").sum("value1").finish();
|
|
|
|
|
|
|
|
// join
|
|
// join
|
|
|
JoinDataSet joinDataSet = sumSet1.join(sumSet2).on("welfarepayer", "welfarepayer").on("welfaretypeid", "welfaretypeid").on("empnumber", "empnumber").on("empname", "empname").on("empidcard", "empidcard");
|
|
JoinDataSet joinDataSet = sumSet1.join(sumSet2).on("welfarepayer", "welfarepayer").on("welfaretypeid", "welfaretypeid").on("empnumber", "empnumber").on("empname", "empname").on("empidcard", "empidcard");
|
|
|
- DataSet dataSet = joinDataSet.select(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type", "value as personSysValue"}, new String[]{"value as companySysValue"}).finish();
|
|
|
|
|
|
|
+ DataSet dataSet = joinDataSet.select(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type", "value as personSysValue","value1 as personSysValuea"}, new String[]{"value as companySysValue","value1 as companySysValuea"}).finish();
|
|
|
|
|
|
|
|
return dataSet;
|
|
return dataSet;
|
|
|
}
|
|
}
|
|
@@ -126,17 +126,17 @@ public class DataComparisonQueryService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public DataSet groupCalPersonDetailOut (DataSet calPersonDataSet) {
|
|
public DataSet groupCalPersonDetailOut (DataSet calPersonDataSet) {
|
|
|
- calPersonDataSet.groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value");
|
|
|
|
|
|
|
+ calPersonDataSet.groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value").sum("value1");
|
|
|
DataSet dataSet1 = calPersonDataSet.copy();
|
|
DataSet dataSet1 = calPersonDataSet.copy();
|
|
|
DataSet dataSet2 = calPersonDataSet.copy();
|
|
DataSet dataSet2 = calPersonDataSet.copy();
|
|
|
|
|
|
|
|
// 按照类型分组汇总
|
|
// 按照类型分组汇总
|
|
|
- DataSet sumSet1 = dataSet1.filter("type = '1'").groupBy(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type"}).sum("value").finish();
|
|
|
|
|
- DataSet sumSet2 = dataSet2.filter("type = '2'").groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value").finish();
|
|
|
|
|
|
|
+ DataSet sumSet1 = dataSet1.filter("type = '1'").groupBy(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type"}).sum("value").sum("value1").finish();
|
|
|
|
|
+ DataSet sumSet2 = dataSet2.filter("type = '2'").groupBy(new String[]{"welfarepayer","welfaretypeid","empnumber","empname","empidcard","type"}).sum("value").sum("value1").finish();
|
|
|
|
|
|
|
|
// join
|
|
// join
|
|
|
JoinDataSet joinDataSet = sumSet1.join(sumSet2).on("welfarepayer", "welfarepayer").on("welfaretypeid", "welfaretypeid").on("empnumber", "empnumber").on("empname", "empname").on("empidcard", "empidcard");
|
|
JoinDataSet joinDataSet = sumSet1.join(sumSet2).on("welfarepayer", "welfarepayer").on("welfaretypeid", "welfaretypeid").on("empnumber", "empnumber").on("empname", "empname").on("empidcard", "empidcard");
|
|
|
- DataSet dataSet = joinDataSet.select(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type", "value as personOutValue"}, new String[]{"value as companyOutValue"}).finish();
|
|
|
|
|
|
|
+ DataSet dataSet = joinDataSet.select(new String[]{"welfarepayer", "welfaretypeid", "empnumber", "empname", "empidcard", "type", "value as personOutValue", "value1 as personOutValuea"}, new String[]{"value as companyOutValue","value1 as companyOutValuea"}).finish();
|
|
|
|
|
|
|
|
return dataSet;
|
|
return dataSet;
|
|
|
}
|
|
}
|