本地新币代码
blame | history | patch | commit | commitdiff | ignore whitespace
peternameyakj
2024-07-30 f23b33bbb9eaff76cac5b69e3b793fc7910fb0fa 
 src/main/java/project/web/admin/AdminWithdrawController.java


@@ -10,6 +10,7 @@


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.jdbc.core.JdbcTemplate;


import org.springframework.web.bind.annotation.RequestMapping;


import org.springframework.web.bind.annotation.RestController;


import org.springframework.web.servlet.ModelAndView;


@@ -20,6 +21,10 @@


import kernel.web.Page;


import kernel.web.PageActionSupport;


import project.Constants;


import project.redis.RedisHandler;


import project.wallet.WalletGatherService;


import project.wallet.WalletService;


import project.wallet.internal.WalletGatherServiceImpl;


import project.withdraw.AdminWithdrawService;


import util.LockFilter;




@@ -31,6 +36,15 @@




   @Resource


   private AdminWithdrawService adminWithdrawService;


   @Autowired


   private RedisHandler redisHandler;




   @Autowired


   private JdbcTemplate jdbcTemplate;




   @Autowired


   private WalletService walletService;






   private static final String action = "normal/adminWithdrawAction!";


   


@@ -215,7 +229,8 @@


         lock = true;




         // 统一处理失败接口


         this.adminWithdrawService.saveReject(id, failure_msg, this.getUsername_login(), this.getLoginPartyId());


         WalletGatherService walletGatherService = new WalletGatherServiceImpl(jdbcTemplate,redisHandler,walletService);


         this.adminWithdrawService.saveReject(id, failure_msg, this.getUsername_login(), this.getLoginPartyId(),walletGatherService);


         ThreadUtils.sleep(300);


      } catch (BusinessException e) {


         modelAndView.addObject("error", e.getMessage());