|
@@ -31,6 +31,8 @@ import org.springframework.util.LinkedMultiValueMap;
|
|
|
import org.springframework.web.client.RestTemplate;
|
|
|
import org.springframework.web.multipart.MultipartFile;
|
|
|
import org.springframework.web.util.UriComponentsBuilder;
|
|
|
+import reactor.util.function.Tuple2;
|
|
|
+import reactor.util.function.Tuples;
|
|
|
|
|
|
import java.net.URI;
|
|
|
import java.util.Collections;
|
|
@@ -61,8 +63,7 @@ public class KfMsgContentServiceImpl extends ServiceImpl<KfMsgContentMapper, KfM
|
|
|
private IGameAppletService gameAppletService;
|
|
|
|
|
|
@Override
|
|
|
- public String uploadMsg(KfApiParam param, MultipartFile files) {
|
|
|
- log.error("发送图片消息参数, param : {}", JsonUtil.toString(param));
|
|
|
+ public Tuple2<String, String> uploadMsg(KfApiParam param, MultipartFile files) {
|
|
|
//查询用户授权信息
|
|
|
KfUser kfUser = kfUserService.getKfUser(SecurityUtil.getUserId(), param.getAppId());
|
|
|
//图片上传腾讯
|
|
@@ -73,9 +74,10 @@ public class KfMsgContentServiceImpl extends ServiceImpl<KfMsgContentMapper, KfM
|
|
|
Map<String, Object> paramMap = param.getParam();
|
|
|
paramMap.put("msg_content", uploadResult);
|
|
|
paramMap.put("msg_id", uploadResultMap.get("msg_id"));
|
|
|
- log.error("解析出来的参数, paramMap : {}", JsonUtil.toString(paramMap));
|
|
|
//腾讯api
|
|
|
- return this.commKfApi(kfUser, param.getAction().getValue(), KfApiEnum.getApiUrl(param.getAction()), paramMap);
|
|
|
+ String apiResult = this.commKfApi(kfUser, param.getAction().getValue(), KfApiEnum.getApiUrl(param.getAction()), paramMap);
|
|
|
+ //返回图片上传结果和消息发送结果
|
|
|
+ return Tuples.of(uploadResult, apiResult);
|
|
|
}
|
|
|
|
|
|
private String imgUploadApi(KfUser kfUser, MultipartFile files) {
|