dubbo集成修改

admin

2020-07-16 be67478cae6bf9308f15949a21e7d0a57a3f0ecb

 fanli/src/main/java/com/yeshi/fanli/controller/admin/ActivityAdminController.java

@@ -1,25 +1,26 @@
package com.yeshi.fanli.controller.admin;



import java.io.PrintWriter;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.Date;

import java.util.List;

import java.util.Map;



import javax.annotation.Resource;



import com.yeshi.fanli.entity.accept.AdminAcceptData;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.JsonUtil;



import com.google.gson.Gson;

import com.google.gson.reflect.TypeToken;

import com.yeshi.fanli.entity.bus.activity.ActivityUser;

import com.yeshi.fanli.entity.bus.activity.RecommendActivity;

import com.yeshi.fanli.entity.bus.activity.RecommendActivityInviteInfo;

import com.yeshi.fanli.exception.ActivityException;

import com.yeshi.fanli.service.inter.activity.ActivityService;

import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;

import com.yeshi.fanli.tag.PageEntity;

import com.yeshi.common.entity.PageEntity;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;



@@ -33,8 +34,6 @@
   @Resource

   private ActivityService activityService;



   @Resource

   private TaoBaoGoodsBriefService taoBaoGoodsBriefService;



   /**

    * 获取活动用户列表

@@ -43,7 +42,7 @@
    * @param out

    */

   @RequestMapping(value = "getActivityUserList")

   public void getUserList(String callback, PrintWriter out) {

   public void getUserList(AdminAcceptData acceptData, String callback, PrintWriter out) {

      List<ActivityUser> list = activityService.getActivityUserList();

      if (StringUtil.isNullOrEmpty(callback)) {

         out.print(JsonUtil.loadTrueResult(JsonUtil.getSimpleGson().toJson(list)));

@@ -53,49 +52,93 @@
   }



   @RequestMapping(value = "getActivity")

   public void getActivity(String callback, long id, PrintWriter out) {

      RecommendActivity recommendActivity = activityService.getRecommendActivityById(id);

      if (recommendActivity.getType() == RecommendActivity.TYPE_INVITE) {

         RecommendActivityInviteInfo info = activityService

               .getRecommendActivityInviteInfoByActivityId(recommendActivity.getId());

         recommendActivity.setInviteInfo(info);

      }

   public void getActivity(AdminAcceptData acceptData,String callback, long id, PrintWriter out) {

		
      try {

         RecommendActivity recommendActivity = activityService.getRecommendActivityById(id);

         if (recommendActivity ==null) {

            if (StringUtil.isNullOrEmpty(callback)) {

               out.print(JsonUtil.loadFalseResult("该动态已不存在"));

            } else {

               out.print(callback + "(" + JsonUtil.loadFalseResult("该动态已不存在") + ")");

            }

            return;

         }

			
         if (recommendActivity.getType() == RecommendActivity.TYPE_INVITE) {

            RecommendActivityInviteInfo info = activityService

                  .getRecommendActivityInviteInfoByActivityId(recommendActivity.getId());

            recommendActivity.setInviteInfo(info);

         }



      if (StringUtil.isNullOrEmpty(callback)) {

         out.print(JsonUtil.loadTrueResult(recommendActivity));

      } else {

         out.print(callback + "(" + JsonUtil.loadTrueResult(recommendActivity) + ")");

         Date startTime = recommendActivity.getStartTime();

         Date endTime = recommendActivity.getEndTime();

			
         if (startTime == null && endTime == null) {

            recommendActivity.setTimeTask(false);

            recommendActivity.setStartTime_str("");

            recommendActivity.setEndTime_str("");

         } else {

            recommendActivity.setTimeTask(true);

				
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm");

            if (startTime == null) {

               recommendActivity.setStartTime_str("");

            } else {

               recommendActivity.setStartTime_str(sdf.format(startTime));

            }

				
            if (endTime == null) {

               recommendActivity.setEndTime_str("");

            } else {

               recommendActivity.setEndTime_str(sdf.format(endTime));

            }

         }

			
         ActivityUser activityUser = recommendActivity.getActivityUser();

         if (activityUser != null) {

            ActivityUser resultUser = activityService.selectActivityUserByPrimaryKey(activityUser.getId());

            recommendActivity.setActivityUser(resultUser);

         }

			
         if (StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadTrueResult(recommendActivity));

         } else {

            out.print(callback + "(" + JsonUtil.loadTrueResult(recommendActivity) + ")");

         }

      } catch (Exception e) {

         if (StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadFalseResult("操作失败"));

         } else {

            out.print(callback + "(" + JsonUtil.loadFalseResult("操作失败") + ")");

         }

         e.printStackTrace();

      }

		
   }



   @RequestMapping(value = "addShareGoodsActivity")

   public void addShareGoodsActivity(String callback, Long uid, String title, String actionIds, boolean top,

         int shareCount, PrintWriter out) {

   public void addShareGoodsActivity(AdminAcceptData acceptData,String callback, Long uid, String actionIds, RecommendActivity activity, PrintWriter out) {



      if (uid == null) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请选择发布用户") + ")");

         return;

      }



      if (StringUtil.isNullOrEmpty(title)) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传标题") + ")");

         return;

      }



		
      if (StringUtil.isNullOrEmpty(actionIds)) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "选择商品") + ")");

         return;

      }



      // title = Jsoup.parse(title).text();



      JSONArray array = JSONArray.fromObject(actionIds);

      List<Long> auctionIds = new ArrayList<>();

      for (int i = 0; i < array.size(); i++) {

         auctionIds.add(array.optLong(i));

      }

		
      try {

         activityService.addShareGoodsRecommendActivity(uid, title, auctionIds, top, shareCount);

         activityService.addShareGoodsRecommendActivity(uid,auctionIds, activity);

         if (StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadTrueResult("添加成功"));

         } else {

@@ -107,15 +150,17 @@
         } else {

            out.print(callback + "(" + JsonUtil.loadFalseResult(e.getCode(), e.getMsg()) + ")");

         }

      } catch (Exception e) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "操作失败") + ")");

         e.printStackTrace();

      }

   }



   // 修改商品分享动态

   @RequestMapping(value = "updateShareGoodsActivity")

   public void updateShareGoodsActivity(String callback, Long id, Long uid, String title, String actionIds,

         boolean top, int shareCount, PrintWriter out) {

   public void updateShareGoodsActivity(AdminAcceptData acceptData,String callback, Long uid, String actionIds, RecommendActivity activity, PrintWriter out) {



      if (id == null) {

      if (activity.getId() == null) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传ID") + ")");

         return;

      }

@@ -125,7 +170,7 @@
         return;

      }



      if (StringUtil.isNullOrEmpty(title)) {

      if (StringUtil.isNullOrEmpty(activity.getTitle())) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传标题") + ")");

         return;

      }

