客户配置信息更新

epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SysSmsServiceImpl.java

@@ -219,6 +219,7 @@ public class SysSmsServiceImpl extends BaseServiceImpl<SysSmsDao, SysSmsEntity>
             parameterResult.forEach(p -> {
                 if (customerId.equals(p.getCustomerId())){
                     p.setBalanceStatus(Integer.valueOf(p.getParameterValue()) >= v.size() ? true : false);
+                    p.setSubtractParameterValue(String.valueOf(Integer.valueOf(p.getParameterValue()) - v.size()));
                 }
             });
         });
@@ -243,6 +244,9 @@ public class SysSmsServiceImpl extends BaseServiceImpl<SysSmsDao, SysSmsEntity>
         }catch (RenException e){
             logger.error(e.getInternalMsg());
         }
+        Map<Boolean, List<CrmParameterResultDTO>> groupByStatus = parameterResult.stream().collect(Collectors.groupingBy(CrmParameterResultDTO::getBalanceStatus));
+        List<CrmParameterResultDTO> crmParameterResultDTOS = groupByStatus.get(true);
+        operCrmOpenFeignClient.updateParamInfo(crmParameterResultDTOS);
 
 //        formDTOList.forEach(dto->{
 //            SysSmsDTO sysSmsDTO = new SysSmsDTO();

epmet-module/oper-crm/oper-crm-client/src/main/java/com/epmet/dto/result/CrmParameterResultDTO.java

@@ -36,4 +36,9 @@ public class CrmParameterResultDTO implements Serializable {
      * 余额状态【parameterValue】true：充足，false：不足
      */
     private Boolean balanceStatus = true;
+
+    /**
+     * 新的参数VALUE值
+     */
+    private String subtractParameterValue;
 }

epmet-module/oper-crm/oper-crm-client/src/main/java/com/epmet/feign/OperCrmOpenFeignClient.java

@@ -85,4 +85,13 @@ public interface OperCrmOpenFeignClient {
 	 */
 	@PostMapping("/oper/crm/parameter/parameterinfo")
 	Result<List<CrmParameterResultDTO>> selectParamInfo(@RequestBody List<CrmParameterFormDTO> formDTOs);
+
+	/**
+	 * @Description  更新客户配置信息
+	 * @Param formDTOS
+	 * @author zxc
+	 * @date 2021/1/4 下午4:23
+	 */
+	@PostMapping("/oper/crm/parameter/parameterupdate")
+	Result updateParamInfo(@RequestBody List<CrmParameterResultDTO> formDTOS);
 }

epmet-module/oper-crm/oper-crm-client/src/main/java/com/epmet/feign/fallback/OperCrmOpenFeignClientFallback.java

@@ -64,4 +64,9 @@ public class OperCrmOpenFeignClientFallback implements OperCrmOpenFeignClient {
 	public Result<List<CrmParameterResultDTO>> selectParamInfo(List<CrmParameterFormDTO> formDTOs) {
 		return ModuleUtils.feignConError(ServiceConstant.OPER_CRM_SERVER, "selectParamInfo", formDTOs);
 	}
+
+	@Override
+	public Result updateParamInfo(List<CrmParameterResultDTO> formDTOS) {
+		return ModuleUtils.feignConError(ServiceConstant.OPER_CRM_SERVER, "updateParamInfo", formDTOS);
+	}
 }

epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/controller/CustomerParameterController.java

@@ -3,7 +3,6 @@ package com.epmet.controller;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.validator.ValidatorUtils;
 import com.epmet.dto.form.CrmParameterFormDTO;
-import com.epmet.dto.form.ParameterFormDTO;
 import com.epmet.dto.result.CrmParameterResultDTO;
 import com.epmet.service.CustomerParameterService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -39,4 +38,16 @@ public class CustomerParameterController {
         return new Result<List<CrmParameterResultDTO>>().ok(parameterService.selectParamInfo(formDTOs));
     }
 
+    /**
+     * @Description  更新客户配置信息
+     * @Param formDTOS
+     * @author zxc
+     * @date 2021/1/4 下午4:23
+     */
+    @PostMapping("parameterupdate")
+    public Result updateParamInfo(@RequestBody List<CrmParameterResultDTO> formDTOS){
+        parameterService.updateParamInfo(formDTOS);
+        return new Result();
+    }
+
 }

epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/dao/CustomerParameterDao.java

@@ -24,4 +24,11 @@ public interface CustomerParameterDao extends BaseDao<CustomerParameterEntity> {
      */
     List<CrmParameterResultDTO> selectParamInfo(@Param("formDTOS")List<CrmParameterFormDTO> formDTOS);
 
+    /**
+     * @Description  更新客户配置信息
+     * @Param formDTOS
+     * @author zxc
+     * @date 2021/1/4 下午4:12
+     */
+    void updateParamInfo(@Param("formDTOS")List<CrmParameterResultDTO> formDTOS);
 }

epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/service/CustomerParameterService.java

@@ -19,4 +19,12 @@ public interface CustomerParameterService {
      */
     List<CrmParameterResultDTO> selectParamInfo(List<CrmParameterFormDTO> formDTOs);
 
+    /**
+     * @Description  更新客户配置信息
+     * @Param formDTOS
+     * @author zxc
+     * @date 2021/1/4 下午4:10
+     */
+    void updateParamInfo(List<CrmParameterResultDTO> formDTOS);
+
 }

epmet-module/oper-crm/oper-crm-server/src/main/java/com/epmet/service/impl/CustomerParameterServiceImpl.java

@@ -7,6 +7,7 @@ import com.epmet.service.CustomerParameterService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
 import java.util.ArrayList;
@@ -40,4 +41,17 @@ public class CustomerParameterServiceImpl implements CustomerParameterService {
         }
         return result;
     }
+
+    /**
+     * @Description  更新客户配置信息
+     * @Param formDTOS
+     * @author zxc
+     * @date 2021/1/4 下午4:11
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateParamInfo(List<CrmParameterResultDTO> formDTOS) {
+        if (CollectionUtils.isEmpty(formDTOS))return;
+        parameterDao.updateParamInfo(formDTOS);
+    }
 }

epmet-module/oper-crm/oper-crm-server/src/main/resources/mapper/CustomerParameterDao.xml

@@ -2,6 +2,19 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.epmet.dao.CustomerParameterDao">
 
+    <!-- 更新客户配置信息 -->
+    <update id="updateParamInfo">
+        <foreach collection="formDTOS" item="f" separator=";">
+            UPDATE customer_parameter
+            SET PARAMETER_VALUE = #{f.subtractParameterValue}
+            <where>
+                DEL_FLAG = 0
+                AND CUSTOMER_ID = #{f.customerId}
+                AND PARAMETER_KEY = #{f.parameterKey}
+            </where>
+        </foreach>
+    </update>
+
     <!-- 查询客户的配置信息 -->
     <select id="selectParamInfo" resultType="com.epmet.dto.result.CrmParameterResultDTO">
         SELECT