diff --git a/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayMemberService.java b/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayMemberService.java index bb58885f2..5e1f39816 100644 --- a/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayMemberService.java +++ b/jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayMemberService.java @@ -1,10 +1,16 @@ package com.jsowell.adapay.service; import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.PropertyNamingStrategies; import com.google.common.collect.Maps; import com.huifu.adapay.model.Member; import com.jsowell.common.util.id.IdUtils; +import com.jsowell.pile.domain.AdapayMemberInfo; +import com.jsowell.pile.service.AdapayMemberInfoService; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.HashMap; @@ -13,6 +19,9 @@ import java.util.Map; @Slf4j @Service public class AdapayMemberService { + + @Autowired + private AdapayMemberInfoService adapayMemberInfoService; /** * 创建汇付会员 */ @@ -30,8 +39,13 @@ public class AdapayMemberService { Map member = Member.create(memberParams); log.info("创建用户,返回参数:" + JSON.toJSONString(member)); log.info("=======execute CreateMember end======="); - // 创建成功保存到数据库 + // 创建成功保存到数据库 + JSONObject jsonObject = JSON.parseObject(String.valueOf(member)); + ObjectMapper mapper = new ObjectMapper(); + mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE); + AdapayMemberInfo adapayMemberInfo = mapper.readValue(jsonObject.toJSONString(), AdapayMemberInfo.class); + adapayMemberInfoService.insert(adapayMemberInfo); return member; }