public ReturnT sinaNews()

in xxljob-demo/xxljob-example-springboot/src/main/java/com/xxljob/executor/jobhandler/AIJob.java [38:91]
48 lines of code
3 McCabe index (conditional complexity)

	public ReturnT<String> sinaNews() throws Exception {
		String url = "https://finance.sina.com.cn/topnews/";
		String model = "deepseek-r1";
		ReturnT<String> rtn = ReturnT.SUCCESS;
		Document document = Jsoup.connect(url).get();
		// 定位到“汇总榜”部分
		Element summaryBlock = document.selectFirst("div.lbti:has(h2:containsOwn(汇总榜))");
		if (summaryBlock != null) {
			// 找到该块中的<script>标签
			Element scriptTag = summaryBlock.parent().selectFirst("script[src]");
			if (scriptTag != null) {
				String jobParam = XxlJobContext.getXxlJobContext().getJobParam();
				// 提取src属性值
				String srcValue = scriptTag.attr("src");
				HttpResponse<String> httpResponse = Unirest.get(srcValue).asString();
				String news = httpResponse.getBody();
				Map<String, Object> bodyMap = new HashMap<>();
				bodyMap.put("model", model);
				List<Map<String, String>> messagesList = new ArrayList<>();
				Map<String, String> message = new HashMap<>();
				message.put("role", "system");
				message.put("content", jobParam);
				messagesList.add(message);

				message = new HashMap<>();
				message.put("role", "user");
				message.put("content", "这是今天的财经新闻，帮我按规则解析：" + news );
				messagesList.add(message);
				bodyMap.put("messages", messagesList);
				String bodyJson = new Gson().toJson(bodyMap);
				Unirest.setTimeouts(120000, 120000); //加大timeout，防止超时退出
				HttpResponse<JsonNode> jsonHttpResponse =
						Unirest.post("https://dashscope.aliyuncs.com/compatible-mode/v1/chat/completions")
								.header("Authorization", "Bearer " + apiKey)
								.header("Content-Type", "application/json")
								.body(bodyJson)
								.asJson();
				OpenAIResponse openAIResponse =
						new Gson().fromJson(jsonHttpResponse.getBody().getObject().toString(), OpenAIResponse.class);
				rtn.setContent(openAIResponse.getChoices().get(0).getMessage().getContent());

				sendMessage(openAIResponse);

				XxlJobHelper.log(openAIResponse.getChoices().get(0).getMessage().getContent());
			} else {
				rtn.setCode(ReturnT.FAIL_CODE);
				rtn.setMsg("未找到汇总榜的<script>标签");
			}
		} else {
			rtn.setCode(ReturnT.FAIL_CODE);
			rtn.setMsg("未找到汇总榜部分");
		}
		return rtn;
	}