帐户清除

ace-common/src/main/java/com/github/wxiaoqi/security/common/biz/BaseBiz.java

@@ -10,6 +10,7 @@ import tk.mybatis.mapper.common.Mapper;
 import tk.mybatis.mapper.entity.Example;
 
 import java.lang.reflect.ParameterizedType;
+import java.util.Collection;
 import java.util.List;
 import java.util.Map;
 
@@ -116,4 +117,5 @@ public abstract class BaseBiz<M extends Mapper<T>, T> {
         List<T> list = mapper.selectByExample(example);
         return new TableResultResponse<T>(result.getTotal(), list);
     }
+
 }

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

@@ -14,6 +14,7 @@ import org.springframework.transaction.annotation.Transactional;
 import tk.mybatis.mapper.entity.Example;
 
 import java.time.Instant;
+import java.util.Collection;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -110,9 +111,16 @@ public class AppUserDetailBiz extends BaseBiz<AppUserDetailMapper, AppUserDetail
         criteria.andIn("userid", memberIds);
         List<AppUserDetail> appUserDetails = mapper.selectByExample(example);
 
-        if (CollectionUtils.isNotEmpty(appUserDetails)){
+        if (CollectionUtils.isNotEmpty(appUserDetails)) {
             userIdAndAppUserDetailMap = appUserDetails.stream().collect(Collectors.toMap(AppUserDetail::getUserid, Function.identity()));
         }
         return userIdAndAppUserDetailMap;
     }
+
+    public void deleteByUserIds(Collection<Integer> userIds) {
+        Example example = new Example(AppUserDetail.class);
+        Example.Criteria criteria = example.createCriteria();
+        criteria.andIn("userid", userIds);
+        mapper.deleteByExample(example);
+    }
 }

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

@@ -198,4 +198,11 @@ public class AppUserLoginBiz extends BaseBiz<AppUserLoginMapper, AppUserLogin> {
     public void available(AppUserLogin appUserLogin) {
         mapper.updateByPrimaryKeySelective(appUserLogin);
     }
+
+    public void deleteByPhones(List<String> phons) {
+        Example example = new Example(AppUserLogin.class);
+        Example.Criteria criteria = example.createCriteria();
+        criteria.andIn("username",phons);
+        mapper.deleteByExample(example);
+    }
 }

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

@@ -241,4 +241,11 @@ public class AppUserRelationBiz extends BaseBiz<AppUserRelationMapper,AppUserRel
         memberSateAndCountMap.put(1,activityCount);
         return memberSateAndCountMap;
     }
+
+    public void deleteByMemberIds(Collection<Integer> userIds) {
+     Example example = new Example(AppUserRelation.class);
+        Example.Criteria criteria = example.createCriteria();
+        criteria.andIn("userId",userIds);
+        mapper.deleteByExample(example);
+    }
 }
\ No newline at end of file

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

@@ -344,4 +344,11 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper, A
     public BigDecimal selectTotalIncomeByUserId(Integer userId) {
         return mapper.selectTotalIncomeByUserId(userId);
     }
+
+    public void deleteByMemberIds(Collection<Integer> userIds) {
+         Example example = new Example(AppUserSellingWater.class);
+        Example.Criteria criteria = example.createCriteria();
+        criteria.andIn("sourceId",userIds);
+        mapper.deleteByExample(example);
+    }
 }
\ No newline at end of file

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rest/DataController.java

+package com.github.wxiaoqi.security.admin.rest;
+
+import com.github.wxiaoqi.security.admin.biz.AppUserDetailBiz;
+import com.github.wxiaoqi.security.admin.biz.AppUserLoginBiz;
+import com.github.wxiaoqi.security.admin.biz.AppUserRelationBiz;
+import com.github.wxiaoqi.security.admin.biz.AppUserSellingWaterBiz;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.xxfc.platform.activity.feign.ActivityFeign;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/24 15:11
+ */
+@RestController
+@RequestMapping("/app/unauth/user_data")
+public class DataController {
+
+    @Autowired
+    private AppUserLoginBiz appUserLoginBiz;
+
+    @Autowired
+    private AppUserDetailBiz appUserDetailBiz;
+
+    @Autowired
+    private AppUserRelationBiz appUserRelationBiz;
+
+    @Autowired
+    private AppUserSellingWaterBiz appUserSellingWaterBiz;
+
+    @Autowired
+    private ActivityFeign activityFeign;
+
+    @GetMapping("/clearByPhone")
+    public ObjectRestResponse<Void> clearData(@RequestParam("phones") List<String> phons) {
+
+        Map<String, Integer> phoneAndUserIdMapByPhones = appUserLoginBiz.findPhoneAndUserIdMapByPhones(phons);
+        Collection<Integer> userIds = phoneAndUserIdMapByPhones.values();
+        appUserLoginBiz.deleteByPhones(phons);
+        appUserDetailBiz.deleteByUserIds(userIds);
+        appUserRelationBiz.deleteByMemberIds(userIds);
+        appUserSellingWaterBiz.deleteByMemberIds(userIds);
+        activityFeign.clearDate(new ArrayList<>(userIds));
+        return ObjectRestResponse.succ();
+    }
+}
\ No newline at end of file

xx-activity/xx-activity-api/src/main/java/com/xxfc/platform/activity/feign/ActivityFeign.java

@@ -49,4 +49,7 @@ public interface ActivityFeign {
     @RequestMapping(value = "/join/user", method = RequestMethod.POST)
     public ObjectRestResponse join(@RequestParam(value = "userId",defaultValue ="0" ) Integer userId);
 
+     @GetMapping("/activity_data/clear")
+     ObjectRestResponse<Void> clearDate(@RequestParam(value = "userIds") List<Integer>  userIds);
+
 }

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/ActivityPopularizeUserBiz.java

@@ -7,6 +7,9 @@ import org.springframework.stereotype.Service;
 import com.xxfc.platform.activity.entity.ActivityPopularizeUser;
 import com.xxfc.platform.activity.mapper.ActivityPopularizeUserMapper;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.List;
 
 /**
  * 用户与推广活动（邀请有礼）的关系表
@@ -24,4 +27,11 @@ public class ActivityPopularizeUserBiz extends BaseBiz<ActivityPopularizeUserMap
             throw new BaseException(ResultCode.DB_OPERATION_FAIL_CODE);
         }
     }
+
+    public void deleteByUserIds(List<Integer> userIds) {
+        Example example  = new Example(ActivityPopularizeUser.class);
+        Example.Criteria criteria = example.createCriteria();
+        criteria.andIn("userId",userIds);
+        mapper.deleteByExample(example);
+    }
 }
\ No newline at end of file

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/rest/DateController.java

+package com.xxfc.platform.activity.rest;
+
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.xxfc.platform.activity.biz.ActivityPopularizeUserBiz;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * @author libin
+ * @version 1.0
+ * @description
+ * @data 2019/7/24 14:58
+ */
+@RestController
+@RequestMapping("/activity_data")
+public class DateController {
+
+       @Autowired
+        private ActivityPopularizeUserBiz activityPopularizeUserBiz;
+
+      @GetMapping("/clear")
+      public ObjectRestResponse<Void> clearDate(@RequestParam(value = "userIds") List<Integer>  userIds){
+          activityPopularizeUserBiz.deleteByUserIds(userIds);
+          return ObjectRestResponse.succ();
+      }
+}

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/rest/admin/CouponAdminController.java

@@ -66,6 +66,6 @@ public class CouponAdminController {
     @GetMapping("check/{id}")
     public Boolean checkCouponHasUsedById(@PathVariable(value = "id") Integer id){
 
-        return true;
+        return false;
     }
 }