diff --git a/order-management-base-service/src/main/java/com/dxhy/order/baseservice/config/BaseXxlJobConfig.java b/order-management-base-service/src/main/java/com/dxhy/order/baseservice/config/BaseXxlJobConfig.java index 9de2fb97..fde53335 100644 --- a/order-management-base-service/src/main/java/com/dxhy/order/baseservice/config/BaseXxlJobConfig.java +++ b/order-management-base-service/src/main/java/com/dxhy/order/baseservice/config/BaseXxlJobConfig.java @@ -13,10 +13,10 @@ import org.springframework.context.annotation.Configuration; * * @author xuxueli 2017-04-28 */ -// @Configuration -// @ComponentScan(basePackages = "com.dxhy.order.baseservice.job") +//@Configuration +//@ComponentScan(basePackages = "com.dxhy.order.baseservice.job") @Slf4j -// @RefreshScope +@RefreshScope public class BaseXxlJobConfig { @Value("${xxl.job.admin.addresses}") diff --git a/order-management-base-service/src/main/java/com/dxhy/order/baseservice/module/thirdservice/user/model/DeptEntity.java b/order-management-base-service/src/main/java/com/dxhy/order/baseservice/module/thirdservice/user/model/DeptEntity.java index fe3cd0ef..237d55eb 100644 --- a/order-management-base-service/src/main/java/com/dxhy/order/baseservice/module/thirdservice/user/model/DeptEntity.java +++ b/order-management-base-service/src/main/java/com/dxhy/order/baseservice/module/thirdservice/user/model/DeptEntity.java @@ -172,4 +172,14 @@ public class DeptEntity implements Serializable { * 组织类型(0:虚拟组织,1:实体组织) */ private String groupType; + + /** + * 开票组织名称 + */ + private String invoiceName; + + /** + * 开票税号 + */ + private String invoiceNsrsbh; } diff --git a/order-management-common/src/main/java/com/dxhy/order/model/OrderProcessInfo.java b/order-management-common/src/main/java/com/dxhy/order/model/OrderProcessInfo.java index e045a091..1c455610 100644 --- a/order-management-common/src/main/java/com/dxhy/order/model/OrderProcessInfo.java +++ b/order-management-common/src/main/java/com/dxhy/order/model/OrderProcessInfo.java @@ -213,6 +213,19 @@ public class OrderProcessInfo implements Serializable { * 是否预制发票 */ private String yzfp; + /** + * 原始结算单号 + */ + private String originDdh; + /** + * 原始订单ID + */ + private String originOrderId; + /** + * 矿别 + */ + private String kb; + diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/InvoiceRemarkSetServiceImpl.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/InvoiceRemarkSetServiceImpl.java index 04cde62e..eb40e32c 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/InvoiceRemarkSetServiceImpl.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/order/service/impl/InvoiceRemarkSetServiceImpl.java @@ -56,6 +56,7 @@ public class InvoiceRemarkSetServiceImpl implements InvoiceRemarkSetService { for(int i=0;i ddmxxx = ddpcxxReq.getDDZXX().get(0).getDDMXXX(); + + for(OrderProcessInfo processInfo:insertProcessInfo){ + processInfo.setBzdh(ddtxx.getBZDH()); + processInfo.setXtly(ddtxx.getXTLY()); + processInfo.setGsdm(ddtxx.getGSDM()); + processInfo.setBhzt(ddtxx.getBHZT()); + processInfo.setYgxm(ddtxx.getYGXM()); + processInfo.setKppzh(ddtxx.getKPPZH()); + processInfo.setPzgzrq(DateUtil.parse(ddtxx.getPZGZRQ(),"yyyy-MM-dd")); + processInfo.setYzfp(ddtxx.getYZFP()); + processInfo.setOriginDdh(ddtxx.getDDH()); + processInfo.setOriginOrderId(processInfo.getOrderInfoId()); + } + for(OrderItemInfo itemInfo:insertOrderItem.get(0)){ + itemInfo.setPh(ddmxxx.get(0).getPH()); + itemInfo.setKb(ddmxxx.get(0).getKB()); + //TODO lfl 这两在哪赋值? + itemInfo.setZnfm(""); + itemInfo.setTswl(""); + } /* * 手动导入判断 diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/InterfaceServiceImplV6.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/InterfaceServiceImplV6.java index 0248c102..482a1906 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/InterfaceServiceImplV6.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/openapi/service/impl/InterfaceServiceImplV6.java @@ -8,7 +8,10 @@ import com.dxhy.order.baseservice.module.thirdservice.simsback.service.SimsBackS import com.dxhy.order.constant.*; import com.dxhy.order.consumer.constant.InterfaceNameEnum; import com.dxhy.order.consumer.dao.InterfaceRequestDataMapper; +import com.dxhy.order.consumer.dao.OrderProcessInfoMapper; +import com.dxhy.order.consumer.modules.order.service.OrderProcessService; import com.dxhy.order.consumer.openapi.protocol.po.EsOutput; +import com.dxhy.order.consumer.openapi.protocol.po.IsInput; import com.dxhy.order.consumer.openapi.protocol.po.PoCommonRequestParam; import com.dxhy.order.consumer.openapi.protocol.po.PoCommonResponseParam; import com.dxhy.order.consumer.openapi.protocol.v4.order.DdpcxxReqBO; @@ -24,6 +27,7 @@ import com.dxhy.order.consumer.openapi.service.InterfaceServiceV6; import com.dxhy.order.invoice.config.InvoiceConfig; import com.dxhy.order.invoice.utils.HttpInvoiceRequestUtilQd; import com.dxhy.order.model.InterfaceRequestData; +import com.dxhy.order.model.OrderProcessInfo; import com.dxhy.order.model.newsk.InvoiceRequestParam; import com.dxhy.order.utils.DecimalCalculateUtil; import com.dxhy.order.utils.DistributedKeyMaker; @@ -34,9 +38,7 @@ import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; -import java.util.Date; -import java.util.List; -import java.util.Objects; +import java.util.*; /** @@ -65,6 +67,8 @@ public class InterfaceServiceImplV6 implements InterfaceServiceV6 { private InvoiceConfig invoiceConfig; @Resource private InterfaceRequestDataMapper interfaceRequestDataMapper; + @Resource + private OrderProcessInfoMapper orderProcessInfoMapper; @Override public DdpcxxRspV5 generateQdInvoiceV6(DdpcxxReqBO ddpcxxReq, String secretId, String kpjh) { @@ -122,10 +126,31 @@ public class InterfaceServiceImplV6 implements InterfaceServiceV6 { public PoCommonResponseParam updateOrderStatus(PoCommonRequestParam requestParam, String secretId) { PoCommonResponseParam poCommonResponseParam = new PoCommonResponseParam(); EsOutput esOutput = new EsOutput(); - esOutput.setBSKEY(""); - esOutput.setSAPKEY(""); - esOutput.setZTYPE(OrderInfoContentEnum.INVOICE_ERROR_CODE_OP_S.getKey()); - esOutput.setZMESSAGE(""); + IsInput is_input = requestParam.getIS_INPUT(); + esOutput.setBSKEY(is_input.getBSKEY()); + esOutput.setSAPKEY(is_input.getSAPKEY()); + String zdata = is_input.getZDATA(); + Map map = JsonUtils.getInstance().parseObject(zdata, Map.class); + String ddh = (String)map.get("ZJSDH"); + String bzdh = (String)map.get("ZBZDH"); + Map queryMap = new HashMap<>(); + queryMap.put("bzdh",bzdh); + List orderProcessInfos = orderProcessInfoMapper.queryOrderInfo(queryMap, null, null); + if(orderProcessInfos.size()!=1){ + esOutput.setZTYPE(OrderInfoContentEnum.INVOICE_ERROR_CODE_OP_E.getKey()); + esOutput.setZMESSAGE("根据报账单号未查询到唯一结算单"); + }else { + OrderProcessInfo orderProcessInfo = orderProcessInfos.get(0); + orderProcessInfo.setBhzt(ConfigureConstant.STRING_1); + int i = orderProcessInfoMapper.updateOrderProcessInfoByFpqqlsh(orderProcessInfo, null); + if(i == 1){ + esOutput.setZTYPE(OrderInfoContentEnum.INVOICE_ERROR_CODE_OP_S.getKey()); + esOutput.setZMESSAGE("驳回状态更新成功"); + }else { + esOutput.setZTYPE(OrderInfoContentEnum.INVOICE_ERROR_CODE_OP_E.getKey()); + esOutput.setZMESSAGE("驳回状态更新失败"); + } + } poCommonResponseParam.setES_OUTPUT(esOutput); return poCommonResponseParam; } diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/BeanTransitionUtils.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/BeanTransitionUtils.java index d2c55728..7a8fb012 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/BeanTransitionUtils.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/BeanTransitionUtils.java @@ -3464,14 +3464,14 @@ public class BeanTransitionUtils { FpkjReqSap req = JsonUtils.getInstance().parseObject(zdataString, FpkjReqSap.class); //批次信息 ddpcxxBO.setDDQQPCH(isinput.getSAPKEY()); - ddpcxxBO.setNSRSBH(deptEntity.getTaxpayerCode()); + ddpcxxBO.setNSRSBH(deptEntity.getInvoiceNsrsbh()); ddpcxxBO.setFPLXDM(CommonUtils.transSnFplxdm(req.getZFPLX())); ddpcxxBO.setKPFS(ConfigureConstant.STRING_1); //订单头信息 ddtxxBO.setDDQQLSH(isinput.getSAPKEY()); ddtxxBO.setKPLX(req.getZSFHZ()); - ddtxxBO.setXHFSBH(deptEntity.getTaxpayerCode()); - ddtxxBO.setXHFMC(deptEntity.getName()); + ddtxxBO.setXHFSBH(deptEntity.getInvoiceNsrsbh()); + ddtxxBO.setXHFMC(deptEntity.getInvoiceName()); ddtxxBO.setXHFDZ(deptEntity.getTaxpayerAddress()); ddtxxBO.setXHFDH(deptEntity.getTaxpayerPhone()); ddtxxBO.setXHFYH(deptEntity.getTaxpayerBank()); @@ -3484,6 +3484,15 @@ public class BeanTransitionUtils { ddtxxBO.setHJJE(req.getZBHSJE()); ddtxxBO.setHJSE(req.getZZSE()); ddtxxBO.setDDH(req.getZJSDH()); + ddtxxBO.setBZDH(req.getZBZDH()); + ddtxxBO.setXTLY(req.getZSJLY()); + ddtxxBO.setGSDM(req.getBUKRS()); + ddtxxBO.setBHZT(ConfigureConstant.STRING_0); + ddtxxBO.setYGXM(req.getPENAM()); + ddtxxBO.setKPPZH(req.getZKPPZH()); + ddtxxBO.setPZGZRQ(req.getZGZRQ()); + ddtxxBO.setYZFP(ConfigureConstant.STRING_0); + ddtxxBO.setORIGINDDH(req.getZJSDH()); //TODO lfl 清单标志怎么处理? ddtxxBO.setQDBZ("0"); //明细信息 @@ -3511,6 +3520,8 @@ public class BeanTransitionUtils { ddmxxxBO.setJE(detail.getZHSJE()); ddmxxxBO.setHSBZ(ConfigureConstant.STRING_1); ddmxxxBO.setSE(detail.getZZSE()); + ddmxxxBO.setPH(detail.getCHARG()); + ddmxxxBO.setKB(detail.getKTYPE()); //TODO lfl 优惠政策标识 取税编对应的优惠政策标识! ddmxxxBO.setYHZCBS("0"); ddmxList.add(ddmxxxBO); diff --git a/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml b/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml index 83bb11fa..719b806d 100644 --- a/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml +++ b/order-management-consumer/src/main/resources/mybatis/mapper/OrderProcessInfoMapper.xml @@ -50,6 +50,9 @@ + + + @@ -85,7 +88,7 @@ ghf_mc, ghf_nsrsbh, kpxm, ddcjsj, ddlx, ddzt, ddly, ywlx,ywlx_id,kpfs, sbyy, order_status, create_time, update_time,xhf_nsrsbh,xhf_mc,ent_id,sksbdm,fg_status,edit_status,num,check_status,check_time, - bzdh,xtly,gsdm,bhzt,ygxm,kppzh,pzgzrq,yzfp + bzdh,xtly,gsdm,bhzt,ygxm,kppzh,pzgzrq,yzfp,origin_ddh,origin_order_id,kb @@ -853,6 +876,15 @@ yzfp = #{processInfo.yzfp,jdbcType=VARCHAR}, + + origin_ddh = #{processInfo.originDdh,jdbcType=VARCHAR}, + + + origin_order_id = #{processInfo.originOrderId,jdbcType=VARCHAR}, + + + kb = #{processInfo.kb,jdbcType=VARCHAR}, +