feat: 调整代码格式

service-deploy/src/test/java/com/simuwang/ApplicationTest.java

@@ -1,5 +1,6 @@
 //package com.simuwang;
 //
+//import ch.qos.logback.core.net.SyslogOutputStream;
 //import cn.hutool.core.collection.ListUtil;
 //import cn.hutool.core.date.DateUtil;
 //import com.simuwang.base.common.conts.DateConst;
@@ -12,8 +13,12 @@
 //import org.springframework.beans.factory.annotation.Autowired;
 //import org.springframework.boot.test.context.SpringBootTest;
 //
+//import java.sql.SQLOutput;
 //import java.util.ArrayList;
+//import java.util.Arrays;
 //import java.util.Date;
+//import java.util.List;
+//import java.util.stream.Collectors;
 //
 //@SpringBootTest(classes = Application.class)
 //public class ApplicationTest {
@@ -62,7 +67,12 @@
 //
 //    @Test
 //    public void testReparseFile() {
-//        emailParseApiService.reparseFile(ListUtil.toList(40, 43));
+//        String secretAccessKey = "e6eb8be82e91439eaaed87c851346f1d";
+//        String accessKeyId = "d70dfdff53434471868a6d60d63b4c84";
+//        String authStringPrefix = "ZTSC";
+//        String signKeyInfo = authStringPrefix+"/"+accessKeyId+"/"+System.currentTimeMillis()+"300";
+//        List<String> hosts = Arrays.asList(new String[]{"host1","host2"});
+//        String headersToSign = hosts.stream().collect(Collectors.joining(":"));
 //    }
 //
 //    @Test

service-manage/src/main/java/com/simuwang/manage/task/DataSynchronizationTask.java

