| | |
| | | |
| | | import com.jcdm.main.bs.orderScheduling.domain.BsOrderScheduling; |
| | | import com.jcdm.main.bs.orderScheduling.service.IBsOrderSchedulingService; |
| | | import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService; |
| | | import com.jcdm.main.da.passingStationCollection.service.impl.DaPassingStationCollectionServiceImpl; |
| | | import com.jcdm.main.webservice.service.ReceivingServices; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Component; |
| | |
| | | @Component("ryTask") |
| | | public class RyTask |
| | | { |
| | | @Autowired |
| | | private DaPassingStationCollectionServiceImpl passingStationCollectionServiceImpl; |
| | | @Autowired |
| | | private IBsOrderSchedulingService bsOrderSchedulingService; |
| | | private static final Logger logger = LoggerFactory.getLogger("sys-user"); |
| | | public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) |
| | | { |
| | |
| | | |
| | | public void ryNoParams() |
| | | { |
| | | System.out.println("执行无参方法"); |
| | | String a=passingStationCollectionServiceImpl.SelectSN("88","OP010"); |
| | | System.out.println("执行过程返回:" + a); |
| | | } |
| | | |
| | | @Autowired |
| | | private IBsOrderSchedulingService bsOrderSchedulingService; |
| | | String url = "http://podqapp.cfmoto.com.cn:50100/XISOAPAdapter/MessageServlet?senderParty=&senderService=BC_MES&receiverParty=&receiverService=&interface=SI_ZPP_CF_BC_001_SYN_OUT&interfaceNamespace=http://cfmoto.com/xi/MES"; |
| | | public void workReportingTasks(){ |
| | | report10(); |
| | |
| | | BsOrderScheduling bsOrderScheduling = new BsOrderScheduling(); |
| | | bsOrderScheduling.setReport10("0"); |
| | | List<BsOrderScheduling> bsOrderSchedulings = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling); |
| | | String status=""; |
| | | String ev_meassage=""; |
| | | for (BsOrderScheduling orderScheduling : bsOrderSchedulings) { |
| | | String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0010")); |
| | | logger.info("{}",xmlResult); |
| | | String status = ReceivingServices.xmlToJSON3(xmlResult); |
| | | if(status.equals("1")){ |
| | | try { |
| | | String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0010")); |
| | | ev_meassage=ReceivingServices.xmlToJSON1(xmlResult); |
| | | status = ReceivingServices.xmlToJSON3(xmlResult); |
| | | } catch (Exception e) { |
| | | status="3"; |
| | | } |
| | | if(status.equals("1")) { |
| | | orderScheduling.setReport10("1"); |
| | | int i = bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); |
| | | System.out.println("更新状态成功"); |
| | | logger.info("{}合箱报工成功",orderScheduling.getOrderNo()); |
| | | }else { |
| | | if(StringUtils.isEmpty(orderScheduling.getSpareField1())){ |
| | | orderScheduling.setSpareField1("1"); |
| | | bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); |
| | | }else{ |
| | | if(Integer.valueOf(orderScheduling.getSpareField1())+1>=3) { |
| | | //累计报工异常超过3次 |
| | | orderScheduling.setReport10("3"); |
| | | orderScheduling.setSpareField1(String.valueOf(Integer.valueOf(orderScheduling.getSpareField1()) + 1)); |
| | | }else { |
| | | orderScheduling.setSpareField1(String.valueOf(Integer.valueOf(orderScheduling.getSpareField1()) + 1)); |
| | | } |
| | | bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); |
| | | } |
| | | if(status.equals("3")) |
| | | logger.info("{}合箱报工因为网络原因,报工失败!",orderScheduling.getOrderNo()); |
| | | else |
| | | logger.info("{}合箱报工失败,原因:{}",orderScheduling.getOrderNo(),ev_meassage); |
| | | } |
| | | } |
| | | } |
| | |
| | | BsOrderScheduling bsOrderScheduling = new BsOrderScheduling(); |
| | | bsOrderScheduling.setReport20("0"); |
| | | List<BsOrderScheduling> bsOrderSchedulings = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling); |
| | | String status=""; |
| | | String ev_meassage=""; |
| | | for (BsOrderScheduling orderScheduling : bsOrderSchedulings) { |
| | | String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0790")); |
| | | logger.info("{}",xmlResult); |
| | | String status = ReceivingServices.xmlToJSON3(xmlResult); |
| | | try { |
| | | String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0020")); |
| | | ev_meassage=ReceivingServices.xmlToJSON1(xmlResult); |
| | | status = ReceivingServices.xmlToJSON3(xmlResult); |
| | | } catch (Exception e) { |
| | | status="3"; |
| | | } |
| | | if(status.equals("1")){ |
| | | orderScheduling.setReport20("1"); |
| | | int i = bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); |
| | | System.out.println("更新状态成功"); |
| | | logger.info("{}总装报工成功",orderScheduling.getOrderNo()); |
| | | }else { |
| | | if(StringUtils.isEmpty(orderScheduling.getSpareField2())){ |
| | | orderScheduling.setSpareField2("1"); |
| | | bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); |
| | | }else{ |
| | | if(Integer.valueOf(orderScheduling.getSpareField2())+1>=3) { |
| | | //累计报工异常超过3次 |
| | | orderScheduling.setReport20("3"); |
| | | orderScheduling.setSpareField2(String.valueOf(Integer.valueOf(orderScheduling.getSpareField2()) + 1)); |
| | | }else{ |
| | | orderScheduling.setSpareField2(String.valueOf(Integer.valueOf(orderScheduling.getSpareField2()) + 1)); |
| | | } |
| | | bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); |
| | | if(status.equals("3")) |
| | | logger.info("{}总装报工因为网络原因,报工失败!",orderScheduling.getOrderNo()); |
| | | else |
| | | logger.info("{}总装报工失败,原因:{}",orderScheduling.getOrderNo(),ev_meassage); |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | " </urn:ZPP_BC_001>\n" + |
| | | " </soapenv:Body>\n" + |
| | | "</soapenv:Envelope>"; |
| | | |
| | | //logger.info("{}",content); |
| | | return content; |
| | | } |
| | | } |