feat(deletedata): 添加销售订单取消签字和删除功能

- 新增 queryIcGeneralHByCancelSignatureV2 和 querySoSaleByDeletev2 方法 - 实现销售出库单和销售订单的批量取消签字和删除 -优化数据处理逻辑，按日期和单位分组进行批量操作 - 添加定时任务，每10秒重新执行删除操作
feat(sales): 过滤实入数量为零的销售退货单明细行
2025-05-07 23:59:11 +08:00 · 2025-05-06 10:41:56 +08:00 · 2025-05-02 15:07:37 +08:00 · 2025-05-01 00:30:45 +08:00 · 2025-04-30 15:18:53 +08:00 · 2025-04-27 15:09:19 +08:00
734 changed files with 166624 additions and 4839 deletions
--- a/.gitignore
+++ b/.gitignore
@ -49,10 +49,13 @@ $RECYCLE.BIN/
 *.msix
 *.msm
 *.msp
 *.iml
 # Windows shortcuts
 *.lnk
-./idea/
+/.idea/
 /log/
 /file/
 /buildpackage/src/main/resources/banner.txt
 /webapp/target/
 /service/target/
--- a/buildpackage/pom.xml
+++ b/buildpackage/pom.xml
@ -99,6 +99,18 @@
                <profile.active>yc</profile.active>
            </properties>
        </profile>
        <profile>
            <id>lets</id> <!--丽知-->
            <properties>
                <profile.active>lets</profile.active>
            </properties>
        </profile>
        <profile>
            <id>letsprod</id> <!--丽知prod-->
            <properties>
                <profile.active>letsprod</profile.active>
            </properties>
        </profile>
    </profiles>
    <build>
        <finalName>kangarooDataCenterV3</finalName>
--- a/buildpackage/src/main/java/com/hzya/frame/WarStartApplication.java
+++ b/buildpackage/src/main/java/com/hzya/frame/WarStartApplication.java
@ -6,7 +6,7 @@ import org.springframework.boot.web.servlet.support.SpringBootServletInitializer
 /***
 * @Content:War启动类 继承SpringBootServletInitializer  初始化servlet 环境
 * @Author 👻👻👻👻👻👻👻👻 gjh
- * @Date  2022-11-29 14:27
+ * @Date 2022-11-29 14:27
 * @Param
 * @return
 **/
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/dao/IPayBillDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/dao/IPayBillDao.java
@ -1,15 +0,0 @@
 package com.hzya.frame.plugin.a8bill.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.a8bill.entity.PayBillEntity;
 /**
 * 组织档案(mdm_org: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-06-07 18:30:04
 */
 public interface IPayBillDao extends IBaseDao<PayBillEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/dao/impl/PayBillDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/dao/impl/PayBillDaoImpl.java
