feat: 提取代码 方便代码跟踪

project-order/src/main/java/com/dituhui/pea/order/service/impl/BeanRemoteServiceImpl.java

@@ -204,8 +204,20 @@ public class BeanRemoteServiceImpl {
                 log.warn("分站：{}工程师{}没有工号", departId, userDetailInfo.getUsername());
                 log.warn("分站：{}工程师{}没有工号", departId, userDetailInfo.getUsername());
                 continue;
                 continue;
             }
             }
-
+            final Address address = userDetailInfo.getAddress();
+            //fixme  正式同步需移除当前逻辑
             engineerCode = "BEAN" + engineerCode;
             engineerCode = "BEAN" + engineerCode;
+            EngineerInfoEntity engineerInfo = getEngineerInfoEntity(departId, engineerCode, userDetailInfo, address);
+            engineerInfoDao.save(engineerInfo);
+            engineerInfoDao.flush();
+            //保存业务属性信息--常用出发地信息
+            EngineerBusinessEntity engineerBusiness = getEngineerBusiness(engineerCode, address);
+            if (engineerBusiness == null){ continue;}
+            engineerBusinessDao.save(engineerBusiness);
+        }
+    }
+
+    private EngineerInfoEntity getEngineerInfoEntity(String departId, String engineerCode, BeanUserDetail userDetailInfo, Address address) {
         //查询是否有当前工程师工号
         //查询是否有当前工程师工号
         EngineerInfoEntity engineerInfo = engineerInfoDao.getByEngineerCode(engineerCode);
         EngineerInfoEntity engineerInfo = engineerInfoDao.getByEngineerCode(engineerCode);
         //获取有用信息保存工程师信息
         //获取有用信息保存工程师信息
@@ -230,7 +242,6 @@ public class BeanRemoteServiceImpl {
 
 
 
 
         //fixme 工作地址存贮
         //fixme 工作地址存贮
-            Address address = userDetailInfo.getAddress();
         if (Objects.nonNull(address)) {
         if (Objects.nonNull(address)) {
             engineerInfo.setWorkAddress(address.getAddress());
             engineerInfo.setWorkAddress(address.getAddress());
         } else {
         } else {
@@ -239,14 +250,13 @@ public class BeanRemoteServiceImpl {
 
 
         engineerInfo.setCreateTime(LocalDateTime.now());
         engineerInfo.setCreateTime(LocalDateTime.now());
         engineerInfo.setUpdateTime(LocalDateTime.now());
         engineerInfo.setUpdateTime(LocalDateTime.now());
+        return engineerInfo;
+    }
 
 
-            engineerInfoDao.save(engineerInfo);
-            engineerInfoDao.flush();
-
-            //保存业务属性信息--常用出发地信息
+    private EngineerBusinessEntity getEngineerBusiness(String engineerCode, Address address) {
         EngineerBusinessEntity engineerBusiness = engineerBusinessDao.getByEngineerCode(engineerCode);
         EngineerBusinessEntity engineerBusiness = engineerBusinessDao.getByEngineerCode(engineerCode);
         if (Objects.nonNull(engineerBusiness)) {
         if (Objects.nonNull(engineerBusiness)) {
-                continue;
+            return null;
         }
         }
 
 
         engineerBusiness = new EngineerBusinessEntity();
         engineerBusiness = new EngineerBusinessEntity();
@@ -275,10 +285,7 @@ public class BeanRemoteServiceImpl {
         engineerBusiness.setDispatchStrategy("CENTER");
         engineerBusiness.setDispatchStrategy("CENTER");
         engineerBusiness.setCreateTime(LocalDateTime.now());
         engineerBusiness.setCreateTime(LocalDateTime.now());
         engineerBusiness.setUpdateTime(LocalDateTime.now());
         engineerBusiness.setUpdateTime(LocalDateTime.now());
-
-            engineerBusinessDao.save(engineerBusiness);
-        }
-
+        return engineerBusiness;
     }
     }
 
 
     private Date converter(String timestamp) {
     private Date converter(String timestamp) {