mirror of
https://github.com/Wanxp/obsidian-douban.git
synced 2026-04-04 08:38:41 +08:00
523 lines
18 KiB
TypeScript
523 lines
18 KiB
TypeScript
import DoubanPlugin from "../../../main";
|
|
import DoubanSubject, {DoubanParameter} from '../model/DoubanSubject';
|
|
import DoubanSubjectLoadHandler from "./DoubanSubjectLoadHandler";
|
|
import {moment, request, RequestUrlParam, TFile} from "obsidian";
|
|
import {i18nHelper} from 'src/org/wanxp/lang/helper';
|
|
import {log} from "src/org/wanxp/utils/Logutil";
|
|
import {CheerioAPI, load} from "cheerio";
|
|
import YamlUtil from "../../../utils/YamlUtil";
|
|
import {
|
|
BasicConst,
|
|
PersonNameMode,
|
|
SearchHandleMode,
|
|
SupportType,
|
|
TemplateKey,
|
|
TemplateTextMode
|
|
} from "../../../constant/Constsant";
|
|
import HandleContext from "../model/HandleContext";
|
|
import HandleResult from "../model/HandleResult";
|
|
import {getDefaultTemplateContent} from "../../../constant/DefaultTemplateContent";
|
|
import StringUtil from "../../../utils/StringUtil";
|
|
import {DEFAULT_SETTINGS} from "../../../constant/DefaultSettings";
|
|
import {DoubanUserParameter, UserStateSubject} from "../model/UserStateSubject";
|
|
import {DoubanSubjectState, DoubanSubjectStateRecords} from "../../../constant/DoubanUserState";
|
|
import DoubanLoginModel from "../../component/DoubanLoginModel";
|
|
import DoubanHumanCheckModel from "../../component/DoubanHumanCheckModel";
|
|
import DoubanMovieSubject from "../model/DoubanMovieSubject";
|
|
import {Person} from "schema-dts";
|
|
|
|
export default abstract class DoubanAbstractLoadHandler<T extends DoubanSubject> implements DoubanSubjectLoadHandler<T> {
|
|
|
|
|
|
public doubanPlugin: DoubanPlugin;
|
|
|
|
constructor(doubanPlugin: DoubanPlugin) {
|
|
this.doubanPlugin = doubanPlugin;
|
|
}
|
|
|
|
async parse(extract: T, context: HandleContext): Promise<HandleResult> {
|
|
let template: string = await this.getTemplate(extract, context);
|
|
await this.saveImage(extract, context);
|
|
let frontMatterStart: number = template.indexOf(BasicConst.YAML_FRONT_MATTER_SYMBOL, 0);
|
|
let frontMatterEnd: number = template.indexOf(BasicConst.YAML_FRONT_MATTER_SYMBOL, frontMatterStart + 1);
|
|
let frontMatter: string = '';
|
|
let frontMatterBefore: string = '';
|
|
let frontMatterAfter: string = '';
|
|
let result: string = '';
|
|
if (frontMatterStart > -1 && frontMatterEnd > -1) {
|
|
frontMatterBefore = template.substring(0, frontMatterStart);
|
|
frontMatter = template.substring(frontMatterStart, frontMatterEnd + 3);
|
|
frontMatterAfter = template.substring(frontMatterEnd + 3);
|
|
if (frontMatterBefore.length > 0) {
|
|
frontMatterBefore = this.parsePartText(frontMatterBefore, extract, context);
|
|
}
|
|
if (frontMatterAfter.length > 0) {
|
|
frontMatterAfter = this.parsePartText(frontMatterAfter, extract, context);
|
|
}
|
|
if (frontMatter.length > 0) {
|
|
frontMatter = this.parsePartText(frontMatter, extract, context, TemplateTextMode.YAML);
|
|
}
|
|
result = frontMatterBefore + frontMatter + frontMatterAfter;
|
|
} else {
|
|
result = this.parsePartText(template, extract, context);
|
|
}
|
|
let fileName: string = '';
|
|
if (SearchHandleMode.FOR_CREATE == context.mode) {
|
|
fileName = this.parsePartText(this.getFileName(context), extract, context);
|
|
}
|
|
|
|
return {content: result, fileName: fileName, subject:extract};
|
|
}
|
|
|
|
private getFileName(context: HandleContext): string {
|
|
const {syncConfig} = context;
|
|
if (syncConfig) {
|
|
return syncConfig.dataFileNamePath;
|
|
}
|
|
const {dataFileNamePath} = context.settings;
|
|
return dataFileNamePath ? dataFileNamePath : DEFAULT_SETTINGS.dataFileNamePath;
|
|
}
|
|
|
|
/**
|
|
* 处理特殊字符
|
|
* @param text
|
|
* @param textMode
|
|
*/
|
|
handleSpecialText(text: string, textMode: TemplateTextMode): string {
|
|
let result = text;
|
|
switch (textMode) {
|
|
case TemplateTextMode.YAML:
|
|
result = YamlUtil.handleText(text);
|
|
break;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* 处理内容数组
|
|
* @param array
|
|
* @param settings
|
|
* @param textMode
|
|
*/
|
|
handleContentArray(array: any[], context: HandleContext, textMode: TemplateTextMode): string {
|
|
let result;
|
|
switch (textMode) {
|
|
// case TemplateTextMode.YAML:
|
|
// result = array.map(YamlUtil.handleText).join(', ');
|
|
// break;
|
|
default:
|
|
result = array.join(context.settings.arraySpilt);
|
|
}
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* 处理特殊内容
|
|
* @param value
|
|
* @param textMode
|
|
* @param settings
|
|
*/
|
|
handleSpecialContent(value: any, textMode: TemplateTextMode = TemplateTextMode.NORMAL, context: HandleContext = null): string {
|
|
let result;
|
|
if (!value) {
|
|
return '';
|
|
}
|
|
if (value instanceof Array) {
|
|
result = this.handleContentArray(value, context, textMode);
|
|
} else if (value instanceof Number) {
|
|
result = value.toString();
|
|
} else {
|
|
result = this.handleSpecialText(value, textMode);
|
|
}
|
|
return result;
|
|
}
|
|
|
|
abstract getSupportType(): SupportType;
|
|
|
|
abstract parseText(beforeContent: string, extract: T, context: HandleContext, textMode: TemplateTextMode): string;
|
|
|
|
abstract support(extract: DoubanSubject): boolean;
|
|
|
|
async handle(url: string, context: HandleContext): Promise<void> {
|
|
let headers = JSON.parse(context.settings.searchHeaders);
|
|
headers.Cookie = context.settings.loginCookiesContent;
|
|
context.plugin.settingsManager.debug(`开始请求地址:${url}`)
|
|
context.plugin.settingsManager.debug(`(注意:请勿向任何人透露你的Cookie,此处若需要截图请**打码**)请求cookie:${context.settings.loginCookiesContent}`)
|
|
const requestUrlParam: RequestUrlParam = {
|
|
url: url,
|
|
method: "GET",
|
|
headers: headers,
|
|
throw: true
|
|
};
|
|
await request(requestUrlParam)
|
|
.then(s => this.humanCheck(s, url))
|
|
.then(load)
|
|
.then(data => this.analysisUserState(data, context))
|
|
.then(({data, userState}) => {
|
|
let sub = this.parseSubjectFromHtml(data, context);
|
|
sub.userState = userState;
|
|
return sub;
|
|
})
|
|
.then(content => this.toEditor(context, content))
|
|
// .then(content => content ? editor.replaceSelection(content) : content)
|
|
.catch(e => {
|
|
log.error(i18nHelper.getMessage('130101', e.toString()), e);
|
|
if (url) {
|
|
let id = StringUtil.analyzeIdByUrl(url);
|
|
context.syncStatusHolder?context.syncStatusHolder.syncStatus.fail(id, ''):null;
|
|
}else {
|
|
context.syncStatusHolder?context.syncStatusHolder.syncStatus.handled(1):null;
|
|
}
|
|
});
|
|
;
|
|
|
|
}
|
|
|
|
|
|
abstract parseSubjectFromHtml(data: CheerioAPI, context: HandleContext): T | undefined;
|
|
|
|
async toEditor(context: HandleContext, extract: T): Promise<T> {
|
|
await this.doubanPlugin.putToObsidian(context, extract);
|
|
return extract;
|
|
}
|
|
|
|
getPersonName(name: string, context: HandleContext): string {
|
|
return this.getPersonNameByMode(name, context.settings.personNameMode);
|
|
}
|
|
|
|
getPersonName2(originalName: string, chineseName: string, context: HandleContext): string {
|
|
return this.getPersonNameByMode2(originalName, chineseName, context.settings.personNameMode);
|
|
}
|
|
|
|
|
|
getPersonNameByMode2(originalName: string, chineseName: string, personNameMode: string): string {
|
|
if (!originalName || !personNameMode) {
|
|
return "";
|
|
}
|
|
let resultName: string;
|
|
switch (personNameMode) {
|
|
case PersonNameMode.CH_NAME:
|
|
resultName = chineseName;
|
|
break;
|
|
case PersonNameMode.EN_NAME:
|
|
resultName = originalName.trim().replaceAll(chineseName, '').trim();
|
|
if (!resultName) {
|
|
resultName = originalName;
|
|
}
|
|
break;
|
|
default:
|
|
resultName = originalName;
|
|
}
|
|
return resultName;
|
|
}
|
|
|
|
|
|
getPersonNameByMode(name: string, personNameMode: string): string {
|
|
if (!name || !personNameMode) {
|
|
return "";
|
|
}
|
|
let resultName: string;
|
|
let regValue: RegExpExecArray;
|
|
switch (personNameMode) {
|
|
case PersonNameMode.CH_NAME:
|
|
regValue = /[\u4e00-\u9fa50-9\. ·\:\u3002|\uff1f|\uff01|\uff0c|\u3001|\uff1b|\uff1a|\u201c|\u201d|\u2018|\u2019|\uff08|\uff09|\u300a|\u300b|\u3008|\u3009|\u3010|\u3011|\u300e|\u300f|\u300c|\u300d|\ufe43|\ufe44|\u3014|\u3015|\u2026|\u2014|\uff5e|\ufe4f|\uffe5\(\)]{2,}/g.exec(name);
|
|
resultName = regValue ? regValue[0] : name;
|
|
break;
|
|
case PersonNameMode.EN_NAME:
|
|
regValue = /[0-9a-zA-Z.\s-:]{2,}/g.exec(name);
|
|
resultName = regValue ? regValue[0] : name;
|
|
break;
|
|
default:
|
|
resultName = name;
|
|
}
|
|
return resultName;
|
|
}
|
|
|
|
getTitleNameByMode(name: string, personNameMode: string, context: HandleContext): string {
|
|
if (!name || !personNameMode) {
|
|
return "";
|
|
}
|
|
if (context.listItem) {
|
|
const newName = context.listItem.title.trim().replaceAll(' ', '');
|
|
switch (personNameMode) {
|
|
case PersonNameMode.CH_NAME:
|
|
return newName;
|
|
break;
|
|
case PersonNameMode.EN_NAME:
|
|
return name.trim().replaceAll(' ', '').replaceAll(newName, '');
|
|
break;
|
|
}
|
|
}
|
|
return this.getPersonNameByMode(name, personNameMode);
|
|
}
|
|
|
|
// html_encode(str: string): string {
|
|
// let s = "";
|
|
// if (str.length == 0) return "";
|
|
// s = str.replace(/&/g, "&");
|
|
// s = s.replace(/</g, "<");
|
|
// s = s.replace(/>/g, ">");
|
|
// s = s.replace(/ /g, " ");
|
|
// s = s.replace(/\'/g, "'");
|
|
// s = s.replace(/\"/g, """);
|
|
// s = s.replace(/\n/g, "<br/>");
|
|
// return s;
|
|
// }
|
|
|
|
html_decode(str: string): string {
|
|
let s = "";
|
|
if (str.length == 0) return "";
|
|
s = str.replace(/&/g, "&");
|
|
s = s.replace(/</g, "<");
|
|
s = s.replace(/>/g, ">");
|
|
s = s.replace(/ /g, " ");
|
|
s = s.replace(/'/g, "\'");
|
|
s = s.replace(/"/g, "\"");
|
|
s = s.replace(/<br\/>/g, "\n");
|
|
return s;
|
|
}
|
|
|
|
private parsePartText(template: string, extract: T, context: HandleContext, textMode: TemplateTextMode = TemplateTextMode.NORMAL): string {
|
|
let resultContent = this.handleCustomVariable(template, context);
|
|
resultContent = resultContent.replaceAll(DoubanParameter.ID, extract.id)
|
|
.replaceAll(DoubanParameter.TITLE, this.handleSpecialContent(extract.title, textMode))
|
|
.replaceAll(DoubanParameter.TYPE, extract.type)
|
|
.replaceAll(DoubanParameter.SCORE, this.handleSpecialContent(extract.score))
|
|
.replaceAll(DoubanParameter.IMAGE, extract.image)
|
|
.replaceAll(DoubanParameter.URL, extract.url)
|
|
.replaceAll(DoubanParameter.DESC, this.handleSpecialContent(extract.desc, textMode))
|
|
.replaceAll(DoubanParameter.PUBLISHER, extract.publisher)
|
|
.replaceAll(DoubanParameter.YEAR_PUBLISHED, extract.datePublished ? moment(extract.datePublished).format('yyyy') : '')
|
|
.replaceAll(DoubanParameter.DATE_PUBLISHED, extract.datePublished ? moment(extract.datePublished).format(context.settings.dateFormat) : '')
|
|
.replaceAll(DoubanParameter.TIME_PUBLISHED, extract.datePublished ? moment(extract.datePublished).format(context.settings.timeFormat) : '')
|
|
.replaceAll(DoubanParameter.CURRENT_DATE, moment(new Date()).format(context.settings.dateFormat))
|
|
.replaceAll(DoubanParameter.CURRENT_TIME, moment(new Date()).format(context.settings.timeFormat))
|
|
.replaceAll(DoubanParameter.GENRE, this.handleSpecialContent(extract.genre, textMode, context))
|
|
;
|
|
resultContent = this.parseUserInfo(resultContent, extract, context, textMode);
|
|
return this.parseText(resultContent, extract, context, textMode);
|
|
}
|
|
|
|
private parseUserInfo(resultContent: string, extract: T, context: HandleContext, textMode: TemplateTextMode) {
|
|
const userState = extract.userState;
|
|
if ((resultContent.indexOf(DoubanUserParameter.MY_TAGS) >= 0 ||
|
|
resultContent.indexOf(DoubanUserParameter.MY_RATING) >= 0 ||
|
|
resultContent.indexOf(DoubanUserParameter.MY_STATE) >= 0 ||
|
|
resultContent.indexOf(DoubanUserParameter.MY_COMMENT) >= 0 ||
|
|
resultContent.indexOf(DoubanUserParameter.MY_COLLECTION_DATE) >= 0 ) && !this.doubanPlugin.userComponent.isLogin()) {
|
|
log.warn(i18nHelper.getMessage('100113'));
|
|
return resultContent;
|
|
}
|
|
if (!userState) {
|
|
return resultContent;
|
|
}
|
|
return resultContent.replaceAll(DoubanUserParameter.MY_TAGS, this.handleSpecialContent(userState.tags, textMode, context))
|
|
.replaceAll(DoubanUserParameter.MY_RATING, this.handleSpecialContent(userState.rate, textMode))
|
|
.replaceAll(DoubanUserParameter.MY_STATE, this.getUserStateName(userState.state))
|
|
.replaceAll(DoubanUserParameter.MY_COMMENT, this.handleSpecialContent(userState.comment, textMode))
|
|
.replaceAll(DoubanUserParameter.MY_COLLECTION_DATE, userState.collectionDate?moment(userState.collectionDate).format(context.settings.dateFormat): '')
|
|
}
|
|
|
|
/**
|
|
* 处理自定义参数
|
|
* @param template
|
|
* @param context
|
|
* @private
|
|
*/
|
|
private handleCustomVariable(template: string, context: HandleContext): string {
|
|
let customProperties = context.settings.customProperties;
|
|
let resultContent = template;
|
|
if (!customProperties) {
|
|
return resultContent;
|
|
}
|
|
customProperties.filter(customProperty => customProperty.name &&
|
|
customProperty.field
|
|
&& (customProperty.field == SupportType.ALL ||
|
|
customProperty.field == this.getSupportType())).forEach(customProperty => {
|
|
resultContent = resultContent.replaceAll(`{{${customProperty.name}}}`, customProperty.value);
|
|
});
|
|
return resultContent;
|
|
}
|
|
|
|
private getTemplateKey():TemplateKey {
|
|
let templateKey: TemplateKey;
|
|
switch (this.getSupportType()) {
|
|
case SupportType.MOVIE:
|
|
templateKey = TemplateKey.movieTemplateFile;
|
|
break;
|
|
case SupportType.BOOK:
|
|
templateKey = TemplateKey.bookTemplateFile;
|
|
break;
|
|
case SupportType.MUSIC:
|
|
templateKey = TemplateKey.musicTemplateFile;
|
|
break;
|
|
case SupportType.TELEPLAY:
|
|
templateKey = TemplateKey.teleplayTemplateFile;
|
|
break;
|
|
case SupportType.GAME:
|
|
templateKey = TemplateKey.gameTemplateFile;
|
|
break;
|
|
case SupportType.NOTE:
|
|
templateKey = TemplateKey.noteTemplateFile;
|
|
break;
|
|
default:
|
|
templateKey = null;
|
|
|
|
}
|
|
return templateKey;
|
|
}
|
|
|
|
private async getTemplate(extract: T, context: HandleContext): Promise<string> {
|
|
const {syncConfig} = context;
|
|
if (syncConfig) {
|
|
if(syncConfig.templateFile) {
|
|
const val = await this.doubanPlugin.fileHandler.getFileContent(syncConfig.templateFile);
|
|
if (val) {
|
|
return val;
|
|
}
|
|
}
|
|
}
|
|
const tempKey: TemplateKey = this.getTemplateKey();
|
|
const templatePath: string = context.settings[tempKey];
|
|
let useUserState:boolean = context.userComponent.isLogin() &&
|
|
extract.userState &&
|
|
extract.userState.collectionDate != null &&
|
|
extract.userState.collectionDate != undefined;
|
|
|
|
useUserState = useUserState ? useUserState : false;
|
|
|
|
// @ts-ignore
|
|
if (!templatePath || StringUtil.isBlank(templatePath)) {
|
|
return getDefaultTemplateContent(tempKey, useUserState);
|
|
}
|
|
const defaultContent = getDefaultTemplateContent(tempKey, useUserState);
|
|
let firstLinkpathDest: TFile = this.doubanPlugin.app.metadataCache.getFirstLinkpathDest(templatePath, '');
|
|
if (!firstLinkpathDest) {
|
|
return defaultContent;
|
|
} else {
|
|
const val = await this.doubanPlugin.fileHandler.getFileContent(firstLinkpathDest.path);
|
|
return val ? val : defaultContent;
|
|
}
|
|
}
|
|
|
|
analysisUserState(html: CheerioAPI, context: HandleContext): {data:CheerioAPI , userState: UserStateSubject} {
|
|
if (!context.userComponent.isLogin()) {
|
|
return {data: html, userState: null};
|
|
}
|
|
if(!html('.nav-user-account')) {
|
|
return {data: html, userState: null};
|
|
}
|
|
return this. analysisUser(html, context);
|
|
}
|
|
|
|
abstract analysisUser(html: CheerioAPI, context: HandleContext): {data:CheerioAPI , userState: UserStateSubject};
|
|
|
|
|
|
public static getUserState(stateWord:string):DoubanSubjectState {
|
|
let state:DoubanSubjectState;
|
|
if(!stateWord) {
|
|
return null;
|
|
}
|
|
if(stateWord.indexOf('想')>=0 ) {
|
|
state = DoubanSubjectState.wish;
|
|
}else if(stateWord.indexOf('在')>=0) {
|
|
state = DoubanSubjectState.do;
|
|
}else if(stateWord.indexOf('过')>=0) {
|
|
state = DoubanSubjectState.collect;
|
|
}else {
|
|
state = DoubanSubjectState.not;
|
|
}
|
|
return state;
|
|
|
|
}
|
|
|
|
private getUserStateName(state: DoubanSubjectState): string {
|
|
if (!state) {
|
|
return '';
|
|
}
|
|
let v = DoubanSubjectStateRecords[this.getSupportType()];
|
|
switch (state) {
|
|
case DoubanSubjectState.wish:
|
|
return v.wish;
|
|
case DoubanSubjectState.do:
|
|
return v.do;
|
|
case DoubanSubjectState.collect:
|
|
return v.collect;
|
|
case DoubanSubjectState.not:
|
|
return v.not;
|
|
default:
|
|
return '';
|
|
}
|
|
}
|
|
|
|
private async saveImage(extract: T, context: HandleContext) {
|
|
const {syncConfig} = context;
|
|
if (!extract.image || (syncConfig && !syncConfig.cacheImage) || !context.settings.cacheImage) {
|
|
return;
|
|
}
|
|
const image = extract.image;
|
|
const filename = image.split('/').pop();
|
|
let folder = syncConfig? syncConfig.attachmentPath : context.settings.attachmentPath;
|
|
if (!folder) {
|
|
folder = DEFAULT_SETTINGS.attachmentPath;
|
|
}
|
|
if ((syncConfig ? syncConfig.cacheHighQuantityImage : context.settings.cacheHighQuantityImage) && context.userComponent.isLogin()) {
|
|
try {
|
|
const fileNameSpilt = filename.split('.');
|
|
const highFilename = fileNameSpilt.first() + '.jpg';
|
|
|
|
const highImage = this.getHighQuantityImageUrl(highFilename);
|
|
const resultValue = await context.netFileHandler.downloadFile(highImage, folder, highFilename, context, false);
|
|
if (resultValue && resultValue.success) {
|
|
extract.image = resultValue.filepath;
|
|
return;
|
|
}
|
|
}catch (e) {
|
|
console.error(e);
|
|
console.error('下载高清封面失败，将会使用普通封面')
|
|
}
|
|
}
|
|
const resultValue = await context.netFileHandler.downloadFile(image, folder, filename, context, true);
|
|
if (resultValue && resultValue.success) {
|
|
extract.image = resultValue.filepath;
|
|
}
|
|
}
|
|
|
|
abstract getHighQuantityImageUrl(fileName:string):string;
|
|
|
|
private async humanCheck(html:any, url:string):Promise<any> {
|
|
this.doubanPlugin.settingsManager.debug(html);
|
|
if (html && html.indexOf("<title>禁止访问</title>") != -1) {
|
|
const loginModel = new DoubanHumanCheckModel(url);
|
|
await loginModel.load();
|
|
return '';
|
|
}else {
|
|
return html;
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
handlePersonNameByMeta(html: CheerioAPI, movie: DoubanSubject, context: HandleContext,
|
|
metaProperty:string, objectProperty:string) {
|
|
let metaProperties: string[] = html(`head > meta[property='${metaProperty}']`).get()
|
|
.map((e) => {
|
|
return html(e).attr('content');
|
|
});
|
|
// @ts-ignore
|
|
movie[objectProperty]
|
|
// @ts-ignore
|
|
.filter((p:Person) => p.name)
|
|
// @ts-ignore
|
|
.map((p:Person) => {
|
|
// @ts-ignore
|
|
const persons = metaProperties.filter((a) => p.name.indexOf(a) >= 0);
|
|
if (persons) {
|
|
// @ts-ignore
|
|
p.name = this.getPersonName2(p.name, persons[0], context);
|
|
}
|
|
})
|
|
}
|
|
}
|