| | |
|---|
| | | package com.jcdm.main.restful.qingYan.service; |
|---|
| | | |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | | import cn.hutool.core.util.StrUtil; |
|---|
| | | import cn.hutool.http.HttpRequest; |
|---|
| | | import cn.hutool.http.HttpResponse; |
|---|
| | | import cn.hutool.json.JSONUtil; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.fasterxml.jackson.core.JsonProcessingException; |
|---|
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
|---|
| | | import com.google.gson.JsonObject; |
|---|
| | | import com.jcdm.common.annotation.Log; |
|---|
| | | import com.jcdm.common.enums.BusinessType; |
|---|
| | | import com.jcdm.common.utils.poi.ExcelUtil; |
|---|
| | | import com.jcdm.common.core.domain.AjaxResult; |
|---|
| | | import com.jcdm.main.constant.Constants; |
|---|
| | | import com.jcdm.main.da.paramCollection.domain.DaParamCollection; |
|---|
| | | import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService; |
|---|
| | | import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection; |
|---|
| | | import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService; |
|---|
| | | import com.jcdm.main.da.testDeviceInterface.domain.DaTestDeviceInterface; |
|---|
| | | import com.jcdm.main.da.testDeviceInterface.service.IDaTestDeviceInterfaceService; |
|---|
| | | import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo; |
|---|
| | | import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService; |
|---|
| | | import com.jcdm.main.restful.qingYan.doman.ChildVO; |
|---|
| | | import com.jcdm.main.restful.qingYan.doman.ParentVO; |
|---|
| | | import com.jcdm.main.restful.qingYan.doman.PostEntity; |
|---|
| | | import com.jcdm.main.rm.repairData.domain.RmRepairData; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.security.access.prepost.PreAuthorize; |
|---|
| | | import org.springframework.web.bind.annotation.PostMapping; |
|---|
| | | import org.springframework.web.bind.annotation.RequestBody; |
|---|
| | | import org.springframework.web.bind.annotation.RequestMapping; |
|---|
| | | import org.springframework.web.bind.annotation.RestController; |
|---|
| | | |
|---|
| | | import javax.servlet.http.HttpServletResponse; |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.lang.reflect.Field; |
|---|
| | | import java.text.ParseException; |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | @RestController |
|---|
| | | @RequestMapping("/jcdmMes") |
|---|
| | | public class ExternalInterface { |
|---|
| | | @Autowired |
|---|
| | | private IDaTestDeviceInterfaceService daTestDeviceInterfaceService; |
|---|
| | | @Autowired |
|---|
| | | private IDaParamCollectionService daParamCollectionService; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private IDaPassingStationCollectionService daPassingStationCollectionService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IOmProductionOrdeInfoService productionOrdeInfoService; |
|---|
| | | |
|---|
| | | String url = "https://imes-uat-group.geelycv-test.com/api/mom-open/restful/aMesSysIntegration/deviceResultFeedback"; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 导出点检任务列表 |
|---|
| | | */ |
|---|
| | | @PostMapping("/deviceResultFeedback") |
|---|
| | | public AjaxResult hdy(@RequestBody ParentVO parentVO) |
|---|
| | | { |
|---|
| | | //保存 |
|---|
| | | //过站记录 |
|---|
| | | // String productNum = parentVO.getProductNum(); |
|---|
| | | // if (StrUtil.isNotBlank(productNum)){ |
|---|
| | | // List<OmProductionOrdeInfo> list = productionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, productNum)); |
|---|
| | | // if (CollUtil.isNotEmpty(list)){ |
|---|
| | | // OmProductionOrdeInfo omProductionOrdeInfo = list.get(0); |
|---|
| | | // DaPassingStationCollection passingStationCollection = new DaPassingStationCollection(); |
|---|
| | | // passingStationCollection.setWorkOrderNo(omProductionOrdeInfo.getWorkOrderNo()); |
|---|
| | | // passingStationCollection.setSfcCode(productNum); |
|---|
| | | // passingStationCollection.setProductCode(omProductionOrdeInfo.getProductCode()); |
|---|
| | | // passingStationCollection.setLocationCode(parentVO.getStationCode()); |
|---|
| | | // passingStationCollection.setOutRsSign(parentVO.getTotalResult()); |
|---|
| | | // passingStationCollection.setCreateTime(new Date()); |
|---|
| | | // |
|---|
| | | // List<ChildVO> checkList = parentVO.getCheckList(); |
|---|
| | | // if (CollUtil.isNotEmpty(checkList)){ |
|---|
| | | // List<String> collect = checkList.stream() |
|---|
| | | // .filter(x -> Constants.IN_BOUND_TIME_CODE.equals(x.getItemCode())) |
|---|
| | | // .map(ChildVO::getItemValue) |
|---|
| | | // .collect(Collectors.toList()); |
|---|
| | | // if (CollUtil.isNotEmpty(collect)){ |
|---|
| | | // String s = collect.get(0); |
|---|
| | | // if (StrUtil.isNotBlank(s)){ |
|---|
| | | // SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
|---|
| | | // try { |
|---|
| | | // Date parse = simpleDateFormat.parse(s); |
|---|
| | | // passingStationCollection.setInboundTime(parse); |
|---|
| | | // } catch (ParseException e) { |
|---|
| | | // throw new RuntimeException(e); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // List<String> collect2 = checkList.stream() |
|---|
| | | // .filter(x -> Constants.OUT_BOUND_TIME_CODE.equals(x.getItemCode())) |
|---|
| | | // .map(ChildVO::getItemValue) |
|---|
| | | // .collect(Collectors.toList()); |
|---|
| | | // if (CollUtil.isNotEmpty(collect2)){ |
|---|
| | | // String s = collect2.get(0); |
|---|
| | | // if (StrUtil.isNotBlank(s)){ |
|---|
| | | // SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
|---|
| | | // try { |
|---|
| | | // Date parse = simpleDateFormat.parse(s); |
|---|
| | | // passingStationCollection.setOutboundTime(parse); |
|---|
| | | // } catch (ParseException e) { |
|---|
| | | // throw new RuntimeException(e); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // daPassingStationCollectionService.save(passingStationCollection); |
|---|
| | | // //参数保存 |
|---|
| | | // List<DaParamCollection> paramCollectionList = new ArrayList<>(); |
|---|
| | | // for (ChildVO childVO : checkList) { |
|---|
| | | // DaParamCollection daParamCollection = new DaParamCollection(); |
|---|
| | | // daParamCollection.setWorkOrderNo(omProductionOrdeInfo.getWorkOrderNo()); |
|---|
| | | // daParamCollection.setSfcCode(productNum); |
|---|
| | | // daParamCollection.setProductCode(omProductionOrdeInfo.getProductCode()); |
|---|
| | | // daParamCollection.setLocationCode(omProductionOrdeInfo.getStationCode()); |
|---|
| | | // daParamCollection.setParamCode(childVO.getItemCode()); |
|---|
| | | // daParamCollection.setParamValue(childVO.getItemValue()); |
|---|
| | | // daParamCollection.setCollectionTime(new Date()); |
|---|
| | | // daParamCollection.setParamName(childVO.getItemText()); |
|---|
| | | // paramCollectionList.add(daParamCollection); |
|---|
| | | // } |
|---|
| | | // if (CollUtil.isNotEmpty(paramCollectionList)){ |
|---|
| | | // daParamCollectionService.insertBatch(paramCollectionList); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | ObjectMapper mapper = new ObjectMapper(); |
|---|
| | | List<ChildVO> li = parentVO.getCheckList(); |
|---|
| | | String s = null; |
|---|
| | | try { |
|---|
| | | s = mapper.writeValueAsString(li); |
|---|
| | | } catch (JsonProcessingException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
| | | DaTestDeviceInterface daTestDeviceInterface = new DaTestDeviceInterface(); |
|---|
| | | daTestDeviceInterface.setRecordId(parentVO.getRecordId()); |
|---|
| | | daTestDeviceInterface.setStationCode(parentVO.getStationCode()); |
|---|
| | | daTestDeviceInterface.setProductNum(parentVO.getProductNum()); |
|---|
| | | daTestDeviceInterface.setTotalResult(parentVO.getTotalResult()); |
|---|
| | | daTestDeviceInterface.setCheckList(s); |
|---|
| | | daTestDeviceInterfaceService.save(daTestDeviceInterface); |
|---|
| | | HttpResponse execute = HttpRequest.post(url).body(JSONUtil.toJsonStr(parentVO)).execute(); |
|---|
| | | return AjaxResult.success(execute.body()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | @PostMapping("/pushParamData") |
|---|
| | | public void receivingData(@RequestBody PostEntity postEntity) throws JsonProcessingException { |
|---|
