| | |
| | | package com.zy.asrs.task.handler; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | | import com.core.common.Cools; |
| | |
| | | @Slf4j |
| | | @Service |
| | | public class MesPakinHandler extends AbstractHandler<String> { |
| | | @Value("${mes.pakin.uri}") |
| | | @Value("${mes.pakin.url}") |
| | | private String uri; |
| | | |
| | | @Value("${mes.pakin.path}") |
| | |
| | | JSONObject jsonObject = null; |
| | | try { |
| | | jsonObject = doPostJsonData(); |
| | | log.info("MesPakinHandler jsonObject:" + jsonObject); |
| | | } catch (IOException e) { |
| | | success = false; |
| | | e.printStackTrace(); |
| | |
| | | int code = jsonObject.getInteger("code"); |
| | | |
| | | if(code == 200){ |
| | | JSONObject jsonData = jsonObject.getJSONObject("data"); |
| | | String orderNo = jsonData.getString("orderNo"); |
| | | Order o = insertOrder(jsonData,orderNo); |
| | | insertOrUpdateOrderDetl(jsonData, o); |
| | | if(!Cools.isEmpty(jsonObject.getString("data")) && jsonObject.getString("data").length()>2){ |
| | | |
| | | JSONArray jsonArray = jsonObject.getJSONArray("data"); |
| | | List<JSONObject> jsonDataList = jsonArray.toJavaList(JSONObject.class); |
| | | |
| | | jsonDataList.forEach(data -> { |
| | | String orderNo = data.getString("orderNo"); |
| | | Order o = insertOrder(data,orderNo); |
| | | insertOrUpdateOrderDetl(data, o); |
| | | }); |
| | | } |
| | | }else { |
| | | success = false; |
| | | log.error("请求mes接口响应错误,响应码为: " + code); |