| | |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | | import com.jcdm.common.core.domain.AjaxResult; |
| | | import com.jcdm.common.utils.StringUtils; |
| | | import com.jcdm.framework.websocket.WebSocketUsers; |
| | | import com.jcdm.main.bs.formulaChild.domain.BsFormulaChildInfo; |
| | | import com.jcdm.main.bs.formulaChild.service.IBsFormulaChildInfoService; |
| | | import com.jcdm.main.constant.Constants; |
| | |
| | | import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo; |
| | | import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService; |
| | | import com.jcdm.main.restful.qingYan.doman.*; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.aspectj.weaver.loadtime.Aj; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.websocket.Session; |
| | | import java.lang.reflect.Field; |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | | import java.util.concurrent.CompletableFuture; |
| | | import java.util.stream.Collectors; |
| | | |
| | | @Slf4j |
| | | @RestController |
| | | @RequestMapping("/jcdmMes") |
| | | public class ExternalInterface { |
| | | Map<String, Session> map = WebSocketUsers.getUsers(); |
| | | |
| | | private static final Logger logger = LoggerFactory.getLogger("sys-user"); |
| | | |
| | | public SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | |
| | | @Autowired |
| | |
| | | if(StringUtils.isNotBlank(parentVO.getProductNum())){ |
| | | OmProductionOrdeInfo one = omProductionOrdeInfoService.getOne(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, parentVO.getProductNum())); |
| | | if(ObjectUtil.isNotNull(one)){ |
| | | logger.info("解绑小车{},pack码是{}"+one.getTrolleyYard(),one.getProductNum()); |
| | | one.setTrolleyYard(""); |
| | | omProductionOrdeInfoService.saveOrUpdate(one); |
| | | } |
| | | } |
| | | } |
| | | // try{ |
| | | // CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> { |
| | | // logger.info("开始执行异步方法"); |
| | | // HttpResponse execute = HttpRequest.post(url).body(JSONUtil.toJsonStr(parentVO)).execute(); |
| | | // logger.info("异步方法执行结束"); |
| | | // logger.info("接收清研,气密异步方法{}"+execute.body()); |
| | | // }); |
| | | // }catch (Exception e){ |
| | | // System.out.println(e.getMessage()); |
| | | // } |
| | | HttpResponse execute = HttpRequest.post(url).body(JSONUtil.toJsonStr(parentVO)).execute(); |
| | | return AjaxResult.success(execute.body()); |
| | | } |
| | |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 放行请空状态 |
| | | */ |
| | | @PostMapping("/sendWebSocket") |
| | | public void sendWebSocket(@RequestBody BsFormulaChildInfo bsFormulaChildInfo) |
| | | { |
| | | WebSocketUsers.sendMessageToUserByText(map.get(bsFormulaChildInfo.getLocationCode()), bsFormulaChildInfo.getResults()); |
| | | } |
| | | |
| | | /** |
| | | * 使用反射获取对象的属性值 |