@ -1,16 +0,0 @@
 package com.hzya.frame.plugin.a8bill.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.a8bill.dao.IPayBillDao;
 import com.hzya.frame.plugin.a8bill.entity.PayBillEntity;
 /**
 * 组织档案(MdmOrg)表数据库访问层
 *
 * @author makejava
 * @since 2024-06-07 18:30:04
 */
 public class PayBillDaoImpl extends MybatisGenericDao<PayBillEntity, String> implements IPayBillDao {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/entity/PayBillEntity.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/entity/PayBillEntity.java
@ -1,14 +0,0 @@
 package com.hzya.frame.plugin.a8bill.entity;
 import com.hzya.frame.web.entity.BaseEntity;
 /**
 * 付款单
 *
 * @author makejava
 * @since 2024-06-07 18:30:04
 */
 public class PayBillEntity extends BaseEntity {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/entity/PayBillEntity.xml
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/entity/PayBillEntity.xml
@ -1,16 +0,0 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.hzya.frame.plugin.a8bill.dao.impl.PayBillDaoImpl">
    <resultMap id="get-PayBillEntity-result" type="com.hzya.frame.plugin.a8bill.entity.PayBillEntity" >
       <result property="id" column="id" jdbcType="VARCHAR"/>
        </resultMap>
    <!-- 查询的字段-->
    <sql id = "PayBillEntity_Base_Column_List">
        id
     </sql>
 </mapper>
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/PayBillPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/PayBillPluginInitializer.java
@ -1,63 +0,0 @@
 package com.hzya.frame.plugin.a8bill.plugin;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.seeyon.paybill.service.IPayBillService;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 /**
 * 付款单(PayBill)表服务接口
 *
 * @author makejava
 * @since 2024-06-07 18:30:05
 */
 public class PayBillPluginInitializer extends PluginBaseEntity{
    Logger logger = LoggerFactory.getLogger(PayBillPluginInitializer.class);
   @Autowired
   private IPayBillService payBillService;
      @Override
    public void initialize() {
        logger.info(getPluginLabel() + "執行初始化方法initialize()");
    }
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    @Override
    public String getPluginId() {
        return "PayBillPlugin";
    }
    @Override
    public String getPluginName() {
        return "PayBillPlugin插件";
    }
    @Override
    public String getPluginLabel() {
        return "PayBillPlugin";
    }
    @Override
    public String getPluginType() {
        return "1";
    }
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) {
          try {
              logger.info("======开始执行付款单据信息同步========");
             return payBillService.sendEngineerPayBillToBip(requestJson);
          }catch (Exception e){
              logger.info("======执行付款单据同步失败:{}========",e.getMessage());
              e.printStackTrace();
          }
          return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/RecBillPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/plugin/RecBillPluginInitializer.java
@ -1,63 +0,0 @@
 package com.hzya.frame.plugin.a8bill.plugin;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.seeyon.paybill.service.IPayBillService;
 import com.hzya.frame.seeyon.recbill.service.IRecBillService;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 /**
 * 收款单(RecBill)表服务接口
 *
 * @author makejava
 * @since 2024-06-07 18:30:05
 */
 public class RecBillPluginInitializer extends PluginBaseEntity{
    Logger logger = LoggerFactory.getLogger(RecBillPluginInitializer.class);
   @Autowired
   private IRecBillService recBillService;
      @Override
    public void initialize() {
        logger.info(getPluginLabel() + "執行初始化方法initialize()");
    }
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    @Override
    public String getPluginId() {
        return "RecBillPluginInitializer";
    }
    @Override
    public String getPluginName() {
        return "RecBillPluginInitializer插件";
    }
    @Override
    public String getPluginLabel() {
        return "RecBillPluginInitializer";
    }
    @Override
    public String getPluginType() {
        return "1";
    }
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) {
          try {
              logger.info("======开始执行收款单据信息同步========");
             return recBillService.sendRecBillToBip(requestJson);
          }catch (Exception e){
              logger.info("======执行收款单据同步失败:{}========",e.getMessage());
              e.printStackTrace();
          }
          return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/service/IPayBillService.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/service/IPayBillService.java
@ -1,13 +0,0 @@
 package com.hzya.frame.plugin.a8bill.service;
 import com.hzya.frame.basedao.service.IBaseService;
 import com.hzya.frame.plugin.a8bill.entity.PayBillEntity;
 /**
 * 付款单
 *
 * @author makejava
 * @since 2024-06-07 18:30:05
 */
 public interface IPayBillService extends IBaseService<PayBillEntity, String>{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/service/impl/PayBillServiceImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/a8bill/service/impl/PayBillServiceImpl.java
@ -1,22 +0,0 @@
 package com.hzya.frame.plugin.a8bill.service.impl;
 import com.hzya.frame.basedao.service.impl.BaseService;
 import com.hzya.frame.plugin.a8bill.entity.PayBillEntity;
 import com.hzya.frame.plugin.a8bill.service.IPayBillService;
 /**
 *  private IMdmOrgDao mdmOrgDao;
 *
 *     @Autowired
 *        public void setMdmOrgDao(IMdmOrgDao dao) {
 * 		this.mdmOrgDao = dao;
 * 		this.dao = dao;
 *    }
 *
 * @author makejava
 * @since 2024-06-07 18:30:05
 */
 public class PayBillServiceImpl extends BaseService<PayBillEntity, String> implements IPayBillService {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/AgentPayResultPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/AgentPayResultPluginInitializer.java
@ -1,114 +0,0 @@
 package com.hzya.frame.plugin.cbs8.plugin;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.cbs8.dto.req.AgentPayResultRequestDTO;
 import com.hzya.frame.cbs8.dto.res.AgentPayQueryDTO;
 import com.hzya.frame.cbs8.dto.res.AgentPayResultResDTO;
 import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.checkerframework.checker.units.qual.A;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import java.util.List;
 /**
 * @Description
 * @Author xiangerlin
 * @Date 2024/6/18 17:22
 **/
 public class AgentPayResultPluginInitializer extends PluginBaseEntity {
    Logger logger = LoggerFactory.getLogger(AgentPayResultPluginInitializer.class);
    @Autowired
    private ICbsPluginService cbsPluginService;
    /***
     * 插件初始化方法
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 10:48
     * @Param []
     * @return void
     **/
    @Override
    public void initialize() {
    }
    /****
     * 插件销毁方法
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    /****
     * 插件的ID
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginId() {
        return "CBS8AgentPayResultPlugin";
    }
    /****
     * 插件的名称
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginName() {
        return "cbs8代发代扣详情查询插件";
    }
    /****
     * 插件的显示值
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginLabel() {
        return "cbs8代发代扣详情查询插件";
    }
    /***
     * 插件类型 1、场景插件
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 14:01
     * @Param []
     * @return java.lang.String
     **/
    @Override
    public String getPluginType() {
        return "1";
    }
    /***
     * 执行业务代码
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-07 11:20
     * @param requestJson  执行业务代码的参数
     * @return void
     **/
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
        //1、查询代发代扣交易未完成代
        //2、调用cbs接口
        AgentPayResultRequestDTO agentPayResultRequestDTO = new AgentPayResultRequestDTO();
        agentPayResultRequestDTO.setBusNum("PA00034224062600011");
        AgentPayResultResDTO agentPayResultResDTO = cbsPluginService.agentPayResult(agentPayResultRequestDTO);
        //记录日志
        return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/ElecBillPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/ElecBillPluginInitializer.java
@ -1,101 +0,0 @@
 package com.hzya.frame.plugin.cbs8.plugin;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 /**
 * @Description 电子回单定时任务
 * @Author xiangerlin
 * @Date 2024/6/17 14:03
 **/
 public class ElecBillPluginInitializer extends PluginBaseEntity {
    Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired
    private ICbsPluginService cbsPluginService;
    /***
     * 插件初始化方法
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 10:48
     * @Param []
     * @return void
     **/
    @Override
    public void initialize() {
        logger.info(getPluginLabel() + "執行初始化方法initialize()");
    }
    /****
     * 插件销毁方法
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    /****
     * 插件的ID
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginId() {
        return "CBS8ElecBillPlugin";
    }
    /****
     * 插件的名称
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginName() {
        return "cbs8电子回单插件";
    }
    /****
     * 插件的显示值
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginLabel() {
        return "cbs8电子回单插件";
    }
    /***
     * 插件类型 1、场景插件
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 14:01
     * @Param []
     * @return java.lang.String
     **/
    @Override
    public String getPluginType() {
        return "1";
    }
    /***
     * 执行业务代码
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-07 11:20
     * @param requestJson  执行业务代码的参数
     * @return void
     **/
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
        cbsPluginService.elecBillUpload(requestJson);
        return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyAgentPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyAgentPluginInitializer.java
@ -1,116 +0,0 @@
 package com.hzya.frame.plugin.cbs8.plugin;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.cbs8.dto.res.PayResponseDTO;
 import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
 import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentDetailEntity;
 import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentEntity;
 import com.hzya.frame.seeyon.cbs8.service.IAgentPaymentService;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.apache.commons.collections.CollectionUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import java.util.List;
 /**
 * @Description
 * @Author xiangerlin
 * @Date 2024/6/18 14:03
 **/
 public class PayApplyAgentPluginInitializer extends PluginBaseEntity {
    Logger logger = LoggerFactory.getLogger(PayApplyAgentPluginInitializer.class);
    @Autowired
    private ICbsPluginService cbsPluginService;
    @Autowired
    private IAgentPaymentService agentPaymentService;
    /***
     * 插件初始化方法
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 10:48
     * @Param []
     * @return void
     **/
    @Override
    public void initialize() {
        logger.info(getPluginLabel() + "執行初始化方法initialize()");
    }
    /****
     * 插件销毁方法
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    /****
     * 插件的ID
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginId() {
        return "CBS8PayApplyAgentPlugin";
    }
    /****
     * 插件的名称
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginName() {
        return "cbs8代发代扣插件";
    }
    /****
     * 插件的显示值
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginLabel() {
        return "cbs8代发代扣插件";
    }
    /***
     * 插件类型 1、场景插件
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 14:01
     * @Param []
     * @return java.lang.String
     **/
    @Override
    public String getPluginType() {
        return "1";
    }
    /***
     * 执行业务代码
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-07 11:20
     * @param requestJson  执行业务代码的参数
     * @return void
     **/
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
        //1、查询代支付的
        AgentPaymentEntity agentPaymentEntity = new AgentPaymentEntity();
        agentPaymentEntity.setOaId("4442823497745714629");
        cbsPluginService.applyAgentPay(agentPaymentEntity);
        return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyPluginInitializer.java
@ -1,112 +0,0 @@
 package com.hzya.frame.plugin.cbs8.plugin;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
 import com.hzya.frame.seeyon.cbs8.entity.PaymentEntity;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 /**
 * @Description 经办支付申请
 * @Author xiangerlin
 * @Date 2024/6/7 13:42
 **/
 public class PayApplyPluginInitializer extends PluginBaseEntity {
    Logger logger = LoggerFactory.getLogger(PayApplyPluginInitializer.class);
    @Autowired
    private ICbsPluginService cbsPluginService;
    /***
     * 插件初始化方法
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 10:48
     * @Param []
     * @return void
     **/
    @Override
    public void initialize() {
        logger.info(getPluginLabel() + "執行初始化方法initialize()");
    }
    /****
     * 插件销毁方法
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    /****
     * 插件的ID
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginId() {
        return "CBS8PayApplyPlugin";
    }
    /****
     * 插件的名称
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginName() {
        return "cbs8支付申请插件";
    }
    /****
     * 插件的显示值
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginLabel() {
        return "cbs8支付申请插件";
    }
    /***
     * 插件类型 1、场景插件
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 14:01
     * @Param []
     * @return java.lang.String
     **/
    @Override
    public String getPluginType() {
        return "1";
    }
    /***
     * 执行业务代码
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-07 11:20
     * @param requestJson  执行业务代码的参数
     * @return void
     **/
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
        PaymentEntity paymentEntity = null;
        if (null != requestJson){
            requestJson.remove("jsonStr");
            paymentEntity = JSONObject.parseObject(requestJson.toString(),PaymentEntity.class);
        }
        if (null == paymentEntity)
            paymentEntity = new PaymentEntity();
        //支付申请
        paymentEntity.setOaId("8475071606892874568");
        cbsPluginService.applyPay(paymentEntity);
        return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayResultPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayResultPluginInitializer.java
@ -1,110 +0,0 @@
 package com.hzya.frame.plugin.cbs8.plugin;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
 import com.hzya.frame.seeyon.cbs8.entity.CbsLogEntity;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 /**
 * @Description 查询支付结果
 * @Author xiangerlin
 * @Date 2024/6/14 16:24
 **/
 public class PayResultPluginInitializer extends PluginBaseEntity {
    Logger logger = LoggerFactory.getLogger(PayResultPluginInitializer.class);
    @Autowired
    private ICbsPluginService cbsPluginService;
    /***
     * 插件初始化方法
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 10:48
     * @Param []
     * @return void
     **/
    @Override
    public void initialize() {
        logger.info(getPluginLabel() + "執行初始化方法initialize()");
    }
    /****
     * 插件销毁方法
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    /****
     * 插件的ID
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginId() {
        return "CBS8PayResultPlugin";
    }
    /****
     * 插件的名称
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginName() {
        return "cbs8支付结果查询插件";
    }
    /****
     * 插件的显示值
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginLabel() {
        return "cbs8支付结果查询插件";
    }
    /***
     * 插件类型 1、场景插件
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 14:01
     * @Param []
     * @return java.lang.String
     **/
    @Override
    public String getPluginType() {
        return "1";
    }
    /***
     * 执行业务代码
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-07 11:20
     * @param requestJson  执行业务代码的参数
     * @return void
     **/
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
        CbsLogEntity cbsLogEntity = null;
        if (null != requestJson){
            requestJson.remove("jsonStr");
            cbsLogEntity = JSONObject.parseObject(requestJson.toString(),CbsLogEntity.class);
        }
        if (null == cbsLogEntity){
            cbsLogEntity = new CbsLogEntity();
        }
        cbsPluginService.queryResult(cbsLogEntity);
        return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/TransactionDetailPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/TransactionDetailPluginInitializer.java
@ -1,126 +0,0 @@
 package com.hzya.frame.plugin.cbs8.plugin;
 import cn.hutool.core.date.DateUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.base.PluginBaseEntity;
 import com.hzya.frame.cbs8.dto.req.TransactionDetailReqDTO;
 import com.hzya.frame.cbs8.dto.res.TransactionDetailDTO;
 import com.hzya.frame.cbs8.util.CBSUtil;
 import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
 import com.hzya.frame.web.entity.JsonResultEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import java.util.List;
 /**
 * @Description 交易明细查询
 * @Author xiangerlin
 * @Date 2024/6/17 16:03
 **/
 public class TransactionDetailPluginInitializer extends PluginBaseEntity {
    Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired
    private ICbsPluginService cbsPluginService;
    /***
     * 插件初始化方法
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 10:48
     * @Param []
     * @return void
     **/
    @Override
    public void initialize() {
        logger.info(getPluginLabel() + "執行初始化方法initialize()");
    }
    /****
     * 插件销毁方法
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public void destroy() {
        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
    }
    /****
     * 插件的ID
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginId() {
        return "CBS8TransactionDetailQueryPlugin";
    }
    /****
     * 插件的名称
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginName() {
        return "cbs8交易明细查询插件";
    }
    /****
     * 插件的显示值
     * @author 👻👻👻👻👻👻👻👻 gjh
     * @date 2023-08-02 10:48
     * @return void
     **/
    @Override
    public String getPluginLabel() {
        return "cbs8交易明细查询插件";
    }
    /***
     * 插件类型 1、场景插件
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-02 14:01
     * @Param []
     * @return java.lang.String
     **/
    @Override
    public String getPluginType() {
        return "1";
    }
    /***
     * 执行业务代码
     * @Author 👻👻👻👻👻👻👻👻 gjh
     * @Date 2023-08-07 11:20
     * @param requestJson  执行业务代码的参数
     * @return void
     **/
    @Override
    public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
        TransactionDetailReqDTO transactionDetailReqDTO = null;
        if (null != requestJson){
            requestJson.remove("jsonStr");
            transactionDetailReqDTO = JSONObject.parseObject(requestJson.toString(),TransactionDetailReqDTO.class);
        }
        if (null == transactionDetailReqDTO){
            transactionDetailReqDTO = new TransactionDetailReqDTO();
        }
        transactionDetailReqDTO.setCurrentPage(CBSUtil.DEFAULT_CURRENT_PAGE);
        transactionDetailReqDTO.setPageSize(CBSUtil.DEFAULT_PAGE_SIZE);
        transactionDetailReqDTO.setStartDate(DateUtil.today());
        transactionDetailReqDTO.setEndDate(DateUtil.today());
        transactionDetailReqDTO.setDateType("0");
        transactionDetailReqDTO.setLoanType("2");
        //1查询交易明细
        List<TransactionDetailDTO> transactionDetailList = cbsPluginService.queryTransactionDetail(transactionDetailReqDTO);
        //保存交易明细到OA底表
        cbsPluginService.saveTransactionDetail(transactionDetailList);
        return new JsonResultEntity("成功",true,transactionDetailList);
        //return null;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/service/ICbsPluginService.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/service/ICbsPluginService.java
@ -1,76 +0,0 @@
 package com.hzya.frame.plugin.cbs8.service;
 import com.alibaba.fastjson.JSONObject;
 import com.hzya.frame.cbs8.dto.req.AgentPayResultRequestDTO;
 import com.hzya.frame.cbs8.dto.req.TransactionDetailReqDTO;
 import com.hzya.frame.cbs8.dto.res.AgentPayResultResDTO;
 import com.hzya.frame.cbs8.dto.res.PayResponseDTO;
 import com.hzya.frame.cbs8.dto.res.TransactionDetailDTO;
 import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentDetailEntity;
 import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentEntity;
 import com.hzya.frame.seeyon.cbs8.entity.CbsLogEntity;
 import com.hzya.frame.seeyon.cbs8.entity.PaymentEntity;
 import java.util.List;
 /**
 * @Description
 * @Author xiangerlin
 * @Date 2024/6/17 08:46
 **/
 public interface ICbsPluginService {
    /**
     * 支付申请
     * @param entity
     */
     void applyPay(PaymentEntity entity)throws Exception;
    /**
     * 保存支付申请日志
     * @param entity
     * @throws Exception
     */
     void savePayLog(PaymentEntity entity,PayResponseDTO payResponseDTO)throws Exception;
    /**
     * 查询支付申请的交易结果
     * @param cbsLogEntity
     * @throws Exception
     */
     void queryResult(CbsLogEntity cbsLogEntity)throws Exception;
    /**
     * 电子回单查询 并上传OA
     * @param requestJson
     * @throws Exception
     */
    void elecBillUpload(JSONObject requestJson)throws Exception;
    /**
     * 查询交易明细
     * transactionDetailReqDTO.currentPage 、 transactionDetailReqDTO.pageSize 必填
     * @param transactionDetailReqDTO
     */
    List<TransactionDetailDTO> queryTransactionDetail(TransactionDetailReqDTO transactionDetailReqDTO);
    /**
     * 代发代扣 支付申请
     * @param paymentEntity
     */
    void applyAgentPay(AgentPaymentEntity paymentEntity);
    /**
     * 代发代扣 结果详情查询
     * @param agentPayResultRequestDTO
     * @return
     */
    AgentPayResultResDTO agentPayResult(AgentPayResultRequestDTO agentPayResultRequestDTO);
    /**
     * 保存交易明细到OA底表
     * @param transactionDetailList
     */
    void saveTransactionDetail(List<TransactionDetailDTO> transactionDetailList);
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/service/impl/CbsPluginServiceImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/service/impl/CbsPluginServiceImpl.java
@ -1,513 +0,0 @@
 package com.hzya.frame.plugin.cbs8.service.impl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.convert.Convert;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.io.FileUtil;
 import cn.hutool.core.map.MapBuilder;
 import cn.hutool.core.util.NumberUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.http.HttpRequest;
 import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.hzya.frame.cbs8.dto.req.*;
 import com.hzya.frame.cbs8.dto.res.*;
 import com.hzya.frame.cbs8.service.ICbs8Service;
 import com.hzya.frame.cbs8.util.CBSUtil;
 import com.hzya.frame.cbs8.util.CurrencyEnum;
 import com.hzya.frame.cbs8.util.PayState;
 import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
 import com.hzya.frame.seeyon.cap4.form.dto.*;
 import com.hzya.frame.seeyon.cbs8.entity.*;
 import com.hzya.frame.seeyon.cbs8.service.*;
 import com.hzya.frame.seeyon.entity.CtpAttachmentEntity;
 import com.hzya.frame.seeyon.entity.CtpFileEntity;
 import com.hzya.frame.seeyon.service.ICtpAttachmentService;
 import com.hzya.frame.seeyon.util.RestUtil;
 import com.hzya.frame.uuid.UUIDLong;
 import com.hzya.frame.web.exception.BaseSystemException;
 import org.apache.commons.collections.CollectionUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import java.io.File;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 /**
 * @Description
 * @Author xiangerlin
 * @Date 2024/6/17 08:46
 **/
 public class CbsPluginServiceImpl implements ICbsPluginService {
    Logger logger = LoggerFactory.getLogger(CbsPluginServiceImpl.class);
    @Autowired
    private ICbs8Service cbs8Service;
    @Autowired
    private IPaymentService paymentService;
    @Autowired
    private ICbsLogService cbsLogService;
    @Autowired
    private ICtpAttachmentService ctpAttachmentService;
    @Autowired
    private ITransactionDetailService transactionDetailService;
    @Autowired
    private IAgentPaymentService agentPaymentService;
    @Autowired
    private IAgentPaymentDetailService agentPaymentDetailService;
    @Autowired
    private RestUtil restUtil;
    @Value("${cbs8.elec_path:}")
    private String elec_path;
    @Value("${OA.data_source_code:}")
    private String oa_data_source_code;
    /**
     * 支付申请
     *
     * @param paymentEntity
     */
    @Override
    public void applyPay(PaymentEntity paymentEntity) throws Exception{
        //查询待支付的列表
        if (null == paymentEntity){
            paymentEntity = new PaymentEntity();
        }
        paymentEntity.setDataSourceCode(oa_data_source_code);
        List<PaymentEntity> paymentList = paymentService.queryUnpaid(paymentEntity);
       /* List<PaymentEntity> paymentList = new ArrayList<>();
        paymentEntity.setReferenceNum("CL202406140001");
        paymentEntity.setPayAccount("655905707410000");
        paymentEntity.setPayBankName("");
        paymentEntity.setAmount("99");
        paymentEntity.setRevAccount("123456778");
        paymentEntity.setRevBankName("中国工商银行总行清算中心");
        paymentEntity.setRevBankType("ICB");
        paymentEntity.setRevAccountName("测试账户");
        paymentEntity.setCnapsCode("102100099996");
        paymentEntity.setPurpose("测试用途");
        paymentEntity.setBusType("202");
        paymentEntity.setCurrency("10");
        paymentEntity.setPurpose("测试用途");
        paymentList.add(paymentEntity);*/
        if (CollectionUtils.isNotEmpty(paymentList)){
            for (PaymentEntity pay : paymentList) {
                //调用支付申请接口
                PayResponseDTO payResponseDTO = cbs8Service.payApply(pay);
                boolean successed = payResponseDTO.getSuccessed();
                if (successed){
                    pay.setPayResult(PayState.p.getValue());
                }else {
                    pay.setPayResult("推送失败");
                }
                //4、更新OA表单
                pay.setDataSourceCode(oa_data_source_code);
                pay.setApplyCode(payResponseDTO.getBusNum());
                paymentService.updatePayState(pay);
                //5、记录操作日志
                savePayLog(pay,payResponseDTO);
            }
        }
    }
    /**
     * 保存支付申请日志
     *
     * @param entity
     * @throws Exception
     */
    @Override
    public void savePayLog(PaymentEntity entity,PayResponseDTO payResponseDTO) throws Exception {
        //4. 保存日志
        CbsLogEntity cbsLogEntity = new CbsLogEntity();
        cbsLogEntity.setTitle(entity.getTitle());
        cbsLogEntity.setPay_company(entity.getPayCompany());
        cbsLogEntity.setPayee(entity.getRevAccountName());
        cbsLogEntity.setAmount(entity.getAmount());
        cbsLogEntity.setOa_id(entity.getOaId());
        cbsLogEntity.setBill_code(Convert.toStr(entity.getReferenceNumNew(),entity.getReferenceNum()));
        cbsLogEntity.setTab_name_ch(entity.getBillName());
        cbsLogEntity.setTab_name_en(entity.getTableName());
        Boolean successed = payResponseDTO.getSuccessed();
        if (successed){
            cbsLogEntity.setPay_state(PayState.p.getValue());
            cbsLogEntity.setApply_state(PayState.two.getValue());
            cbsLogEntity.setCbs_apply_code(payResponseDTO.getBusNum());
            cbsLogEntity.setSuccessed("true");
            entity.setPayResult(PayState.p.getValue());
        }else {
            cbsLogEntity.setPay_state("推送失败");
            cbsLogEntity.setMessage(payResponseDTO.getErrorMsg());
            cbsLogEntity.setSuccessed("false");
            entity.setPayResult("推送失败");
        }
        cbsLogService.saveLog(cbsLogEntity);
    }
    /**
     * 查询支付申请的交易结果
     *
     * @param cbsLogEntity
     * @throws Exception
     */
    @Override
    public void queryResult(CbsLogEntity cbsLogEntity) throws Exception {
        if (null == cbsLogEntity){
            cbsLogEntity = new CbsLogEntity();
        }
        cbsLogEntity.setDataSourceCode(oa_data_source_code);
        // 1、查询支付中的日志
        List<CbsLogEntity> inPayList = cbsLogService.queryInPayment(cbsLogEntity);
        if (CollectionUtils.isNotEmpty(inPayList)){
            for (CbsLogEntity entity : inPayList) {
                try {
                    List<PayResultResDTO> payResultResList = cbs8Service.queryPayResult(new PayResultRequestDTO(entity.getBill_code()));
                    if (CollectionUtils.isNotEmpty(payResultResList)){
                        PayResultResDTO payResultResDTO = payResultResList.get(0);
                        //支付申请状态
                        String status = payResultResDTO.getStatus();
                        //支付状态
                        String pay_status = payResultResDTO.getPayStatus();
                        //不等于支付中的时候 更新支付状态
                        if (!PayState.p.getType().equals(pay_status)){
                            //如果支付状态为空，保存支付申请状态，如果支付状态不为空，则保存支付状态
                            PaymentEntity paymentEntity = new PaymentEntity();
                            paymentEntity.setOaId(entity.getOa_id());
                            paymentEntity.setApplyCode(entity.getCbs_apply_code());
                            paymentEntity.setDataSourceCode(oa_data_source_code);
                            List<PaymentEntity> paymentList = paymentService.query(paymentEntity);
                            if (CollectionUtils.isNotEmpty(paymentList)){
                                paymentEntity = paymentList.get(0);
                                if (StrUtil.isEmpty(pay_status)) {
                                    //支付申请状态 支付状态和支付申请状态用一个
                                    paymentEntity.setPayResult(PayState.payStateGetValue(status));
                                } else {
                                    //支付状态 支付状态和支付申请状态用一个
                                    paymentEntity.setPayResult(PayState.payStateGetValue(pay_status));
                                }
                                if (StrUtil.isNotEmpty(pay_status) && pay_status.equals(PayState.g.getType())) {
                                    //支付时间
                                    paymentEntity.setPayDate(CBSUtil.convertTimestampToString(payResultResDTO.getPayDate()));
                                }
                                //更新视图单据状态
                                paymentEntity.setDataSourceCode(oa_data_source_code);
                                paymentService.updatePayState(paymentEntity);
                                //更新日志表状态
                                entity.setPay_state(paymentEntity.getPayResult());
                                entity.setApply_state(PayState.payStateGetValue(status));
                                entity.setDataSourceCode(oa_data_source_code);
                                cbsLogService.updateLog(entity);
                            }
                        }
                    }
                }catch (Exception e){
                 e.printStackTrace();
                 logger.error("查询交易结果出错",e);
                }
            }
        }
    }
    /**
     * 电子回单查询 并上传OA
     *
     * @param requestJson
     * @throws Exception
     */
    @Override
    public void elecBillUpload(JSONObject requestJson) throws Exception {
        //查询支付成功 没有电子回单的数据
        PaymentEntity paymentEntity = new PaymentEntity();
       // List<PaymentEntity> paymentList = paymentService.queryElecIsNull(paymentEntity);
        paymentEntity.setPayDate("2024-06-20");
        paymentEntity.setReferenceNum("41");
        List<PaymentEntity> paymentList = Arrays.asList(paymentEntity);
        if (CollectionUtils.isNotEmpty(paymentList)) {
            for (PaymentEntity pay : paymentList) {
                try {
                    String payDate = DateUtil.format(DateUtil.parse(pay.getPayDate()), "yyyy-MM-dd");
                    //查询cbs电子回单
                    List<ElecResponseDTO> elecResList = cbs8Service.queryElecBill(new ElecRequestDTO(payDate,DateUtil.today(),pay.getReferenceNum()));
                    if (CollectionUtils.isNotEmpty(elecResList)){
                        ElecResponseDTO elecResponseDTO = elecResList.get(0);
                        String bucketFileUrl = elecResponseDTO.getBucketFileUrl();
                        String bucketFileName = elecResponseDTO.getBucketFileName();
                        //上传电子回单到OA
                        HttpUtil.downloadFile(bucketFileUrl, FileUtil.file(elec_path));//附件下载
                        String pdfUrl = elec_path + bucketFileName;
                        File file = new File(pdfUrl);
                        if (file.exists()) {
                            CtpFileEntity cpFileEntity =  new CtpFileEntity();
                            cpFileEntity.setFile(file);
                            cpFileEntity.setDataSourceCode(oa_data_source_code);
                            JSONObject jsonObjectUpload = restUtil.fileUpload(file,"8000240005");
                            String file_url = jsonObjectUpload.getString("fileUrl");
                            if (null != jsonObjectUpload && StrUtil.isNotEmpty(file_url)) {
                                String sub_reference = String.valueOf(UUIDLong.longUUID());
                                pay.setReceipt(sub_reference);
                                //更新表单的电子回单值
                                paymentService.updateElec(pay);
                                //保存附件关系
                                CtpAttachmentEntity ctpAttachmentEntity = new CtpAttachmentEntity();
                                ctpAttachmentEntity.setFile_url(file_url);
                                ctpAttachmentService.saveAttachment(file_url, pay.getSummaryId(), sub_reference);
                            }
                            //删除本地临时文件
                            file.delete();
                        }
                    }
                }catch (Exception e){
                    logger.error("电子回单查询出错",e);
                }
            }
        }
    }
    /**
     * 查询交易明细
     * transactionDetailReqDTO.currentPage 、 transactionDetailReqDTO.pageSize 必填
     * @param transactionDetailReqDTO
     */
    @Override
    public List<TransactionDetailDTO> queryTransactionDetail(TransactionDetailReqDTO transactionDetailReqDTO) {
        boolean hasNextPage = true;//是否有下一页
        int currentPage = transactionDetailReqDTO.getCurrentPage();
        int pageSize = transactionDetailReqDTO.getPageSize();
        if (currentPage == 0){
            currentPage = CBSUtil.DEFAULT_CURRENT_PAGE;//页码
        }
        if (pageSize == 0){
            pageSize = CBSUtil.DEFAULT_PAGE_SIZE;//每页条数
            transactionDetailReqDTO.setPageSize(pageSize);
        }
        List<TransactionDetailDTO> resultList = new ArrayList<>();
        do{
            transactionDetailReqDTO.setCurrentPage(currentPage);//页码
            currentPage++;//页码自增
            hasNextPage = false;//保护功能，防止出现死循环
            CbsResDataDTO dataDTO = cbs8Service.queryTransactionDetail(transactionDetailReqDTO);
            if (null != dataDTO){
                hasNextPage = dataDTO.getHasNextPage();
                List<TransactionDetailDTO> transactionDetailDTOList = CBSUtil.convertJsonArrayToList(dataDTO.getList(), TransactionDetailDTO.class);
                resultList.addAll(transactionDetailDTOList);
            }
        }while (hasNextPage);
        return resultList;
    }
    /**
     * 代发代扣 支付申请
     *
     * @param paymentEntity
     */
    @Override
    public void applyAgentPay(AgentPaymentEntity paymentEntity) {
        try {
            if (null != paymentEntity ){
                paymentEntity.setDataSourceCode(oa_data_source_code);
                List<AgentPaymentEntity> agentPaymentList = agentPaymentService.queryUnpaid(paymentEntity);
                if (CollectionUtils.isNotEmpty(agentPaymentList)){
                    for (AgentPaymentEntity agentPay : agentPaymentList) {
                        AgentPaymentDetailEntity detailEntity = new AgentPaymentDetailEntity();
                        detailEntity.setFormmainId(agentPay.getOaId());
                        detailEntity.setDataSourceCode(oa_data_source_code);
                        List<AgentPaymentDetailEntity> agentPaymentDetailList = agentPaymentService.queryDetails(detailEntity);
                        if (CollectionUtils.isNotEmpty(agentPaymentDetailList)){
                            PaymentApplySubmitReqDTO paymentApplySubmitReqDTO = BeanUtil.copyProperties(agentPay,PaymentApplySubmitReqDTO.class);
                            List<PaymentApplyAgentDTO> paymentApplyAgentList = new ArrayList<>();
                            for (AgentPaymentDetailEntity detail : agentPaymentDetailList) {
                                PaymentApplyAgentDTO detailDTO = BeanUtil.copyProperties(detail,PaymentApplyAgentDTO.class);
                                paymentApplyAgentList.add(detailDTO);
                            }
                            //招行这里要传203
                            paymentApplySubmitReqDTO.setBankExtend5("203");
                            PayResponseDTO payResponseDTO =  cbs8Service.agentPayApply(paymentApplySubmitReqDTO,paymentApplyAgentList);
                            if (null != payResponseDTO){
                                Boolean successed = payResponseDTO.getSuccessed();
                                AgentPaymentEntity pay = new AgentPaymentEntity();
                                pay.setOaId(paymentEntity.getOaId());
                                pay.setDataSourceCode(oa_data_source_code);
                                if (successed){
                                    //更新申请单号到OA
                                    pay.setApplyCode(payResponseDTO.getBusNum());
                                    pay.setPayResult("审批中");
                                }else {
                                    pay.setPayResult(payResponseDTO.getErrorMsg());
                                }
                                agentPaymentService.updateResult(pay);
                                System.out.println(JSONObject.toJSONString(payResponseDTO));
                            }
                        }
                    }
                }
            }else {
                throw new BaseSystemException("参数不能为空");
            }
        }catch (Exception e){
            logger.error("代发代扣出错:{}",e);
        }
    }
    /**
     * 代发代扣 结果详情查询
     *
     * @param agentPayResultRequestDTO
     * @return
     */
    @Override
    public AgentPayResultResDTO agentPayResult(AgentPayResultRequestDTO agentPayResultRequestDTO) {
        try {
            if (null != agentPayResultRequestDTO && StrUtil.isNotEmpty(agentPayResultRequestDTO.getBusNum())){
                AgentPayResultResDTO agentPayResultResDTO = cbs8Service.agentPayResult(agentPayResultRequestDTO);
                //更新OA表单
                String busNum = agentPayResultResDTO.getBusNum();
                if (StringUtils.isNotEmpty(busNum)){
                    AgentPaymentEntity agentPaymentEntity = new AgentPaymentEntity();
                    agentPaymentEntity.setApplyCode(busNum);
                    agentPaymentEntity.setDataSourceCode(oa_data_source_code);
                    AgentPaymentEntity entity =  agentPaymentService.queryByApplyCode(agentPaymentEntity);
                    String pay_status = agentPayResultResDTO.getPayStatus();
                    String status = agentPayResultResDTO.getStatus();
                    if (null != entity){
                        AgentPaymentEntity result = new AgentPaymentEntity();
                        result.setOaId(entity.getOaId());
                        result.setDataSourceCode(oa_data_source_code);
                        //更新主表
                        if (StrUtil.isEmpty(pay_status)) {
                            result.setPayResult(PayState.payStateGetValue(status));//支付申请状态 支付状态和支付申请状态用一个
                        } else {
                            result.setPayResult(PayState.payStateGetValue(pay_status));//支付状态 支付状态和支付申请状态用一个
                        }
                        agentPaymentService.updateResult(result);
                        //更新明细表
                        List<AgentPayQueryDTO> agentDetails = agentPayResultResDTO.getAgentDetails();
                        for (AgentPayQueryDTO d : agentDetails) {
                            AgentPaymentDetailEntity detail = new AgentPaymentDetailEntity();
                            detail.setFormmainId(entity.getOaId());
                            detail.setDtlAmount(d.getDtlAmount());
                            detail.setDtlCnapsCode(d.getDtlCnapsCode());
                            detail.setDtlRevName(d.getDtlRevName());
                            detail.setDtlSeqNum(Integer.valueOf(d.getDtlSeqNum()));
                            detail.setPayResult(PayState.payStateGetValue(d.getDtlStatus()));
                            detail.setPayDate(CBSUtil.convertTimestampToString(d.getDtlPayTime()));
                            detail.setDataSourceCode(oa_data_source_code);
                            agentPaymentDetailService.updatePayResult(detail);
                        }
                    }
                }
                return agentPayResultResDTO;
            }
        }catch (Exception e){
            logger.error("代发代扣详情结果查询出错{}",e);
        }
        return null;
    }
    /**
     * 保存交易明细到OA底表
     *
     * @param transactionlList
     */
    @Override
    public void saveTransactionDetail(List<TransactionDetailDTO> transactionlList) {
        if (CollectionUtils.isNotEmpty(transactionlList)){
            //过滤已经保存过的数据
            //收款档案表的数据
            TransactionDetailEntity transactionDetailEntity = new TransactionDetailEntity();
            transactionDetailEntity.setBankTransactionDate(DateUtil.lastWeek().toDateStr());
            transactionDetailEntity.setDataSourceCode(oa_data_source_code);
            List<TransactionDetailEntity> transactionDetailList = transactionDetailService.querySerialNumber(transactionDetailEntity);
            //过滤已经保存的数据
            if (CollectionUtils.isNotEmpty(transactionDetailList)){
                //过滤transactionlList 去除已经存在transactionDetailList中的数据，条件为transactionSerialNumber相等
                if (CollectionUtils.isNotEmpty(transactionlList)){
                    transactionlList = transactionlList.stream()
                            .filter(item -> transactionDetailList.stream()
                                    .noneMatch(detailItem -> item.getTransactionSerialNumber().equals(detailItem.getTransactionSerialNumber())))
                            .collect(Collectors.toList());
                }
            }
            if (CollectionUtils.isNotEmpty(transactionlList)){
                //保存到OA底表
                for (TransactionDetailDTO dto : transactionlList) {
                    TransactionDetailEntity transactionDetail = new TransactionDetailEntity();
                    BeanUtil.copyProperties(dto,transactionDetail);
                    transactionDetail.setCurrency(CurrencyEnum.getChineseNameByCode(dto.getCurrency()));
                    if (NumberUtil.isNumber(dto.getBankTransactionDate())){//如果是时间戳 转换成日期字符串
                        transactionDetail.setBankTransactionDate(CBSUtil.convertTimestampToString(dto.getBankTransactionDate()));
                    }
                    transactionDetailService.restSave(transactionDetail);
                }
            }
        }
    }
    //这个方法没用，用的是8.0批量保存方式，我没有测试
    private void saveTransactionDetailTemp(List<TransactionDetailDTO> transactionDetailList) {
        if (CollectionUtils.isNotEmpty(transactionDetailList)){
            //过滤已经保存过的数据
            for (TransactionDetailDTO dto : transactionDetailList) {
                List<FormDataDTO> dataList = new ArrayList<>();
                FormDTO formDTO = new FormDTO();
                formDTO.setFormCode("formmain_0233");
                formDTO.setLoginName("yonyou");
                formDTO.setRightId("6603635988997229999.-8611088937958683581");
                String field0001=dto.getAccountNo();//我方银行账号
                String field0002=dto.getAccountName();//我方户名
                String field0003=dto.getOpenBank();//我方开户行
                String field0004=dto.getBankType();//我方银行类型
                String field0005=dto.getTransactionSerialNumber();//交易流水号
                String field0006=dto.getBankTransactionDate();//交易日期
                String field0007=dto.getBankSerialNumber();//银行流水号
                String field0008=dto.getCurrency();//币种
                String field0009=dto.getIncurredAmount();//收款金额
                String field0010=dto.getPurpose();//用途
                String field0011=dto.getDigest();//摘要
                String field0012=dto.getOppositeAccount();//对方账号
                String field0013=dto.getOppositeName();//对方户名
                String field0014=dto.getOppositeOpeningBank();//对方开户行
                String field0015=dto.getRemark();//备注
                //fields
                List<RecordFieldDTO> fields = new ArrayList<>();
                fields.add(new RecordFieldDTO("field0001",field0001,field0001));
                fields.add(new RecordFieldDTO("field0002",field0002,field0002));
                fields.add(new RecordFieldDTO("field0003",field0003,field0003));
                fields.add(new RecordFieldDTO("field0004",field0004,field0004));
                fields.add(new RecordFieldDTO("field0005",field0005,field0005));
                fields.add(new RecordFieldDTO("field0006",field0006,field0006));
                fields.add(new RecordFieldDTO("field0007",field0007,field0007));
                fields.add(new RecordFieldDTO("field0008",field0008,field0008));
                fields.add(new RecordFieldDTO("field0009",field0009,field0009));
                fields.add(new RecordFieldDTO("field0010",field0010,field0010));
                fields.add(new RecordFieldDTO("field0011",field0011,field0011));
                fields.add(new RecordFieldDTO("field0012",field0012,field0012));
                fields.add(new RecordFieldDTO("field0013",field0013,field0013));
                fields.add(new RecordFieldDTO("field0014",field0014,field0014));
                fields.add(new RecordFieldDTO("field0015",field0015,field0015));
                //masterTable
                MasterTableDTO masterTableDTO = new MasterTableDTO();
                masterTableDTO.setName("formmain_1284");
                RecordDTO recordDTO = new RecordDTO();
                recordDTO.setId(UUIDLong.longUUID());
                recordDTO.setFields(fields);
                masterTableDTO.setRecord(recordDTO);
                //dataList
                FormDataDTO formDataDTO = new FormDataDTO();
                formDataDTO.setMasterTable(masterTableDTO);
                dataList.add(formDataDTO);
                formDTO.setDataList(dataList);
            }
        }
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/constant/ExportConstant.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/constant/ExportConstant.java
@ -0,0 +1,24 @@
 package com.hzya.frame.plugin.lets.constant;
 import java.util.HashMap;
 import java.util.Map;
 /**
 * 如果是海外店铺，税率为 0
 *
 * @Author：liuyang
 * @Package：com.hzya.frame.plugin.lets.constant
 * @Project：kangarooDataCenterV3
 * @name：ExportConstant
 * @Date：2024/8/13 18:00
 * @Filename：ExportConstant
 */
 public class ExportConstant {
    public static final Map<String, String> exportConstant = new HashMap<>();
    static {
        exportConstant.put("xuni-intoyou-japan", "xuni-intoyou-japan");
        exportConstant.put("B2BFX20240001", "B2BFX20240001");
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/constant/OverallConstant.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/constant/OverallConstant.java
@ -0,0 +1,181 @@
 package com.hzya.frame.plugin.lets.constant;
 import java.util.HashMap;
 import java.util.Map;
 /**
 * lets全局静态参数配置
 */
 public class OverallConstant {
    private static final Map<String, String> devOverAll = new HashMap<>();
    private static final Map<String, String> testOverAll = new HashMap<>();
    private static final Map<String, String> prodOverAll = new HashMap<>();
    private static final Map<String, String> prodOverPublic = new HashMap<>();
    static {
        //dev
        loadDev();
        //prod
        loadProd();
        //公共部分
        loadPublic();
    }
    private static void loadPublic() {
        //存货分类
        prodOverPublic.put("bdinvSaveCode", "8000370025");//存货分类新增
        prodOverPublic.put("bdinvUpdateCode", "8000370026");//存货分类修改
        prodOverPublic.put("bdinvDeleteCode", "8000370027");//存货分类删除
        //存货基本档案
        prodOverPublic.put("bdinvclSaveCode", "8000370002");//存货基本档案新增
        prodOverPublic.put("bdinvclUpdateCode", "8000370046");//存货基本档案修改
        prodOverPublic.put("bdinvclSealCode", "8000370058");//存货基本档案封存
        prodOverPublic.put("bdinvclUnsealCode", "8000370059");//存货基本档案取消封存
        prodOverPublic.put("bdinvclAllotCode", "8000370003");//存货基本档案自动分配
        //成套件
        prodOverPublic.put("setpartInsertCode", "8000370063");//成套件新增
        prodOverPublic.put("setpartDeleteCode", "8000370064");//成套件删除
        prodOverPublic.put("setpartQueryCode", "8000370065");//成套件查询
        //组装拆卸
        prodOverPublic.put("special4lSaveCode", "8000370066");//成套件查询
        //调拨
        prodOverPublic.put("approveqzCode", "8000370009");//调拨订单保存即审批
        prodOverPublic.put("approveInqzCode", "8000370054");//调拨入库保存并签字
        //其他出入库
        prodOverPublic.put("otherinqzCode", "8000370007");//库存其他入库保存即签字
        prodOverPublic.put("otheroutqzCode", "8000370008");//库存其他出库保存即签字
        prodOverPublic.put("otheroutsignCode", "8000370067");//库存其他出库即签字
        prodOverPublic.put("otherinsignCode", "8000370068");//库存其他入库即签字
        prodOverPublic.put("custdocSaveCode", "8000370062");//客商档案新增
        prodOverPublic.put("custdocSave", "/u8cloud/api/uapbd/custdoc/insert");//客商档案新增
        prodOverPublic.put("custdocQuery", "/u8cloud/api/uapbd/custdoc/query");//客商档案查询
        prodOverPublic.put("custdocUpdate", "8000370040");//客商档案修改
        prodOverPublic.put("custdocAssignCode", "8000370001");//客商档案分配
        prodOverPublic.put("custdocAssign", "/u8cloud/api/uapbd/custdoc/assign");//客商档案分配
        prodOverPublic.put("custmandocSave", "/u8cloud/api/uapbd/custmandoc/insert");//客商档案新增
        prodOverPublic.put("bdcorpQueryCode", "8000370060");//公司档案查询
        prodOverPublic.put("bdcorpQuery", "/u8cloud/api/uapbd/bdcorp/query");//公司档案查询
        prodOverPublic.put("bddefdoclistsaveCode", "8000370061");//自定义档案内容新增
        prodOverPublic.put("bddefdoclistUpdateCode", "8000370070");//自定义档案内容更新
        //应收单
        prodOverPublic.put("arapYsInsertApproveCode", "8000370069");//自定义档案内容查询
        //付款单
        prodOverPublic.put("arapFkInsetCode", "8000370044");//付款单审批
        prodOverPublic.put("arapFkApproveCode", "8000370045");//付款单保存即审批
        prodOverPublic.put("appId", "800037");//数智中台
        prodOverPublic.put("publicKey", "ZJYAWb7lhAUTYqekPkU+uHJv1/ObJxb7dT7sD8HPRDGAgyhCe7eDIk+3zDUT+v578prj");//数智中台
        prodOverPublic.put("secretKey", "fviZnLBsQUAGF8w8FSOdJi7XlIm/XAZclMxRagDLfTyJFlvnIBF3w66Hrpfzs8cYj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=");//数智中台
    }
    private static void loadDev() {
        //测式U8C
        devOverAll.put("u8cApiUrl", "http://39.170.109.90:19099");
        devOverAll.put("u8cApiUsercodePK", "admin");
        devOverAll.put("u8cApiPasswordPK", "cbc3df059791996e4cce8e4ac51f4f8e");
        devOverAll.put("u8cApiTrantypePK", "pk");
        devOverAll.put("u8cApiSystemPK", "lz");
        devOverAll.put("u8cApiNeedStackTracePK", "Y");
        devOverAll.put("u8cApiZdrPK", "TB_NEW100000000004OP");//单据制单人---测试环境：tbadmin
        devOverAll.put("u8cApiUsercodeCode", "admin1");
 //        devOverAll.put("u8cApiPasswordCode", "83f1ad3e7fa3617f1aae62ae7413c810");
        devOverAll.put("u8cApiPasswordCode", "f7fcde654e968541cc803c4b08c30abb");
        devOverAll.put("u8cApiTrantypeCode", "code");
        devOverAll.put("u8cApiSystemCode", "lz1");
        devOverAll.put("u8cApiNeedStackTraceCode", "Y");
        devOverAll.put("u8cApiZdrCode", "tbadmin");//单据制单人---测试环境：tbadmin
        devOverAll.put("u8c自定义项档案-公司对照", "0001A11000000004XB42");
        devOverAll.put("u8c自定义项档案-店铺主键", "0001A110000000000EBX");
        devOverAll.put("u8c自定义项档案-平台主键", "0001A110000000000EEU");
        devOverAll.put("u8c自定义项档案-存货分类对应收支项目主键", "0001A210000000008FBN");
        devOverAll.put("u8c自定义项档案-单据红字标识-Y主键", "0001A1100000000027LP");
        devOverAll.put("u8c自定义项档案-单据红字标识-Y名称", "Y");
        devOverAll.put("u8c自定义项档案-单据红字标识-N主键", "0001A1100000000027LQ");
        devOverAll.put("u8c自定义项档案-单据红字标识-N名称", "N");
        //本地中台地址
        devOverAll.put("u8c_url", "http://127.0.0.1:8081/kangarooDataCenterV3/entranceController/externalCallInterface");
    }
    private static void loadProd() {
        //内网正式U8C
        prodOverAll.put("u8cApiUrl", "http://192.168.10.118:8088");
        //外网正式U8C地址
 //        prodOverAll.put("u8cApiUrl", "http://39.170.109.90:8088");
        //主键
        prodOverAll.put("u8cApiUsercodePK", "admin");
        prodOverAll.put("u8cApiPasswordPK", "cbc3df059791996e4cce8e4ac51f4f8e");
        prodOverAll.put("u8cApiTrantypePK", "pk");
        prodOverAll.put("u8cApiSystemPK", "lz");
        prodOverAll.put("u8cApiNeedStackTracePK", "N");
        prodOverAll.put("u8cApiZdrPK", "TB_NEW100000000004OP");//单据制单人---测试环境：tbadmin
        //编码
        prodOverAll.put("u8cApiUsercodeCode", "admin1");
        prodOverAll.put("u8cApiPasswordCode", "f7fcde654e968541cc803c4b08c30abb");
        prodOverAll.put("u8cApiTrantypeCode", "code");
        prodOverAll.put("u8cApiSystemCode", "lz1");
        prodOverAll.put("u8cApiNeedStackTraceCode", "N");
        prodOverAll.put("u8cApiZdrCode", "tbadmin");//单据制单人---测试环境：tbadmin
 //        prodOverAll.put("u8c自定义项档案-公司对照", "0001A11000000006Q0W1");
        //U8C241231无，如果存在公司会被替换，李佳妮认为1月份的数据不需要盈达公司
        prodOverAll.put("u8c自定义项档案-公司对照", "0001A21000000000R4YA");
        prodOverAll.put("u8c自定义项档案-店铺主键", "0001A110000000000EBX");
        prodOverAll.put("u8c自定义项档案-平台主键", "0001A110000000000EEU");
        //U8C241231无，已经不用了
        //之前存货分类对应收支项目是李佳妮提出来的，后来开发好后发现走不通，某个存货分类对应的收支项目与业务流程完全不搭嘎
        //导致TOB销售业务匹配到采购的收支项目上（说是某个存货分类仅采购有业务发生，其实销售也有），所以这条方案被取消
        prodOverAll.put("u8c自定义项档案-存货分类对应收支项目主键", "0001A210000000008FBN");
        prodOverAll.put("u8c自定义项档案-单据红字标识-Y主键", "0001A1100000000027LP");
        prodOverAll.put("u8c自定义项档案-单据红字标识-Y名称", "Y");
        prodOverAll.put("u8c自定义项档案-单据红字标识-N主键", "0001A1100000000027LQ");
        prodOverAll.put("u8c自定义项档案-单据红字标识-N名称", "N");
        //内网中台地址
        prodOverAll.put("u8c_url", "http://127.0.0.1:8081/kangarooDataCenterV3/entranceController/externalCallInterface");
        //外网中台地址
 //        prodOverAll.put("u8c_url", "http://39.170.109.90:8081/kangarooDataCenterV3/entranceController/externalCallInterface");
    }
    /**
     * 根据key获取全局变量值
     *
     * @param key key值
     * @return 返回String
     */
    public static String getOverAllValue(String key) {
        String value = null;
        if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals("dev")) {
            value = devOverAll.get(key);
        } else if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals("test")) {
            value = testOverAll.get(key);
        } else if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals("prod")) {
            value = prodOverAll.get(key);
        }
        if (value == null) {
            value = prodOverPublic.get(key);
        }
        return value;
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/constant/ProfilesActiveConstant.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/constant/ProfilesActiveConstant.java
@ -0,0 +1,53 @@
 package com.hzya.frame.plugin.lets.constant;
 import java.util.Arrays;
 import java.util.List;
 /**
 * lets项目公共参数
 */
 public class ProfilesActiveConstant {
    public static final String LETS_DATE_SOURCE = "lets_u8c";
    public static final String LETS_PROFILES_ACTIVE = "prod";
    public static final String LOG_STATUS_Y = "Y";
    public static final String LOG_STATUS_N = "N";
    public static final String LOG_STATUS_Y_H = "'Y','H'";
    public static final String TYPE_DATE = "date";
    public static final String TYPE_VBILLCODE = "vbillcode";
    public static final String TYPE_DETAIL_ERROR = "details_error";
    public static final String TYPE_TIME_FRAME = "time_frame";
    public static final String TYPE_OTHER = "other";
 //    public static final String U8C_URL = "http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterface";
    //public static final String U8C_URL = "http://ufidahz.com.cn:9067/kangarooDataCenterV3/entranceController/externalCallInterface";
 //    public static final String OFS_URL_TEST = "http://39.98.58.229/api/edi/ofs/in";
    public static final String SUPPLIER = "'1','3'";
    public static final String CUSTOMER = "'0','2'";
    public static final String sourceSystem1 = "OFS订单系统";
    public static final String sourceSystem2 = "丽知商城";
    public static final String FILTER_COMPANY = "NMNS,YNS,HJ";
    //0:o->中台
    public static final String PUSH_SCENE_TYPE_0 = "0";
    //1:中台->u8c
    public static final String PUSH_SCENE_TYPE_1 = "1";
    //2:o->中台->u8c
    public static final String PUSH_SCENE_TYPE_2 = "2";
    //toc/tob仅退款使用，需要去存货管理档案参考售价的店铺
    public static final List<String> REFERENCE_SHOP_LIST = Arrays.asList("DLTer", "XZJJ", "FANG-Q-L-NEW", "pdd-yanxi-new", "FANG-Q-L", "pdd-yanxi");
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IArapDjzbDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IArapDjzbDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.ArapDjzbEntity;
 import com.hzya.frame.basedao.dao.IBaseDao; 
 /**
 * (ARAP_DJZB: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-11-21 11:26:53
 */
 public interface IArapDjzbDao extends IBaseDao<ArapDjzbEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBankaccbasDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBankaccbasDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdBankaccbasEntity;
 /**
 * (bd_bankaccbas: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-30 15:53:06
 */
 public interface IBdBankaccbasDao extends IBaseDao<BdBankaccbasEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBankdocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBankdocDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdBankdocEntity;
 /**
 * (bd_bankdoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-30 16:16:01
 */
 public interface IBdBankdocDao extends IBaseDao<BdBankdocEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBomDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBomDao.java
@ -0,0 +1,22 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.BdBomEntity;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import java.util.List;
 /**
 * (BD_BOM: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-02 14:56:24
 */
 public interface IBdBomDao extends IBaseDao<BdBomEntity, String> {
    /**
     * 查询BOM版本
     *
     * @author liuyang
     */
    List<BdBomEntity> queryBomVersion(BdBomEntity bdBomEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBusitypeDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdBusitypeDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdBusitypeEntity;
 /**
 * (bd_busitype: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-11-21 10:57:24
 */
 public interface IBdBusitypeDao extends IBaseDao<BdBusitypeEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCalbodyDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCalbodyDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdCalbodyEntity;
 /**
 * (bd_calbody: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-06 17:31:07
 */
 public interface IBdCalbodyDao extends IBaseDao<BdCalbodyEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCargdocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCargdocDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdCargdocEntity;
 /**
 * (bd_cargdoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-07 09:05:12
 */
 public interface IBdCargdocDao extends IBaseDao<BdCargdocEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCorpDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCorpDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdCorpEntity;
 /**
 * (bd_corp: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-06 14:47:17
 */
 public interface IBdCorpDao extends IBaseDao<BdCorpEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCostsubjDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCostsubjDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.BdCostsubjEntity;
 import com.hzya.frame.basedao.dao.IBaseDao;
 /**
 * (BD_COSTSUBJ: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-20 13:39:58
 */
 public interface IBdCostsubjDao extends IBaseDao<BdCostsubjEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCubasdocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCubasdocDao.java
@ -0,0 +1,22 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
 /**
 * (bd_cubasdoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 09:41:41
 */
 public interface IBdCubasdocDao extends IBaseDao<BdCubasdocEntity, String> {
    /**
     * 查询客商基础档案：通过客商管理档案主键，得到客商基础档案
     *
     * @author liuyang
     */
    BdCubasdocEntity queryBdCumandocEntity(BdCubasdocEntity bdCumandocEntity) throws Exception;
    String selectUserNameByPk(String cuserid);
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCumandocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCumandocDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdCumandocEntity;
 /**
 * (bd_cumandoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 09:42:24
 */
 public interface IBdCumandocDao extends IBaseDao<BdCumandocEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCustbankDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdCustbankDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdCustbankEntity;
 /**
 * (bd_custbank: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-30 09:37:43
 */
 public interface IBdCustbankDao extends IBaseDao<BdCustbankEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdDefdocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdDefdocDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdDefdocEntity;
 /**
 * (bd_defdoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 13:46:53
 */
 public interface IBdDefdocDao extends IBaseDao<BdDefdocEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdDefdoclistDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdDefdoclistDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdDefdoclistEntity;
 /**
 * (bd_defdoclist: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 13:49:47
 */
 public interface IBdDefdoclistDao extends IBaseDao<BdDefdoclistEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdDeptdocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdDeptdocDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdDeptdocEntity;
 /**
 * (bd_deptdoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-13 11:37:15
 */
 public interface IBdDeptdocDao extends IBaseDao<BdDeptdocEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdInvbasdocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdInvbasdocDao.java
@ -0,0 +1,37 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdInvbasdocEntity;
 import java.util.List;
 /**
 * (bd_invbasdoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 11:27:08
 */
 public interface IBdInvbasdocDao extends IBaseDao<BdInvbasdocEntity, String> {
    /**
     * 查询存货基础档案
     *
     * @author liuyang
     */
    BdInvbasdocEntity queryBdInvbasdocByPkInvmandoc(BdInvbasdocEntity bdInvbasdocEntity) throws Exception;
    /**
     * 查询存货基础档案
     *
     * @author liuyang
     */
    List<BdInvbasdocEntity> queryBdInvbasdocByPkInvmandocV2(BdInvbasdocEntity bdInvbasdocEntity) throws Exception;
    /**
     * 查询存货基础档案
     *
     * @author liuyang
     */
    List<BdInvbasdocEntity> queryBdInvbasdocByPkInvmandocV3(BdInvbasdocEntity bdInvbasdocEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdInvclDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdInvclDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdInvclEntity;
 /**
 * (bd_invcl: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-01-09 15:08:19
 */
 public interface IBdInvclDao extends IBaseDao<BdInvclEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdInvmandocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdInvmandocDao.java
@ -0,0 +1,29 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdInvmandocEntity;
 import java.util.List;
 /**
 * (bd_invmandoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 11:21:43
 */
 public interface IBdInvmandocDao extends IBaseDao<BdInvmandocEntity, String> {
    /**
     * 根据存货编码查询存货管理档案
     *
     * @author liuyang
     */
    BdInvmandocEntity queryBdInvmandocByInvcode(BdInvmandocEntity bdInvmandocEntity) throws Exception;
    /**
     * 根据存货编码查询存货管理档案
     *
     * @author liuyang
     */
    List<BdInvmandocEntity> queryBdInvmandocByInvcodeList(BdInvmandocEntity bdInvmandocEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdJobbasfilDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdJobbasfilDao.java
@ -0,0 +1,22 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdJobbasfilEntity;
 import com.hzya.frame.plugin.lets.queryvo.ExtBdJobbasfilQueryVo;
 import com.hzya.frame.plugin.lets.resultvo.ExtBdJobbasfilResultVo;
 import java.util.List;
 /**
 * (bd_jobbasfil: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 14:46:18
 */
 public interface IBdJobbasfilDao extends IBaseDao<BdJobbasfilEntity, String> {
    /**
     * 查询项目基本档案，类型名称为：自定义档案映射
     */
    List<ExtBdJobbasfilResultVo> queryProjectBasicArchivesByTypeDIY(ExtBdJobbasfilQueryVo extBdJobbasfilQueryVo) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdJobmngfilDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdJobmngfilDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdJobmngfilEntity;
 /**
 * (bd_jobmngfil: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 14:48:35
 */
 public interface IBdJobmngfilDao extends IBaseDao<BdJobmngfilEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdJobtypeDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdJobtypeDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdJobtypeEntity;
 /**
 * (bd_jobtype: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 14:55:03
 */
 public interface IBdJobtypeDao extends IBaseDao<BdJobtypeEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdPsndocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdPsndocDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdPsndocEntity;
 /**
 * (bd_psndoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-09 15:18:17
 */
 public interface IBdPsndocDao extends IBaseDao<BdPsndocEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdPurorgDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdPurorgDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.BdPurorgEntity;
 import com.hzya.frame.basedao.dao.IBaseDao; 
 /**
 * (BD_PURORG: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-08-20 14:20:10
 */
 public interface IBdPurorgDao extends IBaseDao<BdPurorgEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdRdclDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdRdclDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdRdclEntity;
 /**
 * (bd_rdcl: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-04 13:49:10
 */
 public interface IBdRdclDao extends IBaseDao<BdRdclEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdSalestruDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdSalestruDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdSalestruEntity;
 /**
 * (bd_salestru: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-06 18:20:57
 */
 public interface IBdSalestruDao extends IBaseDao<BdSalestruEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdSetpartDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdSetpartDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.BdSetpartEntity;
 import com.hzya.frame.basedao.dao.IBaseDao; 
 /**
 * (BD_SETPART: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-11 15:34:13
 */
 public interface IBdSetpartDao extends IBaseDao<BdSetpartEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdStordocDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdStordocDao.java
@ -0,0 +1,14 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdStordocEntity;
 /**
 * (bd_stordoc: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 10:19:26
 */
 public interface IBdStordocDao extends IBaseDao<BdStordocEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdTaxitemsDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBdTaxitemsDao.java
@ -0,0 +1,29 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BdTaxitemsEntity;
 import java.util.List;
 /**
 * (bd_taxitems: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-30 18:32:17
 */
 public interface IBdTaxitemsDao extends IBaseDao<BdTaxitemsEntity, String> {
    /**
     * 根据存货编码查询税率
     *
     * @author liuyang
     */
    BdTaxitemsEntity queryBdInvbasdocByInvcode(BdTaxitemsEntity bdTaxitemsEntity) throws Exception;
    /**
     * 根据存货编码查询税率
     *
     * @author liuyang
     */
    List<BdTaxitemsEntity> queryBdInvbasdocByInvcodeV2(BdTaxitemsEntity bdTaxitemsEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocreturnsDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocreturnsDao.java
@ -0,0 +1,21 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BusidataTocreturnsEntity;
 import java.util.List;
 /**
 * OMS退货入库TOC业务主表(busidata_tocreturns: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-03-14 14:48:00
 */
 public interface IBusidataTocreturnsDao extends IBaseDao<BusidataTocreturnsEntity, String> {
    /**
     * 批量插入
     *
     * @author liuyang
     */
    void entityInsertBatch(List<BusidataTocreturnsEntity> busidataTocreturnsEntityList) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocreturnsDetailDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocreturnsDetailDao.java
@ -0,0 +1,19 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BusidataTocreturnsDetailEntity;
 import java.util.List;
 /**
 * OMS退货入库明细TOC业务主表(busidata_tocreturns_detail: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-03-14 14:56:16
 */
 public interface IBusidataTocreturnsDetailDao extends IBaseDao<BusidataTocreturnsDetailEntity, String> {
    /**
     * 批量插入
     */
    void entityInsertBatch(List<BusidataTocreturnsDetailEntity> busidataTocreturnsDetailEntityList) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocsalesDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocsalesDao.java
@ -0,0 +1,21 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BusidataTocsalesEntity;
 import java.util.List;
 /**
 * OMS销售出库TOC业务主表(busidata_tocsales: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-03-11 15:31:56
 */
 public interface IBusidataTocsalesDao extends IBaseDao<BusidataTocsalesEntity, String> {
    /**
     * 批量插入底表数据
     */
    void entityInsertBatch(List<BusidataTocsalesEntity> busidataTocsalesEntityList) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocsalesDetailDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IBusidataTocsalesDetailDao.java
@ -0,0 +1,19 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.BusidataTocsalesDetailEntity;
 import java.util.List;
 /**
 * OMS销售出库TOC业务明细表(busidata_tocsales_detail: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-03-11 15:33:13
 */
 public interface IBusidataTocsalesDetailDao extends IBaseDao<BusidataTocsalesDetailEntity, String> {
    /**
     * 批量插入底表数据
     */
    void entityInsertBatch(List<BusidataTocsalesDetailEntity> busidataTocsalesDetailEntities) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIaMonthledgerDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIaMonthledgerDao.java
@ -0,0 +1,16 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.IaMonthledgerEntity;
 import com.hzya.frame.basedao.dao.IBaseDao;
 /**
 * (IA_MONTHLEDGER: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-03 11:16:01
 */
 public interface IIaMonthledgerDao extends IBaseDao<IaMonthledgerEntity, String> {
    public String queryNbzyjByPkInvmandoc(String pkInvmandoc);
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIaPeriodaccountDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIaPeriodaccountDao.java
@ -0,0 +1,22 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.IaPeriodaccountEntity;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import java.util.List;
 /**
 * (IA_PERIODACCOUNT: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-10-17 10:06:10
 */
 public interface IIaPeriodaccountDao extends IBaseDao<IaPeriodaccountEntity, String> {
    /**
     * 查询存货对应的结存单价
     *
     * @author liuyang
     */
    List<IaPeriodaccountEntity> queryBalancePrice(IaPeriodaccountEntity iaPeriodaccountEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcGeneralBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcGeneralBDao.java
@ -0,0 +1,23 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.IcGeneralBEntity;
 import java.util.List;
 /**
 * (ic_general_b: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-05 08:36:01
 */
 public interface IIcGeneralBDao extends IBaseDao<IcGeneralBEntity, String> {
    /**
     * 根据cgeneralhid表头主键查询
     */
    public List<IcGeneralBEntity> queryByCgeneralhid(String cgeneralhid);
    public List<IcGeneralBEntity> queryAndCinvbasCode(String cgeneralhid);
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcGeneralBb1Dao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcGeneralBb1Dao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.IcGeneralBb1Entity;
 /**
 * (ic_general_bb1: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-06 09:07:47
 */
 public interface IIcGeneralBb1Dao extends IBaseDao<IcGeneralBb1Entity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcGeneralHDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcGeneralHDao.java
@ -0,0 +1,19 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.IcGeneralHEntity;
 import java.util.List;
 /**
 * (ic_general_h: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 19:00:36
 */
 public interface IIcGeneralHDao extends IBaseDao<IcGeneralHEntity, String> {
    List<IcGeneralHEntity> queryIcGeneralHEntity(IcGeneralHEntity icGeneralHEntity);
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcSpecialBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcSpecialBDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.IcSpecialBEntity;
 /**
 * (ic_special_b: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-05 16:06:39
 */
 public interface IIcSpecialBDao extends IBaseDao<IcSpecialBEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcSpecialHDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIcSpecialHDao.java
@ -0,0 +1,18 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.IcSpecialHEntity;
 import java.util.List;
 /**
 * (ic_special_h: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-05 16:05:30
 */
 public interface IIcSpecialHDao extends IBaseDao<IcSpecialHEntity, String> {
    List<IcSpecialHEntity> queryIcSpecialHEntity(IcSpecialHEntity icSpecialHEntity);
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIntegrationTaskLivingDetailsDaoV2.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IIntegrationTaskLivingDetailsDaoV2.java
@ -0,0 +1,25 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.IntegrationTaskLivingDetailsEntityV2;
 //import com.hzya.frame.sys.integrationtask.living.entity.IntegrationTaskLivingDetailsEntity;
 import java.util.List;
 /**
 * 集成任务-实例详情(integration_task_living_details: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-03-12 11:40:15
 */
 public interface IIntegrationTaskLivingDetailsDaoV2 extends IBaseDao<IntegrationTaskLivingDetailsEntityV2, String> {
    /**
     * 批量插入
     */
 //    void entityInsertBatch(List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities) throws Exception;
    /**
     * 批量更新
     */
 //    void entityInsertOrUpdateBatch(List<IntegrationTaskLivingDetailsEntity> integrationTaskLivingDetailsEntities) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IOnlyAfterSalesBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IOnlyAfterSalesBDao.java
@ -0,0 +1,28 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.OnlyAfterSalesBEntity;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import java.util.List;
 /**
 * 售后订单表_仅退款_子表(only_after_sales_b: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-23 10:43:46
 */
 public interface IOnlyAfterSalesBDao extends IBaseDao<OnlyAfterSalesBEntity, String> {
    /**
     * 批量插入或更新数据行
     *
     * @author liuyang
     */
    void entityInsertOrUpdateBatch(List<OnlyAfterSalesBEntity> onlyAfterSalesHEntityList) throws Exception;
    /**
     * 批量插入或更新,推送状态
     *
     * @author liuyang
     */
    void entityInsertOrUpdateBatchBySuccessOrFail(List<OnlyAfterSalesBEntity> onlyAfterSalesHEntityList) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IOnlyAfterSalesHDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IOnlyAfterSalesHDao.java
@ -0,0 +1,28 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.OnlyAfterSalesHEntity;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import java.util.List;
 /**
 * 售后订单表_仅退款_主表(only_after_sales_h: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-23 10:43:07
 */
 public interface IOnlyAfterSalesHDao extends IBaseDao<OnlyAfterSalesHEntity, String> {
    /**
     * 批量插入或者更新
     *
     * @author liuyang
     */
    void insertOrUpdate(List<OnlyAfterSalesHEntity> onlyAfterSalesHEntityList) throws Exception;
    /**
     * 批量更新成功或失败状态
     *
     * @author liuyang
     */
 //    void entityInsertOrUpdateBatchBySuccessOrFail(List<OnlyAfterSalesHEntity> onlyAfterSalesHEntityList) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IPoOrderBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IPoOrderBDao.java
@ -0,0 +1,21 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.PoOrderBEntity;
 import java.util.List;
 /**
 * (po_order_b: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 08:53:25
 */
 public interface IPoOrderBDao extends IBaseDao<PoOrderBEntity, String> {
    /**
     * 查询存货对应的最新采购价
     *
     * @author liuyang
     */
    List<PoOrderBEntity> queryPurchaseUnitPriceByInvcodes(PoOrderBEntity poOrderBEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IPoOrderDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IPoOrderDao.java
@ -0,0 +1,20 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.PoOrderEntity;
 /**
 * (po_order: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 08:52:02
 */
 public interface IPoOrderDao extends IBaseDao<PoOrderEntity, String> {
    /**
     * 填充原始订单号
     *
     * @throws Exception 抛出可能的异常
     * @author liuyang
     */
    void updateVdef20(PoOrderEntity poOrderEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IScOrderBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IScOrderBDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.ScOrderBEntity;
 import com.hzya.frame.basedao.dao.IBaseDao; 
 /**
 * (SC_ORDER_B: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-08-23 16:02:35
 */
 public interface IScOrderBDao extends IBaseDao<ScOrderBEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IScOrderDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IScOrderDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.ScOrderEntity;
 import com.hzya.frame.basedao.dao.IBaseDao; 
 /**
 * (SC_ORDER: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-08-23 15:29:40
 */
 public interface IScOrderDao extends IBaseDao<ScOrderEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleDao.java
@ -0,0 +1,40 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.SoSaleEntity;
 import com.hzya.frame.plugin.lets.u8cdto.QuantityHandDto;
 import com.hzya.frame.plugin.lets.u8cdto.QuantityHandResultDto;
 import java.util.List;
 /**
 * (so_sale: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-16 15:49:53
 */
 public interface ISoSaleDao extends IBaseDao<SoSaleEntity, String> {
    /**
     * 查询U8C销售订单
     *
     * @author liuyang
     */
    List<SoSaleEntity> querySoSaleEntity(SoSaleEntity soSaleEntity) throws Exception;
    /**
     * 查询现存量(发货库存组织、仓库、公司)
     *
     * @author liuyang
     */
    List<QuantityHandResultDto> queryQuantityHand(QuantityHandDto soSaleEntity) throws Exception;
    /**
     * 查询现存量(发货库存组织、仓库、公司、货位)
     *
     * @author liuyang
     */
    List<QuantityHandResultDto> queryQuantityHandV2(QuantityHandDto soSaleEntity) throws Exception;
    void updateSoSale(SoSaleEntity soSaleEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleinvoiceBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleinvoiceBDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.SoSaleinvoiceBEntity;
 import com.hzya.frame.basedao.dao.IBaseDao; 
 /**
 * (SO_SALEINVOICE_B: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-08-31 14:44:18
 */
 public interface ISoSaleinvoiceBDao extends IBaseDao<SoSaleinvoiceBEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleinvoiceDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleinvoiceDao.java
@ -0,0 +1,23 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.plugin.lets.entity.SoSaleinvoiceEntity;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import java.util.List;
 /**
 * (SO_SALEINVOICE: table)表数据库访问层
 *
 * @author makejava
 * @since 2024-08-31 14:43:53
 */
 public interface ISoSaleinvoiceDao extends IBaseDao<SoSaleinvoiceEntity, String> {
    /**
     * 查询需要删除的数据
     *
     * @author liuyang
     */
 //    List<SoSaleinvoiceEntity> querySoSaleinvoiceByDelete(SoSaleinvoiceEntity soSaleinvoiceEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleorderBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/ISoSaleorderBDao.java
@ -0,0 +1,30 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.SoSaleorderBEntity;
 import com.hzya.frame.plugin.lets.queryvo.ExtIntegrationTaskLivingDetailsQueryVo;
 import java.util.List;
 /**
 * (so_saleorder_b: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-16 18:03:07
 */
 public interface ISoSaleorderBDao extends IBaseDao<SoSaleorderBEntity, String> {
    /**
     * 查询U8C销售订单
     *
     * @author liuyang
     */
    List<SoSaleorderBEntity> querySoSaleBEntity(SoSaleorderBEntity soSaleorderBEntity) throws Exception;
    /**
     * 查询U8C TOC分销的销售订单
     *
     * @author liuyang
     */
    List<ExtIntegrationTaskLivingDetailsQueryVo> queryErrorDetailsId(SoSaleorderBEntity soSaleorderBEntity) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IToBillBDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IToBillBDao.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.ToBillBEntity;
 /**
 * (to_bill_b: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-11-21 10:42:21
 */
 public interface IToBillBDao extends IBaseDao<ToBillBEntity, String> {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IToBillDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IToBillDao.java
@ -0,0 +1,19 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.ToBillEntity;
 import java.util.List;
 /**
 * (to_bill: table)表数据库访问层
 *
 * @author makejava
 * @since 2023-11-21 10:41:18
 */
 public interface IToBillDao extends IBaseDao<ToBillEntity, String> {
    List<ToBillEntity> queryToBillEntity(ToBillEntity toBillEntity);
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IUpdateLogisticsNoDao.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/IUpdateLogisticsNoDao.java
@ -0,0 +1,30 @@
 package com.hzya.frame.plugin.lets.dao;
 import com.hzya.frame.basedao.dao.IBaseDao;
 import com.hzya.frame.plugin.lets.entity.UpdateLogisticsNoEntity;
 /**
 * 更新OA物流单号
 *
 * @Author：liuyang
 * @Package：com.hzya.frame.plugin.lets.dao
 * @Project：kangarooDataCenter
 * @name：IUpdateLogisticsNoDao
 * @Date：2023/11/27 10:59
 * @Filename：IUpdateLogisticsNoDao
 */
 public interface IUpdateLogisticsNoDao extends IBaseDao<UpdateLogisticsNoEntity, String> {
    /**
     * 正向：更新物流单号
     *
     * @throws Exception 抛出可能的异常
     */
    void updateLogisticsNo(UpdateLogisticsNoEntity updateLogisticsNo) throws Exception;
    /**
     * 反向：更新物流单号
     *
     * @throws Exception 抛出可能的异常
     */
    void updateLogisticsNoReturn(UpdateLogisticsNoEntity updateLogisticsNo) throws Exception;
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/ArapDjzbDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/ArapDjzbDaoImpl.java
@ -0,0 +1,16 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.plugin.lets.entity.ArapDjzbEntity;
 import com.hzya.frame.plugin.lets.dao.IArapDjzbDao;
 import org.springframework.stereotype.Repository;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 /**
 * (ArapDjzb)表数据库访问层
 *
 * @author makejava
 * @since 2024-11-21 11:26:53
 */
 public class ArapDjzbDaoImpl extends MybatisGenericDao<ArapDjzbEntity, String> implements IArapDjzbDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBankaccbasDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBankaccbasDaoImpl.java
@ -0,0 +1,16 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdBankaccbasDao;
 import com.hzya.frame.plugin.lets.entity.BdBankaccbasEntity;
 /**
 * (BdBankaccbas)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-30 15:53:06
 */
 public class BdBankaccbasDaoImpl extends MybatisGenericDao<BdBankaccbasEntity, String> implements IBdBankaccbasDao {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBankdocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBankdocDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdBankdocDao;
 import com.hzya.frame.plugin.lets.entity.BdBankdocEntity;
 /**
 * (BdBankdoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-30 16:16:01
 */
 public class BdBankdocDaoImpl extends MybatisGenericDao<BdBankdocEntity, String> implements IBdBankdocDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBomDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBomDaoImpl.java
@ -0,0 +1,22 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.plugin.lets.entity.BdBomEntity;
 import com.hzya.frame.plugin.lets.dao.IBdBomDao;
 import org.springframework.stereotype.Repository;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import java.util.List;
 /**
 * (BdBom)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-02 14:56:24
 */
 public class BdBomDaoImpl extends MybatisGenericDao<BdBomEntity, String> implements IBdBomDao {
    @Override
    public List<BdBomEntity> queryBomVersion(BdBomEntity bdBomEntity) throws Exception {
        return query("com.hzya.frame.plugin.lets.dao.impl.BdBomDaoImpl.queryBomVersion", bdBomEntity);
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBusitypeDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdBusitypeDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdBusitypeDao;
 import com.hzya.frame.plugin.lets.entity.BdBusitypeEntity;
 /**
 * (BdBusitype)表数据库访问层
 *
 * @author makejava
 * @since 2023-11-21 10:57:24
 */
 public class BdBusitypeDaoImpl extends MybatisGenericDao<BdBusitypeEntity, String> implements IBdBusitypeDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCalbodyDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCalbodyDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdCalbodyDao;
 import com.hzya.frame.plugin.lets.entity.BdCalbodyEntity;
 /**
 * (BdCalbody)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-06 17:31:07
 */
 public class BdCalbodyDaoImpl extends MybatisGenericDao<BdCalbodyEntity, String> implements IBdCalbodyDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCargdocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCargdocDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdCargdocDao;
 import com.hzya.frame.plugin.lets.entity.BdCargdocEntity;
 /**
 * (BdCargdoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-07 09:05:12
 */
 public class BdCargdocDaoImpl extends MybatisGenericDao<BdCargdocEntity, String> implements IBdCargdocDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCorpDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCorpDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdCorpDao;
 import com.hzya.frame.plugin.lets.entity.BdCorpEntity;
 /**
 * (BdCorp)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-06 14:47:17
 */
 public class BdCorpDaoImpl extends MybatisGenericDao<BdCorpEntity, String> implements IBdCorpDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCostsubjDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCostsubjDaoImpl.java
@ -0,0 +1,16 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.plugin.lets.entity.BdCostsubjEntity;
 import com.hzya.frame.plugin.lets.dao.IBdCostsubjDao;
 import org.springframework.stereotype.Repository;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 /**
 * (BdCostsubj)表数据库访问层
 *
 * @author makejava
 * @since 2024-09-20 13:39:58
 */
 public class BdCostsubjDaoImpl extends MybatisGenericDao<BdCostsubjEntity, String> implements IBdCostsubjDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCubasdocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCubasdocDaoImpl.java
@ -0,0 +1,35 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import cn.hutool.core.lang.Assert;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdCubasdocDao;
 import com.hzya.frame.plugin.lets.entity.BdCubasdocEntity;
 /**
 * (BdCubasdoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 09:41:41
 */
 //@Repository("BdCubasdocDaoImpl")
 public class BdCubasdocDaoImpl extends MybatisGenericDao<BdCubasdocEntity, String> implements IBdCubasdocDao {
    @DS("sowow_sqlserver_test")
    @Override
    public BdCubasdocEntity queryBdCumandocEntity(BdCubasdocEntity bdCumandocEntity) throws Exception {
        Assert.notNull(bdCumandocEntity, "BdCumandocEntity不可为空！");
        Assert.notNull(bdCumandocEntity.getPk_cumandoc(), "供应商管理id不能为空！");
        Assert.notNull(bdCumandocEntity.getPkCorp(), "公司id不能为空!");
 //        Assert.notNull(bdCumandocEntity.getCustflag(), "客商属性不能为空!");
        return query(bdCumandocEntity, "com.hzya.frame.plugin.lets.dao.impl.BdCubasdocDaoImpl.queryBdCumandocByPkCumandoc");
    }
    @DS("sowow_sqlserver_test")
    @Override
    public String selectUserNameByPk(String cuserid) {
        return (String) selectOne("com.hzya.frame.plugin.lets.dao.impl.BdCubasdocDaoImpl.selectUserNameByPk",cuserid);
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCumandocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCumandocDaoImpl.java
@ -0,0 +1,16 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdCumandocDao;
 import com.hzya.frame.plugin.lets.entity.BdCumandocEntity;
 /**
 * (BdCumandoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 09:42:24
 */
 //@Repository("BdCumandocDaoImpl")
 public class BdCumandocDaoImpl extends MybatisGenericDao<BdCumandocEntity, String> implements IBdCumandocDao {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCustbankDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdCustbankDaoImpl.java
@ -0,0 +1,16 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdCustbankDao;
 import com.hzya.frame.plugin.lets.entity.BdCustbankEntity;
 /**
 * (BdCustbank)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-30 09:37:43
 */
 public class BdCustbankDaoImpl extends MybatisGenericDao<BdCustbankEntity, String> implements IBdCustbankDao {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdDefdocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdDefdocDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdDefdocDao;
 import com.hzya.frame.plugin.lets.entity.BdDefdocEntity;
 /**
 * (BdDefdoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 13:46:53
 */
 public class BdDefdocDaoImpl extends MybatisGenericDao<BdDefdocEntity, String> implements IBdDefdocDao {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdDefdoclistDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdDefdoclistDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdDefdoclistDao;
 import com.hzya.frame.plugin.lets.entity.BdDefdoclistEntity;
 /**
 * (BdDefdoclist)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 13:49:47
 */
 public class BdDefdoclistDaoImpl extends MybatisGenericDao<BdDefdoclistEntity, String> implements IBdDefdoclistDao {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdDeptdocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdDeptdocDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdDeptdocDao;
 import com.hzya.frame.plugin.lets.entity.BdDeptdocEntity;
 /**
 * (BdDeptdoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-13 11:37:15
 */
 public class BdDeptdocDaoImpl extends MybatisGenericDao<BdDeptdocEntity, String> implements IBdDeptdocDao {
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdInvbasdocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdInvbasdocDaoImpl.java
@ -0,0 +1,48 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import cn.hutool.core.lang.Assert;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdInvbasdocDao;
 import com.hzya.frame.plugin.lets.entity.BdInvbasdocEntity;
 import java.util.List;
 /**
 * (BdInvbasdoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 11:27:08
 */
 //@Repository("BdInvbasdocDaoImpl")
 public class BdInvbasdocDaoImpl extends MybatisGenericDao<BdInvbasdocEntity, String> implements IBdInvbasdocDao {
    @DS("lets_u8c")
    @Override
    public BdInvbasdocEntity queryBdInvbasdocByPkInvmandoc(BdInvbasdocEntity bdInvbasdocEntity) throws Exception {
        Assert.notNull(bdInvbasdocEntity, "BdInvmandocEntity不可为空！");
        Assert.notNull(bdInvbasdocEntity.getPk_invmandoc(), "pkInvmandoc不可为空！");
 //        Assert.notNull(bdInvbasdocEntity.getPk_corp(), "存货管理档案公司主键不能为空");
        return query(bdInvbasdocEntity, "com.hzya.frame.plugin.lets.dao.impl.BdInvbasdocDaoImpl.queryBdInvbasdocByPkInvmandoc");
    }
    @DS("lets_u8c")
    @Override
    public List<BdInvbasdocEntity> queryBdInvbasdocByPkInvmandocV2(BdInvbasdocEntity bdInvbasdocEntity) throws Exception {
        Assert.notNull(bdInvbasdocEntity, "BdInvmandocEntity不可为空！");
 //        Assert.notNull(bdInvbasdocEntity.getPk_invmandoc(), "pkInvmandoc不可为空！");
 //        Assert.notNull(bdInvbasdocEntity.getPk_corp(), "存货管理档案公司主键不能为空");
        List<BdInvbasdocEntity> bdInvbasdocEntities = queryList(bdInvbasdocEntity, "com.hzya.frame.plugin.lets.dao.impl.BdInvbasdocDaoImpl.queryBdInvbasdocByPkInvmandoc");
        return bdInvbasdocEntities;
    }
    @DS("lets_u8c")
    @Override
    public List<BdInvbasdocEntity> queryBdInvbasdocByPkInvmandocV3(BdInvbasdocEntity bdInvbasdocEntity) throws Exception {
        Assert.notNull(bdInvbasdocEntity, "bdInvbasdocEntity不能为空！");
        Assert.notNull(bdInvbasdocEntity.getInvcodes(), "invcodes不能为空");
        return queryList(bdInvbasdocEntity, "com.hzya.frame.plugin.lets.dao.impl.BdInvbasdocDaoImpl.queryBdInvbasdocByInvcodes");
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdInvclDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdInvclDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdInvclDao;
 import com.hzya.frame.plugin.lets.entity.BdInvclEntity;
 /**
 * (BdInvcl)表数据库访问层
 *
 * @author makejava
 * @since 2024-01-09 15:08:19
 */
 public class BdInvclDaoImpl extends MybatisGenericDao<BdInvclEntity, String> implements IBdInvclDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdInvmandocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdInvmandocDaoImpl.java
@ -0,0 +1,39 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import cn.hutool.core.lang.Assert;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdInvmandocDao;
 import com.hzya.frame.plugin.lets.entity.BdInvmandocEntity;
 import java.util.List;
 /**
 * (BdInvmandoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-08-25 11:21:44
 */
 //@Repository("BdInvmandocDaoImpl")
 public class BdInvmandocDaoImpl extends MybatisGenericDao<BdInvmandocEntity, String> implements IBdInvmandocDao {
    @DS("lets_u8c")
    @Override
    public BdInvmandocEntity queryBdInvmandocByInvcode(BdInvmandocEntity bdInvmandocEntity) throws Exception {
        Assert.notNull(bdInvmandocEntity, "bdInvmandocEntity must not be null");
 //        Assert.notNull(bdInvmandocEntity.getInvcode(), "存货档案编码不能为空");
 //        Assert.notNull(bdInvmandocEntity.getPkCorp(), "存货档案所属企业id不能为空");
        List<BdInvmandocEntity> bdInvmandocEntityList = query("com.hzya.frame.plugin.lets.dao.impl.BdInvmandocDaoImpl.queryBdInvmandocByInvcode", bdInvmandocEntity);
        if (bdInvmandocEntityList != null && bdInvmandocEntityList.size() > 0) {
            return bdInvmandocEntityList.get(0);
        }
        return null;
    }
    @DS("lets_u8c")
    @Override
    public List<BdInvmandocEntity> queryBdInvmandocByInvcodeList(BdInvmandocEntity bdInvmandocEntity) throws Exception {
        Assert.notNull(bdInvmandocEntity, "bdInvmandocEntity must not be null!");
        return query("com.hzya.frame.plugin.lets.dao.impl.BdInvmandocDaoImpl.queryBdInvmandocByInvcode", bdInvmandocEntity);
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdJobbasfilDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdJobbasfilDaoImpl.java
@ -0,0 +1,25 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdJobbasfilDao;
 import com.hzya.frame.plugin.lets.entity.BdJobbasfilEntity;
 import com.hzya.frame.plugin.lets.queryvo.ExtBdJobbasfilQueryVo;
 import com.hzya.frame.plugin.lets.resultvo.ExtBdJobbasfilResultVo;
 import java.util.List;
 /**
 * (BdJobbasfil)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 14:46:18
 */
 public class BdJobbasfilDaoImpl extends MybatisGenericDao<BdJobbasfilEntity, String> implements IBdJobbasfilDao {
    @DS("sowow_sqlserver_test")
    @Override
    public List<ExtBdJobbasfilResultVo> queryProjectBasicArchivesByTypeDIY(ExtBdJobbasfilQueryVo extBdJobbasfilQueryVo) throws Exception {
        return (List<ExtBdJobbasfilResultVo>) selectList("com.hzya.frame.plugin.lets.dao.impl.BdJobbasfilDaoImpl.queryProjectBasicArchivesByTypeDIY", extBdJobbasfilQueryVo);
    }
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdJobmngfilDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdJobmngfilDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdJobmngfilDao;
 import com.hzya.frame.plugin.lets.entity.BdJobmngfilEntity;
 /**
 * (BdJobmngfil)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 14:48:35
 */
 public class BdJobmngfilDaoImpl extends MybatisGenericDao<BdJobmngfilEntity, String> implements IBdJobmngfilDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdJobtypeDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdJobtypeDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdJobtypeDao;
 import com.hzya.frame.plugin.lets.entity.BdJobtypeEntity;
 /**
 * (BdJobtype)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-04 14:55:03
 */
 public class BdJobtypeDaoImpl extends MybatisGenericDao<BdJobtypeEntity, String> implements IBdJobtypeDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdPsndocDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdPsndocDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdPsndocDao;
 import com.hzya.frame.plugin.lets.entity.BdPsndocEntity;
 /**
 * (BdPsndoc)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-09 15:18:18
 */
 public class BdPsndocDaoImpl extends MybatisGenericDao<BdPsndocEntity, String> implements IBdPsndocDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdPurorgDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdPurorgDaoImpl.java
@ -0,0 +1,16 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.plugin.lets.entity.BdPurorgEntity;
 import com.hzya.frame.plugin.lets.dao.IBdPurorgDao;
 import org.springframework.stereotype.Repository;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 /**
 * (BdPurorg)表数据库访问层
 *
 * @author makejava
 * @since 2024-08-20 14:20:11
 */
 public class BdPurorgDaoImpl extends MybatisGenericDao<BdPurorgEntity, String> implements IBdPurorgDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdRdclDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdRdclDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdRdclDao;
 import com.hzya.frame.plugin.lets.entity.BdRdclEntity;
 /**
 * (BdRdcl)表数据库访问层
 *
 * @author makejava
 * @since 2023-12-04 13:49:10
 */
 public class BdRdclDaoImpl extends MybatisGenericDao<BdRdclEntity, String> implements IBdRdclDao{
 }
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdSalestruDaoImpl.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/dao/impl/BdSalestruDaoImpl.java
@ -0,0 +1,15 @@
 package com.hzya.frame.plugin.lets.dao.impl;
 import com.hzya.frame.basedao.dao.MybatisGenericDao;
 import com.hzya.frame.plugin.lets.dao.IBdSalestruDao;
 import com.hzya.frame.plugin.lets.entity.BdSalestruEntity;
 /**
 * (BdSalestru)表数据库访问层
 *
 * @author makejava
 * @since 2023-09-06 18:20:57
 */
 public class BdSalestruDaoImpl extends MybatisGenericDao<BdSalestruEntity, String> implements IBdSalestruDao{
 }
--- a/Show More
+++ b/Show More