修改自增ID

game-business/src/main/java/com/game/business/controller/AppGameBettingController.java

@@ -220,7 +220,6 @@ public class AppGameBettingController extends BaseController{
             finTranRecord.setProCount(0L);
 
             finTranRecord.setOrderId(gameBetting.getId());
-            finTranRecord.setId(IdUtil.getSnowflakeNextId());
             finTranRecordService.insertFinTranRecord(finTranRecord);
         }
 

game-business/src/main/java/com/game/business/controller/AppUserAgentController.java

@@ -85,7 +85,6 @@ public class AppUserAgentController extends BaseController
         AppUserAgent dbPuserAgent = pList.get(0);
 
         AppUserAgent appUserAgent = new AppUserAgent();
-        appUserAgent.setId(IdUtil.getSnowflakeNextId());
         appUserAgent.setTopId((dbPuserAgent.getTopId() == null || dbPuserAgent.getTopId() < 1) ? dbPuserAgent.getUserId() : dbPuserAgent.getTopId());
         appUserAgent.setPid(dbPuserAgent.getUserId());
         appUserAgent.setUserId(appUser.getUserid());
@@ -151,7 +150,6 @@ public class AppUserAgentController extends BaseController
                         commission.setPid(appUserAgent.getPid());
                     }*/
                     commission.setPid(appUserAgent.getPid());
-                    commission.setId(IdUtil.getSnowflakeNextId());
                     commission.setUserId(dbUserAgent.getUserId());
                     appGameCommissionService.insertAppGameCommission(commission);
                 }else{
@@ -289,9 +287,9 @@ public class AppUserAgentController extends BaseController
      */
     public AppUser getAppUser(String userName, String password,String smsRegion) {
         AppUser curUser = appUserService.selectAppUserByUserid(SecurityUtils.getUserId());//操作人用户信息
+
         AppUser appUser = new AppUser();
 
-        appUser.setUserid(IdUtil.getSnowflakeNextId());
         if (StringUtils.isNotBlank(password)) {
             appUser.setPassword(Md5Utils.md5(Md5Utils.md5(password) + appUser.getSalt()));
         }

game-business/src/main/java/com/game/business/mapper/AppUserMapper.java

@@ -58,4 +58,6 @@ public interface AppUserMapper extends BaseMapper<AppUser> {
      * @return 结果
      */
     public int deleteAppUserByUserids(Long[] userids);
+
+    Long nextId();
 }

game-business/src/main/java/com/game/business/mapper/FinTranRecordMapper.java

@@ -58,4 +58,6 @@ public interface FinTranRecordMapper extends BaseMapper<FinTranRecord> {
      * @return 结果
      */
     public int deleteFinTranRecordByIds(Long[] ids);
+
+    Long nextId();
 }

game-business/src/main/java/com/game/business/service/IAppUserService.java

@@ -67,4 +67,6 @@ public interface IAppUserService extends IService<AppUser> {
      * 根据用户id集合查询用户列表
      * */
     public List<AppUser> selectListByIds(List<Long> ids);
+
+    Long nextId();
 }

game-business/src/main/java/com/game/business/service/IFinTranRecordService.java

@@ -67,4 +67,6 @@ public interface IFinTranRecordService extends IService<FinTranRecord> {
      * @return 结果
      */
     public List<FinTranRecord> getUserRecordList(String userId,String beginTime,String endTime);
+
+    Long nextId();
 }

game-business/src/main/java/com/game/business/service/impl/AppUserServiceImpl.java

@@ -10,6 +10,7 @@ import com.game.common.annotation.DataSource;
 import com.game.common.enums.DataSourceType;
 import com.game.common.utils.DateUtils;
 import com.game.common.utils.StringUtils;
+import lombok.val;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.game.business.mapper.AppUserMapper;
@@ -62,6 +63,8 @@ public class AppUserServiceImpl extends ServiceImpl<AppUserMapper, AppUser> impl
     @DataSource(DataSourceType.SLAVE)
     public int insertAppUser(AppUser appUser) {
                 appUser.setCreateTime(DateUtils.getNowDate());
+
+                appUser.setUserid(this.nextId());
             return appUserMapper.insertAppUser(appUser);
     }
 
@@ -132,4 +135,11 @@ public class AppUserServiceImpl extends ServiceImpl<AppUserMapper, AppUser> impl
         queryWrapper.eq(AppUser::getDelFlag,0);
         return appUserMapper.selectList(queryWrapper);
     }
+
+    @Override
+    @DataSource(DataSourceType.SLAVE)
+    public Long nextId(){
+        Long id = appUserMapper.nextId();
+        return  id < 10000 ? 10000 : id;
+    }
 }

game-business/src/main/java/com/game/business/service/impl/FinTranRecordServiceImpl.java

@@ -62,6 +62,7 @@ public class FinTranRecordServiceImpl extends ServiceImpl<FinTranRecordMapper, F
     @DataSource(DataSourceType.SLAVE)
     public int insertFinTranRecord(FinTranRecord finTranRecord) {
                 finTranRecord.setCreateTime(DateUtils.getNowDate());
+                finTranRecord.setId(this.nextId());
             return finTranRecordMapper.insertFinTranRecord(finTranRecord);
     }
 
@@ -102,6 +103,7 @@ public class FinTranRecordServiceImpl extends ServiceImpl<FinTranRecordMapper, F
     }
 
     @Override
+    @DataSource(DataSourceType.SLAVE)
     public List<FinTranRecord> getUserRecordList(String userId, String beginTime, String endTime) {
         LambdaQueryWrapper<FinTranRecord> queryWrapper = new LambdaQueryWrapper<FinTranRecord>();
         queryWrapper.between(FinTranRecord::getCreateTime,beginTime,endTime);
@@ -110,4 +112,11 @@ public class FinTranRecordServiceImpl extends ServiceImpl<FinTranRecordMapper, F
         }
         return finTranRecordMapper.selectList(queryWrapper);
     }
+
+    @Override
+    @DataSource(DataSourceType.SLAVE)
+    public Long nextId() {
+        Long id = finTranRecordMapper.nextId();
+        return  id < 10000 ? 10000 : id;
+    }
 }

game-business/src/main/java/com/game/business/task/AppAgentGameBettingTask.java

@@ -209,7 +209,6 @@ public class AppAgentGameBettingTask {
             finTranRecord.setProCount(0L);
 
             finTranRecord.setOrderId(appGameBetting.getId());
-            finTranRecord.setId(IdUtil.getSnowflakeNextId());
             finTranRecordService.insertFinTranRecord(finTranRecord);
         }
     }
@@ -299,7 +298,6 @@ public class AppAgentGameBettingTask {
         finTranRecord.setProCount(0L);
 
         finTranRecord.setOrderId(appGameBetting.getId());
-        finTranRecord.setId(IdUtil.getSnowflakeNextId());
         finTranRecordService.insertFinTranRecord(finTranRecord);
 
     }

game-business/src/main/java/com/game/business/task/AppGameBettingTask.java

@@ -321,7 +321,6 @@ public class AppGameBettingTask {
                 finTranRecord.setProCount(0L);
 
                 finTranRecord.setOrderId(appGameBetting.getId());
-                finTranRecord.setId(IdUtil.getSnowflakeNextId());
                 finTranRecordService.insertFinTranRecord(finTranRecord);
 
             }

game-business/src/main/resources/mapper/business/AppUserMapper.xml

@@ -814,4 +814,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             #{userid}
         </foreach>
     </delete>
+
+    <select id="nextId" resultType="java.lang.Long">
+        select max(userid) + 1 from app_user
+    </select>
 </mapper>

game-business/src/main/resources/mapper/business/FinTranRecordMapper.xml

@@ -214,4 +214,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             #{id}
         </foreach>
     </delete>
+
+    <select id="nextId" resultType="java.lang.Long">
+        select max(id) + 1 from fin_tran_record
+    </select>
 </mapper>