package com.yeshi.fanli.controller.client.v2;
|
|
import java.io.PrintWriter;
|
|
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.bind.annotation.RequestMethod;
|
import org.yeshi.utils.JsonUtil;
|
|
import com.yeshi.fanli.entity.accept.AcceptData;
|
import com.yeshi.fanli.entity.bus.user.SMSHistory;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.push.DeviceActive;
|
import com.yeshi.fanli.entity.system.BusinessSystem;
|
import com.yeshi.fanli.exception.user.UserAccountException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.BusinessSystemService;
|
import com.yeshi.fanli.service.inter.homemodule.HomeNavbarUserService;
|
import com.yeshi.fanli.service.inter.money.UserMoneyService;
|
import com.yeshi.fanli.service.inter.order.LostOrderService;
|
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.push.DeviceActiveService;
|
import com.yeshi.fanli.service.inter.push.DeviceTokenHWService;
|
import com.yeshi.fanli.service.inter.push.DeviceTokenOPPOService;
|
import com.yeshi.fanli.service.inter.push.DeviceTokenVIVOService;
|
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService;
|
import com.yeshi.fanli.service.inter.user.BindRemindService;
|
import com.yeshi.fanli.service.inter.user.ForbiddenUserIdentifyCodeService;
|
import com.yeshi.fanli.service.inter.user.ShamUserService;
|
import com.yeshi.fanli.service.inter.user.SpreadUserImgService;
|
import com.yeshi.fanli.service.inter.user.TBPidService;
|
import com.yeshi.fanli.service.inter.user.UserAccountBindingHistoryService;
|
import com.yeshi.fanli.service.inter.user.UserAccountService;
|
import com.yeshi.fanli.service.inter.user.UserInfoDeleteRecordService;
|
import com.yeshi.fanli.service.inter.user.UserInfoModifyRecordService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.ThreadUtil;
|
import com.yeshi.fanli.util.VersionUtil;
|
import com.yeshi.fanli.util.account.UserUtil;
|
import com.yeshi.fanli.util.annotation.RequestSerializableByKey;
|
|
import net.sf.json.JSONObject;
|
|
/**
|
* 账户系统
|
*
|
* @author Administrator
|
*
|
*/
|
@Controller
|
@RequestMapping("api/v2/user")
|
public class UserAccountControllerV2 {
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private BusinessSystemService businessSystemService;
|
|
@Resource
|
private ShamUserService shamUserService;
|
|
@Resource
|
private ThreeSaleSerivce threeSaleSerivce;
|
|
@Resource
|
private LostOrderService lostOrderService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private UserAccountService userAccountService;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private TBPidService tbPidService;
|
|
@Resource
|
private DeviceTokenHWService deviceTokenHWService;
|
|
@Resource
|
private DeviceTokenOPPOService deviceTokenOPPOService;
|
|
@Resource
|
private DeviceTokenVIVOService deviceTokenVIVOService;
|
|
@Resource
|
private TaoBaoUnionConfigService taoBaoUnionConfigService;
|
|
@Resource
|
private SpreadUserImgService spreadUserImgService;
|
|
@Resource
|
private UserShareGoodsRecordService userShareGoodsRecordService;
|
|
@Resource
|
private ForbiddenUserIdentifyCodeService forbiddenUserIdentifyCodeService;
|
|
@Resource
|
private UserSystemCouponService userSystemCouponService;
|
|
@Resource
|
private UserMoneyService userMoneyService;
|
|
@Resource
|
private UserAccountBindingHistoryService userAccountBindingHistoryService;
|
|
@Resource
|
private HomeNavbarUserService homeNavbarUserService;
|
|
@Resource
|
private UserInfoDeleteRecordService userInfoDeleteRecordService;
|
|
@Resource
|
private UserTaoLiJinOriginService userTaoLiJinOriginService;
|
|
@Resource
|
private UserInfoModifyRecordService userInfoModifyRecordService;
|
|
@Resource
|
private DeviceActiveService deviceActiveService;
|
|
@Resource
|
private BindRemindService bindRemindService;
|
|
/**
|
* 新版登录 V1.5.3
|
*
|
* @param acceptData
|
* @param vcode
|
* @param phone
|
* @param code
|
* @param loginType
|
* 登录方式： 1-手机登录 2-微信登录
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "login", method = RequestMethod.POST)
|
public void login(AcceptData acceptData, int loginType, String vcode, String phone, String code,
|
HttpServletRequest request, PrintWriter out) {
|
try {
|
BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
|
acceptData.getPackages());
|
if (system == null) {
|
out.print(JsonUtil.loadFalseResult("系统不存在"));
|
return;
|
}
|
|
UserInfo userInfo = null;
|
// 手机登录
|
if (loginType == 1) {
|
userInfo = userAccountService.loginPhone(request, loginType, vcode, phone, system.getAppid());
|
}
|
|
// 微信登录
|
if (loginType == 2) {
|
userInfo = userAccountService.loginWeiXinNew(request, acceptData, loginType, code, system.getAppid());
|
}
|
|
if (userInfo == null) {
|
out.print(JsonUtil.loadFalseResult("登录失败"));
|
} else {
|
JSONObject data = new JSONObject();
|
data.put("userInfo", UserUtil.filterForClientUser(userInfo));
|
out.print(JsonUtil.loadTrueResult(data));
|
|
final UserInfo uuser = userInfo;
|
ThreadUtil.run(new Runnable() {
|
public void run() {
|
String device = acceptData.getDevice();
|
try {
|
// 同步自定义导航
|
homeNavbarUserService.synchroDeviceToUser(uuser.getId(), device);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
if (VersionUtil.greaterThan_1_5_60(acceptData.getPlatform(), acceptData.getVersion())) {
|
/* 新人红包 */
|
try {
|
userTaoLiJinOriginService.synchDeviceHongbao(uuser.getId(), device);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
// 绑定oppo,VIVO推送
|
DeviceActive active = deviceActiveService.getFirstActiveInfo(acceptData.getDevice());
|
if (active != null) {
|
deviceTokenOPPOService.bindUid(uuser.getId(), active.getId());
|
deviceTokenVIVOService.bindUid(uuser.getId(), active.getId());
|
}
|
}
|
});
|
}
|
|
} catch (UserAccountException e) {
|
int errorCode = e.getCode();
|
if (errorCode == 101) { // 需要绑定手机号
|
JSONObject data = new JSONObject();
|
data.put("key", e.getMsg());
|
JSONObject object = new JSONObject();
|
object.put("code", errorCode);
|
object.put("data", data);
|
out.print(object.toString());
|
} else {
|
out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
|
try {
|
LogHelper.cookieLog("登录出错:" + e.getCode() + "-" + e.getMessage());
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
|
} catch (Exception e) {
|
out.print(JsonUtil.loadFalseResult("登录失败"));
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 绑定电话号码 V2.0.1 微信登录
|
*
|
* @param acceptData
|
* @param vcode
|
* @param phone
|
* @param out
|
*/
|
@RequestSerializableByKey(key = "'bindPhoneLogin-'+#phone")
|
@RequestMapping(value = "bindPhoneLogin")
|
public void bindPhoneLogin(AcceptData acceptData, String vcode, String phone, String key,
|
HttpServletRequest request, PrintWriter out) {
|
BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),
|
acceptData.getPackages());
|
if (system == null) {
|
out.print(JsonUtil.loadFalseResult("系统不存在"));
|
return;
|
}
|
|
if (StringUtil.isNullOrEmpty(vcode)) {
|
out.print(JsonUtil.loadFalseResult("验证码不能为空"));
|
return;
|
}
|
|
if (StringUtil.isNullOrEmpty(phone)) {
|
out.print(JsonUtil.loadFalseResult("电话号码不能为空"));
|
return;
|
}
|
|
if (StringUtil.isNullOrEmpty(key)) {
|
out.print(JsonUtil.loadFalseResult("key值不能为空"));
|
return;
|
}
|
|
phone = phone.replaceAll(" ", "");
|
|
String oldVCode = redisManager.getSMSVCode(phone, SMSHistory.TYPE_BIND);
|
if (Constant.IS_OUTNET) {
|
if (!vcode.equalsIgnoreCase(oldVCode)) {
|
out.print(JsonUtil.loadFalseResult(9001, "验证码错误，重新输入"));
|
return;
|
}
|
redisManager.clearSMSFrequencyLimit(phone, SMSHistory.TYPE_BIND);
|
}
|
|
try {
|
UserInfo userInfo = userAccountService.bindPhoneToLogin(phone, key, system.getAppid(), request);
|
|
JSONObject data = new JSONObject();
|
data.put("userInfo", UserUtil.filterForClientUser(userInfo));
|
out.print(JsonUtil.loadTrueResult(data));
|
} catch (UserAccountException e) {
|
out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
|
} catch (Exception e) {
|
out.print(JsonUtil.loadFalseResult(1, "绑定失败"));
|
}
|
}
|
|
/**
|
* 绑定电话号码 V2.0.1 微信登录
|
*
|
* @param acceptData
|
* @param vcode
|
* @param phone
|
* @param out
|
*/
|
@RequestMapping(value = "recordBind")
|
public void recordBind(AcceptData acceptData, Long uid, PrintWriter out) {
|
if (uid == null || uid <= 0) {
|
out.print(JsonUtil.loadFalseResult("用户id为空"));
|
return;
|
}
|
|
bindRemindService.addBindPhone(uid);
|
out.print(JsonUtil.loadTrueResult("记录成功"));
|
}
|
|
}
|
