义乌项目
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wang
2024-05-09 93e36c526fe445c14d5fb19f3653f8a8e55e3a6c 
 hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/downworkstation/service/impl/DownWorkstationServiceImpl.java


@@ -3,23 +3,30 @@


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.github.yulichang.query.MPJQueryWrapper;


import com.mes.downglassinfo.entity.DownGlassInfo;


import com.mes.downglassinfo.entity.DownGlassTask;


import com.mes.downglassinfo.mapper.DownGlassInfoMapper;


import com.mes.downglassinfo.service.DownGlassInfoService;


import com.mes.downglassinfo.service.DownGlassTaskService;


import com.mes.downworkstation.entity.DownWorkstation;


import com.mes.downworkstation.entity.DownWorkstationTask;


import com.mes.downworkstation.entity.DownWorkstionAndDownGlassinfo;


import com.mes.downworkstation.mapper.DownWorkstationMapper;


import com.mes.downworkstation.mapper.DownWorkstationTaskMapper;


import com.mes.downworkstation.service.DownWorkstationService;


import com.mes.downworkstation.service.DownWorkstationTaskService;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;




@Slf4j


@Service


public class DownWorkstationServiceImpl extends ServiceImpl<DownWorkstationMapper, DownWorkstation> implements DownWorkstationService {




@@ -30,13 +37,15 @@


    @Autowired


    private DownGlassInfoService downGlassInfoService;


    @Autowired


    private DownGlassInfoMapper downGlassInfoMapper;


    @Autowired


    private DownGlassTaskService downGlassTaskService;






    @Autowired


    private DownWorkstationTaskService downWorkstationTaskService;




//    @Override


    //    @Override


//    public List<DownWorkstation> gettwoDownWorkstations() {


//        return downWorkstationMapper.getDownWorkstationsInRange(6,10);


//    }


@@ -51,17 +60,37 @@


        return result != null ? result.getTotalquantity() : 0;


    }




//    @Override


//    public int getTotalQuantity(int workstationId) {


//        Integer totalQuantity = downWorkstationMapper.getTotalQuantity(workstationId);


//        return totalQuantity != null ? totalQuantity : 0;


//    }


    //工位显示


    @Override


    public List<Map<String, Object>> getTotalGlassDimensionsByWorkstation() {


        MPJQueryWrapper<DownWorkstation> queryWrapper = new MPJQueryWrapper<>();


        queryWrapper.select("t.workstation_id", "t.flow_card_id", "COALESCE(SUM(b.width), 0) AS totalwidth", "COALESCE(SUM(b.height), 0) AS totalheight")


                .leftJoin("down_glass_info b on t.flow_card_id = b.flow_card_id")


                .groupBy("t.workstation_id", "t.flow_card_id");




//    @Override


//    public int getRacksNumber(int workstationId) {


//        Integer racksNumber = downWorkstationMapper.getRacksNumber(workstationId);


//        return racksNumber != null ? racksNumber : 0;


//    }


//        List<DownWorkstionAndDownGlassinfo> workstationList = downWorkstationMapper.selectJoinList(DownWorkstionAndDownGlassinfo.class, queryWrapper);


        List<DownWorkstionAndDownGlassinfo> workstationList = null;


        List<Map<String, Object>> result = new ArrayList<>();


        for (DownWorkstionAndDownGlassinfo downWorkstionAndDownGlassinfo : workstationList) {


            Map<String, Object> rack = new HashMap<>();




            // 创建子项（item）对象


            Map<String, Object> item = new HashMap<>();


            item.put("height", downWorkstionAndDownGlassinfo.getTotalheight()); // 设置子项高度，根据实际情况设置


            item.put("width", downWorkstionAndDownGlassinfo.getTotalwidth()); // 设置子项宽度，根据实际情况设置


            item.put("fillColor", "yellow"); // 设置子项颜色


            item.put("content", downWorkstionAndDownGlassinfo.getFlowCardId()); // 使用流程卡号作为子项内容




            rack.put("item", item); // 将子项对象放入货架对象中




            result.add(rack); // 将货架对象添加到结果列表中


            //log.info("货架对象: {}", rack);


        }




        return result; // 返回最终结果


    }






    //根据条件获取落架数量


    @Override


    public int getRacksNumber(int workstationId) {


@@ -72,7 +101,8 @@


        DownWorkstation result = baseMapper.selectOne(queryWrapper);


        return result != null ? result.getRacksnumber() : 0;


    }


//根据条件获取工位玻璃信息




    //根据条件获取工位玻璃信息


    @Override


    public List<DownWorkstation> getoneDownWorkstations(int startId, int endId) {


        QueryWrapper<DownWorkstation> queryWrapper = new QueryWrapper<>();


@@ -88,10 +118,9 @@


    @Override


    public void updateracksnumber(String flowCardId, int racksNumber) {


        UpdateWrapper<DownWorkstation> updateWrapper = new UpdateWrapper<>();


        updateWrapper.set("racks_number",racksNumber).eq("flow_card_id", flowCardId);


        baseMapper.update(null, updateWrapper);


        updateWrapper.set("racks_number", racksNumber).eq("flow_card_id", flowCardId);


        baseMapper.update(new DownWorkstation(), updateWrapper);


    }








    @Override


@@ -101,7 +130,7 @@


                .set("flow_card_id", flowCardId)


                .eq("workstation_id", workstationId);




        return baseMapper.update(null, updateWrapper);


        return baseMapper.update(new DownWorkstation(), updateWrapper);


    }




    @Override


@@ -112,8 +141,10 @@


                .set("racks_number", 0)


                .eq("workstation_id", workstationId);




        baseMapper.update(null, updateWrapper);


        baseMapper.update(new DownWorkstation(), updateWrapper);


    }












@@ -123,12 +154,6 @@




        return baseMapper.selectOne(queryWrapper);


    }


















    @Transactional


@@ -142,13 +167,8 @@


    }














    @Override


    public void insertdownglassinfo() {








        List<DownGlassTask> taskdownGlassInf = downGlassTaskService.getUnloadingTaskState();


@@ -192,8 +212,6 @@


        }










        try {


            //查询下片工位表中架子是否绑定了流程卡号 工位表和任务表中状态为1的流程卡号和已落架数量


            List<DownWorkstationTask> taskdownWorkstation = downWorkstationTaskService.getTaskState();


@@ -202,7 +220,7 @@


                for (DownWorkstationTask downWorkstation : taskdownWorkstation) {


                    //更新下片工位表中已落架数量


                    DownWorkstation downWorkstation1 = selectByFlowCardId(downWorkstation.getFlowCardId());


                    updateracksnumber(downWorkstation.getFlowCardId(),downWorkstation1.getRacksnumber()  + 1);


                    updateracksnumber(downWorkstation.getFlowCardId(), downWorkstation1.getRacksnumber() + 1);


                    //更新机械任务表中状态为0


                    downWorkstationTaskService.updateTaskStateToZero(downWorkstation.getId());


                    //删除机械任务表


@@ -217,11 +235,6 @@


            // 或者可以进行其他异常处理，比如记录日志或者返回特定的错误信息


        }


    }
















}