Przeglądaj źródła

去除人群包1.0无效代码

zhaoxian 4 lat temu
rodzic
commit
21a97c896f

+ 0 - 403
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/ai/controller/KuaishouCrowdPackController.java

@@ -1,403 +0,0 @@
-package cn.com.ctop.kuaishou.modules.ai.controller;
-
-import cn.com.ctop.common.module.annotation.AutoLog;
-import cn.com.ctop.common.module.utils.Check;
-import cn.com.ctop.common.module.utils.QueryGenerator;
-import cn.com.ctop.kuaishou.modules.ai.entity.KuaishouCrowdPack;
-import cn.com.ctop.kuaishou.modules.ai.service.IKuaishouCrowdPackService;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.common.api.vo.Result;
-import org.jeecg.common.util.oConvertUtils;
-import org.jeecgframework.poi.excel.ExcelImportUtil;
-import org.jeecgframework.poi.excel.def.NormalExcelConstants;
-import org.jeecgframework.poi.excel.entity.ExportParams;
-import org.jeecgframework.poi.excel.entity.ImportParams;
-import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.DeleteMapping;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
-import org.springframework.web.multipart.MultipartFile;
-import org.springframework.web.multipart.MultipartHttpServletRequest;
-import org.springframework.web.servlet.ModelAndView;
-
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import java.io.IOException;
-import java.io.UnsupportedEncodingException;
-import java.net.URLDecoder;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 人群报表
- *
- * @author jeecg-boot
- * @version V1.0
- * @date 2021-03-26
- */
-@Slf4j
-@Api(tags = "人群报表")
-@RestController
-@RequestMapping("/kuaishouCrowdPack")
-public class KuaishouCrowdPackController {
-    @Autowired
-    private IKuaishouCrowdPackService kuaishouCrowdPackService;
-
-    /**
-     * 分页列表查询
-     *
-     * @param kuaishouCrowdPack
-     * @param pageNo
-     * @param pageSize
-     * @param req
-     * @return
-     */
-    @AutoLog(value = "人群报表-分页列表查询")
-    @ApiOperation(value = "人群报表-分页列表查询", notes = "人群报表-分页列表查询")
-    @GetMapping(value = "/list")
-    public Result<IPage<KuaishouCrowdPack>> list(KuaishouCrowdPack kuaishouCrowdPack,
-                                                 @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
-                                                 @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize,
-                                                 HttpServletRequest req) {
-        Result<IPage<KuaishouCrowdPack>> result = new Result<>();
-        QueryWrapper<KuaishouCrowdPack> queryWrapper = QueryGenerator.initQueryWrapper(kuaishouCrowdPack, req.getParameterMap());
-        Page<KuaishouCrowdPack> page = new Page<KuaishouCrowdPack>(pageNo, pageSize);
-        IPage<KuaishouCrowdPack> pageList = kuaishouCrowdPackService.page(page, queryWrapper);
-        result.setSuccess(true);
-        result.setResult(pageList);
-        return result;
-    }
-
-    /**
-     * 人群包列表
-     *
-     * @param
-     * @return org.jeecg.common.api.vo.Result<java.lang.Object>
-     * @throws
-     * @author ZHAOXA
-     */
-    @GetMapping(value = "/queryPageList")
-    public Result<Object> queryPageList(KuaishouCrowdPack kuaishouCrowdPack,
-                                        @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
-                                        @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
-        try {
-            return kuaishouCrowdPackService.queryPageList(kuaishouCrowdPack, pageNo, pageSize);
-        } catch (Exception e) {
-            log.error("查询异常,", e.getMessage());
-            e.printStackTrace();
-        }
-        return Result.error("查询失败");
-    }
-
-    /**
-     * 相关账户查询
-     *
-     * @param
-     * @return org.jeecg.common.api.vo.Result<java.lang.Object>
-     * @throws
-     * @author ZHAOXA
-     */
-    @GetMapping(value = "/queryRel")
-    public Result<Object> queryRel(String type, String signature,
-                                   @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
-                                   @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
-        try {
-            if (Check.isNull(type) || Check.isNull(signature)) {
-                return Result.error("缺失参数");
-            }
-            return kuaishouCrowdPackService.queryRel(type, signature, pageNo, pageSize);
-        } catch (Exception e) {
-            log.error("查询异常,", e.getMessage());
-            e.printStackTrace();
-        }
-        return Result.error("查询失败");
-    }
-
-    /**
-     * 查询原因
-     *
-     * @param
-     * @return org.jeecg.common.api.vo.Result<java.lang.Object>
-     * @throws
-     * @author ZHAOXA
-     */
-    @GetMapping(value = "/queryFailReason")
-    public Result<Object> queryFailReason(String signature,
-                                          @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
-                                          @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
-        try {
-            return kuaishouCrowdPackService.queryFailReason(signature, pageNo, pageSize);
-        } catch (Exception e) {
-            log.error("查询异常,", e.getMessage());
-            e.printStackTrace();
-        }
-        return Result.error("查询失败");
-    }
-
-    /**
-     * 上传前的人群包校验
-     *
-     * @param
-     * @return org.jeecg.common.api.vo.Result<java.lang.Object>
-     * @throws
-     * @author ZHAOXA
-     */
-    @GetMapping(value = "/checkCrowdPackage")
-    public Result<Object> checkCrowdPackage(String signature) {
-        try {
-            return kuaishouCrowdPackService.checkCrowdPackage(signature);
-        } catch (Exception e) {
-            log.error("查询异常,", e.getMessage());
-            e.printStackTrace();
-        }
-        return Result.error("查询失败");
-    }
-
-    /**
-     * 上传人群包
-     *
-     * @param kuaishouCrowdPack
-     * @return
-     */
-
-    @PostMapping(value = "/uploadCrowdPack")
-    public Result<Object> uploadCrowdPack(@RequestBody JSONObject request) {
-        Integer type = request.getInteger("type");
-        String orientationName = request.getString("orientationName");
-        Long accountId = request.getLong("accountId");
-        String url = request.getString("url");
-        try {
-            if (Check.isNull(type) || Check.isNull(orientationName) || Check.isNull(url) || Check.isNull(accountId)) {
-                return Result.error("缺少参数");
-            }
-            return kuaishouCrowdPackService.uploadCrowdPack(type, orientationName, accountId, url);
-        } catch (Exception e) {
-            log.error("上传异常,", e.getMessage());
-            e.printStackTrace();
-        }
-        return Result.error("上传失败");
-    }
-
-    /**
-     * 账户推送
-     *
-     * @param kuaishouCrowdPack
-     * @return
-     */
-    @AutoLog(value = "账户推送")
-    @ApiOperation(value = "账户推送", notes = "账户推送")
-    @PostMapping(value = "/accountPush")
-    public Result<Object> accountPush(@RequestBody JSONObject request) {
-        try {
-            JSONArray accountIds = request.getJSONArray("accountIds");
-            String signature = request.getString("signature");
-            if (Check.isNull(accountIds) || Check.isNull(signature)) {
-                return Result.error("缺少参数");
-            }
-            return kuaishouCrowdPackService.accountPush(request);
-        } catch (Exception e) {
-            log.error("查询异常,", e.getMessage());
-            e.printStackTrace();
-        }
-        return Result.error("查询失败");
-    }
-
-    @RequestMapping(value = "/crowdListQuery")
-    public Result<Object> crowdListQuery() {
-        try {
-            kuaishouCrowdPackService.crowdListQuery();
-            return Result.ok("success");
-        } catch (Exception e) {
-            log.error("查询异常,", e.getMessage());
-            e.printStackTrace();
-        }
-        return Result.error("查询失败");
-    }
-
-    /**
-     * 添加
-     *
-     * @param kuaishouCrowdPack
-     * @return
-     */
-    @AutoLog(value = "人群报表-添加")
-    @ApiOperation(value = "人群报表-添加", notes = "人群报表-添加")
-    @PostMapping(value = "/add")
-    public Result<KuaishouCrowdPack> add(@RequestBody KuaishouCrowdPack kuaishouCrowdPack) {
-        Result<KuaishouCrowdPack> result = new Result<>();
-        try {
-            kuaishouCrowdPackService.save(kuaishouCrowdPack);
-            result.success("添加成功!");
-        } catch (Exception e) {
-            log.error(e.getMessage(), e);
-            result.error500("操作失败");
-        }
-        return result;
-    }
-
-    /**
-     * 编辑
-     *
-     * @param kuaishouCrowdPack
-     * @return
-     */
-    @AutoLog(value = "人群报表-编辑")
-    @ApiOperation(value = "人群报表-编辑", notes = "人群报表-编辑")
-    @PostMapping(value = "/edit")
-    public Result<KuaishouCrowdPack> edit(@RequestBody KuaishouCrowdPack kuaishouCrowdPack) {
-        Result<KuaishouCrowdPack> result = new Result<KuaishouCrowdPack>();
-        KuaishouCrowdPack kuaishouCrowdPackEntity = kuaishouCrowdPackService.getById(kuaishouCrowdPack.getId());
-        if (kuaishouCrowdPackEntity == null) {
-            result.error500("未找到对应实体");
-        } else {
-            boolean ok = kuaishouCrowdPackService.updateById(kuaishouCrowdPack);
-            if (ok) {
-                result.success("修改成功!");
-            }
-        }
-        return result;
-    }
-
-    /**
-     * 通过id删除
-     *
-     * @param id
-     * @return
-     */
-    @AutoLog(value = "人群报表-通过id删除")
-    @ApiOperation(value = "人群报表-通过id删除", notes = "人群报表-通过id删除")
-    @GetMapping(value = "/delete")
-    public Result<Object> delete(KuaishouCrowdPack kuaishouCrowdPack) {
-        KuaishouCrowdPack kuaishouCrowdPackEntity = kuaishouCrowdPackService.getById(kuaishouCrowdPack.getId());
-        if (kuaishouCrowdPackEntity == null) {
-            return Result.error("未找到对应实体");
-        } else {
-            kuaishouCrowdPackEntity.setDataStatus(0);
-            return kuaishouCrowdPackService.updateDataStatus(kuaishouCrowdPackEntity);
-        }
-    }
-
-    /**
-     * 批量删除
-     *
-     * @param ids
-     * @return
-     */
-    @AutoLog(value = "人群报表-批量删除")
-    @ApiOperation(value = "人群报表-批量删除", notes = "人群报表-批量删除")
-    @DeleteMapping(value = "/deleteBatch")
-    public Result<KuaishouCrowdPack> deleteBatch(@RequestParam(name = "ids", required = true) String ids) {
-        Result<KuaishouCrowdPack> result = new Result<>();
-        if (ids == null || "".equals(ids.trim())) {
-            result.error500("参数不识别!");
-        } else {
-            this.kuaishouCrowdPackService.removeByIds(Arrays.asList(ids.split(",")));
-            result.success("删除成功!");
-        }
-        return result;
-    }
-
-    /**
-     * 通过id查询
-     *
-     * @param id
-     * @return
-     */
-    @AutoLog(value = "人群报表-通过id查询")
-    @ApiOperation(value = "人群报表-通过id查询", notes = "人群报表-通过id查询")
-    @GetMapping(value = "/queryById")
-    public Result<KuaishouCrowdPack> queryById(@RequestParam(name = "id", required = true) String id) {
-        Result<KuaishouCrowdPack> result = new Result<>();
-        KuaishouCrowdPack kuaishouCrowdPack = kuaishouCrowdPackService.getById(id);
-        if (kuaishouCrowdPack == null) {
-            result.error500("未找到对应实体");
-        } else {
-            result.setResult(kuaishouCrowdPack);
-            result.setSuccess(true);
-        }
-        return result;
-    }
-
-    /**
-     * 导出excel
-     *
-     * @param request
-     * @param response
-     */
-    @RequestMapping(value = "/exportXls")
-    public ModelAndView exportXls(HttpServletRequest request, HttpServletResponse response) {
-        // Step.1 组装查询条件
-        QueryWrapper<KuaishouCrowdPack> queryWrapper = null;
-        try {
-            String paramsStr = request.getParameter("paramsStr");
-            if (oConvertUtils.isNotEmpty(paramsStr)) {
-                String deString = URLDecoder.decode(paramsStr, "UTF-8");
-                KuaishouCrowdPack kuaishouCrowdPack = JSON.parseObject(deString, KuaishouCrowdPack.class);
-                queryWrapper = QueryGenerator.initQueryWrapper(kuaishouCrowdPack, request.getParameterMap());
-            }
-        } catch (UnsupportedEncodingException e) {
-            e.printStackTrace();
-        }
-
-        //Step.2 AutoPoi 导出Excel
-        ModelAndView mv = new ModelAndView(new JeecgEntityExcelView());
-        List<KuaishouCrowdPack> pageList = kuaishouCrowdPackService.list(queryWrapper);
-        //导出文件名称
-        mv.addObject(NormalExcelConstants.FILE_NAME, "人群报表列表");
-        mv.addObject(NormalExcelConstants.CLASS, KuaishouCrowdPack.class);
-        mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("人群报表列表数据", "导出人:Jeecg", "导出信息"));
-        mv.addObject(NormalExcelConstants.DATA_LIST, pageList);
-        return mv;
-    }
-
-    /**
-     * 通过excel导入数据
-     *
-     * @param request
-     * @param response
-     * @return
-     */
-    @RequestMapping(value = "/importExcel", method = RequestMethod.POST)
-    public Result<?> importExcel(HttpServletRequest request, HttpServletResponse response) {
-        MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
-        Map<String, MultipartFile> fileMap = multipartRequest.getFileMap();
-        for (Map.Entry<String, MultipartFile> entity : fileMap.entrySet()) {
-            MultipartFile file = entity.getValue();
-            ImportParams params = new ImportParams();
-            params.setTitleRows(2);
-            params.setHeadRows(1);
-            params.setNeedSave(true);
-            try {
-                List<KuaishouCrowdPack> listKuaishouCrowdPacks = ExcelImportUtil.importExcel(file.getInputStream(), KuaishouCrowdPack.class, params);
-                kuaishouCrowdPackService.saveBatch(listKuaishouCrowdPacks);
-                return Result.ok("文件导入成功!数据行数:" + listKuaishouCrowdPacks.size());
-            } catch (Exception e) {
-                log.error(e.getMessage(), e);
-                return Result.error("文件导入失败:" + e.getMessage());
-            } finally {
-                try {
-                    file.getInputStream().close();
-                } catch (IOException e) {
-                    e.printStackTrace();
-                }
-            }
-        }
-        return Result.ok("文件导入失败!");
-    }
-
-}

