Merge branch 'release' into test

# Conflicts:
#	order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java
release
gaorl 2 years ago
commit c13a9d8941
  1. 23
      order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderInfoServiceImpl.java

@ -2025,7 +2025,7 @@ public class OrderInfoServiceImpl implements OrderInfoService {
if(ObjectUtil.isNull(orderItemInfos)){ if(ObjectUtil.isNull(orderItemInfos)){
return R.error("根据订单号未查询到明细行信息"); return R.error("根据订单号未查询到明细行信息");
} }
List<OrderItemInfo> collect = null; List<OrderItemInfo> collect ;
if(itemList != null){ if(itemList != null){
collect = orderItemInfos.stream().filter(t -> itemList.contains(t.getId()) && StringUtils.isNotBlank(t.getSpbm())).collect(Collectors.toList()); collect = orderItemInfos.stream().filter(t -> itemList.contains(t.getId()) && StringUtils.isNotBlank(t.getSpbm())).collect(Collectors.toList());
if(ObjectUtil.isNull(collect)){ if(ObjectUtil.isNull(collect)){
@ -2034,6 +2034,7 @@ public class OrderInfoServiceImpl implements OrderInfoService {
}else{ }else{
collect = orderItemInfos; collect = orderItemInfos;
} }
List<OrderItemInfo> mergeOutItem = orderItemInfos.stream().filter(t -> !collect.contains(t)).collect(Collectors.toList());
TaxEquipmentInfo taxEquipmentInfo = simsBackService.queryTaxEquipment(orderInfo.getNsrsbh(), entId); TaxEquipmentInfo taxEquipmentInfo = simsBackService.queryTaxEquipment(orderInfo.getNsrsbh(), entId);
if(taxEquipmentInfo == null ||StringUtils.isBlank(taxEquipmentInfo.getSksbCode())){ if(taxEquipmentInfo == null ||StringUtils.isBlank(taxEquipmentInfo.getSksbCode())){
return R.error("税控设备查询为空"); return R.error("税控设备查询为空");
@ -2092,8 +2093,8 @@ public class OrderInfoServiceImpl implements OrderInfoService {
orderItemInfo.setXmdj(xmdj.toString()); orderItemInfo.setXmdj(xmdj.toString());
} }
// return R.error("明细行号{}合并错误,合并明细超过0.06暂时不合并",orderItemInfo.getSphxh()); // return R.error("明细行号{}合并错误,合并明细超过0.06暂时不合并",orderItemInfo.getSphxh());
diffJe = diffJe.add(xmjeNew.subtract(xmje)); // diffJe = diffJe.add(xmjeNew.subtract(xmje));
diffSe = diffSe.add(taxAmountNew.subtract(se)); // diffSe = diffSe.add(taxAmountNew.subtract(se));
} }
orderItemInfoList.add(orderItemInfo); orderItemInfoList.add(orderItemInfo);
deleteItem.addAll(value.stream().map(t->t.getId()).collect(Collectors.toList())); deleteItem.addAll(value.stream().map(t->t.getId()).collect(Collectors.toList()));
@ -2105,7 +2106,9 @@ public class OrderInfoServiceImpl implements OrderInfoService {
if(!orderItemInfoList.isEmpty()){ if(!orderItemInfoList.isEmpty()){
orderItemInfoMapper.deleteItemByItemId(deleteItem); orderItemInfoMapper.deleteItemByItemId(deleteItem);
orderItemInfoMapper.insertOrderItemByList(orderItemInfoList); orderItemInfoMapper.insertOrderItemByList(orderItemInfoList);
mergeOutItem.addAll(orderItemInfoList);
} }
BigDecimal se = mergeOutItem.stream().map(t -> new BigDecimal(t.getSe())).reduce(BigDecimal::add).get();
//更新清单标志 重新设置金额 //更新清单标志 重新设置金额
OrderInfo orderInfoNew = new OrderInfo(); OrderInfo orderInfoNew = new OrderInfo();
orderInfoNew.setId(orderInfoId); orderInfoNew.setId(orderInfoId);
@ -2117,18 +2120,14 @@ public class OrderInfoServiceImpl implements OrderInfoService {
if("1".equals(orderInfo.getQdBz())&&orderItemInfos.size() - deleteItem.size() < 8 ){ if("1".equals(orderInfo.getQdBz())&&orderItemInfos.size() - deleteItem.size() < 8 ){
orderInfoNew.setQdBz("0"); orderInfoNew.setQdBz("0");
} }
log.info("差异金额:"+diffJe.toString());
log.info("差异税额:"+diffSe.toString());
if(diffJe.compareTo(BigDecimal.ZERO) != 0){ if(diffJe.compareTo(BigDecimal.ZERO) != 0){
String bhsje = new BigDecimal(orderInfo.getHjbhsje()).add(diffJe).toString(); String bhsje = new BigDecimal(orderInfo.getKphjje()).subtract(se).toString();
String se = new BigDecimal(orderInfo.getHjse()).add(diffSe).toString();
orderInfoNew.setHjbhsje(bhsje); orderInfoNew.setHjbhsje(bhsje);
orderInfoNew.setHjse(se); orderInfoNew.setHjse(se.toString());
orderProcessInfoNew.setHjbhsje(bhsje); orderProcessInfoNew.setHjbhsje(bhsje);
orderProcessInfoNew.setKpse(se); orderProcessInfoNew.setKpse(se.toString());
orderMapper.updateOrderInfoByOrderId(orderInfoNew,null); orderMapper.updateOrderInfoByOrderId(orderInfoNew,Arrays.asList(orderInfo.getNsrsbh()));
orderProcessInfoMapper.updateOrderProcessInfoByProcessId(orderProcessInfoNew,null); orderProcessInfoMapper.updateOrderProcessInfoByProcessId(orderProcessInfoNew,Arrays.asList(orderInfo.getNsrsbh()));
} }
return R.ok(); return R.ok();
} }

Loading…
Cancel
Save