Commit d999f823 authored by lixiaofang's avatar lixiaofang

新增新标签的联想词

parent 213d6a70
...@@ -47,6 +47,7 @@ class Command(BaseCommand): ...@@ -47,6 +47,7 @@ class Command(BaseCommand):
ESPerform.create_index(es_cli, type_name) ESPerform.create_index(es_cli, type_name)
logging.info("begin create [%s] mapping!" % type_name) logging.info("begin create [%s] mapping!" % type_name)
ESPerform.put_index_mapping(es_cli, type_name) ESPerform.put_index_mapping(es_cli, type_name)
if len(options["indices_template"]): if len(options["indices_template"]):
......
...@@ -6,12 +6,12 @@ import logging ...@@ -6,12 +6,12 @@ import logging
import traceback import traceback
import base64 import base64
from django.db import models from django.db import models
from gm_types.gaia import ( # from gm_types.gaia import (
AGILE_TAG_TYPE, # AGILE_TAG_TYPE,
AGILE_TAG_CREATE_TYPE, # AGILE_TAG_CREATE_TYPE,
AGILE_TAG_STYLE, # AGILE_TAG_STYLE,
AGILE_TAG_RECOMMEND_TYPE, # AGILE_TAG_RECOMMEND_TYPE,
) # )
class BaseModel(models.Model): class BaseModel(models.Model):
...@@ -31,8 +31,8 @@ class AgileTag(BaseModel): ...@@ -31,8 +31,8 @@ class AgileTag(BaseModel):
name = models.CharField(verbose_name=u'新标签名字', max_length=128, null=False, unique=True, default='') name = models.CharField(verbose_name=u'新标签名字', max_length=128, null=False, unique=True, default='')
description = models.TextField(verbose_name=u'描述', default='') description = models.TextField(verbose_name=u'描述', default='')
create_tag_type = models.CharField(verbose_name=u"标签创建类型", max_length=3, choices=AGILE_TAG_CREATE_TYPE) create_tag_type = models.CharField(verbose_name=u"标签创建类型", max_length=3, choices=1)
style = models.CharField(verbose_name=u"标签样式", max_length=3, choices=AGILE_TAG_STYLE) style = models.CharField(verbose_name=u"标签样式", max_length=3, choices=1)
topic_recommend_sort = models.IntegerField(verbose_name=u'帖子推荐排序', default=9999) topic_recommend_sort = models.IntegerField(verbose_name=u'帖子推荐排序', default=9999)
...@@ -43,7 +43,7 @@ class AgileTagType(BaseModel): ...@@ -43,7 +43,7 @@ class AgileTagType(BaseModel):
app_label = 'api' app_label = 'api'
agile_tag_id = models.IntegerField(verbose_name=u'新标签', db_index=True) agile_tag_id = models.IntegerField(verbose_name=u'新标签', db_index=True)
agile_tag_type = models.CharField(verbose_name=u"标签类型", max_length=3, choices=AGILE_TAG_TYPE) agile_tag_type = models.CharField(verbose_name=u"标签类型", max_length=3, choices=1)
@property @property
def get_by_id_name(self): def get_by_id_name(self):
......
...@@ -9,10 +9,10 @@ import django.db.models ...@@ -9,10 +9,10 @@ import django.db.models
import copy import copy
from libs.es import ESPerform from libs.es import ESPerform
from associate.models import agile_tag from associate.models import agile_tag
from associate.utils import TagTransfer from associate.utils.agile_tag_transfer import TagTransfer
from gm_types.gaia import ( # from gm_types.gaia import (
AGILE_TAG_TYPE, # AGILE_TAG_TYPE,
) # )
__es = None __es = None
......
...@@ -53,9 +53,15 @@ class ESPerform(object): ...@@ -53,9 +53,15 @@ class ESPerform(object):
@classmethod @classmethod
def __load_mapping(cls, doc_type): def __load_mapping(cls, doc_type):
try: try:
mapping_file_path = os.path.join( mapping_file_path = os.path.join(
os.path.dirname(__file__), os.path.dirname(__file__),
'..', 'trans2es', 'mapping', '%s.json' % (doc_type,)) '..', 'trans2es', 'mapping', '%s.json' % (doc_type,))
if doc_type == "associate_tag":
mapping_file_path = os.path.join(
os.path.dirname(__file__),
'..', 'associate', 'mapping', '%s.json' % (doc_type,))
mapping = '' mapping = ''
with open(mapping_file_path, 'r') as f: with open(mapping_file_path, 'r') as f:
for line in f: for line in f:
...@@ -141,7 +147,7 @@ class ESPerform(object): ...@@ -141,7 +147,7 @@ class ESPerform(object):
try: try:
assert (es_cli is not None) assert (es_cli is not None)
official_index_name = cls.get_official_index_name(sub_index_name,"write") official_index_name = cls.get_official_index_name(sub_index_name, "write")
index_exists = es_cli.indices.exists(official_index_name) index_exists = es_cli.indices.exists(official_index_name)
if not index_exists: if not index_exists:
if not auto_create_index: if not auto_create_index:
......
...@@ -61,7 +61,8 @@ INSTALLED_APPS = [ ...@@ -61,7 +61,8 @@ INSTALLED_APPS = [
'django.contrib.staticfiles', 'django.contrib.staticfiles',
'trans2es', 'trans2es',
'search', 'search',
'injection.data_sync' 'injection.data_sync',
"associate"
] ]
MIDDLEWARE = [ MIDDLEWARE = [
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment