Przeglądaj źródła

合伙人同步bug修复

mac 2 lat temu
rodzic
commit
596c00f063

+ 5 - 0
kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/impl/KxsLeaderAmountLogServiceImpl.java

@@ -38,6 +38,11 @@ public class KxsLeaderAmountLogServiceImpl extends ServiceImpl<KxsLeaderAmountLo
 
 
         //操作类型
         //操作类型
         OperationType operation = dmlData.getOperation();
         OperationType operation = dmlData.getOperation();
+        if (operation.equals(OperationType.DELETE)) {
+            // 删除数据
+            baseMapper.deleteById(id);
+            return;
+        }
 
 
         for (String field : changeFieldList) {
         for (String field : changeFieldList) {
 
 

+ 1 - 1
kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/impl/KxsUserServiceImpl.java

@@ -172,7 +172,7 @@ public class KxsUserServiceImpl extends ServiceImpl<KxsUserMapper, KxsUser> impl
                     //合伙人等级改变
                     //合伙人等级改变
                     int userType = Integer.parseInt(fieldDataMap.get(field).toString());
                     int userType = Integer.parseInt(fieldDataMap.get(field).toString());
                     if(userType > 0){
                     if(userType > 0){
-                        KxsPartner kxsPartner = kxsPartnerMapper.selectById(Wrappers.<KxsPartner>lambdaQuery().eq(KxsPartner::getUserId, userId));
+                        KxsPartner kxsPartner = kxsPartnerMapper.selectOne(Wrappers.<KxsPartner>lambdaQuery().eq(KxsPartner::getUserId, userId));
                         if (kxsPartner == null){
                         if (kxsPartner == null){
                             kxsPartner = new KxsPartner();
                             kxsPartner = new KxsPartner();
                             kxsPartner.setId(Integer.valueOf(userId));
                             kxsPartner.setId(Integer.valueOf(userId));