Browse Source

feature 增加实现方法

xiahan 2 months ago
parent
commit
946ca25411

+ 40 - 0
js-security/security-common/src/main/java/com/rongwei/sfcommon/sys/service/impl/SynchronizationServiceImpl.java

@@ -18,6 +18,7 @@ import com.rongwei.rwcommon.base.exception.CustomException;
 import com.rongwei.rwcommonentity.commonservers.domain.SysFileItemDo;
 import com.rongwei.sfcommon.sys.dao.RiskSynchronizationDao;
 import com.rongwei.sfcommon.sys.service.*;
+import com.rongwei.sfcommon.sys.strategy.riskSyncStrategy.*;
 import com.rongwei.sfcommon.utils.Result;
 import org.apache.commons.beanutils.PropertyUtils;
 import org.apache.commons.lang.StringUtils;
@@ -2814,4 +2815,43 @@ public class SynchronizationServiceImpl implements SynchronizationService {
             }
         }
     }
+
+    @Override
+    public void asyncRiskTask(List<String> ids, String type) {
+
+        RiskDataConversionStrategy riskDataConversionStrategy=null;
+        switch (type) {
+            case "DH":
+                riskDataConversionStrategy = new DHStrategy();
+                break;
+            case "SXKJ":
+                riskDataConversionStrategy = new SXKJStrategy();
+                break;
+            case "LSYD":
+                riskDataConversionStrategy = new LSYDStrategy();
+                break;
+            case "GC":
+                riskDataConversionStrategy = new GCStrategy();
+                break;
+            case "DZ":
+                riskDataConversionStrategy = new DZStrategy();
+                break;
+            case "MBCD":
+                riskDataConversionStrategy = new MBCDStrategy();
+                break;
+            case "DT":
+                riskDataConversionStrategy = new DTStrategy();
+                break;
+            case "DL":
+                riskDataConversionStrategy = new DLStrategy();
+                break;
+            default:
+                break;
+        }
+        if(riskDataConversionStrategy==null){
+            log.error("作业类型:{}不正确",type);
+        }
+        RiskContext primaryContext = new RiskContext(riskDataConversionStrategy);
+        primaryContext.executeStrategy(ids);
+    }
 }