package com.changhong.epc.count.service.count.data.condition.impl;
|
|
import com.changhong.epc.bean.tenant.norm.extend.AppStanderExtend;
|
import com.changhong.epc.bean.tenant.norm.extend.SuppStanderExtend;
|
import com.changhong.epc.count.service.count.data.condition.ICountConditionIter;
|
import com.changhong.epc.count.service.count.execution.ICounter;
|
import com.changhong.epc.count.service.count.execution.impl.FuncCountImpl;
|
import com.changhong.epc.count.service.count.execution.impl.SimpleCounterImpl;
|
import com.changhong.epc.count.service.count.model.AmountKey;
|
import com.changhong.epc.count.service.count.model.UnitInfo;
|
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
|
import com.iemsoft.framework.cloud.core.tools.SpringUtil;
|
import org.springframework.context.annotation.Scope;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
|
/**
|
* 补助标准 数据迭代器
|
* @author wangZX
|
*
|
*/
|
@Service("countConditionIter")
|
@Scope("prototype")
|
public class CountConditionIterImpl implements ICountConditionIter<AppStanderExtend, SuppStanderExtend, UnitInfo>{
|
|
private List<SuppStanderExtend> suppStanderExtend;
|
|
private Iterator<SuppStanderExtend> groupIterator;
|
|
@Override
|
public CountConditionIterImpl setDataSource(List<SuppStanderExtend> data) {
|
if(data == null) return this;
|
suppStanderExtend = data;
|
|
init( data);
|
groupIterator = suppStanderExtend.iterator();
|
return this;
|
}
|
|
/**
|
* 将原始数据转换为可用数据
|
* @param data
|
*/
|
private void init(List<SuppStanderExtend> data) {
|
if(ObjectUtil.empty(data)){
|
return;
|
}
|
// 迭代每一大块
|
for (SuppStanderExtend supp : data) {
|
// 按照行号,分为补助,标准,金额,转换为二维矩阵
|
// System.err.println(JSONTool.toJson(supp));
|
Map<Integer,List<AppStanderExtend>> matrix = new HashMap<>();
|
for (AppStanderExtend appslist : supp.getAppStanderDefs()) {
|
// System.err.println(JSONTool.toJson(appslist));
|
if( matrix.get(appslist.getRowNo()) == null){
|
List<AppStanderExtend> temp = new ArrayList<>();
|
matrix.put(appslist.getRowNo(), temp);
|
}
|
matrix.get(appslist.getRowNo()).add(appslist);
|
}
|
MapToMatrix(supp,matrix);
|
}
|
// System.out.println(JSONTool.toJson(suppStanderExtend));
|
// System.out.println("将原始数据转换为可用数据");
|
}
|
|
private void MapToMatrix(SuppStanderExtend supp, Map<Integer, List<AppStanderExtend>> matrix) {
|
// System.out.println(JSONTool.toJson(supp));
|
List<List<AppStanderExtend>> matrixList = new ArrayList<>();
|
for (Integer colKey : matrix.keySet()) {
|
matrixList.add(matrix.get(colKey));
|
}
|
supp.setAppStanderDefMatrix(matrixList);
|
// System.out.println(JSONTool.toJson(supp));
|
}
|
|
@Override
|
public Boolean hasGropNext() {
|
return groupIterator !=null && groupIterator.hasNext();
|
}
|
private SuppStanderExtend currGroup;
|
List<List<AppStanderExtend>> appStanderDefTwe;
|
Iterator<List<AppStanderExtend>> rowIterator;
|
|
@Override
|
public void initGroup(){
|
appStanderDefTwe = currGroup.getAppStanderDefMatrix();
|
initRow();
|
}
|
|
@Override
|
public void groupNext() {
|
currGroup = groupIterator.next();
|
initGroup();
|
return ;
|
}
|
|
@Override
|
public SuppStanderExtend getCurrGroup() {
|
countEachSuppStanderCount(currGroup);
|
|
|
return currGroup;
|
}
|
|
|
@Override
|
public void gropReset() {
|
if(suppStanderExtend == null)
|
return ;
|
groupIterator = suppStanderExtend.iterator();
|
}
|
|
/***********************************************************************/
|
|
@Override
|
public void initRow(){
|
rowIterator = appStanderDefTwe.iterator();
|
}
|
|
@Override
|
public Boolean hasRowNext() {
|
return rowIterator.hasNext();
|
}
|
|
List<AppStanderExtend> currRow;
|
Iterator<AppStanderExtend> elem;
|
@Override
|
public void rowNext() {
|
currRow = rowIterator.next();
|
initCol();
|
return ;
|
}
|
|
@Override
|
public List<AppStanderExtend> cruuRow() {
|
return currRow;
|
}
|
|
@Override
|
public void initCol(){
|
elem = currRow.iterator();
|
}
|
|
@Override
|
public Boolean hasColNext() {
|
return elem.hasNext();
|
}
|
|
private AppStanderExtend currElem;
|
|
@Override
|
public AppStanderExtend colNext() {
|
currElem = elem.next();
|
return currElem;
|
}
|
|
@Override
|
public AppStanderExtend cruuCol() {
|
return currElem;
|
}
|
|
@Override
|
public ICounter<AppStanderExtend, UnitInfo> getExeCounter() {
|
return getExeCounter(this.cruuCol());
|
}
|
|
@Override
|
public ICounter<AppStanderExtend, UnitInfo> getExeCounter(AppStanderExtend appStanderExtend){
|
if(appStanderExtend.getDefType() == 5){
|
return SpringUtil.getBean(FuncCountImpl.class);
|
}else{
|
return SpringUtil.getBean(SimpleCounterImpl.class);
|
}
|
}
|
|
private Map<AmountKey, String> amountLastCount = new HashMap<>();
|
|
private void countEachSuppStanderCount(SuppStanderExtend guoup) {
|
if(guoup.getRule() != null
|
&& !Objects.equals(guoup.getRule(), "0")){
|
AmountKey k = new AmountKey();
|
// System.out.println("取值规则是:"+guoup.getRule());
|
k.fylx = guoup.getType(); // mdCode
|
// System.out.println("选择的补助类型:"+guoup.getType());
|
k.bxfs = guoup.getName(); // 报销方式
|
// System.out.println("报销方式是:"+guoup.getName());
|
k.id = String.valueOf(guoup.getId());//表中数据ID
|
// System.out.println("表单ID是:"+guoup.getId());
|
amountLastCount.put(k, guoup.getRule());
|
|
}
|
}
|
|
public Map<AmountKey, String> getRecord(){
|
return amountLastCount;
|
}
|
}
|