@@ -135,7 +180,6 @@
         return;

      }



      // title = Jsoup.parse(title).text();



      JSONArray array = JSONArray.fromObject(actionIds);

      List<Long> auctionIds = new ArrayList<>();

@@ -143,7 +187,7 @@
         auctionIds.add(array.optLong(i));

      }

      try {

         activityService.updateShareGoodsRecommendActivity(id, uid, title, auctionIds, top, shareCount);

         activityService.updateShareGoodsRecommendActivity(uid, auctionIds, activity);

         if (StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadTrueResult("添加成功"));

         } else {

@@ -155,6 +199,9 @@
         } else {

            out.print(callback + "(" + JsonUtil.loadFalseResult(e.getCode(), e.getMsg()) + ")");

         }

      } catch (Exception e) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "操作失败") + ")");

         e.printStackTrace();

      }

   }



@@ -170,7 +217,7 @@
    * @param out

    */

   @RequestMapping(value = "addInviteActivity")

   public void addInviteActivity(String callback, Long uid, String title, String img, boolean top, int shareCount,

   public void addInviteActivity(AdminAcceptData acceptData,String callback, Long uid,RecommendActivity activity, String img,

         int px, int py, int size, PrintWriter out) {



      if (uid == null) {

@@ -178,7 +225,7 @@
         return;

      }



      if (StringUtil.isNullOrEmpty(title)) {

      if (StringUtil.isNullOrEmpty(activity.getTitle())) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传标题") + ")");

         return;

      }

@@ -187,11 +234,12 @@
         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "分享图不能为空") + ")");

         return;

      }



      // title = Jsoup.parse(title).text();

		
      //去掉 图片路径前后空格 
      img = img.trim();



      try {

         activityService.addInviteImgRecommendActivity(uid, title, img, top, shareCount, px, py, size);

         activityService.addInviteImgRecommendActivity(uid, activity, img, px, py, size);

         if (StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadTrueResult("添加成功"));

         } else {

@@ -203,6 +251,9 @@
         } else {

            out.print(callback + "(" + JsonUtil.loadFalseResult(e.getCode(), e.getMsg()) + ")");

         }

      } catch (Exception e) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "操作失败") + ")");

         e.printStackTrace();

      }

   }



