package com.jcdm.quartz.task;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.jcdm.main.bs.beatSetting.domain.BsBeatSetting;
|
import com.jcdm.main.bs.beatSetting.domain.ProductNumTable;
|
import com.jcdm.main.bs.beatSetting.service.IBsBeatSettingService;
|
import com.jcdm.main.bs.beatSetting.service.ProductNumTableService;
|
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.om.productionOrde.domain.OmProductionOrdeInfo;
|
import com.jcdm.main.om.productionOrde.service.impl.OmProductionOrdeInfoServiceImpl;
|
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 javax.annotation.Resource;
|
import java.time.Duration;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.temporal.ChronoUnit;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 定时任务调度测试
|
*
|
* @author jc
|
*/
|
@Component("ryTask")
|
public class RyTask
|
{
|
@Autowired
|
private DaPassingStationCollectionServiceImpl passingStationCollectionServiceImpl;
|
@Autowired
|
private IBsOrderSchedulingService bsOrderSchedulingService;
|
|
@Resource
|
private OmProductionOrdeInfoServiceImpl omProductionOrdeInfoService;
|
|
@Resource
|
private IBsBeatSettingService bsBeatSettingService;
|
|
@Resource
|
private ProductNumTableService productNumTableService;
|
|
|
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()
|
{
|
logger.info("执行定时任务开始");
|
String a=passingStationCollectionServiceImpl.SelectSN("88","OP010");
|
BsOrderScheduling bsOrderScheduling = new BsOrderScheduling();
|
bsOrderScheduling.setRemarks("1");
|
List<BsOrderScheduling> bsOrderSchedulingList = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling);
|
if (CollUtil.isNotEmpty(bsOrderSchedulingList)){
|
Map<String, List<BsOrderScheduling>> map = bsOrderSchedulingList.stream().collect(Collectors.groupingBy(BsOrderScheduling::getOrderNo));
|
OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
|
for (String s : map.keySet()) {
|
List<BsOrderScheduling> bsOrderSchedulings = map.get(s);
|
if (CollUtil.isNotEmpty(bsOrderSchedulings)){
|
BsOrderScheduling scheduling = bsOrderSchedulings.get(0);
|
int size = bsOrderSchedulings.size();
|
omProductionOrdeInfo.setPlanQty((long)size);
|
omProductionOrdeInfo.setActualQty((long)0);
|
omProductionOrdeInfo.setWorkOrderNo(s);
|
omProductionOrdeInfo.setProductCode(scheduling.getModel());
|
omProductionOrdeInfo.setOrderStatus("2");
|
omProductionOrdeInfo.setTypeZ(scheduling.getModel());
|
omProductionOrdeInfoService.insertOmProductionOrdeInfo(omProductionOrdeInfo);
|
logger.info("插入工单，{}",s);
|
}
|
}
|
for (BsOrderScheduling scheduling : bsOrderSchedulingList) {
|
scheduling.setRemarks("0");
|
scheduling.setProductionStatus("1");
|
bsOrderSchedulingService.updateBsOrderScheduling(scheduling);
|
}
|
|
}
|
System.out.println("执行过程返回：" + a);
|
logger.info("定时任务执行结束");
|
}
|
|
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();
|
updateProductNum();
|
}
|
|
public void report10(){
|
BsOrderScheduling bsOrderScheduling = new BsOrderScheduling();
|
bsOrderScheduling.setReport10("0");
|
List<BsOrderScheduling> bsOrderSchedulings = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling);
|
String status="";
|
String ev_meassage="";
|
if (CollUtil.isNotEmpty(bsOrderSchedulings)){
|
BsOrderScheduling orderScheduling = bsOrderSchedulings.get(0);
|
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);
|
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);
|
}
|
}
|
}
|
|
public void report20(){
|
BsOrderScheduling bsOrderScheduling = new BsOrderScheduling();
|
bsOrderScheduling.setReport20("0");
|
List<BsOrderScheduling> bsOrderSchedulings = bsOrderSchedulingService.selectBsOrderSchedulingList(bsOrderScheduling);
|
String status="";
|
String ev_meassage="";
|
if (CollUtil.isNotEmpty(bsOrderSchedulings)){
|
BsOrderScheduling orderScheduling = bsOrderSchedulings.get(0);
|
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);
|
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);
|
}
|
}
|
}
|
}
|
|
public void updateProductNum(){
|
LocalDate now = LocalDate.now();
|
ProductNumTable productNumTableQuery = new ProductNumTable();
|
productNumTableQuery.setProductTime(now);
|
//已存在的统计数据
|
List<ProductNumTable> productNumTableList = productNumTableService.selectProductList(productNumTableQuery);
|
String actModel;
|
//获取当天所有生产数据
|
List<BsOrderScheduling> bsOrderSchedulingList = bsOrderSchedulingService.selectBsOrderSchedulingListForNum();
|
if (CollUtil.isNotEmpty(bsOrderSchedulingList)){
|
List<BsOrderScheduling> tempList = bsOrderSchedulingList.stream()
|
.filter(x -> ObjectUtil.isNotNull(x.getFinalAssemblyOfflineTime()))
|
.collect(Collectors.toList());
|
List<BsOrderScheduling> collect2 = tempList.stream()
|
.sorted(Comparator.comparing(BsOrderScheduling::getFinalAssemblyOfflineTime).reversed())
|
.collect(Collectors.toList());
|
if (CollUtil.isNotEmpty(collect2)){
|
BsOrderScheduling bsOrderScheduling = collect2.get(0);
|
actModel = bsOrderScheduling.getModel();
|
} else {
|
actModel = null;
|
}
|
List<String> modelList = tempList.stream().map(BsOrderScheduling::getModel).distinct().collect(Collectors.toList());
|
Integer modelNum = 0;
|
if (CollUtil.isNotEmpty(modelList)){
|
modelNum = modelList.size();
|
}
|
Integer productNumTheory = caculateProductNumTheory(actModel, now, modelNum);
|
List<ProductNumTable> saveDate = new ArrayList<>();
|
Map<String, List<BsOrderScheduling>> collect = bsOrderSchedulingList.stream().collect(Collectors.groupingBy(BsOrderScheduling::getModel));
|
for (String s : collect.keySet()) {
|
|
List<BsOrderScheduling> bsOrderSchedulingList1 = collect.get(s);
|
//合箱上线
|
long count1 = bsOrderSchedulingList1.stream().filter(x -> ObjectUtil.isNotNull(x.getBoxClosingOnlineTime())).count();
|
//总装上线
|
long count2 = bsOrderSchedulingList1.stream().filter(x -> ObjectUtil.isNotNull(x.getFinalAssemblyLaunchTime())).count();
|
//总装下线
|
long count3 = bsOrderSchedulingList1.stream().filter(x -> ObjectUtil.isNotNull(x.getFinalAssemblyOfflineTime())).count();
|
//检查判断是更新还是插入
|
List<ProductNumTable> collect1 = productNumTableList.stream().filter(x -> s.equals(x.getModel())).collect(Collectors.toList());
|
if (CollUtil.isEmpty(collect1)){
|
//插入
|
ProductNumTable productNumTable = new ProductNumTable();
|
UUID uuid = UUID.randomUUID();
|
productNumTable.setId(uuid.getMostSignificantBits());
|
productNumTable.setModel(s);
|
productNumTable.setHxOnlineNum((int) count1);
|
productNumTable.setZzOnlineNum((int) count2);
|
productNumTable.setZzOfflineNum((int) count3);
|
productNumTable.setProductTime(now);
|
productNumTable.setProductNumTheory(productNumTheory);
|
saveDate.add(productNumTable);
|
} else {
|
//更新
|
//判断是否需要更新
|
ProductNumTable productNumTable = collect1.get(0);
|
Integer hxOnlineNum = productNumTable.getHxOnlineNum();
|
Integer zzOnlineNum = productNumTable.getZzOnlineNum();
|
Integer zzOfflineNum = productNumTable.getZzOfflineNum();
|
if (!hxOnlineNum.equals((int)count1) || !zzOnlineNum.equals((int) count2) || !zzOfflineNum.equals((int)count3)){
|
//更新
|
productNumTable.setHxOnlineNum((int) count1);
|
productNumTable.setZzOnlineNum((int) count2);
|
productNumTable.setZzOfflineNum((int) count3);
|
productNumTable.setProductNumTheory(productNumTheory);
|
productNumTableService.updateProductNum(productNumTable);
|
}
|
}
|
}
|
if (CollUtil.isNotEmpty(saveDate)){
|
productNumTableService.insertProductList(saveDate);
|
}
|
}
|
|
|
|
}
|
|
private Integer caculateProductNumTheory(String actModel, LocalDate now,Integer modelNum) {
|
long l = System.currentTimeMillis();
|
System.out.println("开始：----"+l);
|
//计算总产量数据
|
String beat = "";
|
List<BsBeatSetting> bsBeatSettings = bsBeatSettingService.selectBsBeatSettingList(new BsBeatSetting());
|
if (ObjectUtil.isNotNull(actModel)){
|
List<BsBeatSetting> collect = bsBeatSettings.stream().filter(x -> actModel.contains(x.getProductCode())).collect(Collectors.toList());
|
if (CollUtil.isNotEmpty(collect)){
|
BsBeatSetting bsBeatSetting = collect.get(0);
|
beat = bsBeatSetting.getBeat();
|
}
|
}
|
|
LocalDateTime nowTime = LocalDateTime.now();
|
long workTime = 0;
|
LocalDateTime time1 = now.atTime(0, 0, 0);
|
LocalDateTime time_rest = now.atTime(0, 30, 0);
|
LocalDateTime time2 = now.atTime(3, 0, 0);
|
LocalDateTime time3 = now.atTime(3, 10, 0);
|
LocalDateTime time4 = now.atTime(5, 0, 0);
|
LocalDateTime time5 = now.atTime(5, 10, 0);
|
LocalDateTime time6 = now.atTime(7, 0, 0);
|
LocalDateTime time7 = now.atTime(8, 0, 0);
|
LocalDateTime time8 = now.atTime(10, 0, 0);
|
LocalDateTime time9 = now.atTime(10, 10, 0);
|
LocalDateTime time10 = now.atTime(11, 10, 0);
|
LocalDateTime time11 = now.atTime(12, 10, 0);
|
LocalDateTime time12 = now.atTime(15, 0, 0);
|
LocalDateTime time13 = now.atTime(15, 10, 0);
|
LocalDateTime time14 = now.atTime(20, 0, 0);
|
LocalDateTime time15 = now.atTime(20, 10, 0);
|
LocalDateTime time16 = now.atTime(22, 0, 0);
|
LocalDateTime time17 = now.atTime(22, 10, 0);
|
LocalDateTime time18 = now.atTime(23, 59, 59);
|
if (nowTime.isBefore(time_rest)){
|
//0-0.30
|
workTime = 0;
|
} else if (nowTime.isBefore(time2)){
|
//0-3
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 1800;
|
} else if (nowTime.isBefore(time3)){
|
//0-3.10
|
workTime = ChronoUnit.SECONDS.between(time1,time2) - 1800;
|
} else if (nowTime.isBefore(time4)){
|
//0-5
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 2400;
|
} else if (nowTime.isBefore(time5)){
|
//0-5.10
|
workTime = ChronoUnit.SECONDS.between(time1,time4) - 2400;
|
} else if (nowTime.isBefore(time6)){
|
//0-7
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 3000;
|
} else if (nowTime.isBefore(time7)){
|
//0-8
|
workTime = ChronoUnit.SECONDS.between(time1,time6) - 3000;
|
} else if (nowTime.isBefore(time8)){
|
//0-10
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 6600;
|
} else if (nowTime.isBefore(time9)){
|
//0-10.10
|
workTime = ChronoUnit.SECONDS.between(time1,time8) - 6600;
|
} else if (nowTime.isBefore(time10)){
|
//0-11.10
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 7200;
|
} else if (nowTime.isBefore(time11)){
|
//0-12.10
|
workTime = ChronoUnit.SECONDS.between(time1,time10) - 7200;
|
} else if (nowTime.isBefore(time12)){
|
//0-15
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 7200 - 3600;
|
} else if (nowTime.isBefore(time13)){
|
//0-15.10
|
workTime = ChronoUnit.SECONDS.between(time1,time12) - 7200 - 3600;
|
} else if (nowTime.isBefore(time14)){
|
//0-20
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 7200 - 3600 - 600;
|
} else if (nowTime.isBefore(time15)){
|
//0-20.10
|
workTime = ChronoUnit.SECONDS.between(time1,time14) - 7200 - 3600 - 600;
|
} else if (nowTime.isBefore(time16)){
|
//0-22
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 7200 - 3600 - 600 - 600;
|
} else if (nowTime.isBefore(time17)){
|
//0-22.10
|
workTime = ChronoUnit.SECONDS.between(time1,time16) - 7200 - 3600 - 600 - 600;
|
} else if (nowTime.isBefore(time18)){
|
//0-24
|
workTime = ChronoUnit.SECONDS.between(time1,nowTime) - 7200 - 3600 - 600 - 600 - 600;
|
}
|
if (modelNum > 1){
|
workTime = workTime - 1800L *(modelNum-1);
|
if (workTime <0){
|
workTime = 0;
|
}
|
}
|
System.out.println(workTime+"---------");
|
long l2 = System.currentTimeMillis();
|
System.out.println("结束：----"+l2);
|
long l1 = l2 - l;
|
System.out.println("耗费时间：----"+l1);
|
//理论产量
|
Integer productNumTheory = 0;
|
if (StrUtil.isNotBlank(beat)){
|
int i = Integer.parseInt(beat);
|
Integer workTimeInt = (int) workTime;
|
productNumTheory = Math.floorDiv(workTimeInt, i);
|
}
|
return productNumTheory;
|
}
|
|
public static String getProductionPlanInformationXml(String orderNo,String location){
|
String content = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:urn=\"urn:sap-com:document:sap:rfc:functions\">\n" +
|
" <soapenv:Header/>\n" +
|
" <soapenv:Body>\n" +
|
" <urn:ZPP_BC_001>\n" +
|
" <IV_AUFNR>"+orderNo+"</IV_AUFNR>\n" +
|
" <IV_VORNR>"+location+"</IV_VORNR>\n" +
|
" <IV_LMNGA>1</IV_LMNGA>\n" +
|
" <IV_XMNGA>0</IV_XMNGA> \n" +
|
" <IV_STATU>1</IV_STATU> \n" +
|
" </urn:ZPP_BC_001>\n" +
|
" </soapenv:Body>\n" +
|
"</soapenv:Envelope>";
|
//logger.info("{}",content);
|
return content;
|
}
|
}
|
