TaskService.java 9.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234
  1. package com.yihu.jw.service;/**
  2. * Created by nature of king on 2018/5/10.
  3. */
  4. import com.alibaba.fastjson.JSONArray;
  5. import com.yihu.base.mysql.query.BaseJpaService;
  6. import com.yihu.jw.dao.ActivityDao;
  7. import com.yihu.jw.dao.TaskDao;
  8. import com.yihu.jw.dao.TaskPatientDetailDao;
  9. import com.yihu.jw.entity.health.bank.ActivityDO;
  10. import com.yihu.jw.entity.health.bank.TaskDO;
  11. import com.yihu.jw.entity.health.bank.TaskPatientDetailDO;
  12. import com.yihu.jw.restmodel.common.Envelop;
  13. import com.yihu.jw.rm.health.bank.HealthBankMapping;
  14. import com.yihu.jw.util.DateUtils;
  15. import com.yihu.jw.util.ISqlUtils;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.jdbc.core.BeanPropertyRowMapper;
  18. import org.springframework.jdbc.core.JdbcTemplate;
  19. import org.springframework.stereotype.Service;
  20. import javax.transaction.Transactional;
  21. import java.util.ArrayList;
  22. import java.util.Date;
  23. import java.util.List;
  24. import java.util.Map;
  25. /**
  26. * @author wangzhinan
  27. * @create 2018-05-10 13:45
  28. * @desc task service
  29. **/
  30. @Service
  31. @Transactional
  32. public class TaskService extends BaseJpaService<TaskDO,TaskDao>{
  33. @Autowired
  34. private TaskDao taskDao;
  35. @Autowired
  36. private JdbcTemplate jdbcTemplate;
  37. @Autowired
  38. private TaskPatientDetailDao taskPatientDetailDao;
  39. @Autowired
  40. private ActivityDao activityDao;
  41. /**
  42. * 添加任务
  43. *
  44. * @param taskDO 任务对象
  45. * @return
  46. */
  47. public Envelop<Boolean> insert(TaskDO taskDO){
  48. taskDO.setCreateTime(new Date());
  49. taskDO.setUpdateTime(new Date());
  50. taskDao.save(taskDO);
  51. Envelop<Boolean> envelop = new Envelop<>();
  52. envelop.setObj(true);
  53. return envelop;
  54. }
  55. /**
  56. * 更新任务
  57. *
  58. * @param taskDO
  59. * @return
  60. */
  61. public Envelop<Boolean> update(TaskDO taskDO){
  62. String sql = ISqlUtils.getUpdateSql(taskDO);
  63. jdbcTemplate.update(sql);
  64. Envelop<Boolean> envelop = new Envelop<>();
  65. envelop.setObj(true);
  66. return envelop;
  67. }
  68. /* public Envelop<CreditsDetailDO> findByCondition(TaskDO taskDO, Integer page, Integer size) throws ParseException {
  69. String sql = new ISqlUtils().getSql(taskDO,page,size,"*");
  70. List<CreditsDetailDO> creditsDetailDOS = jdbcTemplate.query(sql,new BeanPropertyRowMapper(CreditsDetailDO.class));
  71. String sqlcount = new ISqlUtils().getSql(creditsDetailDO,0,0,"count");
  72. List<Map<String,Object>> rstotal = jdbcTemplate.queryForList(sqlcount);
  73. Long count = 0L;
  74. if(rstotal!=null&&rstotal.size()>0){
  75. count = (Long) rstotal.get(0).get("total");
  76. }
  77. return Envelop.getSuccessListWithPage(HealthBankMapping.api_success, creditsDetailDOS,page,size,count);
  78. }*/
  79. /**
  80. * 查找数据
  81. *
  82. * @param taskDO 任务对象
  83. * @param page 页码
  84. * @param size 分页大小
  85. * @return
  86. */
  87. public Envelop<TaskDO> selectByCondition(TaskDO taskDO,Integer page,Integer size){
  88. TaskDO taskDO2 = new TaskDO();
  89. String sql = new ISqlUtils().getSql(taskDO,page,size,"*");
  90. List<TaskDO> taskDOS = jdbcTemplate.query(sql,new BeanPropertyRowMapper(TaskDO.class));
  91. for (TaskDO taskDO1:taskDOS){
  92. if (taskDO1.getType()!= null && taskDO1.getType().equalsIgnoreCase("ACTIVITY_TASK")){
  93. ActivityDO activityDO = activityDao.findOne(taskDO1.getTransactionId());
  94. taskDO1.setActivityDO(activityDO);
  95. }
  96. //参与活动的详情
  97. String taskSql = "select * from wlyy_health_bank_task_patient_detail where task_id = '"+taskDO1.getId()+
  98. "' and patient_openid = '"+taskDO.getOpenId()+"'";
  99. List<TaskPatientDetailDO> taskPatientDetailDOS = jdbcTemplate.query(taskSql,new BeanPropertyRowMapper(TaskPatientDetailDO.class));
  100. taskDO1.setTaskPatientDetailDOS(taskPatientDetailDOS);
  101. //参与人数
  102. String taskSql1 = "select count(1) as total from wlyy_health_bank_task_patient_detail where task_id = '"+taskDO1.getId()+"'";
  103. List<Map<String,Object>> rstotal = jdbcTemplate.queryForList(taskSql1);
  104. Long count = 0L;
  105. if(rstotal!=null&&rstotal.size()>0){
  106. count = (Long) rstotal.get(0).get("total");
  107. }
  108. taskDO1.setTotal(count);
  109. taskDO1.setPatientId(taskDO.getPatientId());
  110. }
  111. String sqlcount = new ISqlUtils().getSql(taskDO,0,0,"count");
  112. List<Map<String,Object>> rstotal = jdbcTemplate.queryForList(sqlcount);
  113. Long count = 0L;
  114. if(rstotal!=null&&rstotal.size()>0){
  115. count = (Long) rstotal.get(0).get("total");
  116. }
  117. return Envelop.getSuccessListWithPage(HealthBankMapping.api_success, taskDOS,page,size,count);
  118. }
  119. /**
  120. * 查看当前的任务
  121. * @param array taskCode集合
  122. * @param patientId 居民id
  123. * @param page 页码
  124. * @param size 分页大小
  125. * @return
  126. */
  127. public Envelop<TaskDO> selectByTask(JSONArray array,String patientId,Integer page,Integer size){
  128. StringBuffer buffer = new StringBuffer();
  129. List<String> taskCodes = new ArrayList<>();
  130. for (int i=0;i<array.size();i++){
  131. taskCodes.add(array.getString(i));
  132. }
  133. buffer.append(" bt.task_code in(");
  134. if (taskCodes == null || taskCodes.size() == 0){
  135. buffer.append("''");
  136. }else {
  137. for (int i=0;i<taskCodes.size();i++){
  138. buffer.append("'"+taskCodes.get(i)+"'").append(",");
  139. }
  140. buffer.deleteCharAt(buffer.length()-1);
  141. }
  142. buffer.append(") ");
  143. String sql = "select * from wlyy_health_bank_task bt where "+buffer +" ORDER BY update_time DESC LIMIT "+(page-1)*size+","+size;
  144. List<TaskDO> taskDOList = jdbcTemplate.query(sql,new BeanPropertyRowMapper(TaskDO.class));
  145. for (TaskDO taskDO:taskDOList){
  146. if (taskDO.getType().equalsIgnoreCase("ACTIVITY_TASK")){
  147. ActivityDO activityDO = activityDao.findOne(taskDO.getTransactionId());
  148. taskDO.setActivityDO(activityDO);
  149. }
  150. if (taskDO.getPeriod() == 1){
  151. String taskSql = "select * from wlyy_health_bank_task_patient_detail where task_id = '"+taskDO.getId()+
  152. "' and patient_id = '"+patientId+"'";
  153. List<TaskPatientDetailDO> taskPatientDetailDOS = jdbcTemplate.query(taskSql,new BeanPropertyRowMapper(TaskPatientDetailDO.class));
  154. taskDO.setTaskPatientDetailDOS(taskPatientDetailDOS);
  155. }else if (taskDO.getPeriod() == 0){
  156. String taskSql = "select * from wlyy_health_bank_task_patient_detail where task_id = '"+taskDO.getId()+
  157. "' and patient_id = '"+patientId+"' and create_time > '" + DateUtils.getDayBegin() +"' and create_time < '"+ DateUtils.getDayEnd() +"'";
  158. List<TaskPatientDetailDO> taskPatientDetailDOS = jdbcTemplate.query(taskSql,new BeanPropertyRowMapper(TaskPatientDetailDO.class));
  159. taskDO.setTaskPatientDetailDOS(taskPatientDetailDOS);
  160. }
  161. taskDO.setPatientId(patientId);
  162. }
  163. String sqlcount = "select COUNT(1) AS total from wlyy_health_bank_task bt where "+buffer ;
  164. List<Map<String,Object>> rstotal = jdbcTemplate.queryForList(sqlcount);
  165. Long count = 0L;
  166. if(rstotal!=null&&rstotal.size()>0){
  167. count = (Long) rstotal.get(0).get("total");
  168. }
  169. return Envelop.getSuccessListWithPage(HealthBankMapping.api_success, taskDOList,page,size,count);
  170. }
  171. /* public List<TaskDO> getTasks(String patientId){
  172. List<TaskDO> taskDOList = new ArrayList<>();
  173. TaskDO taskDO = new TaskDO();
  174. *//*taskDO.setPatientId(patientId);*//*
  175. taskDO.setTaskCode("BIND");
  176. taskDO.setPeriod(1);
  177. taskDO.setTaskTitle("首次绑定");
  178. taskDO.setTaskContent("(使用社区发放的已关联您身份信息的设备,登录厦门i健康绑定设备)");
  179. taskDO.setTradeType("activity");
  180. taskDO.setTransactionId("402885e96324a409016324c0a45a0006");
  181. taskDO.setCreateTime(new Date());
  182. taskDO.setUpdateTime(new Date());
  183. taskDOList.add(taskDO);
  184. TaskDO taskDO1 = new TaskDO();
  185. *//* taskDO1.setPatientId(patientId);*//*
  186. taskDO1.setTaskCode("MEASURE");
  187. taskDO1.setPeriod(0);
  188. taskDO1.setTaskTitle("每日测量");
  189. taskDO1.setTaskContent("(使用社区发放的已关联您身份信息的设备,绑定后每天完成测量)");
  190. taskDO1.setTradeType("activity");
  191. taskDO1.setTransactionId("402885e96324a409016324c0a45a0006");
  192. taskDO1.setCreateTime(new Date());
  193. taskDO1.setUpdateTime(new Date());
  194. taskDOList.add(taskDO1);
  195. return taskDOList;
  196. }*/
  197. /**
  198. * 删除任务
  199. *
  200. * @param ids taskId集合[]
  201. * @return
  202. */
  203. public Envelop<Boolean> batchDelete(List<String> ids){
  204. Envelop<Boolean> envelop = new Envelop<>();
  205. for (int i =0;i<ids.size();i++){
  206. List<TaskPatientDetailDO> taskPatientDetailDOS = taskPatientDetailDao.selectByTaskId(ids.get(i));
  207. for(TaskPatientDetailDO taskPatientDetailDO:taskPatientDetailDOS){
  208. taskPatientDetailDO.setStatus(-1);
  209. taskPatientDetailDO.setCreateTime(new Date());
  210. taskPatientDetailDO.setUpdateTime(new Date());
  211. taskPatientDetailDao.save(taskPatientDetailDO);
  212. }
  213. TaskDO taskDO = taskDao.findOne(ids.get(i));
  214. taskDO.setStatus(0);
  215. taskDO.setCreateTime(new Date());
  216. taskDO.setUpdateTime(new Date());
  217. taskDao.save(taskDO);
  218. }
  219. return envelop;
  220. }
  221. }