MESHelperServiceImpl.java 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936
  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 net.sf.json.JSONObject;
  13. import net.sf.json.JsonConfig;
  14. import org.apache.commons.lang.StringUtils;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.beans.factory.annotation.Value;
  17. import org.springframework.stereotype.Service;
  18. import sun.awt.TimedWindowEvent;
  19. import java.sql.Timestamp;
  20. import java.util.ArrayList;
  21. import java.util.HashMap;
  22. import java.util.List;
  23. import java.util.Map;
  24. @Service
  25. public class MESHelperServiceImpl implements MESHelperService {
  26. @Autowired
  27. private BaseDao baseDao;
  28. @Value("${spring.datasource.username}")
  29. private String username;
  30. @Override
  31. public Map<Object,Object> DLLMain(String accessKey, String requestId, String data) {
  32. String AE_MASTER = "N_MES_HY";
  33. SpObserver.putSp(AE_MASTER);
  34. Map<Object, Object> map = BaseUtil.parseFormStoreToMap(data);
  35. //解析map
  36. if(!StringUtil.hasText(map.get("type"))){
  37. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPENULL,requestId));
  38. }
  39. if(!StringUtil.hasText(map.get("detail"))){
  40. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_DATAILLEGAL,requestId));
  41. }
  42. String type = map.get("type").toString();
  43. JSONObject json = JSONObject.fromObject(map.get("detail"));
  44. HelperType helperType = HelperType.getTypeByCode(type);
  45. if(null == helperType){
  46. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPEILLEGAL,requestId));
  47. }
  48. int err = 0;
  49. //返回值
  50. Map<Object, Object> remap = new HashMap<Object, Object>();
  51. switch(helperType){
  52. case CheckRoutePassed:
  53. remap = CheckRoutePassed(json);
  54. break;
  55. case CheckUserAndResourcePassed:
  56. remap = CheckUserAndResourcePassed(json);
  57. break;
  58. case GetAddressRangeByMO:
  59. remap = GetAddressRangeByMO(json);
  60. break;
  61. case GetMEIOrNetCodeRange:
  62. remap = GetMEIOrNetCodeRange(json);
  63. break;
  64. case GetRcardMOInfo:
  65. remap = GetRcardMOInfo(json);
  66. break;
  67. case GetMobileAllInfo:
  68. remap = GetMobileAllInfo(json);
  69. break;
  70. case SetAddressInfo:
  71. remap = SetAddressInfo(json);
  72. break;
  73. case GetMaster:
  74. remap = GetMaster(json);
  75. break;
  76. case SetMobileData:
  77. remap = SetMobileData(json);
  78. break;
  79. case SetIMEIInfo:
  80. remap = SetIMEIInfo(json);
  81. break;
  82. case SetTestDetail:
  83. remap = SetTestDetail(json);
  84. break;
  85. case SetPcbaData:
  86. remap = SetPcbaData(json);
  87. break;
  88. case GetInfoByMaterial:
  89. remap = GetInfoByMaterial(json);
  90. break;
  91. case GoMo:
  92. remap = GoMo(json);
  93. break;
  94. case GetMakeInfoBySN:
  95. remap = GetMakeInfoBySN(json);
  96. break;
  97. default:
  98. err = -1;
  99. break;
  100. }
  101. if(err == -1){
  102. throw new ApiSystemException(new ApiResult(ErrorMessage.BUSINESS_TYPEILLEGAL,requestId));
  103. }
  104. SpObserver.putSp(username);
  105. return remap;
  106. }
  107. private Map<Object,Object> GoMo(JSONObject map){
  108. Map<Object, Object> rmap = new HashMap<Object, Object>();
  109. String iSN=null;
  110. String iResCode=null;
  111. String iMo=null;
  112. String oErrMessage=null;
  113. if(map.get("iMo")==null){
  114. oErrMessage = "工单号不能为空";
  115. rmap.put("oErrMessage",oErrMessage);
  116. return rmap;
  117. }
  118. if(map.get("iResCode")==null){
  119. oErrMessage = "岗位资源不能为空";
  120. rmap.put("oErrMessage",oErrMessage);
  121. return rmap;
  122. }
  123. if(map.get("iSN")==null){
  124. oErrMessage = "SN不能为空";
  125. rmap.put("oErrMessage",oErrMessage);
  126. return rmap;
  127. }
  128. iSN=map.get("iSN").toString();
  129. iResCode=map.get("iResCode").toString();
  130. iMo=map.get("iMo").toString();
  131. List<String> list = new ArrayList<String>();
  132. list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
  133. String.valueOf(iMo),
  134. String.valueOf(iResCode),
  135. String.valueOf(iSN),
  136. String.valueOf("")
  137. }, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
  138. oErrMessage=list.get(2);
  139. 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<>' '))");
  140. String ms_status = "";
  141. String ms_stepcode = "";
  142. String ms_nextstepcode = "";
  143. if(rs.next()){
  144. ms_status= rs.getString("ms_status");
  145. ms_stepcode=rs.getString("ms_stepcode");
  146. ms_nextstepcode=rs.getString("ms_nextstepcode");
  147. }
  148. String stepcode = GetStepCodeBySource(iResCode);
  149. if ( oErrMessage == null || (ms_status == "3" && ms_stepcode == stepcode))
  150. {
  151. if (ms_status == "3")
  152. {
  153. oErrMessage = null;
  154. }
  155. }
  156. rmap.put("oErrMessage",oErrMessage);
  157. return rmap;
  158. }
  159. private Map<Object,Object> GetInfoByMaterial(JSONObject map){
  160. Map<Object, Object> rmap = new HashMap<Object, Object>();
  161. String iPCBA=null;
  162. String oErrMessage=null;
  163. if(map.get("iPCBA")==null){
  164. oErrMessage = "主板SN不能为空";
  165. rmap.put("oErrMessage",oErrMessage);
  166. return rmap;
  167. }
  168. iPCBA=map.get("iPCBA").toString();
  169. 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");
  170. if(rs.next()){
  171. if(!rs.getString("ms_id").equals("0")){
  172. 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")+"'");
  173. if (rs.next()){
  174. rmap.put("oSN",rs.getString("ms_sncode"));
  175. rmap.put("oBIOS",rs.getString("ma_bios"));
  176. rmap.put("oEC",rs.getString("ma_ec"));
  177. rmap.put("oHardWare",rs.getString("ma_hardware"));
  178. }
  179. }else{
  180. oErrMessage = "主板SN未查询到关联信息";
  181. rmap.put("oErrMessage",oErrMessage);
  182. return rmap;
  183. }
  184. }
  185. return rmap;
  186. }
  187. private Map<Object,Object> CheckRoutePassed(JSONObject map){
  188. //实际业务数据
  189. Map<Object, Object> rmap = new HashMap<>();
  190. String oErrMessage="";
  191. if(map.get("iSN")==null){
  192. oErrMessage = "SN不能为空";
  193. rmap.put("oErrMessage",oErrMessage);
  194. return rmap;
  195. }
  196. String iSN=map.get("iSN").toString();
  197. String iResCode=map.get("iResCode").toString();
  198. if (iSN ==null)
  199. {
  200. oErrMessage = "SN不能为空";
  201. }
  202. List<String> list = new ArrayList<String>();
  203. list = baseDao.callProcedureWithOut("CS_CHECKSTEPSNANDMACODE", new Object[]{
  204. String.valueOf(""),
  205. String.valueOf(iResCode),
  206. String.valueOf(iSN),
  207. String.valueOf("")
  208. }, new Integer[]{1, 2, 3, 4}, new Integer[]{5, 6, 7});
  209. oErrMessage=list.get(2);
  210. if(oErrMessage!=null){
  211. rmap.put("oErrMessage",oErrMessage);
  212. return rmap;
  213. }
  214. 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<>' '))");
  215. String ms_status = "";
  216. String ms_stepcode = "";
  217. String ms_nextstepcode = "";
  218. if(rs.next()){
  219. ms_status= rs.getString("ms_status");
  220. ms_stepcode=rs.getString("ms_stepcode");
  221. ms_nextstepcode=rs.getString("ms_nextstepcode");
  222. }
  223. String stepcode = GetStepCodeBySource(iResCode);
  224. if (ms_nextstepcode != "" && !ms_nextstepcode.equals(stepcode))
  225. {
  226. oErrMessage = "当前序列号下一工序" + ms_nextstepcode;
  227. }
  228. rmap.put("oErrMessage",oErrMessage);
  229. return rmap;
  230. }
  231. private Map<Object,Object> CheckUserAndResourcePassed(JSONObject map){
  232. //实际业务数据
  233. Map<Object, Object> rmap = new HashMap<>();
  234. String oErrMessage = null;
  235. if (map.get("iUserCode") == null || map.get("iResCode") == null || map.get("iPassWord") == null)
  236. {
  237. oErrMessage = "用户名,密码,岗位资源必须填写";
  238. rmap.put("oErrMessage",oErrMessage);
  239. return rmap;
  240. }
  241. String iUserCode=map.get("iUserCode").toString();
  242. String iPassWord=map.get("iPassWord").toString();
  243. String iResCode=map.get("iResCode").toString();
  244. if (CheckUserLogin(iUserCode, iPassWord))
  245. {
  246. String SQL = "select em_code,em_type,em_name from employee where em_code=? ";
  247. SqlRowList rs = baseDao.queryForRowSet(SQL, iUserCode);
  248. if (rs.next())
  249. {
  250. String em_name = rs.getString("em_name");
  251. String em_type = rs.getString("em_type");
  252. if (iResCode ==null)
  253. {
  254. oErrMessage = "岗位资源不允许为空";
  255. rmap.put("oErrMessage",oErrMessage);
  256. return rmap;
  257. }
  258. if (em_type.equals("admin"))
  259. {
  260. if (!baseDao.checkIf("Source", "sc_code='" + iResCode + "' and sc_statuscode='AUDITED'"))
  261. {
  262. oErrMessage = "岗位资源编号错误或者未审核!";
  263. }
  264. }
  265. else
  266. {
  267. 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'");
  268. //如果存在该编号
  269. if (rs1.next())
  270. {
  271. //判断如果多个岗位资源存在,用户输入的只要在其中就行
  272. while (rs.next())
  273. {
  274. if (rs.getString("ur_resourcecode").equals(iResCode)){
  275. oErrMessage=null;
  276. continue;
  277. }
  278. }
  279. oErrMessage = "用户不处于当前资源所属分组!";
  280. }
  281. else
  282. oErrMessage = "岗位资源编号错误或者未审核!";
  283. }
  284. }
  285. else
  286. oErrMessage = "用户不存在!";
  287. }else{
  288. oErrMessage = "用户名密码不正确!";
  289. }
  290. rmap.put("oErrMessage",oErrMessage);
  291. return rmap;
  292. }
  293. private Map<Object,Object> GetAddressRangeByMO(JSONObject map){
  294. //实际业务数据
  295. Map<Object, Object> rmap = new HashMap<>();
  296. String iSN="";
  297. String oErrMessage = null;
  298. String oWIFI = "";
  299. String oBT = "";
  300. String oCode1 = "";
  301. String oCode2 = "";
  302. String oCode3 = "";
  303. if(map.get("iSN")==null){
  304. oErrMessage = "SN不能为空";
  305. rmap.put("oErrMessage",oErrMessage);
  306. return rmap;
  307. }
  308. iSN=map.get("iSN").toString();
  309. //判断工单是否归属
  310. JSONObject map3=new JSONObject();
  311. map3.put("iSN",iSN);
  312. Map<Object, Object> map2=GetRcardMOInfo(map3);
  313. if(map2.get("oErrMessage")!=null){
  314. oErrMessage=map2.get("oErrMessage").toString();
  315. rmap.put("oErrMessage",oErrMessage);
  316. return rmap;
  317. }
  318. List<String> list = new ArrayList<String>();
  319. list = baseDao.callProcedureWithOut("CS_GETADDRESSBYMAKECODE", new Object[]{
  320. String.valueOf(iSN),
  321. String.valueOf(map2.get("oMoCode").toString()),
  322. }, new Integer[]{1,2}, new Integer[]{3,4,5,6,7,8});
  323. oWIFI = list.get(0);
  324. oBT = list.get(1);
  325. oCode1 = list.get(2);
  326. oCode2 = list.get(3);
  327. oCode3 = list.get(4);
  328. oErrMessage= list.get(5);
  329. if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
  330. rmap.put("oWIFI",oWIFI);
  331. rmap.put("oBT",oBT);
  332. rmap.put("oCode1",oCode1);
  333. rmap.put("oCode2",oCode2);
  334. rmap.put("oCode3",oCode3);
  335. }
  336. else
  337. rmap.put("oErrMessage",oErrMessage);
  338. return rmap;
  339. }
  340. private Map<Object,Object> GetMEIOrNetCodeRange(JSONObject map){
  341. //实际业务数据
  342. Map<Object, Object> rmap = new HashMap<>();
  343. String iSN="";
  344. String oErrMessage = null;
  345. String oIMEI1 = "";
  346. String oIMEI2 = "";
  347. String oMEID = "";
  348. String oNetCode = "";
  349. String oPSN = "";
  350. String oID1 = "";
  351. String oID2 = "";
  352. String oID3 = "";
  353. String oID4 = "";
  354. String oID5 = "";
  355. if(map.get("iSN")==null){
  356. oErrMessage = "SN不能为空";
  357. rmap.put("oErrMessage",oErrMessage);
  358. return rmap;
  359. }
  360. if(map.get("iIMEI1")!=null){
  361. oIMEI1=map.get("iIMEI1").toString();
  362. }
  363. if(map.get("iNetCode")!=null){
  364. oNetCode=map.get("iNetCode").toString();
  365. }
  366. iSN=map.get("iSN").toString();
  367. List<String> list = new ArrayList<String>();
  368. list = baseDao.callProcedureWithOut("CS_GETIMEIORNETCODERANGE", new Object[]{
  369. String.valueOf(iSN),
  370. String.valueOf(""),
  371. String.valueOf(oIMEI1),
  372. String.valueOf(oNetCode),
  373. }, new Integer[]{1,2,3,4}, new Integer[]{5,6,7,8,9,10,11,12,13,14});
  374. oIMEI1 = list.get(0);
  375. oIMEI2 = list.get(1);
  376. oMEID = list.get(2);
  377. oNetCode = list.get(3);
  378. oID1 = list.get(4);
  379. oID2 = list.get(5);
  380. oID3 = list.get(6);
  381. oID4 = list.get(7);
  382. oID5 = list.get(8);
  383. oErrMessage= list.get(9);
  384. if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
  385. rmap.put("oIMEI1",oIMEI1);
  386. rmap.put("oIMEI2",oIMEI2);
  387. rmap.put("oMEID",oMEID);
  388. rmap.put("oNetCode",oNetCode);
  389. rmap.put("oPSN",oPSN);
  390. rmap.put("oID1",oID1);
  391. rmap.put("oID2",oID2);
  392. rmap.put("oID3",oID3);
  393. rmap.put("oID4",oID4);
  394. rmap.put("oID5",oID5);
  395. }
  396. else
  397. rmap.put("oErrMessage",oErrMessage);
  398. return rmap;
  399. }
  400. private Map<Object,Object> GetRcardMOInfo(JSONObject map){
  401. //实际业务数据
  402. Map<Object, Object> rmap = new HashMap<>();
  403. //取MakeProcess表中的执行记录ID最大的一个工单的号码
  404. String oErrMessage = null;
  405. if(map.get("iSN")==null){
  406. oErrMessage = "SN不能为空";
  407. rmap.put("oErrMessage",oErrMessage);
  408. return rmap;
  409. }
  410. String iSN=map.get("iSN").toString();
  411. StringBuffer sql=new StringBuffer();
  412. sql.append("select max(ms_id)ms_id from makeserial where ms_sncode in (select '" + iSN + "' from dual union select sn from ");
  413. sql.append("makesnrelation where beforesn='" + iSN + "' and sn<>' ' union select beforesn from makesnrelation where sn='" + iSN + "' and beforesn<>' ')");
  414. SqlRowList rs = baseDao.queryForRowSet(sql.toString());
  415. String ms_id="";
  416. if(rs.next()){
  417. if(rs.getString("ms_id")==null){
  418. oErrMessage = "序列号:" + iSN + " 未归属工单";
  419. rmap.put("oErrMessage",oErrMessage);
  420. return rmap;
  421. }
  422. else{
  423. ms_id= rs.getString("ms_id");
  424. }
  425. }
  426. Object oMoCode = baseDao.getFieldDataByCondition("MakeSerial", "ms_makecode", "ms_id='" + ms_id + "'");
  427. if (oMoCode != null){
  428. rmap.put("oMoCode",oMoCode);
  429. oErrMessage= null;
  430. }
  431. else
  432. {
  433. oErrMessage = "序列号:" + iSN + " 未归属工单";
  434. }
  435. rmap.put("oErrMessage",oErrMessage);
  436. return rmap;
  437. }
  438. private Map<Object,Object> GetMobileAllInfo(JSONObject map){
  439. //实际业务数据
  440. Map<Object, Object> rmap = new HashMap<>();
  441. String iSN="";
  442. String oErrMessage = null;
  443. String oIMEI1 = "";
  444. String oIMEI2 = "";
  445. String oMEID = "";
  446. String oNetCode = "";
  447. String oPSN = "";
  448. String oID1 = "";
  449. String oID2 = "";
  450. String oID3 = "";
  451. String oID4 = "";
  452. String oID5 = "";
  453. String oWIFI = "";
  454. String oBT = "";
  455. String oCode1 = "";
  456. String oCode2 = "";
  457. String oCode3 = "";
  458. if(map.get("iSN")==null){
  459. oErrMessage = "SN不能为空";
  460. rmap.put("oErrMessage",oErrMessage);
  461. return rmap;
  462. }
  463. iSN=map.get("iSN").toString();
  464. Object ms_id =baseDao.getFieldDataByCondition("makeserial", "max(ms_id)", "ms_sncode='" + iSN + "'");
  465. if(ms_id!=null)
  466. {
  467. SqlRowList rs=baseDao.queryForRowSet("select 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 from MakeSerial where ms_id="+ms_id.toString());
  468. if(rs.next()){
  469. oWIFI = rs.getString("ms_mac");
  470. oBT = rs.getString("ms_bt");
  471. oPSN = rs.getString("ms_psn");
  472. oNetCode = rs.getString("ms_netcode");
  473. oMEID = rs.getString("ms_meid");
  474. oIMEI1 = rs.getString("ms_imei1");
  475. oIMEI2 = rs.getString("ms_imei2");
  476. oCode1 = rs.getString("ms_othcode1");
  477. oCode2 = rs.getString("ms_othcode2");
  478. oCode3 = rs.getString("ms_othcode3");
  479. oID1 = rs.getString("ms_othid3");
  480. oID2 = rs.getString("ms_othid3");
  481. oID3 = rs.getString("ms_othid3");
  482. }
  483. }else
  484. {
  485. oErrMessage = "序列号" + iSN + "不存在";
  486. rmap.put("oErrMessage",oErrMessage);
  487. return rmap;
  488. }
  489. if (oErrMessage == "" || oErrMessage == null || oErrMessage == "null"){
  490. rmap.put("oIMEI1",oIMEI1);
  491. rmap.put("oIMEI2",oIMEI2);
  492. rmap.put("oMEID",oMEID);
  493. rmap.put("oNetCode",oNetCode);
  494. rmap.put("oPSN",oPSN);
  495. rmap.put("oID1",oID1);
  496. rmap.put("oID2",oID2);
  497. rmap.put("oID3",oID3);
  498. rmap.put("oID4",oID4);
  499. rmap.put("oID5",oID5);
  500. rmap.put("oWIFI",oWIFI);
  501. rmap.put("oBT",oBT);
  502. rmap.put("oCode1",oCode1);
  503. rmap.put("oCode2",oCode2);
  504. rmap.put("oCode3",oCode3);
  505. }
  506. else
  507. rmap.put("oErrMessage",oErrMessage);
  508. return rmap;
  509. }
  510. private Map<Object,Object> SetAddressInfo(JSONObject map){
  511. //实际业务数据
  512. Map<Object, Object> rmap = new HashMap<>();
  513. String oErrMessage = null;
  514. if(map.get("iSN")==null){
  515. oErrMessage = "SN不能为空";
  516. rmap.put("oErrMessage",oErrMessage);
  517. return rmap;
  518. }
  519. String iSN=map.get("iSN").toString();
  520. String iWIFI = null;
  521. String iBT = null;
  522. String iCode1 = null;
  523. String iCode2 = null;
  524. String iCode3 = null;
  525. if(map.get("iWIFI")!=null){
  526. iWIFI=map.get("iWIFI").toString();
  527. }
  528. if(map.get("iBT")!=null){
  529. iBT=map.get("iBT").toString();
  530. }
  531. if(map.get("iCode1")!=null){
  532. iCode1=map.get("iCode1").toString();
  533. }
  534. if(map.get("iCode2")!=null){
  535. iCode2=map.get("iCode2").toString();
  536. }
  537. if(map.get("iCode3")!=null){
  538. iCode3=map.get("iCode3").toString();
  539. }
  540. List<String> list = new ArrayList<String>();
  541. list = baseDao.callProcedureWithOut("CS_SETADDRESSINFO", new Object[]{
  542. String.valueOf(iSN),
  543. String.valueOf(iWIFI),
  544. String.valueOf(iBT),
  545. String.valueOf(iCode1),
  546. String.valueOf(iCode2),
  547. String.valueOf(iCode3)
  548. }, new Integer[]{1, 2, 3, 4, 5, 6}, new Integer[]{7});
  549. oErrMessage = list.get(0);
  550. rmap.put("oErrMessage",oErrMessage);
  551. return rmap;
  552. }
  553. private Map<Object,Object> GetMaster(JSONObject map){
  554. //实际业务数据
  555. Map<Object, Object> rmap = new HashMap<>();
  556. SqlRowList rs=baseDao.queryForRowSet("select ma_user from mes.master");
  557. while(rs.next())
  558. {
  559. rmap.put(rs.getString("ma_user"),rs.getString("ma_user"));
  560. }
  561. return rmap;
  562. }
  563. private Map<Object,Object> SetMobileData(JSONObject map){
  564. //实际业务数据
  565. Map<Object, Object> rmap = new HashMap<>();
  566. String oErrMessage = null;
  567. if(map.get("iSN")==null||map.get("iTSN")==null){
  568. oErrMessage = "SN不能为空";
  569. rmap.put("oErrMessage",oErrMessage);
  570. return rmap;
  571. }
  572. String iSN=map.get("iSN").toString();
  573. String iTSN=map.get("iTSN").toString();
  574. String iSourceCode = null;
  575. String iOperater = null;
  576. String iResult = null;
  577. String flag = null;
  578. String iErrCode = null;
  579. if(map.get("iSourceCode")!=null){
  580. iSourceCode=map.get("iSourceCode").toString();
  581. }
  582. if(map.get("iOperater")!=null){
  583. iOperater=map.get("iOperater").toString();
  584. }
  585. if(map.get("iResult")!=null){
  586. iResult=map.get("iResult").toString();
  587. }
  588. if(map.get("flag")!=null){
  589. flag=map.get("flag").toString();
  590. }
  591. if(map.get("iErrCode")!=null){
  592. iErrCode=map.get("iErrCode").toString();
  593. }
  594. List<String> list = new ArrayList<String>();
  595. list = baseDao.callProcedureWithOut("CS_DLLSNCHANGE", new Object[]{
  596. String.valueOf(iTSN),
  597. String.valueOf(iSN),
  598. String.valueOf(iSourceCode),
  599. String.valueOf(iOperater),
  600. String.valueOf(iResult),
  601. String.valueOf(iErrCode),
  602. }, new Integer[]{1, 2, 3, 4, 5, 6}, new Integer[]{7});
  603. oErrMessage = list.get(0);
  604. rmap.put("oErrMessage",oErrMessage);
  605. return rmap;
  606. }
  607. private Map<Object,Object> SetIMEIInfo(JSONObject map){
  608. //实际业务数据
  609. Map<Object, Object> rmap = new HashMap<>();
  610. String oErrMessage = null;
  611. if(map.get("iSN")==null){
  612. oErrMessage = "SN不能为空";
  613. rmap.put("oErrMessage",oErrMessage);
  614. return rmap;
  615. }
  616. String iSN=map.get("iSN").toString();
  617. String iIMEI1=null;
  618. String iIMEI2 = null;
  619. String iIMEI3 = null;
  620. String iMEID = null;
  621. String iNET = null;
  622. String iID1 = null;
  623. String iID2 = null;
  624. String iID3 = null;
  625. if(map.get("iIMEI1")!=null){
  626. iIMEI1=map.get("iIMEI1").toString();
  627. }
  628. if(map.get("iIMEI2")!=null){
  629. iIMEI2=map.get("iIMEI2").toString();
  630. }
  631. if(map.get("iIMEI3")!=null){
  632. iIMEI3=map.get("iIMEI3").toString();
  633. }
  634. if(map.get("iMEID")!=null){
  635. iMEID=map.get("iMEID").toString();
  636. }
  637. if(map.get("iNET")!=null){
  638. iNET=map.get("iNET").toString();
  639. }
  640. if(map.get("iID1")!=null){
  641. iID1=map.get("iID1").toString();
  642. }
  643. if(map.get("iID2")!=null){
  644. iID2=map.get("iID2").toString();
  645. }
  646. if(map.get("iID3")!=null){
  647. iID3=map.get("iID3").toString();
  648. }
  649. List<String> list = new ArrayList<String>();
  650. list = baseDao.callProcedureWithOut("CS_SETIMEIINFO", new Object[]{
  651. String.valueOf(iSN),
  652. String.valueOf(iIMEI1),
  653. String.valueOf(iIMEI2),
  654. String.valueOf(iIMEI3),
  655. String.valueOf(iMEID),
  656. String.valueOf(iNET),
  657. String.valueOf(""),
  658. String.valueOf(iID1),
  659. String.valueOf(iID2),
  660. String.valueOf(iID3),
  661. }, new Integer[]{1, 2, 3, 4, 5, 6,7,8,9,10}, new Integer[]{11});
  662. oErrMessage = list.get(0);
  663. rmap.put("oErrMessage",oErrMessage);
  664. return rmap;
  665. }
  666. private Map<Object,Object> SetTestDetail(JSONObject map){
  667. //实际业务数据
  668. Map<Object, Object> rmap = new HashMap<>();
  669. String oErrMessage=null;
  670. if(map.get("iSN")==null){
  671. oErrMessage = "SN不能为空";
  672. rmap.put("oErrMessage",oErrMessage);
  673. return rmap;
  674. }
  675. String iSN=map.get("iSN").toString();
  676. String iTestResult= "";
  677. String iResCode= "";
  678. String iClassName="";
  679. String iTestDetail= "";
  680. if(map.get("iTestResult")!=null){
  681. iTestResult=map.get("iTestResult").toString();
  682. }
  683. if(map.get("iClassName")!=null){
  684. iClassName=map.get("iClassName").toString();
  685. }
  686. if(map.get("iResCode")!=null){
  687. iResCode=map.get("iResCode").toString();
  688. }
  689. if(map.get("iTestDetail")!=null){
  690. iTestDetail=map.get("iTestDetail").toString();
  691. }
  692. JSONObject map3=new JSONObject();
  693. map3.put("iSN",iSN);
  694. Map<Object, Object> map2=GetRcardMOInfo(map3);
  695. String omakeCode = "";
  696. StringBuffer sql=new StringBuffer();
  697. String[] name=iClassName.split("\\|");
  698. String[] result=iTestResult.split("\\|");
  699. String[] value=iTestDetail.split("\\|");
  700. if(name.length!=value.length||name.length!=result.length){
  701. rmap.put("oErrMessage","测试项目名称和值的项次不一致");
  702. return rmap;
  703. }
  704. for (int i=0;i<name.length;i++){
  705. sql.setLength(0);
  706. sql.append("Insert into STEPTESTDETAIL (STD_ID,STD_CLASS,STD_SN,STD_MAKECODE,STD_ACTUALVALUE,STD_TESTRESULT,STD_INDATE,STD_RESCODE)");
  707. sql.append("values(STEPTESTDETAIL_SEQ.nextval,'"+name[i]+"','" + iSN + "','" + map2.get("oMoCode") + "','" + value[i] + "','" + result[i] + "',sysdate,'" + iResCode + "')");
  708. baseDao.execute(sql.toString());
  709. }
  710. rmap.put("oErrMessage",oErrMessage);
  711. return rmap;
  712. }
  713. private Map<Object,Object> SetPcbaData(JSONObject map){
  714. //实际业务数据
  715. Map<Object, Object> rmap = new HashMap<>();
  716. String oErrMessage = null;
  717. if(map.get("iSN")==null){
  718. oErrMessage = "SN不能为空";
  719. rmap.put("oErrMessage",oErrMessage);
  720. return rmap;
  721. }
  722. String iSN=map.get("iSN").toString();
  723. String iResCode = null;
  724. String iOperator = null;
  725. String iResult = null;
  726. String iErrCode = null;
  727. if(map.get("iResCode")!=null){
  728. iResCode=map.get("iResCode").toString();
  729. }
  730. if(map.get("iOperater")!=null){
  731. iOperator=map.get("iOperater").toString();
  732. }
  733. if(map.get("iResult")!=null){
  734. iResult=map.get("iResult").toString();
  735. }
  736. if(map.get("iErrCode")!=null){
  737. iErrCode=map.get("iErrCode").toString();
  738. }
  739. JSONObject map3=new JSONObject();
  740. map3.put("iSN",iSN);
  741. Map<Object, Object> map2=GetRcardMOInfo(map3);
  742. String oMoCode=null;
  743. if(map2.get("oMoCode")!=null){
  744. oMoCode=map2.get("oMoCode").toString();
  745. }
  746. if (map2.get("oErrMessage")==null)
  747. return SetStepFinish(oMoCode, iResCode, iSN, "", iResult, iOperator, iErrCode);
  748. return rmap;
  749. }
  750. /// <summary>
  751. /// 获取步骤代码
  752. /// </summary>
  753. /// <param name="Source"></param>
  754. /// <returns></returns>
  755. private String GetStepCodeBySource(String Source)
  756. {
  757. Object o=baseDao.getFieldDataByCondition("source", "sc_stepcode", "sc_code='" + Source + "'");
  758. if(o!=null)
  759. return o.toString();
  760. else
  761. return "";
  762. }
  763. private Boolean CheckUserLogin(String iUserCode, String iPassWord)
  764. {
  765. SqlRowList rs =baseDao.queryForRowSet("select em_code from employee where em_code='"+iUserCode+"' and em_password =?",iPassWord);
  766. if (rs.next())
  767. return true;
  768. else
  769. {
  770. return false;
  771. }
  772. }
  773. private Map<Object,Object> GetMakeInfoBySN(JSONObject map)
  774. {
  775. Map<Object, Object> rmap = new HashMap<Object, Object>();
  776. String iSN=null;
  777. String oErrMessage=null;
  778. if(map.get("iSN")==null){
  779. oErrMessage = "SN不能为空";
  780. rmap.put("oErrMessage",oErrMessage);
  781. return rmap;
  782. }
  783. iSN=map.get("iSN").toString();
  784. 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 " +
  785. "left join makeserial on ms_makecode=ma_code where ms_sncode='"+iSN+"'");
  786. if(rs.next()){
  787. rmap.put("oMaremark1",rs.getString("ma_remark1"));
  788. rmap.put("oMaremark2",rs.getString("ma_remark2"));
  789. rmap.put("oMaremark3",rs.getString("ma_remark3"));
  790. rmap.put("oMaremark4",rs.getString("ma_remark4"));
  791. rmap.put("oMaremark5",rs.getString("ma_remark5"));
  792. rmap.put("oMaremark6",rs.getString("ma_remark6"));
  793. rmap.put("oMaremark7",rs.getString("ma_remark7"));
  794. rmap.put("oMaremark8",rs.getString("ma_remark8"));
  795. rmap.put("oMaremark9",rs.getString("ma_remark9"));
  796. rmap.put("oMaremark10",rs.getString("ma_remark10"));
  797. rmap.put("oMaremark11",rs.getString("ma_remark11"));
  798. rmap.put("oMaremark12",rs.getString("ma_remark12"));
  799. rmap.put("oMaremark13",rs.getString("ma_remark13"));
  800. rmap.put("oMaremark14",rs.getString("ma_remark14"));
  801. rmap.put("oMaremark15",rs.getString("ma_remark15"));
  802. rmap.put("oMaremark16",rs.getString("ma_remark16"));
  803. return rmap;
  804. }else{
  805. oErrMessage = "SN未查询到关联信息";
  806. rmap.put("oErrMessage",oErrMessage);
  807. return rmap;
  808. }
  809. }
  810. public Map<Object,Object> SetStepFinish(String iMakeCode, String iSourceCode, String iSN, String iMPKind, String iResult, String iUserCode, String iErrCode)
  811. {
  812. String oErrMessage = null;
  813. Object StepCode = baseDao.getFieldDataByCondition("Makeserial", "ms_stepcode", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  814. String CurrentStep = GetStepCodeBySource(iSourceCode);
  815. Map<Object, Object> rmap = new HashMap<>();
  816. switch (iResult)
  817. {
  818. case "OK":
  819. break;
  820. case "NG":
  821. if (iErrCode == "")
  822. {
  823. oErrMessage = "测试结果为NG时必须传递不良代码";
  824. rmap.put("oErrMessage",oErrMessage);
  825. return rmap;
  826. }
  827. else
  828. {
  829. baseDao.updateByCondition("makebad", "mb_status=-1", "mb_sncode='" + iSN + "' and mb_makecode='" + iMakeCode + "' and mb_stepcode='" + CurrentStep + "' and mb_status=0");
  830. String[] BadCode = iErrCode.split(",");
  831. StringBuffer sql=new StringBuffer();
  832. for (int i = 0; i < BadCode.length; i++)
  833. {
  834. if(!baseDao.checkIf("badcode","bc_code='"+ BadCode[i]+"'")){
  835. oErrMessage = "不良代码"+BadCode[i]+"不存在";
  836. rmap.put("oErrMessage",oErrMessage);
  837. return rmap;
  838. }
  839. Object BgCode = baseDao.getFieldDataByCondition("badcode", "nvl(bc_groupcode,' ')", "bc_code='" + BadCode[i] + "'");
  840. Object BgName= baseDao.getFieldDataByCondition("badcode", "nvl(bc_groupname,' ')", "bc_code='" + BadCode[i] + "'");
  841. int mb_id = baseDao.getSeqId("makebad_seq");
  842. sql.setLength(0);
  843. sql.append("insert into makebad(mb_id,mb_makecode,mb_mscode,mb_sncode,mb_inman,mb_indate,mb_stepcode");
  844. sql.append(",mb_sourcecode,mb_badcode,mb_badtable,mb_bgcode,mb_bgname,mb_soncode,mb_status) select '" + mb_id + "'");
  845. sql.append(",ma_code,ms_code,ms_sncode,'" + iUserCode + "',sysdate,'" + CurrentStep + "','" + iSourceCode + "','" + BadCode[i] + "','',");
  846. sql.append("'" + BgCode + "','"+BgName+"',sp_soncode,'0' from make left join makeSerial on ms_makecode=ma_code left join stepProduct on ");
  847. sql.append("sp_mothercode=ma_prodcode and sp_stepcode=ms_nextstepcode where ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  848. baseDao.execute(sql.toString());
  849. }
  850. //将不良的序列号的状态码设为3
  851. baseDao.execute("update makeserial set ms_status='3' where ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  852. }
  853. break;
  854. default:
  855. oErrMessage = "测试结果必须为NG或者OK";
  856. rmap.put("oErrMessage",oErrMessage);
  857. return rmap;
  858. }
  859. //不良采集为良品是更新
  860. if (StepCode!=null &&StepCode.toString().equals(CurrentStep) && iResult == "OK")
  861. {
  862. Object[] ob = baseDao.getFieldsDataByCondition("makeserial", "ms_status,ms_craftcode,ms_prodcode", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  863. if (ob!=null)
  864. {
  865. String ms_status =ob[0].toString();
  866. String ms_craftcode= ob[1].toString();
  867. String ms_prodcode = ob[2].toString();
  868. if (ms_status == "3")
  869. {
  870. 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();
  871. baseDao.updateByCondition("makeserial", "ms_status=1,ms_nextstepcode='" + nextstepcode + "'", "ms_sncode='" + iSN + "' and ms_makecode='" + iMakeCode + "'");
  872. baseDao.updateByCondition("makebad", "mb_status=-1", "mb_sncode='" + iSN + "' and mb_makecode='" + iMakeCode + "'");
  873. }
  874. }
  875. }
  876. return CS_SetFinish(iMakeCode, iSourceCode, iSN, iUserCode, iResult);
  877. }
  878. private Map<Object,Object> CS_SetFinish(String iMakeCode, String iSourceCode, String iSN, String iUserCode, String iResult)
  879. {
  880. Map<Object, Object> rmap = new HashMap<>();
  881. String oErrMessage=null;
  882. List<String> list = new ArrayList<String>();
  883. list = baseDao.callProcedureWithOut("CS_SETSTEPRESULT", new Object[]{
  884. String.valueOf(iMakeCode),
  885. String.valueOf(iSourceCode),
  886. String.valueOf(iSN),
  887. String.valueOf(iUserCode),
  888. String.valueOf(iResult),
  889. }, new Integer[]{1, 2, 3, 4, 5}, new Integer[]{6});
  890. oErrMessage = list.get(0);
  891. rmap.put("oErrMessage",oErrMessage);
  892. return rmap;
  893. }
  894. private String checkAccessKey(String accessKey,String requestId){
  895. Object accessSecret_O = baseDao.getFieldDataByCondition("APIEMPLOYEE", "AE_SECRET", "AE_KEY='" + accessKey + "'");
  896. Object AE_MASTER = baseDao.getFieldDataByCondition("APIEMPLOYEE", "AE_MASTER", "AE_KEY='" + accessKey + "'");
  897. String accessSecret = accessSecret_O == null ? "" : accessSecret_O.toString();
  898. // 检查KEY是否合理
  899. if (StringUtils.isEmpty(accessKey) || StringUtils.isEmpty(accessSecret) || AE_MASTER== null || "".equals(AE_MASTER.toString())) {
  900. ApiResult apiResult = new ApiResult(ErrorMessage.ACCESSKEY_ILLEGAL.getCode(),ErrorMessage.ACCESSKEY_ILLEGAL.getMessage(),requestId);
  901. throw new ApiSystemException(apiResult);
  902. }
  903. return AE_MASTER.toString();
  904. }
  905. }