feat:基金别名管理列表调整

service-base/src/main/java/com/simuwang/base/mapper/daq/FundAliasMapper.java

@@ -36,4 +36,6 @@ public interface FundAliasMapper {
     void batchInsert(@Param("itemDoList") List<FundAliasDO> fundAliasDOS);
 
     List<FundRegisterDO> getNotMappingFundList();
+
+    void updateReviewStatus(@Param("idList")List<Integer> idList, @Param("reviewStatus")Integer reviewStatus,@Param("userId") Integer userId);
 }

service-base/src/main/java/com/simuwang/base/pojo/dos/FundAliasDO.java

@@ -69,6 +69,9 @@ public class FundAliasDO {
     private Date updateTime;
 
     private Date lastPriceDate;
+
+    private Integer reviewStatus;
+
     public FundAliasVO toVo() {
         FundAliasVO fundAliasVO = new FundAliasVO();
         fundAliasVO.setId(this.id);
@@ -81,6 +84,7 @@ public class FundAliasDO {
         fundAliasVO.setCompanyName(this.companyName);
         fundAliasVO.setNavTotal(this.navTotal);
         fundAliasVO.setAssetTotal(this.assetTotal);
+        fundAliasVO.setReviewStatus(this.reviewStatus);
         return fundAliasVO;
     }
 }

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

@@ -51,4 +51,6 @@ public class FundAliasVO {
      * 最新净值日期
      */
     private String priceDate;
+
+    private Integer reviewStatus;
 }

service-base/src/main/resources/mapper/daq/FundAliasMapper.xml

@@ -17,9 +17,10 @@
         <result column="createtime" property="createTime"/>
         <result column="updaterid" property="updaterId"/>
         <result column="updatetime" property="updateTime"/>
+        <result column="review_status" property="reviewStatus"/>
     </resultMap>
     <update id="saveFundAlias" parameterType="com.simuwang.base.pojo.dos.FundAliasDO">
-        update fund_alias set target_fund_id=#{targetFundId},updatetime=#{updateTime}
+        update fund_alias set target_fund_id=#{targetFundId},updatetime=#{updateTime},review_status=#{reviewStatus}
         where isvalid =1 and id=#{id}
     </update>
     <update id="batchDelete">
@@ -28,6 +29,17 @@
             #{id}
         </foreach>
     </update>
+    <update id="updateReviewStatus">
+        update fund_alias
+        set updatetime=now(),
+        review_status = #{reviewStatus},
+        updaterid=#{userId}
+        where isvalid = 1
+        and id in
+        <foreach item="id" collection="idList" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </update>
 
     <select id="queryFundByNameAndRegisterNumber" resultMap="BaseResultMap">
         select alias.target_fund_id,
@@ -100,6 +112,7 @@
         alias.createtime,
         alias.updatetime,
         alias.updaterid,
+        alias.review_status,
         fnmi.nav_total,
         fnmi.asset_total
         from PPW_EMAIL.fund_alias alias
@@ -182,11 +195,11 @@
 
     <insert id="batchInsert">
         insert into fund_alias(source_fund_name, source_register_number,target_fund_id,
-                                         isvalid,creatorid,createtime,updaterid,updatetime)
+                                         isvalid,creatorid,createtime,updaterid,updatetime,review_status)
         values
         <foreach collection="itemDoList" item="itemDo" index="index" separator=",">
             (#{itemDo.sourceFundName},#{itemDo.sourceRegisterNumber},#{itemDo.targetFundId},
-            #{itemDo.isvalid}, #{itemDo.creatorId}, #{itemDo.createTime}, #{itemDo.updaterId}, #{itemDo.updateTime})
+            #{itemDo.isvalid}, #{itemDo.creatorId}, #{itemDo.createTime}, #{itemDo.updaterId}, #{itemDo.updateTime}, #{itemDo.reviewStatus})
         </foreach>
     </insert>
 

service-daq/src/main/java/com/simuwang/daq/service/EmailParseService.java

@@ -998,6 +998,11 @@ public class EmailParseService {
         fundAliasDO.setCreateTime(new Date());
         fundAliasDO.setUpdateTime(new Date());
         fundAliasDO.setUpdaterId(0);
+        if(StringUtil.isNotEmpty(fundId)){
+            fundAliasDO.setReviewStatus(1);
+        }else{
+            fundAliasDO.setReviewStatus(0);
+        }
         return fundAliasDO;
     }
 

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

@@ -5,6 +5,7 @@ import com.simuwang.base.pojo.dto.query.FundAliasPageQuery;
 import com.simuwang.base.pojo.vo.FundAliasVO;
 import com.simuwang.base.pojo.vo.IdListVO;
 import com.simuwang.base.pojo.vo.IdVO;
+import com.simuwang.base.pojo.vo.ReviewStatusVO;
 import com.simuwang.logging.SystemLog;
 import com.simuwang.manage.service.FundAliasService;
 import com.smppw.common.pojo.ResultVo;
@@ -74,4 +75,10 @@ public class FunAliasController {
     }
 
 
+    @SystemLog(value = "根据邮件ID修改处理状态")
+    @PostMapping("/review-status")
+    public ResultVo reviewStatus(@RequestBody ReviewStatusVO reviewStatusVO){
+        fundAliasService.updateReviewStatus(reviewStatusVO);
+        return ResultVo.ok(true);
+    }
 }

service-manage/src/main/java/com/simuwang/manage/service/FundAliasService.java

@@ -5,6 +5,7 @@ import com.simuwang.base.pojo.dos.FundRegisterDO;
 import com.simuwang.base.pojo.dto.query.FundAliasPageQuery;
 import com.simuwang.base.pojo.vo.FundAliasVO;
 import com.simuwang.base.pojo.vo.IdListVO;
+import com.simuwang.base.pojo.vo.ReviewStatusVO;
 
 import java.util.List;
 
@@ -24,4 +25,6 @@ public interface FundAliasService {
     void deleteFundAlias(IdListVO idListVO);
 
     List<FundRegisterDO> getNotMappingFundList();
+
+    void updateReviewStatus(ReviewStatusVO reviewStatusVO);
 }

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

@@ -9,6 +9,7 @@ import com.simuwang.base.pojo.dos.FundRegisterDO;
 import com.simuwang.base.pojo.dto.query.FundAliasPageQuery;
 import com.simuwang.base.pojo.vo.FundAliasVO;
 import com.simuwang.base.pojo.vo.IdListVO;
+import com.simuwang.base.pojo.vo.ReviewStatusVO;
 import com.simuwang.manage.service.EmailFundAssetService;
 import com.simuwang.manage.service.EmailFundNavService;
 import com.simuwang.manage.service.EmailFundInfoService;
@@ -86,7 +87,9 @@ public class FundAliasServiceImpl implements FundAliasService {
         fundAliasDO.setUpdaterId(UserUtils.getLoginUser().getUserId());
         fundAliasDO.setCreatorId(UserUtils.getLoginUser().getUserId());
         fundAliasDO.setUpdateTime(new Date());
-
+        if(StringUtil.isNotEmpty(fundAliasVO.getTargetFundId())){
+            fundAliasVO.setReviewStatus(1);
+        }
         FundAliasDO oldFundAliasDO = fundAliasMapper.searchFundAliasById(fundAliasVO.getId());
         String oldFundId = oldFundAliasDO.getTargetFundId();
         fundAliasMapper.saveFundAlias(fundAliasDO);
@@ -136,4 +139,10 @@ public class FundAliasServiceImpl implements FundAliasService {
     public List<FundRegisterDO> getNotMappingFundList() {
         return fundAliasMapper.getNotMappingFundList();
     }
+
+    @Override
+    public void updateReviewStatus(ReviewStatusVO reviewStatusVO) {
+        Integer userId = UserUtils.getLoginUser().getUserId();
+        fundAliasMapper.updateReviewStatus(reviewStatusVO.getIdList(),reviewStatusVO.getReviewStatus(),userId);
+    }
 }