Browse Source

修改定时任务

yumeng 3 years ago
parent
commit
a20cad04ab

+ 2 - 0
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/service/IProjectMemberService.java

@@ -52,4 +52,6 @@ public interface IProjectMemberService extends IService<ProjectMember> {
     List<ProjectMember> getOwnProducts(List<Integer> mediaList, Long productId);
 
     List<Long> getProjectIdsByProductId(Long productId, String userId);
+
+    void syncSale();
 }

+ 36 - 0
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/service/impl/ProjectMemberServiceImpl.java

@@ -454,6 +454,42 @@ public class ProjectMemberServiceImpl extends ServiceImpl<ProjectMemberMapper, P
         return memberMapper.getProjectIdsByProductId(productId, userId);
     }
 
+    @Autowired
+    private ISysUserService sysUserService;
+
+    @Override
+    public void syncSale() {
+        List<Project> list = projectService.list();
+        for (Project project : list) {
+            Long projectId = project.getId();
+            String saleId = project.getSaleId();
+            if(Check.isNull(saleId)){
+                continue;
+            }
+
+            QueryWrapper<ProjectMember> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("project_id", projectId);
+            queryWrapper.eq("user_id", saleId);
+            queryWrapper.last("limit 1");
+            ProjectMember projectMember = memberMapper.selectOne(queryWrapper);
+            if (!Check.isNull(projectMember)) {
+                continue;
+            }
+            ProjectMember addMember = new ProjectMember();
+            SysUser user = sysUserService.getById(saleId);
+            addMember.setProjectId(projectId);
+            addMember.setProjectName(project.getProjectName());
+            addMember.setUserId(saleId);
+            addMember.setUserName(user.getRealname());
+            String roleCode = memberMapper.getRoleCodeByUserId(saleId);
+            addMember.setRoleCode(roleCode);
+            memberMapper.insert(addMember);
+
+        }
+
+
+    }
+
 }
 
 

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/material/mapper/xml/EtlKuaishouVideoInfoMapper.xml

@@ -87,6 +87,6 @@
     </insert>
 
     <select id="getVideoMinDate" resultType="java.lang.String">
-        select min(stat_date) from ctop_kuaishou_report_daily_material where signature = #{signature}
+        select min(stat_date) from application.kuaishou_material_video_report_daily_dw where signature = #{signature}
     </select>
 </mapper>

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/material/service/impl/EtlKuaishouVideoInfoServiceImpl.java

@@ -176,7 +176,7 @@ public class EtlKuaishouVideoInfoServiceImpl extends ServiceImpl<EtlKuaishouVide
                         //查询视频初次消耗时间
                         String minDate = etlKuaishouVideoInfoMapper.getVideoMinDate(signature);
                         if (null != minDate && !"".equals(minDate)) {
-                            Date getDate = DateUtils.parseDate(minDate, "yyyy-MM-dd");
+                            Date getDate = DateUtils.parseDate(minDate, "yyyyMMdd");
                             etlKuaishouVideoInfo.setStateDate(getDate);
                         }
                         addList.add(etlKuaishouVideoInfo);