Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

    <dependency>
        <groupId>com.github.binarywang</groupId>
        <artifactId>weixin-java-mp</artifactId>
        <version>4.7.0</version>
    </dependency>
    <dependency>
        <groupId>org.jsoup</groupId>
        <artifactId>jsoup</artifactId>
        <version>1.14.3</version> <!-- or latest version China编程-->
    </dependency>

import me.chanjar.weixin.mp.api.WxMpService;
import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class WeChatConfig {
    @Value("${wechat.mp.appId}")
    private String appId;
    @Value("${wechat.mp.appSecret}")
    private String appSecret;
    @Bean
    public WxMpService wxMpService() {
        WxMpService wxMpService = new WxMpServiceImpl();
        wxMpService.setWxMpConfigStorage(wxMpConfigStorage());
        return wxMpService;
    }
    @Bean
    public me.chanjar.weixin.mp.config.WxMpConfigStorage wxMpConfigStorage() {
        me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl wxMpConfigStorage = new me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl();
        wxMpConfigStorage.setAppId(appId);
        wxMpConfigStorage.setSecret(appSecret);
        return wxMpConfigStorage;
    }
}

wechat.mp.appId=your_apChina编程p_id
wechat.mp.appSecret=your_app_secret

@Data
public class WeChatArticle {
    private String title;
    private String content;
    private String author;
    // 其他文章属性，如封面图片URL等可根据需求添加
}

import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.mp.api.WxMpService;
import me.chanjar.weixin.mp.bean.material.WxMpMassArticle;
import me.chanjar.weixin.mp.bean.material.WxMpMassArticleArticle;
import me.chanjar.weixin.mp.bean.material.WxMpMaterialArticleUploadResult;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class WeChatArticleService {
    @Resource
    private WxMpService wxMpService;
    public String addDraft(String title, String content, String thumbnailUrl) throws WxErrorException {
        // 提取图片URL并替换
        List<String> imageUrls = extractImageUrls(content);
        for (String imgUrl : imageUrls) {
            String wechatUrl = uploadImage(imgUrl);
            content = content.replace(imgUrl, wechatUrl);
        }
        WxMpDraftArticles article = new WxMpDraftArticles();
        article.setAuthor("拾壹");
        article.setContent(content);
        article.setTitle(title);
        article.setThumbMediaId(mediaUploadInImage(thumbnailUrl));
        // 可根据需求设置更多文章属性，如封面图片等
        WxMpAddDraft news = new WxMpAddDraft();
        news.setArticles(Collections.singletonList(article));
        return wxMpService.getDraftService().addDraft(news);
    }
      /**
     * 根据url上传永久素材
     * @param url 图片url
     * @return 微信素材ID
     */
    public String mediaUploadInImage(String url) throws IOException, WxErrorException {
        byte[] bytes = this.downloadImage(url);
        File file = convert(bytes);
        String mediaId = materialFileUpload("image",file);
        FileUtil.del(file);
        return mediaId;
    }
    /**
     * 根据文件上传永久素材
     * @param type 文件类型
     * @param file 文件
     * @return 微信素材ID
     */
    public String materialFileUpload(String type,File file) throws IOException, WxErrorException {
        WxMpMaterial wxMpMaterial = new WxMpMaterial();
        wxMpMaterial.setFile(file);
        WxMpMaterialUploadResult image = wxMpService.getMaterialService().materialFileUpload(type,wxMpMaterial);
        return image.getMediaId();
    }
      /**
     * 根据url上传图片
     * @param url 图片url
     * @return 微信可访问的url地址
     */
    public String uploadImage(String url) throws IOException, WxErrorException {
        byte[] bytes = this.downloadImage(url);
        //bytes转成file
        File file = convert(bytes);
        WxMediaImgUploadResult wxMediaImgUploadResult = wxMpService.getMaterialService().mediaImgUpload(file);
        FileUtil.del(file);
        return wxMediaImgUploadResult.getUrl();
    }
      /**
     * byte[] 转 File
     *
     * @param bytes
     * @return
     * @throws IOException
     */
    public static File convert(byte[] bytes) throws IOException {
        // 创建一个临时文件
        File tempFile = File.createTempFile("temp-", ".png");
        // 使用 FileOutputStream 将字节数组写入文件
        try (FileOutputStream fos = new FileOutputStream(tempFile)) {
            fos.write(bytes);
        }
        return tempFile;
    }
      /**
     * 下载图片
     *
     * @param url
     * @return
     */
    private byte[] downloadImage(String url) {
        return new RestTemplate().getForObject(url, byte[].class);
    }
      /**
     * 提取 HTML 中的图片 URL
 GJjqfUd    */
    private List<String> extractImageUrls(String html) {
        org.jsoup.nodes.Document doc = Jsoup.parse(html);
        return doc.select("img").stream()
                .map(img -> img.attr("src"))
                .collect(Collectors.toList());
    }
}

import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.mp.api.WxMpService;
import me.chanjar.weixin.mp.bean.material.WxMpMassArticle;
import me.chanjar.weixin.mp.bean.material.WxMpMassArticleArticle;
import me.chanjar.weixin.mp.bean.material.WxMpMaterialArticleUploadResult;
import me.chanjar.weixin.mp.bean.message.WxMpMassMessage;
import me.chanjar.weixin.mp.bean.message.WxMpMassMessageResult;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class WeChatArticleService {
    public void wechatSendAll(String mediaId)www.chinasem.cn {
        try {
            WxMpDraftInfo draft = wxMpService.getDraftService().getDraft(mediaId);
            if (draft == null || draft.getNewsItem() == null || draft.getNewsItem().isEmpty()) {
                throw new ServiceException("无效的mediaId: " + mediaId);
            }
            WxMpMassTagMessage wxMpMassTagMessage = new WxMpMassTagMessage();
            wxMpMassTagMessage.setMediaId(mediaId);
            wxMpMassTagMessage.setMsgType("mpnews");
            wxMpMassTagMessage.setSendAll(true);
            wxMpMassTagMessage.setSendIgnoreReprint(true);
            wxMpService.getMassMessageService().massGroupMessageSend(wxMpMassTagMessage);
        } catch (WxErrorException e) {
            log.error("微信群发失败", e);
            throw new RuntimeException(e);
        }
    }
}