| | |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.java110.core.client.RestTemplate; |
| | | import com.java110.core.context.Environment; |
| | | import com.java110.core.factory.GenerateCodeFactory; |
| | | import com.java110.core.log.LoggerFactory; |
| | | import com.java110.dto.app.AppDto; |
| | |
| | | |
| | | public static final String FALLBACK_URL = "http://SERVICE_NAME/businessApi/fallBack"; |
| | | |
| | | public static final String BOOT_FALLBACK_URL = "http://127.0.0.1:8008/businessApi/fallBack"; |
| | | |
| | | public static final String SERVICE_NAME = "SERVICE_NAME"; |
| | | |
| | | |
| | | @Autowired |
| | | private ICenterServiceDAO centerServiceDAOImpl; |
| | | |
| | | @Autowired |
| | | private RestTemplate outRestTemplate; |
| | | |
| | | @Autowired |
| | | private RestTemplate restTemplate; |
| | |
| | | try { |
| | | JSONArray params = generateParam(orderItemDto); |
| | | httpEntity = new HttpEntity<String>(params.toJSONString(), header); |
| | | restTemplate.exchange(FALLBACK_URL.replace(SERVICE_NAME, orderItemDto.getServiceName()), HttpMethod.POST, httpEntity, String.class); |
| | | |
| | | if (Environment.isStartBootWay()) { |
| | | outRestTemplate.exchange(BOOT_FALLBACK_URL, HttpMethod.POST, httpEntity, String.class); |
| | | } else if (!StringUtil.isEmpty(orderItemDto.getActionObj()) && !orderItemDto.getActionObj().equals("meter_water")) { |
| | | restTemplate.exchange(FALLBACK_URL.replace(SERVICE_NAME, orderItemDto.getServiceName()), HttpMethod.POST, httpEntity, String.class); |
| | | } |
| | | |
| | | //标记为订单项失败 |
| | | Map info = new HashMap(); |
| | |
| | | /** |
| | | * 这里 兼容性处理 |
| | | * 因为我们不涉及 物理删除 都是逻辑删除 所以 status_cd 为 1 时强行设置为DEL 为逻辑删除 |
| | | * |
| | | * @param orderItemDto |
| | | * @return |
| | | */ |
| | |
| | | |
| | | for (int afterValueIndex = 0; afterValueIndex < afterValues.size(); afterValueIndex++) { |
| | | JSONObject keyValue = afterValues.getJSONObject(afterValueIndex); |
| | | if (keyValue.containsKey("status_cd") && "1".equals(keyValue.getString("status_cd"))) { |
| | | if (keyValue.containsKey("status_cd") && "'1'".equals(keyValue.getString("status_cd"))) { |
| | | return "DEL"; |
| | | } |
| | | } |