diff --git a/db/800pjcloudx_wallet.sql b/db/800pjcloudx_wallet.sql index 58d141db1..0493737ae 100644 --- a/db/800pjcloudx_wallet.sql +++ b/db/800pjcloudx_wallet.sql @@ -64,23 +64,22 @@ CREATE INDEX idx_dept_id ON mch_manage (dept_id); -- ---------------------------- -- Table structure for mch_dpet_user -- ---------------------------- -DROP TABLE IF EXISTS `mch_dept_user`; -CREATE TABLE mch_dept_user +DROP TABLE IF EXISTS `mch_dept`; +CREATE TABLE mch_dept ( - id bigint NOT NULL COMMENT '主键', - mch_id bigint NOT NULL COMMENT '商户id', - user_id bigint NOT NULL COMMENT '用户id', - user_dept_id bigint NOT NULL COMMENT '用户部门id', - create_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '创建人', - create_time datetime DEFAULT NULL COMMENT '创建时间', - update_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '修改人', - update_time datetime DEFAULT NULL COMMENT '修改时间', - del_flag char(1) COLLATE utf8mb4_general_ci DEFAULT '0' COMMENT '删除标记', - tenant_id bigint DEFAULT NULL COMMENT '租户ID', + id BIGINT(19) not null comment '主键', + mch_id BIGINT(19) not null comment '商户id', + dept_id BIGINT(19) not null comment '部门id', + create_by VARCHAR(64) null comment '创建人', + create_time DATETIME null comment '创建时间', + update_by VARCHAR(64) null comment '修改人', + update_time DATETIME null comment '修改时间', + del_flag CHAR default '0' null comment '删除标记', + tenant_id BIGINT(19) null comment '租户ID', PRIMARY KEY (id) ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 - COLLATE = utf8mb4_general_ci COMMENT ='用户部门商户关系表'; + COLLATE = utf8mb4_general_ci COMMENT ='商户部门关系表'; -- ---------------------------- -- Table structure for wallet_manage @@ -113,15 +112,15 @@ CREATE TABLE wallet_manage CREATE INDEX idx_dept_id ON wallet_manage (user_id); -- ---------------------------- --- Table structure for wallet_rule_price_config +-- Table structure for mch_rule_price_config -- ---------------------------- -DROP TABLE IF EXISTS wallet_rule_price_config; -CREATE TABLE wallet_rule_price_config +DROP TABLE IF EXISTS mch_rule_price_config; +CREATE TABLE mch_rule_price_config ( - id bigint NOT NULL COMMENT '主键', - rule_price_type varchar(64) NOT NULL COMMENT '规则类型', - base_price bigint NOT NULL COMMENT '基础金额', - multiple bigint NOT NULL COMMENT '额外支付的倍数', + id BIGINT(19) not null comment '主键', + rule_price_type VARCHAR(64) not null comment '规则类型', + base_price BIGINT(19) not null comment '基础金额', + multiple BIGINT(19) not null comment '额外支付的倍数', create_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '创建人', create_time datetime DEFAULT NULL COMMENT '创建时间', update_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '修改人', @@ -133,16 +132,17 @@ CREATE TABLE wallet_rule_price_config DEFAULT CHARSET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '商家商品价格配置表'; -- ---------------------------- --- Table structure for wallet_rule_mch_config +-- Table structure for mch_rule_join -- ---------------------------- -DROP TABLE IF EXISTS wallet_rule_mch_config; -CREATE TABLE wallet_rule_mch_config +DROP TABLE IF EXISTS mch_rule_join; +CREATE TABLE mch_rule_join ( - id bigint NOT NULL COMMENT '主键', - source_mch_id bigint NOT NULL COMMENT '源商户id', - target_mch_id bigint NOT NULL COMMENT '目标商户id', - target_dept_id bigint NOT NULL COMMENT '目标部门id', - rule_price_config_id bigint NOT NULL COMMENT '规则配置id', + id BIGINT(19) not null comment '主键', + source_mch_id BIGINT(19) not null comment '源商户id', + target_mch_id BIGINT(19) not null comment '目标商户id', + target_dept_id BIGINT(19) not null comment '目标部门id', + rule_price_config_id BIGINT(19) not null comment '规则配置id', + status VARCHAR(64) default '0' not null comment '是否启用', create_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '创建人', create_time datetime DEFAULT NULL COMMENT '创建时间', update_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '修改人', @@ -159,10 +159,11 @@ CREATE TABLE wallet_rule_mch_config DROP TABLE IF EXISTS wallet_type; CREATE TABLE wallet_type ( - id bigint NOT NULL COMMENT '主键', - name varchar(64) NOT NULL COMMENT '钱包名', - icon varchar(256) NOT NULL COMMENT '钱包图标', + id bigint NOT NULL COMMENT '主键', + name varchar(64) NOT NULL COMMENT '钱包名', + icon varchar(256) NOT NULL COMMENT '钱包图标', unique_code varchar(16) COMMENT '饭卡code', + is_rule char(1) DEFAULT '0' NOT NULL COMMENT '是否启用钱包转账规则', create_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '创建人', create_time datetime DEFAULT NULL COMMENT '创建时间', update_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '修改人', @@ -173,6 +174,54 @@ CREATE TABLE wallet_type ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 COMMENT ='钱包类型'; +-- ---------------------------- +-- Table structure for wallet_rule_join +-- ---------------------------- +DROP TABLE IF EXISTS wallet_rule_join; +CREATE TABLE wallet_rule_join +( + id BIGINT(19) not null comment '主键', + source_wallet_type_id BIGINT(19) not null comment '源钱包类型id', + target_wallet_type_id BIGINT(19) not null comment '目标钱包类型id', + target_dept_id BIGINT(19) not null comment '目标部门id', + balance_multiple int DEFAULT 0 NOT NULL COMMENT '钱包转换百分比', + status VARCHAR(64) default '0' not null comment '是否启用', + create_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '创建人', + create_time datetime DEFAULT NULL COMMENT '创建时间', + update_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '修改人', + update_time datetime DEFAULT NULL COMMENT '修改时间', + del_flag char(1) COLLATE utf8mb4_general_ci DEFAULT '0' COMMENT '删除标记', + tenant_id bigint DEFAULT NULL COMMENT '租户ID', + PRIMARY KEY (id) +) ENGINE = InnoDB + DEFAULT CHARSET = utf8mb4 + COLLATE = utf8mb4_general_ci COMMENT = '钱包规则配置'; + +-- ---------------------------- +-- Table structure for wallet_rule_transaction +-- ---------------------------- +DROP TABLE IF EXISTS wallet_rule_transaction; +CREATE TABLE wallet_rule_transaction +( + id BIGINT(19) not null comment '主键', + source_wallet_id BIGINT(19) not null comment '源钱包id', + target_wallet_id BIGINT(19) not null comment '目标钱包id', + source_wallet_balance int not null comment '源钱包余额', + target_wallet_balance int not null comment '目标钱包余额', + balance int DEFAULT 0 NOT NULL COMMENT '转换金额', + after_balance int DEFAULT 0 NOT NULL COMMENT '转换后的金额', + balance_multiple int DEFAULT 0 NOT NULL COMMENT '钱包转换百分比', + is_refund VARCHAR(64) default '0' not null comment '是否退回', + create_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '创建人', + create_time datetime DEFAULT NULL COMMENT '创建时间', + update_by varchar(64) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '修改人', + update_time datetime DEFAULT NULL COMMENT '修改时间', + del_flag char(1) COLLATE utf8mb4_general_ci DEFAULT '0' COMMENT '删除标记', + tenant_id bigint DEFAULT NULL COMMENT '租户ID', + PRIMARY KEY (id) +) ENGINE = InnoDB + DEFAULT CHARSET = utf8mb4 + COLLATE = utf8mb4_general_ci COMMENT = '钱包转账记录'; -- ---------------------------- -- Table structure for wallet_active diff --git a/pjcloud-common/pjcloud-common-core/src/main/java/com/bsd/pjcloud/common/core/constant/enums/MerchantTypeEnum.java b/pjcloud-common/pjcloud-common-core/src/main/java/com/bsd/pjcloud/common/core/constant/enums/MerchantTypeEnum.java index 5403a03a1..81fb03f69 100644 --- a/pjcloud-common/pjcloud-common-core/src/main/java/com/bsd/pjcloud/common/core/constant/enums/MerchantTypeEnum.java +++ b/pjcloud-common/pjcloud-common-core/src/main/java/com/bsd/pjcloud/common/core/constant/enums/MerchantTypeEnum.java @@ -7,8 +7,8 @@ import lombok.RequiredArgsConstructor; @Getter public enum MerchantTypeEnum { CANTEEN("1", "食堂"), - SUPERMARKET("2", "合作超市"), - SELF_SUPERMARKET("3", "自营超市"), + SUPERMARKET("2", "合作商家"), + SELF_SUPERMARKET("3", "自营商家"), ; /** diff --git a/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java b/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java index 435eb4830..3ff254153 100644 --- a/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java +++ b/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java @@ -30,7 +30,6 @@ import com.bsd.pjcloud.hard.service.HardManagerService; import com.bsd.pjcloud.hard.mqtt.config.MqttConfig; import com.bsd.pjcloud.hard.utils.MqTopicUtil; import com.bsd.pjcloud.mqtt.api.feign.RemoteMqttEventService; -import com.bsd.pjcloud.wallet.api.entity.MchManageEntity; import com.bsd.pjcloud.wallet.api.feign.RemoteMchService; import com.bsd.pjcloud.wallet.api.utils.WalletDataUtil; import com.bsd.pjcloud.wallet.api.vo.MchManageVo; diff --git a/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/dto/DeptAllListDto.java b/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/dto/DeptAllListDto.java index f5ab38542..48bb0eb77 100644 --- a/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/dto/DeptAllListDto.java +++ b/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/dto/DeptAllListDto.java @@ -13,4 +13,6 @@ public class DeptAllListDto { private Boolean isInclude; + private String isSyncZy; + } diff --git a/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteDeptService.java b/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteDeptService.java index b18412c04..722609be9 100644 --- a/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteDeptService.java +++ b/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteDeptService.java @@ -54,6 +54,10 @@ public interface RemoteDeptService { @PostMapping("/dept/inner-all-dept") R> getInnerAllDept(@RequestBody DeptAllListDto dto); + @NoToken + @PostMapping("/dept/inner-dept") + R> getInnerDept(@RequestBody DeptAllListDto dto); + /** * 通过部门ID获取负责人列表 * diff --git a/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteUserService.java b/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteUserService.java index 135e5707a..64e51160e 100644 --- a/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteUserService.java +++ b/pjcloud-upms/pjcloud-upms-api/src/main/java/com/bsd/pjcloud/admin/api/feign/RemoteUserService.java @@ -40,6 +40,7 @@ import java.util.Set; @FeignClient(contextId = "remoteUserService", value = ServiceNameConstants.UPMS_SERVICE) public interface RemoteUserService { + @NoToken @PostMapping("/user/inner-page") R> getRemoteUserPage(@RequestParam Long current, @RequestParam Long size, @RequestBody UserDTO userDTO); diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysDeptController.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysDeptController.java index 6b844270a..065482f31 100644 --- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysDeptController.java +++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysDeptController.java @@ -225,4 +225,12 @@ public class SysDeptController { public R> getInnerAllDept(@RequestBody DeptAllListDto dto) { return R.ok(sysDeptMapper.allList(dto)); } + + @Inner + @PostMapping("/inner-dept") + public R> getInnerDept(@RequestBody DeptAllListDto dto) { + return R.ok(sysDeptService.getInnerDept(dto)); + } + + } diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysUserController.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysUserController.java index 63ab689c1..69692f12b 100644 --- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysUserController.java +++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/controller/SysUserController.java @@ -211,15 +211,16 @@ public class SysUserController { /** * 分页查询用户 */ + @Inner @PostMapping("/inner-page") - public R> getRemoteUserPage(@RequestParam Long current, @RequestParam Long size, @RequestBody UserDTO userDTO) { + public R> innerPage(@RequestParam Long current, @RequestParam Long size, @RequestBody UserDTO userDTO) { if (ObjectUtil.isEmpty(userDTO.getIsFindCheckUser())) { userDTO.setIsFindCheckUser(true); } Page pageParams = new Page(); pageParams.setCurrent(current); pageParams.setSize(size); - return R.ok(userService.getUsersWithRolePage(pageParams, userDTO).getRecords()); + return R.ok(userService.innerPage(pageParams, userDTO).getRecords()); } /** diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysDeptService.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysDeptService.java index c985ca6af..94ba43d45 100644 --- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysDeptService.java +++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysDeptService.java @@ -21,6 +21,7 @@ package com.bsd.pjcloud.admin.service; import cn.hutool.core.lang.tree.Tree; import com.baomidou.mybatisplus.extension.service.IService; +import com.bsd.pjcloud.admin.api.dto.DeptAllListDto; import com.bsd.pjcloud.admin.api.entity.SysDept; import com.bsd.pjcloud.admin.api.vo.DeptExcelVO; import com.bsd.pjcloud.admin.api.vo.OrgTreeVO; @@ -127,4 +128,6 @@ public interface SysDeptService extends IService { */ List selectByNames(List names); + + List getInnerDept(DeptAllListDto dto); } diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java index f5d0b23eb..cfaa7d60e 100644 --- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java +++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java @@ -61,6 +61,8 @@ public interface SysUserService extends IService { */ IPage getUsersWithRolePage(Page page, UserDTO userDTO); + IPage innerPage(Page page, UserDTO userDTO); + /** * 删除用户 * @@ -214,6 +216,7 @@ public interface SysUserService extends IService { /** * 根据用户名或者手机号获取数据库权限的用户信息 + * * @param eq * @return */ diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysDeptServiceImpl.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysDeptServiceImpl.java index 6d6b56a09..c961176ab 100644 --- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysDeptServiceImpl.java +++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysDeptServiceImpl.java @@ -31,6 +31,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.bsd.pjcloud.admin.api.constant.OrgTypeEnum; import com.bsd.pjcloud.admin.api.constant.PostCodeEnum; +import com.bsd.pjcloud.admin.api.dto.DeptAllListDto; import com.bsd.pjcloud.admin.api.entity.*; import com.bsd.pjcloud.admin.api.utils.DataUtil; import com.bsd.pjcloud.admin.api.vo.DeptExcelVO; @@ -413,6 +414,15 @@ public class SysDeptServiceImpl extends ServiceImpl impl ); } + @Override + public List getInnerDept(DeptAllListDto dto) { + return baseMapper.selectList(new LambdaQueryWrapper() + .eq(ObjectUtil.isNotEmpty(dto.getDeptId()), SysDept::getDeptId, dto.getDeptId()) + .eq(ObjectUtil.isNotEmpty(dto.getIsSyncZy()), SysDept::getIsSyncZy, dto.getIsSyncZy()) + .in(ObjectUtil.isNotEmpty(dto.getDeptIds()), SysDept::getDeptId, dto.getDeptIds()) + ); + } + /** * 递归查询所有子节点。 * diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java index f167b82f3..942b32b55 100644 --- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java +++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java @@ -142,8 +142,8 @@ public class SysUserServiceImpl extends ServiceImpl impl BeanUtils.copyProperties(userDto, sysUser); // 判断是否为部门管理员 PjcloudUser applyUser = SecurityUtils.getUser(); - boolean isDeptAdmin=false; - if (null!=applyUser){ + boolean isDeptAdmin = false; + if (null != applyUser) { isDeptAdmin = sysRoleService.isDeptAdmin(applyUser.getId()); if (isDeptAdmin) { List defaultRoles = sysRoleService.findRolesByCodes(List.of(CommonRoleConstant.DEFAULT_USER, CommonRoleConstant.AUTO_CREATE_WALLET)); @@ -272,6 +272,37 @@ public class SysUserServiceImpl extends ServiceImpl impl return list; } + @Override + public IPage innerPage(Page page, UserDTO userDTO) { + IPage list = baseMapper.getUserVosPage(page, userDTO, null); + if (ObjectUtil.isNotEmpty(list.getRecords())) { + List userIds = list.getRecords().stream().map(UserVO::getUserId).distinct().toList(); + if (ObjectUtil.isNotEmpty(userIds)) { + SysUserFaceDto faceDto = new SysUserFaceDto(); + List faceList = sysUserFaceMapper.groupConcatFaces(faceDto); + DataUtil.convertFacesList(list.getRecords(), CollectionUtils.convertMap(faceList, SysUserFaceVo::getUserId)); + } + // 审批流程 + if (userDTO.getIsFindCheckUser()) { + List processInstanceIds = list.getRecords().stream().map(UserVO::getProcessId).filter(ObjectUtil::isNotEmpty).distinct().toList(); + if (ObjectUtil.isNotEmpty(processInstanceIds)) { + List taskList = flowUtil.queryProcessInstanceList(SecurityUtils.getUser().getId().toString(), processInstanceIds); + if (ObjectUtil.isNotEmpty(taskList)) { + Map taskMap = CollectionUtils.convertMap(taskList, TaskDto::getProcessInstanceId); + CollectionUtils.convertList(list.getRecords(), v -> { + TaskDto task = taskMap.get(v.getProcessId()); + if (ObjectUtil.isNotEmpty(task)) { + v.setIsCheckUser(true); + } + return v; + }); + } + } + } + } + return list; + } + /** * 通过ID查询用户信息 * @@ -292,8 +323,16 @@ public class SysUserServiceImpl extends ServiceImpl impl @Override @Transactional(rollbackFor = Exception.class) public Boolean deleteUserByIds(Long[] ids) { - // 删除 spring cache List userList = baseMapper.selectBatchIds(CollUtil.toList(ids)); + // 判断是否可以删除 + userList.forEach(v -> { + String errorMsg = remoteWalletService.isDel(v.getUserId()).getData(); + if (ObjectUtil.isNotEmpty(errorMsg)) { + throw new RuntimeException(errorMsg); + } + }); + + // 删除 spring cache Cache cache = cacheManager.getCache(CacheConstants.USER_DETAILS); for (SysUser sysUser : userList) { cache.evict(sysUser.getUsername()); diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/resources/mapper/SysDeptMapper.xml b/pjcloud-upms/pjcloud-upms-biz/src/main/resources/mapper/SysDeptMapper.xml index 2b0f16b9b..26f0f5838 100644 --- a/pjcloud-upms/pjcloud-upms-biz/src/main/resources/mapper/SysDeptMapper.xml +++ b/pjcloud-upms/pjcloud-upms-biz/src/main/resources/mapper/SysDeptMapper.xml @@ -24,6 +24,7 @@ + @@ -37,6 +38,7 @@ a.name, a.hard_group_id, a.sort_order, + a.is_sync_zy, a.create_by, a.update_by, a.create_time, @@ -50,6 +52,9 @@ AND a.dept_id = #{dto.deptId} + + AND a.is_sync_zy = #{dto.isSyncZy} + @@ -69,9 +74,11 @@ + + + + + \ No newline at end of file diff --git a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/MchManageMapper.xml b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchManageMapper.xml similarity index 81% rename from pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/MchManageMapper.xml rename to pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchManageMapper.xml index ca14f6af0..400887fe2 100644 --- a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/MchManageMapper.xml +++ b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchManageMapper.xml @@ -2,7 +2,7 @@ - + @@ -14,6 +14,10 @@ + + + + diff --git a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleMchConfigMapper.xml b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchRuleJoinMapper.xml similarity index 59% rename from pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleMchConfigMapper.xml rename to pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchRuleJoinMapper.xml index b4cdc813b..015011d50 100644 --- a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleMchConfigMapper.xml +++ b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchRuleJoinMapper.xml @@ -1,13 +1,14 @@ - - + + - + + @@ -21,6 +22,7 @@ a.source_mch_id, a.target_mch_id, a.rule_price_config_id, + a.status, a.create_by, a.create_time, a.update_by, @@ -42,17 +44,38 @@ - p.id as rulePirceConfigId, p.rule_price_type, p.base_price, - p.multiple - from wallet_rule_mch_config a - left join wallet_rule_price_config p on a.rule_price_config_id = p.id + p.multiple, + source.name as sourceMchName, + target.name as targetMchName + from mch_rule_join a + left join mch_rule_price_config p on a.rule_price_config_id = p.id + left join mch_manage source on source.id = a.source_mch_id + left join mch_manage target on target.id = a.target_mch_id order by a.create_time desc , a.id desc + + \ No newline at end of file diff --git a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRulePriceConfigMapper.xml b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchRulePriceConfigMapper.xml similarity index 84% rename from pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRulePriceConfigMapper.xml rename to pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchRulePriceConfigMapper.xml index 39e197642..1a896a330 100644 --- a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRulePriceConfigMapper.xml +++ b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/mch/MchRulePriceConfigMapper.xml @@ -1,9 +1,9 @@ - + - + @@ -15,4 +15,6 @@ + + \ No newline at end of file diff --git a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleJoinMapper.xml b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleJoinMapper.xml new file mode 100644 index 000000000..c8615e689 --- /dev/null +++ b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleJoinMapper.xml @@ -0,0 +1,79 @@ + + + + + + + + + + + + + + + + + + + + + select a.id, + a.source_wallet_type_id, + a.target_wallet_type_id, + a.target_dept_id, + a.balance_multiple, + a.status, + a.create_by, + a.create_time, + a.update_by, + a.update_time, + a.del_flag, + a.tenant_id, + + + + a.del_flag = 0 + + and a.source_wallet_type_id = #{dto.sourceWalletTypeId} + + + and a.target_wallet_type_id = #{dto.targetWalletTypeId} + + + and a.target_dept_id = #{dto.targetDeptId} + + + + + + + \ No newline at end of file diff --git a/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleTransactionMapper.xml b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleTransactionMapper.xml new file mode 100644 index 000000000..f0a0f878b --- /dev/null +++ b/pjcloud-wallet/pjcloud-wallet-biz/src/main/resources/mapper/rule/WalletRuleTransactionMapper.xml @@ -0,0 +1,85 @@ + + + + + + + + + + + + + + + + + + + + + + + + select a.id, + a.source_wallet_id, + a.target_wallet_id, + a.source_wallet_balance, + a.target_wallet_balance, + a.balance, + a.after_balance, + a.balance_multiple, + a.is_refund, + a.create_by, + a.create_time, + a.update_by, + a.update_time, + a.del_flag, + a.tenant_id, + + + + a.del_flag = 0 + + and a.source_wallet_id = #{dto.sourceWalletId} + + + and a.target_wallet_id = #{dto.targetWalletId} + + + + + \ No newline at end of file