|
@@ -36,11 +36,11 @@ import org.apache.http.message.BasicNameValuePair;
|
|
|
import org.apache.http.params.CoreConnectionPNames;
|
|
|
import org.apache.http.util.EntityUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.data.jpa.repository.Query;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import com.xt.jygl.common.Constants;
|
|
|
import com.xt.jygl.common.GlobalData;
|
|
|
-import com.xt.jygl.gkjcxx.gq.entity.GqEntity;
|
|
|
import com.xt.jygl.gkjcxx.gq.service.GqService;
|
|
|
import com.xt.jygl.gkjygl.cghzyxxgl.dcsb.dao.DcsbDao;
|
|
|
import com.xt.jygl.gkjygl.cghzyxxgl.dcsb.entity.DcsbEntity;
|
|
@@ -51,7 +51,6 @@ import com.xt.jygl.workflow.service.impl.BaseWorkFlowServiceImpl;
|
|
|
import com.xtframe.core.support.SecurityMgr;
|
|
|
import com.xtframe.sec.common.BaseEntity;
|
|
|
import com.xtframe.sec.common.SecRepository;
|
|
|
-import com.xtframe.sec.role.entity.RoleEntity;
|
|
|
import com.xtframe.sec.user.entity.UserEntity;
|
|
|
import com.xtframe.sec.utils.SecUtils;
|
|
|
import com.xtframe.util.StringUtils;
|
|
@@ -152,22 +151,21 @@ public class DcsbServiceImpl extends BaseWorkFlowServiceImpl<DcsbEntity, String>
|
|
|
// 提交流程
|
|
|
create(param, variables);
|
|
|
//
|
|
|
- /*GqEntity gq = gqService.findOne(gqid);
|
|
|
- List<RoleEntity> reList = securityMgr.roleService().findByCode(Constants.ROLE_DCSBSC);
|
|
|
- if (reList != null && reList.size() > 0) {
|
|
|
- for (RoleEntity re : reList) {
|
|
|
- List<UserEntity> ueList = securityMgr.userService().findByRole(re.getId());
|
|
|
- if (ueList != null && gq != null && gq.getSsgkglbm() != null) {
|
|
|
- for (UserEntity ue : ueList) {
|
|
|
- if (ue.getSsglbm() != null && ue.getSsglbm().getId() != null && ue.getSsglbm().getId().equals(gq.getSsgkglbm().getId())) {
|
|
|
- tuisong(" 您收到一条提醒", entity.getSsjyr().getGkjyr() + "的单船申报", 7, ue.getWeixinid(), entity.getId(), true);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-*/
|
|
|
+ /*
|
|
|
+ * GqEntity gq = gqService.findOne(gqid); List<RoleEntity> reList =
|
|
|
+ * securityMgr.roleService().findByCode(Constants.ROLE_DCSBSC); if
|
|
|
+ * (reList != null && reList.size() > 0) { for (RoleEntity re :
|
|
|
+ * reList) { List<UserEntity> ueList =
|
|
|
+ * securityMgr.userService().findByRole(re.getId()); if (ueList !=
|
|
|
+ * null && gq != null && gq.getSsgkglbm() != null) { for (UserEntity
|
|
|
+ * ue : ueList) { if (ue.getSsglbm() != null &&
|
|
|
+ * ue.getSsglbm().getId() != null &&
|
|
|
+ * ue.getSsglbm().getId().equals(gq.getSsgkglbm().getId())) {
|
|
|
+ * tuisong(" 您收到一条提醒", entity.getSsjyr().getGkjyr() + "的单船申报", 7,
|
|
|
+ * ue.getWeixinid(), entity.getId(), true); } } } }
|
|
|
+ *
|
|
|
+ * }
|
|
|
+ */
|
|
|
}
|
|
|
return entity;
|
|
|
|
|
@@ -207,16 +205,111 @@ public class DcsbServiceImpl extends BaseWorkFlowServiceImpl<DcsbEntity, String>
|
|
|
return dao.findDcsb(szdid);
|
|
|
}
|
|
|
|
|
|
+ @SuppressWarnings("unchecked")
|
|
|
@Override
|
|
|
public List<Object> tongjiproValue(String startDate, String endDate, String hwzl, String nwmid, String szdid, String szgkid, String szgqid, String jcgid, String dedlid) {
|
|
|
+ Map<String, Object> params = new HashMap<String, Object>();
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
+ sb.append("select count(tw.id) sbsl,tg.gkmc, round(sum(tw.zysl / 10000), 4) sum ");
|
|
|
+ sb.append(" from GK_OPERATION_JSJY_DCSB tw left join GK_BASIC_JSJY_GK_GK tg on tw.szgk = tg.id ");
|
|
|
+ sb.append(" where tw.RECORD_STATUS !=9 ");
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(startDate)) {
|
|
|
+ sb.append(" and to_char(tw.bgsj, 'yyyy-mm-dd') >= :startDate ");
|
|
|
+ params.put("startDate", startDate);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(endDate)) {
|
|
|
+ sb.append(" and to_char(tw.bgsj, 'yyyy-mm-dd') <= :endDate ");
|
|
|
+ params.put("endDate", endDate);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(hwzl)) {
|
|
|
+ sb.append(" and tw.hwzl = :hwzl");
|
|
|
+ params.put("hwzl", hwzl);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(nwmid)) {
|
|
|
+ sb.append(" and tw.nwm = :nwmid");
|
|
|
+ params.put("nwmid", nwmid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szdid)) {
|
|
|
+ sb.append(" and tw.szd = :szd");
|
|
|
+ params.put("szd", szdid);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(szgkid)) {
|
|
|
+ sb.append(" and tw.szgk = :szgk");
|
|
|
+ params.put("szgk", szgkid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szgqid)) {
|
|
|
+ sb.append(" and tw.szgq = :szgq");
|
|
|
+ params.put("szgq", szgqid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(jcgid)) {
|
|
|
+ sb.append(" and tw.jcg = :jcg");
|
|
|
+ params.put("jcg", jcgid);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(dedlid)) {
|
|
|
+ sb.append(" and tw.hwzldedl = :hwzldedl");
|
|
|
+ params.put("hwzldedl", dedlid);
|
|
|
+ }
|
|
|
+ sb.append(" group by tg.gkmc ");
|
|
|
+ System.out.println(sb.toString());
|
|
|
+ return (List<Object>) dao.nativeQuery(sb.toString(), params);
|
|
|
|
|
|
- return dao.tongjiproValue(startDate, endDate, hwzl, nwmid, szdid, szgkid, szgqid, jcgid, dedlid);
|
|
|
}
|
|
|
|
|
|
+ @SuppressWarnings("unchecked")
|
|
|
@Override
|
|
|
public List<Object> tongjicityValue(String startDate, String endDate, String hwzl, String nwmid, String szdid, String szgkid, String szgqid, String jcgid, String dedlid) {
|
|
|
+ Map<String, Object> params = new HashMap<String, Object>();
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
+ sb.append("select count(tw.id) sbsl,tg.gqmc, round(sum(tw.zysl / 10000), 4) sum ");
|
|
|
+ sb.append(" from GK_OPERATION_JSJY_DCSB tw left join GK_BASIC_JSJY_GK_GQ tg on tw.szgq = tg.id ");
|
|
|
+ sb.append(" where tw.RECORD_STATUS !=9 ");
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(startDate)) {
|
|
|
+ sb.append(" and to_char(tw.bgsj, 'yyyy-mm-dd') >= :startDate ");
|
|
|
+ params.put("startDate", startDate);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(endDate)) {
|
|
|
+ sb.append(" and to_char(tw.bgsj, 'yyyy-mm-dd') <= :endDate ");
|
|
|
+ params.put("endDate", endDate);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(hwzl)) {
|
|
|
+ sb.append(" and tw.hwzl = :hwzl");
|
|
|
+ params.put("hwzl", hwzl);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(nwmid)) {
|
|
|
+ sb.append(" and tw.nwm = :nwmid");
|
|
|
+ params.put("nwmid", nwmid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szdid)) {
|
|
|
+ sb.append(" and tw.szd = :szd");
|
|
|
+ params.put("szd", szdid);
|
|
|
+ }
|
|
|
|
|
|
- return dao.tongjicityValue(startDate, endDate, hwzl, nwmid, szdid, szgkid, szgqid, jcgid, dedlid);
|
|
|
+ if (!StringUtils.isEmpty(szgkid)) {
|
|
|
+ sb.append(" and tw.szgk = :szgk");
|
|
|
+ params.put("szgk", szgkid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szgqid)) {
|
|
|
+ sb.append(" and tw.szgq = :szgq");
|
|
|
+ params.put("szgq", szgqid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(jcgid)) {
|
|
|
+ sb.append(" and tw.jcg = :jcg");
|
|
|
+ params.put("jcg", jcgid);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(dedlid)) {
|
|
|
+ sb.append(" and tw.hwzldedl = :hwzldedl");
|
|
|
+ params.put("hwzldedl", dedlid);
|
|
|
+ }
|
|
|
+ sb.append(" group by tg.gqmc ");
|
|
|
+ System.out.println(sb.toString());
|
|
|
+ return (List<Object>) dao.nativeQuery(sb.toString(), params);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -263,14 +356,109 @@ public class DcsbServiceImpl extends BaseWorkFlowServiceImpl<DcsbEntity, String>
|
|
|
return dao.hwttltbmt(hwzlid, startDate, szdid, szgkid, szgqid, sfdwkf);
|
|
|
}
|
|
|
|
|
|
+ @SuppressWarnings("unchecked")
|
|
|
@Override
|
|
|
public List<Object> dcsbtjbg(String sTime, String eTime, String hwzl, String nwmid, String szdid, String szgkid, String szgqid, String jcgid) {
|
|
|
- return dao.dcsbtjbg(sTime, eTime, hwzl, nwmid, szdid, szgkid, szgqid, jcgid);
|
|
|
+ Map<String, Object> params = new HashMap<String, Object>();
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
+ sb.append("select text,a.jgnm,a.jgwm,a.cgnm,a.cgwm from GK_OPERATION_JSJY_CODE c ");
|
|
|
+ sb.append(" left join ( select d.hwzl,sum(case when (d.jcg = '5701' and d.nwm = '5601') then d.zysl end) as jgnm, ");
|
|
|
+ sb.append(" sum(case when (d.jcg = '5701' and d.nwm = '5602') then d.zysl end) as jgwm, ");
|
|
|
+ sb.append(" sum(case when (d.jcg = '5702' and d.nwm = '5601') then d.zysl end) as cgnm, ");
|
|
|
+ sb.append(" sum(case when (d.jcg = '5702' and d.nwm = '5602') then d.zysl end) as cgwm ");
|
|
|
+ sb.append(" from GK_OPERATION_JSJY_DCSB d where d.record_status != 9 ");
|
|
|
+ if (!StringUtils.isEmpty(sTime)) {
|
|
|
+ sb.append(" and to_char(d.bgsj, 'yyyy-mm-dd') >= :sTime ");
|
|
|
+ params.put("sTime", sTime);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(eTime)) {
|
|
|
+ sb.append(" and to_char(d.bgsj, 'yyyy-mm-dd') <= :eTime ");
|
|
|
+ params.put("eTime", eTime);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(hwzl)) {
|
|
|
+ sb.append(" and d.hwzl = :hwzl");
|
|
|
+ params.put("hwzl", hwzl);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(nwmid)) {
|
|
|
+ sb.append(" and d.nwm = :nwmid");
|
|
|
+ params.put("nwmid", nwmid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szdid)) {
|
|
|
+ sb.append(" and d.szd = :szd");
|
|
|
+ params.put("szd", szdid);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(szgkid)) {
|
|
|
+ sb.append(" and d.szgk = :szgk");
|
|
|
+ params.put("szgk", szgkid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szgqid)) {
|
|
|
+ sb.append(" and d.szgq = :szgq");
|
|
|
+ params.put("szgq", szgqid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(jcgid)) {
|
|
|
+ sb.append(" and d.jcg = :jcg");
|
|
|
+ params.put("jcg", jcgid);
|
|
|
+ }
|
|
|
+ sb.append(" group by d.hwzl) a on a.hwzl =c.id where c.pid = 72 order by c.id ");
|
|
|
+ System.out.println(sb.toString());
|
|
|
+ return (List<Object>) dao.nativeQuery(sb.toString(), params);
|
|
|
}
|
|
|
|
|
|
+ @SuppressWarnings("unchecked")
|
|
|
@Override
|
|
|
public List<Object> dcsbtjbg2(String sTime, String eTime, String hwzldedl, String nwmid, String szdid, String szgkid, String szgqid, String jcgid) {
|
|
|
- return dao.dcsbtjbg2(sTime, eTime, hwzldedl, nwmid, szdid, szgkid, szgqid, jcgid);
|
|
|
+ Map<String, Object> params = new HashMap<String, Object>();
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
+ sb.append("select text,a.jgnm,a.jgwm,a.cgnm,a.cgwm from GK_OPERATION_JSJY_CODE c ");
|
|
|
+ sb.append(" left join ( select d.hwzldedl,sum(case when (d.jcg = '5701' and d.nwm = '5601') then d.zysl end) as jgnm, ");
|
|
|
+ sb.append(" sum(case when (d.jcg = '5701' and d.nwm = '5602') then d.zysl end) as jgwm, ");
|
|
|
+ sb.append(" sum(case when (d.jcg = '5702' and d.nwm = '5601') then d.zysl end) as cgnm, ");
|
|
|
+ sb.append(" sum(case when (d.jcg = '5702' and d.nwm = '5602') then d.zysl end) as cgwm ");
|
|
|
+ sb.append(" from GK_OPERATION_JSJY_DCSB d where d.record_status != 9 ");
|
|
|
+ if (!StringUtils.isEmpty(sTime)) {
|
|
|
+ sb.append(" and to_char(d.bgsj, 'yyyy-mm-dd') >= :sTime ");
|
|
|
+ params.put("sTime", sTime);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(eTime)) {
|
|
|
+ sb.append(" and to_char(d.bgsj, 'yyyy-mm-dd') <= :eTime ");
|
|
|
+ params.put("eTime", eTime);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(hwzldedl)) {
|
|
|
+ sb.append(" and d.hwzldedl = :hwzldedl");
|
|
|
+ params.put("hwzldedl", hwzldedl);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(nwmid)) {
|
|
|
+ sb.append(" and d.nwm = :nwmid");
|
|
|
+ params.put("nwmid", nwmid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szdid)) {
|
|
|
+ sb.append(" and d.szd = :szd");
|
|
|
+ params.put("szd", szdid);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!StringUtils.isEmpty(szgkid)) {
|
|
|
+ sb.append(" and d.szgk = :szgk");
|
|
|
+ params.put("szgk", szgkid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(szgqid)) {
|
|
|
+ sb.append(" and d.szgq = :szgq");
|
|
|
+ params.put("szgq", szgqid);
|
|
|
+ }
|
|
|
+ if (!StringUtils.isEmpty(jcgid)) {
|
|
|
+ sb.append(" and d.jcg = :jcg");
|
|
|
+ params.put("jcg", jcgid);
|
|
|
+ }
|
|
|
+ sb.append(" group by d.hwzldedl) a on a.hwzldedl =c.id ");
|
|
|
+ sb.append(" where c.pid = 7201 or c.pid = 7202 or c.pid = 7203 ");
|
|
|
+ sb.append(" or c.pid = 7204 or c.pid = 7205 or c.pid = 7206 ");
|
|
|
+ sb.append(" or c.pid = 7207 or c.pid = 7208 or c.pid = 7209 ");
|
|
|
+ sb.append(" or c.pid = 7210 or c.pid = 7211 or c.pid = 7212 ");
|
|
|
+ sb.append(" or c.pid = 7213 or c.pid = 7214 or c.pid = 7215 ");
|
|
|
+ sb.append(" or c.pid = 7216 or c.pid = 7217 order by c.id ");
|
|
|
+ System.out.println(sb.toString());
|
|
|
+ return (List<Object>) dao.nativeQuery(sb.toString(), params);
|
|
|
+
|
|
|
}
|
|
|
|
|
|
// 参数顺序 标题,内容,微信应用id,微信id,业务key(PC端调用),查看or编辑页面
|
|
@@ -287,7 +475,7 @@ public class DcsbServiceImpl extends BaseWorkFlowServiceImpl<DcsbEntity, String>
|
|
|
sbf.append(URLEncoder.encode(("http://" + GlobalData.WEIXIN_IP + ":" + GlobalData.WEIXIN_PORT + "/weixinoa/mobile/dcsb/" + path + ".html?hname=db&isDone=1&id=" + busskey), "utf-8"));
|
|
|
sbf.append("&response_type=code&scope=snsapi_base&state=a#wechat_redirect");
|
|
|
String json = "{\"touser\": \"" + weixinid + "\",\"toparty\": \"" + "" + "\"" + ",\"totag\": \"\",\"msgtype\": \"text\",\"agentid\": \"" + agentid + "\",\"text\": {\"content\": \"" + content + ",<a href='" + sbf.toString() + "'>点击查看</a>" + "\"},\"safe\":\"0\"}";
|
|
|
- System.out.println("@@@@"+json);
|
|
|
+ System.out.println("@@@@" + json);
|
|
|
sendWxmsg(json);
|
|
|
} catch (Exception e) {
|
|
|
flag = false;
|
|
@@ -426,7 +614,7 @@ public class DcsbServiceImpl extends BaseWorkFlowServiceImpl<DcsbEntity, String>
|
|
|
// TODO Auto-generated method stub
|
|
|
return dao.findByJyrid(jyrid);
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
@Override
|
|
|
public List<Object> findByGqids(List<String> gqids) {
|
|
|
// TODO Auto-generated method stub
|