exit price

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileShowServiceImpl.java

@@ -180,19 +180,28 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
         if (smilePriceParam.getStatus().equals(0)) {
             //计算该用户的佣金
             Map userPerformance = orderTicketsMapper.getUserPerformanceByUidAndProId(smilePriceParam.getUid(),smilePriceParam.getPerformancesId());
-            smilePrice.setPrice(userPerformance.get("commiss")==null?new BigDecimal(0):new BigDecimal(userPerformance.get("commiss").toString()));
+            BigDecimal price = userPerformance.get("commiss") == null ? new BigDecimal(0) : new BigDecimal(userPerformance.get("commiss").toString());
+            smilePrice.setPrice(price);
             smilePrice.setCreatedDate(LocalDateTime.now());
             smilePriceMapper.insert(smilePrice);
             smileRedisUtils.setPriceByUid(smilePriceParam.getPerformancesId(), smilePriceParam.getUid());
+            //计算总营收
+            BigDecimal userTotalPrice = smileRedisUtils.getUserTotalPrice(smilePriceParam.getUid());
+            smileRedisUtils.setUserTotalPrice(smilePriceParam.getUid(),(price.add(userTotalPrice)).toString());
         } else {
-            //删除打款信息
-            smileRedisUtils.delPriceByUid(smilePriceParam.getPerformancesId(), smilePriceParam.getUid());
             LambdaQueryWrapper<SmilePrice> queryWrapper = Wrappers.lambdaQuery(SmilePrice.class);
             queryWrapper.eq(SmilePrice::getPerformancesId, smilePriceParam.getPerformancesId());
             queryWrapper.eq(SmilePrice::getUid, smilePriceParam.getUid());
+            queryWrapper.eq(SmilePrice::getDelTag,0);
+            SmilePrice smilePrice1 = smilePriceMapper.selectOne(queryWrapper);
+            BigDecimal userTotalPrice = smileRedisUtils.getUserTotalPrice(smilePriceParam.getUid());
+            smileRedisUtils.setUserTotalPrice(smilePriceParam.getUid(),(userTotalPrice.subtract(smilePrice1.getPrice())).toString());
+            //删除打款信息
+            smileRedisUtils.delPriceByUid(smilePriceParam.getPerformancesId(), smilePriceParam.getUid());
+            //更新打款表
             smilePrice.setUpdatedDate(LocalDateTime.now());
             smilePrice.setDelTag(1);
-            smilePriceMapper.update(smilePrice, queryWrapper);
+            smilePriceMapper.updateById(smilePrice);
         }
         return AjaxResult.success();
     }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/utils/SmileRedisUtils.java

@@ -9,6 +9,7 @@ import com.liquidnet.service.goblin.dto.vo.SmileUserVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.math.BigDecimal;
 import java.util.List;
 
 @Component
@@ -130,6 +131,14 @@ public class SmileRedisUtils {
         redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SMILE_AGENT.concat(performancesId).concat(":").concat(ticketId), smileAgentVo);
     }
 
+    public BigDecimal getUserTotalPrice(String uid) {
+       return new BigDecimal((redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SELL_USER_REVENUE.concat(uid)))==null ? "0":(String) (redisDataSourceUtil.getRedisSweetUtil().get(SmileRedisConst.SELL_USER_REVENUE.concat(uid))));
+    }
+
+    public void setUserTotalPrice(String uid, String add) {
+        redisDataSourceUtil.getRedisSweetUtil().set(SmileRedisConst.SELL_USER_REVENUE.concat(uid),add);
+    }
+
 
     /*public Boolean set(String key, Object value){
         return redisDataSourceUtil.getRedisSweetUtil().set(key, value);