add ASMS同步状态

2023-10-18 15:15:03 +08:00
parent f2595f2985
commit 00f10b047c
3 changed files with 20 additions and 1 deletions
@@ -87,6 +87,7 @@ public class LawsAsmsOpenApiController extends JeroController<LawsAsmsOpenApi, I
 	@ApiOperation(value="汽车标准数字化平台ASMS开放API接口管理-添加", notes="汽车标准数字化平台ASMS开放API接口管理-添加")
 	@PostMapping(value = "/add")
 	public Result<T> add(@Validated @RequestBody LawsAsmsOpenApi lawsAsmsOpenApi) {
+		lawsAsmsOpenApi.setStatus("0");
 		lawsAsmsOpenApiService.add(lawsAsmsOpenApi);
 		return Result.OK("操作成功!");
 	}
@@ -59,4 +59,9 @@ public class LawsAsmsOpenApi implements Serializable {
 	@Excel(name = "参数map", width = 15)
    @ApiModelProperty(value = "参数map")
    private java.lang.String queryParamJson;
+    /**状态（0未同步、1已同步）*/
+    @Excel(name = "状态（0未同步、1已同步）", width = 15)
+    @ApiModelProperty(value = "状态（0未同步、1已同步）")
+    @Dict(dicCode = "sync_status")
+    private java.lang.String status;
 }
@@ -151,7 +151,7 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe

 			if ("1".equals(lawsAsmsOpenApi.getApiType())
 					&& StringUtils.isNotBlank(lawsAsmsOpenApi.getDictId()) && !Objects.isNull(mapList)) {
-				// 如果是普通字典类型、字典id不为空、返回的数据不为空，则进行数据字典同步操作
+				// 如果是下拉字典（普通）、字典id不为空、返回的数据不为空，则进行数据字典同步操作
 				List<SysDictItem> dictItemList = new ArrayList();

 				// 删除该字典的全部数据项
@@ -180,15 +180,28 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
 						} else if ("name".equals(k)) {
 							// 字典项名称
 							dictItem.setItemText(v);
+						} else if ("id".equals(k)) {
+							// 主键
+							dictItem.setId(v);
+						} else if ("pid".equals(k)) {
+							// 父节点id
+							dictItem.setParentId(v);
+						} else if ("source".equals(k)) {
+							// 来源
+							dictItem.setDescription(v);
 						}
 					});
 					dictItemList.add(dictItem);
 				}
 				// 保存到数据库
 				sysDictItemService.saveBatch(dictItemList);
+				// 状态设置为已同步
+				lawsAsmsOpenApi.setStatus("1");
 				log.info("添加”{}“的字典数据项{}条数据...", lawsAsmsOpenApi.getApiName(), dictItemList.size());
 			}

 		});
+
+		updateBatchById(lawsAsmsOpenApiList);
 	}
 }