/** * WPML compatibility functions * * @global array $duplicated_posts Array to store the posts being duplicated. * * @package Yoast\WP\Duplicate_Post * @since 3.2 */ add_action( 'admin_init', 'duplicate_post_wpml_init' ); /** * Add handlers for WPML compatibility. */ function duplicate_post_wpml_init() { if ( defined( 'ICL_SITEPRESS_VERSION' ) ) { add_action( 'dp_duplicate_page', 'duplicate_post_wpml_copy_translations', 10, 3 ); add_action( 'dp_duplicate_post', 'duplicate_post_wpml_copy_translations', 10, 3 ); add_action( 'shutdown', 'duplicate_wpml_string_packages', 11 ); } } global $duplicated_posts; // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: Renaming a global variable is a BC break. $duplicated_posts = []; /** * Copy post translations. * * @global SitePress $sitepress Instance of the Main WPML class. * @global array $duplicated_posts Array of duplicated posts. * * @param int $post_id ID of the copy. * @param WP_Post $post Original post object. * @param string $status Status of the new post. */ function duplicate_post_wpml_copy_translations( $post_id, $post, $status = '' ) { global $sitepress; global $duplicated_posts; remove_action( 'dp_duplicate_page', 'duplicate_post_wpml_copy_translations', 10 ); remove_action( 'dp_duplicate_post', 'duplicate_post_wpml_copy_translations', 10 ); $current_language = $sitepress->get_current_language(); $trid = $sitepress->get_element_trid( $post->ID ); if ( ! empty( $trid ) ) { $translations = $sitepress->get_element_translations( $trid ); $new_trid = $sitepress->get_element_trid( $post_id ); foreach ( $translations as $code => $details ) { if ( $code !== $current_language ) { if ( $details->element_id ) { $translation = get_post( $details->element_id ); if ( ! $translation ) { continue; } $new_post_id = duplicate_post_create_duplicate( $translation, $status ); if ( ! is_wp_error( $new_post_id ) ) { $sitepress->set_element_language_details( $new_post_id, 'post_' . $translation->post_type, $new_trid, $code, $current_language ); } } } } // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: see above. $duplicated_posts[ $post->ID ] = $post_id; } } /** * Duplicate string packages. * * @global array() $duplicated_posts Array of duplicated posts. */ function duplicate_wpml_string_packages() { // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: renaming the function would be a BC-break. global $duplicated_posts; foreach ( $duplicated_posts as $original_post_id => $duplicate_post_id ) { // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. $original_string_packages = apply_filters( 'wpml_st_get_post_string_packages', false, $original_post_id ); // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. $new_string_packages = apply_filters( 'wpml_st_get_post_string_packages', false, $duplicate_post_id ); if ( is_array( $original_string_packages ) ) { foreach ( $original_string_packages as $original_string_package ) { $translated_original_strings = $original_string_package->get_translated_strings( [] ); foreach ( $new_string_packages as $new_string_package ) { $cache = new WPML_WP_Cache( 'WPML_Package' ); $cache->flush_group_cache(); $new_strings = $new_string_package->get_package_strings(); foreach ( $new_strings as $new_string ) { if ( isset( $translated_original_strings[ $new_string->name ] ) ) { foreach ( $translated_original_strings[ $new_string->name ] as $language => $translated_string ) { do_action( // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. 'wpml_add_string_translation', $new_string->id, $language, $translated_string['value'], $translated_string['status'] ); } } } } } } } } 備忘録 – Raqqa

備忘録

—

by

in Uncategorized

全体（工程1 + 工程2）

工程1：DomainGuide（View Pack）取り込み

目的：View単位（action_xmlid単位）の入口＝DomainGuide/仕様を DeciKG に取り込む（冪等）

ソース（あなたの環境の真実）

decikg/packs/view_common01/ にある Pack（YAML など）
- これが public.decikg_view_pack のソース（あなたの言う通り）

取り込み先（Postgres）

public.decikg_view_pack
- action_xmlid をキーに UPSERT（冪等）
- yaml_text（原文保持）
- json_doc（正規化）
- source_hash（差分判定）

反映先（Neo4j）

例：(:ViewCommon {action_xmlid,...}) など “仕様ノード”
- ※工程2のDoD（観測データのリレーション）とは別枠だけど、後続の推論の基盤

“Dev-portalからは YAMLで吐く” 前提

将来の運用では Pack の入力は
- exchange/inbox/packs/*.yaml のような “受け口” に Dev-portal が吐くYAMLが来る想定
ただし 現状はそれの代わりに decikg/packs/view_common01/ をソースにしている（今回の実装）

工程2：Materials（観測データ）取り込み → Neo4j投影

目的：推論・ランキングの根拠になる観測データ（fact/odoo-like）を Neo4j に載せる
DoD：Opp→Signal/Outcome/EmailEvent/PhraseStat が Neo4j で確認できる

ソース（今回の入力）

exchange/inbox/materials/*.csv
- ※今回だけCSV（将来はDev-portalがYAMLを吐く、というのは “Pack側” の話であって、観測データがYAMLになるとは限らない想定でもOK）

工程2-1：CSV → JSONL 変換（完了）

変換後の置き場（v0.1仕様）
import_dir/materials/*.jsonl
- 1行1レコード
- 共通フィールド：kind, key, refs, attrs, ts, source
- kind→Label は確定済み（Company/Period/…）

工程2-2：JSONL → Postgres staging（完了）

public.decikg_material_raw（raw保持）
- 再実行・差分追跡・品質確認のための “一次保管”

工程2-3：Postgres → Neo4j 投影（これから）

入力ソースは JSONLではなく Postgres staging（決定済み方針）

public.decikg_material_raw を読み、
kindごとの handler で MERGEノード、
refs で MERGEリレーション を張る

DoDの最低限リレーション（v0.1）

(Opportunity)-[:HAS_SIGNAL]->(ProposalSignal)
(Opportunity)-[:HAS_OUTCOME]->(Outcome)
(Opportunity)-[:HAS_EMAIL_EVENT]->(EmailEvent)
(Opportunity)-[:HAS_PHRASE_STAT]->(PhraseStat) ※opp_idがある行のみ
追加(A) opp_id空の PhraseStat：
- (Partner)-[:HAS_PHRASE_STAT]->(PhraseStat)

「JsonLのDomainGuideはどこに？」への最終回答（今回の構成）

DomainGuide は materials の JSONL ではない
いまの DomainGuide のソースは decikg/packs/view_common01/
それが Postgres の public.decikg_view_pack に入っている
（必要なら）Neo4jの :ViewCommon に投影される

“使うファイル”だけをプロセス別に一覧（迷ったらここだけ見る）

工程1（Pack / DomainGuide）

入力（今回）：decikg/packs/view_common01/*（YAML等）
入力（将来運用）：exchange/inbox/packs/*.yaml（Dev-portal吐き出し）
出力（Postgres）：public.decikg_view_pack
出力（Neo4j）：:ViewCommon 等の仕様ノード

工程2（Materials / 観測データ）

入力（今回）：exchange/inbox/materials/*.csv
中間生成：import_dir/materials/*.jsonl
staging（Postgres）：public.decikg_material_raw
投影（Neo4j）：Company/Period/…/Opportunity… + DoDリレーション

Comments

コメントを残すコメントをキャンセル