+ 0 - 41
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/ai/mapper/KuaishouCrowdPackMapper.java

@@ -1,41 +0,0 @@
-package cn.com.ctop.kuaishou.modules.ai.mapper;
-
-import cn.com.ctop.kuaishou.modules.ai.entity.KuaishouCrowdPack;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import org.apache.ibatis.annotations.Param;
-
-import java.util.List;
-
-/**
- * 人群报表
- *
- * @author: jeecg-boot
- * @date: 2021-03-26
- * @cersion: V1.0
- */
-public interface KuaishouCrowdPackMapper extends BaseMapper<KuaishouCrowdPack> {
-
-    Long getTotal(@Param(value = "status") Integer status, @Param(value = "accountId") Long accountId, @Param(value = "orientationName") String orientationName);
-
-    List<JSONObject> queryPageList(@Param(value = "status") Integer status, @Param(value = "accountId") Long accountId, @Param(value = "orientationName") String orientationName);
-
-    List<KuaishouCrowdPack> queryListByStatus();
-
-    List<JSONObject> queryFailReason(@Param(value = "signature") String signature);
-
-    List<JSONObject> queryRelAccounts(@Param(value = "signature") String signature);
-
-    List<JSONObject> queryRelProject(@Param(value = "signature") String signature);
-
-    void replaceBatch(@Param(value = "list") List<KuaishouCrowdPack> list);
-
-    Integer queryProjectCount(@Param(value = "signature") String signature);
-
-    KuaishouCrowdPack queryByAccountId(@Param(value = "accountId") Long accountId, @Param(value = "orientationId") Long orientationId);
-
-    Integer queryAccountCount(@Param(value = "signature") String signature);
-
-    void update(JSONObject obj);
-}

