|
@@ -158,101 +158,101 @@ public class AccountManagementServiceImpl extends ServiceImpl<AccountManagementM
|
|
|
.eq(AccountRemainder::getAccountManagementId,id));
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 导入账户表的数据
|
|
|
- */
|
|
|
- @Override
|
|
|
- @Transactional(rollbackFor = {Exception.class})
|
|
|
- @TenantIgnore
|
|
|
- public void importsAmount(AccountManagementDto dto) {
|
|
|
- //查询云帆账户表的数据
|
|
|
-// List<FundAccount> fundAccounts = baseMapper.importsAmount(dto);
|
|
|
-// for (FundAccount fundAccount : fundAccounts) {
|
|
|
-// //添加资金账户表的数据
|
|
|
-// AccountManagement accountManagement = new AccountManagement();
|
|
|
-// //查询多公司表
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getCompanyId())){
|
|
|
-// DynamicDataSourceContextHolder.push(SourceConstant.COMMON);
|
|
|
-//
|
|
|
-// Corporation corporation = corporationService.getOne(Wrappers.<Corporation>lambdaQuery().eq(Corporation::getYfId,fundAccount.getCompanyId()));
|
|
|
-// if(ObjectUtil.isNotEmpty(corporation)){
|
|
|
-// accountManagement.setCorporationId(corporation.getId());
|
|
|
-// }
|
|
|
-//
|
|
|
-// DynamicDataSourceContextHolder.poll();
|
|
|
-// }
|
|
|
-// accountManagement.setTenantId(fundAccount.getTenantId());
|
|
|
-// accountManagement.setYfId(fundAccount.getId());
|
|
|
-// accountManagement.setAlias(fundAccount.getName());
|
|
|
-// accountManagement.setAccountOpening(fundAccount.getAccountNumber());
|
|
|
-// accountManagement.setCreateTime(fundAccount.getCreateTime());
|
|
|
-// accountManagement.setUpdateTime(fundAccount.getUpdateTime());
|
|
|
-// accountManagement.setAccountOpening(fundAccount.getAccountNumber());
|
|
|
-// //查询用户
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getCreateUser())){
|
|
|
-// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
-// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getCreateUser()));
|
|
|
-// accountManagement.setCreateUser(sysUser.getUserId());
|
|
|
-// DynamicDataSourceContextHolder.poll();
|
|
|
-// }
|
|
|
+// /**
|
|
|
+// * 导入账户表的数据
|
|
|
+// */
|
|
|
+// @Override
|
|
|
+// @Transactional(rollbackFor = {Exception.class})
|
|
|
+// @TenantIgnore
|
|
|
+// public void importsAmount(AccountManagementDto dto) {
|
|
|
+// //查询云帆账户表的数据
|
|
|
+//// List<FundAccount> fundAccounts = baseMapper.importsAmount(dto);
|
|
|
+//// for (FundAccount fundAccount : fundAccounts) {
|
|
|
+//// //添加资金账户表的数据
|
|
|
+//// AccountManagement accountManagement = new AccountManagement();
|
|
|
+//// //查询多公司表
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getCompanyId())){
|
|
|
+//// DynamicDataSourceContextHolder.push(SourceConstant.COMMON);
|
|
|
+////
|
|
|
+//// Corporation corporation = corporationService.getOne(Wrappers.<Corporation>lambdaQuery().eq(Corporation::getYfId,fundAccount.getCompanyId()));
|
|
|
+//// if(ObjectUtil.isNotEmpty(corporation)){
|
|
|
+//// accountManagement.setCorporationId(corporation.getId());
|
|
|
+//// }
|
|
|
+////
|
|
|
+//// DynamicDataSourceContextHolder.poll();
|
|
|
+//// }
|
|
|
+//// accountManagement.setTenantId(fundAccount.getTenantId());
|
|
|
+//// accountManagement.setYfId(fundAccount.getId());
|
|
|
+//// accountManagement.setAlias(fundAccount.getName());
|
|
|
+//// accountManagement.setAccountOpening(fundAccount.getAccountNumber());
|
|
|
+//// accountManagement.setCreateTime(fundAccount.getCreateTime());
|
|
|
+//// accountManagement.setUpdateTime(fundAccount.getUpdateTime());
|
|
|
+//// accountManagement.setAccountOpening(fundAccount.getAccountNumber());
|
|
|
+//// //查询用户
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getCreateUser())){
|
|
|
+//// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
+//// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getCreateUser()));
|
|
|
+//// accountManagement.setCreateUser(sysUser.getUserId());
|
|
|
+//// DynamicDataSourceContextHolder.poll();
|
|
|
+//// }
|
|
|
+////
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getUpdateUser())){
|
|
|
+//// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
+//// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getUpdateUser()));
|
|
|
+//// accountManagement.setCreateUser(sysUser.getUserId());
|
|
|
+//// DynamicDataSourceContextHolder.poll();
|
|
|
+//// }
|
|
|
+//// accountManagement.setCreateTime(fundAccount.getCreateTime());
|
|
|
+//// accountManagement.setUpdateTime(fundAccount.getUpdateTime());
|
|
|
+//// baseMapper.insert(accountManagement);
|
|
|
+////
|
|
|
+//// //添加资金账户余额表的信息
|
|
|
+//// AccountRemainder accountRemainder = new AccountRemainder();
|
|
|
+//// accountRemainder.setTenantId(fundAccount.getTenantId());
|
|
|
+//// accountRemainder.setAccountManagementId(accountManagement.getId());
|
|
|
+//// //查询用户
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getCreateUser())){
|
|
|
+//// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
+//// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getCreateUser()));
|
|
|
+//// accountRemainder.setCreateUser(sysUser.getUserId());
|
|
|
+//// DynamicDataSourceContextHolder.poll();
|
|
|
+//// }
|
|
|
+////
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getUpdateUser())){
|
|
|
+////
|
|
|
+//// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
+//// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getUpdateUser()));
|
|
|
+//// accountRemainder.setCreateUser(sysUser.getUserId());
|
|
|
+//// DynamicDataSourceContextHolder.poll();
|
|
|
+//// }
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getRmbAmount())){
|
|
|
+//// accountRemainder.setId(IdWorker.getId());
|
|
|
+//// accountRemainder.setRemainder(fundAccount.getRmbAmount());
|
|
|
+//// accountRemainder.setCurrency("RMB");
|
|
|
+//// accountRemainderService.save(accountRemainder);
|
|
|
+//// }
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getDollarAmount())){
|
|
|
+//// accountRemainder.setId(IdWorker.getId());
|
|
|
+//// accountRemainder.setRemainder(fundAccount.getDollarAmount());
|
|
|
+//// accountRemainder.setCurrency("USD");
|
|
|
+//// accountRemainderService.save(accountRemainder);
|
|
|
+//// }
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getEuroAmount())){
|
|
|
+//// accountRemainder.setId(IdWorker.getId());
|
|
|
+//// accountRemainder.setRemainder(fundAccount.getEuroAmount());
|
|
|
+//// accountRemainder.setCurrency("EUR");
|
|
|
+//// accountRemainderService.save(accountRemainder);
|
|
|
+//// }
|
|
|
+////
|
|
|
+//// if (ObjectUtil.isNotEmpty(fundAccount.getSterlingAmount())){
|
|
|
+//// accountRemainder.setId(IdWorker.getId());
|
|
|
+//// accountRemainder.setRemainder(fundAccount.getSterlingAmount());
|
|
|
+//// accountRemainder.setCurrency("GBP");
|
|
|
+//// accountRemainderService.save(accountRemainder);
|
|
|
+//// }
|
|
|
+//// }
|
|
|
//
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getUpdateUser())){
|
|
|
-// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
-// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getUpdateUser()));
|
|
|
-// accountManagement.setCreateUser(sysUser.getUserId());
|
|
|
-// DynamicDataSourceContextHolder.poll();
|
|
|
-// }
|
|
|
-// accountManagement.setCreateTime(fundAccount.getCreateTime());
|
|
|
-// accountManagement.setUpdateTime(fundAccount.getUpdateTime());
|
|
|
-// baseMapper.insert(accountManagement);
|
|
|
-//
|
|
|
-// //添加资金账户余额表的信息
|
|
|
-// AccountRemainder accountRemainder = new AccountRemainder();
|
|
|
-// accountRemainder.setTenantId(fundAccount.getTenantId());
|
|
|
-// accountRemainder.setAccountManagementId(accountManagement.getId());
|
|
|
-// //查询用户
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getCreateUser())){
|
|
|
-// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
-// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getCreateUser()));
|
|
|
-// accountRemainder.setCreateUser(sysUser.getUserId());
|
|
|
-// DynamicDataSourceContextHolder.poll();
|
|
|
-// }
|
|
|
-//
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getUpdateUser())){
|
|
|
-//
|
|
|
-// DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
-// SysUser sysUser = sysUserService.getOne(Wrappers.<SysUser>lambdaQuery().eq(SysUser::getYfUserId, fundAccount.getUpdateUser()));
|
|
|
-// accountRemainder.setCreateUser(sysUser.getUserId());
|
|
|
-// DynamicDataSourceContextHolder.poll();
|
|
|
-// }
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getRmbAmount())){
|
|
|
-// accountRemainder.setId(IdWorker.getId());
|
|
|
-// accountRemainder.setRemainder(fundAccount.getRmbAmount());
|
|
|
-// accountRemainder.setCurrency("RMB");
|
|
|
-// accountRemainderService.save(accountRemainder);
|
|
|
-// }
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getDollarAmount())){
|
|
|
-// accountRemainder.setId(IdWorker.getId());
|
|
|
-// accountRemainder.setRemainder(fundAccount.getDollarAmount());
|
|
|
-// accountRemainder.setCurrency("USD");
|
|
|
-// accountRemainderService.save(accountRemainder);
|
|
|
-// }
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getEuroAmount())){
|
|
|
-// accountRemainder.setId(IdWorker.getId());
|
|
|
-// accountRemainder.setRemainder(fundAccount.getEuroAmount());
|
|
|
-// accountRemainder.setCurrency("EUR");
|
|
|
-// accountRemainderService.save(accountRemainder);
|
|
|
-// }
|
|
|
-//
|
|
|
-// if (ObjectUtil.isNotEmpty(fundAccount.getSterlingAmount())){
|
|
|
-// accountRemainder.setId(IdWorker.getId());
|
|
|
-// accountRemainder.setRemainder(fundAccount.getSterlingAmount());
|
|
|
-// accountRemainder.setCurrency("GBP");
|
|
|
-// accountRemainderService.save(accountRemainder);
|
|
|
-// }
|
|
|
-// }
|
|
|
-
|
|
|
- }
|
|
|
+// }
|
|
|
|
|
|
|
|
|
/**
|