lite模型同步

SLN/%PUBPRJ%-core/src/main/resources/sysmodel/%ITEM%.json.ftl

+<#ibiztemplate>
+TARGET=PSSYSTEM
+</#ibiztemplate>
+{
+    "systemid":"${sys.codeName}",
+    "systemname":"${sys.getLogicName()}",
+    "entities":[
+    <#if sys.getAllPSDataEntities()??>
+        <#list sys.getAllPSDataEntities() as de>
+    {
+    "entity_name":"${de.name}",
+    "logicname":"${de.logicName}",
+    "code_name":"${de.codeName}",
+    "table_name":"${de.getTableName()}",
+    "system_id":"${sys.codeName}",
+    "system_name":"${sys.logicName}",
+    "ds_id":null,
+    "ds_name":"",
+    "defield":[
+    <#if de.getPSDEFields()??>
+    <#list de.getPSDEFields() as defield>
+    {
+    "fieldname":"${defield.name}" ,
+    "codename":"${defield.codeName}",
+    "field_logic_name":"${defield.logicName}",
+    "entity_name":"${de.codeName}",
+    "ref_field_name":"<#if defield.getRelatedPSDEField()??>${defield.getRelatedPSDEField().codeName}</#if>",
+    "relation_name":"<#if (defield.getDataType()=='PICKUP' || defield.getDataType()='PICKUPDATA' )&& defield.getPSDER1N()>${defield.getPSDER1N().getName()}</#if>",
+    "field_type":"${srfr7javatype(defield.getStdDataType())}",
+    "dict":"<#if defield.getPSCodeList()??>${defield.getPSCodeList().codeName}</#if>",
+    "nullable":<#if defield.isAllowEmpty()>1<#else>0</#if>,
+    "physical_field":<#if defield.isPhisicalDEField()>1<#else>0</#if>,
+    "data_type":"${srfdatatype(defield.getStdDataType())}",
+    "data_length":<#if defield.getLength()?c!='-1'>${defield.getLength()?c}</#if>,
+    "data_preci":${defield.getPrecision()}?c,
+    "expression":"",
+    }<#if defield_has_next>,</#if>
+    </#list>
+    </#if>
+    ],
+    "relations":[
+    <#if de.getMinorPSDERs()??>
+    <#list de.getMinorPSDERs() as minorPSDER>
+    {"name":"${minorPSDER.name}",
+     "relation_type":"${minorPSDER.getDERType()}",
+     "code_name":"${minorPSDER.getCodeName()}",
+     "entity_name":"${minorPSDER.getMinorPSDataEntity().codeName}",
+     "ref_entity_name":"${minorPSDER.getMajorPSDataEntity().codeName}",
+     "nested_name":"",
+     "lookup":""
+    }<#if minorPSDER_has_next>,</#if>
+    </#list>
+    </#if>
+    ]
+ }
+    <#if de_has_next>,</#if>
+        </#list>
+    </#if>
+    ]
+}

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/client/IBZLiteFallback.java.ftl

+<#ibiztemplate>
+TARGET=PSSYSTEM
+</#ibiztemplate>
+package ${pub.getPKGCodeName()}.util.client;
+
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.stereotype.Component;
+
+@Component
+public class IBZLiteFallback implements IBZLiteFeignClient {
+
+	@Override
+	public Boolean syncSysModel(JSONObject system) {
+		return null;
+	}
+}

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/client/IBZLiteFeignClient.java.ftl

+<#ibiztemplate>
+TARGET=PSSYSTEM
+</#ibiztemplate>
+package ${pub.getPKGCodeName()}.util.client;
+
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+
+@FeignClient(value = "${ibiz.ref.service.lite:ibzlite-api}",contextId = "lite",fallback = IBZLiteFallback.class)
+public interface IBZLiteFeignClient
+{
+	/**
+	 * 同步系统资模型到lite
+	 * @param system 系统模型信息
+	 * @return
+	 */
+	@PostMapping("/dstsystems/save")
+	Boolean syncSysModel(@RequestBody JSONObject system);
+}

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/job/PermissionSyncJob.java.ftl

@@ -23,6 +23,7 @@ TARGET=PSSYSTEM
 package ${pub.getPKGCodeName()}.util.job;
 
 import ${pub.getPKGCodeName()}.util.client.IBZUAAFeignClient;
+import ${pub.getPKGCodeName()}.util.client.IBZLiteFeignClient;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.JSONArray;
 import lombok.extern.slf4j.Slf4j;
@@ -68,6 +69,10 @@ public class PermissionSyncJob implements ApplicationRunner {
     private ${pub.getPKGCodeName()}.util.client.IBZNotifyFeignClient notifyFeignClient;
     </#if>
 
+    @Autowired
+    @Lazy
+    IBZLiteFeignClient liteFeignClient;
+
     @Override
     public void run(ApplicationArguments args) {
         try {
@@ -89,6 +94,24 @@ public class PermissionSyncJob implements ApplicationRunner {
             log.error(String.format("向[UAA]同步系统资源失败，请检查[UAA]服务是否正常! [%s]",ex));
         }
 
+        try {
+            InputStream sysModel= this.getClass().getResourceAsStream("/sysmodel/${sys.codeName}.json"); //获取当前系统所有实体资源能力
+            String strSysModel = IOUtils.toString(sysModel,"UTF-8");
+            JSONObject system= new JSONObject();
+            system.put("pssystemid",systemId);
+            system.put("pssystemname",systemName);
+            system.put("sysstructure",JSONObject.parseObject(strSysModel));
+            system.put("md5check",DigestUtils.md5DigestAsHex(strSysModel.getBytes()));
+            if(liteFeignClient.syncSysModel(system)){
+                log.info("向[lite]同步系统模型成功");
+            }else{
+                log.error("向[lite]同步系统模型失败");
+            }
+        }
+        catch (Exception ex) {
+            log.error(String.format("向[lite]同步系统模型失败，请检查[lite]服务是否正常! [%s]",ex));
+        }
+
         <#if hasWF>
         try{
             List<Map<String,Object>> bpmnfiles=new ArrayList();