From d9865c5576c8ed413d2b69a36b3ec5f15bee015b Mon Sep 17 00:00:00 2001
From: value <z1292839451@163.com>
Date: 星期一, 22 四月 2024 00:33:36 +0800
Subject: [PATCH] 功能调整

---
 data-server/src/main/java/com/yuanchu/mom/service/impl/FansSubmitServiceImpl.java |   22 +++++++++++++++++++++-
 1 files changed, 21 insertions(+), 1 deletions(-)

diff --git a/data-server/src/main/java/com/yuanchu/mom/service/impl/FansSubmitServiceImpl.java b/data-server/src/main/java/com/yuanchu/mom/service/impl/FansSubmitServiceImpl.java
index 193955e..d468ac9 100644
--- a/data-server/src/main/java/com/yuanchu/mom/service/impl/FansSubmitServiceImpl.java
+++ b/data-server/src/main/java/com/yuanchu/mom/service/impl/FansSubmitServiceImpl.java
@@ -1,5 +1,6 @@
 package com.yuanchu.mom.service.impl;
 
+import cn.hutool.core.bean.BeanUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -97,7 +98,17 @@
             date2 = LocalDateTime.parse(date + "T00:00:00").minusDays(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
             fansSubmit.setCreateTime(LocalDateTime.parse(date + "T00:00:00"));
         }
-        fansSubmitMapper.insert(fansSubmit);
+        try {
+            FansSubmit fansSubmit1 = fansSubmitMapper.selectOne(Wrappers.<FansSubmit>lambdaQuery().eq(FansSubmit::getCustom, fansSubmit.getCustom()).eq(FansSubmit::getProduct, fansSubmit.getProduct()).eq(FansSubmit::getVx, fansSubmit.getVx()).last("limit 1"));
+            if(BeanUtil.isEmpty(fansSubmit1)){
+                fansSubmitMapper.insert(fansSubmit);
+            }else{
+                fansSubmit1.setFansAdd(fansSubmit.getFansAdd());
+                fansSubmitMapper.updateById(fansSubmit1);
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         List<FansSubmit> fansSubmits = fansSubmitMapper.selectList(Wrappers.<FansSubmit>lambdaQuery().eq(FansSubmit::getProduct, fansSubmit.getProduct()).eq(FansSubmit::getVx, fansSubmit.getVx()).select(FansSubmit::getFansAdd).like(FansSubmit::getCreateTime, date));
         Integer sum = 0;
         for (FansSubmit fansSubmit2 : fansSubmits) {
@@ -127,6 +138,15 @@
         queryWrapper.select("DISTINCT vx").like("create_time", format);
         return fansSubmitMapper.selectList(queryWrapper);
     }
+
+    @Override
+    public void deleteAllFans(String date) {
+        List<FansSubmit> list = fansSubmitMapper.selectList(Wrappers.<FansSubmit>lambdaQuery().eq(FansSubmit::getCreateUser, getLook.selectPowerByMethodAndUserId("selectDataReportingList").get("userId")).like(FansSubmit::getCreateTime, date).select(FansSubmit::getId));
+        for (FansSubmit fansSubmit : list) {
+            delFansSubmit(fansSubmit.getId());
+        }
+    }
+
 }
 
 

--
Gitblit v1.9.3