+ 0 - 344
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/ai/mapper/xml/KuaishouCrowdPackMapper.xml

@@ -1,344 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="cn.com.ctop.kuaishou.modules.ai.mapper.KuaishouCrowdPackMapper">
-
-    <select id="getTotal" resultType="java.lang.Long">
-        SELECT  IFNULL(COUNT(1),0) FROM(
-        SELECT 1
-        FROM ctop_kuaishou_crowd_package t1
-        LEFT JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-        WHERE t1.`status` is not null
-        AND t1.`status`!=2
-        and t1.data_status = 1
-        AND t1.signature is not null
-        <if test="orientationName !=null">
-            AND orientation_name LIKE CONCAT('%',#{orientationName},'%')
-        </if>
-        <if test="accountId !=null">
-            AND t2.account_id = #{accountId}
-        </if>
-        <if test="status !=null">
-            AND t1.`status` =#{status}
-        </if>
-        GROUP BY t1.signature
-        ) t
-    </select>
-
-    <select id="queryPageList" resultType="com.alibaba.fastjson.JSONObject">
-        SELECT t1.id,
-        t1.account_id as 'accountId',
-        t2.auth_name as 'accountName',
-        IFNULL(stat_date,'') as 'statDate',
-        IFNULL(t1.orientation_id,'') as 'orientationId',
-        IFNULL(orientation_name,'') as 'orientationName',
-        IFNULL(url,'') as 'url',
-        IFNULL(population_type,'') as 'populationType',
-        IFNULL(t1.type,'') as 'type',
-        CASE t1.type
-        WHEN 1 THEN 'IMEI'
-        WHEN 2 THEN 'IDFA'
-        WHEN 3 THEN 'IMEI_MD5'
-        WHEN 4 THEN 'IDFA_MD5'
-        WHEN 5 THEN '手机号-MD5'
-        WHEN 7 THEN 'OAID'
-        WHEN 8 THEN 'OAID_MD5'
-        ELSE ''
-        END as 'typeStr',
-        <if test="status ==null">
-            t4.statusStr,
-            t4.`status`,
-        </if>
-        <if test="status !=null">
-            t1.`status`,
-            CASE t1.`status`
-            WHEN 0 THEN '计算中'
-            WHEN 1 THEN '已生效'
-            WHEN 3 THEN '推送中'
-            WHEN 4 THEN '已推送'
-            WHEN 5 THEN '计算失败'
-            WHEN 6 THEN '推送失败'
-            WHEN 7 THEN '已失效'
-            ELSE ''
-            END as 'statusStr',
-        </if>
-        IFNULL(t1.signature,'') as 'signature',
-        IFNULL(cover_num,0) as 'coverNum'
-        FROM ctop_kuaishou_crowd_package t1
-        LEFT JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-        LEFT JOIN (
-        SELECT t.signature ,COUNT(1) as 'num' FROM (SELECT DISTINCT signature, t2.project_id FROM
-        ctop_kuaishou_crowd_package t1
-        INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-        where orientation_id is not null
-        GROUP BY project_id) t
-        ) t3 ON t1.signature = t3.signature
-        left join
-        (
-        SELECT signature,
-        CASE maxlevel
-        WHEN 66 THEN '计算中'
-        WHEN 77 THEN '已生效'
-        WHEN 88 THEN '推送中'
-        WHEN 99 THEN '已推送'
-        WHEN 33 THEN '计算失败'
-        WHEN 44 THEN '推送失败'
-        WHEN 55 THEN '已失效'
-        ELSE ''
-        END as 'statusStr',
-        CASE maxlevel
-        WHEN 66 THEN 0
-        WHEN 77 THEN 1
-        WHEN 88 THEN 3
-        WHEN 99 THEN 4
-        WHEN 33 THEN 5
-        WHEN 44 THEN 6
-        WHEN 55 THEN 7
-        ELSE -1
-        END as 'status'
-        FROM (
-        SELECT signature,max(level) as 'maxlevel' FROM (
-        SELECT signature,
-        CASE t1.`status`
-        WHEN 0 THEN 66
-        WHEN 1 THEN 77
-        WHEN 3 THEN 88
-        WHEN 4 THEN 99
-        WHEN 5 THEN 33
-        WHEN 6 THEN 44
-        WHEN 7 THEN 55
-        ELSE ''
-        END as 'level'
-        FROM ctop_kuaishou_crowd_package t1
-        where signature IN(
-        SELECT signature
-        FROM ctop_kuaishou_crowd_package t1
-        LEFT JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-        WHERE t1.`status` is not null
-        AND t1.`status`!=2
-        and t1.data_status = 1
-        AND t1.signature is not null
-        <if test="orientationName !=null">
-            AND orientation_name LIKE CONCAT('%',#{orientationName},'%')
-        </if>
-        <if test="accountId !=null">
-            AND t2.account_id =#{accountId}
-        </if>
-        GROUP BY t1.signature
-        )
-        GROUP BY t1.signature,`status`
-        )t1
-        GROUP BY signature
-        ) t2
-        ) t4 ON t1.signature = t4.signature
-        WHERE t1.`status` is not null
-        AND t1.`status`!=2
-        and t1.data_status = 1
-        AND t1.signature is not null
-        <if test="orientationName !=null">
-            AND orientation_name LIKE CONCAT('%',#{orientationName},'%')
-        </if>
-        <if test="accountId !=null">
-            AND t2.account_id =#{accountId}
-        </if>
-        <if test="status !=null">
-            AND t1.`status` =#{status}
-        </if>
-        GROUP BY t1.signature
-        order by t1.update_time desc
-    </select>
-
-    <select id="queryListByStatus" resultType="cn.com.ctop.kuaishou.modules.ai.entity.KuaishouCrowdPack">
-        SELECT account_id
-        FROM ctop_kuaishou_crowd_package
-        WHERE `status` !=2
-        GROUP BY account_id
-    </select>
-
-    <select id="queryFailReason" resultType="com.alibaba.fastjson.JSONObject">
-        SELECT DISTINCT IFNULL(t3.project_name, null) as 'projectName', IFNULL(t2.auth_name, null)as 'accountName', IFNULL(t1.message, null) as 'message'
-        FROM ctop_kuaishou_crowd_package t1
-                 INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-                 INNER JOIN ctop_project t3 ON t2.project_id = t3.id
-        WHERE t1.signature = #{signature}
-          AND t1.data_status = 0
-    </select>
-
-    <select id="queryRelAccounts" resultType="com.alibaba.fastjson.JSONObject">
-        SELECT IFNULL(t1.project_name, '') AS 'projectName' ,
-               IFNULL(t1.auth_name, '') AS 'accountName',
-               t2.count,
-               t1.`status`,
-               CASE t1.`status`
-                   WHEN 0 THEN '计算中'
-                   WHEN 1 THEN '已生效'
-                   WHEN 2 THEN '已删除'
-                   WHEN 3 THEN '推送中'
-                   WHEN 4 THEN '已推送'
-                   WHEN 5 THEN '计算失败'
-                   WHEN 6 THEN '推送失败'
-                   WHEN 7 THEN '已失效'
-                   ELSE ''
-                   END as 'statusStr'
-        FROM (
-                 SELECT t2.auth_name, t2.account_id, t3.project_name, t1.status
-                 FROM ctop_kuaishou_crowd_package t1
-                          INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-                          INNER JOIN ctop_project t3 ON t3.id = t2.project_id
-                 where signature = #{signature}
-                   and data_status = 1
-                   AND `status` !=2
-                 GROUP BY t1.account_id
-             ) t1
-                 LEFT JOIN(
-            SELECT t.account_id, COUNT(1) as 'count'
-            FROM (
-                     SELECT t1.account_id, signature
-                     FROM ctop_kuaishou_crowd_package t1
-                              INNER JOIN (
-                         SELECT t1.account_id
-                         FROM ctop_kuaishou_crowd_package t1
-                                  INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-                         where signature = #{signature}
-                           and data_status = 1
-                           AND `status` !=2
-                         GROUP BY account_id
-                     ) t2 ON t1.account_id = t2.account_id
-                     where signature is not NULL
-                       AND data_status = 1
-                       AND `status` != 2
-                     GROUP BY signature, t1.account_id
-                 ) t
-            GROUP BY t.account_id
-        ) t2 ON t1.account_id = t2.account_id
-    </select>
-
-    <select id="queryRelProject" resultType="com.alibaba.fastjson.JSONObject">
-        SELECT IFNULL(CONCAT(tt3.project_name, '(', tt.project_id, ')'), '') as 'projectName' ,
-               tt.accountCount,
-               tt2.count
-        FROM (
-                 SELECT t.project_id, COUNT(1) as  'accountCount'
-                 FROM (
-                          SELECT t1.project_id, t1.account_id
-                          FROM ctop_user_allocation t1
-                                   INNER JOIN(
-                              SELECT t1.account_id
-                              FROM ctop_kuaishou_crowd_package t1
-                                       INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-                              where signature = #{signature}
-                                AND data_status = 1
-                                AND `status` !=2
-                              GROUP BY t1.account_id
-                          ) t2 ON t2.account_id = t1.account_id
-                      ) t
-                 GROUP BY t.project_id
-             ) tt
-                 LEFT JOIN
-             (
-                 SELECT t.project_id, t.account_id, COUNT(1) as 'count'
-                 FROM (
-                          SELECT t3.project_id, t1.account_id, signature
-                          FROM ctop_kuaishou_crowd_package t1
-                                   INNER JOIN (
-                              SELECT t1.account_id
-                              FROM ctop_kuaishou_crowd_package t1
-                                       INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-                              where signature = #{signature}
-                                AND data_status = 1
-                                AND `status` !=2
-                              GROUP BY t1.account_id
-                          ) t2 ON t1.account_id = t2.account_id
-                                   INNER JOIN ctop_user_allocation t3 ON t3.account_id = t2.account_id
-                          where signature is not NULL
-                            AND data_status = 1
-                            AND `status` != 2
-                          GROUP BY signature, t1.account_id, t3.project_id
-                      ) t
-                 GROUP BY t.account_id, t.project_id
-             ) tt2 ON tt2.project_id = tt.project_id
-                 LEFT JOIN ctop_project tt3 ON tt2.project_id = tt3.id
-        GROUP BY tt.project_id
-    </select>
-
-    <select id="queryProjectCount" resultType="java.lang.Integer">
-        SELECT IFNULL(COUNT(1),0)
-        FROM (SELECT t2.project_id
-              FROM ctop_kuaishou_crowd_package t1
-                       INNER JOIN ctop_user_allocation t2 ON t1.account_id = t2.account_id
-              where orientation_id is not null
-                AND signature = #{signature}
-                AND data_status = 1
-                AND `status` !=2
-              GROUP BY project_id) t
-    </select>
-    <select id="queryAccountCount" resultType="java.lang.Integer">
-        SELECT IFNULL(COUNT(1),0)
-        FROM (
-                 SELECT account_id
-                 FROM ctop_kuaishou_crowd_package
-                 WHERE signature = #{signature}
-                   AND `status` !=2
-                 AND data_status = 1
-                 GROUP BY account_id) t
-    </select>
-
-    <select id="queryByAccountId" resultType="cn.com.ctop.kuaishou.modules.ai.entity.KuaishouCrowdPack">
-        SELECT *
-        FROM ctop_kuaishou_crowd_package
-        where data_status = 1
-        AND `status` !=2
-        <if test="accountId!=null">
-            AND account_id = #{accountId}
-        </if>
-        <if test="orientationId!=null">
-            AND orientation_id = #{orientationId}
-        </if>
-        limit 1
-    </select>
-
-    <update id="update">
-        update ctop_kuaishou_crowd_package
-        set status = #{status}
-        where account_id = #{account_id}
-        and orientation_id = #{orientation_id}
-    </update>
-
-    <insert id="replaceBatch">
-        replace into ctop_kuaishou_crowd_package(
-        account_id,
-        stat_date,
-        orientation_id,
-        orientation_name,
-        url,
-        population_type,
-        data_status,
-        type,
-        status,
-        signature,
-        cover_num,
-        record_size,
-        match_size,
-        message
-        )
-        values
-        <foreach collection="list" item="li" separator=",">
-            (
-            #{li.accountId},
-            #{li.statDate},
-            #{li.orientationId},
-            #{li.orientationName},
-            #{li.url},
-            #{li.populationType},
-            #{li.dataStatus},
-            #{li.type},
-            #{li.status},
-            #{li.signature},
-            #{li.coverNum},
-            #{li.recordSize},
-            #{li.matchSize},
-            #{li.message}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

+ 0 - 31
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/ai/service/IKuaishouCrowdPackService.java

@@ -1,31 +0,0 @@
-package cn.com.ctop.kuaishou.modules.ai.service;
-
-import cn.com.ctop.kuaishou.modules.ai.entity.KuaishouCrowdPack;
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.extension.service.IService;
-import org.jeecg.common.api.vo.Result;
-
-/**
- * @Description: 人群报表
- * @Author: jeecg-boot
- * @Date: 2021-03-26
- * @Version: V1.0
- */
-public interface IKuaishouCrowdPackService extends IService<KuaishouCrowdPack> {
-
-    Result<Object> queryPageList(KuaishouCrowdPack kuaishouCrowdPack, Integer pageNo, Integer pageSize);
-
-    Result<Object> uploadCrowdPack(Integer type, String orientationName, Long accountId, String url);
-
-    Result<Object> accountPush(JSONObject request);
-
-    void crowdListQuery();
-
-    Result<Object> queryRel(String type, String signature, Integer pageNo, Integer pageSize);
-
-    Result<Object> queryFailReason(String signature, Integer pageNo, Integer pageSize);
-
-    Result<Object> updateDataStatus(KuaishouCrowdPack kuaishouCrowdPack);
-
-    Result<Object> checkCrowdPackage(String signature);
-}

+ 0 - 277
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/ai/service/impl/KuaishouCrowdPackServiceImpl.java

@@ -1,277 +0,0 @@
-package cn.com.ctop.kuaishou.modules.ai.service.impl;
-
-import cn.com.ctop.common.module.entity.CtopOauthToken;
-import cn.com.ctop.common.module.mapper.UserAllocationMapper;
-import cn.com.ctop.common.module.service.ICtopOauthTokenService;
-import cn.com.ctop.common.module.utils.Check;
-import cn.com.ctop.common.module.utils.LoadFileUtil;
-import cn.com.ctop.kuaishou.modules.ai.entity.KuaishouCrowdPack;
-import cn.com.ctop.kuaishou.modules.ai.mapper.KuaishouCrowdPackMapper;
-import cn.com.ctop.kuaishou.modules.ai.service.IKuaishouCrowdPackService;
-import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouInterfaceService;
-import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouPopulationService;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.github.pagehelper.PageHelper;
-import com.github.pagehelper.PageInfo;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.common.api.vo.Result;
-import org.jeecg.common.util.DateUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Service;
-
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.UUID;
-
-/**
- * 人群报表
- *
- * @author jeecg-boot
- * @version V1.0
- * @date 2021-03-26
- */
-@Slf4j
-@Service
-public class KuaishouCrowdPackServiceImpl extends ServiceImpl<KuaishouCrowdPackMapper, KuaishouCrowdPack> implements IKuaishouCrowdPackService {
-
-    @Autowired
-    private KuaishouCrowdPackMapper crowdPackMapper;
-
-    @Autowired
-    private ICtopOauthTokenService tokenService;
-
-    @Autowired
-    private IKuaishouPopulationService iKuaishouPopulationService;
-
-    @Autowired
-    private IKuaishouInterfaceService kuaishouInterfaceService;
-
-    @Autowired
-    UserAllocationMapper userAllocationMapper;
-
-    @Value("${zip.local.download-path}")
-    private String downloadPath;
-
-
-    @Override
-    public Result<Object> queryPageList(KuaishouCrowdPack kuaishouCrowdPack, Integer pageNo, Integer pageSize) {
-        Long total = crowdPackMapper.getTotal(kuaishouCrowdPack.getStatus(), kuaishouCrowdPack.getAccountId(), kuaishouCrowdPack.getOrientationName());
-        PageHelper.startPage(pageNo, pageSize, false);
-        List<JSONObject> list = crowdPackMapper.queryPageList(kuaishouCrowdPack.getStatus(), kuaishouCrowdPack.getAccountId(), kuaishouCrowdPack.getOrientationName());
-        for (JSONObject object : list) {
-            int count = crowdPackMapper.queryProjectCount(object.getString("signature"));
-            object.put("projectCount", count);
-            int accountCount = crowdPackMapper.queryAccountCount(object.getString("signature"));
-            object.put("accountCount", accountCount);
-        }
-        PageInfo pageInfo = new PageInfo(list);
-        pageInfo.setTotal(total);
-        return Result.ok(pageInfo);
-    }
-
-    @Override
-    public Result<Object> uploadCrowdPack(Integer type, String orientationName, Long accountId, String url) {
-        StringBuffer path = new StringBuffer();
-        path.append(downloadPath).append(DateUtils.getNowDate(DateUtils.WEB_FORMAT)).append("/").append(UUID.randomUUID().toString()).append("/");
-        if (!url.contains("http")) {
-            url = "https:".concat(url);
-        }
-        String newFileUrl = LoadFileUtil.downLoadFromUrl(url, path.toString());
-        if (Check.isNull(newFileUrl)) {
-            return Result.error("文件下载失败,路径:" + url);
-        }
-        String md5 = null;
-        try {
-            md5 = LoadFileUtil.getMD5(newFileUrl);
-        } catch (IOException e) {
-            log.error("获取MD5签名失败", e);
-        }
-        QueryWrapper<KuaishouCrowdPack> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("account_id", accountId);
-        queryWrapper.eq("signature", md5);
-        queryWrapper.eq("data_status", 1);
-        queryWrapper.last("limit 1");
-        KuaishouCrowdPack one = crowdPackMapper.selectOne(queryWrapper);
-        if (!Check.isNull(one)) {
-            return Result.error("本账户已上传过该人群包,人群包名为:" + one.getOrientationName());
-        }
-        CtopOauthToken token = tokenService.getTokenByAccountId(accountId);
-        JSONObject jsonObject = iKuaishouPopulationService.updatePopulation(token, type, orientationName, newFileUrl);
-        LoadFileUtil.delFile(newFileUrl);
-        if (!Check.isNull(jsonObject)) {
-            if (jsonObject.getInteger("code") == 0) {
-                KuaishouCrowdPack crowdPack = JSONObject.toJavaObject(jsonObject.getJSONObject("data"), KuaishouCrowdPack.class);
-                crowdPack.setSignature(md5);
-                crowdPack.setUrl(url);
-                crowdPack.setMessage(jsonObject.getString("message"));
-                crowdPack.setStatDate(DateUtils.formatDate(new Date()));
-                crowdPack.setDataStatus(1);
-                this.save(crowdPack);
-            } else {
-                KuaishouCrowdPack crowdPack = new KuaishouCrowdPack();
-                crowdPack.setAccountId(accountId);
-                crowdPack.setOrientationName(orientationName);
-                crowdPack.setSignature(md5);
-                crowdPack.setUrl(url);
-                crowdPack.setMessage(jsonObject.getString("message"));
-                crowdPack.setStatDate(DateUtils.formatDate(new Date()));
-                crowdPack.setDataStatus(0);
-                this.save(crowdPack);
-                return Result.error(jsonObject.getString("message"));
-            }
-        }
-        return Result.ok("success");
-    }
-
-    @Override
-    public Result<Object> accountPush(JSONObject request) {
-        JSONArray accountIds = request.getJSONArray("accountIds");
-        String signature = request.getString("signature");
-        Long accountId = request.getLong("accountId");
-        CtopOauthToken token = tokenService.getTokenByAccountId(accountId);
-        QueryWrapper<KuaishouCrowdPack> wrapper = new QueryWrapper<>();
-        wrapper.eq("account_id", accountId);
-        wrapper.eq("signature", signature);
-        wrapper.eq("status", 4);
-        wrapper.last("limit 1");
-        KuaishouCrowdPack kuaishouCrowdPack = crowdPackMapper.selectOne(wrapper);
-        if (Check.isNull(kuaishouCrowdPack)) {
-            return Result.error("该账户下没有可推送人群包");
-        }
-        JSONObject jsonObject = iKuaishouPopulationService.pushAccountsPopulation(token, kuaishouCrowdPack.getOrientationId(), accountIds);
-        if (jsonObject.getInteger("code") == 0) {
-            List<KuaishouCrowdPack> list = new ArrayList<>();
-            JSONObject data = jsonObject.getJSONObject("data");
-            if (!Check.isNull(data)) {
-                JSONArray success = data.getJSONArray("success");
-                for (Object account : success) {
-                    kuaishouCrowdPack.setAccountId(Long.valueOf(String.valueOf(account)));
-                    kuaishouCrowdPack.setMessage("PUSH OK");
-                    kuaishouCrowdPack.setStatDate(DateUtils.formatDate(new Date()));
-                    list.add(kuaishouCrowdPack);
-                }
-                JSONArray fail = data.getJSONArray("fail");
-                for (Object account : fail) {
-                    Long aaccount = Long.valueOf(String.valueOf(account));
-                    KuaishouCrowdPack crowdPack = crowdPackMapper.queryByAccountId(aaccount, kuaishouCrowdPack.getOrientationId());
-                    if (Check.isNull(crowdPack)) {
-                        kuaishouCrowdPack.setDataStatus(0);
-                        kuaishouCrowdPack.setAccountId(aaccount);
-                        kuaishouCrowdPack.setMessage("推送失败");
-                        kuaishouCrowdPack.setStatDate(DateUtils.formatDate(new Date()));
-                        kuaishouCrowdPack.setStatus(null);
-                        kuaishouCrowdPack.setType(null);
-                        kuaishouCrowdPack.setCoverNum(null);
-                        kuaishouCrowdPack.setRecordSize(null);
-                        kuaishouCrowdPack.setMatchSize(null);
-                        list.add(kuaishouCrowdPack);
-                    }
-                }
-                if (list.size() > 0) {
-                    crowdPackMapper.replaceBatch(list);
-                }
-            }
-        } else {
-            return Result.error(jsonObject.getString("message"));
-        }
-        return Result.ok("success");
-    }
-
-    @Override
-    public void crowdListQuery() {
-        List<KuaishouCrowdPack> crowdList = crowdPackMapper.queryListByStatus();
-        for (int i = 0; i <= 7; i++) {
-            if (i != 2) {
-                for (KuaishouCrowdPack crowdPack : crowdList) {
-                    CtopOauthToken token = tokenService.getTokenByAccountId(crowdPack.getAccountId());
-                    JSONObject jsonObject = iKuaishouPopulationService.getPopulationList(crowdPack.getAccountId(), token.getAccessToken(), i);
-                    if (jsonObject.getInteger("code") == 0) {
-                        JSONObject data = jsonObject.getJSONObject("data");
-                        if (!Check.isNull(data)) {
-                            JSONArray details = data.getJSONArray("details");
-                            if (details.size() > 0) {
-                                for (int j = 0; j < details.size(); j++) {
-                                    JSONObject obj = details.getJSONObject(j);
-                                    if (Check.isNull(crowdPackMapper.queryByAccountId(obj.getLong("account_id"), obj.getLong("orientation_id")))) {
-                                        KuaishouCrowdPack oldPack = crowdPackMapper.queryByAccountId(null, obj.getLong("orientation_id"));
-                                        KuaishouCrowdPack crowdPackEntity = JSONObject.toJavaObject(obj, KuaishouCrowdPack.class);
-                                        if (!Check.isNull(oldPack)) {
-                                            crowdPackEntity.setStatDate(oldPack.getStatDate());
-                                            crowdPackEntity.setUrl(oldPack.getUrl());
-                                            crowdPackEntity.setSignature(oldPack.getSignature());
-                                        }
-                                        crowdPackEntity.setMessage("PUSH OK");
-                                        crowdPackEntity.setDataStatus(1);
-                                        this.save(crowdPackEntity);
-                                    } else {
-                                        crowdPackMapper.update(obj);
-                                    }
-                                }
-                            }
-                        }
-                    }
-                }
-            }
-        }
-    }
-
-    @Override
-    public Result<Object> queryRel(String type, String signature, Integer pageNo, Integer pageSize) {
-        PageHelper.startPage(pageNo, pageSize);
-        List<JSONObject> list = null;
-        if ("1".equals(type)) {
-            list = crowdPackMapper.queryRelProject(signature);
-        } else {
-            list = crowdPackMapper.queryRelAccounts(signature);
-        }
-        PageInfo pageInfo = new PageInfo(list);
-        return Result.ok(pageInfo);
-    }
-
-    @Override
-    public Result<Object> queryFailReason(String signature, Integer pageNo, Integer pageSize) {
-        PageHelper.startPage(pageNo, pageSize);
-        List<JSONObject> list = crowdPackMapper.queryFailReason(signature);
-        PageInfo pageInfo = new PageInfo(list);
-        return Result.ok(pageInfo);
-    }
-
-    @Override
-    public Result<Object> updateDataStatus(KuaishouCrowdPack kuaishouCrowdPack) {
-        CtopOauthToken token = tokenService.getTokenByAccountId(kuaishouCrowdPack.getAccountId());
-        JSONObject object = iKuaishouPopulationService.deletePopulation(kuaishouCrowdPack.getAccountId(), kuaishouCrowdPack.getOrientationId(), token.getAccessToken());
-        if (!Check.isNull(object)) {
-            if (object.getInteger("code") == 0) {
-                if (this.removeById(kuaishouCrowdPack.getId())) {
-                    return Result.ok("删除成功");
-                }
-            }
-            return Result.error("删除失败,".concat(object.getString("message")));
-        }
-        return Result.error("删除失败");
-    }
-
-    @Override
-    public Result<Object> checkCrowdPackage(String signature) {
-        QueryWrapper<KuaishouCrowdPack> wrapper = new QueryWrapper<>();
-        wrapper.eq("signature", signature);
-        wrapper.eq("data_status", 1);
-        wrapper.last("limit 1");
-        KuaishouCrowdPack kuaishouCrowdPack = crowdPackMapper.selectOne(wrapper);
-        Result result = new Result();
-        if (Check.isNull(kuaishouCrowdPack)) {
-            return Result.ok("success");
-        }
-        result.setSuccess(true);
-        result.setCode(201);
-        result.setMessage("后台保存过该人群包,名称为:" + kuaishouCrowdPack.getOrientationName());
-        result.setResult(kuaishouCrowdPack);
-        return result;
-    }
-}