package com.changhong.epc.parsing.service.bill.impl;
|
|
import com.changhong.epc.bean.form.CpnVal;
|
import com.changhong.epc.bean.form.Fieldsets;
|
import com.changhong.epc.bean.form.FormBaseEntity;
|
import com.changhong.epc.bean.parsing.BillInfo;
|
import com.changhong.epc.bean.parsing.BillLevel;
|
import com.changhong.epc.bean.tenant.bill.OCRBillEntity;
|
import com.changhong.epc.bean.tenant.bill.OCRBillHeaderEntity;
|
import com.changhong.epc.bean.tenant.system.extend.ErrSystemMsgExtend;
|
import com.changhong.epc.constter.form.FormConst;
|
import com.changhong.epc.constter.system.SystemClients;
|
import com.changhong.epc.parsing.service.bill.cpnval.IBillToCpnValData;
|
import com.changhong.epc.parsing.service.bill.cpnval.imp.BillToCpnValData;
|
import com.changhong.epc.parsing.service.bill.group.AbstractGroupBill;
|
import com.changhong.epc.parsing.service.util.BillTool;
|
import com.changhong.epc.parsing.service.util.IFromOperate;
|
import com.iemsoft.framework.cloud.core.exception.IEMRuntimeException;
|
import com.iemsoft.framework.cloud.core.tools.JSONTool;
|
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.context.annotation.Scope;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
|
@Slf4j
|
@Service("autoAllotJourney")
|
@Scope("prototype")
|
public class AutoAllotJourneyImpl extends AbstractGroupBill implements SystemClients, FormConst{
|
|
private OCRBillEntity bill;
|
private OCRBillEntity oldBill;
|
|
@Resource
|
private IFromOperate fromOperate;
|
|
private IBillToCpnValData<List<BillLevel>> allotJourney = new BillToCpnValData();
|
/**
|
* 分配行程入口
|
* @param bill
|
* @param billInfo
|
* @return
|
*/
|
@Override
|
@Transactional
|
public Fieldsets addBillInfo(OCRBillEntity bill, BillInfo billInfo) {
|
//未实现 -> 检查是否可分配行程（根据规则检查信息）
|
// int pNum = getPDataRowNum(billInfo.getFormId(),JSONTool.toObj(billInfo.getInfo(), Map.class).get("tenantId"),billInfo.getOrderCode());
|
// billInfo.setFormDataId(pNum);
|
// System.out.println("票据列表："+JSONTool.toJson(bill.getBillDatas()));
|
billInfoCheck(bill);
|
// System.out.println(JSONTool.toJson(bill));
|
/*
|
* 分配行程
|
*/
|
OCRBillEntity cloneBill;
|
|
//yuezhw 18.1.2,扩展实体,加一个formId;
|
bill.setFormId(billInfo.getFormId());
|
this.bill = bill;
|
|
this.oldBill = JSONTool.toObj(JSONTool.toJson(bill), OCRBillEntity.class);
|
|
mappingJourney(billInfo);
|
cloneBill = resultOCRBillEntity();
|
insertBillData(billInfo, cloneBill);
|
|
return getFieldsets();
|
}
|
|
@Override
|
public OCRBillEntity resultOCRBillEntity() {
|
return getOCRBillEntity();
|
}
|
|
@Override
|
public List<ErrSystemMsgExtend> getRecordErrCode() {
|
return null;
|
}
|
|
@Override
|
protected void editJourney(BillInfo billInfo) {
|
FormBaseEntity formAll = fromOperate.selectFromAll(billInfo);
|
allotJourney.setDatSource(blAll,formAll);
|
allotJourney.analysisSource();
|
String tenantId = Objects.toString(JSONTool.toObj(billInfo.getInfo(), Map.class).get("tenantId"),"0");
|
|
// 获得已经处理 全部行程
|
List<List<CpnVal>> allJourneyCpn = allotJourney.getAllJourneyCpn();
|
// 获得行程子表单
|
CpnVal journeySubForm = allotJourney.getJourneySubForm();
|
/**
|
* 删除之前的行程数据
|
*/
|
try {
|
fromOperate.deleteFormData(billInfo, journeySubForm);
|
} catch (Exception e) {
|
log.error("调用自定表单删除接口失败 ！\n\n\n");
|
}
|
try {
|
if(ObjectUtil.empty(allJourneyCpn)){
|
log.debug("行程为空");
|
}else {
|
//向子表单添加行程
|
List<Integer> insertCpnVal = fromOperate.insertCpnVal(billInfo, journeySubForm, allJourneyCpn);
|
log.debug("获得所有行程的行程ID" + Arrays.toString(insertCpnVal.toArray()));
|
/**
|
* 为每一张票据添加行程ID
|
*/
|
allotJourney.setEachBillJourneyId(insertCpnVal);
|
}
|
|
} catch (Exception e) {
|
|
log.debug("调用自定表单删除接口失败 ！\n\n\n");
|
throw new IEMRuntimeException("E0100","调用Form自定表单插入接口失败 ！");
|
}
|
|
}
|
|
// @Override
|
// protected void setCityBill() {
|
// List<OCRBillHeaderEntity> allBill = getOCRBillEntity().getBillDatas();
|
// splitCityBodyBill(allBill);
|
// super.setCityBill();
|
// }
|
|
/**
|
* 拆分body中的城市间交通费
|
* @param allBill
|
*/
|
protected void splitCityBodyBill(List<OCRBillHeaderEntity> allBill){
|
|
List<OCRBillHeaderEntity> cityBodyBills = new ArrayList<>();
|
// 获得城市间交通费在body中的。
|
Iterator<OCRBillHeaderEntity> ite = allBill.listIterator();
|
while(ite.hasNext()){
|
OCRBillHeaderEntity ocrBillHeaderEntity = ite.next();
|
if(BillTool.isJourneyBill(ocrBillHeaderEntity)
|
&& ObjectUtil.notEmpty(ocrBillHeaderEntity.getBillBodyEntityList())){
|
cityBodyBills.add(ocrBillHeaderEntity);
|
ite.remove();
|
}
|
}
|
if(ObjectUtil.empty(cityBodyBills)){
|
return;
|
}
|
cityBodyBills.stream().forEach(cityBodyBill->allBill.addAll(BillTool.splitBody(cityBodyBill)));
|
}
|
|
@Override
|
protected OCRBillEntity getOCRBillEntity() {
|
return bill;
|
}
|
|
@Override
|
protected OCRBillEntity getOldOCRBillEntity() {
|
return oldBill;
|
}
|
|
public Fieldsets getFieldsets() {
|
return fieldsets;
|
}
|
|
// public int getPDataRowNum(String formId,Object tenantId,String orderCode){
|
// Map<String,Object> map = new HashMap<>();
|
// map.put("formId", formId);
|
// map.put("tenantId", tenantId);
|
// map.put("orderCode", orderCode);
|
// RestInterface restInterface = SpringUtil.getBean(SERVER_FORM.getBeanName(), RestInterface.class);
|
// Object fromRest = restInterface.post(FormUrlConst.SELECT_DATAROWNUM, map, ResMsg.class).getData();
|
// return Integer.parseInt(java.util.Objects.toString(fromRest,"0"));
|
// }
|
}
|
