20221130

xiaoyong931011

2022-12-08 d071926dc82b991b762aaefea03c6d21621c415e

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java

@@ -706,6 +706,16 @@
        String md5Pwd = SecureUtil.md5(AppContants.MEMBER_LOGIN_CODE);
        member.setPassword(md5Pwd);
        dappMemberDao.updateById(member);

        String redisKey = AppContants.REDIS_KEY_SIGN + member.getId();
        String existToken = redisUtils.getString(redisKey);
        if (StrUtil.isNotBlank(existToken)) {
            Object o = redisUtils.get(existToken);
            if (ObjectUtil.isNotEmpty(o)) {
                redisUtils.del(existToken);
            }
        }
        redisUtils.del(redisKey);
    }

    @Override
@@ -1073,7 +1083,7 @@
            dappAccountMoneyChangeDao.insert(addFlow);

            dappAccountMoneyChangeDao.deleteById(dappAccountMoneyChangeEntity.getId());
            return new FebsResponse().fail().message("操作成功");
            return new FebsResponse().success().message("操作成功");
        }else{
            return new FebsResponse().fail().message("只允许回退【盈利分成】和【流水佣金】");
        }
@@ -1150,6 +1160,50 @@
        return adminTeamInfoVoIPage;
    }

    @Override
    public FebsResponse sendBackMessage(DappMessageEntity dappMessageEntity) {
        if(ObjectUtil.isEmpty(dappMessageEntity.getBackMessage())){
            return new FebsResponse().fail().message("回复不能为空。");
        }
        Long id = dappMessageEntity.getId();
        DappMessageEntity dappMessage = dappMessageDao.selectById(id);
        DappMessageEntity dappMessageEntityBack = new DappMessageEntity();
        dappMessageEntityBack.setMemberId(dappMessage.getMemberId());
        dappMessageEntityBack.setBackMessage(dappMessageEntity.getBackMessage());
        dappMessageDao.insert(dappMessageEntityBack);
        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public IPage<DappMessageEntity> showMessageList(DappMessageEntity dappMessageEntity, QueryRequest request) {
        dappMessageEntity = dappMessageDao.selectById(dappMessageEntity.getId());
        Page<DappMessageEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
        IPage<DappMessageEntity> dappMessageEntitys = dappMemberDao.showMessageListInPage(page, dappMessageEntity);
        return dappMessageEntitys;
    }

    @Override
    public IPage<ApiMessageListVo> getMessageListInPage(ApiMessageListDto apiMessageListDto) {
        Page<ApiMessageListVo> page = new Page<>(apiMessageListDto.getPageNum(), apiMessageListDto.getPageSize());

        DappMemberEntity member = LoginUserUtil.getAppUser();
        DappMessageEntity dappMessageEntity = new DappMessageEntity();
        dappMessageEntity.setMemberId(member.getId());
        IPage<ApiMessageListVo> records = dappMemberDao.getMessageListInPage(page, dappMessageEntity);
        return records;
    }

    @Override
    public void reloadSystem() {
        //系统开关设置为ON
        DataDictionaryCustom onOff = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.ON_OFF.getType(), DataDictionaryEnum.ON_OFF.getCode());
        onOff.setValue("OFFSET!");
        dataDictionaryCustomMapper.updateById(onOff);
        dappWalletCoinDao.updateAmountToZero();
        //将所有的挂机记录结束
        igtOnHookPlanOrderDao.updatePlanOrder();
    }

    public String generateAsaToken(String token) {
        RSA rsa = new RSA(null, AppContants.PUBLIC_KEY);
        return rsa.encryptBase64(token + "_" + System.currentTimeMillis(), KeyType.PublicKey);