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/controller/admin/shop/BanLiShopGoodsSetAdminController.java |  342 ++++++++++++++++++++++++++++++--------------------------
 1 files changed, 181 insertions(+), 161 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/admin/shop/BanLiShopGoodsSetAdminController.java b/fanli/src/main/java/com/yeshi/fanli/controller/admin/shop/BanLiShopGoodsSetAdminController.java
index 345937f..e101b31 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/admin/shop/BanLiShopGoodsSetAdminController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/admin/shop/BanLiShopGoodsSetAdminController.java
@@ -1,161 +1,181 @@
-package com.yeshi.fanli.controller.admin.shop;
-
-import java.io.PrintWriter;
-import java.util.ArrayList;
-import java.util.List;
-
-import javax.annotation.Resource;
-import javax.servlet.http.HttpServletRequest;
-
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.yeshi.utils.JsonUtil;
-
-import com.google.gson.Gson;
-import com.google.gson.GsonBuilder;
-import com.google.gson.reflect.TypeToken;
-import com.yeshi.fanli.entity.shop.BanLiShopGoodsSets;
-import com.yeshi.fanli.exception.shop.BanLiShopGoodsSetException;
-import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsSetService;
-import com.yeshi.fanli.tag.PageEntity;
-import com.yeshi.fanli.util.Constant;
-import com.yeshi.fanli.util.StringUtil;
-
-import net.sf.json.JSONObject;
-
-@Controller
-@RequestMapping("admin/new/api/v1/blSet")
-public class BanLiShopGoodsSetAdminController {
-	
-	@Resource
-	private BanLiShopGoodsSetService banLiShopGoodsSetService;
-	
-	
-	/**
-	 * 淇濆瓨淇℃伅
-	 * 
-	 * @param callback
-	 * @param special
-	 * @param out
-	 */
-	@RequestMapping(value = "save")
-	public void save(String callback, BanLiShopGoodsSets record, HttpServletRequest request, PrintWriter out) {
-		try {
-			banLiShopGoodsSetService.saveObject(record);
-			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("淇濆瓨鎴愬姛"));
-		} catch (BanLiShopGoodsSetException e) {
-			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
-		} catch (Exception e) {
-			e.printStackTrace();
-			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
-		}
-	}
-	
-	 /** 
-	 * 鍒犻櫎
-	 * @param callback
-	 * @param idArray
-	 * @param out
-	 */
-	@RequestMapping(value = "delete")
-	public void delete(String callback, String idArray, PrintWriter out) {
-		try {
-			if (StringUtil.isNullOrEmpty(idArray)) {
-				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨鎿嶄綔鐨勬暟鎹�"));
-				return;
-			}
-
-			Gson gson = new Gson();
-			List<Long> list = gson.fromJson(idArray, new TypeToken<ArrayList<Long>>() {
-			}.getType());
-			if (list == null || list.size() == 0) {
-				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈娴嬪埌鍒犻櫎鐨勬暟鎹�"));
-				return;
-			}
-			banLiShopGoodsSetService.delete(list);
-			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎴愬姛鍒犻櫎鏁版嵁"));
-		} catch (Exception e) {
-			e.printStackTrace();
-			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍒犻櫎澶辫触"));
-		}
-	}
-	
-	
-	/**
-	 * 鏌ヨ
-	 * @param callback
-	 * @param pageIndex
-	 * @param pageSize
-	 * @param key  妯$硦鏌ヨ锛氳鏄庛�佹爣璇�
-	 * @param out
-	 */
-	@RequestMapping(value = "query")
-	public void query(String callback, Integer pageIndex, Integer pageSize, String key, Long goodsId, PrintWriter out) {
-		try {
-			if (pageIndex == null || pageIndex < 1)
-				pageIndex = 1;
-	
-			if (pageSize == null || pageSize < 1) 
-				pageSize = Constant.PAGE_SIZE;
-	
-			List<BanLiShopGoodsSets> list = banLiShopGoodsSetService.listQuery(pageIndex, pageSize, key, goodsId);
-			if (list == null || list.size() == 0) {
-				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁"));
-				return;
-			}
-			
-			long count = banLiShopGoodsSetService.countQuery(key, goodsId);
-			
-			int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
-			PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
-
-			GsonBuilder gsonBuilder = new GsonBuilder();
-			gsonBuilder.serializeNulls(); 
-			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
-
-			JSONObject data = new JSONObject();
-			data.put("pe", pe);
-			data.put("result_list", gson.toJson(list));
-			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
-		} catch (Exception e) {
-			e.printStackTrace();
-			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
-		}
-	}
-
-	
-	
-//	/**
-//	 * 绛涢�夊垪琛�
-//	 * 
-//	 * @param callback
-//	 * @param out
-//	 */
-//	@RequestMapping(value = "getOptions")
-//	public void getOptions(String callback, PrintWriter out) {
-//		try {
-//			List<BanLiShopGoodsClass> list = banLiShopGoodsClassService.listAllGoodsClass();
-//			if (list == null || list.size() == 0) {
-//				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁"));
-//				return;
-//			}
-//
-//			List<Object> result_list = new ArrayList<Object>();
-//			if (list != null && list.size() > 0) {
-//				for (BanLiShopGoodsClass record : list) {
-//					Map<String, Object> map = new HashMap<String, Object>();
-//					map.put("key", record.getId());
-//					map.put("value", record.getName());
-//					result_list.add(map);
-//				}
-//			}
-//
-//			JSONObject data = new JSONObject();
-//			data.put("result_list", result_list);
-//			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
-//		} catch (Exception e) {
-//			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
-//			e.printStackTrace();
-//		}
-//	}
-}
+package com.yeshi.fanli.controller.admin.shop;
+
+import java.io.PrintWriter;
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+
+import com.yeshi.fanli.entity.accept.AdminAcceptData;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.yeshi.utils.JsonUtil;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.reflect.TypeToken;
+import com.yeshi.fanli.entity.shop.BanLiShopGoodsSets;
+import com.yeshi.fanli.exception.shop.BanLiShopGoodsSetException;
+import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsSetService;
+import com.yeshi.common.entity.PageEntity;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.StringUtil;
+
+import net.sf.json.JSONObject;
+
+@Controller
+@RequestMapping("admin/new/api/v1/blSet")
+public class BanLiShopGoodsSetAdminController {
+	
+	@Resource
+	private BanLiShopGoodsSetService banLiShopGoodsSetService;
+	
+	
+	/**
+	 * 淇濆瓨淇℃伅
+	 * 
+	 * @param callback
+	 * @param special
+	 * @param out
+	 */
+	@RequestMapping(value = "save")
+	public void save(AdminAcceptData acceptData, String callback, BanLiShopGoodsSets record, HttpServletRequest request, PrintWriter out) {
+		try {
+			banLiShopGoodsSetService.saveObject(record);
+			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("淇濆瓨鎴愬姛"));
+		} catch (BanLiShopGoodsSetException e) {
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
+		} catch (Exception e) {
+			e.printStackTrace();
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
+		}
+	}
+	
+	/**
+	 * 淇敼鐘舵��
+	 * @param callback
+	 * @param id
+	 * @param out
+	 */
+	@RequestMapping(value = "switchState")
+	public void switchState(AdminAcceptData acceptData,String callback, Long id, PrintWriter out) {
+		try {
+			banLiShopGoodsSetService.switchState(id);
+			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛"));
+		} catch (BanLiShopGoodsSetException e) {
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
+		} catch (Exception e) {
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔澶辫触"));
+			e.printStackTrace();
+		}
+	}
+	
+	 /** 
+	 * 鍒犻櫎
+	 * @param callback
+	 * @param idArray
+	 * @param out
+	 */
+	@RequestMapping(value = "delete")
+	public void delete(AdminAcceptData acceptData,String callback, String idArray, PrintWriter out) {
+		try {
+			if (StringUtil.isNullOrEmpty(idArray)) {
+				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨鎿嶄綔鐨勬暟鎹�"));
+				return;
+			}
+
+			Gson gson = new Gson();
+			List<Long> list = gson.fromJson(idArray, new TypeToken<ArrayList<Long>>() {
+			}.getType());
+			if (list == null || list.size() == 0) {
+				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈娴嬪埌鍒犻櫎鐨勬暟鎹�"));
+				return;
+			}
+			banLiShopGoodsSetService.delete(list);
+			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎴愬姛鍒犻櫎鏁版嵁"));
+		} catch (Exception e) {
+			e.printStackTrace();
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍒犻櫎澶辫触"));
+		}
+	}
+	
+	
+	/**
+	 * 鏌ヨ
+	 * @param callback
+	 * @param pageIndex
+	 * @param pageSize
+	 * @param key  妯$硦鏌ヨ锛氳鏄庛�佹爣璇�
+	 * @param out
+	 */
+	@RequestMapping(value = "query")
+	public void query(AdminAcceptData acceptData,String callback, Integer pageIndex, Integer pageSize, String key, Long goodsId, PrintWriter out) {
+		try {
+			if (pageIndex == null || pageIndex < 1)
+				pageIndex = 1;
+	
+			if (pageSize == null || pageSize < 1) 
+				pageSize = Constant.PAGE_SIZE;
+	
+			List<BanLiShopGoodsSets> list = banLiShopGoodsSetService.listQuery(pageIndex, pageSize, key, goodsId);
+			if (list == null || list.size() == 0) {
+				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁"));
+				return;
+			}
+			
+			long count = banLiShopGoodsSetService.countQuery(key, goodsId);
+			
+			int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+			PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
+
+			GsonBuilder gsonBuilder = new GsonBuilder();
+			gsonBuilder.serializeNulls(); 
+			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
+
+			JSONObject data = new JSONObject();
+			data.put("pe", pe);
+			data.put("result_list", gson.toJson(list));
+			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
+		} catch (Exception e) {
+			e.printStackTrace();
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
+		}
+	}
+
+	
+	
+//	/**
+//	 * 绛涢�夊垪琛�
+//	 * 
+//	 * @param callback
+//	 * @param out
+//	 */
+//	@RequestMapping(value = "getOptions")
+//	public void getOptions(String callback, PrintWriter out) {
+//		try {
+//			List<BanLiShopGoodsClass> list = banLiShopGoodsClassService.listAllGoodsClass();
+//			if (list == null || list.size() == 0) {
+//				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁"));
+//				return;
+//			}
+//
+//			List<Object> result_list = new ArrayList<Object>();
+//			if (list != null && list.size() > 0) {
+//				for (BanLiShopGoodsClass record : list) {
+//					Map<String, Object> map = new HashMap<String, Object>();
+//					map.put("key", record.getId());
+//					map.put("value", record.getName());
+//					result_list.add(map);
+//				}
+//			}
+//
+//			JSONObject data = new JSONObject();
+//			data.put("result_list", result_list);
+//			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
+//		} catch (Exception e) {
+//			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
+//			e.printStackTrace();
+//		}
+//	}
+}

--
Gitblit v1.8.0