diff --git a/jianshui-admin/src/main/java/com/jianshui/api/config/WebserviceResponseHandler.java b/jianshui-admin/src/main/java/com/jianshui/api/config/WebserviceResponseHandler.java index 9f62980..fcbc1bb 100644 --- a/jianshui-admin/src/main/java/com/jianshui/api/config/WebserviceResponseHandler.java +++ b/jianshui-admin/src/main/java/com/jianshui/api/config/WebserviceResponseHandler.java @@ -1,10 +1,7 @@ package com.jianshui.api.config; import cn.hutool.core.util.XmlUtil; -import org.w3c.dom.CDATASection; -import org.w3c.dom.Document; -import org.w3c.dom.Element; -import org.w3c.dom.Node; +import org.w3c.dom.*; import javax.xml.namespace.QName; import javax.xml.parsers.DocumentBuilderFactory; @@ -38,9 +35,11 @@ public class WebserviceResponseHandler implements SOAPHandler Sph; + @JSONField(name = "mfdwgr") + private String mfdwgr; + + @JSONField(name = "djzh") + private String djzh; + + @JSONField(name = "cyjg") + private String cyjg; + + @JSONField(name = "smfdwgr") + private String smfdwgr; + + @JSONField(name = "cpxh") + private String cpxh; + + @JSONField(name = "escsc") + private String escsc; + + @JSONField(name = "cycs") + private String cycs; + + @JSONField(name = "mfdwgrdz") + private String mfdwgrdz; + + @JSONField(name = "clsbh") + private String clsbh; + + @JSONField(name = "smfdh") + private String smfdh; + + @JSONField(name = "escscdz") + private String escscdz; + + @JSONField(name = "smfdwgrzz") + private String smfdwgrzz; + + @JSONField(name = "smfdwdmsfzh") + private String smfdwdmsfzh; + @JSONField(name = "escscdh") + private String escscdh; + @JSONField(name = "cpzh") + private String cpzh; + + @JSONField(name = "escsckhyhzh") + private String escsckhyhzh; + + @JSONField(name = "cjhj") + private String cjhj; + + @JSONField(name = "xdpbz") + private String xdpbz; + + @JSONField(name = "cllx") + private String cllx; + + @JSONField(name = "qdbz") + private String qdbz; + + @JSONField(name = "cpybz") + private String cpybz; + + @JSONField(name = "zrdcgsmc") + private String zrdcgsmc; + + @JSONField(name = "escscsbh") + private String escscsbh; + + @JSONField(name = "mfdwdmsfzh") + private String mfdwdmsfzh; + + @JSONField(name = "mfdh") + private String mfdh; + + + } diff --git a/jianshui-income/src/main/java/com/jianshui/income/service/impl/EleCheckInvoiceImpl.java b/jianshui-income/src/main/java/com/jianshui/income/service/impl/EleCheckInvoiceImpl.java index 7838262..55eee20 100644 --- a/jianshui-income/src/main/java/com/jianshui/income/service/impl/EleCheckInvoiceImpl.java +++ b/jianshui-income/src/main/java/com/jianshui/income/service/impl/EleCheckInvoiceImpl.java @@ -1,5 +1,6 @@ package com.jianshui.income.service.impl; +import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.jianshui.common.core.domain.AjaxResult; @@ -117,12 +118,21 @@ public class EleCheckInvoiceImpl implements ICheckInvoice { // 如果需要扣费 robUserMoney += 1; } + String errorMsg = resultJson.getString("message"); JSONObject result = new JSONObject(); result.put("robUserMoney", robUserMoney); return new AjaxResult(Integer.parseInt(checkResult), errorMsg, result); } invoiceCheck = this.handelCheckResult(invoiceCheck, resultContent); // 批量处理一把 + + // TODO: 2023/6/5 确定一下哪些需要扣钱 + List cyjgList = Arrays.asList("9999", "0002", "0005", "1004", "1005", "1006", "1007", "1008", "1009","1010", "1011", "1012", "1013", "1014", "1015", "1020", "1021"); + if (cyjgList.contains(invoiceCheck.getCyjg())) { + log.info("单个发票校验错误结果:companyId=" + companyId + ",errorCode=" + invoiceCheck.getCyjg() + ",returnMessage=" + invoiceCheck.getCyjgxx()); + return new AjaxResult(5,invoiceCheck.getCyjgxx()); + } + // note-gong 2021/6/17 9:20 查询下数据库中是否存在相同发票;存在就判断下状态是否一致,不一致扣款;不存在就直接扣款 DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Calendar cal = Calendar.getInstance(); @@ -166,6 +176,15 @@ public class EleCheckInvoiceImpl implements ICheckInvoice { result.put("resultContent", resultContent); // 开始批量更新数据库 老田加的队列。这里没有。他写的队列也不对,上面已经插入过了这里还插入。SB // RedisQueueUtil.build().setData(invoiceCheck).onQueue("income_result_save_consumer").retry(0).dispatch(); + + // TODO: 2023/6/5 测试关闭 + // :校验是否查询本企业发票 + /*String xhfsbh = invoiceCheck.getXhfsbh() != null ? invoiceCheck.getXhfsbh() : ""; + if(StrUtil.isEmpty(xhfsbh) || !companyservice.getSellertax().equals(xhfsbh)){ + log.info("单个发票校验非本企业发票:companyId=" + companyId + ",errorCode=" + invoiceCheck.getCyjg() + ",returnMessage=" + invoiceCheck.getCyjgxx()); + return new AjaxResult(34,"授权企业与所查询发票的购方不一致,请进行核实"); + }*/ + // 更新成功处理返回数据 return AjaxResult.success(result); }