b41b31b383e807ea6577c06d1bd495ed80148fb2.svn-base 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  1. package xin.glue.ui.H.H05;
  2. import xin.glue.ui.common.ProduceFactory;
  3. import com.posdata.glue.biz.activity.PosActivity;
  4. import com.posdata.glue.biz.constants.PosBizControlConstants;
  5. import com.posdata.glue.context.PosContext;
  6. import com.posdata.glue.dao.vo.PosParameter;
  7. import com.posdata.glue.dao.vo.PosRow;
  8. import com.posdata.glue.dao.vo.PosRowSet;
  9. /**
  10. * 冷轧移送回退处理
  11. * @author Administrator
  12. *
  13. */
  14. public class ReturnTrans extends PosActivity {
  15. public String runActivity(PosContext context) {
  16. // TODO Auto-generated method stub
  17. // 行状态
  18. String[] rowStuts = (String[]) context.get("rowStuts");
  19. // 选择标志
  20. String[] CHK = (String[]) context.get("CHK");
  21. // 钢卷号
  22. String[] coilNo = (String[]) context.get("OLD_SAMPL_NO");
  23. // 堆放位置
  24. String[] curLoadLoc = (String[]) context.get("CUR_LOAD_LOC");
  25. // 班次
  26. String[] TRNF_SHIFT = (String[]) context.get("TRNF_SHIFT");
  27. // 班组
  28. String[] TRNF_GROUP = (String[]) context.get("TRNF_GROUP");
  29. // 操作人
  30. String[] TRNF_REG = (String[]) context.get("TRNF_REG");
  31. // 操作时间
  32. String[] TRNF_DTIME = (String[]) context.get("TRNF_DTIME");
  33. //登录人
  34. String []LOGIN_ID = (String[])context.get("LOGIN_ID");
  35. // 循环rowStuts,取出相应的节点行数
  36. for(int i=0;i<rowStuts.length;i++){
  37. //如果选择标志为Y的情况,说明是需要操作的。
  38. if(CHK[i].equals("Y")){
  39. //进行冷轧是否已经接收的判断
  40. String sqlc = "SELECT * FROM c_tbk02_coil_comm T WHERE T.OLD_SAMPL_NO = ? AND T.COIL_STAT='2' AND T.CUR_LOAD_LOC IS NOT NULL";
  41. PosParameter paramc = new PosParameter();
  42. paramc.setWhereClauseParameter(0,coilNo[i]);
  43. PosRowSet CoilVo1 = getDao("mesdao").findByQueryStatement(sqlc, paramc);
  44. if (CoilVo1.hasNext()) {
  45. String vtemp="COILIN";
  46. context.put("rs", vtemp);
  47. return PosBizControlConstants.SUCCESS;
  48. }
  49. PosParameter param = new PosParameter();
  50. param.setValueParamter(0, TRNF_SHIFT[0]);
  51. param.setValueParamter(1, TRNF_GROUP[0]);
  52. param.setValueParamter(2, TRNF_REG[0]);
  53. param.setValueParamter(3, curLoadLoc[i]);
  54. param.setValueParamter(4, TRNF_DTIME[0]);
  55. param.setWhereClauseParameter(0, coilNo[i]);
  56. getDao("mesdao").update("UIH052400_05.update", param);
  57. PosParameter param1 = new PosParameter();
  58. param1.setValueParamter(0, coilNo[i]);
  59. param1.setValueParamter(1, TRNF_REG[0]);
  60. param1.setWhereClauseParameter(0, curLoadLoc[i]);
  61. param1.setWhereClauseParameter(1, curLoadLoc[i]);
  62. param1.setWhereClauseParameter(2, curLoadLoc[i]);
  63. param1.setWhereClauseParameter(3, curLoadLoc[i]);
  64. getDao("mesdao").update("UIH052400_06.update", param1);
  65. //删除冷轧原料中还未入库的数据 20190909 wl
  66. PosParameter paramD = new PosParameter();
  67. paramD.setWhereClauseParameter(0, coilNo[i]);
  68. getDao("mesdao").delete("UIH052400_01.delete", paramD);
  69. Number SEQ = null;
  70. int SEQ_1 = 0;
  71. //记录库存移动的情况
  72. PosParameter param11 = new PosParameter();
  73. PosRowSet rows11 = getDao("mesdao").find("UIH050700_05.select", param11);
  74. if(rows11.hasNext()){
  75. PosRow row11 = rows11.next();
  76. SEQ = (Number) row11.getAttribute("ROLL_SEQ");
  77. if(null == SEQ){
  78. SEQ_1 = 1;
  79. }else{
  80. SEQ_1 = SEQ.intValue()+1;
  81. }
  82. //取出主键后,更新移动表
  83. PosParameter param4 = new PosParameter();
  84. param4.setValueParamter(0, new Integer(SEQ_1));
  85. param4.setValueParamter(1, "");
  86. param4.setValueParamter(2, curLoadLoc[0]);
  87. param4.setValueParamter(3, coilNo[i]);
  88. param4.setValueParamter(4, TRNF_REG[0]);
  89. param4.setValueParamter(5, TRNF_SHIFT[0]);
  90. param4.setValueParamter(6, TRNF_GROUP[0]);
  91. param4.setValueParamter(7, TRNF_DTIME[0]);
  92. param4.setValueParamter(8, LOGIN_ID[0]);
  93. getDao("mesdao").insert("UIH050700_01.insert", param4);
  94. }
  95. //新增退回记录
  96. PosParameter param2 = new PosParameter();
  97. param2.setValueParamter(0, coilNo[i]);
  98. param2.setValueParamter(1, curLoadLoc[0]);
  99. param2.setValueParamter(2, TRNF_REG[0]);
  100. param2.setValueParamter(3, TRNF_SHIFT[0]);
  101. param2.setValueParamter(4, TRNF_GROUP[0]);
  102. param2.setValueParamter(5, TRNF_DTIME[0]);
  103. getDao("mesdao").update("UIH052400_04.insert", param2);
  104. }
  105. }
  106. return PosBizControlConstants.SUCCESS;
  107. }
  108. }