@@ -219,11 +270,11 @@
    * @param out

    */

   @RequestMapping(value = "updateInviteActivity")

   public void updateInviteActivity(String callback, Long id, Long uid, String title, String img, boolean top,

         int shareCount, int px, int py, int size, PrintWriter out) {

   public void updateInviteActivity(AdminAcceptData acceptData,String callback, Long uid, RecommendActivity activity, String img,

          int px, int py, int size, PrintWriter out) {



      if (id == null) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请选择用户") + ")");

      if (activity.getId() == null) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "ID不能为空") + ")");

         return;

      }



@@ -232,7 +283,7 @@
         return;

      }



      if (StringUtil.isNullOrEmpty(title)) {

      if (StringUtil.isNullOrEmpty(activity.getTitle())) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传标题") + ")");

         return;

      }

@@ -245,7 +296,7 @@
      // title = Jsoup.parse(title).text();



      try {

         activityService.updateInviteImgRecommendActivity(id, uid, title, img, top, shareCount, px, py, size);

         activityService.updateInviteImgRecommendActivity(uid, activity, img, px, py, size);

         if (StringUtil.isNullOrEmpty(callback))

            out.print(JsonUtil.loadTrueResult("添加成功"));

         else

@@ -255,6 +306,9 @@
            out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));

         else

            out.print(callback + "(" + JsonUtil.loadFalseResult(e.getCode(), e.getMsg()) + ")");

      } catch (Exception e) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "操作失败") + ")");

         e.printStackTrace();

      }

   }



@@ -269,29 +323,28 @@
    * @param out

    */

   @RequestMapping(value = "addTextImgActivity")

   public void addTextImgActivity(String callback, Long uid, String title, String imgs, boolean top, int shareCount,

   public void addTextImgActivity(AdminAcceptData acceptData,String callback, Long uid, RecommendActivity activity, String imgs,

         PrintWriter out) {

      if (uid == null) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请选择发布用户") + ")");

         return;

      }



      if (StringUtil.isNullOrEmpty(title)) {

      if (StringUtil.isNullOrEmpty(activity.getTitle())) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传标题") + ")");

         return;

      }



      // title = Jsoup.parse(title).text();



      List<String> imgList = new ArrayList<>();

      if (!StringUtil.isNullOrEmpty(imgs)) {

         JSONArray array = JSONArray.fromObject(imgs);

         for (int i = 0; i < array.size(); i++)

            imgList.add(array.optString(i));

            imgList.add(array.optString(i).trim());

      }



      try {

         activityService.addTextAndImgRecommendActivity(uid, title, imgList, top, shareCount);

         activityService.addTextAndImgRecommendActivity(uid, imgList, activity);

         if (StringUtil.isNullOrEmpty(callback))

            out.print(JsonUtil.loadTrueResult("添加成功"));

         else

@@ -301,6 +354,9 @@
            out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));

         else

            out.print(callback + "(" + JsonUtil.loadFalseResult(e.getCode(), e.getMsg()) + ")");

      } catch (Exception e) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "操作失败") + ")");

         e.printStackTrace();

      }

   }



@@ -316,10 +372,9 @@
    * @param out

    */

   @RequestMapping(value = "updateTextImgActivity")

   public void updateTextImgActivity(String callback, Long id, Long uid, String title, String imgs, boolean top,

         int shareCount, PrintWriter out) {

   public void updateTextImgActivity(AdminAcceptData acceptData,String callback, Long uid,  String imgs, RecommendActivity activity, PrintWriter out) {



      if (id == null) {

      if (activity.getId() == null) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传ID") + ")");

         return;

      }

@@ -329,7 +384,7 @@
         return;

      }



      if (StringUtil.isNullOrEmpty(title)) {

      if (StringUtil.isNullOrEmpty(activity.getTitle())) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "请上传标题") + ")");

         return;

      }

