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.*;
|
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.util.itextpdf.HtmlToPdfUtils;
|
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 org.springframework.web.bind.annotation.RequestBody;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.*;
|
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;
|
|
@Autowired
|
private DateUtil dateUtil;
|
|
@Resource
|
private DriverActivityRegisteredMapper driverActivityRegisteredMapper;
|
|
@Resource
|
private DriverActivityHistoryMapper driverActivityHistoryMapper;
|
|
@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";
|
|
@Autowired
|
private SMSUtil smsUtil;
|
|
@Autowired
|
private TEmailService emailService;
|
|
|
/**
|
* 获取短信验证码
|
* @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 = "";
|
|
//发送验证码短信
|
redisUtil.setStrValue(phone, authCode, 5 * 60);//设置五分钟过期
|
switch (language){
|
case 1:
|
// sms = "您的验证码为：" + authCode + "，该验证码5分钟内有效，请勿泄漏于他人！";
|
sms = "Your verification code is " + authCode + ", it is valid within 5 minutes, please do not reveal it to others.";
|
break;
|
case 2:
|
sms = "Your verification code is " + authCode + ", it is valid within 5 minutes, please do not reveal it to others.";
|
break;
|
case 3:
|
sms = "Votre code de validation est " + authCode + " et il est valide pendant 5 minutes. Veuillez ne pas le révéler à d’autres personnes.";
|
break;
|
}
|
smsUtil.sendCellulantMessage(phone, sms);
|
smsrecordService.saveData(type, phone, authCode, 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);
|
redisUtil.remove(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" : "CAPTCHA non valide");
|
}
|
|
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, null);
|
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();
|
document.getElementsByTag("title").get(0).text("注册成功");
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
document.getElementsByTag("title").get(0).text("Registered successfully");
|
Element user_english = document.getElementById("user_english");
|
user_english.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
document.getElementsByTag("title").get(0).text("Enregistré avec succès");
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès", document.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/registration_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/registration_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
|
this.addCoupon(userInfo, language);//添加优惠券
|
if(null != uid){
|
if(type == 2){//司机分享
|
Driver driver = driverMapper.selectById(uid);
|
Map<String, Date> date = dateUtil.getStartAndEndDate(new Date());
|
//邀请用户注册
|
List<DriverActivityHistory> list = driverActivityHistoryMapper.queryList(uid, 2, 1, date.get("startTime"), date.get("endTime"));
|
BigDecimal bigDecimal = new BigDecimal("0");
|
for (DriverActivityHistory driverActivityHistory : list) {
|
bigDecimal = bigDecimal.add(new BigDecimal(driverActivityHistory.getMoney()));
|
incomeService.saveData(2, driver.getId(), 1, driverActivityHistory.getId(), null, driverActivityHistory.getMoney());
|
driverActivityHistory.setCarryOut(2);
|
driverActivityHistoryMapper.updateById(driverActivityHistory);
|
}
|
|
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();
|
|
document1.getElementsByTag("title").get(0).text("司机奖励通知");
|
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();
|
|
document1.getElementsByTag("title").get(0).text("Reward-driver notice");
|
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();
|
|
document1.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense");
|
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 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/invitation_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/invitation_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(driver.getId());
|
tEmail.setType(2);
|
tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
}
|
|
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 = "";
|
String endTime = "";
|
if(null != map.get("startTime")){
|
startTime = map.get("startTime").toString();
|
map.put("startTime", DateUtil.conversionFormat(language, startTime));
|
startTime = DateUtil.conversionFormat(language, startTime);
|
}
|
if(null != map.get("endTime")){
|
endTime = map.get("endTime").toString();
|
map.put("endTime", DateUtil.conversionFormat(language, endTime));
|
endTime = DateUtil.conversionFormat(language, endTime);
|
}
|
int num = 0;
|
double fullMoney = 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++;
|
fullMoney = userCouponRecord.getFullMoney();
|
}
|
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();
|
document1.getElementsByTag("title").get(0).text("优惠券到账");
|
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平台");
|
Element chinese_remark = document1.getElementById("chinese_remark");
|
chinese_remark.text("注意：满减活动，每单消费至少GHS " + fullMoney + "，才可享用。");
|
}
|
if(language == 2){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
document1.getElementsByTag("title").get(0).text("Coupon is in");
|
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);
|
Element english_remark = document1.getElementById("english_remark");
|
english_remark.text("NB! Coupon is valid only for the trip fare not less than GHS " + fullMoney + " per ride.");
|
}
|
if(language == 3){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
document1.getElementsByTag("title").get(0).text("Le coupon est arrivé sur le compte");
|
Element french_user = document1.getElementById("french_user");
|
french_user.text("Cher(ère) " + userInfo1.getNickName() + "，");
|
Element french_number = document1.getElementById("french_number");
|
french_number.text("Vous avez reçu " + num + " coupons.");
|
Element french_date = document1.getElementById("french_date");
|
french_date.text("Vous devriez les utiliser du" + startTime + " au " + endTime + ", voir le détail sur la plate-forme I-GO.");
|
Element french_remark = document1.getElementById("french_remark");
|
french_remark.text("Remarque! Le coupon n'est valable que pour le tarif d'au moins GHS " + fullMoney + " par trajet.");
|
}
|
EmailUtil.send(userInfo1.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/coupon_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/coupon_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
|
}
|
}
|
}
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error(language == 1 ? "账号被冻结" : language == 2 ? "Account is frozen" : "Le compte est gelé");
|
}
|
|
//调用单点登录的逻辑
|
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());
|
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 {
|
boolean b = this.checkCaptcha(phone, code);
|
if(!b){
|
return ResultUtil.error(language == 1 ? "验证码无效" : language == 2 ? "Invalid CAPTCHA" : "CAPTCHA non valide");
|
}
|
|
UserInfo userInfo = userInfoMapper.queryByPhone(phone);
|
if(null != userInfo){
|
return ResultUtil.error(language == 1 ? "手机号已被注册" : language == 2 ? "The mobile phone number has been registered" : "Le numéro de téléphone portable a été enregistré");
|
}
|
if(null == userInfo){
|
userInfo = new UserInfo();
|
userInfo.setPhoneOperator(phoneOperator);
|
userInfo.setPhone(phone);
|
userInfo.setPassWord(ShiroKit.md5("", salt));
|
userInfo.setNickName(this.getDefaultName());
|
userInfo.setRegistIp(null);
|
userInfo.setIsAuth(1);
|
userInfo.setConsumption(0D);
|
userInfo.setBalance(0D);
|
userInfo.setState(1);
|
|
//用户所属企业
|
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();
|
document.getElementsByTag("title").get(0).text("注册成功");
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
document.getElementsByTag("title").get(0).text("Registered successfully");
|
Element user_english = document.getElementById("user_english");
|
user_english.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
document.getElementsByTag("title").get(0).text("Enregistré avec succès");
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès", document.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/registration_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/registration_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
|
this.addCoupon(userInfo, language);//添加优惠券
|
if(null != uid){
|
if(type == 2){//司机分享
|
Driver driver = driverMapper.selectById(uid);
|
Map<String, Date> date = dateUtil.getStartAndEndDate(new Date());
|
//邀请用户注册
|
List<DriverActivityHistory> list = driverActivityHistoryMapper.queryList(uid, 2, 1, date.get("startTime"), date.get("endTime"));
|
BigDecimal bigDecimal = new BigDecimal("0");
|
for (DriverActivityHistory driverActivityHistory : list) {
|
bigDecimal = bigDecimal.add(new BigDecimal(driverActivityHistory.getMoney()));
|
incomeService.saveData(2, driver.getId(), 1, driverActivityHistory.getId(), null, driverActivityHistory.getMoney());
|
driverActivityHistory.setCarryOut(2);
|
driverActivityHistoryMapper.updateById(driverActivityHistory);
|
}
|
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();
|
|
document1.getElementsByTag("title").get(0).text("司机奖励通知");
|
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();
|
|
document1.getElementsByTag("title").get(0).text("Reward-driver notice");
|
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();
|
|
document1.getElementsByTag("title").get(0).text("Avis de chauffeur de récompense");
|
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 ? "Reward-driver notice" : "Avis de chauffeur de récompense", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/invitation_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/invitation_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(driver.getId());
|
tEmail.setType(2);
|
tEmail.setName(language == 1 ? "司机奖励通知" : language == 2 ? "Reward-driver notice" : "Avis de chauffeur de récompense");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
}
|
|
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 = "";
|
String endTime = "";
|
if(null != map.get("startTime")){
|
startTime = map.get("startTime").toString();
|
map.put("startTime", DateUtil.conversionFormat(language, startTime));
|
startTime = DateUtil.conversionFormat(language, startTime);
|
}
|
if(null != map.get("endTime")){
|
endTime = map.get("endTime").toString();
|
map.put("endTime", DateUtil.conversionFormat(language, endTime));
|
endTime = DateUtil.conversionFormat(language, endTime);
|
}
|
int num = 0;
|
double fullMoney = 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++;
|
fullMoney = userCouponRecord.getFullMoney();
|
}
|
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();
|
document1.getElementsByTag("title").get(0).text("优惠券到账");
|
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平台");
|
Element chinese_remark = document1.getElementById("chinese_remark");
|
chinese_remark.text("注意：满减活动，每单消费至少GHS " + fullMoney + "，才可享用。");
|
}
|
if(language == 2){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
document1.getElementsByTag("title").get(0).text("Coupon is in");
|
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);
|
Element english_remark = document1.getElementById("english_remark");
|
english_remark.text("NB! Coupon is valid only for the trip fare not less than GHS " + fullMoney + " per ride.");
|
}
|
if(language == 3){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
document1.getElementsByTag("title").get(0).text("Le coupon est arrivé sur le compte");
|
Element french_user = document1.getElementById("french_user");
|
french_user.text("Cher(ère) " + userInfo1.getNickName() + "，");
|
Element french_number = document1.getElementById("french_number");
|
french_number.text("Vous avez reçu " + num + " coupons.");
|
Element french_date = document1.getElementById("french_date");
|
french_date.text("Vous devriez les utiliser du" + startTime + " au " + endTime + ", voir le détail sur la plate-forme I-GO.");
|
Element french_remark = document1.getElementById("french_remark");
|
french_remark.text("Remarque! Le coupon n'est valable que pour le tarif d'au moins GHS " + fullMoney + " par trajet.");
|
}
|
EmailUtil.send(userInfo1.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/coupon_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/coupon_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
|
}
|
}
|
}
|
}
|
return ResultUtil.success();
|
}
|
|
|
/**
|
* 手机号码查询用户
|
* @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 ? "Wrong password" : "Mot de passe erroné");
|
}
|
|
//调用单点登录的逻辑
|
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.setEmail(userInfo.getEmail());
|
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(language == 1 ? "微信登录请求失败，请重试" : language == 2 ? "WeChat login request failed, please try again." : "La demande de connexion WeChat a échoué, veuillez réessayer.");
|
}
|
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();
|
document.getElementsByTag("title").get(0).text("注册成功");
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
document.getElementsByTag("title").get(0).text("Registered successfully");
|
Element user_english = document.getElementById("user_english");
|
user_english.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
document.getElementsByTag("title").get(0).text("Enregistré avec succès");
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès", document.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/registration_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/registration_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
|
|
this.addCoupon(userInfo, language);//添加优惠券
|
|
}
|
if(userInfo.getState() == 2){
|
return ResultUtil.error(language == 1 ? "账号被冻结" : language == 2 ? "Account is frozen" : "Le compte est gelé");
|
}
|
|
//调用单点登录的逻辑
|
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 = "";
|
String endTime = "";
|
if(null != map.get("startTime")){
|
startTime = map.get("startTime").toString();
|
map.put("startTime", DateUtil.conversionFormat(language, startTime));
|
startTime = DateUtil.conversionFormat(language, startTime);
|
}
|
if(null != map.get("endTime")){
|
endTime = map.get("endTime").toString();
|
map.put("endTime", DateUtil.conversionFormat(language, endTime));
|
endTime = DateUtil.conversionFormat(language, endTime);
|
}
|
int num = 0;
|
double fullMoney = 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++;
|
fullMoney = userCouponRecord.getFullMoney();
|
}
|
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 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();
|
document1.getElementsByTag("title").get(0).text("优惠券到账");
|
Element chinese_user = document1.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.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平台");
|
Element chinese_remark = document1.getElementById("chinese_remark");
|
chinese_remark.text("注意：满减活动，每单消费至少GHS " + fullMoney + "，才可享用。");
|
}
|
if(language == 2){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
document1.getElementsByTag("title").get(0).text("Coupon is in");
|
Element english_user = document1.getElementById("english_user");
|
english_user.text("Hello " + userInfo.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);
|
Element english_remark = document1.getElementById("english_remark");
|
english_remark.text("NB! Coupon is valid only for the trip fare not less than GHS " + fullMoney + " per ride.");
|
}
|
if(language == 3){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
document1.getElementsByTag("title").get(0).text("Le coupon est arrivé sur le compte");
|
Element french_user = document1.getElementById("french_user");
|
french_user.text("Cher(ère) " + userInfo.getNickName() + "，");
|
Element french_number = document1.getElementById("french_number");
|
french_number.text("Vous avez reçu " + num + " coupons.");
|
Element french_date = document1.getElementById("french_date");
|
french_date.text("Vous devriez les utiliser du" + startTime + " au " + endTime + ", voir le détail sur la plate-forme I-GO.");
|
Element french_remark = document1.getElementById("french_remark");
|
french_remark.text("Remarque! Le coupon n'est valable que pour le tarif d'au moins GHS " + fullMoney + " par trajet.");
|
}
|
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/coupon_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/coupon_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
}
|
}
|
return ResultUtil.success(loginWarpper);
|
}
|
@Override
|
public ResultUtil<LoginWarpper> wxIsLogin(Integer language, String jscode) throws Exception {
|
UserInfo userInfo = null;
|
String phone=null;
|
if(ToolUtil.isEmpty(jscode)){
|
return ResultUtil.error(language == 1 ? "微信登录请求失败，请重试" : language == 2 ? "WeChat login request failed, please try again." : "La demande de connexion WeChat a échoué, veuillez réessayer.");
|
}
|
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,language == 1 ? "微信登录请求失败，请重试" : language == 2 ? "WeChat login request failed, please try again." : "La demande de connexion WeChat a échoué, veuillez réessayer.");
|
}
|
|
|
if(userInfo.getState() == 2){
|
return ResultUtil.error(language == 1 ? "账号被冻结" : language == 2 ? "Account is frozen" : "Le compte est gelé");
|
}
|
|
//调用单点登录的逻辑
|
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,int type) throws Exception {
|
UserInfo userInfo=null;
|
if(type==1){
|
userInfo = this.selectOne(new EntityWrapper<UserInfo>().eq("faceBookId", id).ne("flag", 3));
|
}else {
|
userInfo = this.selectOne(new EntityWrapper<UserInfo>().eq("twitterId", 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));
|
if(type==1){
|
userInfo.setFaceBookId(id);
|
}else {
|
userInfo.setTwitterId(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, null);
|
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();
|
document.getElementsByTag("title").get(0).text("注册成功");
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
document.getElementsByTag("title").get(0).text("Registered successfully");
|
Element user_english = document.getElementById("user_english");
|
user_english.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
document.getElementsByTag("title").get(0).text("Enregistré avec succès");
|
Element user_french = document.getElementById("user_french");
|
user_french.text("Bonjour " + userInfo.getNickName() + "，");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès", document.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/registration_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/registration_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "注册成功" : language == 2 ? "Registered successfully" : "Enregistré avec succès");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
this.addCoupon(userInfo, language);//添加优惠券
|
}
|
|
if(userInfo.getState() == 2){
|
return ResultUtil.error(language == 1 ? "账号被冻结" : language == 2 ? "Account is frozen" : "Le compte est gelé");
|
}
|
|
//调用单点登录的逻辑
|
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 = "";
|
String endTime = "";
|
if(null != map.get("startTime")){
|
startTime = map.get("startTime").toString();
|
map.put("startTime", DateUtil.conversionFormat(language, startTime));
|
startTime = DateUtil.conversionFormat(language, startTime);
|
}
|
if(null != map.get("endTime")){
|
endTime = map.get("endTime").toString();
|
map.put("endTime", DateUtil.conversionFormat(language, endTime));
|
endTime = DateUtil.conversionFormat(language, endTime);
|
}
|
int num = 0;
|
double fullMoney = 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++;
|
fullMoney = userCouponRecord.getFullMoney();
|
}
|
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 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();
|
document1.getElementsByTag("title").get(0).text("优惠券到账");
|
Element chinese_user = document1.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.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平台");
|
Element chinese_remark = document1.getElementById("chinese_remark");
|
chinese_remark.text("注意：满减活动，每单消费至少GHS " + fullMoney + "，才可享用。");
|
}
|
if(language == 2){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
document1.getElementsByTag("title").get(0).text("Coupon is in");
|
Element english_user = document1.getElementById("english_user");
|
english_user.text("Hello " + userInfo.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);
|
Element english_remark = document1.getElementById("english_remark");
|
english_remark.text("NB! Coupon is valid only for the trip fare not less than GHS " + fullMoney + " per ride.");
|
}
|
if(language == 3){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
document1.getElementsByTag("title").get(0).text("Le coupon est arrivé sur le compte");
|
Element french_user = document1.getElementById("french_user");
|
french_user.text("Cher(ère) " + userInfo.getNickName() + "，");
|
Element french_number = document1.getElementById("french_number");
|
french_number.text("Vous avez reçu " + num + " coupons.");
|
Element french_date = document1.getElementById("french_date");
|
french_date.text("Vous devriez les utiliser du" + startTime + " au " + endTime + ", voir le détail sur la plate-forme I-GO.");
|
Element french_remark = document1.getElementById("french_remark");
|
french_remark.text("Remarque! Le coupon n'est valable que pour le tarif d'au moins GHS " + fullMoney + " par trajet.");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/coupon_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/coupon_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
}
|
}
|
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 ? "Mobile phone number was not registered." : "Le numéro de téléphone portable n’a pas été 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" : "CAPTCHA non valide");
|
}
|
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);
|
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" : "CAPTCHA non valide");
|
}
|
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);
|
userInfo.setFlag(3);
|
this.updateById(userInfo);//删除原有数据
|
//还原之前账号领取的注册优惠券
|
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);
|
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" : "CAPTCHA non valide");
|
}
|
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 ? "E-mail address is already in use." : "L’adresse e-mail est déjà utilisée.");
|
}
|
userInfo.setEmail(email);
|
userInfo.setUpdateTime(new Date());
|
userInfo.setUpdateUser(userInfo.getId());
|
this.updateById(userInfo);
|
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 language, Integer uid) throws Exception {
|
Map<String, Object> map = userInfoMapper.queryUserInfo(uid, null);
|
if(null != map.get("birthday")){
|
String birthday = map.get("birthday").toString();
|
map.put("birthday", DateUtil.conversionFormat(language, birthday));
|
}
|
Double sum = paymentRecordService.queryRechargeMoneySum(uid);
|
map.put("rechargeAmountSum",sum);
|
return map;
|
}
|
|
|
/**
|
* 电话号码查询用户
|
* @param phone
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public Map<String, Object> queryUser(Integer language, String phone) throws Exception {
|
Map<String, Object> map = userInfoMapper.queryUserInfo(null, phone);
|
if(null == map){
|
return null;
|
}
|
if(null != map.get("birthday")){
|
String birthday = map.get("birthday").toString();
|
map.put("birthday", DateUtil.conversionFormat(language, birthday));
|
}
|
return map;
|
}
|
|
|
/**
|
* 设置紧急联系人
|
* @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(ToolUtil.isEmpty(userInfo.getPhone())){
|
return ResultUtil.error(language == 1 ? "请先绑定手机号码" : language == 2 ? "Please bind your mobile phone number first." : "Veuillez d’abord vous inscrire en liant votre numéro de téléphone portable.");
|
}
|
if(money.compareTo(0D) <= 0){
|
return ResultUtil.error(language == 1 ? "支付金额必须大于0元" : language == 2 ? "Payment amount must be greater than zero." : "Le montant du paiement doit être supérieur à zéro.", "");
|
}
|
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("https://igo.i-go.group/payMoney/pages/success.html");
|
checkoutRequest.setFailRedirectUrl("https://igo.i-go.group/payMoney/pages/fail.html");
|
return TinggPayUtil.checkoutRequest(checkoutRequest);
|
}
|
|
if(payType == 2){//银行卡支付
|
Integer integer = paymentRecordService.saveData(2, uid, 1, null, null, 2, 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("https://igo.i-go.group/payMoney/pages/success.html");
|
checkoutRequest.setFailRedirectUrl("https://igo.i-go.group/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" : "CAPTCHA non valide");
|
}
|
UserInfo userInfo = this.selectById(uid);
|
UserInfo userInfo1 = userInfoMapper.queryByPhone(phone);
|
if(null != userInfo1){
|
return ResultUtil.error(language == 1 ? "手机号已被注册" : language == 2 ? "Mobile phone number has been registered." : "Le numéro de téléphone portable 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();
|
document.getElementsByTag("title").get(0).text("重置密码");
|
Element user_chinese = document.getElementById("user_chinese");
|
user_chinese.text("您好 " + userInfo.getNickName() + "，");
|
}
|
if(2 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("french").remove();
|
document.getElementsByTag("title").get(0).text("Reset password");
|
Element user_chinese = document.getElementById("user_english");
|
user_chinese.text("Hello " + userInfo.getNickName() + "，");
|
}
|
if(3 == language){
|
document.getElementById("chinese").remove();
|
document.getElementById("english").remove();
|
document.getElementsByTag("title").get(0).text("Réinitialiser le mot de passe");
|
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());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/password_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/password_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(uid);
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "重置密码" : language == 2 ? "Reset password" : "Réinitialiser le mot de passe");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
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" : "CAPTCHA non valide");
|
}
|
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, paymentRecordId);
|
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(language, money, companyId);
|
List<UserCouponRecord> list = new ArrayList<>();
|
for(Map<String, Object> map : query){
|
//添加通用优惠券
|
Double lavePrice = Double.valueOf(String.valueOf(map.get("lavePrice")));
|
String startTime = "";
|
String endTime = "";
|
if(null != map.get("startTime")){
|
startTime = map.get("startTime").toString();
|
}
|
if(null != map.get("endTime")){
|
endTime = map.get("endTime").toString();
|
}
|
double fullMoney = 0;
|
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);
|
fullMoney = userCouponRecord.getFullMoney();
|
//开始修改剩余总发放金额
|
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 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();
|
document1.getElementsByTag("title").get(0).text("优惠券到账");
|
Element chinese_user = document1.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.getNickName() + "，");
|
Element chinese_number = document1.getElementById("chinese_number");
|
chinese_number.text("您有" + list.size() + "张优惠券到账");
|
Element chinese_date = document1.getElementById("chinese_date");
|
chinese_date.text("此活动有效期在" + startTime + "至" + endTime + "，详情请查看I-GO平台");
|
Element chinese_remark = document1.getElementById("chinese_remark");
|
chinese_remark.text("注意：满减活动，每单消费至少GHS " + fullMoney + "，才可享用。");
|
}
|
if(language == 2){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
document1.getElementsByTag("title").get(0).text("Coupon is in");
|
Element english_user = document1.getElementById("english_user");
|
english_user.text("Hello " + userInfo.getNickName() + "，");
|
Element english_number = document1.getElementById("english_number");
|
english_number.text("You have received " + list.size() + " coupons");
|
Element english_date = document1.getElementById("english_date");
|
english_date.text("You could use them from " + startTime + " to " + endTime);
|
Element english_remark = document1.getElementById("english_remark");
|
english_remark.text("NB! Coupon is valid only for the trip fare not less than GHS " + fullMoney + " per ride.");
|
}
|
if(language == 3){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
document1.getElementsByTag("title").get(0).text("Le coupon est arrivé sur le compte");
|
Element french_user = document1.getElementById("french_user");
|
french_user.text("Cher(ère) " + userInfo.getNickName() + "，");
|
Element french_number = document1.getElementById("french_number");
|
french_number.text("Vous avez reçu " + list.size() + " coupons.");
|
Element french_date = document1.getElementById("french_date");
|
french_date.text("Vous devriez les utiliser du " + startTime + " au " + endTime + ", voir le détail sur la plate-forme I-GO.");
|
Element french_remark = document1.getElementById("french_remark");
|
french_remark.text("Remarque! Le coupon n'est valable que pour le tarif d'au moins GHS " + fullMoney + " par trajet.");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/coupon_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/coupon_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(userInfo.getId());
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
tEmail.setWeek(EmailUtil.getWeek(language,i));
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
}
|
}
|
}
|
|
|
|
/**
|
* 获取默认名称
|
* @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(language, userInfo.getCompanyId());
|
|
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();
|
double fullMoney = 0;
|
int num = 0;
|
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(0 < num && ToolUtil.isNotEmpty(userInfo.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();
|
document1.getElementsByTag("title").get(0).text("优惠券到账");
|
Element chinese_user = document1.getElementById("chinese_user");
|
chinese_user.text("您好 " + userInfo.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平台");
|
Element chinese_remark = document1.getElementById("chinese_remark");
|
chinese_remark.text("注意：满减活动，每单消费至少GHS " + fullMoney + "，才可享用。");
|
}
|
if(language == 2){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("french").remove();
|
document1.getElementsByTag("title").get(0).text("Coupon is in");
|
Element english_user = document1.getElementById("english_user");
|
english_user.text("Hello " + userInfo.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);
|
Element english_remark = document1.getElementById("english_remark");
|
english_remark.text("NB! Coupon is valid only for the trip fare not less than GHS " + fullMoney + " per ride.");
|
}
|
if(language == 3){
|
document1.getElementById("chinese").remove();
|
document1.getElementById("english").remove();
|
document1.getElementsByTag("title").get(0).text("Le coupon est arrivé sur le compte");
|
Element french_user = document1.getElementById("french_user");
|
french_user.text("Cher(ère) " + userInfo.getNickName() + "，");
|
Element french_number = document1.getElementById("french_number");
|
french_number.text("Vous avez reçu " + num + " coupons.");
|
Element french_date = document1.getElementById("french_date");
|
french_date.text("Vous devriez les utiliser du " + startTime + " au " + endTime + ", voir le détail sur la plate-forme I-GO.");
|
Element french_remark = document1.getElementById("french_remark");
|
french_remark.text("Remarque! Le coupon n'est valable que pour le tarif d'au moins GHS " + fullMoney + " par trajet.");
|
}
|
EmailUtil.send(userInfo.getEmail(), language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte", document1.html());
|
//开始生成pdf收据和html收据
|
File file = new File("/home/igotechgh/nginx/html/files/html/");
|
if(!file.exists()){
|
file.mkdirs();
|
}
|
String randomString = ToolUtil.getRandomString(10);
|
file = new File("/home/igotechgh/nginx/html/files/html/coupon_" + randomString + ".html");
|
if(!file.exists()){
|
file.createNewFile();
|
}
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write(document1.html());
|
fileWriter.flush();
|
fileWriter.close();
|
|
String link ="https://igo.i-go.group/files/html/coupon_" + randomString + ".html";
|
TEmail tEmail = new TEmail();
|
tEmail.setLink(link);
|
tEmail.setUserId(userInfo.getId());
|
tEmail.setType(1);
|
tEmail.setName(language == 1 ? "优惠券到账" : language == 2 ? "Coupon is in" : "Le coupon est arrivé sur le compte");
|
tEmail.setCreateTime(new Date());
|
int i = cn.hutool.core.date.DateUtil.dayOfWeek(new Date())-1;
|
boolean am = cn.hutool.core.date.DateUtil.isAM(new Date());
|
if(am){
|
tEmail.setAmOrPm(language==1?"上午":language==2?"morning":"matin");
|
}else {
|
tEmail.setAmOrPm(language==1?"下午":language==2?"afternoon":"après-midi");
|
}
|
emailService.insert(tEmail);
|
}
|
|
//添加系统消息
|
systemNoticeService.addSystemNotice(1, language == 1 ? "您已获得" + num + "张优惠券，点击查看" : language == 2 ? "You've got " + num + " coupon, click to view" : "Vous avez reçu " + num + " coupon, cliquez pour voir", 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;
|
}
|
}
|
