cloud-server-account/src/main/java/com/dsh/account/model/QueryDataFee.java
New file @@ -0,0 +1,16 @@ package com.dsh.account.model; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import java.util.List; @Data @AllArgsConstructor @NoArgsConstructor public class QueryDataFee { private String data; private List<Integer> ids; } cloud-server-activity/src/main/java/com/dsh/activity/model/QueryDataFee.java
New file @@ -0,0 +1,16 @@ package com.dsh.activity.model; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import java.util.List; @Data @AllArgsConstructor @NoArgsConstructor public class QueryDataFee { private String data; private List<Integer> ids; } cloud-server-competition/src/main/java/com/dsh/competition/model/QueryDataFee.java
New file @@ -0,0 +1,16 @@ package com.dsh.competition.model; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import java.util.List; @Data @AllArgsConstructor @NoArgsConstructor public class QueryDataFee { private String data; private List<Integer> ids; } cloud-server-course/src/main/java/com/dsh/course/model/QueryDataFee.java
New file @@ -0,0 +1,16 @@ package com.dsh.course.model; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import java.util.List; @Data @AllArgsConstructor @NoArgsConstructor public class QueryDataFee { private String data; private List<Integer> ids; } cloud-server-management/src/main/java/com/dsh/course/feignClient/account/model/QueryDataFee.java
New file @@ -0,0 +1,16 @@ package com.dsh.course.feignClient.account.model; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import java.util.List; @Data @AllArgsConstructor @NoArgsConstructor public class QueryDataFee { private String data; private List<Integer> ids; } cloud-server-management/src/main/java/com/dsh/course/mapper/SiteBookingMapper.java
New file @@ -0,0 +1,13 @@ package com.dsh.course.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.dsh.guns.modular.system.model.SiteBooking; /** * @author zhibing.pu * @date 2023/7/13 16:48 */ public interface SiteBookingMapper extends BaseMapper<SiteBooking> { } cloud-server-management/src/main/java/com/dsh/guns/modular/system/service/ISiteBookingService.java
New file @@ -0,0 +1,12 @@ package com.dsh.guns.modular.system.service; import com.baomidou.mybatisplus.extension.service.IService; import com.dsh.guns.modular.system.model.SiteBooking; /** * @author zhibing.pu * @date 2023/7/13 16:49 */ public interface ISiteBookingService extends IService<SiteBooking> { } cloud-server-management/src/main/java/com/dsh/guns/modular/system/service/impl/SiteBookingServiceImpl.java
New file @@ -0,0 +1,16 @@ package com.dsh.guns.modular.system.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.dsh.course.mapper.SiteBookingMapper; import com.dsh.guns.modular.system.model.SiteBooking; import com.dsh.guns.modular.system.service.ISiteBookingService; import org.springframework.stereotype.Service; /** * @author zhibing.pu * @date 2023/7/13 16:49 */ @Service public class SiteBookingServiceImpl extends ServiceImpl<SiteBookingMapper, SiteBooking> implements ISiteBookingService { } cloud-server-management/src/main/resources/mapper/SiteBookingMapper.xml
New file @@ -0,0 +1,6 @@ <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.dsh.course.mapper.SiteBookingMapper"> </mapper> cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java
New file @@ -0,0 +1,265 @@ package com.dsh.other.controller; import cn.hutool.http.HttpRequest; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.dsh.other.entity.TGame; import com.dsh.other.entity.TGameConfig; import com.dsh.other.entity.TGameRecord; import com.dsh.other.feignclient.account.AppUserClient; import com.dsh.other.feignclient.account.model.AppUser; import com.dsh.other.model.QueryMySiteVo; import com.dsh.other.service.TGameConfigService; import com.dsh.other.service.TGameRecordService; import com.dsh.other.service.TGameService; import com.dsh.other.util.*; import com.dsh.other.util.httpClinet.HttpResult; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; @RestController @RequestMapping("/api/game") public class GameController { @Autowired private TGameRecordService gameRecordService; @Autowired private TGameService gameService; @Autowired private TGameConfigService gameConfigService; @Autowired private TokenUtil tokenUtil; @Autowired private AppUserClient appUserClient; @Autowired private PayMoneyUtil payMoneyUtil; @ResponseBody @PostMapping("/queryGameList") @ApiOperation(value = "获取当前场地的游戏列表配置", tags = {"用户—游戏"}) @ApiImplicitParams({ @ApiImplicitParam(value = "siteId", name = "siteId", dataType = "int", required = true), @ApiImplicitParam(value = "storeId", name = "storeId", dataType = "int", required = true), @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."), }) public ResultUtil<List<TGameConfig>> queryGameList(Integer siteId, Integer storeId){ try { List<TGameConfig> tGameConfigs = new ArrayList<>(); List<TGame> list = gameService.list(new LambdaQueryWrapper<TGame>().eq(TGame::getSiteId, siteId).eq(TGame::getStoreId, storeId)); if(list.size()>0){ Integer id = list.get(0).getId(); tGameConfigs = gameConfigService.list(new LambdaQueryWrapper<TGameConfig>().eq(TGameConfig::getOtherId, id)); } return ResultUtil.success(tGameConfigs); }catch (Exception e){ e.printStackTrace(); return ResultUtil.runErr(); } } @ResponseBody @PostMapping("/payGame") @ApiOperation(value = "支付游戏", tags = {"用户—游戏"}) @ApiImplicitParams({ @ApiImplicitParam(value = "三方游戏id", name = "gameId", dataType = "int", required = true), @ApiImplicitParam(value = "游戏配置id", name = "configId", dataType = "int", required = true), @ApiImplicitParam(value = "sutuId", name = "sutuId", dataType = "int", required = true), @ApiImplicitParam(value = "spaceId", name = "spaceId", dataType = "int", required = true), @ApiImplicitParam(value = "1微信 2支付宝 3玩湃币", name = "type", dataType = "int", required = true), @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."), }) public ResultUtil payGame(Integer gameId, Integer configId,Integer type,Integer sutuId,Integer spaceId){ try { Integer uid = tokenUtil.getUserIdFormRedis(); if(null == uid){ return ResultUtil.tokenErr(); } SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5); TGameConfig config = gameConfigService.getById(configId); TGameRecord tGameRecord = new TGameRecord(); tGameRecord.setGameId(gameId); tGameRecord.setPayType(type); tGameRecord.setUserId(uid); tGameRecord.setNumber(code); gameRecordService.save(tGameRecord); if(type==1){ ResultUtil weixinpay = payMoneyUtil.weixinpay("游戏支付", "", code, config.getCash().toString(), "/base/course/weChatPaymentCourseCallback", "APP", ""); if(weixinpay.getCode() == 200){ new Thread(new Runnable() { @Override public void run() { try { int num = 1; int wait = 0; while (num <= 10){ int min = 5000; wait += (min * num); Thread.sleep(wait); List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("code", code).eq("payType", 2)); TGameRecord one = list.get(0); if(one.getStatus() == 1){ break; } ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(code, ""); if(resultUtil.getCode() == 200 && one.getStatus() == 0){ /** * SUCCESS—支付成功, * REFUND—转入退款, * NOTPAY—未支付, * CLOSED—已关闭, * REVOKED—已撤销(刷卡支付), * USERPAYING--用户支付中, * PAYERROR--支付失败(其他原因,如银行返回失败) */ Map<String, String> data1 = resultUtil.getData(); String s = data1.get("trade_state"); String transaction_id = data1.get("transaction_id"); if("REFUND".equals(s) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10){ break; } if("SUCCESS".equals(s)){ for (TGameRecord coursePackagePayment : list) { coursePackagePayment.setStatus(1); coursePackagePayment.setOrderNo(transaction_id); } gameRecordService.updateBatchById(list); Integer integer = startGame(uid, gameId, spaceId, sutuId); break; } if("USERPAYING".equals(s)){ num++; } } } }catch (Exception e){ e.printStackTrace(); } } }).start(); } return weixinpay; }else if(type==2){ ResultUtil alipay = payMoneyUtil.alipay("游戏支付", "游戏支付", "", code, config.getCash().toString(), "/base/course/aliPaymentCourseCallback"); if(alipay.getCode() == 200){ new Thread(new Runnable() { @Override public void run() { try { int num = 1; int wait = 0; while (num <= 10){ int min = 5000; wait += (min * num); Thread.sleep(wait); List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("code", code).eq("payType", 3)); TGameRecord one = list.get(0); if(one.getStatus() == 1){ break; } ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryALIOrder(code); if(resultUtil.getCode() == 200 && one.getStatus() == 0){ /** * WAIT_BUYER_PAY(交易创建,等待买家付款)、 * TRADE_CLOSED(未付款交易超时关闭,或支付完成后全额退款)、 * TRADE_SUCCESS(交易支付成功)、 * TRADE_FINISHED(交易结束,不可退款) */ Map<String, String> data1 = resultUtil.getData(); String s = data1.get("tradeStatus"); String tradeNo = data1.get("tradeNo"); if("TRADE_CLOSED".equals(s) || "TRADE_FINISHED".equals(s) || num == 10){ break; } if("TRADE_SUCCESS".equals(s)){ for (TGameRecord coursePackagePayment : list) { coursePackagePayment.setStatus(1); coursePackagePayment.setOrderNo(tradeNo); } gameRecordService.updateBatchById(list); Integer integer = startGame(uid, gameId, spaceId, sutuId); break; } if("WAIT_BUYER_PAY".equals(s)){ num++; } } } }catch (Exception e){ e.printStackTrace(); } } }).start(); } return alipay; }else if(type==3){ AppUser appUser = appUserClient.queryAppUser(uid); Integer playPaiCoins = appUser.getPlayPaiCoins(); BigDecimal playCoin = config.getPlayCoin(); int i = playCoin.intValue(); if(playPaiCoins<i){ return ResultUtil.error("玩湃币不足"); } int i1 = playPaiCoins - i; appUser.setPlayPaiCoins(i1); appUserClient.updateAppUser(appUser); startGame(uid,gameId,spaceId,sutuId); return ResultUtil.success(); }else { return ResultUtil.error("支付方式错误"); } }catch (Exception e){ e.printStackTrace(); return ResultUtil.runErr(); } } private static Integer startGame(Integer uid,Integer gameId,Integer spaceId,Integer sutuId){ HashMap<String, String> map = new HashMap<>(); map.put("sign","0DB011836143EEE2C2E072967C9F4E4B"); map.put("app_user_id",uid+""); map.put("game_id",gameId+""); map.put("space_id",spaceId+""); map.put("sutu_id",sutuId+""); String s = HttpRequestUtil.postRequest("https://try.daowepark.com/v7/user_api/general/gameStart", map); JSONObject jsonObject = JSONObject.parseObject(s); Object code = jsonObject.get("code"); if(String.valueOf(code)!=null && "200".equals(String.valueOf(code))){ return 200; }else { return 500; } } public static void main(String[] args) { Integer integer = startGame(1, 13, 1001, 1001); System.out.println(integer); } } cloud-server-other/src/main/java/com/dsh/other/entity/TGameRecord.java
New file @@ -0,0 +1,65 @@ package com.dsh.other.entity; import java.math.BigDecimal; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.extension.activerecord.Model; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableField; import java.io.Serializable; import lombok.Data; import lombok.EqualsAndHashCode; import lombok.experimental.Accessors; /** * <p> * * </p> * * @author administrator * @since 2023-10-07 */ @Data @EqualsAndHashCode(callSuper = false) @Accessors(chain = true) @TableName("t_game_record") public class TGameRecord extends Model<TGameRecord> { private static final long serialVersionUID=1L; @TableId(value = "id", type = IdType.AUTO) private Integer id; @TableField("userId") private Integer userId; @TableField("gameId") private Integer gameId; /** * 1玩湃币 2微信 3支付宝 */ @TableField("payType") private Integer payType; /** * 金额 */ private BigDecimal money; /** * 0待支付 1已支付 */ private Integer status; private String number; @TableField("orderNo") private String orderNo; @Override protected Serializable pkVal() { return this.id; } } cloud-server-other/src/main/java/com/dsh/other/mapper/TGameRecordMapper.java
New file @@ -0,0 +1,17 @@ package com.dsh.other.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.dsh.other.entity.TGameRecord; /** * <p> * Mapper 接口 * </p> * * @author administrator * @since 2023-10-07 */ public interface TGameRecordMapper extends BaseMapper<TGameRecord> { } cloud-server-other/src/main/java/com/dsh/other/service/TGameRecordService.java
New file @@ -0,0 +1,17 @@ package com.dsh.other.service; import com.baomidou.mybatisplus.extension.service.IService; import com.dsh.other.entity.TGameRecord; /** * <p> * 服务类 * </p> * * @author administrator * @since 2023-10-07 */ public interface TGameRecordService extends IService<TGameRecord> { } cloud-server-other/src/main/java/com/dsh/other/service/impl/TGameRecordServiceImpl.java
New file @@ -0,0 +1,21 @@ package com.dsh.other.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.dsh.other.entity.TGameRecord; import com.dsh.other.mapper.TGameRecordMapper; import com.dsh.other.service.TGameRecordService; import org.springframework.stereotype.Service; /** * <p> * 服务实现类 * </p> * * @author administrator * @since 2023-10-07 */ @Service public class TGameRecordServiceImpl extends ServiceImpl<TGameRecordMapper, TGameRecord> implements TGameRecordService { } cloud-server-other/src/main/java/com/dsh/other/util/HttpRequestUtil.java
New file @@ -0,0 +1,254 @@ package com.dsh.other.util; import com.alibaba.fastjson.JSONObject; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; import org.apache.commons.httpclient.SimpleHttpConnectionManager; import org.apache.commons.httpclient.methods.GetMethod; import org.apache.commons.httpclient.methods.PostMethod; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.PrintWriter; import java.security.MessageDigest; import java.util.Map; public class HttpRequestUtil { public static String postRequest(String url, Map<String, String> params) { // 构造HttpClient的实例 HttpClient httpClient = new HttpClient(); // 创建POST方法的实例 PostMethod postMethod = new PostMethod(url); // 设置请求头信息 postMethod.setRequestHeader("Connection", "close"); postMethod.addRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8"); // 添加参数 for (Map.Entry<String, String> entry : params.entrySet()) { postMethod.addParameter(entry.getKey(), entry.getValue()); } // 使用系统提供的默认的恢复策略,设置请求重试处理,用的是默认的重试处理:请求三次 httpClient.getParams().setBooleanParameter("http.protocol.expect-continue", false); // 接收处理结果 String result = null; try { // 执行Http Post请求 httpClient.executeMethod(postMethod); // 返回处理结果 result = postMethod.getResponseBodyAsString(); } catch (HttpException e) { // 发生致命的异常,可能是协议不对或者返回的内容有问题 System.out.println("请检查输入的URL!"); e.printStackTrace(); } catch (IOException e) { // 发生网络异常 System.out.println("发生网络异常!"); e.printStackTrace(); } finally { // 释放链接 postMethod.releaseConnection(); // 关闭HttpClient实例 if (httpClient != null) { ((SimpleHttpConnectionManager) httpClient.getHttpConnectionManager()).shutdown(); httpClient = null; } } return result; } public static String postRequest1(String url, Map<String, String> params,String appKey,String appSecret) { // 构造HttpClient的实例 HttpClient httpClient = new HttpClient(); // 创建POST方法的实例 PostMethod postMethod = new PostMethod(url); // 设置请求头信息 String nonce = String.valueOf(Double.valueOf(Math.random() * 1000000.0D).intValue()); String timeMillis = String.valueOf(System.currentTimeMillis()); String signature = string2Sha1(appSecret + nonce + timeMillis); postMethod.setRequestHeader("Host", "api-cn.ronghub.com"); postMethod.setRequestHeader("App-Key", appKey); postMethod.setRequestHeader("Signature", signature); postMethod.setRequestHeader("Nonce", nonce); postMethod.setRequestHeader("Timestamp", timeMillis); postMethod.setRequestHeader("Host", "api-cn.ronghub.com"); postMethod.addRequestHeader("Content-Type", "application/json"); // 添加参数 for (Map.Entry<String, String> entry : params.entrySet()) { postMethod.addParameter(entry.getKey(), entry.getValue()); } // 使用系统提供的默认的恢复策略,设置请求重试处理,用的是默认的重试处理:请求三次 httpClient.getParams().setBooleanParameter("http.protocol.expect-continue", false); // 接收处理结果 String result = null; try { // 执行Http Post请求 httpClient.executeMethod(postMethod); // 返回处理结果 result = postMethod.getResponseBodyAsString(); } catch (HttpException e) { // 发生致命的异常,可能是协议不对或者返回的内容有问题 System.out.println("请检查输入的URL!"); e.printStackTrace(); } catch (IOException e) { // 发生网络异常 System.out.println("发生网络异常!"); e.printStackTrace(); } finally { // 释放链接 postMethod.releaseConnection(); // 关闭HttpClient实例 if (httpClient != null) { ((SimpleHttpConnectionManager) httpClient.getHttpConnectionManager()).shutdown(); httpClient = null; } } return result; } private static String string2Sha1(String str){ if(str==null||str.length()==0){ return null; } char hexDigits[] = {'0','1','2','3','4','5','6','7','8','9', 'a','b','c','d','e','f'}; try { MessageDigest mdTemp = MessageDigest.getInstance("SHA1"); mdTemp.update(str.getBytes("UTF-8")); byte[] md = mdTemp.digest(); int j = md.length; char buf[] = new char[j*2]; int k = 0; for (int i = 0; i < j; i++) { byte byte0 = md[i]; buf[k++] = hexDigits[byte0 >>> 4 & 0xf]; buf[k++] = hexDigits[byte0 & 0xf]; } return new String(buf); } catch (Exception e) { // TODO: handle exception return null; } } public static String getRequest(String url, Map<String, String> params) { // 构造HttpClient实例 HttpClient client = new HttpClient(); // 拼接参数 String paramStr = ""; for (String key : params.keySet()) { paramStr = paramStr + "&" + key + "=" + params.get(key); } paramStr = paramStr.substring(1); // 创建GET方法的实例 GetMethod method = new GetMethod(url + "?" + paramStr); // 接收返回结果 String result = null; try { // 执行HTTP GET方法请求 client.executeMethod(method); // 返回处理结果 result = method.getResponseBodyAsString(); } catch (HttpException e) { // 发生致命的异常,可能是协议不对或者返回的内容有问题 System.out.println("请检查输入的URL!"); e.printStackTrace(); } catch (IOException e) { // 发生网络异常 System.out.println("发生网络异常!"); e.printStackTrace(); } finally { // 释放链接 method.releaseConnection(); // 关闭HttpClient实例 if (client != null) { ((SimpleHttpConnectionManager) client .getHttpConnectionManager()).shutdown(); client = null; } } return result; } /** * 发送网络请求 * @param url * @return */ public static String sendNetRequest(String url, Map<String, String> params) { // 构造HttpClient实例 HttpClient client = new HttpClient(); String paramStr = ""; for (String key : params.keySet()) { paramStr = paramStr + "&" + key + "=" + params.get(key); } paramStr = paramStr.substring(1); System.err.println(url + "?" + paramStr); // 创建GET方法的实例 GetMethod method = new GetMethod(url + "?" + paramStr); // 接收返回结果 String result = null; try { // 执行HTTP GET方法请求 client.executeMethod(method); // 返回处理结果 result = method.getResponseBodyAsString(); } catch (HttpException e) { // 发生致命的异常,可能是协议不对或者返回的内容有问题 System.out.println("请检查输入的URL!"); e.printStackTrace(); } catch (IOException e) { // 发生网络异常 System.out.println("发生网络异常!"); e.printStackTrace(); } finally { // 释放链接 method.releaseConnection(); // 关闭HttpClient实例 if (client != null) { ((SimpleHttpConnectionManager) client.getHttpConnectionManager()).shutdown(); client = null; } } return result; } /** * jsonp跨域请求数据响应<br/> * 方法名:responsejsonpData<br/> * @author:Mryang<br/> * @createTime:2016年7月31日-下午11:17:31 <br/> * @tel: 15198268054<br/> * @param request * @param response * @param map void<br/> * @exception <br/> * @since 1.0.0 */ public void responsejsonpData(HttpServletRequest request, HttpServletResponse response, Map<String, Object> map) { response.setCharacterEncoding("UTF-8"); response.setHeader("Content-Type", "text/html;Charset=utf-8"); try { PrintWriter writer = response.getWriter(); String params = request.getParameter("callback"); String json = JSONObject.toJSONString(map); writer.print(params+ "("+json+")"); } catch (IOException e) { e.printStackTrace(); } } } cloud-server-other/src/main/resources/mapper/TGameRecordMapper.xml
New file @@ -0,0 +1,6 @@ <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.dsh.other.mapper.TGameRecordMapper"> </mapper>