| | |
|---|
| | | import com.fzzy.api.service.ApiRemoteService; |
|---|
| | | import com.fzzy.api.service.ApiTriggerService; |
|---|
| | | import com.fzzy.api.utils.*; |
|---|
| | | import com.fzzy.api.view.repository.Api1102Rep; |
|---|
| | | import com.fzzy.api.view.repository.Api1104Rep; |
|---|
| | | import com.fzzy.api.view.repository.Api1202Rep; |
|---|
| | | import com.fzzy.api.view.repository.ApiLogRep; |
|---|
| | | import com.fzzy.api.view.repository.*; |
|---|
| | | import com.fzzy.push.sh2023.dto.*; |
|---|
| | | import lombok.Data; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | import java.math.BigDecimal; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.HashSet; |
|---|
| | | import java.util.List; |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private Api1104Rep api1104Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1109Rep api1109Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1202Rep api1202Rep; |
|---|
| | | @Autowired |
|---|
| | | private Api1205Rep api1205Rep; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public String getProtocol() { |
|---|
| | |
|---|
| | | list.add(api1106); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1107.equals(inteId)) { |
|---|
| | | SH2023Api1107 api1107; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1107> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1107> api1107List = castList(data, Api1107.class); |
|---|
| | | for (Api1107 apiData : api1107List) { |
|---|
| | | api1107 = new SH2023Api1107(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1107); |
|---|
| | | api1107.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1107); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1108.equals(inteId)) { |
|---|
| | | SH2023Api1108 api1108; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1108> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1108> api1108List = castList(data, Api1108.class); |
|---|
| | | for (Api1108 apiData : api1108List) { |
|---|
| | | api1108 = new SH2023Api1108(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1108); |
|---|
| | | api1108.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1108); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1109.equals(inteId)) { |
|---|
| | | SH2023Api1109 api1109; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1109> list = new ArrayList<>(); |
|---|
| | | FileUtil file; |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1109> api1109List = castList(data, Api1109.class); |
|---|
| | | for (Api1109 apiData : api1109List) { |
|---|
| | | api1109 = new SH2023Api1109(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1109); |
|---|
| | | api1109.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | file = new FileUtil(); |
|---|
| | | api1109.setWjl(file.imgToIo(apiData.getWjdz() + apiData.getWjmc())); |
|---|
| | | list.add(api1109); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1110.equals(inteId)) { |
|---|
| | | SH2023Api1110 api1110; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1110> list = new ArrayList<>(); |
|---|
| | | HashSet<String> set = new HashSet<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1110> api1110List = castList(data, Api1110.class); |
|---|
| | | for (Api1110 apiData : api1110List) { |
|---|
| | | // 因为廒间是根据货位截取，所以要判断廒间是否重复 |
|---|
| | | if (!set.add(apiData.getHwdm().substring(0, 28))) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | api1110 = new SH2023Api1110(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1110); |
|---|
| | | api1110.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1110.setAjdm(apiData.getHwdm().substring(0, 28)); |
|---|
| | | api1110.setAjxdwz(apiData.getHwxdwz()); |
|---|
| | | api1110.setAjwzys(apiData.getHwwzys()); |
|---|
| | | list.add(api1110); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1111.equals(inteId)) { |
|---|
| | | SH2023Api1111 api1111; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1111> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1111> api1111List = castList(data, Api1111.class); |
|---|
| | | for (Api1111 apiData : api1111List) { |
|---|
| | | api1111 = new SH2023Api1111(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1111); |
|---|
| | | api1111.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1111); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1112.equals(inteId)) { |
|---|
| | | SH2023Api1112 api1112; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1112> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1112> api1112List = castList(data, Api1112.class); |
|---|
| | | for (Api1112 apiData : api1112List) { |
|---|
| | | api1112 = new SH2023Api1112(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1112); |
|---|
| | | api1112.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1112); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1113.equals(inteId)) { |
|---|
| | | SH2023Api1113 api1113; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1113> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1113> api1113List = castList(data, Api1113.class); |
|---|
| | | for (Api1113 apiData : api1113List) { |
|---|
| | | api1113 = new SH2023Api1113(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1113); |
|---|
| | | api1113.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1113); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1201.equals(inteId)) { |
|---|
| | | SH2023Api1201 api1201; |
|---|
| | | //最后转换为json |
|---|
| | |
|---|
| | | list.add(api1205); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1206.equals(inteId)) { |
|---|
| | | SH2023Api1206 api1206; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1206> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1206> api1206List = castList(data, Api1206.class); |
|---|
| | | for (Api1206 apiData : api1206List) { |
|---|
| | | api1206 = new SH2023Api1206(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1206); |
|---|
| | | api1206.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | List<Api1205> api1205List = api1205Rep.getDataById(apiData.getCkjsdh()); |
|---|
| | | api1206.setPch(api1205List.get(0).getHwdm() + DateFormatUtils.format(api1205List.get(0).getCmsj(), "yyyy")); |
|---|
| | | list.add(api1206); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1208.equals(inteId)) { |
|---|
| | | SH2023Api1208 api1208; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1208> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1208> api1208List = castList(data, Api1208.class); |
|---|
| | | for (Api1208 apiData : api1208List) { |
|---|
| | | api1208 = new SH2023Api1208(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1208); |
|---|
| | | api1208.setZglkdm(api1208.getHwdm().substring(0, 21)); |
|---|
| | | |
|---|
| | | //TODO 来粮代码 |
|---|
| | | |
|---|
| | | api1208.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1208.setPch(apiData.getHwdm() + apiData.getShnd()); |
|---|
| | | list.add(api1208); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1212.equals(inteId)) { |
|---|
| | | SH2023Api1212 api1212; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1212> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1212> api1212List = castList(data, Api1212.class); |
|---|
| | | for (Api1212 apiData : api1212List) { |
|---|
| | | api1212 = new SH2023Api1212(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1212); |
|---|
| | | api1212.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1212); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1301.equals(inteId)) { |
|---|
| | | SH2023Api1301 api1301; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1301> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1301> api1301List = castList(data, Api1301.class); |
|---|
| | | for (Api1301 apiData : api1301List) { |
|---|
| | | api1301 = new SH2023Api1301(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1301); |
|---|
| | | api1301.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1301); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1302.equals(inteId)) { |
|---|
| | | SH2023Api1302 api1302; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1302> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1302> api1302List = castList(data, Api1302.class); |
|---|
| | | for (Api1302 apiData : api1302List) { |
|---|
| | | api1302 = new SH2023Api1302(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1302); |
|---|
| | | api1302.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1302.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJcsj(), "yyyy")); |
|---|
| | | //todo 温湿度检测数据不全 |
|---|
| | | list.add(api1302); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1303.equals(inteId)) { |
|---|
| | | SH2023Api1303 api1303; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1303> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1303> api1303List = castList(data, Api1303.class); |
|---|
| | | for (Api1303 apiData : api1303List) { |
|---|
| | | api1303 = new SH2023Api1303(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1303); |
|---|
| | | api1303.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1303.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJcsj(), "yyyy")); |
|---|
| | | list.add(api1303); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1304.equals(inteId)) { |
|---|
| | | SH2023Api1304 api1304; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1304> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1304> api1304List = castList(data, Api1304.class); |
|---|
| | | for (Api1304 apiData : api1304List) { |
|---|
| | | api1304 = new SH2023Api1304(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1304); |
|---|
| | | api1304.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1304.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJcsj(), "yyyy")); |
|---|
| | | list.add(api1304); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1305.equals(inteId)) { |
|---|
| | | SH2023Api1305 api1305; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1305> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1305> api1305List = castList(data, Api1305.class); |
|---|
| | | for (Api1305 apiData : api1305List) { |
|---|
| | | api1305 = new SH2023Api1305(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1305); |
|---|
| | | api1305.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1305.setAjdm(apiData.getTfzydh().substring(0, 28)); |
|---|
| | | list.add(api1305); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1306.equals(inteId)) { |
|---|
| | | SH2023Api1306 api1306; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1306> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1306> api1306List = castList(data, Api1306.class); |
|---|
| | | for (Api1306 apiData : api1306List) { |
|---|
| | | api1306 = new SH2023Api1306(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1306); |
|---|
| | | api1306.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1306.setPch(apiData.getXzzydh().substring(0, 30) + DateFormatUtils.format(apiData.getXzkssj(), "yyyy")); |
|---|
| | | api1306.setAjdm(apiData.getXzzydh().substring(0, 28)); |
|---|
| | | list.add(api1306); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1307.equals(inteId)) { |
|---|
| | | SH2023Api1307 api1307; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1307> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1307> api1307List = castList(data, Api1307.class); |
|---|
| | | for (Api1307 apiData : api1307List) { |
|---|
| | | api1307 = new SH2023Api1307(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1307); |
|---|
| | | api1307.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1307.setAjdm(apiData.getHwdm().substring(0, 28)); |
|---|
| | | List<Api1109> api1109List = api1109Rep.getDataByFileId(apiData.getFileStorageId()); |
|---|
| | | api1307.setTxbh(api1109List.get(0).getWjmc()); |
|---|
| | | list.add(api1307); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1310.equals(inteId)) { |
|---|
| | | SH2023Api1310 api1310; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1310> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1310> api1310List = castList(data, Api1310.class); |
|---|
| | | for (Api1310 apiData : api1310List) { |
|---|
| | | api1310 = new SH2023Api1310(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1310); |
|---|
| | | api1310.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1310.setJyrq(apiData.getJysj()); |
|---|
| | | api1310.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJysj(), "yyyy")); |
|---|
| | | List<Api1202> api1202List = api1202Rep.getDataByHwdm(apiData.getHwdm()); |
|---|
| | | api1310.setLspzdm(api1202List.get(0).getLspzdm()); |
|---|
| | | list.add(api1310); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else if (SH2023Constant.SH_2023_API_CODE_1401.equals(inteId)) { |
|---|
| | | SH2023Api1401 api1401; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1401> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1401> api1401List = castList(data, Api1401.class); |
|---|
| | | for (Api1401 apiData : api1401List) { |
|---|
| | | api1401 = new SH2023Api1401(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1401); |
|---|
| | | api1401.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1401); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | }else if (SH2023Constant.SH_2023_API_CODE_1401.equals(inteId)) { |
|---|
| | | SH2023Api1401 api1401; |
|---|
| | | //最后转换为json |
|---|
| | | List<SH2023Api1401> list = new ArrayList<>(); |
|---|
| | | //把data转化成list集合 |
|---|
| | | List<Api1401> api1401List = castList(data, Api1401.class); |
|---|
| | | for (Api1401 apiData : api1401List) { |
|---|
| | | api1401 = new SH2023Api1401(); |
|---|
| | | BeanUtils.copyProperties(apiData, api1401); |
|---|
| | | api1401.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | list.add(api1401); |
|---|
| | | } |
|---|
| | | return JSON.toJSONString(list); |
|---|
| | | } else { |
|---|
| | | return JSON.toJSONString(data); |
|---|
| | | } |
|---|
