| | |
| | | import cn.gistack.by.nettyUpload.utils.ExceptionUtils; |
| | | import cn.gistack.by.picUpload.entity.BaiyiPicEntity; |
| | | import cn.gistack.by.picUpload.entity.XfByPic; |
| | | import cn.gistack.by.picUpload.entity.XfBySnRelation; |
| | | import cn.gistack.by.picUpload.service.BaiyiPicService; |
| | | import cn.gistack.resource.feign.IOssClient; |
| | | import cn.hutool.core.date.DateUtil; |
| | |
| | | import java.net.URISyntaxException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.Date; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import org.springframework.mock.web.MockMultipartFile; |
| | |
| | | * 没有Authorization验证 |
| | | */ |
| | | private static final String UPLOAD_FILE_URL_OLD = "/termite/termiteDataupOld"; |
| | | /** |
| | | * * 旧设备sn码和物联网关系表 |
| | | * * 没有Authorization验证 |
| | | */ |
| | | private static final String UPLOAD_FILE_OLD_RELATION = "/termite/termiteRelation"; |
| | | |
| | | private NettyHttpConfig nettyHttpConfig; |
| | | |
| | |
| | | baiyiPicService.inserXfOldPicUrl(xfByPic); |
| | | |
| | | |
| | | }else if(UPLOAD_DATA_URL.equals(urlyz)) { //传数据 |
| | | }else if(UPLOAD_FILE_OLD_RELATION.equals(urlyz)) { //传sn和rtu编码关系接口 |
| | | HttpPostMultipartRequestDecoder test = new HttpPostMultipartRequestDecoder(fullRequest); |
| | | List<InterfaceHttpData> bodyHttpDatas = test.getBodyHttpDatas(); |
| | | String sn = ""; |
| | | for (InterfaceHttpData item : bodyHttpDatas ) { |
| | | if ( item instanceof Attribute){ |
| | | |
| | | } else if (item instanceof FileUpload) { |
| | | System.out.println("Attribute:::"+item.getName()); |
| | | |
| | | Attribute attribute = (Attribute) item; |
| | | String value = attribute.getValue(); |
| | | switch (attribute.getName()) { |
| | | case "sn": |
| | | sn = value; |
| | | break; |
| | | } |
| | | |
| | | } |
| | | } |
| | | // 查询sn对应的 |
| | | XfBySnRelation xfBySnRelation = baiyiPicService.selectMnnoBySn(sn); |
| | | HashMap<String, Object> objectObjectHashMap = new HashMap<>(); |
| | | objectObjectHashMap.put("mn_no", xfBySnRelation.getWlwRtu()); |
| | | objectObjectHashMap.put("order", xfBySnRelation.getWlwOrder()); |
| | | |
| | | |
| | | HttpResponseUtils.sendResponseJson2(ctx, HttpResponseStatus.OK, "查询成功",objectObjectHashMap); |
| | | return ; |
| | | } else { |
| | | HttpResponseUtils.sendResponseJson2(ctx, HttpResponseStatus.BAD_REQUEST, "验证失败",null); |
| | | return ; |