-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- 对一些模组端的优化
- Loading branch information
Showing
9 changed files
with
218 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -4,6 +4,8 @@ | |
|
|
||
| public interface IStorage { | ||
|
|
||
|
|
||
|
|
||
| /** | ||
| * 处理订单 | ||
| */ | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
185 changes: 185 additions & 0 deletions
185
src/main/java/com/meteor/aifadianpay/storage/sub/SqliteStorage.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,185 @@ | ||
| package com.meteor.aifadianpay.storage.sub; | ||
|
|
||
| import com.meteor.aifadianpay.AifadianPay; | ||
| import com.meteor.aifadianpay.afdian.response.Order; | ||
| import com.meteor.aifadianpay.afdian.response.SkuDetail; | ||
| import com.meteor.aifadianpay.api.event.SendOutGoodsEvent; | ||
| import com.meteor.aifadianpay.data.ShopItem; | ||
| import com.meteor.aifadianpay.filter.FilterManager; | ||
| import com.meteor.aifadianpay.mysql.data.KeyValue; | ||
| import com.meteor.aifadianpay.storage.IStorage; | ||
| import com.meteor.aifadianpay.util.BaseConfig; | ||
| import org.bukkit.Bukkit; | ||
| import org.bukkit.entity.Player; | ||
|
|
||
| import java.sql.*; | ||
| import java.util.Arrays; | ||
| import java.util.List; | ||
|
|
||
| public class SqliteStorage implements IStorage { | ||
|
|
||
|
|
||
| private final String ORDER_TABLE = "AIFADIAN_ORDERS_0"; | ||
| private final String SKU_DETAIL_TABLE = "AIFADIAN_SKUDETAIL_0"; | ||
|
|
||
| private AifadianPay plugin; | ||
| private Connection connection; | ||
|
|
||
|
|
||
| private void connect(){ | ||
| try { | ||
| Class.forName("org.sqlite.JDBC"); | ||
| this.connection = DriverManager.getConnection("jdbc:sqlite:"+plugin.getDataFolder().getPath()+"/data.db"); | ||
|
|
||
| String orders_column = "CREATE TABLE IF NOT EXISTS AIFADIAN_ORDERS_0 (" | ||
| + "out_trade_no varchar(40) PRIMARY KEY," | ||
| + "remark varchar(100)," | ||
| + "user_id varchar(40)," | ||
| + "plan_title varchar(40)," | ||
| + "redeem_id varchar(40)," | ||
| + "price varchar(40)," | ||
| + "insert_time bigint" | ||
| + ")"; | ||
|
|
||
| Statement statement = connection.createStatement(); | ||
|
|
||
| String skudetail_column = "CREATE TABLE IF NOT EXISTS AIFADIAN_SKUDETAIL_0 (" | ||
| + "out_trade_no varchar(40)," | ||
| + "sku_id varchar(40)," | ||
| + "price varchar(40)," | ||
| + "name varchar(40)," | ||
| + "count int" | ||
| + ")"; | ||
| statement.execute(orders_column); | ||
| statement.execute(skudetail_column); | ||
| } catch (SQLException e) { | ||
| throw new RuntimeException(e); | ||
| } catch (ClassNotFoundException e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
|
|
||
|
|
||
| public SqliteStorage(AifadianPay plugin){ | ||
| this.plugin = plugin; | ||
| this.connect();; | ||
| } | ||
|
|
||
| public boolean isExistOrder(String no){ | ||
| PreparedStatement preparedStatement = null; | ||
| ResultSet resultSet; | ||
| resultSet = null; | ||
| try { | ||
| preparedStatement = this.connection.prepareStatement("select * from " + ORDER_TABLE + " where out_trade_no = ?"); | ||
| resultSet = preparedStatement.executeQuery(); | ||
| while (resultSet.next()) return true; | ||
| } catch (SQLException e) { | ||
| throw new RuntimeException(e); | ||
| }finally { | ||
| try { | ||
| preparedStatement.close(); | ||
| resultSet.close(); | ||
| } catch (SQLException e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
| return false; | ||
| } | ||
|
|
||
|
|
||
| public void insertOrder(Order order) { | ||
|
|
||
| String sql = "INSERT INTO AIFADIAN_ORDERS_0 (out_trade_no, remark, user_id, plan_title, redeem_id,price,insert_time) VALUES (?, ?, ?, ?,?,?,?)"; | ||
|
|
||
| try ( | ||
| PreparedStatement statement = connection.prepareStatement(sql)) { | ||
| statement.setString(1,order.getOutTradeNo()); | ||
| statement.setString(2,order.getRemark()); | ||
| statement.setString(3,order.getUserId()); | ||
| statement.setString(4,order.getPlanTitle()); | ||
| statement.setString(5,order.getRedeemId()); | ||
| statement.setString(6,order.getTotalAmount()); | ||
| statement.setLong(7,System.currentTimeMillis()); | ||
| statement.executeUpdate(); | ||
| } catch (SQLException e) { | ||
| } | ||
| } | ||
|
|
||
|
|
||
| public void insertSkudetail(Order order,SkuDetail skuDetail) { | ||
|
|
||
| String sql = "INSERT INTO AIFADIAN_SKUDETAIL_0 (out_trade_no, sku_id, price, `name`, `count`) VALUES (?, ?, ?, ?, ?)"; | ||
|
|
||
| try ( | ||
| PreparedStatement statement = connection.prepareStatement(sql)) { | ||
| statement.setString(1,order.getOutTradeNo()); | ||
| statement.setString(2,skuDetail.getSkuId()); | ||
| statement.setString(3,order.getTotalAmount()); | ||
| statement.setString(4,skuDetail.getName()); | ||
| statement.setInt(5,skuDetail.getCount()); | ||
| statement.executeUpdate(); | ||
| } catch (SQLException e) { | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public void handeOrder(Order order, boolean b) { | ||
| List<Order> orders = FilterManager.meet(Arrays.asList(order)); | ||
| if(!orders.isEmpty()){ | ||
| Order handleOrder = orders.get(0); | ||
| Player playerExact = Bukkit.getPlayerExact(handleOrder.getRemark()); | ||
|
|
||
| if(playerExact!=null&&b){ | ||
|
|
||
|
|
||
| if(!isExistOrder(handleOrder.getOutTradeNo())){ | ||
|
|
||
| /*** | ||
| * 插入已处理订单表 | ||
| */ | ||
| this.insertOrder(handleOrder); | ||
|
|
||
|
|
||
| /*** | ||
| * 型号处理 | ||
| */ | ||
| for (SkuDetail skuDetail : handleOrder.getSkuDetail()) { | ||
| this.insertSkudetail(handleOrder,skuDetail); | ||
| } | ||
|
|
||
| /** | ||
| * 发货 | ||
| */ | ||
| ShopItem shopItem = BaseConfig.STORE.getShopItemMap().get(handleOrder.getPlanTitle()); | ||
| Bukkit.getScheduler().runTask(plugin,()->{ | ||
| SendOutGoodsEvent sendOutGoodsEvent = new SendOutGoodsEvent(playerExact,shopItem,handleOrder.getOutTradeNo(),handleOrder.getSkuDetail(),handleOrder); | ||
| Bukkit.getServer().getPluginManager().callEvent(sendOutGoodsEvent); | ||
| }); | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public int queryPlayerDonate(String p) { | ||
| PreparedStatement preparedStatement = null; | ||
| ResultSet resultSet = null; | ||
| try { | ||
| String sql = "select sum(`price`) as count from "+ORDER_TABLE+" where remark = ?"; | ||
| preparedStatement = connection.prepareStatement(sql); | ||
| preparedStatement.setString(1,p); | ||
| resultSet = preparedStatement.executeQuery(); | ||
| while (resultSet.next()) return resultSet.getInt("sum"); | ||
| } catch (Throwable e) { | ||
| throw new RuntimeException(e); | ||
| }finally { | ||
| try { | ||
| preparedStatement.close(); | ||
| resultSet.close(); | ||
| } catch (SQLException e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
| return 0; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters