AchievementServiceImpl.java 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576
  1. package com.goafanti.achievement.service.impl;
  2. import java.math.BigDecimal;
  3. import java.text.ParseException;
  4. import java.util.ArrayList;
  5. import java.util.Calendar;
  6. import java.util.Date;
  7. import java.util.HashMap;
  8. import java.util.List;
  9. import java.util.Map;
  10. import java.util.UUID;
  11. import org.apache.commons.lang3.StringUtils;
  12. import org.springframework.beans.BeanUtils;
  13. import org.springframework.beans.factory.annotation.Autowired;
  14. import org.springframework.stereotype.Service;
  15. import com.goafanti.achievement.bo.AchievementImportBo;
  16. import com.goafanti.achievement.bo.AchievementListBo;
  17. import com.goafanti.achievement.bo.AchievementOrgOwnerDetailBo;
  18. import com.goafanti.achievement.bo.AchievementPartnerListBo;
  19. import com.goafanti.achievement.bo.AchievementUserOwnerDetailBo;
  20. import com.goafanti.achievement.service.AchievementService;
  21. import com.goafanti.common.constant.AFTConstants;
  22. import com.goafanti.common.dao.AchievementDemandCountMapper;
  23. import com.goafanti.common.dao.AchievementDemandMapper;
  24. import com.goafanti.common.dao.AchievementKeywordMapper;
  25. import com.goafanti.common.dao.AchievementMapper;
  26. import com.goafanti.common.dao.DemandKeywordMapper;
  27. import com.goafanti.common.dao.NoticeMapper;
  28. import com.goafanti.common.dao.OrganizationIdentityMapper;
  29. import com.goafanti.common.dao.UserIdentityMapper;
  30. import com.goafanti.common.dao.UserRoleMapper;
  31. import com.goafanti.common.enums.AchievementAuditStatus;
  32. import com.goafanti.common.enums.AchievementReleaseStatus;
  33. import com.goafanti.common.enums.AchievementSwitchSign;
  34. import com.goafanti.common.enums.DeleteStatus;
  35. import com.goafanti.common.enums.DemandAuditStatus;
  36. import com.goafanti.common.enums.DemandReleaseStatus;
  37. import com.goafanti.common.enums.NoticeReadStatus;
  38. import com.goafanti.common.enums.NoticeStatus;
  39. import com.goafanti.common.enums.UserType;
  40. import com.goafanti.common.model.Achievement;
  41. import com.goafanti.common.model.AchievementDemand;
  42. import com.goafanti.common.model.AchievementDemandCount;
  43. import com.goafanti.common.model.AchievementKeyword;
  44. import com.goafanti.common.model.Admin;
  45. import com.goafanti.common.model.Notice;
  46. import com.goafanti.common.model.OrganizationIdentity;
  47. import com.goafanti.common.model.UserIdentity;
  48. import com.goafanti.common.utils.DateUtils;
  49. import com.goafanti.core.mybatis.BaseMybatisDao;
  50. import com.goafanti.core.mybatis.page.Pagination;
  51. import com.goafanti.core.shiro.token.TokenManager;
  52. import com.goafanti.demand.bo.DemandAchievementListBo;
  53. import com.goafanti.portal.bo.AchievementDetailBo;
  54. import com.goafanti.portal.bo.AchievementPortalDetailBo;
  55. import com.goafanti.portal.bo.AchievementPortalSimilarListBo;
  56. import com.goafanti.portal.bo.AchievementSearchListBo;
  57. @Service
  58. public class AchievementServiceImpl extends BaseMybatisDao<AchievementMapper> implements AchievementService {
  59. @Autowired
  60. private AchievementMapper achievementMapper;
  61. @Autowired
  62. private UserRoleMapper userRoleMapper;
  63. @Autowired
  64. private NoticeMapper noticeMapper;
  65. @Autowired
  66. private AchievementKeywordMapper achievementKeywordMapper;
  67. @Autowired
  68. private AchievementDemandMapper achievementDemandMapper;
  69. @Autowired
  70. private DemandKeywordMapper demandKeywordMapper;
  71. @Autowired
  72. private AchievementDemandCountMapper achievementDemandCountMapper;
  73. @Autowired
  74. private UserIdentityMapper userIdentityMapper;
  75. @Autowired
  76. private OrganizationIdentityMapper organizationIdentityMapper;
  77. @SuppressWarnings("unchecked")
  78. @Override
  79. public Pagination<AchievementListBo> listUserOwnerAchievement(String ownerId, Integer auditStatus,
  80. Integer serialNumber, String name, String keyword, Integer category, Integer status,
  81. String releaseDateStartDate, String releaseDateEndDate, Integer releaseStatus, Integer pNo, Integer pSize) {
  82. if (pNo == null || pNo < 0) {
  83. pNo = 1;
  84. }
  85. if (pSize == null || pSize < 0 || pSize > 10) {
  86. pSize = 10;
  87. }
  88. return (Pagination<AchievementListBo>) findPage("findUserOwnerAchievementListByPage",
  89. "findUserOwnerAchievementCount", disposeParams(ownerId, auditStatus, serialNumber, name, keyword,
  90. category, status, releaseDateStartDate, releaseDateEndDate, releaseStatus),
  91. pNo, pSize);
  92. }
  93. @SuppressWarnings("unchecked")
  94. @Override
  95. public Pagination<AchievementListBo> listOrgOwnerAchievement(String ownerId, Integer auditStatus,
  96. Integer serialNumber, String name, String keyword, Integer category, Integer status,
  97. String releaseDateStartDate, String releaseDateEndDate, Integer releaseStatus, Integer pNo, Integer pSize) {
  98. if (pNo == null || pNo < 0) {
  99. pNo = 1;
  100. }
  101. if (pSize == null || pSize < 0 || pSize > 10) {
  102. pSize = 10;
  103. }
  104. return (Pagination<AchievementListBo>) findPage("findOrgOwnerAchievementListByPage",
  105. "findOrgOwnerAchievementCount", disposeParams(ownerId, auditStatus, serialNumber, name, keyword,
  106. category, status, releaseDateStartDate, releaseDateEndDate, releaseStatus),
  107. pNo, pSize);
  108. }
  109. @Override
  110. public void saveAchievement(Achievement a, String[] keywords) {
  111. a.setId(UUID.randomUUID().toString());
  112. a.setDeletedSign(DeleteStatus.UNDELETE.getCode());
  113. Calendar now = Calendar.getInstance();
  114. now.set(Calendar.MILLISECOND, 0);
  115. if (TokenManager.getToken() instanceof Admin) {
  116. a.setTechBrokerId(TokenManager.getAdminId());
  117. }
  118. a.setReleaseStatus(AchievementReleaseStatus.UNRELEASE.getCode());
  119. if (AchievementAuditStatus.SUBMIT.getCode().equals(a.getAuditStatus())) {
  120. a.setAuditStatus(DemandAuditStatus.INAUDIT.getCode());
  121. createAuditorNotice(a);
  122. } else {
  123. a.setAuditStatus(AchievementAuditStatus.CREATE.getCode());
  124. }
  125. a.setCreateTime(now.getTime());
  126. achievementMapper.insert(a);
  127. disposeAchievementKeyword(keywords, a, false);
  128. }
  129. @Override
  130. public int updateAchievement(Achievement a, String[] keywords, Integer switchSign) {
  131. if (AchievementAuditStatus.SUBMIT.getCode().equals(a.getAuditStatus())) {
  132. a.setAuditStatus(DemandAuditStatus.INAUDIT.getCode());
  133. createAuditorNotice(a);
  134. }
  135. disposeAchievementKeyword(keywords, a, true);
  136. achievementMapper.updateByPrimaryKeySelective(a);
  137. if (null != switchSign && AchievementSwitchSign.CLOSE.getCode().equals(switchSign)){
  138. achievementMapper.updateOwnerId(a.getId());
  139. }
  140. return 1;
  141. }
  142. @Override
  143. public Achievement selectByPrimaryKey(String id) {
  144. return achievementMapper.selectByPrimaryKey(id);
  145. }
  146. @Override
  147. public int deleteByPrimaryKey(List<String> id) {
  148. achievementKeywordMapper.batchDeleteByAchievementIds(id);
  149. achievementDemandMapper.batchDeleteByAchievementIds(id);
  150. for (String s : id) {
  151. Achievement a = achievementMapper.selectByPrimaryKey(s);
  152. if (null != a && StringUtils.isNotBlank(a.getOwnerId())) {
  153. AchievementDemandCount adc = achievementDemandCountMapper.selectByUid(a.getOwnerId());
  154. if (null != adc) {
  155. adc.setAchievementCount(adc.getAchievementCount() - 1);
  156. if (adc.getAchievementCount() < 0) {
  157. adc.setAchievementCount(0);
  158. }
  159. achievementDemandCountMapper.updateByPrimaryKeySelective(adc);
  160. }
  161. }
  162. }
  163. return achievementMapper.batchDeleteByPrimaryKey(id);
  164. }
  165. @SuppressWarnings("unchecked")
  166. @Override
  167. public Pagination<AchievementListBo> listUserAchievement(Integer auditStatus, Integer serialNumber, String name,
  168. String keyword, Integer category, Integer ownerType, Integer status, String releaseDateStartDate,
  169. String releaseDateEndDate, Integer releaseStatus, Integer pNo, Integer pSize) {
  170. if (pNo == null || pNo < 0) {
  171. pNo = 1;
  172. }
  173. if (pSize == null || pSize < 0 || pSize > 10) {
  174. pSize = 10;
  175. }
  176. return (Pagination<AchievementListBo>) findPage("findAchievementListByPage",
  177. "findAchievementCount", disposeParams(TokenManager.getUserId(), auditStatus, serialNumber, name,
  178. keyword, category, status, releaseDateStartDate, releaseDateEndDate, releaseStatus),
  179. pNo, pSize);
  180. }
  181. private Map<String, Object> disposeParams(String ownerId, Integer auditStatus, Integer serialNumber, String name,
  182. String keyword, Integer category, Integer status, String releaseDateStartDate, String releaseDateEndDate,
  183. Integer releaseStatus) {
  184. Map<String, Object> params = new HashMap<>();
  185. Date rStart = null;
  186. Date rEnd = null;
  187. if (!StringUtils.isBlank(releaseDateStartDate)) {
  188. try {
  189. rStart = DateUtils.parseDate(releaseDateStartDate, AFTConstants.YYYYMMDD);
  190. } catch (ParseException e) {
  191. }
  192. }
  193. if (!StringUtils.isBlank(releaseDateEndDate)) {
  194. try {
  195. rEnd = DateUtils.addDays(DateUtils.parseDate(releaseDateEndDate, AFTConstants.YYYYMMDD), 1);
  196. } catch (ParseException e) {
  197. }
  198. }
  199. if (null != rStart) {
  200. params.put("rStart", rStart);
  201. }
  202. if (null != rEnd) {
  203. params.put("rEnd", rEnd);
  204. }
  205. if (null != auditStatus) {
  206. params.put("auditStatus", auditStatus);
  207. }
  208. if (!StringUtils.isBlank(ownerId)) {
  209. params.put("ownerId", ownerId);
  210. }
  211. if (null != serialNumber) {
  212. params.put("serialNumber", serialNumber);
  213. }
  214. if (!StringUtils.isBlank(name)) {
  215. params.put("name", name);
  216. }
  217. if (!StringUtils.isBlank(keyword)) {
  218. params.put("keyword", keyword);
  219. }
  220. if (null != category) {
  221. params.put("category", category);
  222. }
  223. if (null != status) {
  224. params.put("status", status);
  225. }
  226. if (null != releaseStatus) {
  227. params.put("releaseStatus", releaseStatus);
  228. }
  229. if (TokenManager.hasRole(AFTConstants.TECHBROKER)){
  230. params.put("techBrokerId", TokenManager.getAdminId());
  231. }
  232. return params;
  233. }
  234. @Override
  235. public int updateAuditAchievement(Achievement a, String techBroderId, Integer auditStatus) {
  236. a.setAuditStatus(auditStatus);
  237. if (AchievementAuditStatus.AUDITED.getCode().equals(auditStatus)) {
  238. Calendar now = Calendar.getInstance();
  239. now.set(Calendar.MILLISECOND, 0);
  240. a.setReleaseDate(now.getTime());
  241. a.setReleaseStatus(DemandReleaseStatus.RELEASED.getCode());
  242. a.setTechBrokerId(techBroderId);
  243. String ownerId = a.getOwnerId();
  244. if (StringUtils.isNotBlank(ownerId)) {
  245. if (UserType.PERSONAL.getCode().equals(a.getOwnerType())){
  246. UserIdentity ui = userIdentityMapper.selectUserIdentityByUserId(ownerId);
  247. if (null != ui){
  248. a.setOwnerName(ui.getUsername());
  249. }
  250. } else if (UserType.ORGANIZATION.getCode().equals(a.getOwnerType())){
  251. OrganizationIdentity oi = organizationIdentityMapper.selectOrgIdentityByUserId(ownerId);
  252. if (null != oi){
  253. a.setOwnerName(oi.getUnitName());
  254. }
  255. }
  256. AchievementDemandCount adc = achievementDemandCountMapper.selectByUid(ownerId);
  257. if (null == adc) {
  258. AchievementDemandCount achievementDemandCount = new AchievementDemandCount();
  259. achievementDemandCount.setId(UUID.randomUUID().toString());
  260. achievementDemandCount.setUid(ownerId);
  261. achievementDemandCount.setAchievementCount(AFTConstants.ACHIEVEMENT_DEMAND_FIRST_COUNT);
  262. achievementDemandCount.setDemandCount(AFTConstants.ACHIEVEMENT_DEMAND_INIT_COUNT);
  263. achievementDemandCountMapper.insert(achievementDemandCount);
  264. } else {
  265. adc.setAchievementCount(adc.getAchievementCount() + 1);
  266. achievementDemandCountMapper.updateByPrimaryKeySelective(adc);
  267. }
  268. }
  269. } else {
  270. a.setReleaseStatus(DemandReleaseStatus.UNRELEASE.getCode());
  271. }
  272. createTechBorkerNotice(a);
  273. return achievementMapper.updateByPrimaryKeySelective(a);
  274. }
  275. @Override
  276. public int updateReleaseStatus(Achievement a) {
  277. a.setAuditStatus(AchievementAuditStatus.CREATE.getCode());
  278. a.setReleaseStatus(AchievementReleaseStatus.UNRELEASE.getCode());
  279. achievementDemandMapper.deleteByAchievementId(a.getId());
  280. achievementKeywordMapper.batchDeleteByAchievementId(a.getId());
  281. achievementMapper.updateByPrimaryKeySelective(a);
  282. if (StringUtils.isNotBlank(a.getOwnerId())) {
  283. AchievementDemandCount adc = achievementDemandCountMapper.selectByUid(a.getOwnerId());
  284. if (null != adc) {
  285. adc.setAchievementCount(adc.getAchievementCount() - 1);
  286. if (adc.getAchievementCount() < 0) {
  287. adc.setAchievementCount(0);
  288. }
  289. achievementDemandCountMapper.updateByPrimaryKeySelective(adc);
  290. }
  291. }
  292. return achievementMapper.updateReleaseDate(a.getId());
  293. }
  294. @Override
  295. public AchievementUserOwnerDetailBo selectUserOwnerDetail(String id) {
  296. return achievementMapper.selectUserOwnerDetail(id);
  297. }
  298. @Override
  299. public AchievementOrgOwnerDetailBo selectOrgOwnerDetail(String id) {
  300. return achievementMapper.selectOrgOwnerDetail(id);
  301. }
  302. @Override
  303. public List<DemandAchievementListBo> selectAchievementDemandListByAchievementId(String id) {
  304. return achievementDemandMapper.selectAchievementDemandListByAchievementId(id);
  305. }
  306. @Override
  307. public void insertImport(List<AchievementImportBo> data) {
  308. if (null == data || data.isEmpty()) {
  309. return;
  310. }
  311. Achievement a = null;
  312. AchievementKeyword ak = null;
  313. List<Achievement> achievementList = new ArrayList<>();
  314. List<AchievementKeyword> AchievementKeywordList = new ArrayList<>();
  315. Calendar now = Calendar.getInstance();
  316. now.set(Calendar.MILLISECOND, 0);
  317. for (AchievementImportBo bo : data) {
  318. a = new Achievement();
  319. BeanUtils.copyProperties(bo, a);
  320. a.setId(UUID.randomUUID().toString());
  321. a.setDeletedSign(DeleteStatus.UNDELETE.getCode());
  322. a.setCreateTime(now.getTime());
  323. a.setAuditStatus(AchievementAuditStatus.INAUDIT.getCode());
  324. a.setReleaseStatus(AchievementReleaseStatus.UNRELEASE.getCode());
  325. List<String> keywordsList = bo.getKeywords();
  326. if (null != keywordsList && keywordsList.size() > 0) {
  327. for (String s : keywordsList) {
  328. if (!StringUtils.isBlank(s)) {
  329. ak = new AchievementKeyword();
  330. ak.setAchievementId(a.getId());
  331. ak.setKeyword(s.trim());
  332. ak.setId(UUID.randomUUID().toString());
  333. AchievementKeywordList.add(ak);
  334. }
  335. }
  336. }
  337. achievementList.add(a);
  338. }
  339. achievementMapper.insertBatch(achievementList);
  340. achievementKeywordMapper.insertBatch(AchievementKeywordList);
  341. }
  342. @SuppressWarnings("unchecked")
  343. @Override
  344. public Pagination<AchievementSearchListBo> listAchievementSearchList(Integer bargainingMode, Integer category,
  345. Integer maturity, BigDecimal transferPriceLower, BigDecimal transferPriceUpper, Integer transferMode,
  346. String keyword, Integer fieldA, Integer fieldB, Integer pNo, Integer pSize) {
  347. Map<String, Object> params = new HashMap<>();
  348. if (!StringUtils.isBlank(keyword)) {
  349. params.put("keyword", keyword);
  350. }
  351. if (null != bargainingMode) {
  352. params.put("bargainingMode", bargainingMode);
  353. }
  354. if (null != category) {
  355. params.put("category", category);
  356. }
  357. if (null != maturity) {
  358. params.put("maturity", maturity);
  359. }
  360. if (null != transferPriceLower) {
  361. params.put("transferPriceLower", transferPriceLower);
  362. }
  363. if (null != transferPriceUpper) {
  364. params.put("transferPriceUpper", transferPriceUpper);
  365. }
  366. if (null != transferMode) {
  367. params.put("transferMode", transferMode);
  368. }
  369. if (null != fieldA) {
  370. params.put("fieldA", fieldA);
  371. }
  372. if (null != fieldB) {
  373. params.put("fieldB", fieldB);
  374. }
  375. if (pNo == null || pNo < 0) {
  376. pNo = 1;
  377. }
  378. if (pSize == null || pSize < 0 || pSize > 20) {
  379. pSize = 20;
  380. }
  381. return (Pagination<AchievementSearchListBo>) findPage("findSearchAchievementListByPage",
  382. "findSearchAchievementCount", params, pNo, pSize);
  383. }
  384. @Override
  385. public AchievementDetailBo selectAchievementSearchDetail(String uid, String id) {
  386. return achievementMapper.selectAchievementSearchDetail(uid, id);
  387. }
  388. private void createTechBorkerNotice(Achievement a) {
  389. noticeMapper.insert(disposeNotice(a, null));
  390. }
  391. // 给所有审核员发送审核通知
  392. private void createAuditorNotice(Achievement a) {
  393. List<String> ids = userRoleMapper.listAuditor();
  394. List<Notice> list = new ArrayList<>();
  395. if (null != ids && ids.size() > 0) {
  396. for (String s : ids) {
  397. list.add(disposeNotice(a, s));
  398. }
  399. noticeMapper.insertBatch(list);
  400. }
  401. }
  402. private Notice disposeNotice(Achievement a, String aid) {
  403. Notice n = new Notice();
  404. Calendar now = Calendar.getInstance();
  405. now.set(Calendar.MILLISECOND, 0);
  406. n.setId(UUID.randomUUID().toString());
  407. n.setCreateTime(now.getTime());
  408. n.setReaded(NoticeReadStatus.UNREAD.getCode());
  409. n.setRid(a.getId());
  410. if (StringUtils.isBlank(aid)) {
  411. n.setAid(a.getTechBrokerId());
  412. if (UserType.PERSONAL.getCode().equals(a.getOwnerType())) {
  413. n.setContent("编号" + a.getSerialNumber() + NoticeStatus.PERSONALACHIEVEMENTT.getDesc() + " "
  414. + (AchievementAuditStatus.AUDITED.getCode().equals(a.getAuditStatus())
  415. ? AchievementAuditStatus.AUDITED.getDesc()
  416. : AchievementAuditStatus.UNAUDITED.getDesc()));
  417. n.setNoticeType(NoticeStatus.PERSONALACHIEVEMENTT.getCode());
  418. } else if (UserType.ORGANIZATION.getCode().equals(a.getOwnerType())) {
  419. n.setContent("编号" + a.getSerialNumber() + NoticeStatus.ORGANIZATIONACHIEVEMENT.getDesc() + " "
  420. + (AchievementAuditStatus.AUDITED.getCode().equals(a.getAuditStatus())
  421. ? AchievementAuditStatus.AUDITED.getDesc()
  422. : AchievementAuditStatus.UNAUDITED.getDesc()));
  423. n.setNoticeType(NoticeStatus.ORGANIZATIONACHIEVEMENT.getCode());
  424. }
  425. } else {
  426. n.setAid(aid);
  427. if (UserType.PERSONAL.getCode().equals(a.getOwnerType())) {
  428. n.setContent(
  429. NoticeStatus.PERSONALACHIEVEMENTT.getDesc() + " " + AchievementAuditStatus.SUBMIT.getDesc());
  430. n.setNoticeType(NoticeStatus.PERSONALACHIEVEMENTT.getCode());
  431. } else if (UserType.ORGANIZATION.getCode().equals(a.getOwnerType())) {
  432. n.setContent(
  433. NoticeStatus.ORGANIZATIONACHIEVEMENT.getDesc() + " " + AchievementAuditStatus.SUBMIT.getDesc());
  434. n.setNoticeType(NoticeStatus.ORGANIZATIONACHIEVEMENT.getCode());
  435. }
  436. }
  437. return n;
  438. }
  439. private void disposeAchievementKeyword(String[] keywords, Achievement a, boolean delete) {
  440. if (null != keywords && keywords.length > 0) {
  441. if (delete) {
  442. achievementKeywordMapper.batchDeleteByAchievementId(a.getId());
  443. }
  444. List<AchievementKeyword> list = new ArrayList<>();
  445. AchievementKeyword ak = null;
  446. for (int i = 0; i < keywords.length; i++) {
  447. ak = new AchievementKeyword();
  448. ak.setId(UUID.randomUUID().toString());
  449. ak.setAchievementId(a.getId());
  450. ak.setKeyword(keywords[i].trim());
  451. list.add(ak);
  452. }
  453. achievementKeywordMapper.insertBatch(list);
  454. }
  455. }
  456. @Override
  457. public int updateMatchDemand(Achievement a) {
  458. achievementDemandMapper.deleteByAchievementId(a.getId());// 删除之前匹配单
  459. List<AchievementKeyword> achievement = achievementKeywordMapper.selectKeywordsByAchievementId(a.getId());
  460. if (null != achievement && achievement.size() > 0) {
  461. List<String> keyword = new ArrayList<>();
  462. for (AchievementKeyword k : achievement) {
  463. if (!StringUtils.isBlank(k.getKeyword())) {
  464. keyword.add(k.getKeyword());
  465. }
  466. }
  467. List<AchievementDemand> list = demandKeywordMapper.selectAchievementDemand(keyword);
  468. if (null != list && list.size() > 0) {
  469. for (AchievementDemand ad : list) {
  470. ad.setAchievementId(a.getId());
  471. }
  472. return achievementDemandMapper.insertBatch(list);
  473. }
  474. }
  475. return 0;
  476. }
  477. @SuppressWarnings("unchecked")
  478. @Override
  479. public Pagination<AchievementPartnerListBo> listPartnerAchievement(String ownerId, Integer pNo, Integer pSize) {
  480. Map<String, Object> params = new HashMap<>();
  481. params.put("ownerId", ownerId);
  482. if (pNo == null || pNo < 0) {
  483. pNo = 1;
  484. }
  485. if (pSize == null || pSize < 0 || pSize > 10) {
  486. pSize = 10;
  487. }
  488. return (Pagination<AchievementPartnerListBo>) findPage("findPartnerAchievementListByPage",
  489. "findPartnerAchievementCount", params, pNo, pSize);
  490. }
  491. @Override
  492. public AchievementPortalDetailBo findUserPortalAchievementDetail(String id) {
  493. return achievementMapper.findUserPortalAchievementDetail(id, TokenManager.getUserId());
  494. }
  495. @Override
  496. public AchievementPortalDetailBo findOrgPortalAchievementDetail(String id) {
  497. return achievementMapper.findOrgPortalAchievementDetail(id, TokenManager.getUserId());
  498. }
  499. @Override
  500. public List<AchievementPortalSimilarListBo> findByFieldA(Integer fieldA, String id, Integer type) {
  501. if (UserType.PERSONAL.getCode().equals(type)) {
  502. return achievementMapper.findUserPortalSimilarByFieldA(fieldA, id);
  503. } else if (UserType.ORGANIZATION.getCode().equals(type)) {
  504. return achievementMapper.findOrgPortalSimilarByFieldA(fieldA, id);
  505. }
  506. return null;
  507. }
  508. }