将CMQ替换为rabbitmq

admin

2024-10-16 62a447d89331aee1feae7724c7616aa1bb2cfe79

 fanli/src/main/java/com/yeshi/fanli/controller/admin/homemodule/FloatADAdminController.java

@@ -1,257 +1,270 @@
package com.yeshi.fanli.controller.admin.homemodule;



import java.io.PrintWriter;

import java.util.ArrayList;

import java.util.List;

import java.util.Set;



import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



import org.springframework.stereotype.Controller;

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

import org.springframework.web.multipart.MultipartHttpServletRequest;

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.AppVersionInfo;

import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl;

import com.yeshi.fanli.entity.bus.homemodule.FloatAD;

import com.yeshi.fanli.entity.bus.homemodule.Special;

import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl.AdActivityType;

import com.yeshi.fanli.exception.homemodule.FloatADException;

import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;

import com.yeshi.fanli.service.inter.config.AppVersionService;

import com.yeshi.fanli.service.inter.homemodule.AdActivityVersionControlService;

import com.yeshi.fanli.service.inter.homemodule.FloatADService;

import com.yeshi.fanli.tag.PageEntity;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



@Controller

@RequestMapping("admin/new/api/v1/floatad")

public class FloatADAdminController {



   @Resource

   private FloatADService floatADervice;



   @Resource

   private JumpDetailV2Service jumpDetailV2Service;

	
   @Resource

   private AppVersionService appVersionService;

	
   @Resource

   private AdActivityVersionControlService adActivityVersionControlService;

	
	


   /**

    * 保存信息

    * 
    * @param callback

    * @param special

    * @param out

    */

   @RequestMapping(value = "save")

   public void save(String callback, FloatAD floatAD, String jumpType, HttpServletRequest request,PrintWriter out) {

      try {

         // 1. 先判断httpRequest 是否含有文件类型 
         if (request instanceof MultipartHttpServletRequest) {

              MultipartHttpServletRequest fileRequest = (MultipartHttpServletRequest) request;

              floatADervice.saveObject(fileRequest.getFile("file"), floatAD, jumpType);

           }else{

              floatADervice.saveObject(null, floatAD, jumpType);

           }

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("保存成功"));

      } catch (FloatADException e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));

      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("保存失败"));

         e.printStackTrace();

      }

   }







   /**

    * 修改排序

    * 
    * @param callback

    * @param goodsClass

    * @param out

    */

   @RequestMapping(value = "updateOrder")

   public void updateOrder(String callback, Long id, Integer moveType, PrintWriter out) {

      try {

         floatADervice.updateOrder(id, moveType);

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));

      } catch (FloatADException 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(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;

         }



         int count = floatADervice.deleteByPrimaryKeyList(list);



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("成功删除[" + count + "]条数据"));



      } catch (Exception e) {

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

         e.printStackTrace();

      }



   }



   /**

    * 查询

    * 
    * @param callback

    * @param pageIndex

    * @param pageSize

    * @param out

    */

   @RequestMapping(value = "query")

   public void query(String callback, Integer pageIndex, Integer pageSize, String key, Integer state,

         String version, String platform, PrintWriter out) {



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

         pageIndex = 1;

      }



      pageSize =Integer.MAX_VALUE;



      try {

         List<FloatAD> list = floatADervice.listQuery((pageIndex - 1) * pageSize, pageSize, key, state);

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

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

            return;

         }

         long count = floatADervice.countQuery(key, state);

			
         List<AppVersionInfo> versionList = null;

         if (!StringUtil.isNullOrEmpty(version) || !StringUtil.isNullOrEmpty(platform)) {

            versionList = new ArrayList<>();

            if (!StringUtil.isNullOrEmpty(version)) {

               AppVersionInfo appVersion = appVersionService.selectByPrimaryKey(Long.parseLong(version));

               if (appVersion != null)

                  versionList.add(appVersion);

            } else {

               List<AppVersionInfo> appVersionList = appVersionService.getAppVersionInfoListByPlatform(platform);

               if (appVersionList != null) {

                  versionList.addAll(appVersionList);

               }

            }

         }

			
         // 过滤

         if (versionList != null) {

            if (versionList.size() > 0) {

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

               for (FloatAD floatAD : list) {

                  sourceIdList.add(floatAD.getId());

               }

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

               for (AppVersionInfo versionInfo : versionList)

                  versionIdList.add(versionInfo.getId());

               Set<Long> sets = adActivityVersionControlService.filterSourceIdByVersion(sourceIdList,

                     AdActivityType.floatAD, versionIdList);

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

                  if (!sets.contains(list.get(i).getId())) {

                     list.remove(i--);

                  }

               }

               count = list.size();

            } else {

               list.clear();

               count = 0;

            }

         }



         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'T'HH:mm").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) {

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

         e.printStackTrace();

      }

   }

	
	
   /**

    * 设置版本

    * 
    * @param callback

    * @param id

    * @param moveType

    * @param sex

    * @param out

    */

   @RequestMapping(value = "setVersions")

   public void setVersions(String callback, Long id, String versions, PrintWriter out) {

      JSONArray versionArray = JSONArray.fromObject(versions);

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

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

         Long version = versionArray.optLong(i);

         versionIds.add(version);

      }

      try {

         floatADervice.setVersions(id, versionIds);

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

      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMessage()));

      }

   }



   @RequestMapping(value = "getVersions")

   public void getVersions(String callback, Long id, PrintWriter out) {

      List<AdActivityVersionControl> list = adActivityVersionControlService

            .listByTypeAndSourceId(AdActivityType.floatAD, id);



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

      if (list != null)

         for (AdActivityVersionControl control : list)

            versionList.add(control.getVersion().getId());

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

   }

}

