客户初始化接口完善

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java

@@ -88,7 +88,8 @@ public enum EpmetErrorCode {
 	PUBLIC_NOT_EXISTS(8651,"手机号未注册，请先完成信息注册"),
 	SELECT_CUSTOMER_ERROR(8652,"未查询到注册客户信息"),
 	SELECT_AGENCY_ERROR(8653,"根据客户信息未查询到注册客户组织信息"),
-	SELECT_USER_ERROR(8654,"根据客户信息未查询到注册客户管理员信息");
+	SELECT_USER_ERROR(8654,"根据客户信息未查询到注册客户管理员信息"),
+	UPDATE_CUSTOMER_ERROR(8655,"更新注册客户信息为已完成初始化失败");
 
 
 	private int code;

epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/EpmetThirdFeignClient.java

@@ -60,4 +60,12 @@ public interface EpmetThirdFeignClient {
     @PostMapping(value = "third/pacustomer/getcustomeragencyuser/{customerId}")
     Result<InitCustomerResultDTO> getCustomerAgencyUser(@PathVariable("customerId") String customerId);
 
+    /**
+     * @param customerId
+     * @return
+     * @Author sun
+     * @Description 修改客户数据状态为已完成初始化
+     **/
+    @PostMapping(value = "third/pacustomer/updatecustomer/{customerId}")
+    Result updateCustomer(@PathVariable("customerId") String customerId);
 }

epmet-module/epmet-third/epmet-third-client/src/main/java/com/epmet/feign/fallback/EpmetThirdFeignClientFallback.java

@@ -37,4 +37,9 @@ public class EpmetThirdFeignClientFallback implements EpmetThirdFeignClient {
     public Result<InitCustomerResultDTO> getCustomerAgencyUser(String customerId) {
         return ModuleUtils.feignConError(ServiceConstant.EPMET_THIRD_SERVER, "getCustomerAgencyUser", customerId);
     }
+
+    @Override
+    public Result updateCustomer(String customerId) {
+        return ModuleUtils.feignConError(ServiceConstant.EPMET_THIRD_SERVER, "updateCustomer", customerId);
+    }
 }

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/controller/PaCustomerController.java

@@ -110,4 +110,16 @@ public class PaCustomerController {
         return new Result<InitCustomerResultDTO>().ok(paCustomerService.getCustomerAgencyUser(customerId));
     }
 
+    /**
+     * @param customerId
+     * @return
+     * @Author sun
+     * @Description 修改客户数据状态为已完成初始化
+     **/
+    @PostMapping(value = "updatecustomer/{customerId}")
+    public Result updateCustomer(@PathVariable("customerId") String customerId) {
+        paCustomerService.updateCustomer(customerId);
+        return new Result();
+    }
+
 }

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/dao/PaCustomerDao.java

@@ -50,4 +50,12 @@ public interface PaCustomerDao extends BaseDao<PaCustomerEntity> {
      * @Description  查询公众号注册的客户信息列表
      **/
     List<CustomerAgencyResultDTO> registerInfo();
+
+    /**
+     * @param dto
+     * @return
+     * @Author sun
+     * @Description 修改客户数据状态为已完成初始化
+     **/
+    int updateCustomerById(PaCustomerDTO dto);
 }

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/PaCustomerService.java

@@ -148,4 +148,11 @@ public interface PaCustomerService extends BaseService<PaCustomerEntity> {
      **/
     InitCustomerResultDTO getCustomerAgencyUser(String customerId);
 
+    /**
+     * @param customerId
+     * @return
+     * @Author sun
+     * @Description 修改客户数据状态为已完成初始化
+     **/
+    void updateCustomer(String customerId);
 }

epmet-module/epmet-third/epmet-third-server/src/main/java/com/epmet/service/impl/PaCustomerServiceImpl.java

@@ -413,4 +413,23 @@ public class PaCustomerServiceImpl extends BaseServiceImpl<PaCustomerDao, PaCust
         return result;
     }
 
+    /**
+     * @param customerId
+     * @return
+     * @Author sun
+     * @Description 修改客户数据状态为已完成初始化
+     **/
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateCustomer(String customerId) {
+        //更新pa_customer表数据状态
+        PaCustomerDTO dto = new PaCustomerDTO();
+        dto.setId(customerId);
+        dto.setIsInitialize(NumConstant.ONE);
+        if (baseDao.updateCustomerById(dto) < NumConstant.ONE) {
+            logger.error(EpmetErrorCode.UPDATE_CUSTOMER_ERROR.getMsg());
+            throw new RenException(EpmetErrorCode.UPDATE_CUSTOMER_ERROR.getCode());
+        }
+    }
+
 }

epmet-module/epmet-third/epmet-third-server/src/main/resources/mapper/PaCustomerDao.xml

@@ -56,4 +56,12 @@
             pca.CREATED_TIME DESC
     </select>
 
+    <update id="updateCustomerById">
+        UPDATE pa_customer
+        SET is_initialize = #{isInitialize}
+        WHERE
+            del_flag = '0'
+        AND id = #{id}
+    </update>
+
 </mapper>

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/AgencyServiceImpl.java

@@ -309,6 +309,7 @@ public class AgencyServiceImpl implements AgencyService {
      * @Date 2020/7/16 17:13
      **/
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void saveRootAgency(AddAgencyAndStaffFormDTO agencyAndStaff) {
         CustomerAgencyDTO agencyDTO = agencyAndStaff.getAgencyDTO();
         AdminStaffFromDTO staffDTO = agencyAndStaff.getStaffDTO();

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

@@ -472,6 +472,12 @@ public class CustomerServiceImpl extends BaseServiceImpl<CustomerDao, CustomerEn
             throw new RenException(agencyResult.getCode(), agencyResult.getInternalMsg());
         }
 
+        //6.更新第三方数据库中客户数据状态为已初始化
+        Result customerResult = epmetThirdFeignClient.updateCustomer(formDTO.getCustomerId());
+        if (!customerResult.success()) {
+            throw new RenException(customerResult.getCode(), customerResult.getInternalMsg());
+        }
+
     }
 
 }