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.JwtTokenUtil;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
import com.stylefeng.guns.modular.system.dao.DriverActivityRegisteredMapper;
|
import com.stylefeng.guns.modular.system.dao.DriverMapper;
|
import com.stylefeng.guns.modular.system.dao.UserActivityInviteMapper;
|
import com.stylefeng.guns.modular.system.dao.UserInfoMapper;
|
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.util.GoogleMap.AddressComponentsVo;
|
import com.stylefeng.guns.modular.system.util.GoogleMap.GoogleMapUtil;
|
import com.stylefeng.guns.modular.system.util.GoogleMap.ReverseGeocodeVo;
|
import com.stylefeng.guns.modular.system.util.Tingg.TinggPayUtil;
|
import com.stylefeng.guns.modular.system.util.Tingg.model.CheckoutRequest;
|
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.jsoup.Jsoup;
|
import org.jsoup.nodes.Document;
|
import org.jsoup.nodes.Element;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.File;
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
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;
|
|
@Resource
|
private DriverMapper driverMapper;
|
|
@Resource
|
private DriverActivityRegisteredMapper driverActivityRegisteredMapper;
|
|
@Autowired
|
private IIncomeService incomeService;
|
|
@Autowired
|
private PushUtil pushUtil;
|
|
@Autowired
|
private ISystemNoticeService systemNoticeService;
|
|
@Autowired
|
private PayMoneyUtil payMoneyUtil;
|
|
@Autowired
|
private IBankCardService bankCardService;
|
|
@Value("${callbackPath}")
|
private String callbackPath;
|
|
@Value("${spring.mail.template-path}")
|
private String templatePath;
|
|
private String salt = "&a.s";
|
|
|
/**
|
* 获取短信验证码
|
* @param phone
|
* @return
|
*/
|
@Override
|
public ResultUtil queryCaptcha(String phone, Integer type, Integer language) throws Exception {
|
Random random = new Random();
|
Object value = redisUtil.getValue(phone);
|
if(value==null){
|
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 templateId = "";
|
switch (language){
|
case 1:
|
templateId = "b793ae3d41a049059197bfe92cf8bc83";
|
break;
|
case 2:
|
templateId = "058c7d11ce594d668841cceb49fb5c9a";
|
break;
|
case 3:
|
templateId = "4edbe604da6546808ffda582085b3c83";
|
break;
|
}
|
SMSUtil.send_huawei_sms(templateId, "+" + phone, "[\"" + authCode + "\"]");
|
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("1246".equals(code)){
|
return true;
|
}
|
|
if(null != value && code.equals(String.valueOf(value))){
|
return true;
|
}else{
|
return false;
|
}
|
}
|
|
/**
|
* 手机验证码登录
|
* @param phone
|
* @param code
|
* @param uid 分享用户的id
|
* @param type 分享用户的来源
|
* @return
|
*/
|
@Override
|
public ResultUtil<LoginWarpper> captchaLogin(String phoneOperator, String phone, String code, String registIp, Double lat, Double lng,Integer uid,Integer type,
|
Integer userType, Integer language) throws Exception {
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
return ResultUtil.error(language == 1 ? "验证码无效" : language == 2 ? "Invalid captcha" : "Code de vérification invalide");
|
}
|
|
UserInfo userInfo = userInfoMapper.queryByPhone(phone);
|
if(null == userInfo){
|
userInfo = new UserInfo();
|
userInfo.setPhoneOperator(phoneOperator);
|
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);
|
|
//用户所属企业
|
if(null != lat && null != lng){
|
ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(lat, lat);
|
AddressComponentsVo[] addressComponentsVos = reverseGeocode.getAddressComponentsVos();
|
String[] citys = new String[addressComponentsVos.length];
|
for (int i = 0; i < addressComponentsVos.length; i++) {
|
citys[i] = addressComponentsVos[i].getLongName();
|
}
|
Company query = companyCityService.query(citys);
|
userInfo.setCompanyId(null != query ? query.getId() : null);
|
userInfo.setRegistAreaCode(null);
|
}else{
|
userInfo.setCompanyId(1);
|
}
|
Double money = this.userInfoMapper.queryFreeMOney();
|
if(money!=null){
|
userInfo.setFreeMoney(BigDecimal.valueOf(money));
|
}
|
if(null!=uid){
|
userInfo.setUid(uid);
|
}
|
if(null!=type){
|
userInfo.setuType(type);
|
}
|
|
this.insert(userInfo);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/register.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(1 == language){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element user_english = document.getElementById("user_english");
|
user_english.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "注册成功" : language == 2 ? "Successful registration" : "Inscription réussie", document.html());
|
}
|
|
this.addCoupon(userInfo, language);//添加优惠券
|
if(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(map.get("money"))));
|
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(driver.getActivityMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setLaveActivityMoney(bigDecimal.add(new BigDecimal(driver.getLaveActivityMoney())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driver.setBalance(bigDecimal.add(new BigDecimal(driver.getBalance())).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
|
driverMapper.updateById(driver);
|
|
if(ToolUtil.isNotEmpty(driver.getEmail())){
|
String path1 = templatePath + "driver/index.html";
|
Document document1 = Jsoup.parse(new File(path1), "UTF-8");
|
if(1 == language){
|
document1.getElementById("english").remove();
|
document1.getElementById("french").remove();
|
document1.getElementById("invite").remove();
|
document1.getElementById("settle").remove();
|
document1.getElementById("pass").remove();
|
document1.getElementById("bill").remove();
|
document1.getElementById("reward").remove();
|
document1.getElementById("rewardToday").remove();
|
|
Element user_user = document1.getElementById("user_user");
|
user_user.text("您好 " + driver.getFirstName() + " " + driver.getLastName() + "，");
|
Element user_content = document1.getElementById("user_content");
|
user_content.text("您已成功邀请一位用户注册I-GO，获得奖励GHS " + bigDecimal.doubleValue() + "，请查收");
|
}
|
if(2 == language){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
document1.getElementById("invite1").remove();
|
document1.getElementById("settle1").remove();
|
document1.getElementById("pass1").remove();
|
document1.getElementById("bill1").remove();
|
document1.getElementById("reward1").remove();
|
document1.getElementById("rewardToday1").remove();
|
|
Element user1_user = document1.getElementById("user1_user");
|
user1_user.text("Hello " + driver.getFirstName() + " " + driver.getLastName() + "，");
|
Element user1_content = document1.getElementById("user1_content");
|
user1_content.text("You have succeeded to invite a rider to register with I-GO, so you received a GHS " + bigDecimal.doubleValue() + " bonus, please check your balance.");
|
}
|
if(3 == language){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
document1.getElementById("invite1").remove();
|
document1.getElementById("settle1").remove();
|
document1.getElementById("pass1").remove();
|
document1.getElementById("bill1").remove();
|
document1.getElementById("reward1").remove();
|
document1.getElementById("rewardToday1").remove();
|
|
Element user2_user = document1.getElementById("user2_user");
|
user2_user.text("Bonjour " + driver.getFirstName() + " " + driver.getLastName() + "，");
|
Element user2_content = document1.getElementById("user2_content");
|
user2_content.text("Vous avez invité avec succès un utilisateur à s’inscrire à i-go pour recevoir une récompense GHS " + bigDecimal.doubleValue() + ". Veuillez vérifier");
|
}
|
EmailUtil.send(driver.getEmail(), language == 1 ? "邀请奖励" : language == 2 ? "invitation bonus" : "prime d'invitation", document1.html());
|
}
|
}
|
if(type == 1){//用户分享
|
UserInfo userInfo1 = userInfoMapper.selectById(uid);
|
List<Map<String, Object>> query = userActivityInviteMapper.query(userInfo1.getCompanyId());
|
Date date = new Date();
|
for(Map<String, Object> map : query){
|
Double lavePrice = Double.valueOf(map.get("lavePrice").toString());
|
String startTime = map.get("startTime").toString();
|
String endTime = map.get("endTime").toString();
|
int num = 0;
|
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(userInfo1.getCompanyId());
|
userCouponRecord.setUserId(uid);
|
userCouponRecordService.insert(userCouponRecord);
|
//修改剩余可发放总金额
|
lavePrice -= Double.valueOf(String.valueOf(map.get("money")));
|
num++;
|
}
|
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);
|
|
if(ToolUtil.isNotEmpty(userInfo1.getEmail())){
|
String path1 = templatePath + "user/coupon.html";
|
Document document1 = Jsoup.parse(new File(path1), "UTF-8");
|
if(language == 1){
|
document1.getElementById("english").remove();
|
document1.getElementById("french").remove();
|
Element chinese_user = document1.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo1.getNickName() + "，");
|
Element chinese_number = document1.getElementById("chinese_number");
|
chinese_number.text("您有" + num + "张优惠券到账");
|
Element chinese_date = document1.getElementById("chinese_date");
|
chinese_date.text("此活动有效期在" + startTime + "至" + endTime + "，详情请查看I-GO平台");
|
}
|
if(language == 2){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
Element english_user = document1.getElementById("english_user");
|
english_user.text("Hello " + userInfo1.getNickName() + "，");
|
Element english_number = document1.getElementById("english_number");
|
english_number.text("You have received " + num + " coupons");
|
Element english_date = document1.getElementById("english_date");
|
english_date.text("You could use them from" + startTime + "to" + endTime);
|
}
|
if(language == 3){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
Element french_user = document1.getElementById("french_user");
|
french_user.text("Bonjour " + userInfo1.getNickName() + "，");
|
Element french_number = document1.getElementById("french_number");
|
french_number.text("Vous avez " + num + " coupons à recevoir");
|
Element french_date = document1.getElementById("french_date");
|
french_date.text("Cette promotion est valide du" + startTime + "au" + endTime);
|
}
|
EmailUtil.send(userInfo1.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon arrives" : "Le coupon arrive", document1.html());
|
}
|
|
}
|
}
|
}
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId());
|
|
String token = this.getToken(userInfo, "");
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
loginWarpper.setEmail(userInfo.getEmail());
|
|
smsrecordService.saveData(1, phone, code, "短信验证码【" + code + "】已发到您的手机，验证码将在5分钟后失效，请及时登录!");
|
return ResultUtil.success(loginWarpper);
|
}
|
|
@Override
|
public synchronized ResultUtil<LoginWarpper> captchaLogin(String phoneOperator, String phone, String code, Integer uid, Integer type, Integer userType, Integer language) throws Exception {
|
ResultUtil<LoginWarpper> resultUtil = this.captchaLogin(phoneOperator, phone, code, null, null, null,uid,type,userType,language);
|
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, Integer language) throws Exception {
|
UserInfo userInfo = this.queryByPhone(phone);
|
if(null == userInfo){
|
return ResultUtil.error(language == 1 ? "账号无效" : language == 2 ? "Invalid account" : "Compte non valide");
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error(language == 1 ? "账号被冻结" : language == 2 ? "Account is frozen." : "Le compte est gelé");
|
}
|
if(!ShiroKit.md5(password, salt).equals(userInfo.getPassWord())){
|
return ResultUtil.error(language == 1 ? "密码错误" : language == 2 ? "Password error" : "Mot de passe incorrect");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId());
|
|
String token = this.getToken(userInfo, password);
|
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,
|
String encryptedData, String iv,Integer uid, Integer language) throws Exception {
|
UserInfo userInfo = null;
|
String phone=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);
|
if(null==userInfo){
|
String result= weChatUtil.decrypt1(encryptedData,map.get("sessionKey"),iv);
|
JSONObject json=JSONObject.parseObject(result);
|
|
if (!ToolUtil.isEmpty(result) && result.length()>0) {
|
userInfo = userInfoMapper.queryByPhone(json.getString("phoneNumber"));
|
phone=json.getString("phoneNumber");
|
}
|
}
|
if(null!=userInfo && !openid.equals(userInfo.getAppletsOpenId())){
|
userInfo.setAppletsOpenId(openid);
|
userInfo.setUnionid(unionid);
|
userInfo.setNickName(ToolUtil.isNotEmpty(nickName) ? nickName : this.getDefaultName());
|
userInfo.setAvatar(avatar);
|
userInfoMapper.updateById(userInfo);
|
}
|
|
|
}else{//APP
|
userInfo = userInfoMapper.queryByOpenid(openid);
|
}
|
if(null == userInfo){
|
userInfo = new UserInfo();
|
userInfo.setPassWord(ShiroKit.md5("", salt));
|
userInfo.setRegistIp(registIp);
|
userInfo.setSex(sex);
|
userInfo.setPhone(phone);
|
userInfo.setNickName(ToolUtil.isNotEmpty(nickName) ? nickName : this.getDefaultName());
|
userInfo.setAvatar(avatar);
|
Double money = this.userInfoMapper.queryFreeMOney();
|
if(money!=null){
|
userInfo.setFreeMoney(BigDecimal.valueOf(money));
|
}
|
if(null!=uid){
|
userInfo.setUid(uid);
|
//微信登录只能是乘客用户分享
|
userInfo.setuType(1);
|
}
|
|
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);
|
userInfo.setCompanyId(1);
|
this.insert(userInfo);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/register.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(1 == language){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element user_english = document.getElementById("user_english");
|
user_english.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "注册成功" : language == 2 ? "Successful registration" : "Inscription réussie", document.html());
|
}
|
|
|
this.addCoupon(userInfo, language);//添加优惠券
|
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId());
|
|
String token = this.getToken(userInfo, "");
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setPhone(ToolUtil.isNotEmpty(userInfo.getPhone()) ? 2 : 1);
|
loginWarpper.setEmail(userInfo.getEmail());
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
if(uid!=null){
|
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());
|
String startTime = map.get("startTime").toString();
|
String endTime = map.get("endTime").toString();
|
int num = 0;
|
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")));
|
num++;
|
}
|
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);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/coupon.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(language == 1){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element chinese_user = document.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.getNickName() + "，");
|
Element chinese_number = document.getElementById("chinese_number");
|
chinese_number.text("您有" + num + "张优惠券到账");
|
Element chinese_date = document.getElementById("chinese_date");
|
chinese_date.text("此活动有效期在" + startTime + "至" + endTime + "，详情请查看I-GO平台");
|
}
|
if(language == 2){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element english_user = document.getElementById("english_user");
|
english_user.text("Hello " + userInfo.getNickName() + "，");
|
Element english_number = document.getElementById("english_number");
|
english_number.text("You have received " + num + " coupons");
|
Element english_date = document.getElementById("english_date");
|
english_date.text("You could use them from" + startTime + "to" + endTime);
|
}
|
if(language == 3){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element french_user = document.getElementById("french_user");
|
french_user.text("Bonjour " + userInfo.getNickName() + "，");
|
Element french_number = document.getElementById("french_number");
|
french_number.text("Vous avez " + num + " coupons à recevoir");
|
Element french_date = document.getElementById("french_date");
|
french_date.text("Cette promotion est valide du" + startTime + "au" + endTime);
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon arrives" : "Le coupon arrive", document.html());
|
}
|
}
|
}
|
return ResultUtil.success(loginWarpper);
|
}
|
@Override
|
public ResultUtil<LoginWarpper> wxIsLogin(String jscode) throws Exception {
|
UserInfo userInfo = null;
|
String phone=null;
|
if(ToolUtil.isEmpty(jscode)){
|
return ResultUtil.error("微信登录请求失败，请重试");
|
}
|
Map<String, String> map = weChatUtil.code2Session(jscode);
|
String openid = map.get("openid");
|
String unionid = map.get("unionid");
|
userInfo = userInfoMapper.queryByOpenid2(openid);
|
if(null==userInfo){
|
return ResultUtil.getResult(2000,"微信登录请求失败，请重试");
|
}
|
|
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId());
|
|
String token = this.getToken(userInfo, "");
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setPhone(ToolUtil.isNotEmpty(userInfo.getPhone()) ? 2 : 1);
|
loginWarpper.setEmail(userInfo.getEmail());
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
return ResultUtil.success(loginWarpper);
|
}
|
|
|
@Override
|
public ResultUtil facebookLogin(String id, String name, String email, Double lat, Double lng, Integer uid, Integer language) throws Exception {
|
UserInfo userInfo = this.selectOne(new EntityWrapper<UserInfo>().eq("faceBookId", id).ne("flag", 3));
|
if(null == userInfo){
|
userInfo = new UserInfo();
|
userInfo.setEmail(email);
|
userInfo.setNickName(name);
|
userInfo.setIsAuth(1);
|
userInfo.setConsumption(0D);
|
userInfo.setBalance(0D);
|
userInfo.setIntegral(0);
|
userInfo.setPassWord(ShiroKit.md5("", salt));
|
userInfo.setFaceBookId(id);
|
userInfo.setState(1);
|
userInfo.setFlag(1);
|
userInfo.setInsertTime(new Date());
|
userInfo.setFreeMoney(new BigDecimal(0));
|
|
Double money = this.userInfoMapper.queryFreeMOney();
|
if(money!=null){
|
userInfo.setFreeMoney(BigDecimal.valueOf(money));
|
}
|
if(null!=uid){
|
userInfo.setUid(uid);
|
//微信登录只能是乘客用户分享
|
userInfo.setuType(1);
|
}
|
//用户所属企业
|
if(null != lat && null != lng){
|
ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(lat, lng);
|
if(null != reverseGeocode){
|
AddressComponentsVo[] addressComponentsVos = reverseGeocode.getAddressComponentsVos();
|
String[] citys = new String[addressComponentsVos.length];
|
for (int i = 0; i < addressComponentsVos.length; i++) {
|
citys[i] = addressComponentsVos[i].getLongName();
|
}
|
Company query = companyCityService.query(citys);
|
userInfo.setCompanyId(null != query ? query.getId() : null);
|
userInfo.setRegistAreaCode(null);
|
}
|
|
}
|
this.insert(userInfo);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/register.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(1 == language){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element user_english = document.getElementById("user_english");
|
user_english.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "注册成功" : language == 2 ? "Successful registration" : "Inscription réussie", document.html());
|
}
|
|
|
this.addCoupon(userInfo, language);//添加优惠券
|
}
|
|
if(userInfo.getState() == 2){
|
return ResultUtil.error("账号被冻结");
|
}
|
|
//调用单点登录的逻辑
|
this.singlePointLogin(userInfo.getId());
|
|
String token = this.getToken(userInfo, "");
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setPhone(ToolUtil.isNotEmpty(userInfo.getPhone()) ? 2 : 1);
|
loginWarpper.setEmail(userInfo.getEmail());
|
loginWarpper.setEmergencyContact(userInfo.getEmergencyContact());
|
loginWarpper.setEmergencyContactNumber(userInfo.getEmergencyContactNumber());
|
if(uid!=null){
|
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());
|
String startTime = map.get("startTime").toString();
|
String endTime = map.get("endTime").toString();
|
int num = 0;
|
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")));
|
num++;
|
}
|
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);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/coupon.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(language == 1){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element chinese_user = document.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.getNickName() + "，");
|
Element chinese_number = document.getElementById("chinese_number");
|
chinese_number.text("您有" + num + "张优惠券到账");
|
Element chinese_date = document.getElementById("chinese_date");
|
chinese_date.text("此活动有效期在" + startTime + "至" + endTime + "，详情请查看I-GO平台");
|
}
|
if(language == 2){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element english_user = document.getElementById("english_user");
|
english_user.text("Hello " + userInfo.getNickName() + "，");
|
Element english_number = document.getElementById("english_number");
|
english_number.text("You have received " + num + " coupons");
|
Element english_date = document.getElementById("english_date");
|
english_date.text("You could use them from" + startTime + "to" + endTime);
|
}
|
if(language == 3){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element french_user = document.getElementById("french_user");
|
french_user.text("Bonjour " + userInfo.getNickName() + "，");
|
Element french_number = document.getElementById("french_number");
|
french_number.text("Vous avez " + num + " coupons à recevoir");
|
Element french_date = document.getElementById("french_date");
|
french_date.text("Cette promotion est valide du" + startTime + "au" + endTime);
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon arrives" : "Le coupon arrive", document.html());
|
}
|
}
|
}
|
return ResultUtil.success(loginWarpper);
|
}
|
|
/**
|
* 忘记密码操作
|
* @param phone
|
* @param code
|
* @param password
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil forgetPassword(String phone, String code, String password, Integer language) throws Exception {
|
UserInfo userInfo = this.queryByPhone(phone);
|
if(null == userInfo){
|
return ResultUtil.error(language == 1 ? "手机号码未注册" : language == 2 ? "Cell phone number is not registered" : "Numéro de téléphone portable non enregistré");
|
}
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
b = this.checkCaptcha(userInfo.getEmail(), code);
|
}
|
if(!b){
|
return ResultUtil.error(language == 1 ? "验证码无效" : language == 2 ? "Invalid captcha" : "Code de vérification invalide");
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error(language == 1 ? "账号已被冻结" : language == 2 ? "The account has been frozen" : "Le compte a été gelé");
|
}
|
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 phoneOperator, String phone, String code, Integer language) throws Exception {
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
return ResultUtil.error(language == 1 ? "验证码无效" : language == 2 ? "Invalid captcha" : "Code de vérification invalide");
|
}
|
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);
|
|
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, "");
|
LoginWarpper loginWarpper = new LoginWarpper();
|
loginWarpper.setId(userInfo1.getId());
|
loginWarpper.setToken(token);
|
loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
loginWarpper.setPhone(2);
|
loginWarpper.setEmail(userInfo1.getEmail());
|
return ResultUtil.success(loginWarpper);
|
}
|
|
userInfo.setPhoneOperator(phoneOperator);
|
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());
|
}
|
|
|
@Override
|
public ResultUtil bindingEmail(Integer uid, Integer type, String email, String code, Integer language) throws Exception {
|
boolean b = this.checkCaptcha(email, code);
|
if(!b){
|
return ResultUtil.error(language == 1 ? "验证码无效" : language == 2 ? "Invalid captcha" : "Code de vérification invalide");
|
}
|
UserInfo userInfo = this.selectById(uid);
|
UserInfo userInfo1 = userInfoMapper.queryByEmail(email);
|
if(null != userInfo1 && uid.compareTo(userInfo1.getId()) != 0){
|
return ResultUtil.error(language == 1 ? "邮箱已被使用" : language == 2 ? "The mailbox is in use" : "La boîte mail a déjà été utilisée");
|
}
|
|
// 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);
|
//
|
// 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, "");
|
// LoginWarpper loginWarpper = new LoginWarpper();
|
// loginWarpper.setId(userInfo1.getId());
|
// loginWarpper.setToken(token);
|
// loginWarpper.setAppid(UUIDUtil.getRandomCode());
|
// loginWarpper.setPhone(2);
|
// loginWarpper.setEmail(userInfo1.getEmail());
|
// return ResultUtil.success(loginWarpper);
|
// }
|
|
userInfo.setEmail(email);
|
userInfo.setUpdateTime(new Date());
|
userInfo.setUpdateUser(userInfo.getId());
|
this.updateById(userInfo);
|
// if(type == 1){//注册成功后发送邮件
|
//// EmailUtil.getMimeMessage(email, "注册账户", "");
|
// }
|
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, String bankCardId, Double money, Integer uid, Integer type, Integer language) throws Exception {
|
UserInfo userInfo = userInfoMapper.selectById(uid);
|
if(money.compareTo(0D) <= 0){
|
return ResultUtil.error("支付金额必须大于0元", "");
|
}
|
if(payType == 1){//手机支付
|
Integer integer = paymentRecordService.saveData(2, uid, 1, null, null, 1, money, "", 1);//添加预支付数据
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
String merchantTransactionId = sdf.format(new Date()) + language + integer;
|
CheckoutRequest checkoutRequest = new CheckoutRequest();
|
checkoutRequest.setMsisdn(Long.valueOf(userInfo.getPhone()));
|
checkoutRequest.setCustomerEmail(userInfo.getEmail());
|
checkoutRequest.setAccountNumber(userInfo.getPhone());
|
checkoutRequest.setCustomerFirstName(userInfo.getFirstName());
|
checkoutRequest.setCustomerLastName(userInfo.getLastName());
|
checkoutRequest.setRequestAmount(money);
|
checkoutRequest.setMerchantTransactionId(merchantTransactionId);
|
checkoutRequest.setRequestDescription("Account top-up");
|
checkoutRequest.setCallbackUrl(callbackPath + "/base/wxCancelUserBalance");
|
checkoutRequest.setPendingRedirectUrl("");
|
checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html");
|
checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html");
|
return TinggPayUtil.checkoutRequest(checkoutRequest);
|
}
|
|
if(payType == 2){//银行卡支付
|
Integer integer = paymentRecordService.saveData(2, uid, 1, null, null, 1, money, "", 1);//添加预支付数据
|
BankCard bankCard = bankCardService.selectById(bankCardId);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
String merchantTransactionId = sdf.format(new Date()) + language + integer;
|
CheckoutRequest checkoutRequest = new CheckoutRequest();
|
checkoutRequest.setMsisdn(Long.valueOf(bankCard.getCode()));
|
checkoutRequest.setCustomerEmail(userInfo.getEmail());
|
checkoutRequest.setAccountNumber(bankCard.getCode());
|
checkoutRequest.setCustomerFirstName(bankCard.getFirstName());
|
checkoutRequest.setCustomerLastName(bankCard.getLastName());
|
checkoutRequest.setRequestAmount(money);
|
checkoutRequest.setMerchantTransactionId(merchantTransactionId);
|
checkoutRequest.setRequestDescription("Account top-up");
|
checkoutRequest.setCallbackUrl(callbackPath + "/base/wxCancelUserBalance");
|
checkoutRequest.setPendingRedirectUrl("");
|
checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html");
|
checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html");
|
return TinggPayUtil.checkoutRequest(checkoutRequest);
|
}
|
return ResultUtil.success("");
|
}
|
|
|
/**
|
* 修改手机号码
|
* @param code
|
* @param phone
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil updatePhone(String code, String phoneOperator, String phone, Integer uid, Integer language) throws Exception {
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
return ResultUtil.error(language == 1 ? "验证码无效" : language == 2 ? "Invalid captcha" : "Code de vérification invalide");
|
}
|
UserInfo userInfo = this.selectById(uid);
|
UserInfo userInfo1 = userInfoMapper.queryByPhone(phone);
|
if(null != userInfo1){
|
return ResultUtil.error(language == 1 ? "手机号已被注册" : language == 2 ? "The phone number has been registered" : "Le numéro de téléphone a été enregistré");
|
}
|
userInfo.setPhoneOperator(phoneOperator);
|
userInfo.setPhone(phone);
|
this.updateById(userInfo);
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 修改密码
|
* @param password
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil updatePass(String password, Integer uid, Integer language) throws Exception {
|
UserInfo userInfo = this.selectById(uid);
|
userInfo.setPassWord(ShiroKit.md5(password, salt));
|
this.updateById(userInfo);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/passwordReset.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(1 == language){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element user_chinese = document.getElementById("user_english");
|
user_chinese.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "重置密码" : language == 2 ? "Reset password" : "Réinitialiser le mot de passe", document.html());
|
}
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 修改个人信息
|
* @param avatar
|
* @param nickname
|
* @param sex
|
* @param birthday
|
* @param uid
|
* @throws Exception
|
*/
|
@Override
|
public ResultUtil updateInfo(String avatar, String nickname, Integer sex, Date birthday, String email, String code, String lastName, String firstName, Integer uid, Integer language) 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);
|
}
|
if(null != email){
|
String value = redisUtil.getValue(email);
|
if(ToolUtil.isEmpty(value) || code.equals(value)){
|
return ResultUtil.error(language == 1 ? "验证码无效" : language == 2 ? "Invalid captcha" : "Code de vérification invalide");
|
}
|
userInfo.setEmail(email);
|
}
|
if(null != lastName){
|
userInfo.setLastName(lastName);
|
}
|
if(null != firstName){
|
userInfo.setFirstName(firstName);
|
}
|
this.updateById(userInfo);
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 获取实名认证数据
|
* @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
|
* @throws Exception
|
*/
|
@Override
|
public void payCancelUserBalance(Integer id, String order_id, Integer paymentRecordId, Integer language) throws Exception {
|
PaymentRecord query = paymentRecordService.selectById(paymentRecordId);
|
UserInfo userInfo = this.selectById(query.getUserId());
|
if(null != query){
|
//添加交易明细
|
transactionDetailsService.saveData(Integer.valueOf(query.getUserId()), "余额充值", 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(), language);//添加优惠券
|
|
}else{
|
System.err.println("预支付数据异常（paymentRecordId = " + paymentRecordId + ")");
|
}
|
|
}
|
|
|
|
/**
|
* 添加充值活动优惠券
|
* @param userId
|
* @param money
|
* @param companyId
|
* @throws Exception
|
*/
|
public synchronized void addCoupon(Integer userId, Double money, Integer companyId, Integer paymentRecordId, Integer language) 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")));
|
String startTime = map.get("startTime").toString();
|
String endTime = map.get("endTime").toString();
|
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);
|
|
UserInfo userInfo = userInfoMapper.selectById(userId);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/coupon.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(language == 1){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element chinese_user = document.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.getNickName() + "，");
|
Element chinese_number = document.getElementById("chinese_number");
|
chinese_number.text("您有" + list.size() + "张优惠券到账");
|
Element chinese_date = document.getElementById("chinese_date");
|
chinese_date.text("此活动有效期在" + startTime + "至" + endTime + "，详情请查看I-GO平台");
|
}
|
if(language == 2){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element english_user = document.getElementById("english_user");
|
english_user.text("Hello " + userInfo.getNickName() + "，");
|
Element english_number = document.getElementById("english_number");
|
english_number.text("You have received " + list.size() + " coupons");
|
Element english_date = document.getElementById("english_date");
|
english_date.text("You could use them from" + startTime + "to" + endTime);
|
}
|
if(language == 3){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element french_user = document.getElementById("french_user");
|
french_user.text("Bonjour " + userInfo.getNickName() + "，");
|
Element french_number = document.getElementById("french_number");
|
french_number.text("Vous avez " + list.size() + " coupons à recevoir");
|
Element french_date = document.getElementById("french_date");
|
french_date.text("Cette promotion est valide du" + startTime + "au" + endTime);
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon arrives" : "Le coupon arrive", document.html());
|
}
|
}
|
}
|
}
|
|
|
|
/**
|
* 获取默认名称
|
* @return
|
*/
|
public String getDefaultName(){
|
int num = this.selectCount(new EntityWrapper<UserInfo>().ne("flag", 3)) + 1000001;
|
return "IGO" + String.valueOf(num).substring(1);
|
}
|
|
|
/**
|
* 获取token
|
* @param userInfo
|
* @param password
|
* @return
|
*/
|
private String getToken(UserInfo userInfo, String password) throws Exception{
|
//封装请求账号密码为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()), 7 * 24 * 60 * 60);
|
redisUtil.setStrValue("USER_" + userInfo.getPhone(), s.substring(s.length() - 32));
|
redisUtil.setStrValue("USER_" + userInfo.getId(), s);
|
return s;
|
}
|
|
|
/**
|
* 注册时查询活动添加优惠券
|
* @param userInfo
|
* @throws Exception
|
*/
|
private synchronized void addCoupon(UserInfo userInfo, Integer language) 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")));
|
String startTime = map.get("startTime").toString();
|
String endTime = map.get("endTime").toString();
|
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);
|
|
if(ToolUtil.isNotEmpty(userInfo.getEmail())){
|
String path = templatePath + "user/coupon.html";
|
Document document = Jsoup.parse(new File(path), "UTF-8");
|
if(language == 1){
|
document.getElementById("english").remove();
|
document.getElementById("french").remove();
|
Element chinese_user = document.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.getNickName() + "，");
|
Element chinese_number = document.getElementById("chinese_number");
|
chinese_number.text("您有" + num + "张优惠券到账");
|
Element chinese_date = document.getElementById("chinese_date");
|
chinese_date.text("此活动有效期在" + startTime + "至" + endTime + "，详情请查看I-GO平台");
|
}
|
if(language == 2){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
Element english_user = document.getElementById("english_user");
|
english_user.text("Hello " + userInfo.getNickName() + "，");
|
Element english_number = document.getElementById("english_number");
|
english_number.text("You have received " + num + " coupons");
|
Element english_date = document.getElementById("english_date");
|
english_date.text("You could use them from" + startTime + "to" + endTime);
|
}
|
if(language == 3){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
Element french_user = document.getElementById("french_user");
|
french_user.text("Bonjour " + userInfo.getNickName() + "，");
|
Element french_number = document.getElementById("french_number");
|
french_number.text("Vous avez " + list.size() + " coupons à recevoir");
|
Element french_date = document.getElementById("french_date");
|
french_date.text("Cette promotion est valide du" + startTime + "au" + endTime);
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon arrives" : "Le coupon arrive", document.html());
|
}
|
}
|
}
|
//添加系统消息
|
systemNoticeService.addSystemNotice(1, "您已获得" + num + "张优惠券，点击查看", userInfo.getId(), 2);
|
}
|
|
|
/**
|
* 单点登录
|
* @param id
|
*/
|
private void singlePointLogin(Integer id) throws Exception{
|
//开始验证当前账号是否在别处登录
|
String value = redisUtil.getValue("USER_" + id);
|
if(ToolUtil.isNotEmpty(value)){//将另外设备上的强迫下线
|
//开始清除redis中无效的数据
|
UserInfo userInfo = userInfoMapper.selectById(id);
|
String key = redisUtil.getValue("USER_" + userInfo.getPhone());
|
redisUtil.remove(key);//删除个人信息数据
|
redisUtil.remove("USER_" + userInfo.getPhone());//删除后台冻结相关缓存
|
redisUtil.remove("USER_" + id);//清除存储的token
|
}
|
}
|
|
@Override
|
public List<Map<String, Object>> queryMyInviteList(Integer type, Integer uid, Integer pageNum, Integer size) {
|
pageNum = (pageNum - 1) * size;
|
if(type==1){
|
//乘客表uType为1表示是乘客邀请的
|
return userInfoMapper.queryMyInviteUserList(1,uid,pageNum,size);
|
}else if(type==2){
|
//司机表uType为1表示是乘客邀请的
|
return driverMapper.queryMyInviteDriverList(1,uid, pageNum, size);
|
}
|
return null;
|
}
|
|
@Override
|
public Integer getAppOpenInfo(Integer type) {
|
return userInfoMapper.getAppOpenInfo(type);
|
}
|
|
@Override
|
public Integer queryLanguage(Integer uid, Integer language) {
|
UserInfo userInfo = this.selectById(uid);
|
if(null != userInfo.getLanguage()){
|
language = userInfo.getLanguage();
|
}
|
if(null == language){
|
language = 2;
|
}
|
return language;
|
}
|
}
|
