茅台预约app程序 茅台酒预约系统 多账户自动预约程序源码 茅台批量预约软件.zip

package com.oddfar.campus.business.service.impl; import cn.hutool.core.convert.Convert; import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; import cn.hutool.crypto.Mode; import cn.hutool.crypto.Padding; import cn.hutool.crypto.symmetric.AES; import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpResponse; import cn.hutool.http.HttpUtil; import cn.hutool.http.Method; import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; import com.oddfar.campus.business.entity.IUser; import com.oddfar.campus.business.mapper.IUserMapper; import com.oddfar.campus.business.service.IMTLogFactory; import com.oddfar.campus.business.service.IMTService; import com.oddfar.campus.business.service.IShopService; import com.oddfar.campus.business.service.IUserService; import com.oddfar.campus.common.core.RedisCache; import com.oddfar.campus.common.exception.ServiceException; import com.oddfar.campus.common.utils.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import javax.annotation.PostConstruct; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; import java.util.regex.Matcher; import java.util.regex.Pattern; @Service public class IMTServiceImpl implements IMTService { private static final Logger logger = LoggerFactory.getLogger(IMTServiceImpl.class); @Autowired private IUserMapper iUserMapper; @Autowired private RedisCache redisCache; @Autowired private IUserService iUserService; @Autowired private IShopService iShopService; private final static String SALT = "2af72f100c356273d46284f6fd1dfc08"; private final static String AES_KEY = "qbhajinldepmucsonaaaccgypwuvcjaa"; private final static String AES_IV = "2018534749963515"; /** * 项目启动时，初始化数据 */ @PostConstruct public void init() { new Thread(new Runnable() { @Override public void run() { refreshAll(); } }).start(); } @Override public String getMTVersion() { String mtVersion = Convert.toStr(redisCache.getCacheObject("mt_version")); if (StringUtils.isNotEmpty(mtVersion)) { return mtVersion; } String url = "https://apps.apple.com/cn/app/i%E8%8C%85%E5%8F%B0/id1600482450"; String htmlContent = HttpUtil.get(url); Pattern pattern = Pattern.compile("new__latest__version\">(.*?)</p>", Pattern.DOTALL); Matcher matcher = pattern.matcher(htmlContent); if (matcher.find()) { mtVersion = matcher.group(1); mtVersion = mtVersion.replace("版本 ", ""); } redisCache.setCacheObject("mt_version", mtVersion); return mtVersion; } @Override public void refreshMTVersion() { redisCache.deleteObject("mt_version"); getMTVersion(); } @Override public Boolean sendCode(String mobile, String deviceId) { Map<String, Object> data = new HashMap<>(); data.put("mobile", mobile); data.put("md5", signature(mobile)); data.put("timestamp", String.valueOf(System.currentTimeMillis())); // data.put("MT-APP-Version", MT_VERSION); HttpRequest request = HttpUtil.createRequest(Method.POST, "https://app.moutai519.com.cn/xhr/front/user/register/vcode"); request.header("MT-Device-ID", deviceId); request.header("MT-APP-Version", getMTVersion()); request.header("User-Agent", "iOS;16.3;Apple;?unrecognized?"); request.header("Content-Type", "application/json"); HttpResponse execute = request.body(JSONObject.toJSONString(data)).execute(); JSONObject jsonObject = JSONObject.parseObject(execute.body()); //成功返回 {"code":2000} logger.info("「发送验证码返回」：" + jsonObject.toJSONString()); if (jsonObject.getString("code").equals("2000")) { return Boolean.TRUE; } else { logger.error("「发送验证码-失败」：" + jsonObject.toJSONString()); throw new ServiceException("发送验证码错误"); // return false; } } @Override public boolean login(String mobile, String code, String deviceId) { Map<String, String> map = new HashMap<>(); map.put("mobile", mobile); map.put("vCode", code); map.put("md5", signature(mobile + code + "" + "")); map.put("timestamp", String.valueOf(System.currentTimeMillis())); map.put("MT-APP-Version", getMTVersion()); HttpRequest request = HttpUtil.createRequest(Method.POST, "https://app.moutai519.com.cn/xhr/front/user/register/login"); IUser user = iUserMapper.selectById(mobile); if (user != null) { deviceId = user.getDeviceId(); } request.header("MT-Device-ID", deviceId); request.header("MT-APP-Version", getMTVersion()); request.header("User-Agent", "iOS;16.3;Apple;?unrecognized?"); request.header("Content-Type", "application/json"); HttpResponse execute = request.body(JSONObject.toJSONString(map)).execute(); JSONObject body = JSONObject.parseObject(execute.body()); if (body.getString("code").equals("2000")) { // logger.info("「登录请求-成功」" + body.toJSONString()); iUserService.insertIUser(Long.parseLong(mobile), deviceId, body); return true; } else { logger.error("「登录请求-失败」" + body.toJSONString()); throw new ServiceException("登录失败，本地错误日志已记录"); // return false; } } @Override public void reservation(IUser iUser) { if (StringUtils.isEmpty(iUser.getItemCode())) { return; } String[] items = iUser.getItemCode().split("@"); String logContent = ""; for (String itemId : items) { try { String shopId = iShopService.getShopId(iUser.getShopType(), itemId, iUser.getProvinceName(), iUser.getCityName(), iUser.getLat(), iUser.getLng()); //预约 JSONObject json = reservation(iUser, itemId, shopId); logContent += String.format("[预约项目]：%s\n[shopId]：%s\n[结果返回]：%s\n\n", itemId, shopId, json.toString()); } catch (Exception e) { logContent += String.format("执行报错--[预约项目]：%s\n[结果返回]：%s\n\n", itemId, e.getMessage()); } } // try { // //预约后领取耐力值 // String energyAward = getEnergyAward(iUser); // logContent += "[申购耐力值]:" + energyAward; // } catch (Exception e) { // logContent += "执行报错--[申购耐力值]:" + e.getMessage(); // } //日志记录 IMTLogFactory.reservation(iUser, logContent); //预约后延迟领取耐力值 getEnergyAwardDelay(iUser); } /** * 延迟执行：获取申购耐力值，并记录日志 * * @param iUser */ public void getEnergyAwardDelay(IUser iUser) { Runnable runnable = new Runnable() { @Override public void run() { String logContent = ""; //sleep 10秒 try { Thread.sleep(10000); //预约后领取耐力值 String energyAward = getEnergyAward(iUser);