update 汇付会员

This commit is contained in:
2023-06-09 08:18:42 +08:00
parent a02bebb74f
commit bf9f2e5273
2 changed files with 21 additions and 10 deletions

View File

@@ -8,6 +8,7 @@ import com.google.common.collect.Maps;
import com.huifu.adapay.model.Member;
import com.jsowell.adapay.dto.AdapayMemberInfoDTO;
import com.jsowell.adapay.vo.AdapayMemberInfoVO;
import com.jsowell.common.exception.BusinessException;
import com.jsowell.common.util.StringUtils;
import com.jsowell.common.util.id.IdUtils;
import com.jsowell.pile.domain.AdapayMemberInfo;
@@ -138,15 +139,17 @@ public class AdapayMemberService {
log.info("创建用户,返回参数:" + JSON.toJSONString(member));
log.info("=======execute CreateMember end=======");
// 创建成功保存到数据库
if (member != null && StringUtils.equals((String)member.get("status"), "succeeded")) {
JSONObject jsonObject = JSON.parseObject(String.valueOf(member));
ObjectMapper mapper = new ObjectMapper();
mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);
AdapayMemberInfo adapayMemberInfo = mapper.readValue(jsonObject.toJSONString(), AdapayMemberInfo.class);
adapayMemberInfo.setMerchantId(dto.getMerchantId());
adapayMemberInfoService.insert(adapayMemberInfo);
if (member == null || StringUtils.equals((String)member.get("status"), "failed")) {
String errorMsg = member == null ? "创建汇付用户失败" : (String) member.get("error_msg");
throw new BusinessException("00500001", errorMsg);
}
// 创建成功保存到数据库
JSONObject jsonObject = JSON.parseObject(String.valueOf(member));
ObjectMapper mapper = new ObjectMapper();
mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);
AdapayMemberInfo adapayMemberInfo = mapper.readValue(jsonObject.toJSONString(), AdapayMemberInfo.class);
adapayMemberInfo.setMerchantId(dto.getMerchantId());
adapayMemberInfoService.insert(adapayMemberInfo);
}
public AdapayMemberInfoVO selectAdapayMember(String merchantId) {