update

jsowell-pile/src/main/java/com/jsowell/adapay/dto/AdapayMemberInfoDTO.java

@@ -0,0 +1,21 @@
+package com.jsowell.adapay.dto;
+
+import lombok.*;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class AdapayMemberInfoDTO {
+    // 运营商id
+    private String merchantId;
+    // 地址
+    private String location;
+    // 电子邮箱
+    private String email;
+    // 性别
+    private String gender;
+    // 昵称
+    private String nickname;
+}

jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayMemberService.java

@@ -6,11 +6,14 @@ 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.adapay.dto.AdapayMemberInfoDTO;
+import com.jsowell.common.util.StringUtils;
 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.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import java.util.HashMap;
@@ -20,6 +23,9 @@ import java.util.Map;
 @Service
 public class AdapayMemberService {
 
+    @Value("${adapay.appId}")
+    private String ADAPAY_APP_ID;
+
     @Autowired
     private AdapayMemberInfoService adapayMemberInfoService;
 
@@ -115,4 +121,28 @@ public class AdapayMemberService {
         System.out.println("=======execute list Member end=======");
         return member;
     }
+
+    public void createMember(AdapayMemberInfoDTO dto) throws Exception {
+        log.info("=======execute CreateMember begin=======");
+        Map<String, Object> memberParams = Maps.newHashMap();
+        memberParams.put("member_id", "AM" + IdUtils.getMemberId());
+        memberParams.put("app_id", ADAPAY_APP_ID);
+        memberParams.put("location", dto.getLocation());
+        memberParams.put("email", dto.getEmail());
+        memberParams.put("gender", dto.getGender());
+        memberParams.put("nickname", dto.getNickname());
+        log.info("创建用户，请求参数：" + JSON.toJSONString(memberParams));
+        Map<String, Object> member = Member.create(memberParams);
+        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);
+            adapayMemberInfoService.insert(adapayMemberInfo);
+        }
+    }
 }