java-insagent-pc/src/main/java/com/ydtech/modules/admin/service/impl/SysAmountAuditingServiceImpl.java

package com.ydtech.modules.admin.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.ydtech.core.page.HttpResult;
import com.ydtech.modules.admin.dao.SysAmountAuditingMapper;
import com.ydtech.modules.admin.model.po.SysAmountAuditingEntity;
import com.ydtech.modules.admin.model.po.SysUserAccount;
import com.ydtech.modules.admin.model.vo.SysAmountAuditingVo;
import com.ydtech.modules.admin.service.SysAmountAuditingService;
import com.ydtech.modules.admin.service.SysUserAccountService;
import com.ydtech.modules.base.controller.BaseController;
import com.ydtech.modules.fnc.entity.InsPlyIncome;
import com.ydtech.modules.order.entity.BasePageResult;
import com.ydtech.utils.StringUtils;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

@Service
public class SysAmountAuditingServiceImpl extends ServiceImpl<SysAmountAuditingMapper, SysAmountAuditingEntity> implements SysAmountAuditingService {
    @Autowired
    private SysUserAccountService sysUserAccountService;

    @Autowired
    private SysAmountAuditingService sysAmountAuditingService;

    @Override
    @Transactional
    public void AmountReview(SysAmountAuditingVo sysAmountAuditingVo) {

        SysAmountAuditingEntity sysAmountAuditingEntity = sysAmountAuditingService.getById(sysAmountAuditingVo.getId());

        BigDecimal amount = sysAmountAuditingVo.getAmount();
        String userId = sysAmountAuditingVo.getUserId();
//        SysUserAccount sysUserAccountEntity = new SysUserAccount();
//      用户扣减金额
        if (StringUtils.isNotEmpty(userId)) {
//            sysUserAccountEntity.setUserId(userId);
            SysUserAccount sysUserAccount = sysUserAccountService.getById(userId);
            if (ObjectUtils.isNotEmpty(sysUserAccount)) {
                String amountStatus = sysAmountAuditingVo.getAmountStatus();
                if (StringUtils.isNotEmpty(amountStatus)) {
                    if ("1".equals(amountStatus)) {
                        sysUserAccount.setHandlingAmountAccount(amount);
                        sysUserAccount.setHandlingAmountPayment(sysUserAccount.getHandlingAmountPayment().subtract(amount));
//                        sysUserAccountEntity.setHandlingFee(afterAmount);
                    } else if ("2".equals(amountStatus)) {
                        sysUserAccount.setDocumentaryAmountAccount(amount);
                        sysUserAccount.setDocumentaryAmountpayment(sysUserAccount.getDocumentaryAmountpayment().subtract(amount));
//                        sysUserAccountEntity.setDocumentary(afterAmount);
                    } else {
                        sysUserAccount.setPromotionAmountAccount(amount);
                        sysUserAccount.setPromotionAmountPayment(sysUserAccount.getPromotionAmountPayment().subtract(amount));
//                        sysUserAccountEntity.setPromotion(afterAmount);
                    }
                }
                sysUserAccountService.updateById(sysUserAccount);
            }
            sysAmountAuditingVo.setAuditingStatus("3");
            sysAmountAuditingVo.setAuditingUserId(BaseController.getUser().getId());
            sysAmountAuditingVo.setAuditingTime(new Date());
            BeanUtils.copyProperties(sysAmountAuditingVo, sysAmountAuditingEntity);
            baseMapper.updateById(sysAmountAuditingEntity);
        }


    }

    @Override
    public SysAmountAuditingEntity getByUserId(String userId,String amountStatus) {
        return baseMapper.getByUserId(userId,amountStatus);
    }

    @Override
    public HttpResult<BasePageResult<SysAmountAuditingEntity>> queryByVo(SysAmountAuditingVo sysAmountAuditingVo) {
        try{
            HashMap<String, Object> params = new HashMap<>();
            PageInfo<List<InsPlyIncome>> pageHelper = null;
            PageHelper.startPage(sysAmountAuditingVo.getPageNum(),sysAmountAuditingVo.getPageSize());
            params.put("pageNum",sysAmountAuditingVo.getPageNum());
            params.put("pageSize",sysAmountAuditingVo.getPageSize());
            if(ObjectUtils.isNotEmpty(sysAmountAuditingVo.getStartTime())){
                params.put("startDate",sysAmountAuditingVo.getStartTime().toString());
            }
            if(ObjectUtils.isNotEmpty(sysAmountAuditingVo.getEndTime())){
                params.put("endDate",sysAmountAuditingVo.getEndTime().toString());
            }
            if(StringUtils.isNotEmpty(sysAmountAuditingVo.getAuditingStatus())){
                params.put("auditingStatus",sysAmountAuditingVo.getAuditingStatus());
            }
            if(StringUtils.isNotEmpty(sysAmountAuditingVo.getUserId())){
                params.put("userId",sysAmountAuditingVo.getUserId());
            }
            if(StringUtils.isNotEmpty(sysAmountAuditingVo.getId())){
                params.put("id",sysAmountAuditingVo.getId());
            }

            if(StringUtils.isNotEmpty(sysAmountAuditingVo.getAmountStatus())){
                params.put("amountStatus",sysAmountAuditingVo.getAmountStatus());
            }
            if(StringUtils.isNotEmpty(sysAmountAuditingVo.getMobile())){
                params.put("mobile",sysAmountAuditingVo.getMobile());
            }
            if(StringUtils.isNotEmpty(sysAmountAuditingVo.getUserName())){
                params.put("userName",sysAmountAuditingVo.getUserName());
            }

            List<SysAmountAuditingEntity> list = baseMapper.queryPageOrderNew(params);
            pageHelper=new PageInfo(list);
            BasePageResult<SysAmountAuditingEntity> pageResult=new BasePageResult<SysAmountAuditingEntity>(sysAmountAuditingVo.getPageNum(), sysAmountAuditingVo.getPageSize(), pageHelper.getTotal(), pageHelper.getPages(), list);
            return HttpResult.ok(pageResult);
        }catch (Exception e){
            e.printStackTrace();
            return HttpResult.error("查询异常");
        }
    }

    @Override
    public BasePageResult<SysAmountAuditingEntity> queryAppPage(SysAmountAuditingVo sysAmountAuditingVo) {
        String id = BaseController.getUser().getId();
        sysAmountAuditingVo.setUserId(id);
        Page<SysAmountAuditingEntity> page = new Page<>(sysAmountAuditingVo.getPageNum(), sysAmountAuditingVo.getPageSize());
        QueryWrapper<SysAmountAuditingEntity> wrapper = new QueryWrapper<>();
        Page<SysAmountAuditingEntity> sysUserAccountHistoryPage = baseMapper.queryPageOrder(sysAmountAuditingVo, page);
        return new BasePageResult<>(sysAmountAuditingVo.getPageNum(), page.getSize(), sysUserAccountHistoryPage.getTotal(), page.getPages(),
                sysUserAccountHistoryPage.getRecords());
    }

    @Override
    public  List<SysAmountAuditingEntity> getProgressIng(HashMap<String, Object> params) {
        return  baseMapper.getProgressIng(params);

    }
}