Compare commits

..

No commits in common. 'master' and 'zkh' have entirely different histories.
master ... zkh

  1. 2
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/controller/InvoiceController.java
  2. 8
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/model/OrderListQuery.java
  3. 2
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/model/PageOrderInvoiceDetail.java
  4. 1
      order-management-invoice/src/main/java/com/dxhy/order/invoice/module/invoice/service/impl/OrderInvoiceInfoServiceImpl.java
  5. 31
      order-management-invoice/src/main/resources/mybatis/mapper/OrderInvoiceInfoMapper.xml
  6. 4
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/controller/OrderHandleController.java
  7. 2
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/OrderHandleService.java
  8. 4
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/OrderHandleServiceImpl.java
  9. 11
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/SkOrderServiceImpl.java
  10. 51
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/bespoke/service/impl/YyOrderServiceImpl.java
  11. 12
      order-management-order/src/main/java/com/dxhy/order/consumer/modules/validate/service/impl/ValidateInterfaceOrderServiceImpl.java

@ -66,8 +66,6 @@ public class InvoiceController {
log.debug("{}发票明细列表查询参数:{}", LOGGER_MSG, JsonUtils.getInstance().toJsonString(orderBatchQuery));
//数据转换
Map<String, Object> paramMap = PageBeanConvertUtil.convertToMap(orderBatchQuery);
paramMap.put("pzhStart", orderBatchQuery.getPzhStart());
paramMap.put("pzhEnd", orderBatchQuery.getPzhEnd());
if (StringUtils.isBlank(orderBatchQuery.getXhfNsrsbh())) {
log.error("{},请求税号为空!", LOGGER_MSG);
return R.error(OrderValidateEnum.TAXCODE_ISNULL.getKey(), OrderValidateEnum.TAXCODE_ISNULL.getMessage());

@ -260,13 +260,5 @@ public class OrderListQuery {
* 短信交付状态 0未交付 1已交付
*/
private String shortMsgPushStatus;
/**
* 凭证号排序
*/
private String pzhStart;
/**
* 订单号排序
*/
private String pzhEnd;
}

@ -86,6 +86,4 @@ public class PageOrderInvoiceDetail implements Serializable {
* 前端使用,取值为特殊票种发票查询 特殊票种
*/
private String fpcxTspz;
private String pzh;
}

@ -409,7 +409,6 @@ public class OrderInvoiceInfoServiceImpl implements OrderInvoiceInfoService {
@Override
public PageInfo<PageOrderInvoiceDetail> selectRedAndInvoiceByMap(Map<String, Object> paramMap, List<String> shList, List<String> entList) {
log.info("MAP===={}", JsonUtils.getInstance().toJsonString(paramMap));
int pageSize = Integer.parseInt(String.valueOf(paramMap.get(ConfigureConstant.STRING_PAGE_SIZE)));
int currPage = Integer.parseInt(String.valueOf(paramMap.get(ConfigureConstant.STRING_CURR_PAGE)));

@ -136,7 +136,6 @@
<result column="sykchje" property="sykchje" jdbcType="VARCHAR"/>
<result column="sykchbhsje" jdbcType="VARCHAR" property="sykchbhsje"/>
<result column="sykchse" jdbcType="VARCHAR" property="sykchse"/>
<result column="byzd2" jdbcType="VARCHAR" property="pzh"/>
</resultMap>
@ -1326,8 +1325,8 @@
oii.qdfwlx,
oii.qdyhm,
oii.skcwdm,
oii.skcwms,
oi.byzd2
oii.skcwms
FROM order_invoice_info oii
LEFT JOIN order_info oi ON oii.fpqqlsh = oi.fpqqlsh
LEFT JOIN order_process_info opi ON oii.fpqqlsh = opi.fpqqlsh
@ -1636,12 +1635,6 @@
<if test="map.maxhjje!=null and map.maxhjje!= '' ">
and CAST(oii.kphjje AS DECIMAL(40,2)) &lt;= CAST(#{map.maxhjje,jdbcType=VARCHAR} as DECIMAL(40,2))
</if>
<if test="map.pzhStart !=null and map.pzhStart != '' ">
and CAST(oi.byzd2 AS UNSIGNED) &gt;= CAST(#{map.pzhStart,jdbcType=VARCHAR} as UNSIGNED)
</if>
<if test="map.pzhEnd !=null and map.pzhEnd != '' ">
and CAST(oi.byzd2 AS UNSIGNED) &lt;= CAST(#{map.pzhEnd,jdbcType=VARCHAR} as UNSIGNED)
</if>
</where>
</sql>
@ -1655,26 +1648,6 @@
<when test="map.orderBy !=null and map.orderBy == 'checkTime' ">
order by check_time desc
</when>
<when test="map.orderBy !=null and map.orderBy == '88' ">
order by CASE
WHEN oi.byzd2 IS NULL OR oi.byzd2 = '' THEN 1
ELSE 0
END,
CONVERT(oi.byzd2, UNSIGNED) asc,ddh DESC
</when>
<when test="map.orderBy !=null and map.orderBy == '99' ">
order by CASE
WHEN oi.byzd2 IS NULL OR oi.byzd2 = '' THEN 1
ELSE 0
END,
CONVERT(oi.byzd2, UNSIGNED) asc,ddh asc
</when>
<when test="map.orderBy !=null and map.orderBy == '66' ">
order by CONVERT(oi.byzd2, UNSIGNED) DESC,ddh DESC
</when>
<when test="map.orderBy !=null and map.orderBy == '77' ">
order by CONVERT(oi.byzd2, UNSIGNED) DESC,ddh asc
</when>
<otherwise>
ORDER BY kprq DESC
</otherwise>

@ -218,9 +218,9 @@ public class OrderHandleController {
if (fpqqlshList == null || fpqqlshList.isEmpty()) {
return R.error("发票请求流水号不能为空");
}
String ddh = orderHandleService.createOrderByCopyInvoice(fpqqlshList.get(ConfigureConstant.INT_0), shList, entList,orderBatchQuery.getFpzldm());
orderHandleService.createOrderByCopyInvoice(fpqqlshList.get(ConfigureConstant.INT_0), shList, entList,orderBatchQuery.getFpzldm());
return R.ok().put(ConfigureConstant.MSG, "订单复制成功,请前往订单管理-订单处理使用订单号:"+ddh+"查询");
return R.ok().put(ConfigureConstant.MSG, "订单复制成功");
} catch (OrderReceiveException e) {
log.error("发票复制订单异常", e);
return R.error(e.getMessage());

@ -46,7 +46,7 @@ public interface OrderHandleService {
* @return
* @throws OrderReceiveException
*/
String createOrderByCopyInvoice(String fpqqlsh, List<String> shList, List<String> entList,String fpzldm) throws OrderReceiveException;
int createOrderByCopyInvoice(String fpqqlsh, List<String> shList, List<String> entList,String fpzldm) throws OrderReceiveException;
FileModel saveInvoiceFile(OrderInvoiceInfo orderInvoiceInfo);

@ -123,7 +123,7 @@ public class OrderHandleServiceImpl implements OrderHandleService {
}
@Override
public String createOrderByCopyInvoice(String fpqqlsh, List<String> shList, List<String> entList, String fpzldm) throws OrderReceiveException {
public int createOrderByCopyInvoice(String fpqqlsh, List<String> shList, List<String> entList, String fpzldm) throws OrderReceiveException {
//查询发票信息
OrderInvoiceInfo orderInvoiceInfoParam = new OrderInvoiceInfo();
orderInvoiceInfoParam.setFpqqlsh(fpqqlsh);
@ -258,7 +258,7 @@ public class OrderHandleServiceImpl implements OrderHandleService {
orderInfoQd.setUpdateTime(now);
orderInfoQdMapper.insertOrderInfoQd(orderInfoQd);
}
return ddh;
return ConfigureConstant.INT_1;
}
@Override

@ -180,14 +180,8 @@ public class SkOrderServiceImpl implements OrderService {
try {
if (locked){
List<SkOrderItemInfo> skOrderItemInfoList = skOrderItemInfoMapper.queryOrderItemInfo(skOrderInfo.getId());
boolean fpresent = skOrderItemInfoList.stream().anyMatch(item->DecimalCalculateUtil.stringLessZero(item.getHsje()));
boolean zpresent = skOrderItemInfoList.stream().anyMatch(item->DecimalCalculateUtil.stringMoreZero(item.getHsje()));
if (fpresent && zpresent && skOrderItemInfoList.size() > ConfigureConstant.INT_2){
backMessage.add(String.format(message, skOrderInfo.getXsddm(), "含有负数行订单明细不能超过两行"));
continue;
}
if (CollectionUtils.isNotEmpty(skOrderItemInfoList)) {
DdpcxxReqBO ddpcxxReqBO = transitionReadData(fpresent && zpresent,skOrderInfo, skOrderItemInfoList, deptEntity);
DdpcxxReqBO ddpcxxReqBO = transitionReadData(skOrderInfo, skOrderItemInfoList, deptEntity);
DdpcxxRspBO ddpcxxRspBO = allocateInvoiceInterfaceServiceImplV3.allocateInvoicesV3(ddpcxxReqBO, "", null, ConfigurerInfo.INTERFACE_VERSION_V6);
log.debug("V3生成预制返回信息:{}", JSON.toJSONString(ddpcxxRspBO));
String format = String.format(message, skOrderInfo.getXsddm(), ddpcxxRspBO.getZTXX());
@ -344,7 +338,7 @@ public class SkOrderServiceImpl implements OrderService {
return ConfigureConstant.INT_1;
}
public DdpcxxReqBO transitionReadData(boolean isZk, SkOrderInfo skOrderInfo, List<SkOrderItemInfo> skOrderItemInfoList, DeptEntity deptEntity) {
public DdpcxxReqBO transitionReadData(SkOrderInfo skOrderInfo, List<SkOrderItemInfo> skOrderItemInfoList, DeptEntity deptEntity) {
TaxEquipmentInfo taxEquipmentInfo = simsBackService.queryTaxEquipment(deptEntity.getTaxpayerCode(), deptEntity.getDeptId());
@ -393,6 +387,7 @@ public class SkOrderServiceImpl implements OrderService {
String invoiceAmount = ConfigureConstant.STRING_0;
String taxAmount = ConfigureConstant.STRING_0;
boolean isZk = skOrderItemInfoList.size()>ConfigureConstant.INT_1;
String xmmc = skOrderItemInfoList.get(ConfigureConstant.INT_0).getCpmc();
if (isZk){
List<SkOrderItemInfo> collect = skOrderItemInfoList.stream().filter(item -> DecimalCalculateUtil.stringCompare(item.getHsje(), ConfigureConstant.STRING_0) > ConfigureConstant.INT_0).collect(Collectors.toList());

@ -6,10 +6,13 @@ import com.dxhy.base.common.constant.OrderManagementConstant;
import com.dxhy.base.common.model.OrderInfo;
import com.dxhy.base.common.model.R;
import com.dxhy.base.common.utils.DecimalCalculateUtil;
import com.dxhy.base.service.module.buyer.model.BuyerEntity;
import com.dxhy.base.service.module.buyer.service.BuyerService;
import com.dxhy.base.service.module.thirdservice.simsback.model.TaxEquipmentInfo;
import com.dxhy.base.service.module.thirdservice.simsback.service.SimsBackService;
import com.dxhy.base.service.module.thirdservice.user.model.DeptEntity;
import com.dxhy.base.service.module.thirdservice.user.service.UserInfoService;
import com.dxhy.base.service.openapi.protocol.qd.PageGfxxReq;
import com.dxhy.base.thirdservice.module.base.service.BaseService;
import com.dxhy.base.thirdservice.module.thirdservice.redis.service.RedissonService;
import com.dxhy.management.common.constant.ConfigureConstant;
@ -46,7 +49,6 @@ import org.redisson.api.RLock;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
@ -78,6 +80,8 @@ public class YyOrderServiceImpl implements OrderService {
@Resource
private AllocateInvoiceInterfaceServiceV3 allocateInvoiceInterfaceServiceImplV3;
@Resource
private BuyerService buyerService;
@Resource
private SimsBackService simsBackService;
@ -97,9 +101,6 @@ public class YyOrderServiceImpl implements OrderService {
@Resource
private RedissonService redissonService;
@Value("${exculd.nsrsbh}")
private String exculdNsrsbh;
//订单读入
@Override
public R orderRead(ReqParam reqParam) {
@ -183,14 +184,8 @@ public class YyOrderServiceImpl implements OrderService {
try {
if (locked){
List<YyOrderItemInfo> yyOrderItemInfoList = yyOrderItemInfoMapper.queryOrderItemInfo(yyOrderInfo.getId());
boolean fpresent = yyOrderItemInfoList.stream().anyMatch(item->DecimalCalculateUtil.stringLessZero(item.getIsum()));
boolean zpresent = yyOrderItemInfoList.stream().anyMatch(item->DecimalCalculateUtil.stringMoreZero(item.getIsum()));
if (fpresent && zpresent && yyOrderItemInfoList.size() > ConfigureConstant.INT_2){
backMessage.add(String.format(message, yyOrderInfo.getCdlcode(), "含有负数行订单明细不能超过两行"));
continue;
}
if (CollectionUtils.isNotEmpty(yyOrderItemInfoList)) {
DdpcxxReqBO ddpcxxReqBO = transitionReadData(fpresent && zpresent,yyOrderInfo, yyOrderItemInfoList, deptEntity);
DdpcxxReqBO ddpcxxReqBO = transitionReadData(yyOrderInfo, yyOrderItemInfoList, deptEntity);
DdpcxxRspBO ddpcxxRspBO = allocateInvoiceInterfaceServiceImplV3.allocateInvoicesV3(ddpcxxReqBO, "", null, ConfigurerInfo.INTERFACE_VERSION_V6);
log.debug("V3生成预制返回信息:{}", JSON.toJSONString(ddpcxxRspBO));
String format = String.format(message, yyOrderInfo.getCdlcode(), ddpcxxRspBO.getZTXX());
@ -300,27 +295,8 @@ public class YyOrderServiceImpl implements OrderService {
DynamicContextHolder.push(ConfigureConstant.MAIN);
tInvoiceInvmapMapper.deleteBackMsg(fphm);
for (NewTable newTable : newTableList) {
//判断是否存在逗号
log.debug("cdlCode:{}", newTable.getCDLCode());
List<String> ddhList = new ArrayList<>();
if (newTable.getCDLCode().contains(",") || newTable.getCDLCode().contains(",")){
String[] ddhs = newTable.getCDLCode().replace(",", ",").split(",");
ddhList = Arrays.asList(ddhs);
}else {
ddhList.add(newTable.getCDLCode());
}
log.debug("cdlCodeList:{}", JSON.toJSONString(ddhList));
for (String cdlCode : ddhList) {
DynamicContextHolder.push(nsrsbh);
log.debug("exculdNsrsbh:{}", exculdNsrsbh);
if (StringUtils.isNotBlank(exculdNsrsbh) && Arrays.asList(exculdNsrsbh.split(",")).contains(nsrsbh)){
NewTable newTableFull = new NewTable();
BeanUtil.copyProperties(newTable, newTableFull);
newTableFull.setCDLCode(cdlCode);
DynamicContextHolder.push(ConfigureConstant.MAIN);
count += tInvoiceInvmapMapper.insertBackMsg(newTableFull);
}else {
List<InvoiceBpmmap> ddbhList = yyOrderMapper.getDdbh(cdlCode);
List<InvoiceBpmmap> ddbhList = yyOrderMapper.getDdbh(newTable.getCDLCode());
log.debug("查询到中间表信息:{}", JSON.toJSONString(ddbhList));
if (CollectionUtils.isNotEmpty(ddbhList)) {
for (InvoiceBpmmap invoiceBpmmap : ddbhList) {
@ -328,16 +304,12 @@ public class YyOrderServiceImpl implements OrderService {
BeanUtil.copyProperties(newTable, newTableFull);
newTableFull.setBpmNo(invoiceBpmmap.getBpmno());
newTableFull.setBpmlsNo(invoiceBpmmap.getBpmlsno());
newTableFull.setCDLCode(cdlCode);
DynamicContextHolder.push(ConfigureConstant.MAIN);
count += tInvoiceInvmapMapper.insertBackMsg(newTableFull);
}
}
}
}
}
return count;
}
@ -378,10 +350,10 @@ public class YyOrderServiceImpl implements OrderService {
yyOrderInfo.setHsje(hsje.setScale(ConfigureConstant.INT_2, RoundingMode.HALF_UP).toPlainString());
yyOrderInfo.setSe(se.setScale(ConfigureConstant.INT_2, RoundingMode.HALF_UP).toPlainString());
yyOrderInfo.setBz(bz.toString());
if (ConfigureConstant.STRING_26.equals(yyOrderInfo.getCvouchtype())) {
if (yyOrderInfo.getCvouchtype().equals(ConfigureConstant.STRING_26)) {
yyOrderInfo.setCvouchtype(ConfigureConstant.STRING_001);
}
if (ConfigureConstant.STRING_27.equals(yyOrderInfo.getCvouchtype())) {
if (yyOrderInfo.getCvouchtype().equals(ConfigureConstant.STRING_27)) {
yyOrderInfo.setCvouchtype(ConfigureConstant.STRING_002);
}
yyOrderInfoMapper.insertYyOrderInfo(yyOrderInfo);
@ -389,7 +361,7 @@ public class YyOrderServiceImpl implements OrderService {
return ConfigureConstant.INT_1;
}
public DdpcxxReqBO transitionReadData(boolean isZk,YyOrderInfo yyOrderInfo, List<YyOrderItemInfo> yyOrderItemInfoList, DeptEntity deptEntity) {
public DdpcxxReqBO transitionReadData(YyOrderInfo yyOrderInfo, List<YyOrderItemInfo> yyOrderItemInfoList, DeptEntity deptEntity) {
TaxEquipmentInfo taxEquipmentInfo = simsBackService.queryTaxEquipment(deptEntity.getTaxpayerCode(), deptEntity.getDeptId());
@ -434,11 +406,12 @@ public class YyOrderServiceImpl implements OrderService {
// ddtxxBO.setSFZSXFYHZH(ebsOrderInfo.getSalebankAccountJud());
ddtxxBO.setGMFLX("04");
ddtxxBO.setBYZD1(yyOrderInfo.getYscdlcode());
ddtxxBO.setBYZD2(yyOrderInfo.getCpznum());
String invoiceAmount = ConfigureConstant.STRING_0;
String taxAmount = ConfigureConstant.STRING_0;
boolean isZk = yyOrderItemInfoList.size()>ConfigureConstant.INT_1;
String xmmc = yyOrderItemInfoList.get(ConfigureConstant.INT_0).getCinvname();
if (isZk){
List<YyOrderItemInfo> collect = yyOrderItemInfoList.stream().filter(item -> DecimalCalculateUtil.stringCompare(item.getIsum(), ConfigureConstant.STRING_0) > ConfigureConstant.INT_0).collect(Collectors.toList());

@ -528,12 +528,12 @@ public class ValidateInterfaceOrderServiceImpl implements ValidateInterfaceOrder
resultMapList.add(checkResultMap);
}
//订单号格式校验,只能是数字、字母、#、_、-
// if (StringUtils.isNotBlank(ddh)) {
// Matcher matcher = PatternConstant.DDH_PATTERN.matcher(ddh);
// if (!matcher.matches()) {
// resultMapList.add(OrderCheckParamUtil.generateErrorMap(prefixMsg, OrderValidateEnum.CHECK_ISS7PRI_107067A));
// }
// }
if (StringUtils.isNotBlank(ddh)) {
Matcher matcher = PatternConstant.DDH_PATTERN.matcher(ddh);
if (!matcher.matches()) {
resultMapList.add(OrderCheckParamUtil.generateErrorMap(prefixMsg, OrderValidateEnum.CHECK_ISS7PRI_107067A));
}
}
/**
* 订单主体-订单日期

Loading…
Cancel
Save