ariesy 添加缺失文件 v2

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> {
+
+}

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);
+
+        }
+    }
+
+}