From 17fe9514e8fc186cf2b01394ace6c503d0b4b392 Mon Sep 17 00:00:00 2001
From: yefei <yefei@ele-cloud.com>
Date: Fri, 14 Apr 2023 10:18:52 +0800
Subject: [PATCH 1/5] =?UTF-8?q?ariesy=20=E8=A7=A3=E5=86=B3=E8=BF=9B?=
 =?UTF-8?q?=E9=A1=B9bug=20v1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/BaseInvoiceController.java     |  5 ++++
 .../BaseRzTDxRecordInvoiceController.java     |  1 +
 .../receipt/BaseReceiptOutServiceImpl.java    |  6 ++--
 .../resources/mapper/BaseSggxcxMapper.xml     | 28 +++++++++++++++++--
 .../dxhy/core/controller/ExcelController.java |  2 +-
 .../InvoiceDetailServiceImpl.java             | 18 ++++++++----
 .../com/dxhy/core/util/InvoiceQueryUtil.java  |  2 +-
 .../erp/controller/InterfaceController.java   | 10 +++++++
 .../service/fpqs/impl/FpqsServiceImpl.java    |  6 +++-
 .../fpqs/impl/SignFpqsServiceImpl.java        |  9 +++++-
 10 files changed, 74 insertions(+), 13 deletions(-)

