From 7fa83e5dd03f7896bd1d1e8c47f5e926ff3d4ba0 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:12:24 +0800
Subject: [PATCH] CMQ改造为rabbitmq
---
service-push/src/main/java/com/ks/push/controller/admin/AdminAppController.java | 79 +++++++++++++++++++++++++++++++++++++--
1 files changed, 74 insertions(+), 5 deletions(-)
diff --git a/service-push/src/main/java/com/ks/push/controller/admin/AdminAppController.java b/service-push/src/main/java/com/ks/push/controller/admin/AdminAppController.java
index 24f8a33..b316902 100644
--- a/service-push/src/main/java/com/ks/push/controller/admin/AdminAppController.java
+++ b/service-push/src/main/java/com/ks/push/controller/admin/AdminAppController.java
@@ -1,27 +1,96 @@
package com.ks.push.controller.admin;
+import com.google.gson.*;
+import com.ks.push.dao.BPushAppInfoDao;
import com.ks.push.pojo.DO.BPushAppInfo;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Controller;
-import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
+import org.yeshi.utils.JsonUtil;
+import org.yeshi.utils.TimeUtil;
import javax.annotation.Resource;
import javax.servlet.http.HttpSession;
-import javax.validation.constraints.NotEmpty;
+import java.lang.reflect.Type;
+import java.util.Date;
+import java.util.List;
@Controller
@RequestMapping("/admin/api/app")
public class AdminAppController {
@Resource
- private BPushAppInfo adminUserManager;
+ private BPushAppInfoDao bPushAppInfoDao;
@ResponseBody
@RequestMapping("list")
- public String list(@NotEmpty(message = "璐﹀彿涓嶈兘涓虹┖") String account, @NotEmpty(message = "瀵嗙爜涓嶈兘涓虹┖") String pwd, @NotEmpty(message = "楠岃瘉鐮佷笉鑳戒负绌�") String code, BindingResult bindingResult, HttpSession session) {
+ public String list(String key, int page, int limit) {
+ BPushAppInfoDao.DaoQuery daoQuery = new BPushAppInfoDao.DaoQuery();
+ daoQuery.name = key;
+ daoQuery.start = (page - 1) * limit;
+ daoQuery.count = limit;
+ List<BPushAppInfo> list = bPushAppInfoDao.list(daoQuery);
+ long count = bPushAppInfoDao.count(daoQuery);
+ JSONObject data = new JSONObject();
+ Gson gson = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
- return null;
+ @Override
+ public JsonElement serialize(Date date, Type type, JsonSerializationContext jsonSerializationContext) {
+ return date == null ? new JsonPrimitive("") : new JsonPrimitive(TimeUtil.getGernalTime(date.getTime(), "yyyy.MM.dd HH:mm"));
+ }
+ }).create();
+
+ data.put("list", gson.toJson(list));
+ data.put("count", count);
+ return JsonUtil.loadTrueResult(data);
+ }
+
+ @ResponseBody
+ @RequestMapping("delete")
+ public String delete(String ids) {
+ JSONArray array = JSONArray.fromObject(ids);
+ for (int i = 0; i < array.size(); i++) {
+ Query query = new Query();
+ query.addCriteria(Criteria.where("appCode").is(array.optString(i)));
+ bPushAppInfoDao.delete(query);
+ }
+ return JsonUtil.loadTrueResult("");
+ }
+
+
+ @ResponseBody
+ @RequestMapping("update")
+ public String update(BPushAppInfo app, HttpSession session) {
+ if (app.getAppCode() == null) {
+ return JsonUtil.loadFalseResult("ID涓嶈兘涓虹┖");
+ }
+ bPushAppInfoDao.updateSelective(app);
+ return JsonUtil.loadTrueResult("");
+ }
+
+
+ @ResponseBody
+ @RequestMapping("add")
+ public String add(BPushAppInfo app, HttpSession session) {
+ if (app.getAppCode() == null) {
+ return JsonUtil.loadFalseResult("appCode涓嶈兘涓虹┖");
+ }
+ //鏌ヨ鏄惁瀛樺湪
+ BPushAppInfoDao.DaoQuery daoQuery = new BPushAppInfoDao.DaoQuery();
+ daoQuery.appCode = app.getAppCode();
+ if (bPushAppInfoDao.count(daoQuery) > 0) {
+ return JsonUtil.loadFalseResult("appCode宸茬粡瀛樺湪");
+ }
+ if (app.getCreateTime() == null) {
+ app.setCreateTime(new Date());
+ }
+
+ bPushAppInfoDao.save(app);
+ return JsonUtil.loadTrueResult("");
}
--
Gitblit v1.8.0