营销系统-保存用户新增和活跃数据

pig-statistics/pig-statistics-api/src/main/java/com/pig4cloud/pig/statistics/api/feign/RemoteStatUserDataService.java

@@ -20,4 +20,12 @@ public interface RemoteStatUserDataService {
 	@PostMapping("/user/active/save")
 	R<Boolean> saveMktStatActiveUser(@RequestBody MktStatActiveUser data);
 
+	@NoToken
+	@PostMapping("/user/new/update")
+	R<Boolean> updateMktStatNewUser(@RequestBody MktStatNewUser data);
+
+	@NoToken
+	@PostMapping("/user/active/update")
+	R<Boolean> updateMktStatActiveUser(@RequestBody MktStatActiveUser data);
+
 }

pig-statistics/pig-statistics-biz/src/main/java/com/pig4cloud/pig/statistics/service/UserAnalyseService.java

@@ -161,9 +161,23 @@ public interface UserAnalyseService {
 	Boolean saveMktStatNewUser(MktStatNewUser data);
 
 	/**
-	 * 保存新增用戶数据
+	 * 保存活跃用戶数据
 	 * @param data
 	 * @return
 	 */
 	Boolean saveMktStatActiveUser(MktStatActiveUser data);
+
+	/**
+	 * 修改新增用户数据
+	 * @param data
+	 * @return
+	 */
+	Boolean updateMktStatNewUser(MktStatNewUser data);
+
+	/**
+	 * 修改活跃用户数据
+	 * @param data
+	 * @return
+	 */
+	Boolean updateMktStatActiveUser(MktStatActiveUser data);
 }

pig-statistics/pig-statistics-biz/src/main/java/com/pig4cloud/pig/statistics/service/impl/UserAnalyseServiceImpl.java

@@ -3,6 +3,7 @@ package com.pig4cloud.pig.statistics.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.pig4cloud.pig.common.core.exception.BusinessException;
@@ -1170,6 +1171,28 @@ public class UserAnalyseServiceImpl implements UserAnalyseService {
 		return activeUserMapper.insert(data) == 1;
 	}
 
+	@Override
+	public Boolean updateMktStatNewUser(MktStatNewUser data) {
+		LambdaUpdateWrapper<MktStatNewUser> updateWrapper = new LambdaUpdateWrapper<>();
+		updateWrapper.eq(MktStatNewUser::getUserId, data.getUserId());
+		updateWrapper.eq(MktStatNewUser::getVersion, "0.0.0");
+		updateWrapper.eq(MktStatNewUser::getChannel, "应用市场");
+		updateWrapper.set(MktStatNewUser::getAppId, data.getAppId());
+		int update = newUserMapper.update(null, updateWrapper);
+		return update == 1;
+	}
+
+	@Override
+	public Boolean updateMktStatActiveUser(MktStatActiveUser data) {
+		LambdaUpdateWrapper<MktStatActiveUser> updateWrapper = new LambdaUpdateWrapper<>();
+		updateWrapper.eq(MktStatActiveUser::getUserId, data.getUserId());
+		updateWrapper.eq(MktStatActiveUser::getVersion, "0.0.0");
+		updateWrapper.eq(MktStatActiveUser::getChannel, "应用市场");
+		updateWrapper.set(MktStatActiveUser::getAppId, data.getAppId());
+		int update = activeUserMapper.update(null, updateWrapper);
+		return update == 1;
+	}
+
 
 	/************************************** 公用方法 **************************************
 	 * 统计指定时间范围内的新增用户数