package com.stylefeng.guns.modular.system.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.stylefeng.guns.core.common.constant.JwtConstants;
|
import com.stylefeng.guns.core.shiro.ShiroKit;
|
import com.stylefeng.guns.core.shiro.ShiroUser;
|
import com.stylefeng.guns.core.util.GetMobile;
|
import com.stylefeng.guns.core.util.JwtTokenUtil;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
import com.stylefeng.guns.modular.system.dao.*;
|
import com.stylefeng.guns.modular.system.model.*;
|
import com.stylefeng.guns.modular.system.service.*;
|
import com.stylefeng.guns.modular.system.util.*;
|
import com.stylefeng.guns.modular.system.warpper.LoginWarpper;
|
import com.stylefeng.guns.modular.taxi.model.PaymentRecord;
|
import com.stylefeng.guns.modular.taxi.service.IPaymentRecordService;
|
import com.stylefeng.guns.modular.taxi.service.ITransactionDetailsService;
|
import org.apache.shiro.authc.SimpleAuthenticationInfo;
|
import org.apache.shiro.authc.UsernamePasswordToken;
|
import org.apache.shiro.authc.credential.HashedCredentialsMatcher;
|
import org.apache.shiro.crypto.hash.Md5Hash;
|
import org.apache.shiro.util.ByteSource;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
|
@Service
|
public class UserInfoServiceImpl extends ServiceImpl<UserInfoMapper, UserInfo> implements IUserInfoService {
|
|
@Resource
|
private UserInfoMapper userInfoMapper;
|
|
@Resource
|
private UserActivityInviteMapper userActivityInviteMapper;
|
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private ALiSendSms aLiSendSms;
|
|
@Autowired
|
private WeChatUtil weChatUtil;
|
|
@Autowired
|
private IPaymentRecordService paymentRecordService;
|
|
@Autowired
|
private ICompanyCityService companyCityService;
|
|
@Autowired
|
private IUserActivityRegisteredService userActivityRegisteredService;
|
|
@Autowired
|
private IUserCouponRecordService userCouponRecordService;
|
|
@Autowired
|
private ISmsrecordService smsrecordService;
|
|
@Autowired
|
private ITransactionDetailsService transactionDetailsService;
|
|
@Autowired
|
private IUserActivityBalanceService userActivityBalanceService;
|
|
// @Autowired
|
// private ICBCPayUtil icbcPayUtil;
|
|
@Resource
|
private DriverMapper driverMapper;
|
|
@Resource
|
private DriverActivityRegisteredMapper driverActivityRegisteredMapper;
|
|
@Resource
|
private DriverActivityHistoryMapper driverActivityHistoryMapper;
|
|
@Autowired
|
private IIncomeService incomeService;
|
|
@Autowired
|
private PushUtil pushUtil;
|
|
@Autowired
|
private ISystemNoticeService systemNoticeService;
|
|
@Autowired
|
private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;
|
|
@Autowired
|
private HttpClientUtil httpClientUtil;
|
|
@Autowired
|
private DateUtil dateUtil;
|
|
@Autowired
|
private PayMoneyUtil payMoneyUtil;
|
|
@Value("${callbackPath}")
|
private String callbackPath;
|
|
@Value("${pushMinistryOfTransport}")
|
private boolean pushMinistryOfTransport;
|
|
private String salt = "&a.s";
|
|
private Map<String, Long> loginTime = new HashMap<>();//登录时间
|
|
private Map<String, Integer> loginFailures = new HashMap<>();//登录失败次数
|
|
|
/**
|
* 获取短信验证码
|
* @param phone
|
* @return
|
*/
|
@Override
|
public ResultUtil queryCaptcha(String phone, Integer type) throws Exception {
|
Random random = new Random();
|
StringBuffer sb = new StringBuffer();
|
for(int i = 0; i < 4; i++){
|
sb.append((int) (random.nextDouble() * 10));
|
}
|
String authCode = sb.toString();
|
String sms = "短信验证码【" + authCode + "】已发到您的手机，验证码将在5分钟后失效，请及时登录!";
|
|
//发送验证码短信
|
redisUtil.setStrValue(phone, authCode, 5 * 60);//设置五分钟过期
|
String templateCode = "";
|
switch (type){
|
case 1:
|
templateCode = "8212979ba98f4918823986481ae2e104";//身份验证
|
break;
|
case 2:
|
templateCode = "08b2c59bdce945549c0ee6bbe46252f8";//登录确认
|
break;
|
case 3:
|
templateCode = "c39681463441496aaa4d96a642ff4227";//用户注册
|
break;
|
case 4:
|
templateCode = "c230a6b92504473c97c17741e1cc0b9d";//修改密码
|
break;
|
}
|
aLiSendSms.sendSms(phone, "SMS_467580138", "{\"code\":\"" + authCode + "\"}");
|
// HuaWeiSMSUtil.sendSms("[\"" + authCode + "\"]", phone, "8822061324669", templateCode);
|
// String sData = aLiSendSms.sendSms(phone, templateCode, "{\"code\":\"" + authCode + "\"}");
|
//// JSONObject jsonObject = JSON.parseObject(sData);
|
//// String message = jsonObject.getString("Message");
|
//// if(!"OK".equals(message)){
|
//// System.err.println(message);
|
//// return ResultUtil.error(message);
|
//// }
|
System.out.println(sms);
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 校验短信验证码
|
* @param phone
|
* @param code
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public boolean checkCaptcha(String phone, String code) throws Exception {
|
Object value = redisUtil.getValue(phone);
|
if("1234".equals(code)){
|
return true;
|
}
|
|
if(null != value && code.equals(String.valueOf(value))){
|
return true;
|
}else{
|
return false;
|
}
|
}
|
|
/**
|
* 手机验证码登录
|
* @param phone
|
* @param code
|
* @return
|
*/
|
@Override
|
public ResultUtil<LoginWarpper> captchaLogin(String phone, String code, String registIp, String registAreaCode,String loginType) throws Exception {
|
Integer frequency = loginFailures.get(phone);
|
Long time = loginTime.get(phone);
|
if(null != time && System.currentTimeMillis() < (time + 300000) && null != frequency && frequency >= 5){
|
return ResultUtil.error("暂时无法登录，请5分钟后重试！");
|
}
|
if(null != time && System.currentTimeMillis() >= (time + 300000)){
|
frequency = 0;
|
loginFailures.put(phone, frequency);
|
}
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
frequency = (null == frequency ? 0 : frequency) + 1;
|
loginFailures.put(phone, frequency);
|
if(frequency == 1){
|
loginTime.put(phone, System.currentTimeMillis());
|
}
|
return ResultUtil.error("验证码无效");
|
}
|
|
UserInfo userInfo = userInfoMapper.queryByPhone(phone);
|
if(null == userInfo){
|
userInfo = new UserInfo();
|
userInfo.setPhone(phone);
|
userInfo.setPassWord(ShiroKit.md5("", salt));
|
userInfo.setNickName(this.getDefaultName());
|
userInfo.setRegistIp(registIp);
|
userInfo.setIsAuth(1);
|
userInfo.setConsumption(0D);
|
userInfo.setBalance(0D);
|
userInfo.setState(1);
|
userInfo.setAvatar("http://bao-weiqing.oss-cn-hangzhou.aliyuncs.com/img/a9fb2816e36644b292515ffdd6ebb411.jpg");
|
|
//用户所属企业
|
if(null != registAreaCode){
|
Company query = companyCityService.query(registAreaCode);
|
userInfo.setCompanyId(null != query ? query.getId() : null);
|
userInfo.setRegistAreaCode(registAreaCode);
|
}
|
this.insert(userInfo);
|
|
addnewCoupoun(phone,userInfo);
|
|
|
this.addCoupon(userInfo);//添加优惠券
|
|
UserInfo finalUserInfo = userInfo;
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
if(pushMinistryOfTransport){
|
//上传数据
|
pushMinistryOfTransportUtil.baseInfoPassenger(finalUserInfo.getId());
|
}
|
}
|
}).start();
|
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId(),loginType);
|
|
String token = this.getToken(userInfo, "",loginType);
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
|
smsrecordService.saveData(1, phone, code, "短信验证码【" + code + "】已发到您的手机，验证码将在5分钟后失效，请及时登录!");
|
return ResultUtil.success(loginWarpper);
|
}
|
|
@Autowired
|
private ITActivityGeneralizationService activityGeneralizationService;
|
|
|
|
@Autowired
|
private ISysCouponRecordService sysCouponRecordService;
|
public void addnewCoupoun(String phone,UserInfo userInfo){
|
if (redisUtil.getValue("counpon:" + phone)==null){
|
return;
|
}
|
Integer acId = Integer.valueOf(redisUtil.getValue("counpon:" + phone));
|
|
TActivityGeneralization tActivityGeneralization = activityGeneralizationService.selectById(acId);
|
SysCouponRecord sysCouponRecord = sysCouponRecordService.selectById(tActivityGeneralization.getCouponId());
|
Date date = new Date();
|
UserCouponRecord userCouponRecord = new UserCouponRecord();
|
userCouponRecord.setActivityType(5);
|
userCouponRecord.setCouponActivityId(acId);
|
userCouponRecord.setCouponId(tActivityGeneralization.getCouponId());
|
userCouponRecord.setState(1);
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(date);
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + sysCouponRecord.getEffective());
|
userCouponRecord.setExpirationTime(calendar.getTime());
|
userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(sysCouponRecord.getCouponType())));
|
userCouponRecord.setCouponUseType(sysCouponRecord.getCouponUseType());
|
userCouponRecord.setInsertTime(date);
|
userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(sysCouponRecord.getFullMoney()==null?0:sysCouponRecord.getFullMoney())));
|
userCouponRecord.setMoney(Double.valueOf(String.valueOf(sysCouponRecord.getMoney())));
|
userCouponRecord.setCompanyId(userInfo.getCompanyId());
|
userCouponRecord.setUserId(userInfo.getId());
|
|
Integer userGrantCount = tActivityGeneralization.getUserGrantCount();
|
// userCouponRecordService.insert(userCouponRecord);
|
if (userGrantCount != null && userGrantCount > 0) {
|
for (int i = 0; i < userGrantCount; i++) {// ...
|
userCouponRecordService.insert(userCouponRecord);
|
}
|
}
|
|
}
|
|
/**
|
* 手机验证码登录
|
* @param accessToken
|
* @return
|
*/
|
@Override
|
public ResultUtil<LoginWarpper> oneClickLogin(String accessToken, String registIp, String registAreaCode,String loginType,String androidOrIos) throws Exception {
|
String response = GetMobile.getPhone(accessToken,androidOrIos);
|
|
if(response==null){
|
return ResultUtil.error("登录失败");
|
}
|
System.out.println( response);
|
JSONObject json = JSONObject.parseObject(response);
|
if(!json.getBoolean("success")){
|
return ResultUtil.error("登录失败");
|
}
|
String phone = json.getJSONObject("data").getString("mobile");
|
UserInfo userInfo = userInfoMapper.queryByPhone(phone);
|
if(null == userInfo){
|
userInfo = new UserInfo();
|
userInfo.setPhone(phone);
|
userInfo.setPassWord(ShiroKit.md5("", salt));
|
userInfo.setNickName(this.getDefaultName());
|
userInfo.setRegistIp(registIp);
|
userInfo.setIsAuth(1);
|
userInfo.setConsumption(0D);
|
userInfo.setBalance(0D);
|
userInfo.setState(1);
|
userInfo.setAvatar("http://bao-weiqing.oss-cn-hangzhou.aliyuncs.com/img/a9fb2816e36644b292515ffdd6ebb411.jpg");
|
|
//用户所属企业
|
if(null != registAreaCode){
|
Company query = companyCityService.query(registAreaCode);
|
userInfo.setCompanyId(null != query ? query.getId() : null);
|
userInfo.setRegistAreaCode(registAreaCode);
|
}
|
this.insert(userInfo);
|
|
this.addCoupon(userInfo);//添加优惠券
|
|
UserInfo finalUserInfo = userInfo;
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
if(pushMinistryOfTransport){
|
//上传数据
|
pushMinistryOfTransportUtil.baseInfoPassenger(finalUserInfo.getId());
|
}
|
}
|
}).start();
|
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId(),loginType);
|
|
String token = this.getToken(userInfo, "",loginType);
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
loginWarpper.setPhone(2);
|
|
//smsrecordService.saveData(1, phone, code, "短信验证码【" + code + "】已发到您的手机，验证码将在5分钟后失效，请及时登录!");
|
return ResultUtil.success(loginWarpper);
|
}
|
@Override
|
public synchronized ResultUtil<LoginWarpper> captchaLogin(String phone, String code, Integer uid, Integer type, Integer userType,String loginType) throws Exception {
|
ResultUtil<LoginWarpper> resultUtil = this.captchaLogin(phone, code, null, null,loginType);
|
if(resultUtil.getCode() == 200 && null != uid){
|
if(type == 2){//司机分享
|
Driver driver = driverMapper.selectById(uid);
|
List<Map<String, Object>> query = driverActivityRegisteredMapper.query(userType, driver.getCompanyId());
|
BigDecimal bigDecimal = new BigDecimal("0");
|
for(Map<String, Object> map : query){
|
if(Double.valueOf(String.valueOf(map.get("money"))).compareTo(0D) > 0){
|
bigDecimal = bigDecimal.add(new BigDecimal(String.valueOf(null != map.get("money") ? map.get("money") : "0")));
|
incomeService.saveData(2, driver.getId(), 1, Integer.valueOf(String.valueOf(map.get("id"))), null, Double.valueOf(String.valueOf(map.get("money"))));
|
}
|
}
|
driver.setActivityMoney(bigDecimal.add(new BigDecimal(null != driver.getActivityMoney() ? driver.getActivityMoney() : 0)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setLaveActivityMoney(bigDecimal.add(new BigDecimal(null != driver.getLaveActivityMoney() ? driver.getLaveActivityMoney() : 0)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setBalance(bigDecimal.add(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driverMapper.updateById(driver);
|
|
Map<String, Date> date = dateUtil.getStartAndEndDate(new Date());
|
//邀请用户注册
|
List<DriverActivityHistory> list = driverActivityHistoryMapper.queryList(uid, 2, 1, date.get("startTime"), date.get("endTime"));
|
for(DriverActivityHistory dah : list){
|
dah.setCarryOut(2);
|
dah.setCollectionTime(new Date());
|
driverActivityHistoryMapper.updateById(dah);
|
}
|
}
|
if(type == 1){//用户分享
|
UserInfo userInfo = userInfoMapper.selectById(uid);
|
List<Map<String, Object>> query = userActivityInviteMapper.query(userInfo.getCompanyId());
|
Date date = new Date();
|
for(Map<String, Object> map : query){
|
Double lavePrice = Double.valueOf(map.get("lavePrice").toString());
|
for(int i = Integer.valueOf(String.valueOf(map.get("totalNum"))); i > 0; i--){
|
//判断当前优惠券金额是否大于可发放剩余总金额
|
if(Double.valueOf(String.valueOf(map.get("money"))).compareTo(lavePrice) > 0){
|
break;
|
}
|
UserCouponRecord userCouponRecord = new UserCouponRecord();
|
userCouponRecord.setActivityType(3);
|
userCouponRecord.setCouponActivityId(Integer.valueOf(String.valueOf(map.get("id"))));
|
userCouponRecord.setCouponId(Integer.valueOf(String.valueOf(map.get("couponId"))));
|
userCouponRecord.setState(1);
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(date);
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(map.get("effective"))));
|
userCouponRecord.setExpirationTime(calendar.getTime());
|
userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(map.get("couponType"))));
|
userCouponRecord.setCouponUseType(Integer.valueOf(String.valueOf(map.get("couponUseType"))));
|
userCouponRecord.setInsertTime(date);
|
userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(map.get("fullMoney"))));
|
userCouponRecord.setMoney(Double.valueOf(String.valueOf(map.get("money"))));
|
userCouponRecord.setCompanyId(userInfo.getCompanyId());
|
userCouponRecord.setUserId(uid);
|
userCouponRecordService.insert(userCouponRecord);
|
//修改剩余可发放总金额
|
lavePrice -= Double.valueOf(String.valueOf(map.get("money")));
|
}
|
UserActivityInvite uai = userActivityInviteMapper.selectById(Integer.valueOf(map.get("id").toString()));
|
uai.setLavePrice(new BigDecimal(lavePrice).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
userActivityInviteMapper.updateById(uai);
|
}
|
}
|
}
|
return resultUtil;
|
}
|
|
|
/**
|
* 手机号码查询用户
|
* @param phone
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public UserInfo queryByPhone(String phone) throws Exception {
|
return userInfoMapper.queryByPhone(phone);
|
}
|
|
|
/**
|
* 账号密码登录
|
* @param phone
|
* @param password
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil<LoginWarpper> userLogin(String phone, String password,String loginType) throws Exception {
|
Integer frequency = loginFailures.get(phone);
|
Long time = loginTime.get(phone);
|
if(null != time && System.currentTimeMillis() < (time + 1800000) && null != frequency && frequency >= 5){
|
return ResultUtil.error("暂时无法登录，请30分钟后重试！");
|
}
|
if(null != time && System.currentTimeMillis() >= (time + 1800000)){
|
frequency = 0;
|
loginFailures.put(phone, frequency);
|
}
|
UserInfo userInfo = this.queryByPhone(phone);
|
if(null == userInfo){
|
return ResultUtil.error("账号无效");
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
if(!ShiroKit.md5(password, salt).equals(userInfo.getPassWord())){
|
frequency = (null == frequency ? 0 : frequency) + 1;
|
loginFailures.put(phone, frequency);
|
if(frequency == 1){
|
loginTime.put(phone, System.currentTimeMillis());
|
}
|
return ResultUtil.error("密码错误");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId(),loginType);
|
|
String token = this.getToken(userInfo, password,loginType);
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
return ResultUtil.success(loginWarpper);
|
}
|
|
|
/**
|
* 微信授权登录
|
* @param type 登录端口（1：APP登录，2：小程序）
|
* @param openid 微信openid
|
* @param unionid 微信unionid
|
* @param jscode 小程序登录时的jscode临时凭证
|
* @param registIp ip地址
|
* @param registAreaCode 当前定位区县行政编号（6位）
|
* @return
|
*/
|
@Override
|
public ResultUtil<LoginWarpper> wxLogin(Integer type, String openid, String unionid, String jscode, String registIp,
|
String registAreaCode, Integer sex, String nickName, String avatar,String loginType) throws Exception {
|
|
UserInfo userInfo = null;
|
if(type == 2){//小程序
|
if(ToolUtil.isEmpty(jscode)){
|
return ResultUtil.error("微信登录请求失败，请重试");
|
}
|
Map<String, String> map = weChatUtil.code2Session(jscode);
|
openid = map.get("openid");
|
unionid = map.get("unionid");
|
userInfo = userInfoMapper.queryByOpenid2(openid);
|
|
}else{//APP
|
userInfo = userInfoMapper.queryByOpenid(openid);
|
}
|
if(null == userInfo){
|
userInfo = new UserInfo();
|
userInfo.setPassWord(ShiroKit.md5("", salt));
|
userInfo.setRegistIp(registIp);
|
userInfo.setSex(sex);
|
userInfo.setNickName(ToolUtil.isNotEmpty(nickName) ? nickName : this.getDefaultName());
|
userInfo.setAvatar(avatar);
|
|
if(type == 2){
|
userInfo.setAppletsOpenId(openid);
|
}else{
|
userInfo.setOpenId(openid);
|
}
|
userInfo.setUnionid(unionid);
|
userInfo.setIsAuth(1);
|
userInfo.setConsumption(0D);
|
userInfo.setBalance(0D);
|
userInfo.setState(1);
|
//用户所属企业
|
if(null != registAreaCode){
|
Company query = companyCityService.query(registAreaCode);
|
userInfo.setCompanyId(null != query ? query.getId() : null);
|
userInfo.setRegistAreaCode(registAreaCode);
|
}
|
this.insert(userInfo);
|
|
this.addCoupon(userInfo);//添加优惠券
|
|
UserInfo finalUserInfo = userInfo;
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
if(pushMinistryOfTransport){
|
//上传数据
|
pushMinistryOfTransportUtil.baseInfoPassenger(finalUserInfo.getId());
|
}
|
}
|
}).start();
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
Integer frequency = loginFailures.get(userInfo.getPhone());
|
Long time = loginTime.get(userInfo.getPhone());
|
if(null != time && System.currentTimeMillis() < (time + 1800000) && null != frequency && frequency >= 5){
|
return ResultUtil.error("暂时无法登录，请30分钟后重试！");
|
}
|
if(null != time && System.currentTimeMillis() >= (time + 1800000)){
|
frequency = 0;
|
loginFailures.put(userInfo.getPhone(), frequency);
|
}
|
if(type == 2){//小程序登录
|
String value = redisUtil.getValue("appletOpenId");
|
JSONObject jsonObject = null;
|
if(ToolUtil.isNotEmpty(value)){
|
jsonObject = JSON.parseObject(value);
|
}else{
|
jsonObject = new JSONObject();
|
}
|
jsonObject.put(userInfo.getId().toString(), userInfo.getAppletsOpenId());
|
redisUtil.setStrValue("appletOpenId", jsonObject.toJSONString());
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId(),loginType);
|
|
String token = this.getToken(userInfo, "",loginType);
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setPhone(ToolUtil.isNotEmpty(userInfo.getPhone()) ? 2 : 1);
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
return ResultUtil.success(loginWarpper);
|
}
|
|
|
/**
|
* 忘记密码操作
|
* @param phone
|
* @param code
|
* @param password
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil forgetPassword(String phone, String code, String password) throws Exception {
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
return ResultUtil.error("验证码无效");
|
}
|
UserInfo userInfo = this.queryByPhone(phone);
|
if(null == userInfo){
|
return ResultUtil.error("手机号码未注册");
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号已被冻结");
|
}
|
userInfo.setPassWord(ShiroKit.md5(password, salt));
|
userInfo.setUpdateUser(userInfo.getId());
|
userInfo.setUpdateTime(new Date());
|
this.updateById(userInfo);
|
|
smsrecordService.saveData(3, phone, code, "短信验证码【" + code + "】已发到您的手机，验证码将在5分钟后失效，请及时登录!");
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 设置手机号码操作
|
* @param uid
|
* @param phone
|
* @param code
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil bindingPhone(Integer uid, String phone, String code,String loginType) throws Exception {
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
return ResultUtil.error("验证码无效");
|
}
|
UserInfo userInfo = this.selectById(uid);
|
UserInfo userInfo1 = userInfoMapper.queryByPhone(phone);
|
if(null != userInfo1){
|
userInfo1.setOpenId(userInfo.getOpenId());
|
userInfo1.setUnionid(userInfo.getUnionid());
|
userInfo1.setAppletsOpenId(userInfo.getAppletsOpenId());
|
userInfo1.setAvatar(userInfo.getAvatar());
|
userInfo1.setSex(userInfo.getSex());
|
userInfo1.setNickName(userInfo.getNickName());
|
this.updateById(userInfo1);
|
|
if(loginType.equals("Applets")){//小程序登录后绑定手机号码
|
String value = redisUtil.getValue("appletOpenId");
|
JSONObject jsonObject = null;
|
if(ToolUtil.isNotEmpty(value)){
|
jsonObject = JSON.parseObject(value);
|
jsonObject.remove(userInfo.getId().toString());//删除原有账号缓存的数据
|
}else{
|
jsonObject = new JSONObject();
|
}
|
jsonObject.put(userInfo1.getId().toString(), userInfo.getAppletsOpenId());
|
redisUtil.setStrValue("appletOpenId", jsonObject.toJSONString());
|
}
|
|
|
|
this.deleteById(userInfo.getId());//删除原有数据
|
//还原之前账号领取的注册优惠券
|
List<UserCouponRecord> list = userCouponRecordService.selectList(new EntityWrapper<UserCouponRecord>().eq("userId", userInfo.getId()));
|
for(UserCouponRecord ucr : list){
|
if(ucr.getActivityType() == 1){//赠送
|
|
}
|
if(ucr.getActivityType() == 2){//注册
|
UserActivityRegistered userActivityRegistered = userActivityRegisteredService.selectById(ucr.getCouponActivityId());
|
userActivityRegistered.setLaveNum(userActivityRegistered.getLaveNum() + 1);
|
userActivityRegistered.setLavePrice(userActivityRegistered.getLavePrice() + ucr.getMoney());
|
userActivityRegisteredService.updateById(userActivityRegistered);
|
}
|
if(ucr.getActivityType() == 3){//邀请
|
|
}
|
if(ucr.getActivityType() == 4){//充值
|
|
}
|
userCouponRecordService.deleteById(ucr.getId());
|
}
|
|
|
//获取新的token等数据
|
String token = this.getToken(userInfo1, "",loginType);
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo1.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setPhone(2);
|
return ResultUtil.success(loginWarpper);
|
}
|
|
userInfo.setPhone(phone);
|
userInfo.setUpdateTime(new Date());
|
userInfo.setUpdateUser(userInfo.getId());
|
this.updateById(userInfo);
|
|
smsrecordService.saveData(2, phone, code, "短信验证码【" + code + "】已发到您的手机，验证码将在5分钟后失效，请及时登录!");
|
return ResultUtil.success(new LoginWarpper());
|
}
|
|
|
/**
|
* 从redis中获取数据
|
* @param request
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public Integer getUserIdFormRedis(HttpServletRequest request) throws Exception {
|
String requestHeader = request.getHeader(JwtConstants.AUTH_HEADER);
|
if (requestHeader != null && requestHeader.startsWith("Bearer ")) {
|
requestHeader = requestHeader.substring(requestHeader.indexOf(" ") + 1);
|
String key = null;
|
int length = requestHeader.length();
|
if(length > 32){
|
key = requestHeader.substring(length - 32);
|
}else{
|
key = requestHeader;
|
}
|
String value = redisUtil.getValue(key);
|
return null != value ? Integer.valueOf(value) : null;
|
}else{
|
return null;
|
}
|
}
|
|
|
/**
|
* 获取用户详情
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public Map<String, Object> queryUserInfo(Integer uid) throws Exception {
|
return userInfoMapper.queryUserInfo(uid, null);
|
}
|
|
|
/**
|
* 电话号码查询用户
|
* @param phone
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public Map<String, Object> queryUser(String phone) throws Exception {
|
return userInfoMapper.queryUserInfo(null, phone);
|
}
|
|
|
/**
|
* 设置紧急联系人
|
* @param name
|
* @param phone
|
* @param uid
|
* @throws Exception
|
*/
|
@Override
|
public void setUrgentUser(String name, String phone, Integer uid) throws Exception {
|
userInfoMapper.setUrgentUser(name, phone, uid);
|
}
|
|
|
/**
|
* 充值余额
|
* @param payType
|
* @param money
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil depositBalance(Integer payType, Double money, Integer uid, Integer type) throws Exception {
|
UserInfo userInfo = userInfoMapper.selectById(uid);
|
if(money.compareTo(0D) <= 0){
|
return ResultUtil.error("支付金额必须大于0元");
|
}
|
if(payType == 1){//微信支付
|
// String value = redisUtil.getValue("appletOpenId");
|
// String appletsOpenId = null;
|
// if(ToolUtil.isNotEmpty(value)){
|
// JSONObject jsonObject = JSON.parseObject(value);
|
// appletsOpenId = jsonObject.getString(uid.toString());
|
// }else{
|
// appletsOpenId = userInfo.getAppletsOpenId();
|
// }
|
Integer integer = paymentRecordService.saveData(2, uid, 1, null, null, 1, money, "", 1);//添加预支付数据
|
String app = (type == 1 ? "APP" : "JSAPI");
|
System.err.println(app);
|
return payMoneyUtil.weixinpay("余额充值", uid.toString(), integer.toString(), money.toString(), "/base/wxCancelUserBalance", app, userInfo.getAppletsOpenId());
|
|
// String value = redisUtil.getValue("appletOpenId");
|
// String appletsOpenId = null;
|
// if(ToolUtil.isNotEmpty(value)){
|
// JSONObject jsonObject = JSON.parseObject(value);
|
// appletsOpenId = jsonObject.getString(uid.toString());
|
// }else{
|
// appletsOpenId = userInfo.getAppletsOpenId();
|
// }
|
// Integer integer = paymentRecordService.saveData(2, uid, 1, null, null, 1, money, "", 1);//添加预支付数据
|
// Map<String, String> map = icbcPayUtil.placeAnOrder(integer.toString(), 9, 5, uid.toString(), "余额充值", money, callbackPath + "/base/wxCancelUserBalance", uid.toString(), type, appletsOpenId);
|
// if(map.get("code").equals("200")){
|
// PaymentRecord paymentRecord = paymentRecordService.selectById(integer);
|
// paymentRecord.setCode(map.get("order_id"));
|
// paymentRecordService.updateById(paymentRecord);
|
// return ResultUtil.success(map.get("data"));
|
// }else{
|
// return ResultUtil.error(map.get("msg"), "");
|
// }
|
}
|
if(payType == 2){//支付宝支付
|
Integer integer = paymentRecordService.saveData(2, uid, 1, null, null, 2, money, "", 1);//添加预支付数据
|
|
return payMoneyUtil.alipay("余额充值", "余额充值", uid.toString(), integer.toString(), money.toString(), "/base/aliCancelUserBalance");
|
// Integer integer = paymentRecordService.saveData(2, uid, 1, null, null, 2, money, "", 1);//添加预支付数据
|
// Map<String, String> map = icbcPayUtil.placeAnOrder(integer.toString(), 10, 5, uid.toString(), "余额充值", money, callbackPath + "/base/aliCancelUserBalance", uid.toString(), type, null);
|
// if(map.get("code").equals("200")){
|
// PaymentRecord paymentRecord = paymentRecordService.selectById(integer);
|
// paymentRecord.setCode(map.get("order_id"));
|
// paymentRecordService.updateById(paymentRecord);
|
// return ResultUtil.success(map.get("data"));
|
// }else{
|
// return ResultUtil.error(map.get("msg"), "");
|
// }
|
}
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 修改手机号码
|
* @param code
|
* @param phone
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil updatePhone(String code, String phone, Integer uid) throws Exception {
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
return ResultUtil.error("验证码无效");
|
}
|
UserInfo userInfo = this.selectById(uid);
|
UserInfo userInfo1 = userInfoMapper.queryByPhone(phone);
|
if(null != userInfo1){
|
return ResultUtil.error("手机号已被注册");
|
}
|
userInfo.setPhone(phone);
|
this.updateById(userInfo);
|
|
// smsrecordService.saveData(2, phone, code, "短信验证码【" + code + "】已发到您的手机，验证码将在5分钟后失效，请及时登录!");
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 修改密码
|
* @param password
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil updatePass(String password, Integer uid) throws Exception {
|
UserInfo userInfo = this.selectById(uid);
|
userInfo.setPassWord(ShiroKit.md5(password, salt));
|
this.updateById(userInfo);
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 修改个人信息
|
* @param avatar
|
* @param nickname
|
* @param sex
|
* @param birthday
|
* @param uid
|
* @throws Exception
|
*/
|
@Override
|
public void updateInfo(String avatar, String nickname, Integer sex, Date birthday, Integer uid) throws Exception {
|
UserInfo userInfo = this.selectById(uid);
|
if(ToolUtil.isNotEmpty(avatar)){
|
userInfo.setAvatar(avatar);
|
}
|
if(ToolUtil.isNotEmpty(nickname)){
|
userInfo.setNickName(nickname);
|
}
|
if(null != sex){
|
userInfo.setSex(sex);
|
}
|
if(null != birthday){
|
userInfo.setBirthday(birthday);
|
}
|
this.updateById(userInfo);
|
}
|
|
|
/**
|
* 获取实名认证数据
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public Map<String, Object> queryRealName(Integer uid) throws Exception {
|
return userInfoMapper.queryRealName(uid);
|
}
|
|
|
/**
|
* 完成余额充值后的处理
|
* @param id 用户id
|
* @param order_id 工行订单id
|
* @param type 支付类型（1=微信，2=支付宝）
|
* @throws Exception
|
*/
|
@Override
|
public void payCancelUserBalance(Integer id, String order_id, Integer paymentRecordId, Integer type) throws Exception {
|
UserInfo userInfo = this.selectById(id);
|
PaymentRecord query = paymentRecordService.selectById(paymentRecordId);
|
if(null != query){
|
//添加交易明细
|
transactionDetailsService.saveData(Integer.valueOf(id), "余额充值", query.getAmount(), 2, 1, 1, 5, null);
|
double v = new BigDecimal(userInfo.getBalance()).add(new BigDecimal(query.getAmount())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
|
userInfo.setBalance(v);
|
this.updateById(userInfo);
|
|
query.setCode(order_id);
|
query.setState(2);
|
paymentRecordService.updateById(query);
|
|
this.addCoupon(userInfo.getId(), query.getAmount(), userInfo.getCompanyId(), query.getId());//添加优惠券
|
|
}else{
|
System.err.println("预支付数据异常（userId = " + id + ")");
|
}
|
|
}
|
|
|
/**
|
* H5接入道行龙城实现登录
|
* @param authCode
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil<LoginWarpper> dxlcLogin(String authCode, String registAreaCode,String loginType) throws Exception {
|
Map<String, Object> map = new HashMap<>();
|
//生成环境
|
String path = "https://open.brightcns.com";
|
map.put("clientId", "4821416759766550929");
|
map.put("clientSecret", "yuDyNoOuFeknuLGbLSsWZoaLtHGQaelobgmMlbpgquyAacyBXomwDDSgErKWtDwy");
|
//测试环境
|
// String path = "https://open.test.brightcns.cn";
|
// map.put("clientId", "4818328904840251536");
|
// map.put("clientSecret", "JZrYSBvtVlIRbnsnoJuaqheRWAEHcEJVgeAeIHAUojwUwZIAVzSpAWxgozhfPbcq");
|
map.put("grantType", "authorization_code");
|
map.put("authCode", authCode);
|
String get = httpClientUtil.pushHttpRequset("GET", path + "/api/oauth/accessToken", map, null, "");
|
System.err.print("获取accessToken：" + get);
|
JSONObject jsonObject = JSON.parseObject(get);
|
Boolean success = jsonObject.getBoolean("success");
|
String code = jsonObject.getString("code");
|
if(success && "SUCCESS".equals(code)){
|
JSONObject data = jsonObject.getJSONObject("data");
|
String accessToken = data.getString("accessToken");
|
String userId = data.getString("userId");
|
String refreshToken = data.getString("refreshToken");
|
Map<String, String> userInfo = this.getUserInfo(accessToken);
|
if(null == userInfo){
|
return ResultUtil.error("获取用户信息失败");
|
}
|
return this.captchaLogin(userInfo.get("phone"), "1234", null, registAreaCode, loginType);
|
}else{
|
return ResultUtil.error(jsonObject.getString("msg"));
|
}
|
}
|
|
/**
|
* 小程序使用手机号登录绑定微信
|
* @param userId
|
* @param jscode
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil phoneLoginBindingWeChat(Integer userId, String jscode) throws Exception {
|
Map<String, String> map = weChatUtil.code2Session(jscode);
|
String openid = map.get("openid");
|
String unionid = map.get("unionid");
|
//将当前小程序openid存储到缓存中用后面的支付时使用
|
String value = redisUtil.getValue("appletOpenId");
|
JSONObject jsonObject = null;
|
if(ToolUtil.isNotEmpty(value)){
|
jsonObject = JSON.parseObject(value);
|
}else{
|
jsonObject = new JSONObject();
|
}
|
jsonObject.put(userId.toString(), openid);
|
redisUtil.setStrValue("appletOpenId", jsonObject.toJSONString());
|
return ResultUtil.success();
|
}
|
|
public Map<String, String> getUserInfo(String accessToken){
|
String path = "https://open.brightcns.com";//生产环境
|
// String path = "https://open.test.brightcns.cn";//测试环境
|
Map<String, Object> map = new HashMap<>();
|
map.put("accessToken", accessToken);
|
String get = httpClientUtil.pushHttpRequset("GET", path + "/api/userinfo", map, null, "");
|
System.err.print("获取用户信息：" + get);
|
JSONObject jsonObject = JSON.parseObject(get);
|
Boolean success = jsonObject.getBoolean("success");
|
String code = jsonObject.getString("code");
|
if(success && "SUCCESS".equals(code)){
|
Map<String, String> map1 = new HashMap<>();
|
JSONObject data = jsonObject.getJSONObject("data");
|
map1.put("userId", data.getString("userId"));
|
map1.put("phone", data.getString("phone"));
|
map1.put("userName", data.getString("userName"));
|
return map1;
|
}
|
return null;
|
}
|
|
|
|
/**
|
* 添加充值活动优惠券
|
* @param userId
|
* @param money
|
* @param companyId
|
* @throws Exception
|
*/
|
public synchronized void addCoupon(Integer userId, Double money, Integer companyId, Integer paymentRecordId) throws Exception{
|
List<Map<String, Object>> query = userActivityBalanceService.query(money, companyId);
|
List<UserCouponRecord> list = new ArrayList<>();
|
for(Map<String, Object> map : query){
|
//添加通用优惠券
|
Double lavePrice = Double.valueOf(String.valueOf(map.get("lavePrice")));
|
if(null != map.get("bcompanyId")){
|
for(int i = 0; i < Integer.valueOf(String.valueOf(map.get("generalNum"))); i++){
|
//判断当前发放的优惠券是否大于剩余总发放金额
|
if(Double.valueOf(String.valueOf(map.get("bmoney"))).compareTo(lavePrice) > 0){
|
break;
|
}
|
UserCouponRecord userCouponRecord = new UserCouponRecord();
|
userCouponRecord.setUserId(userId);
|
userCouponRecord.setCompanyId(Integer.valueOf(String.valueOf(map.get("bcompanyId"))));
|
userCouponRecord.setMoney(Double.valueOf(String.valueOf(map.get("bmoney"))));
|
userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(map.get("bfullMoney"))));
|
userCouponRecord.setInsertTime(new Date());
|
userCouponRecord.setState(1);
|
userCouponRecord.setCouponUseType(Integer.valueOf(String.valueOf(map.get("bcouponUseType"))));
|
userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(map.get("bcouponType"))));
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(map.get("beffective"))));
|
userCouponRecord.setExpirationTime(calendar.getTime());
|
userCouponRecord.setPaymentRecordId(paymentRecordId);
|
userCouponRecord.setActivityType(4);
|
userCouponRecord.setCouponActivityId(Integer.valueOf(String.valueOf(map.get("id"))));
|
userCouponRecord.setCouponId(Integer.valueOf(String.valueOf(map.get("bId"))));
|
list.add(userCouponRecord);
|
//开始修改剩余总发放金额
|
lavePrice -= Double.valueOf(String.valueOf(map.get("bmoney")));
|
}
|
}
|
|
//专车优惠券
|
if(null != map.get("ccompanyId")){
|
for(int i = 0; i < Integer.valueOf(String.valueOf(map.get("specialNum"))); i++){
|
//判断当前发放的优惠券是否大于剩余总发放金额
|
if(Double.valueOf(String.valueOf(map.get("cmoney"))).compareTo(lavePrice) > 0){
|
break;
|
}
|
UserCouponRecord userCouponRecord = new UserCouponRecord();
|
userCouponRecord.setUserId(userId);
|
userCouponRecord.setCompanyId(Integer.valueOf(String.valueOf(map.get("ccompanyId"))));
|
userCouponRecord.setMoney(Double.valueOf(String.valueOf(map.get("cmoney"))));
|
userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(map.get("cfullMoney"))));
|
userCouponRecord.setInsertTime(new Date());
|
userCouponRecord.setState(1);
|
userCouponRecord.setCouponUseType(Integer.valueOf(String.valueOf(map.get("ccouponUseType"))));
|
userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(map.get("ccouponType"))));
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(map.get("ceffective"))));
|
userCouponRecord.setExpirationTime(calendar.getTime());
|
userCouponRecord.setPaymentRecordId(paymentRecordId);
|
userCouponRecord.setActivityType(4);
|
userCouponRecord.setCouponActivityId(Integer.valueOf(String.valueOf(map.get("id"))));
|
userCouponRecord.setCouponId(Integer.valueOf(String.valueOf(map.get("cId"))));
|
list.add(userCouponRecord);
|
//开始修改剩余总发放金额
|
lavePrice -= Double.valueOf(String.valueOf(map.get("cmoney")));
|
}
|
}
|
|
//出租车优惠券
|
if(null != map.get("dcompanyId")){
|
for(int i = 0; i < Integer.valueOf(String.valueOf(map.get("taxiNum"))); i++){
|
//判断当前发放的优惠券是否大于剩余总发放金额
|
if(Double.valueOf(String.valueOf(map.get("dmoney"))).compareTo(lavePrice) > 0){
|
break;
|
}
|
UserCouponRecord userCouponRecord = new UserCouponRecord();
|
userCouponRecord.setUserId(userId);
|
userCouponRecord.setCompanyId(Integer.valueOf(String.valueOf(map.get("dcompanyId"))));
|
userCouponRecord.setMoney(Double.valueOf(String.valueOf(map.get("dmoney"))));
|
userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(map.get("dfullMoney"))));
|
userCouponRecord.setInsertTime(new Date());
|
userCouponRecord.setState(1);
|
userCouponRecord.setCouponUseType(Integer.valueOf(String.valueOf(map.get("dcouponUseType"))));
|
userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(map.get("dcouponType"))));
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(map.get("deffective"))));
|
userCouponRecord.setExpirationTime(calendar.getTime());
|
userCouponRecord.setPaymentRecordId(paymentRecordId);
|
userCouponRecord.setActivityType(4);
|
userCouponRecord.setCouponActivityId(Integer.valueOf(String.valueOf(map.get("id"))));
|
userCouponRecord.setCouponId(Integer.valueOf(String.valueOf(map.get("dId"))));
|
list.add(userCouponRecord);
|
//开始修改剩余总发放金额
|
lavePrice -= Double.valueOf(String.valueOf(map.get("dmoney")));
|
}
|
}
|
|
//跨城优惠券
|
if(null != map.get("ecompanyId")){
|
for(int i = 0; i < Integer.valueOf(String.valueOf(map.get("intercityNum"))); i++){
|
//判断当前发放的优惠券是否大于剩余总发放金额
|
if(Double.valueOf(String.valueOf(map.get("emoney"))).compareTo(lavePrice) > 0){
|
break;
|
}
|
UserCouponRecord userCouponRecord = new UserCouponRecord();
|
userCouponRecord.setUserId(userId);
|
userCouponRecord.setCompanyId(Integer.valueOf(String.valueOf(map.get("ecompanyId"))));
|
userCouponRecord.setMoney(Double.valueOf(String.valueOf(map.get("emoney"))));
|
userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(map.get("efullMoney"))));
|
userCouponRecord.setInsertTime(new Date());
|
userCouponRecord.setState(1);
|
userCouponRecord.setCouponUseType(Integer.valueOf(String.valueOf(map.get("ecouponUseType"))));
|
userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(map.get("ecouponType"))));
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(map.get("eeffective"))));
|
userCouponRecord.setExpirationTime(calendar.getTime());
|
userCouponRecord.setPaymentRecordId(paymentRecordId);
|
userCouponRecord.setActivityType(4);
|
userCouponRecord.setCouponActivityId(Integer.valueOf(String.valueOf(map.get("id"))));
|
userCouponRecord.setCouponId(Integer.valueOf(String.valueOf(map.get("eId"))));
|
list.add(userCouponRecord);
|
//开始修改剩余总发放金额
|
lavePrice -= Double.valueOf(String.valueOf(map.get("emoney")));
|
}
|
}
|
UserActivityBalance uab = userActivityBalanceService.selectById(Integer.valueOf(map.get("id").toString()));
|
uab.setLavePrice(new BigDecimal(lavePrice).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
userActivityBalanceService.updateById(uab);
|
|
if(list.size() > 0){
|
userCouponRecordService.insertBatch(list);
|
}
|
}
|
}
|
|
|
|
/**
|
* 获取默认名称
|
* @return
|
*/
|
public String getDefaultName(){
|
int num = this.selectCount(new EntityWrapper<UserInfo>().ne("flag", 3)) + 1000001;
|
return "WL" + String.valueOf(num).substring(1);
|
}
|
|
|
/**
|
* 获取token
|
* @param userInfo
|
* @param password
|
* @return
|
*/
|
private String getToken(UserInfo userInfo, String password,String type) throws Exception{
|
if(ToolUtil.isEmpty(type))type="APP";
|
//封装请求账号密码为shiro可验证的token
|
UsernamePasswordToken usernamePasswordToken = new UsernamePasswordToken(userInfo.getPhone(), password.toCharArray());
|
String credentials = userInfo.getPassWord();
|
ByteSource credentialsSalt = new Md5Hash(salt);
|
SimpleAuthenticationInfo simpleAuthenticationInfo = new SimpleAuthenticationInfo(
|
new ShiroUser(), credentials, credentialsSalt, "");
|
|
//校验用户账号密码
|
HashedCredentialsMatcher md5CredentialsMatcher = new HashedCredentialsMatcher();
|
md5CredentialsMatcher.setHashAlgorithmName(ShiroKit.hashAlgorithmName);
|
md5CredentialsMatcher.setHashIterations(ShiroKit.hashIterations);
|
boolean passwordTrueFlag = md5CredentialsMatcher.doCredentialsMatch(
|
usernamePasswordToken, simpleAuthenticationInfo);
|
String s = JwtTokenUtil.generateToken(String.valueOf(userInfo.getId()));
|
redisUtil.setStrValue(s.substring(s.length() - 32), String.valueOf(userInfo.getId()), 180 * 24 * 60 * 60);
|
redisUtil.setStrValue("USER_"+type+"_" + userInfo.getPhone(), s.substring(s.length() - 32));
|
redisUtil.setStrValue("USER_"+type +"_"+ userInfo.getId(), s);
|
return s;
|
}
|
|
|
/**
|
* 注册时查询活动添加优惠券
|
* @param userInfo
|
* @throws Exception
|
*/
|
private synchronized void addCoupon(UserInfo userInfo) throws Exception{
|
//添加优惠券
|
List<Map<String, Object>> list = userActivityRegisteredService.query(userInfo.getCompanyId());
|
int num = 0;
|
for(Map<String, Object> map : list){
|
if(null != map){
|
Integer totalNum = Integer.valueOf(String.valueOf(map.get("totalNum")));
|
Double lavePrice = Double.valueOf(String.valueOf(map.get("lavePrice")));
|
for(int i = totalNum; i > 0; i--){
|
//判断当前发放的优惠券是否大于剩余可发送总金额
|
if(Double.valueOf(String.valueOf(map.get("money"))).compareTo(lavePrice) > 0){
|
break;
|
}
|
UserCouponRecord userCouponRecord = new UserCouponRecord();
|
userCouponRecord.setUserId(userInfo.getId());
|
userCouponRecord.setCompanyId(Integer.valueOf(String.valueOf(map.get("companyId"))));
|
userCouponRecord.setMoney(Double.valueOf(String.valueOf(map.get("money"))));
|
userCouponRecord.setFullMoney(Double.valueOf(String.valueOf(map.get("fullMoney"))));
|
userCouponRecord.setInsertTime(new Date());
|
userCouponRecord.setState(1);
|
userCouponRecord.setCouponUseType(Integer.valueOf(String.valueOf(map.get("couponUseType"))));
|
userCouponRecord.setCouponType(Integer.valueOf(String.valueOf(map.get("couponType"))));
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
Integer integer = Integer.valueOf(String.valueOf(null != map.get("effective") ? map.get("effective") : "0"));
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + integer);
|
userCouponRecord.setExpirationTime(calendar.getTime());
|
userCouponRecord.setCouponId(Integer.valueOf(String.valueOf(map.get("couponId"))));
|
userCouponRecord.setCouponActivityId(Integer.valueOf(String.valueOf(map.get("id"))));
|
userCouponRecord.setActivityType(2);
|
userCouponRecordService.insert(userCouponRecord);
|
//修改剩余可发放总金额
|
lavePrice -= Double.valueOf(String.valueOf(map.get("money")));
|
num++;
|
}
|
UserActivityRegistered uar = userActivityRegisteredService.selectById(Integer.valueOf(map.get("id").toString()));
|
uar.setLavePrice(new BigDecimal(lavePrice).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
userActivityRegisteredService.updateById(uar);
|
}
|
}
|
//添加系统消息
|
systemNoticeService.addSystemNotice(1, "您已获得" + num + "张优惠券，点击查看", userInfo.getId(), 2);
|
}
|
|
|
/**
|
* 单点登录
|
* @param id
|
*/
|
private void singlePointLogin(Integer id,String type) throws Exception{
|
if(ToolUtil.isEmpty(type))type="APP";
|
//开始验证当前账号是否在别处登录
|
String value = redisUtil.getValue("USER_"+type+"_" + id);
|
if(ToolUtil.isNotEmpty(value)){//将另外设备上的强迫下线
|
//开始清除redis中无效的数据
|
UserInfo userInfo = userInfoMapper.selectById(id);
|
String key = redisUtil.getValue("USER_"+type+"_" + userInfo.getPhone());
|
redisUtil.remove(key);//删除个人信息数据
|
redisUtil.remove("USER_"+type+"_" + userInfo.getPhone());//删除后台冻结相关缓存
|
redisUtil.remove("USER_"+type+"_" + id);//清除存储的token
|
}
|
}
|
}
|
