feature:订单三个页面和发票查询页面添加所属组织字段

release
gaorl 2 years ago
parent 37bc4668c4
commit acd95dc988
  1. 4
      order-management-common/src/main/java/com/dxhy/order/model/OrderProcessInfo.java
  2. 8
      order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/OrderProcessServiceImpl.java
  3. 4
      order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/SDEnregyServiceImpl.java
  4. 2
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/model/vo/OrderInvoiceDetailVO.java
  5. 7
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/service/impl/OrderInvoiceInfoServiceImpl.java

@ -246,5 +246,9 @@ public class OrderProcessInfo implements Serializable {
* yhbh 用户编号 * yhbh 用户编号
*/ */
private String yhbh; private String yhbh;
/**
* 所属组织
*/
private String taxpayerName;
} }

@ -3,6 +3,8 @@ package com.dxhy.order.consumer.modules.order.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.dxhy.order.baseservice.module.thirdservice.user.model.DeptEntity;
import com.dxhy.order.baseservice.module.thirdservice.user.service.UserInfoService;
import com.dxhy.order.constant.ConfigureConstant; import com.dxhy.order.constant.ConfigureConstant;
import com.dxhy.order.constant.OrderInfoEnum; import com.dxhy.order.constant.OrderInfoEnum;
import com.dxhy.order.model.OrderInvoiceInfo; import com.dxhy.order.model.OrderInvoiceInfo;
@ -27,6 +29,7 @@ import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.stream.Collectors;
/** /**
* 订单处理业务实现 * 订单处理业务实现
@ -46,6 +49,8 @@ public class OrderProcessServiceImpl implements OrderProcessService {
@Resource @Resource
private OrderInvoiceInfoService orderInvoiceInfoService; private OrderInvoiceInfoService orderInvoiceInfoService;
@Resource
private UserInfoService userInfoService;
@Override @Override
public OrderProcessInfo selectOrderProcessInfoByProcessId(String id, List<String> shList) { public OrderProcessInfo selectOrderProcessInfoByProcessId(String id, List<String> shList) {
@ -70,6 +75,8 @@ public class OrderProcessServiceImpl implements OrderProcessService {
log.debug("订单查询,当前页:{},页面条数:{}", currPage, pageSize); log.debug("订单查询,当前页:{},页面条数:{}", currPage, pageSize);
PageHelper.startPage(currPage, pageSize); PageHelper.startPage(currPage, pageSize);
List<OrderProcessInfo> list = orderProcessInfoMapper.queryOrderInfo(paramMap, shList, entList); List<OrderProcessInfo> list = orderProcessInfoMapper.queryOrderInfo(paramMap, shList, entList);
List<DeptEntity> taxpayerEntityList = userInfoService.getTaxpayerEntityList();
Map<String, String> collect = taxpayerEntityList.stream().collect(Collectors.toMap(t -> t.getDeptId(), t -> t.getName()));
list.forEach(op -> { list.forEach(op -> {
//如果是红票,将清单标志改为0,(红票没有清单) //如果是红票,将清单标志改为0,(红票没有清单)
if (OrderInfoEnum.ORDER_BILLING_INVOICE_TYPE_1.getKey().equals(op.getKplx())) { if (OrderInfoEnum.ORDER_BILLING_INVOICE_TYPE_1.getKey().equals(op.getKplx())) {
@ -79,6 +86,7 @@ public class OrderProcessServiceImpl implements OrderProcessService {
if (Objects.isNull(op.getDyztms())) { if (Objects.isNull(op.getDyztms())) {
op.setDyztms(""); op.setDyztms("");
} }
op.setTaxpayerName(StringUtils.isNotBlank(collect.get(op.getEntId()))?collect.get(op.getEntId()):"");
}); });
PageInfo<OrderProcessInfo> pageInfo = new PageInfo<>(list); PageInfo<OrderProcessInfo> pageInfo = new PageInfo<>(list);
return new PageUtils(pageInfo.getList(), (int) pageInfo.getTotal(), pageInfo.getPageSize(), return new PageUtils(pageInfo.getList(), (int) pageInfo.getTotal(), pageInfo.getPageSize(),

@ -537,11 +537,11 @@ public class SDEnregyServiceImpl extends SDEnregyServiceAbstract {
String resp = response.body(); String resp = response.body();
log.info("[MDM主动同步物料]响应结果:{}", resp); log.info("[MDM主动同步物料]响应结果:{}", resp);
if(StringUtils.isBlank(resp)){ if(StringUtils.isBlank(resp)){
return R.error("获取物料信息失败,请检查客户编码是否正确"); return R.error("获取物料信息失败,请检查物料编码是否正确");
} }
SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(resp, SDEnergyMdmBaseBO.class); SDEnergyMdmBaseBO baseBO = JSONObject.parseObject(resp, SDEnergyMdmBaseBO.class);
if(baseBO == null || baseBO.getESB() == null|| baseBO.getESB().getDATA()==null){ if(baseBO == null || baseBO.getESB() == null|| baseBO.getESB().getDATA()==null){
return R.error("获取物料信息失败,请检查客户编码是否正确"); return R.error("获取物料信息失败,请检查物料编码是否正确");
} }
List<MdmSyncGroupTaxCodeReqBO> mdmGmfxxtbReqBOS = (List<MdmSyncGroupTaxCodeReqBO>) Optional.of(baseBO) List<MdmSyncGroupTaxCodeReqBO> mdmGmfxxtbReqBOS = (List<MdmSyncGroupTaxCodeReqBO>) Optional.of(baseBO)
.map(SDEnergyMdmBaseBO::getESB) .map(SDEnergyMdmBaseBO::getESB)

@ -90,7 +90,7 @@ public class OrderInvoiceDetailVO implements Serializable {
*/ */
private String sksbdm; private String sksbdm;
private String entId; private String entId;
private String taxpayerName;
/** /**
* 报账单号 * 报账单号

@ -17,6 +17,8 @@ import com.dxhy.order.baseservice.module.thirdservice.rabbitmq.service.RabbitMqS
import com.dxhy.order.baseservice.module.thirdservice.redis.service.RedisService; import com.dxhy.order.baseservice.module.thirdservice.redis.service.RedisService;
import com.dxhy.order.baseservice.module.thirdservice.simsback.model.PushPauseInvoice; import com.dxhy.order.baseservice.module.thirdservice.simsback.model.PushPauseInvoice;
import com.dxhy.order.baseservice.module.thirdservice.simsback.service.SimsBackService; import com.dxhy.order.baseservice.module.thirdservice.simsback.service.SimsBackService;
import com.dxhy.order.baseservice.module.thirdservice.user.model.DeptEntity;
import com.dxhy.order.baseservice.module.thirdservice.user.service.UserInfoService;
import com.dxhy.order.constant.*; import com.dxhy.order.constant.*;
import com.dxhy.order.invoice.config.InvoiceConfig; import com.dxhy.order.invoice.config.InvoiceConfig;
import com.dxhy.order.invoice.module.invoice.dao.*; import com.dxhy.order.invoice.module.invoice.dao.*;
@ -120,6 +122,8 @@ public class OrderInvoiceInfoServiceImpl implements OrderInvoiceInfoService {
@Resource @Resource
private InvoiceKpdInfoService invoiceKpdInfoService; private InvoiceKpdInfoService invoiceKpdInfoService;
@Resource
private UserInfoService userInfoService;
@Autowired @Autowired
@Qualifier("asyncExecutor") @Qualifier("asyncExecutor")
private Executor voucherTaskExecutor; private Executor voucherTaskExecutor;
@ -238,8 +242,11 @@ public class OrderInvoiceInfoServiceImpl implements OrderInvoiceInfoService {
PageInfo<OrderInvoiceDetail> orderInvoiceDetailPageInfo = new PageInfo<>(list); PageInfo<OrderInvoiceDetail> orderInvoiceDetailPageInfo = new PageInfo<>(list);
//添加发票查询-特殊票种值(0:其他;1:成品油发票;2:收购发票;3:机动车专票;) //添加发票查询-特殊票种值(0:其他;1:成品油发票;2:收购发票;3:机动车专票;)
List<OrderInvoiceDetailVO> orderInvoiceDetailVOList = new ArrayList<>(list.size()); List<OrderInvoiceDetailVO> orderInvoiceDetailVOList = new ArrayList<>(list.size());
List<DeptEntity> taxpayerEntityList = userInfoService.getTaxpayerEntityList();
Map<String, String> collect = taxpayerEntityList.stream().collect(Collectors.toMap(t -> t.getDeptId(), t -> t.getName()));
list.forEach(orderInvoiceDetail -> { list.forEach(orderInvoiceDetail -> {
OrderInvoiceDetailVO orderInvoiceDetailVO = convertOrderInvoiceDetailVO(orderInvoiceDetail); OrderInvoiceDetailVO orderInvoiceDetailVO = convertOrderInvoiceDetailVO(orderInvoiceDetail);
orderInvoiceDetailVO.setTaxpayerName(StringUtils.isNotBlank(collect.get(orderInvoiceDetail.getEntId()))?collect.get(orderInvoiceDetail.getEntId()):"");
orderInvoiceDetailVOList.add(orderInvoiceDetailVO); orderInvoiceDetailVOList.add(orderInvoiceDetailVO);
}); });
return new PageUtils(orderInvoiceDetailVOList, (int) orderInvoiceDetailPageInfo.getTotal(), return new PageUtils(orderInvoiceDetailVOList, (int) orderInvoiceDetailPageInfo.getTotal(),

Loading…
Cancel
Save