收支明细同步来源创客

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/user/KxsChangeTypeKindMapper.java

@@ -0,0 +1,17 @@
+package com.kxs.transfer.api.mapper.user;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.user.api.model.KxsChangeTypeKind;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 收支明细分类明细表(KxsChangeTypeKind)表数据库访问层
+ *
+ * @author 系统
+ * @since 2024-04-29 14:20:11
+ */
+@Mapper
+public interface KxsChangeTypeKindMapper extends BaseMapper<KxsChangeTypeKind> {
+
+}
+

kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/impl/KxsUserAmountLogServiceImpl.java

@@ -3,6 +3,7 @@ package com.kxs.transfer.api.service.user.impl;
 import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.date.LocalDateTimeUtil;
 import com.aliyun.dts.subscribe.clients.record.OperationType;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.kxs.common.core.constant.enums.AmountLogChangeTypesEnum;
 import com.kxs.common.core.constant.enums.KindTypeEnum;
@@ -16,16 +17,14 @@ import com.kxs.product.api.model.KxsShopOrder;
 import com.kxs.product.api.vo.kxsapp.shop.ShopOrderDetailVO;
 import com.kxs.transfer.api.mapper.product.KxsMachineMapper;
 import com.kxs.transfer.api.mapper.product.KxsShopOrderMapper;
+import com.kxs.transfer.api.mapper.user.KxsChangeTypeKindMapper;
 import com.kxs.transfer.api.mapper.user.KxsLeaderAmountLogMapper;
 import com.kxs.transfer.api.mapper.user.KxsUserAmountLogMapper;
 import com.kxs.transfer.api.mapper.user.KxsUserMapper;
 import com.kxs.transfer.api.model.table.DMLData;
 import com.kxs.transfer.api.model.table.FieldData;
 import com.kxs.transfer.api.service.user.KxsUserAmountLogService;
-import com.kxs.user.api.model.KxsLeaderAmountLog;
-import com.kxs.user.api.model.KxsUser;
-import com.kxs.user.api.model.KxsUserAmount;
-import com.kxs.user.api.model.KxsUserAmountLog;
+import com.kxs.user.api.model.*;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -35,6 +34,7 @@ import java.time.LocalDateTime;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * 用户余额记录日志表(KxsUserAmountLog)表服务实现类
@@ -51,6 +51,8 @@ public class KxsUserAmountLogServiceImpl extends ServiceImpl<KxsUserAmountLogMap
     private final KxsUserMapper userMapper;
     private final KxsShopOrderMapper orderMapper;
     private final KxsMachineMapper machineMapper;
+    private final KxsChangeTypeKindMapper kxsChangeTypeKindMapper;
+
     @Override
     public void changeData(DMLData dmlData) {
         //修改的字段值
@@ -63,7 +65,9 @@ public class KxsUserAmountLogServiceImpl extends ServiceImpl<KxsUserAmountLogMap
         int id = Integer.parseInt(dmlData.getId());
 
         //增加的changeType
-        List<Integer> adds = Arrays.asList(0, 1, 6, 12, 21, 30, 31, 50, 60, 62, 64, 66, 111, 112, 114, 115, 116, 117, 118, 119, 120, 121, 122, 123, 126, 127, 128, 129, 130, 131, 133, 134, 135, 136, 137, 301, 311, 312, 313, 314, 315);
+        List<KxsChangeTypeKind> kxsChangeTypeKinds = kxsChangeTypeKindMapper.selectList(Wrappers.<KxsChangeTypeKind>lambdaQuery().eq(KxsChangeTypeKind::getKind, 1));
+        List<Integer> adds = kxsChangeTypeKinds.stream().map(KxsChangeTypeKind::getId).toList();
+//        List<Integer> adds = Arrays.asList(0, 1, 6, 12, 21, 30, 31, 50, 60, 62, 64, 66, 111, 112, 114, 115, 116, 117, 118, 119, 120, 121, 122, 123, 126, 127, 128, 129, 130, 131, 133, 134, 135, 136, 137, 301, 311, 312, 313, 314, 315);
 
         KxsUserAmountLog userAmountLog = new KxsUserAmountLog();
         userAmountLog.setId(id);