From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/service/impl/count/DailyCountMomentsServiceImpl.java | 288 ++++++++++++++++++++++++++++----------------------------
1 files changed, 144 insertions(+), 144 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/count/DailyCountMomentsServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/count/DailyCountMomentsServiceImpl.java
index 60f856f..dfa7b22 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/count/DailyCountMomentsServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/count/DailyCountMomentsServiceImpl.java
@@ -1,144 +1,144 @@
-package com.yeshi.fanli.service.impl.count;
-
-import java.math.BigDecimal;
-import java.util.Date;
-import java.util.List;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Service;
-
-import com.yeshi.fanli.dao.user.count.DailyCountMomentsDao;
-import com.yeshi.fanli.entity.admin.count.DailyCountMoments;
-import com.yeshi.fanli.entity.admin.count.DailyCountMoments.DailyCountMomentsEnum;
-import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.count.DailyCountMomentsService;
-import org.yeshi.utils.MoneyBigDecimalUtil;
-import com.yeshi.fanli.util.StringUtil;
-import org.yeshi.utils.TimeUtil;
-
-@Service
-public class DailyCountMomentsServiceImpl implements DailyCountMomentsService {
-
- @Resource
- private DailyCountMomentsDao dailyCountMomentsDao;
-
- @Override
- public List<DailyCountMoments> getDailyCountList(String type, Date startTime, Date endTime) throws Exception {
- // 鏌ヨ绫诲瀷
- DailyCountMomentsEnum typeEnum = getTypeEnum(type);
- if (typeEnum == null) {
- return null;
- }
- return dailyCountMomentsDao.query(typeEnum, startTime, endTime);
- }
-
- /**
- * 鑾峰彇鏋氫妇绫诲瀷
- *
- * @param type
- * @return
- */
- private DailyCountMomentsEnum getTypeEnum(String name) {
- if (StringUtil.isNullOrEmpty(name)) {
- return null;
- }
-
- DailyCountMomentsEnum[] array = DailyCountMomentsEnum.values();
- for (int i = 0; i < array.length; i++) {
- if (array[i].name().equals(name)) {
- return array[i];
- }
- }
- return null;
- }
-
- /**
- * 鑾峰彇鏋氫妇绫诲瀷
- *
- * @param type
- * @return
- */
- @Override
- public String getTypeEnumDesc(String name) {
- if (StringUtil.isNullOrEmpty(name)) {
- return "";
- }
-
- DailyCountMomentsEnum[] array = DailyCountMomentsEnum.values();
- for (int i = 0; i < array.length; i++) {
- if (array[i].name().equals(name)) {
- return array[i].getDesc();
- }
- }
- return "";
- }
-
-
-
-
- /**
- * 娣诲姞鍒嗕韩娆℃暟缁熻
- */
- @Override
- public void addShareClick() {
- try {
- BigDecimal num = new BigDecimal(1);
- // 褰撴棩鏃ユ湡
- String toDay = TimeUtil.getGernalTime(java.lang.System.currentTimeMillis());
-
- String id = StringUtil.Md5(toDay + DailyCountMomentsEnum.shareClick.name());
-
- DailyCountMoments moments = dailyCountMomentsDao.get(id);
- if (moments != null) {
- moments.setTotal(MoneyBigDecimalUtil.add(moments.getTotal(), num));
- moments.setUpdateDate(new Date());
- dailyCountMomentsDao.save(moments);
- } else {
- moments = new DailyCountMoments();
- moments.setId(id);
- moments.setTotal(num);
- moments.setType(DailyCountMomentsEnum.shareClick);
- moments.setUpdateDate(new Date());
- moments.setDay(TimeUtil.parse(toDay));
- dailyCountMomentsDao.save(moments);
- }
- } catch (Exception e) {
- e.printStackTrace();
- LogHelper.error(e);
- }
- }
-
-
- /**
- * 娣诲姞澶嶅埗璇勮缁熻
- */
- @Override
- public void addCopyComment() {
- try {
- BigDecimal num = new BigDecimal(1);
- // 褰撴棩鏃ユ湡
- String toDay = TimeUtil.getGernalTime(java.lang.System.currentTimeMillis());
-
- String id = StringUtil.Md5(toDay + DailyCountMomentsEnum.copyComment.name());
-
- DailyCountMoments moments = dailyCountMomentsDao.get(id);
- if (moments != null) {
- moments.setTotal(MoneyBigDecimalUtil.add(moments.getTotal(), num));
- moments.setUpdateDate(new Date());
- dailyCountMomentsDao.save(moments);
- } else {
- moments = new DailyCountMoments();
- moments.setId(id);
- moments.setTotal(num);
- moments.setType(DailyCountMomentsEnum.copyComment);
- moments.setUpdateDate(new Date());
- moments.setDay(TimeUtil.parse(toDay));
- dailyCountMomentsDao.save(moments);
- }
- } catch (Exception e) {
- e.printStackTrace();
- LogHelper.error(e);
- }
- }
-}
+package com.yeshi.fanli.service.impl.count;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Service;
+
+import com.yeshi.fanli.dao.user.count.DailyCountMomentsDao;
+import com.yeshi.fanli.entity.admin.count.DailyCountMoments;
+import com.yeshi.fanli.entity.admin.count.DailyCountMoments.DailyCountMomentsEnum;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.count.DailyCountMomentsService;
+import org.yeshi.utils.MoneyBigDecimalUtil;
+import com.yeshi.fanli.util.StringUtil;
+import org.yeshi.utils.TimeUtil;
+
+@Service
+public class DailyCountMomentsServiceImpl implements DailyCountMomentsService {
+
+ @Resource
+ private DailyCountMomentsDao dailyCountMomentsDao;
+
+ @Override
+ public List<DailyCountMoments> getDailyCountList(String type, Date startTime, Date endTime) throws Exception {
+ // 鏌ヨ绫诲瀷
+ DailyCountMomentsEnum typeEnum = getTypeEnum(type);
+ if (typeEnum == null) {
+ return null;
+ }
+ return dailyCountMomentsDao.query(typeEnum, startTime, endTime);
+ }
+
+ /**
+ * 鑾峰彇鏋氫妇绫诲瀷
+ *
+ * @param type
+ * @return
+ */
+ private DailyCountMomentsEnum getTypeEnum(String name) {
+ if (StringUtil.isNullOrEmpty(name)) {
+ return null;
+ }
+
+ DailyCountMomentsEnum[] array = DailyCountMomentsEnum.values();
+ for (int i = 0; i < array.length; i++) {
+ if (array[i].name().equals(name)) {
+ return array[i];
+ }
+ }
+ return null;
+ }
+
+ /**
+ * 鑾峰彇鏋氫妇绫诲瀷
+ *
+ * @param type
+ * @return
+ */
+ @Override
+ public String getTypeEnumDesc(String name) {
+ if (StringUtil.isNullOrEmpty(name)) {
+ return "";
+ }
+
+ DailyCountMomentsEnum[] array = DailyCountMomentsEnum.values();
+ for (int i = 0; i < array.length; i++) {
+ if (array[i].name().equals(name)) {
+ return array[i].getDesc();
+ }
+ }
+ return "";
+ }
+
+
+
+
+ /**
+ * 娣诲姞鍒嗕韩娆℃暟缁熻
+ */
+ @Override
+ public void addShareClick() {
+ try {
+ BigDecimal num = new BigDecimal(1);
+ // 褰撴棩鏃ユ湡
+ String toDay = TimeUtil.getGernalTime(java.lang.System.currentTimeMillis());
+
+ String id = StringUtil.Md5(toDay + DailyCountMomentsEnum.shareClick.name());
+
+ DailyCountMoments moments = dailyCountMomentsDao.get(id);
+ if (moments != null) {
+ moments.setTotal(MoneyBigDecimalUtil.add(moments.getTotal(), num));
+ moments.setUpdateDate(new Date());
+ dailyCountMomentsDao.save(moments);
+ } else {
+ moments = new DailyCountMoments();
+ moments.setId(id);
+ moments.setTotal(num);
+ moments.setType(DailyCountMomentsEnum.shareClick);
+ moments.setUpdateDate(new Date());
+ moments.setDay(TimeUtil.parse(toDay));
+ dailyCountMomentsDao.save(moments);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ LogHelper.error(e);
+ }
+ }
+
+
+ /**
+ * 娣诲姞澶嶅埗璇勮缁熻
+ */
+ @Override
+ public void addCopyComment() {
+ try {
+ BigDecimal num = new BigDecimal(1);
+ // 褰撴棩鏃ユ湡
+ String toDay = TimeUtil.getGernalTime(java.lang.System.currentTimeMillis());
+
+ String id = StringUtil.Md5(toDay + DailyCountMomentsEnum.copyComment.name());
+
+ DailyCountMoments moments = dailyCountMomentsDao.get(id);
+ if (moments != null) {
+ moments.setTotal(MoneyBigDecimalUtil.add(moments.getTotal(), num));
+ moments.setUpdateDate(new Date());
+ dailyCountMomentsDao.save(moments);
+ } else {
+ moments = new DailyCountMoments();
+ moments.setId(id);
+ moments.setTotal(num);
+ moments.setType(DailyCountMomentsEnum.copyComment);
+ moments.setUpdateDate(new Date());
+ moments.setDay(TimeUtil.parse(toDay));
+ dailyCountMomentsDao.save(moments);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ LogHelper.error(e);
+ }
+ }
+}
--
Gitblit v1.8.0