|
|
|
@ -2,6 +2,7 @@ package com.inspect.metadata.montdatamqhandle.service.impl; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSONArray; |
|
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
|
import com.inspect.base.core.constant.Color; |
|
|
|
import com.inspect.metadata.eqpbook.service.IBasedataEqpBookService; |
|
|
|
import com.inspect.metadata.montdata.domain.BasedataMontTaskStaData; |
|
|
|
import com.inspect.metadata.montdata.service.IBasedataMontTaskStaDataService; |
|
|
|
@ -30,20 +31,19 @@ public class BasedataMontTaskStaDataConsumerHandle implements IBasedataMontDataH |
|
|
|
private FeignMsgClient feignMsgClient; |
|
|
|
|
|
|
|
public void handMontData(JSONObject jsonObject) { |
|
|
|
logger.info("handMontData:" + jsonObject); |
|
|
|
logger.info(Color.GREEN + "[METADATA] handMontData: {}" + Color.END, jsonObject); |
|
|
|
String Type = jsonObject.getString("Type"); |
|
|
|
JSONArray jsonObjectItems = jsonObject.getJSONArray("Items"); |
|
|
|
List<BasedataMontTaskStaData> list = jsonObjectItems.toJavaList(BasedataMontTaskStaData.class); |
|
|
|
if (null != list && !list.isEmpty()) { |
|
|
|
Date nowDate = DateUtils.getNowDate(); |
|
|
|
|
|
|
|
for (BasedataMontTaskStaData basedataMontTaskstadata : list) { |
|
|
|
basedataMontTaskstadata.setCreateTime(nowDate); |
|
|
|
this.basedataMontTaskStaDataService.insertBasedataMontTaskStaData(basedataMontTaskstadata); |
|
|
|
basedataMontTaskStaDataService.insertBasedataMontTaskStaData(basedataMontTaskstadata); |
|
|
|
basedataMontTaskstadata.setCreateTime(null); |
|
|
|
} |
|
|
|
|
|
|
|
this.feignMsgClient.senMessageToMl(Type, jsonObject.toJSONString()); |
|
|
|
feignMsgClient.senMessageToMl(Type, jsonObject.toJSONString()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|