Skip to content

I
iBiz商业中心
提交 06a9440c 编写于 作者: yujiaming's avatar yujiaming
浏览文件
操作

calc_price, product_change行为

上级 fc0ca110
隐藏空白字符变更
内嵌 并排
正在显示 包含 448 行增加 和 0 行删除
businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/extensions/service/Purchase_order_lineExService.java
浏览文件 @ 06a9440c
package cn.ibizlab.businesscentral.core.extensions.service; package cn.ibizlab.businesscentral.core.extensions.service;
import cn.ibizlab.businesscentral.core.odoo_account.domain.Account_account_tag;
import cn.ibizlab.businesscentral.core.odoo_account.domain.Account_fiscal_position;
import cn.ibizlab.businesscentral.core.odoo_account.domain.Account_tax;
import cn.ibizlab.businesscentral.core.odoo_base.domain.Res_company;
import cn.ibizlab.businesscentral.core.odoo_base.domain.Res_currency;
import cn.ibizlab.businesscentral.core.odoo_base.domain.Res_lang;
import cn.ibizlab.businesscentral.core.odoo_base.domain.Res_partner;
import cn.ibizlab.businesscentral.core.odoo_product.domain.Product_product;
import cn.ibizlab.businesscentral.core.odoo_product.domain.Product_supplier_taxes_rel;
import cn.ibizlab.businesscentral.core.odoo_product.domain.Product_supplierinfo;
import cn.ibizlab.businesscentral.core.odoo_product.domain.Product_template;
import cn.ibizlab.businesscentral.core.odoo_purchase.domain.Purchase_order;
import cn.ibizlab.businesscentral.core.odoo_purchase.service.impl.Purchase_order_lineServiceImpl; import cn.ibizlab.businesscentral.core.odoo_purchase.service.impl.Purchase_order_lineServiceImpl;
import cn.ibizlab.businesscentral.util.dict.StaticDict;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import cn.ibizlab.businesscentral.core.odoo_purchase.domain.Purchase_order_line; import cn.ibizlab.businesscentral.core.odoo_purchase.domain.Purchase_order_line;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.context.annotation.Primary; import org.springframework.context.annotation.Primary;
import java.math.BigDecimal;
import java.sql.Timestamp;
import java.util.*; import java.util.*;
/** /**
...@@ -16,6 +37,24 @@ import java.util.*; ...@@ -16,6 +37,24 @@ import java.util.*;
@Service("Purchase_order_lineExService") @Service("Purchase_order_lineExService")
public class Purchase_order_lineExService extends Purchase_order_lineServiceImpl { public class Purchase_order_lineExService extends Purchase_order_lineServiceImpl {
@Autowired
private cn.ibizlab.businesscentral.core.odoo_product.service.IProduct_templateService productTemplateService;
@Autowired
private cn.ibizlab.businesscentral.core.odoo_base.service.IRes_langService langService;
@Autowired
private cn.ibizlab.businesscentral.core.odoo_product.service.IProduct_supplier_taxes_relService productSupplierTaxesRelService;
@Autowired
private cn.ibizlab.businesscentral.core.odoo_account.service.IAccount_taxService accountTaxService;
@Autowired
private cn.ibizlab.businesscentral.core.odoo_product.service.IProduct_supplierinfoService supplierinfoService;
@Autowired
private cn.ibizlab.businesscentral.core.odoo_account.service.IAccount_fiscal_positionService accountFiscalPositionService;
@Override @Override
protected Class currentModelClass() { protected Class currentModelClass() {
return com.baomidou.mybatisplus.core.toolkit.ReflectionKit.getSuperClassGenericType(this.getClass().getSuperclass(), 1); return com.baomidou.mybatisplus.core.toolkit.ReflectionKit.getSuperClassGenericType(this.getClass().getSuperclass(), 1);
...@@ -29,6 +68,260 @@ public class Purchase_order_lineExService extends Purchase_order_lineServiceImpl ...@@ -29,6 +68,260 @@ public class Purchase_order_lineExService extends Purchase_order_lineServiceImpl
@Override @Override
@Transactional @Transactional
public Purchase_order_line calc_price(Purchase_order_line et) { public Purchase_order_line calc_price(Purchase_order_line et) {
Map vals = new HashMap();
Purchase_order order = purchaseOrderService.get(et.getOrderId());
vals.put("price_unit", et.getPriceUnit());
vals.put("currency_id", order.getCurrencyId());
vals.put("product_qty", et.getProductQty());
vals.put("product", et.getProductId());
vals.put("partner", order.getPartnerId());
/**
// account.py中的compute_all()方法， 未处理完成
JSONArray jsonArray = JSONArray.parseArray(et.getTaxesId());
Long taxId = jsonArray.getJSONObject(0).getLong("srfkey");
Account_tax accountTax = accountTaxService.get(taxId);
Long companyId = null;
if(accountTax == null){
companyId = et.getCompanyId();
}else {
companyId = accountTax.getCompanyId();
}
// taxes = self.flatten_taxes_hierarchy(), 未处理
List<Account_tax> taxes = null;
Boolean baseExcludedFlag = false;
Boolean includedFlag = false;
for(Account_tax tax : taxes){
if(tax.getPriceInclude()){
includedFlag = true;
}else if(tax.getIncludeBaseAmount()){
baseExcludedFlag = true;
}
if(baseExcludedFlag && includedFlag){
throw new RuntimeException("无法混合任何税收，包括影响基本金额但不包含在价格中的税收。");
}
}
// 处理币种转换时的舍入
Res_company company = resCompanyService.get(companyId);
Long currencyId = null;
if(vals.get("currency_id") == null){
currencyId = company.getCurrencyId();
}
Res_currency currency = resCurrencyService.get(currencyId);
Double prec = currency.getRounding();
Boolean roundTax = true;
if(StringUtils.compare(company.getTaxCalculationRoundingMethod(), StaticDict.RES_COMPANY__TAX_CALCULATION_ROUNDING_METHOD.ROUND_GLOBALLY.getValue()) == 0){
roundTax = false;
}
Boolean roundTotal = true;
// 未处理
// if 'round' in self.env.context:
// round_tax = bool(self.env.context['round'])
// round_total = bool(self.env.context['round'])
if(!roundTax){
prec *= 1e-5;
}
// recompute_base()方法，未定义
// base = round(price_unit * quantity, precision_rounding=prec)， round()方法未处理未处理
Double base = 0.0;
Double sign = 1.0;
if(base <= 0.0){
base = -base;
sign = -1.0;
}
Map totalIncludedCheckpoints = new HashMap();
int i = taxes.size() - 1;
Boolean storeIncludedTaxTotal = true;
Double inclFixedAmount, inclPercentAmount, inclDivisionAmount = 0.0;
Map cachedTaxAmounts = new HashMap();
Collections.reverse(taxes);
for(Account_tax tax : taxes){
// tax_repartition_lines = (
// is_refund
// and tax.refund_repartition_line_ids
// or tax.invoice_repartition_line_ids
// ).filtered(lambda x: x.repartition_type == "tax")， 未处理
List<Long> taxRepartitionLines = null;
// sum_repartition_factor = sum(tax_repartition_lines.mapped("factor"))
Double sumRepartitionFactor = 0.0;
if(tax.getIncludeBaseAmount()){
// base = recompute_base(base, incl_fixed_amount, incl_percent_amount, incl_division_amount, prec) , 未处理
base = null;
inclFixedAmount = inclPercentAmount = inclDivisionAmount = 0.0;
storeIncludedTaxTotal = true;
}
// if tax.price_include or self._context.get('force_price_include'), 未处理
if(tax.getPriceInclude() || ){
if(StringUtils.compare(tax.getAmountType(), StaticDict.ACCOUNT_TAX__AMOUNT_TYPE.PERCENT.getValue()) == 0){
inclPercentAmount += tax.getAmount() * sumRepartitionFactor;
}else if(StringUtils.compare(tax.getAmountType(), StaticDict.ACCOUNT_TAX__AMOUNT_TYPE.DIVISION.getValue()) == 0){
inclDivisionAmount += tax.getAmount() * sumRepartitionFactor;
}else if(StringUtils.compare(tax.getAmountType(), StaticDict.ACCOUNT_TAX__AMOUNT_TYPE.FIXED.getValue()) == 0){
inclFixedAmount += tax.getAmount() * sumRepartitionFactor;
}else{
// tax._compute_amount(base, sign * price_unit, quantity, product, partner) * sum_repartition_factor ,未处理
Double taxAmount = 0.0;
inclFixedAmount += taxAmount;
cachedTaxAmounts.put(i, taxAmount);
}
Boolean condition = StringUtils.compare(tax.getAmountType(), StaticDict.ACCOUNT_TAX__AMOUNT_TYPE.PERCENT.getValue()) != 0 && StringUtils.compare(tax.getAmountType(), StaticDict.ACCOUNT_TAX__AMOUNT_TYPE.DIVISION.getValue()) != 0 && StringUtils.compare(tax.getAmountType(), StaticDict.ACCOUNT_TAX__AMOUNT_TYPE.FIXED.getValue()) != 0;
if(storeIncludedTaxTotal && (tax.getAmount()!=null || condition)){
totalIncludedCheckpoints.put(i, base);
storeIncludedTaxTotal =false;
}
}
i -= 1;
}
// total_excluded = recompute_base(base, incl_fixed_amount, incl_percent_amount, incl_division_amount, prec), 未处理
// 计算不包含税的总计
Double totalExculded = 0.0;
base = totalExculded;
Double totalIncluded = totalExculded;
Double totalVoid = totalExculded;
List<Map> taxesVals = new ArrayList<>();
i = 0;
Double cumulatedTaxIncludedAmount = 0.0;
//
for(Account_tax tax : taxes){
// tax_repartition_lines = (is_refund and tax.refund_repartition_line_ids or tax.invoice_repartition_line_ids).filtered(lambda x: x.repartition_type == 'tax')
List<Long> taxRepartitionLines = null;
// sum_repartition_factor = sum(tax_repartition_lines.mapped('factor'))
Double sumRepartitionFactor = null;
// price_include = self._context.get('force_price_include', tax.price_include)
Double priceInclude = null;
// 计算taxAmount
Double taxAmount = null;
if(priceInclude != null && totalIncludedCheckpoints.get(i) != null){
taxAmount = (Double)totalIncludedCheckpoints.get(i) - (base + cumulatedTaxIncludedAmount);
cumulatedTaxIncludedAmount = 0.0;
}else {
// tax_amount = tax.with_context(force_price_include=False)._compute_amount(base, sign * price_unit, quantity, product, partner)
// taxAmount = ;
}
// tax_amount = round(tax_amount, precision_rounding=prec)
// 对taxAmount进行四舍五入操作
// factorized_tax_amount = round(tax_amount * sum_repartition_factor, precision_rounding=prec)
Double factorizedTaxAmount = null;
if(priceInclude != null && totalIncludedCheckpoints.get(i) == null) {
// cumulated_tax_included_amount += factorized_tax_amount
cumulatedTaxIncludedAmount += factorizedTaxAmount;
}
// subsequent_taxes = self.env['account.tax']
List<Account_tax> subsequentTaxes = null;
// subsequent_tags = self.env['account.account.tag']
List<Account_account_tag> subsequentTags = null;
if(tax.getIncludeBaseAmount() != null){
// 未处理
// subsequent_taxes = taxes[i+1:]
// subsequent_tags = subsequent_taxes.get_tax_tags(is_refund, 'base')
}
// repartition_line_amounts = [round(tax_amount * line.factor, precision_rounding=prec) for line in tax_repartition_lines]
List repartitionLineAmounts = null;
// total_rounding_error = round(factorized_tax_amount - sum(repartition_line_amounts), precision_rounding=prec)
Double totalRoundingError = null;
// nber_rounding_steps = int(abs(total_rounding_error / currency.rounding))
Integer nberRoundingSteps = (int)Math.abs(totalRoundingError / currency.getRounding());
// rounding_error = round(nber_rounding_steps and total_rounding_error / nber_rounding_steps or 0.0, precision_rounding=prec)
Double roundingError = null;
// for repartition_line, line_amount in zip(tax_repartition_lines, repartition_line_amounts)
for(){
if(nberRoundingSteps != null){
// line_amount += rounding_error
nberRoundingSteps -= 1;
}
Map taxInfo = new HashMap();
taxInfo.put("id", tax.getId());
// partner and tax.with_context(lang=partner.lang).name or tax.name, 未处理
String name = tax.getName();
taxInfo.put("name", name);
// sign * line_amount, 未处理
Double amount = sign * 1;
taxInfo.put("amount", amount);
// round(sign * base, precision_rounding=prec), 未处理
base = null;
taxInfo.put("base", base);
taxInfo.put("sequence", tax.getSequence());
// repartition_line.account_id.id, 未处理
Long accountId = null;
if(StringUtils.compare(tax.getTaxExigibility(), StaticDict.ACCOUNT_TAX__TAX_EXIGIBILITY.ON_PAYMENT.getValue()) == 0){
// tax.cash_basis_transition_account_id.id, 不存在？
accountId = tax.g;
}
taxInfo.put("account_id", accountId);
taxInfo.put("analytic", tax.getAnalytic());
taxInfo.put("price_include", priceInclude);
taxInfo.put("tax_exigibility", tax.getTaxExigibility());
// taxInfo.put("tax_repartition_line_id", );
// taxInfo.put("tag_ids", );
// taxInfo.put("tax_ids", );
taxesVals.add(taxInfo);
// if not repartition_line.account_id:
if(){
// total_void += line_amount
totalVoid += 0;
}
}
if(tax.getIncludeBaseAmount() != null){
base += factorizedTaxAmount;
}
totalIncluded += factorizedTaxAmount;
i += 1;
}
Map result = new HashMap();
// result.put("base_tags", );
result.put("taxes", taxesVals);
result.put("total_excluded", totalExculded);
result.put("total_included", totalIncluded);
result.put("total_void", totalVoid);
*/
// 计算price_subtotal， 小计
BigDecimal priceSubTotal = new BigDecimal(et.getPriceUnit() * et.getProductQty());
et.setPriceSubtotal(priceSubTotal);
// 计算price_tax，税率
Double priceTax = 0.10 * et.getPriceUnit() * et.getProductQty();
et.setPriceTax(priceTax);
// 计算price_total， 总计
BigDecimal priceTotal = priceSubTotal.add(new BigDecimal(priceTax));
et.setPriceTotal(priceTotal);
// this.update(et);
return super.calc_price(et); return super.calc_price(et);
} }
/** /**
...@@ -39,6 +332,161 @@ public class Purchase_order_lineExService extends Purchase_order_lineServiceImpl ...@@ -39,6 +332,161 @@ public class Purchase_order_lineExService extends Purchase_order_lineServiceImpl
@Override @Override
@Transactional @Transactional
public Purchase_order_line product_change(Purchase_order_line et) { public Purchase_order_line product_change(Purchase_order_line et) {
// 判断当前的订单行的id
if(et.getId() != null){
// 根据product更新订单行的数据
// 重新设置订单行的datePlanned,并将price_unit和product_qty设置为0
et.setDatePlanned(new Timestamp(System.currentTimeMillis()));
et.setPriceUnit(0.0);
et.setProductQty(0.0);
// _product_id_change()方法
// 重新设置当前所选产品的计量单位
Product_product product = productProductService.get(et.getProductId());
Product_template productTemplate = productTemplateService.get(product.getProductTmplId());
if(productTemplate.getUomPoId() != null){
et.setProductUom(productTemplate.getUomPoId());
}else {
et.setProductUom(productTemplate.getUomId());
}
// 重新设置订单行中产品的说明内容，未处理完毕
// name的获取
Res_partner partner = resPartnerService.get(et.getPartnerId());
// 语言处理
// partner.getLang();
String name = productTemplate.getName();
et.setName(name);
// 计算taxid _compute_tax_id
//
Purchase_order order = purchaseOrderService.get(et.getOrderId());
Long fpos = null;
if (order.getFiscalPositionId() != null) {
fpos = order.getFiscalPositionId();
}else{
// line.order_id.partner_id.with_context(force_company=line.company_id.id).property_account_position_id, 未处理
Res_partner partner1 = resPartnerService.get(order.getPartnerId());
}
// 获取当前产品的默认税种
JSONArray jsonArray = new JSONArray();
List<Product_supplier_taxes_rel> productSupplierTaxesRels = productSupplierTaxesRelService.selectByProdId(productTemplate.getId());
if(productSupplierTaxesRels.size() != 0){
for(Product_supplier_taxes_rel productSupplierTaxesRel : productSupplierTaxesRels){
Account_tax accountTax = accountTaxService.get(productSupplierTaxesRel.getTaxId());
if(accountTax.getCompanyId() != order.getCompanyId()){
productSupplierTaxesRels.remove(productSupplierTaxesRel);
}else{
JSONObject jsonObject = new JSONObject();
jsonObject.put("srfkey", accountTax.getId());
jsonObject.put("srfmajortext", accountTax.getName());
jsonArray.add(jsonObject);
}
}
}
if(fpos != null){
// 调用map_tax()方法， 未处理
et.setTaxesId("test");
}else{
et.setTaxesId(jsonArray.toString());
}
// 设置订单行的产品数量 _suggest_quantity(),使用供应商的供应的最小数量和单位
// 获取供应商的最小供应数量,需要检测
Double minQty = 0.0;
Long productUom = 0L;
List<Product_supplierinfo> productSupplierinfos = supplierinfoService.selectByProductTmplId(productTemplate.getId());
// 找到该产品最小供应数量以及计量单位
if(productSupplierinfos.size() != 0){
for(Product_supplierinfo supplierinfo : productSupplierinfos){
if(supplierinfo.getName() == order.getPartnerId() && (!(supplierinfo.getProductId()!=null) || supplierinfo.getProductId() == et.getProductId())){
if(supplierinfo.getMinQty() != 0){
if(minQty == 0.0){
minQty = supplierinfo.getMinQty();
productUom = supplierinfo.getProductUom();
}else if(supplierinfo.getMinQty() < minQty){
minQty = supplierinfo.getMinQty();
productUom = supplierinfo.getProductUom();
}
}
}
}
}
if(minQty != 0.0){
et.setProductQty(minQty);
et.setProductUom(productUom);
}else{
et.setProductQty(1.0);
}
// _onchange_quantity(),
Map params = new HashMap();
params.put("order_id", et.getOrderId());
Long seller = null;
// 未处理，需要调用product.py中的_select_seller()方法'
Product_supplierinfo supplierinfo = supplierinfoService.get(seller);
// 判断需不需要重新设置计划日期
if(seller != null || et.getDatePlanned() == null){
// self._get_date_planned(seller).strftime(DEFAULT_SERVER_DATETIME_FORMAT)， 未处理
Timestamp dateOrder = order.getDateOrder();
Long time = 0L;
if(dateOrder != null){
if(seller != null){
time = dateOrder.getTime() + supplierinfo.getDelay() * 24 * 60 * 60;
}else{
time = dateOrder.getTime();
}
}else{
if(seller != null){
time = new Date().getTime() + supplierinfo.getDelay() * 24 * 60 * 60;
}else{
time = new Date().getTime();
}
}
Timestamp datePlanned = new Timestamp(time);
et.setDatePlanned(datePlanned);
}
if(seller == null){
// 未处理
List<Product_supplierinfo> supplierinfos = supplierinfoService.selectByProductTmplId(productTemplate.getId());
if(supplierinfos.size() != 0){
for(Product_supplierinfo supplierinfo1 : supplierinfos){
if(supplierinfo1.getName() == et.getPartnerId()){
et.setPriceUnit(0.0);
}
}
}
}else{
Double priceUnit = 10.0; // 模拟数据
if(seller != null){
// price_unit = self.env['account.tax']._fix_tax_included_price_company(seller.price, self.product_id.supplier_taxes_id, self.taxes_id, self.company_id) , 未处理
// 调用account.py中的_fix_tax_included_price_company()方法,未处理
Double price = supplierinfo.getPrice();
log.warn("链接_fix_tax_included_price_company()");
}
if(priceUnit != 0.0 && order.getCurrencyId() != null && supplierinfo.getCurrencyId() != order.getCurrencyId()){
// 当当前订单的币种和供应商所用币种不同时，进行转换，获取转换后的单价, _convert方法 未处理
log.warn("链接_convert()");
priceUnit = priceUnit;
}
// 判断当前使用的计量单位和供应商的计量的单位是否相同，通过供应商的计量单位来重新计算单价
if(seller != null && et.getProductUom() != null && supplierinfo.getProductUom() != et.getProductUom()){
// seller.product_uom._compute_price(price_unit, self.product_uom), 未处理
priceUnit = priceUnit;
}
et.setPriceUnit(priceUnit);
}
// this.create(et);
// 计算税前和税后的总价
et = this.calc_price(et);
}
return super.product_change(et); return super.product_change(et);
} }
} }
......
Markdown 格式
0% or
您添加了 0 人 到此讨论。请谨慎行事。
先完成此消息的编辑！
想要评论请 注册 或