diff --git a/src/main/java/adapterContext.xml b/src/main/java/adapterContext.xml index a00e840..10c1ec4 100644 --- a/src/main/java/adapterContext.xml +++ b/src/main/java/adapterContext.xml @@ -214,7 +214,7 @@ - */1 * * * * ? + */3 * * * * ? diff --git a/src/main/java/com/dev/swms/server/interfaces/ItemJobLauncher.java b/src/main/java/com/dev/swms/server/interfaces/ItemJobLauncher.java index 5c123d7..f34fb16 100644 --- a/src/main/java/com/dev/swms/server/interfaces/ItemJobLauncher.java +++ b/src/main/java/com/dev/swms/server/interfaces/ItemJobLauncher.java @@ -37,8 +37,6 @@ import com.dev.swms.server.service.shipping.PickTicketManager; import com.dev.swms.server.service.shipping.WaveDocManager; import com.dev.swms.server.utils.interfaceUtil; -import org.apache.log4j.Logger; - /** * @author dev * @version $Id: AdapterLauncher.java,v 1.2 2010/06/01 09:14:16 peng.lei Exp $ @@ -122,7 +120,7 @@ public class ItemJobLauncher implements ApplicationListener { public void DefaultAutoWaveDoc0(){ Warehouse w =commonDao.load(Warehouse.class, 1L); if(w.isBeGyWarehouse()){ - logger.info("杂单开始"); + System.out.println("杂单开始"); /*waveDocManager.NewWaveDoc01("ONLINE_STATION001"); waveDocManager.NewWaveDoc01("ONLINE_STATION002"); waveDocManager.NewWaveDoc01("ONLINE_STATION003"); @@ -143,7 +141,7 @@ public class ItemJobLauncher implements ApplicationListener { public void autoLibraryTask(){ synchronized ("ltTaskOut") { //按工作站循环下发 -// logger.info("1------"); +// System.out.println("1------"); for(int y1=602;y1<=605;y1++) { int gzd=0; Boolean daup =false; @@ -152,8 +150,10 @@ public class ItemJobLauncher implements ApplicationListener { + " and ltask.type in ('2','6','3') " +" and ltask.toCellCode='"+y1+"'" + " order by ltask.relatedBill4 desc,ltask.seq asc,ltask.createDate asc"); -// logger.info("1------"+y1); -// logger.info(y1+"zgz="+ls21.size()); +// System.out.println("1------"+y1); +// System.out.println(y1+"zgz="+ls21.size()); + //查到4个巷道没有任务的巷道 1：false；2:false; + gzd=ls21.size(); if (ls21.size()>=3) { continue; @@ -165,16 +165,16 @@ public class ItemJobLauncher implements ApplicationListener { + " and ltask.type in ('2','6','3') " +" and ltask.relatedBill5='"+y+"'" + " order by ltask.seq asc"); -// logger.info("1------"+y1+"-----"+y); -// logger.info(y+"hdtask="+ls22.size()); +// System.out.println("1------"+y1+"-----"+y); +// System.out.println(y+"hdtask="+ls22.size()); if (ls22.size()>0) { continue; }else { List listTasks=moveDocManager.autoOutLibraryTask3(y,y1);//生成出库的移位任务， + System.out.println("xiafarenw="+listTasks.size()); moveDocManager.autoWcsLibraryTask(listTasks);//下发任务 -// logger.info("xiafarenw="+listTasks.size()); if(listTasks.size()>0) { -// logger.info("1------"+y1+"-----"+y+"---2222"); + System.out.println("1------"+y1+"-----"+y+"---2222"); gzd++; if(gzd>=3) {//判定工作站任务是否大于三个，大于跳出工作站循环 daup=true; @@ -185,7 +185,7 @@ public class ItemJobLauncher implements ApplicationListener { } } // if(daup) { -// logger.info("1------"+y1+"--跳出---"+"---2222"); +// System.out.println("1------"+y1+"--跳出---"+"---2222"); // break; // } } @@ -235,7 +235,7 @@ public class ItemJobLauncher implements ApplicationListener { int e=0; switch (a) { case 1: - logger.info("1"); + System.out.println("1"); if (true) { List agvTasks = commonDao.findByQuery(" from AgvTask agvTask " + " where 1=1 " //agvTask.beIssue=true @@ -256,28 +256,28 @@ public class ItemJobLauncher implements ApplicationListener { } break; case 2: - logger.info("2"); + System.out.println("2"); //下发料箱整理AGV任务 hujiaoAgvTask1(1763L,"料箱整理",null); break; case 3: - logger.info("3"); + System.out.println("3"); //下发货架整理AGV任务 hujiaoAgvTask1(1765L,"货架整理",null); break; case 4: - logger.info("4"); + System.out.println("4"); //下发库位整理AGV任务 hujiaoAgvTask1(1763L,"库位整理",null); break; case 5: - logger.info("5"); + System.out.println("5"); //下发AGV取料AGV任务 hujiaoAgvTask1(1763L,"拣货",null); break; case 6: //到站一分钟后调用返库 - logger.info("6"); + System.out.println("6"); List agvTasks = commonDao.findByQuery(" from AgvTask agvTask " + " where agvTask.beIssue=true " + " and agvTask.status in ('ATPICK') " @@ -297,17 +297,17 @@ public class ItemJobLauncher implements ApplicationListener { } break; case 7: - logger.info("7"); + System.out.println("7"); //下发AGV取料AGV任务 agvTaskManager.sendAgvTask("拣货",null); break; case 8: - logger.info("8"); + System.out.println("8"); //下发AGV取料AGV任务 agvTaskManager.sendAgvTask("盘点",null); break; case 9: - logger.info("9"); + System.out.println("9"); //下发AGV取料AGV任务 agvTaskManager.sendAgvTask("呼叫",null); break; @@ -475,7 +475,7 @@ public class ItemJobLauncher implements ApplicationListener { public void DefaultAutoPickticket(){ Warehouse w =commonDao.load(Warehouse.class, 1L); if(w.isDisabled()==false){ -// logger.info("接单开始"); +// System.out.println("接单开始"); pickTicketManager.receivePickticket(); } } @@ -499,7 +499,7 @@ public class ItemJobLauncher implements ApplicationListener { // commonDao.store(pt); // break; }else { -// logger.info("工单号"+pt.getCode()+" 未拣货完成"); +// System.out.println("工单号"+pt.getCode()+" 未拣货完成"); } } } diff --git a/src/main/java/com/dev/swms/server/model/base/Item.java b/src/main/java/com/dev/swms/server/model/base/Item.java index 2c1e8b0..5921a05 100644 --- a/src/main/java/com/dev/swms/server/model/base/Item.java +++ b/src/main/java/com/dev/swms/server/model/base/Item.java @@ -92,7 +92,6 @@ public class Item extends Entity { protected String strExtend1;//备注 - /**品管类别*/ protected String strExtend3;//标准价 protected String strExtend2;//币种 diff --git a/src/main/java/com/dev/swms/server/model/inventory/Task.java b/src/main/java/com/dev/swms/server/model/inventory/Task.java index 14328c7..12f1584 100644 --- a/src/main/java/com/dev/swms/server/model/inventory/Task.java +++ b/src/main/java/com/dev/swms/server/model/inventory/Task.java @@ -140,10 +140,10 @@ public class Task extends VersionalEntity { private String strBill4;//合单库位 private String strBill5;//合单人 private String strBill6;//是否未未拆包装 - private String strBill7;//大容器号 - private String strBill8;//头物料拼接号 + private String strBill7;// + private String strBill8;// private String strBill9;// - private String strBill10;// + private String strBill10;//退料属性（T） private Date dateBill1=new Date();//下发日期 private Date dateBill2;//合单移动日期 private Date dateBill3;//合单任务完成日期 @@ -156,6 +156,8 @@ public class Task extends VersionalEntity { private String oldGzz;//原工作站 private String oldZrw;//原子任务 + + public String getOldGzz() { return oldGzz; } diff --git a/src/main/java/com/dev/swms/server/service/count/pojo/DefaultCountPlanManager.java b/src/main/java/com/dev/swms/server/service/count/pojo/DefaultCountPlanManager.java index eb6d1f1..9aa6649 100644 --- a/src/main/java/com/dev/swms/server/service/count/pojo/DefaultCountPlanManager.java +++ b/src/main/java/com/dev/swms/server/service/count/pojo/DefaultCountPlanManager.java @@ -33,6 +33,7 @@ import com.dev.swms.server.model.base.PackageUnit; import com.dev.swms.server.model.base.Structure; import com.dev.swms.server.model.base.Warehouse; import com.dev.swms.server.model.base.WarehouseArea; +import com.dev.swms.server.model.base.WarehouseAreaStatus; import com.dev.swms.server.model.base.Worker; import com.dev.swms.server.model.base.Workstation; import com.dev.swms.server.model.count.CountDetail; @@ -75,12 +76,10 @@ import com.dev.energy.server.model.EntityFactory; import com.dev.energy.server.service.pojo.DefaultBaseManager; import com.dev.energy.server.util.LocalizedMessage; import com.dev.energy.server.web.security.UserHolder; -import org.apache.log4j.Logger; @SuppressWarnings("unchecked") public class DefaultCountPlanManager extends DefaultBaseManager implements CountPlanManager { - private static Logger logger = Logger.getLogger(DefaultCountPlanManager.class); protected final InventoryManager inventoryManager; protected final ItemManager itemManager; protected final BussinessCodeManager bussinessCodeManager; @@ -101,7 +100,7 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements * @see com.dev.swms.server.service.count.CountPlanManager#active(java.lang.Long) */ public void active(RowData rowData) { - logger.info(new Date()); + System.out.println(new Date()); Long countPlanId = (Long) rowData.getColumnValue(0); CountPlan countPlan = commonDao.load(CountPlan.class, countPlanId); if (countPlan.active()) { @@ -110,13 +109,13 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements || CountMethod.MOVED_ITEM.equals(countPlan.getCountMethod()) || CountMethod.ABC.equals(countPlan.getCountMethod())) { //按货品盘点 - logger.info(new Date()); + System.out.println(new Date()); List cdlists= commonDao.findByQuery(" from CountDetail c where c.countPlan.id="+countPlanId); for (CountDetail countDetail : cdlists) { Item item = ((CountDetailItem) countDetail).getItem(); createCountRecordByItem(countPlan, item,countDetail); } - logger.info(new Date()); + System.out.println(new Date()); } else { //按库位动碰盘点&&按库位盘点 for (CountDetail countDetail : countPlan.getDetails()) { @@ -140,7 +139,7 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements } else { throw new BusinessException("countPlan.active.failed"); } - logger.info(new Date()); + System.out.println(new Date()); } /** @@ -181,7 +180,7 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements // return; // } // } -// logger.info(inventories.size()); +// System.out.println(inventories.size()); item.setCycleDate(new Date()); if(inventories.size()>0) createCountRecordByInventories(countPlan, inventories); @@ -239,6 +238,7 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements record.setQuantity(inventory.getQtyOfMasterPack()); record.setOperator(UserHolder.getUser().getName()); record.setOccurTime(new Date()); + record.setBarCode(inventory.getBarCode()); commonDao.store(record); inventory.setCounPlan(countPlan.getCode()); commonDao.store(inventory); @@ -1122,7 +1122,7 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements commonDao.store(cr); // inv.setCounPlan(countPlan.getCode()); // commonDao.store(inv); - logger.info(inv.getId() ); + System.out.println(inv.getId() ); js++; } // countPlan.setStatus(CountStatus.ACTIVE); @@ -1222,7 +1222,7 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements commonDao.store(cr); // inv.setCounPlan(countPlan.getCode()); // commonDao.store(inv); - logger.info(inv.getId() ); + System.out.println(inv.getId() ); js++; } // countPlan.setStatus(CountStatus.ACTIVE); @@ -1375,6 +1375,7 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements List CountRecords = commonDao.findByQuery(" from CountRecord cr where cr.countPlan.id=:id and cr.needCount=1 and cr.delta=0", new String[] { "id"},new Object[] {countPlanId}); for(CountRecord cr:CountRecords){ + //是否盘点，是否有差异 if(cr.isNeedCount()&&cr.getCountQuantity()-cr.getQuantity()!=0) { if(cr.getIndId()==null) { cr.setIndId(0L); @@ -1387,7 +1388,19 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements inv.setQuantity(cr.getCountQuantity()); inv.setCounPlan(null); InventoryLog log1 = new InventoryLog(InventoryLogType.CHECK_ADJUST,inv.getSOI(), 1, w==null?"":w.getName(), inv.getLocation(), cr.getItemKey(), new Date(), inv.getQuantity(), null, "盘点调整", null, null); - commonDao.store(inv); + if(inv.getQtyOfMasterPack()==0) { + commonDao.delete(inv); + List list=commonDao.findByQuery("select inv.id from Inventory inv where inv.location.id="+inv.getLocation().getId()+" and " + + " inv.quantity>0 "); + if(list.size()==0) { + Location invloc=this.load(Location.class, inv.getLocation().getId()); + invloc.setStatus(WarehouseAreaStatus.FREE); + commonDao.store(invloc); + } + }else { + commonDao.store(inv); + } + Inventory moveInv=new Inventory(); List incs=commonDao.findByQuery(" from Inventory inv where inv.location.id=97197 and " + " inv.itemKey.id="+cr.getItemKey().getId()+" "); @@ -1457,12 +1470,8 @@ public class DefaultCountPlanManager extends DefaultBaseManager implements dInv.setStatus("已入库"); dInv.setStorageDate(new Date()); commonDao.store(dInv); -// cr.setDelta(1); -// commonDao.store(cr); -// InventoryLog log3 = new InventoryLog(InventoryLogType.CHECK_ADJUST,dInv.getSOI(), 1, w==null?"":w.getName(), loc, cr.getItemKey(), new Date(), moveInv.getQuantity(), null, null, null, null); -// log3.setSerial(dInv.getBarCode()); -// log3.setSrcLoc(cr.getLocation()); -// commonDao.store(log3); + loc.setStatus(WarehouseAreaStatus.OCCUPY); + commonDao.store(loc); } }else { if(cr.isNeedCount()&&cr.getCountQuantity()-cr.getQuantity()==0) { diff --git a/src/main/java/com/dev/swms/server/service/interfaceLog/pojo/DefaultInterfaceRespManager.java b/src/main/java/com/dev/swms/server/service/interfaceLog/pojo/DefaultInterfaceRespManager.java index 2722507..357ca27 100644 --- a/src/main/java/com/dev/swms/server/service/interfaceLog/pojo/DefaultInterfaceRespManager.java +++ b/src/main/java/com/dev/swms/server/service/interfaceLog/pojo/DefaultInterfaceRespManager.java @@ -71,7 +71,7 @@ import com.dev.swms.server.service.sequence.BussinessCodeManager; import com.dev.swms.server.service.shipping.PickTicketManager; import com.dev.swms.server.utils.TimeNumberUtils; import com.dev.swms.server.web.filter.WarehouseHolder; -import org.apache.log4j.Logger; + public class DefaultInterfaceRespManager extends DefaultBaseManager implements InterfaceRespManager{ protected final InterfaceManager interfaceManager; protected final ASNManager asnManager; @@ -83,7 +83,6 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I protected LocationStorageManager locationStorageManager; protected final AgvTaskManager agvTaskManager; protected final MoveDocManager moveDocManager; - private static Logger logger = Logger.getLogger(DefaultInterfaceRespManager.class); public DefaultInterfaceRespManager(InterfaceManager interfaceManager,ASNManager asnManager,PickTicketManager pickTicketManager, BussinessCodeManager manager3,JdbcManager jdbcManager,ItemManager itemManager,InterfaceReqManager interfaceReqManager, LocationStorageManager locationStorageManager,AgvTaskManager agvTaskManager,MoveDocManager moveDocManager) { @@ -219,7 +218,7 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I JSONArray pickTickets=json.getJSONArray("header"); for(int j=0;j billTypes=commonDao.findByQuery(" from BillType bt where bt.code='"+billTypess+"'");//单据类型查询 for(int j=0;j billTypes=commonDao.findByQuery(" from BillType bt where bt.code='"+billType+"'");//单据类型查询 for(int j=0;j billTypes=commonDao.findByQuery(" from BillType bt where bt.code='"+billType+"'"); JSONObject objectItem=new JSONObject(); JSONObject asn=JSONObject.fromObject(jsonArray.get(j)); -// logger.info(asn); +// System.out.println(asn); // String billType=""; String PO=asn.has("sourceId") ? asn.getString("sourceId") : ""; //入库序号 int lineNo=asn.has("lineNo") ? asn.getInt("lineNo") : 0; //行号 @@ -1726,7 +1725,7 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I List billTypes=commonDao.findByQuery(" from BillType bt where bt.code='"+billType+"'"); JSONObject objectItem=new JSONObject(); JSONObject asn=JSONObject.fromObject(jsonArray.get(j)); -// logger.info(asn); +// System.out.println(asn); // String billType=""; String PO=asn.has("sourceId") ? asn.getString("sourceId") : ""; //入库序号 @@ -2210,7 +2209,6 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I }else { asnDetail.setExpectedQuantity(expectedQuantity); } - asnDetail.setItem(items.get(0)); asnDetail.setStrBill2(strBill2); // asnDetail.setStrBill1(strBill1); @@ -2269,7 +2267,7 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I List billTypes=commonDao.findByQuery(" from BillType bt where bt.code='"+billType+"'"); JSONObject objectItem=new JSONObject(); JSONObject asn=JSONObject.fromObject(jsonArray.get(j)); - logger.info(asn); + System.out.println(asn); // String billType=""; log.setFunction("盘点差异"); String MATNR=asn.has("MATNR") ? asn.getString("MATNR") : ""; //物料号 @@ -2362,7 +2360,7 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I CountPlan countPlan=null; for(int j=0;j agvTasks = commonDao.findByQuery(" from AgvTask agvTask where agvTask.robotJobId='"+taskCode+"' or agvTask.robotJobId='A"+taskCode+"'"); -// logger.info("打印3--"+agvTasks.size()); +// System.out.println("打印3--"+agvTasks.size()); if (agvTasks.size()>0) { AgvTask agvTask=agvTasks.get(0); @@ -2711,7 +2709,7 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I agvTask.setStationCode(locationStorage.get(0).getGzzCode()); commonDao.store(agvTask); } -// logger.info("打印3"+agvTask.getRobotJobId()); +// System.out.println("打印3"+agvTask.getRobotJobId()); //判断接驳口状态是否可用 // if(WcsCSDCode.getWmsJbkCode1(WcsCSDCode.getWmsCSDCode(work))) { string = interfaceReqManager.sendAgvTask(agvTask)+""; @@ -2759,7 +2757,7 @@ public class DefaultInterfaceRespManager extends DefaultBaseManager implements I String msg=""; for(int j=0;j0) { for(int j=0;j list= (List)query.list(); String sql1=" select ad.id,asn.code,ad.be_quality from ASN_DETAIL ad " @@ -238,7 +236,6 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA List asnds=(List)query1.list(); String sql2=sql1+" and ad.EXPECTED_QUANTITY=ad.RECEIVED_QUANTITY "; -// logger.info(sql2); //整理完成 Query query2 = session.createSQLQuery(sql2); List asds=(List)query2.list(); @@ -257,7 +254,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA obj.put("strBill7", arrier[i++]==null?"":arrier[i-1]);//行号 obj.put("propC5", arrier[i++]==null?"":arrier[i-1]); obj.put("propC2", arrier[i++]==null?"":arrier[i-1]); -// logger.info(arrier[8].toString()+"----"); +// System.out.println(arrier[8].toString()+"----"); if(itemcode!=null&&!itemcode.equals("")) { if(arrier[8]!=null&&arrier[8].toString().length()>0) { @@ -1104,7 +1101,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA // sql+=" and (upper(md.RELATEBILLCODE) like upper('%"+ asn_code + "%') or upper(s.LP) like upper('%"+ asn_code +"%'))"; // } sql+=" order by mdd.ID "; - logger.info(sql); +// System.out.println(sql); Query query = session.createSQLQuery(sql); List list= (List)query.list(); if(list.size()>0){ @@ -1245,7 +1242,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA if(moveDocDetail.getStrBill11()!=null&&moveDocDetail.getStrBill11().equals("1")) { msg="加急料号"+item.getCode()+"，需要出库"; } -// logger.info(moveDocDetail.getStrBill11()); +// System.out.println(moveDocDetail.getStrBill11()); data1.put("beMarkWeight", beMarkWeight); array.add(data1); } @@ -1346,7 +1343,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA sql+=" and z.id = "+zoneId; } sql+=" group by md.RELATEBILLCODE,z.name,s.LP order by mdd.ID "; - logger.info(sql); +// System.out.println(sql); Query query = session.createSQLQuery(sql); List list= (List)query.list(); if(list.size()>0){ @@ -1510,7 +1507,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA } } long etime1 = System.currentTimeMillis(); - logger.infof(bigTask.getCode()+"亮灯时长："+(etime1 - stime1)); + System.out.printf(bigTask.getCode()+"亮灯时长："+(etime1 - stime1)); } taskids = sb.substring(0,sb.length()-1).toString(); @@ -1558,7 +1555,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA data = array.toString(); status = "1"; long etime2 = System.currentTimeMillis(); - logger.infof("料箱列表显示时长："+(etime2 - stime2)); + System.out.printf("料箱列表显示时长："+(etime2 - stime2)); }else{ msg = "找不到相应记录!"; @@ -1635,7 +1632,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA } } long etime1 = System.currentTimeMillis(); - logger.info(agvTask.getRobotJobId()+"亮灯时长："+(etime1 - stime1)+"\n"); +// System.out.printf(agvTask.getRobotJobId()+"亮灯时长："+(etime1 - stime1)+"\n"); } agvid = sb.substring(0,sb.length()-1).toString(); @@ -1683,7 +1680,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA } } long etime2 = System.currentTimeMillis(); - logger.info("料箱列表显示时长："+(etime2 - stime2)+"\n"); +// System.out.printf("料箱列表显示时长："+(etime2 - stime2)+"\n"); }else{ msg = "locode参数错误或为空!"; @@ -3797,7 +3794,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA msg+=",加急单"; data1.put("zoneName", zoneCode); } - logger.info(":"+jsondata1); +// System.out.println(":"+jsondata1); obj.put("data1", jsondata1); status = "1"; } @@ -5449,7 +5446,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA }else{ xlh=strBill2; } - logger.info("料号="+item_code+" ,序列号="+xlh); +// System.out.println("料号="+item_code+" ,序列号="+xlh); String sql=" from ASNDetail ad where ad.item.code='"+item_code+"' and ad.strBill2='"+xlh+"' "; List ASNDetails = commonDao.findByQuery(sql); @@ -5879,7 +5876,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA } sql+=" order by mdd.ID "; - logger.info(sql); +// System.out.println(sql); Query query = session.createSQLQuery(sql); List list= (List)query.list(); @@ -5998,7 +5995,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA if (userId > 0) { if (warehouseId > 0) { - logger.info("PC货架上架完成返库：DefaultQueryAppManager：submitAndPcStockPutHJ"); +// System.out.println("PC货架上架完成返库：DefaultQueryAppManager：submitAndPcStockPutHJ"); List locs=commonDao.findByQuery(" from Location l where l.code='"+stockCode+"' and l.disabled=0 "); if(locs.size()>0) { Location loc=locs.get(0); @@ -6012,7 +6009,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA ag.setType("货架返库"); commonDao.store(ag); boolean bo= interfaceReqManager.sendAgvTask(ag); - logger.info(bo+"--"+ag.getClassification()+"--"+ag.getCode()); +// System.out.println(bo+"--"+ag.getClassification()+"--"+ag.getCode()); if(bo&&ag.getClassification().equals("盘点")&&ag.getCode()!=null) { pickTicketManager.quercountPlan(ag, userId); } @@ -6025,7 +6022,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA } } }else { - logger.info("无agvTask 任务"); + System.out.println("无agvTask 任务"); } status="1"; @@ -6263,7 +6260,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA List invqty= commonDao.findByQuery(sql2); if(invqty.size()>0) { tqty=invqty.get(0); - logger.info("灯数量"+tqty); +// System.out.println("灯数量"+tqty); } InterWMStask iwt=InterWMStasks.get(i); iwt.setQuant((int)tqty); @@ -6799,7 +6796,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA List invqty= commonDao.findByQuery(sql2); if(invqty.size()>0) { tqty=invqty.get(0); - logger.info("打印数量"+tqty); +// System.out.println("打印数量"+tqty); } //打印拣货标签 submitPrintTask( userId, number, mac, lsCode, t , ptd, pt, @@ -7054,7 +7051,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA // }else { barcode+="/"+ymd.format(new Date()); // } - logger.info(barcode); +// System.out.println(barcode); String emergent=""; if(pt!=null&&bt.getName().indexOf("工单")>=0&&pt.getEquatedQuantity()!=null &&(pt.getEquatedQuantity().equals("H")||pt.getEquatedQuantity().equals("U") @@ -7341,7 +7338,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA String countCode=taskcode.replace(",","','"); sql+=" and t.countCode in('"+countCode+"') "; }else { - logger.info("请选择盘点单号"); + System.out.println("请选择盘点单号"); becount=false; } @@ -7435,7 +7432,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA String countCode=taskcode.replace(",","','"); sql+=" and cr.count_Code in('"+countCode+"') "; }else { - logger.info("请选择盘点单号"); + System.out.println("请选择盘点单号"); } sql+=" group by c.id,cr.count_Code,l.code,l.ID ,cr.NEED_COUNT,i.id,i.code,ik.PROP_C1,ik.PROP_D2,\r\n" + " i.SINGLE_ITEM,i.BE_MARK_WEIGHT,i.isBOM "; @@ -7896,7 +7893,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA } } catch (Exception e) { e.printStackTrace(); - logger.info("连接失败"); + System.out.print("连接失败"); }finally{ session.close(); } @@ -7976,7 +7973,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA xlh=serial; } -// logger.info("料号="+item_code+" ,序列号="+xlh); +// System.out.println("料号="+item_code+" ,序列号="+xlh); String hql=" from Inventory inv where inv.quantity>0 " + " and inv.itemKey.item.code='"+item_code+"'" + " and inv.status='已入库'" @@ -8983,7 +8980,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA if(zone.getId()==1763) { //容器返库3#料箱区 if(srcLocation.getStock()!=null) { -// logger.info("容器返库1"); +// System.out.println("容器返库1"); Stock stock= commonDao.load(Stock.class, srcLocation.getStock().getId()); List tsks=commonDao.findByQuery(" from Task t where 1=1 " + " and t.endRegion='"+t.getEndRegion()+"'" @@ -8997,7 +8994,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA AgvTask agv=commonDao.load(AgvTask.class, t.getAgvTask().getId()); if(agv.getStatus().equals("ATPICK")) { interfaceReqManager.wcsNextPT(agv.getRobotJobId(), s.getLP(), WcsCSDCode.getWcsCSDCode(t.getEndRegion())); -// logger.info("容器返库2"); +// System.out.println("容器返库2"); } } } @@ -9829,7 +9826,7 @@ public class DefaultQueryAppManager extends DefaultBaseManager implements QueryA }else { data1.put("t_count", "清点");//q } -// logger.info("-"+arrier[6].toString()); +// System.out.println("-"+arrier[6].toString()); } data1.put("lc_code", arrier[7]==null?"":arrier[7]);//地标码 String hx=arrier[8]==null?"":arrier[8].toString();//相差分钟 diff --git a/src/main/java/com/dev/swms/server/service/picking/allocate/DefaultAutoAllocator.java b/src/main/java/com/dev/swms/server/service/picking/allocate/DefaultAutoAllocator.java index 13c098a..29a299b 100644 --- a/src/main/java/com/dev/swms/server/service/picking/allocate/DefaultAutoAllocator.java +++ b/src/main/java/com/dev/swms/server/service/picking/allocate/DefaultAutoAllocator.java @@ -97,7 +97,7 @@ import com.dev.energy.server.model.EntityFactory; import com.dev.energy.server.service.pojo.DefaultBaseManager; import com.dev.energy.server.util.LocalizedMessage; import com.dev.energy.server.web.security.UserHolder; -import org.apache.log4j.Logger; + /** * @author dev * @@ -112,7 +112,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo protected final JdbcManager jdbcManager; protected final AgvTaskManager agvTaskManager; protected final InterfaceReqManager interfaceReqManager; - private static Logger logger = Logger.getLogger(DefaultAutoAllocator.class); + public DefaultAutoAllocator(ItemManager manager,InventoryManager manager1, @@ -295,7 +295,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo //List inventories =sortByRule(tempInventories,moveDocDetail.getItem().getWarehouseItemStorageRule(), pickItemRule,turnOverMode); //tempInventories.clear(); // for(Inventory inv:inventories){ -// logger.info(inv.getId()+"===="+inv.getAvaliableQuantity()); +// System.out.println(inv.getId()+"===="+inv.getAvaliableQuantity()); // } //拣货分配，累加已分配数量 totalQty += allocateInventory(inventories, moveDocDetail); @@ -309,7 +309,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo if((moveDocDetail.getPreAllocatedQuantity()-moveDocDetail.getAllocatedQuantity())<=0){ break; }else{ - logger.info(moveDocDetail.getItem()+"===="+moveDocDetail.getAllocatedQuantity()); + System.out.println(moveDocDetail.getItem()+"===="+moveDocDetail.getAllocatedQuantity()); } } @@ -395,7 +395,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo if((DoubleUtils.format4F(moveDocDetail.getPreAllocatedQuantity())-DoubleUtils.format4F(moveDocDetail.getAllocatedQuantity()))<=0){ return null; }else{ - logger.info(moveDocDetail.getItem()+"===="+moveDocDetail.getAllocatedQuantity()); + System.out.println(moveDocDetail.getItem()+"===="+moveDocDetail.getAllocatedQuantity()); } // } return errmsg; @@ -527,10 +527,10 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo pickTicketDetails=commonDao.findByQuery(" from PickTicketDetail ptd where ptd.pickTicket.id in ("+StringUtils.strip(pickTicketId.toString(),"[]")+") " + "and ptd.pickTicket.billType.code in('GPUTPTC') order by ptd.pickTicket.id,ptd.id"); if(pickTicketDetails.size()>0) { - logger.info(pickTicketDetails.size()+" 行数！"); + System.out.println(pickTicketDetails.size()+" 行数！"); preAllocate(pickTicketDetails); }else { - logger.info("今天无工单出库出库信息！"); + System.out.println("今天无工单出库出库信息！"); } return ""; } @@ -1581,7 +1581,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo task.setWarehouseArea(inventory.getWarehouseArea()); task.setBarCode(inventory.getBarCode()); task.setSrcLP(inventory.getLocation().getStock()); - logger.info(inventory.getLocation().getId()); + System.out.println(inventory.getLocation().getId()); commonDao.store(task); } @@ -1592,7 +1592,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo } shuaXinWaveDoc(id);//刷新波次单 }else{ - logger.info("无波次任务!"+"\n"); + System.out.println("无波次任务!"+"\n"); } } @@ -1764,7 +1764,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo WaveDocDetail wdd = t.getWaveDocDetail(); SeedWall sw = wdd.getSeedWall(); LocationStorage ls = sw.getLocationStorage();//工作站 - logger.info("任务:"+t.getCode()+"\n"); + System.out.println("任务:"+t.getCode()+"\n"); String outsueAGVJSON = interfaceManager.outsueAGVJSON("kckq", ls.getDescription(), "QP_OUTBOUND", "", 1,0, "SI_QUICK_PICK", true, t.getCode(), 1, t.getSrcLoc().getCode(), 0); String result = interfaceManager.doSslPost(ApiURL.issueAGV,outsueAGVJSON); JSONObject json = JSONObject.fromObject(result); @@ -1794,19 +1794,19 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo int waveSum=(int) (inv.get(i).getQtyOfMasterPack()-inv.get(i).getQueuedQuantity()); if (sum-waveSum>=0) { - logger.info("料箱整箱:"+inv.get(i).getLocation().getCode()); + System.out.println("料箱整箱:"+inv.get(i).getLocation().getCode()); String outsueAGVJSON=interfaceManager.outsueAGVJSON("kckq", ls.getDescription(), "QP_OUTBOUND", "", 1, 0, "SI_QUICK_PICK", true, robotJobId, 1l,inv.get(i).getLocation().getCode(),0); interfaceManager.doSslPost(ApiURL.issueAGV, outsueAGVJSON); } else{ - logger.info("料箱单拣:"+inv.get(i).getLocation().getCode()); + System.out.println("料箱单拣:"+inv.get(i).getLocation().getCode()); String outsueAGVJSON=interfaceManager.outsueAGVJSON("kckq", ls.getDescription(), "QP_OUTBOUND", "", 1, 0, "SI_QUICK_PICK", true, robotJobId, 1,inv.get(i).getLocation().getCode(),0); interfaceManager.doSslPost(ApiURL.issueAGV, outsueAGVJSON); } sum=sum-waveSum; if (sum<=0) { - logger.info("呼叫完成:"); + System.out.println("呼叫完成:"); return; } } @@ -1821,9 +1821,9 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo // .getPickTicket().getLx().getCode() List robotJobIds=new ArrayList(); String returnAGVJSON=interfaceManager.returnAGVJSON(robotJobIds,1l,"", false,"RETURN_WAREHOUSE"); - logger.info("json:"+returnAGVJSON); + System.out.println("json:"+returnAGVJSON); }*/ -// logger.info("回传入库:"+inv.get(i).getLocation().getCode()); +// System.out.println("回传入库:"+inv.get(i).getLocation().getCode()); List robotJobIds=new ArrayList(); String returnAGVJSON=interfaceManager.returnAGVJSON(robotJobIds,1L,containerCode, false,"RETURN_WAREHOUSE"); interfaceManager.doSslPost(ApiURL.returnAGV, returnAGVJSON); @@ -1892,7 +1892,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo Map map= new HashMap(); map.put("waveDoc.id", id); getQuantityMap(map); - logger.info("取消分配执行时长："+(etime - stime)+"\n"); + System.out.printf("取消分配执行时长："+(etime - stime)+"\n"); jdbcManager.saveExceptionLog(UserHolder.getUser().getName()+"取消分配!"); } } @@ -1976,7 +1976,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo } shuaxinPick(pt);//刷新出库单 long etime = System.currentTimeMillis(); - logger.info("取消分配执行时长："+(etime - stime)+"\n"); + System.out.printf("取消分配执行时长："+(etime - stime)+"\n"); } } @@ -2048,7 +2048,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo // } shuaxinPick(pt);//刷新出库单 long etime = System.currentTimeMillis(); - logger.info("取消分配执行时长："+(etime - stime)+"\n"); + System.out.printf("取消分配执行时长："+(etime - stime)+"\n"); } } @@ -2379,7 +2379,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo }else { String bsql=" from BillTypeConfig b where b.billType.id="+pt.getBillType().getId(); - if(ptd.getNewLotInfo()!=null&&ptd.getNewLotInfo().getPropC9()!=null&&!ptd.getNewLotInfo().getPropC9().equals("")) { + if(ptd.getNewLotInfo().getPropC9()!=null&&!ptd.getNewLotInfo().getPropC9().equals("")) { bsql+=" and b.plantCode='"+ptd.getNewLotInfo().getPropC9()+"'"; } List bts=commonDao.findByQuery(bsql); @@ -2483,6 +2483,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo task.setPlanQuantity(allocateQty); task.setPlanQuantityMU(allocateQty); task.setInventoryStatus(inventory.getStatus()); + task.setStrBill10(inventory.getStatuss()); task.setCreateTime(new Date()); task.setWarehouseArea(inventory.getWarehouseArea()); task.setBarCode(inventory.getBarCode()); @@ -2517,7 +2518,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo // interfaceReqManager.wmsSapZhuantaihuichuang(listtask, 0,"",1);//状态回传 // } // }else { -// logger.info(pt.getCode()+"自动分配，无回传状态"); +// System.out.println(pt.getCode()+"自动分配，无回传状态"); // } // // shuaxinPick(pt);//刷新订单 @@ -2566,7 +2567,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo try { commonDao.store(pt); }catch(Exception e){ - logger.info(pt.getId()+"保存失败"); + System.out.println(pt.getId()+"保存失败"); } } } @@ -2688,7 +2689,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo } shuaXinWaveDoc(id);//刷新波次单 }else{ - logger.info("无波次任务!"+"\n"); + System.out.println("无波次任务!"+"\n"); } } @@ -3130,6 +3131,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo task.setCreateTime(new Date()); task.setWarehouseArea(inventory.getWarehouseArea()); task.setBarCode(inventory.getBarCode()); + task.setStrBill10(inventory.getStatuss()); task.setSrcLP(inventory.getLocation().getStock()); if(UserHolder.getUser()!=null) { task.setOperator(UserHolder.getUser().getName()); @@ -3193,10 +3195,10 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo WarehouseArea wa=this.load(WarehouseArea.class, Long.parseLong(obj[0].toString())); if(wa.getName().equals("料箱区")){ createAGV(obj[1].toString(),pickTicketDetailIds, wa.getId(),ave); - logger.info(obj[1]); + System.out.println(obj[1]); }else if(wa.getName().equals("货架区")){ createAGV(obj[1].toString(),pickTicketDetailIds, wa.getId(),ave); - logger.info(obj[1]); + System.out.println(obj[1]); } } @@ -3353,7 +3355,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo } }else { - logger.info("无出库单明细"); + System.out.println("无出库单明细"); } } @@ -3440,7 +3442,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo if(zone.getId()==1763) { //容器返库 if(srcLocation.getStock()!=null) { - logger.info("容器返库1"); + System.out.println("容器返库1"); Stock stock= commonDao.load(Stock.class, srcLocation.getStock().getId()); List tsks=commonDao.findByQuery(" from Task t where 1=1 " + " and t.endRegion='"+t.getEndRegion()+"'" @@ -3453,7 +3455,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo AgvTask agv=commonDao.load(AgvTask.class, t.getAgvTask().getId()); if(agv.getStatus().equals("ATPICK")) { interfaceReqManager.wcsNextPT(agv.getRobotJobId(), s.getLP(), WcsCSDCode.getWcsCSDCode(t.getEndRegion())); - logger.info("容器返库2"); + System.out.println("容器返库2"); } } } @@ -3506,7 +3508,7 @@ public class DefaultAutoAllocator extends DefaultBaseManager implements AutoAllo //未回传的 List tasks2 = commonDao.findByQuery("select p.id from Task p where p.billCode='" + billCode + "' and p.popular=0 " + " and p.pickTicketDetail.pickTicket.id=" + pt.getId()); - logger.info(tasks1.size() + "-----" + tasks2.size()); + System.out.println(tasks1.size() + "-----" + tasks2.size()); // 是否回传SAP，其他出库不出WMS仓，出库完成不用回传，自动生成入库单，入库完成后在回传。 BillType bt = commonDao.load(BillType.class, pt.getBillType().getId()); if (tasks1.size() > 0 && tasks1.size() == tasks2.size()) { diff --git a/src/main/java/com/dev/swms/server/service/receiving/ASNManager.java b/src/main/java/com/dev/swms/server/service/receiving/ASNManager.java index 85e8cc9..3388617 100644 --- a/src/main/java/com/dev/swms/server/service/receiving/ASNManager.java +++ b/src/main/java/com/dev/swms/server/service/receiving/ASNManager.java @@ -31,6 +31,8 @@ public interface ASNManager extends BaseManager{ @Transactional void asnBatch(Map map,String taskCode,Long print); @Transactional + void printOrderAll(List ids,Long print); + @Transactional void storeASN(ASN asn); //任务转移 @Transactional diff --git a/src/main/java/com/dev/swms/server/service/receiving/MoveDocManager.java b/src/main/java/com/dev/swms/server/service/receiving/MoveDocManager.java index 7f6747e..a160b2c 100644 --- a/src/main/java/com/dev/swms/server/service/receiving/MoveDocManager.java +++ b/src/main/java/com/dev/swms/server/service/receiving/MoveDocManager.java @@ -309,6 +309,9 @@ public interface MoveDocManager extends BaseManager { /** 出空托*/ @Transactional void stockCk(List ids); + /** 出空托*/ + @Transactional + void stockCk(List ids,String gzz); /** 呼叫托盘*/ @Transactional void byLibrartTask(String sls,String dlp,String lp,String type,String classification) ; diff --git a/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultASNManager.java b/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultASNManager.java index da22f2a..74de071 100644 --- a/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultASNManager.java +++ b/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultASNManager.java @@ -136,7 +136,7 @@ import com.dev.energy.server.web.security.UserHolder; import com.sun.corba.se.spi.orbutil.threadpool.Work; import com.sun.org.apache.bcel.internal.generic.NEW; import com.thoughtworks.xstream.alias.ClassMapper.Null; -import org.apache.log4j.Logger; + /** * @author dev * @@ -155,7 +155,6 @@ public class DefaultASNManager extends DefaultBaseManager implements ASNManager protected final InterfaceManager interfaceManager; protected final InterfaceReqManager interfaceReqManager; protected final UserManager userManager; - private static Logger logger = Logger.getLogger(DefaultASNManager.class); protected final WmsOperationHisManager wmsOperationHisManager; public DefaultASNManager(ItemManager manager, InventoryManager manager2, BussinessCodeManager manager3, PutawayAllocator putawayAllocator, WarehouseManager manager4, InterfaceLogManager manager5, @@ -257,7 +256,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { } } catch (Exception e) { -// logger.info("----"); +// System.out.println("----"); } asnDetail.setAsn(asn); @@ -616,11 +615,11 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { } // 单一明细收货确认 public BoxLabel confirmReceivingBar(Long asn_detail_id, BoxLabel b,String type,Long loc_id,Long workerId,Long wId,String receive_subset) { - logger.info("---0 "+asn_detail_id); + System.out.println("---0 "+asn_detail_id); ASNDetail asnDetail =this.commonDao.get(ASNDetail.class, asn_detail_id);//b.getAsnDetail(); - logger.info("---1 "); + System.out.println("---1 "); ASN asn = this.commonDao.get(ASN.class, asnDetail.getAsn().getId());//asnDetail.getAsn(); - logger.info("---2 "+asn.getId()); + System.out.println("---2 "+asn.getId()); Location location = commonDao.load(Location.class, loc_id); if(!b.isBeInput()){ Worker worker = this.load(Worker.class, workerId); @@ -639,22 +638,22 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { } commonDao.store(itemKey); - logger.info("---3 "+itemKey.getId()); + System.out.println("---3 "+itemKey.getId()); ReceivedRecord receivedRecord=this.receive(asn, asnDetail, itemKey, b, location, worker); commonDao.store(receivedRecord); - logger.info("---4 "); + System.out.println("---4 "); b.setBeInput(Boolean.TRUE); b.setReceivedRecordId(receivedRecord.getId()); b.setReceiveDate(new Date()); b.setWorker(worker); this.commonDao.store(b); - logger.info("---5 "+receivedRecord.getId()); + System.out.println("---5 "+receivedRecord.getId()); // if(itemKey.getLotInfo()!=null){ // LotInfo newLot=itemKey.getLotInfo(); // newLot.setPropL3(receivedRecord.getId()); // itemKey.setLotInfo(newLot); // this.commonDao.store(itemKey); -// logger.info(itemKey.getId()+"==="+itemKey.getLotInfo().getPropC9()); +// System.out.println(itemKey.getId()+"==="+itemKey.getLotInfo().getPropC9()); // } } return b; @@ -744,9 +743,9 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { String aString=jsonStrs.toString().replace(" ", ""); JSONObject jsonStr = JSONObject.fromObject(aString); jsonArray = JSONArray.fromObject(jsonStr.getString("header_list")); - logger.info("解密后:"+jsonArray); + System.out.println("解密后:"+jsonArray); } catch (Exception e) { - logger.info("错误"+e.getMessage()); + System.out.println("错误"+e.getMessage()); } return jsonArray; } @@ -1192,7 +1191,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { commonDao.store(moveDoc); // } for (ReceivedRecord record : asn.getReceivedRecords()) { - logger.info(record.getId()); + System.out.println(record.getId()); // 直接收货上架的记录不再加入上架计划明细A if (!LocationType.RECEIVE.equals(record.getLocation().getType())|| record.getWarehouseArea().getId()==1766) { @@ -1790,7 +1789,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { new String[] { "id"},new Object[] {WarehouseHolder.getWarehouse().getId()}); Location l =ls.get(0); for (int i = 1; i invs =commonDao.findByQuery(" from Inventory i where i.location.stock.id="+stockId); double saleTime=0D; @@ -2725,7 +2724,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { s.setSaleTime((int)Math.ceil(saleTime)); s.setStatus(WarehouseAreaStatus.OCCUPY); commonDao.store(s); - logger.info("热度值："+s.getSaleTime()); + System.out.println("热度值："+s.getSaleTime()); } @@ -3380,7 +3379,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { ReceivedRecord rr=this.load(ReceivedRecord.class, id); ASNDetail ad=rr.getAsnDetail(); String param=""; - logger.info(param); + System.out.println(param); // interfaceManager.doSslPost("http://192.168.109.12/wstoptst/ws/r/awsp920",param); interfaceManager.doSslPost("",param); } @@ -3410,7 +3409,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { @Override public List scanASN(JSONArray jsonArray) { // TODO Auto-generated method stub - logger.info("jsonArray:"+jsonArray.getJSONObject(0).getString("wms_order_no")); + System.out.println("jsonArray:"+jsonArray.getJSONObject(0).getString("wms_order_no")); ASN asn=new ASN(); asn.setCode(jsonArray.getJSONObject(0).getString("wms_order_no")); @@ -3638,7 +3637,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { LocationStorage ls =this.load(LocationStorage.class, LocationStorageId);//工作站 for(int i=0;i SeedWalls = commonDao.findByQuery(" from SeedWall s where s.locationStorage.id=:id ", new String[] { "id"},new Object[] {ls.getId()}); @@ -4563,7 +4562,7 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { // obj.put("propC1",sdf.format(new Date())); obj.put("propC1",ad.getLotInfo().getPropC1()); obj.put("workName",UserHolder.getUser().getName()); - logger.info(obj.toString()); + System.out.println(obj.toString()); PrintTask pt=new PrintTask(); pt.setType("3"); pt.setStatus("0"); @@ -4578,7 +4577,54 @@ public void addASNDetail(Long id,ASNDetail asnDetail) { } } + @Override + public void printOrderAll(List ids,Long print){ + SimpleDateFormat sdf=new SimpleDateFormat("yyyyMMdd"); + double allocatedQuantity = 0; + for (Long id: ids) { + ASN asn=commonDao.load(ASN.class, id); + List ads=commonDao.findByQuery(" from ASNDetail ad where ad.asn.id=" + +id+" and ad.expectedQuantity>0"); + for(ASNDetail ad:ads) { + Long quantity =1L; + Item item=commonDao.load(Item.class, ad.getItem().getId()); + PrintEquipment pe=commonDao.load(PrintEquipment.class, print); + String qrcode="QAR/"+asn.getRelatedBill1()+"/"+ad.getStrBill8()+"/"+item.getCode()+"/"+item.getUnit(); + if(ad.getStrBill2()!=null&&!ad.getStrBill2().equals("")) { + qrcode+="/"+ad.getStrBill2()+"/"+sdf.format(new Date()); + }else { + qrcode+="//"+sdf.format(new Date()); + } + JSONObject obj=new JSONObject(); + obj.put("itemName", item.getName()); + obj.put("unit", item.getUnit()); + obj.put("quantity", ad.getExpectedQtyOfMasterUnit()); + obj.put("taskCode", asn.getRelatedBill1()); + obj.put("qrcode", qrcode); + obj.put("barCode", ad.getStrBill2()==null?"":ad.getStrBill2()); + obj.put("loc", ad.getLotInfo().getPropC2()); + obj.put("itemCode", item.getCode()); +// obj.put("propC1",sdf.format(new Date())); + obj.put("propC1",ad.getLotInfo().getPropC1()); + obj.put("workName",UserHolder.getUser().getName()); + System.out.println(obj.toString()); + PrintTask pt=new PrintTask(); + pt.setType("3"); + pt.setStatus("0"); + pt.setQuantity(quantity); + pt.setContent(obj.toString()); + pt.setCreateName(UserHolder.getUser().getName()); + pt.setCreateDate(new Date()); + pt.setMac(pe.getMac()); + pt.setPrintName(pe.getPrintName()); + pt.setPrintTitle(asn.getRelatedBill1()+"/"+item.getCode()); + commonDao.store(pt); + } + + } + + } public boolean checkLoc(ASNDetail ad ,long stockId){ boolean cheak=true; diff --git a/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultMoveDocManager.java b/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultMoveDocManager.java index 01e5330..4b88316 100644 --- a/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultMoveDocManager.java +++ b/src/main/java/com/dev/swms/server/service/receiving/pojo/DefaultMoveDocManager.java @@ -98,7 +98,7 @@ import com.dev.energy.server.service.pojo.DefaultBaseManager; import com.dev.energy.server.util.DateUtil; import com.dev.energy.server.util.LocalizedMessage; import com.dev.energy.server.web.security.UserHolder; -import org.apache.log4j.Logger; + public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDocManager { protected final InventoryManager inventoryManager; protected final PutawayAllocator putawayAllocator; @@ -111,7 +111,6 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc protected final LocationManager locationManager; protected final AgvTaskManager agvTaskManager; - private static Logger logger = Logger.getLogger(DefaultMoveDocManager.class); public DefaultMoveDocManager(InventoryManager manager, PutawayAllocator allocator, BussinessCodeManager manager2, InterfaceLogManager manager3, ItemManager manager4, AutoAllocator autoAllocator, InterfaceManager interfaceManager, InterfaceReqManager interfaceReqManager, @@ -1096,7 +1095,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc commonDao.store(dstloc); } //加急订单生成出库任务 -// logger.info(adlist1.size()); +// System.out.println(adlist1.size()); if(adlist1.size()>0) { for(Long asnid:adlist1) { autoAllocator.addPickTicketTask(asnid, userId); @@ -1165,7 +1164,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc .findByQuery("select inv.itemKey.item.id from Inventory inv where inv.qtyOfMasterPack>0 and inv.location.id=" + deslocation.getId()); if (invs1.size() >= 1) { - logger.info(invs1.get(0) + "-------" + item.getId()); + System.out.println(invs1.get(0) + "-------" + item.getId()); if (invs1.get(0).intValue() == item.getId().intValue()) { } else { @@ -1346,10 +1345,10 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc + md.getId() + " and m.planQuantityOfMU=m.moveQuantity"); md.setAccomplish(mdids.size()); commonDao.store(md); -// logger.info("1----"); +// System.out.println("1----"); if (detail.getReceivedRecordId() != null) { ReceivedRecord r = commonDao.load(ReceivedRecord.class, detail.getReceivedRecordId()); -// logger.info("2----"); +// System.out.println("2----"); if (r != null) { if (r.getSrcLP() != null) { Stock s = commonDao.load(Stock.class, r.getSrcLP().getId()); @@ -1360,7 +1359,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc r.setSrcLPCode(s.getLP()); commonDao.store(r); } -// logger.info("3----"); +// System.out.println("3----"); inventoryManager.createReceivingInventory(r,deslocation); } } @@ -1671,7 +1670,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc for (Long id : ids) { MoveDoc moveDoc = commonDao.load(MoveDoc.class, id); interfaceManager.doSslPost("http://192.168.109.12/wtoptst/ws/r/awsp920", ""); - logger.info(""); + System.out.println(""); } } @@ -2288,12 +2287,15 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc srcInv.setStatuss("T"); } commonDao.store(srcInv); + locst.setStatus(WarehouseAreaStatus.OCCUPY); + commonDao.store(locst); } + } } inventoryManager.addInventoryLog(InventoryLogType.RECEIVING, 1, ad.getAsn().getRelatedBill1(), - rd.getLocation(), (rd.getSrcLP() == null ? null : rd.getSrcLP().getLP()), rd.getItemKey(), + srcInv.getLocation(), (rd.getSrcLP() == null ? null : rd.getSrcLP().getLP()), rd.getItemKey(), rd.getReceiveDate(), null, rd.getReceivedQuantity(), null, srcInv == null ? "" : srcInv.getStatus(), srcInv == null ? 0L : srcInv.getId(), null, asn.getBillType(), 0, rd.getBarCode(), null,asn.getSourceType()); @@ -2319,13 +2321,13 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc List list=new ArrayList(); list.add(locationStorage.getId()); locationManager.kuwei(list);*/ - logger.info(st.getLP()+"有上架信息"); + System.out.println(st.getLP()+"有上架信息"); rd.setBeMoved(Boolean.TRUE); this.commonDao.store(rd); } }else if(inventorys.size()>0) { - logger.info(st.getLP()+"有库存信息"); + System.out.println(st.getLP()+"有库存信息"); locationStorage.setStatus(WarehouseAreaStatus.OCCUPY); this.commonDao.store(locationStorage); // st.setLocationStorage(locationStorage); @@ -2448,7 +2450,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc } String cs="01"; String lsString=as+"-"+bs+"-"+cs; - logger.info("行："+as+" ,列："+bs+ ";层" +cs); + System.out.println("行："+as+" ,列："+bs+ ";层" +cs); String cd="3"; if(lStorage.getGdType().equals("1")) { cd="'1','2','3'"; @@ -2921,10 +2923,10 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc t.setLibraryTask(tprw.get(0)); t.setAgvStatus(2); this.commonDao.store(t); -// logger.info("已存在：" + st.getLP()); +// System.out.println("已存在：" + st.getLP()); continue; } else { -// logger.info("不存在：" + st.getLP()); +// System.out.println("不存在：" + st.getLP()); } // List librarys = this.commonDao.findByQuery(hql); // if (librarys.size() > 0) { @@ -3315,7 +3317,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc if(t.getPickTicketDetail().getSOI()!=null) { relatedBill4="2"; } - logger.info(st.getLP()); + System.out.println(st.getLP()); LocationStorage ls = st.getLocationStorage(); String hql = "from LibraryTask t where t.status='OPEN' and t.fromCellCode='" + ls.getCode() + "' and t.type=" + LibraryTaskType.ck; @@ -3661,10 +3663,10 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc // hql += " and t.toCellCode in ('"+endRegion+"')"; List tprw = this.commonDao.findByQuery(tp_hql); if (tprw.size() > 0) { - logger.info("已有任务存在：" + st.getLP()); + System.out.println("已有任务存在：" + st.getLP()); return null; } else { - logger.info("新任务：" + st.getLP()); + System.out.println("新任务：" + st.getLP()); } String gzz = gzzCode; @@ -3711,10 +3713,10 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc hql += " and t.toCellCode in ('"+endRegion+"')"; List tprw = this.commonDao.findByQuery(tp_hql); if (tprw.size() > 0) { - logger.info("已存在：" + st.getLP()); + System.out.println("已存在：" + st.getLP()); return null; } else { - logger.info("不存在：" + st.getLP()); + System.out.println("不存在：" + st.getLP()); } String gzz = gzzCode; @@ -3858,7 +3860,17 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc }*/ } } - + public void stockCk(List ids,String gzz) { +// int gzz=602; + // TODO 自动生成的方法存根 + for (Long id : ids) { + Inventory inventory=this.load(Inventory.class, id); + inventory.setQueuedQuantity(inventory.getQuantity()); + commonDao.store(inventory); + stockCk(inventory,gzz+""); + + } + } @Override public void byLibrartTask(String sls, String dlp) { // TODO 自动生成的方存根 @@ -3873,7 +3885,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc LocationStorage ls1=stock.getLocationStorage(); LocationStorage ls2=null; // if (stock.getRdType().equals(ls1.getRdType())) { -// logger.info("无需移位"); +// System.out.println("无需移位"); // continue; // }else { ls2 = findLocationStorageFor7(stock); @@ -3947,12 +3959,12 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc public void stockPickTicket(List ids) { //创建一个 Calendar 实例 Calendar calendar = Calendar.getInstance();//获取当前日期 - Date currentDate = new Date();logger.info("当前日期:"+ currentDate); + Date currentDate = new Date();System.out.println("当前日期:"+ currentDate); //将 Calendar 设置为当前日期 calendar.setTime(currentDate);//为 Calendar 增加一天 calendar.add(Calendar.DATE,1);//获取增加一天后的日期 Date nextDate = calendar.getTime(); - logger.info("增加一天后的日期: " + nextDate); + System.out.print("增加一天后的日期: " + nextDate); SimpleDateFormat sdf =new SimpleDateFormat("yyyy-MM-dd"); String sql =" from PickTicketDetail ptd where 1=1 "; sql+=" and CONVERT(varchar(100),ptd.pickTicket.orderDate, 23)='"+sdf.format(nextDate)+"'" @@ -4061,7 +4073,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc //获取目标点 ls2 = findLocationStorageFor7(stock); if (ls2!=null) { - logger.info("起点："+ls1.getName()+" 目标点："+ls2.getName()+"----"+stock.getLP()); + System.out.println("起点："+ls1.getName()+" 目标点："+ls2.getName()+"----"+stock.getLP()); try { LibraryTask t2 = interfaceReqManager.storeLibraryTask(LibraryTaskType.byzl, LibraryTaskType.yk, stock.getLP(), ls1.getName(),ls2.getName(), "", 1, @@ -4083,7 +4095,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc } }else { - logger.info("无库存记录"); + System.out.println("无库存记录"); } } @@ -4141,8 +4153,6 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc + " and l.type='存储点' and l.status='" + WarehouseAreaStatus.FREE + "' " + " and l.disabled=false and l.id not in("+sql4+")"; - - String px_sql = " order by l.gdType asc "; //库位高度 if (st.getGdType().equals(TranType.gd_d)) { sql += " and 1=1"; @@ -4152,9 +4162,16 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc sql += " and l.gdType =3"; } if (st!=null) { - /**容器已经在仓库内 只能 做单巷道移位 查询同巷道库位*/ - sql+=" and l.agvZone='"+st.getAgvZone()+"'"; + /**容器已经在仓库内 只能 做单巷道移位 查询同巷道库位*/ + sql+=" and l.agvZone='"+st.getAgvZone()+"'"; } + String px_sql = " order by l.gdType asc,l.sqType asc "; + //深浅位 +// if (st.getRdType().equals(TranType.rd_g)) { +// px_sql += " ,l.sqType desc"; +// } else { +// px_sql += " ,l.sqType asc"; +// } //判断热度值 if (st.getRdType().equals(TranType.rd_d)) { px_sql += " ,l.rdType desc"; @@ -4163,12 +4180,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc } else if (st.getRdType().equals(TranType.rd_g)) { px_sql += " , l.rdType asc"; } - //深浅位 - if (st.getRdType().equals(TranType.rd_g)) { - px_sql += " ,l.sqType desc"; - } else { - px_sql += " ,l.sqType asc"; - } + px_sql += " ,substring(l.code,4,2) asc,substring(l.code,7,2) desc "; List ls =new ArrayList(); String hql1=""; @@ -4209,17 +4221,17 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc public void autoInLibraryTask() { //查询入库任务 List libraryTaskView1s2 = commonDao.findByQuery(" from LibraryTaskView1 ltask " - + " where ltask.classification='入库' "); + + " where ltask.classification in ('入库','入空托') "); for(LibraryTaskView1 libraryTaskView2 : libraryTaskView1s2) { List libraryTasks2 = commonDao.findByQuery(" from LibraryTask ltask where " - + " ltask.status='"+STATUS.UNAUDITED+"' and ltask.classification='入库' " + + " ltask.status='"+STATUS.UNAUDITED+"' and ltask.classification in ('入库','入空托') " + " and ltask.relationCode='"+libraryTaskView2.getRelationCode()+"'" + " order by ltask.seq asc"); if(libraryTasks2.size()>0) { LibraryTask libraryTask=libraryTasks2.get(0); if(libraryTask.getClassification()!=null&& - libraryTask.getClassification().equals("入库")) { + (libraryTask.getClassification().equals("入库")||libraryTask.getClassification().equals("入空托"))) { for (int i = 0; i < libraryTasks2.size(); i++) { LibraryTask libraryTask1=libraryTasks2.get(i); @@ -4516,7 +4528,8 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc } //下发出库、移库任务 if(libraryTask.getClassification()!=null&& - !libraryTask.getClassification().equals("入库")) { + !libraryTask.getClassification().equals("入库")&& + !libraryTask.getClassification().equals("入空托")) { //查询托盘是否有正在执行的任务 List lids= commonDao.findByQuery(" from LibraryTask ltask where " + " ltask.status in('ATCALL','ATWAIT','ATWORK','ATPICK') " @@ -4773,7 +4786,8 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc } else if(libraryTask.getClassification()!=null&& - libraryTask.getClassification().equals("入库")) { + (libraryTask.getClassification().equals("入库") + ||libraryTask.getClassification().equals("入空托"))) { boolean flag = agvTaskManager.sendLibraryTask(libraryTask);//下发任务 if (flag) { @@ -5314,7 +5328,7 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc } } - + public synchronized List autoOutLibraryTask3(int y,int y1){ //任务组； @@ -5322,31 +5336,17 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc //跳除巷道循环 boolean xh=false; //出库任务按巷道下发，每个巷道只有一个任务执行 - - -// List libraryTaskView1s = commonDao.findByQuery(" from LibraryTaskView1 ltask where ltask.agvZone='"+y+"'" -// + " and ltask.classification not in('入空托','入库') and ltask.toCellCode='"+y1+"'" -// + " order by ltask.relatedBill4 desc,ltask.relationCode asc "); -// for (LibraryTaskView1 libraryTaskView1 : libraryTaskView1s) { //查询关联任务 //查询移库和出库的任务 List libraryTasks = commonDao.findByQuery(" from LibraryTask ltask where " + " ltask.status='"+STATUS.UNAUDITED+"' and ltask.relatedBill5='"+y+"' " -// + " and ltask.relationCode='"+libraryTaskView1.getRelationCode()+"'" + " and ltask.classification not in('入空托','入库') and ltask.toCellCode='"+y1+"'" + " order by ltask.relatedBill4 desc,ltask.relationCode asc,ltask.seq asc"); -// for(libraryTasks.size()>0) { -// LibraryTask libraryTask=libraryTasks.get(0); for(LibraryTask libraryTask:libraryTasks) { //查询任务对应的容器 List sls= commonDao.findByQuery(" From Stock s where s.LP='"+libraryTask.getBarcode()+"' "); //查询出库任务起点 -// List locst=commonDao.findByQuery(" from LocationStorage l where l.code='"+libraryTask.getFromCellCode()+"'" -// + " and l.warehouseArea.id=1766 "); -// if(locst.size()>0) { -// LocationStorage lsa=locst.get(0); - LocationStorage lssds=null;//出库托盘的浅位单浅位点位 if(sls.size()>0&&sls.get(0).getLocationStorage()!=null) { Stock st=sls.get(0); @@ -5429,8 +5429,6 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc seq=ltz.getSeq()+1; relationCode=ltz.getRelationCode(); } - - // 判断浅位有没有托盘 List sts1 = this.commonDao .findByQuery("from Stock s where s.locationStorage.sqType=1 and s.locationStorage.relevanceCode='" @@ -5462,12 +5460,10 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc commonDao.store(libraryTask); listTasks.add(libraryTask); xh=true; - break; +// break; } } } else { - - //浅库位托盘没任务 LocationStorage lq2 ; // 搬运到其他 @@ -5517,7 +5513,8 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc libraryTask.setRelationCode(t1.getRelationCode());// commonDao.store(libraryTask); listTasks.add(libraryTask); - + xh=true; +// break; }else { //目标位置浅位托盘，没有任务，产生移位到深位的任务，再将移位托盘放在浅位。 @@ -5540,7 +5537,8 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc libraryTask.setRelationCode(t2.getRelationCode());// commonDao.store(libraryTask); listTasks.add(libraryTask); - + xh=true; +// break; } }else { @@ -5556,7 +5554,8 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc libraryTask.setRelationCode(t1.getRelationCode());// commonDao.store(libraryTask); listTasks.add(libraryTask); - + xh=true; +// break; // } }else { @@ -5571,20 +5570,13 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc libraryTask.setRelationCode(t1.getRelationCode()); commonDao.store(libraryTask); listTasks.add(libraryTask); + xh=true; +// break; } } } else { - //浅位直接下发任务 -// boolean flag = agvTaskManager.sendLibraryTask(libraryTask);//下发任务 -// interfaceManager.storeInterfaceLog("立库出库任务", libraryTask.getId()+libraryTask.getBarcode(), "wms", "library", flag+"", -// interfaceReqManager.jsonLibrayTask(libraryTask)); -// -// if (flag) { -// libraryTask.setBeIssue(1); -// libraryTask.setStatus(STATUS.ATCALL);//料箱到传送带 -// commonDao.store(libraryTask); -// } + xh=true; listTasks.add(libraryTask); break; @@ -5599,7 +5591,6 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc } } -// } return listTasks; } //下发WCS立库任务 @@ -5607,8 +5598,8 @@ public class DefaultMoveDocManager extends DefaultBaseManager implements MoveDoc for(LibraryTask slt:listTasks) { if(slt.getStatus().equals(STATUS.UNAUDITED)) { boolean flag2 = agvTaskManager.sendLibraryTask(slt);//下发任务 - interfaceManager.storeInterfaceLog("立库出库任务", slt.getId()+slt.getBarcode(), "wms", "library", flag2+"", - interfaceReqManager.jsonLibrayTask(slt)); +// interfaceManager.storeInterfaceLog("立库出库任务", slt.getId()+slt.getBarcode(), "wms", "library", flag2+"", +// interfaceReqManager.jsonLibrayTask(slt)); if (flag2) { slt.setStatus(STATUS.ATCALL);//料箱到传送带 slt.setBeIssue(1); diff --git a/src/main/java/com/dev/swms/server/service/shipping/pojo/DefaultPickTicketManager.java b/src/main/java/com/dev/swms/server/service/shipping/pojo/DefaultPickTicketManager.java index 527171e..7db55b8 100644 --- a/src/main/java/com/dev/swms/server/service/shipping/pojo/DefaultPickTicketManager.java +++ b/src/main/java/com/dev/swms/server/service/shipping/pojo/DefaultPickTicketManager.java @@ -160,7 +160,6 @@ import com.mysql.jdbc.Connection; import com.mysql.jdbc.Statement; import com.sun.mail.imap.protocol.Status; -import org.apache.log4j.Logger; /** * @author dev * @@ -181,7 +180,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick protected final String lotparam = "inventory.itemKeyInventory.itemKey.lotInfo."; protected final MoveDocManager moveDocManager; protected final CountPlanManager countPlanManager; - private static Logger logger = Logger.getLogger(DefaultPickTicketManager.class); + public DefaultPickTicketManager(ItemManager manager, InventoryManager manager2, AutoAllocator autoAllocator, BussinessCodeManager manager3, InterfaceLogManager manager4, JdbcManager jdbcManager, InterfaceManager interfaceManager, InterfaceReqManager interfaceReqManager, AgvTaskManager agvTaskManager, @@ -493,7 +492,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick try { commonDao.store(pickTicket); }catch (Exception e) { -// logger.info("pickTicket保存"+e.getMessage()); +// System.out.println("pickTicket保存"+e.getMessage()); } }else { commonDao.delete(pickTicket); @@ -1295,7 +1294,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick interfaceReqManager.wmsSapZhuantaihuichuang(listtask, 0,"",1);//状态回传 } }else { - logger.info(pt.getCode()+"自动分配，无回传状态"); + System.out.println(pt.getCode()+"自动分配，无回传状态"); } shuaxinPick(pt);//刷新订单 @@ -2394,7 +2393,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick log.getStorageDate(), log.getSOI(), task.getWarehouseArea(), task.getBarCode()); inventory.setQuantity(DoubleUtils.format4F(inventory.getQuantity() + movedQuantity)); inventory.setQtyOfMasterPack(DoubleUtils.format4F(inventory.getQuantity())); - logger.info(inventory.getQuantity()); + System.out.println(inventory.getQuantity()); if (inventory.isNew()) { ik.getInventories().add(inventory); } @@ -2878,7 +2877,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick task.setPlanQuantityMU(allocateQty); task.setInventoryStatus(inventory.getStatus()); task.setCreateTime(new Date()); - + task.setStrBill10(inventory.getStatuss()); task.setWarehouseArea(inventory.getLocation().getZone()); task.setBarCode(inventory.getBarCode()); task.setSrcLP(inventory.getLocation().getStock()); @@ -3412,7 +3411,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick PickTicketDetail pd = commonDao.load(PickTicketDetail.class, id); String a = interfaceUtil.aa(pd); interfaceUtil.doSslPost("http://192.168.1.171:80/trilink/mes/outboundResp", a); - // logger.info("发送数据："+a); + // System.out.println("发送数据："+a); } } @@ -3717,7 +3716,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick int y = jdbcManager.receiveQDCK(code); int i = jdbcManager.receiveQDCKD(code); if (i > 0) { - logger.info("成功"); + System.out.println("成功"); } } @@ -3727,7 +3726,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick PickTicket pickTicket = commonDao.load(PickTicket.class, id); String param = ""; interfaceManager.doSslPost("", param); - logger.info(param); + System.out.println(param); } } @@ -3736,7 +3735,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick for (Long id : ids) { // String str=itemManager.synchroPick(id); String param = ""; - logger.info(param); + System.out.println(param); interfaceManager.doSslPost("", param); } } @@ -3744,7 +3743,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick public void synchroItem(List ids) { for (Long id : ids) { String param = ""; - logger.info(param); + System.out.println(param); interfaceManager.doSslPost("", param); } } @@ -3755,7 +3754,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick Task t = this.load(Task.class, id); PickTicketDetail ptd = t.getPickTicketDetail(); String param = ""; - logger.info(param); + System.out.println(param); interfaceManager.doSslPost("", param); } } @@ -4140,6 +4139,11 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick }else { invsql += " AND inv.itemKey.lotInfo.propD2 is null "; } + if(task.getStrBill10() != null && task.getStrBill10().length() > 0) { + invsql += " AND inv.statuss='"+task.getStrBill10()+"' "; + }else { + invsql += " AND (inv.statuss is null or inv.statuss='' )"; + } } invsql+=" order by inv.queuedQuantity desc "; List invs = commonDao.findByQuery(invsql); @@ -4172,7 +4176,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick } } if (srcInv == null) { - logger.info("未找到库存记录!"); + System.out.println("未找到库存记录!"); } else { task.setDstLoc(dstLoc); task.setDstLP(dstLP); @@ -4428,7 +4432,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick //共拣货数 List tasks2 = commonDao.findByQuery("select p.id from Task p where p.billCode='" + task.getBillCode() + "' and p.popular<=0 " + " and p.planQuantity>0 and p.pickTicketDetail.pickTicket.id=" + pt.getId()); -// logger.info(tasks1.size() + "-----" + tasks2.size()); +// System.out.println(tasks1.size() + "-----" + tasks2.size()); // 是否回传SAP，其他出库不出WMS仓，出库完成不用回传，自动生成入库单，入库完成后在回传。 if (tasks1.size() > 0 && tasks1.size() == tasks2.size()) { if (bt.getCode().equals("YINVENTORY")) { @@ -4544,6 +4548,15 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick newTask.setWorker2(t.getWorker2()); newTask.setDateBill1(t.getDateBill1()); newTask.setStrBill1(t.getStrBill1()); + newTask.setStrBill2(t.getStrBill2()); + newTask.setStrBill3(t.getStrBill3()); + newTask.setStrBill4(t.getStrBill4()); + newTask.setStrBill5(t.getStrBill5()); + newTask.setStrBill6(t.getStrBill6()); + newTask.setStrBill7(t.getStrBill7()); + newTask.setStrBill8(t.getStrBill8()); + newTask.setStrBill9(t.getStrBill9()); + newTask.setStrBill10(t.getStrBill10()); newTask.setStrBill3(t.getStrBill3()); commonDao.store(newTask); t.setPlanQuantity(pickedQuantity); @@ -4635,7 +4648,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick agvTask.setStatus(STATUS.RECEIVED); agvTask.setMovedQuantityMU(agvTask.getPlanQuantity()); commonDao.store(agvTask); - logger.info(agvTask.getRobotJobId() + "返库成功~" + "\n"); + System.out.printf(agvTask.getRobotJobId() + "返库成功~" + "\n"); } } @@ -4695,7 +4708,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick for (TaskLog tl : TaskLogs) { // 查询需要出库的库存 if (tl.getMovedQuantity() == tl.getShipQuantity()) { - logger.info("已发运!"); + System.out.println("已发运!"); } else { ItemKey ik = this.load(ItemKey.class, tl.getItemKey().getId()); Item item = this.load(Item.class, ik.getItem().getId()); @@ -4795,7 +4808,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick for (TaskLog tl : TaskLogs) { // 查询需要出库的库存 if (tl.getMovedQuantity() == tl.getShipQuantity()) { - logger.info("已发运!"); + System.out.println("已发运!"); } else { ItemKey ik = this.load(ItemKey.class, tl.getItemKey().getId()); Item item = this.load(Item.class, ik.getItem().getId()); @@ -4873,7 +4886,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick for (TaskLog tl : TaskLogs) { // 查询需要出库的库存 if (tl.getMovedQuantity() == tl.getShipQuantity()) { - logger.info("已发运!"); + System.out.println("已发运!"); } else { ItemKey ik = this.load(ItemKey.class, tl.getItemKey().getId()); Item item = this.load(Item.class, ik.getItem().getId()); @@ -5037,7 +5050,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick // } // } // long etime2 = System.currentTimeMillis(); -// logger.infof("拍灯取料时间：" + (etime2 - stime2)); +// System.out.printf("拍灯取料时间：" + (etime2 - stime2)); // } catch (Exception e) { // message = e.getMessage(); // } @@ -5083,7 +5096,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick } else if (pt.getShipToName().equals("ONLINE_STATION010")) { agv = "AGV10"; } - logger.info("AGV请求：" + sdf.format(new Date()) + "\n"); + System.out.printf("AGV请求：" + sdf.format(new Date()) + "\n"); new DefaultWDTManager(pt.getCode(), agv, 0, Integer.parseInt(pt.getExecutePlanNo())); String result = DefaultClient.bodys; JSONObject json = JSONObject.fromObject(result); @@ -5092,9 +5105,9 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick String message = json.has("message") ? json.getString("message") : ""; jdbcManager.saveExceptionLog(pt.getCode() + "," + message + "," + pt.getExecutePlanNo()); } - logger.info("旺店通反馈：" + sdf.format(new Date()) + "\n"); + System.out.printf("旺店通反馈：" + sdf.format(new Date()) + "\n"); long etime1 = System.currentTimeMillis(); - logger.info("出库回传面单打印：" + (etime1 - stime1) + "\n"); + System.out.printf("出库回传面单打印：" + (etime1 - stime1) + "\n"); } @Override @@ -5382,7 +5395,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick for (PickTicket pt : PickTickets) { i++; ShipConfirm(pt.getId(), 1080); - logger.info(i); + System.out.println(i); } } @@ -5522,7 +5535,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick jsonobj.put("ReturnSet", ReturnSet); } - logger.info(jsonobj.toString()); + System.out.println(jsonobj.toString()); } @@ -5864,7 +5877,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick public void huichuandItems(List ids) { // ids =commonDao.findByQuery("select id from Item i where i.volume>0 "); - logger.info("行数" + ids.size()); + System.out.println("行数" + ids.size()); huichuanItems(ids); } @@ -5968,7 +5981,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick public void addasn(List ids) { - logger.info("生成入库单"); + System.out.println("生成入库单"); for (Long id : ids) { PickTicket pickTicket = commonDao.load(PickTicket.class, id); if (pickTicket.getSourceType().equals("311")||pickTicket.getSourceType().equals("301")) { @@ -5979,7 +5992,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick boolean adnnd = false; int i = 1; ASN asn = null; -// logger.info(tas.size() + "----拣货行数"); +// System.out.println(tas.size() + "----拣货行数"); List list = new ArrayList(); for (Task t : tas) { PickTicketDetail ptd = commonDao.load(PickTicketDetail.class, t.getPickTicketDetail().getId()); @@ -6009,7 +6022,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick commonDao.store(pickTicket); list.add(pickTicket.getSourceId()); i = 1; - logger.info("创建成功" + t.getBillCode()); + System.out.println("创建成功" + t.getBillCode()); } if (asn != null) { ASNDetail ad = EntityFactory.getEntity(ASNDetail.class); @@ -6056,7 +6069,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick commonDao.store(ad); commonDao.store(asn); } else { - logger.info("无入库单信息"); + System.out.println("无入库单信息"); } } } else { @@ -7020,13 +7033,13 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick if(workerId>0) { Worker w = commonDao.load(Worker.class, workerId); task.setWorker1(w); - if(task.getAgvStatus()==0) { - task.setAgvStatus(1); - } } if(targetArea!=null&&targetArea.length()>0) { task.setEndRegion(targetArea); } + if(task.getAgvStatus()==0) { + task.setAgvStatus(1); + } commonDao.store(task); wmsOperationHisManager.storeOperationHis(task.getId(), task.getBillCode(), null, "", "拣货界面", "重新指定拣货人", null, null, 0, 0, 0, 0, "", "WMS"); @@ -7091,7 +7104,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick // 查询波次出库单 // List waveDocs = commonDao // .findByQuery("select w.id from WaveDoc w where w.status='PICKUP'"); -// logger.info("工作站拣货任务下发：" + swName + " 开始分配播种格,剩余" + blank); +// System.out.println("工作站拣货任务下发：" + swName + " 开始分配播种格,剩余" + blank); if (true) { // 查询所有含有task.agvStatus=1(未下发到工作站) 的子工单 List billListObjects = commonDao.findByQuery("select t.billCode from " @@ -7100,7 +7113,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick + " order by max(t.pickTicketDetail.SOI) desc,min(t.createTime) ,t.billCode "); String billCode = ""; -// logger.info("任务数"+billListObjects.size()); +// System.out.println("任务数"+billListObjects.size()); if (billListObjects.size() > 0) { for (Object obj : billListObjects) { List taskLists = commonDao @@ -7114,7 +7127,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick Location srcloc=commonDao.load(Location.class, tr.getSrcLoc().getId()); if(srcloc.getZone().getId()==1765L) { for(Object ogj:itemtypes) { -// logger.info("大件+"+ogj.toString()); +// System.out.println("大件+"+ogj.toString()); if(ogj!=null&&ogj.toString().equals("大件")) { dj=true; } @@ -7191,7 +7204,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick List agvTasks = commonDao.findByQuery(" from AgvTask agvTask " + " where agvTask.beIssue=true" + " and agvTask.status='" + STATUS.ATWAIT + "' " + " and agvTask.type='AGV上料'"); for (AgvTask agvTask : agvTasks) { - logger.info("AGV任务重送:" + agvTask.getRobotJobId()); + System.out.println("AGV任务重送:" + agvTask.getRobotJobId()); agvTaskManager.sendAgvTask(agvTask); } } @@ -7225,7 +7238,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick // } else { barcode += "/" + ymd.format(new Date()); // } - logger.info(barcode); + System.out.println(barcode); macs = printEquipment == null ? "" : printEquipment.getMac(); printName = printEquipment == null ? "" : printEquipment.getPrintName(); BillType bt = commonDao.load(BillType.class, pt.getBillType().getId()); @@ -7330,7 +7343,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick // 查询波次出库单 List waveDocs = commonDao .findByQuery("select w.id from WaveDoc w where w.status='PICKUP'"); - logger.info("工作站拣货任务下发：" + swName + " 开始分配播种格,剩余" + blank); + System.out.println("工作站拣货任务下发：" + swName + " 开始分配播种格,剩余" + blank); if (true) { // 查询所有含有task.agvStatus=1(未下发到工作站) 的子工单 List billListObjects = commonDao.findByQuery("select t.billCode from " @@ -7389,13 +7402,13 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick sql += " order by cr.count_Code,l.CODE,cr.NEED_COUNT "; Query query = session.createSQLQuery(sql); List objs = query.list();// commonDao.findByQuery(sql); - logger.info("盘点查询----" + objs.size()); + System.out.println("盘点查询----" + objs.size()); if (objs.size() > 0) { CountPlan c = null; Worker w = commonDao.load(Worker.class, userId); for (Object id : objs) { CountRecord cr = commonDao.load(CountRecord.class, Long.parseLong(id.toString())); - logger.info("无盘点明细"); + System.out.println("无盘点明细"); c = cr.getCountPlan(); cr.setCountQuantity(cr.getQuantity()); cr.setNeedCount(true); @@ -7416,7 +7429,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick } } } catch (Exception e) { - logger.info("盘点返库异常" + e.getMessage()); + System.out.println("盘点返库异常" + e.getMessage()); } finally { session.close(); } @@ -7458,7 +7471,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick public void addasnTask(List ids) { -// logger.info("task生成入库单"); +// System.out.println("task生成入库单"); // List tas = commonDao.findByQuery( // "from Task t where t.pickTicketDetail.pickTicket.id=" + id + " order by t.billCode "); String ASNcode = ""; @@ -7495,7 +7508,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick // commonDao.store(pickTicket); list.add(t.getBillCode()); i = 1; -// logger.info("创建成功" + t.getBillCode()); +// System.out.println("创建成功" + t.getBillCode()); }else { asn=asns.get(0); } @@ -7527,7 +7540,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick commonDao.store(ad); commonDao.store(asn); } else { - logger.info("无入库单信息"); + System.out.println("无入库单信息"); } } if(asn!=null) @@ -7806,7 +7819,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick Location loc = this.load(Location.class, task.getSrcLoc().getId());//原库位 WarehouseArea wa = this.load(WarehouseArea.class, loc.getZone().getId()); if (task.getPlanQuantity() == task.getMovedQuantityMU()) { - logger.info("已拣货"); + System.out.println("已拣货"); } else if ( task.getPlanQuantity() - task.getMovedQuantityMU()>0) { String invsql = " from Inventory inv " + " where 1=1 " @@ -7818,12 +7831,12 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick } List invs = commonDao.findByQuery(invsql); if (invs.size() == 0) { - logger.info("未找到库存记录!"); + System.out.println("未找到库存记录!"); } Inventory srcInv = invs.get(0); if (srcInv == null) { task.setMovedQuantityMU(task.getMovedQuantityMU() + task.getPlanQuantity()); - logger.info("未找到库存记录!"); + System.out.println("未找到库存记录!"); } else { task.setDstLoc(dstLoc); // 如果拣货数量等于库存占用数量则直接移位到目标库位上，否则生成新的需要出库的库存 @@ -7944,7 +7957,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick Inventory srcInv = invs.get(0); if (srcInv == null) { task.setMovedQuantityMU(task.getMovedQuantityMU() + task.getPlanQuantity()); - logger.info("未找到库存记录!"); + System.out.println("未找到库存记录!"); } else { task.setDstLoc(dstLoc); // 如果拣货数量等于库存占用数量则直接移位到目标库位上，否则生成新的需要出库的库存 @@ -8222,7 +8235,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick obj.put("issueRemarks", issueRemarks);//下发备注（表头） obj.put("data", jsar.toString()); content=obj.toString(); - logger.info(content); + System.out.println(content); // 打印拣货标签 PrintTask pt2 = EntityFactory.getEntity(PrintTask.class); pt2.setType("4");// A4 @@ -8428,7 +8441,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick public void arrangeUrgent(List ids){ List list= commonDao.findByQuery(" from PickTicketDetail pd where pd.SOI in('X','U')" + " AND pd.pickTicket.status='OPEN' and pd.strBill15 is null"); - logger.info(list.size()); + System.out.println(list.size()); for(PickTicketDetail pdt:list) { String sql="select inv.id from Inventory inv where inv.itemKey.item.id="+pdt.getItem().getId() +" and inv.status='已入库' "; @@ -8490,9 +8503,9 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick waveDoc.setLkqQty(lkqQty); waveDoc.setLxqQty(lxqQty); waveDoc.setHjqQty(hjqQty); + waveDoc.setLogic(logic); waveDoc.setLongtiem(longtiem); waveDoc.setApplyDoc(pickCode); - waveDoc.setLogic(logic); waveDoc.setStartDate(date1); waveDoc.setEndDate(date2); waveDoc.setPrintCount(taskqty);//拆分行数 @@ -9659,15 +9672,15 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick for(Long tashid:tids1) { countTasks.remove(tashid); } -// logger.info("1"+countTasks.toString()); -// logger.info("2"+tids1.toString()); +// System.out.println("1"+countTasks.toString()); +// System.out.println("2"+tids1.toString()); if(countTasks.size()==0) { jdwz="X"; } List tLocds2=commonDao.findByQuery(taskloc2); fromaddress=tLocds2.get(0); - logger.info(jdwz); + System.out.println(jdwz); //位置回传 JSONObject bh= wmsSapWeizhihuichuang(tids1,fromaddress,dstLoc.getCode(),jdwz); //更新task任务的信息 @@ -9875,18 +9888,18 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick public void printPickTicketTask(Task ts, Long pId) { try { Task task=commonDao.load(Task.class, ts.getId()); -// logger.info("A4---1"); +// System.out.println("A4---1"); PrintEquipment printEquipment = commonDao.load(PrintEquipment.class, pId); if(printEquipment!=null) { String balls=""; -// logger.info("A4---2"); +// System.out.println("A4---2"); PickTicketDetail ptd1=commonDao.load(PickTicketDetail.class, task.getPickTicketDetail().getId()); PickTicket pt = commonDao.load(PickTicket.class, ptd1.getPickTicket().getId()); -// logger.info("A4---3"); +// System.out.println("A4---3"); List tasklist=commonDao.findByQuery(" from Task t where t.pickTicketDetail.pickTicket.id="+pt.getId()+ " and t.planQuantity>0 order by t.billCode,t.pickTicketDetail.item.code "); -// logger.info("A4---3----1"); +// System.out.println("A4---3----1"); JSONArray jsar=new JSONArray(); String content=""; String macs = printEquipment.getMac(); @@ -9900,7 +9913,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick String handoverLocation=ptd1.getStrBill16();//交接位置（表头） String issuedBy=task.getStrBill1();//下发人（表头） String issueRemarks=ptd1.getStrBill13();//下发备注（表头） -// logger.info("A4---4"); +// System.out.println("A4---4"); JSONObject obj = new JSONObject(); obj.put("applicantNumber", applicantNumber);//申请号（表头） obj.put("applicant", applicant);//申请人（表头） @@ -9910,7 +9923,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick obj.put("handoverLocation", handoverLocation);//交接位置（表头） obj.put("issuedBy", issuedBy);//下发人（表头） obj.put("issueRemarks", issueRemarks);//下发备注（表头） -// logger.info("A4---5"); +// System.out.println("A4---5"); String strbill=""; for (Task t :tasklist) { PickTicketDetail ptd = commonDao.load(PickTicketDetail.class, t.getPickTicketDetail().getId()); @@ -9925,7 +9938,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick Location lc=commonDao.load(Location.class, t.getSrcLoc().getId()); WarehouseArea zone=commonDao.load(WarehouseArea.class, lc.getZone().getId()); -// logger.info("A4---6"); +// System.out.println("A4---6"); JSONObject obj1 = new JSONObject(); balls=t.getEndRegion(); if(!strbill.equals("")&&!strbill.equals(t.getBillCode())) { @@ -9952,7 +9965,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick balls=wName; } obj1.put("billname", t.getBillCode());//子任务号（表明细） -// logger.info("A4---7"); +// System.out.println("A4---7"); obj1.put("itemCode", item.getCode());//物料号（表明细） obj1.put("qty", t.getMovedQuantityMU());//数量（表明细） obj1.put("order_qty", ptd.getOrderQuantity());//需求数量（表明细） @@ -9986,7 +9999,7 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick obj1.put("notes", ptd.getStrBill17());//备注（表明细） jsar.add(obj1.toString()); } -// logger.info("A4---8"); +// System.out.println("A4---8"); obj.put("data", jsar.toString()); content=obj.toString(); // 打印拣货标签 @@ -10001,12 +10014,12 @@ public class DefaultPickTicketManager extends DefaultBaseManager implements Pick pt2.setPrintName(printName); pt2.setPrintTitle(billCode); commonDao.store(pt2); -// logger.info("A4---9"); +// System.out.println("A4---9"); }else { throw new BusinessException("A4打印编号错误"); } }catch (Exception e) { - logger.info("打印A4失败"+e.getMessage()); + System.out.println("打印A4失败"+e.getMessage()); } } public void printPickTicketA4(Long taskid,Long printid) { diff --git a/src/main/java/com/dev/swms/server/web/servlet/PlanCountServlet.java b/src/main/java/com/dev/swms/server/web/servlet/PlanCountServlet.java index f0121fc..9a9ce17 100644 --- a/src/main/java/com/dev/swms/server/web/servlet/PlanCountServlet.java +++ b/src/main/java/com/dev/swms/server/web/servlet/PlanCountServlet.java @@ -81,13 +81,12 @@ import net.sf.json.JSONArray; import net.sf.json.JSONObject; import sun.security.krb5.Asn1Exception; -import org.apache.log4j.Logger; /** * Servlet implementation class LoginAppServlet */ public class PlanCountServlet extends HttpServlet { private static final long serialVersionUID = 1L; - private static Logger logger = Logger.getLogger(PlanCountServlet.class); + protected static ApplicationContext ac; /** * @see HttpServlet#HttpServlet() @@ -114,7 +113,7 @@ public class PlanCountServlet extends HttpServlet { * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response) */ protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { - logger.info("==========app出库========"+new Date()); + System.out.println("==========app出库========"+new Date()); CommonDao commonDao = (CommonDao) ac.getBean("commonDao"); request.setCharacterEncoding("UTF-8"); BufferedReader reader = new BufferedReader(new InputStreamReader(request.getInputStream(),"UTF-8"));//post方式传递读取字符流 @@ -128,7 +127,7 @@ public class PlanCountServlet extends HttpServlet { e.printStackTrace(); } - logger.info("result:"+result.toString()); + System.out.println("result:"+result.toString()); JSONObject json= JSONObject.fromObject(result.toString()); QueryAppManager app = (QueryAppManager) ac.getBean("queryAppManager"); String methodType =json.has("methodType")?json.getString("methodType"):""; @@ -216,10 +215,10 @@ public class PlanCountServlet extends HttpServlet { resultJson=app.queryLocList( propC2, workerId, wId); } - logger.info("======"+resultJson.toString()); + System.out.println("======"+resultJson.toString()); PrintWriter out = null; try { - response.setContentType(resultJson.toString()); +// response.setContentType(resultJson.toString()); response.setCharacterEncoding("UTF-8"); out = response.getWriter(); out.print(resultJson.toString()); @@ -371,7 +370,7 @@ public class PlanCountServlet extends HttpServlet { } }else { - + System.out.println(); msg="料号不存在错误！"; } diff --git a/src/main/java/com/dev/swms/server/web/servlet/SwmsExportGridServlet.java b/src/main/java/com/dev/swms/server/web/servlet/SwmsExportGridServlet.java index 848f9cb..99875ec 100644 --- a/src/main/java/com/dev/swms/server/web/servlet/SwmsExportGridServlet.java +++ b/src/main/java/com/dev/swms/server/web/servlet/SwmsExportGridServlet.java @@ -30,24 +30,49 @@ import javax.servlet.ServletException; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.lang.StringUtils; -import org.apache.log4j.Logger; + public class SwmsExportGridServlet extends BaseHttpServlet { private static final long serialVersionUID = 1L; private final DateFormat dateFormatter = new SimpleDateFormat("yyyy-MM-dd"); - private static Logger logger = Logger.getLogger(SwmsExportGridServlet.class); + public String decodeRequestURL( String queryString) { + StringBuilder urlBuilder = new StringBuilder(); + + if (queryString != null) { + try { + String decodedQueryString = URLDecoder.decode(queryString, "UTF-8"); + urlBuilder.append('?').append(decodedQueryString); + } catch (Exception e) { + // Handle exception if UTF-8 is not supported + e.printStackTrace(); + } + } + return urlBuilder.toString(); + } + + public void process(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException { - logger.info("export join....."); +// System.out.println("export join....."); res.setContentType("text/html; charset=UTF-8"); req.setCharacterEncoding("UTF-8"); res.setCharacterEncoding("UTF-8"); + +// String queryString = req.getQueryString(); +// System.out.println("------------------------------------------------"); +// System.out.println(queryString); +// System.out.println("-----------------decodeRequestURL-------------------------------"); +// queryString=decodeRequestURL(queryString); +// System.out.println(queryString); +// System.out.println("-----------------decodeRequestURL2-------------------------------"); +// queryString=decodeRequestURL(queryString); +// System.out.println(queryString); + UniConfig uniConfig = (UniConfig)this.ac.getBean("uniConfig"); String exportExcelType = req.getParameter("exportType"); if(StringUtils.isNotEmpty(exportExcelType)) { - exportExcelType = URLDecoder.decode(StringUtils.substring(exportExcelType, 0, exportExcelType.length() - 3)); + exportExcelType = URLDecoder.decode(StringUtils.substring(exportExcelType, 0, exportExcelType.length() - 3),"utf-8"); } - Map map = req.getParameterMap(); HashMap params = new HashMap(); Iterator sf = map.keySet().iterator(); @@ -61,18 +86,20 @@ public class SwmsExportGridServlet extends BaseHttpServlet { ids = null; if(dataSourceType != null && dataSourceType.length > 0) { ids = dataSourceType[0]; -// logger.info("parameter:"+ids); -// logger.info("parameter2:"); +// System.out.println("parameter:"+ids); +// System.out.println("parameter2:"); if(ids != null) { - ids = URLDecoder.decode(ids); + ids = URLDecoder.decode(ids,"utf-8"); +// System.out.println("----ids----:"+ids); } } if(ids == null) { + params.put(pageId, ids); } else { String page = "^\\[\\w+(,\\w+)*\\]\\w*$"; -// logger.info("===="+ids); + System.out.println("===="+ids); String gc; ArrayList tableConfig; int dataSourceParamUtil; @@ -121,6 +148,7 @@ public class SwmsExportGridServlet extends BaseHttpServlet { Float var30 = new Float(ids.substring(0, ids.length() - 3)); params.put(pageId, var30); } else { +// System.out.println("ids:"+ids); params.put(pageId, ids); } } else { @@ -135,7 +163,6 @@ public class SwmsExportGridServlet extends BaseHttpServlet { hql = var17[dataSourceParamUtil]; tableConfig.add(Long.valueOf(hql)); } - params.put(pageId, tableConfig); } } diff --git a/src/main/java/com/dev/swms/server/web/servlet/export/impl/XLSExportGenerator.java b/src/main/java/com/dev/swms/server/web/servlet/export/impl/XLSExportGenerator.java index aca0392..0951b94 100644 --- a/src/main/java/com/dev/swms/server/web/servlet/export/impl/XLSExportGenerator.java +++ b/src/main/java/com/dev/swms/server/web/servlet/export/impl/XLSExportGenerator.java @@ -8,6 +8,7 @@ import com.dev.energy.server.util.LocalizedMessage; import com.dev.swms.server.utils.ConvertEnumName; import com.dev.swms.server.web.servlet.export.ExportExcelGenerator; +import java.io.UnsupportedEncodingException; import java.sql.Timestamp; import java.text.ParseException; import java.text.SimpleDateFormat; @@ -17,6 +18,7 @@ import java.util.Date; import java.util.Iterator; import java.util.List; import java.util.Map; +import java.util.Set; import java.util.regex.Matcher; import java.util.regex.Pattern; import javax.servlet.http.HttpServletResponse; @@ -47,7 +49,20 @@ public class XLSExportGenerator implements ExportExcelGenerator, ApplicationCont private static final WritableCellFormat detFormat = new WritableCellFormat(detFont); private SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss"); - +// public static String convertToUTF8(String inputString) { +// try { +// // 将字符串转换为字节数组 +// byte[] inputBytes = inputString.getBytes("UTF-8"); +// +// // 将字节数组转换回字符串 +// String utf8EncodedString = new String(inputBytes, "UTF-8"); +// +// return utf8EncodedString; +// } catch (UnsupportedEncodingException e) { +// e.printStackTrace(); +// return null; +// } +// } public void exportExcel(ApplicationContext ac,String hql, Map params, TableConfig tableConfig, HttpServletResponse res, String referenceModel, String locale) throws Exception { String pagingNumberPer="40000"; String pageName = this.sdf.format(new Date()); @@ -55,12 +70,27 @@ public class XLSExportGenerator implements ExportExcelGenerator, ApplicationCont Matcher matcher = pattern.matcher(pageName); pageName = matcher.replaceAll(""); String header = "attachment; filename=" + pageName + ".xls"; - res.setCharacterEncoding("GBK"); - res.setContentType("application/ms-excel; charset=GBK"); + res.setCharacterEncoding("UTF-8"); + res.setContentType("application/ms-excel; charset=UTF-8"); res.setHeader("content-disposition", header); +// res.setContentType("text/html;charset=UTF-8"); WritableWorkbook workbook = Workbook.createWorkbook(res.getOutputStream()); params.put("pagingNumberPer", pagingNumberPer); params.put("pagingPage", "1"); +// Set> itor = params.entrySet(); +// int y=0; +// for (Map.Entry me : itor) { +// y++; +// System.out.println(y+"--"+me.getKey().toString()); +// if(me.getValue()!=null) { +// try { +// System.out.println(convertToUTF8(me.getValue()+"")); +// }catch (Exception e) { +// System.out.println(me.getValue()); +// } +// } +// } + ValueListQueryManager gridQueryManager = (ValueListQueryManager)ac.getBean("valueListQueryManager"); int s1=hql.indexOf("where"); if(s1<0){ @@ -74,6 +104,8 @@ public class XLSExportGenerator implements ExportExcelGenerator, ApplicationCont } } ValueList valueList = gridQueryManager.queryByValueList(hql, params); +// System.out.println("hsl"+hql); +// System.out.println(valueList.getList().size()); int offset = 1; int exportTotalPages = valueList.getValueListInfo().getTotalNumberOfPages(); do { @@ -95,12 +127,12 @@ public class XLSExportGenerator implements ExportExcelGenerator, ApplicationCont Collections.addAll(list, objs); List columnProperties = tableConfig.getColumnProperties(); int cloSize=columnProperties.size(); - for(int col = 1; col - + - - @@ -102,11 +102,11 @@ /~locCode: AND (location.code) like ({locCode})~/ /~worker.name: AND (worker.name) like ({worker.name})~/ /~countRecord.countCode: AND (countRecord.countCode) like ({countRecord.countCode})~/ - /~zone.name: AND upper(zone.name) like upper({zone.name})~/ + /~zone.name: AND zone.id = {zone.name}~/ /~location.id: AND location.id = {location.id}~/ /~beaa: AND (({beaa}=true and countRecord.deltaQuantity<>0) or ( {beaa}=false and countRecord.deltaQuantity=0)) ~/ /~countRecord.needCount: AND countRecord.needCount= {countRecord.needCount} ~/ - /~countRecord.targetArea: AND upper(countRecord.targetArea) like upper({countRecord.targetArea})~/ + /~countRecord.targetArea: AND (countRecord.targetArea) like ({countRecord.targetArea})~/ and (1=1 /~beginDate: AND CONVERT(varchar(100), countRecord.issuedDate, 23) = {beginDate} ~/ /~endDate: or (CONVERT(varchar(100), countRecord.issuedDate, 23)>= {beginDate} and CONVERT(varchar(100), countRecord.issuedDate, 23)<= {endDate}) ~/ diff --git a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainHeDanInventoryPage.xml b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainHeDanInventoryPage.xml index 6c0992e..8f4aa66 100644 --- a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainHeDanInventoryPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainHeDanInventoryPage.xml @@ -16,9 +16,14 @@ - + + + + @@ -39,7 +44,7 @@ - @@ -91,7 +96,7 @@ /~inventory.propC3: AND upper(inventory.propC3) LIKE upper({inventory.propC3})~/ /~inventory.propC5: AND upper(inventory.propC5) LIKE upper({inventory.propC5})~/ /~inventory.status: AND upper(inventory.status) LIKE upper({inventory.status})~/ - /~inventory.kqName: and inventory.kqName = {inventory.kqName}~/ + /~inventory.kqName: and inventory.zone.id = {inventory.kqName}~/ /~inventory.lock : and inventory.lock = {inventory.lock} ~/ /~inventory.singleItem : and inventory.singleItem = {inventory.singleItem} ~/ order by inventory.locCode,inventory.propC1 diff --git a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryLogPage.xml b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryLogPage.xml index 047370d..8820288 100644 --- a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryLogPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryLogPage.xml @@ -76,6 +76,22 @@ + + + + + + = {beginDate} ~/ /~endDate: AND CONVERT(varchar(100), inventoryLog.occurTime, 23)>= {beginDate} and CONVERT(varchar(100), inventoryLog.occurTime, 23)<= {endDate} ~/ diff --git a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryPage.xml b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryPage.xml index edb831f..93f80d6 100644 --- a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainInventoryPage.xml @@ -44,23 +44,27 @@ - - + + + + + readOnly="false" required="false" reserve="false" forceOverride="false"> + commonCode.code From PlantInfo commonCode + where commonCode.disabled = false ]]> 0 and loc.type not in ('RECEIVE','SHIP') @@ -122,7 +126,7 @@ /~location.id: AND inventory.location.id = {location.id}~/ /~item.code: AND upper(item.code) LIKE upper({item.code})~/ /~item.name: AND item.name LIKE {item.name}~/ - /~wa.name: AND wa.name LIKE {wa.name}~/ + /~wa.name: AND wa.id = {wa.name}~/ /~inventory.status: AND upper(inventory.status) LIKE upper({inventory.status})~/ /~propC1: AND inventory.itemKey.lotInfo.propC1 LIKE {propC1}~/ /~propC2: AND inventory.itemKey.lotInfo.propC2 LIKE {propC2}~/ @@ -131,7 +135,6 @@ /~propC9: AND inventory.itemKey.lotInfo.propC9 LIKE {propC9}~/ /~inventory.SOI: AND inventory.SOI LIKE {inventory.SOI}~/ /~inventory.propC1: AND inventory.itemKeyInventory.itemKey.lotInfo.propC1 LIKE {inventory.propC1}~/ - /~inventory.location.zone.id: AND inventory.location.zone.id= {inventory.location.zone.id}~/ /~quantity: AND inventory.quantity <= {quantity}~/ /~LP: AND inventory.LP.LP LIKE {LP}~/ /~inventory.counPlan : and ((inventory.counPlan is not null AND {inventory.counPlan}=true) OR (inventory.counPlan is null AND {inventory.counPlan}=false)) ~/ diff --git a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainOAXuliehaoPage.xml b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainOAXuliehaoPage.xml index 0aec83c..38b6e11 100644 --- a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainOAXuliehaoPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainOAXuliehaoPage.xml @@ -38,13 +38,17 @@ from CommonCode commonCode where commonCode.codeType = '库存状态']]> - + + + - @@ -58,11 +62,10 @@ - + - - - - - - - - - - - + + + + + + + + + + + + + diff --git a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainXuliehaoPage.xml b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainXuliehaoPage.xml index fe17a5f..5799282 100644 --- a/src/webapp/WEB-INF/classes/config/origen/inventory/maintainXuliehaoPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/inventory/maintainXuliehaoPage.xml @@ -94,6 +94,13 @@ AND lc.disabled = false ]]> + + + - + + + + @@ -56,8 +61,8 @@ enumType="PickTicketStatus"> + commonCode.code From PlantInfo commonCode + where commonCode.disabled = false]]> + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/webapp/WEB-INF/classes/config/origen/receiving/editPrintAsnBillPage.xml b/src/webapp/WEB-INF/classes/config/origen/receiving/editPrintAsnBillPage.xml new file mode 100644 index 0000000..d6c0b84 --- /dev/null +++ b/src/webapp/WEB-INF/classes/config/origen/receiving/editPrintAsnBillPage.xml @@ -0,0 +1,39 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/webapp/WEB-INF/classes/config/origen/receiving/maintainASNPage.xml b/src/webapp/WEB-INF/classes/config/origen/receiving/maintainASNPage.xml index e1612b7..11ea64b 100644 --- a/src/webapp/WEB-INF/classes/config/origen/receiving/maintainASNPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/receiving/maintainASNPage.xml @@ -173,7 +173,10 @@ - + + + diff --git a/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivedRecordPage.xml b/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivedRecordPage.xml index 3cdd709..171bbcb 100644 --- a/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivedRecordPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivedRecordPage.xml @@ -24,7 +24,7 @@ - @@ -146,7 +146,7 @@ /~rs.id : and rs.id = {rs.id}~/ /~ad.lotInfo.propC9: AND ad.lotInfo.propC9 like {ad.lotInfo.propC9} ~/ /~beInput: AND ad.beInput= {beInput} ~/ - /~inventory.kqName: and rd.warehouseArea.name like {inventory.kqName} ~/ + /~inventory.kqName: and rd.warehouseArea.id like {inventory.kqName} ~/ /~rd.itemKey.lotInfo.propC1: AND rd.itemKey.lotInfo.propC1 like {rd.itemKey.lotInfo.propC1} ~/ /~rd.itemKey.lotInfo.propC2: AND rd.itemKey.lotInfo.propC2 like {rd.itemKey.lotInfo.propC2} ~/ /~rd.itemKey.lotInfo.propC3: AND rd.itemKey.lotInfo.propC3 like {rd.itemKey.lotInfo.propC3} ~/ diff --git a/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivingInventoryPage.xml b/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivingInventoryPage.xml index cd0d476..0639012 100644 --- a/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivingInventoryPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/receiving/maintainReceivingInventoryPage.xml @@ -18,9 +18,14 @@ - + + + + @@ -29,8 +34,8 @@ enumType="PickTicketStatus"> + commonCode.code From PlantInfo commonCode + where commonCode.disabled = false ]]> - + + + + @@ -149,6 +154,7 @@ FROM Task task LEFT JOIN task.pickTicketDetail as pickTicketDetail LEFT JOIN task.pickTicketDetail.pickTicket as pickTicket + left join pickTicket.billType as billType LEFT JOIN task.itemKey as itemKey left join task.waveDoc as waveDoc LEFT JOIN task.itemKey.item as item @@ -189,6 +195,7 @@ /~task.strBill4: AND task.strBill4 LIKE {task.strBill4}~/ /~propC2: AND itemKey.lotInfo.propC2 like {propC2} ~/) /~szone.id: AND szone.id = {szone.id}~/ + /~billType.name: AND billType.id = {billType.name}~/ order by task.pickTicketDetail.pickTicket.orderDate,task.id desc ]]> diff --git a/src/webapp/WEB-INF/classes/config/origen/shipping/maintainPickTicketPage.xml b/src/webapp/WEB-INF/classes/config/origen/shipping/maintainPickTicketPage.xml index b1b6d00..4cd127b 100644 --- a/src/webapp/WEB-INF/classes/config/origen/shipping/maintainPickTicketPage.xml +++ b/src/webapp/WEB-INF/classes/config/origen/shipping/maintainPickTicketPage.xml @@ -82,7 +82,7 @@ + visible="true" horizonAlign="center" /> 'A' ) or ({pickTicket.equatedQuantity}=false and pickTicket.equatedQuantity<'A' )) ~/ /~billType.name: AND billType.id = {billType.name}~/ /~dLzone.name: AND dLzone.name = {dLzone.name}~/ - /~agv.status: AND agv.status ={agv.status} ~/ - /~billCode: AND (t.billCode) LIKE ({billCode})~/ /~t.strBill1: AND t.strBill1 LIKE {t.strBill1}~/ /~warehouseArea.id: AND szone.id = {warehouseArea.id}~/ @@ -288,6 +288,7 @@ + @@ -314,6 +315,7 @@ +