personnel.java 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668
  1. package restcontroller.webmanage.sale.salestarget;
  2. import beans.datacontrllog.DataContrlLog;
  3. import com.alibaba.fastjson.JSONArray;
  4. import com.alibaba.fastjson.JSONObject;
  5. import common.Controller;
  6. import common.YosException;
  7. import common.annotation.API;
  8. import common.annotation.CACHEING;
  9. import common.annotation.CACHEING_CLEAN;
  10. import common.annotation.cm;
  11. import common.data.*;
  12. import org.apache.commons.lang.StringUtils;
  13. import org.apache.poi.xssf.usermodel.*;
  14. import restcontroller.R;
  15. import restcontroller.webmanage.saletool.orderclue.ExportExcel;
  16. import java.util.ArrayList;
  17. import java.util.HashMap;
  18. @API(title = "管理端-销售目标-人员目标")
  19. public class personnel extends Controller {
  20. /**
  21. * 构造函数
  22. * @param content
  23. */
  24. public personnel(JSONObject content) throws YosException {
  25. super(content);
  26. }
  27. @API(title = "新建年度或添加人员", apiversion = R.ID20220831165302.v1.class)
  28. @CACHEING_CLEAN(cms = {@cm(clazz = personnel.class, method = {"queryList", "queryDetailList"}), @cm(clazz = personnelstatistics.class, method = {"queryList"})})
  29. public String insert() throws YosException {
  30. Long year = content.getLong("year");
  31. String assessmentindicators=content.getString("assessmentindicators");
  32. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  33. String statisticaldimension=content.getStringValue("statisticaldimension");
  34. String sa_accountclassids=content.getStringValue("sa_accountclassids");
  35. JSONArray salesArray = content.getJSONArray("sales");
  36. ArrayList<String> sqlList = new ArrayList<>();
  37. if (sa_salestargetbillid <= 0) {
  38. //查询创建年度是否存在
  39. if (dbConnect.runSqlQuery("SELECT 1 FROM sa_salestargetbill WHERE year = " + year + " AND targettype ='人员目标' AND siteid = '" + siteid + "'").isNotEmpty()) {
  40. return getErrReturnObject().setErrMsg(year + "年度目标已存在,无法创建").toString();
  41. }
  42. sa_salestargetbillid = createTableID("sa_salestargetbill");
  43. SQLFactory sqlFactory = new SQLFactory(this, "创建新年度");
  44. sqlFactory.addParameter("siteid", siteid);
  45. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  46. sqlFactory.addParameter("username", username);
  47. sqlFactory.addParameter("sys_enterpriseid", "null");
  48. sqlFactory.addParameter("userid", userid);
  49. sqlFactory.addParameter("year", year);
  50. sqlFactory.addParameter("assessmentindicators", assessmentindicators);
  51. sqlFactory.addParameter("statisticaldimension", statisticaldimension);
  52. sqlFactory.addParameter("sa_accountclassids", sa_accountclassids);
  53. sqlFactory.addParameter("targettype", "人员目标");
  54. sqlFactory.addParameter("tradefield", "");
  55. sqlList.add(sqlFactory.getSQL());
  56. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "人员目标新增", "人员目标新增"+year ).getSQL());
  57. //获取所有启用业务员
  58. SQLFactory saleareahrsqlFactory = new SQLFactory(this, "通用-人员范围查询");
  59. saleareahrsqlFactory.addParameter("siteid", siteid);
  60. saleareahrsqlFactory.addParameter_SQL("where", " 1=1 ");
  61. saleareahrsqlFactory.addParameter_SQL("isIn", " not in ");
  62. saleareahrsqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  63. String sql = saleareahrsqlFactory.getSQL();
  64. Rows saleareahrrows = dbConnect.runSqlQuery(sql);
  65. salesArray=saleareahrrows.toJsonArray();
  66. }
  67. String[] types = {"年", "季", "月"};
  68. long[] ids = createTableID("sa_salestarget", salesArray.size() * 17);
  69. int index = 1;
  70. for (Object obj : salesArray) {
  71. JSONObject saleObj = (JSONObject) obj;
  72. System.out.println(saleObj.toString());
  73. SQLFactory saleFactory = new SQLFactory(this, "人员范围新增");
  74. saleFactory.addParameter("siteid", siteid);
  75. saleFactory.addParameter("sa_salestargethrid", createTableID("sa_salestargethr"));
  76. saleFactory.addParameter("hrid", saleObj.getLongValue("hrid"));
  77. saleFactory.addParameter("position", saleObj.getStringValue("position"));
  78. saleFactory.addParameter("sa_saleareaid", saleObj.getStringValue("sa_saleareaid"));
  79. saleFactory.addParameter("areaname", saleObj.getStringValue("areaname"));
  80. saleFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  81. saleFactory.addParameter("depname", saleObj.getStringValue("depname"));
  82. saleFactory.addParameter("departmentid", saleObj.getLongValue("departmentid"));
  83. saleFactory.addParameter("name", saleObj.getStringValue("name"));
  84. sqlList.add(saleFactory.getSQL());
  85. for (String type : types) {
  86. int point;
  87. if (type.equals("年")) {
  88. point = 1;
  89. } else if (type.equals("季")) {
  90. point = 4;
  91. } else if (type.equals("月")) {
  92. point = 12;
  93. } else {
  94. point = 0;
  95. }
  96. for (int i = 0; i < point; i++) {
  97. SQLFactory targetFactory = new SQLFactory(this, "人员-目标明细新增");
  98. targetFactory.addParameter("siteid", siteid);
  99. targetFactory.addParameter("sa_salestargetid", ids[index - 1]);
  100. targetFactory.addParameter("type", type);
  101. targetFactory.addParameter("point", i + 1);
  102. targetFactory.addParameter("targettype", "人员目标");
  103. targetFactory.addParameter("sa_saleareaid", saleObj.getString("sa_saleareaid"));
  104. targetFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  105. targetFactory.addParameter("year", year);
  106. targetFactory.addParameter("sa_projectid", "null");
  107. targetFactory.addParameter("createby", username);
  108. targetFactory.addParameter("target_l", 0);
  109. targetFactory.addParameter("target_h", 0);
  110. sqlList.add(targetFactory.getSQL());
  111. index++;
  112. }
  113. }
  114. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "区域编辑", "添加区域" + saleObj.getStringValue("areaname")).getSQL());
  115. }
  116. dbConnect.runSqlUpdate(sqlList);
  117. return getSucReturnObject().toString();
  118. }
  119. @API(title = "删除人员", apiversion = R.ID20220901111202.v1.class)
  120. @CACHEING_CLEAN(cms = {@cm(clazz = personnel.class, method = {"queryList", "queryDetailList"}), @cm(clazz = personnelstatistics.class, method = {"queryList"})})
  121. public String deletePeople() throws YosException {
  122. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  123. JSONArray salesArray = content.getJSONArray("sa_saleareaid");
  124. if (salesArray.size() <= 0) {
  125. return getErrReturnObject().setErrMsg("请选择人员").toString();
  126. }
  127. String sql = "SELECT 1 FROM sa_salestarget WHERE sa_saleareaid in " + salesArray + " and sa_salestargetbillid = " + sa_salestargetbillid + " and targettype = '人员目标' and (target_l >0 or target_h >0)";
  128. sql = sql.replace("[", "(").replace("]", ")");
  129. if (dbConnect.runSqlQuery(sql).isNotEmpty()) {
  130. return getErrReturnObject().setErrMsg("存在已填写的数据,无法删除").toString();
  131. }
  132. ArrayList<String> sqlList = new ArrayList<>();
  133. //删除人员范围
  134. SQLFactory sqlFactory = new SQLFactory(this, "人员-删除人员范围");
  135. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  136. sqlFactory.addParameter("siteid", siteid);
  137. sqlFactory.addParameter_in("sa_saleareaid", salesArray.toArray());
  138. sqlList.add(sqlFactory.getSQL());
  139. //删除人员目标
  140. SQLFactory sqlFactory2 = new SQLFactory(this, "人员-删除目标明细");
  141. sqlFactory2.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  142. sqlFactory2.addParameter("siteid", siteid);
  143. sqlFactory2.addParameter_in("sa_saleareaid", salesArray.toArray());
  144. sqlList.add(sqlFactory2.getSQL());
  145. //操作记录
  146. for (Object obj : salesArray) {
  147. Long sa_saleareaid = Long.valueOf(obj.toString());
  148. String name = "";
  149. Rows rows = dbConnect.runSqlQuery("SELECT areaname from sa_salearea WHERE sa_saleareaid = " + sa_saleareaid);
  150. if (rows.isNotEmpty()) {
  151. name = rows.get(0).getString("areaname");
  152. }
  153. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "人员编辑", "移除人员" + name).getSQL());
  154. }
  155. dbConnect.runSqlUpdate(sqlList);
  156. return getSucReturnObject().toString();
  157. }
  158. @API(title = "年度目标列表", apiversion = R.ID20220901132502.v1.class)
  159. @CACHEING
  160. public String queryList() throws YosException {
  161. /*
  162. 过滤条件设置
  163. */
  164. String targettype =content.getString("targettype");
  165. StringBuffer where = new StringBuffer(" 1=1 ");
  166. if (content.containsKey("where")) {
  167. JSONObject whereObject = content.getJSONObject("where");
  168. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  169. where.append(" and(");
  170. where.append("t1.year like'%").append(whereObject.getString("condition")).append("%' ");
  171. where.append("or t1.createby like'%").append(whereObject.getString("condition")).append("%' ");
  172. where.append(")");
  173. }
  174. if (whereObject.containsKey("status") && !"".equals(whereObject.getString("status"))) {
  175. where.append(" and(");
  176. where.append("t1.status like'%").append(whereObject.getString("status")).append("%' ");
  177. where.append(")");
  178. }
  179. }
  180. SQLFactory sqlFactory = new SQLFactory(this, "年度目标列表", pageSize, pageNumber, pageSorting);
  181. sqlFactory.addParameter("siteid", siteid);
  182. sqlFactory.addParameter_SQL("where", where);
  183. sqlFactory.addParameter("targettype", targettype);
  184. Rows rows = dbConnect.runSqlQuery(sqlFactory);
  185. Rows accountclassrows = dbConnect.runSqlQuery("select sa_accountclassid,accountname from sa_accountclass where siteid='"+siteid+"'");
  186. RowsMap accountclassrowsMap = accountclassrows.toRowsMap("sa_accountclassid");
  187. for (Row row:rows) {
  188. JSONArray jsonArray= new JSONArray();
  189. if(isJSONArray(row.getString("statisticaldimension"))){
  190. row.put("statisticaldimension",JSONArray.parseArray(row.getString("statisticaldimension")));
  191. }
  192. if(isJSONArray(row.getString("sa_accountclassids"))){
  193. JSONArray sa_accountclassids =JSONArray.parseArray(row.getString("sa_accountclassids"));
  194. for (Object object:sa_accountclassids) {
  195. Long sa_accountclassid = Long.valueOf(object.toString());
  196. if(accountclassrowsMap.containsKey(String.valueOf(sa_accountclassid))){
  197. if(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).isNotEmpty()){
  198. jsonArray.add(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).get(0));
  199. }
  200. }
  201. }
  202. row.put("sa_accountclassids",jsonArray);
  203. }
  204. }
  205. return getSucReturnObject().setData(rows).toString();
  206. }
  207. @API(title = "目标详情", apiversion = R.ID20220901140402.v1.class)
  208. public String queryDetail() throws YosException {
  209. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  210. SQLFactory sqlFactory = new SQLFactory(this, "人员-目标详情");
  211. sqlFactory.addParameter("siteid", siteid);
  212. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  213. Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
  214. Rows accountclassrows = dbConnect.runSqlQuery("select sa_accountclassid,accountname from sa_accountclass where siteid='"+siteid+"'");
  215. RowsMap accountclassrowsMap = accountclassrows.toRowsMap("sa_accountclassid");
  216. for (Row row:rows) {
  217. JSONArray jsonArray= new JSONArray();
  218. if(isJSONArray(row.getString("statisticaldimension"))){
  219. row.put("statisticaldimension",JSONArray.parseArray(row.getString("statisticaldimension")));
  220. }
  221. if(isJSONArray(row.getString("sa_accountclassids"))){
  222. JSONArray sa_accountclassids =JSONArray.parseArray(row.getString("sa_accountclassids"));
  223. for (Object object:sa_accountclassids) {
  224. Long sa_accountclassid = Long.valueOf(object.toString());
  225. if(accountclassrowsMap.containsKey(String.valueOf(sa_accountclassid))){
  226. if(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).isNotEmpty()){
  227. jsonArray.add(accountclassrowsMap.get(String.valueOf(sa_accountclassid)).get(0));
  228. }
  229. }
  230. }
  231. row.put("sa_accountclassids",jsonArray);
  232. }
  233. }
  234. return getSucReturnObject().setData(rows.isNotEmpty() ? rows.get(0) : new Rows()).toString();
  235. }
  236. @API(title = "目标编辑", apiversion = R.ID20220902162902.v1.class)
  237. @CACHEING_CLEAN(cms = {@cm(clazz = personnel.class, method = {"queryList", "queryDetailList"}), @cm(clazz = personnelstatistics.class, method = {"queryList"})})
  238. public String edit() throws YosException {
  239. Long sa_salestargetbillid = content.getLongValue("sa_salestargetbillid");
  240. Long sa_saleareaid = content.getLong("sa_saleareaid");
  241. if (sa_salestargetbillid == 0) {
  242. Long year = content.getLongValue("year");
  243. Rows rows = dbConnect.runSqlQuery("SELECT DISTINCT sa_salestargetbillid from sa_salestarget WHERE year = " + year + " and sa_saleareaid=" + sa_saleareaid + " and targettype ='人员目标' and siteid='" + siteid + "'");
  244. if (rows.isNotEmpty()) {
  245. sa_salestargetbillid = rows.get(0).getLong("sa_salestargetbillid");
  246. }
  247. }
  248. if (sa_salestargetbillid == 0) {
  249. return getErrReturnObject().setErrMsg("年度目标不存在或该人员不在年度目标中,请先创建年度目标或添加相关人员到年度目标中").toString();
  250. }
  251. ArrayList<String> sqlList = new ArrayList<>();
  252. String key_l = "y1l";
  253. String key_h = "y1h";
  254. if (content.containsKey(key_l) && content.containsKey(key_h)) {
  255. sqlList.add(getSql(content.getString(key_l), content.getString(key_h), sa_salestargetbillid, sa_saleareaid, "年", 1));
  256. }
  257. for (int i = 1; i < 5; i++) {
  258. key_l = "s" + i + "l";
  259. key_h = "s" + i + "h";
  260. if (content.containsKey(key_l) && content.containsKey(key_h)) {
  261. sqlList.add(getSql(content.getString(key_l), content.getString(key_h), sa_salestargetbillid, sa_saleareaid, "季", i));
  262. }
  263. }
  264. for (int i = 1; i < 13; i++) {
  265. key_l = "m" + i + "l";
  266. key_h = "m" + i + "h";
  267. if (content.containsKey(key_l) && content.containsKey(key_h)) {
  268. sqlList.add(getSql(content.getString(key_l), content.getString(key_h), sa_salestargetbillid, sa_saleareaid, "月", i));
  269. }
  270. }
  271. sqlList.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "编辑人员目标", "编辑人员目标").getSQL());
  272. dbConnect.runSqlUpdate(sqlList);
  273. return getSucReturnObject().toString();
  274. }
  275. public String getSql(String target_l, String target_h, Long id, Long sa_saleareaid, String type, int point) {
  276. return " UPDATE sa_salestarget SET target_l=" + target_l + ",target_h = " + target_h + " WHERE sa_salestargetbillid =" + id + " and sa_saleareaid =" + sa_saleareaid + " and type ='" + type + "' AND point = " + point;
  277. }
  278. @API(title = "目标详情列表", apiversion = R.ID20220901141802.v1.class)
  279. @CACHEING
  280. public String queryDetailList() throws YosException {
  281. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  282. /*
  283. 过滤条件设置
  284. */
  285. StringBuffer where = new StringBuffer(" 1=1 ");
  286. if (content.containsKey("where")) {
  287. JSONObject whereObject = content.getJSONObject("where");
  288. if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
  289. where.append(" and(");
  290. where.append("t.name like'%").append(whereObject.getString("condition")).append("%' ");
  291. where.append("or t.depfullname like'%").append(whereObject.getString("condition")).append("%' ");
  292. where.append("or t.depname like'%").append(whereObject.getString("condition")).append("%' ");
  293. where.append("or t.position like'%").append(whereObject.getString("condition")).append("%' ");
  294. where.append(")");
  295. }
  296. }
  297. SQLFactory sqlFactory = new SQLFactory(this, "人员-目标详情列表");
  298. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  299. sqlFactory.addParameter_SQL("where", where);
  300. sqlFactory.addParameter("siteid", siteid);
  301. String sql = sqlFactory.getSQL();
  302. Rows rows = dbConnect.runSqlQuery(sql);
  303. Rows saleareas = dbConnect.runSqlQuery("select * from sa_salearea where parentid=0");
  304. Long sa_saleareaid=0l;
  305. if(!saleareas.isEmpty() && saleareas.size()==1){
  306. sa_saleareaid=saleareas.get(0).getLong("sa_saleareaid");
  307. for (Row row :rows) {
  308. if(row.getLong("parentid")==0 ){
  309. row.put("y1l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("y1l"));
  310. row.put("y1h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("y1h"));
  311. row.put("s1l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s1l"));
  312. row.put("s1h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s1h"));
  313. row.put("s2l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s2l"));
  314. row.put("s2h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s2h"));
  315. row.put("s3l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s3l"));
  316. row.put("s3h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s3h"));
  317. row.put("s4l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s4l"));
  318. row.put("s4h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("s4h"));
  319. row.put("m1l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m1l"));
  320. row.put("m1h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m1h"));
  321. row.put("m2l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m2l"));
  322. row.put("m2h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m2h"));
  323. row.put("m3l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m3l"));
  324. row.put("m3h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m3h"));
  325. row.put("m4l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m4l"));
  326. row.put("m4h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m4h"));
  327. row.put("m5l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m5l"));
  328. row.put("m5h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m5h"));
  329. row.put("m6l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m6l"));
  330. row.put("m6h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m6h"));
  331. row.put("m7l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m7l"));
  332. row.put("m7h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m7h"));
  333. row.put("m8l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m8l"));
  334. row.put("m8h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m8h"));
  335. row.put("m9l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m9l"));
  336. row.put("m9h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m9h"));
  337. row.put("m10l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m10l"));
  338. row.put("m10h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m10h"));
  339. row.put("m11l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m11l"));
  340. row.put("m11h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m11h"));
  341. row.put("m12l",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m12l"));
  342. row.put("m12h",rows.toRowsMap("parentid").get(sa_saleareaid.toString()).sum("m12h"));
  343. }
  344. }
  345. }
  346. return getSucReturnObject().setData(rows).toString();
  347. }
  348. @API(title = "人员目标导入模板", apiversion = R.ID20220913093102.v1.class)
  349. public String downloadExcel() throws YosException {
  350. ExcelFactory excelFactory = new ExcelFactory("人员目标导入模板");
  351. XSSFSheet sheet = excelFactory.getXssfWorkbook().createSheet("Sheet1");
  352. XSSFWorkbook xssfFWorkbook = excelFactory.getXssfWorkbook();
  353. personnelexcel.setBatchDetailSheetColumn1(sheet);// 设置工作薄列宽
  354. XSSFCellStyle titleCellStyle1 = ExportExcel.createTitleCellStyle1(xssfFWorkbook);
  355. XSSFCellStyle titleCellStyle2 = ExportExcel.createTitleCellStyle2(xssfFWorkbook);
  356. XSSFCellStyle titleCellStyle3 = ExportExcel.createBodyCellStyle(xssfFWorkbook);
  357. personnelexcel.batchDetail(sheet, titleCellStyle1, titleCellStyle2, titleCellStyle3, xssfFWorkbook);// 写入标题
  358. Rows aa = uploadExcelToObs(excelFactory);
  359. String url = "";
  360. if (!aa.isEmpty()) {
  361. url = aa.get(0).getString("url");
  362. }
  363. return getSucReturnObject().setData(url).toString();
  364. }
  365. @API(title = "人员目标导入", apiversion = R.ID20220913092702.v1.class)
  366. @CACHEING_CLEAN(apiversions = {R.ID20220901141802.class})
  367. public String personnelTargetImport() throws YosException {
  368. Long sa_salestargetbillid = content.getLong("sa_salestargetbillid");
  369. Long year = content.getLong("year");
  370. ExcelFactory e;
  371. try {
  372. if (content.getLong("attachmentid") > 0) {
  373. e = getPostExcelFactory(content.getLong("attachmentid"));
  374. // 本地
  375. //e = getPostExcelFactory();
  376. } else {
  377. e = getPostExcelFactory();
  378. // 本地
  379. //e = getPostExcelFactory();
  380. }
  381. ArrayList<String> keys = new ArrayList<>();
  382. ArrayList<String> sqllist = new ArrayList<>();
  383. keys.add("name");
  384. String keyl = "y1l";
  385. keys.add(keyl);
  386. for (int i = 1; i < 5; i++) {
  387. keyl = "s" + i + "l";
  388. keys.add(keyl);
  389. }
  390. for (int i = 1; i < 13; i++) {
  391. keyl = "m" + i + "l";
  392. keys.add(keyl);
  393. }
  394. Rows rows = e.getSheetRows(0, keys, 2);
  395. ArrayList<String> areanameList = new ArrayList<>();
  396. for (Row row : rows) {
  397. areanameList.add(row.getString("name"));
  398. }
  399. //查询可导入的用户信息
  400. SQLFactory sqlFactory = new SQLFactory(this, "人员-查询可导入区域信息");
  401. sqlFactory.addParameter("siteid", siteid);
  402. sqlFactory.addParameter_in("areaname", areanameList);
  403. sqlFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  404. String sql = sqlFactory.getSQL();
  405. RowsMap areaRowsMap = dbConnect.runSqlQuery(sql).toRowsMap("areaname");
  406. boolean iserr = false;
  407. Rows rowserr = new Rows();
  408. Rows rowssuc = new Rows();
  409. // 手机号码的格式:第一位只能为1,第二位可以是3,4,5,7,8,第三位到第十一位可以为0-9中任意一个数字
  410. String regex = "^((13[0-9])|(14[5,7,9])|(15[0-3,5-9])|(166)|(17[3,5,6,7,8])|(18[0-9])|(19[1,8,9]))\\d{8}$";
  411. for (Row row : rows) {
  412. if (StringUtils.isEmpty(row.getString("name"))) {
  413. iserr = true;
  414. row.put("msg", "错误信息:必填项不能为空");
  415. rowserr.add(row);
  416. } else {
  417. Rows userRows = areaRowsMap.get(row.getString("name"));
  418. if (userRows.isNotEmpty()) {
  419. row.putAll(userRows.get(0));
  420. rowssuc.add(row);
  421. } else {
  422. iserr = true;
  423. row.put("msg", "错误信息:数据已导入或区域不在数据库中");
  424. rowserr.add(row);
  425. }
  426. }
  427. }
  428. String[] types = {"年", "季", "月"};
  429. long[] ids = createTableID("sa_salestarget", rowssuc.size() * 17);
  430. int index = 1;
  431. if (!rowssuc.isEmpty()) {
  432. for (Row row : rowssuc) {
  433. SQLFactory saleFactory = new SQLFactory(this, "人员范围新增");
  434. saleFactory.addParameter("siteid", siteid);
  435. saleFactory.addParameter("sa_salestargethrid", createTableID("sa_salestargethr"));
  436. saleFactory.addParameter("hrid", 0);
  437. saleFactory.addParameter("position", "");
  438. saleFactory.addParameter("sa_saleareaid", row.getString("sa_saleareaid"));
  439. saleFactory.addParameter("areaname", row.getString("areaname"));
  440. saleFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  441. saleFactory.addParameter("depname", "");
  442. saleFactory.addParameter("departmentid",0);
  443. saleFactory.addParameter("name","");
  444. sqllist.add(saleFactory.getSQL());
  445. for (String type : types) {
  446. int point;
  447. if (type.equals("年")) {
  448. point = 1;
  449. } else if (type.equals("季")) {
  450. point = 4;
  451. } else if (type.equals("月")) {
  452. point = 12;
  453. } else {
  454. point = 0;
  455. }
  456. for (int i = 0; i < point; i++) {
  457. double target_l = 0L;
  458. double target_h = 0L;
  459. if (type.equals("年")) {
  460. target_l = row.getDouble("y1l");
  461. target_h = row.getDouble("y1h");
  462. }
  463. if (type.equals("季")) {
  464. target_l = row.getDouble("s" + (i + 1) + "l");
  465. target_h = row.getDouble("s" + (i + 1) + "h");
  466. }
  467. if (type.equals("月")) {
  468. target_l = row.getDouble("m" + (i + 1) + "l");
  469. target_h = row.getDouble("m" + (i + 1) + "h");
  470. }
  471. SQLFactory targetFactory = new SQLFactory(this, "人员-目标明细新增");
  472. targetFactory.addParameter("siteid", siteid);
  473. targetFactory.addParameter("sa_salestargetid", ids[index - 1]);
  474. targetFactory.addParameter("type", type);
  475. targetFactory.addParameter("point", i + 1);
  476. targetFactory.addParameter("targettype", "人员目标");
  477. targetFactory.addParameter("sa_saleareaid", row.getString("sa_saleareaid"));
  478. targetFactory.addParameter("sa_salestargetbillid", sa_salestargetbillid);
  479. targetFactory.addParameter("year", year);
  480. targetFactory.addParameter("sa_projectid", "null");
  481. targetFactory.addParameter("createby", username);
  482. targetFactory.addParameter("target_l", target_l);
  483. targetFactory.addParameter("target_h", target_h);
  484. sqllist.add(targetFactory.getSQL());
  485. index++;
  486. }
  487. }
  488. }
  489. }
  490. if (sqllist != null && !sqllist.isEmpty()) {
  491. dbConnect.runSqlUpdate("delete from sa_salestargethr where siteid='"+siteid+"' and sa_salestargetbillid="+sa_salestargetbillid);
  492. dbConnect.runSqlUpdate("delete from sa_salestarget where siteid='"+siteid+"' and sa_salestargetbillid="+sa_salestargetbillid);
  493. sqllist.add(DataContrlLog.createLog(this, "sa_salestargetbill", sa_salestargetbillid, "导入", "导入人员目标").getSQL());
  494. dbConnect.runSqlUpdate(sqllist);
  495. }
  496. if (iserr) {
  497. ExcelFactory excelFactory = new ExcelFactory("人员目标导入错误信息");
  498. ArrayList<String> colNameList = new ArrayList<String>();
  499. HashMap<String, Class> keytypemap = new HashMap<String, Class>();
  500. colNameList.add("name");
  501. String key_l = "y1l";
  502. colNameList.add(key_l);
  503. for (int a = 1; a < 5; a++) {
  504. key_l = "s" + a + "l";
  505. colNameList.add(key_l);
  506. }
  507. for (int a = 1; a < 13; a++) {
  508. key_l = "m" + a + "l";
  509. colNameList.add(key_l);
  510. }
  511. colNameList.add("msg");
  512. keytypemap.put("name", String.class);
  513. keytypemap.put("phonenumber", String.class);
  514. key_l = "y1l";
  515. keytypemap.put(key_l, String.class);
  516. for (int a = 1; a < 5; a++) {
  517. key_l = "s" + a + "l";
  518. keytypemap.put(key_l, String.class);
  519. }
  520. for (int a = 1; a < 13; a++) {
  521. key_l = "m" + a + "l";
  522. keytypemap.put(key_l, String.class);
  523. }
  524. keytypemap.put("msg", String.class);
  525. rowserr.setFieldList(colNameList);
  526. rowserr.setFieldTypeMap(keytypemap);
  527. addSheet(excelFactory, "Sheet1", rowserr);
  528. Rows aa = uploadExcelToObs(excelFactory);
  529. String url = "";
  530. if (!aa.isEmpty()) {
  531. url = aa.get(0).getString("url");
  532. }
  533. return getSucReturnObject().setData(url).toString();
  534. }
  535. } catch (Exception e1) {
  536. // TODO Auto-generated catch block
  537. e1.printStackTrace();
  538. return getErrReturnObject().setErrMsg(e1.getMessage()).toString();
  539. }
  540. return getSucReturnObject().toString();
  541. }
  542. public XSSFSheet addSheet(ExcelFactory excelFactory, String sheetname, Rows datarows) {
  543. ArrayList<String> keylist = datarows.getFieldList();
  544. XSSFSheet sheet = excelFactory.getXssfWorkbook().createSheet(sheetname);
  545. XSSFWorkbook xssfFWorkbook = excelFactory.getXssfWorkbook();
  546. XSSFCellStyle xssfCellStyle1 = xssfFWorkbook.createCellStyle();
  547. XSSFFont font = xssfFWorkbook.createFont();
  548. font.setColor((short) 0xa);
  549. font.setFontHeightInPoints((short) 12);
  550. font.setBold(true);
  551. xssfCellStyle1.setFont(font);
  552. personnelexcel.setBatchDetailSheetColumn2(sheet);// 设置工作薄列宽
  553. XSSFCellStyle titleCellStyle1 = ExportExcel.createTitleCellStyle1(xssfFWorkbook);
  554. XSSFCellStyle titleCellStyle2 = ExportExcel.createTitleCellStyle2(xssfFWorkbook);
  555. personnelexcel.batchDetailErr(sheet, titleCellStyle1, titleCellStyle2, xssfFWorkbook);// 写入标题
  556. for (int n = 0; n < datarows.size(); n++) {
  557. Row row = datarows.get(n);
  558. XSSFRow datarow = sheet.createRow(n + 2);
  559. for (int i1 = 0; i1 < keylist.size(); i1++) {
  560. Class fieldclazztype = datarows.getFieldMeta(keylist.get(i1)).getFieldtype();
  561. if (fieldclazztype == Integer.class) {
  562. datarow.createCell(i1).setCellValue(row.getInteger(keylist.get(i1)).intValue());
  563. } else if (fieldclazztype == Long.class) {
  564. datarow.createCell(i1).setCellValue(row.getLong(keylist.get(i1)));
  565. } else if (fieldclazztype == Float.class) {
  566. datarow.createCell(i1).setCellValue(row.getFloat(keylist.get(i1)));
  567. } else if (fieldclazztype == Double.class) {
  568. datarow.createCell(i1).setCellValue(row.getDouble(keylist.get(i1)));
  569. } else {
  570. datarow.createCell(i1).setCellValue(row.getString(keylist.get(i1)));
  571. }
  572. if (i1 == 18) {
  573. datarow.getCell(i1).setCellStyle(xssfCellStyle1);
  574. }
  575. }
  576. }
  577. return sheet;
  578. }
  579. }