| | |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.alibaba.fastjson2.JSONArray; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.dy.common.multiDataSource.DataSourceContext; |
|---|
| | | import com.dy.common.mw.protocol.Command; |
|---|
| | | import com.dy.common.webUtil.BaseResponse; |
|---|
| | | import com.dy.common.webUtil.QueryResultVo; |
|---|
| | |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.dubbo.common.utils.PojoUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.core.env.Environment; |
|---|
| | | import org.springframework.http.HttpEntity; |
|---|
| | | import org.springframework.http.HttpHeaders; |
|---|
| | | import org.springframework.http.HttpMethod; |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private RestTemplate restTemplate; |
|---|
| | | |
|---|
| | | protected static String mwUrlSendCom = "http://127.0.0.1:8070/rtuMw/com/send"; |
|---|
| | | // protected static String mwUrlSendCom = "http://127.0.0.1:8070/rtuMw/com/send"; |
|---|
| | | protected String comSendUrl; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * pro_mw：属性 |
|---|
| | | * tag从控制器中获取 |
|---|
| | | * key_mw：url的key |
|---|
| | | */ |
|---|
| | | private Environment env = null; |
|---|
| | | private String pro_mw = "mw"; |
|---|
| | | private String key_mw = "comSendUrl"; |
|---|
| | | @Autowired |
|---|
| | | public ControllerSv(Environment env) { |
|---|
| | | this.env = env; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据指定获取控制器记录 |
|---|
| | |
|---|
| | | */ |
|---|
| | | public QueryResultVo<List<VoController>> getControllers(QueryVo queryVo) { |
|---|
| | | |
|---|
| | | Command com = new Command(); |
|---|
| | | Command com = new Command() ; |
|---|
| | | com.id = Command.defaultId; |
|---|
| | | com.code = "LCD0001"; |
|---|
| | | com.type = "innerCommand"; |
|---|
| | | comSendUrl = env.getProperty(pro_mw + "." + DataSourceContext.get() + "." + key_mw); |
|---|
| | | |
|---|
| | | JSONObject response = (JSONObject) JSON.toJSON(sendCom2Mw(com)); |
|---|
| | | |
|---|
| | | |
|---|
| | | if (response != null && response.getString("code").equals("0001")) { |
|---|
| | | JSONObject attachment = response.getJSONObject("content").getJSONObject("attachment").getJSONObject("onLineMap"); |
|---|
| | |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | protected BaseResponse sendCom2Mw(Command com) { |
|---|
| | | String url = UriComponentsBuilder.fromUriString(mwUrlSendCom) |
|---|
| | | String url = UriComponentsBuilder.fromUriString(comSendUrl) |
|---|
| | | .build() |
|---|
| | | .toUriString(); |
|---|
| | | HttpHeaders headers = new HttpHeaders(); |
|---|
