123

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppUserSellingWaterBiz.java

@@ -5,6 +5,7 @@ import com.github.wxiaoqi.security.admin.dto.OrderGoodsDTO;
 import com.github.wxiaoqi.security.admin.dto.OrderWaterDTO;
 import com.github.wxiaoqi.security.admin.entity.AppUserRelation;
 import com.github.wxiaoqi.security.admin.entity.MyWalletDetail;
+import com.github.wxiaoqi.security.admin.mapper.MyWalletDetailMapper;
 import com.github.wxiaoqi.security.admin.vo.AppUserVo;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections.CollectionUtils;
@@ -46,6 +47,11 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper,Ap
     @Autowired
     AppUserDetailBiz  detailBiz;
 
+    @Autowired
+    MyWalletDetailMapper walletDetailMapper;
+
+
+
      //购买计算用户拥金
      public  void payOrderWater(OrderWaterDTO orderWaterDTO){
 
@@ -151,6 +157,8 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper,Ap
             walletDetail.setCono(orderId);
             walletDetail.setItype(1);
             walletDetail.setAmount(amount);
+            walletDetailMapper.insertSelective(walletDetail);
+
 
 
         }

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/MyWaterBiz.java

+package com.github.wxiaoqi.security.admin.biz;
+
+import com.github.wxiaoqi.security.admin.entity.MyWallet;
+import com.github.wxiaoqi.security.admin.entity.MyWalletDetail;
+import com.github.wxiaoqi.security.admin.mapper.MyWalletDetailMapper;
+import com.github.wxiaoqi.security.admin.mapper.MyWalletMapper;
+import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+
+/**
+ * 钱包
+ *
+ * @author libin
+ * @email 18178966185@163.com
+ * @date 2019-07-09 10:00:42
+ */
+@Service
+@Slf4j
+public class MyWaterBiz extends BaseBiz<MyWalletMapper, MyWallet>{
+
+
+    @Autowired
+    MyWalletDetailMapper walletDetailMapper;
+
+
+    //更新我的钱包
+    public  void updMyWater(Integer userId, Integer orderId,BigDecimal amount){
+        log.info("---更新我的钱包----userId==="+userId+"----orderId===="+orderId+"----amount===="+amount);
+        MyWallet wallet=new MyWallet();
+        wallet.setUserId(userId);
+        wallet=selectOne(wallet);
+        //进账之前余额
+        BigDecimal balance=new BigDecimal("0.00");
+        //已提现金额
+        BigDecimal withdrawals=new BigDecimal("0.00");
+        //进账总额(元)
+        BigDecimal totalAmount=new BigDecimal("0.00");
+        //今日收益
+        BigDecimal todayAmount=new BigDecimal("0.00");
+        //未入账金额
+        BigDecimal unbooked=new BigDecimal("0.00");
+        Integer id=0;
+        if(wallet==null){
+            wallet=new MyWallet();
+            wallet.setUserId(userId);
+            totalAmount=amount;
+            todayAmount=amount;
+        }else {
+            id=wallet.getId();
+            balance=wallet.getBalance();
+            wallet.setBalance(balance.add(amount));
+        }
+        MyWalletDetail walletDetail=new MyWalletDetail();
+        walletDetail.setUserId(userId);
+        walletDetail.setSource(1);
+        walletDetail.setCono(orderId);
+        walletDetail.setItype(1);
+        walletDetail.setAmount(amount);
+        walletDetail.setBalance(balance);
+        walletDetailMapper.insertSelective(walletDetail);
+    }
+
+}
\ No newline at end of file