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.AdActivityVersionControl.AdActivityType; import com.yeshi.fanli.entity.bus.homemodule.FloatAD; 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.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 id * @param out */ @RequestMapping(value = "switchState") public void switchState(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(String callback, String idArray, PrintWriter out) { try { if (StringUtil.isNullOrEmpty(idArray)) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择操作的数据")); return; } Gson gson = new Gson(); List list = gson.fromJson(idArray, new TypeToken>() { }.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 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 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 appVersionList = appVersionService.getAppVersionInfoListByPlatform(platform); if (appVersionList != null) { versionList.addAll(appVersionList); } } } // 过滤 if (versionList != null) { if (versionList.size() > 0) { List sourceIdList = new ArrayList<>(); for (FloatAD floatAD : list) { sourceIdList.add(floatAD.getId()); } List versionIdList = new ArrayList<>(); for (AppVersionInfo versionInfo : versionList) versionIdList.add(versionInfo.getId()); Set 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 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 list = adActivityVersionControlService .listByTypeAndSourceId(AdActivityType.floatAD, id); List versionList = new ArrayList<>(); if (list != null) for (AdActivityVersionControl control : list) versionList.add(control.getVersion().getId()); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(versionList)); } }