MESHelperServiceImpl.java 82 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082
  1. package com.uas.eis.serviceImpl;
  2. import com.uas.eis.core.config.SpObserver;
  3. import com.uas.eis.dao.BaseDao;
  4. import com.uas.eis.dao.SqlRowList;
  5. import com.uas.eis.entity.ErrorMessage;
  6. import com.uas.eis.entity.HelperType;
  7. import com.uas.eis.exception.ApiSystemException;
  8. import com.uas.eis.sdk.entity.ApiResult;
  9. import com.uas.eis.service.MESDataService;
  10. import com.uas.eis.service.MESHelperService;
  11. import com.uas.eis.utils.*;
  12. import flexjson.JSON;
  13. import net.sf.json.JSONArray;
  14. import net.sf.json.JSONObject;
  15. import net.sf.json.JsonConfig;
  16. import org.apache.commons.lang.StringUtils;
  17. import org.dom4j.DocumentException;
  18. import org.springframework.beans.factory.annotation.Autowired;
  19. import org.springframework.beans.factory.annotation.Value;
  20. import org.springframework.boot.jackson.JsonObjectDeserializer;
  21. import org.springframework.stereotype.Service;
  22. import org.springframework.web.bind.annotation.RequestBody;
  23. import org.w3c.dom.Document;
  24. import org.w3c.dom.Element;
  25. import org.w3c.dom.Node;
  26. import org.w3c.dom.NodeList;
  27. import org.xml.sax.SAXException;
  28. import sun.awt.TimedWindowEvent;
  29. import java.io.IOException;
  30. import java.sql.Timestamp;
  31. import java.util.*;
  32. import org.dom4j.DocumentHelper;
  33. import javax.xml.parsers.DocumentBuilder;
  34. import javax.xml.parsers.DocumentBuilderFactory;
  35. import javax.xml.parsers.ParserConfigurationException;
  36. import org.xml.sax.InputSource;
  37. import java.io.StringReader;
  38. @Service
  39. public class MESHelperServiceImpl implements MESHelperService {
  40. @Autowired
  41. private BaseDao baseDao;
  42. @Value("${spring.datasource.username}")
  43. private String username;
  44. @Override
  45. public Map<Object,Object> Radium(String data) {
  46. Map<String, Object> map=null;
  47. Map<Object, Object> rmap = new HashMap<Object, Object>();
  48. String oErrMessage="";
  49. String UserName="";
  50. try{
  51. map =BaseUtil.convertJsonToMap(data);
  52. }catch (Exception e){
  53. System.out.printf(e.getMessage()) ;
  54. }
  55. if(map.get("SN")==null){
  56. rmap.put("code",-1);
  57. rmap.put("message","SN号不能为空");
  58. return rmap;
  59. }
  60. if(map.get("MO")==null){
  61. rmap.put("code",-1);
  62. rmap.put("message","工单号不能为空");
  63. return rmap;
  64. }
  65. if(map.get("SpecificationName")==null){
  66. rmap.put("code",-1);
  67. rmap.put("message","工序不能为空");
  68. return rmap;
  69. }
  70. if(map.get("UserName")==null){
  71. rmap.put("code",-1);
  72. rmap.put("message","用户不能为空");
  73. return rmap;
  74. }
  75. String specificationName=map.get("SpecificationName").toString();
  76. String MO=map.get("MO").toString();
  77. Map<Object,Object> map1=BaseUtil.parseFormStoreToMap(map.get("SN").toString());
  78. for (Map.Entry<Object, Object> entry : map1.entrySet()) {
  79. Object key = entry.getKey();
  80. Object value = entry.getValue();
  81. SqlRowList rs=baseDao.queryForRowSet("select 1 from makesnlist where msl_sncode='"+value.toString().toUpperCase()+"'" +
  82. " and msl_makecode='"+MO+"' and msl_Radium=-1");
  83. if(rs.next()){
  84. oErrMessage+="序列号"+value.toString().toUpperCase()+"已镭雕,";
  85. }else {
  86. baseDao.execute("update makesnlist set msl_Radium=-1 where msl_sncode='"+value.toString().toUpperCase()+"' and " +
  87. "msl_makecode='"+MO+"'");
  88. }
  89. //启用过站
  90. if(baseDao.getFieldDataByCondition("configs","data","caller='MESSetting' and code='Radium'").toString().equals("1")){
  91. oErrMessage+=GoMo(value.toString().toUpperCase(),MO, specificationName);
  92. if(oErrMessage.equals("null")){
  93. oErrMessage="";
  94. }else{
  95. rmap.put("code",-1);
  96. rmap.put("message",oErrMessage);
  97. return rmap;
  98. }
  99. oErrMessage+=CheckRoutePassed(value.toString().toUpperCase(),specificationName);
  100. if(oErrMessage.equals("null")){
  101. oErrMessage="";
  102. }else{
  103. rmap.put("code",-1);
  104. rmap.put("message",oErrMessage);
  105. return rmap;
  106. }
  107. oErrMessage+=SetPcbaData(value.toString().toUpperCase(),specificationName,UserName,"OK");
  108. if(oErrMessage.equals("null")){
  109. oErrMessage="";
  110. }else{
  111. rmap.put("code",-1);
  112. rmap.put("message",oErrMessage);
  113. return rmap;
  114. }
  115. }
  116. }
  117. if(oErrMessage.equals("")||oErrMessage==null){
  118. rmap.put("code",0);
  119. rmap.put("message","镭射识别绑定成功");
  120. return rmap;
  121. }else{
  122. rmap.put("code",-1);
  123. rmap.put("message",oErrMessage);
  124. return rmap;
  125. }
  126. }
  127. @Override
  128. public Map<Object,Object> SPI(String data) {
  129. Map<Object, Object> rmap = new HashMap<Object, Object>();
  130. try{
  131. DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
  132. DocumentBuilder builder = factory.newDocumentBuilder();
  133. try {
  134. try{
  135. Element root;
  136. NodeList books;
  137. Document document = builder.parse(new InputSource(new StringReader(data)));
  138. root = document.getDocumentElement();
  139. books = root.getChildNodes();
  140. String Username="";
  141. String Shiftname="";
  142. String MachineNO="";
  143. String LineNO="";
  144. String procedure="";
  145. String Moname="";
  146. String Lotsn="";
  147. String Side="";
  148. String Result="";
  149. String Defect="";
  150. String elementQTY="";
  151. String TestQTY="";
  152. String Time="";
  153. for (Node node = books.item(1).getFirstChild(); node != null; node = node.getNextSibling()) {
  154. {
  155. if (node.getNodeName().equals("UpdAOISPIRecord")) {
  156. NodeList books1 = node.getChildNodes();
  157. for (int i = 0; i < books1.getLength(); i++) {
  158. Node node1 = books1.item(i);
  159. if(!node1.getNodeName().equals("#text")){
  160. switch (node1.getNodeName()){
  161. case "Username":{
  162. Username=node1.getTextContent();
  163. break;
  164. }
  165. case "Shiftname":{
  166. Shiftname=node1.getTextContent();
  167. break;
  168. }
  169. case "MachineNO":{
  170. MachineNO=node1.getTextContent(); break;
  171. }
  172. case "LineNO":{
  173. LineNO=node1.getTextContent();
  174. break;
  175. }
  176. case "procedure":
  177. procedure=node1.getTextContent();
  178. break;
  179. case "Moname":
  180. Moname=node1.getTextContent();
  181. break;
  182. case "Lotsn":
  183. Lotsn=node1.getTextContent();
  184. break;
  185. case "Side":
  186. Side=node1.getTextContent();
  187. break;
  188. case "Result":
  189. Result=node1.getTextContent();
  190. break;
  191. case "Defect":
  192. Defect=node1.getTextContent();
  193. break;
  194. case "elementQTY":
  195. elementQTY=node1.getTextContent();
  196. break;
  197. case "TestQTY":
  198. TestQTY=node1.getTextContent();
  199. break;
  200. case "Time":
  201. Time=node1.getTextContent();
  202. break;
  203. default:
  204. break;
  205. }
  206. //System.out.printf("名称:"+node1.getNodeName());
  207. //System.out.printf("值:"+node1.getTextContent());
  208. //System.out.printf("类型:"+node1.getNodeType());
  209. }
  210. }
  211. }
  212. }
  213. }
  214. Time=Time.substring(0,19).replaceAll("T"," ");
  215. baseDao.execute("insert into devicetestinfo(DTI_ID, DTI_SNCODE, DTI_USERNAME, DTI_MACHINE, DTI_LINECODE, DTI_RESULT, DTI_MAKECODE, DTI_SHIFTNAME, DTI_PROGRAM, DTI_DEFECT, " +
  216. "DTI_TESTQTY, DTI_MACHINETYPE, DTI_TYPE, DTI_TIME, DTI_SOURCECONTENT,dti_elementQTY)values(devicetestinfo_seq.nextval,'"+Lotsn+"','"+Username+"','"+MachineNO+"','"+LineNO+"','"+Result+"'" +
  217. ",'"+Moname+"','"+Shiftname+"','"+procedure+"','"+Defect+"','"+TestQTY+"','SPI','SPI',to_date('"+Time+"','yyyy-mm-dd hh24:mi:ss'),'','"+elementQTY+"')");
  218. }catch (IOException e){
  219. System.out.printf(e.getMessage());
  220. }
  221. }
  222. catch (SAXException e){
  223. }
  224. }catch (ParserConfigurationException e){
  225. }
  226. return rmap;
  227. }
  228. @Override
  229. public String AOI(String Username,String Shiftname, String MachineNO, String LineNO, String procedure,String Moname, String Lotsn,String Side,String Result,String Defect,String elementQTY,String TestQTY,String Type,String Time) {
  230. baseDao.execute("insert into devicetestinfo(DTI_ID, DTI_SNCODE, DTI_USERNAME, DTI_MACHINE, DTI_LINECODE, DTI_RESULT, DTI_MAKECODE, DTI_SHIFTNAME, DTI_PROGRAM, DTI_DEFECT, " +
  231. "DTI_TESTQTY, DTI_MACHINETYPE, DTI_TYPE, DTI_TIME, DTI_SOURCECONTENT,dti_elementQTY)values(devicetestinfo_seq.nextval,'"+Lotsn+"','"+Username+"','"+MachineNO+"','"+LineNO+"','"+Result+"'" +
  232. ",'"+Moname+"','"+Shiftname+"','"+procedure+"','"+Defect+"','"+TestQTY+"','"+Type+"','AOI',to_date('"+Time+"','yyyy-mm-dd hh24:mi:ss'),'','"+elementQTY+"')");
  233. return "";
  234. }
  235. @Override
  236. public String UploadSteel(String SteelMeshCode,String scraperCode, String SteelMeshCount, String scraperCount, String datatime) {
  237. String err = CheckSteel(SteelMeshCode);
  238. //判断钢网编号
  239. if(SteelMeshCode!=null&&!"".equals(SteelMeshCode)){
  240. baseDao.execute("insert into devicetestinfo(DTI_ID, DTI_SNCODE,DTI_TESTQTY, DTI_MACHINETYPE, DTI_TYPE, DTI_TIME, DTI_SOURCECONTENT)values(devicetestinfo_seq.nextval,'"+scraperCode+"','"+scraperCount+"','钢网','钢网',to_date('"+datatime+"','yyyy-mm-dd hh24:mi:ss'),'')");
  241. baseDao.execute("update stencil set st_usecount=nvl(st_usecount,0)+"+scraperCount +" where st_code='"+SteelMeshCode+"'");
  242. }
  243. //判断刮刀编号
  244. if(scraperCode!=null&&!"".equals(scraperCode)){
  245. baseDao.execute("insert into devicetestinfo(DTI_ID, DTI_SNCODE,DTI_TESTQTY, DTI_MACHINETYPE, DTI_TYPE, DTI_TIME, DTI_SOURCECONTENT)values(devicetestinfo_seq.nextval,'"+scraperCode+"','"+scraperCount+"','刮刀','刮刀',to_date('"+datatime+"','yyyy-mm-dd hh24:mi:ss'),'')");
  246. baseDao.execute("update stencil set st_usecount=nvl(st_usecount,0)+"+scraperCount +" where st_code='"+scraperCode+"'");
  247. }
  248. return err;
  249. }
  250. @Override
  251. public String CheckSteel(String SteelMeshCode) {
  252. Map<Object, Object> rmap = new HashMap<Object, Object>();
  253. SqlRowList rs=baseDao.queryForRowSet("select st_kind,nvl(st_usecount,0)st_usecount,nvl(st_maxusecount,0)st_maxusecount from stencil where st_code='"+SteelMeshCode+"'");
  254. if(rs.next()){
  255. String st_usecount=rs.getString("st_usecount");
  256. String st_maxusecount=rs.getString("st_maxusecount");
  257. String st_kind=rs.getString("st_kind");
  258. if(Integer.parseInt(st_usecount)>=Integer.parseInt(st_maxusecount)){
  259. return rs.getString("st_kind")+"已使用"+st_usecount+",超出最大使用次数"+st_maxusecount;
  260. }
  261. }else{
  262. return "编号不存在";
  263. }
  264. return "";
  265. }
  266. @Override
  267. public Map<Object,Object> SetupResultDataInterface(String data) {
  268. Map<Object, Object> rmap = new HashMap<Object, Object>();
  269. JSONObject object = JSONObject.fromObject(data);
  270. Object object1 = object.get("data");
  271. JSONObject obj = JSONObject.fromObject(object1);
  272. JSONObject SetupResultDetail=obj.getJSONObject("SetupResultDetail");
  273. if(SetupResultDetail!=null){
  274. String ActionType=SetupResultDetail.get("ActionType").toString();
  275. String MessageSendTime=Time(SetupResultDetail.getString("MessageSendTime"));
  276. String LineName=SetupResultDetail.get("LineName").toString();
  277. String SetupName=SetupResultDetail.get("SetupName").toString();
  278. String MachineName=SetupResultDetail.get("MachineName").toString();
  279. String OrderNumber=SetupResultDetail.get("OrderNumber").toString();
  280. String DockingStationID=SetupResultDetail.get("DockingStationID").toString();
  281. String Operator=SetupResultDetail.get("Operator").toString();
  282. String TableLocation=SetupResultDetail.get("TableLocation").toString();
  283. String TableId=SetupResultDetail.get("TableId").toString();
  284. String Track=SetupResultDetail.get("Track").toString();
  285. String FeederTypeName=SetupResultDetail.get("FeederTypeName").toString();
  286. String FeederID=SetupResultDetail.get("FeederID").toString();
  287. JSONObject PackagingUnitDetail=SetupResultDetail.getJSONObject("PackagingUnit");
  288. if(PackagingUnitDetail!=null){
  289. String PUID=PackagingUnitDetail.getString("PUID");
  290. String ComponentBarcode=PackagingUnitDetail.getString("ComponentBarcode");
  291. String ComponentBarcodeFragment=PackagingUnitDetail.getString("ComponentBarcodeFragment");
  292. String OriginalQuantity=PackagingUnitDetail.getString("OriginalQuantity");
  293. String Quantity=PackagingUnitDetail.getString("Quantity");
  294. String CreateDate=Time(PackagingUnitDetail.getString("CreateDate"));
  295. String DateCode=PackagingUnitDetail.getString("DateCode");
  296. String BatchId=PackagingUnitDetail.getString("BatchId");
  297. String MsdLevel=PackagingUnitDetail.getString("MsdLevel");
  298. JSONObject LockInfoList=null;
  299. try{
  300. LockInfoList=PackagingUnitDetail.getJSONObject("LockInfoList");
  301. }catch (Exception e){
  302. }
  303. JSONObject SplicedPackagingUnitList=null;
  304. try{
  305. SplicedPackagingUnitList=PackagingUnitDetail.getJSONObject("SplicedPackagingUnitList");
  306. }catch (Exception e){
  307. }
  308. String smt_line="";
  309. if(LineName.equals("Line1")){
  310. smt_line="贴片L1线";
  311. }
  312. if(LineName.equals("Line2")){
  313. smt_line="贴片L2线";
  314. }
  315. if(LineName.equals("Line3")||LineName.equals("L3")){
  316. smt_line="贴片L3线";
  317. }
  318. if(LineName.equals("Line4")||LineName.equals("L4")){
  319. smt_line="贴片L4线";
  320. }
  321. if(LineName.equals("Line5")){
  322. smt_line="贴片L5线";
  323. }
  324. if(LineName.equals("Line6")){
  325. smt_line="贴片L6线";
  326. }
  327. Object makecode=baseDao.getFieldDataByCondition("Line","li_makecode","li_code='"+smt_line+"'");
  328. int sr_id=baseDao.getSeqId("SETUPRESULTDETAIL_seq");
  329. baseDao.execute("insert into SETUPRESULTDETAIL(sr_id,ACTIONTYPE,LINENAME,SetupName,ORDERNUMBER,MACHINENAME," +
  330. "TABLEID,DOCKINGSTATIONID,OPERATOR,TableLocation,FeederTypeName,FeederID,MessageSendTime)values('"+sr_id+"'," +
  331. "'"+ActionType+"','"+LineName+"','"+SetupName+"','"+OrderNumber+"','"+MachineName+"','"+TableId+"','"+DockingStationID+"'," +
  332. "'"+Operator+"','"+TableLocation+"','"+FeederTypeName+"','"+FeederID+"',to_date('"+MessageSendTime+"','yyyy-mm-dd hh24:mi:ss'))");
  333. int pu_id=baseDao.getSeqId("PACKAGINGUNIT_seq");
  334. baseDao.execute("insert into PACKAGINGUNIT(PU_ID,PUID,PU_SRID,ComponentBarcodeFragment,ComponentBarcode,OriginalQuantity,Quantity,CreateDate," +
  335. "DateCode,BatchId,MsdLevel,makecode)values('"+pu_id+"','"+PUID+"','"+sr_id+"','"+ComponentBarcodeFragment+"','"+ComponentBarcode+"','"+OriginalQuantity+"','"+Quantity+"',to_date('"+CreateDate+"','yyyy-mm-dd hh24:mi:ss')," +
  336. "'"+DateCode+"','"+BatchId+"','"+MsdLevel+"','"+makecode+"')");
  337. if(LockInfoList!=null){
  338. JSONArray LockInfoItem=LockInfoList.getJSONArray("LockInfoItem");
  339. for(int i=0;i<LockInfoItem.size();i++){
  340. JSONObject map=LockInfoItem.getJSONObject(i);
  341. String Date=Time(map.getString("Date"));
  342. String Message=map.getString("Message");
  343. String Reason=map.getString("Reason");
  344. String Source=map.getString("Source");
  345. baseDao.execute("insert into LOCKINFOLIST(LF_ID,lf_puid,INDATE,MESSAGE,REASON,SOURCE)" +
  346. "values(LOCKINFOLIST_seq.nextval,'"+pu_id+"',to_date('"+Date+"','yyyy-mm-dd hh24:mi:ss'),'"+Message+"'," +
  347. "'"+Reason+"','"+Source+"')");
  348. }
  349. }
  350. if(SplicedPackagingUnitList!=null){
  351. JSONArray SplicedPackagingUnitItem=SplicedPackagingUnitList.getJSONArray("SplicedPackagingUnitItem");
  352. for(int i=0;i<SplicedPackagingUnitItem.size();i++){
  353. JSONObject map=SplicedPackagingUnitItem.getJSONObject(i);
  354. String UID1=map.getString("PUID");
  355. String ComponentBarcode1=map.getString("ComponentBarcode");
  356. String ComponentName=map.getString("ComponentName");
  357. String OriginalQuantity1=map.getString("OriginalQuantity");
  358. String Quantity1=map.getString("Quantity");
  359. String ManufacturePartNumber=map.getString("ManufacturePartNumber");
  360. String Manufacturer=map.getString("Manufacturer");
  361. String Supplier=map.getString("Supplier");
  362. baseDao.execute("insert into SPLICEDPACKAGING (SP_ID,SP_PUID,PUID,COMPONENTBARCODE,ORIGINALQUANTITY,QUANTITY)" +
  363. "values(SPLICEDPACKAGING_seq.nextval,'"+pu_id+"','"+UID1+"','"+ComponentBarcode1+"','"+OriginalQuantity1+"','"+Quantity1+"')");
  364. }
  365. }
  366. }
  367. rmap.put("code","0");
  368. rmap.put("result","OK");
  369. rmap.put("ServerMessage","MES:贴片机数据记录成功");
  370. }
  371. return rmap;
  372. }
  373. @Override
  374. public Map<Object,Object> StateEventDetail(String data) {
  375. Map<Object, Object> rmap = new HashMap<Object, Object>();
  376. JSONObject object = JSONObject.fromObject(data);
  377. Object object1 = object.get("data");
  378. JSONObject obj = JSONObject.fromObject(object1);
  379. JSONObject StateEventDetail=obj.getJSONObject("StateEventDetail");
  380. if(StateEventDetail!=null){
  381. int st_id=baseDao.getSeqId("StateEventDetail_seq");
  382. String MessageSendTime=Time(StateEventDetail.getString("MessageSendTime"));
  383. String CompletionStatusType=StateEventDetail.getString("CompletionStatusType");
  384. String LineFullPath=StateEventDetail.getString("LineFullPath");
  385. String LineName=StateEventDetail.getString("LineName");
  386. String MachineFullPath=StateEventDetail.getString("MachineFullPath");
  387. String MachineName=StateEventDetail.getString("MachineName");
  388. String JobFullPath=StateEventDetail.getString("JobFullPath");
  389. String JobName=StateEventDetail.getString("JobName");
  390. String RecipeFullPath=StateEventDetail.getString("RecipeFullPath");
  391. String RecipeName=StateEventDetail.getString("RecipeName");
  392. String SetupFullPath=StateEventDetail.getString("SetupFullPath");
  393. String SetupName=StateEventDetail.getString("SetupName");
  394. String BoardFullPath=StateEventDetail.getString("BoardFullPath");
  395. String BoardName=StateEventDetail.getString("BoardName");
  396. String OrderNumber=StateEventDetail.getString("OrderNumber");
  397. String ConveyorMode=StateEventDetail.getString("ConveyorMode");
  398. String DownloadMode=StateEventDetail.getString("DownloadMode");
  399. String FactoryLayoutPath=StateEventDetail.getString("FactoryLayoutPath");
  400. String MachineId=StateEventDetail.getString("MachineId");
  401. String MachineType=StateEventDetail.getString("MachineType");
  402. String TypeName=StateEventDetail.getString("TypeName");
  403. String ProcessingAreaCount=StateEventDetail.getString("ProcessingAreaCount");
  404. String StationSoftwareVersion=StateEventDetail.getString("StationSoftwareVersion");
  405. String MonitoringServiceVersion=StateEventDetail.getString("MonitoringServiceVersion");
  406. String ComputerAddress=StateEventDetail.getString("ComputerAddress");
  407. baseDao.execute("insert into StateEventDetail(ST_ID, MESSAGESENDTIME, COMPLETIONSTATUSTYPE, LINEFULLPATH, LINENAME, MACHINEFULLPATH, MACHINENAME, JOBFULLPATH, JOBNAME, RECIPEFULLPATH, RECIPENAME, SETUPFULLPATH, SETUPNAME, BOARDFULLPATH, BOARDNAME, ORDERNUMBER, CONVEYORMODE, DOWNLOADMODE, FACTORYLAYOUTPATH, MACHINEID, MACHINETYPE, TYPENAME, PROCESSINGAREACOUNT, STATIONSOFTWAREVERSION, MONITORINGSERVICEVERSION, COMPUTERADDRESS)" +
  408. "values("+st_id+", to_date('"+MessageSendTime+"','yyyy-mm-dd hh24:mi:ss'), '"+CompletionStatusType+"', '"+LineFullPath+"', '"+LineName+"', '"+MachineFullPath+"', '"+MachineName+"', '"+JobFullPath+"', '"+JobName+"', '"+RecipeFullPath+"', '"+RecipeName+"', '"+SetupFullPath+"', '"+SetupName+"', '"+BoardFullPath+"', '"+BoardName+"', '"+OrderNumber+"', '"+ConveyorMode+"', '"+DownloadMode+"', '"+FactoryLayoutPath+"', '"+MachineId+"', '"+MachineType+"', '"+TypeName+"', '"+ProcessingAreaCount+"', '"+StationSoftwareVersion+"', '"+MonitoringServiceVersion+"', '"+ComputerAddress+"')");
  409. JSONArray ProcessingAreaStateList=StateEventDetail.getJSONArray("ProcessingAreaStateList");
  410. for (int i=0;i<ProcessingAreaStateList.size();i++){
  411. JSONObject map1=ProcessingAreaStateList.getJSONObject(i);
  412. String ProcessingArea=map1.getString("ProcessingArea");
  413. String Conveyor=map1.getString("Conveyor");
  414. String CurrentStateBegin=map1.getString("CurrentStateBegin");
  415. String CurrentStateCode=map1.getString("CurrentStateCode");
  416. String CurrentStateDescription=map1.getString("CurrentStateDescription");
  417. String PreviousStateCode=map1.getString("PreviousStateCode");
  418. String PreviousStateDescription=map1.getString("PreviousStateDescription");
  419. baseDao.execute("insert into ProcessingAreaStateList(RAS_ID, RAS_STID, PROCESSINGAREA, CONVEYOR, CURRENTSTATEBEGIN, CURRENTSTATECODE, CURRENTSTATEDESCRIPTION, PREVIOUSSTATECODE, PREVIOUSSTATEDESCRIPTION)" +
  420. "values(ProcessingAreaStateList_seq.nextval,'"+st_id+"','"+ProcessingArea+"','"+Conveyor+"','"+CurrentStateBegin+"'," +
  421. "'"+CurrentStateCode+"','"+CurrentStateDescription+"','"+PreviousStateCode+"','"+PreviousStateDescription+"')");
  422. }
  423. }
  424. rmap.put("code","0");
  425. rmap.put("result","OK");
  426. rmap.put("ServerMessage","MES:贴片机数据记录成功");
  427. return rmap;
  428. }
  429. @Override
  430. public Map<Object,Object> SendPlaceData(String data) {
  431. Map<Object, Object> rmap = new HashMap<Object, Object>();
  432. JSONObject object = JSONObject.fromObject(data);
  433. Object object1 = object.get("data");
  434. JSONObject obj = JSONObject.fromObject(object1);
  435. JSONObject PlacedDataDetail=obj.getJSONObject("PlacedDataDetail");
  436. if(PlacedDataDetail!=null){
  437. int pd_id=baseDao.getSeqId("PlacedDataDetail_seq");
  438. String MESSAGESENDTIME=Time(PlacedDataDetail.getString("MessageSendTime"));
  439. String COMPLETIONSTATUSTYPE=PlacedDataDetail.getString("CompletionStatusType");
  440. String LINEFULLPATH=PlacedDataDetail.getString("LineFullPath");
  441. String MACHINEFULLPATH=PlacedDataDetail.getString("MachineFullPath");
  442. String RECIPEFULLPATH=PlacedDataDetail.getString("RecipeFullPath");
  443. String RECIPENAME=PlacedDataDetail.getString("RecipeName");
  444. String SETUPFULLPATH=PlacedDataDetail.getString("SetupName");
  445. String BOARDFULLPATH=PlacedDataDetail.getString("BoardFullPath");
  446. String FACTORYLAYOUTPATH=PlacedDataDetail.getString("FactoryLayoutPath");
  447. String MACHINEID=PlacedDataDetail.getString("MachineId");
  448. String MACHINETYPE=PlacedDataDetail.getString("MachineType");
  449. String STATIONSOFTWAREVERSION=PlacedDataDetail.getString("StationSoftwareVersion");
  450. String MONITORINGSERVICEVERSION=PlacedDataDetail.getString("MonitoringServiceVersion");
  451. String COMPUTERADDRESS=PlacedDataDetail.getString("ComputerAddress");
  452. baseDao.execute("insert into PlacedDataDetail(pd_id,MessageSendTime,CompletionStatusType,LineFullPath,MachineFullPath,RecipeFullPath," +
  453. "RecipeName,SETUPFULLPATH,BoardFullPath,FactoryLayoutPath,MachineId,MachineType,StationSoftwareVersion,MonitoringServiceVersion," +
  454. "ComputerAddress)values('"+pd_id+"',to_date('"+MESSAGESENDTIME+"','yyyy-mm-dd hh24:mi:ss'),'"+COMPLETIONSTATUSTYPE+"'," +
  455. "'"+LINEFULLPATH+"','"+MACHINEFULLPATH+"','"+RECIPEFULLPATH+"','"+RECIPENAME+"','"+SETUPFULLPATH+"','"+BOARDFULLPATH+"'," +
  456. "'"+FACTORYLAYOUTPATH+"','"+MACHINEID+"','"+MACHINETYPE+"','"+STATIONSOFTWAREVERSION+"','"+MONITORINGSERVICEVERSION+"','"+COMPUTERADDRESS+"')");
  457. JSONArray PanelList=PlacedDataDetail.getJSONArray("PlacedComponentList");
  458. for (int i=0;i<PanelList.size();i++){
  459. JSONObject map1=PanelList.getJSONObject(i);
  460. String TABLELOCATION =map1.getString("TableLocation");
  461. String TRACK=map1.getString("Track");
  462. String DIVISION=map1.getString("Division");
  463. String COMPONENTFULLPATH=map1.getString("ComponentFullPath");
  464. String COMPONENTNAME=map1.getString("ComponentName");
  465. String COMPONENTSHAPEFULLPATH=map1.getString("ComponentShapeFullPath");
  466. String FEEDERCATEGORY=map1.getString("FeederCategory");
  467. String FEEDERTYPENAME=map1.getString("FeederTypeName");
  468. String FEEDERID=map1.getString("FeederID");
  469. String ACCESSTOTAL=map1.getString("AccessTotal");
  470. String PlacedComponents=map1.getString("PlacedComponents");
  471. String REJECTQTY=map1.getString("RejectQty");
  472. String REJECTIDENT=map1.getString("RejectIdent");
  473. String REJECTVACUUM=map1.getString("RejectVacuum");
  474. String TRACKEMPTY=map1.getString("TrackEmpty");
  475. String IDENTERRROR=map1.getString("IdentErrror");
  476. String MATERIALDEFECT=map1.getString("MaterialDefect");
  477. String ABSENCEAFTERPICK=map1.getString("AbsenceAfterPick");
  478. String ABSENCEBEFOREPLACEMENT=map1.getString("AbsenceBeforePlacement");
  479. String TREATMENTERROR=map1.getString("TreatmentError");
  480. baseDao.execute("insert into PlacedComponentList(pc_id,pc_pdid,TABLELOCATION,TRACK,DIVISION,COMPONENTFULLPATH," +
  481. "COMPONENTNAME,COMPONENTSHAPEFULLPATH,FEEDERCATEGORY,FEEDERTYPENAME,FEEDERID,ACCESSTOTAL,PlacedComponents," +
  482. "REJECTQTY,REJECTIDENT,REJECTVACUUM,TRACKEMPTY,IDENTERRROR,MATERIALDEFECT,ABSENCEAFTERPICK,ABSENCEBEFOREPLACEMENT,TREATMENTERROR)" +
  483. "values(PlacedComponentList_seq.nextval,'"+pd_id+"','"+TABLELOCATION+"','"+TRACK+"','"+DIVISION+"','"+COMPONENTFULLPATH+"'" +
  484. ",'"+COMPONENTNAME+"','"+COMPONENTSHAPEFULLPATH+"','"+FEEDERCATEGORY+"','"+FEEDERTYPENAME+"','"+FEEDERID+"'," +
  485. "'"+ACCESSTOTAL+"','"+PlacedComponents+"','"+REJECTQTY+"','"+REJECTIDENT+"','"+REJECTVACUUM+"','"+TRACKEMPTY+"'," +
  486. "'"+IDENTERRROR+"','"+MATERIALDEFECT+"','"+ABSENCEAFTERPICK+"','"+ABSENCEBEFOREPLACEMENT+"','"+TREATMENTERROR+"')");
  487. }
  488. JSONArray PickupErrorList=PlacedDataDetail.getJSONArray("PickupErrorList");
  489. for (int i=0;i<PickupErrorList.size();i++){
  490. JSONObject map1=PickupErrorList.getJSONObject(i);
  491. String GANTRY=map1.getString("Gantry");
  492. String HEAD=map1.getString("Head");
  493. String SEGMENT1=map1.getString("Segment");
  494. String NOZZLE=map1.getString("Nozzle");
  495. String TABLELOCATION=map1.getString("TableLocation");
  496. String TRACK=map1.getString("Track");
  497. String DIVISION=map1.getString("Division");
  498. String TOWER=map1.getString("Tower");
  499. String LEVEL1=map1.getString("Level");
  500. String COMPONENTFULLPATH=map1.getString("ComponentFullPath");
  501. String COMPONENTNAME=map1.getString("ComponentName");
  502. String COMPONENTSHAPEFULLPATH=map1.getString("ComponentShapeFullPath");
  503. String COMPONENTSHAPENAME=map1.getString("ComponentShapeName");
  504. String FEEDERCATEGORY=map1.getString("FeederCategory");
  505. String FEEDERTYPENAME=map1.getString("FeederTypeName");
  506. String FEEDERID=map1.getString("FeederID");
  507. String ERRORTYPE=map1.getString("ErrorType");
  508. String ERRORDESCRIPTION=map1.getString("ErrorDescription");
  509. baseDao.execute("insert into PickupErrorList(pe_id,pe_pdid,Gantry,Head,SEGMENT1,NOZZLE,TABLELOCATION,TRACK,DIVISION,TOWER" +
  510. ",LEVEL1,COMPONENTFULLPATH,COMPONENTNAME,COMPONENTSHAPEFULLPATH,COMPONENTSHAPENAME,FEEDERCATEGORY,FEEDERTYPENAME," +
  511. "FEEDERID,ERRORTYPE,ERRORDESCRIPTION)values(PickupErrorList_seq.nextval,'"+pd_id+"','"+GANTRY+"','"+HEAD+"','"+SEGMENT1+"','"+NOZZLE+"'," +
  512. "'"+TABLELOCATION+"','"+TRACK+"','"+DIVISION+"','"+TOWER+"','"+LEVEL1+"','"+COMPONENTFULLPATH+"','"+COMPONENTNAME+"'," +
  513. "'"+COMPONENTSHAPEFULLPATH+"','"+COMPONENTSHAPENAME+"','"+FEEDERCATEGORY+"','"+FEEDERTYPENAME+"','"+FEEDERID+"','"+ERRORTYPE+"'," +
  514. "'"+ERRORDESCRIPTION+"')");
  515. }
  516. }
  517. rmap.put("code","0");
  518. rmap.put("result","OK");
  519. rmap.put("ServerMessage","MES:贴片机数据记录成功");
  520. return rmap;
  521. }
  522. @Override
  523. public Map<Object,Object> TraceabilityDataInterface(String data) {
  524. Integer td_id=baseDao.getSeqId("TRACEDATA_seq");
  525. Map<Object, Object> rmap = new HashMap<Object, Object>();
  526. JSONObject object = JSONObject.fromObject(data);
  527. Object object1 = object.get("data");
  528. JSONObject obj = JSONObject.fromObject(object1);
  529. JSONObject TraceabilityDataDetail=obj.getJSONObject("TraceabilityDataDetail");
  530. if(TraceabilityDataDetail!=null){
  531. String DateBegin=Time(TraceabilityDataDetail.get("DateBegin").toString());
  532. String DateCompleted=Time(TraceabilityDataDetail.get("DateCompleted").toString());
  533. String LineName=TraceabilityDataDetail.get("LineName").toString();
  534. String MachineName=TraceabilityDataDetail.get("MachineName").toString();
  535. String BoardName=TraceabilityDataDetail.get("BoardName").toString();
  536. String MachineID=TraceabilityDataDetail.get("MachineID").toString();
  537. String BoardSide=TraceabilityDataDetail.get("BoardSide").toString();
  538. String OrderNumber=TraceabilityDataDetail.get("OrderNumber").toString();
  539. String PCBBarcode=TraceabilityDataDetail.get("PCBBarcode").toString();
  540. baseDao.execute("insert into TRACEDATA(TD_ID,DateBegin,DateCompleted,LineName,MachineName,BoardName,MachineID,BoardSide,OrderNumber,PCBBarcode,TD_INDATE)" +
  541. "values("+td_id+",to_date('"+DateBegin+"','yyyy-mm-dd hh24:mi:ss'),to_date('"+DateCompleted+"','yyyy-mm-dd hh24:mi:ss')," +
  542. "'"+LineName+"','"+MachineName+"','"+BoardName+"','"+MachineID+"','"+BoardSide+"','"+OrderNumber+"','"+PCBBarcode+"',sysdate)");
  543. JSONObject MaterialTraceabilityDetail=null;
  544. try{
  545. MaterialTraceabilityDetail=TraceabilityDataDetail.getJSONObject("MaterialTraceabilityDetail");
  546. }catch (Exception e){
  547. }
  548. JSONObject MaterialConsumptionDetail=null;
  549. try{
  550. MaterialConsumptionDetail=TraceabilityDataDetail.getJSONObject("MaterialConsumptionDetail");
  551. }catch (Exception e){
  552. }
  553. //上料信息
  554. if(MaterialTraceabilityDetail!=null){
  555. JSONArray PanelList=MaterialTraceabilityDetail.getJSONArray("PanelList");
  556. for (int i=0;i<PanelList.size();i++){
  557. JSONObject map=PanelList.getJSONObject(i);
  558. String PanelName=map.get("PanelName").toString();
  559. JSONArray PackagingUnitRefList=map.getJSONArray("PackagingUnitRefList");
  560. System.out.println(PackagingUnitRefList.size());
  561. if(PackagingUnitRefList!=null){
  562. for (int j=0;j<PackagingUnitRefList.size();j++){
  563. String PlaceRefID="";
  564. JSONObject map1=PackagingUnitRefList.getJSONObject(j);
  565. String PUID=map1.getString("PUID");
  566. String TableLocation=map1.getString("TableLocation");
  567. String Track=map1.getString("Track");
  568. String ComponentBarcode=map1.getString("ComponentBarcode");
  569. String OriginalQuantity=map1.getString("OriginalQuantity");
  570. String Quantity=map1.getString("Quantity");
  571. String CreateDate=Time(map1.getString("CreateDate"));
  572. String DateCode=map1.getString("DateCode");
  573. String Batch2=map1.getString("Batch2");
  574. String MsdLevel=map1.getString("MsdLevel");
  575. String VerifiedDate=Time(map1.getString("VerifiedDate"));
  576. String Operator=map1.getString("Operator");
  577. JSONArray PlaceRefList=map1.getJSONArray("PlaceRefList");
  578. if(PlaceRefList!=null){
  579. for (int k=0;k<PlaceRefList.size();k++){
  580. JSONObject map2=PlaceRefList.getJSONObject(k);
  581. PlaceRefID+=map2.getString("PlaceRefID")+",";
  582. }
  583. }
  584. baseDao.execute("insert into MATERIALTRACE(MT_ID,MT_TDID,PANELNAME,PUID,PlaceRefList,TableLocation,Track,ComponentBarcode,OriginalQuantity,Quantity,CreateDate,DateCode,Batch2,MsdLevel,VerifiedDate,Operator)" +
  585. "values(MATERIALTRACE_seq.nextval,'"+td_id+"','"+PanelName+"','"+PUID+"','"+PlaceRefID+"','"+TableLocation+"','"+Track+"','"+ComponentBarcode+"','"+OriginalQuantity+"','"+Quantity+"',to_date('"+CreateDate+"','yyyy-mm-dd hh24:mi:ss'),'"+DateCode+"','"+Batch2+"'," +
  586. "'"+MsdLevel+"',to_date('"+CreateDate+"','yyyy-mm-dd hh24:mi:ss'),'"+Operator+"')");
  587. }
  588. }
  589. }
  590. }
  591. //扣料信息
  592. if(MaterialConsumptionDetail!=null){
  593. JSONArray ConsumedPackagingUnitList=MaterialConsumptionDetail.getJSONArray("ConsumedPackagingUnitList");
  594. for (int i=0;i<ConsumedPackagingUnitList.size();i++){
  595. JSONObject map1=ConsumedPackagingUnitList.getJSONObject(i);
  596. String PUID=map1.getString("PUID");
  597. String AccessTotal=map1.getString("AccessTotal");
  598. String RejectIdent=map1.getString("RejectIdent");
  599. String RejectVacuum=map1.getString("RejectVacuum");
  600. String TrackEmpty=map1.getString("TrackEmpty");
  601. baseDao.execute("insert into CONSUMEDPACKAGING(cp_id,cp_tdid,puid,AccessTotal,RejectIdent,RejectVacuum" +
  602. ",TrackEmpty) values(CONSUMEDPACKAGING_seq.nextval,'"+td_id+"','"+PUID+"','"+AccessTotal+"','"+RejectIdent+"','"+RejectVacuum+"'," +
  603. "'"+TrackEmpty+"')");
  604. }
  605. }
  606. rmap.put("code","0");
  607. rmap.put("result","OK");
  608. rmap.put("ServerMessage","MES:贴片机数据记录成功");
  609. }
  610. return rmap;
  611. }
  612. public Map<Object,Object> XrayTestDataSave(String data){
  613. Map<Object, Object> rmap = new HashMap<Object, Object>();
  614. Map<String, Object> map=null;
  615. JSONObject object = JSONObject.fromObject(data);
  616. Object object1 = object.get("data");
  617. JSONObject obj = JSONObject.fromObject(object1);
  618. JSONArray object2=obj.getJSONArray("NonconformData");
  619. Object Barcode=obj.get("Barcode");
  620. Object EquipmentEncode=obj.get("EquipmentEncode");
  621. Object ModelType=obj.get("ModelType");
  622. Object CheckNumber=obj.get("CheckNumber");
  623. Object NcmNumber=obj.get("NcmNumber");
  624. Object NonconformNumber=obj.get("NonconformNumber");
  625. Object CheckDate=obj.get("CheckDate");
  626. Object ShiftName=obj.get("ShiftName");
  627. Object LineBody=obj.get("LineBody");
  628. Object Inspector=obj.get("Inspector");
  629. int XT_ID = baseDao.getSeqId("xraytest_seq");
  630. baseDao.execute("insert into xraytest(XT_ID, BARCODE, EQUIPMENTENCODE, MODELTYPE, CHECKNUMBER, NCMNUMBER, NONCONFORMNUMBER, CHECKDATE, SHIFTNAME, LINEBODY, INSPECTOR)" +
  631. "values("+XT_ID+",'"+Barcode+"','"+EquipmentEncode+"','"+ModelType+"','"+CheckNumber+"','"+NcmNumber+"','"+NonconformNumber+"',to_date('"+CheckDate+"','yyyy-mm-dd hh24:mi:ss')" +
  632. ",'"+ShiftName+"','"+LineBody+"','"+Inspector+"')");
  633. for (int i=0;i<object2.size();i++){
  634. JSONObject map1=object2.getJSONObject(i);
  635. String NonconformANo=map1.getString("NonconformANo");
  636. String NonconformDescription=map1.getString("NonconformDescription");
  637. baseDao.execute("insert into XrayTestdetail(xtd_xtid,xtd_id,NONCONFORMANO, NONCONFORMDESCRIPTION)" +
  638. "values("+XT_ID+",XrayTestdetail_seq.nextval,'"+NonconformANo+"','"+NonconformDescription+"')");
  639. }
  640. rmap.put("code","0");
  641. rmap.put("result","OK");
  642. rmap.put("ServerMessage","MES:检查数据上传成功!");
  643. return rmap;
  644. }
  645. public String Time(String time){
  646. return time.replaceAll("T"," ").substring(0,19);
  647. }
  648. @Override
  649. public Map<Object,Object> Weigh(String data) {
  650. Map<Object, Object> rmap = new HashMap<Object, Object>();
  651. String oErrMessage="";
  652. String lotSN="";
  653. String specificationName="";
  654. String weight="";
  655. String moName="";
  656. String workcenterName="";
  657. Map<String, Object> map=null;
  658. try{
  659. map =BaseUtil.convertJsonToMap(data);
  660. }catch (Exception e){
  661. System.out.printf(e.getMessage()) ;
  662. }
  663. if(map.get("lotSN")==null){
  664. oErrMessage = "SN不能为空";
  665. rmap.put("oErrMessage",oErrMessage);
  666. return rmap;
  667. }
  668. if(map.get("lotSN")==null){
  669. oErrMessage = "SN不能为空";
  670. rmap.put("oErrMessage",oErrMessage);
  671. return rmap;
  672. }
  673. if(map.get("specificationName")==null){
  674. oErrMessage = "工序不能为空";
  675. rmap.put("oErrMessage",oErrMessage);
  676. return rmap;
  677. }
  678. if(map.get("weight")==null){
  679. oErrMessage = "重量不能为空";
  680. rmap.put("oErrMessage",oErrMessage);
  681. return rmap;
  682. }
  683. lotSN=map.get("lotSN").toString();
  684. SqlRowList rs=baseDao.queryForRowSet("select ms_sncode from makeserial where ms_imei1='"+lotSN+"' or ms_imei2='"+lotSN+"' or ms_imei3='"+lotSN+"' or ms_imei4='"+lotSN+"'");
  685. if(rs.next()){
  686. lotSN=rs.getString("ms_sncode");
  687. }else{
  688. rs=baseDao.queryForRowSet("select mil_sncode from makeimeilist where mil_imei1='"+lotSN+"' or mil_imei2='"+lotSN+"' or mil_imei3='"+lotSN+"' or mil_imei4='"+lotSN+"'");
  689. if(rs.next()){
  690. lotSN=rs.getString("mil_sncode");
  691. }
  692. }
  693. specificationName=map.get("specificationName").toString();
  694. weight=map.get("weight").toString().replaceAll("KG","");
  695. oErrMessage=CheckRoutePassed(lotSN,specificationName);
  696. if(oErrMessage!=null){
  697. rmap.put("code",-1);
  698. rmap.put("message",oErrMessage);
  699. Map<String, String> rmap1 = new HashMap<String, String>();
  700. rmap1.put("minWeight","");
  701. rmap1.put("maxWeightc","");
  702. rmap1.put("machineModel","");
  703. rmap.put("dataInfo",rmap1);
  704. return rmap;
  705. }
  706. Object[] obj = baseDao.getFieldsDataByCondition("makeserial left join product on pr_code=ms_prodcode","pr_colorboxminw,pr_colorboxmaxw","ms_id =(select max(ms_id) from makeserial where ms_sncode='"+lotSN+"')");
  707. if(obj[0]!=null&&obj[1]!=null){
  708. //不在设置的重量范围内
  709. if(Double.parseDouble(weight)<Double.parseDouble(obj[0].toString())||Double.parseDouble(weight)>Double.parseDouble(obj[1].toString())){
  710. rmap.put("code",-1);
  711. rmap.put("message","SN["+lotSN+"]重量为"+weight+",不符合重量范围"+obj[0]+"-"+obj[1]);
  712. Map<String, String> rmap1 = new HashMap<String, String>();
  713. rmap1.put("minWeight",obj[0].toString());
  714. rmap1.put("maxWeight",obj[1].toString());
  715. rmap1.put("machineModel","");
  716. rmap.put("dataInfo",rmap1);
  717. return rmap;
  718. }
  719. Object oErr=SetPcbaData(lotSN,specificationName,specificationName,"OK");
  720. if(oErr==null){
  721. rmap.put("code",0);
  722. rmap.put("message","SN["+lotSN+"]重量为"+weight+",符合重量范围"+obj[0]+"-"+obj[1]+",称重通过");
  723. Object ms_id=baseDao.getFieldDataByCondition("makeserial","max(ms_id)","ms_sncode='"+lotSN+"'");
  724. baseDao.execute("update makeserial set ms_grossw ='"+weight+"' where ms_id="+ms_id);
  725. }else{
  726. rmap.put("code",-1);
  727. rmap.put("message",oErr);
  728. }
  729. Map<String, String> rmap1 = new HashMap<String, String>();
  730. rmap1.put("minWeight",obj[0].toString());
  731. rmap1.put("maxWeight",obj[1].toString());
  732. rmap1.put("machineModel","");
  733. rmap.put("dataInfo",rmap1);
  734. return rmap;
  735. }
  736. return rmap;
  737. }
  738. @Override
  739. public Map<Object,Object> UploadReelInfo(String data) {
  740. Map<Object, Object> rmap = new HashMap<Object, Object>();
  741. String oErrMessage="";
  742. String ReelId="";
  743. String Quantity="";
  744. Map<String, Object> map=null;
  745. try{
  746. map =BaseUtil.convertJsonToMap(data);
  747. }catch (Exception e){
  748. System.out.printf(e.getMessage()) ;
  749. }
  750. if(map.get("ReelId")==null){
  751. rmap.put("Status","NG");
  752. rmap.put("Meassage","料盘ID不能为空");
  753. return rmap;
  754. }
  755. if(map.get("Quantity")==null){
  756. rmap.put("Status","NG");
  757. rmap.put("Meassage","数量不能为空");
  758. return rmap;
  759. }
  760. ReelId=map.get("ReelId").toString();
  761. Quantity=map.get("Quantity").toString();
  762. SqlRowList rs=baseDao.queryForRowSet("select bar_id,bar_prodcode,bar_remain,pr_spec,to_char(nvl(bar_madedate,sysdate),'yyyy-mm-dd')bar_madedate,bar_vendcode,bar_vendbarcode,pr_detail,bar_ordercode from barcode left join product on bar_prodcode = pr_code where bar_code=?",ReelId);
  763. if(rs.next()){
  764. /*baseDao.execute("update barcode@ERP_JMDZ_HF set bar_remain=?,bar_status = 2 where bar_id=?",Quantity,rs.getString("bar_id"));
  765. baseDao.execute("insert into barcodechange@ERP_JMDZ_HF(BC_ID,BC_INDATE, BC_REASON, BC_QTY, BC_BARCODE, BC_PRODCODE, BC_NEWQTY)" +
  766. "values(barcodechange_seq.nextval@ERP_JMDZ_HF,sysdate,'点料机更新条码数量',?,?,?,?)",rs.getString("bar_remain"),ReelId,rs.getString("bar_prodcode"),Quantity);*/
  767. baseDao.execute("update barcode set bar_remain=?,bar_status = 1,bar_outno = '' where bar_code=?",Quantity,ReelId);
  768. baseDao.execute("insert into barcodechange(BC_ID,BC_INDATE, BC_REASON, BC_QTY, BC_BARCODE, BC_PRODCODE, BC_NEWQTY)" +
  769. "values(barcodechange_seq.nextval,sysdate,'点料机更新条码数量',?,?,?,?)",rs.getString("bar_remain"),ReelId,rs.getString("bar_prodcode"),Quantity);
  770. rmap.put("Status","OK");
  771. rmap.put("Meassage","通过");
  772. rmap.put("PN",rs.getString("bar_prodcode"));
  773. rmap.put("MPN",rs.getString("pr_spec"));
  774. rmap.put("DataCode",rs.getString("bar_madedate"));
  775. rmap.put("VENDCODE",rs.getString("bar_vendcode") != null ? rs.getString("bar_vendcode") : "");
  776. rmap.put("VENDBARCODE",rs.getString("bar_vendbarcode") != null ? rs.getString("bar_vendbarcode") : "");
  777. rmap.put("PRDETAIL",rs.getString("pr_detail") != null ? rs.getString("bar_vendbarcode") : "");
  778. rmap.put("ORDERCODE",rs.getString("bar_ordercode") != null ? rs.getString("bar_ordercode") : "");
  779. }else {
  780. rmap.put("Status","NG");
  781. rmap.put("Meassage","条码不存在");
  782. return rmap;
  783. }
  784. return rmap;
  785. }
  786. @Override
  787. public Map<Object,Object> SendSolderExecuteNode(String data) {
  788. Map<Object, Object> rmap = new HashMap<Object, Object>();
  789. String SolderCode="",ScanTime ="",Station ="",Node ="";
  790. String SysName = "",UserName ="";
  791. Map<String, Object> map=null;
  792. try{
  793. map =BaseUtil.convertJsonToMap(data);
  794. }catch (Exception e){
  795. System.out.printf(e.getMessage()) ;
  796. }
  797. if(map.get("SolderCode")==null){
  798. rmap.put("Result","NG");
  799. rmap.put("Meassage","锡膏条码不能为空");
  800. return rmap;
  801. }
  802. if(map.get("ScanTime")==null){
  803. rmap.put("Result","NG");
  804. rmap.put("Meassage","扫描时间不能为空");
  805. return rmap;
  806. }
  807. if(map.get("Station")==null){
  808. rmap.put("Result","NG");
  809. rmap.put("Meassage","设备编码不能为空");
  810. return rmap;
  811. }
  812. if(map.get("Node")==null){
  813. rmap.put("Result","NG");
  814. rmap.put("Meassage","当前节点状态不能为空");
  815. return rmap;
  816. }
  817. SolderCode=map.get("SolderCode").toString();
  818. ScanTime=Time(map.get("ScanTime").toString());
  819. Station=map.get("Station").toString();
  820. Node=map.get("Node").toString();
  821. UserName=map.get("UserName").toString();
  822. SysName=map.get("SysName").toString();
  823. //SqlRowList rs=baseDao.queryForRowSet("select bar_id,bar_prodcode,bar_remain,pr_spec,to_char(nvl(bar_madedate,sysdate),'yyyy-mm-dd')bar_madedate from barcode@ERP_JMDZ_HF left join product on bar_prodcode = pr_code where bar_code=?",SolderCode);
  824. SqlRowList rs=baseDao.queryForRowSet("SELECT spb_id,nvl(spb_use_count,1) spb_use_count FROM spmbarcode WHERE spb_barcode = ?",SolderCode);
  825. if(rs.next()){
  826. String curCount = rs.getString("spb_use_count");
  827. if(Node.contains("回温开始")){
  828. int spb_use_count = Integer.parseInt(curCount) + 1;
  829. baseDao.updateByCondition("spmbarcode", "spb_status = '"+Node+"',spb_update_time = to_date('"+ScanTime+"','yyyy-mm-dd hh24:mi:ss'),spb_use_count = '"+ spb_use_count +"'", "spb_barcode='" + SolderCode + "'");
  830. baseDao.execute("INSERT INTO spmlog ( spl_id, spl_date, spl_operation, spl_operator, spl_barcode, spl_user_count, spl_equipment,spl_sysname) VALUES ( spmlog_seq.NEXTVAL, TO_DATE(?, 'yyyy-mm-dd hh24:mi:ss'), ?, ?, ?, ?, ?,?)",ScanTime,Node,UserName,SolderCode,spb_use_count,Station,SysName);
  831. rmap.put("Result","OK");
  832. rmap.put("Meassage", Node +": 记录成功");
  833. }else{
  834. baseDao.updateByCondition("spmbarcode", "spb_status = '"+Node+"',spb_update_time = to_date('"+ScanTime+"','yyyy-mm-dd hh24:mi:ss'),spb_use_count = '"+ curCount +"'", "spb_barcode='" + SolderCode + "'");
  835. baseDao.execute("INSERT INTO spmlog ( spl_id, spl_date, spl_operation, spl_operator, spl_barcode, spl_user_count, spl_equipment,spl_sysname) VALUES ( spmlog_seq.NEXTVAL, TO_DATE(?, 'yyyy-mm-dd hh24:mi:ss'), ?, ?, ?, ?, ?,?)",ScanTime,Node,UserName,SolderCode,curCount,Station,SysName);
  836. rmap.put("Result","OK");
  837. rmap.put("Meassage",Node +": 记录成功");
  838. }
  839. }else {
  840. rmap.put("Result","NG");
  841. rmap.put("Meassage","锡膏条码不存在,请先录入锡膏");
  842. return rmap;
  843. }
  844. return rmap;
  845. }
  846. @Override
  847. public Map<Object,Object> StencilInspect(String data){
  848. Map<Object, Object> rmap = new HashMap<Object, Object>();
  849. String MeshCode ="",InspectMode ="";
  850. Map<String, Object> map=null;
  851. try{
  852. map =BaseUtil.convertJsonToMap(data);
  853. }catch (Exception e){
  854. System.out.printf(e.getMessage()) ;
  855. }
  856. if(map.get("MeshCode")==null){
  857. rmap.put("Result","NG");
  858. rmap.put("Meassage","钢网编码不能为空");
  859. return rmap;
  860. }
  861. InspectMode=map.get("InspectMode").toString();
  862. MeshCode = map.get("MeshCode").toString();
  863. Map<Object, Object> paramsMap = new HashMap<Object, Object>();
  864. Map<Object, Object> paramsMap1 = new HashMap<Object, Object>();
  865. try{
  866. SqlRowList rs=baseDao.queryForRowSet("SELECT st_id,st_line,nvl(st_cleannums, 0) st_cleannums FROM stencil WHERE st_kind = '钢网' AND st_code = ?",MeshCode);
  867. if(rs.next()){
  868. String cleannums = rs.getString("st_cleannums");
  869. SqlRowList rs1=baseDao.queryForRowSet("SELECT stenciluse_seq.NEXTVAL seq FROM dual");
  870. if(rs1.next()){
  871. paramsMap.put("su_id",rs1.getString("seq"));
  872. paramsMap.put("su_useman",map.get("Inspector").toString());
  873. paramsMap.put("su_stcode",MeshCode);
  874. paramsMap.put("su_stid",rs.getString("st_id"));
  875. paramsMap.put("su_status",InspectMode);
  876. paramsMap.put("su_linecode",rs.getString("st_line"));
  877. paramsMap.put("su_usedate",map.get("InspectTime").toString());
  878. paramsMap.put("su_ensiona",map.get("Tension1").toString());
  879. paramsMap.put("su_ensionb",map.get("Tension2").toString());
  880. paramsMap.put("su_ensionc",map.get("Tension3").toString());
  881. paramsMap.put("su_ensiond",map.get("Tension4").toString());
  882. paramsMap.put("su_ensione",map.get("Tension5").toString());
  883. if(InspectMode.contains("清洗")){
  884. paramsMap.put("su_cleannums",Integer.parseInt(cleannums) + 1);
  885. baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap,"stenciluse"));
  886. }else{
  887. paramsMap.put("su_cleannums",cleannums);
  888. baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap,"stenciluse"));
  889. }
  890. // paramsMap1.put("std_id","steptestdetail_seq.NEXTVAL");
  891. paramsMap1.put("std_class",InspectMode);
  892. paramsMap1.put("STD_SUBCLASS1",rs1.getString("seq"));
  893. paramsMap1.put("STD_DATE",map.get("InspectTime").toString());
  894. paramsMap1.put("STD_VALUE1",map.get("DeviceCode").toString());
  895. paramsMap1.put("STD_VALUE2",map.get("action").toString());
  896. paramsMap1.put("STD_VALUE3",map.get("Inspector").toString());
  897. paramsMap1.put("STD_VALUE4",map.get("HoleResult").toString());
  898. paramsMap1.put("STD_VALUE5",map.get("TensionResult").toString());
  899. paramsMap1.put("STD_VALUE6",map.get("InspectResult").toString());
  900. paramsMap1.put("STD_VALUE7",map.get("InspectState").toString());
  901. paramsMap1.put("STD_VALUE8",map.get("SizeErrNum").toString());
  902. paramsMap1.put("STD_VALUE9",map.get("LocationErrNum").toString());
  903. paramsMap1.put("STD_VALUE10",map.get("SurplusNum").toString());
  904. paramsMap1.put("STD_VALUE11",map.get("InsufficientNum").toString());
  905. paramsMap1.put("STD_VALUE12",map.get("AreaErrNum").toString());
  906. paramsMap1.put("STD_VALUE13",map.get("ForeignMatterNum").toString());
  907. paramsMap1.put("STD_VALUE14",map.get("PlugHoleNum").toString());
  908. paramsMap1.put("STD_VALUE15",map.get("OtherErrNum").toString());
  909. paramsMap1.put("STD_VALUE16",map.get("ErrCount").toString());
  910. paramsMap1.put("STD_VALUE17",map.get("HoleCount").toString());
  911. baseDao.execute(SqlUtil.getInsertSqlByMap(paramsMap1,"steptestdetail"));
  912. rmap.put("Result","OK");
  913. rmap.put("Meassage",InspectMode +": 记录成功");
  914. }else{
  915. rmap.put("Result","NG");
  916. rmap.put("Meassage","获取序列失败");
  917. }
  918. }else {
  919. rmap.put("Result","NG");
  920. rmap.put("Meassage","钢网条码不存在,请先录入钢网");
  921. return rmap;
  922. }
  923. }catch(Exception e){
  924. rmap.put("Result", "NG");
  925. rmap.put("Meassage", "系统异常: " + e.getMessage());
  926. }
  927. return rmap;
  928. }
  929. @Override
  930. public Map<Object,Object> FirstInspect(String data){
  931. Map<String, Object> map=null;
  932. try{
  933. map =BaseUtil.convertJsonToMap(data);
  934. }catch (Exception e){
  935. System.out.printf(e.getMessage()) ;
  936. }
  937. baseDao.execute("insert into "+username+".EISDATA(ed_id,ed_data,ed_indate)values("+username+".EISDATA_seq.nextval,?,sysdate)",data);
  938. Map<Object, Object> rmap = new HashMap<Object, Object>();
  939. rmap.put("Result", "OK");
  940. rmap.put("Meassage", "成功");
  941. return rmap;
  942. }
  943. @Override
  944. public Map<Object,Object> DLLMain(String accessKey, String requestId, String data) {
  945. String AE_MASTER = "N_MES";
  946. SpObserver.putSp(AE_MASTER);
  947. Map<Object, Object> map = BaseUtil.parseFormStoreToMap(data);
  948. //解析map
  949. if(!StringUtil.hasText(map.get("type"))){
  950. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPENULL,requestId));
  951. }
  952. if(!StringUtil.hasText(map.get("detail"))){
  953. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_DATAILLEGAL,requestId));
  954. }
  955. String type = map.get("type").toString();
  956. JSONObject json = JSONObject.fromObject(map.get("detail"));
  957. HelperType helperType = HelperType.getTypeByCode(type);
  958. if(null == helperType){
  959. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPEILLEGAL,requestId));
  960. }
  961. baseDao.execute("insert into EISDATA(ed_id,ed_data,ed_indate)values(EISDATA_seq.nextval,?,sysdate)",data);
  962. int err = 0;
  963. //返回值
  964. Map<Object, Object> remap = new HashMap<Object, Object>();
  965. switch(helperType){
  966. case CheckRoutePassed:
  967. remap = CheckRoutePassed(json);
  968. break;
  969. case CheckUserAndResourcePassed:
  970. remap = CheckUserAndResourcePassed(json);
  971. break;
  972. case GetAddressRangeByMO:
  973. remap = GetAddressRangeByMO(json);
  974. break;
  975. case GetMEIOrNetCodeRange:
  976. remap = GetMEIOrNetCodeRange(json);
  977. break;
  978. case GetRcardMOInfo:
  979. remap = GetRcardMOInfo(json);
  980. break;
  981. case GetMobileAllInfo:
  982. remap = GetMobileAllInfo(json);
  983. break;
  984. case SetAddressInfo:
  985. remap = SetAddressInfo(json);
  986. break;
  987. case GetMaster:
  988. remap = GetMaster(json);
  989. break;
  990. case SetMobileData:
  991. remap = SetMobileData(json);
  992. break;
  993. case SetIMEIInfo:
  994. remap = SetIMEIInfo(json);
  995. break;
  996. case SetTestDetail:
  997. remap = SetTestDetail(json);
  998. break;
  999. case SetPcbaData:
  1000. remap = SetPcbaData(json);
  1001. break;
  1002. case GetInfoByMaterial:
  1003. remap = GetInfoByMaterial(json);
  1004. break;
  1005. case GoMo:
  1006. remap = GoMo(json);
  1007. break;
  1008. case GetMakeInfoBySN:
  1009. remap = GetMakeInfoBySN(json);
  1010. break;
  1011. default:
  1012. err = -1;
  1013. break;
  1014. }
  1015. if(err == -1){
  1016. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPEILLEGAL,requestId));
  1017. }
  1018. SpObserver.putSp(username);
  1019. return remap;
  1020. }
  1021. private Map<Object,Object> GoMo(JSONObject map){
  1022. Map<Object, Object> rmap = new HashMap<Object, Object>();
  1023. String iSN=null;
  1024. String iResCode=null;
  1025. String iMo=null;
  1026. String oErrMessage=null;
  1027. if(map.get("iMo")==null){
  1028. oErrMessage = "工单号不能为空";
  1029. rmap.put("oErrMessage",oErrMessage);
  1030. return rmap;
  1031. }
  1032. if(map.get("iResCode")==null){
  1033. oErrMessage = "岗位资源不能为空";
  1034. rmap.put("oErrMessage",oErrMessage);
  1035. return rmap;
  1036. }
  1037. if(map.get("iSN")==null){
  1038. oErrMessage = "SN不能为空";
  1039. rmap.put("oErrMessage",oErrMessage);
  1040. return rmap;
  1041. }
  1042. iSN=map.get("iSN").toString();
  1043. iResCode=map.get("iResCode").toString();
  1044. iMo=map.get("iMo").toString();
  1045. List<String> list = new ArrayList<String>();
  1046. list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
  1047. String.valueOf(iMo),
  1048. String.valueOf(iResCode),
  1049. String.valueOf(iSN),
  1050. String.valueOf("")
  1051. }, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
  1052. oErrMessage=list.get(2);
  1053. SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=( select max(ms_id) from makeserial where ms_sncode in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' ' union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
  1054. String ms_status = "";
  1055. String ms_stepcode = "";
  1056. String ms_nextstepcode = "";
  1057. if(rs.next()){
  1058. ms_status= rs.getString("ms_status");
  1059. ms_stepcode=rs.getString("ms_stepcode");
  1060. ms_nextstepcode=rs.getString("ms_nextstepcode");
  1061. }
  1062. String stepcode = GetStepCodeBySource(iResCode);
  1063. if ( oErrMessage == null || (ms_status == "3" && ms_stepcode == stepcode))
  1064. {
  1065. if (ms_status == "3")
  1066. {
  1067. oErrMessage = null;
  1068. }
  1069. }
  1070. rmap.put("oErrMessage",oErrMessage);
  1071. return rmap;
  1072. }
  1073. private String GoMo(String iSN,String iMo,String iResCode){
  1074. Map<Object, Object> rmap = new HashMap<Object, Object>();
  1075. String oErrMessage=null;
  1076. List<String> list = new ArrayList<String>();
  1077. list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
  1078. String.valueOf(iMo),
  1079. String.valueOf(iResCode),
  1080. String.valueOf(iSN),
  1081. String.valueOf("")
  1082. }, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
  1083. oErrMessage=list.get(2);
  1084. SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=( select max(ms_id) from makeserial where ms_sncode in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' ' union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
  1085. String ms_status = "";
  1086. String ms_stepcode = "";
  1087. String ms_nextstepcode = "";
  1088. if(rs.next()){
  1089. ms_status= rs.getString("ms_status");
  1090. ms_stepcode=rs.getString("ms_stepcode");
  1091. ms_nextstepcode=rs.getString("ms_nextstepcode");
  1092. }
  1093. String stepcode = GetStepCodeBySource(iResCode);
  1094. if ( oErrMessage == null || (ms_status == "3" && ms_stepcode == stepcode))
  1095. {
  1096. if (ms_status == "3")
  1097. {
  1098. oErrMessage = null;
  1099. }
  1100. }
  1101. return oErrMessage;
  1102. }
  1103. private Map<Object,Object> GetInfoByMaterial(JSONObject map){
  1104. Map<Object, Object> rmap = new HashMap<Object, Object>();
  1105. String iPCBA=null;
  1106. String oErrMessage=null;
  1107. if(map.get("iPCBA")==null){
  1108. oErrMessage = "主板SN不能为空";
  1109. rmap.put("oErrMessage",oErrMessage);
  1110. return rmap;
  1111. }
  1112. iPCBA=map.get("iPCBA").toString();
  1113. SqlRowList rs=baseDao.queryForRowSet("select nvl(max(ms_id),0)ms_id from CRAFTMATERIAL left join makeserial on ms_firstsn=cm_firstsn where cm_barcode='"+iPCBA+"' and nvl(cm_status,0)<>-1 order by cm_id desc");
  1114. if(rs.next()){
  1115. if(!rs.getString("ms_id").equals("0")){
  1116. rs=baseDao.queryForRowSet("select ma_bios,ma_ec,ms_sncode,ma_hardware from makeserial left join make on ms_makecode=ma_code where ms_id='"+rs.getString("ms_id")+"'");
  1117. if (rs.next()){
  1118. rmap.put("oSN",rs.getString("ms_sncode"));
  1119. rmap.put("oBIOS",rs.getString("ma_bios"));
  1120. rmap.put("oEC",rs.getString("ma_ec"));
  1121. rmap.put("oHardWare",rs.getString("ma_hardware"));
  1122. }
  1123. }else{
  1124. oErrMessage = "主板SN未查询到关联信息";
  1125. rmap.put("oErrMessage",oErrMessage);
  1126. return rmap;
  1127. }
  1128. }
  1129. return rmap;
  1130. }
  1131. private Map<Object,Object> CheckRoutePassed(JSONObject map){
  1132. //实际业务数据
  1133. Map<Object, Object> rmap = new HashMap<>();
  1134. String iSN=map.get("iSN").toString();
  1135. String iResCode=map.get("iResCode").toString();
  1136. String oErrMessage="";
  1137. if (iSN ==null)
  1138. {
  1139. oErrMessage = "SN不能为空";
  1140. }
  1141. List<String> list = new ArrayList<String>();
  1142. list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
  1143. String.valueOf(""),
  1144. String.valueOf(iResCode),
  1145. String.valueOf(iSN),
  1146. String.valueOf("")
  1147. }, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
  1148. oErrMessage=list.get(2);
  1149. if(oErrMessage!=null){
  1150. rmap.put("oErrMessage",oErrMessage);
  1151. return rmap;
  1152. }
  1153. SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=( select max(ms_id) from makeserial where ms_sncode in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' ' union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
  1154. String ms_status = "";
  1155. String ms_stepcode = "";
  1156. String ms_nextstepcode = "";
  1157. if(rs.next()){
  1158. ms_status= rs.getString("ms_status");
  1159. ms_stepcode=rs.getString("ms_stepcode");
  1160. ms_nextstepcode=rs.getString("ms_nextstepcode");
  1161. }
  1162. String stepcode = GetStepCodeBySource(iResCode);
  1163. if (ms_nextstepcode != "" && !ms_nextstepcode.equals(stepcode))
  1164. {
  1165. oErrMessage = "当前序列号下一工序" + ms_nextstepcode;
  1166. }
  1167. rmap.put("oErrMessage",oErrMessage);
  1168. return rmap;
  1169. }
  1170. private String CheckRoutePassed(String iSN,String iResCode){
  1171. //实际业务数据
  1172. Map<Object, Object> rmap = new HashMap<>();
  1173. String oErrMessage;
  1174. if (iSN ==null)
  1175. {
  1176. oErrMessage = "SN不能为空";
  1177. }
  1178. List<String> list = new ArrayList<String>();
  1179. list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
  1180. String.valueOf(""),
  1181. String.valueOf(iResCode),
  1182. String.valueOf(iSN),
  1183. String.valueOf("")
  1184. }, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
  1185. oErrMessage=list.get(2);
  1186. if(oErrMessage!=null){
  1187. return oErrMessage;
  1188. }
  1189. SqlRowList rs = baseDao.queryForRowSet("select ms_status,ms_stepcode,ms_nextstepcode from makeserial where ms_id=( select max(ms_id) from makeserial where ms_sncode in ( select '" + iSN + "' from dual union select sn from makesnrelation where beforesn='" + iSN + "' and sn<>' ' union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' '))");
  1190. String ms_status = "";
  1191. String ms_stepcode = "";
  1192. String ms_nextstepcode = "";
  1193. if(rs.next()){
  1194. ms_status= rs.getString("ms_status");
  1195. ms_stepcode=rs.getString("ms_stepcode");
  1196. ms_nextstepcode=rs.getString("ms_nextstepcode");
  1197. }
  1198. String stepcode = GetStepCodeBySource(iResCode);
  1199. if (ms_nextstepcode != "" && !ms_nextstepcode.equals(stepcode))
  1200. {
  1201. oErrMessage = "当前序列号"+iSN+"下一工序" + ms_nextstepcode;
  1202. }
  1203. return oErrMessage;
  1204. }
  1205. private Map<Object,Object> CheckUserAndResourcePassed(JSONObject map){
  1206. //实际业务数据
  1207. Map<Object, Object> rmap = new HashMap<>();
  1208. String oErrMessage = null;
  1209. if (map.get("iUserCode") == null || map.get("iResCode") == null || map.get("iPassWord") == null)
  1210. {
  1211. oErrMessage = "用户名,密码,岗位资源必须填写";
  1212. rmap.put("oErrMessage",oErrMessage);
  1213. return rmap;
  1214. }
  1215. String iUserCode=map.get("iUserCode").toString();
  1216. String iPassWord=map.get("iPassWord").toString();
  1217. String iResCode=map.get("iResCode").toString();
  1218. if (CheckUserLogin(iUserCode, iPassWord))
  1219. {
  1220. String SQL = "select em_code,em_type,em_name from employee where em_code=? ";
  1221. SqlRowList rs = baseDao.queryForRowSet(SQL, iUserCode);
  1222. if (rs.next())
  1223. {
  1224. String em_name = rs.getString("em_name");
  1225. String em_type = rs.getString("em_type");
  1226. if (iResCode ==null)
  1227. {
  1228. oErrMessage = "岗位资源不允许为空";
  1229. rmap.put("oErrMessage",oErrMessage);
  1230. return rmap;
  1231. }
  1232. if (em_type.equals("admin"))
  1233. {
  1234. if (!baseDao.checkIf("Source", "sc_code='" + iResCode + "' and sc_statuscode='AUDITED'"))
  1235. {
  1236. oErrMessage = "岗位资源编号错误或者未审核!";
  1237. }
  1238. }
  1239. else
  1240. {
  1241. SqlRowList rs1=baseDao.queryForRowSet("select ur_resourcecode from cs$empgroup left join cs$userresource on ur_groupcode=eg_groupcode left join source on ur_resourcecode=sc_code where eg_emcode = '"+ iUserCode + "' and sc_statuscode='AUDITED'");
  1242. //如果存在该编号
  1243. if (rs1.next())
  1244. {
  1245. //判断如果多个岗位资源存在,用户输入的只要在其中就行
  1246. while (rs.next())
  1247. {
  1248. if (!rs.getString("ur_resourcecode").equals("iResCode")){
  1249. oErrMessage = "用户不处于当前资源所属分组!";
  1250. }else
  1251. {
  1252. oErrMessage=null;
  1253. continue;
  1254. }
  1255. }
  1256. }
  1257. else
  1258. oErrMessage = "岗位资源编号错误或者未审核!";
  1259. }
  1260. }
  1261. else
  1262. oErrMessage = "用户不存在!";
  1263. }else{
  1264. oErrMessage = "用户名密码不正确!";
  1265. }
  1266. rmap.put("oErrMessage",oErrMessage);
  1267. return rmap;
  1268. }
  1269. private Map<Object,Object> GetAddressRangeByMO(JSONObject map){
  1270. //实际业务数据
  1271. Map<Object, Object> rmap = new HashMap<>();
  1272. String iSN="";
  1273. String oErrMessage = null;
  1274. String oWIFI = "";
  1275. String oBT = "";
  1276. String oNetCard = "";
  1277. String oCode1 = "";
  1278. String oCode2 = "";
  1279. String oCode3 = "";
  1280. if(map.get("iSN")==null){
  1281. oErrMessage = "SN不能为空";
  1282. rmap.put("oErrMessage",oErrMessage);
  1283. return rmap;
  1284. }
  1285. iSN=map.get("iSN").toString();
  1286. //判断工单是否归属
  1287. JSONObject map3=new JSONObject();
  1288. map3.put("iSN",iSN);
  1289. Map<Object, Object> map2=GetRcardMOInfo(map3);
  1290. if(map2.get("oErrMessage")!=null){
  1291. oErrMessage=map2.get("oErrMessage").toString();
  1292. rmap.put("oErrMessage",oErrMessage);
  1293. return rmap;
  1294. }
  1295. List<String> list = new ArrayList<String>();
  1296. list = baseDao.callProcedureWithOut("CS_GETADDRESSBYMAKECODE_FIMEI", new Object[]{
  1297. String.valueOf(iSN),
  1298. String.valueOf(map2.get("oMoCode").toString()),
  1299. }, new Integer[]{1,2}, new Integer[]{3,4,5,6,7,8,9});
  1300. oWIFI = list.get(0);
  1301. oBT = list.get(1);
  1302. oNetCard = list.get(2);
  1303. oCode1 = list.get(3);
  1304. oCode2 = list.get(4);
  1305. oCode3 = list.get(5);
  1306. oErrMessage= list.get(6);
  1307. if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
  1308. rmap.put("oWIFI",oWIFI);
  1309. rmap.put("oBT",oBT);
  1310. rmap.put("oNetCard",oNetCard);
  1311. rmap.put("oCode1",oCode1);
  1312. rmap.put("oCode2",oCode2);
  1313. rmap.put("oCode3",oCode3);
  1314. rmap.put("oErrMessage",oErrMessage);
  1315. }
  1316. else
  1317. rmap.put("oErrMessage",oErrMessage);
  1318. return rmap;
  1319. }
  1320. private Map<Object,Object> GetMEIOrNetCodeRange(JSONObject map){
  1321. //实际业务数据
  1322. Map<Object, Object> rmap = new HashMap<>();
  1323. String iSN="";
  1324. String oErrMessage = null;
  1325. String oIMEI1 = "";
  1326. String oIMEI2 = "";
  1327. String oIMEI3 = "";
  1328. String oIMEI4 = "";
  1329. String oMEID = "";
  1330. String oNetCode = "";
  1331. String oPSN = "";
  1332. String oID1 = "";
  1333. String oID2 = "";
  1334. String oID3 = "";
  1335. String oID4 = "";
  1336. String oID5 = "";
  1337. if(map.get("iSN")==null){
  1338. oErrMessage = "SN不能为空";
  1339. rmap.put("oErrMessage",oErrMessage);
  1340. return rmap;
  1341. }
  1342. if(map.get("iIMEI1")!=null){
  1343. oIMEI1=map.get("iIMEI1").toString();
  1344. }
  1345. if(map.get("iNetCode")!=null){
  1346. oNetCode=map.get("iNetCode").toString();
  1347. }
  1348. iSN=map.get("iSN").toString();
  1349. Object MAC_IMEI=baseDao.getFieldDataByCondition("makeaddresslist", "mal_imei", "mal_sncode='" + iSN + "'");
  1350. if(MAC_IMEI!=null){
  1351. oIMEI1=MAC_IMEI.toString();
  1352. }
  1353. List<String> list = new ArrayList<String>();
  1354. list = baseDao.callProcedureWithOut("CS_GETIMEIORNETCODERANGE_FIMEI", new Object[]{
  1355. String.valueOf(iSN),
  1356. String.valueOf(""),
  1357. String.valueOf(oIMEI1),
  1358. String.valueOf(oNetCode),
  1359. }, new Integer[]{1,2,3,4}, new Integer[]{5,6,7,8,9,10,11,12,13,14,15});
  1360. oIMEI1 = list.get(0);
  1361. oIMEI2 = list.get(1);
  1362. oIMEI3 = list.get(2);
  1363. oIMEI4 = list.get(3);
  1364. oMEID = list.get(4);
  1365. oNetCode = list.get(5);
  1366. oPSN = list.get(6);
  1367. oID1 = list.get(7);
  1368. oID2 = list.get(8);
  1369. oID3 = list.get(9);
  1370. oErrMessage= list.get(10);
  1371. if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
  1372. rmap.put("oIMEI1",oIMEI1);
  1373. rmap.put("oIMEI2",oIMEI2);
  1374. rmap.put("oIMEI3",oIMEI3);
  1375. rmap.put("oIMEI4",oIMEI4);
  1376. rmap.put("oMEID",oMEID);
  1377. rmap.put("oNetCode",oNetCode);
  1378. rmap.put("oPSN",oPSN);
  1379. rmap.put("oID1",oID1);
  1380. rmap.put("oID2",oID2);
  1381. rmap.put("oID3",oID3);
  1382. rmap.put("oErrMessage",oErrMessage);
  1383. }
  1384. else
  1385. rmap.put("oErrMessage",oErrMessage);
  1386. return rmap;
  1387. }
  1388. private Map<Object,Object> GetRcardMOInfo(JSONObject map){
  1389. //实际业务数据
  1390. Map<Object, Object> rmap = new HashMap<>();
  1391. //取MakeProcess表中的执行记录ID最大的一个工单的号码
  1392. String oErrMessage = null;
  1393. if(map.get("iSN")==null){
  1394. oErrMessage = "SN不能为空";
  1395. rmap.put("oErrMessage",oErrMessage);
  1396. return rmap;
  1397. }
  1398. String iSN=map.get("iSN").toString();
  1399. StringBuffer sql=new StringBuffer();
  1400. sql.append("select max(ms_id)ms_id from makeserial where ms_sncode in (select '" + iSN + "' from dual union select sn from ");
  1401. sql.append("makesnrelation where beforesn='" + iSN + "' and sn<>' ' union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' ')");
  1402. SqlRowList rs = baseDao.queryForRowSet(sql.toString());
  1403. String ms_id="";
  1404. if(rs.next()){
  1405. if(rs.getString("ms_id")==null){
  1406. oErrMessage = "序列号:" + iSN + " 未归属工单";
  1407. rmap.put("oErrMessage",oErrMessage);
  1408. return rmap;
  1409. }
  1410. else{
  1411. ms_id= rs.getString("ms_id");
  1412. }
  1413. }
  1414. Object oMoCode = baseDao.getFieldDataByCondition("MakeSerial", "ms_makecode", "ms_id='" + ms_id + "'");
  1415. if (oMoCode != null){
  1416. rmap.put("oMoCode",oMoCode);
  1417. oErrMessage= null;
  1418. }
  1419. else
  1420. {
  1421. oErrMessage = "序列号:" + iSN + " 未归属工单";
  1422. }
  1423. rmap.put("oErrMessage",oErrMessage);
  1424. return rmap;
  1425. }
  1426. private Map<Object,Object> GetMobileAllInfo(JSONObject map){
  1427. //实际业务数据
  1428. Map<Object, Object> rmap = new HashMap<>();
  1429. String iSN="";
  1430. String oErrMessage = null;
  1431. String oIMEI1 = "";
  1432. String oIMEI2 = "";
  1433. String oIMEI3 = "";
  1434. String oIMEI4 = "";
  1435. String oMEID = "";
  1436. String oNetCode = "";
  1437. String oNetCard = "";
  1438. String oPSN = "";
  1439. String oID1 = "";
  1440. String oID2 = "";
  1441. String oID3 = "";
  1442. String oID4 = "";
  1443. String oID5 = "";
  1444. String oWIFI = "";
  1445. String oBT = "";
  1446. String oCode1 = "";
  1447. String oCode2 = "";
  1448. String oCode3 = "";
  1449. if(map.get("iSN")==null){
  1450. oErrMessage = "SN不能为空";
  1451. rmap.put("oErrMessage",oErrMessage);
  1452. return rmap;
  1453. }
  1454. iSN=map.get("iSN").toString();
  1455. Object ms_id =baseDao.getFieldDataByCondition("makeserial", "max(ms_id)", "ms_sncode='" + iSN + "'");
  1456. if(ms_id!=null)
  1457. {
  1458. SqlRowList rs=baseDao.queryForRowSet("select ms_imei4,ms_id, ms_mac, ms_bt, ms_meid, ms_netcode, ms_psn, ms_imei1, ms_imei2, ms_imei3, ms_othcode1, ms_othcode2, ms_othcode3, ms_othid1, ms_othid2, ms_othid3,ms_netcard from MakeSerial where ms_id="+ms_id.toString());
  1459. if(rs.next()){
  1460. oWIFI = rs.getString("ms_mac");
  1461. oBT = rs.getString("ms_bt");
  1462. oPSN = rs.getString("ms_psn");
  1463. oNetCode = rs.getString("ms_netcode");
  1464. oNetCard = rs.getString("ms_netcard");
  1465. oMEID = rs.getString("ms_meid");
  1466. oIMEI1 = rs.getString("ms_imei1");
  1467. oIMEI2 = rs.getString("ms_imei2");
  1468. oIMEI3 = rs.getString("ms_imei3");
  1469. oIMEI4 = rs.getString("ms_imei4");
  1470. oCode1 = rs.getString("ms_othcode1");
  1471. oCode2 = rs.getString("ms_othcode2");
  1472. oCode3 = rs.getString("ms_othcode3");
  1473. oID1 = rs.getString("ms_othid1");
  1474. oID2 = rs.getString("ms_othid2");
  1475. oID3 = rs.getString("ms_othid3");
  1476. }
  1477. }else
  1478. {
  1479. oErrMessage = "序列号" + iSN + "不存在";
  1480. rmap.put("oErrMessage",oErrMessage);
  1481. return rmap;
  1482. }
  1483. if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
  1484. rmap.put("oIMEI1",oIMEI1);
  1485. rmap.put("oIMEI2",oIMEI2);
  1486. rmap.put("oIMEI3",oIMEI3);
  1487. rmap.put("oIMEI4",oIMEI4);
  1488. rmap.put("oMEID",oMEID);
  1489. rmap.put("oNetCode",oNetCode);
  1490. rmap.put("oNetCard",oNetCard);
  1491. rmap.put("oPSN",oPSN);
  1492. rmap.put("oID1",oID1);
  1493. rmap.put("oID2",oID2);
  1494. rmap.put("oID3",oID3);
  1495. rmap.put("oID4",oID4);
  1496. rmap.put("oID5",oID5);
  1497. rmap.put("oWIFI",oWIFI);
  1498. rmap.put("oBT",oBT);
  1499. rmap.put("oCode1",oCode1);
  1500. rmap.put("oCode2",oCode2);
  1501. rmap.put("oCode3",oCode3);
  1502. rmap.put("oErrMessage","");
  1503. }
  1504. else
  1505. rmap.put("oErrMessage",oErrMessage);
  1506. return rmap;
  1507. }
  1508. private Map<Object,Object> SetAddressInfo(JSONObject map){
  1509. //实际业务数据
  1510. Map<Object, Object> rmap = new HashMap<>();
  1511. String oErrMessage = null;
  1512. if(map.get("iSN")==null){
  1513. oErrMessage = "SN不能为空";
  1514. rmap.put("oErrMessage",oErrMessage);
  1515. return rmap;
  1516. }
  1517. String iSN=map.get("iSN").toString();
  1518. String iWIFI = null;
  1519. String iBT = null;
  1520. String iCode1 = null;
  1521. String iCode2 = null;
  1522. String iCode3 = null;
  1523. String iNetCard=null;
  1524. if(map.get("iWIFI")!=null){
  1525. iWIFI=map.get("iWIFI").toString();
  1526. }
  1527. if(map.get("iMAC")!=null){
  1528. iWIFI=map.get("iMAC").toString();
  1529. }
  1530. if(map.get("iBT")!=null){
  1531. iBT=map.get("iBT").toString();
  1532. }
  1533. if(map.get("iCode1")!=null){
  1534. iCode1=map.get("iCode1").toString();
  1535. }
  1536. if(map.get("iNetCard")!=null){
  1537. iNetCard=map.get("iNetCard").toString();
  1538. }
  1539. if(map.get("iCode2")!=null){
  1540. iCode2=map.get("iCode2").toString();
  1541. }
  1542. if(map.get("iCode3")!=null){
  1543. iCode3=map.get("iCode3").toString();
  1544. }
  1545. List<String> list = new ArrayList<String>();
  1546. list = baseDao.callProcedureWithOut("CS_SETADDRESSINFO_FIMEI", new Object[]{
  1547. String.valueOf(iSN),
  1548. String.valueOf(iWIFI),
  1549. String.valueOf(iBT),
  1550. String.valueOf(iNetCard),
  1551. String.valueOf(iCode1),
  1552. String.valueOf(iCode2),
  1553. String.valueOf(iCode3)
  1554. }, new Integer[]{1, 2, 3, 4, 5, 6,7}, new Integer[]{8});
  1555. oErrMessage = list.get(0);
  1556. rmap.put("oErrMessage",oErrMessage);
  1557. return rmap;
  1558. }
  1559. private Map<Object,Object> GetMaster(JSONObject map){
  1560. //实际业务数据
  1561. Map<Object, Object> rmap = new HashMap<>();
  1562. SqlRowList rs=baseDao.queryForRowSet("select ma_user from mes.master");
  1563. while(rs.next())
  1564. {
  1565. rmap.put(rs.getString("ma_user"),rs.getString("ma_user"));
  1566. }
  1567. return rmap;
  1568. }
  1569. private Map<Object,Object> SetMobileData(JSONObject map){
  1570. //实际业务数据
  1571. Map<Object, Object> rmap = new HashMap<>();
  1572. String oErrMessage = null;
  1573. if(map.get("iSN")==null||map.get("iTSN")==null){
  1574. oErrMessage = "SN不能为空";
  1575. rmap.put("oErrMessage",oErrMessage);
  1576. return rmap;
  1577. }
  1578. String iSN=map.get("iSN").toString();
  1579. String iTSN=map.get("iTSN").toString();
  1580. String iSourceCode = null;
  1581. String iOperater = null;
  1582. String iResult = null;
  1583. String flag = null;
  1584. String iErrCode = null;
  1585. if(map.get("iSourceCode")!=null){
  1586. iSourceCode=map.get("iSourceCode").toString();
  1587. }
  1588. if(map.get("iOperater")!=null){
  1589. iOperater=map.get("iOperater").toString();
  1590. }
  1591. if(map.get("iResult")!=null){
  1592. iResult=map.get("iResult").toString();
  1593. }
  1594. if(map.get("flag")!=null){
  1595. flag=map.get("flag").toString();
  1596. }
  1597. if(map.get("iErrCode")!=null){
  1598. iErrCode=map.get("iErrCode").toString();
  1599. }
  1600. List<String> list = new ArrayList<String>();
  1601. list = baseDao.callProcedureWithOut("CS_DLLSNCHANGE", new Object[]{
  1602. String.valueOf(iTSN),
  1603. String.valueOf(iSN),
  1604. String.valueOf(iSourceCode),
  1605. String.valueOf(iOperater),
  1606. String.valueOf(iResult),
  1607. String.valueOf(iErrCode),
  1608. }, new Integer[]{1, 2, 3, 4, 5, 6}, new Integer[]{7});
  1609. oErrMessage = list.get(0);
  1610. rmap.put("oErrMessage",oErrMessage);
  1611. return rmap;
  1612. }
  1613. private Map<Object,Object> SetIMEIInfo(JSONObject map){
  1614. //实际业务数据
  1615. Map<Object, Object> rmap = new HashMap<>();
  1616. String oErrMessage = null;
  1617. if(map.get("iSN")==null){
  1618. oErrMessage = "SN不能为空";
  1619. rmap.put("oErrMessage",oErrMessage);
  1620. return rmap;
  1621. }
  1622. String iSN=map.get("iSN").toString();
  1623. String iIMEI1=null;
  1624. String iIMEI2 = null;
  1625. String iIMEI3 = null;
  1626. String iIMEI4 = null;
  1627. String iMEID = null;
  1628. String iPSN = null;
  1629. String iNET = null;
  1630. String iID1 = null;
  1631. String iID2 = null;
  1632. String iID3 = null;
  1633. if(map.get("iPSN")!=null){
  1634. iPSN=map.get("iPSN").toString();
  1635. }
  1636. if(map.get("iIMEI1")!=null){
  1637. iIMEI1=map.get("iIMEI1").toString();
  1638. }
  1639. if(map.get("iIMEI2")!=null){
  1640. iIMEI2=map.get("iIMEI2").toString();
  1641. }
  1642. if(map.get("iIMEI3")!=null){
  1643. iIMEI3=map.get("iIMEI3").toString();
  1644. }
  1645. if(map.get("iIMEI4")!=null){
  1646. iIMEI4=map.get("iIMEI4").toString();
  1647. }
  1648. if(map.get("iMEID")!=null){
  1649. iMEID=map.get("iMEID").toString();
  1650. }
  1651. if(map.get("iNET")!=null){
  1652. iNET=map.get("iNET").toString();
  1653. }
  1654. if(map.get("iID1")!=null){
  1655. iID1=map.get("iID1").toString();
  1656. }
  1657. if(map.get("iID2")!=null){
  1658. iID2=map.get("iID2").toString();
  1659. }
  1660. if(map.get("iID3")!=null){
  1661. iID3=map.get("iID3").toString();
  1662. }
  1663. List<String> list = new ArrayList<String>();
  1664. list = baseDao.callProcedureWithOut("CS_SETIMEIINFO_FIMEI", new Object[]{
  1665. String.valueOf(iSN),
  1666. String.valueOf(iIMEI1),
  1667. String.valueOf(iIMEI2),
  1668. String.valueOf(iIMEI3),
  1669. String.valueOf(iIMEI4),
  1670. String.valueOf(iMEID),
  1671. String.valueOf(iNET),
  1672. String.valueOf(iPSN),
  1673. String.valueOf(iID1),
  1674. String.valueOf(iID2),
  1675. String.valueOf(iID3),
  1676. }, new Integer[]{1, 2, 3, 4, 5, 6,7,8,9,10,11}, new Integer[]{12});
  1677. oErrMessage = list.get(0);
  1678. rmap.put("oErrMessage",oErrMessage);
  1679. return rmap;
  1680. }
  1681. private Map<Object,Object> SetTestDetail(JSONObject map){
  1682. //实际业务数据
  1683. Map<Object, Object> rmap = new HashMap<>();
  1684. String oErrMessage=null;
  1685. if(map.get("iSN")==null){
  1686. oErrMessage = "SN不能为空";
  1687. rmap.put("oErrMessage",oErrMessage);
  1688. return rmap;
  1689. }
  1690. String iSN=map.get("iSN").toString();
  1691. String iTestResult= "";
  1692. String iResCode= "";
  1693. String iClassName="";
  1694. String iTestDetail= "";
  1695. if(map.get("iTestResult")!=null){
  1696. iTestResult=map.get("iTestResult").toString();
  1697. }
  1698. if(map.get("iClassName")!=null){
  1699. iClassName=map.get("iClassName").toString();
  1700. }
  1701. if(map.get("iResCode")!=null){
  1702. iResCode=map.get("iResCode").toString();
  1703. }
  1704. if(map.get("iTestDetail")!=null){
  1705. iTestDetail=map.get("iTestDetail").toString();
  1706. }
  1707. JSONObject map3=new JSONObject();
  1708. map3.put("iSN",iSN);
  1709. Map<Object, Object> map2=GetRcardMOInfo(map3);
  1710. String omakeCode = "";
  1711. StringBuffer sql=new StringBuffer();
  1712. String[] name=iClassName.split("\\|");
  1713. String[] result=iTestResult.split("\\|");
  1714. String[] value=iTestDetail.split("\\|");
  1715. if(name.length!=value.length||name.length!=result.length){
  1716. rmap.put("oErrMessage","测试项目名称和值的项次不一致");
  1717. return rmap;
  1718. }
  1719. for (int i=0;i<name.length;i++){
  1720. sql.setLength(0);
  1721. sql.append("Insert into STEPTESTDETAIL (STD_ID,STD_CLASS,STD_SN,STD_MAKECODE,STD_ACTUALVALUE,STD_TESTRESULT,STD_INDATE,STD_RESCODE)");
  1722. sql.append("values(STEPTESTDETAIL_SEQ.nextval,'"+name[i]+"','" + iSN + "','" + map2.get("oMoCode") + "','" + value[i] + "','" + result[i] + "',sysdate,'" + iResCode + "')");
  1723. baseDao.execute(sql.toString());
  1724. }
  1725. rmap.put("oErrMessage",oErrMessage);
  1726. return rmap;
  1727. }
  1728. private Map<Object,Object> SetPcbaData(JSONObject map){
  1729. //实际业务数据
  1730. Map<Object, Object> rmap = new HashMap<>();
  1731. String oErrMessage = null;
  1732. if(map.get("iSN")==null){
  1733. oErrMessage = "SN不能为空";
  1734. rmap.put("oErrMessage",oErrMessage);
  1735. return rmap;
  1736. }
  1737. String iSN=map.get("iSN").toString();
  1738. String iResCode = null;
  1739. String iOperator = null;
  1740. String iResult = null;
  1741. String iErrCode = null;
  1742. if(map.get("iResCode")!=null){
  1743. iResCode=map.get("iResCode").toString();
  1744. }
  1745. if(map.get("iOperator")!=null){
  1746. iOperator=map.get("iOperator").toString();
  1747. }
  1748. if(map.get("iResult")!=null){
  1749. iResult=map.get("iResult").toString();
  1750. }
  1751. if(map.get("iErrCode")!=null){
  1752. iErrCode=map.get("iErrCode").toString();
  1753. }
  1754. JSONObject map3=new JSONObject();
  1755. map3.put("iSN",iSN);
  1756. Map<Object, Object> map2=GetRcardMOInfo(map3);
  1757. String oMoCode=null;
  1758. if(map2.get("oMoCode")!=null){
  1759. oMoCode=map2.get("oMoCode").toString();
  1760. }
  1761. if (map2.get("oErrMessage")==null)
  1762. return SetStepFinish(oMoCode, iResCode, iSN, "", iResult, iOperator, iErrCode);
  1763. return rmap;
  1764. }
  1765. private Object SetPcbaData(String iSN,String iResCode,String iOperator,String iResult){
  1766. //实际业务数据
  1767. Map<Object, Object> rmap = new HashMap<>();
  1768. String iErrCode = null;
  1769. if(iSN==null){
  1770. iErrCode = "SN不能为空";
  1771. return iErrCode;
  1772. }
  1773. JSONObject map3=new JSONObject();
  1774. map3.put("iSN",iSN);
  1775. Map<Object, Object> map2=GetRcardMOInfo(map3);
  1776. String oMoCode=null;
  1777. if(map2.get("oMoCode")!=null){
  1778. oMoCode=map2.get("oMoCode").toString();
  1779. }
  1780. if (map2.get("oErrMessage")==null)
  1781. map2= SetStepFinish(oMoCode, iResCode, iSN, "", iResult, iResCode, iErrCode);
  1782. return map2.get("oErrMessage");
  1783. }
  1784. /// <summary>
  1785. /// 获取步骤代码
  1786. /// </summary>
  1787. /// <param name="Source"></param>
  1788. /// <returns></returns>
  1789. private String GetStepCodeBySource(String Source)
  1790. {
  1791. Object o=baseDao.getFieldDataByCondition("source", "sc_stepcode", "sc_code='" + Source + "'");
  1792. if(o!=null)
  1793. return o.toString();
  1794. else
  1795. return "";
  1796. }
  1797. private Boolean CheckUserLogin(String iUserCode, String iPassWord)
  1798. {
  1799. SqlRowList rs =baseDao.queryForRowSet("select em_code from employee where em_code='"+iUserCode+"' and em_password =?",iPassWord);
  1800. if (rs.next())
  1801. return true;
  1802. else
  1803. {
  1804. return false;
  1805. }
  1806. }
  1807. private Map<Object,Object> GetMakeInfoBySN(JSONObject map)
  1808. {
  1809. Map<Object, Object> rmap = new HashMap<Object, Object>();
  1810. String iSN=null;
  1811. String oErrMessage=null;
  1812. if(map.get("iSN")==null){
  1813. oErrMessage = "SN不能为空";
  1814. rmap.put("oErrMessage",oErrMessage);
  1815. return rmap;
  1816. }
  1817. iSN=map.get("iSN").toString();
  1818. SqlRowList rs=baseDao.queryForRowSet("select ma_remark1,ma_remark2,ma_remark3,ma_remark4,ma_remark5,ma_remark6,ma_remark7,ma_remark8,ma_remark9,ma_remark10,ma_remark11,ma_remark12,ma_remark13,ma_remark14,ma_remark15,ma_remark16 from make " +
  1819. "left join makeserial on ms_makecode=ma_code where ms_sncode='"+iSN+"'");
  1820. if(rs.next()){
  1821. rmap.put("oMaremark1",rs.getString("ma_remark1"));
  1822. rmap.put("oMaremark2",rs.getString("ma_remark2"));
  1823. rmap.put("oMaremark3",rs.getString("ma_remark3"));
  1824. rmap.put("oMaremark4",rs.getString("ma_remark4"));
  1825. rmap.put("oMaremark5",rs.getString("ma_remark5"));
  1826. rmap.put("oMaremark6",rs.getString("ma_remark6"));
  1827. rmap.put("oMaremark7",rs.getString("ma_remark7"));
  1828. rmap.put("oMaremark8",rs.getString("ma_remark8"));
  1829. rmap.put("oMaremark9",rs.getString("ma_remark9"));
  1830. rmap.put("oMaremark10",rs.getString("ma_remark10"));
  1831. rmap.put("oMaremark11",rs.getString("ma_remark11"));
  1832. rmap.put("oMaremark12",rs.getString("ma_remark12"));
  1833. rmap.put("oMaremark13",rs.getString("ma_remark13"));
  1834. rmap.put("oMaremark14",rs.getString("ma_remark14"));
  1835. rmap.put("oMaremark15",rs.getString("ma_remark15"));
  1836. rmap.put("oMaremark16",rs.getString("ma_remark16"));
  1837. return rmap;
  1838. }else{
  1839. oErrMessage = "SN未查询到关联信息";
  1840. rmap.put("oErrMessage",oErrMessage);
  1841. return rmap;
  1842. }
  1843. }
  1844. public Map<Object,Object> SetStepFinish(String iMakeCode, String iSourceCode, String iSN, String iMPKind, String iResult, String iUserCode, String iErrCode)
  1845. {
  1846. String oErrMessage = null;
  1847. Object StepCode = baseDao.getFieldDataByCondition("Makeserial", "ms_stepcode", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  1848. String CurrentStep = GetStepCodeBySource(iSourceCode);
  1849. Object BgCode = baseDao.getFieldDataByCondition("step", "nvl(st_badgroupcode,' ')", "st_code='" + CurrentStep + "'");
  1850. Map<Object, Object> rmap = new HashMap<>();
  1851. switch (iResult)
  1852. {
  1853. case "OK":
  1854. break;
  1855. case "NG":
  1856. if (iErrCode == "")
  1857. {
  1858. oErrMessage = "测试结果为NG时必须传递不良代码";
  1859. rmap.put("oErrMessage",oErrMessage);
  1860. return rmap;
  1861. }
  1862. else
  1863. {
  1864. baseDao.updateByCondition("makebad", "mb_status=-1", "mb_sncode='" + iSN + "' and mb_makecode='" + iMakeCode + "' and mb_stepcode='" + CurrentStep + "' and mb_status=0");
  1865. String[] BadCode = iErrCode.split(",");
  1866. StringBuffer sql=new StringBuffer();
  1867. for (int i = 0; i < BadCode.length; i++)
  1868. {
  1869. if(!baseDao.checkIf("badcode","bc_code='"+ BadCode[i]+"'")){
  1870. oErrMessage = "不良代码"+BadCode[i]+"不存在";
  1871. rmap.put("oErrMessage",oErrMessage);
  1872. return rmap;
  1873. }
  1874. int mb_id = baseDao.getSeqId("makebad_seq");
  1875. sql.setLength(0);
  1876. sql.append("insert into makebad(mb_id,mb_makecode,mb_mscode,mb_sncode,mb_inman,mb_indate,mb_stepcode");
  1877. sql.append(",mb_sourcecode,mb_badcode,mb_badtable,mb_bgcode,mb_soncode,mb_status) select '" + mb_id + "'");
  1878. sql.append(",ma_code,ms_code,ms_sncode,'" + iUserCode + "',sysdate,'" + CurrentStep + "','" + iSourceCode + "','" + BadCode[i] + "','',");
  1879. sql.append("'" + BgCode + "',sp_soncode,'0' from make left join makeSerial on ms_makecode=ma_code left join stepProduct on ");
  1880. sql.append("sp_mothercode=ma_prodcode and sp_stepcode=ms_nextstepcode where ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  1881. baseDao.execute(sql.toString());
  1882. }
  1883. //将不良的序列号的状态码设为3
  1884. baseDao.execute("update makeserial set ms_status='3' where ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  1885. }
  1886. break;
  1887. default:
  1888. oErrMessage = "测试结果必须为NG或者OK";
  1889. rmap.put("oErrMessage",oErrMessage);
  1890. return rmap;
  1891. }
  1892. //不良采集为良品是更新
  1893. if (StepCode!=null &&StepCode.toString().equals(CurrentStep) && iResult == "OK")
  1894. {
  1895. Object[] ob = baseDao.getFieldsDataByCondition("makeserial", "ms_status,ms_craftcode,ms_prodcode", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  1896. if (ob!=null)
  1897. {
  1898. String ms_status =ob[0].toString();
  1899. String ms_craftcode= ob[1].toString();
  1900. String ms_prodcode = ob[2].toString();
  1901. if (ms_status == "3")
  1902. {
  1903. String nextstepcode =baseDao.getFieldDataByCondition("craft left join craftdetail on cr_id=cd_crid ", "cd_nextstepcode", "cr_code='" + ms_craftcode + "' and cr_prodcode='" + ms_prodcode + "' and cd_stepcode='" + CurrentStep + "'").toString();
  1904. baseDao.updateByCondition("makeserial", "ms_status=1,ms_nextstepcode='" + nextstepcode + "'", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  1905. baseDao.updateByCondition("makebad", "mb_status=-1", "mb_sncode='" + iSN + "' and mb_makecode='" + iMakeCode + "'");
  1906. }
  1907. }
  1908. }
  1909. return CS_SetFinish(iMakeCode, iSourceCode, iSN, iUserCode, iResult);
  1910. }
  1911. private Map<Object,Object> CS_SetFinish(String iMakeCode, String iSourceCode, String iSN, String iUserCode, String iResult)
  1912. {
  1913. Map<Object, Object> rmap = new HashMap<>();
  1914. String oErrMessage=null;
  1915. List<String> list = new ArrayList<String>();
  1916. list = baseDao.callProcedureWithOut("CS_SETSTEPRESULT", new Object[]{
  1917. String.valueOf(iMakeCode),
  1918. String.valueOf(iSourceCode),
  1919. String.valueOf(iSN),
  1920. String.valueOf(iUserCode),
  1921. String.valueOf(iResult),
  1922. }, new Integer[]{1, 2, 3, 4, 5}, new Integer[]{6});
  1923. oErrMessage = list.get(0);
  1924. rmap.put("oErrMessage",oErrMessage);
  1925. return rmap;
  1926. }
  1927. @Override
  1928. public Map<Object,Object> getMESSnCode(String data) {
  1929. Map<String, Object> map=null;
  1930. Map<Object, Object> rmap = new HashMap<Object, Object>();
  1931. try{
  1932. map =BaseUtil.convertJsonToMap(data);
  1933. }catch (Exception e){
  1934. rmap.put("code",-1);
  1935. rmap.put("message",e.getMessage());
  1936. System.out.printf(e.getMessage()) ;
  1937. return rmap;
  1938. }
  1939. String macode = map.get("moid") == null ? "" : String.valueOf(map.get("moid"));
  1940. if("".equals(macode)){
  1941. rmap.put("code",-1);
  1942. rmap.put("message","工单不能为空");
  1943. return rmap;
  1944. }
  1945. if (!baseDao.checkIf("make","ma_code='"+macode+"'")){
  1946. rmap.put("code",-1);
  1947. rmap.put("message","工单【"+macode+"】不存在");
  1948. return rmap;
  1949. }
  1950. if (baseDao.checkIf("make","nvl(ma_statuscode,' ')<>'STARTED' and ma_code='"+macode+"'")){
  1951. rmap.put("code",-1);
  1952. rmap.put("message","工单不是已下放状态");
  1953. return rmap;
  1954. }
  1955. if (!baseDao.checkIf("MakeSnList","msl_makecode='"+macode+"'")){
  1956. rmap.put("code",-1);
  1957. rmap.put("message","工单未维护SN");
  1958. return rmap;
  1959. }
  1960. double sncount = map.get("count") == null ? 0 : Double.parseDouble(map.get("count").toString());
  1961. if(sncount<=0){
  1962. rmap.put("code",-1);
  1963. rmap.put("message","SN数量必须大于0");
  1964. return rmap;
  1965. }
  1966. int count = baseDao.getCountByCondition("MakeSnList", "msl_makecode='" + macode + "' and nvl(msl_status,0)=0");
  1967. if (count<sncount){
  1968. rmap.put("code",-1);
  1969. rmap.put("message","SN不足!");
  1970. return rmap;
  1971. }
  1972. List<String> sqls = new ArrayList<>();
  1973. List<Map<String, Object>> maps = new ArrayList<>();
  1974. Map<String, Object> snmap=null;
  1975. SqlRowList rs = baseDao.queryForRowSet("select msl_sncode,msl_id from (select msl_sncode,msl_id from MakeSnList where msl_makecode='" + macode + "' and nvl(msl_status,0)=0 order by msl_sncode) where rownum<="+sncount +" order by msl_sncode ");
  1976. String mainbarcode="";
  1977. String msl_id="";
  1978. while (rs.next()){
  1979. snmap=new HashMap<String, Object>();
  1980. snmap.put("serialNo",rs.getGeneralString("msl_sncode"));
  1981. mainbarcode=rs.getGeneralString("msl_sncode");
  1982. maps.add(snmap);
  1983. sqls.add("update MakeSnList set msl_signtime=sysdate,msl_status=-1 where msl_id="+rs.getGeneralInt("msl_id"));
  1984. msl_id+=rs.getGeneralInt("msl_id")+",";
  1985. }
  1986. msl_id+="0";
  1987. baseDao.execute("update MakeSnList set msl_mainbarcode='"+mainbarcode+"' where msl_id in ("+msl_id+")");
  1988. if (sqls!=null&&sqls.size()>0){
  1989. baseDao.execute(sqls);
  1990. }
  1991. rmap.put("code",0);
  1992. rmap.put("data",maps);
  1993. return rmap;
  1994. }
  1995. }