HeatingPaymentsInvoker/yjBusiness/src/main/java/com/yinjie/heating/business/dao/DocDao.java

package com.yinjie.heating.business.dao;

import com.yinjie.heating.common.entity.doc.BusinessScript;
import com.yinjie.heating.common.entity.inquire.InquireCondition;
import com.yinjie.heating.common.entity.inquire.InquireMainInfo;
import com.yinjie.heating.common.entity.inquire.InquireResultColumn;
import com.yinjie.heating.common.entity.system.CompanyInfo;
import com.dySweetFishPlugin.sql.dao.*;
import com.sweetfish.source.PageFlipper;
import org.rex.RMap;

import java.util.List;

@SuppressWarnings({"rawtypes", "unused"})
public interface DocDao extends DaoRepository {


    //region 业务脚本

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.QUERY, owait = OperatorWait.AWAIT)
    @SqlId(clazz = DocDao.class, sql = "selectBusinessScript", table = "tbBusinessScript", params = {1})
    List<BusinessScript> selectBusinessScript(RMap params, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode,
                                              PageFlipper pageFlipper);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "addBusinessScript", table = "tbBusinessScript", params = {1})
    void addBusinessScript(BusinessScript businessScript, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "updateBusinessScript", table = "tbBusinessScript", params = {1})
    void updateBusinessScript(BusinessScript businessScript, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "voidBusinessScript", table = "tbBusinessScript", params = {1})
    void voidBusinessScript(BusinessScript businessScript, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    //endregion


    //region 查询统计
    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.QUERY, owait = OperatorWait.AWAIT)
    @SqlId(clazz = DocDao.class, sql = "selectInquireMainInfo", table = "eiInquireMainInfo", params = {1})
    List<InquireMainInfo> selectInquireMainInfo(RMap params, PageFlipper pageFlipper, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "addInquireMainInfo", table = "eiInquireMainInfo", params = {1}, sort = 1)
    @SqlId(clazz = DocDao.class, sql = "addInquireResultColumn", table = "eiInquireResultColumn", params = {2}, sort = 2)
    @SqlId(clazz = DocDao.class, sql = "addInquireCondition", table = "eiInquireCondition", params = {3}, sort = 3)
    void addInquireMainInfo(InquireMainInfo inquireMainInfo, List<InquireResultColumn> columnList,
                           List<InquireCondition> conditionList, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "updateInquireMainInfo", table = "eiInquireMainInfo", params = {1}, sort = 1)
    @SqlId(clazz = DocDao.class, sql = "deleteInquireResultColumnByMain", table = "eiInquireResultColumn", params = {1}, sort = 2)
    @SqlId(clazz = DocDao.class, sql = "deleteInquireConditionByMain", table = "eiInquireCondition", params = {1}, sort = 3)
    @SqlId(clazz = DocDao.class, sql = "addInquireResultColumn", table = "eiInquireResultColumn", params = {2}, sort = 4)
    @SqlId(clazz = DocDao.class, sql = "addInquireCondition", table = "eiInquireCondition", params = {3}, sort = 5)
    void updateInquireMainInfo(InquireMainInfo inquireMainInfo, List<InquireResultColumn> columnList,
                              List<InquireCondition> conditionList, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "voidInquireMainInfo", table = "eiInquireMainInfo", params = {1})
    void voidInquireMainInfo(InquireMainInfo inquireMainInfo, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);


    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.QUERY, owait = OperatorWait.AWAIT)
    @SqlId(clazz = DocDao.class, sql = "selectInquireResultColumn", table = "eiInquireResultColumn", params = {1})
    List<InquireResultColumn> selectInquireResultColumn(RMap params, PageFlipper pageFlipper, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "addInquireResultColumn", table = "eiInquireResultColumn", params = {1})
    int addInquireResultColumn(InquireResultColumn inquireResultColumn, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "updateInquireResultColumn", table = "eiInquireResultColumn", params = {1})
    int updateInquireResultColumn(InquireResultColumn inquireResultColumn, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "deleteInquireResultColumn", table = "eiInquireResultColumn", params = {1})
    int deleteInquireResultColumn(InquireResultColumn inquireResultColumn, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);


    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.QUERY, owait = OperatorWait.AWAIT)
    @SqlId(clazz = DocDao.class, sql = "selectInquireCondition", table = "eiInquireCondition", params = {1})
    List<InquireCondition> selectInquireCondition(RMap params, PageFlipper pageFlipper, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "addInquireCondition", table = "eiInquireCondition", params = {1})
    int addInquireCondition(InquireCondition inquireCondition, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "updateInquireCondition", table = "eiInquireCondition", params = {1})
    int updateInquireCondition(InquireCondition inquireCondition, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "deleteInquireCondition", table = "eiInquireCondition", params = {1})
    int deleteInquireCondition(InquireCondition inquireCondition, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);
    //endregion

    //region分厂档案
    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.QUERY, owait = OperatorWait.AWAIT)
    @SqlId(clazz = DocDao.class, sql = "selectCompanyInfo", table = "tbCompanyInfo", params = {1})
    List<CompanyInfo> selectCompanyInfo(RMap params, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode, PageFlipper pageFlipper);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "addCompanyInfo", table = "tbCompanyInfo", params = {1})
    int addCompanyInfo(CompanyInfo companyInfo, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "updateCompanyInfo", table = "tbCompanyInfo", params = {1})
    int updateCompanyInfo(CompanyInfo companyInfo, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);

    @Sharding(databaseShardingStrategy = SupplierDataBaseShardingStrategy.class, tableShardingStrategy = SupplierTableShardingStrategy.class)
    @DAOMethod(operator = OperatorType.UPDATE, owait = OperatorWait.ASNYC)
    @SqlId(clazz = DocDao.class, sql = "voidCompanyInfo", table = "tbCompanyInfo", params = {1})
    int voidCompanyInfo(CompanyInfo companyInfo, @DatabaseShardingBy String dataSourceId, @TableShardingBy Long supplierCode);
    //endregion
}