package com.jcdm.quartz.task; 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; import com.jcdm.common.utils.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.List; /** * 定时任务调度测试 * * @author jc */ @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) { System.out.println(StringUtils.format("执行多参方法: 字符串类型{},布尔类型{},长整型{},浮点型{},整形{}", s, b, l, d, i)); } public void ryParams(String params) { System.out.println("执行有参方法:" + params); } public void ryNoParams() { String a=passingStationCollectionServiceImpl.SelectSN("88","OP010"); System.out.println("执行过程返回:" + a); } 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(); report20(); } public void report10(){ BsOrderScheduling bsOrderScheduling = new BsOrderScheduling(); bsOrderScheduling.setReport10("0"); List bsOrderSchedulings = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling); for (BsOrderScheduling orderScheduling : bsOrderSchedulings) { String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0010")); String status = ReceivingServices.xmlToJSON3(xmlResult); if(status.equals("1")){ orderScheduling.setReport10("1"); int i = bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); System.out.println("更新状态成功"); //logger.info("{}合箱报工成功",orderScheduling.getOrderNo()); } } } public void report20(){ BsOrderScheduling bsOrderScheduling = new BsOrderScheduling(); bsOrderScheduling.setReport20("0"); List bsOrderSchedulings = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling); for (BsOrderScheduling orderScheduling : bsOrderSchedulings) { String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0020")); String status = ReceivingServices.xmlToJSON3(xmlResult); if(status.equals("1")){ orderScheduling.setReport20("1"); int i = bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling); System.out.println("更新状态成功"); //logger.info("{}总装报工成功",orderScheduling.getOrderNo()); } } } public static String getProductionPlanInformationXml(String orderNo,String location){ String content = "\n" + " \n" + " \n" + " \n" + " "+orderNo+"\n" + " "+location+"\n" + " 1\n" + " 0 \n" + " 1 \n" + " \n" + " \n" + ""; //logger.info("{}",content); return content; } }