package com.yeshi.fanli.controller.admin.user.vip;
|
|
import java.io.PrintWriter;
|
import java.lang.reflect.Type;
|
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.IPUtil;
|
import org.yeshi.utils.JsonUtil;
|
|
import com.google.gson.Gson;
|
import com.google.gson.GsonBuilder;
|
import com.google.gson.JsonElement;
|
import com.google.gson.JsonPrimitive;
|
import com.google.gson.JsonSerializationContext;
|
import com.google.gson.JsonSerializer;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.bus.user.vip.GiveVIPApplyInfo;
|
import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;
|
import com.yeshi.fanli.entity.common.AdminUser;
|
import com.yeshi.fanli.exception.user.vip.GiveVIPApplyInfoException;
|
import com.yeshi.fanli.exception.user.vip.UserVIPPreInfoException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.vip.GiveVIPApplyInfoService;
|
import com.yeshi.fanli.tag.PageEntity;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.annotation.RequestSerializableByKey;
|
|
import net.sf.json.JSONObject;
|
|
@Controller
|
@RequestMapping("admin/new/api/v1/vip")
|
public class UserVipApplyAdminController {
|
|
@Resource
|
private GiveVIPApplyInfoService giveVIPApplyInfoService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
/**
|
*
|
* @param callback
|
* @param pageIndex
|
* @param pageSize
|
* @param key 搜索：暂只提供uid
|
* @param state 状态：
|
* @param out
|
*/
|
@RequestMapping(value = "queryVip")
|
public void queryVip(String callback, Integer pageIndex, Integer pageSize, String key, Integer state,
|
PrintWriter out) {
|
try {
|
|
Long targetUid = null;
|
try {
|
targetUid = Long.parseLong(key);
|
} catch (Exception e) {
|
}
|
|
List<GiveVIPApplyInfo> list = giveVIPApplyInfoService.listByStateAndTargetUid(targetUid, state, pageIndex,
|
pageSize);
|
|
if (list == null || list.size() == 0) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));
|
return;
|
}
|
|
for (GiveVIPApplyInfo info : list) {
|
// 组织用户信息
|
UserInfo userInfo = userInfoService.selectByPKey(info.getTargetUid());
|
UserInfo simpleInfo = new UserInfo(userInfo.getId());
|
simpleInfo.setNickName(userInfo.getNickName());
|
simpleInfo.setPortrait(userInfo.getPortrait());
|
info.setTargetUser(simpleInfo);
|
// 组织其他平台信息
|
if (info.getHasDoOtherPlatform() != null && info.getHasDoOtherPlatform()) {
|
String st = "平台：" + (StringUtil.isNullOrEmpty(info.getOtherPlatformName()) ? "未知"
|
: info.getOtherPlatformName());
|
st += "\n粉丝数：";
|
st += "直接粉丝数(" + (info.getOtherDirectTeams() == null ? "未知" : info.getOtherDirectTeams());
|
|
st += ") 间接粉丝数(" + (info.getOtherInDirectTeams() == null ? "未知" : info.getOtherInDirectTeams())
|
+ ")";
|
|
st += "\n平台等级：" + (StringUtil.isNullOrEmpty(info.getOtherLevel()) ? "未知" : info.getOtherLevel());
|
|
st += "\n月均收入：" + (StringUtil.isNullOrEmpty(info.getOtherMonthIncome()) ? "未知"
|
: info.getOtherMonthIncome());
|
|
info.setOtherPlatformInfo(st);
|
} else {
|
info.setOtherPlatformInfo("暂无");
|
}
|
|
}
|
|
long count = giveVIPApplyInfoService.countByStateAndTargetUid(targetUid, state);
|
int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
|
PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
|
|
GsonBuilder gsonBuilder = new GsonBuilder().registerTypeAdapter(UserLevelEnum.class,
|
new JsonSerializer<UserLevelEnum>() {
|
|
public JsonElement serialize(UserLevelEnum arg0, Type arg1, JsonSerializationContext arg2) {
|
return new JsonPrimitive(arg0.getName());
|
}
|
});
|
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) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 超级会员升级通过
|
* @param callback
|
* @param id
|
* @param out
|
* @param request
|
* @throws UserVIPPreInfoException
|
*/
|
@RequestSerializableByKey(key = "'passApplyVIP-' +#id")
|
@RequestMapping(value = "passVIP")
|
public void passVIP(String callback, String id, PrintWriter out, HttpServletRequest request) {
|
try {
|
/* 检验是否登陆 */
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
if (admin == null) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆。"));
|
return;
|
}
|
giveVIPApplyInfoService.pass(id, admin.getId());
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));
|
LogHelper.userInfo(
|
"[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "通过了[id=" + id + "]的升级会员申请!");
|
} catch (GiveVIPApplyInfoException e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
|
return;
|
} catch (UserVIPPreInfoException e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
|
}
|
}
|
|
/**
|
* 超级会员升级拒绝
|
* @param callback
|
* @param id
|
* @param reason
|
* @param out
|
* @param request
|
*/
|
|
@RequestMapping(value = "rejectVIP")
|
public void rejectVIP(String callback, String id, String reason, PrintWriter out, HttpServletRequest request) {
|
try {
|
/* 检验是否登陆 */
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
if (admin == null) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆"));
|
return;
|
}
|
|
giveVIPApplyInfoService.reject(id, admin.getId(), reason);
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("拒绝成功"));
|
LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 拒绝提现id=" + id
|
+ "的升级超级会员申请不存在!");
|
} catch (GiveVIPApplyInfoException e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
|
return;
|
} catch (Exception e) {
|
e.printStackTrace();
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作失败"));
|
return;
|
}
|
}
|
|
@RequestMapping(value = "apply")
|
public void apply(String callback, Long uid, String level, String applyReason, PrintWriter out,
|
HttpServletRequest request) {
|
try {
|
/* 检验是否登陆 */
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
if (admin == null) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆"));
|
return;
|
}
|
|
UserInfo user = userInfoService.selectAvailableByPrimaryKey(uid);
|
if (user == null) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户不存在或已经被封禁"));
|
return;
|
}
|
|
GiveVIPApplyInfo info = new GiveVIPApplyInfo();
|
info.setApplyReason(applyReason);
|
info.setTargetUid(uid);
|
info.setSourceUid(uid);
|
info.setMark(String.format("管理员(%s)代为申请", admin.getName()));
|
info.setLevel(UserLevelEnum.valueOf(level));
|
giveVIPApplyInfoService.addGiveVIPApplyInfo(info);
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("成功"));
|
} catch (GiveVIPApplyInfoException e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
|
return;
|
} catch (Exception e) {
|
e.printStackTrace();
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作失败"));
|
return;
|
}
|
}
|
|
}
|
