Yangwl
/
LanJu_Mes
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

逻辑删除+手持增加缓冲区接口+工艺车数

Browse Source
highway
zhaoxiaolin 1 year ago
parent d0c62cb2df
commit d394d2a1df
9 changed files with 121 additions and 165 deletions
Show Stats Download Patch File Download Diff File

63
op-api/op-api-system/src/main/java/com/op/system/api/domain/dto/WCSDataDTO.java
Unescape Escape View File

@ -5,13 +5,22 @@ import java.util.List;
public class WCSDataDTO {
private String sku;
// private String sku;
//
// private String loadNo;
//
// private List<WCSDataItemsDTO> unLoadItems;
private String loadNo;
private String stationNo;
private int qty;
private List<WCSDataItemsDTO> unLoadItems;
public int getQty() {
return qty;
}
private String stationNo;
public void setQty(int qty) {
this.qty = qty;
}
public String getStationNo() {
return stationNo;
@ -21,27 +30,27 @@ public class WCSDataDTO {
this.stationNo = stationNo;
}
public String getSku() {
return sku;
}
public void setSku(String sku) {
this.sku = sku;
}
public String getLoadNo() {
return loadNo;
}
public void setLoadNo(String loadNo) {
this.loadNo = loadNo;
}
public List<WCSDataItemsDTO> getUnLoadItems() {
return unLoadItems;
}
public void setUnLoadItems(List<WCSDataItemsDTO> unLoadItems) {
this.unLoadItems = unLoadItems;
}
// public String getSku() {
// return sku;
// }
//
// public void setSku(String sku) {
// this.sku = sku;
// }
//
// public String getLoadNo() {
// return loadNo;
// }
//
// public void setLoadNo(String loadNo) {
// this.loadNo = loadNo;
// }
//
// public List<WCSDataItemsDTO> getUnLoadItems() {
// return unLoadItems;
// }
//
// public void setUnLoadItems(List<WCSDataItemsDTO> unLoadItems) {
// this.unLoadItems = unLoadItems;
// }
}

2
op-modules/op-mes/src/main/java/com/op/mes/mapper/ProRfidProcessDetailMapper.java
Unescape Escape View File

@ -66,4 +66,6 @@ public interface ProRfidProcessDetailMapper {
public String getStationType(String equipmentCode);
String getActuaEquips(ProRfidProcessDetail rfidInfo);
Integer getEquipNum(String machineCode);
}

84
op-modules/op-mes/src/main/java/com/op/mes/service/impl/IWCInterfaceServiceImpl.java
Unescape Escape View File

@ -79,49 +79,59 @@ public class IWCInterfaceServiceImpl implements IWCSInterfaceService {
*/
@Override
public WCSDTO requestDestinationStations(WCSDTO wcsdto) {
DynamicDataSourceContextHolder.push("ds_"+wcsdto.getFactory());
DynamicDataSourceContextHolder.push("ds_" + wcsdto.getFactory());
WCSDTO dto = new WCSDTO();//最终结果
BeanUtils.copyBeanProp(dto,wcsdto);
//根据rfid跟工单绑定，成型机跟工单绑定，获取对应工艺。
ProRfidProcessDetail rfidInfo = proRfidProcessDetailMapper.getRfidInfo(wcsdto.getRfidNo());
//获取设备类型
if(rfidInfo!=null && StringUtils.isNotBlank(rfidInfo.getMachineCode())){
//设备-工艺路线的设备大范围
String[] machineCodes0 = rfidInfo.getMachineCode().split(",");
String stationType = proRfidProcessDetailMapper.getStationType(machineCodes0[0]);
if(StringUtils.isNotBlank(stationType)){
dto.setStationType(stationType);
}
//设备-根据工单获取实际规划设备路线
String machinecode = rfidInfo.getProdLineCode();//proRfidProcessDetailMapper.getActuaEquips(rfidInfo);
JSONArray codeArray = JSONArray.parseArray(machinecode);
List<String> list2 = new ArrayList<>();
for(int c1=0;c1<codeArray.size();c1++){
String equipCode0 = codeArray.getJSONArray(c1).getString(1);
list2.add(equipCode0);
}
try {
BeanUtils.copyBeanProp(dto, wcsdto);
//根据rfid跟工单绑定，成型机跟工单绑定，获取对应工艺。
ProRfidProcessDetail rfidInfo = proRfidProcessDetailMapper.getRfidInfo(wcsdto.getRfidNo());
//获取设备类型
if (rfidInfo != null && StringUtils.isNotBlank(rfidInfo.getMachineCode())) {
//设备-工艺路线的设备大范围
String[] machineCodes0 = rfidInfo.getMachineCode().split(",");
String stationType = proRfidProcessDetailMapper.getStationType(machineCodes0[0]);
if (StringUtils.isNotBlank(stationType)) {
dto.setStationType(stationType);
}
//设备-根据工单获取实际规划设备路线
String machinecode = rfidInfo.getProdLineCode();//proRfidProcessDetailMapper.getActuaEquips(rfidInfo);
JSONArray codeArray = JSONArray.parseArray(machinecode);
List<String> list2 = new ArrayList<>();
for (int c1 = 0; c1 < codeArray.size(); c1++) {
String equipCode0 = codeArray.getJSONArray(c1).getString(1);
list2.add(equipCode0);
}
//取交集
List<String> list1 = Arrays.asList(machineCodes0);
List<String> machineArray = list1.stream()
.filter(u1-> list2.contains(u1))
.collect(Collectors.toList());
//取交集
List<String> list1 = Arrays.asList(machineCodes0);
List<String> machineArray = list1.stream()
.filter(u1 -> list2.contains(u1))
.collect(Collectors.toList());
dto.setSku(rfidInfo.getProductCode());
dto.setSpec(rfidInfo.getProductModel());
dto.setProductionState(rfidInfo.getNowProcessId());
List<WCSDataDTO> stationNos = new ArrayList<>();
WCSDataDTO wCSDataDTO = null;
for(String machineCode:machineArray){
wCSDataDTO = new WCSDataDTO();
if(StringUtils.isNotBlank(machineCode)){
wCSDataDTO.setStationNo(machineCode);
stationNos.add(wCSDataDTO);
dto.setSku(rfidInfo.getProductCode());
dto.setSpec(rfidInfo.getProductModel());
dto.setProductionState(rfidInfo.getNowProcessId());
List<WCSDataDTO> stationNos = new ArrayList<>();
WCSDataDTO wCSDataDTO = null;
for (String machineCode : machineArray) {
wCSDataDTO = new WCSDataDTO();
if (StringUtils.isNotBlank(machineCode)) {
wCSDataDTO.setStationNo(machineCode);
if ("2".equals(stationType)) {
Integer qty = proRfidProcessDetailMapper.getEquipNum(machineCode);
wCSDataDTO.setQty(qty == null ? 0 : qty);
}
stationNos.add(wCSDataDTO);
}
}
dto.setStationNos(stationNos);
dto.setCode("0");
}
dto.setStationNos(stationNos);
}catch (Exception e){
dto.setCode("1");
dto.setMessage("MES管理系统接口调用失败");
}
return dto;
}
public static void main(String args[]){

96
op-modules/op-mes/src/main/java/com/op/mes/service/impl/MesPrepareValidateServiceImpl.java
Unescape Escape View File

@ -1,96 +0,0 @@
package com.op.mes.service.impl;
import java.util.List;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.op.common.core.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.op.mes.mapper.MesPrepareValidateMapper;
import com.op.mes.domain.MesPrepareValidate;
import com.op.mes.service.IMesPrepareValidateService;
/**
* 生产前准备记录报表Service业务层处理
*
* @author Open Platform
* @date 2023-08-04
*/
@Service
public class MesPrepareValidateServiceImpl implements IMesPrepareValidateService {
@Autowired
private MesPrepareValidateMapper mesPrepareValidateMapper;
/**
* 查询生产前准备记录报表
*
* @param validateId 生产前准备记录报表主键
* @return 生产前准备记录报表
*/
@Override
@DS("#header.poolName")
public MesPrepareValidate selectMesPrepareValidateByValidateId(String validateId) {
return mesPrepareValidateMapper.selectMesPrepareValidateByValidateId(validateId);
}
/**
* 查询生产前准备记录报表列表
*
* @param mesPrepareValidate 生产前准备记录报表
* @return 生产前准备记录报表
*/
@Override
@DS("#header.poolName")
public List<MesPrepareValidate> selectMesPrepareValidateList(MesPrepareValidate mesPrepareValidate) {
return mesPrepareValidateMapper.selectMesPrepareValidateList(mesPrepareValidate);
}
/**
* 新增生产前准备记录报表
*
* @param mesPrepareValidate 生产前准备记录报表
* @return 结果
*/
@Override
@DS("#header.poolName")
public int insertMesPrepareValidate(MesPrepareValidate mesPrepareValidate) {
mesPrepareValidate.setCreateTime(DateUtils.getNowDate());
return mesPrepareValidateMapper.insertMesPrepareValidate(mesPrepareValidate);
}
/**
* 修改生产前准备记录报表
*
* @param mesPrepareValidate 生产前准备记录报表
* @return 结果
*/
@Override
@DS("#header.poolName")
public int updateMesPrepareValidate(MesPrepareValidate mesPrepareValidate) {
mesPrepareValidate.setUpdateTime(DateUtils.getNowDate());
return mesPrepareValidateMapper.updateMesPrepareValidate(mesPrepareValidate);
}
/**
* 批量删除生产前准备记录报表
*
* @param validateIds 需要删除的生产前准备记录报表主键
* @return 结果
*/
@Override
@DS("#header.poolName")
public int deleteMesPrepareValidateByValidateIds(String[] validateIds) {
return mesPrepareValidateMapper.deleteMesPrepareValidateByValidateIds(validateIds);
}
/**
* 删除生产前准备记录报表信息
*
* @param validateId 生产前准备记录报表主键
* @return 结果
*/
@Override
public int deleteMesPrepareValidateByValidateId(String validateId) {
return mesPrepareValidateMapper.deleteMesPrepareValidateByValidateId(validateId);
}
}

5
op-modules/op-mes/src/main/resources/mapper/mes/ProRfidProcessDetailMapper.xml
Unescape Escape View File

@ -92,6 +92,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
from pro_order_workorder
where workorder_code = #{workorderCode}
</select>
<select id="getEquipNum" resultType="java.lang.Integer">
select isvalue from base_equipment_attached
where property = 'dollyNumber'
and device_code = #{machineCode}
</select>
<insert id="insertProRfidProcessDetail" parameterType="ProRfidProcessDetail">
insert into pro_rfid_process_detail

11
op-modules/op-plan/src/main/java/com/op/plan/domain/ProRoute.java
Unescape Escape View File

@ -54,12 +54,21 @@ public class ProRoute extends BaseEntity
private String attr4;
private String fileList;
//每车的bp数
private Integer carNumUnit;
private List<String> idList;
private String routeVersion;
public Integer getCarNumUnit() {
return carNumUnit;
}
public void setCarNumUnit(Integer carNumUnit) {
this.carNumUnit = carNumUnit;
}
public List<String> getIdList() {
return idList;
}

4
op-modules/op-plan/src/main/resources/mapper/plan/ProRouteMapper.xml
Unescape Escape View File

@ -21,11 +21,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<result property="updateTime" column="update_time" />
<result property="routeVersion" column="route_version" />
<result property="needCheck" column="need_check" />
<result property="carNumUnit" column="car_num_unit" />
</resultMap>
<select id="selectRouteByItemCode" resultMap="ProRouteResult">
select pr.route_code,pr.route_name
select pr.route_code,pr.route_name,pr.car_num_unit
from pro_route pr
INNER JOIN pro_route_product prp ON pr.route_id = prp.route_id
where prp.item_code = #{itemCode} and pr.enable_flag = 'Y'

10
op-modules/op-technology/src/main/java/com/op/technology/domain/ProRoute.java
Unescape Escape View File

@ -64,6 +64,8 @@ public class ProRoute extends BaseEntity
/** 其他 */
private String tecOther;
/**每车bp数**/
private Integer carNumUnit;
private String fileList;
private List<BaseFile> files;
@ -72,6 +74,14 @@ public class ProRoute extends BaseEntity
private String routeVersion;
public Integer getCarNumUnit() {
return carNumUnit;
}
public void setCarNumUnit(Integer carNumUnit) {
this.carNumUnit = carNumUnit;
}
public List<String> getIdList() {
return idList;
}

11
op-modules/op-technology/src/main/resources/mapper/technology/ProRouteMapper.xml
Unescape Escape View File

@ -26,12 +26,14 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<result property="tecMachine" column="tec_machine" />
<result property="tecOther" column="tec_other" />
<result property="tecDepreciation" column="tec_depreciation" />
<result property="carNumUnit" column="car_num_unit" />
</resultMap>
<sql id="selectProRouteVo">
select route_id, route_code, route_name, route_desc, enable_flag, remark,
attr1, attr2, attr3, attr4, create_by, create_time, update_by, update_time,
route_version,need_check,tec_man,tec_machine,tec_other,tec_depreciation
route_version,need_check,tec_man,tec_machine,tec_other,tec_depreciation,car_num_unit
from pro_route
</sql>
@ -63,7 +65,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<select id="checkRouteCodeUnique" parameterType="ProRoute" resultMap="ProRouteResult">
select top 1 route_id, route_code, route_name, route_desc,
enable_flag, remark, attr1, attr2, attr3, attr4,
create_by, create_time, update_by, update_time,need_check,tec_man,tec_machine,tec_other,tec_depreciation
create_by, create_time, update_by, update_time,need_check,tec_man,tec_machine,tec_other,tec_depreciation,
car_num_unit
from pro_route
where route_code = #{routeCode}
</select>
@ -98,6 +101,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<if test="tecMachine != null">tec_machine,</if>
<if test="tecOther != null">tec_other,</if>
<if test="tecDepreciation != null">tec_depreciation,</if>
<if test="carNumUnit != null">car_num_unit,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="routeId != null and routeId != ''">#{routeId},</if>
@ -121,6 +126,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<if test="tecMachine != null">#{tecMachine},</if>
<if test="tecOther != null">#{tecOther},</if>
<if test="tecDepreciation != null">#{tecDepreciation},</if>
<if test="carNumUnit != null">#{carNumUnit},</if>
</trim>
</insert>
@ -147,6 +153,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<if test="tecMachine != null">tec_machine = #{tecMachine},</if>
<if test="tecOther != null">tec_other = #{tecOther},</if>
<if test="tecDepreciation != null">tec_depreciation=#{tecDepreciation},</if>
<if test="carNumUnit != null">car_num_unit= #{carNumUnit},</if>
</trim>
where route_id = #{routeId}
</update>

Write Preview
Loading…
Cancel
Save