package com.yeshi.fanli.controller.client;
|
|
import java.io.PrintWriter;
|
import java.lang.reflect.InvocationTargetException;
|
import java.lang.reflect.Type;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.apache.commons.beanutils.PropertyUtils;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.yeshi.utils.BigDecimalUtil;
|
import org.yeshi.utils.HttpUtil;
|
import org.yeshi.utils.IPUtil;
|
import org.yeshi.utils.JsonUtil;
|
import org.yeshi.utils.NumberUtil;
|
import org.yeshi.utils.tencentcloud.COSManager;
|
|
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.accept.AcceptData;
|
import com.yeshi.fanli.entity.bus.user.AccountDetails;
|
import com.yeshi.fanli.entity.bus.user.AccountMessage;
|
import com.yeshi.fanli.entity.bus.user.BindingAccount;
|
import com.yeshi.fanli.entity.bus.user.CollectionGoods;
|
import com.yeshi.fanli.entity.bus.user.Extract;
|
import com.yeshi.fanli.entity.bus.user.ExtractRecord;
|
import com.yeshi.fanli.entity.bus.user.HongBao;
|
import com.yeshi.fanli.entity.bus.user.HongBaoExtra;
|
import com.yeshi.fanli.entity.bus.user.HongBaoMessage;
|
import com.yeshi.fanli.entity.bus.user.LostOrder;
|
import com.yeshi.fanli.entity.bus.user.MoneyRecord;
|
import com.yeshi.fanli.entity.bus.user.OrderItem;
|
import com.yeshi.fanli.entity.bus.user.PassWordErrorRecord;
|
import com.yeshi.fanli.entity.bus.user.SMSHistory;
|
import com.yeshi.fanli.entity.bus.user.UserActiveLog;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.bus.user.WeiXinUser;
|
import com.yeshi.fanli.entity.system.System;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;
|
import com.yeshi.fanli.exception.BindingAccountException;
|
import com.yeshi.fanli.exception.ObjectStateException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.config.SystemService;
|
import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;
|
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;
|
import com.yeshi.fanli.service.inter.hongbao.HongBaoService;
|
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.order.LostOrderService;
|
import com.yeshi.fanli.service.inter.order.OrderItemServcie;
|
import com.yeshi.fanli.service.inter.order.OrderService;
|
import com.yeshi.fanli.service.inter.user.AccountDetailsService;
|
import com.yeshi.fanli.service.inter.user.AccountMessageService;
|
import com.yeshi.fanli.service.inter.user.BindingAccountService;
|
import com.yeshi.fanli.service.inter.user.ExtractRecordService;
|
import com.yeshi.fanli.service.inter.user.ExtractService;
|
import com.yeshi.fanli.service.inter.user.MoneyRecordService;
|
import com.yeshi.fanli.service.inter.user.PassWordErrorRecordService;
|
import com.yeshi.fanli.service.inter.user.ShamUserService;
|
import com.yeshi.fanli.service.inter.user.UserAccountService;
|
import com.yeshi.fanli.service.inter.user.UserActiveLogService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.WxDownService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.GsonUtil;
|
import com.yeshi.fanli.util.HongBaoUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.ThreadUtil;
|
import com.yeshi.fanli.util.TimeUtil;
|
import com.yeshi.fanli.util.Utils;
|
import com.yeshi.fanli.util.account.UserUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.util.wx.WXLoginUtil;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
|
@Controller
|
@RequestMapping("api/v1/customer")
|
public class UserInfoController {
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private OrderService orderService;
|
|
@Resource
|
private HongBaoService hongBaoService;
|
|
@Resource
|
private MoneyRecordService moneyRecordService;
|
|
@Resource
|
private BindingAccountService bindingAccountService;
|
|
@Resource
|
private ExtractService extractService;
|
|
@Resource
|
private PassWordErrorRecordService passWordErrorRecordService;
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private SystemService systemService;
|
|
@Resource
|
private HongBaoMessageService hongBaoMessageService;
|
|
@Resource
|
private ShamUserService shamUserService;
|
|
@Resource
|
private ThreeSaleSerivce threeSaleSerivce;
|
|
@Resource
|
private LostOrderService lostOrderService;
|
|
@Resource
|
private OrderItemServcie orderItemServcie;
|
|
@Resource
|
private AccountDetailsService accountDetailsService;
|
|
@Resource
|
private AccountMessageService accountMessageService;
|
|
@Resource
|
private CollectionGoodsService collectionGoodsService;
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private WxDownService wxDownService;
|
|
@Resource
|
private UserAccountService loginService;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private ExtractRecordService extractRecordService;
|
|
@Resource
|
private UserActiveLogService userActiveLogService;
|
|
private static final String PASSWORD_MAX_ERROR = "password_max_error";
|
private static final String EXTRACT_MIN_MONEY = "extract_min_money";
|
private static final String EXTRACT_MAX_MONEY = "extract_max_money";
|
|
/**
|
* 获取用户信息
|
*
|
* @param acceptData
|
* @param form
|
* @param requst
|
* @param out
|
*/
|
@RequestMapping(value = "getuserinfo", method = RequestMethod.POST)
|
public void getUserInfo(AcceptData acceptData, UserInfo form, String code, String create, boolean first,
|
HttpServletRequest requst, PrintWriter out) {
|
String remotIP = IPUtil.getRemotIP(requst);
|
long id = form.getId();
|
// 判断是不是用ID登陆的，如果是用ID登陆的其他都不要管了
|
if (id != 0) {
|
UserInfo find = userInfoService.getUserByIdWithMybatis(id);
|
// ThreadUtil.run(new Runnable() {
|
// @Override
|
// public void run() {
|
// threeSaleSerivce.effective(find);
|
// }
|
// });
|
if (find != null) {
|
// 邀请关系生效
|
threeSaleSerivce.effective(find);
|
// 重新计算用户等级
|
threeSaleSerivce.reComputeUserRank(id);
|
|
// 添加用户活跃记录
|
UserActiveLog userActiveLog = new UserActiveLog();
|
userActiveLog.setChannel(acceptData.getChannel());
|
userActiveLog.setIp(requst.getRemoteHost());
|
userActiveLog.setUid(find.getId());
|
userActiveLog.setVersionCode(acceptData.getVersion());
|
userActiveLog.setOsVersion(acceptData.getOsVersion());
|
userActiveLog.setDeviceType(acceptData.getDeviceType());
|
userActiveLogService.addUserActiveLog(userActiveLog);
|
|
outUserInfo(acceptData, out, remotIP, find, acceptData.getDevice());
|
return;
|
} else {
|
out.print(JsonUtil.loadFalseResult("不存在该账户！"));
|
return;
|
}
|
}
|
// 不是用ID的登陆的事就多了
|
System system = systemService.getSystemCache(acceptData.getPlatform(), acceptData.getPackages());
|
if (system == null) {
|
out.print(JsonUtil.loadFalseResult("系统不存在"));
|
return;
|
}
|
String appid = system.getAppid();
|
|
// 判断是否是第一次正常登陆
|
/*
|
* String platform = acceptData.getPlatform(); if(platform == "ios") {
|
* // 1: 安卓 2：ios if(firstIos == "1") { //第一次登陆 first = true; } else {
|
* first = false; } }
|
*/
|
if (first) {
|
int loginType = form.getLoginType();
|
// WeiXinUserParam wxParam = null;
|
// 如果是微信登陆，那需要先获取到微信的unionid
|
WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);
|
if (loginType == Constant.WEIXIN && StringUtil.isNullOrEmpty(form.getWxUnionId())) {
|
// wxParam = WXinUtil.getWxParam(code);
|
if (weiXinUser == null) {
|
out.print(JsonUtil.loadFalseResult("登录失败"));
|
return;
|
}
|
form.setWxOpenId(weiXinUser.getOpenid());
|
form.setWxUnionId(weiXinUser.getUnionid());
|
}
|
String openid = loginType == 1 ? form.getOpenid() : form.getWxUnionId();
|
LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(requst) + "]" + (loginType == 1 ? "淘宝登陆" : "微信登陆")
|
+ "[openid:" + openid + "]");
|
if (openid == null || openid.equals("")) {
|
out.print(JsonUtil.loadFalseResult("登录失败"));
|
return;
|
}
|
// 获取用户信息
|
UserInfo user = userInfoService.getUserByLoginTypeAndOpenId(loginType, openid, appid);
|
// 判断获取的用户信息是否为空，如果不为空就做的事就又多了
|
if (user != null) {// 数据库中已经存在该用户
|
outUserInfo(acceptData, out, remotIP, user, acceptData.getDevice());
|
UserInfo temp = user;
|
long lastLoginTime = temp.getLastLoginTime() == null ? 0 : temp.getLastLoginTime().longValue();
|
if (lastLoginTime == 0) {// 等于0则是第一次登陆，那么需要判断用户是不是被传销来的,如果是的话，那需要修改相关三级分销的状态
|
ThreadUtil.run(new Runnable() {
|
@Override
|
public void run() {
|
threeSaleSerivce.effective(temp);
|
}
|
|
});
|
}
|
return;
|
}
|
// 查询到的用户信息为空,那么需要填充一些用户信息
|
if (loginType == Constant.WEIXIN) {
|
form.setPortrait(weiXinUser.getHeadimgurl());
|
String wxHeadImg = COSManager.getInstance()
|
.uploadFile(HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()),
|
Constant.WXHEADURL + UUID.randomUUID().toString())
|
.getUrl();
|
form.setWxPic(wxHeadImg);
|
form.setNickName(weiXinUser.getNickname());
|
form.setWxName(weiXinUser.getNickname());
|
} else if (loginType == Constant.TAOBAO) {
|
form.setTbName(form.getNickName());
|
form.setTbPic(form.getPortrait());
|
}
|
form.setLastLoginIp(remotIP);
|
form.setLastLoginTime(java.lang.System.currentTimeMillis());
|
form.setSystem(system);
|
requst.getSession().setAttribute("newUser", form);
|
out.append(JsonUtil.loadTrueResult(2, form));
|
return;
|
}
|
|
if (create == null || "0".equals(create)) {
|
out.append(JsonUtil.loadFalseResult("参数create不能为空!"));
|
return;
|
}
|
|
UserInfo newUser = (UserInfo) requst.getSession().getAttribute("newUser");
|
UserInfo mainUser = (UserInfo) requst.getSession().getAttribute("mainUser");
|
if (Constant.NEWUSER.equals(create)) { // 创建
|
UserInfo user;
|
synchronized (UserInfo.class) {
|
user = userInfoService.addUser(newUser, appid);
|
}
|
if (user != null) {
|
|
JSONObject data = new JSONObject();
|
data.put("user", GsonUtil.toJsonExpose(user));
|
data.put("first", 1);
|
out.print(JsonUtil.loadTrueResult(data));
|
LogHelper.userInfo(GsonUtil.toJsonExpose(user));
|
} else {
|
LogHelper.userInfo("不存在用户:" + GsonUtil.toJsonExpose(form));
|
out.print(JsonUtil.loadFalseResult("登录失败"));
|
}
|
requst.getSession().removeAttribute("newUser");
|
return;
|
} else if (Constant.BINDUSER.equals(create) && mainUser == null) { // 绑定
|
int formLoginType = form.getLoginType();
|
int newUserLoginType = newUser.getLoginType();
|
if (newUserLoginType == formLoginType) { // 相同类型不能绑定
|
out.print(JsonUtil.loadFalseResult("相同类型的账号不能绑定！"));
|
return;
|
}
|
// 判断是不是微信。如果是微信就要填充微信相关信息
|
if (formLoginType == Constant.WEIXIN/*
|
* &&
|
* StringUtil.isNullOrEmpty(form
|
* .getWxOpenId())
|
*/) {
|
WeiXinUser xinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);
|
if (xinUser == null) {
|
out.print(JsonUtil.loadFalseResult("登录失败"));
|
return;
|
}
|
form.setWxOpenId(xinUser.getOpenid());
|
form.setWxUnionId(xinUser.getUnionid());
|
form.setPortrait(xinUser.getHeadimgurl());
|
form.setNickName(xinUser.getNickname());
|
form.setWxName(xinUser.getNickname());
|
String wxHeadImg = COSManager.getInstance()
|
.uploadFile(HttpUtil.getAsInputStream(xinUser.getHeadimgurl()),
|
Constant.WXHEADURL + UUID.randomUUID().toString())
|
.getUrl();
|
form.setWxPic(wxHeadImg);
|
} else if (formLoginType == Constant.TAOBAO) {
|
form.setTbName(form.getNickName());
|
form.setTbPic(form.getPortrait());
|
}
|
form.setSystem(system);
|
requst.getSession().setAttribute("mainUser", form);
|
String openid = formLoginType == 1 ? form.getOpenid() : form.getWxUnionId();
|
// 获取主账户用户信息
|
UserInfo find = userInfoService.getUserByLoginTypeAndOpenId(formLoginType, openid, appid);
|
if (find != null) {
|
// 主账户不为空就进行绑定操作
|
bind(find, newUser);
|
userInfoService.update(find);
|
outUserInfo(acceptData, out, remotIP, find, acceptData.getDevice());
|
requst.getSession().removeAttribute("newUser");
|
requst.getSession().removeAttribute("mainUser");
|
} else {
|
// 为空的话就返回用户信息
|
out.print(JsonUtil.loadTrueResult(3, form));
|
return;
|
}
|
} else {// create=2 ，mainUser != null 创建并绑定！
|
bind(mainUser, newUser);
|
mainUser = userInfoService.addUser(mainUser, appid);
|
outUserInfo(acceptData, out, remotIP, mainUser, acceptData.getDevice());
|
requst.getSession().removeAttribute("newUser");
|
requst.getSession().removeAttribute("mainUser");
|
}
|
}
|
|
/**
|
* 淘特价登录
|
*
|
* @param acceptData
|
* @param form
|
* @param code
|
* @param create
|
* @param first
|
* @param requst
|
* @param out
|
*/
|
|
@RequestMapping(value = "getuserinfo_ttj", method = RequestMethod.POST)
|
public void getUserInfoTTJ(AcceptData acceptData, UserInfo form, String code, String create, boolean first,
|
HttpServletRequest requst, PrintWriter out) {
|
String remotIP = IPUtil.getRemotIP(requst);
|
long id = form.getId();
|
// 判断是不是用ID登陆的，如果是用ID登陆的其他都不要管了
|
if (id != 0) {
|
UserInfo find = userInfoService.getUserById(id);
|
if (find != null) {
|
outUserInfo(acceptData, out, remotIP, find, acceptData.getDevice());
|
return;
|
} else {
|
out.print(JsonUtil.loadFalseResult("不存在该账户！"));
|
return;
|
}
|
}
|
// 不是用ID的登陆的事就多了
|
System system = systemService.getSystemCache(acceptData.getPlatform(), acceptData.getPackages());
|
if (system == null) {
|
out.print(JsonUtil.loadFalseResult("系统不存在"));
|
return;
|
}
|
form.setSystem(system);
|
String appid = system.getAppid();
|
UserInfo user = userInfoService.getUserByLoginTypeAndOpenId(1, form.getOpenid(), appid);
|
if (user == null) {
|
// 创建用户
|
userInfoService.addUser(form, appid);
|
user = userInfoService.getUserByLoginTypeAndOpenId(1, form.getOpenid(), appid);
|
}
|
|
// 返回用户信息
|
outUserInfo(acceptData, out, remotIP, user, acceptData.getDevice());
|
}
|
|
/**
|
* 将副账户绑定到主账户上
|
*
|
* @param mainUser
|
* @param viceUser
|
*/
|
private void bind(UserInfo mainUser, UserInfo viceUser) {
|
int loginType = viceUser.getLoginType();
|
if (loginType == Constant.TAOBAO) {
|
mainUser.setOpenid(viceUser.getOpenid());
|
mainUser.setTbName(viceUser.getNickName());
|
mainUser.setTbPic(viceUser.getTbPic());
|
} else if (loginType == Constant.WEIXIN) {
|
mainUser.setWxName(viceUser.getWxName());
|
mainUser.setWxOpenId(viceUser.getWxOpenId());
|
mainUser.setWxUnionId(viceUser.getWxUnionId());
|
mainUser.setWxPic(viceUser.getWxPic());
|
}
|
}
|
|
private void outUserInfo(AcceptData acceptData, PrintWriter out, String remotIP, UserInfo user, String device) {
|
BigDecimal MyTotalMoney = hongBaoService.getMyTotalHongBaoByUid(user.getId());
|
user.setTotalHongBao(MyTotalMoney);
|
BigDecimal unOpenmoney = hongBaoService.getUnOpenHongBaoByUid(user.getId());
|
BigDecimal canOpenMoney = hongBaoService.getCanOpenHongBaoByUid(user.getId());
|
user.setNoOpenHongBao(unOpenmoney);
|
user.setCanOpenHongBao(canOpenMoney);
|
|
/**
|
* 查询改用户返利红包
|
*/
|
BigDecimal fanliHB = user.getTotalHongBao();
|
user.setTotalHongBao(fanliHB);
|
|
GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();
|
|
JSONObject data = new JSONObject();
|
data.put("user", JsonUtil.getConvertBigDecimalToStringBuilder(gsonBuilder).create()
|
.toJson(UserUtil.filterForClientUser(user)));
|
data.put("first", 0);
|
if ("ios".equalsIgnoreCase(acceptData.getPlatform())
|
&& configService.iosOnLining(Integer.parseInt(acceptData.getVersion())))
|
data.put("inviteList", String.format("http://%s/%s/client/share/friends_new_online.html",
|
Constant.systemCommonConfig.getProjectHost(), Constant.systemCommonConfig.getProjectName()));
|
else
|
data.put("inviteList", configService.get("team_list"));
|
out.print(JsonUtil.loadTrueResult(data));
|
final UserInfo uuser = user;
|
ThreadUtil.run(new Runnable() {
|
public void run() {
|
LogHelper.userInfo(GsonUtil.toJsonExpose(uuser));
|
uuser.setLastLoginIp(remotIP);
|
uuser.setLastLoginTime(java.lang.System.currentTimeMillis());
|
userInfoService.updateLoginInfo(uuser);
|
wxDownService.save(device);
|
}
|
});
|
}
|
|
@RequestMapping("bindUserInfo")
|
public void bindUserInfo(AcceptData acceptData, UserInfo form, String code, PrintWriter out) {
|
UserInfo find = userInfoService.getUserById(form.getId());
|
if (find == null) {
|
out.print(JsonUtil.loadFalseResult("绑定失败，不存在该用户！"));
|
return;
|
}
|
int loginType = form.getLoginType();
|
if (loginType == Constant.WEIXIN) {
|
WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);
|
|
if (weiXinUser == null) {
|
out.print(JsonUtil.loadFalseResult("绑定失败，用户异常请重试！"));
|
return;
|
}
|
|
LogHelper.test(
|
String.format("绑定微信:头像为 %s \n 昵称为 %s", weiXinUser.getHeadimgurl(), weiXinUser.getNickname()));
|
|
String wxUnionId = weiXinUser.getUnionid();
|
UserInfo userInfo = userInfoService.getUserByLoginTypeAndOpenId(loginType, wxUnionId, Constant.APPID);
|
if (userInfo != null) {
|
out.print(JsonUtil.loadFalseResult("绑定失败，该微信账户已存在!"));
|
return;
|
}
|
find.setWxName(weiXinUser.getNickname());
|
find.setWxOpenId(weiXinUser.getOpenid());
|
find.setWxUnionId(weiXinUser.getUnionid());
|
String wxHeadImg = COSManager.getInstance()
|
.uploadFile(HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()),
|
Constant.WXHEADURL + UUID.randomUUID().toString())
|
.getUrl();
|
find.setWxPic(wxHeadImg);
|
} else { // 绑定淘宝
|
LogHelper.test(String.format("绑定淘宝:头像为 %s \n 昵称为 %s", form.getPortrait(), form.getTbName()));
|
UserInfo userInfo = userInfoService.getUserByLoginTypeAndOpenId(loginType, form.getOpenid(),
|
Constant.APPID);
|
if (userInfo != null) {
|
out.print(JsonUtil.loadFalseResult("绑定失败，该淘宝账户已存在!"));
|
return;
|
}
|
find.setOpenid(form.getOpenid());
|
find.setTbName(form.getTbName());
|
find.setTbPic(form.getPortrait());
|
}
|
userInfoService.update(find);
|
out.print(JsonUtil.loadTrueResult(GsonUtil.toJsonExpose(UserUtil.filterForClientUser(find))));
|
}
|
|
/**
|
*
|
* @param data
|
* @param uid
|
* 用户ID
|
* @param type
|
* 需要解绑的账户类型
|
*/
|
@RequestMapping("unBindUserInfo")
|
public void unBindUserInfo(AcceptData data, long uid, int type, PrintWriter out) {
|
UserInfo find = userInfoService.getUserById(uid);
|
if (find == null) {
|
out.print(JsonUtil.loadFalseResult("不存在该用户！"));
|
return;
|
}
|
String openid = find.getOpenid();
|
String wxUnionId = find.getWxUnionId();
|
if (Constant.TAOBAO == type) {
|
if (StringUtil.isNullOrEmpty(openid)) {
|
out.print(JsonUtil.loadFalseResult("当前用户未绑定该类型账户！"));
|
return;
|
}
|
} else if (Constant.WEIXIN == type) {
|
if (StringUtil.isNullOrEmpty(wxUnionId)) {
|
out.print(JsonUtil.loadFalseResult("当前用户未绑定该类型账户！"));
|
return;
|
}
|
}
|
int count = 0;
|
if (StringUtil.isNullOrEmpty(openid)) {
|
count++;
|
}
|
if (StringUtil.isNullOrEmpty(wxUnionId)) {
|
count++;
|
}
|
if (count == 1) {
|
out.print(JsonUtil.loadFalseResult("当前只绑定了一个账户，不能解绑！"));
|
return;
|
}
|
userInfoService.unBindUserInfo(find, type);
|
out.print(JsonUtil.loadTrueResult("解绑成功"));
|
}
|
|
/**
|
* 获取提现记录
|
*
|
* @param acceptData
|
* @param uid
|
* 用户id
|
* @param page
|
* 页数（从0开始）
|
* @param out
|
*/
|
@RequestMapping(value = "getmoneyrecord", method = RequestMethod.POST)
|
public void getMoneyRecord(AcceptData acceptData, long uid, int page, PrintWriter out) {
|
UserInfo user = userInfoService.getUserById(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
if (page < 0) {
|
page = 0;
|
}
|
|
List<MoneyRecord> moneyRecordList = moneyRecordService.getMoneyRecord(uid, page);
|
int count = moneyRecordService.getCount(uid);
|
JSONObject data = new JSONObject();
|
if (moneyRecordList == null || moneyRecordList.size() == 0) {
|
data.put("count", 0);
|
data.put("moneyRecordList", new ArrayList());
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
}
|
data.put("count", count);
|
Gson gson = new GsonBuilder().excludeFieldsWithoutExposeAnnotation().create();
|
data.put("moneyRecordList", gson.toJson(moneyRecordList));
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
/**
|
* 获取当前用户红包
|
*
|
* @param acceptData
|
* @param uid
|
* 用户id
|
* @param out
|
* @throws ObjectStateException
|
*/
|
@RequestMapping(value = "gethongbao", method = RequestMethod.POST)
|
public void getHongBao(AcceptData acceptData, long uid, PrintWriter out) {
|
UserInfo user = userInfoService.getUserById(uid);
|
JSONObject data = new JSONObject();
|
if (user == null) {
|
data.put("count", 0);
|
data.put("hongBaoList", new ArrayList());
|
data.put("error", "用户不存在");
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
}
|
List<HongBaoExtra> hongBaoList = hongBaoService.getHongBao(uid);
|
|
if (hongBaoList.size() == 0) {
|
data.put("count", 0);
|
data.put("hongBaoList", hongBaoList);
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
}
|
data.put("count", hongBaoList.size());
|
data.put("hongBaoList", GsonUtil.toJsonExpose(hongBaoList));
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
}
|
|
/**
|
* 设置提现密码
|
*
|
* @param acceptData
|
* @param payPassword
|
* 提现密码（要经过md5加密）
|
* @param uid
|
* 用户id
|
* @param out
|
*/
|
@RequestMapping(value = "setpaypassword", method = RequestMethod.POST)
|
public void setPayPassword(AcceptData acceptData, String payPassword, long uid, PrintWriter out) {
|
UserInfo user = userInfoService.getUserById(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
user.setPayPassword(payPassword);
|
userInfoService.update(user);
|
out.print(JsonUtil.loadTrueResult("设置成功"));
|
}
|
|
/**
|
* 获取用户提现账号
|
*
|
* @param acceptData
|
* @param uid
|
* @param out
|
*/
|
@RequestMapping(value = "getuseraccount", method = RequestMethod.POST)
|
public void getUserAccount(AcceptData acceptData, Long uid, PrintWriter out) {
|
|
if (uid == null) {
|
out.print(JsonUtil.loadFalseResult(1, "请登录"));
|
return;
|
}
|
|
UserInfo user = userInfoService.getUserByIdWithMybatis(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
|
List<BindingAccount> bindingAccountList = bindingAccountService.getBindingAccountByUid(uid);
|
JSONObject data = new JSONObject();
|
data.put("user", user);
|
Gson gson = new GsonBuilder().excludeFieldsWithoutExposeAnnotation().create();
|
String maxError = "5";
|
maxError = configService.get(PASSWORD_MAX_ERROR); // 当日输错密码最多次数
|
PassWordErrorRecord record = passWordErrorRecordService.getRecord(uid);
|
int max = Integer.parseInt(maxError);
|
if (record.getCount() >= max) {
|
data.put("error", "1"); // 达到最多限制
|
} else {
|
data.put("error", "0");
|
}
|
data.put("maxError", maxError);
|
String minMoney = configService.get(EXTRACT_MIN_MONEY); // 单笔提现的最小金额
|
String maxMoney = configService.get(EXTRACT_MAX_MONEY); // 单笔提现的最大金额
|
int maxDayCount = Integer.parseInt(configService.get("extract_count_day"));
|
ExtractRecord extractRecord = extractRecordService.getExtractRecordByUid(uid);
|
boolean canExtract = true;
|
String errorMsg = "";
|
if (extractRecord != null && extractRecord.getCount() >= maxDayCount) {
|
canExtract = false;
|
errorMsg = String.format("每日最多提现%s次", maxDayCount + "");
|
} else if (extractRecord != null
|
&& extractRecord.getMoney().add(new BigDecimal(minMoney)).compareTo(new BigDecimal(maxMoney)) > 0) {
|
canExtract = false;
|
errorMsg = String.format("每日最多提现%s元", maxMoney);
|
}
|
data.put("canExtract", canExtract);
|
data.put("extractErrorMsg", errorMsg);
|
|
data.put("minMoney", minMoney);
|
data.put("maxMoney", maxMoney);
|
data.put("bindingAccountList", gson.toJson(filterBindingAccount(bindingAccountList)));
|
|
JSONObject alipayVerify = new JSONObject();
|
try {
|
bindingAccountService.canVerifyAlipayAccount(uid);
|
alipayVerify.put("state", 0);
|
alipayVerify.put("msg", "可绑定");
|
} catch (BindingAccountException e) {
|
alipayVerify.put("state", e.getCode());
|
alipayVerify.put("msg", e.getMsg());
|
}
|
|
data.put("alipayBindState", alipayVerify);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
/**
|
* 是否能够提现
|
*
|
* @param acceptData
|
* @param uid
|
* @param out
|
*/
|
@RequestMapping(value = "canextract", method = RequestMethod.POST)
|
public void canExtract(AcceptData acceptData, Long uid, BigDecimal money, PrintWriter out) {
|
|
if (uid == null) {
|
out.print(JsonUtil.loadFalseResult(1, "请登录"));
|
return;
|
}
|
|
if (money == null) {
|
out.print(JsonUtil.loadFalseResult(1, "请上传金额"));
|
return;
|
}
|
|
UserInfo user = userInfoService.getUserByIdWithMybatis(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
|
String minMoney = configService.get(EXTRACT_MIN_MONEY); // 单笔提现的最小金额
|
String maxMoney = configService.get(EXTRACT_MAX_MONEY); // 单笔提现的最大金额
|
int maxDayCount = Integer.parseInt(configService.get("extract_count_day"));
|
ExtractRecord extractRecord = extractRecordService.getExtractRecordByUid(uid);
|
boolean canExtract = true;
|
String errorMsg = "";
|
if (extractRecord != null && extractRecord.getCount() + 1 >= maxDayCount) {
|
canExtract = false;
|
errorMsg = String.format("每日最多提现%s次", maxDayCount + "");
|
} else if (extractRecord != null
|
&& extractRecord.getMoney().add(money).compareTo(new BigDecimal(maxMoney)) > 0) {
|
canExtract = false;
|
errorMsg = String.format("每日最多提现%s元", maxMoney);
|
} else if (new BigDecimal(minMoney).compareTo(money) > 0) {
|
canExtract = false;
|
errorMsg = String.format("每次最低提现%s元", minMoney);
|
}
|
|
if (canExtract) {
|
out.print(JsonUtil.loadTrueResult(""));
|
} else {
|
out.print(JsonUtil.loadFalseResult(errorMsg));
|
}
|
}
|
|
@RequestMapping(value = "getalipayaccount", method = RequestMethod.POST)
|
public void getAlipayAccount(AcceptData acceptData, Long uid, PrintWriter out) {
|
|
if (uid == null) {
|
out.print(JsonUtil.loadFalseResult(1, "请登录"));
|
return;
|
}
|
|
List<BindingAccount> bindingAccountList = bindingAccountService.getBindingAccountByUid(uid);
|
|
if (bindingAccountList == null || bindingAccountList.size() == 0) {
|
out.print(JsonUtil.loadFalseResult(2, "尚未绑定支付宝"));
|
return;
|
}
|
|
out.print(JsonUtil.loadTrueResult(JsonUtil.getSimpleGsonWithDate().toJson(bindingAccountList.get(0))));
|
}
|
|
public static List<BindingAccount> filterBindingAccount(List<BindingAccount> bindingAccountList) {
|
List<BindingAccount> accountList = new ArrayList<>();
|
|
if (bindingAccountList != null)
|
for (BindingAccount bindingAccount : bindingAccountList) {
|
BindingAccount dest = new BindingAccount();
|
try {
|
PropertyUtils.copyProperties(dest, bindingAccount);
|
if (!StringUtil.isNullOrEmpty(dest.getAccount()) && !StringUtil.isNullOrEmpty(dest.getName())) {
|
String name = "";
|
if ((dest.getName() + "").length() > 2)
|
for (int i = 0; i < (dest.getName() + "").length(); i++) {
|
if (i == 0)
|
name += dest.getName().charAt(i);
|
else
|
name += "*";
|
}
|
else
|
name = dest.getName().charAt(0) + "*";
|
dest.setName(name);
|
|
String account = "";
|
if (dest.getAccount().indexOf("@") > -1) {// 邮箱
|
int index = dest.getAccount().indexOf("@");
|
|
for (int i = 0; i < dest.getAccount().length(); i++) {
|
if (i < 3 || i >= index)
|
account += dest.getAccount().charAt(i);
|
else
|
account += "*";
|
}
|
} else if (StringUtil.isMobile(dest.getAccount())) {// 电话
|
account = dest.getAccount().substring(0, 3) + "*****" + dest.getAccount()
|
.substring(dest.getAccount().length() - 2, dest.getAccount().length());
|
|
} else {// 其他
|
if (dest.getAccount().length() >= 6) {
|
for (int i = 0; i < dest.getAccount().length(); i++) {
|
if (i < 3 || i >= dest.getAccount().length() - 2)
|
account += dest.getAccount().charAt(i);
|
else
|
account += "*";
|
}
|
} else {
|
for (int i = 0; i < dest.getAccount().length(); i++) {
|
if (i < 1 || i >= dest.getAccount().length() - 1)
|
account += dest.getAccount().charAt(i);
|
else
|
account += "*";
|
}
|
}
|
}
|
|
dest.setAccount(account);
|
|
}
|
accountList.add(dest);
|
} catch (IllegalAccessException e) {
|
e.printStackTrace();
|
} catch (InvocationTargetException e) {
|
e.printStackTrace();
|
} catch (NoSuchMethodException e) {
|
e.printStackTrace();
|
}
|
}
|
|
return accountList;
|
}
|
|
public static BindingAccount filterBindingAccount(BindingAccount bindingAccount) {
|
BindingAccount dest = new BindingAccount();
|
try {
|
PropertyUtils.copyProperties(dest, bindingAccount);
|
if (!StringUtil.isNullOrEmpty(dest.getAccount()) && !StringUtil.isNullOrEmpty(dest.getName())) {
|
String name = "";
|
if ((dest.getName() + "").length() > 2)
|
for (int i = 0; i < (dest.getName() + "").length(); i++) {
|
if (i == 0)
|
name += dest.getName().charAt(i);
|
else
|
name += "*";
|
}
|
else
|
name = dest.getName().charAt(0) + "*";
|
dest.setName(name);
|
|
String account = "";
|
if (dest.getAccount().indexOf("@") > -1) {// 邮箱
|
int index = dest.getAccount().indexOf("@");
|
|
for (int i = 0; i < dest.getAccount().length(); i++) {
|
if (i < 3 || i >= index)
|
account += dest.getAccount().charAt(i);
|
else
|
account += "*";
|
}
|
} else if (StringUtil.isMobile(dest.getAccount())) {// 电话
|
account = dest.getAccount().substring(0, 3) + "*****"
|
+ dest.getAccount().substring(dest.getAccount().length() - 2, dest.getAccount().length());
|
|
} else {// 其他
|
if (dest.getAccount().length() >= 6) {
|
for (int i = 0; i < dest.getAccount().length(); i++) {
|
if (i < 3 || i >= dest.getAccount().length() - 2)
|
account += dest.getAccount().charAt(i);
|
else
|
account += "*";
|
}
|
} else {
|
for (int i = 0; i < dest.getAccount().length(); i++) {
|
if (i < 1 || i >= dest.getAccount().length() - 1)
|
account += dest.getAccount().charAt(i);
|
else
|
account += "*";
|
}
|
}
|
}
|
|
dest.setAccount(account);
|
|
}
|
} catch (IllegalAccessException e) {
|
e.printStackTrace();
|
} catch (InvocationTargetException e) {
|
e.printStackTrace();
|
} catch (NoSuchMethodException e) {
|
e.printStackTrace();
|
}
|
|
return dest;
|
|
}
|
|
/**
|
* 客户端提现密码输入错误时调用
|
*
|
* @param acceptData
|
* @param uid
|
* 用户id
|
* @param out
|
*/
|
@RequestMapping(value = "errormax", method = RequestMethod.POST)
|
public void errorMax(AcceptData acceptData, long uid, PrintWriter out) {
|
UserInfo user = userInfoService.getUserById(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
PassWordErrorRecord record = passWordErrorRecordService.getRecord(user.getId());
|
record.setUserInfo(user);
|
String maxErrorStr = "5";
|
maxErrorStr = configService.get(PASSWORD_MAX_ERROR); // 当日输错密码最多次数
|
int maxError = Integer.parseInt(maxErrorStr);
|
int count = passWordErrorRecordService.setRecord(record);
|
JSONObject data = new JSONObject();
|
int c = maxError - count;
|
if (c <= 0) { // 当错误次数还未超过当日输错最多次数时，state为1，代表还能继续输入，little为剩余次数。state为2则不能继续输入，提现客户端退出输入密码界面
|
data.put("state", "2");
|
data.put("little", 0);
|
} else {
|
data.put("state", "1");
|
data.put("little", c);
|
}
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
/**
|
* 添加用户提现账号
|
*
|
* @param acceptData
|
* @param uid
|
* 用户id
|
* @param account
|
* 账号
|
* @param name
|
* 真实名字
|
* @param type
|
* 账号类型：1.支付宝 2.微信
|
* @param out
|
*/
|
@RequestMapping(value = "addbindingaccount", method = RequestMethod.POST)
|
public void addBindingAccount(AcceptData acceptData, long uid, String account, String name, int type,
|
PrintWriter out) {
|
|
if (Constant.ZHIFUBAO != type && Constant.WEIXIN != type) {
|
out.print(JsonUtil.loadFalseResult(Constant.NOTYPE));
|
return;
|
}
|
UserInfo user = userInfoService.getUserById(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
BindingAccount addAccount = new BindingAccount();
|
addAccount.setAccount(account);
|
addAccount.setType(type);
|
addAccount.setUserInfo(user);
|
addAccount.setName(name);
|
try {
|
bindingAccountService.addBindingAccount(addAccount);
|
} catch (BindingAccountException e) {
|
out.print(JsonUtil.loadFalseResult(e.getMessage()));
|
return;
|
}
|
out.print(JsonUtil.loadTrueResult(Constant.BA_SUCCESS));
|
return;
|
}
|
|
/**
|
* 删除用户提现账号
|
*
|
* @param acceptData
|
* @param uid
|
* 用户id
|
* @param type
|
* 账号类型
|
* @param out
|
*/
|
@RequestMapping(value = "deletebindingaccount", method = RequestMethod.POST)
|
public void deleteBindingAccount(AcceptData acceptData, long uid, int type, PrintWriter out) {
|
|
if (type != Constant.ZHIFUBAO && type != Constant.WEIXIN) {
|
out.print(JsonUtil.loadFalseResult(Constant.NOTYPE));
|
return;
|
}
|
|
UserInfo user = userInfoService.getUserById(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
BindingAccount account = new BindingAccount();
|
account.setType(type);
|
account.setUserInfo(user);
|
Integer deletecount = bindingAccountService.deleteBindingAccount(account);
|
JSONObject data = new JSONObject();
|
data.put("count", deletecount);
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
}
|
|
/**
|
* 提现
|
*
|
* @param acceptData
|
* @param uid
|
* 用户id
|
* @param money
|
* 提现金额
|
* @param pwd
|
* 密码
|
* @param request
|
* @param type
|
* 提现账户类型
|
* @param out
|
*/
|
@RequestMapping(value = "extractmoney", method = RequestMethod.POST)
|
public void extractMoney(AcceptData acceptData, long uid, double money, String pwd, HttpServletRequest request,
|
int type, PrintWriter out) {
|
UserInfo user = userInfoService.getUserById(uid);
|
LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]");
|
if (user == null) {
|
LogHelper.userInfo("不存在该用户:uid=" + uid);
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
System system = systemService.getSystemCache(acceptData.getPlatform(), acceptData.getPackages());
|
if (system == null) {
|
LogHelper.userInfo("提现时，不存在该系统");
|
out.print(JsonUtil.loadFalseResult("系统不存在"));
|
return;
|
}
|
PassWordErrorRecord record = passWordErrorRecordService.getRecord(user.getId());
|
int errorcount = record.getCount();
|
String maxStr = "5";
|
maxStr = configService.get(PASSWORD_MAX_ERROR);
|
int max = Integer.parseInt(maxStr);
|
if (max <= errorcount) {
|
LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]用户[" + GsonUtil.toJson(user) + "]:提现密码错误已达上限！");
|
out.print(JsonUtil.loadFalseResult("提现密码已达到每日错误次数上限，请明日再试！"));
|
return;
|
}
|
|
if (pwd == null || !pwd.equals(user.getPayPassword())) {
|
passWordErrorRecordService.setRecord(record);
|
out.print(JsonUtil.loadFalseResult("支付密码错误"));
|
return;
|
}
|
|
passWordErrorRecordService.deleteRecord(uid);// 当提现密码输入正确时，清除当前用户的密码错误输入记录
|
|
String minMoney = configService.get(EXTRACT_MIN_MONEY); // 单笔提现最小金额
|
|
if (money < 0.1) { // 转帐到支付宝的最小金额
|
out.print(JsonUtil.loadFalseResult("单笔提现金额需要大于：" + 0.1 + "元"));
|
return;
|
}
|
|
double dminMoney = Double.parseDouble(minMoney);
|
if (money < dminMoney) { // 后台设置的单笔转账的最小金额
|
out.print(JsonUtil.loadFalseResult("单笔提现金额需要大于：" + dminMoney + "元"));
|
return;
|
}
|
String maxMoney = configService.get(EXTRACT_MAX_MONEY); // 单笔提现最大金额
|
double dmaxMoney = Double.parseDouble(maxMoney);
|
if (dmaxMoney < money) { // 后台设置的单笔转账的最大金额
|
out.print(JsonUtil.loadFalseResult("单笔提现金额多为：" + dmaxMoney + "元"));
|
return;
|
}
|
|
if (type != Constant.ZHIFUBAO && type != Constant.WEIXIN) { // 提现类型必须是支付宝类型或者微信类型，目前（20170506）仅支持支付宝
|
out.print(JsonUtil.loadFalseResult(Constant.NOTYPE));
|
return;
|
}
|
|
BindingAccount bindingAccount = bindingAccountService.getBindingAccountByUidAndType(uid, type);
|
if (bindingAccount == null) {
|
out.print(JsonUtil.loadFalseResult(Constant.NOACCOUNT));
|
return;
|
}
|
|
Extract extract = new Extract();
|
extract.setIp(IPUtil.getRemotIP(request));
|
extract.setAccount(bindingAccount.getAccount());
|
extract.setName(bindingAccount.getName());
|
extract.setMoney(new BigDecimal(String.valueOf(money)));
|
extract.setUserInfo(user);
|
extract.setExtractTime(java.lang.System.currentTimeMillis());
|
extract.setType(type);
|
extract.setState(0);
|
extract.setSystem(system);
|
Integer etype = extractService.addExtract(extract);
|
if (etype == null) {
|
out.print(JsonUtil.loadTrueResult("操作成功"));
|
return;
|
} else if (etype == 1 || etype == 2) {
|
out.print(JsonUtil.loadFalseResult("已超过当日提现次数或提现金额"));
|
} else if (etype == 3) {
|
out.print(JsonUtil.loadFalseResult("提现金额大于我的红包"));
|
}
|
|
}
|
|
/**
|
* 新版提现
|
*
|
* @param acceptData
|
* @param uid
|
* @param money
|
* @param vcode
|
* 手机验证码
|
* @param request
|
* @param type
|
* @param out
|
*/
|
@RequestMapping(value = "extractmoneynew", method = RequestMethod.POST)
|
public void extractMoneyNew(AcceptData acceptData, long uid, BigDecimal money, String vcode,
|
HttpServletRequest request, int type, PrintWriter out) {
|
UserInfo user = userInfoService.getUserById(uid);
|
if (user == null) {
|
out.print(JsonUtil.loadFalseResult("用户不存在"));
|
return;
|
}
|
|
if (money == null) {
|
out.print(JsonUtil.loadFalseResult(1, "请上传提现金额"));
|
return;
|
}
|
|
// 判断手机验证码的正确性
|
String oldCode = redisManager.getSMSVCode(user.getPhone(), SMSHistory.TYPE_LOGIN);
|
if (StringUtil.isNullOrEmpty(oldCode) || !oldCode.equalsIgnoreCase(vcode)) {
|
out.print(JsonUtil.loadFalseResult(90001, "验证码错误"));
|
return;
|
}
|
|
System system = systemService.getSystemCache(acceptData.getPlatform(), acceptData.getPackages());
|
if (system == null) {
|
LogHelper.userInfo("提现时，不存在该系统");
|
out.print(JsonUtil.loadFalseResult("系统不存在"));
|
return;
|
}
|
|
String minMoney = configService.get(EXTRACT_MIN_MONEY); // 单笔提现最小金额
|
|
if (money.compareTo(new BigDecimal("0.1")) < 0) { // 转帐到支付宝的最小金额
|
out.print(JsonUtil.loadFalseResult("单笔提现金额需要大于：" + 0.1 + "元"));
|
return;
|
}
|
|
if (money.compareTo(new BigDecimal(minMoney)) < 0) { // 后台设置的单笔转账的最小金额
|
out.print(JsonUtil.loadFalseResult("单笔提现金额需要大于：" + minMoney + "元"));
|
return;
|
}
|
String maxMoney = configService.get(EXTRACT_MAX_MONEY); // 单笔提现最大金额
|
if (new BigDecimal(maxMoney).compareTo(money) < 0) { // 后台设置的单笔转账的最大金额
|
out.print(JsonUtil.loadFalseResult("单笔提现金额多为：" + maxMoney + "元"));
|
return;
|
}
|
|
if (type != Constant.ZHIFUBAO && type != Constant.WEIXIN) { // 提现类型必须是支付宝类型或者微信类型，目前（20170506）仅支持支付宝
|
out.print(JsonUtil.loadFalseResult(Constant.NOTYPE));
|
return;
|
}
|
|
BindingAccount bindingAccount = bindingAccountService.getBindingAccountByUidAndType(uid, type);
|
if (bindingAccount == null) {
|
out.print(JsonUtil.loadFalseResult(Constant.NOACCOUNT));
|
return;
|
}
|
|
Extract extract = new Extract();
|
extract.setIp(IPUtil.getRemotIP(request));
|
extract.setAccount(bindingAccount.getAccount());
|
extract.setName(bindingAccount.getName());
|
extract.setMoney(new BigDecimal(String.valueOf(money)));
|
extract.setUserInfo(user);
|
extract.setExtractTime(java.lang.System.currentTimeMillis());
|
extract.setType(type);
|
extract.setState(0);
|
extract.setSystem(system);
|
Integer etype = extractService.addExtract(extract);
|
if (etype == null) {
|
JSONObject data = new JSONObject();
|
data.put("id", extract.getId());
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
} else if (etype == 1) {
|
out.print(JsonUtil.loadFalseResult("已超过当日提现次数"));
|
} else if (etype == 2) {
|
out.print(JsonUtil.loadFalseResult("已超过当日提现金额"));
|
} else if (etype == 3) {
|
out.print(JsonUtil.loadFalseResult("提现金额大于我的红包"));
|
}
|
|
}
|
|
/**
|
* 获取提现进度
|
*
|
* @param acceptData
|
* @param id
|
* @param uid
|
* @param out
|
*/
|
@RequestMapping(value = "getextractprocess", method = RequestMethod.POST)
|
public void getExtractProcess(AcceptData acceptData, long id, Long uid, PrintWriter out) {
|
if (uid == null) {
|
out.print(JsonUtil.loadFalseResult("请上传用户ID"));
|
return;
|
}
|
Extract extract = extractService.getExtractById(id);
|
if (extract == null) {
|
out.print(JsonUtil.loadFalseResult("提现记录不存在"));
|
return;
|
}
|
if (extract.getUserInfo().getId().longValue() != uid) {
|
out.print(JsonUtil.loadFalseResult("不属于当前用户的提现记录"));
|
return;
|
}
|
|
BindingAccount account = new BindingAccount();
|
account.setAccount(extract.getAccount());
|
account.setName(extract.getName());
|
List<BindingAccount> bindingAccountList = new ArrayList<>();
|
bindingAccountList.add(account);
|
bindingAccountList = filterBindingAccount(bindingAccountList);
|
|
JSONObject data = new JSONObject();
|
data.put("id", extract.getId());
|
data.put("money", "¥" + extract.getMoney().toString());
|
data.put("account", bindingAccountList.get(0).getAccount());
|
data.put("expireTime",
|
TimeUtil.getGernalTime(extract.getExtractTime() + 1000 * 60 * 60 * 24L, "yyyy-MM-dd HH:mm"));// 24小时后到账
|
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping(value = "openhongbao")
|
public void openHongBao(AcceptData acceptData, long hid, HttpServletRequest request, PrintWriter out) {
|
String ip = IPUtil.getRemotIP(request);
|
HongBaoExtra hbx = hongBaoService.open(hid, ip);
|
if (hbx == null) {
|
out.print(JsonUtil.loadFalseResult("红包异常"));
|
LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "] 打开红包[id=" + hid + "]失败！");
|
return;
|
}
|
JSONObject data = new JSONObject();
|
data.put("hongBao", GsonUtil.toJsonExpose(hbx));
|
out.print(JsonUtil.loadTrueResult(data));
|
LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "] 打开红包[id=" + hid + "]成功！");
|
}
|
|
@RequestMapping(value = "getHongBaoMessages", method = RequestMethod.POST)
|
public void getHongBaoMessages(AcceptData acceptData, PrintWriter out) {
|
List<HongBaoMessage> list = shamUserService.getManyData();
|
JSONObject data = new JSONObject();
|
data.put("list", list);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("findLostOrder")
|
public void findLostOrder(AcceptData acceptData, LostOrder lostOrder, PrintWriter out) {
|
boolean orderNum = true;
|
|
if (!NumberUtil.isNumeric(lostOrder.getOrderId())) {
|
orderNum = false;
|
} else if (lostOrder.getOrderId().length() < 12 || lostOrder.getOrderId().length() > 20) {
|
orderNum = false;
|
} else
|
orderNum = Utils.isOrderNum(lostOrder.getOrderId());
|
|
int state;
|
String stateInfo = "提交成功，请等待审核结果。";
|
if (!orderNum) {
|
state = -4;
|
stateInfo = "请提交标准的订单号";
|
} else {
|
state = lostOrderService.addLostOrder(lostOrder);
|
if (state == -3) {
|
stateInfo = "该订单已是返利订单。";
|
} else if (state == -2) {
|
stateInfo = "请勿重复提交,该订单已在审核中。";
|
} else if (state == -1) {
|
stateInfo = "该订单申诉已通过，请稍后查看。";
|
} else if (state == -5) {
|
stateInfo = "该订单为分享奖金订单";
|
}
|
}
|
JSONObject data = new JSONObject();
|
data.put("state", state);
|
data.put("info", stateInfo);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("findOrderItemList")
|
public void findOrderItemList(AcceptData acceptData, long uid, int page, PrintWriter out) {
|
List<OrderItem> list = orderItemServcie.findOrderItemList(uid, page);
|
list.parallelStream().forEach(oi -> {
|
oi.setDesc();
|
});
|
int count = orderItemServcie.getCount(uid);
|
Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
|
.excludeFieldsWithoutExposeAnnotation().create();
|
JSONObject data = new JSONObject();
|
data.put("list", gson.toJson(list));
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
/**
|
* 获取提成订单列表
|
*
|
* @param acceptData
|
* @param uid
|
* @param page
|
* @param out
|
*/
|
@RequestMapping("getTiChengOrderList")
|
public void getTiChengOrderList(AcceptData acceptData, long uid, int page, PrintWriter out) {
|
List<HongBao> list = hongBaoService.getTiChengHongBaoList(uid, page);
|
long count = hongBaoService.getTiChengHongBaoListCount(uid);
|
List<OrderItem> orderItemList = HongBaoUtil.convertToTiChengOrder(list);
|
Gson gson = JsonUtil.getApiCommonGson();
|
JSONObject data = new JSONObject();
|
data.put("list", gson.toJson(orderItemList));
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("getOrderItem")
|
public void getOrderItem(AcceptData acceptData, long id, PrintWriter out) {
|
OrderItem orderItem = orderItemServcie.getOne(id);
|
if (orderItem == null) {
|
out.print(JsonUtil.loadFalseResult("不存在该订单"));
|
return;
|
}
|
orderItem.setDesc();
|
JSONObject data = new JSONObject();
|
GsonBuilder gsonBuilder = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder());
|
Gson gson = gsonBuilder.excludeFieldsWithoutExposeAnnotation().create();
|
data.put("orderItem", gson.toJson(orderItem));
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("findAccountMessageList")
|
public void findAccountMessageList(AcceptData acceptData, long uid, int page, PrintWriter out) {
|
accountMessageService.syncSystemZnx(uid);
|
List<AccountMessage> list = accountMessageService.findAccountMessageList(uid, page);
|
int count = accountMessageService.getCount(uid);
|
JSONObject data = new JSONObject();
|
data.put("list", GsonUtil.toJsonExpose(list));
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("openAccountMessage")
|
public void openAccountMessage(AcceptData acceptData, long id, PrintWriter out) {
|
accountMessageService.open(id);
|
out.print(JsonUtil.loadTrueResult("打开成功"));
|
}
|
|
@RequestMapping("findCanOpenMessage")
|
public void findCanOpenMessage(AcceptData acceptData, long uid, PrintWriter out) {
|
accountMessageService.syncSystemZnx(uid);
|
// count>0 有消息
|
int count = accountMessageService.getCanOpenCount(uid);
|
out.print(JsonUtil.loadTrueResult(count));
|
}
|
|
@RequestMapping("collectionGoods")
|
public void collectionGoods(AcceptData acceptData, long uid, long auctionId, int type, PrintWriter out) {
|
CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId);
|
if (type == 1) {
|
if (find != null) {
|
out.print(JsonUtil.loadFalseResult(""));
|
return;
|
}
|
CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid));
|
collectionGoodsService.save(cg);
|
out.print(JsonUtil.loadTrueResult("收藏成功"));
|
return;
|
} else {
|
if (find == null) {
|
out.print(JsonUtil.loadTrueResult("取消收藏成功"));
|
return;
|
} else {
|
collectionGoodsService.delete(find);
|
out.print(JsonUtil.loadTrueResult("取消收藏成功"));
|
return;
|
}
|
}
|
|
}
|
|
/**
|
* h5收藏
|
*
|
* @param callback
|
* @param acceptData
|
* @param uid
|
* @param auctionId
|
* @param out
|
*/
|
@RequestMapping("collectionGoodsJp")
|
public void collectionGoodsJp(String callback, AcceptData acceptData, Long uid, Long auctionId, PrintWriter out) {
|
|
if (uid == null || auctionId == null) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(""));
|
return;
|
}
|
|
CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId);
|
|
if (find == null) {
|
// 添加收藏
|
CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid));
|
collectionGoodsService.save(cg);
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(1));
|
} else {
|
// 取消收藏
|
collectionGoodsService.delete(find);
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(0));
|
}
|
|
}
|
|
@RequestMapping("collectionGoodsList")
|
public void collectionGoodsList(AcceptData acceptData, long uid, int page, PrintWriter out) {
|
List<CollectionGoods> coList = collectionGoodsService.findCollectionGoods(uid, page + 1);
|
int count = collectionGoodsService.getCount(uid);
|
JSONObject data = new JSONObject();
|
Map<String, String> map = hongBaoManageService.convertMap();
|
String proportion = map.get("hongbao_goods_proportion");
|
String fcRate = map.get("hongbao_fc_ratio");
|
List<TaoBaoGoodsBriefExtra> list = new ArrayList<TaoBaoGoodsBriefExtra>();
|
coList.parallelStream().forEachOrdered(cg -> {
|
TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.getTaoBaoGoodsBrief(cg);
|
goodsBrief.setSalesCount(TaoBaoUtil.getSaleCount(goodsBrief.getBiz30day()));
|
TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion,
|
fcRate, "");
|
taoBaoGoodsBriefExtra.setCreatetime(new Date(cg.getCreateTime()));
|
|
list.add(taoBaoGoodsBriefExtra);
|
});
|
GsonBuilder builder = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
|
@Override
|
public JsonElement serialize(Date value, Type theType, JsonSerializationContext context) {
|
if (value == null) {
|
return new JsonPrimitive("");
|
} else {
|
return new JsonPrimitive(value.getTime() + "");
|
}
|
}
|
});
|
|
Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(builder).excludeFieldsWithoutExposeAnnotation()
|
.create();
|
data.put("list", gson.toJson(list));
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("deleteCollectionGoods")
|
public void deleteCollectionGoods(AcceptData acceptData, String ids, Integer type, long uid, PrintWriter out) {
|
if (type != null && type == 1) {
|
clearConllectionGoods(acceptData, uid, out);
|
} else {
|
if (!StringUtil.isNullOrEmpty(ids)) {
|
Arrays.asList(ids.split(",")).parallelStream().forEach(auctionIdStr -> {
|
collectionGoodsService.delete(Long.parseLong(auctionIdStr), uid);
|
});
|
}
|
}
|
out.print(JsonUtil.loadTrueResult("删除成功"));
|
}
|
|
@RequestMapping("clearConllectionGoods")
|
public void clearConllectionGoods(AcceptData acceptData, long uid, PrintWriter out) {
|
collectionGoodsService.clear(uid);
|
out.print(JsonUtil.loadTrueResult("删除成功"));
|
}
|
|
@RequestMapping("ruleMessage")
|
public void ruleMessage(AcceptData acceptData, PrintWriter out) {
|
JSONObject data = new JSONObject();
|
data.put("rank3", String.format("成功邀请50个好友完成注册安装%sAPP（包括一度好友和二度好友之和）",
|
Constant.systemCommonConfig.getProjectChineseName()));
|
data.put("rank2", String.format("成功邀请5个好友完成注册安装%sAPP（包括一度好友和二度好友之和）",
|
Constant.systemCommonConfig.getProjectChineseName()));
|
data.put("rank1", String.format("成功邀请1个好友完成注册安装%sAPP（包括一度好友和二度好友之和）",
|
Constant.systemCommonConfig.getProjectChineseName()));
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("findAccountDetailsList")
|
public void findAccountDetailsList(AcceptData acceptData, long uid, int page, PrintWriter out) {
|
List<AccountDetails> list = accountDetailsService.findAccountDetailsList(uid, page);
|
int count = accountDetailsService.getCount(uid);
|
JSONObject data = new JSONObject();
|
data.put("list", GsonUtil.toJsonExpose(list));
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping("findAccountDetailsListV2")
|
public void findAccountDetailsListNew(AcceptData acceptData, long uid, int page, PrintWriter out) {
|
List<AccountDetails> list = accountDetailsService.findAccountDetailsListWithState(uid, page);
|
long count = accountDetailsService.getCountWithState(uid);
|
JSONObject data = new JSONObject();
|
JSONArray array = new JSONArray();
|
for (AccountDetails ad : list) {
|
JSONObject item = JSONObject.fromObject(GsonUtil.toJsonExpose(ad));
|
if (ad.getState() != null && ad.getState() != -1)
|
item.put("stateIcon",
|
"http://hcj-1255749512.file.myqcloud.com/resource/app/extract_state_" + ad.getState() + ".png");
|
array.add(item);
|
}
|
data.put("list", array);
|
data.put("count", count);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping(value = "isWxDown")
|
|
public void isWxDown(AcceptData acceptData, PrintWriter out) {
|
boolean b = wxDownService.isWxDownFirstLogin(acceptData.getDevice());
|
// IOS上线测试
|
if (Integer.parseInt(acceptData.getVersion()) >= 22
|
&& acceptData.getPackages().equalsIgnoreCase(Constant.systemCommonConfig.getIosBundleId()))
|
b = false;
|
JSONObject data = new JSONObject();
|
data.put("isFirst", b);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
// 获取商品分享链接
|
@RequestMapping(value = "getGoodsShareUrl")
|
public void getGoodsShareUrl(AcceptData acceptData, long id, PrintWriter out) {
|
out.print(JsonUtil
|
.loadTrueResult(String.format("%s?id=" + id, Constant.systemCommonConfig.getAppShareInfoUrl())));
|
}
|
|
}
|
