fix:联调回推问题修改及优化

zkh
路明慧 11 months ago
parent e66903730b
commit ee360b23ad
  1. 4
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/OrderHandleServiceImpl.java
  2. 18
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/SkOrderServiceImpl.java
  3. 10
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/YyOrderServiceImpl.java

@ -22,6 +22,7 @@ import com.dxhy.base.thirdservice.module.base.service.BaseService;
import com.dxhy.order.baseservice.exception.OrderReceiveException; import com.dxhy.order.baseservice.exception.OrderReceiveException;
import com.dxhy.order.baseservice.model.OrderInvoiceInfo; import com.dxhy.order.baseservice.model.OrderInvoiceInfo;
import com.dxhy.order.baseservice.model.OrderOriginExtendInfo; import com.dxhy.order.baseservice.model.OrderOriginExtendInfo;
import com.dxhy.order.baseservice.model.QuickResponseCodeItemInfo;
import com.dxhy.order.baseservice.model.queue.CommonTsMqData; import com.dxhy.order.baseservice.model.queue.CommonTsMqData;
import com.dxhy.order.baseservice.model.queue.FpYxTsMqData; import com.dxhy.order.baseservice.model.queue.FpYxTsMqData;
import com.dxhy.order.consumer.dao.OrderOriginExtendInfoMapper; import com.dxhy.order.consumer.dao.OrderOriginExtendInfoMapper;
@ -304,7 +305,7 @@ public class OrderHandleServiceImpl implements OrderHandleService {
if (flag){ if (flag){
fileModel.setCode(ConfigureConstant.STRING_0000); fileModel.setCode(ConfigureConstant.STRING_0000);
fileModel.setFilePath(path.toString()); fileModel.setFilePath(path.toString());
fileModel.setFileName(fileDownLoad.getFileName()); fileModel.setFileName(fileName);
return fileModel; return fileModel;
} }
fileModel.setCode(ConfigureConstant.STRING_9999); fileModel.setCode(ConfigureConstant.STRING_9999);
@ -448,6 +449,7 @@ public class OrderHandleServiceImpl implements OrderHandleService {
OrderInvoiceInfo orderQuery = new OrderInvoiceInfo(); OrderInvoiceInfo orderQuery = new OrderInvoiceInfo();
orderQuery.setFpqqlsh(fpqqlsh); orderQuery.setFpqqlsh(fpqqlsh);
orderQuery.setPushStatus(OrderInfoEnum.PUSH_STATUS_1.getKey()); orderQuery.setPushStatus(OrderInfoEnum.PUSH_STATUS_1.getKey());
orderQuery.setInvoicePushSbyy("推送成功");
int updateByPrimaryKeySelective = orderInvoiceInfoService.updateOrderInvoiceInfoByFpqqlsh(orderQuery, shList); int updateByPrimaryKeySelective = orderInvoiceInfoService.updateOrderInvoiceInfoByFpqqlsh(orderQuery, shList);
if (updateByPrimaryKeySelective <= 0) { if (updateByPrimaryKeySelective <= 0) {
log.error("推送状态更新失败"); log.error("推送状态更新失败");

@ -36,16 +36,14 @@ import com.dxhy.order.consumer.modules.bespoke.service.OrderService;
import com.dxhy.order.consumer.openapi.protocol.v4.order.*; import com.dxhy.order.consumer.openapi.protocol.v4.order.*;
import com.dxhy.order.consumer.openapi.protocol.v6.order.QdTxxBO; import com.dxhy.order.consumer.openapi.protocol.v6.order.QdTxxBO;
import com.dxhy.order.consumer.openapi.service.AllocateInvoiceInterfaceServiceV3; import com.dxhy.order.consumer.openapi.service.AllocateInvoiceInterfaceServiceV3;
import com.dxhy.order.invoice.module.invoice.dao.OrderInfoMapper;
import com.dxhy.order.invoice.module.invoice.dao.OrderItemInfoMapper; import com.dxhy.order.invoice.module.invoice.dao.OrderItemInfoMapper;
import com.dxhy.order.invoice.module.invoice.service.OrderInvoiceInfoService;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.github.pagehelper.page.PageMethod; import com.github.pagehelper.page.PageMethod;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
@ -55,6 +53,9 @@ import java.util.*;
@Service("skOrderServiceImpl") @Service("skOrderServiceImpl")
public class SkOrderServiceImpl implements OrderService { public class SkOrderServiceImpl implements OrderService {
@Value("${pdf.back.url}")
private String backUrl;
@Resource @Resource
private SkOrderInfoMapper skOrderInfoMapper; private SkOrderInfoMapper skOrderInfoMapper;
@ -85,9 +86,6 @@ public class SkOrderServiceImpl implements OrderService {
@Resource @Resource
private TInvoiceInvmapMapper tInvoiceInvmapMapper; private TInvoiceInvmapMapper tInvoiceInvmapMapper;
@Resource
private LuoxinBack luoxinBack;
// 订单读入 // 订单读入
@Override @Override
public R orderRead(ReqParam reqParam) { public R orderRead(ReqParam reqParam) {
@ -231,16 +229,16 @@ public class SkOrderServiceImpl implements OrderService {
newTable.setInvoiceNo(orderInvoiceInfo.getSdfphm()); newTable.setInvoiceNo(orderInvoiceInfo.getSdfphm());
newTable.setInvoiceTime(orderInvoiceInfo.getKprq()); newTable.setInvoiceTime(orderInvoiceInfo.getKprq());
newTable.setInvoiceAmount(orderInvoiceInfo.getKphjje()); newTable.setInvoiceAmount(orderInvoiceInfo.getKphjje());
newTable.setInvoicePhoto(fileModel.getFilePath());
newTable.setInvoiceFilename(fileModel.getFileName()); newTable.setInvoiceFilename(fileModel.getFileName());
newTable.setOperater(orderInvoiceInfo.getKpr()); newTable.setOperater(orderInvoiceInfo.getKpr());
newTable.setOperateDate(orderInvoiceInfo.getKprq()); newTable.setOperateDate(orderInvoiceInfo.getKprq());
newTable.setShipper(luoxinBack.getWrite(orderInvoiceInfo.getXhfNsrsbh())); newTable.setShipper(orderInvoiceInfo.getXhfNsrsbh());
newTable.setStatus(ConfigureConstant.STRING_1);
newTable.setInvoicePhoto(backUrl.concat(fileModel.getFilePath()).concat("/").concat(fileModel.getFileName()));
DynamicContextHolder.push(ConfigureConstant.MAIN); DynamicContextHolder.push(ConfigureConstant.MAIN);
tInvoiceInvmapMapper.deleteBackMsg(newTable.getCDLCode()); tInvoiceInvmapMapper.deleteBackMsg(orderInvoiceInfo.getSdfphm());
tInvoiceInvmapMapper.insertBackMsg(newTable); tInvoiceInvmapMapper.insertBackMsg(newTable);
} }
} }

@ -42,10 +42,9 @@ import com.github.pagehelper.page.PageMethod;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
@ -55,6 +54,9 @@ import java.util.*;
@Service("yyOrderService") @Service("yyOrderService")
public class YyOrderServiceImpl implements OrderService { public class YyOrderServiceImpl implements OrderService {
@Value("${pdf.back.url}")
private String backUrl;
@Resource @Resource
private YyOrderMapper yyOrderMapper; private YyOrderMapper yyOrderMapper;
@ -231,10 +233,12 @@ public class YyOrderServiceImpl implements OrderService {
newTable.setInvoiceNo(orderInvoiceInfo.getSdfphm()); newTable.setInvoiceNo(orderInvoiceInfo.getSdfphm());
newTable.setInvoiceTime(orderInvoiceInfo.getKprq()); newTable.setInvoiceTime(orderInvoiceInfo.getKprq());
newTable.setInvoiceAmount(orderInvoiceInfo.getKphjje()); newTable.setInvoiceAmount(orderInvoiceInfo.getKphjje());
newTable.setInvoicePhoto(fileModel.getFilePath());
newTable.setInvoiceFilename(fileModel.getFileName()); newTable.setInvoiceFilename(fileModel.getFileName());
newTable.setOperater(orderInvoiceInfo.getKpr()); newTable.setOperater(orderInvoiceInfo.getKpr());
newTable.setOperateDate(orderInvoiceInfo.getKprq()); newTable.setOperateDate(orderInvoiceInfo.getKprq());
newTable.setShipper(orderInvoiceInfo.getXhfNsrsbh());
newTable.setStatus(ConfigureConstant.STRING_1);
newTable.setInvoicePhoto(backUrl.concat(fileModel.getFilePath()).concat("/").concat(fileModel.getFileName()));
newTableList.add(newTable); newTableList.add(newTable);
//更新会写表 //更新会写表

Loading…
Cancel
Save