#

zzgtfwq

2 天以前 7d7a2c1b4a8f4c0ce412916cf8acba3510e3ba05

#

 src/main/java/com/zy/asrs/mapper/TaskWrkMapper.java

@@ -9,4 +9,5 @@
@Repository
public interface TaskWrkMapper extends BaseMapper<TaskWrk> {
    TaskWrk selectByWrkNo(Integer wrkNo);
    TaskWrk selectByTaskNo(Integer taskNo);
}

 src/main/java/com/zy/asrs/service/TaskWrkService.java

@@ -8,6 +8,7 @@

public interface TaskWrkService extends IService<TaskWrk> {

    TaskWrk selectByWrkNo(Integer wrkNo);
//    TaskWrk selectByWrkNo(Integer wrkNo);
    TaskWrk selectByTaskNo(Integer taskNo);

}

 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java

@@ -1242,6 +1242,20 @@

    /////////////////////////////////////RGV调度/////////////////////////////////////

    public synchronized void taskCreate() {
        for (RgvSlave rgvSlave : slaveProperties.getRgv()) {
            try {
                for (RgvSlave.RgvStn inSta : rgvSlave.getRgvInSta()) {
                    boolean create = deviceDetectionCreate(inSta);
                    if (create) {
                        continue;
                    }
                }
            } catch (Exception e){

            }
        }
    }
    public synchronized void taskStart() {
        for (RgvSlave rgvSlave : slaveProperties.getRgv()) {
            try {
@@ -1724,6 +1738,32 @@
        return true;
    }

    public boolean deviceDetectionCreate(RgvSlave.RgvStn inSta) {
        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, inSta.getDevpPlcId());
        StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
        if (staProtocol == null) {
            return false;
        }
        // 判断是否满足取货条件
        if (staProtocol.isAutoing()
//                && staProtocol.isLoading()
//                && staProtocol.isStaOk()
                && staProtocol.getWorkNo() != 0) {
            TaskWrk taskWrk = taskWrkService.selectByTaskNo(staProtocol.getWorkNo());
            if (Cools.isEmpty(taskWrk)){
                if (inSta.getStaNo()==117 || inSta.getStaNo()==120 || inSta.getStaNo()==123
                        || inSta.getStaNo()==217 || inSta.getStaNo()==220 || inSta.getStaNo()==223){
                    WrkMast wrkMast = wrkMastService.selectByWrkNo(staProtocol.getWorkNo());
                    if (!Cools.isEmpty(wrkMast) && wrkMast.getIoType()<100){
                        return true;
                    }
                } else {
                    return true;
                }
            }
        }
        return false;
    }
    public TaskWrk deviceDetection(RgvSlave.RgvStn inSta) {

        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, inSta.getDevpPlcId());
@@ -1741,7 +1781,7 @@
//                && staProtocol.isLoading()
//                && staProtocol.isStaOk()
                && staProtocol.getWorkNo() != 0) {
            TaskWrk taskWrk = taskWrkService.selectByWrkNo(staProtocol.getWorkNo());
            TaskWrk taskWrk = taskWrkService.selectByTaskNo(staProtocol.getWorkNo());
            if (taskWrk != null) {
                Integer stano = staProtocol.getStaNo().intValue();
                if (staProtocol.getSiteId() == 1004 || staProtocol.getSiteId()==1020){
@@ -1859,7 +1899,7 @@
                // 判断是否满足取货条件
                if (staProtocolOther.isAutoing()
                        && staProtocolOther.getWorkNo() != 0) {
                    TaskWrk taskWrkOther = taskWrkService.selectByWrkNo(staProtocolOther.getWorkNo());
                    TaskWrk taskWrkOther = taskWrkService.selectByTaskNo(staProtocolOther.getWorkNo());
                    if (taskWrkOther != null) {
                        return taskWrkOther;
                    }

 src/main/java/com/zy/asrs/service/impl/TaskWrkServiceImpl.java

@@ -9,8 +9,13 @@
@Service("taskWrkService")
public class TaskWrkServiceImpl extends ServiceImpl<TaskWrkMapper, TaskWrk> implements TaskWrkService {

//    @Override
//    public TaskWrk selectByWrkNo(Integer wrkNo) {
//        return this.baseMapper.selectByWrkNo(wrkNo);
//    }

    @Override
    public TaskWrk selectByWrkNo(Integer wrkNo) {
        return this.baseMapper.selectByWrkNo(wrkNo);
    public TaskWrk selectByTaskNo(Integer taskNo) {
        return this.baseMapper.selectByTaskNo(taskNo);
    }
}

 src/main/java/com/zy/core/MainProcess.java

@@ -88,6 +88,8 @@
                if (!SystemProperties.WCS_RUNNING_STATUS.get()) {
                    continue;
                }
                // 任务生成
                mainService.taskCreate();
                // 任务下发
                mainService.taskStart();


 src/main/java/com/zy/core/thread/SiemensDevpThread.java

@@ -543,7 +543,7 @@

            //更新任务步序
            TaskWrkService taskWrkService = SpringUtils.getBean(TaskWrkService.class);
            TaskWrk taskWrk = taskWrkService.selectByWrkNo(staProtocol.getWorkNo());
            TaskWrk taskWrk = taskWrkService.selectByTaskNo(staProtocol.getWorkNo());
            if (taskWrk != null) {
                taskWrk.setCommandStep(taskWrk.getCommandStep() + 1);//更新指令步序
                taskWrkService.updateById(taskWrk);

 src/main/resources/mapper/TaskWrkMapper.xml

@@ -36,4 +36,10 @@
          and "wrk_no" = #{wrkNo}
    </select>

    <select id="selectByTaskNo" resultMap="BaseResultMap">
        select top 1 * from wcs_task_wrk
        where 1=1
          and "task_no" = #{taskNo}
    </select>

</mapper>