123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519 |
- package cn.com.taiji.zhongxiao.service;
- import java.io.IOException;
- import java.io.UnsupportedEncodingException;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- import java.util.ArrayList;
- import java.util.Calendar;
- import java.util.Date;
- import java.util.HashMap;
- import java.util.List;
- import java.util.Map;
- import java.util.Set;
- import java.util.Vector;
- import java.util.concurrent.ExecutionException;
- import java.util.concurrent.Future;
- import javax.inject.Inject;
- import javax.persistence.criteria.CriteriaBuilder;
- import javax.persistence.criteria.CriteriaBuilder.In;
- import javax.persistence.criteria.CriteriaQuery;
- import javax.persistence.criteria.Join;
- import javax.persistence.criteria.Predicate;
- import javax.persistence.criteria.Root;
- import cn.hutool.core.util.StrUtil;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import org.springframework.beans.BeanUtils;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.data.domain.Page;
- import org.springframework.data.domain.PageRequest;
- import org.springframework.data.domain.Sort;
- import org.springframework.data.domain.Sort.Direction;
- import org.springframework.data.domain.Sort.Order;
- import org.springframework.data.jpa.domain.Specification;
- import org.springframework.jdbc.core.BeanPropertyRowMapper;
- import org.springframework.jdbc.core.JdbcTemplate;
- import org.springframework.jdbc.core.RowMapper;
- import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
- import org.springframework.stereotype.Service;
- import com.alibaba.csb.sdk.HttpCaller;
- import com.alibaba.csb.sdk.HttpCallerException;
- import com.fasterxml.jackson.core.JsonParseException;
- import com.fasterxml.jackson.databind.JsonMappingException;
- import com.fasterxml.jackson.databind.ObjectMapper;
- import cn.com.taiji.sys.domain.Code;
- import cn.com.taiji.sys.domain.Dept;
- import cn.com.taiji.sys.domain.Role;
- import cn.com.taiji.sys.domain.User;
- import cn.com.taiji.sys.dto.CodeDto;
- import cn.com.taiji.sys.dto.UserDto;
- import cn.com.taiji.sys.service.UserService;
- import cn.com.taiji.util.Pagination;
- import cn.com.taiji.util.ToolUtil;
- import cn.com.taiji.zhongxiao.domain.Indicators;
- import cn.com.taiji.zhongxiao.domain.IndicatorsRepository;
- import cn.com.taiji.zhongxiao.domain.Subscribemanage;
- import cn.com.taiji.zhongxiao.domain.SubscribemanageRepository;
- import cn.com.taiji.zhongxiao.domain.Sxcode;
- import cn.com.taiji.zhongxiao.domain.SxcodeRepository;
- import cn.com.taiji.zhongxiao.domain.TcodeSet;
- import cn.com.taiji.zhongxiao.domain.TdataMeta;
- import cn.com.taiji.zhongxiao.domain.TdataMetaRepository;
- import cn.com.taiji.zhongxiao.domain.TguajieopinionList;
- import cn.com.taiji.zhongxiao.domain.TguajieopinionListRepository;
- import cn.com.taiji.zhongxiao.domain.TinfoClass;
- import cn.com.taiji.zhongxiao.domain.TinfoClassRepository;
- import cn.com.taiji.zhongxiao.domain.TinfoclassDatameta;
- import cn.com.taiji.zhongxiao.domain.TinfoclassRes;
- import cn.com.taiji.zhongxiao.domain.TmessageInfo;
- import cn.com.taiji.zhongxiao.domain.TresClassify;
- import cn.com.taiji.zhongxiao.domain.TshareApply;
- import cn.com.taiji.zhongxiao.domain.TshareApplyRepository;
- import cn.com.taiji.zhongxiao.dto.DelayDataShareInfo;
- import cn.com.taiji.zhongxiao.dto.DelayInfo;
- import cn.com.taiji.zhongxiao.dto.DelayServiceShareInfo;
- import cn.com.taiji.zhongxiao.dto.HisTaskDto;
- import cn.com.taiji.zhongxiao.dto.IndicatorsDto;
- import cn.com.taiji.zhongxiao.dto.TcodeSetDto;
- import cn.com.taiji.zhongxiao.dto.TdataMetaDto;
- import cn.com.taiji.zhongxiao.dto.TinfoClassDto;
- import cn.com.taiji.zhongxiao.dto.TserviceRegInfoDto;
- import cn.com.taiji.zhongxiao.dto.TshareApplyDto;
- import cn.com.taiji.zhongxiao.dto.VtasklistDto;
- @Service
- public class TinfoClassService {
- private static final Logger log = LoggerFactory
- .getLogger(TinfoClassService.class);
- @Value("${indicators.ywfglValue}")
- public int ywfglValue;
- @Value("${indicators.yyfglValue}")
- public int yyfglValue;
- @Value("${indicators.qzgllValue}")
- public int qzgllValue;
- @Value("${indicators.xtgllValue}")
- public int xtgllValue;
- @Value("${indicators.gjlValue}")
- public int gjlValue;
- @Value("${indicators.kblValue}")
- public int kblValue;
- @Value("${indicators.sjgxValue}")
- public int sjgxValue;
- @Value("${indicators.mlshValue}")
- public int mlshValue;
- @Value("${indicators.gjshValue}")
- public int gjshValue;
- @Inject
- TguajieopinionListRepository tguajieopinionListRepository;
- @Inject
- TmessageInfoService tmessageInfoService;
- @Inject
- ThreadPoolTaskExecutor threadPoolTaskExecutor;
- @Value("${database_type}")
- String database_type;
- @Value("${admin_id}")
- String admin_id;
- @Value("${zgbmgl_role}")
- String zgbmgl_role;
- @Value("${zgbmbz_role}")
- String zgbmbz_role;
- @Inject
- TshareApplyRepository tshareApplyRepository;
- @Inject
- JdbcTemplate jdbcTemplate;
- @Inject
- TinfoClassRepository tinfoClassRepository;
- @Inject
- TdataMetaRepository tdataMetaRepository;
- @Inject
- UserService uiservice;
- @Inject
- SubscribemanageRepository subscribemanageRepository;
- @Inject
- SxcodeRepository sxcodeRepository;
- @Inject
- TcodeSetService tcodeSetService;
- @Inject
- IndicatorsRepository indicatorsRepository;
- @Inject
- TresClassifyService tresClassifyService;
- @Inject
- SysDeptService deptService;
- @Inject
- DbdcCodeService dbdcCodeService;
- @Inject
- DatametaService datametaService;
- /**
- *
- * @Description: 获取信息类注册信息列表
- * @param dto
- * @param pag
- * @return Pagination<TinfoClassDto>
- * @throws
- * @author lijiezhi_pc
- * @date 2017年12月27日
- */
- public Pagination<TinfoClassDto> findTinfoClassZcList(final TinfoClassDto dto,
- Pagination<TinfoClassDto> pag,final User userInfo,final String type) {
- List<Order> orders = new ArrayList<Sort.Order>();
- Order order = new Order(Direction.ASC, "inprocess");
- Order order1 = new Order(Direction.DESC, "id");
- Order order2 = new Order(Direction.DESC, "createdate");
- Order order3 = new Order(Direction.DESC, "taskname");
- orders.add(order);
- orders.add(order3);
- orders.add(order2);
- orders.add(order1);
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1,
- pag.getPageSize(), sort);
-
- Page<TinfoClass> page;
- page = tinfoClassRepository.findAll(new Specification<TinfoClass>() {
- @Override
- public Predicate toPredicate(Root<TinfoClass> root,
- CriteriaQuery<?> query, CriteriaBuilder cb) {
- List<Predicate> pl = new ArrayList<Predicate>();
- Set<Role> serRole = userInfo.getRoles();
- boolean flag = false;
- for (Role role : serRole) {
- if(admin_id.equals(role.getRoleId()))
- flag = true;
- }
-
- if(!flag&&type.equals("0")){
- In<Object> in = cb.in(root.get("providebmcode"));
- for (Dept dept : userInfo.getDepts()) {
- in.value(dept.getDeptId());
- }
- if(userInfo.getDepts().size()>0){
- pl.add(cb.or(cb.equal(root.get("creator"), userInfo.getUserId()),in));
- }
- else{
- pl.add(cb.equal(root.get("creator"), userInfo.getUserId()));
- }
-
- }
- pl.add(cb.or(cb.equal(root.get("inprocess"), "0"),cb.equal(root.get("inprocess"), "1"),cb.equal(root.get("inprocess"), "2"),cb.equal(root.get("inprocess"), "3")));
- if(!ToolUtil.isNull(dto.getInfoname())){
- pl.add(cb.like(root.<String>get("infoname"), "%"+dto.getInfoname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- pl.add(cb.like(root.<String>get("infotypename"), "%"+dto.getInfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getGlinfotypename())){
- pl.add(cb.like(root.<String>get("glinfotypename"), "%"+dto.getGlinfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getFltag())){
- pl.add(cb.like(root.<String>get("fltag"), "%"+dto.getFltag()+"%"));
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- pl.add(cb.equal(root.get("sharetype"), dto.getSharetype()));
- }
- if(!ToolUtil.isNull(dto.getProvidename())){
- pl.add(cb.equal(root.get("providename"), dto.getProvidename()));
- }
- if(!ToolUtil.isNull(dto.getProvidezgname())){
- pl.add(cb.equal(root.get("providezgname"), dto.getProvidezgname()));
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- pl.add(cb.like(root.get("providebmname"), "%"+dto.getProvidebmname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getTaskname())) {
- switch(dto.getTaskname()) {
- case "未提交": pl.add(cb.equal(root.get("inprocess"), "0"));break;
- case "部门审核":{
- pl.add(cb.equal(root.get("inprocess"), "1"));
- pl.add(cb.equal(root.get("taskname"), "部门审核"));
- };break;
- case "主管部门审核":
- {
- pl.add(cb.equal(root.get("inprocess"), "1"));
- pl.add(cb.equal(root.get("taskname"), "主管部门审核"));
- }
- break;
- case "已发布":pl.add(cb.equal(root.get("inprocess"), "2"));break;
- case "停用":pl.add(cb.equal(root.get("inprocess"), "5"));;break;
- case "编目人员修改":
- {
- pl.add(cb.equal(root.get("inprocess"), "1"));
- pl.add(cb.equal(root.get("taskname"), "编目人员修改"));
- }
- break;
- default:
- break;
- }
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- pl.add(cb.like(root.<String>get("infocode"), "%"+dto.getInfocode()+"%"));
- }
- if(!ToolUtil.isNull(dto.getIsopensocial())){
- pl.add(cb.equal(root.<String>get("isopensocial"), dto.getIsopensocial()));
- }
- if(!ToolUtil.isNull(dto.getIsglqz())){
- pl.add(cb.equal(root.<String>get("isglqz"), dto.getIsglqz()));
- }
- if(!ToolUtil.isNull(dto.getManagetype())){
- pl.add(cb.equal(root.<String>get("managetype"), dto.getManagetype()));
- }
- if(dto.getHitchStatus()!=null){
- if("1".equals(dto.getHitchStatus()+""))
- pl.add(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()));
- else {
- pl.add(cb.or(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()),cb.isNull(root.get("hitchStatus"))));
- }
- }
- // 起始时间
- if (!ToolUtil.isNull(dto.getStartdate())) {
- pl.add(cb.greaterThanOrEqualTo(root.<String> get("updatetime"),dto.getStartdate()));
- }
- // 结束时间
- if (!ToolUtil.isNull(dto.getEnddate())) {
- pl.add(cb.lessThanOrEqualTo(root.<String> get("updatetime"),dto.getEnddate()+" 23:59:59"));
- }
-
- if(type.equals("1")&&!flag){
- In<Object> in = cb.in(root.get("providecode"));
- for (Dept dept : userInfo.getDepts()) {
- in.value(dept.getDeptId());
- }
- if(userInfo.getDepts().size()>0){
- pl.add(in);
- }
- }
- if(type.equals("2")&&!flag){
- In<Object> in = cb.in(root.get("providebmcode"));
- for (Dept dept : userInfo.getDepts()) {
- in.value(dept.getDeptId());
- }
- if(userInfo.getDepts().size()>0){
- pl.add(in);
- }
- }
- if(type.equals("3")&&!flag){
- In<Object> in = cb.in(root.get("xzqhcode"));
- for (Dept dept : userInfo.getDepts()) {
- in.value(dept.getXzqhcode());
- }
- if(userInfo.getDepts().size()>0){
- pl.add(in);
- }
- }
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TinfoClass> dataList = page.getContent();
- List<TinfoClassDto> dtolsit = new ArrayList<TinfoClassDto>();
- for (TinfoClass u : dataList) {
- dtolsit.add(new TinfoClassDto(u));
- }
- pag.setPageResult(dtolsit);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public Pagination<TinfoClassDto> findTinfoClassBgList(final TinfoClassDto dto,
- Pagination<TinfoClassDto> pag,final String userId) {
- List<Order> orders = new ArrayList<Sort.Order>();
- Order order = new Order(Direction.DESC, "inprocess");
- Order order1 = new Order(Direction.DESC, "id");
- Order order2 = new Order(Direction.DESC, "createdate");
- orders.add(order);
- orders.add(order1);
- orders.add(order2);
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1,
- pag.getPageSize(), sort);
- Page<TinfoClass> page;
-
- page = tinfoClassRepository.findAll(new Specification<TinfoClass>() {
- @Override
- public Predicate toPredicate(Root<TinfoClass> root,
- CriteriaQuery<?> query, CriteriaBuilder cb) {
- List<Predicate> pl = new ArrayList<Predicate>();
- pl.add(cb.equal(root.get("creator"), userId));
- pl.add(cb.or(cb.equal(root.get("isbg") ,"1"),cb.equal(root.get("isbg"),"2")));
- if(!ToolUtil.isNull(dto.getInfoname())){
- pl.add(cb.like(root.<String>get("infoname"), "%"+dto.getInfoname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- pl.add(cb.like(root.<String>get("infotypename"), "%"+dto.getInfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- pl.add(cb.equal(root.get("sharetype"), dto.getSharetype()));
- }
- if(!ToolUtil.isNull(dto.getProvidename())){
- pl.add(cb.equal(root.get("providename"), dto.getProvidename()));
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- pl.add(cb.equal(root.get("infocode"), dto.getInfocode()));
- }
- if(dto.getHitchStatus()!=null){
- if("1".equals(dto.getHitchStatus()+""))
- pl.add(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()));
- else {
- pl.add(cb.or(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()),cb.isNull(root.get("hitchStatus"))));
- }
- }
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TinfoClass> dataList = page.getContent();
- List<TinfoClassDto> dtolsit = new ArrayList<TinfoClassDto>();
- for (TinfoClass u : dataList) {
- dtolsit.add(new TinfoClassDto(u));
- }
- pag.setPageResult(dtolsit);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public Pagination<TinfoclassDatameta> findTinfoClassYapplyList(final TinfoClassDto dto,final TinfoclassDatameta datameta,
- Pagination<TinfoclassDatameta> pag,final User userInfo) {
- String deptid="";
- for(Dept dept:userInfo.getDepts()) {
- deptid=deptid+dept.getDeptId()+",";
- }
- StringBuffer sql = new StringBuffer("select p.infocode,p.infoname,p.sharetype sharetype1,p.providebmname,q.* from t_infoclass p,t_infoclass_datameta q where p.id in (select tinfoclassid from t_shareapply where instr(?,applydeptid)>0 and state='2') " +
- " and p.id=q.tinfoclassid ");
- List<String> paramList=new ArrayList<String>();
- paramList.add(deptid);
- if(!ToolUtil.isNull(dto.getInfocode())) {
- sql.append(" and p.infocode like ?");
- paramList.add("%"+dto.getInfocode()+"%");
- }
- if(!ToolUtil.isNull(dto.getInfoname())) {
- sql.append(" and p.infoname like ?");
- paramList.add("%"+dto.getInfoname()+"%");
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())) {
- sql.append(" and p.providebmname like ?");
- paramList.add("%"+dto.getProvidebmname()+"%");
- }
- if(!ToolUtil.isNull(dto.getSharetype())) {
- sql.append(" and p.sharetype = ?");
- paramList.add(dto.getSharetype());
- }
- if(!ToolUtil.isNull(datameta.getXxxmc())) {
- sql.append(" and q.xxxmc = ?");
- paramList.add("%"+datameta.getXxxmc()+"%");
- }
- if(!ToolUtil.isNull(datameta.getXxxbm())) {
- sql.append(" and q.xxxbm = ?");
- paramList.add("%"+datameta.getXxxbm()+"%");
- }
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
- }
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<TinfoclassDatameta>() {
- @Override
- public TinfoclassDatameta mapRow(ResultSet rs, int rowNum) throws SQLException {
- TinfoclassDatameta info =new TinfoclassDatameta();
- info.setId(rs.getString("id"));
- info.setInfoname(rs.getString("infoname"));
- info.setInfocode(rs.getString("infocode"));
- info.setSharetype1(rs.getString("sharetype1"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setXxxmc(rs.getString("xxxmc"));
- info.setXxxbm(rs.getString("xxxbm"));
- info.setGlsjy(rs.getString("glsjy"));
- info.setSharetype(rs.getString("sharetype"));
- info.setShareconditions(rs.getString("shareconditions"));
- info.setSharemodename(rs.getString("sharemodename"));
- info.setSharemode(rs.getString("sharemode"));
- info.setSharemodeid(rs.getString("sharemodeid"));
- info.setSharemodetypename(rs.getString("sharemodetypename"));
- info.setSharemodetype(rs.getString("sharemodetype"));
- info.setSharemodetypeid(rs.getString("sharemodetypeid"));
- info.setIsopensocial(rs.getString("isopensocial"));
- info.setOpencondition(rs.getString("opencondition"));
- info.setMetacode(rs.getString("metacode"));
- info.setMetacodeDis(rs.getString("metacode_dis"));
- info.setMetacodeid(rs.getString("metacodeid"));
- info.setMetaname(rs.getString("metaname"));
- info.setDatatype(rs.getString("datatype"));
- info.setDatatypeDis(rs.getString("datatype_dis"));
- info.setDatatypeid(rs.getString("datatypeid"));
- info.setDatasize(rs.getString("datasize"));
- info.setRanges(rs.getString("ranges"));
- info.setIsprimary(rs.getString("isprimary"));
- info.setIndexnum(rs.getInt("indexnum"));
- info.setTinfoclassid(rs.getString("tinfoclassid"));
- if(!ToolUtil.isNull(rs.getString("codesetid"))){
- TcodeSetDto code = tcodeSetService.getOne(String.valueOf(rs.getString("codesetid")));
- if(code!=null) {
- info.setCodesetid(code.getCodesetId());
- info.setCodesetname(code.getCodesetName());
- }
- }
- info.setDatametaid(rs.getString("datametaid"));
- return info;
-
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public Pagination<TinfoClassDto> findTinfoClassVersionList(final TinfoClassDto dto,
- Pagination<TinfoClassDto> pag) {
- List<Order> orders = new ArrayList<Sort.Order>();
- Order order = new Order(Direction.DESC, "inprocess");
- Order order1 = new Order(Direction.DESC, "id");
- Order order2 = new Order(Direction.DESC, "createdate");
- orders.add(order);
- orders.add(order1);
- orders.add(order2);
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1,
- pag.getPageSize(), sort);
- Page<TinfoClass> page;
- page = tinfoClassRepository.findAll(new Specification<TinfoClass>() {
- @Override
- public Predicate toPredicate(Root<TinfoClass> root,
- CriteriaQuery<?> query, CriteriaBuilder cb) {
- List<Predicate> pl = new ArrayList<Predicate>();
- pl.add(cb.notEqual(root.<String>get("inprocess"), "4"));
-
- if(!ToolUtil.isNull(dto.getInfoname())){
- pl.add(cb.like(root.<String>get("infoname"), "%"+dto.getInfoname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- pl.add(cb.like(root.<String>get("infotypename"), "%"+dto.getInfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- pl.add(cb.equal(root.get("sharetype"), dto.getSharetype()));
- }
- if(!ToolUtil.isNull(dto.getProvidename())){
- pl.add(cb.like(root.<String>get("providename"), "%"+dto.getProvidename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- pl.add(cb.like(root.<String>get("providebmname"), "%"+dto.getProvidebmname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getSourceid())){
- pl.add(cb.equal(root.get("sourceid"), dto.getSourceid()));
- }
- if(dto.getHitchStatus()!=null){
- if("1".equals(dto.getHitchStatus()+""))
- pl.add(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()));
- else {
- pl.add(cb.or(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()),cb.isNull(root.get("hitchStatus"))));
- }
- }
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TinfoClass> dataList = page.getContent();
- List<TinfoClassDto> dtolsit = new ArrayList<TinfoClassDto>();
- for (TinfoClass u : dataList) {
- dtolsit.add(new TinfoClassDto(u));
- }
- pag.setPageResult(dtolsit);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public void disableParent(String id) {
- TinfoClass info = tinfoClassRepository.findOne(id);
- if (info != null) {
- TinfoClass parent = tinfoClassRepository.findOne(info.getParentid());
- if (parent != null) {
- tinfoClassRepository.updateImplementationState(parent.getId(), "2");
- }
- }
- }
- public Pagination<TinfoClassDto> findTinfoClassYsList(final TinfoClassDto dto,
- Pagination<TinfoClassDto> pag,final User userInfo) {
- List<Order> orders = new ArrayList<Sort.Order>();
- if(!ToolUtil.isNull(pag.getSortFiled())){
- if("infocode".equals(pag.getSortFiled())){
- if("desc".equals(pag.getSortType().toLowerCase())) {
- Order order_temp = new Order(Direction.DESC, "infocode");
- orders.add(order_temp);
- }
- else {
- Order order_temp = new Order(Direction.ASC, "infocode");
- orders.add(order_temp);
- }
-
- }
- else if("isopensocial".equals(pag.getSortFiled())){
- if("desc".equals(pag.getSortType().toLowerCase())) {
- Order order_temp = new Order(Direction.DESC, "isopensocial");
- orders.add(order_temp);
- }
- else {
- Order order_temp = new Order(Direction.ASC, "isopensocial");
- orders.add(order_temp);
- }
- }
- else if("sharetype".equals(pag.getSortFiled())){
- if("desc".equals(pag.getSortType().toLowerCase())) {
- Order order_temp = new Order(Direction.DESC, "sharetype");
- orders.add(order_temp);
- }
- else {
- Order order_temp = new Order(Direction.ASC, "sharetype");
- orders.add(order_temp);
- }
- }
-
-
- }
- Order order = new Order(Direction.DESC, "gjcheckstate");
- Order order1 = new Order(Direction.DESC, "id");
- Order order2 = new Order(Direction.DESC, "createdate");
- orders.add(order);
- orders.add(order1);
- orders.add(order2);
-
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1,
- pag.getPageSize(), sort);
- Page<TinfoClass> page;
- page = tinfoClassRepository.findAll(new Specification<TinfoClass>() {
- @Override
- public Predicate toPredicate(Root<TinfoClass> root,
- CriteriaQuery<?> query, CriteriaBuilder cb) {
- Set<Role> serRole = userInfo.getRoles();
- boolean flag = false;
- for (Role role : serRole) {
- if(admin_id.equals(role.getRoleId()))
- flag = true;
- }
- List<Predicate> pl = new ArrayList<Predicate>();
- pl.add(cb.equal(root.get("latestversion"), "1"));
- pl.add(cb.equal(root.get("inprocess"), "2"));
- if(!ToolUtil.isNull(dto.getInfoname())){
- pl.add(cb.like(root.<String>get("infoname"), "%"+dto.getInfoname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- pl.add(cb.like(root.<String>get("infotypename"), "%"+dto.getInfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getGlinfotypename())){
- pl.add(cb.like(root.<String>get("glinfotypename"), "%"+dto.getGlinfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getFltag())){
- pl.add(cb.like(root.<String>get("fltag"), "%"+dto.getFltag()+"%"));
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- pl.add(cb.equal(root.get("sharetype"), dto.getSharetype()));
- }
- if(!ToolUtil.isNull(dto.getProvidename())){
- pl.add(cb.like(root.<String>get("providename"), "%"+dto.getProvidename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- pl.add(cb.like(root.<String>get("providebmname"), "%"+dto.getProvidebmname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getIsopensocial())){
- pl.add(cb.equal(root.<String>get("isopensocial"), dto.getIsopensocial()));
- }
- if(!ToolUtil.isNull(dto.getSharemodetypename())){
- pl.add(cb.equal(root.<String>get("sharemodetypename"), dto.getSharemodetypename()));
- }
- if(!ToolUtil.isNull(dto.getGjcheckstate())){
- if(!"1".equals(dto.getHitchStatus()+""))
- pl.add(cb.equal(root.<String>get("gjcheckstate"), dto.getGjcheckstate()));
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- pl.add(cb.like(root.<String>get("infocode"), "%"+dto.getInfocode()+"%"));
- }
- if(!ToolUtil.isNull(dto.getIsglqz())){
- pl.add(cb.equal(root.<String>get("isglqz"), dto.getIsglqz()));
- }
- if(!ToolUtil.isNull(dto.getManagetype())){
- pl.add(cb.equal(root.<String>get("managetype"), dto.getManagetype()));
- }
- if(dto.getHitchStatus()!=null){//待挂接 已挂接
- if("1".equals(dto.getHitchStatus()+""))
- pl.add(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()));
- else {
- pl.add(cb.or(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()),cb.isNull(root.get("hitchStatus"))));
- }
-
- }
- //起始时间
- if (!ToolUtil.isNull(dto.getStartdate())) {
- pl.add(cb.greaterThanOrEqualTo(root.<String> get("updatetime"),dto.getStartdate()));
- }
- // 结束时间
- if (!ToolUtil.isNull(dto.getEnddate())) {
- pl.add(cb.lessThanOrEqualTo(root.<String> get("updatetime"), dto.getEnddate()+" 23:59:59"));
- }
-
- if(!flag){
- List<Predicate> pl2 = new ArrayList<Predicate>();
- pl2.add(cb.equal(root.<String>get("creator"), userInfo.getUserId()));
- for(Dept dept:userInfo.getDepts()){
- pl2.add(cb.equal(root.<String>get("providebmcode"), dept.getDeptId()));
- String haszgbm="0";
- for(Role role:userInfo.getRoles()){
- if(zgbmgl_role.contains(role.getRoleId())||zgbmbz_role.contains(role.getRoleId())){
- haszgbm="1";
- break;
- }
- }
- if("1".equals(haszgbm)) {
-
-
- pl2.add(cb.equal(root.<String>get("xzqhcode"), dept.getXzqhcode()));
- }
- }
-
- pl.add(cb.or(pl2.toArray(new Predicate[0])));
- }
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TinfoClass> dataList = page.getContent();
- List<TinfoClassDto> dtolsit = new ArrayList<TinfoClassDto>();
- for (TinfoClass u : dataList) {
- TinfoClassDto temp = new TinfoClassDto(u);
- if (StrUtil.isNotBlank(u.getParentid())) {
- TinfoClass parent = tinfoClassRepository.findByPid(u.getParentid());
- if (parent != null && "2".equals(parent.getImplementationState())) {
- temp.setParentState(2);
- } else {
- temp.setParentState(1);
- }
- }
- dtolsit.add(temp);
- }
- pag.setPageResult(dtolsit);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public Pagination<TinfoClassDto> findTinfoClassTqList(final TinfoClassDto dto,
- Pagination<TinfoClassDto> pag,final User userInfo) {
- List<Order> orders = new ArrayList<Sort.Order>();
- if(!ToolUtil.isNull(pag.getSortFiled())){
- if("infocode".equals(pag.getSortFiled())){
- if("desc".equals(pag.getSortType().toLowerCase())) {
- Order order_temp = new Order(Direction.DESC, "infocode");
- orders.add(order_temp);
- }
- else {
- Order order_temp = new Order(Direction.ASC, "infocode");
- orders.add(order_temp);
- }
-
- }
- else if("isopensocial".equals(pag.getSortFiled())){
- if("desc".equals(pag.getSortType().toLowerCase())) {
- Order order_temp = new Order(Direction.DESC, "isopensocial");
- orders.add(order_temp);
- }
- else {
- Order order_temp = new Order(Direction.ASC, "isopensocial");
- orders.add(order_temp);
- }
- }
- else if("sharetype".equals(pag.getSortFiled())){
- if("desc".equals(pag.getSortType().toLowerCase())) {
- Order order_temp = new Order(Direction.DESC, "sharetype");
- orders.add(order_temp);
- }
- else {
- Order order_temp = new Order(Direction.ASC, "sharetype");
- orders.add(order_temp);
- }
- }
-
-
- }
- Order order = new Order(Direction.DESC, "disablestate");
- Order order1 = new Order(Direction.DESC, "id");
- Order order2 = new Order(Direction.DESC, "createdate");
- orders.add(order);
- orders.add(order1);
- orders.add(order2);
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1,
- pag.getPageSize(), sort);
- Page<TinfoClass> page;
- page = tinfoClassRepository.findAll(new Specification<TinfoClass>() {
- @Override
- public Predicate toPredicate(Root<TinfoClass> root,
- CriteriaQuery<?> query, CriteriaBuilder cb) {
- List<Predicate> pl = new ArrayList<Predicate>();
- pl.add(cb.equal(root.get("latestversion"), "1"));
- pl.add(cb.or(cb.equal(root.get("inprocess"), "2"),cb.equal(root.get("inprocess"), "5")));
- if(!ToolUtil.isNull(dto.getInfoname())){
- pl.add(cb.like(root.<String>get("infoname"), "%"+dto.getInfoname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- pl.add(cb.like(root.<String>get("infotypename"), "%"+dto.getInfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- pl.add(cb.equal(root.get("sharetype"), dto.getSharetype()));
- }
- if(!ToolUtil.isNull(dto.getProvidename())){
- pl.add(cb.like(root.<String>get("providename"), "%"+dto.getProvidename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- pl.add(cb.like(root.<String>get("providebmname"), "%"+dto.getProvidebmname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getIsopensocial())){
- pl.add(cb.like(root.<String>get("isopensocial"), "%"+dto.getIsopensocial()+"%"));
- }
- if(!ToolUtil.isNull(dto.getFltag())){
- pl.add(cb.like(root.<String>get("fltag"), "%"+dto.getFltag()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- pl.add(cb.like(root.<String>get("infocode"), "%"+dto.getInfocode()+"%"));
- }
- //判断停用情况的值是否为空,若为空,则默认查询停用审核中的状态
- if(!ToolUtil.isNull(dto.getDisablestate())){
- pl.add(cb.like(root.<String>get("disablestate"), "%"+dto.getDisablestate()+"%"));
- }
- //起始时间
- if (!ToolUtil.isNull(dto.getStartdate())) {
- pl.add(cb.greaterThanOrEqualTo(root.<String> get("updatetime"),dto.getStartdate()));
- }
- // 结束时间
- if (!ToolUtil.isNull(dto.getEnddate())) {
- pl.add(cb.lessThanOrEqualTo(root.<String> get("updatetime"), dto.getEnddate()+" 23:59:59"));
- }
- if(dto.getHitchStatus()!=null){//待挂接 已挂接
- if("1".equals(dto.getHitchStatus()+""))
- pl.add(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()));
- else {
- pl.add(cb.or(cb.equal(root.get("hitchStatus"), dto.getHitchStatus()),cb.isNull(root.get("hitchStatus"))));
- }
- }
- if(!ToolUtil.isNull(dto.getInprocess())){
- pl.add(cb.equal(root.<String>get("inprocess"),dto.getInprocess()));
- }
- Set<Role> serRole = userInfo.getRoles();
- boolean flag = false;
- boolean zgbm =false;
- for (Role role : serRole) {
- if(admin_id.equals(role.getRoleId()))
- flag = true;
- if(zgbmgl_role.equals(role.getRoleId()))
- zgbm = true;
- }
- if(!flag){
- In<Object> in = cb.in(root.get("xzqhcode"));
- In<Object> in2 = cb.in(root.get("providebmcode"));
-
- for (Dept dept : userInfo.getDepts()) {
- in.value(dept.getXzqhcode());
- in2.value(dept.getDeptId());
- }
- if(userInfo.getDepts().size()>0){
- if(zgbm) {
- pl.add(in);
- }
- else {
- pl.add(in2);
- }
- }
- }
-
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TinfoClass> dataList = page.getContent();
- List<TinfoClassDto> dtolsit = new ArrayList<TinfoClassDto>();
- for (TinfoClass u : dataList) {
- dtolsit.add(new TinfoClassDto(u));
- }
- pag.setPageResult(dtolsit);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public Pagination<TdataMetaDto> findDataMetaChooselist(final TdataMetaDto dto,
- Pagination<TdataMetaDto> pag) {
- List<Order> orders = new ArrayList<Sort.Order>();
- Order order1 = new Order(Direction.DESC, "id");
- orders.add(order1);
- Order order2 = new Order(Direction.DESC, "metaname");
- orders.add(order2);
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1,
- pag.getPageSize(), sort);
- Page<TdataMeta> page;
- page = tdataMetaRepository.findAll(new Specification<TdataMeta>() {
- @Override
- public Predicate toPredicate(Root<TdataMeta> root,
- CriteriaQuery<?> query, CriteriaBuilder cb) {
- List<Predicate> pl = new ArrayList<Predicate>();
- pl.add(cb.equal(root.get("state"),3));
- if(dto.getDatacode()!=null&&!"".equals(dto.getDatacode())){
- pl.add(cb.equal(root.get("datacode"),dto.getDatacode()));
- }
- if(dto.getMetaname()!=null&&!"".equals(dto.getMetaname())){
- pl.add(cb.like(root.<String>get("metaname"),"%"+dto.getMetaname()+"%"));
- }
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TdataMeta> dataList = page.getContent();
- List<TdataMetaDto> dtolsit = new ArrayList<TdataMetaDto>();
- for (TdataMeta u : dataList) {
- dtolsit.add(new TdataMetaDto(u));
- }
- pag.setPageResult(dtolsit);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public String getPrecodeByInfoTypeid(String infotypeid) {
- String result="";
- List<Map<String ,Object>> list=new ArrayList<Map<String ,Object>>();
- if("oracle".equals(database_type)){
- String sql="select rescode from t_res_classify start with resid=? connect by prior presid=resid ";
-
- list = jdbcTemplate.queryForList(sql, new Object[]{infotypeid});
-
- }
- else if("mysql".equals(database_type)){
- String sql="select rescode,presid from t_res_classify where resid=?";
- list = jdbcTemplate.queryForList(sql, new Object[]{infotypeid});
- List<Map<String ,Object>> templist=new ArrayList<Map<String ,Object>>();
- templist=list;
- while(templist!=null&&templist.size()>0){
- templist=jdbcTemplate.queryForList(sql, new Object[]{templist.get(0).get("presid")});
- list.addAll(templist);
- }
- }
- int length=0;
- if(list!=null&&list.size()>=3){
- length=list.size();
- }
- if(length!=0){
- Map map1=list.get(length-1);
- Map map2=list.get(length-2);
- Map map3=list.get(length-3);
- result=map1.get("rescode").toString()+map2.get("rescode").toString()+map3.get("rescode").toString();
- }
- return result;
- }
- // @Cacheable(value="tinfoClassCache",key = "#root.targetClass+#id")
- public TinfoClassDto findTinfoClassById(String id) {
- // TODO Auto-generated method stub
- if(id==null){
- return null;
- }
- TinfoClass info = tinfoClassRepository.findOne(id);
- if(info!=null){
- TinfoClassDto dto = new TinfoClassDto(info);
- return dto;
- }
-
- return null;
- }
- public TinfoClass findTinfoClassById2(String id) {
- // TODO Auto-generated method stub
- if(id==null){
- return null;
- }
- TinfoClass info = tinfoClassRepository.findOne(id);
- if(info!=null){
- return info;
- }
-
- return null;
- }
- //@CachePut(value = "tinfoClassCache", key = "#root.targetClass + #result.id")
- public TinfoClassDto saveTinfoClass(TinfoClass result) {
- // TODO Auto-generated method stub
- TinfoClass info = tinfoClassRepository.saveAndFlush(result);
- TinfoClassDto dto = new TinfoClassDto(info);
- List<TshareApply> tshareApplyList = new ArrayList<>();
- if(info.getTshareApplyList()!=null){
- for(TshareApply app:info.getTshareApplyList()){
- tshareApplyList.add(app);
- }
- dto.setTshareApplyList(tshareApplyList);
- }
-
- List<TinfoclassRes> tinfoclassResList = new ArrayList<>();
- if(info.getTinfoclassResList()!=null){
- for(TinfoclassRes app:info.getTinfoclassResList()){
- tinfoclassResList.add(app);
- }
- dto.setTinfoclassResList(tinfoclassResList);
- }
- List<TinfoclassDatameta> tinfoclassDatametaList = new ArrayList<>();
- if(info.getTinfoclassDatametaList()!=null){
- for(TinfoclassDatameta app:info.getTinfoclassDatametaList()){
- tinfoclassDatametaList.add(app);
- }
- dto.setTinfoclassDatametaList(info.getTinfoclassDatametaList());
- }
- return dto;
- }
- public List<Map<String,Object>> resInfo(String sql,String deptid) {
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(deptid))
- paramList.add(deptid);
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- List<Map<String,Object>> infoList = jdbcTemplate.queryForList(sql, args);
- return infoList;
-
- }
- public Pagination<TinfoClassDto> findTinfoClassresClassifyList(TinfoClassDto dto,String resid,
- Pagination<TinfoClassDto> pag,User userInfo) {
- StringBuffer sql=new StringBuffer("select p.isglqz,p.fltag,p.managetype, p.isopensocial, p.id,p.infocode,p.infoname,p.infotypename,p.providename,p.providebmname,p.sharetype,p.sourceid,p.versionid,p.subversionid,p.updatetime,p.hitch_status,p.sharemodetypename,p.bgstatus from t_infoclass p where p.latestversion='1' and p.inprocess='2' and (p.disablestate is null or p.disablestate!='1') ");
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(resid)){
- if("oracle".equals(database_type)){
- paramList.add(resid);
- // paramList.add(resid);//union SELECT q.resid,q.tinfoclassid FROM t_infoclass_res_detail q where q.resid=?
- sql=new StringBuffer("SELECT p.isopensocial,P . ID,p.sharemodetypename,P .infocode,P .infoname,P .infotypename,P .providename,P .providebmname,P .sharetype,P .sourceid,p.versionid,p.updatetime,p.hitch_status ")
- .append(" FROM t_infoclass P,(SELECT resid,'' tinfoclassid FROM t_res_classify")
- .append(" WHERE state = '0' START WITH resid = ? CONNECT BY PRIOR resid = presid")
- .append(" ) w WHERE P .latestversion = '1'")
- .append(" AND P .inprocess = '2' and ((w.resid=p.infotypeid and w.tinfoclassid is null) or (w.resid=p.infotypeid and p.id=w.tinfoclassid)) ");
-
- }
- else if("mysql".equals(database_type)){
-
- //获取到当前分类的所有子节点
- String lastResIds="('"+resid+"',";
- List<Map<String,Object>> menuTreeList=new ArrayList<Map<String,Object>>();
- String sql2="select resid from t_res_classify where presid=?";
- menuTreeList = resInfo(sql2,resid);
- List<Map<String,Object>> templist=menuTreeList;
- Map<String,Object> map = new HashMap<String,Object>();
- while(templist!=null&&templist.size()>0){//
- sql2="select resid from t_res_classify where presid in ";
- String deptids="";
- for(Map info:templist){
- deptids+="'"+info.get("resid")+"'"+",";
- map.put((String) info.get("resid"), info.get("resid"));
- }
- if(deptids.length()>1){
- deptids=deptids.substring(0, deptids.length()-1);
- sql2=sql2+"("+deptids+")";
- }
- templist = resInfo(sql2,"");
- for(Map info:templist){
- map.put((String) info.get("resid"), info.get("resid"));
- }
-
- }
- for (Map.Entry<String,Object> entry : map.entrySet()) {
- lastResIds=lastResIds+"'"+entry.getValue()+"'"+",";
- }
- if(lastResIds.length()>1){
- lastResIds=lastResIds.substring(0, lastResIds.length()-1);
- lastResIds=lastResIds+")";
- }
- //获取资源所属分类
- sql.append("and ( p.infotypeid in ").append(lastResIds).append(" )");//or p.id in (SELECT q.tinfoclassid FROM t_infoclass_res_detail q where q.resid=?)
- //paramList.add(resid);
- }
- //
- }
- String zfbm="否";
- if(userInfo.getDepts()!=null)
- for(Dept dept:userInfo.getDepts()) {
- if(dept.getDeptProperty()!=null&&"政务部门".equals(dept.getDeptProperty())) {
- zfbm="是";
- }
- }
- if(!ToolUtil.isNull(dto.getInfoname())){
- paramList.add("%"+dto.getInfoname()+"%");
- sql.append(" and p.infoname like ? ");
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- paramList.add(dto.getInfocode());
- sql.append(" and p.infocode = ? ");
- }
- if(!ToolUtil.isNull(dto.getIsglqz())){
- paramList.add(dto.getIsglqz());
- sql.append(" and p.isglqz = ? ");
- }
- if(!ToolUtil.isNull(dto.getManagetype())){
- paramList.add(dto.getManagetype());
- sql.append(" and p.managetype = ? ");
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- paramList.add("%"+dto.getInfotypename()+"%");
- sql.append(" and p.infotypename like ? ");
- }
- if(!ToolUtil.isNull(dto.getFltag())){
- paramList.add("%"+dto.getFltag()+"%");
- sql.append(" and p.fltag like ? ");
- }
- if(!ToolUtil.isNull(dto.getSharerange())){
- paramList.add(dto.getSharerange());
- sql.append(" and p.sharerange = ? ");
- }
- if(!ToolUtil.isNull(dto.getGlinfotypename())){
- paramList.add("%"+dto.getGlinfotypename()+"%");
- sql.append(" and p.glinfotypename like ? ");
- }
- if(!ToolUtil.isNull(dto.getProvidename())){
- paramList.add("%"+dto.getProvidename()+"%");
- sql.append(" and p.providename like ? ");
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- paramList.add("%"+dto.getProvidebmname()+"%");
- sql.append(" and p.providebmname like ? ");
- }
- if(!ToolUtil.isNull(dto.getIsopensocial())){
- paramList.add(dto.getIsopensocial());
- sql.append(" and p.isopensocial = ? ");
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- if("否".equals(zfbm)) {
- if("1".equals(dto.getSharetype())) {
- sql.append(" and p.sharetype in ('1','2') ");
- }
- else if("2".equals(dto.getSharetype())) {
- sql.append(" and p.sharetype = 'zfbm' ");
- }
- }
- else {
- paramList.add(dto.getSharetype());
- sql.append(" and p.sharetype = ? ");
- }
-
- }
- if(dto.getHitchStatus()!=null){
- paramList.add(dto.getHitchStatus()+"");
- if("1".equals(dto.getHitchStatus()+""))
-
- sql.append(" and p.hitch_status = ? ");
- else {
- sql.append(" and (p.hitch_status = ? or p.hitch_status is null) ");
- }
- }
- /*//发布时间
- if(dto.getUpdatetime()!=null){
- paramList.add(dto.getUpdatetime());
- sql.append("and p.updatetime =? ");
- }*/
- //起始时间
- if(!ToolUtil.isNull(dto.getStartdate())){
- paramList.add(dto.getStartdate());
- sql.append("and p.updatetime >= ?");
- }
- //结束时间
- if(!ToolUtil.isNull(dto.getEnddate())){
- paramList.add(dto.getEnddate()+" 23:59:59");
- sql.append("and p.updatetime <= ?");
- }
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- if(!ToolUtil.isNull(pag.getSortFiled())){
- if("infocode".equals(pag.getSortFiled())){
- sql.append(" order by p.infocode "+pag.getSortType());
- }
- else if("isopensocial".equals(pag.getSortFiled())){
- sql.append(" order by p.isopensocial "+pag.getSortType());
- }
- else if("sharetype".equals(pag.getSortFiled())){
- sql.append(" order by p.sharetype "+pag.getSortType());
- }
-
-
- }
- else {
- sql.append(" order by p.updatetime desc, p.sharemodetypename desc");
- }
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<TinfoClassDto>(){
- @Override
- public TinfoClassDto mapRow(ResultSet rs, int rowNum) throws SQLException {
- TinfoClassDto info = new TinfoClassDto();
- info.setId(rs.getString("id"));
- info.setInfocode(rs.getString("infocode"));
- info.setInfoname(rs.getString("infoname"));
- info.setInfotypename(rs.getString("infotypename"));
- info.setProvidename(rs.getString("providename"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setSharetype(rs.getString("sharetype"));
- info.setSourceid(rs.getString("sourceid"));
- info.setVersionid(rs.getInt("versionid"));
- info.setSubversionid(rs.getInt("subversionid"));
- info.setUpdatetime(rs.getString("updatetime"));
- info.setIsopensocial(rs.getString("isopensocial"));
- info.setHitchStatus(rs.getInt("hitch_status"));
- info.setSharemodetypename(rs.getString("sharemodetypename"));
- info.setIsglqz(rs.getString("isglqz"));
- info.setBgstatus(rs.getString("bgstatus"));
- info.setFltag(rs.getString("fltag"));
-
- info.setManagetype(rs.getString("managetype"));
- return info;
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public Pagination<TinfoClassDto> findTinfoClassZcCheckList(TinfoClassDto dto,VtasklistDto task,
- Pagination<TinfoClassDto> pag,User userInfo) {
- StringBuffer sql=new StringBuffer("select p.id,p.infocode,p.infoname,p.infotypename,p.providename,p.providebmname,p.isopensocial,p.sharetype,t.* from v_tasklist t,t_infoclass p where t.PROC_INST_ID=p.processid and p.inprocess!='4'");
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(dto.getInfoname())){
- paramList.add("%"+dto.getInfoname()+"%");
- sql.append(" and p.infoname like ? ");
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- paramList.add("%"+dto.getInfotypename()+"%");
- sql.append(" and p.infotypename like ? ");
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- paramList.add(dto.getSharetype());
- sql.append(" and p.sharetype = ? ");
- }
- if(!ToolUtil.isNull(dto.getIsopensocial())){
- paramList.add(dto.getIsopensocial());
- sql.append(" and p.isopensocial = ? ");
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- paramList.add("%"+dto.getProvidebmname()+"%");
- sql.append(" and p.providebmname like ? ");
- }
- if(!ToolUtil.isNull(task.getActName())){
- paramList.add("%"+task.getActName()+"%");
- sql.append(" and t.act_name like ? ");
- }
- Set<Role> serRole = userInfo.getRoles();
- boolean flag = false;
- for (Role role : serRole) {
- if(admin_id.equals(role.getRoleId()))
- flag = true;
- }
- if(!flag){
- sql.append(" and ( t.assignee ='").append(userInfo.getUserId()).append("' or t.candidate='").append(userInfo.getUserId()).append("')");}
- sql.append(" order by t.candidate desc ");
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- if(!ToolUtil.isNull(pag.getSortFiled())){
- if("infocode".equals(pag.getSortFiled())){
- sql.append(" order by p.infocode "+pag.getSortType());
- }
- else if("isopensocial".equals(pag.getSortFiled())){
- sql.append(" order by p.isopensocial "+pag.getSortType());
- }
- else if("sharetype".equals(pag.getSortFiled())){
- sql.append(" order by p.sharetype "+pag.getSortType());
- }
-
-
- }
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<TinfoClassDto>(){
- @Override
- public TinfoClassDto mapRow(ResultSet rs, int rowNum) throws SQLException {
- TinfoClassDto info = new TinfoClassDto();
- VtasklistDto task = new VtasklistDto();
- info.setId(rs.getString("id"));
- info.setInfocode(rs.getString("infocode"));
- info.setInfoname(rs.getString("infoname"));
- info.setInfotypename(rs.getString("infotypename"));
- info.setProvidename(rs.getString("providename"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setIsopensocial(rs.getString("isopensocial"));
- info.setSharetype(rs.getString("sharetype"));
- task.setActId(rs.getString("act_id"));
- task.setActName(rs.getString("act_name"));
- task.setAssignee(rs.getString("assignee"));
- task.setCandidate(rs.getString("candidate"));
- task.setProcinstId(rs.getString("proc_inst_id"));
- task.setTaskId(rs.getString("task_id"));
- task.setFormkey(rs.getString("form_key"));
- task.setTaskstart(rs.getString("create_time"));
- UserDto user=new UserDto();
- if(rs.getString("assignee")!=null){
- user = uiservice.findById(rs.getString("assignee"));
-
- }
- else if(rs.getString("candidate")!=null){
- user = uiservice.findById(rs.getString("candidate"));
- }
- if(user!=null)
- task.setAssigneeName(user.getUserName());
-
- info.setVtaskDto(task);
- return info;
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public Pagination<DelayInfo> findDelayInfoList(DelayInfo dto,
- Pagination<DelayInfo> pag,User userInfo) {
- StringBuffer sql=new StringBuffer("select p.providebmcode,p.providebmname,q.num datasharenum,w.num servicesharenum from bm_delay p " +
- "left join " +
- "datashare_bm_delay q " +
- "on p.providebmcode=q.providebmcode " +
- "left join " +
- "serviceshare_bm_delay w " +
- "on p.providebmcode=w.providebmcode ");
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- paramList.add("%"+dto.getProvidebmname()+"%");
- sql.append(" where p.providebmname like ? ");
- }
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- sql.append(" order by q.num desc,w.num desc");
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<DelayInfo>(){
- @Override
- public DelayInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
- DelayInfo info = new DelayInfo();
- info.setProvidebmcode(rs.getString("providebmcode"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setDatasharenum(rs.getString("datasharenum")==null?"0":rs.getString("datasharenum"));
- info.setServicesharenum(rs.getString("servicesharenum")==null?"0":rs.getString("servicesharenum"));
- List<Map<String,Object>> maplist= jdbcTemplate.queryForList("select p.id from t_messageinfo p where substr(sendtime,1,10)=? and providebmcode=?",
- new Object[] {
- ToolUtil.date2Str(new Date(),"yyyy-MM-dd")
- ,rs.getString("providebmcode")
- });
- if(maplist!=null&&maplist.size()>0) {
- info.setIssend("1");
- }
- else {
- info.setIssend("0");
- }
- return info;
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public Pagination<TinfoClassDto> findTinfoClassMyYsList(TinfoClassDto dto,VtasklistDto task,
- Pagination<TinfoClassDto> pag,User userInfo) {
- StringBuffer sql=new StringBuffer("select p.providebmname, p.isopensocial,p.id,p.infocode,p.infoname,p.infotypename,p.providename,p.sharetype,t.* from V_HISTASKLIST_T t,t_infoclass p where t.PROINSTID=p.processid and p.id=t.busid ");
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(dto.getInfoname())){
- paramList.add("%"+dto.getInfoname()+"%");
- sql.append(" and p.infoname like ? ");
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- paramList.add(dto.getSharetype());
- sql.append(" and p.sharetype = ? ");
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- paramList.add("%"+dto.getInfotypename()+"%");
- sql.append(" and p.infotypename like ? ");
- }
- if(!ToolUtil.isNull(dto.getProvidename())){
- paramList.add("%"+dto.getProvidename()+"%");
- sql.append(" and p.providename like ? ");
- }
- if(!ToolUtil.isNull(task.getActName())){
- paramList.add("%"+task.getActName()+"%");
- sql.append(" and t.taskname like ? ");
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- paramList.add("%"+dto.getProvidebmname()+"%");
- sql.append(" and p.providebmname like ? ");
- }
- sql.append(" and t.taskman ='").append(userInfo.getUserId()).append("'");
- sql.append(" order by t.taskend desc");
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<TinfoClassDto>(){
- @Override
- public TinfoClassDto mapRow(ResultSet rs, int rowNum) throws SQLException {
- TinfoClassDto info = new TinfoClassDto();
- HisTaskDto task = new HisTaskDto();
- info.setId(rs.getString("id"));
- info.setInfocode(rs.getString("infocode"));
- info.setInfoname(rs.getString("infoname"));
- info.setInfotypename(rs.getString("infotypename"));
- info.setProvidename(rs.getString("providename"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setIsopensocial(rs.getString("isopensocial"));
- info.setSharetype(rs.getString("sharetype"));
- task.setBusid(rs.getString("busid"));
- task.setTaskid(rs.getString("taskid"));
- task.setProinstid(rs.getString("proinstid"));
- task.setTaskname(rs.getString("taskname"));
- String manname=rs.getString("manname");
- if(!ToolUtil.isNull(manname)&&manname.split(";").length>1){
- task.setManname(manname.split(";")[0]);
- }
- task.setTaskstart(rs.getString("taskstart"));
- task.setTaskend(rs.getString("taskend"));
- task.setResult(rs.getString("taskmessage").split("outcome")[0]);
- task.setOpinion(rs.getString("taskmessage").split("outcome")[1]);
- info.setHisTaskDto(task);
- return info;
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public List<Map<String,Object>> findExcelData(String sql, Object[] args,Pagination<Map<String,Object>> pag,int lastIndex,int startIndex,final String resulttype) {
-
- pag = pag.findPagination(sql.toString(),pag,args, new RowMapper<Map<String,Object>>(){
- @Override
- public Map<String,Object> mapRow(ResultSet rs, int rowNum) throws SQLException {
- Map<String, Object> dataMap = new HashMap<String, Object>();
- if("1".equals(resulttype)){
-
- dataMap.put("infocode", rs.getString("infocode"));
- dataMap.put("infoname", rs.getString("infoname"));
- dataMap.put("formattypename", rs.getString("formattypename"));
- if("1".equals(rs.getString("sharetype"))){
- dataMap.put("sharetype","有条件共享");
- }
- else if("2".equals(rs.getString("sharetype"))){
- dataMap.put("sharetype","无条件共享");
- }
- else if("3".equals(rs.getString("sharetype"))){
- dataMap.put("sharetype","不予共享");
- }
- dataMap.put("shareconditions",rs.getString("shareconditions"));
- dataMap.put("sharemodename",rs.getString("sharemodename"));
- dataMap.put("sharemodetypename",rs.getString("sharemodetypename"));
-
- dataMap.put("isopensocial",rs.getString("isopensocial"));
- dataMap.put("opencondition",rs.getString("opencondition"));
- dataMap.put("updatecycle",rs.getString("updatecycle"));
- dataMap.put("systeminfo",rs.getString("systeminfo"));
-
- //获取关联事项
- List<Map<String,Object>> itemnamelist=jdbcTemplate.queryForList("select itemname from T_BUSINESSITEM_INFOCLASS p where p.INFOCLASSID=?", new Object[]{rs.getString("id")});
- String itemname="";
- for(Map<String,Object> itemnamemap:itemnamelist){
- itemname+=itemnamemap.get("itemname");
- }
- dataMap.put("itemname",itemname);
- dataMap.put("managetype",rs.getString("managetype"));
- dataMap.put("bz","");
- dataMap.put("datarange",rs.getString("datarange"));
- dataMap.put("providename",rs.getString("providename"));
- dataMap.put("providebmname",rs.getString("providebmname"));
- dataMap.put("infotypename",rs.getString("infotypename"));
- dataMap.put("versionid",rs.getString("versionid"));
- String inprocess = rs.getString("inprocess");
- if("0".equals(inprocess)){
- dataMap.put("taskname","未提交");
- }
- else if("1".equals(inprocess)){
- dataMap.put("taskname",rs.getString("taskname"));
- }
- else if("2".equals(inprocess)){
- dataMap.put("taskname","已发布");
- }
- else if("3".equals(inprocess)){
- dataMap.put("taskname","审核不通过");
- }
- else if("4".equals(inprocess)){
- dataMap.put("taskname","已作废");
- }
- else if("5".equals(inprocess)){
- dataMap.put("taskname","停用");
- }
- if("1".equals(rs.getString("hitch_status"))){
- dataMap.put("hitchstatus","已挂接");
- }
- else{
- dataMap.put("hitchstatus","未挂接");
- }
- dataMap.put("hitchdate",rs.getString("hitchdate"));
- if("2".equals(inprocess)||"5".equals(inprocess)){
- dataMap.put("releasedate",rs.getString("updatetime"));
- }
- dataMap.put("createdate",rs.getString("createdate"));
- List<Map<String,Object>> resnamelist=jdbcTemplate.queryForList("select q.resname resname from T_infoclass_Res p,T_RES_CLASSIFY q where p.TINFOCLASSID=? and q.RESID=p.resid", new Object[]{rs.getString("id")});
- String resname="";
- for(Map<String,Object> resnamemap:resnamelist){
- resname+=resnamemap.get("resname");
- }
- dataMap.put("resname",resname);
- }
- else if("2".equals(resulttype)){
-
- //信息资源编码
- dataMap.put("infocode", rs.getString("infocode"));
- //信息资源名称
- dataMap.put("infoname", rs.getString("infoname"));
- //信息资源摘要
- dataMap.put("infoabstracts", rs.getString("infoabstracts"));
- //信息资源格式
- dataMap.put("formattypename", rs.getString("formattypename"));
- //信息项编码
- dataMap.put("xxxbm", rs.getString("xxxbm"));
- //信息项名称
- dataMap.put("xxxmc", rs.getString("xxxmc"));
- //数据元编号
- List<Map<String,Object>> datacode=jdbcTemplate.queryForList("select datacode from t_datameta where id=?",new Object[]{rs.getString("datametaid")});
- if(datacode!=null&&!datacode.isEmpty()){
- dataMap.put("datametaid", datacode.get(0).get("datacode"));
- }
- else{
- dataMap.put("datametaid", "");
- }
- //数据说明
- dataMap.put("ranges", rs.getString("ranges"));
- dataMap.put("datasize", rs.getString("datasize"));
- dataMap.put("datatype_dis", rs.getString("datatype_dis"));
- //共享类型
- if("1".equals(rs.getString("sharetype"))){
- dataMap.put("sharetype","有条件共享");
- }
- else if("2".equals(rs.getString("sharetype"))){
- dataMap.put("sharetype","无条件共享");
- }
- else if("3".equals(rs.getString("sharetype"))){
- dataMap.put("sharetype","不予共享");
- }
- //共享条件
- dataMap.put("shareconditions", rs.getString("shareconditions"));
- //共享方式
- dataMap.put("sharemodename", rs.getString("sharemodename"));
- dataMap.put("sharemodetypename", rs.getString("sharemodetypename"));
- //是否向社会开放
- dataMap.put("isopensocial", rs.getString("isopensocial"));
- //开放条件
- dataMap.put("opencondition", rs.getString("opencondition"));
- //更新周期
- dataMap.put("updatecycle", rs.getString("updatecycle"));
- //信息资源格式
- dataMap.put("subformattypename",rs.getString("subformattypename"));
- /*'' 关联信息系统,*/
- //获取关联事项
- List<Map<String,Object>> itemnamelist=jdbcTemplate.queryForList("select itemname from T_BUSINESSITEM_INFOCLASS p where p.INFOCLASSID=?", new Object[]{rs.getString("id")});
- String itemname="";
- for(Map<String,Object> itemnamemap:itemnamelist){
- itemname+=itemnamemap.get("itemname");
- }
- dataMap.put("itemname",itemname);
- /*关联资源分类*/
- List<Map<String,Object>> resnamelist=jdbcTemplate.queryForList("select q.resname resname from T_infoclass_Res p,T_RES_CLASSIFY q where p.TINFOCLASSID=? and q.RESID=p.resid", new Object[]{rs.getString("id")});
- String resname="";
- for(Map<String,Object> resnamemap:resnamelist){
- resname+=resnamemap.get("resname");
- }
- dataMap.put("resname",resname);
- //管理方式
- dataMap.put("managetype", rs.getString("managetype"));
- /*'' 备注*/
- //数据范围
- dataMap.put("datarange", rs.getString("datarange"));
- //提供处室
- dataMap.put("providename", rs.getString("providename"));
- //提供部门
- dataMap.put("providebmname", rs.getString("providebmname"));
- //资源分类
- dataMap.put("infotypename", rs.getString("infotypename"));
- //版本号
- dataMap.put("versionid", rs.getString("versionid"));
- //发布时间
- dataMap.put("updatetime", rs.getString("updatetime"));
- if("1".equals(rs.getString("hitch_status"))){
- dataMap.put("hitchstatus","已挂接");
- }
- else{
- dataMap.put("hitchstatus","未挂接");
- }
-
- /*'' 关联分类*/
- }
- return dataMap;
- }
- },jdbcTemplate,database_type, lastIndex, startIndex);
- return pag.getPageResult();
- }
- //@CacheEvict(value = "tinfoClassCache", key = "#root.targetClass + #busId")
- public void updateTinfoClassStateById(String busId, String state) {
- // TODO Auto-generated method stub
- tinfoClassRepository.updateTinfoClassStateById(busId,state);
-
- }
-
- //导出Word
- public Map getData(String ids){
- Map dataMap = new HashMap();
- StringBuffer sql=new StringBuffer("SELECT ID,INFOCODE,INFOTYPENAME,INFONAME,PROVIDENAME,");
- sql.append("CREDITNO, PROVIDEBMNAME, YWBMNAME, XZQHNAME,");
- sql.append("FORMATTYPENAME, MANAGETYPE, INFOABSTRACTS, case when sharetype='1' then '有条件共享' when sharetype='2' then '无条件共享' else '不予共享' end SHARETYPE, ISOPENSOCIAL,");
- sql.append("SHARECONDITIONS, UPDATECYCLE, SYSTEMINFO, DATARANGE,ISSECRET,SHAREMODENAME ");
- if("oracle".equals(database_type)){
- sql.append("FROM T_INFOCLASS where instr(','||?||',',','||id||',')>0");
- }
- else if ("mysql".equals(database_type)){
- sql.append("FROM T_INFOCLASS where instr( concat(',', ?,',', ','), concat(',' , id , ',' )) >0");
-
- }
- List<Map<String,Object>> list=new ArrayList<Map<String,Object>>();
- List<Map<String,Object>> xxxlist=new ArrayList<Map<String,Object>>();
- List<Map<String,Object>> sjylist=new ArrayList<Map<String,Object>>();
- List<Map<String,Object>> dmjlist=new ArrayList<Map<String,Object>>();
- list=jdbcTemplate.queryForList(sql.toString(), new Object[]{ids});
- for(Map<String,Object> map:list){
- //获取所有的信息项
- xxxlist= jdbcTemplate.queryForList("select t.*,y.CODESET_ID from (select p.XXXMC,p.XXXBM,p.DATATYPE_DIS,q.DATACODE,p.SHARETYPE,p.ISOPENSOCIAL,p.DATASIZE,p.CODESETID from T_INFOCLASS_DATAMETA p left join t_datameta q on p.DATAMETAID=q.id where p.TINFOCLASSID=?) t left join T_CODESET y on t.CODESETID=y.id ORDER BY xxxbm asc",new Object[]{map.get("ID")});
- sjylist= jdbcTemplate.queryForList("select distinct p.* from T_INFOCLASS_DATAMETA t,T_DATAMETA p where t.TINFOCLASSID=? and t.DATAMETAID=p.id ",new Object[]{map.get("ID")});
- dmjlist= jdbcTemplate.queryForList("select distinct p.* from T_INFOCLASS_DATAMETA t,T_CODESET p where t.CODESETID=p.id and t.TINFOCLASSID=?",new Object[]{map.get("ID")});
- for(Map temp:dmjlist){
- temp.put("dmdetail", jdbcTemplate.queryForList("select * from T_CODESET_DETAIL t where t.fid=?",new Object[]{temp.get("ID")}));
- }
- map.put("xxxlist", xxxlist);
- map.put("sjylist", sjylist);
- map.put("dmjlist", dmjlist);
- //获取关联资源分类
- List<Map<String,Object>> resnamelist=jdbcTemplate.queryForList("select q.resname resname from T_infoclass_Res p,T_RES_CLASSIFY q where p.TINFOCLASSID=? and q.RESID=p.resid", new Object[]{map.get("ID")});
- String resname="";
- for(Map<String,Object> resnamemap:resnamelist){
- resname+=resnamemap.get("resname");
- }
- map.put("RESNAME",resname);
- //获取关联事项
- List<Map<String,Object>> itemnamelist=jdbcTemplate.queryForList("select itemname from T_BUSINESSITEM_INFOCLASS p where p.INFOCLASSID=?", new Object[]{map.get("ID")});
- String itemname="";
- for(Map<String,Object> itemnamemap:itemnamelist){
- itemname+=itemnamemap.get("itemname");
- }
- map.put("ITEMNAME",itemname);
- }
- dataMap.put("list",list);
- return dataMap;
- }
- public void saveSubcriInfo(String busId, User userInfo) {
- // TODO Auto-generated method stub
- TinfoClass info = tinfoClassRepository.findOne(busId);
- Subscribemanage subscri = subscribemanageRepository.findInfoByClassIdAndUserId(busId,userInfo.getUserId());
- if(subscri==null){
- subscri =new Subscribemanage();
- subscri.setId(ToolUtil.getUUID());
- }
- subscri.setInfoclassids(busId);
- subscri.setInfoclassnames(info.getInfoname());
- subscri.setCreatename(userInfo.getUserName());
- subscri.setCreatenameid(userInfo.getUserId());
- subscri.setState("1");
- subscri.setSubscribedate(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- subscribemanageRepository.save(subscri);
- }
- public Pagination<TinfoClassDto> findMySubscriList(TinfoClassDto dto,
- Pagination<TinfoClassDto> pag,User userInfo) {
- StringBuffer sql=new StringBuffer("select p.versionid,p.hitch_status,p.isopensocial, p.sourceid,p.id,p.infocode,p.infoname,p.infotypename,p.providename,p.providebmname,p.providezgname,p.sharetype from subscribemanage t,t_infoclass p where t.infoclassids=p.id and t.state='1' ");
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(dto.getInfoname())){
- paramList.add("%"+dto.getInfoname()+"%");
- sql.append(" and p.infoname like ? ");
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- paramList.add("%"+dto.getInfocode()+"%");
- sql.append(" and p.infocode like ? ");
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- paramList.add("%"+dto.getInfotypename()+"%");
- sql.append(" and p.infotypename like ? ");
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- paramList.add("%"+dto.getProvidebmname()+"%");
- sql.append(" and p.providename like ? ");
- }
-
- if(!ToolUtil.isNull(dto.getSharetype())){
- paramList.add(dto.getSharetype());
- sql.append(" and p.sharetype = ? ");
- }
- if(!ToolUtil.isNull(dto.getIsopensocial())){
- paramList.add(dto.getIsopensocial());
- sql.append(" and p.isopensocial = ? ");
- }
- if(!ToolUtil.isNull(dto.getProvidezgname())){
- paramList.add("%"+dto.getProvidezgname()+"%");
- sql.append(" and p.providezgname like ? ");
- }
- //起始时间
- if(!ToolUtil.isNull(dto.getStartdate())){
- paramList.add(dto.getStartdate());
- sql.append("and p.updatetime >= ?");
- }
- //结束时间
- if(!ToolUtil.isNull(dto.getEnddate())){
- paramList.add(dto.getEnddate()+" 23:59:59");
- sql.append("and p.updatetime <= ?");
- }
- if(dto.getHitchStatus()!=null){
- paramList.add(dto.getHitchStatus()+"");
- if("1".equals(dto.getHitchStatus()+""))
-
- sql.append(" and p.hitch_status = ? ");
- else {
- sql.append(" and (p.hitch_status = ? or p.hitch_status is null) ");
- }
- }
- sql.append(" and t.createnameid ='").append(userInfo.getUserId()).append("'");
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- if(!ToolUtil.isNull(pag.getSortFiled())){
- if("infocode".equals(pag.getSortFiled())){
- sql.append(" order by p.infocode "+pag.getSortType());
- }
- else if("isopensocial".equals(pag.getSortFiled())){
- sql.append(" order by p.isopensocial "+pag.getSortType());
- }
- else if("sharetype".equals(pag.getSortFiled())){
- sql.append(" order by p.sharetype "+pag.getSortType());
- }
-
-
- }
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<TinfoClassDto>(){
- @Override
- public TinfoClassDto mapRow(ResultSet rs, int rowNum) throws SQLException {
- TinfoClassDto info = new TinfoClassDto();
- info.setId(rs.getString("id"));
- info.setInfocode(rs.getString("infocode"));
- info.setInfoname(rs.getString("infoname"));
- info.setInfotypename(rs.getString("infotypename"));
- info.setProvidename(rs.getString("providename"));
- info.setProvidezgname(rs.getString("providezgname"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setSharetype(rs.getString("sharetype"));
- info.setSourceid(rs.getString("sourceid"));
- info.setVersionid(rs.getInt("versionid"));
- info.setIsopensocial(rs.getString("isopensocial"));
- info.setHitchStatus(rs.getInt("hitch_status"));
-
- return info;
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public void unSubcri(String busId, User userInfo) {
- // TODO Auto-generated method stub
- subscribemanageRepository.unSubcri(busId,userInfo.getUserId(),ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- }
- public List<TinfoClassDto> getAll(Vector<String> v1, String id, String sourceid) {
- // TODO Auto-generated method stub
- StringBuffer sql=new StringBuffer("select id,infoname from t_infoclass " );
- List<TinfoClassDto> infoList = new ArrayList<TinfoClassDto>();
- List<String> paramList=new ArrayList<String>();
- sql.append(" where id!=? and sourceid!=? ");
- paramList.add(id);
- paramList.add(sourceid);
- String s="";
- for(String str:v1){
- if(str.length()>1&&s.indexOf(str+"|")<0)
- s+=str+"|";
- }
- if(!ToolUtil.isNull(s)){
- if("oracle".equals(database_type)){
- sql.append(" and REGEXP_LIKE(infoname, ?) ");
- paramList.add(s.substring(0, s.length()-1)+"");
- }
- else if("mysql".equals(database_type)){
- sql.append("and infoname REGEXP ? ");
- paramList.add(s.substring(0, s.length()-1)+"");
- }
- }
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- infoList = jdbcTemplate.query(sql.toString(), args,
- new RowMapper<TinfoClassDto>() {
- @Override
- public TinfoClassDto mapRow(ResultSet rs, int rowNum)
- throws SQLException {
- TinfoClassDto info = new TinfoClassDto();
- info.setId(rs.getString("id"));
- info.setInfoname(rs.getString("infoname"));
- return info;
- }
- }
- );
-
- return infoList;
- }
-
- //修改挂接上传文件信息
- public void updateTinfoClassHitUp(TinfoClassDto info) {
- // TODO Auto-generated method stub
- tinfoClassRepository.updateTinfoClassHitUpById(info.getId(), info.getHitchUpAdress(), info.getHitchUpName(), info.getHitchSize());
- }
- //修改挂接信息
- public void updateTinfoClassHitInfoById(TinfoClassDto info, User userInfo) {
- // TODO Auto-generated method stub
- tinfoClassRepository.updateTinfoClassHitInfoById(info.getId(), info.getHitch(),userInfo.getUserName(),ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"),info.getDbid());
- }
- public TinfoClass findTinfoClassByInfoCode(String infoCode) {
- // TODO Auto-generated method stub
- return tinfoClassRepository.findTinfoClassByInfoCode(infoCode);
- }
-
- public void syncSxmlInfo() {
- login();
- }
- public void login(){
- ObjectMapper mapper = new ObjectMapper();
- Map<String, String> paramsMap =new HashMap<String,String>();
- paramsMap.put("account", "gd_gxpt440000");
- paramsMap.put("password", "28c9e2d831ab4e86747220b04de4d5a0");
- paramsMap.put("zzjgdm", "");
- paramsMap.put("app_key", "gd_gxpt");
- paramsMap.put("app_secret", "FoZhPSOd9GOQExi5");
- String requestURL = "http://19.224.1.97:8086/service";
- String apiName = "sxml.security.login";
- String version = "1.0.0";
- String accessKey = "6b3131e4b91240b8bb3de475457f8ad2";
- String securityKey = "8ElYku6j9DWjz3xt9ohc6VY/dxY=";
- String csbresult="";
- try {
- csbresult = HttpCaller.changeCharset(HttpCaller.doPost(requestURL, apiName, version, paramsMap, accessKey, securityKey));
- Map map;
- try {
- map = mapper.readValue(csbresult, Map.class);
- list_new_LocalDirectory2(map.get("access_token")+"");
- } catch (JsonParseException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (JsonMappingException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- } catch (HttpCallerException e) {
- e.printStackTrace();
- }
- }
- public void list_new_LocalDirectory2(String access_token) {
- ObjectMapper mapper = new ObjectMapper();
- Calendar c = Calendar.getInstance();
- c.setTime(new Date());
- c.add(Calendar.DATE, -1);
- Date m = c.getTime();
- Map<String, String> paramsMap =new HashMap<String,String>();
- paramsMap.put("access_token", access_token);
- paramsMap.put("itemcode", "");
- paramsMap.put("startdate", ToolUtil.date2Str(m, "yyyy-MM-dd"));
- paramsMap.put("enddate", "");
- String requestURL = "http://19.224.1.97:8086/service";
- String apiName = "sxml.local_directory.list_new_LocalDirectory";
- String version = "1.0.0";
- String accessKey = "6b3131e4b91240b8bb3de475457f8ad2";
- String securityKey = "8ElYku6j9DWjz3xt9ohc6VY/dxY=";
- String csbresult="";
- try {
- csbresult = HttpCaller.changeCharset(HttpCaller.doPost(requestURL, apiName, version, paramsMap, accessKey, securityKey));
- if(csbresult.contains("SUCCESS")){
- try {
- Map map = mapper.readValue(csbresult, Map.class);
- List<Map> maplist=(List<Map>) map.get("data");
- int i=0;
- Sxcode sxcode=new Sxcode();
- for(Map t:maplist){
- sxcode.setCode(t.get("code")+"");
- sxcode.setFlag("0");
- sxcodeRepository.saveAndFlush(sxcode);
- }
-
-
- } catch (IOException e) {//
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
-
- } catch (HttpCallerException e) {
- e.printStackTrace();
- }
- List<Map<String,Object>> synlist=jdbcTemplate.queryForList("select code,flag from sxcode where flag='0' ");
- try {
- doReadList(synlist,access_token);
- } catch (InterruptedException | ExecutionException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- public void doReadList(List<Map<String,Object>> list,String access_token) throws InterruptedException, ExecutionException{
- /**接收集合各段的 执行的返回结果**/
- List<Future<List<Map<String,Object>>>> futureList = new ArrayList<Future<List<Map<String,Object>>>>();
- /**集合总条数**/
- int size = list.size();
- /**将集合切分的段数**/
- int sunSum = 20;
- int listStart,listEnd;
- /***当总条数不足10条时 用总条数 当做线程切分值**/
- if(sunSum > size){
- sunSum = size;
- }
- /**定义子线程**/
- SunSxmlCallable sunCallable;
- for (int i = 0; i < sunSum; i++) {
- /***计算切割 开始和结束**/
- listStart = size / sunSum * i ;
- listEnd = size / sunSum * ( i + 1 );
- /**最后一段线程会 出现与其他线程不等的情况**/
- if(i == sunSum - 1){
- listEnd = size;
- }
- /**线程切断**/
- List<Map<String,Object>> sunList = list.subList(listStart,listEnd);
- /**子线程初始化**/
- sunCallable = new SunSxmlCallable(sunList,access_token,i);
- /***多线程执行***/
- futureList.add(threadPoolTaskExecutor.submit(sunCallable));
- }
-
- }
-
-
- public void saveXxxBm(String infocode, String id) {
- // TODO Auto-generated method stub
- List<Map<String,Object>> list = jdbcTemplate.queryForList("select id,indexnum,xxxbm,glxxxid from t_infoclass_datameta where tinfoclassid=? order by indexnum ", new Object[]{id});
- int j=0;
- int bm=0;
-
- for(Map<String,Object> map:list){
- if(map.get("XXXBM")!=null&&!"".equals(map.get("XXXBM").toString())&&(map.get("glxxxid")==null||"".equals(map.get("glxxxid").toString()))){
- String temp = map.get("XXXBM").toString();
- try{ if(temp.length()>3){
- if(Integer.valueOf(temp.substring(temp.length()-3, temp.length()))>bm){
- bm = Integer.valueOf(temp.substring(temp.length()-3, temp.length()));
- }
- }
-
- }
- catch(NumberFormatException e){
-
- }
- }
- }
- for(int i=0;i<list.size();i++){
- if(list.get(i).get("XXXBM")==null||"".equals(String.valueOf(list.get(i).get("XXXBM")))){
- bm=bm+1;
- jdbcTemplate.update("update t_infoclass_datameta set xxxbm=? where id=? ", new Object[]{infocode+ToolUtil.lpad(bm+"", 3, "0"),list.get(i).get("ID")});
-
- }
- }
- }
- public String generateSql(String infoclassid,String database,String shareid) {
- StringBuffer sql=new StringBuffer("");
- StringBuffer sqlshareid=new StringBuffer("");
- if(!ToolUtil.isNull(shareid)) {
- sqlshareid.append(" and id in (select trim(T_INFOCLASS_DATAMETA_ID) from apply_class where T_SHAREAPPLY_ID='").append(shareid).append("') ");
- }
- String generatesql="";
- Map<String,Object> tablenameMap= jdbcTemplate.queryForMap("select infocode,versionid,infoname from t_infoclass where id=? ", new Object[]{infoclassid});
- if(database_type.equals("mysql")){
- sql.append("select p .isprimary, p .xxxmc, concat('F_' , replace (p .xxxbm, '/', '_')) field_name, p .datatype, p.datasize from t_infoclass_datameta p where p .tinfoclassid = ? ").append(sqlshareid).append(" order by xxxbm") ;
- }
- else{
- sql.append("select p .isprimary, p .xxxmc, 'F_' || replace (p .xxxbm, '/', '_') field_name, p .datatype, p.datasize from t_infoclass_datameta p where p .tinfoclassid = ? ").append(sqlshareid).append(" order by xxxbm");
- }
- String table_name="";
- String infocode=String.valueOf(tablenameMap.get("infocode")==null?"":tablenameMap.get("infocode"));
- String versionid=String.valueOf(tablenameMap.get("versionid")==null?"":tablenameMap.get("versionid"));
- table_name="T_"+(infocode.replace("/", "_"));//+"_V"+versionid
- List<Map<String,Object>> maplist = jdbcTemplate.queryForList(sql.toString(), new Object[]{infoclassid});
- generatesql = ToolUtil.generateCreateTableSql(table_name,maplist,database,String.valueOf(tablenameMap.get("infoname")));
- return generatesql;
- }
- public void generateGxwzinfo() {
- List<Map<String,Object>> maplist = jdbcTemplate.queryForList("select infocode,infoname,providebmname,versionid,hitch_status from t_infoclass where latestversion='1' and inprocess='2'");
- for(Map<String,Object> map:maplist){
- String infocode=String.valueOf(map.get("infocode"));
- //判断是否存在infocode
- String table_name="T_"+(infocode.replace("/", "_"));//+"_V"+String.valueOf(map.get("versionid"))
- List<Map<String,Object>> result=jdbcTemplate.queryForList("select catalog_table_name from GXWZ_INFOCLASS_CATALOG_REL where infoclass_code=? ",new Object[]{infocode});
- if(result!=null&&result.size()>0){//
- if(String.valueOf(result.get(0).get("catalog_table_name")).contains(infocode.replace("/", "_"))){
- jdbcTemplate.update(
- "update gxwz_infoclass_catalog_rel set infoclass_code=?,infoclass_name=?,infoclass_dept=?,catalog_table_name=?,ishangon=? where infoclass_code=?", new Object[]{
- String.valueOf(map.get("infocode")),String.valueOf(map.get("infoname")),String.valueOf(map.get("providebmname")),table_name,String.valueOf(map.get("hitch_status")),String.valueOf(map.get("infocode"))
-
- });
- }
-
- }
- else{
- jdbcTemplate.update(
- "insert into gxwz_infoclass_catalog_rel ( infoclass_code,infoclass_name,infoclass_dept,catalog_table_name,ishangon) values (?,?,?,?,?) ", new Object[]{
- String.valueOf(map.get("infocode")),String.valueOf(map.get("infoname")),String.valueOf(map.get("providebmname")),table_name,String.valueOf(map.get("hitch_status"))
- });
- }
- }
-
- }
- public void updateInfocatalogJob(boolean isAll) {
- List<Map<String,Object>> maplist=new ArrayList<>();
- if(isAll)
- maplist = jdbcTemplate.queryForList("select id,infotypeid from t_infoclass ");
- else
- maplist = jdbcTemplate.queryForList("select id,infotypeid from t_infoclass where infocatalogcode is null");
- for(Map<String,Object> map:maplist){
- String infotypeid=String.valueOf(map.get("infotypeid"));
- String infocatalogcode="";
- List<Map<String,Object>> templist =jdbcTemplate.queryForList("select presid,rescode from t_res_classify where resid=?", new Object[]{infotypeid});
- while(templist!=null&&templist.size()>0){
- infocatalogcode=templist.get(0).get("rescode")+infocatalogcode;
- templist =jdbcTemplate.queryForList("select presid,rescode from t_res_classify where resid=?", new Object[]{templist.get(0).get("presid")});
- }
- jdbcTemplate.update("update t_infoclass set infocatalogcode=? where id=?", new Object[]{infocatalogcode,map.get("id")});
- }
-
- }
- public TinfoClassDto getDefaultInfoByUserId(String userId) {
- TinfoClassDto dto =new TinfoClassDto();
- String sql="select t.dept_name,t.dept_id,t.ywbmid,t.ywbmcode,t.pdeptids,t.ywbmname,t.creditno,t.xzqhcode,t.xzqhid,t.xzqhname,getParentList(x.resid) resname,x.rescode,x.resid from (select q.dept_name,q.dept_id,q.ywbmcode,q.ywbmname,q.creditno,xzqhcode,xzqhid,xzqhname,ywbmid,q.pdeptids from dept_user p,deptinfo q where p.dept_id=q.dept_id and creditno is not null and user_id=?) t left join t_res_classify x on t.dept_id=x.deptid";
- List<Map<String,Object>> maplist=new ArrayList<>();
- maplist=jdbcTemplate.queryForList(sql,new Object[] {userId});
- if(maplist!=null&&maplist.size()>0) {
- Map<String,Object> map =maplist.get(0);
- if(ToolUtil.ToString(map.get("dept_name")).contains("c271fb9c6e7e4faab8d27c91352b597d")) {
- dto.setSharerange("市本级");
- }else {
- dto.setSharerange("其他");
- }
- dto.setProvidebmname(ToolUtil.ToString(map.get("dept_name")));
- dto.setProvidebmcode(ToolUtil.ToString(map.get("dept_id")));
- dto.setXzqhcode(ToolUtil.ToString(map.get("xzqhcode")));
- dto.setXzqhid(ToolUtil.ToString(map.get("xzqhid")));
- dto.setXzqhname(ToolUtil.ToString(map.get("xzqhname")));
- dto.setCreditno(ToolUtil.ToString(map.get("creditno")));
- dto.setInfotype(ToolUtil.ToString(map.get("rescode")));
- dto.setInfotypeid(ToolUtil.ToString(map.get("resid")));
- dto.setInfotypename(ToolUtil.ToString(map.get("resname")).replace("直辖市-天津市-", "").replace("市本级-", ""));
- dto.setYwbmcode(ToolUtil.ToString(map.get("ywbmcode")));
- dto.setYwbmname(ToolUtil.ToString(map.get("ywbmname")));
- dto.setYwbmid(ToolUtil.ToString(map.get("ywbmid")));
- }
- return dto;
- }
- public void deptSynToBusiness() {
- List<Map<String,Object>> maplist2 =jdbcTemplate.queryForList("select p.dept_id,q.id,q.code_code,q.code_name from deptinfo p,code q where p.xzqhid=q.id and (p.xzqhname!=q.code_name or p.xzqhcode!=q.code_code)");
- for(Map<String,Object> map:maplist2) {
- jdbcTemplate.update("update deptinfo set xzqhname=?,xzqhid=?,xzqhcode=? where dept_id=?", new Object[] {
- map.get("code_name")
- ,map.get("id")
- ,map.get("code_code")
- ,map.get("dept_id")
- }
- );
-
- }
- //信息类提供方部门修改
- List<Map<String,Object>> maplist = jdbcTemplate.queryForList("select distinct q.dept_name,q.dept_id,q.xzqhcode,q.xzqhname,q.ywbmname,q.ywbmcode,q.creditno from t_infoclass p,deptinfo q where p.providebmcode=q.dept_id and (p.providebmname!=q.dept_name or p.xzqhcode!=q.xzqhcode or p.ywbmcode!=q.ywbmcode or p.creditno!=q.creditno or q.xzqhname!=p.xzqhname or p.ywbmname!=q.ywbmname)");
- for(Map<String,Object>map:maplist) {
- jdbcTemplate.update("update t_infoclass set providebmname=?,xzqhcode=?,xzqhname=?,ywbmname=?,ywbmcode=?,creditno=? where providebmcode=?",
- new Object[] {
- map.get("dept_name"),map.get("xzqhcode"),map.get("xzqhname"),map.get("ywbmname")
- ,map.get("ywbmcode"),map.get("creditno"),map.get("dept_id")
- }
- );
- }
- //服务注册业务信息同步
- List<Map<String,Object>> mapfwzclist = jdbcTemplate.queryForList("select dept_id,dept_name from t_service_reginfo p,deptinfo q where p.provideid=q.dept_id and p.providename!=q.dept_name");
- for(Map<String,Object>map:mapfwzclist) {
- jdbcTemplate.update("update t_service_reginfo set providename=? where provideid=?",
- new Object[] {
- map.get("dept_name"),map.get("dept_id")
- }
- );
- }
- //共享申请信息同步
- List<Map<String,Object>> mapgxqlist = jdbcTemplate.queryForList("select dept_id,dept_name from t_shareapply p,deptinfo q where p.applydeptid=q.dept_id and p.applydeptname!=q.dept_name");
- for(Map<String,Object>map:mapgxqlist) {
- jdbcTemplate.update("update t_shareapply set applydeptname=? where applydeptid=?",
- new Object[] {
- map.get("dept_name"),map.get("dept_id")
- }
- );
- }
- //接口申请信息同步
- List<Map<String,Object>> mapjksqlist = jdbcTemplate.queryForList("select q.dept_id,q.dept_name from t_service_applyinfo p,deptinfo q where p.mingchengid=q.dept_id and p.mingcheng!=q.dept_name");
- for(Map<String,Object>map:mapjksqlist) {
- jdbcTemplate.update("update t_service_applyinfo set mingcheng=? where mingchengid=?",
- new Object[] {
- map.get("dept_name"),map.get("dept_id")
- }
- );
- }
-
- }
- public boolean xxxIsModified(String id, String parentid) {
- StringBuffer sql=new StringBuffer("select datatype,datasize,xxxmc,xxxbm,datametaid,metaname from t_infoclass_datameta where tinfoclassid=?");
- List<Map<String,Object>> infolist = jdbcTemplate.queryForList(sql.toString(),new Object[] {id});
- List<Map<String,Object>> parentlist = jdbcTemplate.queryForList(sql.toString(),new Object[] {parentid});
- if(infolist==null) {
- infolist=new ArrayList<>();
- }
- if(parentlist==null) {
- parentlist=new ArrayList<>();
- }
- if(infolist.size()!=parentlist.size()) {//信息项个数不同,说明有增删
- return true;
- }
- else {
- for(Map<String,Object> map:infolist) {
- boolean flag=true;
- if(map.get("xxxbm")==null||"".equals(String.valueOf(map.get("xxxbm")))){
- return true;
- }
- else{
- for(Map<String,Object> p_map:parentlist) {
- if(String.valueOf(map.get("datatype")==null?"":map.get("datatype")).equals(String.valueOf(p_map.get("datatype")==null?"":p_map.get("datatype")))
- &&String.valueOf(map.get("datasize")==null?"":map.get("datasize")).equals(String.valueOf(p_map.get("datasize")==null?"":p_map.get("datasize")))
- &&String.valueOf(map.get("xxxmc")==null?"":map.get("xxxmc")).equals(String.valueOf(p_map.get("xxxmc")==null?"":p_map.get("xxxmc")))
- &&String.valueOf(map.get("datametaid")==null?"":map.get("datametaid")).equals(String.valueOf(p_map.get("datametaid")==null?"":p_map.get("datametaid")))
- &&String.valueOf(map.get("metaname")==null?"":map.get("metaname")).equals(String.valueOf(p_map.get("metaname")==null?"":p_map.get("metaname")))){
- flag=false;
- }
- /*
- if((String.valueOf(map.get("xxxbm")==null?"":map.get("xxxbm")).equals(String.valueOf(p_map.get("xxxbm")==null?"":p_map.get("xxxbm")))
- &&
- !String.valueOf(map.get("xxxmc")==null?"":map.get("xxxmc")).equals(String.valueOf(p_map.get("xxxmc")==null?"":p_map.get("xxxmc")))
- )||
- (!String.valueOf(map.get("xxxbm")==null?"":map.get("xxxbm")).equals(String.valueOf(p_map.get("xxxbm")==null?"":p_map.get("xxxbm")))
- &&
- String.valueOf(map.get("xxxmc")==null?"":map.get("xxxmc")).equals(String.valueOf(p_map.get("xxxmc")==null?"":p_map.get("xxxmc")))
- )
- ){
- flag=false;
-
- }
- */
- }
-
- if(flag) {
- return true;
- }
- }
- }
- return false;
- }
- }
- public void generateGlflJob() {
- List<Map<String,Object>> maplist = jdbcTemplate.queryForList("select group_concat(q.resname) glfl,p.tinfoclassid id from t_infoclass_res p,t_res_classify q,t_infoclass z where p.resid=q.resid and z.glinfotypename is null and z.id=p.tinfoclassid group by p.tinfoclassid");
- for(Map<String,Object> map:maplist) {
- jdbcTemplate.update("update t_infoclass set glinfotypename=? where id=?", new Object[] {map.get("glfl"),map.get("id")});
- }
- List<Map<String,Object>> glxtmaplist = jdbcTemplate.queryForList("select group_concat(systeminfo_name) systeminfo,infoclass_id from t_systeminfo_infoclass group by infoclass_id");
- for(Map<String,Object> map:glxtmaplist) {
- jdbcTemplate.update("update t_infoclass set systeminfo=? where id=?", new Object[] {map.get("systeminfo"),map.get("infoclass_id")});
- }
- List<Map<String,Object>> maplist2 = jdbcTemplate.queryForList("select id,infoname,infocode,hitch_status,p.gjsj,p.gjr,p.gjrid from t_infoclass q,t_service_reginfo p where q.sharemodetypename='接口' and instr(p.classid,q.id)>0 and p.inprocess='2' and p.isgj='1' and q.hitch_status=0 ");
- for(Map<String,Object> map:maplist2) {
- jdbcTemplate.update("update t_infoclass q set q.hitch=?,q.hitchdate=?,q.hitchuser=?,q.hitch_size=?,q.hitch_status=?,q.hitch_up_adress=?,q.hitch_up_name=? where q.id=?", new Object[] {
- "",
- map.get("gjsj"),
- map.get("gjr"),
- 0,
- 1,
- "",
- "",
- map.get("id")
- }
- );
- }
-
- }
- public void generateHitchJob() {
- List<Map<String,Object>> maplist = jdbcTemplate.queryForList("select p.id,p.parentid,q.hitch,q.hitchdate,q.hitchuser,q.hitch_size,q.hitch_status,q.hitch_up_adress,q.hitch_up_name from t_infoclass p,t_infoclass q where p.latestversion='1' and p.inprocess='2' and p.gjcheckstate is null and (p.hitch_status is null or p.hitch_status=0) and p.parentid=q.id and p.versionid=q.versionid " +
- " and q.hitch_status=1");
- for(Map<String,Object> map:maplist) {
- jdbcTemplate.update("update t_infoclass q set q.hitch=?,q.gjcheckstate=?,q.hitchdate=?,q.hitchuser=?,q.hitch_size=?,q.hitch_status=?,q.hitch_up_adress=?,q.hitch_up_name=? where q.id=?", new Object[] {
- map.get("hitch"),
- "2",
- map.get("hitchdate"),
- map.get("hitchuser"),
- map.get("hitch_size"),
- map.get("hitch_status"),
- map.get("hitch_up_adress"),
- map.get("hitch_up_name"),
- map.get("id")
- }
- );
- }
- List<Map<String,Object>> maplist2 = jdbcTemplate.queryForList("select p.id,p.parentid,p.infoname,q.infoname pinfoname from t_infoclass p,t_infoclass q where p.parentid=q.id and p.versionid=q.versionid and p.latestversion='1' and p.inprocess='2'");
- for(Map<String,Object> map:maplist2) {
- jdbcTemplate.update("update t_service_reginfo set classid=REPLACE(classid,?,?),classname=REPLACE(classname,?,?)", new Object[] {
- map.get("parentid")+";",
- map.get("id")+";",
- map.get("pinfoname")+";",
- map.get("infoname")+";"
- }
- );
- }
-
-
-
- }
- /*生成超时提醒信息
- * */
- public void generateDelayRemindInfo() {
- //信息类注册
- TmessageInfo info=null;
- // List<Map<String,Object>> maplist = jdbcTemplate.queryForList("select assignee,act_name,count(1) num from v_tasklist_delay p,t_infoclass q where p.proc_inst_id=q.processid group by assignee,act_name");
- // for(Map<String,Object> map:maplist) {
- // info =new TmessageInfo();
- // info.setId(ToolUtil.getUUID());
- // info.setTitle(String.valueOf(map.get("act_name")));
- // info.setContent("您有"+String.valueOf(map.get("num"))+"个信息类注册("+String.valueOf(map.get("act_name"))+")超时未处理,请及时到天津市信息资源目录系统进行处理");
- // info.setSendtime(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- // info.setState("1");
- // info.setReceiver(String.valueOf(map.get("assignee")));
- // tmessageInfoService.saveInfo(info);
- // }
- //信息类共享申请
- List<Map<String,Object>> worklist = jdbcTemplate.queryForList("select workdate from workcalendar where date_format(`workcalendar`.`workdate`,'%Y-%m-%d')=? and iswork='0'", new Object[] {ToolUtil.date2Str(new Date(), "yyyy-MM-dd")});
- if(worklist!=null&&worklist.size()>0) {//只有工作日才生成预警提醒任务
- List<Map<String,Object>> applylist = jdbcTemplate.queryForList("select assignee,act_name,count(1) num from v_tasklist_delay p,t_shareapply q where p.proc_inst_id=q.processid group by assignee,act_name");
- for(Map<String,Object> map:applylist) {
- info =new TmessageInfo();
- info.setId(ToolUtil.getUUID());
- info.setTitle(String.valueOf(map.get("act_name")));
- info.setContent("您有"+String.valueOf(map.get("num"))+"个数据共享申请("+String.valueOf(map.get("act_name"))+")超时未处理,请及时到进行处理");
- info.setSendtime(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- info.setState("1");
- info.setReceiver(String.valueOf(map.get("assignee")));
- tmessageInfoService.saveInfo(info);
- }
- //服务注册
- List<Map<String,Object>> servicelist = jdbcTemplate.queryForList("select assignee,act_name,count(1) num from v_tasklist_delay p,t_service_reginfo q where p.proc_inst_id=q.processid group by assignee,act_name");
- for(Map<String,Object> map:servicelist) {
- info =new TmessageInfo();
- info.setId(ToolUtil.getUUID());
- info.setTitle(String.valueOf(map.get("act_name")));
- info.setContent("您有"+String.valueOf(map.get("num"))+"个服务注册("+String.valueOf(map.get("act_name"))+")超时未处理,请及时进行处理");
- info.setSendtime(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- info.setState("1");
- info.setReceiver(String.valueOf(map.get("assignee")));
- tmessageInfoService.saveInfo(info);
- }
- //服务申请
- List<Map<String,Object>> serviceApplylist = jdbcTemplate.queryForList("select assignee,act_name,count(1) num from v_tasklist_delay p,t_service_applyinfo q where p.proc_inst_id=q.processid group by assignee,act_name");
- for(Map<String,Object> map:serviceApplylist) {
- info =new TmessageInfo();
- info.setId(ToolUtil.getUUID());
- info.setTitle(String.valueOf(map.get("act_name")));
- info.setContent("您有"+String.valueOf(map.get("num"))+"个服务共享申请("+String.valueOf(map.get("act_name"))+")超时未处理,请及时进行处理");
- info.setSendtime(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- info.setState("1");
- info.setReceiver(String.valueOf(map.get("assignee")));
- tmessageInfoService.saveInfo(info);
- }
- }
- }
- /**
- * 短信发送
- */
- public void delayRemindSend() {
- // TODO Auto-generated method stub
- //判断当前是否是工作日
- List<Map<String,Object>> worklist = jdbcTemplate.queryForList("select workdate from workcalendar where date_format(`workcalendar`.`workdate`,'%Y-%m-%d')=? and iswork='0'", new Object[] {ToolUtil.date2Str(new Date(), "yyyy-MM-dd")});
- if(worklist!=null&&worklist.size()>0) {
- log.info("工作日发送短信提醒");
- List<Map<String,Object>> sendlist = jdbcTemplate.queryForList("select p.content,p.id,q.phone_num,p.dealtime,q.user_name from t_messageinfo p,userinfo q where p.receiver=q.user_id and (p.dealtime='' or p.dealtime is null)");
- String serialno="";//短信序列号,可以根据该序列号 获取短信发送情况
- for(Map<String,Object> map:sendlist) {
- try {
- serialno = ToolUtil.getGuid();
- log.info(String.valueOf(map.get("content")));
- String content=String.valueOf(map.get("content")).replace("您", String.valueOf(map.get("user_name"))+"您好,您");
- ToolUtil.sendMsg(String.valueOf(content), String.valueOf(map.get("phone_num")), serialno);
- jdbcTemplate.update("update t_messageinfo set dealtime=?,serialno=? where id=?",new Object[]
- {ToolUtil.date2Str(new Date(),"yyyy-MM-dd HH:mm:ss")
- ,serialno
- ,map.get("id")
- });
- } catch (UnsupportedEncodingException e) {
- log.info("短信接口异常");
- }
-
- }
- }
- else {
- log.info("非工作日不发送短信提醒");
- }
- }
- public Pagination<DelayDataShareInfo> findDelayDataShareInfoList(DelayDataShareInfo dto,
- Pagination<DelayDataShareInfo> pag, User userInfo) {
- StringBuffer sql=new StringBuffer("select distinct w.providebmcode,w.providebmname,p.task_id,w.infoname,w.infocode,p.act_name,q.applydeptname,q.applydate,p.create_time from v_tasklist_delay p,t_shareapply q,t_infoclass w " +
- "where p.proc_inst_id=q.processid and q.tinfoclassid=w.id ");
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(dto.getProvidebmcode())) {
- sql.append(" and w.providebmcode=? ");
- paramList.add(dto.getProvidebmcode());
- }
- if(!ToolUtil.isNull(dto.getInfoname())) {
- sql.append(" and w.infoname=? ");
- paramList.add(dto.getInfoname());
- }
- if(!ToolUtil.isNull(dto.getInfocode())) {
- sql.append(" and w.infocode=? ");
- paramList.add(dto.getInfocode());
- }
- if(!ToolUtil.isNull(dto.getTaskname())) {
- sql.append(" and p.act_name=? ");
- paramList.add(dto.getTaskname());
- }
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
-
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<DelayDataShareInfo>(){
- @Override
- public DelayDataShareInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
- DelayDataShareInfo info = new DelayDataShareInfo();
- info.setApplydate(rs.getString("applydate"));
- info.setCheckdate(rs.getString("create_time"));
- info.setInfoname(rs.getString("infoname"));
- info.setInfocode(rs.getString("infocode"));
- info.setTaskname(rs.getString("act_name"));
- info.setRequirename(rs.getString("applydeptname"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setProvidebmcode(rs.getString("providebmcode"));
- return info;
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public Pagination<DelayServiceShareInfo> findDelayServiceShareInfo(DelayServiceShareInfo dto,
- Pagination<DelayServiceShareInfo> pag, User userInfo) {
- // TODO Auto-generated method stub
- StringBuffer sql=new StringBuffer("select distinct w.PROVIDEid,w.PROVIDENAME,p.TASK_ID,p.act_name,w.cnname,w.apicode,q.createtime,p.create_time,q.mingcheng from v_tasklist_delay p,t_service_applyinfo q,t_service_reginfo w" +
- " where p.proc_inst_id=q.processid and q.reqid=w.regid ");
- List<String> paramList=new ArrayList<String>();
- if(!ToolUtil.isNull(dto.getProvidebmcode())) {
- sql.append(" and w.PROVIDEid=? ");
- paramList.add(dto.getProvidebmcode());
- }
- if(!ToolUtil.isNull(dto.getServicename())) {
- sql.append(" and w.cnname=? ");
- paramList.add(dto.getServicename());
- }
- if(!ToolUtil.isNull(dto.getServicecode())) {
- sql.append(" and w.apicode=? ");
- paramList.add(dto.getServicecode());
- }
- if(!ToolUtil.isNull(dto.getTaskname())) {
- sql.append(" and p.act_name=? ");
- paramList.add(dto.getTaskname());
- }
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
-
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<DelayServiceShareInfo>(){
- @Override
- public DelayServiceShareInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
- DelayServiceShareInfo info = new DelayServiceShareInfo();
- info.setApplydate(rs.getString("createtime"));
- info.setCheckdate(rs.getString("create_time"));
- info.setServicename(rs.getString("cnname"));
- info.setServicecode(rs.getString("apicode"));
- info.setTaskname(rs.getString("act_name"));
- info.setRequirename(rs.getString("mingcheng"));
- info.setProvidebmname(rs.getString("providename"));
- info.setProvidebmcode(rs.getString("provideid"));
- return info;
- }
- },jdbcTemplate,database_type);
- return pag;
- }
- public void generateMsgInfoByProvidebmcode(String busId,User userInfo) {
- TmessageInfo info=null;
-
- //信息类共享申请
- List<Map<String,Object>> applylist = jdbcTemplate.queryForList("select assignee,act_name,count(1) num from v_tasklist_delay p,t_shareapply q,t_infoclass w where p.proc_inst_id=q.processid and q.tinfoclassid=w.id and w.providebmcode=? group by assignee,act_name",new Object[] {busId});
- for(Map<String,Object> map:applylist) {
- info =new TmessageInfo();
- info.setId(ToolUtil.getUUID());
- info.setTitle(String.valueOf(map.get("act_name")));
- info.setContent("您有"+String.valueOf(map.get("num"))+"个数据共享申请("+String.valueOf(map.get("act_name"))+")超时未处理,请及时进行处理");
- info.setSendtime(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- info.setState("1");
- info.setReceiver(String.valueOf(map.get("assignee")));
- info.setSenduser(userInfo.getUserId());
- info.setProvidebmcode(busId);
- tmessageInfoService.saveInfo(info);
- }
- //服务申请
- List<Map<String,Object>> serviceApplylist = jdbcTemplate.queryForList("select assignee,act_name,count(1) from v_tasklist_delay p,t_service_applyinfo q,t_service_reginfo w where p.proc_inst_id=q.processid and q.reqid=w.regid and w.provideid=? group by assignee,act_name",new Object[] {busId});
- for(Map<String,Object> map:serviceApplylist) {
- info =new TmessageInfo();
- info.setId(ToolUtil.getUUID());
- info.setTitle(String.valueOf(map.get("act_name")));
- info.setContent("您有"+String.valueOf(map.get("num"))+"个服务共享申请("+String.valueOf(map.get("act_name"))+")超时未处理,请及时进行处理");
- info.setSendtime(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- info.setState("1");
- info.setReceiver(String.valueOf(map.get("assignee")));
- info.setSenduser(userInfo.getUserId());
- info.setProvidebmcode(busId);
- tmessageInfoService.saveInfo(info);
- }
-
- }
- public void saveTguajieopinionList(TguajieopinionList opinioninfo) {
- // TODO Auto-generated method stub
- tguajieopinionListRepository.save(opinioninfo);
- }
- public List<TguajieopinionList> findTguajieopinionListByDataId(String id, String type) {
-
- return tguajieopinionListRepository.findTguajieopinionListByDataId(id,type);
- }
-
- public List<TinfoClass> findListByIds(String ids){
- List listid = new ArrayList();
- for (String id : ids.split(";")) {
- if(id!=null && !id.trim().isEmpty()){
- listid.add(id);
- }
- }
- return tinfoClassRepository.getData(listid);
- }
- public IndicatorsDto findIndicatorsInfoByDeptid(String deptids) {
- IndicatorsDto indicator =new IndicatorsDto();
- //1
- Object[] ywfglFargs = new Object[]{};
- StringBuffer ywfglFSql= new StringBuffer("select count(1) ywfglf from t_subpower_responsibility where state=1 ");
- if(!ToolUtil.isNull(deptids)) {
- ywfglFSql.append(" and mainid in (select id from t_power_responsibility where instr(?,enforcementbody)>0) ");
- ywfglFargs=new Object[1];
- ywfglFargs[0]=deptids;
- }
- Map map = jdbcTemplate.queryForMap(ywfglFSql.toString(), ywfglFargs);
- indicator.setYwfglF(((Long) map.get("ywfglf")).intValue());
-
- Object[] ywfglCargs = new Object[]{};
- StringBuffer ywfglCSql= new StringBuffer("select count(1) ywfglc from t_subpower_responsibility z where mainid in (select id from t_power_responsibility where state=1) and exists (select q.subid from t_infoclass p ,t_subres_infoclass q where p.id=q.infoclassid and latestversion='1' and p.inprocess='2' and q.subid=z.id)");
- if(!ToolUtil.isNull(deptids)) {
- ywfglCSql=new StringBuffer("select count(1) ywfglc from t_subpower_responsibility z where mainid in (select id from t_power_responsibility where instr(?,enforcementbody)>0 and state=1) and (exists (select q.subid from t_infoclass p ,t_subres_infoclass q where p.id=q.infoclassid and instr(?,p.providebmcode)>0 and p.inprocess='2' and q.subid=z.id) or exists (select id from t_systeminfo_qz where qzid=z.id))");
- ywfglCargs=new Object[2];
- ywfglCargs[0]=deptids;
- ywfglCargs[1]=deptids;
- }
- Map map1 = jdbcTemplate.queryForMap(ywfglCSql.toString(), ywfglCargs);
- indicator.setYwfglC(((Long) map1.get("ywfglc")).intValue());
- //2
-
-
- Object[] yyfglFargs = new Object[]{};
- StringBuffer yyfglFSql= new StringBuffer("select count(1) yyfglf from t_system_info where (isdelete is null or isdelete='') ");
- if(!ToolUtil.isNull(deptids)) {
- yyfglFSql=new StringBuffer(" select count(1) yyfglf from t_system_info where (isdelete is null or isdelete='') and instr(?,sys_dept_id)>0");
- yyfglFargs=new Object[1];
- yyfglFargs[0]=deptids;
- }
- Map map2 = jdbcTemplate.queryForMap(yyfglFSql.toString(), yyfglFargs);
- indicator.setYyfglF(((Long) map2.get("yyfglf")).intValue());
-
-
- Object[] yyfglCargs = new Object[]{};
- StringBuffer yyfglCSql= new StringBuffer("select count(1) yyfglc from t_system_info p where (isdelete is null or isdelete='') and exists (select systeminfo_id from t_systeminfo_infoclass z where systeminfo_id=p.sys_id and exists( select * from t_infoclass where latestversion='1' and inprocess='2' and id=z.infoclass_id))");
- if(!ToolUtil.isNull(deptids)) {
- yyfglCSql=new StringBuffer("select count(1) yyfglc from t_system_info p where instr(?,sys_dept_id)>0 and (isdelete is null or isdelete='') and exists(select systeminfo_id from t_systeminfo_infoclass z where systeminfo_id=p.sys_id and exists( select * from t_infoclass where latestversion='1' and inprocess='2' and instr(?,providebmcode)>0 and id=z.infoclass_id))");
- yyfglCargs=new Object[2];
- yyfglCargs[0]=deptids;
- yyfglCargs[1]=deptids;
- }
- Map map3 = jdbcTemplate.queryForMap(yyfglCSql.toString(), yyfglCargs);
- indicator.setYyfglC(((Long) map3.get("yyfglc")).intValue());
-
- //3
- Object[] qzgllFargs = new Object[]{};
- StringBuffer qzgllFSql= new StringBuffer(" select count(1) qzgllf from t_infoclass p where p.LATESTVERSION='1' and p.INPROCESS='2' ");
- if(!ToolUtil.isNull(deptids)) {
- qzgllFSql=new StringBuffer(" select count(1) qzgllf from t_infoclass p where p.LATESTVERSION='1' and p.INPROCESS='2' and instr(?,providebmcode)>0");
- qzgllFargs=new Object[1];
- qzgllFargs[0]=deptids;
- }
- Map map4 = jdbcTemplate.queryForMap(qzgllFSql.toString(), qzgllFargs);
- indicator.setQzgllF(((Long) map4.get("qzgllf")).intValue());
-
- Object[] qzgllCargs = new Object[]{};
- StringBuffer qzgllCSql= new StringBuffer(" select count(1) qzgllc from t_infoclass p where p.LATESTVERSION='1' and p.INPROCESS='2' and exists(select id from t_subres_infoclass where infoclassid=p.id) ");
- if(!ToolUtil.isNull(deptids)) {
- qzgllCSql=new StringBuffer(" select count(1) qzgllc from t_infoclass p where p.LATESTVERSION='1' and p.INPROCESS='2' and instr(?,providebmcode)>0 and exists(select id from t_subres_infoclass where infoclassid=p.id)");
- qzgllCargs=new Object[1];
- qzgllCargs[0]=deptids;
- }
- Map map5 = jdbcTemplate.queryForMap(qzgllCSql.toString(), qzgllCargs);
- indicator.setQzgllC(((Long) map5.get("qzgllc")).intValue());
- //4
-
- indicator.setXtgllF(((Long) map4.get("qzgllf")).intValue());
-
- Object[] xtgllCargs = new Object[]{};
- StringBuffer xtgllCSql= new StringBuffer(" select count(1) xtgllc from t_infoclass p where p.LATESTVERSION='1' and p.INPROCESS='2' and exists(select systeminfoclass_ID from t_systeminfo_infoclass where infoclass_id=p.id )");
- if(!ToolUtil.isNull(deptids)) {
- xtgllCSql=new StringBuffer(" select count(1) xtgllc from t_infoclass p where p.LATESTVERSION='1' and p.INPROCESS='2' and instr(?,providebmcode)>0 and exists(select systeminfoclass_ID from t_systeminfo_infoclass where infoclass_id=p.id )");
- xtgllCargs=new Object[1];
- xtgllCargs[0]=deptids;
- }
- Map map7 = jdbcTemplate.queryForMap(xtgllCSql.toString(), xtgllCargs);
- indicator.setXtgllC(((Long) map7.get("xtgllc")).intValue());
- //5
- Object[] gjFargs = new Object[]{};
- StringBuffer gjFSql= new StringBuffer(" select count(1) gjlf from t_infoclass where inprocess='2' and latestversion='1' and sharetype!='3'");
- if(!ToolUtil.isNull(deptids)) {
- gjFSql=new StringBuffer(" select count(1) gjlf from t_infoclass where inprocess='2' and latestversion='1' and instr(?,providebmcode)>0 and sharetype!='3'");
- gjFargs=new Object[1];
- gjFargs[0]=deptids;
- }
- Map map8 = jdbcTemplate.queryForMap(gjFSql.toString(), gjFargs);
- indicator.setGjlF(((Long) map8.get("gjlf")).intValue());
- Object[] gjlCargs = new Object[]{};
- StringBuffer gjlCSql= new StringBuffer(" select count(1) gjlc from t_infoclass where inprocess='2' and latestversion='1' and hitch_status=1 and sharetype!='3'");
- if(!ToolUtil.isNull(deptids)) {
- gjlCSql=new StringBuffer(" select count(1) gjlc from t_infoclass where inprocess='2' and latestversion='1' and hitch_status=1 and instr(?,providebmcode)>0 and sharetype!='3'");
- gjlCargs=new Object[1];
- gjlCargs[0]=deptids;
- }
- Map map9 = jdbcTemplate.queryForMap(gjlCSql.toString(), gjlCargs);
- indicator.setGjlC(((Long) map9.get("gjlc")).intValue());
-
-
- Object[] kblcCargs = new Object[]{};
- StringBuffer kblcCSql= new StringBuffer(" select count(1) kblc from t_infoclass where inprocess='2' and latestversion='1' and sharemodetypename='数据库' ");
- if(!ToolUtil.isNull(deptids)) {
- kblcCSql=new StringBuffer(" select count(1) kblc from t_infoclass where inprocess='2' and latestversion='1' and sharemodetypename='数据库' and instr(?,providebmcode)>0 ");
- kblcCargs=new Object[1];
- kblcCargs[0]=deptids;
- }
- Map map10 = jdbcTemplate.queryForMap(kblcCSql.toString(), kblcCargs);
- Object[] kblFargs = new Object[]{};
- StringBuffer kblFSql= new StringBuffer(" select count(1) kbllf from t_infoclass where inprocess='2' and latestversion='1' ");
- if(!ToolUtil.isNull(deptids)) {
- kblFSql=new StringBuffer(" select count(1) kbllf from t_infoclass where inprocess='2' and latestversion='1' and instr(?,providebmcode)>0 ");
- kblFargs=new Object[1];
- kblFargs[0]=deptids;
- }
- Map map18 = jdbcTemplate.queryForMap(kblFSql.toString(), kblFargs);
- indicator.setKblC(((Long) map10.get("kblc")).intValue());
- indicator.setKblF(((Long) map18.get("kbllf")).intValue());
- Object[] mlshCargs = new Object[]{};
- StringBuffer mlshCSql= new StringBuffer(" select count(1) nook from V_HISTASKLIST_T p,t_infoclass q where p.taskname='主管部门审核' and q.latestversion='1' and p.busid=q.ID and p.taskmessage not like '审核通过%'");
- if(!ToolUtil.isNull(deptids)) {
- mlshCSql=new StringBuffer(" select count(1) nook from V_HISTASKLIST_T p,t_infoclass q where p.taskname='主管部门审核' and q.latestversion='1' and p.busid=q.ID and p.taskmessage not like '审核通过%' and instr(?,providebmcode)>0 ");
- mlshCargs=new Object[1];
- mlshCargs[0]=deptids;
- }
- Map map11 = jdbcTemplate.queryForMap(mlshCSql.toString(), mlshCargs);
-
- Object[] mlshFargs = new Object[]{};
- StringBuffer mlshFSql= new StringBuffer(" select count(1) oknum from t_infoclass q where q.latestversion='1' and inprocess='2'");
- if(!ToolUtil.isNull(deptids)) {
- mlshFSql=new StringBuffer(" select count(1) oknum from t_infoclass q where q.latestversion='1' and inprocess='2' and instr(?,providebmcode)>0 ");
- mlshFargs=new Object[1];
- mlshFargs[0]=deptids;
- }
- Map map12 = jdbcTemplate.queryForMap(mlshFSql.toString(), mlshFargs);
- indicator.setMlshC(((Long) map12.get("oknum")).intValue());
- indicator.setMlshF(((Long) map12.get("oknum")).intValue()+((Long) map11.get("nook")).intValue());
-
-
- Object[] gjshCargs = new Object[]{};
- StringBuffer gjshCSql= new StringBuffer("select count(1) nook from t_guajieopinion_list p where datatype='t_infoclass' and result!='审核通过' and p.dataid in (select id from t_infoclass where INPROCESS='2' )" +
- "");
- if(!ToolUtil.isNull(deptids)) {
- gjshCSql=new StringBuffer("select count(1) nook from t_guajieopinion_list p where datatype='t_infoclass' and result!='审核通过' and p.dataid in (select id from t_infoclass where INPROCESS='2' and instr(?,providebmcode)>0)" +
- " ");
- gjshCargs=new Object[1];
- gjshCargs[0]=deptids;
- }
- Map map13 = jdbcTemplate.queryForMap(gjshCSql.toString(), gjshCargs);
-
- Object[] gjshFargs = new Object[]{};
- StringBuffer gjshFSql= new StringBuffer(" select count(1) oknum from t_infoclass q where inprocess='2' and HITCH_STATUS=1");
- if(!ToolUtil.isNull(deptids)) {
- gjshFSql=new StringBuffer(" select count(1) oknum from t_infoclass q where inprocess='2' and HITCH_STATUS=1 and instr(?,providebmcode)>0 ");
- gjshFargs=new Object[1];
- gjshFargs[0]=deptids;
- }
- Map map14 = jdbcTemplate.queryForMap(gjshFSql.toString(), gjshFargs);
- indicator.setGjshC(((Long) map14.get("oknum")).intValue());
- indicator.setGjshF(((Long) map14.get("oknum")).intValue()+((Long) map13.get("nook")).intValue());
-
- Object[] kzlFargs = new Object[]{};
- StringBuffer kzlFSql= new StringBuffer("select sum(SUBSTRING_INDEX( p.nullvaluenum , '/', 1 ) ) nullnum,sum(SUBSTRING_INDEX(SUBSTRING_INDEX( p.nullvaluenum , '/', 2 ),'/',-1)) tt from rkrm_zl_probeinfo p, (select TABLEname,max(TCTIME) tctime from rkrm_zl_probeinfo group by TABLEname) q where p.TABLENAME=q.TABLENAME and p.TCTIME=q.tctime and " +
- " p.tablename in (select concat('t_',replace(infocode,'/','_')) pp from t_infoclass where inprocess='2' and latestversion='1' and HITCH_STATUS=1 " +
- " and sharemodetypename='数据库' ) and p.tablename in (select tablename from current_infoclass)");
- if(!ToolUtil.isNull(deptids)) {
- kzlFSql=new StringBuffer(" select sum(SUBSTRING_INDEX( p.nullvaluenum , '/', 1 ) ) nullnum,sum(SUBSTRING_INDEX(SUBSTRING_INDEX( p.nullvaluenum , '/', 2 ),'/',-1)) tt from rkrm_zl_probeinfo p, (select TABLEname,max(TCTIME) tctime from rkrm_zl_probeinfo group by TABLEname) q where p.TABLENAME=q.TABLENAME and p.TCTIME=q.tctime and " +
- " p.tablename in (select concat('t_',replace(infocode,'/','_')) pp from t_infoclass where inprocess='2' and latestversion='1' and HITCH_STATUS=1 " +
- " and sharemodetypename='数据库' and instr(?,providebmcode)>0 ) and p.tablename in (select tablename from current_infoclass)");
- kzlFargs=new Object[1];
- kzlFargs[0]=deptids;
- }
- Map map15 = jdbcTemplate.queryForMap(kzlFSql.toString(), kzlFargs);
- if(map15.get("nullnum")!=null) {
- indicator.setKzlC(((Double) map15.get("nullnum")));
- }
- else {
- indicator.setKzlC(0);
- }
- if(map15.get("tt")!=null) {
- indicator.setKzlF(((Double) map15.get("tt")));
- }
- else {
- indicator.setKzlF(0);
- }
-
-
-
- Object[] sjgxFargs = new Object[]{};
- StringBuffer sjgxFSql= new StringBuffer("select count(1) allnum from t_infoclass where inprocess='2' and latestversion='1' and HITCH_STATUS=1 and sharemodetypename='数据库' and concat('t_',replace(infocode,'/','_')) in (select tablename from current_infoclass) ");
- if(!ToolUtil.isNull(deptids)) {
- sjgxFSql=new StringBuffer(" select count(1) allnum from t_infoclass where inprocess='2' and latestversion='1' and HITCH_STATUS=1 and instr(?,providebmcode)>0 and sharemodetypename='数据库' and concat('t_',replace(infocode,'/','_')) in (select tablename from current_infoclass)");
- sjgxFargs=new Object[1];
- sjgxFargs[0]=deptids;
- }
- Map map16 = jdbcTemplate.queryForMap(sjgxFSql.toString(), sjgxFargs);
-
- Object[] sjgxCargs = new Object[]{};
- StringBuffer sjgxCSql= new StringBuffer("select count(1) allnum from t_infoclass where inprocess='2' and latestversion='1' and HITCH_STATUS=1 and sharemodetypename='数据库' and concat('t_',replace(infocode,'/','_')) in (select tablename from current_infoclass) and " +
- "concat('t_',replace(infocode,'/','_')) in (select p.table_name from update_rate p,(select table_name,max(insert_time) insert_time from update_rate GROUP BY table_name) q " +
- "where p.table_name=q.table_name and p.insert_time=q.insert_time and p.is_update='1') ");
- if(!ToolUtil.isNull(deptids)) {
- sjgxCSql=new StringBuffer(" select count(1) allnum from t_infoclass where inprocess='2' and latestversion='1' and concat('t_',replace(infocode,'/','_')) in (select tablename from current_infoclass) and HITCH_STATUS=1 and instr(?,providebmcode)>0 and sharemodetypename='数据库' and " +
- "concat('t_',replace(infocode,'/','_')) in (select p.table_name from update_rate p,(select table_name,max(insert_time) insert_time from update_rate GROUP BY table_name) q " +
- "where p.table_name=q.table_name and p.insert_time=q.insert_time and p.is_update='1')");
- sjgxCargs=new Object[1];
- sjgxCargs[0]=deptids;
- }
- Map map17 = jdbcTemplate.queryForMap(sjgxCSql.toString(), sjgxCargs);
-
- indicator.setSjgxC(((Long) map17.get("allnum")).intValue());
-
- indicator.setSjgxF(((Long) map16.get("allnum")).intValue());
-
- return indicator;
- }
- public Pagination<TinfoClassDto> findTinfoClassCsmlList(TinfoClassDto dto, Pagination<TinfoClassDto> pag,
- User userInfo) {
- StringBuffer sql=new StringBuffer("select * from t_infoclass t where latestversion='1' and exists (select * from t_systeminfo_infoclass p where p.infoclass_id=t.id and systeminfo_id=?) ");
- glmlList(sql,dto,pag);
- return pag;
- }
- public Pagination<TinfoClassDto> findTinfoClassQzmlList(TinfoClassDto dto, Pagination<TinfoClassDto> pag,
- User userInfo) {
- StringBuffer sql=new StringBuffer("select * from t_infoclass t where latestversion='1' and exists (select * from t_subres_infoclass p where p.infoclassid=t.id and subid=?) ");
- glmlList(sql,dto,pag);
- return pag;
- }
- private void glmlList(StringBuffer sql, TinfoClassDto dto, Pagination<TinfoClassDto> pag) {
- List<String> paramList=new ArrayList<String>();
- paramList.add(dto.getSysteminfo());
-
- if(!ToolUtil.isNull(dto.getInfoname())){
- sql.append(" and infoname like ? ");
- paramList.add("%"+dto.getInfoname()+"%");
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- sql.append(" and infotypename like ? ");
- paramList.add("%"+dto.getInfotypename()+"%");
- }
- if(!ToolUtil.isNull(dto.getSharetype())){
- sql.append(" and sharetype = ? ");
- paramList.add(dto.getSharetype());
- }
-
-
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- sql.append(" and providebmname like ? ");
- paramList.add("%"+dto.getProvidebmname()+"%");
- }
- if(!ToolUtil.isNull(dto.getTaskname())) {
- switch(dto.getTaskname()) {
- case "未提交": {sql.append(" and inprocess = ? ");
- paramList.add("0");}
- break;
- case "部门审核":{
- sql.append(" and inprocess = ? ");
- paramList.add("1");
- sql.append(" and taskname = ? ");
- paramList.add("部门审核");
- };break;
- case "主管部门审核":
- {
- sql.append(" and inprocess = ? ");
- paramList.add("1");
- sql.append(" and taskname = ? ");
- paramList.add("主管部门审核");
- }
- break;
- case "已发布":{
- sql.append(" and inprocess = ? ");
- paramList.add("2");
- }
- break;
- case "停用":{
- sql.append(" and inprocess = ? ");
- paramList.add("5");
- }break;
- case "编目人员修改":
- {
- sql.append(" and inprocess = ? ");
- paramList.add("1");
- sql.append(" and taskname = ? ");
- paramList.add("编目人员修改");
- }
- break;
- default:
- break;
- }
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- sql.append(" and infocode like ? ");
- paramList.add("%"+dto.getInfocode()+"%");
- }
- if(!ToolUtil.isNull(dto.getIsopensocial())){
- sql.append(" and isopensocial = ? ");
- paramList.add(dto.getIsopensocial());
- }
- if(dto.getHitchStatus()!=null){
- if("1".equals(dto.getHitchStatus()+""))
- sql.append(" and hitch_status =1 ");
- else {
- sql.append(" and (hitch_status =0 or hitch_status is null)");
- }
- }
- // 起始时间
- if (!ToolUtil.isNull(dto.getStartdate())) {
- sql.append(" and updatetime >= ? ");
- paramList.add(dto.getStartdate());
- }
- // 结束时间
- if (!ToolUtil.isNull(dto.getEnddate())) {
- sql.append(" and updatetime <= ? ");
- paramList.add(dto.getEnddate()+" 23:59:59");
- }
-
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
-
- pag = pag.findPagination(sql.toString(),pag,args,new RowMapper<TinfoClassDto>(){
- @Override
- public TinfoClassDto mapRow(ResultSet rs, int rowNum) throws SQLException {
- TinfoClassDto info = new TinfoClassDto();
- info.setInfocode(rs.getString("infocode"));
- info.setInfoname(rs.getString("infoname"));
- info.setInprocess(rs.getString("inprocess"));
- info.setId(rs.getString("id"));
- info.setTaskname(rs.getString("taskname"));
- info.setVersionid(Integer.parseInt(rs.getString("versionid")));
- info.setSubversionid(Integer.parseInt(rs.getString("subversionid")));
- info.setSourceid(rs.getString("sourceid"));
- info.setUpdatetime(rs.getString("updatetime"));
- info.setIsopensocial(rs.getString("isopensocial"));
- info.setInfotypename(rs.getString("infotypename"));
- info.setProvidebmname(rs.getString("providebmname"));
- info.setSharetype(rs.getString("sharetype"));
- info.setHitchStatus(Integer.parseInt(rs.getString("hitch_status")==null?"0":rs.getString("hitch_status")));
- return info;
- }
- },jdbcTemplate,database_type);
-
- }
- public void updateSceneInfoToYwtable() {
- List<Map<String,Object>> maplist = jdbcTemplate.queryForList("select GROUP_CONCAT(q.scene_name) scenename,GROUP_CONCAT(q.scene_code) scenecode,ywid from t_scene_relation p,t_scene_info q where p.ywtable='t_shareapply' and p.sceneid=q.sceneid and issyn is null GROUP BY ywid");
- for(Map map:maplist) {
- jdbcTemplate.update("update t_shareapply set scenename=?,scenecode=? where id=?", new Object[] {map.get("scenename"),map.get("scenecode"),map.get("ywid")});
- jdbcTemplate.update("update t_scene_relation p set p.issyn='1' where p.issyn is null and ywid=? and ywtable='t_shareapply'", new Object[] {map.get("ywid")});
-
- }
- List<Map<String,Object>> maplist2 = jdbcTemplate.queryForList("select GROUP_CONCAT(q.scene_name) scenename,GROUP_CONCAT(q.scene_code) scenecode,ywid from t_scene_relation p,t_scene_info q where p.ywtable='t_service_applyinfo' and p.sceneid=q.sceneid and issyn is null GROUP BY ywid");
- for(Map map:maplist2) {
- jdbcTemplate.update("update t_service_applyinfo set scenename=?,scenecode=? where applyid=?", new Object[] {map.get("scenename"),map.get("scenecode"),map.get("ywid")});
- jdbcTemplate.update("update t_scene_relation p set p.issyn='1' where p.issyn is null and ywid=? and ywtable='t_service_applyinfo'", new Object[] {map.get("ywid")});
- }
- jdbcTemplate.execute("insert into v_histasklist_t select * from v_histasklist p where not exists(select * from v_histasklist_t t where t.taskid=p.taskid)");
- }
- public Pagination<TshareApplyDto> findTshareApplyByClassid(Map<String, Object> dto, Pagination<TshareApplyDto> pag,
- User userInfo) {
- List<Order> orders = new ArrayList<Sort.Order>();
- Order order1 = new Order(Direction.ASC, "actualize");
- orders.add(order1);
- Order order = new Order(Direction.DESC, "applydate");
- Order order2 = new Order(Direction.DESC, "state");
- orders.add(order2);
- orders.add(order);
- Order order3 = new Order(Direction.ASC, "taskname");
-
- orders.add(order3);
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1, pag.getPageSize(), sort);
- Page<TshareApply> page;
- page = tshareApplyRepository.findAll(new Specification<TshareApply>() {
- @Override
- public Predicate toPredicate(Root<TshareApply> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
- List<Predicate> pl = new ArrayList<Predicate>();
-
- Join<TshareApply, TinfoClass> join = root.join("tinfoClass");
- pl.add(cb.isNotNull(join.get("id")));
- pl.add(cb.equal(join.get("id"), dto.get("classid")));
- pl.add(cb.or(cb.equal(root.get("state"),"0"),cb.equal(root.get("state"),"1"),cb.equal(root.get("state"),"2"),cb.equal(root.get("state"),"3")));
- if (dto.get("taskname")!=null&&!"".equals(dto.get("taskname"))) {
- pl.add((cb.equal(root.get("taskname"), dto.get("taskname"))));
- }
- // 申请部门
- if (dto.get("applydeptname")!=null&&!"".equals(dto.get("applydeptname"))) {
- pl.add((cb.like(root.<String>get("applydeptname"), "%" + dto.get("applydeptname") + "%")));
- }
- if (dto.get("shareserialno")!=null&&!"".equals(dto.get("shareserialno"))) {
- pl.add(cb.like(root.get("shareserialno"), "%" + dto.get("shareserialno") + "%"));
- }
- if (dto.get("state")!=null&&!"".equals(dto.get("state"))) {
- pl.add((cb.equal(root.get("state"), dto.get("state"))));
- }
- if (dto.get("scenecode")!=null&&!"".equals(dto.get("scenecode"))) {
- pl.add(cb.like(root.<String>get("scenecode"), "%" + dto.get("scenecode") + "%"));
- }
- if (dto.get("scenename")!=null&&!"".equals(dto.get("scenename"))) {
- pl.add(cb.like(root.<String>get("scenename"), "%" + dto.get("scenename") + "%"));
- }
- if (dto.get("actualize")!=null&&!"".equals(dto.get("actualize"))) {
- if ("1".equals(dto.get("actualize"))||"0".equals(dto.get("actualize"))) {
- pl.add((cb.equal(root.get("actualize"), dto.get("actualize"))));
- }
- else {
- pl.add(cb.or(cb.equal(root.get("actualize"), dto.get("actualize")),
- cb.isNull(root.get("actualize"))));
- }
- }
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TshareApply> dataList = page.getContent();
- List<TshareApplyDto> dtolist = new ArrayList<TshareApplyDto>();
- for (TshareApply u : dataList) {
- TshareApplyDto tshareApplyDto = new TshareApplyDto();
- BeanUtils.copyProperties(u, tshareApplyDto);
- dtolist.add(tshareApplyDto);
- }
- pag.setPageResult(dtolist);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public void updateTshareApplyKnowStateByClassId(String state,String parentid) {
- jdbcTemplate.update("update t_shareapply p set p.knowstate=? where p.tinfoclassid=? and p.state='2' ",new Object[] {state,parentid});
-
- }
- public TinfoClass findTinfoClassByPid(String tinfoClassinfoclassid) {
- TinfoClass info = tinfoClassRepository.findByPid(tinfoClassinfoclassid);
- if(info!=null){
- return info;
- }
-
- return null;
- }
- public Pagination<TserviceRegInfoDto> findserviceInfoByClassid(Map<String, Object> dto,
- Pagination<TserviceRegInfoDto> pag, User userInfo) {
- StringBuffer sql=new StringBuffer("select * from t_service_reginfo where inprocess!='4' ");
- List<String> paramList=new ArrayList<String>();
- if(dto.get("classid")!=null&&!"".equals(dto.get("classid"))){
- paramList.add(dto.get("classid")+"");
- sql.append(" and instr(classid,?)>0 ");
- }
- if(dto.get("cnname")!=null&&!"".equals(dto.get("cnname"))){
- paramList.add("%"+dto.get("cnname")+"%");
- sql.append(" and cnname like ? ");
- }
- if(dto.get("providename")!=null&&!"".equals(dto.get("providename"))){
- paramList.add("%"+dto.get("providename")+"%");
- sql.append(" and enname like ? ");
- }
-
- Object[] args = new Object[]{};
- int length = paramList.size();
- if(length>0){
- args=new Object[length];
- for(int i=0;i<length;i++){
- args[i] = paramList.get(i);
- }
-
- }
- pag = pag.findPagination(sql.toString(),pag,args,new BeanPropertyRowMapper<TserviceRegInfoDto>(TserviceRegInfoDto.class),jdbcTemplate,database_type);
- return pag;
- }
- public void updateClassIdOfServiceInfo(String id, String infoname, String id2, String infoname2) {
- // TODO Auto-generated method stub
- jdbcTemplate.update("update t_service_reginfo set classid=replace(classid,?,?),classname=replace(classname,?,?) where instr(classid,?)>0",new Object[] {
- id2+";",
- id+";",
- infoname2+";",
- infoname+";",
- id2+";"
- });
- }
- public IndicatorsDto findIndicatorsLastResultInfoByDeptid(String deptids) {
- IndicatorsDto dto =new IndicatorsDto();
- List<Indicators> list = indicatorsRepository.findIndicatorByDeptids(deptids);
- double ywfglC=0.0;// 业务覆盖率-分子
- double ywfglF=0.0;// 业务覆盖率-分母
-
- double yyfglC=0.0;// 应用覆盖率-分子
- double yyfglF=0.0;// 应用覆盖率-分母
-
- double qzgllC=0.0;// 权责关联率-分子
- double qzgllF=0.0;// 权责关联率-分母
- double xtgllC=0.0;// 系统关联率-分子
- double xtgllF=0.0;// 系统关联率-分母
-
- double gjlC=0.0;// 挂接率-分子
- double gjlF=0.0;// 挂接率-分母
-
- double kblC=0.0;// 库表率-分子
- double kblF=0.0;// 库表率-分母
-
- double sjgxC=0.0;// 数据更新率率-分子
- double sjgxF=0.0;// 数据更新率率-分母
- double kzlC=0.0;// 空值率-分子
- double kzlF=0.0;// 空值率-分母
- double mlshC=0.0;// 目录审核通过率-分子
- double mlshF=0.0;// 目录审核通过率-分母
- double gjshC=0.0;// 挂接审核通过率-分子
- double gjshF=0.0;// 挂接审核通过率-分母
- for(Indicators info:list) {
- ywfglC+=info.getYwfglC();// 业务覆盖率-分子
- ywfglF+=info.getYwfglF();// 业务覆盖率-分母
-
- yyfglC+=info.getYyfglC();// 应用覆盖率-分子
- yyfglF+=info.getYyfglF();// 应用覆盖率-分母
-
- qzgllC+=info.getQzgllC();// 权责关联率-分子
- qzgllF+=info.getQzgllF();// 权责关联率-分母
- xtgllC+=info.getXtgllC();// 系统关联率-分子
- xtgllF+=info.getXtgllF();// 系统关联率-分母
-
- gjlC+=info.getGjlC();// 挂接率-分子
- gjlF+=info.getGjlF();// 挂接率-分母
-
- kblC+=info.getKblC();// 库表率-分子
- kblF+=info.getKblF();// 库表率-分母
-
- sjgxC+=info.getSjgxC();// 数据更新率率-分子
- sjgxF+=info.getSjgxF();// 数据更新率率-分母
- kzlC+=info.getKzlC();// 空值率-分子
- kzlF+=info.getKzlF();// 空值率-分母
- mlshC+=info.getMlshC();// 目录审核通过率-分子
- mlshF+=info.getMlshF();// 目录审核通过率-分母
- gjshC+=info.getGjshC();// 挂接审核通过率-分子
- gjshF+=info.getGjshF();// 挂接审核通过率-分母
- }
- dto.setYwfglC(ywfglC);// 业务覆盖率-分子
- dto.setYwfglF(ywfglF);// 业务覆盖率-分母
-
- dto.setYyfglC(yyfglC);// 应用覆盖率-分子
- dto.setYyfglF(yyfglF);// 应用覆盖率-分母
-
- dto.setQzgllC(qzgllC);// 权责关联率-分子
- dto.setQzgllF(qzgllF);// 权责关联率-分母
- dto.setXtgllC(xtgllC);// 系统关联率-分子
- dto.setXtgllF(xtgllF);// 系统关联率-分母
-
- dto.setGjlC(gjlC);// 挂接率-分子
- dto.setGjlF(gjlF);// 挂接率-分母
-
- dto.setKblC(kblC);// 库表率-分子
- dto.setKblF(kblF);// 库表率-分母
-
- dto.setSjgxC(sjgxC);// 数据更新率率-分子
- dto.setSjgxF(sjgxF);// 数据更新率率-分母
- dto.setKzlC(kzlC);// 空值率-分子
- dto.setKzlF(kzlF);// 空值率-分母
- dto.setMlshC(mlshC);// 目录审核通过率-分子
- dto.setMlshF(mlshF);// 目录审核通过率-分母
- dto.setGjshC(gjshC);// 挂接审核通过率-分子
- dto.setGjshF(gjshF);// 挂接审核通过率-分母
- return dto;
- }
- public void indicatorJob() {
- List<String> list = jdbcTemplate.queryForList("select dept_id from deptinfo ", String.class);
- IndicatorsDto indicator =new IndicatorsDto();
- Indicators info =new Indicators();
- indicatorsRepository.updateIndicatorsDisable();
- String insertdate = ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss") ;
- List<Future<List<String>>> futureList = new ArrayList<Future<List<String>>>();
- /**集合总条数**/
- int size = list.size();
- /**将集合切分的段数**/
- int sunSum = 20;
- int listStart,listEnd;
- /***当总条数不足10条时 用总条数 当做线程切分值**/
- if(sunSum > size){
- sunSum = size;
- }
- /**定义子线程**/
- SunIndicatorCallable sunCallable;
- for (int i = 0; i < sunSum; i++) {
- /***计算切割 开始和结束**/
- listStart = size / sunSum * i ;
- listEnd = size / sunSum * ( i + 1 );
- /**最后一段线程会 出现与其他线程不等的情况**/
- if(i == sunSum - 1){
- listEnd = size;
- }
- /**线程切断**/
- List<String> sunList = list.subList(listStart,listEnd);
- /**子线程初始化**/
- sunCallable = new SunIndicatorCallable(sunList,i);
- /***多线程执行***/
- futureList.add(threadPoolTaskExecutor.submit(sunCallable));
- }
- // for(String map:list) {
- //
- // indicator =findIndicatorsInfoByDeptid(map+"");
- // indicator.setYwfglValue(ywfglValue);
- // indicator.setYyfglValue(yyfglValue);
- // indicator.setQzgllValue(qzgllValue);
- // indicator.setXtgllValue(xtgllValue);
- // indicator.setGjlValue(gjlValue);
- // indicator.setKblValue(kblValue);
- // indicator.setSjgxValue(sjgxValue);
- // indicator.setMlshValue(mlshValue);
- // indicator.setGjshValue(gjshValue);
- // BeanUtils.copyProperties(indicator, info);
- // info.setDeptid(map+"");
- // info.setInsertdate(insertdate);
- // info.setId(ToolUtil.getUUID());
- // info.setState("1");
- // indicatorsRepository.save(info);
- // }
-
- }
-
- public Pagination<TinfoClassDto> findTinfoClassHitchImplementList(final TinfoClassDto dto,
- Pagination<TinfoClassDto> pag,final User userInfo) {
- List<Order> orders = new ArrayList<Sort.Order>();
- Order order = new Order(Direction.ASC, "implementationState");
- Order order1 = new Order(Direction.DESC, "id");
- orders.add(order);
- orders.add(order1);
- Sort sort = new Sort(orders);
- PageRequest request = new PageRequest(pag.getPageCurrentNum() - 1,
- pag.getPageSize(), sort);
- Page<TinfoClass> page;
- page = tinfoClassRepository.findAll(new Specification<TinfoClass>() {
- @Override
- public Predicate toPredicate(Root<TinfoClass> root,
- CriteriaQuery<?> query, CriteriaBuilder cb) {
- Set<Role> serRole = userInfo.getRoles();
- boolean flag = false;
- for (Role role : serRole) {
- if(admin_id.equals(role.getRoleId()))
- flag = true;
- }
- List<Predicate> pl = new ArrayList<Predicate>();
- pl.add(cb.equal(root.get("latestversion"), "1"));
- pl.add(cb.equal(root.get("inprocess"), "2"));
-
- //挂接情况状态 1是已挂接 0未挂接
- pl.add(cb.equal(root.get("hitchStatus"), "1"));
- if(!ToolUtil.isNull(dto.getInfoname())){
- pl.add(cb.like(root.<String>get("infoname"), "%"+dto.getInfoname()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfotypename())){
- pl.add(cb.like(root.<String>get("infotypename"), "%"+dto.getInfotypename()+"%"));
- }
- if(!ToolUtil.isNull(dto.getInfocode())){
- pl.add(cb.like(root.<String>get("infocode"), "%"+dto.getInfocode()+"%"));
- }
- if(!ToolUtil.isNull(dto.getProvidebmname())){
- pl.add(cb.like(root.<String>get("providebmname"), "%"+dto.getProvidebmname()+"%"));
- }
- //实施起始时间
- if (!ToolUtil.isNull(dto.getStartdate())) {
- pl.add(cb.greaterThanOrEqualTo(root.<String> get("implementationData"),dto.getStartdate()));
- }
- //实施结束时间
- if (!ToolUtil.isNull(dto.getEnddate())) {
- pl.add(cb.lessThanOrEqualTo(root.<String> get("implementationData"), dto.getEnddate()+" 23:59:59"));
- }
- //实施状态:0-未实施 1-已实施
- if(!ToolUtil.isNull(dto.getImplementationState())){
- if("1".equals(dto.getImplementationState())) {
- pl.add(cb.equal(root.get("implementationState"), dto.getImplementationState()));
- }else {
- pl.add(cb.or(cb.equal(root.get("implementationState"),dto.getImplementationState()),cb.isNull(root.get("implementationState"))));
- }
-
- }
- return cb.and(pl.toArray(new Predicate[0]));
- }
- }, request);
- List<TinfoClass> dataList = page.getContent();
- List<TinfoClassDto> dtolsit = new ArrayList<TinfoClassDto>();
- for (TinfoClass u : dataList) {
- dtolsit.add(new TinfoClassDto(u));
- }
- pag.setPageResult(dtolsit);
- pag.setPageCount(page.getTotalPages());
- pag.setPageTotal((int) page.getTotalElements());
- return pag;
- }
- public List<TinfoClass> findListByInfonameAndProviceBmcode(String infoname, String providebmcode) {
- // TODO Auto-generated method stub
- return tinfoClassRepository.findListByInfonameAndProviceBmcode(infoname,providebmcode);
- }
- public String checkInfoValid(TinfoClass info) {
- String resultTip = "";
- info.setCreatedate(ToolUtil.date2Str(new Date(), "yyyy-MM-dd HH:mm:ss"));
- info.setVersionid(1);
- info.setHitchStatus(0);
- info.setLatestversion("1");// 默认最新版本
- info.setInprocess("2");// 未启动流程
- info.setBgstatus("1");// 未变更
- if(!ToolUtil.isNull(info.getInfotypeid())){
- TresClassify res = tresClassifyService.findTresClassifyById(info.getInfotypeid());
- if(res!=null&&!ToolUtil.isNull(res.getResid())){
- info.setInfotype(res.getRescode());
- info.setInfotypename(res.getResname());
- info.setInfotypeid(res.getResid());
- }
- else{
- resultTip +="infotypeid参数对应的资源分类不存在;";
- }
- }
- else{
- resultTip +="infotypeid参数值不能为空;";
- }
- if(!ToolUtil.isNull(info.getProvidebmcode())){
- Dept dept = deptService.findDeptInfoById(info.getProvidebmcode());
- if(dept!=null&&!ToolUtil.isNull(dept.getDeptId())){
- info.setProvidebmcode(dept.getDeptId());
- info.setProvidebmname(dept.getDeptName());
- if(!ToolUtil.isNull(dept.getCreditno())){
- info.setCreditno(dept.getCreditno());
-
- }
- else{
- resultTip +="providebmcode参数对应的部门未维护统一社会信用代码信息;";
- }
- if(!ToolUtil.isNull(dept.getYwbmid())){
- info.setYwbmcode(dept.getYwbmcode());
- info.setYwbmid(dept.getYwbmid());
- info.setYwbmname(dept.getYwbmname());
- }else{
- resultTip +="providebmcode参数对应的部门未维护业务部门信息;";
- }
- if(!ToolUtil.isNull(dept.getXzqhcode())){
- info.setXzqhcode(dept.getXzqhcode());
- info.setXzqhid(dept.getXzqhid());
- info.setXzqhname(dept.getXzqhname());
- }
- else{
- resultTip +="providebmcode参数对应的部门未维护行政区划信息;";
- }
-
-
- }
- else{
- resultTip +="providebmcode参数对应的部门信息不存在;";
- }
- }
- else{
- resultTip +="providebmcode参数值不能为空;";
- }
-
- if (ToolUtil.isNull(info.getInfoname())) {
- resultTip += "infoname不能为空;";
- }
- if (!ToolUtil.isNull(info.getInfoname()) && info.getInfoname().length() > 200) {
- resultTip += "infoname长度不能超过200字符;";
- }
- if (!ToolUtil.isNull(info.getSharerange()) ) {
- if(!"全市,市本级,其他".contains(info.getSharerange()))
- resultTip += "sharerange字典值错误;";
- }
- else{
- resultTip+= "sharerange不能为空;";
- }
- if (ToolUtil.isNull(info.getFormattypename())) {
- resultTip += "formattypename不能为空;";
- } else {
- for (CodeDto code : dbdcCodeService.findCodeByCodeType("xxzygs")) {
- if (code != null && code.getId() != null && info.getFormattypename().equals(code.getCodeName())) {
- info.setFormattype(code.getCodeCode());
- info.setFormattypeid(code.getId());
- }
- }
- if (ToolUtil.isNull(info.getFormattypeid())) {
- resultTip += "formattypename字典值错误;";
- }
- }
- // 信息资源格式分类,要校验 格式与分类是否对应
- if (ToolUtil.isNull(info.getSubformattypename())) {
- resultTip += "subformattypename不能为空;";
- } else {
- for (CodeDto code : dbdcCodeService.findCodeByCodeType(info.getFormattype())) {
- if (code != null && code.getId() != null
- && info.getSubformattypename().equals(code.getCodeName())) {
- info.setSubformattype(code.getCodeCode());
- info.setSubformattypeid(code.getId());
- }
- }
- if (ToolUtil.isNull(info.getSubformattypeid())) {
- resultTip += "formattypename与subformattypename不匹配;";
- }
- }
- // 信息类摘要 校验长度
- if (!ToolUtil.isNull(info.getInfoabstracts()) && info.getInfoabstracts().length() > 400) {
- resultTip += "infoabstracts不能超过400字符;";
- } else if (ToolUtil.isNull(info.getInfoabstracts())) {
- resultTip += "infoabstracts不能为空;";
- }
- // 共享类型 校验数据格式
- if (ToolUtil.isNull(info.getSharetype())) {
- resultTip += "sharetype不能为空;";
- } else {
- if ("123".contains(info.getSharetype())) {
- info.setSharetype(info.getSharetype());
- } else {
- resultTip += "sharetype字典值错误;";
- }
- }
- // 是否向社会开放 校验数据格式 是否
- if (ToolUtil.isNull(info.getIsopensocial())) {
- resultTip += "isopensocial不能为空;";
- } else {
- if (!"不予开放,有条件开放,无条件开放".contains(info.getIsopensocial())) {
- resultTip += "isopensocial字典值错误;";
- }
- }
- // 共享条件 校验长度
- if("2".equals(info.getSharetype())) {
- info.setShareconditions("");
- }
- else {
- if (!ToolUtil.isNull(info.getShareconditions()) && info.getShareconditions().length() > 400) {
- resultTip += "shareconditions不能超过400字符;";
- }
- else if(ToolUtil.isNull(info.getShareconditions())){
- resultTip += "shareconditions不能为空;";
- }
- }
- if("无条件开放".equals(info.getIsopensocial())) {
- info.setOpencondition("");
- }
- else {
- //开放条件 校验长度
- if (!ToolUtil.isNull(info.getOpencondition()) && info.getOpencondition().length() > 400) {
- resultTip += "opencondition不能超过400字符;";
- }
- if (ToolUtil.isNull(info.getOpencondition()) ) {
- resultTip += "opencondition不能为空;";
- }
- }
-
- // 更新频率 校验数据格式
- if (ToolUtil.isNull(info.getUpdatecycle())) {
- resultTip += "updatecycle不能为空;";
- }
- // 数据范围 校验长度
- if (!ToolUtil.isNull(info.getDatarange()) && info.getDatarange().length() > 400) {
- resultTip += "datarange不能超过400字符;";
- }
- // 共享方式 校验数据格式
- if (ToolUtil.isNull(info.getSharemodename())) {
- resultTip += "sharemodename不能为空;";
- } else {
- for (CodeDto code : dbdcCodeService.findCodeByCodeType("gxfs")) {
- if (code != null && code.getId() != null && info.getSharemodename().equals(code.getCodeName())) {
- info.setSharemode(code.getCodeCode());
- info.setSharemodeid(code.getId());
- }
- }
- if (ToolUtil.isNull(info.getSharemodeid())) {
- resultTip += "sharemodename字典值错误;";
- }
- }
- // 共享方式分类
- if (ToolUtil.isNull(info.getSharemodetypename())) {
- resultTip += "sharemodetypename不能为空;";
- } else {
- for (CodeDto code : dbdcCodeService.findCodeByCodeType(info.getSharemode())) {
- if (code != null && code.getId() != null
- && info.getSharemodetypename().equals(code.getCodeName())) {
- info.setSharemodetype(code.getCodeCode());
- info.setSharemodetypeid(code.getId());
- }
- }
- if (ToolUtil.isNull(info.getSharemodetypeid())) {
- resultTip += "sharemodetypename与sharemodename不匹配;";
- }
- }
-
- // 是否加密
- if (ToolUtil.isNull(info.getManagetype())) {
- resultTip += "managetype不能为空;";
- } else {
- if (!"是,否".contains(info.getManagetype())) {
- resultTip += "managetype字典值错误;";
- }
- }
- if(ToolUtil.isNull(resultTip)){
- // 开始校验信息项目
- List<TinfoclassDatameta> datalist = new ArrayList<TinfoclassDatameta>();
- int j=0;
- for (TinfoclassDatameta data : info.getTinfoclassDatametaList()) {
- j=j+1;
- if (data.getXxxmc() != null) {
- // 信息项名称 长度
- if (data.getXxxmc().length() > 200) {
- resultTip += data.getXxxmc()+":信息项的信息项名称不能超过200字符;";
- }
- // 是否主键
- if (ToolUtil.isNull(data.getIsprimary())) {
- resultTip += data.getXxxmc()+":信息项的isprimary必填;";
- } else if (!"是否".contains(data.getIsprimary())) {
- resultTip += data.getXxxmc()+":信息项的isprimary字典值错误;";
- }
- // 数据元编码 看是否存在对应数据元
- if (ToolUtil.isNull(data.getGlsjy())) {
- data.setGlsjy("否");
- } else {
- List<TdataMeta> metalist = datametaService.findTdataMetaByDatacode(data.getGlsjy());
- if (metalist != null && metalist.size() > 0) {
- data.setGlsjy("是");
- data.setDatametaid(metalist.get(0).getId());
- data.setMetacodeid(metalist.get(0).getMetacodeid());
- data.setMetacodeDis(metalist.get(0).getMetacodeDis());
- data.setMetacode(metalist.get(0).getMetacode());
- data.setDatatypeid(metalist.get(0).getDatatypeid());
- data.setDatatypeDis(metalist.get(0).getDatatypeDis());
- data.setDatatype(metalist.get(0).getDatatype());
- data.setDatasize(metalist.get(0).getDatasize());
- } else {
- resultTip += data.getXxxmc()+":glsjy未在已发布的数据元中找到相对应的数据元编码,请填写已发布数据元编码或者留空;";
- }
- }
- if ("否".equals(data.getGlsjy())) {
- // 数据元名称
- if (!ToolUtil.isNull(data.getMetaname()) && data.getMetaname().length() > 200) {
- resultTip += data.getXxxmc()+":信息项的metaname不超过200字符;";
- }
- // 数据元类别
- String metacodetype = "";
- if (ToolUtil.isNull(data.getMetacode())) {
- resultTip += data.getXxxmc()+":信息项,metacode数据元类别不能为空;";
- } else {
- for (CodeDto code : dbdcCodeService.findCodeByCodeType("sjylb")) {
- if (code != null && code.getId() != null
- && data.getMetacode().split("-")[0].equals(code.getCodeValue())) {
- data.setMetacodeid(code.getId());
- data.setMetacodeDis(code.getCodeName());
- data.setMetacode(code.getCodeValue());
- metacodetype = code.getCodeCode();
- }
- }
- if (ToolUtil.isNull(data.getMetacodeid())) {
- resultTip += data.getXxxmc()+":信息项,metacode数据元类别字典值错误;";
- }
- }
- // 数据元类型
- if (ToolUtil.isNull(data.getDatatype())) {
- resultTip += data.getXxxmc()+":信息项,datatype数据元类型不能为空;";
- } else {
- for (CodeDto code : dbdcCodeService.findCodeByCodeType(metacodetype)) {
- if (code != null && code.getId() != null
- && data.getDatatype().split("-")[0].equals(code.getCodeValue())) {
- data.setDatatypeid(code.getId());
- data.setDatatypeDis(code.getCodeName());
- data.setDatatype(code.getCodeValue());
- }
- }
- if (ToolUtil.isNull(data.getDatatypeid())) {
- resultTip += data.getXxxmc()+":信息项,datatype数据元类型与Metacode数据元类别不匹配;";
- }
- }
- // 信息项数据长度
- if (ToolUtil.isNull(data.getDatasize())
- && !"sjylb_dwblx,sjylb_qtlx,sjylb_tpx,sjylb_rqx".contains(data.getMetacode())) {
- resultTip += data.getXxxmc()+":信息项,datasize数据长度不能为空;";
- } else if (data.getDatasize().length() > 200) {
- resultTip += data.getXxxmc()+":信息项,datasize数据长度不超过200字符;";
- }
- }
- data.setIndexnum(j);
- data.setTinfoClass1(info);
- data.setId(ToolUtil.getUUID());
- datalist.add(data);
- }
- }
- if(datalist!=null&&datalist.size()>0){
- info.setTinfoclassDatametaList(datalist);}
- else{
- resultTip += "未维护信息项信息,tinfoclassDatametaList信息为空;";
- }
-
-
- }
-
-
-
- return resultTip;
- }
-
- }
|