@@ -1,239 +1,239 @@
-package com.simuwang.manage.task;
-
-import cn.hutool.core.date.DateUtil;
-import com.simuwang.base.common.enums.TaskType;
-import com.simuwang.base.common.util.DateUtils;
-import com.simuwang.base.common.util.StringUtil;
-import com.simuwang.base.mapper.core.CoreDistributionMapper;
-import com.simuwang.base.mapper.core.SrcNavMapper;
-import com.simuwang.base.mapper.daq.DistributionMapper;
-import com.simuwang.base.mapper.daq.EmailTaskInfoMapper;
-import com.simuwang.base.mapper.daq.NavMapper;
-import com.simuwang.base.mapper.daq.system.SysConfigMapper;
-import com.simuwang.base.pojo.dos.DistributionDO;
-import com.simuwang.base.pojo.dos.EmailTaskInfoDO;
-import com.simuwang.base.pojo.dos.NavDO;
-import com.simuwang.base.pojo.dos.SysConfigDO;
-import com.simuwang.base.pojo.dos.core.CoreDistributionDO;
-import com.simuwang.base.pojo.dos.core.SrcNavDO;
-import com.simuwang.shiro.utils.UserUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 数据同步
- * Author:   chenjianhua
- * Date:     2024/10/25 13:59
- * Description: ${DESCRIPTION}
- */
-@Component
-public class DataSynchronizationTask {
-
-    @Autowired
-    private NavMapper navMapper;
-
-    @Autowired
-    private SrcNavMapper srcNavMapper;
-
-    @Autowired
-    private SysConfigMapper sysConfigMapper;
-
-    @Autowired
-    private DistributionMapper distributionMapper;
-    @Autowired
-    private CoreDistributionMapper coreDistributionMapper;
-    @Autowired
-    private EmailTaskInfoMapper emailTaskInfoMapper;
-    private static final Logger log = LoggerFactory.getLogger(DataSynchronizationTask.class);
-    private static final Integer maxNum = 100000;
-
-    public void synchronization() {
-        EmailTaskInfoDO emailTaskInfoDO = startEmailTask(null, 1);
-        String startDate = sysConfigMapper.selectConfigByKey("last_data_synchronization_time");
-        if (StringUtil.isNull(startDate)) {
-            //沒有配置就新增一个
-            saveConfig();
-        }
-        String endDate = DateUtil.now();
-        long total = navMapper.countNavByTime(startDate, endDate);
-        if (total > maxNum) {
-            Map<String,Long> idMap = navMapper.selectMaxMinId(startDate, endDate);
-            Long minId = idMap.get("minId");
-            Long maxId = idMap.get("maxId");
-            long times = (maxId-minId)%maxNum==0?(maxId-minId)/maxNum:(maxId-minId)/maxNum+1;
-            long startIdx = minId;
-            List<String> fundPriceDateList = new ArrayList<>();
-            for(int idx=1;idx <= times;idx++){
-                long endIdx = startIdx+idx*maxNum;
-                if(endIdx >= maxId){
-                    endIdx = maxId;
-                }
-                List<NavDO> navDOList = navMapper.selectNavListById(startIdx,endIdx,startDate, endDate);
-                List<NavDO> srcNavDOList = new ArrayList<>();
-                //确保每个基金的每个交易日只有一条数据
-                for(NavDO navDo : navDOList){
-                    String fundPriceDate = navDo.getFundId()+DateUtils.format(navDo.getPriceDate(),DateUtils.YYYY_MM_DD);
-                    if(fundPriceDateList.contains(fundPriceDate)){
-                        continue;
-                    }else{
-                        fundPriceDateList.add(fundPriceDate);
-                    }
-                    srcNavDOList.add(navDo);
-                }
-                saveSrcNavList(srcNavDOList);
-                startIdx = endIdx;
-            }
-            return;
-        }
-        List<NavDO> navDOList = navMapper.selectNavListByTime(startDate, endDate);
-        List<NavDO> srcNavDOList = new ArrayList<>();
-        //确保每个基金的每个交易日只有一条数据同步到下游
-        List<String> fundPriceDateList = new ArrayList<>();
-        for(NavDO navDo : navDOList){
-            String fundPriceDate = navDo.getFundId()+DateUtils.format(navDo.getPriceDate(),DateUtils.YYYY_MM_DD);
-            if(fundPriceDateList.contains(fundPriceDate)){
-                continue;
-            }else{
-                fundPriceDateList.add(fundPriceDate);
-            }
-            srcNavDOList.add(navDo);
-        }
-        saveSrcNavList(srcNavDOList);
-        //更新分红
-        List<DistributionDO> distributionDOList = distributionMapper.selectDistributeListByTime(startDate, endDate);
-        saveDistribute(distributionDOList);
-        //更新最后任务时间
-        updateConfig(endDate);
-        endEmailTask(emailTaskInfoDO.getId(),2);
-    }
-
-    private void saveDistribute(List<DistributionDO> distributionDOList) {
-        List<CoreDistributionDO> coreDistributionDOList = new ArrayList<>();
-        //确保每个基金的每个分红日只有一条数据同步到下游
-        List<String> fundDistributionDateList = new ArrayList<>();
-        for(DistributionDO distribution : distributionDOList){
-            String fundDistributionDate = distribution.getFundId()+DateUtils.format(distribution.getDistributeDate(),DateUtils.YYYY_MM_DD);
-            if(fundDistributionDate.contains(fundDistributionDate)){
-                continue;
-            }else{
-                fundDistributionDateList.add(fundDistributionDate);
-            }
-            CoreDistributionDO coreDistributionDO = new CoreDistributionDO();
-            coreDistributionDO.setDistribution(distribution.getDistribution());
-            coreDistributionDO.setDistributeDate(distribution.getDistributeDate());
-            coreDistributionDO.setDistributeType(distribution.getDistributeType());
-            coreDistributionDO.setFundId(distribution.getFundId());
-            coreDistributionDO.setCreateTime(distribution.getCreateTime());
-            coreDistributionDO.setUpdaterId(distribution.getUpdaterId());
-            coreDistributionDO.setCreatorId(distribution.getCreatorId());
-            coreDistributionDO.setUpdateTime(distribution.getUpdateTime());
-            coreDistributionDO.setIsvalid(distribution.getIsvalid());
-            coreDistributionDOList.add(coreDistributionDO);
-            if(coreDistributionDOList.size() >= 500){
-                coreDistributionMapper.saveCoreDistribution(coreDistributionDOList);
-                coreDistributionDOList.clear();
-            }
-        }
-        if(coreDistributionDOList.size() > 0){
-            coreDistributionMapper.saveCoreDistribution(coreDistributionDOList);
-            coreDistributionDOList.clear();
-        }
-    }
-
-    private void updateConfig(String endDate) {
-        SysConfigDO sysConfigDO = new SysConfigDO();
-        sysConfigDO.setConfigKey("last_data_synchronization_time");
-        sysConfigDO.setConfigName("数据同步最后时间");
-        sysConfigDO.setConfigValue(endDate);
-        sysConfigMapper.updateConfigByKey(sysConfigDO);
-    }
-
-    private void saveConfig() {
-        SysConfigDO sysConfigDO = new SysConfigDO();
-        sysConfigDO.setIsvalid(1);
-        sysConfigDO.setCreateTime(DateUtils.getNowDate());
-        sysConfigDO.setUpdateTime(DateUtils.getNowDate());
-        sysConfigDO.setConfigType("1");
-        sysConfigDO.setConfigKey("last_data_synchronization_time");
-        sysConfigDO.setConfigName("数据同步最后时间");
-        sysConfigDO.setConfigValue(DateUtil.now());
-        sysConfigDO.setRemark("数据同步最后时间");
-        sysConfigDO.setCreatorId(1);
-        sysConfigDO.setUpdaterId(1);
-        sysConfigMapper.insertConfig(sysConfigDO);
-    }
-
-    public void saveSrcNavList(List<NavDO> navDOList){
-        List<SrcNavDO> srcNavDOList = new ArrayList<>();
-        for (NavDO navDO : navDOList) {
-            SrcNavDO srcNavDO = new SrcNavDO();
-            srcNavDO.setPriceDate(navDO.getPriceDate());
-            srcNavDO.setFundId(navDO.getFundId());
-            srcNavDO.setNav(navDO.getNav());
-            srcNavDO.setCumulativeNavCrawl(navDO.getCumulativeNavWithdrawal());
-            srcNavDO.setAppType(1);
-            srcNavDO.setNavSource(1);
-            srcNavDO.setCreateTime(navDO.getCreateTime());
-            srcNavDO.setUpdateTime(navDO.getUpdateTime());
-            srcNavDO.setCreatorId(navDO.getCreatorId());
-            srcNavDO.setUpdaterId(navDO.getUpdaterId());
-            srcNavDO.setIsvisible(1);
-            srcNavDO.setSourceId(1);
-            srcNavDO.setIsvalid(navDO.getIsvalid());
-            srcNavDO.setNavMark(null);
-            srcNavDOList.add(srcNavDO);
-            if(srcNavDOList.size() >= 500){
-                srcNavMapper.saveSrcNav(srcNavDOList);
-                srcNavDOList.clear();
-            }
-        }
-        if(srcNavDOList.size() > 0){
-            srcNavMapper.saveSrcNav(srcNavDOList);
-            srcNavDOList.clear();
-        }
-    }
-
-    private EmailTaskInfoDO startEmailTask(String email, Integer taskStatus) {
-        EmailTaskInfoDO  emailTaskInfoDO = new EmailTaskInfoDO();
-        try{
-            emailTaskInfoDO.setTaskName(TaskType.DATA_TRANSFER.getInfo());
-            emailTaskInfoDO.setTaskType(TaskType.DATA_TRANSFER.getType());
-            emailTaskInfoDO.setTaskStatus(taskStatus);
-            emailTaskInfoDO.setStartTime(DateUtils.getNowDate());
-            emailTaskInfoDO.setIsvalid(1);
-            emailTaskInfoDO.setEmail(email);
-            emailTaskInfoDO.setCreateTime(DateUtils.getNowDate());
-            emailTaskInfoDO.setUpdateTime(DateUtils.getNowDate());
-            try{
-                emailTaskInfoDO.setCreatorId(UserUtils.getLoginUser().getUserId());
-                emailTaskInfoDO.setUpdaterId(UserUtils.getLoginUser().getUserId());
-            }catch (Exception e){
-                emailTaskInfoDO.setCreatorId(1);
-                emailTaskInfoDO.setUpdaterId(1);
-            }
-            emailTaskInfoMapper.insert(emailTaskInfoDO);
-        }catch (Exception e){
-            log.error(e.getMessage());
-        }
-        return emailTaskInfoDO;
-    }
-
-    private void endEmailTask(Integer id, Integer taskStatus) {
-        try{
-            EmailTaskInfoDO emailTaskInfoDO = new EmailTaskInfoDO();
-            emailTaskInfoDO.setId(id);
-            emailTaskInfoDO.setTaskStatus(taskStatus);
-            emailTaskInfoDO.setUpdateTime(DateUtils.getNowDate());
-            emailTaskInfoDO.setEndTime(DateUtils.getNowDate());
-            emailTaskInfoMapper.updateTaskStatusById(emailTaskInfoDO);
-        }catch (Exception e){
-            log.error(e.getMessage());
-        }
-    }
-}
+//package com.simuwang.manage.task;
+//
+//import cn.hutool.core.date.DateUtil;
+//import com.simuwang.base.common.enums.TaskType;
+//import com.simuwang.base.common.util.DateUtils;
+//import com.simuwang.base.common.util.StringUtil;
+//import com.simuwang.base.mapper.core.CoreDistributionMapper;
+//import com.simuwang.base.mapper.core.SrcNavMapper;
+//import com.simuwang.base.mapper.daq.DistributionMapper;
+//import com.simuwang.base.mapper.daq.EmailTaskInfoMapper;
+//import com.simuwang.base.mapper.daq.NavMapper;
+//import com.simuwang.base.mapper.daq.system.SysConfigMapper;
+//import com.simuwang.base.pojo.dos.DistributionDO;
+//import com.simuwang.base.pojo.dos.EmailTaskInfoDO;
+//import com.simuwang.base.pojo.dos.NavDO;
+//import com.simuwang.base.pojo.dos.SysConfigDO;
+//import com.simuwang.base.pojo.dos.core.CoreDistributionDO;
+//import com.simuwang.base.pojo.dos.core.SrcNavDO;
+//import com.simuwang.shiro.utils.UserUtils;
+//import org.slf4j.Logger;
+//import org.slf4j.LoggerFactory;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.stereotype.Component;
+//
+//import java.util.ArrayList;
+//import java.util.List;
+//import java.util.Map;
+//
+///**
+// * 数据同步
+// * Author:   chenjianhua
+// * Date:     2024/10/25 13:59
+// * Description: ${DESCRIPTION}
+// */
+//@Component
+//public class DataSynchronizationTask {
+//
+//    @Autowired
+//    private NavMapper navMapper;
+//
+//    @Autowired
+//    private SrcNavMapper srcNavMapper;
+//
+//    @Autowired
+//    private SysConfigMapper sysConfigMapper;
+//
+//    @Autowired
+//    private DistributionMapper distributionMapper;
+//    @Autowired
+//    private CoreDistributionMapper coreDistributionMapper;
+//    @Autowired
+//    private EmailTaskInfoMapper emailTaskInfoMapper;
+//    private static final Logger log = LoggerFactory.getLogger(DataSynchronizationTask.class);
+//    private static final Integer maxNum = 100000;
+//
+//    public void synchronization() {
+//        EmailTaskInfoDO emailTaskInfoDO = startEmailTask(null, 1);
+//        String startDate = sysConfigMapper.selectConfigByKey("last_data_synchronization_time");
+//        if (StringUtil.isNull(startDate)) {
+//            //沒有配置就新增一个
+//            saveConfig();
+//        }
+//        String endDate = DateUtil.now();
+//        long total = navMapper.countNavByTime(startDate, endDate);
+//        if (total > maxNum) {
+//            Map<String,Long> idMap = navMapper.selectMaxMinId(startDate, endDate);
+//            Long minId = idMap.get("minId");
+//            Long maxId = idMap.get("maxId");
+//            long times = (maxId-minId)%maxNum==0?(maxId-minId)/maxNum:(maxId-minId)/maxNum+1;
+//            long startIdx = minId;
+//            List<String> fundPriceDateList = new ArrayList<>();
+//            for(int idx=1;idx <= times;idx++){
+//                long endIdx = startIdx+idx*maxNum;
+//                if(endIdx >= maxId){
+//                    endIdx = maxId;
+//                }
+//                List<NavDO> navDOList = navMapper.selectNavListById(startIdx,endIdx,startDate, endDate);
+//                List<NavDO> srcNavDOList = new ArrayList<>();
+//                //确保每个基金的每个交易日只有一条数据
+//                for(NavDO navDo : navDOList){
+//                    String fundPriceDate = navDo.getFundId()+DateUtils.format(navDo.getPriceDate(),DateUtils.YYYY_MM_DD);
+//                    if(fundPriceDateList.contains(fundPriceDate)){
+//                        continue;
+//                    }else{
+//                        fundPriceDateList.add(fundPriceDate);
+//                    }
+//                    srcNavDOList.add(navDo);
+//                }
+//                saveSrcNavList(srcNavDOList);
+//                startIdx = endIdx;
+//            }
+//            return;
+//        }
+//        List<NavDO> navDOList = navMapper.selectNavListByTime(startDate, endDate);
+//        List<NavDO> srcNavDOList = new ArrayList<>();
+//        //确保每个基金的每个交易日只有一条数据同步到下游
+//        List<String> fundPriceDateList = new ArrayList<>();
+//        for(NavDO navDo : navDOList){
+//            String fundPriceDate = navDo.getFundId()+DateUtils.format(navDo.getPriceDate(),DateUtils.YYYY_MM_DD);
+//            if(fundPriceDateList.contains(fundPriceDate)){
+//                continue;
+//            }else{
+//                fundPriceDateList.add(fundPriceDate);
+//            }
+//            srcNavDOList.add(navDo);
+//        }
+//        saveSrcNavList(srcNavDOList);
+//        //更新分红
+//        List<DistributionDO> distributionDOList = distributionMapper.selectDistributeListByTime(startDate, endDate);
+//        saveDistribute(distributionDOList);
+//        //更新最后任务时间
+//        updateConfig(endDate);
+//        endEmailTask(emailTaskInfoDO.getId(),2);
+//    }
+//
+//    private void saveDistribute(List<DistributionDO> distributionDOList) {
+//        List<CoreDistributionDO> coreDistributionDOList = new ArrayList<>();
+//        //确保每个基金的每个分红日只有一条数据同步到下游
+//        List<String> fundDistributionDateList = new ArrayList<>();
+//        for(DistributionDO distribution : distributionDOList){
+//            String fundDistributionDate = distribution.getFundId()+DateUtils.format(distribution.getDistributeDate(),DateUtils.YYYY_MM_DD);
+//            if(fundDistributionDate.contains(fundDistributionDate)){
+//                continue;
+//            }else{
+//                fundDistributionDateList.add(fundDistributionDate);
+//            }
+//            CoreDistributionDO coreDistributionDO = new CoreDistributionDO();
+//            coreDistributionDO.setDistribution(distribution.getDistribution());
+//            coreDistributionDO.setDistributeDate(distribution.getDistributeDate());
+//            coreDistributionDO.setDistributeType(distribution.getDistributeType());
+//            coreDistributionDO.setFundId(distribution.getFundId());
+//            coreDistributionDO.setCreateTime(distribution.getCreateTime());
+//            coreDistributionDO.setUpdaterId(distribution.getUpdaterId());
+//            coreDistributionDO.setCreatorId(distribution.getCreatorId());
+//            coreDistributionDO.setUpdateTime(distribution.getUpdateTime());
+//            coreDistributionDO.setIsvalid(distribution.getIsvalid());
+//            coreDistributionDOList.add(coreDistributionDO);
+//            if(coreDistributionDOList.size() >= 500){
+//                coreDistributionMapper.saveCoreDistribution(coreDistributionDOList);
+//                coreDistributionDOList.clear();
+//            }
+//        }
+//        if(coreDistributionDOList.size() > 0){
+//            coreDistributionMapper.saveCoreDistribution(coreDistributionDOList);
+//            coreDistributionDOList.clear();
+//        }
+//    }
+//
+//    private void updateConfig(String endDate) {
+//        SysConfigDO sysConfigDO = new SysConfigDO();
+//        sysConfigDO.setConfigKey("last_data_synchronization_time");
+//        sysConfigDO.setConfigName("数据同步最后时间");
+//        sysConfigDO.setConfigValue(endDate);
+//        sysConfigMapper.updateConfigByKey(sysConfigDO);
+//    }
+//
+//    private void saveConfig() {
+//        SysConfigDO sysConfigDO = new SysConfigDO();
+//        sysConfigDO.setIsvalid(1);
+//        sysConfigDO.setCreateTime(DateUtils.getNowDate());
+//        sysConfigDO.setUpdateTime(DateUtils.getNowDate());
+//        sysConfigDO.setConfigType("1");
+//        sysConfigDO.setConfigKey("last_data_synchronization_time");
+//        sysConfigDO.setConfigName("数据同步最后时间");
+//        sysConfigDO.setConfigValue(DateUtil.now());
+//        sysConfigDO.setRemark("数据同步最后时间");
+//        sysConfigDO.setCreatorId(1);
+//        sysConfigDO.setUpdaterId(1);
+//        sysConfigMapper.insertConfig(sysConfigDO);
+//    }
+//
+//    public void saveSrcNavList(List<NavDO> navDOList){
+//        List<SrcNavDO> srcNavDOList = new ArrayList<>();
+//        for (NavDO navDO : navDOList) {
+//            SrcNavDO srcNavDO = new SrcNavDO();
+//            srcNavDO.setPriceDate(navDO.getPriceDate());
+//            srcNavDO.setFundId(navDO.getFundId());
+//            srcNavDO.setNav(navDO.getNav());
+//            srcNavDO.setCumulativeNavCrawl(navDO.getCumulativeNavWithdrawal());
+//            srcNavDO.setAppType(1);
+//            srcNavDO.setNavSource(1);
+//            srcNavDO.setCreateTime(navDO.getCreateTime());
+//            srcNavDO.setUpdateTime(navDO.getUpdateTime());
+//            srcNavDO.setCreatorId(navDO.getCreatorId());
+//            srcNavDO.setUpdaterId(navDO.getUpdaterId());
+//            srcNavDO.setIsvisible(1);
+//            srcNavDO.setSourceId(1);
+//            srcNavDO.setIsvalid(navDO.getIsvalid());
+//            srcNavDO.setNavMark(null);
+//            srcNavDOList.add(srcNavDO);
+//            if(srcNavDOList.size() >= 500){
+//                srcNavMapper.saveSrcNav(srcNavDOList);
+//                srcNavDOList.clear();
+//            }
+//        }
+//        if(srcNavDOList.size() > 0){
+//            srcNavMapper.saveSrcNav(srcNavDOList);
+//            srcNavDOList.clear();
+//        }
+//    }
+//
+//    private EmailTaskInfoDO startEmailTask(String email, Integer taskStatus) {
+//        EmailTaskInfoDO  emailTaskInfoDO = new EmailTaskInfoDO();
+//        try{
+//            emailTaskInfoDO.setTaskName(TaskType.DATA_TRANSFER.getInfo());
+//            emailTaskInfoDO.setTaskType(TaskType.DATA_TRANSFER.getType());
+//            emailTaskInfoDO.setTaskStatus(taskStatus);
+//            emailTaskInfoDO.setStartTime(DateUtils.getNowDate());
+//            emailTaskInfoDO.setIsvalid(1);
+//            emailTaskInfoDO.setEmail(email);
+//            emailTaskInfoDO.setCreateTime(DateUtils.getNowDate());
+//            emailTaskInfoDO.setUpdateTime(DateUtils.getNowDate());
+//            try{
+//                emailTaskInfoDO.setCreatorId(UserUtils.getLoginUser().getUserId());
+//                emailTaskInfoDO.setUpdaterId(UserUtils.getLoginUser().getUserId());
+//            }catch (Exception e){
+//                emailTaskInfoDO.setCreatorId(1);
+//                emailTaskInfoDO.setUpdaterId(1);
+//            }
+//            emailTaskInfoMapper.insert(emailTaskInfoDO);
+//        }catch (Exception e){
+//            log.error(e.getMessage());
+//        }
+//        return emailTaskInfoDO;
+//    }
+//
+//    private void endEmailTask(Integer id, Integer taskStatus) {
+//        try{
+//            EmailTaskInfoDO emailTaskInfoDO = new EmailTaskInfoDO();
+//            emailTaskInfoDO.setId(id);
+//            emailTaskInfoDO.setTaskStatus(taskStatus);
+//            emailTaskInfoDO.setUpdateTime(DateUtils.getNowDate());
+//            emailTaskInfoDO.setEndTime(DateUtils.getNowDate());
+//            emailTaskInfoMapper.updateTaskStatusById(emailTaskInfoDO);
+//        }catch (Exception e){
+//            log.error(e.getMessage());
+//        }
+//    }
+//}

service-manage/src/main/java/com/simuwang/manage/task/ParseSchedulerTask.java

@@ -44,7 +44,8 @@ public class ParseSchedulerTask  extends QuartzJobBean {
     protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
         emailParseApiService = SpringUtil.getBean(EmailParseApiService.class);
         emailConfigService = SpringUtil.getBean(EmailConfigService.class);
-        log.info("ParseSchedulerTask {}", context.getJobDetail().getKey());JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
+        log.info("ParseSchedulerTask {}", context.getJobDetail().getKey());
+        JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
         log.info("ParseSchedulerTask jobDataMap {}", JSON.toJSONString(jobDataMap));
         String account = jobDataMap.get("account").toString();
         String port = jobDataMap.get("port").toString();