积分管理

src/main/java/com/poteviohealth/cgp/integration/controller/feign/IntegrationFeignController.java

@@ -4,6 +4,7 @@ package com.poteviohealth.cgp.integration.controller.feign;
 import com.poteviohealth.cgp.common.facade.log.OperateType;
 import com.poteviohealth.cgp.common.facade.log.OperationLog;
 import com.poteviohealth.cgp.common.integrated.EntityIdParams;
+import com.poteviohealth.cgp.common.integrated.customer.model.CustomerIntegration;
 import com.poteviohealth.cgp.common.model.VaultsResponse;
 import com.poteviohealth.cgp.integration.database.DataSourceDocument;
 import com.poteviohealth.cgp.integration.service.IIntegralDetailService;
@@ -19,6 +20,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
 
 import java.sql.Connection;
 import java.sql.SQLException;
+import java.util.List;
 
 /**
  * <p>
@@ -53,4 +55,13 @@ public class IntegrationFeignController {
             return VaultsResponse.exception();
         }
     }
+
+    @ApiOperation(value = "新增积分详情")
+    @RequestMapping(value = "/saveDetail", method = RequestMethod.POST)
+    @ApiImplicitParam(name = "customerIntegration", value = "运营商ID", required = true)
+    @ResponseBody
+    @OperationLog(type = OperateType.FEIGN,description = "新增积分详情数据")
+    public VaultsResponse saveDetail(List<CustomerIntegration> customerIntegration){
+        return iIntegralDetailService.saveDetail(customerIntegration);
+    }
 }

src/main/java/com/poteviohealth/cgp/integration/mapstruct/IntegralConverter.java

@@ -1,11 +1,15 @@
 package com.poteviohealth.cgp.integration.mapstruct;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.poteviohealth.cgp.common.integrated.customer.model.CustomerIntegration;
 import com.poteviohealth.cgp.common.model.CommonPage;
 import com.poteviohealth.cgp.integration.model.IntegralDetail;
 import com.poteviohealth.cgp.integration.model.outvo.web.IntegralDetailWebOutDTO;
 import org.mapstruct.Mapper;
 import org.mapstruct.factory.Mappers;
+
+import java.util.List;
+
 /**
  * @description 实体映射工具
  * @Date 6:30 PM 2019/7/25
@@ -35,4 +39,6 @@ public interface IntegralConverter {
      **/
     CommonPage<IntegralDetailWebOutDTO> model2WebDTO(CommonPage<IntegralDetail> integralDetailIPage);
 
+    IntegralDetail model2FeginDTO(CustomerIntegration customerIntegration);
+    List<IntegralDetail> model2FeginDTO(List<CustomerIntegration> customerIntegration);
 }

src/main/java/com/poteviohealth/cgp/integration/service/IIntegralDetailService.java

@@ -1,5 +1,6 @@
 package com.poteviohealth.cgp.integration.service;
 
+import com.poteviohealth.cgp.common.integrated.customer.model.CustomerIntegration;
 import com.poteviohealth.cgp.common.model.CommonPage;
 import com.poteviohealth.cgp.common.model.VaultsResponse;
 import com.poteviohealth.cgp.common.service.IBaseService;
@@ -8,6 +9,7 @@ import com.poteviohealth.cgp.integration.model.invo.web.IntegralDetailWebInDTO;
 import com.poteviohealth.cgp.integration.model.outvo.web.IntegralDetailWebOutDTO;
 
 import java.sql.Connection;
+import java.util.List;
 
 /**
  * @author Qin
@@ -28,4 +30,6 @@ public interface IIntegralDetailService extends IBaseService<IntegralDetail> {
      * @return VaultsResponse<CommonPage<IntegralDetailWebOutDTO>>
      **/
     VaultsResponse<CommonPage<IntegralDetailWebOutDTO>> selectPage(IntegralDetailWebInDTO integralDetailWebInDTO);
+
+    VaultsResponse saveDetail(List<CustomerIntegration> customerIntegration);
 }

src/main/java/com/poteviohealth/cgp/integration/service/impl/IntegralDetailServiceImpl.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.poteviohealth.cgp.common.filter.TokenContext;
+import com.poteviohealth.cgp.common.integrated.customer.model.CustomerIntegration;
 import com.poteviohealth.cgp.common.model.CommonPage;
 import com.poteviohealth.cgp.common.model.VaultsResponse;
 import com.poteviohealth.cgp.common.service.impl.BaseServiceImpl;
@@ -22,6 +23,7 @@ import org.springframework.transaction.annotation.Transactional;
 import java.sql.Connection;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.List;
 import java.util.Properties;
 
 /**
@@ -100,6 +102,12 @@ public class IntegralDetailServiceImpl extends BaseServiceImpl<IntegralDetailMap
         return VaultsResponse.success(IntegralConverter.INSTANCE.model2WebDTO(pageOrder));
     }
 
+    @Override
+    public VaultsResponse saveDetail(List<CustomerIntegration> customerIntegration) {
+
+        return VaultsResponse.success(super.saveBatch(IntegralConverter.INSTANCE.model2FeginDTO(customerIntegration)));
+    }
+
     private CommonPage<IntegralDetail> selectOrderIPage(IntegralDetailWebInDTO integralDetailWebInDTO) {
         IPage<IntegralDetail> page = new Page<>(integralDetailWebInDTO.getPageNum(), integralDetailWebInDTO.getPageSize());