From ca52e332b54c1ad93268ff29b1b3fc083e168568 Mon Sep 17 00:00:00 2001
From: yefei <yefei@ele-cloud.com>
Date: Mon, 10 Apr 2023 16:34:22 +0800
Subject: [PATCH] =?UTF-8?q?ariesy=20=E6=B7=BB=E5=8A=A0=E7=BC=BA=E5=A4=B1?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6=20v2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../erp/dao/SignCheckRecordInvoiceDao.java    | 17 ++++++
 .../impl/SignCheckRecordServiceImpl.java      | 58 +++++++++++++++++++
 2 files changed, 75 insertions(+)
 create mode 100644 dxhy-erp/src/main/java/com/dxhy/erp/dao/SignCheckRecordInvoiceDao.java
 create mode 100644 dxhy-erp/src/main/java/com/dxhy/erp/service/impl/SignCheckRecordServiceImpl.java

diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/dao/SignCheckRecordInvoiceDao.java b/dxhy-erp/src/main/java/com/dxhy/erp/dao/SignCheckRecordInvoiceDao.java
new file mode 100644
index 00000000..07b122b8
--- /dev/null
+++ b/dxhy-erp/src/main/java/com/dxhy/erp/dao/SignCheckRecordInvoiceDao.java
@@ -0,0 +1,17 @@
+package com.dxhy.erp.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.dxhy.erp.entity.TdxCheckRecordInvoice;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ *
+ * 发票查验表dao
+ *
+ * @author jiaohongyang
+ * @date 2019年3月26日 下午6:02:48
+ */
+@Mapper
+public interface SignCheckRecordInvoiceDao extends BaseMapper<TdxCheckRecordInvoice> {
+
+}
diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/SignCheckRecordServiceImpl.java b/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/SignCheckRecordServiceImpl.java
new file mode 100644
index 00000000..185c1679
--- /dev/null
+++ b/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/SignCheckRecordServiceImpl.java
@@ -0,0 +1,58 @@
+package com.dxhy.erp.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.dxhy.common.constant.DbConstant;
+import com.dxhy.common.datasource.config.DynamicContextHolder;
+import com.dxhy.common.service.impl.MpBaseServiceImpl;
+import com.dxhy.erp.dao.SignCheckRecordInvoiceDao;
+import com.dxhy.erp.entity.TdxCheckRecordInvoice;
+import com.dxhy.erp.service.SignCheckRecordService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * 发票查验表业务逻辑实现类
+ *
+ * @author ld
+ */
+@Service("signCheckRecordService")
+@Slf4j
+
+public class SignCheckRecordServiceImpl extends MpBaseServiceImpl<SignCheckRecordInvoiceDao, TdxCheckRecordInvoice>
+    implements SignCheckRecordService {
+
+    @Override
+    public TdxCheckRecordInvoice getCheckInvoiceByUuid(String uuid) {
+        QueryWrapper<TdxCheckRecordInvoice> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("uuid", uuid);
+        return super.getOne(queryWrapper);
+    }
+
+    @Override
+    public void saveCheckRecordInvoice(TdxCheckRecordInvoice checkRecordInvoice, String dbName) {
+        DynamicContextHolder.push(dbName + DbConstant.BUSINESS_WRITE);
+        if (checkRecordInvoice != null) {
+            TdxCheckRecordInvoice checkRecordTmp = getCheckInvoiceByUuid(checkRecordInvoice.getUuid());
+            if (checkRecordTmp != null) {
+                if (StringUtils.isNotBlank(checkRecordTmp.getCycs())) {
+                    int cycs = Integer.parseInt(checkRecordTmp.getCycs()) + 1;
+                    checkRecordInvoice.setCycs(cycs + "");
+                } else {
+                    checkRecordInvoice.setCycs("1");
+                }
+            } else {
+                checkRecordInvoice.setCycs("1");
+            }
+            // 删除重复数据，防止重复的操作
+            QueryWrapper<TdxCheckRecordInvoice> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("uuid", checkRecordInvoice.getUuid());
+            remove(queryWrapper);
+            // 保存数据
+            save(checkRecordInvoice);
+
+        }
+    }
+
+}