Commit a1ec79b6 by 王德峰

bb 项目初始化

    清理部分
    清理wk任务
parent e49fc361
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.DataForCheck;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AbsDataCheckDOMapper;
/**
* The Table ABS_DATA_CHECK.
* 账户
*/
@Repository
public class AbsDataCheckDAO{
@Autowired
private AbsDataCheckDOMapper absDataCheckDOMapper;
/**
* desc:getDataForCheck.<br/>
* @param acctDate acctDate
* @param planNos planNos
* @return List<DataForCheck>
*/
public List<DataForCheck> getDataForCheck(Date acctDate,List<String> planNos){
if(planNos!=null && planNos.size()>201){throw new RuntimeException("planNos 超出201长度限制");}
return absDataCheckDOMapper.getDataForCheck(acctDate, planNos);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AbsSequenceDOMapper;
/**
* The Table ABS_SEQUENCE.
* ABS_SEQUENCE
*/
@Repository
public class AbsSequenceDAO{
@Autowired
private AbsSequenceDOMapper absSequenceDOMapper;
/**
* desc:ABS_SEQUENCE.<br/>
* @return Long
*/
public Long getSeqText(){
return absSequenceDOMapper.getSeqText();
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AccountDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AccountDOMapper;
/**
* The Table abs_account.
* 账户
*/
@Repository
public class AccountDAO{
@Autowired
private AccountDOMapper accountDOMapper;
/**
* desc:插入表:abs_account.<br/>
* @param entity entity
* @return int
*/
public int insert(AccountDO entity){
return accountDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_account.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<AccountDO> list){
accountDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键删除数据:abs_account.<br/>
* @param id id
* @return int
*/
public int deleteById(Long id){
return accountDOMapper.deleteById(id);
}
/**
* desc:根据主键获取数据:abs_account.<br/>
* @param id id
* @return AccountDO
*/
public AccountDO getById(Long id){
return accountDOMapper.getById(id);
}
/**
* desc:getByAccountNo.<br/>
* @param actNo actNo
* @return AccountDO
*/
public AccountDO getByAccountNo(String actNo){
return accountDOMapper.getByAccountNo(actNo);
}
/**
* desc:根据EntityCode删除数据:abs_account.<br/>
* @param actType actType
* @param entityCode entityCode
* @return int
*/
public int deleteByEntityCodeAndActType(String actType,String entityCode){
return accountDOMapper.deleteByEntityCodeAndActType(actType, entityCode);
}
/**
* desc:根据机构实体获取账号.<br/>
* @param actAttr actAttr
* @param entityCode entityCode
* @param list list
* @return List<AccountDO>
*/
public List<AccountDO> selectByEntityCodeAndActType(String actAttr,String entityCode,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return accountDOMapper.selectByEntityCodeAndActType(actAttr, entityCode, list);
}
/**
* desc:根据机构实体获取账号.<br/>
* @param actType actType
* @param entityCode entityCode
* @return List<AccountDO>
*/
public List<AccountDO> selectByEntityCodeAndType(String actType,String entityCode){
return accountDOMapper.selectByEntityCodeAndType(actType, entityCode);
}
/**
* desc:根据机构编号删除账号.<br/>
* @param entityCode entityCode
* @return int
*/
public int deleteByEntityCode(String entityCode){
return accountDOMapper.deleteByEntityCode(entityCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AcctDateDO;
import java.util.Date;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AcctDateDOMapper;
/**
* The Table abs_acct_date.
* ABS_ACCT_DATE
*/
@Repository
public class AcctDateDAO{
@Autowired
private AcctDateDOMapper acctDateDOMapper;
/**
* desc:插入表:abs_acct_date.<br/>
* @param entity entity
* @return int
*/
public int insert(AcctDateDO entity){
return acctDateDOMapper.insert(entity);
}
/**
* desc:更新表:abs_acct_date.<br/>
* @param acctDate acctDate
* @param orgCode orgCode
* @return int
*/
public int update(Date acctDate,String orgCode){
return acctDateDOMapper.update(acctDate, orgCode);
}
/**
* desc:根据主键获取数据:abs_acct_date.<br/>
* @param orgCode orgCode
* @return AcctDateDO
*/
public AcctDateDO getDate(String orgCode){
return acctDateDOMapper.getDate(orgCode);
}
/**
* desc:查询所有机构的会计日.<br/>
* @return List<AcctDateDO>
*/
public List<AcctDateDO> queryAcctDate(){
return acctDateDOMapper.queryAcctDate();
}
/**
* desc:根据机构编码锁会计日.<br/>
* @param orgCode orgCode
* @return AcctDateDO
*/
public AcctDateDO getForLock(String orgCode){
return acctDateDOMapper.getForLock(orgCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.ActGeBytearrayDO;
import com.abssqr.plat.common.dal.mysql.auto.mapper.ActGeBytearrayDOMapper;
/**
* The Table act_ge_bytearray.
* ACT_GE_BYTEARRAY
*/
@Repository
public class ActGeBytearrayDAO{
@Autowired
private ActGeBytearrayDOMapper actGeBytearrayDOMapper;
/**
* desc:插入表:act_ge_bytearray.<br/>
* @param entity entity
* @return int
*/
public int insert(ActGeBytearrayDO entity){
return actGeBytearrayDOMapper.insert(entity);
}
/**
* desc:更新表:act_ge_bytearray.<br/>
* @param entity entity
* @return int
*/
public int update(ActGeBytearrayDO entity){
return actGeBytearrayDOMapper.update(entity);
}
/**
* desc:根据主键删除数据:act_ge_bytearray.<br/>
* @param id id
* @return int
*/
public int deleteById(String id){
return actGeBytearrayDOMapper.deleteById(id);
}
/**
* desc:根据主键获取数据:act_ge_bytearray.<br/>
* @param id id
* @return ActGeBytearrayDO
*/
public ActGeBytearrayDO getById(String id){
return actGeBytearrayDOMapper.getById(id);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AstPackDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.paging.ActivePackPage;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AstPackDOMapper;
/**
* The Table ABS_AST_PACK.
* 资产包
*/
@Repository
public class AstPackDAO{
@Autowired
private AstPackDOMapper astPackDOMapper;
/**
* desc:插入表:ABS_AST_PACK.<br/>
* @param entity entity
* @return int
*/
public int insert(AstPackDO entity){
return astPackDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_account.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<AstPackDO> list){
astPackDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据状态获取包.<br/>
* @param scenDate scenDate
* @param packType packType
* @param packStatus packStatus
* @return List<AstPackDO>
*/
public List<AstPackDO> selectPackByStatus(Date scenDate,String packType,String packStatus){
return astPackDOMapper.selectPackByStatus(scenDate, packType, packStatus);
}
/**
* desc:根据packCode获取数据:ABS_AST_PACK.<br/>
* @param packCode packCode
* @return AstPackDO
*/
@Deprecated
public AstPackDO getByPackCode(String packCode){
return astPackDOMapper.getByPackCode(packCode);
}
/**
* desc:根据普通索引AbsTrCtrTask0获取数据:abs_tr_ctr_task.<br/>
* @param scenDate scenDate
* @param status status
* @param packType packType
* @param managerOrgCode managerOrgCode
* @return List<AstPackDO>
*/
public List<AstPackDO> getByManagerOrg(Date scenDate,String status,String packType,String managerOrgCode){
return astPackDOMapper.getByManagerOrg(scenDate, status, packType, managerOrgCode);
}
/**
* desc:更新表:ABS_AST_PACK.<br/>
* @param packStatus packStatus
* @param oldPackStatus oldPackStatus
* @param packCodes packCodes
* @return int
*/
public int updatePackStatus(String packStatus,String oldPackStatus,List<String> packCodes){
if(packCodes!=null && packCodes.size()>201){throw new RuntimeException("packCodes 超出201长度限制");}
return astPackDOMapper.updatePackStatus(packStatus, oldPackStatus, packCodes);
}
/**
* desc:根据packCode获取数据:ABS_AST_PACK.<br/>
* @param planNo planNo
* @param packType packType
* @return List<AstPackDO>
*/
public List<AstPackDO> getByPlanNo(String planNo,String packType){
return astPackDOMapper.getByPlanNo(planNo, packType);
}
/**
* desc:根据packCode获取数据:ABS_AST_PACK.<br/>
* @param scenDate scenDate
* @param planNo planNo
* @param packType packType
* @return AstPackDO
*/
public AstPackDO getLastDayPackByPlanNo(Date scenDate,String planNo,String packType){
return astPackDOMapper.getLastDayPackByPlanNo(scenDate, planNo, packType);
}
/**
* desc:根据packCode获取数据:ABS_AST_PACK.<br/>
* @param activePack activePack
* @return ActivePackPage
*/
@Deprecated
public ActivePackPage queryByActivePacks(ActivePackPage activePack){
int total = astPackDOMapper.queryByActivePacksCount(activePack);
if(total>0){
activePack.setDatas(astPackDOMapper.queryByActivePacksResult(activePack));
}else{
activePack.setDatas(new ArrayList());
}
activePack.setTotal(total);
return activePack;
}
/**
* desc:获取指定状态的资产包数量.<br/>
* @param time time
* @param status status
* @param packType packType
* @return Long
*/
public Long countByStatusAndTime(Date time,String status,String packType){
return astPackDOMapper.countByStatusAndTime(time, status, packType);
}
/**
* desc:锁资产包.<br/>
* @param packCode packCode
* @return AstPackDO
*/
public AstPackDO lockByPackCode(String packCode){
return astPackDOMapper.lockByPackCode(packCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AstPoolDO;
import com.abssqr.plat.common.dal.mysql.auto.paging.PactsAstMatchPage;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.AstPoolItem;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AstPoolDOMapper;
/**
* The Table ABS_AST_POOL.
* 一月的资产池
*/
@Repository
public class AstPoolDAO{
@Autowired
private AstPoolDOMapper astPoolDOMapper;
/**
* desc:插入表:ABS_AST_POOL_JAN.<br/>
* @param entity entity
* @return int
*/
public int insert(AstPoolDO entity){
return astPoolDOMapper.insert(entity);
}
/**
* desc:根据主键删除数据:ABS_AST_POOL_JAN.<br/>
* @param astNo astNo
* @param termNo termNo
* @return int
*/
public int updateSlice(String astNo,Integer termNo){
return astPoolDOMapper.updateSlice(astNo, termNo);
}
/**
* desc:根据主键删除数据:ABS_AST_POOL_JAN.<br/>
* @param astNo astNo
* @param termNo termNo
* @return int
*/
public int deleteByPk(String astNo,Integer termNo){
return astPoolDOMapper.deleteByPk(astNo, termNo);
}
/**
* desc:更新是否一切片.<br/>
* @param astNo astNo
* @param slice slice
* @param termNo termNo
* @return int
*/
public int updateSliceByPk(String astNo,Boolean slice,Integer termNo){
return astPoolDOMapper.updateSliceByPk(astNo, slice, termNo);
}
/**
* desc:资产筛选分页.<br/>
* @param pactsAstMatch pactsAstMatch
* @return PactsAstMatchPage
*/
public PactsAstMatchPage queryForAstMatch(PactsAstMatchPage pactsAstMatch){
int total = astPoolDOMapper.queryForAstMatchCount(pactsAstMatch);
if(total>0){
pactsAstMatch.setDatas(astPoolDOMapper.queryForAstMatchResult(pactsAstMatch));
}else{
pactsAstMatch.setDatas(new ArrayList());
}
pactsAstMatch.setTotal(total);
return pactsAstMatch;
}
/**
* desc:资产筛选分页.<br/>
* @param sysDate sysDate
* @param astNo astNo
* @return List<AstPoolItem>
*/
public List<AstPoolItem> getAstPoolItems(Date sysDate,String astNo){
return astPoolDOMapper.getAstPoolItems(sysDate, astNo);
}
/**
* desc:获取资产池资产.<br/>
* @param astNo astNo
* @param ownOrg ownOrg
* @return AstPoolDO
*/
public AstPoolDO getAstPoolItem(String astNo,String ownOrg){
return astPoolDOMapper.getAstPoolItem(astNo, ownOrg);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AstPriceRuleDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AstPriceRuleDOMapper;
/**
* The Table abs_ast_price_rule.
* ABS_AST_PRICE_RULE
*/
@Repository
public class AstPriceRuleDAO{
@Autowired
private AstPriceRuleDOMapper astPriceRuleDOMapper;
/**
* desc:批量插入表:abs_ast_price_rule.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<AstPriceRuleDO> list){
astPriceRuleDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:删除产品对应定价规则.<br/>
* @param abssqrProdCode abssqrProdCode
* @return int
*/
public int deleteByAbsProdCode(String abssqrProdCode){
return astPriceRuleDOMapper.deleteByAbsProdCode(abssqrProdCode);
}
/**
* desc:根据产品查询定价规则.<br/>
* @param abssqrProdCode abssqrProdCode
* @return List<AstPriceRuleDO>
*/
public List<AstPriceRuleDO> getByAbsProdCode(String abssqrProdCode){
return astPriceRuleDOMapper.getByAbsProdCode(abssqrProdCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AstScreenRuleDO;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.LinkedHashMap;
import java.util.ArrayList;
import java.util.HashSet;
import com.abssqr.plat.common.dal.mysql.auto.paging.ScreenRulePage;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AstScreenRuleDOMapper;
/**
* The Table abs_ast_screen_rule.
* 资产筛选规则
*/
@Repository
public class AstScreenRuleDAO{
@Autowired
private AstScreenRuleDOMapper astScreenRuleDOMapper;
/**
* desc:插入表:abs_ast_screen_rule.<br/>
* @param entity entity
* @return int
*/
public int insert(AstScreenRuleDO entity){
return astScreenRuleDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_ast_screen_rule.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<AstScreenRuleDO> list){
astScreenRuleDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据唯一约束ScreenRuleNo更新表:abs_ast_screen_rule.<br/>
* @param entity entity
* @return int
*/
public int updateByScreenRuleNo(AstScreenRuleDO entity){
return astScreenRuleDOMapper.updateByScreenRuleNo(entity);
}
/**
* desc:根据唯一约束ScreenRuleNo获取数据:abs_ast_screen_rule.<br/>
* @param screenRuleNo screenRuleNo
* @return AstScreenRuleDO
*/
public AstScreenRuleDO getByScreenRuleNo(String screenRuleNo){
return astScreenRuleDOMapper.getByScreenRuleNo(screenRuleNo);
}
/**
* desc:根据唯一约束ScreenRuleNo获取数据:abs_ast_screen_rule.<br/>
* @param screenRuleNos screenRuleNos
* @return Map<String,AstScreenRuleDO>
*/
public List<AstScreenRuleDO> getByScreenRuleNosList(List<String> screenRuleNos){
return astScreenRuleDOMapper.getByScreenRuleNos(screenRuleNos);
}
/**
* desc:根据唯一约束ScreenRuleNo获取数据:abs_ast_screen_rule.<br/>
* @param screenRuleNos screenRuleNos
* @return Map<String,AstScreenRuleDO>
*/
public Map<String,AstScreenRuleDO> getByScreenRuleNos(List<String> screenRuleNos){
if(screenRuleNos!=null && screenRuleNos.size()>201){throw new RuntimeException("screenRuleNos 超出201长度限制");}
Map<String,AstScreenRuleDO> result = new LinkedHashMap();
List<AstScreenRuleDO> resultList = astScreenRuleDOMapper.getByScreenRuleNos(screenRuleNos);
if(resultList!=null && !resultList.isEmpty()){
for(AstScreenRuleDO entity:resultList){
result.put(entity.getScreenRuleNo(),entity);
}
}
return result;
}
/**
* desc:分页查询资产筛选规则.<br/>
* @param screenRule screenRule
* @return ScreenRulePage
*/
public ScreenRulePage getScreenRuleList(ScreenRulePage screenRule){
int total = astScreenRuleDOMapper.getScreenRuleListCount(screenRule);
if(total>0){
screenRule.setDatas(astScreenRuleDOMapper.getScreenRuleListResult(screenRule));
}else{
screenRule.setDatas(new ArrayList());
}
screenRule.setTotal(total);
return screenRule;
}
/**
* desc:获取同名筛选规则数量,防止重名存在.<br/>
* @param screenRuleNo screenRuleNo
* @param screenRuleName screenRuleName
* @return int
*/
public int getSameRuleCnt(String screenRuleNo,String screenRuleName){
return astScreenRuleDOMapper.getSameRuleCnt(screenRuleNo, screenRuleName);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AstSyncTaskCtrDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AstSyncTaskCtrDOMapper;
/**
* The Table abs_ast_sync_task_ctr.
* 资产同步控制任务
*/
@Repository
public class AstSyncTaskCtrDAO{
@Autowired
private AstSyncTaskCtrDOMapper astSyncTaskCtrDOMapper;
/**
* desc:插入表:abs_ast_sync_task_ctr.<br/>
* @param entity entity
* @return int
*/
public int insert(AstSyncTaskCtrDO entity){
return astSyncTaskCtrDOMapper.insert(entity);
}
/**
* desc:更新表:abs_ast_sync_task_ctr.<br/>
* @param extData extData
* @param orgCode orgCode
* @return int
*/
public int updateExtData(String extData,String orgCode){
return astSyncTaskCtrDOMapper.updateExtData(extData, orgCode);
}
/**
* desc:根据主键获取数据:abs_ast_sync_task_ctr.<br/>
* @return List<AstSyncTaskCtrDO>
*/
public List<AstSyncTaskCtrDO> getByOrgCodes(){
return astSyncTaskCtrDOMapper.getByOrgCodes();
}
/**
* desc:根据主键获取数据:abs_ast_sync_task_ctr.<br/>
* @param orgCode orgCode
* @return AstSyncTaskCtrDO
*/
public AstSyncTaskCtrDO getByOrgCode(String orgCode){
return astSyncTaskCtrDOMapper.getByOrgCode(orgCode);
}
/**
* desc:根据主键获取数据:abs_ast_sync_task_ctr.<br/>
* @param orgCode orgCode
* @return AstSyncTaskCtrDO
*/
public AstSyncTaskCtrDO lockByOrgCode(String orgCode){
return astSyncTaskCtrDOMapper.lockByOrgCode(orgCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.AstSyncTaskCtrLogDO;
import java.util.Date;
import java.util.List;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.AstSyncTaskCtrLogDOMapper;
/**
* The Table abs_ast_sync_task_ctr_log.
* 资产同步控制记录
*/
@Repository
public class AstSyncTaskCtrLogDAO{
@Autowired
private AstSyncTaskCtrLogDOMapper astSyncTaskCtrLogDOMapper;
/**
* desc:插入表:abs_ast_sync_task_ctr_log.<br/>
* @param entity entity
* @return int
*/
public int insert(AstSyncTaskCtrLogDO entity){
return astSyncTaskCtrLogDOMapper.insert(entity);
}
/**
* desc:获取指定类型的记录.<br/>
* @param execDate execDate
* @param lastTaskCode lastTaskCode
* @return List<AstSyncTaskCtrLogDO>
*/
public List<AstSyncTaskCtrLogDO> getLastStatusFinishedTasks(Date execDate,String lastTaskCode){
return astSyncTaskCtrLogDOMapper.getLastStatusFinishedTasks(execDate, lastTaskCode);
}
/**
* desc:获取指定类型的记录.<br/>
* @param execDate execDate
* @param orgCode orgCode
* @param taskType taskType
* @return AstSyncTaskCtrLogDO
*/
public AstSyncTaskCtrLogDO getTaskLogByExecDate(Date execDate,String orgCode,String taskType){
return astSyncTaskCtrLogDOMapper.getTaskLogByExecDate(execDate, orgCode, taskType);
}
/**
* desc:获取指定类型的记录.<br/>
* @param orgDate orgDate
* @param orgCode orgCode
* @param taskType taskType
* @return AstSyncTaskCtrLogDO
*/
public AstSyncTaskCtrLogDO getLastTaskLogByOrgDate(Date orgDate,String orgCode,String taskType){
return astSyncTaskCtrLogDOMapper.getLastTaskLogByOrgDate(orgDate, orgCode, taskType);
}
/**
* desc:根据机构会计日执行情况获取.<br/>
* @param orgDate orgDate
* @param orgCode orgCode
* @param taskType taskType
* @return AstSyncTaskCtrLogDO
*/
public AstSyncTaskCtrLogDO getTaskLogByOrgDate(Date orgDate,String orgCode,String taskType){
return astSyncTaskCtrLogDOMapper.getTaskLogByOrgDate(orgDate, orgCode, taskType);
}
/**
* desc:更新表:abs_ast_sync_task_ctr_log.<br/>
* @param hostIp hostIp
* @param status status
* @param taskType taskType
* @param oldStatus oldStatus
* @param taskLogCode taskLogCode
* @return int
*/
public int updateStatus(String hostIp,String status,String taskType,String oldStatus,String taskLogCode){
return astSyncTaskCtrLogDOMapper.updateStatus(hostIp, status, taskType, oldStatus, taskLogCode);
}
/**
* desc:根据主键获取数据:abs_ast_sync_task_ctr_log.<br/>
* @param orgDate orgDate
* @param orgCode orgCode
* @param taskCode taskCode
* @param taskType taskType
* @return Long
*/
public Long canRunByOrgDate(Date orgDate,String orgCode,String taskCode,String taskType){
return astSyncTaskCtrLogDOMapper.canRunByOrgDate(orgDate, orgCode, taskCode, taskType);
}
/**
* desc:获取指定类型的最大完成机构会计日.<br/>
* @param orgCode orgCode
* @param taskType taskType
* @return Date
*/
public Date getTaskLogMaxOrgDate(String orgCode,String taskType){
return astSyncTaskCtrLogDOMapper.getTaskLogMaxOrgDate(orgCode, taskType);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.BizDataChangeDO;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.BizDataChangeDOMapper;
/**
* The Table abs_biz_data_change.
* 业务数据变更记录-审批
*/
@Repository
public class BizDataChangeDAO{
@Autowired
private BizDataChangeDOMapper bizDataChangeDOMapper;
/**
* desc:插入表:abs_biz_data_change.<br/>
* @param entity entity
* @return int
*/
public int insert(BizDataChangeDO entity){
return bizDataChangeDOMapper.insert(entity);
}
/**
* desc:根据唯一约束AbsBizDataChange0更新表:abs_biz_data_change.<br/>
* @param changeNo changeNo
* @param approveStatus approveStatus
* @param oldApproveStatus oldApproveStatus
* @return int
*/
public int updateStatus(String changeNo,String approveStatus,String oldApproveStatus){
return bizDataChangeDOMapper.updateStatus(changeNo, approveStatus, oldApproveStatus);
}
/**
* desc:根据唯一约束AbsBizDataChange0获取数据:abs_biz_data_change.<br/>
* @param changeNo changeNo
* @return BizDataChangeDO
*/
public BizDataChangeDO getByChangeNo(String changeNo){
return bizDataChangeDOMapper.getByChangeNo(changeNo);
}
/**
* desc:测试专用-根据bizNo与审批状态查询数据.<br/>
* @param bizNo bizNo
* @param approveStatus approveStatus
* @return BizDataChangeDO
*/
public BizDataChangeDO getByBizNoAndStatus(String bizNo,String approveStatus){
return bizDataChangeDOMapper.getByBizNoAndStatus(bizNo, approveStatus);
}
/**
* desc:根据bizNo、status和bizType查询审批数量.<br/>
* @param bizType bizType
* @param changeNo changeNo
* @param approveStatus approveStatus
* @return Long
*/
public Long cntByBizNoAndStatusAndBizType(String bizType,String changeNo,String approveStatus){
return bizDataChangeDOMapper.cntByBizNoAndStatusAndBizType(bizType, changeNo, approveStatus);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.CommonTaskDO;
import java.util.List;
import java.util.Date;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.CommonTaskDOMapper;
/**
* The Table ABS_COMMON_TASK.
* ABS_COMMON_TASK
*/
@Repository
public class CommonTaskDAO{
@Autowired
private CommonTaskDOMapper commonTaskDOMapper;
/**
* desc:插入表:ABS_COMMON_TASK.<br/>
* @param entity entity
* @return int
*/
public int insert(CommonTaskDO entity){
return commonTaskDOMapper.insert(entity);
}
/**
* desc:批量插入表:ABS_COMMON_TASK.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<CommonTaskDO> list){
commonTaskDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:查询待执行的任务.<br/>
* @param id id
* @return CommonTaskDO
*/
public CommonTaskDO lockById(Long id){
return commonTaskDOMapper.lockById(id);
}
/**
* desc:查询待执行的任务.<br/>
* @param curTime curTime
* @param limit limit
* @param typeList typeList
* @return List<CommonTaskDO>
*/
public List<CommonTaskDO> selectInitTask(Date curTime,Integer limit,List<String> typeList){
if(typeList!=null && typeList.size()>201){throw new RuntimeException("typeList 超出201长度限制");}
return commonTaskDOMapper.selectInitTask(curTime, limit, typeList);
}
/**
* desc:查询待执行的任务.<br/>
* @param taskType taskType
* @return List<CommonTaskDO>
*/
public List<CommonTaskDO> selectUnifinishTaskByType(String taskType){
return commonTaskDOMapper.selectUnifinishTaskByType(taskType);
}
/**
* desc:更新执行的任务状态.<br/>
* @param id id
* @param memo memo
* @param newStatus newStatus
* @param oldStatus oldStatus
* @return int
*/
public int updateTaskStatus(Long id,String memo,String newStatus,String oldStatus){
return commonTaskDOMapper.updateTaskStatus(id, memo, newStatus, oldStatus);
}
/**
* desc:更新任务为执行中.<br/>
* @param lastExecTime lastExecTime
* @param lastHost lastHost
* @param tasks tasks
* @return int
*/
public int updateTaskExec(Date lastExecTime,String lastHost,List<CommonTaskDO> tasks){
if(tasks!=null && tasks.size()>1000){throw new RuntimeException("tasks 超出1000长度限制");}
return commonTaskDOMapper.updateTaskExec(lastExecTime, lastHost, tasks);
}
/**
* desc:重置状态,更新下次执行时间.<br/>
* @param nextExecTime nextExecTime
* @param id id
* @param memo memo
* @return int
*/
public int updateTaskExep(Date nextExecTime,Long id,String memo){
return commonTaskDOMapper.updateTaskExep(nextExecTime, id, memo);
}
/**
* desc:把任务为Ignore状态的任务改为Init.<br/>
* @param id id
* @return int
*/
public int updateIgnoreTaskStatus2Init(Long id){
return commonTaskDOMapper.updateIgnoreTaskStatus2Init(id);
}
/**
* desc:根据ip重置任务.<br/>
* @param lastHost lastHost
* @return int
*/
public int updateHangTasksByIp(String lastHost){
return commonTaskDOMapper.updateHangTasksByIp(lastHost);
}
/**
* desc:查询当前计划是否有正在执行中的的解绑,同步匹配,解绑匹配任务.<br/>
* @param planNo planNo
* @param statuses statuses
* @param taskTypes taskTypes
* @return List<CommonTaskDO>
*/
public List<CommonTaskDO> queryUnMatchOrMatchTaskByContextAndStatus(String planNo,List<String> statuses,List<String> taskTypes){
if(statuses!=null && statuses.size()>201){throw new RuntimeException("statuses 超出201长度限制");}
if(taskTypes!=null && taskTypes.size()>201){throw new RuntimeException("taskTypes 超出201长度限制");}
return commonTaskDOMapper.queryUnMatchOrMatchTaskByContextAndStatus(planNo, statuses, taskTypes);
}
/**
* desc:通过BizNo查询CommonTask.<br/>
* @param bizNo bizNo
* @return List<CommonTaskDO>
*/
public List<CommonTaskDO> queryByBizNo(String bizNo){
return commonTaskDOMapper.queryByBizNo(bizNo);
}
/**
* desc:根据任务类型和任务状态查询.<br/>
* @param typeList typeList
* @param statusList statusList
* @return List<CommonTaskDO>
*/
public List<CommonTaskDO> queryByTypesAndStatus(List<String> typeList,List<String> statusList){
if(typeList!=null && typeList.size()>201){throw new RuntimeException("typeList 超出201长度限制");}
if(statusList!=null && statusList.size()>201){throw new RuntimeException("statusList 超出201长度限制");}
return commonTaskDOMapper.queryByTypesAndStatus(typeList, statusList);
}
/**
* desc:根据任务类型、任务状态和执行时间范围计数.<br/>
* @param second second
* @param typeList typeList
* @param statusList statusList
* @return Long
*/
public Long countByTypesAndStatusAndRange(Long second,List<String> typeList,List<String> statusList){
if(typeList!=null && typeList.size()>201){throw new RuntimeException("typeList 超出201长度限制");}
if(statusList!=null && statusList.size()>201){throw new RuntimeException("statusList 超出201长度限制");}
return commonTaskDOMapper.countByTypesAndStatusAndRange(second, typeList, statusList);
}
/**
* desc:查询未完成的执行次数大于1的任务数量.<br/>
* @param typeList typeList
* @return Long
*/
public Long countUnFinishAndMultipleExecByTypes(List<String> typeList){
if(typeList!=null && typeList.size()>201){throw new RuntimeException("typeList 超出201长度限制");}
return commonTaskDOMapper.countUnFinishAndMultipleExecByTypes(typeList);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.HostInfoDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.HostHeartInfo;
import com.abssqr.plat.common.dal.mysql.auto.mapper.HostInfoDOMapper;
/**
* The Table abs_host_info.
* 主机信息
*/
@Repository
public class HostInfoDAO{
@Autowired
private HostInfoDOMapper hostInfoDOMapper;
/**
* desc:插入表:abs_host_info.<br/>
* @param entity entity
* @return int
*/
public int insert(HostInfoDO entity){
return hostInfoDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_host_info.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<HostInfoDO> list){
hostInfoDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键删除数据:abs_host_info.<br/>
* @param id id
* @return int
*/
public int deleteById(Long id){
return hostInfoDOMapper.deleteById(id);
}
/**
* desc:根据主键获取数据:abs_host_info.<br/>
* @param id id
* @return HostInfoDO
*/
public HostInfoDO getById(Long id){
return hostInfoDOMapper.getById(id);
}
/**
* desc:根据唯一约束HostIpUnique更新表:abs_host_info.<br/>
* @param entity entity
* @return int
*/
public int updateByHostNameUnique(HostInfoDO entity){
return hostInfoDOMapper.updateByHostNameUnique(entity);
}
/**
* desc:updateHeart.<br/>
* @param hostName hostName
* @return int
*/
public int updateHeart(String hostName){
return hostInfoDOMapper.updateHeart(hostName);
}
/**
* desc:根据唯一约束HostIpUnique删除数据:abs_host_info.<br/>
* @param hostName hostName
* @return int
*/
public int deleteByHostNameUnique(String hostName){
return hostInfoDOMapper.deleteByHostNameUnique(hostName);
}
/**
* desc:根据唯一约束HostIpUnique获取数据:abs_host_info.<br/>
* @param hostName hostName
* @return HostInfoDO
*/
public HostInfoDO selectByName(String hostName){
return hostInfoDOMapper.selectByName(hostName);
}
/**
* desc:根据唯一约束HostIpUnique获取数据:abs_host_info.<br/>
* @param hostIp hostIp
* @return HostInfoDO
*/
public HostInfoDO selectByHostIp(String hostIp){
return hostInfoDOMapper.selectByHostIp(hostIp);
}
/**
* desc:获取超时主机.<br/>
* @param currentTime currentTime
* @param overTime overTime
* @return List<HostInfoDO>
*/
public List<HostInfoDO> listOvertimeHost(Date currentTime,Integer overTime){
return hostInfoDOMapper.listOvertimeHost(currentTime, overTime);
}
/**
* desc:获取所有主机.<br/>
* @return List<HostHeartInfo>
*/
public List<HostHeartInfo> getAllHost(){
return hostInfoDOMapper.getAllHost();
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.JobControlDO;
import com.abssqr.plat.common.dal.mysql.auto.mapper.JobControlDOMapper;
/**
* The Table ABS_JOB_CONTROL.
* ABS_JOB_CONTROL
*/
@Repository
public class JobControlDAO{
@Autowired
private JobControlDOMapper jobControlDOMapper;
/**
* desc:插入表:ABS_JOB_CONTROL.<br/>
* @param entity entity
* @return int
*/
public int insert(JobControlDO entity){
return jobControlDOMapper.insert(entity);
}
/**
* desc:更新表:ABS_JOB_CONTROL.<br/>
* @param entity entity
* @return int
*/
public int update(JobControlDO entity){
return jobControlDOMapper.update(entity);
}
/**
* desc:根据jobName获取数据:ABS_JOB_CONTROL.<br/>
* @param jobName jobName
* @return JobControlDO
*/
public JobControlDO getByJobName(String jobName){
return jobControlDOMapper.getByJobName(jobName);
}
/**
* desc:根据jobName获取数据:ABS_JOB_CONTROL.<br/>
* @param jobName jobName
* @return JobControlDO
*/
public JobControlDO lockByJobName(String jobName){
return jobControlDOMapper.lockByJobName(jobName);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanAstDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanAstDOMapper;
/**
* The Table abs_loan_ast.
* 机构资产
*/
@Repository
public class LoanAstDAO{
@Autowired
private LoanAstDOMapper loanAstDOMapper;
/**
* desc:批量插入表:abs_loan_ast.<br/>
* @param entity entity
* @return int
*/
public int insert(LoanAstDO entity){
return loanAstDOMapper.insert(entity);
}
/**
* desc:更新表:abs_loan_ast.<br/>
* @param entity entity
* @return int
*/
public int update(LoanAstDO entity){
return loanAstDOMapper.update(entity);
}
/**
* desc:根据普通索引AbsLoanAstIdx获取数据:abs_loan_ast.<br/>
* @param astNo astNo
* @return List<LoanAstDO>
*/
public List<LoanAstDO> queryByAstNo(String astNo){
return loanAstDOMapper.queryByAstNo(astNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanAstLogDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanAstLogDOMapper;
/**
* The Table abs_loan_ast_log.
* ABS_LOAN_AST_LOG
*/
@Repository
public class LoanAstLogDAO{
@Autowired
private LoanAstLogDOMapper loanAstLogDOMapper;
/**
* desc:批量插入表:abs_loan_ast_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<LoanAstLogDO> list){
loanAstLogDOMapper.insertBatch(list);
return list.size();
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanAstProfitDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanAstProfitDOMapper;
/**
* The Table abs_loan_ast_profit.
* 机构资产收益
*/
@Repository
public class LoanAstProfitDAO{
@Autowired
private LoanAstProfitDOMapper loanAstProfitDOMapper;
/**
* desc:批量插入表:abs_loan_ast_profit.<br/>
* @param entity entity
* @return int
*/
public int insert(LoanAstProfitDO entity){
return loanAstProfitDOMapper.insert(entity);
}
/**
* desc:更新表:abs_loan_ast_profit.<br/>
* @param entity entity
* @return int
*/
public int updateById(LoanAstProfitDO entity){
return loanAstProfitDOMapper.updateById(entity);
}
/**
* desc:根据普通索引AbsLoanAstProfitIdx获取数据:abs_loan_ast_profit.<br/>
* @param astNo astNo
* @return List<LoanAstProfitDO>
*/
public List<LoanAstProfitDO> queryByAstNo(String astNo){
return loanAstProfitDOMapper.queryByAstNo(astNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanAstProfitLogDO;
import java.util.List;
import java.util.Date;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.LoanAstProfitStat;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanAstProfitLogDOMapper;
/**
* The Table abs_loan_ast_profit_log.
* ABS_LOAN_AST_PROFIT_LOG
*/
@Repository
public class LoanAstProfitLogDAO{
@Autowired
private LoanAstProfitLogDOMapper loanAstProfitLogDOMapper;
/**
* desc:批量插入表:abs_loan_ast_profit_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<LoanAstProfitLogDO> list){
loanAstProfitLogDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:计算金融服务费.<br/>
* @param accountDate accountDate
* @param orgCode orgCode
* @return Long
*/
public Long calcOrgDistPftAmt(Date accountDate,String orgCode){
return loanAstProfitLogDOMapper.calcOrgDistPftAmt(accountDate, orgCode);
}
/**
* desc:计算还款服务费应计与实还.<br/>
* @param accountDate accountDate
* @param orgCode orgCode
* @param splitOrgCode splitOrgCode
* @return LoanAstProfitStat
*/
public LoanAstProfitStat repayOrgDistPftAmt(Date accountDate,String orgCode,String splitOrgCode){
return loanAstProfitLogDOMapper.repayOrgDistPftAmt(accountDate, orgCode, splitOrgCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanBakDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.PropDisbStat;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.PropCntStat;
import com.abssqr.plat.common.dal.mysql.auto.paging.LoanBakListPage;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.LoanBakFormationItem;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.LoanBakReportStat;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.AstScale;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanBakDOMapper;
/**
* The Table abs_loan_bak.
* 信贷资产
*/
@Repository
public class LoanBakDAO{
@Autowired
private LoanBakDOMapper loanBakDOMapper;
/**
* desc:批量插入表:abs_loan_bak.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<LoanBakDO> list){
loanBakDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return PropDisbStat
*/
public PropDisbStat statDisb(Date accountDate,String planNo){
return loanBakDOMapper.statDisb(accountDate, planNo);
}
/**
* desc:statPlanBal.<br/>
* @param accountDate accountDate
* @param ownOrg ownOrg
* @return PropCntStat
*/
public PropCntStat statPlanBal(Date accountDate,String ownOrg){
return loanBakDOMapper.statPlanBal(accountDate, ownOrg);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PropCntStat>
*/
public List<PropCntStat> statLocation(Date accountDate,String planNo){
return loanBakDOMapper.statLocation(accountDate, planNo);
}
/**
* desc:根据主键获取数据:ABS_LOAN_BAK.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PropCntStat>
*/
public List<PropCntStat> statAge(Date accountDate,String planNo){
return loanBakDOMapper.statAge(accountDate, planNo);
}
/**
* desc:根据主键获取数据:ABS_LOAN_BAK.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PropCntStat>
*/
public List<PropCntStat> statGender(Date accountDate,String planNo){
return loanBakDOMapper.statGender(accountDate, planNo);
}
/**
* desc:getPageByOwnOrg.<br/>
* @param loanBakList loanBakList
* @return LoanBakListPage
*/
public LoanBakListPage getPageByOwnOrg(LoanBakListPage loanBakList){
int total = loanBakDOMapper.getPageByOwnOrgCount(loanBakList);
if(total>0){
loanBakList.setDatas(loanBakDOMapper.getPageByOwnOrgResult(loanBakList));
}else{
loanBakList.setDatas(new ArrayList());
}
loanBakList.setTotal(total);
return loanBakList;
}
/**
* desc:统计资产当前剩余分期数量及余额总计.<br/>
* @param accountDate accountDate
* @param ownOrg ownOrg
* @return List<LoanBakFormationItem>
*/
public List<LoanBakFormationItem> queryAstFormation(Date accountDate,String ownOrg){
return loanBakDOMapper.queryAstFormation(accountDate, ownOrg);
}
/**
* desc:统计资产产品分期及余额总计.<br/>
* @param accountDate accountDate
* @param ownOrg ownOrg
* @return List<LoanBakFormationItem>
*/
public List<LoanBakFormationItem> queryProdFormation(Date accountDate,String ownOrg){
return loanBakDOMapper.queryProdFormation(accountDate, ownOrg);
}
/**
* desc:资产余额状态统计代替statBal.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<LoanBakReportStat>
*/
public List<LoanBakReportStat> statLoanBakStatus(Date accountDate,String planNo){
return loanBakDOMapper.statLoanBakStatus(accountDate, planNo);
}
/**
* desc:五级分类统计代替statBal.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<LoanBakReportStat>
*/
public List<LoanBakReportStat> statLoanBakClz(Date accountDate,String planNo){
return loanBakDOMapper.statLoanBakClz(accountDate, planNo);
}
/**
* desc:91逾期未核销统计代替statBal.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param statVal statVal
* @param statType statType
* @param wtfStatus wtfStatus
* @param ovdDays ovdDays
* @return List<LoanBakReportStat>
*/
public List<LoanBakReportStat> statLoanBakOvdWtf(Date accountDate,String planNo,String statVal,String statType,String wtfStatus,Integer ovdDays){
return loanBakDOMapper.statLoanBakOvdWtf(accountDate, planNo, statVal, statType, wtfStatus, ovdDays);
}
/**
* desc:ovd_day天数统计代替statBal.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<LoanBakReportStat>
*/
public List<LoanBakReportStat> statLoanBakOvdDays(Date accountDate,String planNo){
return loanBakDOMapper.statLoanBakOvdDays(accountDate, planNo);
}
/**
* desc:统计当日新增资产年化收益.<br/>
* @param inDate inDate
* @param disbDate disbDate
* @param accountDate accountDate
* @param planNo planNo
* @return List<LoanBakReportStat>
*/
public List<LoanBakReportStat> statLoanBakProfit(Date inDate,Date disbDate,Date accountDate,String planNo){
return loanBakDOMapper.statLoanBakProfit(inDate, disbDate, accountDate, planNo);
}
/**
* desc:获取资产规模.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<AstScale>
*/
public List<AstScale> getAstScale(Date accountDate,String planNo){
return loanBakDOMapper.getAstScale(accountDate, planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanContractDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanContractDOMapper;
/**
* The Table abs_loan_contract.
* 借款合同
*/
@Repository
public class LoanContractDAO{
@Autowired
private LoanContractDOMapper loanContractDOMapper;
/**
* desc:插入表:abs_loan_contract.<br/>
* @param entity entity
* @return int
*/
public int insert(LoanContractDO entity){
return loanContractDOMapper.insert(entity);
}
/**
* desc:根据唯一约束OutContNo获取数据:abs_loan_contract.<br/>
* @param astNo astNo
* @return LoanContractDO
*/
public LoanContractDO getByAstNo(String astNo){
return loanContractDOMapper.getByAstNo(astNo);
}
/**
* desc:根据唯一约束OutContNo获取数据:abs_loan_contract.<br/>
* @param astNos astNos
* @return List<LoanContractDO>
*/
public List<LoanContractDO> getByAstNos(List<String> astNos){
if(astNos!=null && astNos.size()>201){throw new RuntimeException("astNos 超出201长度限制");}
return loanContractDOMapper.getByAstNos(astNos);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanDO;
import com.abssqr.plat.common.dal.mysql.auto.paging.LoanListPage;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.LoanPropCntStat;
import com.abssqr.plat.common.dal.mysql.auto.paging.CapitalAstMatchPage;
import com.abssqr.plat.common.dal.mysql.auto.paging.CapitalAstUnMatchPage;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanDOMapper;
/**
* The Table abs_loan.
* 信贷资产
*/
@Repository
public class LoanDAO{
@Autowired
private LoanDOMapper loanDOMapper;
/**
* desc:插入表:abs_loan.<br/>
* @param entity entity
* @return int
*/
public int insert(LoanDO entity){
return loanDOMapper.insert(entity);
}
/**
* desc:根据唯一约束OutAstNo更新表:abs_loan.<br/>
* @param entity entity
* @return int
*/
public int updateByAstNo(LoanDO entity){
return loanDOMapper.updateByAstNo(entity);
}
/**
* desc:根据唯一约束OutAstNo获取数据:abs_loan.<br/>
* @param outAstNo outAstNo
* @param managerOrgCode managerOrgCode
* @return LoanDO
*/
public LoanDO getByOutAstNo(String outAstNo,String managerOrgCode){
return loanDOMapper.getByOutAstNo(outAstNo, managerOrgCode);
}
/**
* desc:根据唯一约束OutAstNo获取数据:abs_loan.<br/>
* @param outAstNo outAstNo
* @param managerOrgCode managerOrgCode
* @return LoanDO
*/
public LoanDO lockByOutAstNo(String outAstNo,String managerOrgCode){
return loanDOMapper.lockByOutAstNo(outAstNo, managerOrgCode);
}
/**
* desc:根据唯一约束AbsLoan获取数据:abs_loan.<br/>
* @param astNo astNo
* @return LoanDO
*/
public LoanDO getByAstNo(String astNo){
return loanDOMapper.getByAstNo(astNo);
}
/**
* desc:根据唯一约束AbsLoan获取数据:abs_loan.<br/>
* @param astNo astNo
* @return LoanDO
*/
public LoanDO lockByAstNo(String astNo){
return loanDOMapper.lockByAstNo(astNo);
}
/**
* desc:getPageByOwnOrg.<br/>
* @param loanList loanList
* @return LoanListPage
*/
public LoanListPage getPageByOwnOrg(LoanListPage loanList){
int total = loanDOMapper.getPageByOwnOrgCount(loanList);
if(total>0){
loanList.setDatas(loanDOMapper.getPageByOwnOrgResult(loanList));
}else{
loanList.setDatas(new ArrayList());
}
loanList.setTotal(total);
return loanList;
}
/**
* desc:统计机构当前资产规模.<br/>
* @param lenderOrgCode lenderOrgCode
* @return LoanPropCntStat
*/
public LoanPropCntStat statPlanBal(String lenderOrgCode){
return loanDOMapper.statPlanBal(lenderOrgCode);
}
/**
* desc:统计放款池当前持有资产规模(不包含已转出).<br/>
* @param lenderOrgCode lenderOrgCode
* @return LoanPropCntStat
*/
public LoanPropCntStat statSpvBal(String lenderOrgCode){
return loanDOMapper.statSpvBal(lenderOrgCode);
}
/**
* desc:资金资产匹配分页.<br/>
* @param capitalAstMatch capitalAstMatch
* @return CapitalAstMatchPage
*/
public CapitalAstMatchPage queryForCapitalAstMatch(CapitalAstMatchPage capitalAstMatch){
int total = loanDOMapper.queryForCapitalAstMatchCount(capitalAstMatch);
if(total>0){
capitalAstMatch.setDatas(loanDOMapper.queryForCapitalAstMatchResult(capitalAstMatch));
}else{
capitalAstMatch.setDatas(new ArrayList());
}
capitalAstMatch.setTotal(total);
return capitalAstMatch;
}
/**
* desc:资金资产解绑分页.<br/>
* @param capitalAstUnMatch capitalAstUnMatch
* @return CapitalAstUnMatchPage
*/
public CapitalAstUnMatchPage queryForCapitalAstUnMatch(CapitalAstUnMatchPage capitalAstUnMatch){
int total = loanDOMapper.queryForCapitalAstUnMatchCount(capitalAstUnMatch);
if(total>0){
capitalAstUnMatch.setDatas(loanDOMapper.queryForCapitalAstUnMatchResult(capitalAstUnMatch));
}else{
capitalAstUnMatch.setDatas(new ArrayList());
}
capitalAstUnMatch.setTotal(total);
return capitalAstUnMatch;
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanInstalDO;
import java.util.List;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.LoanInstalFormationItem;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanInstalDOMapper;
/**
* The Table abs_loan_instal.
* 还款计划明细
*/
@Repository
public class LoanInstalDAO{
@Autowired
private LoanInstalDOMapper loanInstalDOMapper;
/**
* desc:批量插入表:abs_loan_instal.<br/>
* @param entity entity
* @return int
*/
public int insert(LoanInstalDO entity){
return loanInstalDOMapper.insert(entity);
}
/**
* desc:根据唯一约束AbsLoanInstal更新表:abs_loan_instal.<br/>
* @param entity entity
* @return int
*/
public int update(LoanInstalDO entity){
return loanInstalDOMapper.update(entity);
}
/**
* desc:根据唯一约束AbsLoanInstal获取数据:abs_loan_instal.<br/>
* @param astNo astNo
* @return List<LoanInstalDO>
*/
public List<LoanInstalDO> getByAstNo(String astNo){
return loanInstalDOMapper.getByAstNo(astNo);
}
/**
* desc:获取对应计划的资产数量.<br/>
* @param ownOrg ownOrg
* @param list list
* @return Long
*/
public Long getPlanAstCount(String ownOrg,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return loanInstalDOMapper.getPlanAstCount(ownOrg, list);
}
/**
* desc:获取资产当前剩余分期数量及余额总计.<br/>
* @param ownOrg ownOrg
* @return List<LoanInstalFormationItem>
*/
public List<LoanInstalFormationItem> queryAstFormation(String ownOrg){
return loanInstalDOMapper.queryAstFormation(ownOrg);
}
/**
* desc:获取资产最大分期及余额总计.<br/>
* @param ownOrg ownOrg
* @return List<LoanInstalFormationItem>
*/
public List<LoanInstalFormationItem> queryProdFormation(String ownOrg){
return loanInstalDOMapper.queryProdFormation(ownOrg);
}
/**
* desc:获取计划当前资产规模.<br/>
* @param ownOrg ownOrg
* @return Long
*/
public Long getPlanAstScale(String ownOrg){
return loanInstalDOMapper.getPlanAstScale(ownOrg);
}
/**
* desc:获取计划时间区间内应还汇总金额.<br/>
* @param endDate endDate
* @param startDate startDate
* @param ownOrg ownOrg
* @return Long
*/
public Long getPlanAstShouldScaleByEndDate(Date endDate,Date startDate,String ownOrg){
return loanInstalDOMapper.getPlanAstShouldScaleByEndDate(endDate, startDate, ownOrg);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanInstalLogDO;
import java.util.List;
import java.util.Date;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanInstalLogDOMapper;
/**
* The Table abs_loan_instal_log.
* 分期变更流水
*/
@Repository
public class LoanInstalLogDAO{
@Autowired
private LoanInstalLogDOMapper loanInstalLogDOMapper;
/**
* desc:批量插入表:abs_loan_instal_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<LoanInstalLogDO> list){
loanInstalLogDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:计算金融服务费.<br/>
* @param accountDate accountDate
* @param orgCode orgCode
* @return Long
*/
public Long calcOrgDistPftAmt(Date accountDate,String orgCode){
return loanInstalLogDOMapper.calcOrgDistPftAmt(accountDate, orgCode);
}
/**
* desc:计算金融服务费.<br/>
* @param accountDate accountDate
* @param orgCode orgCode
* @return Long
*/
public Long calcOrgDistPftApporAmt(Date accountDate,String orgCode){
return loanInstalLogDOMapper.calcOrgDistPftApporAmt(accountDate, orgCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.LoanLogDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.LoanLogDOMapper;
/**
* The Table abs_loan_log.
* 资产变更流水
*/
@Repository
public class LoanLogDAO{
@Autowired
private LoanLogDOMapper loanLogDOMapper;
/**
* desc:批量插入表:abs_loan_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<LoanLogDO> list){
loanLogDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:测试专供-主要为查询bizNo.<br/>
* @param outAstNo outAstNo
* @param eventCode eventCode
* @return List<LoanLogDO>
*/
public List<LoanLogDO> getByOutAstNoAndEventCode(String outAstNo,String eventCode){
return loanLogDOMapper.getByOutAstNoAndEventCode(outAstNo, eventCode);
}
/**
* desc:根据资产编号和事件码获取最新的一条.<br/>
* @param astNo astNo
* @param eventCode eventCode
* @return LoanLogDO
*/
public LoanLogDO getLastByAstNoAndEventCode(String astNo,String eventCode){
return loanLogDOMapper.getLastByAstNoAndEventCode(astNo, eventCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.OrgHolidayDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.OrgHolidayDOMapper;
/**
* The Table ABS_ORG_HOLIDAY.
* ABS_ORG_HOLIDAY
*/
@Repository
public class OrgHolidayDAO{
@Autowired
private OrgHolidayDOMapper orgHolidayDOMapper;
/**
* desc:插入表:ABS_ORG_HOLIDAY.<br/>
* @param entity entity
* @return int
*/
public int insert(OrgHolidayDO entity){
return orgHolidayDOMapper.insert(entity);
}
/**
* desc:批量插入表:ABS_ORG_HOLIDAY.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<OrgHolidayDO> list){
orgHolidayDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:通过机构号和日期更新.<br/>
* @param entity entity
* @return int
*/
public int updateByOrgCodeAndDate(OrgHolidayDO entity){
return orgHolidayDOMapper.updateByOrgCodeAndDate(entity);
}
/**
* desc:根据机构编号及开始日期结束日期查询节假日.<br/>
* @param endDate endDate
* @param orgCode orgCode
* @param beginDate beginDate
* @return List<OrgHolidayDO>
*/
public List<OrgHolidayDO> queryHolidayByOrgCodeAndDate(String endDate,String orgCode,String beginDate){
return orgHolidayDOMapper.queryHolidayByOrgCodeAndDate(endDate, orgCode, beginDate);
}
/**
* desc:根据机构码和日期查询节假日.<br/>
* @param orgCode orgCode
* @param dateInfo dateInfo
* @return OrgHolidayDO
*/
public OrgHolidayDO getByOrgCodeAndDate(String orgCode,String dateInfo){
return orgHolidayDOMapper.getByOrgCodeAndDate(orgCode, dateInfo);
}
/**
* desc:根据机构码和日期查询节假日类型.<br/>
* @param orgCode orgCode
* @param dateInfo dateInfo
* @return String
*/
public String getHolidayTypeByOrgCodeAndDate(String orgCode,String dateInfo){
return orgHolidayDOMapper.getHolidayTypeByOrgCodeAndDate(orgCode, dateInfo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.OrganizationDO;
import com.abssqr.plat.common.dal.mysql.auto.paging.OrgListPage;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.LinkedHashMap;
import java.util.ArrayList;
import java.util.HashSet;
import com.abssqr.plat.common.dal.mysql.auto.mapper.OrganizationDOMapper;
/**
* The Table abs_organization.
* 机构信息
*/
@Repository
public class OrganizationDAO{
@Autowired
private OrganizationDOMapper organizationDOMapper;
/**
* desc:insertOrUpdate.<br/>
* @param entity entity
* @return int
*/
public int insert(OrganizationDO entity){
return organizationDOMapper.insert(entity);
}
/**
* desc:判断是否存在同名机构.<br/>
* @param entity entity
* @return Integer
*/
public Integer getSameNameOrgCnt(OrganizationDO entity){
return organizationDOMapper.getSameNameOrgCnt(entity);
}
/**
* desc:根据唯一约束OrgCode更新表:abs_organization.<br/>
* @param entity entity
* @return int
*/
public int updateByOrgCode(OrganizationDO entity){
return organizationDOMapper.updateByOrgCode(entity);
}
/**
* desc:根据唯一约束OrgCode获取数据:abs_organization.<br/>
* @param orgCode orgCode
* @return OrganizationDO
*/
public OrganizationDO getByOrgCode(String orgCode){
return organizationDOMapper.getByOrgCode(orgCode);
}
/**
* desc:查询机构列表.<br/>
* @param orgList orgList
* @return OrgListPage
*/
public OrgListPage queryOrgListForPage(OrgListPage orgList){
int total = organizationDOMapper.queryOrgListForPageCount(orgList);
if(total>0){
orgList.setDatas(organizationDOMapper.queryOrgListForPageResult(orgList));
}else{
orgList.setDatas(new ArrayList());
}
orgList.setTotal(total);
return orgList;
}
/**
* desc:getOrgNames.<br/>
* @param orgCodes orgCodes
* @return Map<String,String>
*/
public List<OrganizationDO> getOrgNamesList(List<String> orgCodes){
return organizationDOMapper.getOrgNames(orgCodes);
}
/**
* desc:getOrgNames.<br/>
* @param orgCodes orgCodes
* @return Map<String,String>
*/
public Map<String,String> getOrgNames(List<String> orgCodes){
if(orgCodes!=null && orgCodes.size()>201){throw new RuntimeException("orgCodes 超出201长度限制");}
Map<String,String> result = new LinkedHashMap();
List<OrganizationDO> resultList = organizationDOMapper.getOrgNames(orgCodes);
if(resultList!=null && !resultList.isEmpty()){
for(OrganizationDO entity:resultList){
result.put(entity.getOrgCode(),entity.getOrgName());
}
}
return result;
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.OrganizationEntityDO;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.LinkedHashMap;
import java.util.ArrayList;
import java.util.HashSet;
import com.abssqr.plat.common.dal.mysql.auto.mapper.OrganizationEntityDOMapper;
/**
* The Table abs_organization_entity.
* 机构参与实体
*/
@Repository
public class OrganizationEntityDAO{
@Autowired
private OrganizationEntityDOMapper organizationEntityDOMapper;
/**
* desc:插入表:abs_organization_entity.<br/>
* @param entity entity
* @return int
*/
public int insert(OrganizationEntityDO entity){
return organizationEntityDOMapper.insert(entity);
}
/**
* desc:更新表:abs_organization_entity.<br/>
* @param entity entity
* @return int
*/
public int updateByEntityCode(OrganizationEntityDO entity){
return organizationEntityDOMapper.updateByEntityCode(entity);
}
/**
* desc:根据唯一约束获取数据:abs_organization_entity.<br/>
* @param entityCode entityCode
* @return OrganizationEntityDO
*/
public OrganizationEntityDO getByEntityCode(String entityCode){
return organizationEntityDOMapper.getByEntityCode(entityCode);
}
/**
* desc:根据唯一约束获取数据:abs_organization_entity.<br/>
* @param list list
* @return Map<String,OrganizationEntityDO>
*/
public List<OrganizationEntityDO> getByEntityCodesList(List<String> list){
return organizationEntityDOMapper.getByEntityCodes(list);
}
/**
* desc:根据唯一约束获取数据:abs_organization_entity.<br/>
* @param list list
* @return Map<String,OrganizationEntityDO>
*/
public Map<String,OrganizationEntityDO> getByEntityCodes(List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
Map<String,OrganizationEntityDO> result = new LinkedHashMap();
List<OrganizationEntityDO> resultList = organizationEntityDOMapper.getByEntityCodes(list);
if(resultList!=null && !resultList.isEmpty()){
for(OrganizationEntityDO entity:resultList){
result.put(entity.getEntityCode(),entity);
}
}
return result;
}
/**
* desc:根据服务机构获取放款机构.<br/>
* @param managerOrgCode managerOrgCode
* @return List<OrganizationEntityDO>
*/
public List<OrganizationEntityDO> getByManagerOrgCode(String managerOrgCode){
return organizationEntityDOMapper.getByManagerOrgCode(managerOrgCode);
}
/**
* desc:根据机构编号删除对应机构.<br/>
* @param entityCode entityCode
* @return int
*/
public int deleteByEntityCode(String entityCode){
return organizationEntityDOMapper.deleteByEntityCode(entityCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAcctTitleDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAcctTitleDOMapper;
/**
* The Table abs_plan_acct_title.
* 计划结算科目信息(收付实现制)
*/
@Repository
public class PlanAcctTitleDAO{
@Autowired
private PlanAcctTitleDOMapper planAcctTitleDOMapper;
/**
* desc:插入表:abs_plan_acct_title.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAcctTitleDO entity){
return planAcctTitleDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_acct_title.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanAcctTitleDO> list){
planAcctTitleDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据唯一约束AbsPlanAcctTitle更新表:abs_plan_acct_title.<br/>
* @param entity entity
* @return int
*/
public int updateAmt(PlanAcctTitleDO entity){
return planAcctTitleDOMapper.updateAmt(entity);
}
/**
* desc:根据唯一约束AbsPlanAcctTitle删除数据:abs_plan_acct_title.<br/>
* @param planNo planNo
* @return List<PlanAcctTitleDO>
*/
public List<PlanAcctTitleDO> getByPlan(String planNo){
return planAcctTitleDOMapper.getByPlan(planNo);
}
/**
* desc:根据唯一约束AbsPlanAcctTitle删除数据:abs_plan_acct_title.<br/>
* @param planNo planNo
* @param listTitleType listTitleType
* @return List<PlanAcctTitleDO>
*/
public List<PlanAcctTitleDO> getByPlanAndTypes(String planNo,List<String> listTitleType){
if(listTitleType!=null && listTitleType.size()>201){throw new RuntimeException("listTitleType 超出201长度限制");}
return planAcctTitleDOMapper.getByPlanAndTypes(planNo, listTitleType);
}
/**
* desc:根据唯一约束AbsPlanAcctTitle删除数据:abs_plan_acct_title.<br/>
* @param list list
* @return List<PlanAcctTitleDO>
*/
public List<PlanAcctTitleDO> getFinFeesByPlan(List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planAcctTitleDOMapper.getFinFeesByPlan(list);
}
/**
* desc:根据唯一约束AbsPlanAcctTitle获取数据:abs_plan_acct_title.<br/>
* @param planNo planNo
* @param titleNo titleNo
* @return PlanAcctTitleDO
*/
public PlanAcctTitleDO getByTitleNo(String planNo,String titleNo){
return planAcctTitleDOMapper.getByTitleNo(planNo, titleNo);
}
/**
* desc:根据计划编号删除分配信息.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planAcctTitleDOMapper.deleteByPlanNo(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAcctTitleLogDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAcctTitleLogDOMapper;
/**
* The Table abs_plan_acct_title_log.
* 计划结算科目信息(收付实现制)
*/
@Repository
public class PlanAcctTitleLogDAO{
@Autowired
private PlanAcctTitleLogDOMapper planAcctTitleLogDOMapper;
/**
* desc:批量插入表:abs_plan_acct_title_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanAcctTitleLogDO> list){
planAcctTitleLogDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键获取数据:abs_plan_acct_title_log.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @return List<PlanAcctTitleLogDO>
*/
public List<PlanAcctTitleLogDO> getByDate(Date endDate,Date startDate,String planNo){
return planAcctTitleLogDOMapper.getByDate(endDate, startDate, planNo);
}
/**
* desc:根据主键获取数据:abs_plan_acct_title_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param calcType calcType
* @param acctEvent acctEvent
* @return PlanAcctTitleLogDO
*/
public PlanAcctTitleLogDO getTitleLogByCondition(Date accountDate,String planNo,String calcType,String acctEvent){
return planAcctTitleLogDOMapper.getTitleLogByCondition(accountDate, planNo, calcType, acctEvent);
}
/**
* desc:汇总统计会计日对应科目流水金额.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param acctEvent acctEvent
* @param listTitleType listTitleType
* @return PlanAcctTitleLogDO
*/
public PlanAcctTitleLogDO getSummaryAcctTitleByTypes(Date accountDate,String planNo,String acctEvent,List<String> listTitleType){
if(listTitleType!=null && listTitleType.size()>201){throw new RuntimeException("listTitleType 超出201长度限制");}
return planAcctTitleLogDOMapper.getSummaryAcctTitleByTypes(accountDate, planNo, acctEvent, listTitleType);
}
/**
* desc:根据计划事件码科目编号获取科目流水.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param titleNo titleNo
* @param acctEvent acctEvent
* @return List<PlanAcctTitleLogDO>
*/
public List<PlanAcctTitleLogDO> getByEventAndTitleNo(Date accountDate,String planNo,String titleNo,String acctEvent){
return planAcctTitleLogDOMapper.getByEventAndTitleNo(accountDate, planNo, titleNo, acctEvent);
}
/**
* desc:根据计划与事件码获取科目流水.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param acctEvent acctEvent
* @param listTitleType listTitleType
* @return List<PlanAcctTitleLogDO>
*/
public List<PlanAcctTitleLogDO> getByPlanAndEvent(Date accountDate,String planNo,String acctEvent,List<String> listTitleType){
if(listTitleType!=null && listTitleType.size()>201){throw new RuntimeException("listTitleType 超出201长度限制");}
return planAcctTitleLogDOMapper.getByPlanAndEvent(accountDate, planNo, acctEvent, listTitleType);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAllocDO;
import java.util.List;
import java.util.Date;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAllocDOMapper;
/**
* The Table abs_plan_alloc.
* 计划-分配计划
*/
@Repository
public class PlanAllocDAO{
@Autowired
private PlanAllocDOMapper planAllocDOMapper;
/**
* desc:插入表:abs_plan_alloc.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAllocDO entity){
return planAllocDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_alloc.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanAllocDO> list){
planAllocDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:更新表:abs_plan_alloc.<br/>
* @param entity entity
* @return int
*/
public int updateByAllocNo(PlanAllocDO entity){
return planAllocDOMapper.updateByAllocNo(entity);
}
/**
* desc:根据AllocNo删除数据:abs_plan_alloc.<br/>
* @param allocNo allocNo
* @return int
*/
public int deleteByAllocNo(String allocNo){
return planAllocDOMapper.deleteByAllocNo(allocNo);
}
/**
* desc:根据主键获取数据:abs_plan_alloc.<br/>
* @param allocNo allocNo
* @return PlanAllocDO
*/
public PlanAllocDO getByAllocNo(String allocNo){
return planAllocDOMapper.getByAllocNo(allocNo);
}
/**
* desc:更新状态.<br/>
* @param status status
* @param allocNo allocNo
* @param oldStatus oldStatus
* @return int
*/
public int updateStatus(String status,String allocNo,String oldStatus){
return planAllocDOMapper.updateStatus(status, allocNo, oldStatus);
}
/**
* desc:根据主键获取数据:abs_plan_alloc.<br/>
* @param planNo planNo
* @return List<PlanAllocDO>
*/
public List<PlanAllocDO> queryByPlanNo(String planNo){
return planAllocDOMapper.queryByPlanNo(planNo);
}
/**
* desc:根据计划编号获取时间段分配金额.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @param status status
* @return List<PlanAllocDO>
*/
public List<PlanAllocDO> queryAllocByPlanNo(Date endDate,Date startDate,String planNo,String status){
return planAllocDOMapper.queryAllocByPlanNo(endDate, startDate, planNo, status);
}
/**
* desc:根据兑付日获取查询最近计划:abs_plan_alloc.<br/>
* @param planType planType
* @return PlanAllocDO
*/
public PlanAllocDO queryRecentlyPlans(String planType){
return planAllocDOMapper.queryRecentlyPlans(planType);
}
/**
* desc:查询相同结算日分配计划数量.<br/>
* @param clearDate clearDate
* @param planNo planNo
* @param allocNo allocNo
* @return int
*/
public int querySameClearDate(Date clearDate,String planNo,String allocNo){
return planAllocDOMapper.querySameClearDate(clearDate, planNo, allocNo);
}
/**
* desc:根据主键获取数据:abs_plan_alloc.<br/>
* @param allocNo allocNo
* @return PlanAllocDO
*/
public PlanAllocDO lockByAllocNo(String allocNo){
return planAllocDOMapper.lockByAllocNo(allocNo);
}
/**
* desc:获取所有已审批通过未解绑的兑付计划.<br/>
* @param planNo planNo
* @return List<PlanAllocDO>
*/
public List<PlanAllocDO> queryUnMatchedApprovedAlloc(String planNo){
return planAllocDOMapper.queryUnMatchedApprovedAlloc(planNo);
}
/**
* desc:根据计划编号获取时间段分配金额.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @param status status
* @param approveStatus approveStatus
* @return Long
*/
public Long queryStatAllocAmtByPlanNoAndPayDate(Date endDate,Date startDate,String planNo,String status,String approveStatus){
return planAllocDOMapper.queryStatAllocAmtByPlanNoAndPayDate(endDate, startDate, planNo, status, approveStatus);
}
/**
* desc:根据计划编号获取累计分配金额.<br/>
* @param endDate endDate
* @param startDate startDate
* @param status status
* @param approveStatus approveStatus
* @param listPlanNos listPlanNos
* @return Long
*/
public Long queryStatTotalAllocAmtByPlanNos(Date endDate,Date startDate,String status,String approveStatus,List<String> listPlanNos){
if(listPlanNos!=null && listPlanNos.size()>201){throw new RuntimeException("listPlanNos 超出201长度限制");}
return planAllocDOMapper.queryStatTotalAllocAmtByPlanNos(endDate, startDate, status, approveStatus, listPlanNos);
}
/**
* desc:根据计划编号删除分配方案.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planAllocDOMapper.deleteByPlanNo(planNo);
}
/**
* desc:查询已审批未兑付的分配计划.<br/>
* @param planNo planNo
* @return List<PlanAllocDO>
*/
public List<PlanAllocDO> queryApprovedNotPayAlloc(String planNo){
return planAllocDOMapper.queryApprovedNotPayAlloc(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAllocFrozenDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAllocFrozenDOMapper;
/**
* The Table abs_plan_alloc_frozen.
* ABS_PLAN_ALLOC_FROZEN
*/
@Repository
public class PlanAllocFrozenDAO{
@Autowired
private PlanAllocFrozenDOMapper planAllocFrozenDOMapper;
/**
* desc:插入表:abs_plan_alloc_frozen.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAllocFrozenDO entity){
return planAllocFrozenDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_alloc_frozen.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanAllocFrozenDO> list){
planAllocFrozenDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:更新表:abs_plan_alloc_frozen.<br/>
* @param entity entity
* @return int
*/
public int update(PlanAllocFrozenDO entity){
return planAllocFrozenDOMapper.update(entity);
}
/**
* desc:根据主键删除数据:abs_plan_alloc_frozen.<br/>
* @param planNo planNo
* @param allocNo allocNo
* @return int
*/
public int deleteByAllocNo(String planNo,String allocNo){
return planAllocFrozenDOMapper.deleteByAllocNo(planNo, allocNo);
}
/**
* desc:根据主键获取数据:abs_plan_alloc_frozen.<br/>
* @param planNo planNo
* @param allocNo allocNo
* @return PlanAllocFrozenDO
*/
public PlanAllocFrozenDO getByAllocNo(String planNo,String allocNo){
return planAllocFrozenDOMapper.getByAllocNo(planNo, allocNo);
}
/**
* desc:根据主键获取数据:abs_plan_alloc_frozen.<br/>
* @param planNo planNo
* @return List<PlanAllocFrozenDO>
*/
public List<PlanAllocFrozenDO> getByPlanNo(String planNo){
return planAllocFrozenDOMapper.getByPlanNo(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAllocItemDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.PlanAllocItemResultMap;
import java.util.Map;
import java.util.Set;
import java.util.LinkedHashMap;
import java.util.ArrayList;
import java.util.HashSet;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAllocItemDOMapper;
/**
* The Table abs_plan_alloc_item.
* 分配事项
*/
@Repository
public class PlanAllocItemDAO{
@Autowired
private PlanAllocItemDOMapper planAllocItemDOMapper;
/**
* desc:插入表:abs_plan_alloc_item.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAllocItemDO entity){
return planAllocItemDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_alloc_item.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanAllocItemDO> list){
planAllocItemDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键删除数据:abs_plan_alloc_item.<br/>
* @param id id
* @return int
*/
public int deleteById(Long id){
return planAllocItemDOMapper.deleteById(id);
}
/**
* desc:根据主键获取数据:abs_plan_alloc_item.<br/>
* @param id id
* @return PlanAllocItemDO
*/
public PlanAllocItemDO getById(Long id){
return planAllocItemDOMapper.getById(id);
}
/**
* desc:根据唯一约束ItemNo更新表:abs_plan_alloc_item.<br/>
* @param entity entity
* @return int
*/
public int updateByItemNo(PlanAllocItemDO entity){
return planAllocItemDOMapper.updateByItemNo(entity);
}
/**
* desc:根据唯一约束ItemNo删除数据:abs_plan_alloc_item.<br/>
* @param itemNo itemNo
* @return int
*/
public int deleteByItemNo(String itemNo){
return planAllocItemDOMapper.deleteByItemNo(itemNo);
}
/**
* desc:根据唯一约束ItemNo获取数据:abs_plan_alloc_item.<br/>
* @param itemNo itemNo
* @return PlanAllocItemDO
*/
public PlanAllocItemDO getByItemNo(String itemNo){
return planAllocItemDOMapper.getByItemNo(itemNo);
}
/**
* desc:根据计划编号获取分配事项.<br/>
* @param planNo planNo
* @return Map<String,List<PlanAllocItemResultMap>>
*/
public List<PlanAllocItemResultMap> getByPlanNoList(String planNo){
return planAllocItemDOMapper.getByPlanNo(planNo);
}
/**
* desc:根据计划编号获取分配事项.<br/>
* @param planNo planNo
* @return Map<String,List<PlanAllocItemResultMap>>
*/
public Map<String,List<PlanAllocItemResultMap>> getByPlanNo(String planNo){
Map<String,List<PlanAllocItemResultMap>> result = new LinkedHashMap();
List<PlanAllocItemResultMap> resultList = planAllocItemDOMapper.getByPlanNo(planNo);
if(resultList!=null && !resultList.isEmpty()){
for(PlanAllocItemResultMap entity:resultList){
List<PlanAllocItemResultMap> vList = result.get(entity.getAllocNo());
if(vList == null){
vList = new ArrayList();
result.put(entity.getAllocNo(),vList);
}
vList.add(entity);
}
}
return result;
}
/**
* desc:根据分配编号获取分配事项.<br/>
* @param allocNo allocNo
* @return Map<String,Long>
*/
public List<PlanAllocItemResultMap> getByAllocNoList(String allocNo){
return planAllocItemDOMapper.getByAllocNo(allocNo);
}
/**
* desc:根据分配编号获取分配事项.<br/>
* @param allocNo allocNo
* @return Map<String,Long>
*/
public Map<String,Long> getByAllocNo(String allocNo){
Map<String,Long> result = new LinkedHashMap();
List<PlanAllocItemResultMap> resultList = planAllocItemDOMapper.getByAllocNo(allocNo);
if(resultList!=null && !resultList.isEmpty()){
for(PlanAllocItemResultMap entity:resultList){
result.put(entity.getTitleNo(),entity.getSettleAmt());
}
}
return result;
}
/**
* desc:根据allocNo删除数据:abs_plan_alloc_item.<br/>
* @param allocNo allocNo
* @return int
*/
public int deleteByAllocNo(String allocNo){
return planAllocItemDOMapper.deleteByAllocNo(allocNo);
}
/**
* desc:根据planNo删除数据.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planAllocItemDOMapper.deleteByPlanNo(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAstDO;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAstDOMapper;
/**
* The Table abs_plan_ast.
* 计划资产水位表
*/
@Repository
public class PlanAstDAO{
@Autowired
private PlanAstDOMapper planAstDOMapper;
/**
* desc:插入表:abs_plan_ast.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAstDO entity){
return planAstDOMapper.insert(entity);
}
/**
* desc:根据唯一约束AbsPlanAstPlanNo更新表:ABS_PLAN_AST.<br/>
* @param entity entity
* @return int
*/
public int updateByPlanNo(PlanAstDO entity){
return planAstDOMapper.updateByPlanNo(entity);
}
/**
* desc:根据 PLAN_NO 锁定计划资产水位表.<br/>
* @param planNo planNo
* @return PlanAstDO
*/
public PlanAstDO lockByPlanNoForUpdate(String planNo){
return planAstDOMapper.lockByPlanNoForUpdate(planNo);
}
/**
* desc:根据 PLAN_NO 查询计划n资产水位表.<br/>
* @param planNo planNo
* @return PlanAstDO
*/
public PlanAstDO getByPlanNo(String planNo){
return planAstDOMapper.getByPlanNo(planNo);
}
/**
* desc:查询累计投放金额合计.<br/>
* @param planType planType
* @return Long
*/
public Long getAllAstAmt(String planType){
return planAstDOMapper.getAllAstAmt(planType);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAstLogDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.PlanStatItem;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.AstLogAmt;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAstLogDOMapper;
/**
* The Table abs_plan_ast_log.
* 计划资产水位变更流水
*/
@Repository
public class PlanAstLogDAO{
@Autowired
private PlanAstLogDOMapper planAstLogDOMapper;
/**
* desc:插入表:abs_plan_ast_log.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAstLogDO entity){
return planAstLogDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_ast_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanAstLogDO> list){
planAstLogDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @param transCode transCode
* @param changeType changeType
* @return List<PlanStatItem>
*/
public List<PlanStatItem> getStatByTransCode(Date endDate,Date startDate,String planNo,String transCode,String changeType){
return planAstLogDOMapper.getStatByTransCode(endDate, startDate, planNo, transCode, changeType);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PlanStatItem>
*/
public List<PlanStatItem> getAstLogStat(Date accountDate,String planNo){
return planAstLogDOMapper.getAstLogStat(accountDate, planNo);
}
/**
* desc:获取水位变化总额.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transCode transCode
* @return List<AstLogAmt>
*/
public List<AstLogAmt> getAmtByPlanNoAndActDateAndTransCode(Date accountDate,String planNo,String transCode){
return planAstLogDOMapper.getAmtByPlanNoAndActDateAndTransCode(accountDate, planNo, transCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAstPriceRuleDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAstPriceRuleDOMapper;
/**
* The Table abs_plan_ast_price_rule.
* 资产定价规则
*/
@Repository
public class PlanAstPriceRuleDAO{
@Autowired
private PlanAstPriceRuleDOMapper planAstPriceRuleDOMapper;
/**
* desc:插入表:abs_plan_ast_price_rule.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAstPriceRuleDO entity){
return planAstPriceRuleDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_ast_price_rule.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanAstPriceRuleDO> list){
planAstPriceRuleDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键删除数据:abs_plan_ast_price_rule.<br/>
* @param id id
* @return int
*/
public int deleteById(Long id){
return planAstPriceRuleDOMapper.deleteById(id);
}
/**
* desc:根据主键获取数据:abs_plan_ast_price_rule.<br/>
* @param id id
* @return PlanAstPriceRuleDO
*/
public PlanAstPriceRuleDO getById(Long id){
return planAstPriceRuleDOMapper.getById(id);
}
/**
* desc:根据普通索引PriceRulePlanNo获取数据:abs_plan_ast_price_rule.<br/>
* @param planNo planNo
* @return List<PlanAstPriceRuleDO>
*/
public List<PlanAstPriceRuleDO> queryByPriceRulePlanNo(String planNo){
return planAstPriceRuleDOMapper.queryByPriceRulePlanNo(planNo);
}
/**
* desc:根据计划编号删除数据:deleteByPlanNo.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planAstPriceRuleDOMapper.deleteByPlanNo(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanAstStatTaskDO;
import java.util.Date;
import java.util.List;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanAstStatTaskDOMapper;
/**
* The Table abs_plan_ast_stat_task.
* 计划资产状态汇总任务
*/
@Repository
public class PlanAstStatTaskDAO{
@Autowired
private PlanAstStatTaskDOMapper planAstStatTaskDOMapper;
/**
* desc:插入表:abs_plan_ast_stat_task.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanAstStatTaskDO entity){
return planAstStatTaskDOMapper.insert(entity);
}
/**
* desc:根据主键获取数据:abs_plan_ast_stat_task.<br/>
* @param planNo planNo
* @return PlanAstStatTaskDO
*/
public PlanAstStatTaskDO lockByPlanNo(String planNo){
return planAstStatTaskDOMapper.lockByPlanNo(planNo);
}
/**
* desc:根据唯一约束AbsAstStatTask更新表:abs_plan_ast_stat_task.<br/>
* @param entity entity
* @return int
*/
public int updateTask(PlanAstStatTaskDO entity){
return planAstStatTaskDOMapper.updateTask(entity);
}
/**
* desc:根据ip重置任务.<br/>
* @param lastHost lastHost
* @return int
*/
public int updateHangTasksByIp(String lastHost){
return planAstStatTaskDOMapper.updateHangTasksByIp(lastHost);
}
/**
* desc:根据唯一约束AbsAstStatTask获取数据:abs_plan_ast_stat_task.<br/>
* @param planNo planNo
* @return PlanAstStatTaskDO
*/
public PlanAstStatTaskDO getByPlanNo(String planNo){
return planAstStatTaskDOMapper.getByPlanNo(planNo);
}
/**
* desc:根据唯一约束AbsAstStatTask获取数据:abs_plan_ast_stat_task.<br/>
* @param curTime curTime
* @param limit limit
* @return List<PlanAstStatTaskDO>
*/
public List<PlanAstStatTaskDO> getToDo(Date curTime,Integer limit){
return planAstStatTaskDOMapper.getToDo(curTime, limit);
}
/**
* desc:更新任务为执行中.<br/>
* @param lastExecTime lastExecTime
* @param lastHost lastHost
* @param planNos planNos
* @return int
*/
public int updateTaskExec(Date lastExecTime,String lastHost,List<String> planNos){
if(planNos!=null && planNos.size()>201){throw new RuntimeException("planNos 超出201长度限制");}
return planAstStatTaskDOMapper.updateTaskExec(lastExecTime, lastHost, planNos);
}
/**
* desc:重置状态,更新下次执行时间.<br/>
* @param nextExecTime nextExecTime
* @param planNo planNo
* @return int
*/
public int updateTaskExep(Date nextExecTime,String planNo){
return planAstStatTaskDOMapper.updateTaskExep(nextExecTime, planNo);
}
/**
* desc:查询执行次数超次数的统计任务.<br/>
* @param execTimes execTimes
* @return List<PlanAstStatTaskDO>
*/
public List<PlanAstStatTaskDO> queryFailStatTask(Long execTimes){
return planAstStatTaskDOMapper.queryFailStatTask(execTimes);
}
/**
* desc:根据状态计数.<br/>
* @param deadLine deadLine
* @param status status
* @return Long
*/
public Long countByStatusAndTime(Date deadLine,String status){
return planAstStatTaskDOMapper.countByStatusAndTime(deadLine, status);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanCapitalLogDO;
import com.abssqr.plat.common.dal.mysql.auto.paging.PlanCapitalLogListPage;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanCapitalLogDOMapper;
/**
* The Table abs_plan_capital_log.
* 计划资金交易流水
*/
@Repository
public class PlanCapitalLogDAO{
@Autowired
private PlanCapitalLogDOMapper planCapitalLogDOMapper;
/**
* desc:插入表:abs_plan_capital_log.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanCapitalLogDO entity){
return planCapitalLogDOMapper.insert(entity);
}
/**
* desc:根据唯一约束AbsPlanCapitalLog获取数据:abs_plan_capital_log.<br/>
* @param planCapitalLogList planCapitalLogList
* @return PlanCapitalLogListPage
*/
public PlanCapitalLogListPage getForPage(PlanCapitalLogListPage planCapitalLogList){
int total = planCapitalLogDOMapper.getForPageCount(planCapitalLogList);
if(total>0){
planCapitalLogList.setDatas(planCapitalLogDOMapper.getForPageResult(planCapitalLogList));
}else{
planCapitalLogList.setDatas(new ArrayList());
}
planCapitalLogList.setTotal(total);
return planCapitalLogList;
}
/**
* desc:根据唯一约束AbsPlanCapitalLog获取数据:abs_plan_capital_log.<br/>
* @param seqNo seqNo
* @param planNo planNo
* @return PlanCapitalLogDO
*/
public PlanCapitalLogDO getBySeqNo(String seqNo,String planNo){
return planCapitalLogDOMapper.getBySeqNo(seqNo, planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanCapitalOrderDO;
import java.util.List;
import java.util.Date;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.paging.PlanCapitalOrderPage;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.CapitalOrderAmt;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanCapitalOrderDOMapper;
/**
* The Table abs_plan_capital_order.
* 计划资金交易订单
*/
@Repository
public class PlanCapitalOrderDAO{
@Autowired
private PlanCapitalOrderDOMapper planCapitalOrderDOMapper;
/**
* desc:插入表:ABS_PLAN_CAPITAL_ORDER.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanCapitalOrderDO entity){
return planCapitalOrderDOMapper.insert(entity);
}
/**
* desc:插入表:ABS_PLAN_CAPITAL_ORDER.<br/>
* @param entity entity
* @return int
*/
public int insertHis(PlanCapitalOrderDO entity){
return planCapitalOrderDOMapper.insertHis(entity);
}
/**
* desc:批量插入表:ABS_PLAN_CAPITAL_ORDER.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanCapitalOrderDO> list){
planCapitalOrderDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据唯一约束AbsPlanCapitalOrdr更新表:ABS_PLAN_CAPITAL_ORDER.<br/>
* @param entity entity
* @return int
*/
public int updateProcess(PlanCapitalOrderDO entity){
return planCapitalOrderDOMapper.updateProcess(entity);
}
/**
* desc:失败的交易重新发起.<br/>
* @param nextExecTime nextExecTime
* @param seqNo seqNo
* @return PlanCapitalOrderDO
*/
public PlanCapitalOrderDO restoreCapitalOrder(Date nextExecTime,String seqNo){
return planCapitalOrderDOMapper.restoreCapitalOrder(nextExecTime, seqNo);
}
/**
* desc:根据唯一约束AbsPlanCapitalOrdr删除数据:ABS_PLAN_CAPITAL_ORDER.<br/>
* @param seqNo seqNo
* @param planNo planNo
* @return int
*/
public int deleteBySeqno(String seqNo,String planNo){
return planCapitalOrderDOMapper.deleteBySeqno(seqNo, planNo);
}
/**
* desc:根据唯一约束AbsPlanCapitalLog获取数据:abs_plan_capital_log.<br/>
* @param seqNo seqNo
* @return PlanCapitalOrderDO
*/
public PlanCapitalOrderDO lockBySeqno(String seqNo){
return planCapitalOrderDOMapper.lockBySeqno(seqNo);
}
/**
* desc:根据唯一约束AbsPlanCapitalLog获取数据:abs_plan_capital_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transType transType
* @return PlanCapitalOrderDO
*/
public PlanCapitalOrderDO lockActiveByPlanNo(Date accountDate,String planNo,String transType){
return planCapitalOrderDOMapper.lockActiveByPlanNo(accountDate, planNo, transType);
}
/**
* desc:根据唯一约束AbsPlanCapitalLog获取数据:abs_plan_capital_log.<br/>
* @param planNo planNo
* @return List<PlanCapitalOrderDO>
*/
public List<PlanCapitalOrderDO> getInitListByPlanNo(String planNo){
return planCapitalOrderDOMapper.getInitListByPlanNo(planNo);
}
/**
* desc:查询存活支付单条数.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transType transType
* @param list list
* @return Long
*/
public Long getActiveCntByCondition(Date accountDate,String planNo,String transType,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planCapitalOrderDOMapper.getActiveCntByCondition(accountDate, planNo, transType, list);
}
/**
* desc:根据状态分页查询订单.<br/>
* @param planCapitalOrder planCapitalOrder
* @return PlanCapitalOrderPage
*/
public PlanCapitalOrderPage getCapitalOrderByStatus(PlanCapitalOrderPage planCapitalOrder){
int total = planCapitalOrderDOMapper.getCapitalOrderByStatusCount(planCapitalOrder);
if(total>0){
planCapitalOrder.setDatas(planCapitalOrderDOMapper.getCapitalOrderByStatusResult(planCapitalOrder));
}else{
planCapitalOrder.setDatas(new ArrayList());
}
planCapitalOrder.setTotal(total);
return planCapitalOrder;
}
/**
* desc:查询执行次数较多的交易单.<br/>
* @param accountDate accountDate
* @param execTimes execTimes
* @param list list
* @return List<PlanCapitalOrderDO>
*/
public List<PlanCapitalOrderDO> queryFailCapitalOrder(Date accountDate,Long execTimes,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planCapitalOrderDOMapper.queryFailCapitalOrder(accountDate, execTimes, list);
}
/**
* desc:查询失败数量.<br/>
* @param execTimes execTimes
* @return Long
*/
public Long getFailCount(Long execTimes){
return planCapitalOrderDOMapper.getFailCount(execTimes);
}
/**
* desc:根据外部交易编码查询交易单用来做mock数据.<br/>
* @param status status
* @param noList noList
* @return List<PlanCapitalOrderDO>
*/
public List<PlanCapitalOrderDO> queryOrderListByOutAcptNo(String status,List<String> noList){
if(noList!=null && noList.size()>201){throw new RuntimeException("noList 超出201长度限制");}
return planCapitalOrderDOMapper.queryOrderListByOutAcptNo(status, noList);
}
/**
* desc:根据计划编号查询支付金额和交易金额.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transType transType
* @return CapitalOrderAmt
*/
public CapitalOrderAmt getHisAmtByPlanNoAndActDateAndTransCode(Date accountDate,String planNo,String transType){
return planCapitalOrderDOMapper.getHisAmtByPlanNoAndActDateAndTransCode(accountDate, planNo, transType);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanClearingLogDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.LoanClearingLogStat;
import com.abssqr.plat.common.dal.base.StatEntity;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanClearingLogDOMapper;
/**
* The Table abs_plan_clearing_log.
* ABS_PLAN_CLEARING_LOG
*/
@Repository
public class PlanClearingLogDAO{
@Autowired
private PlanClearingLogDOMapper planClearingLogDOMapper;
/**
* desc:插入表:abs_plan_clearing_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanClearingLogDO> list){
planClearingLogDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param maxId maxId
* @param minId minId
* @param planNo planNo
* @param execTms execTms
* @return List<LoanClearingLogStat>
*/
public List<LoanClearingLogStat> stat(Date accountDate,Long maxId,Long minId,String planNo,String execTms){
return planClearingLogDOMapper.stat(accountDate, maxId, minId, planNo, execTms);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param maxId maxId
* @param minId minId
* @param planNo planNo
* @param execTms execTms
* @return int
*/
public int deleteStated(Date accountDate,Long maxId,Long minId,String planNo,String execTms){
return planClearingLogDOMapper.deleteStated(accountDate, maxId, minId, planNo, execTms);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param execTms execTms
* @return StatEntity
*/
public StatEntity getStatInx(Date accountDate,String planNo,String execTms){
return planClearingLogDOMapper.getStatInx(accountDate, planNo, execTms);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param planNo planNo
* @param transCode transCode
* @return Date
*/
public Date getMinUnStateAccountDate(String planNo,String transCode){
return planClearingLogDOMapper.getMinUnStateAccountDate(planNo, transCode);
}
/**
* desc:查看清算流水是否都处理完.<br/>
* @param planNo planNo
* @return Long
*/
public Long cntInitClearingLogByPlanNo(String planNo){
return planClearingLogDOMapper.cntInitClearingLogByPlanNo(planNo);
}
/**
* desc:查看清算流水是否都处理完.<br/>
* @param transCode transCode
* @return Long
*/
public Long cntInitClearingLog(String transCode){
return planClearingLogDOMapper.cntInitClearingLog(transCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.LoanClearingLogStat;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.ClearingLogCntAndId;
import com.general.system.common.model.Money;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanClearingLogHisDOMapper;
/**
* The Table abs_plan_clearing_log_his.
* ABS_PLAN_CLEARING_LOG_HIS
*/
@Repository
public class PlanClearingLogHisDAO{
@Autowired
private PlanClearingLogHisDOMapper planClearingLogHisDOMapper;
/**
* desc:插入表:abs_plan_clearing_log_his.<br/>
* @param execTms execTms
* @param clearingSeqNo clearingSeqNo
* @param stat stat
* @return int
*/
public int insertForBak(String execTms,String clearingSeqNo,LoanClearingLogStat stat){
return planClearingLogHisDOMapper.insertForBak(execTms, clearingSeqNo, stat);
}
/**
* desc:获取计划最大id和总数.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transCode transCode
* @return ClearingLogCntAndId
*/
public ClearingLogCntAndId getCntAndMaxIdByPlanNoAndActDateAndTransCode(Date accountDate,String planNo,String transCode){
return planClearingLogHisDOMapper.getCntAndMaxIdByPlanNoAndActDateAndTransCode(accountDate, planNo, transCode);
}
/**
* desc:获取计划清算总额.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transCode transCode
* @return Money
*/
public Money getClearAmtByPlanNoAndActDateAndTransCode(Date accountDate,String planNo,String transCode){
return planClearingLogHisDOMapper.getClearAmtByPlanNoAndActDateAndTransCode(accountDate, planNo, transCode);
}
/**
* desc:根据对手方编号获取计划清算总额.<br/>
* @param accountDate accountDate
* @param transCode transCode
* @param cntPtyCode cntPtyCode
* @return Money
*/
public Money getClearAmtByCntPtyCodeAndActDateAndTransCode(Date accountDate,String transCode,String cntPtyCode){
return planClearingLogHisDOMapper.getClearAmtByCntPtyCodeAndActDateAndTransCode(accountDate, transCode, cntPtyCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanClearingOrderDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.PlanClearingOrderItem;
import java.lang.Long;
import com.general.system.common.model.Money;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanClearingOrderDOMapper;
/**
* The Table abs_plan_clearing_order.
* ABS_PLAN_CLEARING_ORDER
*/
@Repository
public class PlanClearingOrderDAO{
@Autowired
private PlanClearingOrderDOMapper planClearingOrderDOMapper;
/**
* desc:插入表:abs_plan_clearing_order.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanClearingOrderDO entity){
return planClearingOrderDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_clearing_order.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanClearingOrderDO> list){
planClearingOrderDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:更新表:abs_plan_clearing_order.<br/>
* @param memo memo
* @param transStatus transStatus
* @param transOrderNo transOrderNo
* @param oldTransStatus oldTransStatus
* @param list list
* @return int
*/
public int updateBySeqNoList(String memo,String transStatus,String transOrderNo,String oldTransStatus,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planClearingOrderDOMapper.updateBySeqNoList(memo, transStatus, transOrderNo, oldTransStatus, list);
}
/**
* desc:更新表:abs_plan_clearing_order.<br/>
* @param memo memo
* @param seqNo seqNo
* @param transStatus transStatus
* @param transOrderNo transOrderNo
* @param oldTransStatus oldTransStatus
* @return int
*/
public int updateBySeqNo(String memo,String seqNo,String transStatus,String transOrderNo,String oldTransStatus){
return planClearingOrderDOMapper.updateBySeqNo(memo, seqNo, transStatus, transOrderNo, oldTransStatus);
}
/**
* desc:更新表:abs_plan_clearing_order.<br/>
* @param seqNo seqNo
* @return PlanClearingOrderDO
*/
public PlanClearingOrderDO lockBySeqNo(String seqNo){
return planClearingOrderDOMapper.lockBySeqNo(seqNo);
}
/**
* desc:根据普通索引AbsPlanClearingLogCopy1获取数据:abs_plan_clearing_order.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transStatus transStatus
* @return List<PlanClearingOrderItem>
*/
public List<PlanClearingOrderItem> queryByClearingOrderStat(Date accountDate,String planNo,String transStatus){
return planClearingOrderDOMapper.queryByClearingOrderStat(accountDate, planNo, transStatus);
}
/**
* desc:查看结算单是否都处理完.<br/>
* @param planNo planNo
* @return Long
*/
public Long cntInitClearingOrderByPlanNo(String planNo){
return planClearingOrderDOMapper.cntInitClearingOrderByPlanNo(planNo);
}
/**
* desc:查看结算单是否都处理完.<br/>
* @param transCode transCode
* @return Long
*/
public Long cntInitClearingOrder(String transCode){
return planClearingOrderDOMapper.cntInitClearingOrder(transCode);
}
/**
* desc:获取结算总额.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param transCode transCode
* @return Money
*/
public Money getClrOrderAmtByPlanNoAndActDateAndTransCode(Date accountDate,String planNo,String transCode){
return planClearingOrderDOMapper.getClrOrderAmtByPlanNoAndActDateAndTransCode(accountDate, planNo, transCode);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanDO;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.LinkedHashMap;
import java.util.ArrayList;
import java.util.HashSet;
import com.abssqr.plat.common.dal.mysql.auto.paging.PlanListPage;
import java.lang.Long;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.AstServiceReport;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanDOMapper;
/**
* The Table abs_plan.
* 计划信息
*/
@Repository
public class PlanDAO{
@Autowired
private PlanDOMapper planDOMapper;
/**
* desc:插入表:abs_plan.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanDO entity){
return planDOMapper.insert(entity);
}
/**
* desc:根据唯一约束PlanNo更新表:abs_plan.<br/>
* @param entity entity
* @return int
*/
public int updateByPlanNo(PlanDO entity){
return planDOMapper.updateByPlanNo(entity);
}
/**
* desc:根据唯一约束PlanNo更新表:abs_plan.<br/>
* @param planNo planNo
* @param status status
* @param gmtModifier gmtModifier
* @param approveStatus approveStatus
* @return int
*/
public int updateStatusByPlanNo(String planNo,String status,String gmtModifier,String approveStatus){
return planDOMapper.updateStatusByPlanNo(planNo, status, gmtModifier, approveStatus);
}
/**
* desc:根据唯一约束PlanNo修改状态:abs_plan.<br/>
* @param planNo planNo
* @param passed passed
* @return int
*/
public int updatePassed(String planNo,Boolean passed){
return planDOMapper.updatePassed(planNo, passed);
}
/**
* desc:根据唯一约束PlanNo删除数据:abs_plan.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planDOMapper.deleteByPlanNo(planNo);
}
/**
* desc:根据唯一约束PlanNo获取数据:abs_plan.<br/>
* @param planNo planNo
* @return PlanDO
*/
public PlanDO getByPlanNo(String planNo){
return planDOMapper.getByPlanNo(planNo);
}
/**
* desc:根据唯一约束PlanNo获取数据:abs_plan.<br/>
* @param planNo planNo
* @return PlanDO
*/
public PlanDO lockByPlanNo(String planNo){
return planDOMapper.lockByPlanNo(planNo);
}
/**
* desc:根据唯一约束PlanNo获取数据:abs_plan.<br/>
* @param list list
* @return Map<String,String>
*/
public List<PlanDO> queryByPlanNoList(List<String> list){
return planDOMapper.queryByPlanNo(list);
}
/**
* desc:根据唯一约束PlanNo获取数据:abs_plan.<br/>
* @param list list
* @return Map<String,String>
*/
public Map<String,String> queryByPlanNo(List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
Map<String,String> result = new LinkedHashMap();
List<PlanDO> resultList = planDOMapper.queryByPlanNo(list);
if(resultList!=null && !resultList.isEmpty()){
for(PlanDO entity:resultList){
result.put(entity.getPlanNo(),entity.getPlanName());
}
}
return result;
}
/**
* desc:新增判断计划是否存在.<br/>
* @param planNo planNo
* @param planName planName
* @return Integer
*/
public Integer planExist(String planNo,String planName){
return planDOMapper.planExist(planNo, planName);
}
/**
* desc:编辑判断计划是否存在.<br/>
* @param planNo planNo
* @param planName planName
* @return Integer
*/
public Integer getSamePlan(String planNo,String planName){
return planDOMapper.getSamePlan(planNo, planName);
}
/**
* desc:分页查询计划.<br/>
* @param planList planList
* @return PlanListPage
*/
public PlanListPage getPlanList(PlanListPage planList){
int total = planDOMapper.getPlanListCount(planList);
if(total>0){
planList.setDatas(planDOMapper.getPlanListResult(planList));
}else{
planList.setDatas(new ArrayList());
}
planList.setTotal(total);
return planList;
}
/**
* desc:根据状态数组获取计划列表.<br/>
* @param planType planType
* @param planNos planNos
* @param statusList statusList
* @return List<PlanDO>
*/
public List<PlanDO> getPlansByStatusList(String planType,List<String> planNos,List<String> statusList){
if(planNos!=null && planNos.size()>201){throw new RuntimeException("planNos 超出201长度限制");}
if(statusList!=null && statusList.size()>201){throw new RuntimeException("statusList 超出201长度限制");}
return planDOMapper.getPlansByStatusList(planType, planNos, statusList);
}
/**
* desc:根据状态数组获取计划列表.<br/>
* @param status status
* @param planType planType
* @return Long
*/
public Long getAllPlanAmt(String status,String planType){
return planDOMapper.getAllPlanAmt(status, planType);
}
/**
* desc:查询资产服务报告.<br/>
* @param planNo planNo
* @return AstServiceReport
*/
public AstServiceReport getAstServiceReport(String planNo){
return planDOMapper.getAstServiceReport(planNo);
}
/**
* desc:根据服务机构获取存续期受让计划.<br/>
* @param managerOrgCode managerOrgCode
* @return List<PlanDO>
*/
public List<PlanDO> getSpvByManagerOrgCode(String managerOrgCode){
return planDOMapper.getSpvByManagerOrgCode(managerOrgCode);
}
/**
* desc:查询每日任务失败的数量.<br/>
* @param curDate curDate
* @return Long
*/
public Long getFailDailyCount(Date curDate){
return planDOMapper.getFailDailyCount(curDate);
}
/**
* desc:更新定价规则.<br/>
* @param planNo planNo
* @param priceType priceType
* @return int
*/
public int updatePriceType(String planNo,String priceType){
return planDOMapper.updatePriceType(planNo, priceType);
}
/**
* desc:根据类型获取所有的计划.<br/>
* @param planType planType
* @return List<PlanDO>
*/
public List<PlanDO> getAllPlanByType(String planType){
return planDOMapper.getAllPlanByType(planType);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanFeeStructureDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanFeeStructureDOMapper;
/**
* The Table abs_plan_fee_structure.
* 计划费用结构
*/
@Repository
public class PlanFeeStructureDAO{
@Autowired
private PlanFeeStructureDOMapper planFeeStructureDOMapper;
/**
* desc:批量插入表:abs_plan_fee_structure.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanFeeStructureDO> list){
planFeeStructureDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据计划编号删除数据:abs_plan_fee_structure.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planFeeStructureDOMapper.deleteByPlanNo(planNo);
}
/**
* desc:根据计划编号获取数据:abs_plan_fee_structure.<br/>
* @param planNo planNo
* @return List<PlanFeeStructureDO>
*/
public List<PlanFeeStructureDO> selectByPlanNo(String planNo){
return planFeeStructureDOMapper.selectByPlanNo(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanFundFileDO;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanFundFileDOMapper;
/**
* The Table abs_plan_fund_file.
* 资金计划文件信息
*/
@Repository
public class PlanFundFileDAO{
@Autowired
private PlanFundFileDOMapper planFundFileDOMapper;
/**
* desc:插入表:abs_plan_fund_file.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanFundFileDO entity){
return planFundFileDOMapper.insert(entity);
}
/**
* desc:根据主键删除数据:abs_plan_fund_file.<br/>
* @param id id
* @return int
*/
public int deleteById(Long id){
return planFundFileDOMapper.deleteById(id);
}
/**
* desc:根据文件id获取文件信息.<br/>
* @param fileId fileId
* @return PlanFundFileDO
*/
public PlanFundFileDO getByFileId(String fileId){
return planFundFileDOMapper.getByFileId(fileId);
}
/**
* desc:获取最新文件信息.<br/>
* @param planNo planNo
* @return PlanFundFileDO
*/
public PlanFundFileDO queryFileInfo(String planNo){
return planFundFileDOMapper.queryFileInfo(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanInvestStructureDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanInvestStructureDOMapper;
/**
* The Table abs_plan_invest_structure.
* 投资结构
*/
@Repository
public class PlanInvestStructureDAO{
@Autowired
private PlanInvestStructureDOMapper planInvestStructureDOMapper;
/**
* desc:批量插入表:abs_plan_invest_structure.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanInvestStructureDO> list){
planInvestStructureDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据计划编号删除.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planInvestStructureDOMapper.deleteByPlanNo(planNo);
}
/**
* desc:根据计划编号获取.<br/>
* @param planNo planNo
* @return List<PlanInvestStructureDO>
*/
public List<PlanInvestStructureDO> selectByPlanNo(String planNo){
return planInvestStructureDOMapper.selectByPlanNo(planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanMonitorDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanMonitorDOMapper;
/**
* The Table abs_plan_monitor.
* 计划监控指标
*/
@Repository
public class PlanMonitorDAO{
@Autowired
private PlanMonitorDOMapper planMonitorDOMapper;
/**
* desc:插入表:abs_plan_monitor.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanMonitorDO entity){
return planMonitorDOMapper.insert(entity);
}
/**
* desc:根据唯一约束AbsPlanMonitor更新表:abs_plan_monitor.<br/>
* @param entity entity
* @return int
*/
public int updateByIndicator(PlanMonitorDO entity){
return planMonitorDOMapper.updateByIndicator(entity);
}
/**
* desc:根据唯一约束AbsPlanMonitor更新违规日期信息:abs_plan_monitor.<br/>
* @param entity entity
* @return int
*/
public int updateDays(PlanMonitorDO entity){
return planMonitorDOMapper.updateDays(entity);
}
/**
* desc:根据唯一约束AbsPlanMonitor删除数据:abs_plan_monitor.<br/>
* @param planNo planNo
* @param indicator indicator
* @return int
*/
public int deleteByIndicator(String planNo,String indicator){
return planMonitorDOMapper.deleteByIndicator(planNo, indicator);
}
/**
* desc:根据唯一约束AbsPlanMonitor获取数据:abs_plan_monitor.<br/>
* @param planNo planNo
* @return List<PlanMonitorDO>
*/
public List<PlanMonitorDO> getByPlan(String planNo){
return planMonitorDOMapper.getByPlan(planNo);
}
/**
* desc:根据唯一约束AbsPlanMonitor获取数据:abs_plan_monitor.<br/>
* @param planNo planNo
* @param indicator indicator
* @return PlanMonitorDO
*/
public PlanMonitorDO getByIndicator(String planNo,String indicator){
return planMonitorDOMapper.getByIndicator(planNo, indicator);
}
/**
* desc:获取同名筛选规则数量,防止重名存在.<br/>
* @param name name
* @return Integer
*/
public Integer getSameMonitorCnt(String name){
return planMonitorDOMapper.getSameMonitorCnt(name);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanMonitorRecordDO;
import com.abssqr.plat.common.dal.mysql.auto.paging.MonitorRecordPage;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanMonitorRecordDOMapper;
/**
* The Table abs_plan_monitor_record.
* 事件列表
*/
@Repository
public class PlanMonitorRecordDAO{
@Autowired
private PlanMonitorRecordDOMapper planMonitorRecordDOMapper;
/**
* desc:插入表:abs_plan_monitor_record.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanMonitorRecordDO entity){
return planMonitorRecordDOMapper.insert(entity);
}
/**
* desc:获取监控事件列表:ABS_PLAN_MONITOR_RECORD.<br/>
* @param monitorRecord monitorRecord
* @return MonitorRecordPage
*/
public MonitorRecordPage getEventByPlan(MonitorRecordPage monitorRecord){
int total = planMonitorRecordDOMapper.getEventByPlanCount(monitorRecord);
if(total>0){
monitorRecord.setDatas(planMonitorRecordDOMapper.getEventByPlanResult(monitorRecord));
}else{
monitorRecord.setDatas(new ArrayList());
}
monitorRecord.setTotal(total);
return monitorRecord;
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanReportDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanReportDOMapper;
/**
* The Table abs_plan_report.
* ABS_PLAN_REPORT
*/
@Repository
public class PlanReportDAO{
@Autowired
private PlanReportDOMapper planReportDOMapper;
/**
* desc:插入表:abs_plan_report.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanReportDO entity){
return planReportDOMapper.insert(entity);
}
/**
* desc:根据主键获取数据:abs_plan_report.<br/>
* @param planNo planNo
* @param rptType rptType
* @return PlanReportDO
*/
public PlanReportDO getLatest(String planNo,String rptType){
return planReportDOMapper.getLatest(planNo, rptType);
}
/**
* desc:根据主键获取数据:abs_plan_report.<br/>
* @param planNo planNo
* @param rptDate rptDate
* @param rptType rptType
* @return PlanReportDO
*/
public PlanReportDO getReport(String planNo,String rptDate,String rptType){
return planReportDOMapper.getReport(planNo, rptDate, rptType);
}
/**
* desc:根据主键获取数据:abs_plan_report.<br/>
* @param planNo planNo
* @param endDate endDate
* @param rptType rptType
* @param startDate startDate
* @return List<PlanReportDO>
*/
public List<PlanReportDO> getByDate(String planNo,String endDate,String rptType,String startDate){
return planReportDOMapper.getByDate(planNo, endDate, rptType, startDate);
}
/**
* desc:根据主键获取数据:abs_plan_report.<br/>
* @param planNo planNo
* @param rptType rptType
* @param dateList dateList
* @return List<PlanReportDO>
*/
public List<PlanReportDO> getByDateList(String planNo,String rptType,List<String> dateList){
if(dateList!=null && dateList.size()>201){throw new RuntimeException("dateList 超出201长度限制");}
return planReportDOMapper.getByDateList(planNo, rptType, dateList);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanReportEntityDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.resultmap.PlanAstReportStat;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanReportEntityDOMapper;
/**
* The Table abs_plan_report_entity.
* ABS_PLAN_REPORT_ENTITY
*/
@Repository
public class PlanReportEntityDAO{
@Autowired
private PlanReportEntityDOMapper planReportEntityDOMapper;
/**
* desc:批量插入表:abs_plan_report_entity.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanReportEntityDO> list){
planReportEntityDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PlanAstReportStat>
*/
public List<PlanAstReportStat> statBal(Date accountDate,String planNo){
return planReportEntityDOMapper.statBal(accountDate, planNo);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PlanAstReportStat>
*/
public List<PlanAstReportStat> statAccrued(Date accountDate,String planNo){
return planReportEntityDOMapper.statAccrued(accountDate, planNo);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PlanAstReportStat>
*/
public List<PlanAstReportStat> statAmt(Date accountDate,String planNo){
return planReportEntityDOMapper.statAmt(accountDate, planNo);
}
/**
* desc:根据主键获取数据:abs_loan_instal_log.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return int
*/
public int delete(Date accountDate,String planNo){
return planReportEntityDOMapper.delete(accountDate, planNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanReportEntityStatDO;
import java.util.List;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanReportEntityStatDOMapper;
/**
* The Table abs_plan_report_entity_stat.
* ABS_PLAN_REPORT_ENTITY_STAT
*/
@Repository
public class PlanReportEntityStatDAO{
@Autowired
private PlanReportEntityStatDOMapper planReportEntityStatDOMapper;
/**
* desc:批量插入表:abs_plan_report_entity_stat.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanReportEntityStatDO> list){
planReportEntityStatDOMapper.insertBatch(list);
return list.size();
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanReportItemDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanReportItemDOMapper;
/**
* The Table abs_plan_report_item.
* ABS_PLAN_REPORT_ITEM
*/
@Repository
public class PlanReportItemDAO{
@Autowired
private PlanReportItemDOMapper planReportItemDOMapper;
/**
* desc:批量插入表:abs_plan_report_item.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanReportItemDO> list){
planReportItemDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据唯一约束AbsPlanReportItem获取数据:abs_plan_report_item.<br/>
* @param rptNo rptNo
* @param planNo planNo
* @return List<PlanReportItemDO>
*/
public List<PlanReportItemDO> getByRpt(String rptNo,String planNo){
return planReportItemDOMapper.getByRpt(rptNo, planNo);
}
/**
* desc:根据主键获取数据:abs_plan_report.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @return List<PlanReportItemDO>
*/
public List<PlanReportItemDO> getByDate(Date endDate,Date startDate,String planNo){
return planReportItemDOMapper.getByDate(endDate, startDate, planNo);
}
/**
* desc:根据计划和日期获取单项统计值.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param rptItem rptItem
* @return PlanReportItemDO
*/
public PlanReportItemDO getOneRptItemByPlanNoAndAccDate(Date accountDate,String planNo,String rptItem){
return planReportItemDOMapper.getOneRptItemByPlanNoAndAccDate(accountDate, planNo, rptItem);
}
/**
* desc:根据计划和日期获取多个统计项的汇总值.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param list list
* @return List<PlanReportItemDO>
*/
public List<PlanReportItemDO> queryRptItemsByPlanNoAndAccDate(Date accountDate,String planNo,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planReportItemDOMapper.queryRptItemsByPlanNoAndAccDate(accountDate, planNo, list);
}
/**
* desc:根据计划和日期区间获取多个统计项的汇总值.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @param list list
* @return List<PlanReportItemDO>
*/
public List<PlanReportItemDO> queryPlanRptItemsByPlanNoSection(Date endDate,Date startDate,String planNo,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planReportItemDOMapper.queryPlanRptItemsByPlanNoSection(endDate, startDate, planNo, list);
}
/**
* desc:根据计划和日期区间获取多个统计项的每日数据.<br/>
* @param endDate endDate
* @param startDate startDate
* @param listItem listItem
* @param listPlanNo listPlanNo
* @return List<PlanReportItemDO>
*/
public List<PlanReportItemDO> queryDayRptItemsByPlanNoSection(Date endDate,Date startDate,List<String> listItem,List<String> listPlanNo){
if(listItem!=null && listItem.size()>201){throw new RuntimeException("listItem 超出201长度限制");}
if(listPlanNo!=null && listPlanNo.size()>201){throw new RuntimeException("listPlanNo 超出201长度限制");}
return planReportItemDOMapper.queryDayRptItemsByPlanNoSection(endDate, startDate, listItem, listPlanNo);
}
/**
* desc:根据计划和日期区间获取最小日期.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @param list list
* @return Date
*/
public Date queryPlanReportMinDateByPlanNoSection(Date endDate,Date startDate,String planNo,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planReportItemDOMapper.queryPlanReportMinDateByPlanNoSection(endDate, startDate, planNo, list);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanReportItemDefaultDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanReportItemDefaultDOMapper;
/**
* The Table abs_plan_report_item_default.
* ABS_PLAN_REPORT_ITEM_DEFAULT
*/
@Repository
public class PlanReportItemDefaultDAO{
@Autowired
private PlanReportItemDefaultDOMapper planReportItemDefaultDOMapper;
/**
* desc:插入表:abs_plan_report_item_default.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanReportItemDefaultDO entity){
return planReportItemDefaultDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_report_item_default.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanReportItemDefaultDO> list){
planReportItemDefaultDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据计划编号删除基础数据.<br/>
* @param planNo planNo
* @return int
*/
public int deleteByPlanNo(String planNo){
return planReportItemDefaultDOMapper.deleteByPlanNo(planNo);
}
/**
* desc:根据计划编号查询基础数据.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @return List<PlanReportItemDefaultDO>
*/
public List<PlanReportItemDefaultDO> getDefaultRptItem(Date accountDate,String planNo){
return planReportItemDefaultDOMapper.getDefaultRptItem(accountDate, planNo);
}
/**
* desc:根据计划编号查询基础数据.<br/>
* @param planNo planNo
* @return Date
*/
public Date getDefaultRptDate(String planNo){
return planReportItemDefaultDOMapper.getDefaultRptDate(planNo);
}
/**
* desc:根据计划编号查询基础数据.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @return List<PlanReportItemDefaultDO>
*/
public List<PlanReportItemDefaultDO> getDefaultRptItemByDate(Date endDate,Date startDate,String planNo){
return planReportItemDefaultDOMapper.getDefaultRptItemByDate(endDate, startDate, planNo);
}
/**
* desc:根据计划和日期获取多个统计项的汇总值.<br/>
* @param accountDate accountDate
* @param planNo planNo
* @param list list
* @return List<PlanReportItemDefaultDO>
*/
public List<PlanReportItemDefaultDO> queryRptItemsByPlanNoAndAccDate(Date accountDate,String planNo,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planReportItemDefaultDOMapper.queryRptItemsByPlanNoAndAccDate(accountDate, planNo, list);
}
/**
* desc:根据计划和日期区间获取多个统计项的汇总值.<br/>
* @param endDate endDate
* @param startDate startDate
* @param planNo planNo
* @param list list
* @return List<PlanReportItemDefaultDO>
*/
public List<PlanReportItemDefaultDO> queryPlanRptItemsByPlanNoSection(Date endDate,Date startDate,String planNo,List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
return planReportItemDefaultDOMapper.queryPlanRptItemsByPlanNoSection(endDate, startDate, planNo, list);
}
/**
* desc:根据计划和日期区间获取多个统计项的每日数据.<br/>
* @param endDate endDate
* @param startDate startDate
* @param listItem listItem
* @param listPlanNo listPlanNo
* @return List<PlanReportItemDefaultDO>
*/
public List<PlanReportItemDefaultDO> queryDayRptItemsByPlanNoSection(Date endDate,Date startDate,List<String> listItem,List<String> listPlanNo){
if(listItem!=null && listItem.size()>201){throw new RuntimeException("listItem 超出201长度限制");}
if(listPlanNo!=null && listPlanNo.size()>201){throw new RuntimeException("listPlanNo 超出201长度限制");}
return planReportItemDefaultDOMapper.queryDayRptItemsByPlanNoSection(endDate, startDate, listItem, listPlanNo);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanTaskLogDO;
import java.util.List;
import java.util.Date;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanTaskLogDOMapper;
/**
* The Table abs_plan_task_log.
* ABS_PLAN_TASK_LOG
*/
@Repository
public class PlanTaskLogDAO{
@Autowired
private PlanTaskLogDOMapper planTaskLogDOMapper;
/**
* desc:插入表:abs_plan_task_log.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanTaskLogDO entity){
return planTaskLogDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_task_log.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanTaskLogDO> list){
planTaskLogDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据主键删除数据:abs_plan_task_log.<br/>
* @param execDate execDate
* @param planNo planNo
* @param taskType taskType
* @return PlanTaskLogDO
*/
public PlanTaskLogDO delByPlanNoAndDate(Date execDate,String planNo,String taskType){
return planTaskLogDOMapper.delByPlanNoAndDate(execDate, planNo, taskType);
}
/**
* desc:根据主键获取数据:abs_plan_task_log.<br/>
* @param execDate execDate
* @param planNo planNo
* @param taskType taskType
* @return PlanTaskLogDO
*/
public PlanTaskLogDO getByPlanNoAndDate(Date execDate,String planNo,String taskType){
return planTaskLogDOMapper.getByPlanNoAndDate(execDate, planNo, taskType);
}
/**
* desc:根据主键获取数据:abs_plan_task_log.<br/>
* @param execDate execDate
* @param taskType taskType
* @return List<PlanTaskLogDO>
*/
public List<PlanTaskLogDO> getTasks(Date execDate,String taskType){
return planTaskLogDOMapper.getTasks(execDate, taskType);
}
}
package com.abssqr.plat.common.dal.mysql.auto.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.ArrayList;
import com.abssqr.plat.common.dal.mysql.auto.dataobject.PlanTranScreenRelDO;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.LinkedHashMap;
import java.util.ArrayList;
import java.util.HashSet;
import java.lang.String;
import com.abssqr.plat.common.dal.mysql.auto.mapper.PlanTranScreenRelDOMapper;
/**
* The Table abs_plan_tran_screen_rel.
* 产品转让筛选规则关联表
*/
@Repository
public class PlanTranScreenRelDAO{
@Autowired
private PlanTranScreenRelDOMapper planTranScreenRelDOMapper;
/**
* desc:插入表:abs_plan_tran_screen_rel.<br/>
* @param entity entity
* @return int
*/
public int insert(PlanTranScreenRelDO entity){
return planTranScreenRelDOMapper.insert(entity);
}
/**
* desc:批量插入表:abs_plan_tran_screen_rel.<br/>
* @param list list
* @return int
*/
public int insertBatch(List<PlanTranScreenRelDO> list){
planTranScreenRelDOMapper.insertBatch(list);
return list.size();
}
/**
* desc:根据TransferNo删除数据:abs_plan_tran_screen_rel.<br/>
* @param transferNo transferNo
* @return int
*/
public int deleteByTransferNo(String transferNo){
return planTranScreenRelDOMapper.deleteByTransferNo(transferNo);
}
/**
* desc:根据transferNo获取数据:abs_plan_tran_screen_rel.<br/>
* @param transferNo transferNo
* @return List<PlanTranScreenRelDO>
*/
public List<PlanTranScreenRelDO> getByTransferNo(String transferNo){
return planTranScreenRelDOMapper.getByTransferNo(transferNo);
}
/**
* desc:根据prodCode获取数据:planNos.<br/>
* @param list list
* @return Map<String,List<String>>
*/
public List<PlanTranScreenRelDO> getPlanNosByProdListList(List<String> list){
return planTranScreenRelDOMapper.getPlanNosByProdList(list);
}
/**
* desc:根据prodCode获取数据:planNos.<br/>
* @param list list
* @return Map<String,List<String>>
*/
public Map<String,List<String>> getPlanNosByProdList(List<String> list){
if(list!=null && list.size()>201){throw new RuntimeException("list 超出201长度限制");}
Map<String,List<String>> result = new LinkedHashMap();
List<PlanTranScreenRelDO> resultList = planTranScreenRelDOMapper.getPlanNosByProdList(list);
if(resultList!=null && !resultList.isEmpty()){
for(PlanTranScreenRelDO entity:resultList){
List<String> vList = result.get(entity.getProdCode());
if(vList == null){
vList = new ArrayList();
result.put(entity.getProdCode(),vList);
}
vList.add(entity.getPlanNo());
}
}
return result;
}
/**
* desc:根据transferNo获取数据:abs_plan_tran_screen_rel.<br/>
* @param managerOrgCode managerOrgCode
* @return List<String>
*/
public List<String> getPlanNosByManagerOrg(String managerOrgCode){
return planTranScreenRelDOMapper.getPlanNosByManagerOrg(managerOrgCode);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment