资产池管理

app/biz/service/src/main/java/com/abssqr/plat/biz/api/astPool/AstPoolServiceImpl.java

+package com.abssqr.plat.biz.api.astPool;
+
+import com.abssqr.plat.biz.support.ServiceSupport;
+import com.abssqr.plat.common.dal.mysql.auto.paging.AstPoolPage;
+import com.abssqr.plat.common.facade.enums.AstTypeEnum;
+import com.abssqr.plat.common.facade.param.astPool.AstPoolOprParam;
+import com.abssqr.plat.common.facade.param.astPool.AstPoolPageQryParam;
+import com.abssqr.plat.common.facade.result.BasePage;
+import com.abssqr.plat.common.facade.result.astPool.AstPoolVO;
+import com.abssqr.plat.common.facade.service.AstPoolService;
+import com.abssqr.plat.common.model.convertor.AstPoolConvert;
+import com.abssqr.plat.common.model.domain.ast.AstPoolEntity;
+import com.abssqr.plat.common.model.repo.astPool.AstPoolRepository;
+import com.general.system.common.util.VarChecker;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class AstPoolServiceImpl extends ServiceSupport implements AstPoolService{
+
+    @Autowired
+    AstPoolRepository astPoolRepository;
+    @Override
+    public int add(AstPoolOprParam astPoolOprParam) {
+        AstPoolEntity astPoolEntity=new AstPoolEntity();
+        astPoolEntity.setAstTypeEnum(AstTypeEnum.getByCode(astPoolOprParam.getAstTypeCode()));
+        astPoolEntity.setAstPoolNo(astPoolOprParam.getAstPoolNo());
+        astPoolEntity.setAstPoolName(astPoolOprParam.getAstPoolName());
+        VarChecker.checkArgument(astPoolRepository.checkAstPool(astPoolEntity),"资产池名称/资产池编号重复");
+        return astPoolRepository.create(astPoolEntity);
+    }
+
+    @Override
+    public BasePage<AstPoolVO> page(AstPoolPageQryParam astPoolPageQryParam) {
+        BasePage<AstPoolVO> result=new BasePage();
+        AstPoolPage page = astPoolRepository.getPage(astPoolPageQryParam);
+        result.setDatas(AstPoolConvert.convert2VOs(page.getDatas()));
+        result.setCurrPageNo(page.getCurrPageNo());
+        result.setTotal(page.getTotal());
+        return result;
+    }
+
+    @Override
+    public AstPoolVO get(String astPoolNo) {
+        AstPoolEntity astPoolEntity = astPoolRepository.getByAstPoolNo(astPoolNo);
+        VarChecker.checkNotNull(astPoolEntity,"资产池不存在");
+        return AstPoolConvert.convert2VO(astPoolEntity);
+    }
+
+}

app/common/facade/src/main/java/com/abssqr/plat/common/facade/param/astPool/AstPoolPageQryParam.java

 package com.abssqr.plat.common.facade.param.astPool;
 
-import com.abssqr.plat.common.facade.param.base.CommonPlanPageQryParam;
+import com.abssqr.plat.common.facade.base.BasePageQryParam;
+import com.abssqr.plat.common.facade.enums.EventCodeEnum;
 
-public class AstPoolPageQryParam extends CommonPlanPageQryParam {
+public class AstPoolPageQryParam extends BasePageQryParam {
 
     private String astPoolName;
 
@@ -13,4 +14,9 @@ public class AstPoolPageQryParam extends CommonPlanPageQryParam {
     public void setAstPoolName(String astPoolName) {
         this.astPoolName = astPoolName;
     }
+
+    @Override
+    public EventCodeEnum getEventCode() {
+        return EventCodeEnum.ADMIN_LIST_QRY;
+    }
 }

app/common/facade/src/main/java/com/abssqr/plat/common/facade/result/astPool/AstPoolVO.java

@@ -3,8 +3,7 @@ package com.abssqr.plat.common.facade.result.astPool;
 public class AstPoolVO {
     private String astPoolName;
     private String astTypeName;
-    private String astTypeCode;
-
+    private String astPoolNo;
     public String getAstPoolName() {
         return astPoolName;
     }
@@ -21,11 +20,12 @@ public class AstPoolVO {
         this.astTypeName = astTypeName;
     }
 
-    public String getAstTypeCode() {
-        return astTypeCode;
+
+    public String getAstPoolNo() {
+        return astPoolNo;
     }
 
-    public void setAstTypeCode(String astTypeCode) {
-        this.astTypeCode = astTypeCode;
+    public void setAstPoolNo(String astPoolNo) {
+        this.astPoolNo = astPoolNo;
     }
 }

app/common/facade/src/main/java/com/abssqr/plat/common/facade/service/AstPoolService.java

+package com.abssqr.plat.common.facade.service;
+
+import com.abssqr.plat.common.facade.param.astPool.AstPoolOprParam;
+import com.abssqr.plat.common.facade.param.astPool.AstPoolPageQryParam;
+import com.abssqr.plat.common.facade.result.BasePage;
+import com.abssqr.plat.common.facade.result.astPool.AstPoolVO;
+
+public interface AstPoolService {
+
+    int add(AstPoolOprParam astPoolOprParam);
+
+    BasePage<AstPoolVO> page(AstPoolPageQryParam astPoolPageQryParam);
+
+    AstPoolVO get(String astPoolNo);
+}

app/common/model/src/main/java/com/abssqr/plat/common/model/convertor/AstPoolConvert.java

@@ -6,7 +6,12 @@ package com.abssqr.plat.common.model.convertor;
 
 import com.abssqr.plat.common.dal.mysql.auto.dataobject.AstPoolDO;
 import com.abssqr.plat.common.facade.enums.AstTypeEnum;
+import com.abssqr.plat.common.facade.result.astPool.AstPoolVO;
 import com.abssqr.plat.common.model.domain.ast.AstPoolEntity;
+import org.apache.commons.collections.CollectionUtils;
+
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  *
@@ -38,4 +43,46 @@ public class AstPoolConvert {
         return result;
     }
 
+    public static AstPoolVO convert2VO(AstPoolDO param){
+        if(param==null){
+            return null;
+        }
+        AstPoolVO result =new AstPoolVO();
+        result.setAstTypeName(AstTypeEnum.getByCode(param.getAstTypeCode()).getDesc());
+        result.setAstPoolNo(param.getAstPoolNo());
+        result.setAstPoolName(param.getAstPoolName());
+        return result;
+    }
+
+    public static AstPoolVO convert2VO(AstPoolEntity param){
+        if(param==null){
+            return null;
+        }
+        AstPoolVO result =new AstPoolVO();
+        result.setAstTypeName(param.getAstTypeEnum().getDesc());
+        result.setAstPoolNo(param.getAstPoolNo());
+        result.setAstPoolName(param.getAstPoolName());
+        return result;
+    }
+    public static List<AstPoolEntity> convert2Domains(List<AstPoolDO> param) {
+        if (param == null){
+            return null;
+        }
+        List<AstPoolEntity> result=new ArrayList<>();
+        param.forEach(v->{
+           result.add(convert2Domain(v));
+        });
+        return result;
+    }
+    public static List<AstPoolVO> convert2VOs(List<AstPoolDO> astPoolEntity){
+        if(CollectionUtils.isEmpty(astPoolEntity)){
+            return null;
+        }
+        List<AstPoolVO> result=new ArrayList<>();
+        astPoolEntity.forEach(v->{
+            result.add(convert2VO(v));
+        });
+        return result;
+    }
+
 }

app/common/model/src/main/java/com/abssqr/plat/common/model/repo/astPool/AstPoolRepository.java

@@ -30,4 +30,6 @@ public interface AstPoolRepository {
 
 
     AstPoolEntity getByAstPoolNo(String astPoolNo);
+
+    boolean checkAstPool(AstPoolEntity astPoolEntity);
 }
\ No newline at end of file

app/common/model/src/main/java/com/abssqr/plat/common/model/repo/astPool/impl/AstPoolRepositoryImpl.java

@@ -46,5 +46,14 @@ public class AstPoolRepositoryImpl implements AstPoolRepository {
         return AstPoolConvert.convert2Domain(astPoolDO);
     }
 
+    @Override
+    public boolean checkAstPool(AstPoolEntity astPoolEntity) {
+        Long dupliCnt = astPoolDAO.getDupliCnt(astPoolEntity.getAstPoolNo(), astPoolEntity.getAstPoolName());
+        if(dupliCnt!=null&&dupliCnt>1){
+            return false;
+        }
+        return true;
+    }
+
 
 }

app/web/src/main/java/com/abssqr/plat/web/controller/astPool/AstPoolController.java

 package com.abssqr.plat.web.controller.astPool;
 
 import com.abssqr.plat.common.facade.param.astPool.AstPoolOprParam;
+import com.abssqr.plat.common.facade.param.astPool.AstPoolPageQryParam;
+import com.abssqr.plat.common.facade.result.BasePage;
+import com.abssqr.plat.common.facade.result.ast.LoanListVO;
 import com.abssqr.plat.common.facade.result.astPool.AstPoolVO;
-import com.abssqr.plat.common.model.repo.astPool.AstPoolRepository;
+import com.abssqr.plat.common.facade.service.AstPoolService;
+import com.abssqr.plat.common.facade.validation.Valid;
 import com.general.enhanced.controller.annotation.RestJsonController;
+import com.general.system.common.model.BaseResult;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 @RestJsonController
 @RequestMapping("astPool")
 public class AstPoolController {
     @Autowired
-    private AstPoolRepository astPoolRepository;
+    private AstPoolService astPoolService;
 
-    @RequestMapping("add.json")
-    public AstPoolVO add(AstPoolOprParam astPoolEntity){
-        return null;
+    @PostMapping("add.json")
+    public BaseResult add(@Valid AstPoolOprParam astPoolOprParam){
+        return BaseResult.success(astPoolService.add(astPoolOprParam));
     }
+    @PostMapping("page.json")
+    public BasePage<AstPoolVO> page(AstPoolPageQryParam astPoolPageQryParam){
+        return astPoolService.page(astPoolPageQryParam);
+    }
+    @GetMapping("get.json")
+    public AstPoolVO get(String astNo){
+        return  astPoolService.get(astNo);
+    }
+
+
 
 }