Sfoglia il codice sorgente

fix: 别名管理增加最新净值返回

chenjianhua 7 mesi fa
parent
commit
a3a04163ee

+ 2 - 0
service-base/src/main/java/com/simuwang/base/mapper/EmailFundNavMapper.java

@@ -26,4 +26,6 @@ public interface EmailFundNavMapper {
     List<EmailFundNavDO> selectNotMappingNav(@Param("fundName") String sourceFundName);
 
     void batchUpdate(@Param("navList") List<EmailFundNavDO> fundNavDOList);
+
+    String getMaxPriceDate(@Param("fundName")String sourceFundName);
 }

+ 4 - 0
service-base/src/main/java/com/simuwang/base/pojo/vo/FundAliasVO.java

@@ -47,4 +47,8 @@ public class FundAliasVO {
      * 管理人
      */
     private String companyName;
+    /**
+     * 最新净值日期
+     */
+    private String priceDate;
 }

+ 4 - 0
service-base/src/main/resources/mapper/EmailFundNavMapper.xml

@@ -153,6 +153,10 @@
         where nav.isvalid =1 and nav.exception_status=3
           and nav.fund_name=#{fundName}
     </select>
+    <select id="getMaxPriceDate" resultType="java.lang.String" parameterType="java.lang.String">
+        select max(nav.price_date) from PPW_EMAIL.email_fund_nav nav where nav.isvalid =1 and nav.exception_status=3
+                                                                        and nav.fund_name=#{fundName}
+    </select>
 
 
 </mapper>

+ 1 - 1
service-manage/src/main/java/com/simuwang/manage/api/fund/FunAliasController.java

@@ -45,7 +45,7 @@ public class FunAliasController {
     }
 
     /**
-     * 根据ID查询基金别名
+     * 保存基金别名
      * @param fundAliasVO
      * @return
      */

+ 3 - 0
service-manage/src/main/java/com/simuwang/manage/init/QuartzConfig.java

@@ -70,6 +70,9 @@ public class QuartzConfig implements ApplicationRunner {
                 paramDTO.setProtocol(mailboxInfoDO.getProtocol());
                 quartzBean.setJobParam(JSON.toJSONString(paramDTO));
                 QuartzUtils.createScheduleJob(scheduler,quartzBean);
+                if(mailboxInfoDO.getOpenStatus() == null){
+                    continue;
+                }
                 if(mailboxInfoDO.getOpenStatus().equals(OpenStatusType.YES.getCode())){
                     QuartzUtils.resumeScheduleJob(scheduler,quartzBean.getJobName(),quartzBean.getGroupName());
                 }else{

+ 2 - 0
service-manage/src/main/java/com/simuwang/manage/service/impl/FundAliasServiceImpl.java

@@ -63,6 +63,8 @@ public class FundAliasServiceImpl implements FundAliasService {
             if(vo.getTargetFundId() !=null){
                 vo.setCompanyName(companyInformationMapper.getCompanyNameByFundId(vo.getTargetFundId()));
             }
+            //最新净值日期
+            vo.setPriceDate(emailFundNavMapper.getMaxPriceDate(vo.getSourceFundName()));
         }
         long total = fundAliasMapper.countFundAlias(fundAliasPageQuery);
         return MybatisPage.of(total,fundAliasVOList);