search
HomeDatabaseMysql Tutorial最代码网站中关于动态表event的设计思路

原文:最代码网站中关于动态表event的设计思路 为了能将最代码整站用户的操作都展现出来,需要设计一种动态类型,既可以根据业务无限扩展,也可以指定某些用户行为是可以产生多少牛币交换的,这样就在原先javaniu的零散的表设计基础上抽象出event表 表结构如

原文:最代码网站中关于动态表event的设计思路

为了能将最代码整站用户的操作都展现出来,需要设计一种动态类型,既可以根据业务无限扩展,也可以指定某些用户行为是可以产生多少牛币交换的,这样就在原先javaniu的零散的表设计基础上抽象出event表

表结构如下:

CREATE TABLE `javaniu_event` (
  `id` bigint(20) unsigned NOT NULL auto_increment,
  `create_time` datetime NOT NULL,
  `update_time` datetime default NULL,
  `event_rule_id` bigint(20) NOT NULL default '0' COMMENT '用户注册\r\n下载代码\r\n浏览分享\r\n浏览寻求\r\n收藏分享\r\n收藏寻求\r\n浏览活动\r\n追加悬赏\r\n加入活动\r\n拜师\r\n关注用户\r\n发表心情\r\n发表寻求\r\n评论寻求\r\n评论代码\r\n上传代码\r\n下载代码\r\n分享代码\r\n关注用户\r\n浏览分享\r\n浏览寻求\r\n管理员删除代码\r\n收藏分享\r\n收藏寻求\r\n获取勋章\r\n拜师傅\r\n发起活动\r\n浏览活动\r\n加入活动\r\n追加悬赏\r\n连续一周发表心情\r\n用户周贡献排行\r\n用户月贡献排行\r\n用户年贡献排行\r\n代码下载周排行\r\n代码下载月排行\r\n代码下载年排行',
  `user_id` bigint(20) NOT NULL default '0',
  `source_user_id` bigint(20) NOT NULL default '0',
  `source_id` bigint(20) NOT NULL default '0',
  `target_id` bigint(20) NOT NULL default '0',
  `status` int(2) NOT NULL default '0' COMMENT '-1删除0待审核2正常',
  `type` int(2) NOT NULL default '0',
  PRIMARY KEY  (`id`),
  KEY `create_time` (`create_time`),
  KEY `userid_status` (`user_id`,`status`),
  KEY `event_rule_id_source_id` (`event_rule_id`,`source_id`),
  KEY `event_rule_id_status` (`event_rule_id`,`status`),
  KEY `type_source_id` (`type`,`source_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8

关联表event_rule可以指定牛币规则及其动态显示信息,结构如下:

CREATE TABLE `javaniu_event_rule` (
  `id` bigint(20) unsigned NOT NULL auto_increment,
  `create_time` datetime NOT NULL,
  `update_time` datetime default NULL,
  `type` int(1) NOT NULL COMMENT '注册+1\r\n发表心情+1\r\n连续一周发表心情+5\r\n分享代码+1\r\n分享代码被下载+n(n为分享者者自定义牛币)\r\n寻求代码-2\r\n上传代码+1\r\n上传代码被下载+1\r\n代码被设为最佳+n(n为寻求者者自定义牛币)\r\n删除代码-1\r\n无效寻求-2\r\n无效代码-2\r\n管理员奖赏+n\r\n管理员惩罚-n\r\n周top10+5\r\n月top10+10\r\n年top10+100\r\n信息完善+1\r\n包月vip+100\r\n师傅赠送+n牛币\r\n授予徽章+5牛币\r\n',
  `name` varchar(100) NOT NULL,
  `niubi` int(11) NOT NULL,
  `extend_json` varchar(1000) NOT NULL,
  PRIMARY KEY  (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8

event的用户行为数据模型抽象如下:

模型一:用户a通过事件x产生动态0=user_id_a 0 0 0
a=>x=>0
模型二:用户a通过事件x产生产生用户a的数据1=user_id_a 0 0 1
a=>x=>1
模型三:用户a通过事件x对用户b的数据1产生用户a的数据2=user_id_a b 1 2
a=>x+b+1=>2
模型四:用户a通过事件x对用户b的数据1产生动态0=user_id_a b 1 0
a=>x+b+1=>0
模型五:用户a通过事件x对用户b产生动态0=user_id_a b 0 0
a=>x+b=>0

排列组合:
user_id source_user_id source_id target_id
user_id
user_id source_user_id
user_id source_user_id source_id
user_id source_user_id source_id target_id

这样就囊括了所有会出现的用户event,只要在java层做业务转换即可:

最核心的event数据转换java类源码:

package com.zuidaima.core.service.impl;

	private void setSourceAndTarget(Event event, EventRule _eventRule) {
		try {
			EventRule eventRule = new EventRule();
			eventRule.setCreateTime(_eventRule.getCreateTime());
			eventRule.setExtendJson(_eventRule.getExtendJson());
			eventRule.setId(_eventRule.getId());
			eventRule.setName(_eventRule.getName());
			eventRule.setNiubi(_eventRule.getNiubi());
			eventRule.setType(_eventRule.getType());
			eventRule.setUpdateTime(_eventRule.getUpdateTime());
			BaseEntity source = null;
			BaseEntity target = null;
			long sourceId = event.getSourceId();
			long targetId = event.getTargetId();
			JSONObject extend = eventRule.getExtend();
			extend = eventRule.getExtend();
			String description = (String) extend.get("description");
			String _description = null;
			Answer answer = null;
			Project project = null;
			switch (eventRule.getType()) {
			case ModuleConstants.EVENT_TYPE_RULE_PROJECT_CREATE:
			case ModuleConstants.EVENT_TYPE_RULE_PROJECT_DELETE_BY_USER:
			case ModuleConstants.EVENT_TYPE_RULE_PROJECT_DELETE_BY_ADMIN:
			case ModuleConstants.EVENT_TYPE_RULE_PROJECT_VIEW:
			case ModuleConstants.EVENT_TYPE_RULE_PROJECT_COLLECT:
			case ModuleConstants.EVENT_TYPE_RULE_PROJECT_REWARD:
				if (sourceId > 0) {
					source = projectService.findOneById(sourceId);
				}
				if (targetId > 0) {
					target = projectService.findOneById(targetId);
				}
				project = (Project) target;
				if (source != null) {
					project = (Project) source;
				}
				if (project == null) {
					return;
				}
				_description = String.format(
						description,
						ModuleConstants.PROJECT_TYPE_DESC_MAP.get(
								project.getType()).getDesc());
				break;
			case ModuleConstants.EVENT_TYPE_RULE_POST_CREATE:
			case ModuleConstants.EVENT_TYPE_RULE_POST_DELETE_BY_USER:
			case ModuleConstants.EVENT_TYPE_RULE_POST_DELETE_BY_ADMIN:
				if (sourceId > 0) {
					source = postService.findOneById(sourceId);
				}
				if (targetId > 0) {
					target = postService.findOneById(targetId);
				}
				Post post = (Post) target;
				if (source != null) {
					post = (Post) source;
				}
				_description = String.format(description,
						ModuleConstants.POST_TYPE_DESC_MAP.get(post.getType()));
				break;
			// case ModuleConstants.EVENT_TYPE_RULE_GROUP_CREATE://暂时没有这种动态
			case ModuleConstants.EVENT_TYPE_RULE_GROUP_JOIN_IN:
			case ModuleConstants.EVENT_TYPE_RULE_GROUP_DELETE_BY_USER:
				// case
				// ModuleConstants.EVENT_TYPE_RULE_GROUP_DELETE_BY_ADMIN://暂时没有这种动态
				if (sourceId > 0) {
					source = groupService.findOneById(sourceId);
				}
				if (targetId > 0) {
					target = groupService.findOneById(targetId);
				}
				Group group = (Group) source;

				_description = String
						.format(description,
								ModuleConstants.GROUP_TYPE_DESC_MAP.get(group
										.getType()));
				break;
			case ModuleConstants.EVENT_TYPE_RULE_COMMENT_CREATE:
			case ModuleConstants.EVENT_TYPE_RULE_COMMENT_DELETE_BY_USER:
			case ModuleConstants.EVENT_TYPE_RULE_COMMENT_DELETE_BY_ADMIN:
				target = commentService.findOneById(targetId);
				Comment comment = (Comment) target;
				int commentType = comment.getType();
				if (commentType == ModuleConstants.COMMENT_TYPE_ANSWER) {
					source = answerService.findOneById(sourceId);
					answer = (Answer) source;
					project = (Project) answer.getTarget();
					_description = String.format(
							description,
							ModuleConstants.PROJECT_TYPE_DESC_MAP.get(
									project.getType()).getDesc());
				} else if (commentType == ModuleConstants.COMMENT_TYPE_PROJECT) {
					source = projectService.findOneById(sourceId);
					project = (Project) source;
					_description = String.format(
							description,
							ModuleConstants.PROJECT_TYPE_DESC_MAP.get(
									project.getType()).getDesc());
				} else if (commentType == ModuleConstants.COMMENT_TYPE_POST) {
					source = postService.findOneById(sourceId);
					post = (Post) source;
					_description = String.format(description,
							ModuleConstants.POST_TYPE_DESC_MAP.get(post
									.getType()));
				} else {

				}
				break;
			case ModuleConstants.EVENT_TYPE_RULE_ANSWER_CREATE:
			case ModuleConstants.EVENT_TYPE_RULE_ANSWER_BEEN_SET_PERFECT:
				source = projectService.findOneById(sourceId);
				target = answerService.findOneById(targetId);
				project = (Project) source;
				_description = String.format(
						description,
						ModuleConstants.PROJECT_TYPE_DESC_MAP.get(
								project.getType()).getDesc());
				break;
			case ModuleConstants.EVENT_TYPE_RULE_ANSWER_GET:
			case ModuleConstants.EVENT_TYPE_RULE_ANSWER_DELETE_BY_USER:
			case ModuleConstants.EVENT_TYPE_RULE_ANSWER_DELETE_BY_ADMIN:
				source = answerService.findOneById(sourceId);
				answer = (Answer) source;
				Project _project = (Project) answer.getTarget();
				_description = String.format(
						description,
						ModuleConstants.PROJECT_TYPE_DESC_MAP.get(
								_project.getType()).getDesc());
				break;
			case ModuleConstants.EVENT_TYPE_RULE_REPUTATION_CREATE:
				if (sourceId > 0) {
					source = reputationService.findOneById(sourceId);
				}
				if (targetId > 0) {
					target = reputationService.findOneById(targetId);
				}
				break;
			case ModuleConstants.EVENT_TYPE_RULE_USER_FOLLOW:
				source = userService.findOneById(sourceId);
				User _user = (User) source;
				_description = String
						.format(description,
								"<a href='/user/n/" &#43; _user.getName()
										&#43; ".htm'>" &#43; _user.getName() &#43; "</a>");
				break;
			case ModuleConstants.EVENT_TYPE_RULE_MENTION_COMMENT:
				target = commentService.findOneById(targetId);
				comment = (Comment) target;
				commentType = comment.getType();
				if (commentType == ModuleConstants.COMMENT_TYPE_ANSWER) {
					source = answerService.findOneById(sourceId);
					answer = (Answer) source;
					project = (Project) answer.getTarget();
					_description = String.format(
							description,
							ModuleConstants.PROJECT_TYPE_DESC_MAP.get(
									project.getType()).getDesc());
				} else if (commentType == ModuleConstants.COMMENT_TYPE_PROJECT) {
					source = projectService.findOneById(sourceId);
					project = (Project) source;
					_description = String.format(
							description,
							ModuleConstants.PROJECT_TYPE_DESC_MAP.get(
									project.getType()).getDesc());
				} else if (commentType == ModuleConstants.COMMENT_TYPE_POST) {
					source = postService.findOneById(sourceId);
					post = (Post) source;
					_description = String.format(description,
							ModuleConstants.POST_TYPE_DESC_MAP.get(post
									.getType()));
				} else {

				}
				break;
			case ModuleConstants.EVENT_TYPE_RULE_MENTION_POST:
				source = postService.findOneById(sourceId);
				break;
			default:
				_description = description;
			}

			extend.put("description", _description);
			eventRule.setExtend(extend);
			eventRule.setExtendJson(extend.toString());
			event.setEventRule(eventRule);

			event.setSource(source);
			event.setTarget(target);
		} catch (Exception e) {
			logger.error("Fail to setSourceAndTarget event:" &#43; event);
		}
	}

freemarker显示层转换核心代码:

<#switch event.eventRule.type>
				<#case event_type_rule_post_create>
					<@event_post_macro event.target/>
					<#break>
				<#case event_type_rule_project_create>
					<@event_project_macro event event.target/>
					<#break>
				<#case event_type_rule_project_view>
				<#case event_type_rule_project_collect>
				<#case event_type_rule_project_reward>
					<@event_project_macro event event.source/>
					<#break>
				<#case event_type_rule_comment_create>
					<@event_comment_macro event event.target/>
					<#break>
				<#case event_type_rule_answer_create>
					<@event_answer_macro event event.target/>
					<#break>
				<#case event_type_rule_answer_get>
				<#case event_type_rule_answer_been_set_perfect>
					<@event_answer_macro event event.source/>
					<#break>
				<#case event_type_rule_mention_comment>
					<@event_comment_macro event event.target/>
					<#break>
				<#case event_type_rule_mention_post>
					<@event_post_macro event.source/>
					<#break>
				</#switch>

比如其中一种event type的freemarker macro代码如下:

<!--event post-->
<#macro event_post_macro post>
	<div class="content margin_top5">
		${post.contentExt}
		<span class="comments_count">
			<a target="_blank" href="/mood/${post.id}/comment.htm" rel="nofollow"><img src="/static/imghwm/default1.png"  data-src="/resource/img/comment.gif"  class="lazy"  alt="${post.thirdSort}个评论">  ${post.thirdSort}</a>
		</span>
	</div>
</#macro>

这样的设计符合高内聚低耦合的设计思路,未来可以根据业务实现无限扩张,当然代价就是event表越来越大,但可以通过分库分表来分担压力,大家可以参考下,有好的意见可以留言。

Statement
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
How to use MySQL functions for data processing and calculationHow to use MySQL functions for data processing and calculationApr 29, 2025 pm 04:21 PM

MySQL functions can be used for data processing and calculation. 1. Basic usage includes string processing, date calculation and mathematical operations. 2. Advanced usage involves combining multiple functions to implement complex operations. 3. Performance optimization requires avoiding the use of functions in the WHERE clause and using GROUPBY and temporary tables.

An efficient way to batch insert data in MySQLAn efficient way to batch insert data in MySQLApr 29, 2025 pm 04:18 PM

Efficient methods for batch inserting data in MySQL include: 1. Using INSERTINTO...VALUES syntax, 2. Using LOADDATAINFILE command, 3. Using transaction processing, 4. Adjust batch size, 5. Disable indexing, 6. Using INSERTIGNORE or INSERT...ONDUPLICATEKEYUPDATE, these methods can significantly improve database operation efficiency.

Steps to add and delete fields to MySQL tablesSteps to add and delete fields to MySQL tablesApr 29, 2025 pm 04:15 PM

In MySQL, add fields using ALTERTABLEtable_nameADDCOLUMNnew_columnVARCHAR(255)AFTERexisting_column, delete fields using ALTERTABLEtable_nameDROPCOLUMNcolumn_to_drop. When adding fields, you need to specify a location to optimize query performance and data structure; before deleting fields, you need to confirm that the operation is irreversible; modifying table structure using online DDL, backup data, test environment, and low-load time periods is performance optimization and best practice.

How to analyze the execution plan of MySQL queryHow to analyze the execution plan of MySQL queryApr 29, 2025 pm 04:12 PM

Use the EXPLAIN command to analyze the execution plan of MySQL queries. 1. The EXPLAIN command displays the execution plan of the query to help find performance bottlenecks. 2. The execution plan includes fields such as id, select_type, table, type, possible_keys, key, key_len, ref, rows and Extra. 3. According to the execution plan, you can optimize queries by adding indexes, avoiding full table scans, optimizing JOIN operations, and using overlay indexes.

How to use MySQL subquery to improve query efficiencyHow to use MySQL subquery to improve query efficiencyApr 29, 2025 pm 04:09 PM

Subqueries can improve the efficiency of MySQL query. 1) Subquery simplifies complex query logic, such as filtering data and calculating aggregated values. 2) MySQL optimizer may convert subqueries to JOIN operations to improve performance. 3) Using EXISTS instead of IN can avoid multiple rows returning errors. 4) Optimization strategies include avoiding related subqueries, using EXISTS, index optimization, and avoiding subquery nesting.

How to configure the character set and collation rules of MySQLHow to configure the character set and collation rules of MySQLApr 29, 2025 pm 04:06 PM

Methods for configuring character sets and collations in MySQL include: 1. Setting the character sets and collations at the server level: SETNAMES'utf8'; SETCHARACTERSETutf8; SETCOLLATION_CONNECTION='utf8_general_ci'; 2. Create a database that uses specific character sets and collations: CREATEDATABASEexample_dbCHARACTERSETutf8COLLATEutf8_general_ci; 3. Specify character sets and collations when creating a table: CREATETABLEexample_table(idINT

How to uninstall MySQL and clean residual filesHow to uninstall MySQL and clean residual filesApr 29, 2025 pm 04:03 PM

To safely and thoroughly uninstall MySQL and clean all residual files, follow the following steps: 1. Stop MySQL service; 2. Uninstall MySQL packages; 3. Clean configuration files and data directories; 4. Verify that the uninstallation is thorough.

How to rename a database in MySQLHow to rename a database in MySQLApr 29, 2025 pm 04:00 PM

Renaming a database in MySQL requires indirect methods. The steps are as follows: 1. Create a new database; 2. Use mysqldump to export the old database; 3. Import the data into the new database; 4. Delete the old database.

See all articles

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

Video Face Swap

Video Face Swap

Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Tools

SAP NetWeaver Server Adapter for Eclipse

SAP NetWeaver Server Adapter for Eclipse

Integrate Eclipse with SAP NetWeaver application server.

mPDF

mPDF

mPDF is a PHP library that can generate PDF files from UTF-8 encoded HTML. The original author, Ian Back, wrote mPDF to output PDF files "on the fly" from his website and handle different languages. It is slower than original scripts like HTML2FPDF and produces larger files when using Unicode fonts, but supports CSS styles etc. and has a lot of enhancements. Supports almost all languages, including RTL (Arabic and Hebrew) and CJK (Chinese, Japanese and Korean). Supports nested block-level elements (such as P, DIV),

SublimeText3 Mac version

SublimeText3 Mac version

God-level code editing software (SublimeText3)

Dreamweaver Mac version

Dreamweaver Mac version

Visual web development tools

EditPlus Chinese cracked version

EditPlus Chinese cracked version

Small size, syntax highlighting, does not support code prompt function