diff --git a/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java b/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java
index 74c4d2fa..e80b0e81 100644
--- a/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java
+++ b/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java
@@ -423,6 +423,10 @@ public class BaseInvoiceController extends AbstractController {
         pramsMap.put("paymentDateEnd", map.get("paymentDateEnd"));
         pramsMap.put("settlementNo", map.get("settlementNo"));
         pramsMap.put("voucherNumber", map.get("voucherNumber"));
+        pramsMap.put("snVoucherNumber", map.get("snVoucherNumber"));
+        pramsMap.put("postingTime", map.get("postingTime"));
+        pramsMap.put("imageId", map.get("imageId"));
+        pramsMap.put("accountPeriod", map.get("accountPeriod"));
         String inAccountStatus = (String)map.get("inAccountStatus");
 
         if (sfkrz != null) {
@@ -628,6 +632,7 @@ public class BaseInvoiceController extends AbstractController {
             return ResponseEntity.ok(R.error("签收状态不能为空！"));
         }
         String qsflag = getUserInfo().getQsStatus();
+        log.info("签收开关qsflag:{}",qsflag);
         if ("1".equals(qsflag)) {
             pramsMap.put("qszt", "1");
         }
diff --git a/dxhy-base/src/main/java/com/dxhy/base/controller/BaseRzTDxRecordInvoiceController.java b/dxhy-base/src/main/java/com/dxhy/base/controller/BaseRzTDxRecordInvoiceController.java
index 4574ac2a..a95d93f5 100644
--- a/dxhy-base/src/main/java/com/dxhy/base/controller/BaseRzTDxRecordInvoiceController.java
+++ b/dxhy-base/src/main/java/com/dxhy/base/controller/BaseRzTDxRecordInvoiceController.java
@@ -467,6 +467,7 @@ public class BaseRzTDxRecordInvoiceController extends AbstractController {
         pramsMap.put("gfsh", gfshList);
         String qsflag = getUserInfo().getQsStatus();
         pramsMap.put("qsflag", qsflag);
+        log.info("签收认证状态为:{}",qsflag);
         if (!StringHelper.isBlank(datalist)) {
 
             pramsMap.put("datalist", datalist);
diff --git a/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java b/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java
index d20e2ef6..d53bd613 100644
--- a/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java
+++ b/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java
@@ -199,7 +199,8 @@ public class BaseReceiptOutServiceImpl extends MpBaseServiceImpl<BaseReceiptOutD
         QueryWrapper<BaseTDxOutReason> query = new QueryWrapper<>();
         query.eq("reason_code", record.getOutReason());
         BaseTDxOutReason reason = baseTDxOutReasonDao.selectOne(query);
-        vo.setReason(reason.getOutReason());
+        if (reason != null)
+            vo.setReason(reason.getOutReason());
         return vo;
     }
 
@@ -651,7 +652,8 @@ public class BaseReceiptOutServiceImpl extends MpBaseServiceImpl<BaseReceiptOutD
         QueryWrapper<BaseTDxOutReason> query = new QueryWrapper<>();
         query.eq("reason_code", record.getOutReason());
         BaseTDxOutReason reason = baseTDxOutReasonDao.selectOne(query);
-        vo.setReason(reason.getOutReason());
+        if (reason != null)
+            vo.setReason(reason.getOutReason());
         // 认证日期 string类型的长日期转为string类型的短日期
         String certDate = record.getCertDate();
         Date date = new Date();
diff --git a/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml b/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml
index 6dfa02e8..a0e772f9 100644
--- a/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml
+++ b/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml
@@ -64,7 +64,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE date_format(t.invoice_date,'%Y-%m-%d') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.auth_status in('0','5','6')
         and t.export_mark = '0'
@@ -171,6 +171,18 @@
         <if test="qsksrq==null or qsksrq=='' or qsjsrq==null or qsjsrq==''">
             order by t.invoice_date desc
         </if>
+        <if test="snVoucherNumber != null and snVoucherNumber != '' and snVoucherNumber != 'null' and snVoucherNumber != '99'">
+            and t.sn_voucher_number = #{snVoucherNumber}
+        </if>
+        <if test="postingTime != null and postingTime != '' and postingTime != 'null' and postingTime != '99'">
+            and t.postingTime = #{postingTime}
+        </if>
+        <if test="imageId != null and imageId != '' and imageId != 'null' and imageId != '99'">
+            and t.image_id = #{imageId}
+        </if>
+        <if test="accountPeriod != null and accountPeriod != '' and accountPeriod != 'null' and accountPeriod != '99'">
+            and t.account_period = #{accountPeriod}
+        </if>
     </select>
     <select id="selectDksh" parameterType="java.util.Map"
             resultType="com.dxhy.base.entity.BaseTDxDkCount"
@@ -199,7 +211,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE to_char(t.invoice_date,'yyyy-MM-dd') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.auth_status in('0','5','6')
         and t.export_mark = '0'
@@ -323,6 +335,18 @@
         <if test="eleInvoiceNo!=null and eleInvoiceNo!='' and eleInvoiceNo!='null'">
             and t.ele_invoice_no = #{eleInvoiceNo}
         </if>
+        <if test="snVoucherNumber != null and snVoucherNumber != '' and snVoucherNumber != 'null' and snVoucherNumber != '99'">
+            and t.sn_voucher_number = #{snVoucherNumber}
+        </if>
+        <if test="postingTime != null and postingTime != '' and postingTime != 'null' and postingTime != '99'">
+            and t.postingTime = #{postingTime}
+        </if>
+        <if test="imageId != null and imageId != '' and imageId != 'null' and imageId != '99'">
+            and t.image_id = #{imageId}
+        </if>
+        <if test="accountPeriod != null and accountPeriod != '' and accountPeriod != 'null' and accountPeriod != '99'">
+            and t.account_period = #{accountPeriod}
+        </if>
     </select>
 
     <select id="selectHj" parameterType="java.util.Map"
diff --git a/dxhy-core/src/main/java/com/dxhy/core/controller/ExcelController.java b/dxhy-core/src/main/java/com/dxhy/core/controller/ExcelController.java
index 59f39471..0f724a53 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/controller/ExcelController.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/controller/ExcelController.java
@@ -253,7 +253,7 @@ public class ExcelController extends AbstractController {
 
             Map<String, Object> returnMap = new HashMap<>(2);
             returnMap.put("id",tdxExcelExprortlog.getId());
-            returnMap.put("setviceType","2");
+            returnMap.put("serviceType","2");
 
             return ResponseEntity.ok(R.ok().put("data", returnMap));
         } catch (Exception e) {
diff --git a/dxhy-core/src/main/java/com/dxhy/core/service/invoicedetail/InvoiceDetailServiceImpl.java b/dxhy-core/src/main/java/com/dxhy/core/service/invoicedetail/InvoiceDetailServiceImpl.java
index 8fdb658a..ea32dfbe 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/service/invoicedetail/InvoiceDetailServiceImpl.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/service/invoicedetail/InvoiceDetailServiceImpl.java
@@ -158,10 +158,18 @@ public class InvoiceDetailServiceImpl extends MpBaseServiceImpl<TDxRecordInvoice
 
         // 取发票上的价税合计
         String totalAmount = checkRecordVo.getTotalAmount();
-        // 价税合计小写
-        checkInfo.put("detailAmountTotal", totalAmount);
-        // 价税合计大写
-        checkInfo.put("stringTotalAmount", NumberToCN.number2CNMontrayUnit(new BigDecimal(totalAmount)));
+        if(totalAmount != null && StringUtils.isNoneBlank(totalAmount)) {
+            log.info("totalAmount={}",totalAmount);
+            // 价税合计小写
+            checkInfo.put("detailAmountTotal", totalAmount);
+            // 价税合计大写
+            checkInfo.put("stringTotalAmount", NumberToCN.number2CNMontrayUnit(new BigDecimal(totalAmount)));
+        }else{
+            // 价税合计小写
+            checkInfo.put("detailAmountTotal", "0");
+            // 价税合计大写
+            checkInfo.put("stringTotalAmount", "零");
+        }
         // 发票票面信息
         checkInfo.put("invoiceSubjectList", JSON.toJSON(checkRecordVo));
         // 机动车部分信息
@@ -277,7 +285,7 @@ public class InvoiceDetailServiceImpl extends MpBaseServiceImpl<TDxRecordInvoice
             }
             checkRecordVo.setTotalAmount(MathUtil.round(detailAmount.toPlainString()));
         } else {
-            if (invoiceRecord.getTotalAmount() == null) {
+            if (invoiceRecord.getTotalAmount() != null) {
                 BigDecimal add = invoiceRecord.getInvoiceAmount().add(invoiceRecord.getTaxAmount());
                 checkRecordVo.setTotalAmount(MathUtil.round(add.toPlainString()));
             } else {
diff --git a/dxhy-core/src/main/java/com/dxhy/core/util/InvoiceQueryUtil.java b/dxhy-core/src/main/java/com/dxhy/core/util/InvoiceQueryUtil.java
index 9955a3b0..3b0572d6 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/util/InvoiceQueryUtil.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/util/InvoiceQueryUtil.java
@@ -164,7 +164,7 @@ public class InvoiceQueryUtil {
             if(FplxEnum.QDZZP.getFplxDm().equals(invoiceType) || FplxEnum.QDPP.getFplxDm().equals(invoiceType)){
                 requestData.put("invoiceType", "31");
                 requestData.put("invoiceCode", "");
-                requestData.put("invoiceNo", invoiceNo);
+                requestData.put("invoiceNo", invoiceCode + invoiceNo);
             }else {
                 requestData.put("invoiceType", iu.getFplxdm());
                 requestData.put("invoiceCode", invoiceCode);
diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/controller/InterfaceController.java b/dxhy-erp/src/main/java/com/dxhy/erp/controller/InterfaceController.java
index 46b9ccc1..7eaed13d 100644
--- a/dxhy-erp/src/main/java/com/dxhy/erp/controller/InterfaceController.java
+++ b/dxhy-erp/src/main/java/com/dxhy/erp/controller/InterfaceController.java
@@ -712,6 +712,16 @@ public class InterfaceController extends AbstractController {
                 returnResult = invoicePoolService.salsePush(globalInfo, requestParam, request, response, authorize);
                 break;
             // 接口编码不存在
+
+            // 获取单张发票
+            case "INVOICE.SINGLEINVOICECHECK":
+                returnResult = gatherService.singleInvoiceChenck(globalInfo, requestParam, request, response, authorize);
+                break;
+            // 获取单张发票
+            case "INVOICE.SYNCINVOICEINFO":
+                returnResult = gatherService.syncInvoiceInfo(globalInfo, requestParam, request, response, authorize);
+                break;
+
             default:
                 returnResult = authStatusService.getInterfaceCodeError(globalInfo);
                 break;
diff --git a/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/FpqsServiceImpl.java b/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/FpqsServiceImpl.java
index 17848afd..6d0d2e7f 100644
--- a/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/FpqsServiceImpl.java
+++ b/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/FpqsServiceImpl.java
@@ -92,7 +92,11 @@ public class FpqsServiceImpl extends MpBaseServiceImpl<SignRecordInvoiceDao, TDx
         // 1、基础信息校验
         String note ="";
         String uuid ="";
-        uuid = pramsMap.get("invoiceCode") + pramsMap.get("invoiceNo");
+        if(pramsMap.get("invoiceCode") != null) {
+            uuid = pramsMap.get("invoiceCode") + pramsMap.get("invoiceNo");
+        }else{
+            uuid = pramsMap.get("invoiceNo");
+        }
         if(!FplxEnum.QDZZP.getFplxDm().equals(invoiceType)){
             note = signRulesUtils.validateInvoiceInfo(pramsMap.get("invoiceCode"), pramsMap.get("invoiceNo"));
         }
diff --git a/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/SignFpqsServiceImpl.java b/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/SignFpqsServiceImpl.java
index b117e35c..b6438f7b 100644
--- a/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/SignFpqsServiceImpl.java
+++ b/dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/SignFpqsServiceImpl.java
@@ -59,6 +59,7 @@ import javax.annotation.Resource;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.math.BigDecimal;
+import java.security.acl.LastOwnerException;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -3386,7 +3387,13 @@ public class SignFpqsServiceImpl extends MpBaseServiceImpl<SignRecordInvoiceDao,
             for (int i = 0; i < resultList.size(); i++) {
                 QsExcelEntity qsExcelEntity = new QsExcelEntity();
                 BeanUtils.copyProperties(qsExcelEntity,resultList.get(i));
-                qsExcelEntity.setInvoiceAmount(AmountFormatUtil.fmtMicrometer(MathUtil.round(resultList.get(i).getTotalAmount().toPlainString())));
+
+                log.info("导出的发票数据魏:{}",JSONObject.toJSONString(resultList.get(i)));
+                log.info("totalAmount={}",resultList.get(i).getTotalAmount());
+
+                if(resultList.get(i) != null && resultList.get(i).getInvoiceAmount() != null) {
+                    qsExcelEntity.setInvoiceAmount(AmountFormatUtil.fmtMicrometer(MathUtil.round(resultList.get(i).getInvoiceAmount().toPlainString())));
+                }
                 excelList.add(qsExcelEntity);
             }
         }

From 6f284d26f3bdaeb391aa3c53fcea6f1544f32a3b Mon Sep 17 00:00:00 2001
From: yefei <yefei@ele-cloud.com>
Date: Fri, 14 Apr 2023 14:15:09 +0800
Subject: [PATCH 2/5] =?UTF-8?q?ariesy=20=E8=A7=A3=E5=86=B3=E8=BF=9B?=
 =?UTF-8?q?=E9=A1=B9bug=20v2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../BaseInvoiceManualCheckServiceImpl.java    |  8 +++--
 .../receipt/BaseReceiptOutServiceImpl.java    |  6 ++--
 .../resources/mapper/BaseSggxcxMapper.xml     | 32 +++++++++----------
 3 files changed, 26 insertions(+), 20 deletions(-)

diff --git a/dxhy-base/src/main/java/com/dxhy/base/service/invoicecheck/BaseInvoiceManualCheckServiceImpl.java b/dxhy-base/src/main/java/com/dxhy/base/service/invoicecheck/BaseInvoiceManualCheckServiceImpl.java
index f0ad784f..324d8afd 100644
--- a/dxhy-base/src/main/java/com/dxhy/base/service/invoicecheck/BaseInvoiceManualCheckServiceImpl.java
+++ b/dxhy-base/src/main/java/com/dxhy/base/service/invoicecheck/BaseInvoiceManualCheckServiceImpl.java
@@ -14,6 +14,7 @@ import java.util.Map;
 import javax.annotation.Resource;
 
 import com.dxhy.common.constant.DictConstant;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import com.alibaba.fastjson.JSONObject;
@@ -49,6 +50,7 @@ import com.github.pagehelper.PageInfo;
  * @version 1.0
  */
 @SuppressWarnings({"AlibabaLowerCamelCaseVariableNaming", "AlibabaUndefineMagicConstant", "AlibabaMethodTooLong"})
+@Slf4j
 @Service("baseInvoiceManualCheckService")
 public class BaseInvoiceManualCheckServiceImpl extends MpBaseServiceImpl<BaseTDxRecordInvoiceDao, BaseTDxRecordInvoice>
     implements BaseInvoiceManualCheckService {
@@ -204,10 +206,12 @@ public class BaseInvoiceManualCheckServiceImpl extends MpBaseServiceImpl<BaseTDx
                     if (!"1".equals(pageList.get(i).getAuthStatus())) {
                         vo.setSelect(false);
                     }
+
+                    log.info("返回的发票信息是:{}",pageList.get(i));
                     String invoiceStatus="07";
                     if ( !invoiceStatus.contains(pageList.get(i).getInvoiceStatus())
-                        || pageList.get(i).getInvoiceAmount().compareTo(new BigDecimal(0)) < 0
-                        || pageList.get(i).getTaxAmount().compareTo(new BigDecimal(0)) < 0) {
+                        || pageList.get(i).getInvoiceAmount() != null && pageList.get(i).getInvoiceAmount().compareTo(new BigDecimal(0)) < 0
+                        || pageList.get(i).getTaxAmount() != null && pageList.get(i).getTaxAmount().compareTo(new BigDecimal(0)) < 0) {
                         vo.setSelect(false);
                         vo.setUpgradeStatus("0");
                     }
diff --git a/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java b/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java
index d53bd613..d64994b7 100644
--- a/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java
+++ b/dxhy-base/src/main/java/com/dxhy/base/service/receipt/BaseReceiptOutServiceImpl.java
@@ -190,7 +190,8 @@ public class BaseReceiptOutServiceImpl extends MpBaseServiceImpl<BaseReceiptOutD
         // 转出金额
         vo.setOutAmount(AmountFormatUtil.fmtMicrometer(MathUtil.round(record.getOutInvoiceAmout().toPlainString())));
         // 转出税额
-        vo.setOutTax(AmountFormatUtil.fmtMicrometer(MathUtil.round(record.getOutTaxAmount().toPlainString())));
+        if (record.getOutTaxAmount() != null)
+            vo.setOutTax(AmountFormatUtil.fmtMicrometer(MathUtil.round(record.getOutTaxAmount().toPlainString())));
 
         vo.setRemark(record.getOutRemark());
         vo.setOutBelongDate(record.getOutBelongDate());
@@ -644,7 +645,8 @@ public class BaseReceiptOutServiceImpl extends MpBaseServiceImpl<BaseReceiptOutD
         // 转出金额
         vo.setOutAmount(AmountFormatUtil.fmtMicrometer(MathUtil.round(record.getOutInvoiceAmout().toPlainString())));
         // 转出税额
-        vo.setOutTax(AmountFormatUtil.fmtMicrometer(MathUtil.round(record.getOutTaxAmount().toPlainString())));
+        if (record.getOutTaxAmount() != null)
+            vo.setOutTax(AmountFormatUtil.fmtMicrometer(MathUtil.round(record.getOutTaxAmount().toPlainString())));
         vo.setRemark(record.getOutRemark());
         vo.setOutDate(DateUtils.dateToStr(record.getOutDate()));
         vo.setOutBelongDate(record.getOutBelongDate());
diff --git a/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml b/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml
index a0e772f9..1afb3819 100644
--- a/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml
+++ b/dxhy-base/src/main/resources/mapper/BaseSggxcxMapper.xml
@@ -110,7 +110,7 @@
             and t.payment_status = #{paymentStatus}
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType == '14' ">
-            and (t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08') )
+            and t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08')
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType != '14' ">
             and t.invoice_type = #{invoiceType}
@@ -257,7 +257,7 @@
             and t.payment_status = #{paymentStatus}
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType == '14' ">
-            and (t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08') )
+            and t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08')
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType != '14' ">
             and t.invoice_type = #{invoiceType}
@@ -355,7 +355,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE date_format(t.invoice_date,'%Y-%m-%d') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.auth_status in('0','5','6')
         and t.export_mark = '0'
@@ -392,7 +392,7 @@
             and t.voucher_number like concat('%',concat(#{voucherNumber},'%'))
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType == '14' ">
-            and (t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08') )
+            and t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08')
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType != '14' ">
             and t.invoice_type = #{invoiceType}
@@ -463,7 +463,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE to_char(t.invoice_date,'yyyy-mm-dd') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.auth_status in('0','5','6')
         and t.export_mark = '0'
@@ -479,10 +479,10 @@
 
         <if
                 test="sfkrz != '99' and sfkrz != null and sfkrz != '' and sfkrz != 'null' and sfkrz == '0'.toString()">
-            and (t.invoice_status in ('1','2','3','4','8','80') or t.invoice_amount &lt;0 or t.tax_amount &lt;0 or
+            and t.invoice_status in ('1','2','3','4','8','80') or t.invoice_amount &lt;0 or t.tax_amount &lt;0 or
             to_char(t.invoice_date,'yyyymmdd') &lt;= c.select_start_date or
             to_char(t.invoice_date,'yyyymmdd') &gt;=
-            c.select_end_date or d.tj_status in ('1','2'))
+            c.select_end_date or d.tj_status in ('1','2')
 
         </if>
         and t.gf_tax_no in
@@ -500,7 +500,7 @@
             and t.voucher_number like concat('%',concat(#{voucherNumber},'%'))
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType == '14' ">
-            and (t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08') )
+            and t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08')
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType != '14' ">
             and t.invoice_type = #{invoiceType}
@@ -755,7 +755,7 @@
         where date_format(t.invoice_date,'%Y-%m-%d') between #{kpksrq} and #{kpjsrq}
         and t.rzh_yesorno = '0'
         and t.invoice_status in ('0','7')
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.export_mark = '0'
         and t.invoice_amount>0
         and t.tax_amount>=0
@@ -789,7 +789,7 @@
             and date_format(t.qs_date,'%Y-%m-%d') between #{qsksrq} and #{qsjsrq}
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType == '14' ">
-            and (t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08') )
+            and t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08')
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType != '14' ">
             and t.invoice_type = #{invoiceType}
@@ -834,7 +834,7 @@
         where to_char(t.invoice_date,'yyyy-MM-dd') between #{kpksrq} and #{kpjsrq}
         and t.rzh_yesorno = '0'
         and t.invoice_status in ('0','7')
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.invoice_amount>0
         and t.tax_amount>=0
         and t.auth_status in ('0','5','6')
@@ -867,7 +867,7 @@
             and to_char(t.qs_date,'yyyy-MM-dd') between #{qsksrq} and #{qsjsrq}
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType == '14' ">
-            and (t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08') )
+            and t.invoice_type = '14' or (t.invoice_type = '32' and t.lq_tdyslxDm='08')
         </if>
         <if test="invoiceType != null and invoiceType != '' and invoiceType != 'null' and invoiceType != '14' ">
             and t.invoice_type = #{invoiceType}
@@ -925,7 +925,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE date_format(t.invoice_date,'%Y-%m-%d') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.invoice_status in ('0','7')
         and t.auth_status in('0','5','6')
@@ -1012,7 +1012,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE to_char(t.invoice_date,'yyyy-MM-dd') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.invoice_status in ('0','7')
         and t.auth_status in('0','5','6')
@@ -1094,7 +1094,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE date_format(t.invoice_date,'%Y-%m-%d') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.invoice_status in ('0','7')
         and t.auth_status in('0','5','6')
@@ -1169,7 +1169,7 @@
         from t_dx_record_invoice t left join t_dx_tax_current c on t.gf_tax_no = c.taxno
         left join t_dx_dk_count d on c.taxno = d.taxno and c.current_tax_period = d.skssq
         WHERE to_char(t.invoice_date,'yyyy-MM-dd') between #{kpksrq} and #{kpjsrq}
-        and (t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08'))
+        and t.invoice_type in('01','03','08','14','31','283','161','183','185') or (t.invoice_type ='32' and t.lq_tdyslxDm='08')
         and t.rzh_yesorno = '0'
         and t.invoice_status in ('0','7')
         and t.auth_status in('0','5','6')

From 324a7825b28de3ac8dc808161ce9bea6ba7675ae Mon Sep 17 00:00:00 2001
From: "zhenghaiyang@ele-cloud.com" <zhenghaiyang@ele-cloud.com>
Date: Fri, 14 Apr 2023 19:15:15 +0800
Subject: [PATCH 3/5] =?UTF-8?q?=E9=82=AE=E7=AE=B1=E9=87=87=E9=9B=86?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mailGather/EmailMaintainController.java   | 24 ++++++++++
 .../mailGather/MailGatherLogController.java   | 29 +++++++++++
 .../core/dao/mailGather/EmailMaintainDao.java |  4 +-
 .../model/mailGather/MailGatherLogVo.java     | 15 +++++-
 .../mailGather/EmailMaintainService.java      |  2 +
 .../impl/EmailMaintainServiceImpl.java        |  6 ++-
 .../impl/MailGatherLogServiceImpl.java        |  7 +++
 .../com/dxhy/core/task/SnEmailGatherTask.java |  6 +--
 .../dxhy/core/task/SnEmailGatherTaskTest.java | 14 +++---
 .../mapper/mailGather/EmailMaintainMapper.xml |  2 +-
 .../mapper/mailGather/MailGatherLogMapper.xml | 48 ++++++++-----------
 11 files changed, 115 insertions(+), 42 deletions(-)

diff --git a/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java b/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java
index b2f4cf11..4c8986aa 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java
@@ -4,7 +4,9 @@ import cn.hutool.core.codec.Base64;
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.fastjson.JSONObject;
+import com.dxhy.common.constant.DbConstant;
 import com.dxhy.common.controller.AbstractController;
+import com.dxhy.common.datasource.config.DynamicContextHolder;
 import com.dxhy.common.util.UUIDUtils;
 import com.dxhy.common.utils.Base64Encoding;
 import com.dxhy.common.utils.R;
@@ -91,6 +93,13 @@ public class EmailMaintainController extends AbstractController  {
         }
         String loginname = getUserInfo().getLoginname();
         emailMaintain.setCreateUser(loginname);
+        DynamicContextHolder.push(DbConstant.BASICS_READ);
+        EmailMaintainVo vo = new EmailMaintainVo();
+        vo.setEmailAddress(emailMaintain.getEmailAddress());
+        EmailMaintainVo maintainVo = emailMaintainService.getEmailMaintainVo(vo);
+        if(maintainVo != null){
+            return ResponseEntity.ok(R.error("邮箱地址已存在！"));
+        }
         boolean insert = this.emailMaintainService.insert(emailMaintain);
         if(insert){
             return ResponseEntity.ok(R.ok());
@@ -106,6 +115,19 @@ public class EmailMaintainController extends AbstractController  {
      */
     @PostMapping("/edit")
     public ResponseEntity<R> edit(@RequestBody  EmailMaintainVo emailMaintain) {
+        if(StringUtils.isBlank(emailMaintain.getEmailPassword()) || StringUtils.isBlank(emailMaintain.getEmailAddress()) ){
+            return ResponseEntity.ok(R.error("邮箱地址/密码不能为空！"));
+        }else {
+            String encode = Base64Encoding.encode(emailMaintain.getEmailPassword());
+            emailMaintain.setEmailPassword(encode);
+        }
+        DynamicContextHolder.push(DbConstant.BASICS_READ);
+        EmailMaintainVo vo = new EmailMaintainVo();
+        vo.setEmailAddress(emailMaintain.getEmailAddress());
+        EmailMaintainVo maintainVo = emailMaintainService.getEmailMaintainVo(vo);
+        if(maintainVo != null && maintainVo.getId().equals(emailMaintain.getId())){
+            return ResponseEntity.ok(R.error("邮箱地址已存在！"));
+        }
         boolean b = emailMaintainService.update(emailMaintain);
         if(b){
             return ResponseEntity.ok(R.ok());
@@ -142,6 +164,7 @@ public class EmailMaintainController extends AbstractController  {
                     errorMsgList.add("第" + resultIndex + "行，用户编码不能为空");
                     continue;
                 }
+                DynamicContextHolder.push(DbConstant.BASICS_READ);
                 String userName = emailMaintainService.getUserName(userId);
                 if(StringUtils.isBlank(userName)){
                     errorMsgList.add("第" + resultIndex + "行，用户编码在系统中查询不到，请核实！");
@@ -206,6 +229,7 @@ public class EmailMaintainController extends AbstractController  {
         if(StringUtils.isEmpty(userCode)){
             return ResponseEntity.ok(R.error("数据不能为空！"));
         }
+        DynamicContextHolder.push(DbConstant.BASICS_READ);
         String userName = emailMaintainService.getUserName(userCode);
         if(StringUtils.isNotEmpty(userName)){
             JSONObject json = new JSONObject();
diff --git a/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/MailGatherLogController.java b/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/MailGatherLogController.java
index 6815c9d5..448522f5 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/MailGatherLogController.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/MailGatherLogController.java
@@ -1,8 +1,12 @@
 package com.dxhy.core.controller.mailGather;
 
+import com.dxhy.common.constant.DbConstant;
 import com.dxhy.common.controller.AbstractController;
+import com.dxhy.common.datasource.config.DynamicContextHolder;
 import com.dxhy.common.utils.R;
 import com.dxhy.core.service.mailGather.MailGatherLogService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -10,6 +14,9 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.Map;
 
 /**
@@ -18,6 +25,7 @@ import java.util.Map;
  * @author makejava
  * @since 2023-03-23 08:42:35
  */
+@Slf4j
 @RestController
 @RequestMapping("/mailGatherLog")
 public class MailGatherLogController extends AbstractController {
@@ -26,6 +34,7 @@ public class MailGatherLogController extends AbstractController {
      */
     @Resource
     private MailGatherLogService mailGatherLogService;
+    final SimpleDateFormat sf2 = new SimpleDateFormat("yyyy-MM-dd");
 
     /**
      * 分页查询
@@ -46,6 +55,26 @@ public class MailGatherLogController extends AbstractController {
         if (pramsMap.get("parseEnd") == null || "".equals(pramsMap.get("parseEnd"))) {
             return ResponseEntity.ok(R.error("结束日期不能为空！"));
         }
+        Object parseStart = pramsMap.get("parseStart");
+        Object parseEnd = pramsMap.get("parseEnd");
+        if (parseEnd == null || parseEnd == null) {
+
+        } else {
+            try {
+                Date starttime = sf2.parse(String.valueOf(parseStart));
+                Date endtime = sf2.parse(String.valueOf(parseEnd));
+                if (starttime.after(endtime)) {
+                    return ResponseEntity.ok(R.error("开始时间不能大于结束时间"));
+                }
+                pramsMap.put("startTime", starttime);
+                pramsMap.put("endTime", endtime);
+            } catch (ParseException e) {
+                throw new RuntimeException(e);
+            }
+        }
+        String loginname = getUserInfo().getLoginname();
+        pramsMap.put("createUser",loginname);
+        DynamicContextHolder.push(DbConstant.BASICS_READ);
         return ResponseEntity.ok(R.ok().put("data",this.mailGatherLogService.queryByPage(pramsMap)));
     }
 
diff --git a/dxhy-core/src/main/java/com/dxhy/core/dao/mailGather/EmailMaintainDao.java b/dxhy-core/src/main/java/com/dxhy/core/dao/mailGather/EmailMaintainDao.java
index 4cad42c4..c59db2ec 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/dao/mailGather/EmailMaintainDao.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/dao/mailGather/EmailMaintainDao.java
@@ -35,7 +35,7 @@ public interface EmailMaintainDao extends BaseMapper<EmailMaintainVo> {
      * @param emailMaintainVo 查询条件
      * @return 总行数
      */
-    long count(EmailMaintainVo emailMaintainVo);
+    EmailMaintainVo getEmailMaintainVo(EmailMaintainVo emailMaintainVo);
 
     /**
      * 新增数据
@@ -81,4 +81,6 @@ public interface EmailMaintainDao extends BaseMapper<EmailMaintainVo> {
 
     String getUserName(@Param("userCode") String userCode);
 
+
+
 }
diff --git a/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java b/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java
index 2e665fa2..4cd119b7 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java
@@ -16,7 +16,7 @@ public class MailGatherLogVo extends CommonDTO {
     private String subject;
     private String fromAddress;
     private String receiveAddress;
-    private String sentDate;
+    private Date sentDate;
     private String fileType;
     private String fpdm;
     private String fphm;
@@ -26,4 +26,17 @@ public class MailGatherLogVo extends CommonDTO {
     private String fileName;
     private Date createTime;
 
+
+    public String deptId;
+
+    private String companyCode;
+
+    public String deptName;
+
+    public String username;
+
+    public String userId;
+
+    public String createUser;
+
 }
diff --git a/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/EmailMaintainService.java b/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/EmailMaintainService.java
index 99328e74..d855e687 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/EmailMaintainService.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/EmailMaintainService.java
@@ -51,4 +51,6 @@ public interface EmailMaintainService {
     String getUserName(String userCode);
 
     int insertBatch(List<EmailMaintainVo> entities);
+
+    EmailMaintainVo getEmailMaintainVo(EmailMaintainVo emailMaintain);
 }
diff --git a/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/EmailMaintainServiceImpl.java b/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/EmailMaintainServiceImpl.java
index 7b9fb5c5..507a89a8 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/EmailMaintainServiceImpl.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/EmailMaintainServiceImpl.java
@@ -117,9 +117,13 @@ public class EmailMaintainServiceImpl implements EmailMaintainService {
         return emailMaintainDao.insertBatch(entities);
     }
 
+    @Override
+    public EmailMaintainVo getEmailMaintainVo(EmailMaintainVo emailMaintain) {
+        return emailMaintainDao.getEmailMaintainVo(emailMaintain);
+    }
+
     //根据用户名进行查询
     public void getdeptInfo(String deptId){
         DynamicContextHolder.push(DbConstant.BASICS_READ);
-
     }
 }
diff --git a/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/MailGatherLogServiceImpl.java b/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/MailGatherLogServiceImpl.java
index 83ebd997..12e63f4f 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/MailGatherLogServiceImpl.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/MailGatherLogServiceImpl.java
@@ -5,16 +5,19 @@ import cn.hutool.core.codec.Base64;
 import com.alibaba.fastjson.JSONObject;
 import com.dxhy.common.constant.DbConstant;
 import com.dxhy.common.datasource.config.DynamicContextHolder;
+import com.dxhy.common.util.UUIDUtils;
 import com.dxhy.core.dao.mailGather.MailGatherLogDao;
 import com.dxhy.core.model.mailGather.MailGatherLogVo;
 import com.dxhy.core.service.mailGather.MailGatherLogService;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
@@ -70,6 +73,10 @@ public class MailGatherLogServiceImpl implements MailGatherLogService {
      */
     @Override
     public MailGatherLogVo insert(MailGatherLogVo mailGatherLog) {
+        if(StringUtils.isEmpty(mailGatherLog.getId())){
+            mailGatherLog.setId(UUIDUtils.generateShortUuid());
+        }
+        mailGatherLog.setCreateTime(new Date());
         this.mailGatherLogDao.insert(mailGatherLog);
         return mailGatherLog;
     }
diff --git a/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java b/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java
index c8197e2c..bafa7e34 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java
@@ -8,6 +8,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.dxhy.common.constant.DbConstant;
 import com.dxhy.common.datasource.config.DynamicContextHolder;
 import com.dxhy.common.util.MD5;
+import com.dxhy.common.util.UUIDUtils;
 import com.dxhy.core.job.entity.ScheduleJobEntity;
 import com.dxhy.core.job.service.ScheduleJobService;
 import com.dxhy.core.model.mailGather.EmailMaintainVo;
@@ -89,18 +90,17 @@ public class SnEmailGatherTask {
     }
 
     public void  parseEmail(EmailMaintainVo maintainVo){
+        log.info("邮箱采集内部方法开始执行--");
         long startTime = System.currentTimeMillis();
         String password = Base64Decoder.decodeStr(maintainVo.getEmailPassword());
         String emailName = maintainVo.getEmailAddress();
-
         try {
             Store store = mailAuth(emailName, password);
             if(store == null){
                 MailGatherLogVo gatherLogVo = new MailGatherLogVo();
-                gatherLogVo.setId(IdUtil.nanoId());
+                gatherLogVo.setId(UUIDUtils.generateShortUuid());
                 gatherLogVo.setErrorMsg("邮箱认证失败");
                 gatherLogVo.setOcrType("1");
-                gatherLogVo.setCreateTime(new Date());
                 gatherLogVo.setFromAddress(emailName);
                 mailGatherLogService.insert(gatherLogVo);
                 return;
diff --git a/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTaskTest.java b/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTaskTest.java
index f18287d5..ccd67d02 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTaskTest.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTaskTest.java
@@ -37,8 +37,10 @@ class SnEmailGatherTaskTest {
         String port = "110";
         //邮件接收服务器地址
         String mail_host = "mail.pop3.host";
-        String emailName = "15201210373@163.com";
-        String password = "JKZATQTPHDDQTQSH";
+        String emailName = "1149953701@qq.com";
+        String password = "pmdzleyabmlzgdhc";
+//         String emailName = "15201210373@163.com";
+//        String password = "JKZATQTPHDDQTQSH";
         String mailSuffix = emailName.split("@")[1];
         //邮箱类型
         String mailType = mailSuffix.split("\\.")[0];
@@ -61,7 +63,7 @@ class SnEmailGatherTaskTest {
             //连接邮箱服务器
             //获取当前时间
             Date currentTime = new Date();
-            // 获得收件箱    pop3协议只有一个有效的文件夹就是INBOX
+            // 品 ping获得收件箱    pop3协议只有一个有效的文件夹就是INBOX
             Folder folder = store.getFolder("INBOX");
             //获取邮件列表
             folder.open(Folder.READ_WRITE);
@@ -113,8 +115,8 @@ class SnEmailGatherTaskTest {
 
                                     Map resultMap = JSONObject.parseObject(body, Map.class);
                                     Object status = resultMap.get("status");
+                                    System.out.println(JSONObject.toJSONString("================="+resultMap));
                                     if(status != null && "200".equals(String.valueOf(status))){
-
                                     }
                                     System.out.println(body);
                                 } catch (NoSuchAlgorithmException e) {
@@ -165,7 +167,7 @@ class SnEmailGatherTaskTest {
             OpenServiceOcr openServiceOcr = openServiceOcrs.get(i);
             OpenServiceOcr.InvoiceOcrData invoiceOcrData = openServiceOcr.getData();
             OcrResultToyxVo resultToyxVo = new OcrResultToyxVo();
-            resultToyxVo.setCompanyId("");
+            resultToyxVo.setCompanyId("c040");
             resultToyxVo.setSource("01");
             resultToyxVo.setInvoiceCode(invoiceOcrData.getFPDM());
             resultToyxVo.setInvoiceNumber(invoiceOcrData.getFPHM());
@@ -176,7 +178,7 @@ class SnEmailGatherTaskTest {
             resultToyxVo.setFileType("102");
             resultToyxVo.setFileByte(map.get("pdfStream"));
             resultToyxVo.setEmail(map.get("emailName"));
-            resultToyxVo.setEmployeeId("");
+            resultToyxVo.setEmployeeId("01142085");
 
             resultToyxVoList.add(resultToyxVo);
         }
diff --git a/dxhy-core/src/main/resources/mapper/mailGather/EmailMaintainMapper.xml b/dxhy-core/src/main/resources/mapper/mailGather/EmailMaintainMapper.xml
index d1ae63c0..9d3d1a52 100644
--- a/dxhy-core/src/main/resources/mapper/mailGather/EmailMaintainMapper.xml
+++ b/dxhy-core/src/main/resources/mapper/mailGather/EmailMaintainMapper.xml
@@ -48,7 +48,7 @@
     </select>
 
     <!--统计总行数-->
-    <select id="count" resultType="java.lang.Long">
+    <select id="getEmailMaintainVo" resultMap="EmailMaintainMap">
         select count(1)
         from email_maintain
         <where>
diff --git a/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml b/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml
index 734cbac5..659088f5 100644
--- a/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml
+++ b/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml
@@ -7,7 +7,7 @@
         <result property="subject" column="subject" jdbcType="VARCHAR"/>
         <result property="fromAddress" column="from_address" jdbcType="VARCHAR"/>
         <result property="receiveAddress" column="receive_address" jdbcType="VARCHAR"/>
-        <result property="sentDate" column="sent_date" jdbcType="VARCHAR"/>
+        <result property="sentDate" column="sent_date" jdbcType="TIMESTAMP"/>
         <result property="fileType" column="file_type" jdbcType="VARCHAR"/>
         <result property="fpdm" column="fpdm" jdbcType="VARCHAR"/>
         <result property="fphm" column="fphm" jdbcType="VARCHAR"/>
@@ -28,42 +28,32 @@
 
     <!--查询指定行数据-->
     <select id="queryAllByLimit" resultMap="MailGatherLogMap" parameterType="java.util.Map">
-        select
-          id, subject, from_address, receive_address, sent_date, file_type, fpdm, fphm, msg_uid, ocr_type, error_msg, file_name, create_time
-        from mail_gather_log
+        SELECT
+        m.sent_date, e.dept_name, e.username,  m.from_address, m.file_name, m.file_type, m.ocr_type, m.error_msg
+        FROM
+        mail_gather_log m
+        LEFT JOIN email_maintain e ON m.from_address = e.email_address
         <where>
-            <if test="fromAddress != null and fromAddress != ''">
-                and from_address = #{fromAddress}
-            </if>
-            <if test="receiveAddress != null and receiveAddress != ''">
-                and receive_address = #{receiveAddress}
+            <if test="deptId != null and deptId != ''">
+                and e.dept_id = #{deptId}
             </if>
-            <if test="sentDate != null and sentDate != ''">
-                and sent_date = #{sentDate}
+            <if test="username != null and username != ''">
+                and e.username = #{username}
             </if>
-            <if test="fileType != null and fileType != ''">
-                and file_type = #{fileType}
+            <if test="userId != null and userId != ''">
+                and e.user_id = #{userId}
             </if>
-            <if test="fpdm != null and fpdm != ''">
-                and fpdm = #{fpdm}
-            </if>
-            <if test="fphm != null and fphm != ''">
-                and fphm = #{fphm}
-            </if>
-            <if test="msgUid != null and msgUid != ''">
-                and msg_uid = #{msgUid}
+            <if test="createUser != null and createUser != ''">
+                and e.create_user = #{createUser}
             </if>
             <if test="ocrType != null and ocrType != ''">
-                and ocr_type = #{ocrType}
+                and m.ocr_type = #{ocrType}
             </if>
-            <if test="errorMsg != null and errorMsg != ''">
-                and error_msg = #{errorMsg}
-            </if>
-            <if test="fileName != null and fileName != ''">
-                and file_name = #{fileName}
+            <if test="startTime !=null and startTime != ''">
+                and m.sent_date >= #{startTime}
             </if>
-            <if test="createTime != null">
-                and create_time = #{createTime}
+            <if test="endTime !=null and endTime != ''">
+                and #{endTime} >= m.sent_date
             </if>
         </where>
     </select>

From cc174c8f8cd978b499e07d3ae2a37f5672356efd Mon Sep 17 00:00:00 2001
From: "zhenghaiyang@ele-cloud.com" <zhenghaiyang@ele-cloud.com>
Date: Fri, 14 Apr 2023 19:16:56 +0800
Subject: [PATCH 4/5] =?UTF-8?q?=E9=82=AE=E7=AE=B1=E9=87=87=E9=9B=86?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/dxhy/core/model/mailGather/MailGatherLogVo.java     | 2 +-
 .../src/main/java/com/dxhy/core/task/SnEmailGatherTask.java | 2 +-
 .../resources/mapper/mailGather/MailGatherLogMapper.xml     | 6 +++---
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java b/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java
index 4cd119b7..5e8a9a96 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/model/mailGather/MailGatherLogVo.java
@@ -16,7 +16,7 @@ public class MailGatherLogVo extends CommonDTO {
     private String subject;
     private String fromAddress;
     private String receiveAddress;
-    private Date sentDate;
+    private String sentDate;
     private String fileType;
     private String fpdm;
     private String fphm;
diff --git a/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java b/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java
index bafa7e34..4df321d5 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java
@@ -127,7 +127,7 @@ public class SnEmailGatherTask {
                 gatherLogVo.setSubject(EmailParseUtils.getSubject(msg));
                 gatherLogVo.setFromAddress(emailName);
                 gatherLogVo.setReceiveAddress(EmailParseUtils.getReceiveAddress(msg, null));
-                gatherLogVo.setSentDate( EmailParseUtils.getSentDate(msg, null));
+                gatherLogVo.setSentDate(EmailParseUtils.getSentDate(msg, null));
                 gatherLogVo.setCreateTime(new Date());
 
                 log.debug("主题: " + EmailParseUtils.getSubject(msg));
diff --git a/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml b/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml
index 659088f5..1c9614e9 100644
--- a/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml
+++ b/dxhy-core/src/main/resources/mapper/mailGather/MailGatherLogMapper.xml
@@ -29,7 +29,7 @@
     <!--查询指定行数据-->
     <select id="queryAllByLimit" resultMap="MailGatherLogMap" parameterType="java.util.Map">
         SELECT
-        m.sent_date, e.dept_name, e.username,  m.from_address, m.file_name, m.file_type, m.ocr_type, m.error_msg
+        m.create_time, e.dept_name, e.username,  m.from_address, m.file_name, m.file_type, m.ocr_type, m.error_msg
         FROM
         mail_gather_log m
         LEFT JOIN email_maintain e ON m.from_address = e.email_address
@@ -50,10 +50,10 @@
                 and m.ocr_type = #{ocrType}
             </if>
             <if test="startTime !=null and startTime != ''">
-                and m.sent_date >= #{startTime}
+                and m.create_time >= #{startTime}
             </if>
             <if test="endTime !=null and endTime != ''">
-                and #{endTime} >= m.sent_date
+                and #{endTime} >= m.create_time
             </if>
         </where>
     </select>

From 71b0f98fe6d26f6c0f3e56cff94ab9be1ece840a Mon Sep 17 00:00:00 2001
From: "zhenghaiyang@ele-cloud.com" <zhenghaiyang@ele-cloud.com>
Date: Fri, 14 Apr 2023 19:31:33 +0800
Subject: [PATCH 5/5] =?UTF-8?q?=E9=82=AE=E7=AE=B1=E9=87=87=E9=9B=86?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/mailGather/EmailMaintainController.java     | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java b/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java
index 4c8986aa..21625943 100644
--- a/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java
+++ b/dxhy-core/src/main/java/com/dxhy/core/controller/mailGather/EmailMaintainController.java
@@ -115,11 +115,8 @@ public class EmailMaintainController extends AbstractController  {
      */
     @PostMapping("/edit")
     public ResponseEntity<R> edit(@RequestBody  EmailMaintainVo emailMaintain) {
-        if(StringUtils.isBlank(emailMaintain.getEmailPassword()) || StringUtils.isBlank(emailMaintain.getEmailAddress()) ){
-            return ResponseEntity.ok(R.error("邮箱地址/密码不能为空！"));
-        }else {
-            String encode = Base64Encoding.encode(emailMaintain.getEmailPassword());
-            emailMaintain.setEmailPassword(encode);
+        if(StringUtils.isBlank(emailMaintain.getEmailPassword())){
+            return ResponseEntity.ok(R.error("邮箱地址不能为空！"));
         }
         DynamicContextHolder.push(DbConstant.BASICS_READ);
         EmailMaintainVo vo = new EmailMaintainVo();