@@ -340,11 +395,11 @@
      if (!StringUtil.isNullOrEmpty(imgs)) {

         JSONArray array = JSONArray.fromObject(imgs);

         for (int i = 0; i < array.size(); i++)

            imgList.add(array.optString(i));

            imgList.add(array.optString(i).trim());

      }



      try {

         activityService.updateTextAndImgRecommendActivity(id, uid, title, imgList, top, shareCount);

         activityService.updateTextAndImgRecommendActivity(uid, imgList, activity);

         if (StringUtil.isNullOrEmpty(callback))

            out.print(JsonUtil.loadTrueResult("添加成功"));

         else

@@ -354,9 +409,13 @@
            out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));

         else

            out.print(callback + "(" + JsonUtil.loadFalseResult(e.getCode(), e.getMsg()) + ")");

      } catch (Exception e) {

         out.print(callback + "(" + JsonUtil.loadFalseResult(1, "操作失败") + ")");

         e.printStackTrace();

      }

   }



	
   /**

    * 

    * @param pageIndex

@@ -365,41 +424,124 @@
    *            查询条件

    * @param out

    */

   @RequestMapping(value = "getRecommendActivityList", method = RequestMethod.POST)

   public void getRecommendActivityList(int pageIndex, String key, PrintWriter out) {

      List<RecommendActivity> recommendActivityList = null;

      if (StringUtil.isNullOrEmpty(key)) {

         recommendActivityList = activityService.getRecommendActivityList(pageIndex, Constant.PAGE_SIZE);

      } else {

         recommendActivityList = activityService.queryRecommendActivityList(key, pageIndex, Constant.PAGE_SIZE);

   @RequestMapping(value = "query")

   public void query(AdminAcceptData acceptData,String callback, Integer pageIndex, Integer pageSize, String key, PrintWriter out) {

		
      if (pageIndex == null || pageIndex < 1) {

         pageIndex = 1;

      }



      int count = (int) activityService.getRecommendActivityCount();

      if (pageSize == null || pageSize < 1) {

         pageSize = Constant.PAGE_SIZE;

      }

		
      try {

			
         List<RecommendActivity> list = activityService.queryRecommendActivityList(key, pageIndex, Constant.PAGE_SIZE);

         if (list == null || list.size() == 0) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));

            return;

         }

		
         for (RecommendActivity activity: list) {

				
            Date startTime = activity.getStartTime();

            Date endTime = activity.getEndTime();

				
            if (startTime == null && endTime == null) {

               activity.setTimeTask(false);

               activity.setStartTime_str("");

               activity.setEndTime_str("");

            } else {

               activity.setTimeTask(true);

					
               SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm");

               if (startTime == null) {

                  activity.setStartTime_str("");

               } else {

                  activity.setStartTime_str(sdf.format(startTime));

               }

					
               if (endTime == null) {

                  activity.setEndTime_str("");

               } else {

                  activity.setEndTime_str(sdf.format(endTime));

               }

            }

         }

			
         int count = (int) activityService.getRecommendActivityCount(key);



      int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1;

         int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1;

         PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage);

			
         JSONObject data = new JSONObject();

         data.put("pe", pe);

         data.put("result_list", list);



      PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage);

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));



      Map<String, String> map = new HashMap<String, String>();

      map.put("key", key);

      pe.setParams(map);

      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("查询失败"));

         e.printStackTrace();

      }

   }

	
	
	
   @RequestMapping(value = "saveModify")

   public void saveModify(AdminAcceptData acceptData,String callback, RecommendActivity recommendActivity, PrintWriter out) {

      try {



      JSONObject data = new JSONObject();

      data.put("pe", pe);

      data.put("recommendActivityList", recommendActivityList);

         Long id = recommendActivity.getId();

         if (id == null) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("ID不能为空"));

            return;

         }

			
         RecommendActivity resultObj = activityService.selectByPrimaryKey(id);

         if (resultObj == null) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作数据已不存在"));

            return;

         }



      out.print(JsonUtil.loadTrueResult(data));

         activityService.updateByPrimaryKeySelective(recommendActivity);



      return;

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("修改成功"));



      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));

         e.printStackTrace();

      }

   }



   @RequestMapping(value = "deleteRecommendActivity", method = RequestMethod.POST)

   public void deleteRecommendActivity(long[] rsids, PrintWriter out) {

      // recommendSpecialService.deleteSpecials(rsids);

	


      activityService.deleteRecommendActivity(rsids);

      out.print(JsonUtil.loadTrueResult("删除成功"));

	
   @RequestMapping(value = "delete")

   public void delete(AdminAcceptData acceptData,String callback, String idArray, PrintWriter out) {



      if (StringUtil.isNullOrEmpty(idArray)) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择操作的数据"));

         return;

      }

		
      try {

         Gson gson = new Gson();

         long[] hsids = gson.fromJson(idArray, new TypeToken<long[]>() {}.getType());

			
         if (hsids == null || hsids.length == 0) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未检测到删除的数据"));

            return;

         }

			
         activityService.deleteRecommendActivity(hsids);

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("删除成功"));

			
      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("删除失败"));

         e.printStackTrace();

      }

   }

   // deleteRecommendActivity



	
}