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

- 新增 queryIcGeneralHByCancelSignatureV2 和 querySoSaleByDeletev2 方法
- 实现销售出库单和销售订单的批量取消签字和删除
-优化数据处理逻辑，按日期和单位分组进行批量操作
- 添加定时任务，每10秒重新执行删除操作

.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/

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>

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
  **/

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

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

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

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>
-

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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