serviceorder.java 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960
  1. package restcontroller.webmanage.sale.serviceorder;
  2. import beans.data.BatchDeleteErr;
  3. import beans.datacontrllog.DataContrlLog;
  4. import beans.datatag.DataTag;
  5. import beans.datateam.DataTeam;
  6. import beans.parameter.Parameter;
  7. import beans.salearea.SaleArea;
  8. import com.alibaba.fastjson2.JSONArray;
  9. import com.alibaba.fastjson2.JSONObject;
  10. import common.BaseClass;
  11. import common.Controller;
  12. import common.YosException;
  13. import common.annotation.API;
  14. import common.annotation.CACHEING;
  15. import common.annotation.CACHEING_CLEAN;
  16. import common.data.*;
  17. import org.apache.commons.lang.StringUtils;
  18. import org.apache.cxf.configuration.security.DNConstraintsType;
  19. import restcontroller.R;
  20. import restcontroller.webmanage.executorService.Executor;
  21. import restcontroller.webmanage.sale.serviceorder.tools.HttpURLRest;
  22. import restcontroller.webmanage.sale.serviceorder.tools.VerificationManage;
  23. import restcontroller.webmanage.sale.workorder.workorder;
  24. import restcontroller.webmanage.sale.workorder.workpresetInfo;
  25. import utility.sms.Sms;
  26. import java.util.*;
  27. import java.util.regex.Pattern;
  28. /**
  29. * 服务申请单
  30. */
  31. @API(title = "服务申请单管理")
  32. public class serviceorder extends Controller {
  33. public static HashMap<String, VerificationManage> message_map = new HashMap<>();
  34. public serviceorder(JSONObject arg0) throws YosException {
  35. super(arg0);
  36. // TODO Auto-generated constructor stub
  37. }
  38. @API(title = "服务申请单新增更新", apiversion = R.ID20230206091403.v1.class)
  39. @CACHEING_CLEAN(apiversions = {R.ID20230206091603.v1.class, R.ID20230206091703.v1.class, R.ID20230206101303.v1.class, R.ID20230217100703.v1.class, R.ID20230217133003.v1.class})
  40. public String insertormodify_serviceorder() throws YosException {
  41. ArrayList<String> sqlList = new ArrayList<>();
  42. // 表名
  43. String tableName = "sa_serviceorder";
  44. Long sa_serviceorderid = content.getLong("sa_serviceorderid");
  45. String servicetype = content.getString("servicetype"); //服务分类
  46. if (sys_enterpriseid<=0) {
  47. sys_enterpriseid = content.getLong("sys_enterpriseid");
  48. }
  49. String remarks = content.getStringValue("remarks");
  50. String class1 = content.getStringValue("class1");
  51. String class2 = content.getStringValue("class2");
  52. String reason = content.getStringValue("reason");
  53. String province = content.getStringValue("province");
  54. String city = content.getStringValue("city");
  55. String county = content.getStringValue("county");
  56. String address = content.getStringValue("address");
  57. String scenecontact = content.getStringValue("scenecontact");
  58. String scenecontactrole = content.getStringValue("scenecontactrole");
  59. String scenecontactphonenumber = content.getStringValue("scenecontactphonenumber");
  60. String billdate = content.getStringValue("billdate");
  61. String begdate = content.getStringValue("begdate");
  62. String enddate = content.getStringValue("enddate");
  63. long saler_hrid = content.getLongValue("saler_hrid");
  64. String sku = content.getStringValue("sku");
  65. String cardno = content.getStringValue("cardno");
  66. long itemid = content.getLongValue("itemid");
  67. SQLFactory sqlFactory = new SQLFactory(this, "服务申请单新增");
  68. if (content.containsKey("servicetype")) {
  69. if (content.getString("servicetype").equals("安装")) {
  70. if (StringUtils.isBlank(sku)) {
  71. return getErrReturnObject().setErrMsg("安装服务单需添加序列号").toString();
  72. }
  73. if (dbConnect.runSqlQuery("select * from sa_warrantycard where sku='" + sku + "' and siteid='" + siteid + "'").isNotEmpty()) {
  74. DataTag.createSystemTag(this, "sa_serviceorder", sa_serviceorderid, "重复安装");
  75. //return getErrReturnObject().setErrMsg("该序列号已安装,无法再次安装").toString();
  76. }
  77. }
  78. }
  79. if (content.containsKey("phonenumber") && !"".equals(content.getString("phonenumber"))) {
  80. if (!Pattern.matches("^1([358][0-9]|4[579]|66|7[0135678]|9[89])[0-9]{8}$", content.getString("phonenumber"))) {
  81. return getErrReturnObject().setErrMsg("手机格式有误").toString();
  82. }
  83. }
  84. if (sa_serviceorderid <= 0 || dbConnect.runSqlQuery(
  85. "select sa_serviceorderid from sa_serviceorder where sa_serviceorderid=" + sa_serviceorderid)
  86. .isEmpty()) {
  87. sa_serviceorderid = createTableID(tableName);
  88. sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  89. if (saler_hrid != 0) {
  90. sqlFactory.addParameter("saler_hrid", saler_hrid);
  91. } else {
  92. Rows hrRows = dbConnect.runSqlQuery("select hrid from sys_enterprise_tradefield where siteid='" + siteid + "' and sys_enterpriseid=" + sys_enterpriseid);
  93. if (hrRows.isEmpty()) {
  94. sqlFactory.addParameter("saler_hrid", saler_hrid);
  95. } else {
  96. sqlFactory.addParameter("saler_hrid", hrRows.get(0).getLong("hrid"));
  97. }
  98. }
  99. sqlList.add(
  100. DataContrlLog.createLog(this, "sa_serviceorder", sa_serviceorderid, "新增", "服务申请单新增成功").getSQL());
  101. } else {
  102. Rows rows = dbConnect.runSqlQuery(
  103. "SELECT status,sys_enterpriseid,sa_orderid from sa_serviceorder WHERE sa_serviceorderid = "
  104. + sa_serviceorderid);
  105. if (rows.isNotEmpty()) {
  106. if (rows.get(0).getString("status").equals("新建")) {
  107. sqlFactory = new SQLFactory(this, "服务申请单更新");
  108. sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  109. sqlList.add(DataContrlLog.createLog(this, "sa_serviceorder", sa_serviceorderid, "更新", "服务申请单更新成功")
  110. .getSQL());
  111. } else {
  112. return getErrReturnObject().setErrMsg("非新建状态下无法编辑").toString();
  113. }
  114. } else {
  115. return getErrReturnObject().setErrMsg("该服务申请单不存在").toString();
  116. }
  117. }
  118. sqlFactory.addParameter("saler_hrid", saler_hrid);
  119. sqlFactory.addParameter("servicetype", servicetype);
  120. sqlFactory.addParameter("siteid", siteid);
  121. sqlFactory.addParameter("userid", userid);
  122. sqlFactory.addParameter("username", username);
  123. sqlFactory.addParameter("sa_serviceorderid", sa_serviceorderid);
  124. sqlFactory.addParameter("sa_orderid", 0);
  125. sqlFactory.addParameter("remarks", remarks);
  126. sqlFactory.addParameter("class1", class1);
  127. sqlFactory.addParameter("class2", class2);
  128. sqlFactory.addParameter("reason", reason);
  129. sqlFactory.addParameter("province", province);
  130. sqlFactory.addParameter("city", city);
  131. sqlFactory.addParameter("county", county);
  132. sqlFactory.addParameter("address", address);
  133. sqlFactory.addParameter("scenecontact", scenecontact);
  134. sqlFactory.addParameter("scenecontactrole", scenecontactrole);
  135. sqlFactory.addParameter("scenecontactphonenumber", scenecontactphonenumber);
  136. // 服务申请单号createBillCode("serviceorder")
  137. sqlFactory.addParameter("billno", createBillCode("serviceorder"));
  138. sqlFactory.addParameter("billdate", billdate.equals("") ? "null" : billdate);
  139. sqlFactory.addParameter("begdate", begdate.equals("") ? "null" : begdate);
  140. sqlFactory.addParameter("enddate", enddate.equals("") ? "null" : enddate);
  141. sqlFactory.addParameter("name", content.getStringValue("name"));
  142. sqlFactory.addParameter("phonenumber", content.getStringValue("phonenumber"));
  143. sqlFactory.addParameter("sa_customersid", content.getStringValue("sa_customersid"));
  144. sqlList.add(sqlFactory.getSQL());
  145. InsertSQL insertSQL = SQLFactory.createInsertSQL(this, "sa_serviceorderitems");
  146. insertSQL.setUniqueid(createTableID("sa_serviceorderitems"));
  147. insertSQL.setSiteid(siteid);
  148. insertSQL.setValue("sa_serviceorderid", sa_serviceorderid);
  149. insertSQL.setValue("itemid", itemid);
  150. insertSQL.setValue("sku", sku);
  151. insertSQL.setValue("cardno", cardno);
  152. insertSQL.setValue("reason", reason);
  153. sqlList.add(insertSQL.getSQL());
  154. dbConnect.runSqlUpdate("delete from sa_serviceorderitems where siteid='" + siteid + "' and sa_serviceorderid=" + sa_serviceorderid);
  155. dbConnect.runSqlUpdate(sqlList);
  156. content.put("sa_serviceorderid", sa_serviceorderid);
  157. return queryserviceorderMain();
  158. }
  159. /**
  160. * 服务分类查询
  161. **/
  162. @API(title = "服务分类查询", apiversion = R.ID20230206112003.v1.class)
  163. public String servicetypeList() throws YosException {
  164. Rows rows = new Rows();
  165. Row row1 = new Row();
  166. row1.put("value", "维修");
  167. Row row2 = new Row();
  168. row2.put("value", "安装");
  169. Row row3 = new Row();
  170. row3.put("value", "清洗");
  171. rows.add(row1);
  172. rows.add(row2);
  173. rows.add(row3);
  174. return getSucReturnObject().setData(rows).toString();
  175. }
  176. @API(title = "可选择序列号列表查询", apiversion = R.ID2025082210142103.v1.class)
  177. @CACHEING
  178. public String queryskuList() throws YosException {
  179. if (content.containsKey("sys_enterpriseid")) {
  180. sys_enterpriseid = content.getLong("sys_enterpriseid");
  181. }
  182. /*
  183. * 过滤条件设置
  184. */
  185. StringBuffer where = new StringBuffer(" 1=1 ");
  186. if (content.containsKey("where")) {
  187. JSONObject whereObject = content.getJSONObject("where");
  188. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  189. where.append(" and(");
  190. where.append("t2.itemname like'%").append(whereObject.getString("condition")).append("%' ");
  191. where.append("or t2.itemno like'%").append(whereObject.getString("condition")).append("%' ");
  192. where.append("or t1.sku like'%").append(whereObject.getString("condition")).append("%' ");
  193. where.append(")");
  194. }
  195. }
  196. // String hrid = content.getString("hrid");
  197. // SQLFactory sqlFactory = new SQLFactory(this, "审核订单列表查询", pageSize, pageNumber, pageSorting);
  198. // sqlFactory.addParameter_SQL("where", where);
  199. // sqlFactory.addParameter("siteid", siteid);
  200. // sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  201. // Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL(false));
  202. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sa_itemsku", "sku");
  203. querySQL.setTableAlias("t1");
  204. querySQL.addJoinTable(JOINTYPE.left, "plm_item", "t2", "t1.itemid=t2.itemid and t1.siteid=t2.siteid", "itemid", "itemno", "itemname", "model", "spec");
  205. querySQL.addJoinTable(JOINTYPE.left, "plm_unit", "t3", "t3.unitid=t2.unitid and t3.siteid=t2.siteid", "unitname");
  206. querySQL.addJoinTable(JOINTYPE.left, "sa_agents", "t4", "t4.sa_agentsid=t1.sa_agentsid and t4.siteid=t1.siteid", "agentnum");
  207. querySQL.addJoinTable(JOINTYPE.left, "sys_enterprise", "t5", "t5.sys_enterpriseid=t4.sys_enterpriseid and t5.siteid=t4.siteid", "contact", "phonenumber", "address");
  208. querySQL.addJoinTable(JOINTYPE.left, "sa_warrantycard", "t6", "t6.sku=t1.sku and t6.siteid=t1.siteid", "cardno", "begdate", "enddate");
  209. querySQL.addJoinTable(JOINTYPE.left, "sa_customers", "t7", "t6.sa_customersid=t7.sa_customersid and t6.siteid=t7.siteid", "sa_customersid");
  210. querySQL.addQueryFields("customername", "t7.name");
  211. querySQL.addQueryFields("customerphonenumber", "t7.phonenumber");
  212. querySQL.setSiteid(siteid);
  213. querySQL.setWhere("t1.sa_agentsid in (select sa_agentsid from sa_agents where sys_enterpriseid=" + sys_enterpriseid + ")");
  214. querySQL.setWhere(where.toString());
  215. querySQL.setPage(pageSize, pageNumber);
  216. Rows rows = querySQL.query();
  217. return getSucReturnObject().setData(rows).toString();
  218. }
  219. @API(title = "可选择订单列表查询", apiversion = R.ID20230206091503.v1.class)
  220. @CACHEING
  221. public String queryCheckOrderList() throws YosException {
  222. if (content.containsKey("sys_enterpriseid")) {
  223. sys_enterpriseid = content.getLong("sys_enterpriseid");
  224. }
  225. /*
  226. * 过滤条件设置
  227. */
  228. StringBuffer where = new StringBuffer(" 1=1 ");
  229. // if(content.getBooleanValue("istool")) {
  230. // where.append(" and t1.type ='工具借用单' ");
  231. // }else {
  232. // where.append(" and t1.type !='工具借用单' ");
  233. // }
  234. if (content.containsKey("where")) {
  235. JSONObject whereObject = content.getJSONObject("where");
  236. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  237. where.append(" and(");
  238. where.append("t1.sonum like'%").append(whereObject.getString("condition")).append("%' ");
  239. where.append(")");
  240. }
  241. if (whereObject.containsKey("sonum") && !"".equals(whereObject.getString("sonum"))) {
  242. where.append(" and t1.sonum ='").append(whereObject.getString("sonum")).append("' ");
  243. }
  244. if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
  245. where.append(" and t1.checkdate >='").append(whereObject.getString("begindate")).append("' ");
  246. }
  247. if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
  248. where.append(" and t1.checkdate <='").append(whereObject.getString("enddate")).append("' ");
  249. }
  250. }
  251. // String hrid = content.getString("hrid");
  252. SQLFactory sqlFactory = new SQLFactory(this, "审核订单列表查询");
  253. sqlFactory.addParameter_SQL("where", where);
  254. sqlFactory.addParameter("siteid", siteid);
  255. sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
  256. // Rows rows = dbConnect.runSqlQuery(sqlFactory);
  257. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_site_parameter", "sys_site_parameterid");
  258. querySQL.setTableAlias("t0");
  259. querySQL.addJoinTable(JOINTYPE.right, sqlFactory, "t1", "t0.siteid='111'", "*");
  260. querySQL.setPage(pageSize, pageNumber);
  261. Rows rows = querySQL.query();
  262. return getSucReturnObject().setData(rows).toString();
  263. }
  264. @API(title = "服务申请单详情", apiversion = R.ID20230206091603.v1.class)
  265. @CACHEING
  266. public String queryserviceorderMain() throws YosException {
  267. Long sa_serviceorderid = content.getLong("sa_serviceorderid");
  268. SQLFactory sqlFactory = new SQLFactory(this, "服务申请单详情查询");
  269. sqlFactory.addParameter("sa_serviceorderid", sa_serviceorderid);
  270. sqlFactory.addParameter("siteid", siteid);
  271. Rows rows = dbConnect.runSqlQuery(sqlFactory);
  272. ArrayList<Long> ids = rows.toArrayList("sa_serviceorderid", new ArrayList<>());
  273. HashMap<Long, ArrayList<String>> tagRows = DataTag.queryTag(this, "sa_serviceorder", ids, true);
  274. for (Row row : rows) {
  275. if (tagRows.get(row.getLong("sa_serviceorderid")) != null) {
  276. row.put("tag", tagRows.get(row.getLong("sa_serviceorderid")));
  277. } else {
  278. row.put("tag", new ArrayList<String>());
  279. }
  280. }
  281. Row row = rows.isNotEmpty() ? rows.get(0) : new Row();
  282. // if(!row.isEmpty()) {
  283. // //服务申请单关联物料查询
  284. // SQLFactory sqlFactorytitem = new SQLFactory(this, "服务申请单关联物料查询");
  285. // sqlFactorytitem.addParameter("sa_serviceorderid", sa_serviceorderid);
  286. // sqlFactorytitem.addParameter("siteid", siteid);
  287. // row.put("titems",dbConnect.runSqlQuery(sqlFactorytitem));
  288. // //服务申请单关联工单查询
  289. // SQLFactory sqlFactoryworkorder = new SQLFactory(this, "服务申请单关联工单查询");
  290. // sqlFactoryworkorder.addParameter("sa_serviceorderid", sa_serviceorderid);
  291. // sqlFactoryworkorder.addParameter("siteid", siteid);
  292. // row.put("workorder",dbConnect.runSqlQuery(sqlFactoryworkorder));
  293. // }
  294. Rows backreasonRows = dbConnect.runSqlQuery("select backreason from sys_dataextend where ownertable='sa_serviceorder' and siteid='" + siteid + "' and backreason is not null and backreason <>'' and ownerid=" + sa_serviceorderid + " order by changedate desc");
  295. if (!backreasonRows.isEmpty()) {
  296. row.put("backreason", backreasonRows.get(0).getString("backreason"));
  297. } else {
  298. row.put("backreason", "");
  299. }
  300. return getSucReturnObject().setData(row).toString();
  301. }
  302. @API(title = "服务申请单详情(不验证token))", apiversion = R.ID20230217133003.v1.class, accesstoken = false)
  303. public String queryserviceorderMainWithoutToken() throws YosException {
  304. Long sa_serviceorderid = content.getLong("sa_serviceorderid");
  305. SQLFactory sqlFactory = new SQLFactory(this, "服务申请单详情查询2");
  306. sqlFactory.addParameter("sa_serviceorderid", sa_serviceorderid);
  307. Rows rows = dbConnect.runSqlQuery(sqlFactory);
  308. Row row = rows.isNotEmpty() ? rows.get(0) : new Row();
  309. if (!row.isEmpty()) {
  310. //服务申请单关联物料查询
  311. SQLFactory sqlFactorytitem = new SQLFactory(this, "服务申请单关联物料查询");
  312. sqlFactorytitem.addParameter("sa_serviceorderid", sa_serviceorderid);
  313. row.put("titems", dbConnect.runSqlQuery(sqlFactorytitem));
  314. //服务申请单关联工单查询
  315. SQLFactory sqlFactoryworkorder = new SQLFactory(this, "服务申请单关联工单查询");
  316. sqlFactoryworkorder.addParameter("sa_serviceorderid", sa_serviceorderid);
  317. row.put("workorder", dbConnect.runSqlQuery(sqlFactoryworkorder));
  318. }
  319. Rows backreasonRows = dbConnect.runSqlQuery("select backreason from sys_dataextend where ownertable='sa_serviceorder' and backreason is not null and backreason <>'' and ownerid=" + sa_serviceorderid + " order by changedate desc");
  320. if (!backreasonRows.isEmpty()) {
  321. row.put("backreason", backreasonRows.get(0).getString("backreason"));
  322. } else {
  323. row.put("backreason", "");
  324. }
  325. return getSucReturnObject().setData(row).toString();
  326. }
  327. @API(title = "服务申请单关联工单查询", apiversion = R.ID20230207154203.v1.class)
  328. @CACHEING
  329. public String queryserviceorderWorkorderList() throws YosException {
  330. Long sa_serviceorderid = content.getLong("sa_serviceorderid");
  331. StringBuffer where = new StringBuffer(" 1=1 ");
  332. // if (content.containsKey("where")) {
  333. // JSONObject whereObject = content.getJSONObject("where");
  334. // if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  335. // where.append(" and(");
  336. // where.append("t1.billno like'%").append(whereObject.getString("condition")).append("%' ");
  337. // where.append("or t3.sonum like'%").append(whereObject.getString("condition")).append("%' ");
  338. // where.append("or t2.enterprisename like'%").append(whereObject.getString("condition")).append("%' ");
  339. // where.append("or t1.reason like'%").append(whereObject.getString("condition")).append("%' ");
  340. // where.append(")");
  341. // }
  342. // if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  343. // where.append(" and t1.status ='").append(whereObject.getString("status")).append("' ");
  344. // }
  345. // }
  346. SQLFactory sqlFactory = new SQLFactory(this, "服务申请单关联工单查询");
  347. sqlFactory.addParameter("siteid", siteid);
  348. sqlFactory.addParameter("sa_serviceorderid", sa_serviceorderid);
  349. sqlFactory.addParameter_SQL("where", where);
  350. // Rows rows = dbConnect.runSqlQuery(sqlFactory);
  351. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_site_parameter", "sys_site_parameterid");
  352. querySQL.setTableAlias("t0");
  353. querySQL.addJoinTable(JOINTYPE.right, sqlFactory, "t1", "t0.siteid='111'", "*");
  354. querySQL.setPage(pageSize, pageNumber);
  355. Rows rows = querySQL.query();
  356. return getSucReturnObject().setData(rows).toString();
  357. }
  358. @API(title = "查询服务申请单列表", apiversion = R.ID20230206091703.v1.class)
  359. @CACHEING
  360. public String queryserviceorderList() throws YosException {
  361. StringBuffer where = new StringBuffer(" 1=1 ");
  362. if (content.containsKey("where")) {
  363. JSONObject whereObject = content.getJSONObject("where");
  364. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  365. where.append(" and(");
  366. where.append("t1.servicetype like'%").append(whereObject.getString("condition")).append("%' ");
  367. where.append("or t2.enterprisename like'%").append(whereObject.getString("condition")).append("%' ");
  368. where.append("or t1.reason like'%").append(whereObject.getString("condition")).append("%' ");
  369. where.append("or t1.class1 like'%").append(whereObject.getString("condition")).append("%' ");
  370. where.append(")");
  371. }
  372. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  373. where.append(" and t1.status ='").append(whereObject.getString("status")).append("' ");
  374. }
  375. if (whereObject.containsKey("class1") && !"".equals(whereObject.getString("class1"))) {
  376. where.append(" and t1.class1 ='").append(whereObject.getString("class1")).append("' ");
  377. }
  378. if (whereObject.containsKey("servicetype") && !"".equals(whereObject.getString("servicetype"))) {
  379. where.append(" and t1.servicetype ='").append(whereObject.getString("servicetype")).append("' ");
  380. }
  381. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  382. where.append(" and t1.status ='").append(whereObject.getString("status")).append("' ");
  383. }
  384. if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
  385. where.append(" and t1.submitdate >='").append(whereObject.getString("begindate")).append("'");
  386. }
  387. if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
  388. where.append(" and t1.submitdate <='").append(whereObject.getString("enddate")).append("'");
  389. }
  390. if (whereObject.containsKey("submitdate") && !"".equals(whereObject.getString("submitdate"))) {
  391. where.append(" and t1.submitdate >='").append(whereObject.getString("submitdate")).append("'");
  392. where.append(" and t1.submitdate <='").append(getDate_Str(whereObject.getDate("submitdate"), 1)).append("'");
  393. }
  394. if (whereObject.containsKey("phonenumber") && !"".equals(whereObject.getString("phonenumber"))) {
  395. where.append(" and t1.scenecontactphonenumber ='").append(whereObject.getString("phonenumber")).append("'");
  396. }
  397. if (whereObject.containsKey("customerphonenumber") && !"".equals(whereObject.getString("customerphonenumber"))) {
  398. where.append(" and t1.phonenumber ='").append(whereObject.getString("customerphonenumber")).append("'");
  399. }
  400. if (whereObject.containsKey("sa_customersid") && !"".equals(whereObject.getString("sa_customersid"))) {
  401. where.append(" and t1.sa_customersid ='").append(whereObject.getString("sa_customersid")).append("'");
  402. }
  403. if(whereObject.getBooleanValue("todaysubmitCount")){
  404. where.append(" and t1.status != '新建' and DATE(t1.submitdate) = CURDATE() ");
  405. }
  406. if(whereObject.getBooleanValue("todayazsubmitCount")){
  407. where.append(" and t1.status != '新建' and t10.type='安装' and DATE(t1.submitdate) = CURDATE() ");
  408. }
  409. if(whereObject.getBooleanValue("todaywxsubmitCount")){
  410. where.append(" and t1.status != '新建' and t10.type='维修' and DATE(t1.submitdate) = CURDATE() ");
  411. }
  412. if(whereObject.getBooleanValue("todayqxsubmitCount")){
  413. where.append(" and t1.status != '新建' and t10.type='清洗' and DATE(t1.submitdate) = CURDATE() ");
  414. }
  415. if(whereObject.getBooleanValue("tobeassignedCount")){
  416. where.append(" and t1.status = '待分配' ");
  417. }
  418. if(whereObject.getBooleanValue("tobeassignedCount24")){
  419. where.append(" and t1.status = '待分配' and t1.submitdate < DATE_SUB(NOW(), INTERVAL 24 HOUR) ");
  420. }
  421. if(whereObject.getBooleanValue("pendingCount")){
  422. where.append(" and t1.status = '待受理' ");
  423. }
  424. if(whereObject.getBooleanValue("pendingCount24")){
  425. where.append(" and t1.status = '待受理' and t1.allocationdate < DATE_SUB(NOW(), INTERVAL 24 HOUR) ");
  426. }
  427. if(whereObject.getBooleanValue("refuseacceptCount")){
  428. where.append(" and t1.status = '拒绝受理' ");
  429. }
  430. if(whereObject.getBooleanValue("tobeservedCount")){
  431. where.append(" and t1.status = '待服务' ");
  432. }
  433. if(whereObject.getBooleanValue("inserviceCount")){
  434. where.append(" and t1.status = '服务中' ");
  435. }
  436. }
  437. SQLFactory sqlFactory = new SQLFactory(this, "服务申请单列表查询");
  438. sqlFactory.addParameter("siteid", siteid);
  439. sqlFactory.addParameter_SQL("where", where);
  440. // Rows rows = dbConnect.runSqlQuery(sqlFactory);
  441. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_site_parameter", "sys_site_parameterid");
  442. querySQL.setTableAlias("t0");
  443. querySQL.addJoinTable(JOINTYPE.right, sqlFactory, "t1", "t0.siteid='111'", "*");
  444. querySQL.setPage(pageSize, pageNumber);
  445. Rows rows = querySQL.query();
  446. ArrayList<Long> ids = rows.toArrayList("sa_serviceorderid", new ArrayList<>());
  447. HashMap<Long, ArrayList<String>> tagRows = DataTag.queryTag(this, "sa_serviceorder", ids, true);
  448. for (Row row : rows) {
  449. if (tagRows.get(row.getLong("sa_serviceorderid")) != null) {
  450. row.put("tag", tagRows.get(row.getLong("sa_serviceorderid")));
  451. } else {
  452. row.put("tag", new ArrayList<String>());
  453. }
  454. }
  455. return getSucReturnObject().setData(rows).toString();
  456. }
  457. @API(title = "服务申请单状态统计", apiversion = R.ID2025111809442603.v1.class)
  458. public String queryserviceorderStatusList() throws YosException {
  459. SQLFactory sqlFactory2 = new SQLFactory(this, "服务申请单状态统计");
  460. sqlFactory2.addParameter("siteid", siteid);
  461. sqlFactory2.addParameter_SQL("where", " 1=1 ");
  462. Rows rows_total = dbConnect.runSqlQuery(sqlFactory2.getSQL());
  463. return getSucReturnObject().setData(rows_total).toString();
  464. }
  465. @API(title = "查询服务申请单列表(不验证token)", apiversion = R.ID20230217100703.v1.class, accesstoken = false)
  466. public String queryserviceorderListWithoutToken() throws YosException {
  467. StringBuffer where = new StringBuffer(" 1=1 ");
  468. boolean isadmin = content.getBooleanValue("isadmin");
  469. if (!isadmin) {
  470. if (usertype == 1) {
  471. ArrayList<Long> sa_saleareaidsList = new ArrayList<>();
  472. sa_saleareaidsList.addAll(userInfo.getSaleAreaIds());
  473. sa_saleareaidsList.addAll(SaleArea.getSubSaleAreaIds(this, userInfo.getSaleAreaIds()));
  474. String where2 = " and t1.sys_enterpriseid in (select sys_enterpriseid from sys_enterprise_tradefield where siteid='" + siteid + "' and sa_saleareaid in " + sa_saleareaidsList + ")";
  475. where2 = where2.replace("[", "(").replace("]", ")");
  476. where.append(where2);
  477. } else if (usertype == 21 || usertype == 22) {
  478. where.append(" and t1.sys_enterpriseid=" + sys_enterpriseid + " ");
  479. }
  480. }
  481. if (content.containsKey("where")) {
  482. JSONObject whereObject = content.getJSONObject("where");
  483. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  484. where.append(" and(");
  485. where.append("t1.billno like'%").append(whereObject.getString("condition")).append("%' ");
  486. where.append("or t3.sonum like'%").append(whereObject.getString("condition")).append("%' ");
  487. where.append("or t2.enterprisename like'%").append(whereObject.getString("condition")).append("%' ");
  488. where.append("or t1.reason like'%").append(whereObject.getString("condition")).append("%' ");
  489. where.append(")");
  490. }
  491. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  492. where.append(" and t1.status ='").append(whereObject.getString("status")).append("' ");
  493. }
  494. if (whereObject.containsKey("begindate") && !"".equals(whereObject.getString("begindate"))) {
  495. where.append(" and t1.submitdate >='").append(whereObject.getString("begindate")).append("'");
  496. }
  497. if (whereObject.containsKey("enddate") && !"".equals(whereObject.getString("enddate"))) {
  498. where.append(" and t1.submitdate <='").append(whereObject.getString("enddate")).append("'");
  499. }
  500. if (whereObject.containsKey("phonenumber") && !"".equals(whereObject.getString("phonenumber"))) {
  501. where.append(" and t1.scenecontactphonenumber ='").append(whereObject.getString("phonenumber")).append("'");
  502. }
  503. }
  504. SQLFactory sqlFactory = new SQLFactory(this, "服务申请单列表查询2");
  505. //sqlFactory.addParameter("siteid", siteid);
  506. sqlFactory.addParameter_SQL("where", where);
  507. // Rows rows = dbConnect.runSqlQuery(sqlFactory);
  508. QuerySQL querySQL = SQLFactory.createQuerySQL(this, "sys_site_parameter", "sys_site_parameterid");
  509. querySQL.setTableAlias("t0");
  510. querySQL.addJoinTable(JOINTYPE.right, sqlFactory, "t1", "t0.siteid='111'", "*");
  511. querySQL.setPage(pageSize, pageNumber);
  512. Rows rows = querySQL.query();
  513. return getSucReturnObject().setData(rows).toString();
  514. }
  515. @API(title = "工单模板查询", apiversion = R.ID20230206155803.v1.class)
  516. @CACHEING
  517. public String queryworkerordertemplate() throws YosException {
  518. Rows rows = dbConnect.runSqlQuery(
  519. "select sa_workorder_templateid,name,type from sa_workorder_template where siteid='" + siteid + "' and isused=1");
  520. return getSucReturnObject().setData(rows).toString();
  521. }
  522. @API(title = "服务申请单转工单", apiversion = R.ID20230207091003.v1.class)
  523. @CACHEING_CLEAN(apiversions = {R.ID20230206091603.v1.class, R.ID20230206091703.v1.class, R.ID20230206101303.v1.class, R.ID20230208140103.v1.class, R.ID20230208140203.v1.class,
  524. R.ID20230209091103.v1.class, R.ID20230207154203.v1.class, R.ID20230217100703.v1.class, R.ID20230217133003.v1.class})
  525. public String serviceorderToWorkorder() throws YosException {
  526. Long sa_serviceorderid = content.getLong("sa_serviceorderid");
  527. String type = content.getString("type");
  528. JSONArray projectlearders = content.getJSONArray("projectlearders");
  529. Long sa_workorder_templateid = content.getLongValue("sa_workorder_templateid");
  530. Rows rows = dbConnect
  531. .runSqlQuery("select * from sa_serviceorder where sa_serviceorderid ='"
  532. + sa_serviceorderid + "' and siteid='" + siteid + "'");
  533. Rows workorderRows = dbConnect
  534. .runSqlQuery("select sa_workorderid,status,billno from sa_workorder where sa_serviceorderid ='"
  535. + sa_serviceorderid + "' and siteid='" + siteid + "'");
  536. if (rows.isEmpty()) {
  537. return getErrReturnObject().setErrMsg("此服务单不存在").toString();
  538. } else {
  539. if (!rows.get(0).getString("status").equals("待受理")) {
  540. return getErrReturnObject().setErrMsg("非待受理状态无法生成工单").toString();
  541. }
  542. }
  543. if (!workorderRows.isEmpty()) {
  544. for (Row row : workorderRows) {
  545. if (row.getString("type").equals(type) && !row.getString("status").equals("作废")) {
  546. return getErrReturnObject().setErrMsg("已存在" + type + "类型的工单,无法继续生成此类型的工单").toString();
  547. }
  548. }
  549. }
  550. ArrayList<String> sqlList = new ArrayList<>();
  551. long sa_workorderid = createTableID("sa_workorder");
  552. SQLFactory sqlFactory = new SQLFactory(this, "服务工单新增");
  553. String billno = createBillCode("workorder");
  554. sqlFactory.addParameter("siteid", siteid);
  555. sqlFactory.addParameter("type", type);
  556. sqlFactory.addParameter("sa_serviceorderid", sa_serviceorderid);
  557. sqlFactory.addParameter("billno", billno);
  558. sqlFactory.addParameter("sys_enterpriseid", rows.get(0).getString("sys_enterpriseid"));
  559. sqlFactory.addParameter("sa_workorderid", sa_workorderid);
  560. sqlFactory.addParameter("reason", rows.get(0).getString("reason"));
  561. sqlFactory.addParameter("address", rows.get(0).getString("address"));
  562. sqlFactory.addParameter("isouritem", 1);
  563. sqlFactory.addParameter("startdate", StringUtils.isBlank(rows.get(0).getString("begdate")) ? (StringUtils.isBlank(rows.get(0).getString("billdate")) ? "NULL" : rows.get(0).getString("billdate")) : rows.get(0).getString("begdate"));
  564. sqlFactory.addParameter("scenecontact", rows.get(0).getString("scenecontact"));
  565. sqlFactory.addParameter("scenecontactrole", rows.get(0).getString("scenecontactrole"));
  566. sqlFactory.addParameter("scenecontactphonenumber", rows.get(0).getString("scenecontactphonenumber"));
  567. sqlFactory.addParameter("remarks", rows.get(0).getString("remarks"));
  568. sqlFactory.addParameter("status", "待接单");
  569. sqlFactory.addParameter("userid", userid);
  570. sqlFactory.addParameter("username", username);
  571. sqlFactory.addParameter("sa_workorder_templateid", sa_workorder_templateid);
  572. SQLFactory factory = new SQLFactory(this, "查询订单收货日期");
  573. factory.addParameter("sa_orderid", rows.get(0).getLong("sa_orderid"));
  574. factory.addParameter("siteid", siteid);
  575. Rows rowsreceive = dbConnect.runSqlQuery(factory.getSQL());
  576. if (!rowsreceive.isEmpty()) {
  577. //System.out.println(888);
  578. Date receivedate = rowsreceive.get(0).getDate("receivedate");
  579. Calendar calendar = Calendar.getInstance();
  580. calendar.add(Calendar.YEAR, -2);
  581. Date date = calendar.getTime();
  582. if (date.before(receivedate)) {
  583. sqlFactory.addParameter("inqualityguaranteeperiod", 1);
  584. } else {
  585. sqlFactory.addParameter("inqualityguaranteeperiod", 0);
  586. }
  587. } else {
  588. sqlFactory.addParameter("inqualityguaranteeperiod", 0);
  589. }
  590. sqlList.add("delete from sa_workorder_node where sa_workorderid=" + sa_workorderid);
  591. sqlList.addAll(getAddWorkorderNodeSql(sa_workorder_templateid, sa_workorderid));
  592. sqlList.add(sqlFactory.getSQL());
  593. sqlList.add("update sa_serviceorder set status='待服务' where sa_serviceorderid=" + sa_serviceorderid);
  594. if (projectlearders != null && !projectlearders.isEmpty()) {
  595. sqlList.add("delete from sys_datateam where ownertable='sa_workorder' and ownerid="
  596. + sa_workorderid + " and siteid='" + siteid + "'");
  597. for (Object obj : projectlearders) {
  598. sqlList.addAll(DataTeam.createTeamSQL(this, "sa_workorder", sa_workorderid, (int) obj));
  599. }
  600. }
  601. dbConnect.runSqlUpdate(sqlList);
  602. //发送短信
  603. Rows serviceorderRows = dbConnect.runSqlQuery("select t2.enterprisename,t1.billno,t1.submitby,t1.remarks from sa_serviceorder t1 left join sys_enterprise t2 on t1.sys_enterpriseid=t2.sys_enterpriseid and t1.siteid=t2.siteid where t1.sa_serviceorderid ='" + sa_serviceorderid + "' and t1.siteid='" + siteid + "'");
  604. for (Object obj : projectlearders) {
  605. int projectlearder = (int) obj;
  606. Rows workersRows = dbConnect.runSqlQuery("select t3.phonenumber from sys_hr t1 left join sys_users t3 on t1.userid = t3.userid left join sys_hr t4 on t1.siteid = t4.siteid and t1.reporthrid = t4.hrid where t1.siteid = '" + siteid + "' and t1.isworker=1 and t1.userid=" + projectlearder);
  607. if (!workersRows.isEmpty()) {
  608. if (StringUtils.isNotBlank(workersRows.get(0).getString("phonenumber"))) {
  609. Sms sms = new Sms();
  610. sms.sendout(Sms.SmsType.Notice, siteid, workersRows.get(0).getString("phonenumber"), "工单号:" + billno + "已指派请处理,客户名称:" + (StringUtils.isBlank(serviceorderRows.get(0).getString("enterprisename")) ? "" : serviceorderRows.get(0).getString("enterprisename"))
  611. + ",提交人:" + serviceorderRows.get(0).getString("submitby") + ",备注:" + serviceorderRows.get(0).getString("remarks"));
  612. }
  613. }
  614. }
  615. return getSucReturnObject().setData(sa_workorderid).toString();
  616. }
  617. @API(title = "重新指派工单", apiversion = R.ID2025101710510903.v1.class)
  618. @CACHEING_CLEAN(apiversions = {serviceorder.class, workorder.class,restcontroller.sale.serviceorder.serviceorder.class})
  619. public String reAssigningWorkorder() throws YosException {
  620. Long sa_workorderid = content.getLong("sa_workorderid");
  621. JSONArray projectlearders = content.getJSONArray("projectlearders");
  622. boolean ismanage = content.getBooleanValue("ismanage");
  623. ArrayList<String> sqlList = new ArrayList<>();
  624. Rows rows = dbConnect
  625. .runSqlQuery("select status,billno from sa_workorder where sa_workorderid ='"
  626. + sa_workorderid + "' and siteid='" + siteid + "'");
  627. for (Row row : rows) {
  628. if (row.getString("status").equals("已完工")) {
  629. return getErrReturnObject().setErrMsg("单号为:【" + row.getString("billno") + "】的工单为已完工状态,无法重新指派工单")
  630. .toString();
  631. }
  632. }
  633. if(!ismanage){
  634. Rows datateamrows =dbConnect.runSqlQuery("select * from sys_datateam where ownertable='sa_workorder' and ownerid="
  635. + sa_workorderid + " and siteid='" + siteid + "'");
  636. if(datateamrows.isNotEmpty()){
  637. return getErrReturnObject().setErrMsg("该任务已由其他同事负责推进").toString();
  638. }
  639. }
  640. if(rows.get(0).getString("status").equals("提交")){
  641. sqlList.add("update sa_workorder set status='进行中' where sa_workorderid ='"
  642. + sa_workorderid + "' and siteid='" + siteid + "'");
  643. }else{
  644. sqlList.add("update sa_workorder set status='待接单' where sa_workorderid ='"
  645. + sa_workorderid + "' and siteid='" + siteid + "'");
  646. }
  647. sqlList.add("delete from sys_datateam where ownertable='sa_workorder' and ownerid="
  648. + sa_workorderid + " and siteid='" + siteid + "'");
  649. if (projectlearders != null && !projectlearders.isEmpty()) {
  650. for (Object obj : projectlearders) {
  651. sqlList.addAll(DataTeam.createTeamSQL(this, "sa_workorder", sa_workorderid, (int) obj));
  652. }
  653. }
  654. dbConnect.runSqlUpdate(sqlList);
  655. return getSucReturnObject().toString();
  656. }
  657. @API(title = "删除", apiversion = R.ID20230206091803.v1.class)
  658. @CACHEING_CLEAN(apiversions = {R.ID20230206091603.v1.class, R.ID20230206091703.v1.class, R.ID20230206101303.v1.class, R.ID20230217100703.v1.class, R.ID20230217133003.v1.class})
  659. public String delete() throws YosException {
  660. JSONArray sa_serviceorderids = content.getJSONArray("sa_serviceorderids");
  661. BatchDeleteErr batchDeleteErr = BatchDeleteErr.create(this, sa_serviceorderids.size());
  662. for (Object o : sa_serviceorderids) {
  663. long sa_serviceorderid = Long.parseLong(o.toString());
  664. Rows RowsStatus = dbConnect
  665. .runSqlQuery("select sa_serviceorderid,status from sa_serviceorder where siteid='" + siteid
  666. + "' and sa_serviceorderid='" + sa_serviceorderid + "'");
  667. if (RowsStatus.isNotEmpty()) {
  668. if (!RowsStatus.get(0).getString("status").equals("新建")) {
  669. //batchDeleteErr.addErr(sa_serviceorderid, "非新建状态的服务申请单无法删除");
  670. continue;
  671. }
  672. }
  673. dbConnect.runSqlUpdate("delete from sa_serviceorder where siteid='" + siteid + "' and sa_serviceorderid="
  674. + sa_serviceorderid);
  675. }
  676. return batchDeleteErr.getReturnObject().toString();
  677. }
  678. @API(title = "发送手机验证码", apiversion = R.ID20230215173103.v1.class, accesstoken = false)
  679. public String sendMessage() throws YosException {
  680. String customerphone = "";
  681. long sa_workorderid=content.getLong("sa_workorderid");
  682. Rows rows = dbConnect.runSqlQuery("select t1.type,t2.* from sa_workorder t1 inner join sa_serviceorder t2 on t1.sa_serviceorderid=t2.sa_serviceorderid and t1.siteid=t2.siteid where t1.sa_workorderid="+sa_workorderid);
  683. if(rows.isEmpty()){
  684. return getErrReturnObject().setErrMsg("该工单不存在").toString();
  685. }
  686. long createuserid = rows.get(0).getLong("createuserid");
  687. String type=rows.get(0).getString("type");
  688. Rows userrows =dbConnect.runSqlQuery("select t2.usertype,t1.phonenumber from sys_users t1 inner join sys_usersite t2 on t1.userid = t2.userid where t2.siteid = '"+siteid+"' and t1.userid="+createuserid);
  689. long usertype = 0;
  690. if(userrows.isNotEmpty()){
  691. usertype=userrows.get(0).getLong("usertype");
  692. }else{
  693. //return getErrReturnObject().setErrMsg("工单创建人信息有误").toString();
  694. }
  695. if(usertype==99){
  696. customerphone=userrows.get(0).getString("phonenumber");
  697. }else{
  698. if(type.equals("安装")){
  699. customerphone=rows.get(0).getString("scenecontactphonenumber");
  700. }
  701. }
  702. if (!Pattern.matches("^1([358][0-9]|4[579]|66|7[0135678]|9[89])[0-9]{8}$", customerphone)) {
  703. return getErrReturnObject().setErrMsg("手机格式有误").toString();
  704. }
  705. String verificationCode = createVerificationCode();
  706. dbConnect.runSqlUpdate("update sa_workorder set verificationcode='"+verificationCode+"' where sa_workorderid="+sa_workorderid);
  707. Rows wxserviceRows = dbConnect.runSqlQuery("select t2.userid from sys_wechatapp_openids t1 inner join sys_users t2 on t1.userid=t2.userid where t2.phonenumber='"+customerphone+"'");
  708. Row row = new Row();
  709. if(wxserviceRows.isEmpty()){
  710. ArrayList<Long> userids = wxserviceRows.toArrayList("userid",new ArrayList<>());
  711. JSONObject extradata = new JSONObject();
  712. extradata.put("extraUserList", userids);
  713. Executor.sendEml(this, "verificationcode_push", sa_workorderid,siteid, extradata);
  714. if (!BaseClass.isdebug() && !Arrays.asList(Parameter.getString("system_invalidate_phonenumber").split(",")).contains(customerphone)) {
  715. row.put("code", 1);
  716. row.put("msg", "验证码已发送,请注意查收!");
  717. }
  718. }else {
  719. if(StringUtils.isNotBlank("customerphone")){
  720. Sms sms = new Sms();
  721. sms.sendout(Sms.SmsType.PassWord,customerphone, Parameter.getString("chuanglan_sms_model_password"), new String[]{verificationCode});
  722. message_map.put(customerphone, new VerificationManage(verificationCode));
  723. }
  724. if (!BaseClass.isdebug() && !Arrays.asList(Parameter.getString("system_invalidate_phonenumber").split(",")).contains(customerphone)) {
  725. row.put("code", 1);
  726. row.put("msg", "手机验证码已发送,请注意查收!");
  727. }else{
  728. row.put("code", 1);
  729. row.put("msg", "手机验证码为:"+verificationCode);
  730. }
  731. }
  732. return getSucReturnObject().setData(row).toString();
  733. }
  734. /**
  735. * 验证码校验
  736. **/
  737. @API(title = "发送手机验证码", apiversion = R.ID20230215173203.v1.class, accesstoken = false)
  738. public String checkVerificationCode() throws YosException {
  739. String customerphone = "";
  740. long sa_workorderid=content.getLong("sa_workorderid");
  741. Rows rows = dbConnect.runSqlQuery("select t1.type,t2.* from sa_workorder t1 inner join sa_serviceorder t2 on t1.sa_serviceorderid=t2.sa_serviceorderid and t1.siteid=t2.siteid where t1.sa_workorderid="+sa_workorderid);
  742. if(rows.isEmpty()){
  743. return getErrReturnObject().setErrMsg("该工单不存在").toString();
  744. }
  745. long createuserid = rows.get(0).getLong("createuserid");
  746. String type=rows.get(0).getString("type");
  747. Rows userrows =dbConnect.runSqlQuery("select t2.usertype,t1.phonenumber from sys_users t1 inner join sys_usersite t2 on t1.userid = t2.userid where t2.siteid = '"+siteid+"' and t1.userid="+createuserid);
  748. long usertype = 0;
  749. if(userrows.isNotEmpty()){
  750. usertype=userrows.get(0).getLong("usertype");
  751. }else{
  752. //return getErrReturnObject().setErrMsg("工单创建人信息有误").toString();
  753. }
  754. if(usertype==99){
  755. customerphone=userrows.get(0).getString("phonenumber");
  756. }else{
  757. if(type.equals("安装")){
  758. customerphone=rows.get(0).getString("scenecontactphonenumber");
  759. }
  760. }
  761. String code = content.getStringValue("code");
  762. if (!message_map.containsKey(customerphone) || !message_map.get(customerphone).check(code)) {
  763. return getErrReturnObject().setErrMsg("验证码错误或者过期").toString();
  764. }
  765. return getSucReturnObject().toString();
  766. }
  767. private ArrayList<String> getAddWorkorderNodeSql(long sa_workorder_templateid, long sa_workorderid)
  768. throws YosException {
  769. ArrayList sqList = new ArrayList<String>();
  770. Rows rows = dbConnect.runSqlQuery(
  771. "select t1.sa_workorder_template_worksid,t1.sequence,t1.parentid,t2.* from sa_workorder_template_works t1 inner join sa_workpreset t2 on t1.siteid=t2.siteid and t1.sa_workpresetid=t2.sa_workpresetid where t1.siteid='"
  772. + siteid + "' and t1.sa_workorder_templateid =" + sa_workorder_templateid + " order by t1.sequence asc");
  773. RowsMap rowsMap = rows.toRowsMap("parentid");
  774. if (!rowsMap.get(0).isEmpty()) {
  775. for (Row row : rowsMap.get(0)) {
  776. workpresetInfo workpresetInfo = new workpresetInfo();
  777. workpresetInfo.setWorkname(row.getString("workname"));
  778. workpresetInfo.setRemarks(row.getString("remarks"));
  779. workpresetInfo.setAdditem(row.getLong("additem"));
  780. workpresetInfo.setAddperson(row.getLong("addperson"));
  781. workpresetInfo.setAmountpay(row.getLong("amountpay"));
  782. workpresetInfo.setConfirm(row.getLong("confirm"));
  783. workpresetInfo.setConfirm_options(JSONArray.parseArray(row.getString("confirm_options")));
  784. workpresetInfo.setContractupload(row.getLong("contractupload"));
  785. workpresetInfo.setFileupload(row.getLong("fileupload"));
  786. workpresetInfo.setItemtype(row.getString("itemtype"));
  787. workpresetInfo.setRequired(row.getLong("required"));
  788. workpresetInfo.setTextedit(row.getLong("textedit"));
  789. workpresetInfo.setSignature(row.getLong("signature"));
  790. workpresetInfo.setPasscheck(row.getLong("passcheck"));
  791. workpresetInfo.setQuestionedit(row.getLong("questionedit"));
  792. workpresetInfo.setQuestionoption(row.getString("questionoption"));
  793. String workpresetjson = JSONObject.toJSONString(workpresetInfo);
  794. SQLFactory sqlFactory = new SQLFactory(this, "服务工单流程节点新增");
  795. long sa_workorder_nodeid = createTableID("sa_workorder_node");
  796. sqlFactory.addParameter("sa_workorder_nodeid", sa_workorder_nodeid);
  797. sqlFactory.addParameter("sa_workorderid", sa_workorderid);
  798. sqlFactory.addParameter("siteid", siteid);
  799. sqlFactory.addParameter("parentid", 0);
  800. sqlFactory.addParameter("workpresetjson", workpresetjson);
  801. sqlFactory.addParameter("sequence", row.getLong("sequence"));
  802. sqlFactory.addParameter("userid", userid);
  803. sqlFactory.addParameter("username", username);
  804. sqList.add(sqlFactory.getSQL());
  805. if (!rowsMap.get(row.getLong("sa_workorder_template_worksid")).isEmpty()) {
  806. for (Row row2 : rowsMap.get(row.getLong("sa_workorder_template_worksid"))) {
  807. workpresetInfo workpresetInfo1 = new workpresetInfo();
  808. workpresetInfo1.setWorkname(row2.getString("workname"));
  809. workpresetInfo1.setRemarks(row2.getString("remarks"));
  810. workpresetInfo1.setAdditem(row2.getLong("additem"));
  811. workpresetInfo1.setAddperson(row2.getLong("addperson"));
  812. workpresetInfo1.setAmountpay(row2.getLong("amountpay"));
  813. workpresetInfo1.setConfirm(row2.getLong("confirm"));
  814. workpresetInfo1.setConfirm_options(JSONArray.parseArray(row2.getString("confirm_options")));
  815. workpresetInfo1.setContractupload(row2.getLong("contractupload"));
  816. workpresetInfo1.setFileupload(row2.getLong("fileupload"));
  817. workpresetInfo1.setItemtype(row2.getString("itemtype"));
  818. workpresetInfo1.setRequired(row2.getLong("required"));
  819. workpresetInfo1.setTextedit(row2.getLong("textedit"));
  820. workpresetInfo1.setSignature(row2.getLong("signature"));
  821. workpresetInfo1.setPasscheck(row.getLong("passcheck"));
  822. workpresetInfo1.setQuestionedit(row.getLong("questionedit"));
  823. workpresetInfo1.setQuestionoption(row.getString("questionoption"));
  824. String workpresetjson1 = JSONObject.toJSONString(workpresetInfo1);
  825. SQLFactory sqlFactory1 = new SQLFactory(this, "服务工单流程节点新增");
  826. sqlFactory1.addParameter("sa_workorder_nodeid", createTableID("sa_workorder_node"));
  827. sqlFactory1.addParameter("sa_workorderid", sa_workorderid);
  828. sqlFactory1.addParameter("siteid", siteid);
  829. sqlFactory1.addParameter("parentid", sa_workorder_nodeid);
  830. sqlFactory1.addParameter("workpresetjson", workpresetjson1);
  831. sqlFactory1.addParameter("sequence", row2.getLong("sequence"));
  832. sqlFactory1.addParameter("userid", userid);
  833. sqlFactory1.addParameter("username", username);
  834. sqList.add(sqlFactory1.getSQL());
  835. }
  836. }
  837. }
  838. }
  839. return sqList;
  840. }
  841. // private String sendMessage_0(String phone, String verificationCode) throws Exception {
  842. // HttpURLRest rest = new HttpURLRest("http://smssh1.253.com/msg/v1/send/json");
  843. // rest.addHeader("Content-type", "applica分配tion/json");
  844. // JSONObject jsonObject = new JSONObject();
  845. // jsonObject.put("account", "N3147701");
  846. // jsonObject.put("password", "4ClGyab6fv6a87");
  847. // jsonObject.put("msg", "【浙江美大】您好,您的验证码是" + verificationCode);
  848. // jsonObject.put("phone", phone);
  849. // rest.addRawBody(jsonObject.toString());
  850. // String s = rest.post();
  851. //// PaoSetRemote verCodehistory = getpaoset("VerCodehistory");
  852. //// PaoRemote remote = verCodehistory.addAtEnd();
  853. //// remote.setValue("phone",phone);
  854. //// remote.setValue("msg","【Banninger】您好,您的验证码是"+verificationCode);
  855. //// remote.setValue("content",s);
  856. //// verCodehistory.save();
  857. // return s;
  858. // }
  859. public static String createVerificationCode() {
  860. String s = "";
  861. while (s.length() < 6)
  862. s += (int) (Math.random() * 10);
  863. return s;
  864. }
  865. }