zhaoxian 1 éve
szülő
commit
588c27374f

+ 2 - 0
module-common/src/main/java/cn/com/ctop/common/module/mapper/ProjectMapper.java

@@ -33,4 +33,6 @@ public interface ProjectMapper extends BaseMapper<Project> {
     List<Long> getProjectIdsByProductIdAndNotIn(@Param("productId") Long productId, @Param("partakeProjectIds") List<Long> partakeProjectIds);
 
     JSONObject getProjectByAccountId(@Param("accountId") Long accountId);
+
+    List<Long> getProjectIdsByMediaId(String mediaId);
 }

+ 6 - 0
module-common/src/main/java/cn/com/ctop/common/module/mapper/xml/ProjectMapper.xml

@@ -94,4 +94,10 @@
 	)
     </select>
 
+    <select id="getProjectIdsByMediaId" resultType="Long">
+        SELECT id
+        FROM ctop_project
+        WHERE media_id = #{mediaId}
+    </select>
+
 </mapper>

+ 2 - 0
module-common/src/main/java/cn/com/ctop/common/module/service/IProjectService.java

@@ -32,4 +32,6 @@ public interface IProjectService extends IService<Project> {
     List<Long> getProjectIdsByProductIdAndNotIn(Long productId, List<Long> partakeProjectIds);
 
     JSONObject getProjectByAccountId(Long accountId);
+
+    List<Long> getProjectIdsByMediaId(String mediaId);
 }

+ 5 - 0
module-common/src/main/java/cn/com/ctop/common/module/service/impl/ProjectServiceImpl.java

@@ -80,4 +80,9 @@ public class ProjectServiceImpl extends ServiceImpl<ProjectMapper, Project> impl
     public JSONObject getProjectByAccountId(Long accountId) {
         return projectMapper.getProjectByAccountId(accountId);
     }
+
+    @Override
+    public List<Long> getProjectIdsByMediaId(String mediaId) {
+        return projectMapper.getProjectIdsByMediaId(mediaId);
+    }
 }

+ 49 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/AgentManagementJob.java

@@ -0,0 +1,49 @@
+package cn.com.ctop.job.bytedance.handler;
+
+import cn.com.ctop.common.module.service.IProjectService;
+import cn.com.ctop.toutiao.modules.agent.service.AgentManagementService;
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.util.DateUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ 头条结算单
+ */
+@Slf4j
+@Component
+public class AgentManagementJob {
+    @Autowired
+    AgentManagementService agentManagementService;
+    @Autowired
+    private IProjectService projectService;
+
+    static ExecutorService executorService = Executors.newFixedThreadPool(3);
+
+    @XxlJob("agentManagementJob")
+    public void execute() throws Exception {
+        List<Long> ids = projectService.getProjectIdsByMediaId("1");
+
+        String today = DateUtils.date2Str();
+        //昨天
+        String yesterday = DateUtils.getLastDay(today, 1);
+        String yesterday3 = DateUtils.getLastDay(today, 3);
+
+        for (Long id : ids) {
+            executorService.submit(new Runnable() {
+                @Override
+                public void run() {
+                    agentManagementService.insertAccountTransactionDayByProjectId(id,yesterday3,yesterday);
+                }
+            });
+        }
+        XxlJobHelper.log("同步头条结算单完成");
+    }
+
+}