package com.yeshi.fanli.controller.admin.homemodule;

import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;

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.springframework.web.multipart.MultipartHttpServletRequest;
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.AppVersionInfo;
import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl;
import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl.AdActivityType;
import com.yeshi.fanli.entity.bus.homemodule.FloatAD;
import com.yeshi.fanli.exception.homemodule.FloatADException;
import com.yeshi.fanli.service.inter.config.AppVersionService;
import com.yeshi.fanli.service.inter.homemodule.AdActivityVersionControlService;
import com.yeshi.fanli.service.inter.homemodule.FloatADService;
import com.yeshi.common.entity.PageEntity;
import com.yeshi.fanli.util.StringUtil;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

@Controller
@RequestMapping("admin/new/api/v1/floatad")
public class FloatADAdminController {

    @Resource
    private FloatADService floatADervice;

    @Resource
    private AppVersionService appVersionService;

    @Resource
    private AdActivityVersionControlService adActivityVersionControlService;


    /**
     * 保存信息
     *
     * @param callback
     * @param out
     */
    @RequestMapping(value = "save")
    public void save(AdminAcceptData acceptData, String callback, FloatAD floatAD, String jumpType, HttpServletRequest request, PrintWriter out) {
        try {
            // 1. 先判断httpRequest 是否含有文件类型
            if (request instanceof MultipartHttpServletRequest) {
                MultipartHttpServletRequest fileRequest = (MultipartHttpServletRequest) request;
                floatADervice.saveObject(fileRequest.getFile("file"), floatAD, jumpType);
            } else {
                floatADervice.saveObject(null, floatAD, jumpType);
            }
            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("保存成功"));
        } catch (FloatADException e) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
        } catch (Exception e) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("保存失败"));
            e.printStackTrace();
        }
    }


    /**
     * 修改排序
     *
     * @param acceptData
     * @param callback
     * @param id
     * @param moveType
     * @param out
     */
    @RequestMapping(value = "updateOrder")
    public void updateOrder(AdminAcceptData acceptData, String callback, Long id, Integer moveType, PrintWriter out) {
        try {
            floatADervice.updateOrder(id, moveType);
            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));
        } catch (FloatADException e) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
        } catch (Exception e) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作失败"));
            e.printStackTrace();
        }
    }


    /**
     * 修改状态
     *
     * @param callback
     * @param id
     * @param out
     */
    @RequestMapping(value = "switchState")
    public void switchState(AdminAcceptData acceptData, String callback, Long id, PrintWriter out) {
        try {
            floatADervice.switchState(id);
            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));
        } catch (FloatADException 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;
            }

            int count = floatADervice.deleteByPrimaryKeyList(list);

            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("成功删除[" + count + "]条数据"));

        } catch (Exception e) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("删除失败"));
            e.printStackTrace();
        }

    }

    /**
     * 查询
     *
     * @param callback
     * @param pageIndex
     * @param pageSize
     * @param out
     */
    @RequestMapping(value = "query")
    public void query(AdminAcceptData acceptData, String callback, Integer pageIndex, Integer pageSize, String key, Integer state,
                      String version, String platform, PrintWriter out) {

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

        pageSize = Integer.MAX_VALUE;

        try {
            List<FloatAD> list = floatADervice.listQuery((pageIndex - 1) * pageSize, pageSize, key, state, acceptData.getSystem());
            if (list == null || list.size() == 0) {
                JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));
                return;
            }
            long count = floatADervice.countQuery(key, state, acceptData.getSystem());

            List<AppVersionInfo> versionList = null;
            if (!StringUtil.isNullOrEmpty(version) || !StringUtil.isNullOrEmpty(platform)) {
                versionList = new ArrayList<>();
                if (!StringUtil.isNullOrEmpty(version)) {
                    AppVersionInfo appVersion = appVersionService.selectByPrimaryKey(Long.parseLong(version));
                    if (appVersion != null)
                        versionList.add(appVersion);
                } else {
                    List<AppVersionInfo> appVersionList = appVersionService.getAppVersionInfoListByPlatform(platform, acceptData.getSystem());
                    if (appVersionList != null) {
                        versionList.addAll(appVersionList);
                    }
                }
            }

            // 过滤
            if (versionList != null) {
                if (versionList.size() > 0) {
                    List<Long> sourceIdList = new ArrayList<>();
                    for (FloatAD floatAD : list) {
                        sourceIdList.add(floatAD.getId());
                    }
                    List<Long> versionIdList = new ArrayList<>();
                    for (AppVersionInfo versionInfo : versionList)
                        versionIdList.add(versionInfo.getId());
                    Set<Long> sets = adActivityVersionControlService.filterSourceIdByVersion(sourceIdList,
                            AdActivityType.floatAD, versionIdList);
                    for (int i = 0; i < list.size(); i++) {
                        if (!sets.contains(list.get(i).getId())) {
                            list.remove(i--);
                        }
                    }
                    count = list.size();
                } else {
                    list.clear();
                    count = 0;
                }
            }

            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'T'HH:mm").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) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
            e.printStackTrace();
        }
    }


    /**
     * 设置版本
     *
     * @param callback
     * @param id
     * @param out
     */
    @RequestMapping(value = "setVersions")
    public void setVersions(AdminAcceptData acceptData, String callback, Long id, String versions, PrintWriter out) {
        JSONArray versionArray = JSONArray.fromObject(versions);
        List<Long> versionIds = new ArrayList<>();
        for (int i = 0; i < versionArray.size(); i++) {
            Long version = versionArray.optLong(i);
            versionIds.add(version);
        }
        try {
            floatADervice.setVersions(id, versionIds);
            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(""));
        } catch (Exception e) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMessage()));
        }
    }

    @RequestMapping(value = "getVersions")
    public void getVersions(AdminAcceptData acceptData, String callback, Long id, PrintWriter out) {
        List<AdActivityVersionControl> list = adActivityVersionControlService
                .listByTypeAndSourceId(AdActivityType.floatAD, id);

        List<Long> versionList = new ArrayList<>();
        if (list != null)
            for (AdActivityVersionControl control : list)
                versionList.add(control.getVersion().getId());
        JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(versionList));
    }
}