Bläddra i källkod

Merge remote-tracking branch 'origin/master'

yumeng 3 år sedan
förälder
incheckning
1bd77fcd17

+ 32 - 0
module-common/src/main/java/cn/com/ctop/common/module/entity/AccountAttributionInfo.java

@@ -0,0 +1,32 @@
+package cn.com.ctop.common.module.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+@Data
+@TableName("ctop_account_attribution_info")
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class AccountAttributionInfo {
+    @TableId
+    private String id;
+    private Long accountId;
+    private Long projectId;
+    private Long productId;
+    private String advertiserId;
+    private String companyId;
+    private String projectName;
+    private String advertiserName;
+    private String companyName;
+    private String saleId;
+    private String userId;
+    private String orgCode;
+    @TableField(exist = false)
+    private String userName;
+    @TableField(exist = false)
+    private String authName;
+}

+ 13 - 0
module-common/src/main/java/cn/com/ctop/common/module/mapper/AccountAttributionInfoMapper.java

@@ -0,0 +1,13 @@
+package cn.com.ctop.common.module.mapper;
+
+import cn.com.ctop.common.module.entity.AccountAttributionInfo;
+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;
+
+public interface AccountAttributionInfoMapper extends BaseMapper<AccountAttributionInfo> {
+    void reloadData();
+}

+ 29 - 0
module-common/src/main/java/cn/com/ctop/common/module/mapper/xml/AccountAttributionInfoMapper.xml

@@ -0,0 +1,29 @@
+<?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.common.module.mapper.AccountAttributionInfoMapper">
+
+    <insert id="reloadData">
+        replace into ctop_account_attribution_info(id, account_id, project_id, product_id, advertiser_id, company_id,
+                                          account_name, project_name, advertiser_name, company_name, sale_id, user_id,
+                                          org_code)
+        select cua.account_id,
+               cua.account_id,
+               cp.id,
+               product.id,
+               ca.id,
+               uc.company_id,
+               cua.auth_name,
+               cp.project_name,
+               ca.name,
+               uc.company_name,
+               cp.sale_id,
+               su.id,
+               su.org_code
+        from ctop_user_allocation cua
+                 left join ctop_project cp on cua.project_id = cp.id
+                 left join ctop_advertiser ca on ca.id = cua.advertiser_id
+                 left join sys_user su on su.id = cua.user_id
+                 left join user_company uc on uc.user_id = cua.user_id
+                 left join ctop_product product on product.id = cp.product_id where cua.account_id is not null;
+    </insert>
+</mapper>

+ 8 - 0
module-common/src/main/java/cn/com/ctop/common/module/service/AccountAttributionInfoService.java

@@ -0,0 +1,8 @@
+package cn.com.ctop.common.module.service;
+
+import cn.com.ctop.common.module.entity.AccountAttributionInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+public interface AccountAttributionInfoService extends IService<AccountAttributionInfo> {
+    void reloadData();
+}

+ 19 - 0
module-common/src/main/java/cn/com/ctop/common/module/service/impl/AccountAttributionInfoServiceImpl.java

@@ -0,0 +1,19 @@
+package cn.com.ctop.common.module.service.impl;
+
+import cn.com.ctop.common.module.entity.AccountAttributionInfo;
+import cn.com.ctop.common.module.mapper.AccountAttributionInfoMapper;
+import cn.com.ctop.common.module.service.AccountAttributionInfoService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+@Service
+public class AccountAttributionInfoServiceImpl extends ServiceImpl<AccountAttributionInfoMapper, AccountAttributionInfo> implements AccountAttributionInfoService {
+    @Resource
+    private AccountAttributionInfoMapper accountAttributionInfoMapper;
+    @Override
+    public void reloadData() {
+        accountAttributionInfoMapper.reloadData();
+    }
+}

+ 17 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/AccountAttributionInfoJob.java

@@ -0,0 +1,17 @@
+package cn.com.ctop.job.kuaishou.handler;
+
+import cn.com.ctop.common.module.service.AccountAttributionInfoService;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class AccountAttributionInfoJob {
+    @Autowired
+    private AccountAttributionInfoService accountAttributionInfoService;
+
+    @XxlJob("reloadAccountAttributionInfo")
+    public void execute() throws Exception {
+        accountAttributionInfoService.reloadData();
+    }
+}