update

jsowell-admin/src/main/java/com/jsowell/service/TempService.java

@@ -21,6 +21,7 @@ import com.jsowell.common.constant.Constants;
 import com.jsowell.common.constant.RabbitConstants;
 import com.jsowell.common.core.domain.ykc.TransactionRecordsData;
 import com.jsowell.common.core.redis.RedisCache;
+import com.jsowell.common.enums.MemberWalletEnum;
 import com.jsowell.common.enums.adapay.AdapayStatusEnum;
 import com.jsowell.common.enums.adapay.MerchantDelayModeEnum;
 import com.jsowell.common.enums.ykc.*;
@@ -65,6 +66,10 @@ import java.util.stream.Collectors;
 @Service
 public class TempService {
 
+    private static final String JSOWELL_MEMBER_MERCHANT_ID = "1";
+
+    private static final String NANTONG_CHENMING_WALLET_MERCHANT_ID = "575";
+
     private Logger logger = LoggerFactory.getLogger(this.getClass());
 
     @Autowired
@@ -1557,22 +1562,105 @@ public class TempService {
     /**
      * 从文件中导入会员余额
      */
-    public void batchImportMemberBalance(List<ImportMemberBalanceDTO> list) {
+    public BatchImportMemberBalanceResultDTO batchImportMemberBalance(List<ImportMemberBalanceDTO> list) {
+        BatchImportMemberBalanceResultDTO result = new BatchImportMemberBalanceResultDTO();
         if (CollectionUtils.isEmpty(list)) {
-            return;
+            return result;
+        }
+
+        result.setTotalCount(list.size());
+        List<ImportMemberBalanceItemResultDTO> itemResults = list.parallelStream()
+                .map(this::importMemberBalanceSafely)
+                .collect(Collectors.toList());
+
+        long successCount = itemResults.stream().filter(ImportMemberBalanceItemResultDTO::isSuccess).count();
+        List<ImportMemberBalanceItemResultDTO> failedList = itemResults.stream()
+                .filter(item -> !item.isSuccess())
+                .collect(Collectors.toList());
+
+        result.setSuccessCount((int) successCount);
+        result.setFailCount(failedList.size());
+        result.setFailedList(failedList);
+
+        logger.info("批量导入会员余额完成, totalCount:{}, successCount:{}, failCount:{}",
+                result.getTotalCount(), result.getSuccessCount(), result.getFailCount());
+        return result;
+    }
+
+    private ImportMemberBalanceItemResultDTO importMemberBalanceSafely(ImportMemberBalanceDTO memberBalanceDTO) {
+        String phone = memberBalanceDTO != null ? memberBalanceDTO.getPhone() : null;
+        try {
+            importMemberBalance(memberBalanceDTO);
+            return ImportMemberBalanceItemResultDTO.success(phone);
+        } catch (Exception e) {
+            logger.error("导入会员余额失败, phone:{}, param:{}", phone, JSON.toJSONString(memberBalanceDTO), e);
+            return ImportMemberBalanceItemResultDTO.fail(phone, e.getMessage());
         }
-        list.parallelStream().forEach(this::importMemberBalance);
     }
 
     private void importMemberBalance(ImportMemberBalanceDTO memberBalanceDTO) {
-        // 1. 根据手机号查询万车充会员信息
-        MemberBasicInfo memberBasicInfo = memberBasicInfoService.selectInfoByMobileNumber(memberBalanceDTO.getPhone(), "1");
-        // 2. 如果没有万车充会员信息，则自动注册万车充会员，并创建“南通晨鸣中锦置业有限责任公司”运营商钱包
-        if (memberBasicInfo == null) {
-
+        if (memberBalanceDTO == null) {
+            throw new BusinessException("", "导入会员余额失败，参数不能为空");
+        }
+        String phone = memberBalanceDTO.getPhone();
+        BigDecimal balance = memberBalanceDTO.getBalance();
+        if (StringUtils.isBlank(phone)) {
+            throw new BusinessException("", "导入会员余额失败，手机号不能为空");
+        }
+        if (balance == null || balance.compareTo(BigDecimal.ZERO) <= 0) {
+            throw new BusinessException("", "导入会员余额失败，余额必须大于0");
         }
 
-        // 3. 根据balance添加余额
-    }
-}
+        // 1. 根据手机号查询万车充会员信息；不存在则静默注册一个属于万车充体系的会员。
+        MemberBasicInfo memberBasicInfo = findOrCreateJsowellMember(phone);
 
+        // 2. 给“南通晨鸣中锦置业有限责任公司”运营商钱包增加本金余额。
+        increaseMemberWalletBalance(memberBasicInfo.getMemberId(), balance);
+
+        logger.info("导入会员余额成功, phone:{}, memberId:{}, merchantId:{}, balance:{}",
+                phone, memberBasicInfo.getMemberId(), NANTONG_CHENMING_WALLET_MERCHANT_ID, balance);
+    }
+
+    /**
+     * 根据手机号查询万车充会员；若不存在，则自动注册后重新查询。
+     */
+    private MemberBasicInfo  findOrCreateJsowellMember(String phone) {
+        MemberBasicInfo memberBasicInfo = memberBasicInfoService.selectInfoByMobileNumber(phone, JSOWELL_MEMBER_MERCHANT_ID);
+        if (memberBasicInfo != null) {
+            return memberBasicInfo;
+        }
+
+        logger.info("导入会员余额时未查询到万车充会员，开始自动注册, phone:{}, merchantId:{}",
+                phone, JSOWELL_MEMBER_MERCHANT_ID);
+        MemberRegisterAndLoginDTO loginDTO = MemberRegisterAndLoginDTO.builder()
+                .mobileNumber(phone)
+                .firstLevelMerchantId(JSOWELL_MEMBER_MERCHANT_ID)
+                .build();
+        memberService.memberRegisterAndLoginV2(loginDTO);
+
+        memberBasicInfo = memberBasicInfoService.selectInfoByMobileNumber(phone, JSOWELL_MEMBER_MERCHANT_ID);
+        if (memberBasicInfo == null) {
+            logger.error("导入会员余额时自动注册后仍未查询到会员, phone:{}, merchantId:{}",
+                    phone, JSOWELL_MEMBER_MERCHANT_ID);
+            throw new BusinessException(ReturnCodeEnum.CODE_MEMBER_REGISTER_AND_LOGIN_ERROR);
+        }
+        return memberBasicInfo;
+    }
+
+    /**
+     * 给指定会员在目标运营商钱包中增加本金余额。
+     *
+     * <p>如果该运营商钱包不存在，现有余额逻辑会自动创建钱包并记录流水。</p>
+     */
+    private void increaseMemberWalletBalance(String memberId, BigDecimal balance) {
+        UpdateMemberBalanceDTO updateMemberBalanceDTO = UpdateMemberBalanceDTO.builder()
+                .memberId(memberId)
+                .type(MemberWalletEnum.TYPE_IN.getValue())
+                .subType(MemberWalletEnum.SUBTYPE_TOP_UP.getValue())
+                .updatePrincipalBalance(balance)
+                .targetMerchantId(NANTONG_CHENMING_WALLET_MERCHANT_ID)
+                .build();
+        memberBasicInfoService.updateMemberBalance(updateMemberBalanceDTO);
+    }
+
+}