2 Commits 28a7688802 ... c0dcdbff17

Author SHA1 Message Date
  luoyb c0dcdbff17 Merge remote-tracking branch 'origin/master' 5 days ago
  luoyb c98b5e92fd feature: kafka消费信息处理 5 days ago

+ 5 - 0
ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/consumption/domain/bo/ConsumptionBo.java

@@ -119,6 +119,11 @@ public class ConsumptionBo extends BaseEntity {
119 119
      * 交易类型
120 120
      */
121 121
     private CreditTypeEnum creditType;
122
+
123
+    /**
124
+     * 租户编号
125
+     */
126
+    private String tenantId;
122 127
     //endregion
123 128
 
124 129
     //region 错扣补款属性

File diff suppressed because it is too large
+ 45 - 32
ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/mq/KafkaNormalConsumer.java


+ 5 - 5
ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/payment/mapper/PtUserAccountMapper.java

@@ -31,11 +31,11 @@ public interface PtUserAccountMapper extends BaseMapperPlus<PtUserAccount, PtUse
31 31
 
32 32
     Page<PtUserAccount4SelectVo> customPageList(Page<PtUserAccount> page, @Param("bo") PtUserAccountBo bo);
33 33
 
34
-    @Override
35
-    @DataPermission({
36
-        @DataColumn(key = "deptName", value = "dept_id"),
37
-    })
38
-    List<PtUserAccount> selectList(@Param(Constants.WRAPPER) Wrapper<PtUserAccount> queryWrapper);
34
+    //@Override
35
+    //@DataPermission({
36
+    //    @DataColumn(key = "deptName", value = "dept_id"),
37
+    //})
38
+    //List<PtUserAccount> selectList(@Param(Constants.WRAPPER) Wrapper<PtUserAccount> queryWrapper);
39 39
 
40 40
     default Page<PtUserAccountVo>customSelectVoPage(Page<PtUserAccount> page, Wrapper<PtUserAccount> wrapper){
41 41
         // 根据条件分页查询实体对象列表

+ 4 - 2
ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/payment/service/impl/PtUserAccountServiceImpl.java

@@ -438,9 +438,11 @@ public class PtUserAccountServiceImpl implements IPtUserAccountService {
438 438
      */
439 439
     @Override
440 440
     public PtUserAccountVo queryByNameAndNumb(String realName, String userNumb) {
441
-        PtUserAccountVo vo = baseMapper.selectVoOne(Wrappers.<PtUserAccount>lambdaQuery()
441
+        LambdaQueryWrapper<PtUserAccount> query = new LambdaQueryWrapper<PtUserAccount>()
442 442
             .eq(PtUserAccount::getRealName,realName)
443
-            .eq(PtUserAccount::getUserNumb,userNumb));
443
+            .eq(PtUserAccount::getUserNumb,userNumb);
444
+
445
+        PtUserAccountVo vo = baseMapper.selectVoOne(query);
444 446
         if(vo!=null) {
445 447
             String deptName = remoteDeptService.selectDeptNameByIds(vo.getDeptId().toString());
446 448
             vo.setDeptName(deptName);