【短信】结算账户不足通知

server/cloud-syb/src/main/java/com/shusi/modules/pay/service/impl/PaySettlementAccountServiceImpl.java

 package com.shusi.modules.pay.service.impl;
 
 
+import cn.hutool.json.JSONUtil;
 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.google.common.collect.Lists;
 import com.shusi.convertor.DataConverter;
 import com.shusi.convertor.DataType;
 import com.shusi.enums.SettlementAccountStatus;
@@ -17,14 +19,20 @@ import com.shusi.modules.pay.domain.dto.PaySettlementAccountQryDTO;
 import com.shusi.modules.pay.domain.dto.PaySettlementAccountUpdDTO;
 import com.shusi.modules.pay.domain.vo.PaySettlementAccountVO;
 import com.shusi.modules.pay.service.PaySettlementAccountService;
+import com.shusi.modules.sys.service.SysConfigService;
+import com.shusi.msg.MsgUtil;
 import com.shusi.util.DataUtil;
 import com.shusi.util.JsonUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.map.HashedMap;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import javax.annotation.Resource;
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 
 
@@ -40,6 +48,9 @@ import java.util.Set;
 @Slf4j
 public class PaySettlementAccountServiceImpl extends ServiceImpl<PaySettlementAccountDao, PaySettlementAccount> implements PaySettlementAccountService {
 
+    @Resource
+    private SysConfigService sysConfigService;
+
     @Override
     public Page<PaySettlementAccountVO> listPage(Page<PaySettlementAccountVO> page, PaySettlementAccountQryDTO paySettlementAccountQryDTO) {
         List<PaySettlementAccountVO> list = this.baseMapper.listPage(page, paySettlementAccountQryDTO);
@@ -64,6 +75,15 @@ public class PaySettlementAccountServiceImpl extends ServiceImpl<PaySettlementAc
             acc.setStatus(SettlementAccountStatus.USED.getValue());
             acc.setPayAccountId(payAccountId);
             boolean b = this.updateById(acc);
+            int size = accountList.size();
+            if (b && size <= 6) {
+                String financePhone = sysConfigService.getValue("finance_phone", "");
+                if (StringUtils.isNotBlank(financePhone)) {
+                    Map params = new HashedMap();
+                    params.put("count", size - 1);
+                    MsgUtil.sendToUser("pay_settlement_info", JSONUtil.toJsonStr(params), null, Lists.newArrayList(financePhone));
+                }
+            }
             return acc;
         } else {
             throw new BusinessException("未找到未使用的结算卡账户");