新增视频号客服消息模型

Author: binarywang

.superpowers/sdd/task-1-report.md

@@ -0,0 +1,22 @@
+# Task 1 报告
+
+## 修改
+
+- 新增 `WxChannelKfCosUploadResponse`，映射 `cos_url` 并继承频道基础响应。
+- 新增 `WxChannelKfSendMsgParam`，映射 `request_id`、`open_id`、`msg_type` 和嵌套 `text.content`。
+- 新增 `WxChannelKfSendMsgResponse`，映射 `msg_id` 并继承频道基础响应。
+- 新增 TestNG JSON 编解码测试 `WxChannelKfBeanTest`。
+
+## TDD 测试
+
+- 红灯：`mvn -pl weixin-java-channel -Dtest=WxChannelKfBeanTest -DfailIfNoTests=false test`，因 3 个模型类不存在，在 testCompile 阶段失败。
+- 绿灯：`mvn -pl weixin-java-channel dependency:build-classpath -Dmdep.outputFile=/tmp/wxjava-channel-test-cp.txt -Dmdep.includeScope=test -q && TEST_CP="$(cat /tmp/wxjava-channel-test-cp.txt)" && java -cp "weixin-java-channel/target/test-classes:weixin-java-channel/target/classes:${TEST_CP}" org.testng.TestNG -testclass me.chanjar.weixin.channel.bean.kf.WxChannelKfBeanTest`，3 个测试通过，0 失败，0 跳过。
+- `git diff --check`：通过。
+
+## Commit
+
+`d742d673b`（新增视频号客服消息模型）。
+
+## 顾虑
+
+仓库父 POM 的 Surefire pluginManagement 默认配置 `skip=true`，因此 Maven 测试命令会显示 Tests are skipped；已使用同一编译产物和依赖通过 TestNG CLI 实际执行测试。

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/bean/kf/WxChannelKfCosUploadResponse.java

@@ -0,0 +1,20 @@
+package me.chanjar.weixin.channel.bean.kf;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import me.chanjar.weixin.channel.bean.base.WxChannelBaseResponse;
+
+/** 客服素材上传响应。 */
+@Data
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+public class WxChannelKfCosUploadResponse extends WxChannelBaseResponse {
+
+  private static final long serialVersionUID = 1L;
+
+  /** 素材在 COS 上的地址。 */
+  @JsonProperty("cos_url")
+  private String cosUrl;
+}

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/bean/kf/WxChannelKfSendMsgParam.java

@@ -0,0 +1,40 @@
+package me.chanjar.weixin.channel.bean.kf;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/** 发送客服消息请求参数。 */
+@Data
+@NoArgsConstructor
+public class WxChannelKfSendMsgParam implements Serializable {
+
+  private static final long serialVersionUID = 1L;
+
+  /** 请求幂等标识。 */
+  @JsonProperty("request_id")
+  private String requestId;
+
+  /** 接收消息的用户 openid。 */
+  @JsonProperty("open_id")
+  private String openId;
+
+  /** 消息类型。 */
+  @JsonProperty("msg_type")
+  private String msgType;
+
+  /** 文本消息内容。 */
+  @JsonProperty("text")
+  private Text text;
+
+  @Data
+  @NoArgsConstructor
+  public static class Text implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @JsonProperty("content")
+    private String content;
+  }
+}

weixin-java-channel/src/main/java/me/chanjar/weixin/channel/bean/kf/WxChannelKfSendMsgResponse.java

@@ -0,0 +1,20 @@
+package me.chanjar.weixin.channel.bean.kf;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import me.chanjar.weixin.channel.bean.base.WxChannelBaseResponse;
+
+/** 发送客服消息响应。 */
+@Data
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+public class WxChannelKfSendMsgResponse extends WxChannelBaseResponse {
+
+  private static final long serialVersionUID = 1L;
+
+  /** 消息 id。 */
+  @JsonProperty("msg_id")
+  private String msgId;
+}

weixin-java-channel/src/test/java/me/chanjar/weixin/channel/bean/kf/WxChannelKfBeanTest.java

@@ -0,0 +1,59 @@
+package me.chanjar.weixin.channel.bean.kf;
+
+import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertFalse;
+import static org.testng.Assert.assertNotNull;
+
+import me.chanjar.weixin.channel.util.JsonUtils;
+import org.testng.annotations.Test;
+
+/** JSON serialization tests for channel customer service models. */
+public class WxChannelKfBeanTest {
+
+  @Test
+  public void testSendMsgParamJson() {
+    WxChannelKfSendMsgParam param = new WxChannelKfSendMsgParam();
+    param.setRequestId("request-1");
+    param.setOpenId("open-1");
+    param.setMsgType("text");
+    WxChannelKfSendMsgParam.Text text = new WxChannelKfSendMsgParam.Text();
+    text.setContent("hello");
+    param.setText(text);
+
+    String json = JsonUtils.encode(param);
+    assertNotNull(json);
+    assertFalse(json.contains("requestId"));
+    assertFalse(json.contains("openId"));
+    assertFalse(json.contains("msgType"));
+    WxChannelKfSendMsgParam decoded = JsonUtils.decode(json, WxChannelKfSendMsgParam.class);
+    assertEquals(decoded.getRequestId(), "request-1");
+    assertEquals(decoded.getOpenId(), "open-1");
+    assertEquals(decoded.getMsgType(), "text");
+    assertNotNull(decoded.getText());
+    assertEquals(decoded.getText().getContent(), "hello");
+  }
+
+  @Test
+  public void testCosUploadResponseJson() {
+    WxChannelKfCosUploadResponse response = JsonUtils.decode(
+      "{\"errcode\":0,\"errmsg\":\"ok\",\"cos_url\":\"https://example.test/media\"}",
+      WxChannelKfCosUploadResponse.class);
+
+    assertEquals(response.getErrCode(), 0);
+    assertEquals(response.getCosUrl(), "https://example.test/media");
+    assertEquals(JsonUtils.decode(JsonUtils.encode(response), WxChannelKfCosUploadResponse.class)
+      .getCosUrl(), "https://example.test/media");
+  }
+
+  @Test
+  public void testSendMsgResponseJson() {
+    WxChannelKfSendMsgResponse response = JsonUtils.decode(
+      "{\"errcode\":0,\"errmsg\":\"ok\",\"msg_id\":\"msg-1\"}",
+      WxChannelKfSendMsgResponse.class);
+
+    assertEquals(response.getErrCode(), 0);
+    assertEquals(response.getMsgId(), "msg-1");
+    assertEquals(JsonUtils.decode(JsonUtils.encode(response), WxChannelKfSendMsgResponse.class)
+      .getMsgId(), "msg-1");
+  }
+}