|
@@ -8,13 +8,10 @@ import java.text.SimpleDateFormat;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Calendar;
|
|
|
import java.util.Collection;
|
|
|
-import java.util.Collections;
|
|
|
-import java.util.Comparator;
|
|
|
import java.util.Date;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
-import java.util.Set;
|
|
|
|
|
|
import javax.persistence.criteria.CriteriaBuilder;
|
|
|
import javax.persistence.criteria.CriteriaQuery;
|
|
@@ -45,6 +42,8 @@ import org.springframework.web.bind.annotation.RequestMethod;
|
|
|
import org.springframework.web.bind.annotation.RequestParam;
|
|
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
|
|
|
|
+import com.jtgh.cjhs.entity.DtywCbsbEntity;
|
|
|
+import com.jtgh.cjhs.service.DtywCbsbService;
|
|
|
import com.jtgh.yjpt.anon.Log;
|
|
|
import com.jtgh.yjpt.anon.Log.Type;
|
|
|
import com.jtgh.yjpt.client.zysqbp.ZysqbpWebService;
|
|
@@ -66,13 +65,15 @@ import com.jtgh.yjpt.dao.task.GztxDao;
|
|
|
import com.jtgh.yjpt.dao.zysqbp.ZysqbpBgDao;
|
|
|
import com.jtgh.yjpt.entity.BaseEntity;
|
|
|
import com.jtgh.yjpt.entity.auth.UserEntity;
|
|
|
+import com.jtgh.yjpt.entity.cjhs.CjhsDbEntity;
|
|
|
+import com.jtgh.yjpt.entity.cjhs.CjhsEntity;
|
|
|
+import com.jtgh.yjpt.entity.cjhs.CjhsHwEntity;
|
|
|
import com.jtgh.yjpt.entity.common.AccessoryEntity;
|
|
|
import com.jtgh.yjpt.entity.common.CodeEntity;
|
|
|
import com.jtgh.yjpt.entity.common.TaskInfoEntity;
|
|
|
import com.jtgh.yjpt.entity.gg.GgEntity;
|
|
|
import com.jtgh.yjpt.entity.gkgq.GqEntity;
|
|
|
import com.jtgh.yjpt.entity.hs.ZysqbpHsEntity;
|
|
|
-import com.jtgh.yjpt.entity.hs.ZysqbphsdbEntity;
|
|
|
import com.jtgh.yjpt.entity.jyr.BwEntity;
|
|
|
import com.jtgh.yjpt.entity.jyr.JyrEntity;
|
|
|
import com.jtgh.yjpt.entity.jyr.JyrNsEntity;
|
|
@@ -85,11 +86,13 @@ import com.jtgh.yjpt.entity.zysqbp.ZysqbpCountEntity;
|
|
|
import com.jtgh.yjpt.entity.zysqbp.ZysqbpCountEntity1;
|
|
|
import com.jtgh.yjpt.entity.zysqbp.ZysqbpEntity;
|
|
|
import com.jtgh.yjpt.entity.zysqbp.ZysqbpGatherEntity;
|
|
|
+import com.jtgh.yjpt.service.cjhs.CjhsDbService;
|
|
|
+import com.jtgh.yjpt.service.cjhs.CjhsService;
|
|
|
+import com.jtgh.yjpt.service.cjhs.GkToCjhsService;
|
|
|
import com.jtgh.yjpt.service.common.AccessoryService;
|
|
|
import com.jtgh.yjpt.service.common.CodeService;
|
|
|
import com.jtgh.yjpt.service.common.WorkflowMangerService;
|
|
|
import com.jtgh.yjpt.service.gkgq.GqService;
|
|
|
-import com.jtgh.yjpt.service.hs.HsCompareService;
|
|
|
import com.jtgh.yjpt.service.jyr.BwService;
|
|
|
import com.jtgh.yjpt.service.jyr.CkService;
|
|
|
import com.jtgh.yjpt.service.jyr.DcService;
|
|
@@ -152,10 +155,19 @@ public class ZysqbpController extends BaseController {
|
|
|
private GztxDao gztxDao;
|
|
|
@Autowired
|
|
|
private WxhwpmService wxhwpmService;
|
|
|
- @Autowired
|
|
|
- private HsCompareService compareService;
|
|
|
+ /*
|
|
|
+ * @Autowired private HsCompareService compareService;
|
|
|
+ */
|
|
|
@Autowired
|
|
|
private JyrNsService nsService;
|
|
|
+ @Autowired
|
|
|
+ private CjhsService cjhsService;
|
|
|
+ @Autowired
|
|
|
+ private CjhsDbService cjhsDbService;
|
|
|
+ @Autowired
|
|
|
+ private DtywCbsbService dtywCbsbService;
|
|
|
+ @Autowired
|
|
|
+ private GkToCjhsService gkToCjhsService;
|
|
|
|
|
|
/**
|
|
|
* 查询统计
|
|
@@ -184,7 +196,7 @@ public class ZysqbpController extends BaseController {
|
|
|
*/
|
|
|
public BusinessContext compare(ZysqbpEntity vo) {
|
|
|
try {
|
|
|
-// compareService.doCompare(vo.getId().toString());
|
|
|
+ // compareService.doCompare(vo.getId().toString());
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return createBusinessContext("msg.fail", true);
|
|
@@ -194,11 +206,13 @@ public class ZysqbpController extends BaseController {
|
|
|
|
|
|
/**
|
|
|
* 一览页面
|
|
|
+ *
|
|
|
* @param pageable
|
|
|
* @param functionId
|
|
|
* @param entity
|
|
|
* @param lcStatus
|
|
|
- * @param bgsj1 报告时间起
|
|
|
+ * @param bgsj1
|
|
|
+ * 报告时间起
|
|
|
* @param bgsj2报告时间止
|
|
|
* @param kgsj1开工时间起
|
|
|
* @param kgsj2开工时间止
|
|
@@ -210,7 +224,7 @@ public class ZysqbpController extends BaseController {
|
|
|
public BusinessContext list(Pageable pageable, final Long functionId,
|
|
|
final ZysqbpEntity entity, final String lcStatus, final Date bgsj1,
|
|
|
final Date bgsj2, final Date kgsj1, final Date kgsj2,
|
|
|
- final Date wgsj1, final Date wgsj2,final CodeEntity zs) {
|
|
|
+ final Date wgsj1, final Date wgsj2, final CodeEntity zs) {
|
|
|
BusinessContext bc = new BusinessContext();
|
|
|
List<PredicateModel> filterList = new ArrayList<PredicateModel>();
|
|
|
try {
|
|
@@ -225,7 +239,8 @@ public class ZysqbpController extends BaseController {
|
|
|
list.add(cb.notEqual(
|
|
|
root.get("recordStatus").as(String.class),
|
|
|
BaseEntity.RECORD_STATE_DELETE));
|
|
|
- if (BaseEntity.RECORD_STATE_DELETE != entity.getRecordStatus()) {
|
|
|
+ if (BaseEntity.RECORD_STATE_DELETE != entity
|
|
|
+ .getRecordStatus()) {
|
|
|
list.add(cb.equal(
|
|
|
root.get("recordStatus").as(String.class),
|
|
|
String.valueOf(entity.getRecordStatus())));
|
|
@@ -256,8 +271,9 @@ public class ZysqbpController extends BaseController {
|
|
|
root.get("szd").get("id").as(String.class),
|
|
|
entity.getSzd().getId() + "%"));
|
|
|
if (null != zs)
|
|
|
- list.add(cb.equal(
|
|
|
- root.get("zydw").get("zs").as(CodeEntity.class),zs));
|
|
|
+ list.add(cb
|
|
|
+ .equal(root.get("zydw").get("zs")
|
|
|
+ .as(CodeEntity.class), zs));
|
|
|
if (null != entity.getSzgq())
|
|
|
list.add(cb.equal(root.get("szgq").as(GqEntity.class),
|
|
|
entity.getSzgq()));
|
|
@@ -360,9 +376,10 @@ public class ZysqbpController extends BaseController {
|
|
|
return null;
|
|
|
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
/**
|
|
|
* 打印
|
|
|
+ *
|
|
|
* @param id
|
|
|
* @param type
|
|
|
* @param response
|
|
@@ -610,9 +627,9 @@ public class ZysqbpController extends BaseController {
|
|
|
param.get(15) + ""));
|
|
|
}
|
|
|
if (!"".equals(param.get(16))) {
|
|
|
- list.add(cb.equal(
|
|
|
- root.get("zydw").get("zs").get("id").as(Long.class),
|
|
|
- Long.parseLong(param.get(16)+"")));
|
|
|
+ list.add(cb.equal(root.get("zydw").get("zs").get("id")
|
|
|
+ .as(Long.class),
|
|
|
+ Long.parseLong(param.get(16) + "")));
|
|
|
}
|
|
|
if (Constants.YES.equals(Utils.getCurrentUser().getSfcd())) {
|
|
|
list.add(cb.equal(
|
|
@@ -714,7 +731,8 @@ public class ZysqbpController extends BaseController {
|
|
|
.getBgsj()),
|
|
|
entity.getWxwpmc(),
|
|
|
mao,
|
|
|
- null == entity.getSzd() ? "" :entity.getSzd().getName(),
|
|
|
+ null == entity.getSzd() ? "" : entity.getSzd()
|
|
|
+ .getName(),
|
|
|
null == entity.getSzgq() ? "" : entity.getSzgq()
|
|
|
.getGqmc(),
|
|
|
null == entity.getKgsj() ? "" : sdf.format(entity
|
|
@@ -736,7 +754,8 @@ public class ZysqbpController extends BaseController {
|
|
|
.getBgsj()),
|
|
|
entity.getWxhwmcbh(),
|
|
|
mao,
|
|
|
- null == entity.getSzd() ? "" : entity.getSzd().getName(),
|
|
|
+ null == entity.getSzd() ? "" : entity.getSzd()
|
|
|
+ .getName(),
|
|
|
null == entity.getSzgq() ? "" : entity.getSzgq()
|
|
|
.getGqmc(),
|
|
|
null == entity.getKgsj() ? "" : sdf.format(entity
|
|
@@ -1270,6 +1289,7 @@ public class ZysqbpController extends BaseController {
|
|
|
}
|
|
|
entity2.setBh(entity.getBh());
|
|
|
zysqbpService.save(entity2);
|
|
|
+ gkToCjhsService.saveData(entity2);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -1300,7 +1320,7 @@ public class ZysqbpController extends BaseController {
|
|
|
public BusinessContext doCompare(ZysqbpEntity entity) {
|
|
|
BusinessContext bc = createBusinessContext();
|
|
|
if (Constants.GGDM_ID_ZYDD_BW.equals(entity.getZydd().getId())) {
|
|
|
- // entity = compareService.doCompare(entity.getId().toString());
|
|
|
+ // entity = compareService.doCompare(entity.getId().toString());
|
|
|
}
|
|
|
bc.setResult(entity);
|
|
|
return bc;
|
|
@@ -1308,9 +1328,10 @@ public class ZysqbpController extends BaseController {
|
|
|
|
|
|
public BusinessContext doViewInit(Long id) {
|
|
|
ZysqbpEntity vo = zysqbpService.findOne(id);
|
|
|
- if (Constants.GGDM_ID_ZYDD_BW.equals(vo.getZydd().getId())) {
|
|
|
- vo = compareService.doCompare(vo.getId().toString());
|
|
|
- }
|
|
|
+ /*
|
|
|
+ * if (Constants.GGDM_ID_ZYDD_BW.equals(vo.getZydd().getId())) { vo =
|
|
|
+ * compareService.doCompare(vo.getId().toString()); }
|
|
|
+ */
|
|
|
BusinessContext bc = createBusinessContext();
|
|
|
bc.setResult(vo);
|
|
|
// 附件查询
|
|
@@ -1327,6 +1348,7 @@ public class ZysqbpController extends BaseController {
|
|
|
List<AccessoryEntity> acc = accessoryService.findAll(accSpec);
|
|
|
if (acc != null && acc.size() > 0)
|
|
|
vo.setAccessory(acc.get(0));
|
|
|
+
|
|
|
return bc;
|
|
|
}
|
|
|
|
|
@@ -1791,9 +1813,8 @@ public class ZysqbpController extends BaseController {
|
|
|
if (szd.equals(0l))
|
|
|
PoiUtils.setCellValue(st0, 1, 1, "湖北省危险货物作业情况汇总表");
|
|
|
else
|
|
|
- PoiUtils.setCellValue(st0, 1, 1,
|
|
|
- codeService.findOne(szd).getName()
|
|
|
- + "危险货物作业情况汇总表");
|
|
|
+ PoiUtils.setCellValue(st0, 1, 1, codeService.findOne(szd)
|
|
|
+ .getName() + "危险货物作业情况汇总表");
|
|
|
PoiUtils.setCellValue(st0, 2, 10, sdf.format(new Date()));
|
|
|
PoiUtils.setCellValue(st0, 3, 2, e.getGkwhqys() + "个");
|
|
|
PoiUtils.setCellValue(st0, 3, 4, e.getYfxkz() + "个");
|
|
@@ -2115,6 +2136,7 @@ public class ZysqbpController extends BaseController {
|
|
|
// 发工作提醒
|
|
|
setGztx("你单位" + sdf.format(entity.getUpdateDate())
|
|
|
+ "提交的取消作业申请已审核未通过", entity1.getAddUser());
|
|
|
+ gkToCjhsService.saveData(entity1);
|
|
|
} else {// 取消通过,流程结束,数据状态改为6,设置取消作业时间,
|
|
|
ZysqbpEntity entity2 = zysqbpService.findOne(entity.getId());
|
|
|
entity2.setRecordStatus(ZysqbpEntity.RECORD_STATE_QXCOMPLETED);
|
|
@@ -2125,6 +2147,7 @@ public class ZysqbpController extends BaseController {
|
|
|
entity2 = zysqbpService.save(entity2);
|
|
|
setGztx("你单位" + sdf.format(entity.getUpdateDate())
|
|
|
+ "提交的取消作业申请已审核通过", entity2.getAddUser());
|
|
|
+ gkToCjhsService.saveData(entity2);
|
|
|
}
|
|
|
|
|
|
}
|
|
@@ -2170,6 +2193,8 @@ public class ZysqbpController extends BaseController {
|
|
|
entity1 = zysqbpService.save(entity1);
|
|
|
setGztx("你单位" + sdf.format(bgvo.getAddDate()) + "申请的作业变更已审核未通过",
|
|
|
entity1.getAddUser());
|
|
|
+ //同步海事
|
|
|
+ gkToCjhsService.saveData(entity1);
|
|
|
} else {// 变更通过,流程结束,数据状态改为10,替换新数据
|
|
|
ZysqbpEntity entity2 = zysqbpService.findOne(entity.getId());
|
|
|
entity2.setRecordStatus(ZysqbpEntity.RECORD_STATE_BGCOMPLETED);
|
|
@@ -2184,6 +2209,8 @@ public class ZysqbpController extends BaseController {
|
|
|
// 发工作提醒
|
|
|
setGztx("你单位" + sdf.format(bgvo.getAddDate()) + "申请的作业变更审核通过",
|
|
|
entity2.getAddUser());
|
|
|
+ //同步海事
|
|
|
+ gkToCjhsService.saveData(entity2);
|
|
|
}
|
|
|
|
|
|
}
|
|
@@ -2234,55 +2261,23 @@ public class ZysqbpController extends BaseController {
|
|
|
* @param id
|
|
|
* @return
|
|
|
*/
|
|
|
- public BusinessContext queryDb(Long id) {
|
|
|
- List<ZysqbphsdbEntity> list = new ArrayList<ZysqbphsdbEntity>();
|
|
|
- Map<String, Map<String, String>> map = compareService.mergeInfo(id);
|
|
|
- if (map == null) {
|
|
|
- return creaBusinessContext(list);
|
|
|
- }
|
|
|
- Set<String> set = map.keySet();
|
|
|
- if (set != null && set.size() > 0) {
|
|
|
- for (String str : set) {
|
|
|
- ZysqbphsdbEntity temp = new ZysqbphsdbEntity();
|
|
|
- temp.setName(str);
|
|
|
- temp.setGkj(map.get(str).get("GK"));
|
|
|
- temp.setHs(map.get(str).get("HS"));
|
|
|
- temp.setZt(map.get(str).get("ZT"));
|
|
|
- String xh = map.get(str).get("XH");
|
|
|
- if (org.springframework.util.StringUtils.hasText(xh)) {
|
|
|
- temp.setXh(new Integer(xh));
|
|
|
- } else {
|
|
|
- temp.setXh(Integer.MAX_VALUE);
|
|
|
- }
|
|
|
- list.add(temp);
|
|
|
- }
|
|
|
- Collections.sort(list, new Comparator<ZysqbphsdbEntity>() {
|
|
|
-
|
|
|
- @Override
|
|
|
- public int compare(ZysqbphsdbEntity o1, ZysqbphsdbEntity o2) {
|
|
|
- return o1.getXh().compareTo(o2.getXh());
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
- /**
|
|
|
- * 这边暂时用的测试数据,数据库有数据时,将下面的注释掉的代码放开,test里的去掉
|
|
|
- */
|
|
|
- // test=============================
|
|
|
- // ZysqbphsdbEntity temp = new ZysqbphsdbEntity();
|
|
|
- // temp.setName("危险品");
|
|
|
- // temp.setGkj("23");
|
|
|
- // temp.setHs("32");
|
|
|
- // temp.setZt(HsCompareService.ZC);
|
|
|
- // list.add(temp);
|
|
|
- // ZysqbphsdbEntity temp2 = new ZysqbphsdbEntity();
|
|
|
- // temp2.setName("总重量");
|
|
|
- // temp2.setGkj("23");
|
|
|
- // temp2.setHs("32");
|
|
|
- // temp2.setZt(HsCompareService.YC);
|
|
|
- // list.add(temp2);
|
|
|
- // =====test end=====
|
|
|
- return creaBusinessContext(list);
|
|
|
- }
|
|
|
+ /*
|
|
|
+ * public BusinessContext queryDb(Long id) { List<ZysqbphsdbEntity> list =
|
|
|
+ * new ArrayList<ZysqbphsdbEntity>(); Map<String, Map<String, String>> map =
|
|
|
+ * compareService.mergeInfo(id); if (map == null) { return
|
|
|
+ * creaBusinessContext(list); } Set<String> set = map.keySet(); if (set !=
|
|
|
+ * null && set.size() > 0) { for (String str : set) { ZysqbphsdbEntity temp
|
|
|
+ * = new ZysqbphsdbEntity(); temp.setName(str);
|
|
|
+ * temp.setGkj(map.get(str).get("GK")); temp.setHs(map.get(str).get("HS"));
|
|
|
+ * temp.setZt(map.get(str).get("ZT")); String xh = map.get(str).get("XH");
|
|
|
+ * if (org.springframework.util.StringUtils.hasText(xh)) { temp.setXh(new
|
|
|
+ * Integer(xh)); } else { temp.setXh(Integer.MAX_VALUE); } list.add(temp); }
|
|
|
+ * Collections.sort(list, new Comparator<ZysqbphsdbEntity>() {
|
|
|
+ *
|
|
|
+ * @Override public int compare(ZysqbphsdbEntity o1, ZysqbphsdbEntity o2) {
|
|
|
+ * return o1.getXh().compareTo(o2.getXh()); } }); } // =====test end=====
|
|
|
+ * return creaBusinessContext(list); }
|
|
|
+ */
|
|
|
|
|
|
/**
|
|
|
* 海事申报结果详细
|
|
@@ -2359,9 +2354,10 @@ public class ZysqbpController extends BaseController {
|
|
|
Page<ZysqbpEntity> pageList = zysqbpService.findAll(spec, pageable);
|
|
|
for (ZysqbpEntity vo : pageList) {
|
|
|
// 如果比对结果条件为空,重新比对
|
|
|
- if (StringUtils.isEmpty(dbStatus)) {
|
|
|
- vo = compareService.doCompare(vo.getId().toString());
|
|
|
- }
|
|
|
+ /*
|
|
|
+ * if (StringUtils.isEmpty(dbStatus)) { vo =
|
|
|
+ * compareService.doCompare(vo.getId().toString()); }
|
|
|
+ */
|
|
|
// 检索附件
|
|
|
filterList = new ArrayList<PredicateModel>();
|
|
|
addNotEmptyModel(filterList, "entityType.id",
|
|
@@ -2410,7 +2406,7 @@ public class ZysqbpController extends BaseController {
|
|
|
*/
|
|
|
public BusinessContext queryGkList(ASObject param) {
|
|
|
List<ZysqbpHsEntity> list = new ArrayList<ZysqbpHsEntity>();
|
|
|
- list = compareService.findGkwpp(param);
|
|
|
+ /* list = compareService.findGkwpp(param); */
|
|
|
return creaBusinessContext(list);
|
|
|
}
|
|
|
|
|
@@ -2458,90 +2454,104 @@ public class ZysqbpController extends BaseController {
|
|
|
bc.setResult(accessoryService.save(accNew));
|
|
|
return bc;
|
|
|
}
|
|
|
-
|
|
|
- public BusinessContext findByGg(GgEntity ggEntity){
|
|
|
- BusinessContext bc = new BusinessContext();
|
|
|
- List<ZysqbpEntity> list = zysqbpService.getZysqbpListByBgsjAndCm(ggEntity.getAddDate(), ggEntity.getByzd3());
|
|
|
- if(list != null && list.size() >0){
|
|
|
- bc.setResult(list.get(0));
|
|
|
- }
|
|
|
- return bc;
|
|
|
+
|
|
|
+ public BusinessContext findByGg(GgEntity ggEntity) {
|
|
|
+ BusinessContext bc = new BusinessContext();
|
|
|
+ List<ZysqbpEntity> list = zysqbpService.getZysqbpListByBgsjAndCm(
|
|
|
+ ggEntity.getAddDate(), ggEntity.getByzd3());
|
|
|
+ if (list != null && list.size() > 0) {
|
|
|
+ bc.setResult(list.get(0));
|
|
|
+ }
|
|
|
+ return bc;
|
|
|
}
|
|
|
+
|
|
|
/*
|
|
|
- * 批量签章时,获取所要保护的数据
|
|
|
- * xh 2016.7.4
|
|
|
- * ( public String GetmSignatureData(@RequestParam String documentID,HttpSession session) )
|
|
|
+ * 批量签章时,获取所要保护的数据 xh 2016.7.4 ( public String
|
|
|
+ * GetmSignatureData(@RequestParam String documentID,HttpSession session) )
|
|
|
*/
|
|
|
@RequestMapping(value = "GetmSignatureData", method = RequestMethod.GET)
|
|
|
- @ResponseBody
|
|
|
- public String GetmSignatureData(@RequestParam String documentID){
|
|
|
+ @ResponseBody
|
|
|
+ public String GetmSignatureData(@RequestParam String documentID) {
|
|
|
ZysqbpEntity data = zysqbpService.findOne(Long.parseLong(documentID));
|
|
|
-
|
|
|
- String audit_user="",audit_date="",audit_op="";
|
|
|
- SimpleDateFormat myFmt=new SimpleDateFormat("yyyy-M-d");
|
|
|
- SimpleDateFormat myFmt2=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
-
|
|
|
- //审批信息
|
|
|
+
|
|
|
+ String audit_user = "", audit_date = "", audit_op = "";
|
|
|
+ SimpleDateFormat myFmt = new SimpleDateFormat("yyyy-M-d");
|
|
|
+ SimpleDateFormat myFmt2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+
|
|
|
+ // 审批信息
|
|
|
if (data.getTaskList() != null && data.getTaskList().size() > 0) {
|
|
|
for (TaskInfoEntity task : data.getTaskList()) {
|
|
|
if ("wf.sc".equals(task.getCurrName())) {
|
|
|
-// parameters.put("audit_user", task.getAuditUsername());
|
|
|
-// parameters.put("audit_date", task.getAuditTime());
|
|
|
-// parameters.put("audit_op", task.getAuditMsg());
|
|
|
-// parameters.put("audit_dept", task.getByzd2());
|
|
|
+ // parameters.put("audit_user", task.getAuditUsername());
|
|
|
+ // parameters.put("audit_date", task.getAuditTime());
|
|
|
+ // parameters.put("audit_op", task.getAuditMsg());
|
|
|
+ // parameters.put("audit_dept", task.getByzd2());
|
|
|
audit_user = task.getAuditUsername();
|
|
|
- if(task.getAuditTime()!=null)
|
|
|
+ if (task.getAuditTime() != null)
|
|
|
audit_date = myFmt.format(task.getAuditTime());
|
|
|
- audit_op = task.getAuditMsg();
|
|
|
+ audit_op = task.getAuditMsg();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
- String div = "\r\n";//分隔符
|
|
|
+
|
|
|
+ String div = "\r\n";// 分隔符
|
|
|
StringBuffer sb = new StringBuffer();
|
|
|
- sb.append("BH="+ ((data.getBh()==null)?"":data.getBh())+ div);
|
|
|
- sb.append("ZYDW="+((data.getZydw()==null)?"":data.getZydw().getGkjyr())+div);
|
|
|
- sb.append("ZYWTR="+((data.getZywtr()==null)?"":data.getZywtr())+div);
|
|
|
- sb.append("CM="+((data.getCm()==null)?"":data.getCm())+div);
|
|
|
- sb.append("XCGLFZR="+((data.getXcglfzr()==null)?"":data.getXcglfzr())+div);
|
|
|
- sb.append("WXHWMCBH="+((data.getWxhwmcbh()==null)?"":data.getWxhwmcbh())+div);
|
|
|
- sb.append("WPBH="+((data.getWpbh()==null)?"":data.getWpbh())+div);
|
|
|
- sb.append("WXPLB="+((data.getWxplb()==null)?"":data.getWxplb())+div);
|
|
|
- sb.append("BYZD4="+((data.getByzd4()==null)?"":data.getByzd4())+div);
|
|
|
-
|
|
|
- String inorout ="";
|
|
|
+ sb.append("BH=" + ((data.getBh() == null) ? "" : data.getBh()) + div);
|
|
|
+ sb.append("ZYDW="
|
|
|
+ + ((data.getZydw() == null) ? "" : data.getZydw().getGkjyr())
|
|
|
+ + div);
|
|
|
+ sb.append("ZYWTR=" + ((data.getZywtr() == null) ? "" : data.getZywtr())
|
|
|
+ + div);
|
|
|
+ sb.append("CM=" + ((data.getCm() == null) ? "" : data.getCm()) + div);
|
|
|
+ sb.append("XCGLFZR="
|
|
|
+ + ((data.getXcglfzr() == null) ? "" : data.getXcglfzr()) + div);
|
|
|
+ sb.append("WXHWMCBH="
|
|
|
+ + ((data.getWxhwmcbh() == null) ? "" : data.getWxhwmcbh())
|
|
|
+ + div);
|
|
|
+ sb.append("WPBH=" + ((data.getWpbh() == null) ? "" : data.getWpbh())
|
|
|
+ + div);
|
|
|
+ sb.append("WXPLB=" + ((data.getWxplb() == null) ? "" : data.getWxplb())
|
|
|
+ + div);
|
|
|
+ sb.append("BYZD4=" + ((data.getByzd4() == null) ? "" : data.getByzd4())
|
|
|
+ + div);
|
|
|
+
|
|
|
+ String inorout = "";
|
|
|
// 1进港/2出港
|
|
|
- if(data.getInorout().equals("1")){
|
|
|
+ if (data.getInorout().equals("1")) {
|
|
|
inorout = "进港";
|
|
|
+ } else if (data.getInorout().equals("2")) {
|
|
|
+ inorout = "出港";
|
|
|
}
|
|
|
- else if(data.getInorout().equals("2")){
|
|
|
- inorout="出港";
|
|
|
- }
|
|
|
- sb.append("INOROUT="+inorout+div);
|
|
|
-
|
|
|
- sb.append("ZYSL="+((data.getZysl()==null)?"":data.getZysl())+div);
|
|
|
- sb.append("SG="+((data.getSg()==null)?"":data.getSg())+div);
|
|
|
- sb.append("XG="+((data.getXg()==null)?"":data.getXg())+div);
|
|
|
-
|
|
|
- String mao="";
|
|
|
- //1内贸/2外贸
|
|
|
- if(data.getMao().equals("1")){
|
|
|
+ sb.append("INOROUT=" + inorout + div);
|
|
|
+
|
|
|
+ sb.append("ZYSL=" + ((data.getZysl() == null) ? "" : data.getZysl())
|
|
|
+ + div);
|
|
|
+ sb.append("SG=" + ((data.getSg() == null) ? "" : data.getSg()) + div);
|
|
|
+ sb.append("XG=" + ((data.getXg() == null) ? "" : data.getXg()) + div);
|
|
|
+
|
|
|
+ String mao = "";
|
|
|
+ // 1内贸/2外贸
|
|
|
+ if (data.getMao().equals("1")) {
|
|
|
mao = "内贸";
|
|
|
- }
|
|
|
- else if(data.getMao().equals("2")){
|
|
|
+ } else if (data.getMao().equals("2")) {
|
|
|
mao = "外贸 ";
|
|
|
}
|
|
|
- sb.append("MAO="+mao+div);
|
|
|
-
|
|
|
-
|
|
|
- sb.append("HZWXX="+(data.getHzwxx()==null?"": resource.getString(data.getHzwxx()))+div);
|
|
|
- sb.append("DXDJ="+((data.getDxdj()==null)?"":data.getDxdj())+div);
|
|
|
- sb.append("WRLB="+((data.getWrlb()==null)?"":data.getWrlb())+div);
|
|
|
- sb.append("JZXSL="+((data.getWrlb()==null)?"":data.getWrlb())+div);
|
|
|
- sb.append("HC="+((data.getHc()==null)?"":data.getHc())+div);
|
|
|
- sb.append("HWZL="+ (data.getHwzl()==null?"": resource.getString(data.getHwzl().getName()))+div);
|
|
|
-
|
|
|
+ sb.append("MAO=" + mao + div);
|
|
|
+
|
|
|
+ sb.append("HZWXX="
|
|
|
+ + (data.getHzwxx() == null ? "" : resource.getString(data
|
|
|
+ .getHzwxx())) + div);
|
|
|
+ sb.append("DXDJ=" + ((data.getDxdj() == null) ? "" : data.getDxdj())
|
|
|
+ + div);
|
|
|
+ sb.append("WRLB=" + ((data.getWrlb() == null) ? "" : data.getWrlb())
|
|
|
+ + div);
|
|
|
+ sb.append("JZXSL=" + ((data.getWrlb() == null) ? "" : data.getWrlb())
|
|
|
+ + div);
|
|
|
+ sb.append("HC=" + ((data.getHc() == null) ? "" : data.getHc()) + div);
|
|
|
+ sb.append("HWZL="
|
|
|
+ + (data.getHwzl() == null ? "" : resource.getString(data
|
|
|
+ .getHwzl().getName())) + div);
|
|
|
+
|
|
|
String hwxs = data.getHwxs();
|
|
|
String hwxs1 = "";
|
|
|
if (hwxs != null && hwxs != "") {
|
|
@@ -2629,34 +2639,149 @@ public class ZysqbpController extends BaseController {
|
|
|
}
|
|
|
hwxs1 = hwxs1.substring(0, hwxs1.length() - 1);
|
|
|
}
|
|
|
-
|
|
|
- sb.append("HWXS="+hwxs1+div);
|
|
|
- sb.append("LHXZ="+((data.getLhxz()==null)?"":data.getLhxz())+div);
|
|
|
-
|
|
|
- String zydd = ((data.getZydd()==null)?"":resource.getString(data.getZydd().getName()))+
|
|
|
- ((data.getZyddqybh()==null) ? "" : data.getZyddqybh().getQynbmc());
|
|
|
- sb.append("ZYDD="+zydd+div);
|
|
|
-
|
|
|
- sb.append("ZYSJQ="+((data.getZysjq()==null)?"":myFmt2.format(data.getZysjq()))+div);
|
|
|
- sb.append("ZYSJZ="+((data.getZysjz()==null)?"":myFmt2.format(data.getZysjz()))+div);
|
|
|
- sb.append("AQFFCS="+((data.getAqffcs()==null)?"":data.getAqffcs())+div);
|
|
|
- sb.append("BGR="+((data.getBgr()==null)?"":data.getBgr())+div);
|
|
|
- sb.append("LXFS="+((data.getLxfs()==null)?"":data.getLxfs())+div);
|
|
|
- sb.append("BGSJ="+((data.getBgsj()==null)?"":myFmt2.format(data.getBgsj()))+div);
|
|
|
- sb.append("BYZD2="+((data.getByzd2()==null)?"":data.getByzd2())+div);
|
|
|
-
|
|
|
- //审核意见
|
|
|
- sb.append("SHYJ="+audit_op+div);
|
|
|
- sb.append("SHR="+audit_user+div);
|
|
|
- sb.append("SHSJ="+audit_date+div);
|
|
|
-
|
|
|
-
|
|
|
- try {
|
|
|
- return java.net.URLEncoder.encode(sb.toString(),"gb2312");
|
|
|
- } catch (UnsupportedEncodingException e) {
|
|
|
+
|
|
|
+ sb.append("HWXS=" + hwxs1 + div);
|
|
|
+ sb.append("LHXZ=" + ((data.getLhxz() == null) ? "" : data.getLhxz())
|
|
|
+ + div);
|
|
|
+
|
|
|
+ String zydd = ((data.getZydd() == null) ? "" : resource.getString(data
|
|
|
+ .getZydd().getName()))
|
|
|
+ + ((data.getZyddqybh() == null) ? "" : data.getZyddqybh()
|
|
|
+ .getQynbmc());
|
|
|
+ sb.append("ZYDD=" + zydd + div);
|
|
|
+
|
|
|
+ sb.append("ZYSJQ="
|
|
|
+ + ((data.getZysjq() == null) ? "" : myFmt2.format(data
|
|
|
+ .getZysjq())) + div);
|
|
|
+ sb.append("ZYSJZ="
|
|
|
+ + ((data.getZysjz() == null) ? "" : myFmt2.format(data
|
|
|
+ .getZysjz())) + div);
|
|
|
+ sb.append("AQFFCS="
|
|
|
+ + ((data.getAqffcs() == null) ? "" : data.getAqffcs()) + div);
|
|
|
+ sb.append("BGR=" + ((data.getBgr() == null) ? "" : data.getBgr()) + div);
|
|
|
+ sb.append("LXFS=" + ((data.getLxfs() == null) ? "" : data.getLxfs())
|
|
|
+ + div);
|
|
|
+ sb.append("BGSJ="
|
|
|
+ + ((data.getBgsj() == null) ? ""
|
|
|
+ : myFmt2.format(data.getBgsj())) + div);
|
|
|
+ sb.append("BYZD2=" + ((data.getByzd2() == null) ? "" : data.getByzd2())
|
|
|
+ + div);
|
|
|
+
|
|
|
+ // 审核意见
|
|
|
+ sb.append("SHYJ=" + audit_op + div);
|
|
|
+ sb.append("SHR=" + audit_user + div);
|
|
|
+ sb.append("SHSJ=" + audit_date + div);
|
|
|
+
|
|
|
+ try {
|
|
|
+ return java.net.URLEncoder.encode(sb.toString(), "gb2312");
|
|
|
+ } catch (UnsupportedEncodingException e) {
|
|
|
e.printStackTrace();
|
|
|
- }
|
|
|
-
|
|
|
- return "error";
|
|
|
+ }
|
|
|
+
|
|
|
+ return "error";
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 初始化海事比对数据
|
|
|
+ *
|
|
|
+ * @param id
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public BusinessContext doCjhsInit(Long id) {
|
|
|
+ BusinessContext bc = createBusinessContext();
|
|
|
+ CjhsEntity cjhs = cjhsService.findCjhsByGksbbh(id);
|
|
|
+ List<CjhsHwEntity> cjhsHwList = cjhs.getHshwList();
|
|
|
+ List<CjhsHwEntity> list = new ArrayList<CjhsHwEntity>();
|
|
|
+ //货物总重量取和
|
|
|
+ if (cjhsHwList != null && cjhsHwList.size() > 0) {
|
|
|
+ CjhsHwEntity cjhsHw = cjhsHwList.get(0);
|
|
|
+ double zzl=0;
|
|
|
+ for (CjhsHwEntity hw : cjhsHwList) {
|
|
|
+ if (hw.getZqysmczw() != null
|
|
|
+ && hw.getZqysmczw().trim()
|
|
|
+ .equals(cjhsHw.getZqysmczw().trim())) {
|
|
|
+ zzl = zzl+ hw.getZzl();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ cjhsHw.setZzl(zzl);
|
|
|
+ list.add(cjhsHw);
|
|
|
+ }
|
|
|
+ bc.setResult(cjhs);
|
|
|
+ return bc;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 长江海事船舶申报单列表
|
|
|
+ *
|
|
|
+ * @param id
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public BusinessContext queryCjhsList(ZysqbpEntity zysqbp,Pageable pageable, Date ksq,
|
|
|
+ Date ksz, Date jsq, Date jsz, String zygk,
|
|
|
+ String cm) {
|
|
|
+ BusinessContext bc = new BusinessContext();
|
|
|
+ List<PredicateModel> filterList = new ArrayList<PredicateModel>();
|
|
|
+ ksq = Utils.getDateFirstTime(ksq);
|
|
|
+ ksz = Utils.getDateLastTime(ksz);
|
|
|
+ jsq = Utils.getDateFirstTime(jsq);
|
|
|
+ jsz = Utils.getDateLastTime(jsz);
|
|
|
+ addNotEmptyModel(filterList, "kszysj", ksq, Operator.GTE);
|
|
|
+ addNotEmptyModel(filterList, "kszysj", ksz, Operator.LTE);
|
|
|
+ addNotEmptyModel(filterList, "jszysj", jsq, Operator.GTE);
|
|
|
+ addNotEmptyModel(filterList, "jszysj", jsz, Operator.LTE);
|
|
|
+ addNotEmptyModel(filterList, "gkzwmc", zygk, Operator.LIKE);
|
|
|
+ addNotEmptyModel(filterList, "zwcm", cm, Operator.LIKE);
|
|
|
+ // 权限过滤
|
|
|
+ Specification<DtywCbsbEntity> spec = SpecificationCreater
|
|
|
+ .searchByPredicateModels(filterList);
|
|
|
+ SinglePageRequest page = new SinglePageRequest(pageable.getPageSize(),
|
|
|
+ pageable.getPageNumber(), "desc", "kszysj");
|
|
|
+ Page<DtywCbsbEntity> cbsbPageList = dtywCbsbService.findAll(spec, page);
|
|
|
+ List<CjhsEntity> cjhsList = new ArrayList<CjhsEntity>();
|
|
|
+ List<CjhsDbEntity> cjhsDbList = cjhsDbService.findByGksbbh(zysqbp
|
|
|
+ .getId());
|
|
|
+ for (DtywCbsbEntity cbsb : cbsbPageList) {
|
|
|
+ CjhsEntity cjhs = cjhsService.changeFromDtywCbsbNoHw(cbsb);
|
|
|
+ if (cjhsDbList != null && cjhsDbList.size() > 0) {
|
|
|
+ CjhsDbEntity Db = cjhsDbList.get(0);
|
|
|
+ if (Db.getHssbbh().equals(cjhs.getSbdbh())) {
|
|
|
+ cjhs.setSfpp("Y");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ cjhsList.add(cjhs);
|
|
|
+ }
|
|
|
+ bc.setAttribute("list", cjhsList);
|
|
|
+ bc.setAttribute("totalCount", 0);
|
|
|
+ if (cbsbPageList != null) {
|
|
|
+ bc.setAttribute("totalCount", cbsbPageList.getTotalElements());
|
|
|
+ }
|
|
|
+ return bc;
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 长江海事货物信息
|
|
|
+ *
|
|
|
+ * @param id
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public BusinessContext queryCjhsHwList(String hssbbh,ZysqbpEntity zysqbp) {
|
|
|
+ BusinessContext bc = new BusinessContext();
|
|
|
+ bc.setAttribute("list", cjhsService.findCjhsHwListByHssbbh(zysqbp,hssbbh));
|
|
|
+ return bc;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 保存比对结果
|
|
|
+ * @param entity 海事货物
|
|
|
+ * @param gksbbh 港口申报单
|
|
|
+ */
|
|
|
+ public void saveDb(CjhsHwEntity entity,Long gksbbh){
|
|
|
+ CjhsDbEntity db = new CjhsDbEntity();
|
|
|
+ db.setGksbbh(gksbbh);
|
|
|
+ db.setHssbbh(entity.getSbdbh());
|
|
|
+ db.setBsxh(entity.getBsxh());
|
|
|
+ db.setXh(entity.getXh());
|
|
|
+ cjhsDbService.update(db);
|
|
|
+ }
|
|
|
+
|
|
|
}
|